|
@@ -48,7 +48,7 @@ class IncomingThread {
|
|
|
}
|
|
|
|
|
|
private func process(message: TMessage) {
|
|
|
- //print("incoming process", message.toLogString())
|
|
|
+ //print(("incoming process", message.toLogString())
|
|
|
if message.getCode() == CoreMessage_TMessageCode.LOGIN_FILE {
|
|
|
loginFile(message: message)
|
|
|
} else if message.getCode() == CoreMessage_TMessageCode.PUSH_MYSELF || message.getCode() == CoreMessage_TMessageCode.PUSH_MYSELF_ACK || message.getCode() == CoreMessage_TMessageCode.PULL_MYSELF {
|
|
@@ -172,7 +172,7 @@ class IncomingThread {
|
|
|
} else if message.getCode() == CoreMessage_TMessageCode.GET_BATCH_GROUP_NO_MEMBERS {
|
|
|
pushGroupNoMembers(message: message)
|
|
|
} else {
|
|
|
- //print("unprocessed code", message.getCode())
|
|
|
+ //print(("unprocessed code", message.getCode())
|
|
|
ack(message: message)
|
|
|
}
|
|
|
// case (CoreMessage_TMessageCode.FORM_PUSH_UPDATE):
|
|
@@ -211,7 +211,7 @@ class IncomingThread {
|
|
|
ack(message: message)
|
|
|
} catch {
|
|
|
rollback.pointee = true
|
|
|
- print(error)
|
|
|
+ //print(error)
|
|
|
}
|
|
|
})
|
|
|
}
|
|
@@ -290,7 +290,7 @@ class IncomingThread {
|
|
|
if type == "wb" {
|
|
|
switch (Int(status)) {
|
|
|
case CoreMessage_TMessageCode.WB_INCOMING:
|
|
|
- //print("WB_INCOMING")
|
|
|
+ //print(("WB_INCOMING")
|
|
|
DispatchQueue.main.async {
|
|
|
let controller = AppStoryBoard.Palio.instance.instantiateViewController(identifier: "wbVC") as! WhiteboardViewController
|
|
|
controller.modalPresentationStyle = .overFullScreen
|
|
@@ -303,7 +303,7 @@ class IncomingThread {
|
|
|
}
|
|
|
}
|
|
|
default:
|
|
|
- //print("default")
|
|
|
+ //print(("default")
|
|
|
var dataMessage: [AnyHashable : Any] = [:]
|
|
|
dataMessage["message"] = message
|
|
|
NotificationCenter.default.post(name: NSNotification.Name(rawValue: "wbSession"), object: nil, userInfo: dataMessage)
|
|
@@ -311,7 +311,7 @@ class IncomingThread {
|
|
|
} else if type == "ss"{
|
|
|
switch (Int(status)) {
|
|
|
case CoreMessage_TMessageCode.SS_INCOMING:
|
|
|
- //print("SS_INCOMING")
|
|
|
+ //print(("SS_INCOMING")
|
|
|
DispatchQueue.main.async {
|
|
|
let controller = ScreenSharingViewController()
|
|
|
controller.modalPresentationStyle = .overFullScreen
|
|
@@ -324,7 +324,7 @@ class IncomingThread {
|
|
|
}
|
|
|
}
|
|
|
default:
|
|
|
- //print("default")
|
|
|
+ //print(("default")
|
|
|
var dataMessage: [AnyHashable : Any] = [:]
|
|
|
dataMessage["message"] = message
|
|
|
NotificationCenter.default.post(name: NSNotification.Name(rawValue: "ssSession"), object: nil, userInfo: dataMessage)
|
|
@@ -465,11 +465,11 @@ class IncomingThread {
|
|
|
if err_code == "00" {
|
|
|
self.updateInquiry(messageId: message_id)
|
|
|
} else {
|
|
|
- //print("MASUK MINQ SEND CHAT")
|
|
|
+ //print(("MASUK MINQ SEND CHAT")
|
|
|
Database.shared.database?.inTransaction({ (fmdb, rollback) in
|
|
|
if let cursor = Database.shared.getRecords(fmdb: fmdb, query: "select message from INQUIRY where id = '\(message_id)'"), cursor.next() {
|
|
|
if let message = cursor.string(forColumnIndex: 0) {
|
|
|
- //print("MASUK MINQ ADA MESSAGE")
|
|
|
+ //print(("MASUK MINQ ADA MESSAGE")
|
|
|
OutgoingThread.default.addQueue(message: TMessage(data: message))
|
|
|
if message_scope != "3" {
|
|
|
DispatchQueue.main.async {
|
|
@@ -484,7 +484,7 @@ class IncomingThread {
|
|
|
}
|
|
|
|
|
|
private func updateInquiry(messageId: String) {
|
|
|
- //print("UPDATE INQUIRY")
|
|
|
+ //print(("UPDATE INQUIRY")
|
|
|
Database.shared.database?.inTransaction({ (fmdb, rollback) in
|
|
|
_ = Database.shared.updateRecord(fmdb: fmdb, table: "INQUIRY", cvalues: [
|
|
|
"status" : "1"
|
|
@@ -555,7 +555,7 @@ class IncomingThread {
|
|
|
}
|
|
|
|
|
|
private func sendUpdateTyping(message: TMessage) -> Void {
|
|
|
- //print("update typing \(message)")
|
|
|
+ //print(("update typing \(message)")
|
|
|
if let delegate = Nexilis.shared.messageDelegate {
|
|
|
delegate.onTyping(message: message)
|
|
|
}
|
|
@@ -606,7 +606,7 @@ class IncomingThread {
|
|
|
var data = Data(media)
|
|
|
|
|
|
if !key_filename.isEmpty, data.count == 0, let download = Nexilis.getDownload(forKey: key_filename) {
|
|
|
- //print("corrupted...", key_filename)
|
|
|
+ //print(("corrupted...", key_filename)
|
|
|
if let delegate = download.delegate {
|
|
|
delegate.onDownloadProgress(fileName: key_filename, progress: -1)
|
|
|
} else if let completion = download.onDownloadProgress {
|
|
@@ -635,7 +635,7 @@ class IncomingThread {
|
|
|
do {
|
|
|
let documentDir = try FileManager.default.url(for: .documentDirectory, in: .userDomainMask, appropriateFor: nil, create: true)
|
|
|
let url = documentDir.appendingPathComponent(key_filename)
|
|
|
- //print("write file \(url.path)")
|
|
|
+ //print(("write file \(url.path)")
|
|
|
try data.write(to: url, options: .atomic)
|
|
|
if let download = Nexilis.getDownload(forKey: key_filename) {
|
|
|
if let delegate = download.delegate {
|
|
@@ -645,7 +645,7 @@ class IncomingThread {
|
|
|
}
|
|
|
}
|
|
|
} catch {
|
|
|
- print(error)
|
|
|
+ //print(error)
|
|
|
if let download = Nexilis.getDownload(forKey: key_filename) {
|
|
|
if let delegate = download.delegate {
|
|
|
delegate.onDownloadProgress(fileName: key_filename, progress: -1)
|
|
@@ -703,7 +703,7 @@ class IncomingThread {
|
|
|
ack(message: message)
|
|
|
} catch {
|
|
|
rollback.pointee = true
|
|
|
- print(error)
|
|
|
+ //print(error)
|
|
|
}
|
|
|
})
|
|
|
}
|
|
@@ -855,7 +855,7 @@ class IncomingThread {
|
|
|
ack(message: message)
|
|
|
} catch {
|
|
|
rollback.pointee = true
|
|
|
- print(error)
|
|
|
+ //print(error)
|
|
|
}
|
|
|
})
|
|
|
}
|
|
@@ -894,7 +894,7 @@ class IncomingThread {
|
|
|
}
|
|
|
} catch {
|
|
|
rollback.pointee = true
|
|
|
- print(error)
|
|
|
+ //print(error)
|
|
|
}
|
|
|
})
|
|
|
}
|
|
@@ -937,7 +937,7 @@ class IncomingThread {
|
|
|
ack(message: message)
|
|
|
} catch {
|
|
|
rollback.pointee = true
|
|
|
- print(error)
|
|
|
+ //print(error)
|
|
|
}
|
|
|
})
|
|
|
}
|
|
@@ -974,7 +974,7 @@ class IncomingThread {
|
|
|
}
|
|
|
} catch {
|
|
|
rollback.pointee = true
|
|
|
- print(error)
|
|
|
+ //print(error)
|
|
|
}
|
|
|
})
|
|
|
}
|
|
@@ -1013,7 +1013,7 @@ class IncomingThread {
|
|
|
ack(message: message)
|
|
|
} catch {
|
|
|
rollback.pointee = true
|
|
|
- print(error)
|
|
|
+ //print(error)
|
|
|
}
|
|
|
})
|
|
|
}
|
|
@@ -1047,7 +1047,7 @@ class IncomingThread {
|
|
|
}
|
|
|
} catch {
|
|
|
rollback.pointee = true
|
|
|
- print(error)
|
|
|
+ //print(error)
|
|
|
}
|
|
|
})
|
|
|
}
|
|
@@ -1056,7 +1056,7 @@ class IncomingThread {
|
|
|
private func receiveMessage(message: TMessage) -> Void {
|
|
|
let message_id = message.getBody(key: CoreMessage_TMessageKey.MESSAGE_ID)
|
|
|
guard let _ = UserDefaults.standard.string(forKey: "status") else {
|
|
|
- //print("App not ready!!! skip receive message \(message_id)")
|
|
|
+ //print(("App not ready!!! skip receive message \(message_id)")
|
|
|
ack(message: message)
|
|
|
return
|
|
|
}
|
|
@@ -1068,14 +1068,14 @@ class IncomingThread {
|
|
|
}
|
|
|
})
|
|
|
let media = message.getMedia()
|
|
|
- //print("MEDIA \(media)");
|
|
|
+ //print(("MEDIA \(media)");
|
|
|
let thumb_id = message.getBody(key: CoreMessage_TMessageKey.THUMB_ID)
|
|
|
if media.count > 0 {
|
|
|
do {
|
|
|
let data = Data(media)
|
|
|
let documentDir = try FileManager.default.url(for: .documentDirectory, in: .userDomainMask, appropriateFor: nil, create: true)
|
|
|
let url = documentDir.appendingPathComponent(thumb_id)
|
|
|
- //print("write thumb \(url.path)")
|
|
|
+ //print(("write thumb \(url.path)")
|
|
|
try data.write(to: url, options: .atomic)
|
|
|
// let image = UIImage(data: data)
|
|
|
// let save = UserDefaults.standard.bool(forKey: "saveToGallery")
|
|
@@ -1083,7 +1083,7 @@ class IncomingThread {
|
|
|
// UIImageWriteToSavedPhotosAlbum(image!, nil, nil, nil)
|
|
|
// }
|
|
|
} catch {
|
|
|
- print(error)
|
|
|
+ //print(error)
|
|
|
}
|
|
|
}
|
|
|
if (!thumb_id.isEmpty) {
|
|
@@ -1091,21 +1091,21 @@ class IncomingThread {
|
|
|
print ("masuk download \(progress)")
|
|
|
if(progress == 100) {
|
|
|
Nexilis.saveMessage(message: message, withStatus: false)
|
|
|
- //print("save message incoming")
|
|
|
+ //print(("save message incoming")
|
|
|
}
|
|
|
}
|
|
|
ack(message: message)
|
|
|
return
|
|
|
}
|
|
|
Nexilis.saveMessage(message: message, withStatus: false)
|
|
|
- //print("save message incoming")
|
|
|
+ //print(("save message incoming")
|
|
|
ack(message: message)
|
|
|
}
|
|
|
|
|
|
private func receiveMessageStatus(message: TMessage) -> Void {
|
|
|
let message_id = message.getBody(key: CoreMessage_TMessageKey.MESSAGE_ID)
|
|
|
guard let _ = UserDefaults.standard.string(forKey: "status") else {
|
|
|
- //print("App not ready!!! skip receive message \(message_id)")
|
|
|
+ //print(("App not ready!!! skip receive message \(message_id)")
|
|
|
return
|
|
|
}
|
|
|
Nexilis.updateMessageStatus(message: message)
|
|
@@ -1217,7 +1217,7 @@ class IncomingThread {
|
|
|
ack(message: message)
|
|
|
} catch {
|
|
|
rollback.pointee = true
|
|
|
- print(error)
|
|
|
+ //print(error)
|
|
|
}
|
|
|
})
|
|
|
}
|
|
@@ -1234,7 +1234,7 @@ class IncomingThread {
|
|
|
_ = Database.shared.deleteRecord(fmdb: fmdb, table: "MESSAGE_SUMMARY", _where: "l_pin='\(l_pin)'")
|
|
|
_ = Database.shared.deleteRecord(fmdb: fmdb, table: "POST", _where: "author_f_pin='\(l_pin)'")
|
|
|
cursor.close()
|
|
|
- //print("Buddy deleted: \(l_pin)")
|
|
|
+ //print(("Buddy deleted: \(l_pin)")
|
|
|
if let delegate = Nexilis.shared.personInfoDelegate {
|
|
|
delegate.onUpdatePersonInfo(state: 99, message: "delete_buddy,\(l_pin)")
|
|
|
}
|
|
@@ -1378,7 +1378,7 @@ class IncomingThread {
|
|
|
}
|
|
|
} catch {
|
|
|
rollback.pointee = true
|
|
|
- print(error)
|
|
|
+ //print(error)
|
|
|
}
|
|
|
})
|
|
|
}
|
|
@@ -1432,7 +1432,7 @@ class IncomingThread {
|
|
|
ack(message: message)
|
|
|
} catch {
|
|
|
rollback.pointee = true
|
|
|
- print(error)
|
|
|
+ //print(error)
|
|
|
}
|
|
|
})
|
|
|
}
|
|
@@ -1469,7 +1469,7 @@ class IncomingThread {
|
|
|
ack(message: message)
|
|
|
} catch {
|
|
|
rollback.pointee = true
|
|
|
- print(error)
|
|
|
+ //print(error)
|
|
|
}
|
|
|
})
|
|
|
}
|
|
@@ -1512,7 +1512,7 @@ class IncomingThread {
|
|
|
ack(message: message)
|
|
|
} catch {
|
|
|
rollback.pointee = true
|
|
|
- print(error)
|
|
|
+ //print(error)
|
|
|
}
|
|
|
})
|
|
|
}
|
|
@@ -1565,7 +1565,7 @@ class IncomingThread {
|
|
|
|
|
|
private func getLiveVideoList(message: TMessage) -> Void {
|
|
|
let data = message.getBody(key: CoreMessage_TMessageKey.DATA)
|
|
|
- print(data)
|
|
|
+ //print(data)
|
|
|
if let delegate = Nexilis.shared.streamingDelagate {
|
|
|
delegate.onStartLS(state: 99, message: data)
|
|
|
}
|
|
@@ -1573,7 +1573,7 @@ class IncomingThread {
|
|
|
}
|
|
|
private func getLSTitle(message: TMessage) -> Void {
|
|
|
let title = message.getBody(key: CoreMessage_TMessageKey.TITLE)
|
|
|
- print(title)
|
|
|
+ //print(title)
|
|
|
if let delegate = Nexilis.shared.streamingDelagate {
|
|
|
delegate.onJoinLS(state: 999, message: title)
|
|
|
}
|
|
@@ -1595,7 +1595,7 @@ class IncomingThread {
|
|
|
let last_loc_update = message.getBody(key: CoreMessage_TMessageKey.LAST_LOC_UPDATE)
|
|
|
let user_type = message.getBody(key: CoreMessage_TMessageKey.USER_TYPE)
|
|
|
if let delegate = Nexilis.shared.personInfoDelegate {
|
|
|
- //print("INcoming \(connected)")
|
|
|
+ //print(("INcoming \(connected)")
|
|
|
delegate.onUpdatePersonInfo(state: 00, message: connected)
|
|
|
}
|
|
|
Database.shared.database?.inTransaction({ (fmdb, rollback) in
|
|
@@ -1625,7 +1625,7 @@ class IncomingThread {
|
|
|
let name = message.getBody(key: CoreMessage_TMessageKey.NAME,default_value: "")
|
|
|
let quantity = message.getBody(key: CoreMessage_TMessageKey.QUANTITY,default_value: "")
|
|
|
let data = broadcaster+","+f_pin+","+thumb_id+","+name+","+quantity
|
|
|
- print(data)
|
|
|
+ //print(data)
|
|
|
if let delegate = Nexilis.shared.streamingDelagate {
|
|
|
delegate.onJoinLS(state: 98, message: data)
|
|
|
}
|
|
@@ -1639,7 +1639,7 @@ class IncomingThread {
|
|
|
let name = message.getBody(key: CoreMessage_TMessageKey.NAME,default_value: "")
|
|
|
let quantity = message.getBody(key: CoreMessage_TMessageKey.QUANTITY,default_value: "")
|
|
|
let data = broadcaster+","+f_pin+","+thumb_id+","+name+","+quantity
|
|
|
- print(data)
|
|
|
+ //print(data)
|
|
|
if let delegate = Nexilis.shared.streamingDelagate {
|
|
|
delegate.onJoinLS(state: 97, message: data)
|
|
|
}
|
|
@@ -1650,7 +1650,7 @@ class IncomingThread {
|
|
|
let likes = message.getBody(key: CoreMessage_TMessageKey.LIKES,default_value: "")
|
|
|
let quantity = message.getBody(key: CoreMessage_TMessageKey.QUANTITY,default_value: "")
|
|
|
let data = l_pin+","+likes+","+quantity
|
|
|
- print(data)
|
|
|
+ //print(data)
|
|
|
if let delegate = Nexilis.shared.streamingDelagate {
|
|
|
delegate.onJoinLS(state: 96, message: data)
|
|
|
}
|
|
@@ -1664,7 +1664,7 @@ class IncomingThread {
|
|
|
let name = message.getBody(key: CoreMessage_TMessageKey.NAME,default_value: "")
|
|
|
let messages = message.getBody(key: CoreMessage_TMessageKey.MESSAGE_TEXT,default_value: "")
|
|
|
let data = l_pin+","+f_pin+","+thumb_id+","+name+","+messages
|
|
|
- print(data)
|
|
|
+ //print(data)
|
|
|
if let delegate = Nexilis.shared.streamingDelagate {
|
|
|
delegate.onJoinLS(state: 95, message: data)
|
|
|
}
|
|
@@ -1675,7 +1675,7 @@ class IncomingThread {
|
|
|
let likes = message.getBody(key: CoreMessage_TMessageKey.LIKES,default_value: "")
|
|
|
let quantity = message.getBody(key: CoreMessage_TMessageKey.QUANTITY,default_value: "")
|
|
|
let data = l_pin+","+likes+","+quantity
|
|
|
- print(data)
|
|
|
+ //print(data)
|
|
|
if let delegate = Nexilis.shared.streamingDelagate {
|
|
|
delegate.onJoinLS(state: 94, message: data)
|
|
|
}
|
|
@@ -1688,7 +1688,7 @@ class IncomingThread {
|
|
|
let name = message.getBody(key: CoreMessage_TMessageKey.NAME,default_value: "")
|
|
|
let quantity = message.getBody(key: CoreMessage_TMessageKey.QUANTITY,default_value: "")
|
|
|
let data = broadcaster+","+f_pin+","+thumb_id+","+name+","+quantity
|
|
|
- print(data)
|
|
|
+ //print(data)
|
|
|
if let delegate = Nexilis.shared.seminarDelegate {
|
|
|
delegate.onJoinSeminar(state: 98, message: data)
|
|
|
}
|
|
@@ -1701,7 +1701,7 @@ class IncomingThread {
|
|
|
let name = message.getBody(key: CoreMessage_TMessageKey.NAME,default_value: "")
|
|
|
let quantity = message.getBody(key: CoreMessage_TMessageKey.QUANTITY,default_value: "")
|
|
|
let data = broadcaster+","+f_pin+","+thumb_id+","+name+","+quantity
|
|
|
- print(data)
|
|
|
+ //print(data)
|
|
|
if let delegate = Nexilis.shared.seminarDelegate {
|
|
|
delegate.onJoinSeminar(state: 97, message: data)
|
|
|
}
|
|
@@ -1712,7 +1712,7 @@ class IncomingThread {
|
|
|
let f_pin = message.getBody(key: CoreMessage_TMessageKey.F_PIN,default_value: "")
|
|
|
let status = message.getBody(key: CoreMessage_TMessageKey.STATUS,default_value: "")
|
|
|
let data = f_pin+","+l_pin+","+status
|
|
|
- print(data)
|
|
|
+ //print(data)
|
|
|
if let delegate = Nexilis.shared.seminarDelegate {
|
|
|
delegate.onJoinSeminar(state: 96, message: data)
|
|
|
}
|
|
@@ -1726,7 +1726,7 @@ class IncomingThread {
|
|
|
let name = message.getBody(key: CoreMessage_TMessageKey.NAME,default_value: "")
|
|
|
let messages = message.getBody(key: CoreMessage_TMessageKey.MESSAGE_TEXT,default_value: "")
|
|
|
let data = l_pin+","+f_pin+","+thumb_id+","+name+","+messages
|
|
|
- print(data)
|
|
|
+ //print(data)
|
|
|
if let delegate = Nexilis.shared.seminarDelegate {
|
|
|
delegate.onJoinSeminar(state: 95, message: data)
|
|
|
}
|
|
@@ -1736,10 +1736,10 @@ class IncomingThread {
|
|
|
let f_pin = message.getBody(key: CoreMessage_TMessageKey.F_PIN,default_value: "")
|
|
|
let l_pin = message.getBody(key: CoreMessage_TMessageKey.L_PIN,default_value: "")
|
|
|
let data = f_pin
|
|
|
- //print("data ss")
|
|
|
- print(data)
|
|
|
- print(l_pin)
|
|
|
- print(state)
|
|
|
+ //print(("data ss")
|
|
|
+ //print(data)
|
|
|
+ //print(l_pin)
|
|
|
+ //print(state)
|
|
|
if let delegate = Nexilis.shared.screenSharingDelegate {
|
|
|
delegate.onJoinScreenSharing(state: state, message: data)
|
|
|
}
|
|
@@ -1749,7 +1749,7 @@ class IncomingThread {
|
|
|
private func sendMSISDN(message: TMessage) -> Void {
|
|
|
let errcod = message.getBody(key: CoreMessage_TMessageKey.ERRCOD,default_value: "")
|
|
|
let data = errcod
|
|
|
- print(data)
|
|
|
+ //print(data)
|
|
|
if (errcod == "00"){
|
|
|
if let delegate = Nexilis.shared.loginDelegate {
|
|
|
delegate.onProcess(message: "Success", status: "1")
|
|
@@ -1773,7 +1773,7 @@ class IncomingThread {
|
|
|
let l_name = message.getBody(key: CoreMessage_TMessageKey.LAST_NAME, default_value: "")
|
|
|
let thumb_id = message.getBody(key: CoreMessage_TMessageKey.THUMB_ID, default_value: "")
|
|
|
let data = f_pin+"|"+f_name+"|"+l_name+"|"+thumb_id
|
|
|
- print(data)
|
|
|
+ //print(data)
|
|
|
if let delegate = Nexilis.shared.loginDelegate {
|
|
|
delegate.onProcess(message: data, status: reg_status)
|
|
|
}
|
|
@@ -1856,7 +1856,7 @@ class IncomingThread {
|
|
|
ack(message: message)
|
|
|
} catch {
|
|
|
rollback.pointee = true
|
|
|
- print(error)
|
|
|
+ //print(error)
|
|
|
}
|
|
|
})
|
|
|
}
|