|
|
|
@ -33,6 +33,7 @@ public class MessageManager: BaseServiceManager { |
|
|
|
|
self["createCustomMessage"] = createCustomMessage |
|
|
|
|
self["createQuoteMessage"] = createQuoteMessage |
|
|
|
|
self["createCardMessage"] = createCardMessage |
|
|
|
|
self["createFaceMessage"] = createFaceMessage |
|
|
|
|
// self["forceSyncMsg"] = forceSyncMsg |
|
|
|
|
self["clearC2CHistoryMessage"] = clearC2CHistoryMessage |
|
|
|
|
self["clearGroupHistoryMessage"] = clearGroupHistoryMessage |
|
|
|
@ -75,15 +76,15 @@ public class MessageManager: BaseServiceManager { |
|
|
|
|
// func findMessages(methodCall: FlutterMethodCall, result: @escaping FlutterResult){ |
|
|
|
|
// Open_im_sdkFindMessages(BaseCallback(result: result), methodCall[jsonString: "messageIDList"]) |
|
|
|
|
// } |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
func markC2CMessageAsRead(methodCall: FlutterMethodCall, result: @escaping FlutterResult){ |
|
|
|
|
Open_im_sdkMarkC2CMessageAsRead(BaseCallback(result: result), methodCall[string: "operationID"], methodCall[string: "userID"], methodCall[jsonString: "messageIDList"]) |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
func typingStatusUpdate(methodCall: FlutterMethodCall, result: @escaping FlutterResult){ |
|
|
|
|
Open_im_sdkTypingStatusUpdate(BaseCallback(result: result), methodCall[string: "operationID"], methodCall[string: "userID"], methodCall[string: "msgTip"]) |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
func createTextMessage(methodCall: FlutterMethodCall, result: @escaping FlutterResult){ |
|
|
|
|
callBack(result, Open_im_sdkCreateTextMessage(methodCall[string: "operationID"], methodCall[string: "text"])) |
|
|
|
|
} |
|
|
|
@ -116,18 +117,18 @@ public class MessageManager: BaseServiceManager { |
|
|
|
|
|
|
|
|
|
func createVideoMessageFromFullPath(methodCall: FlutterMethodCall, result: @escaping FlutterResult){ |
|
|
|
|
let prama = Open_im_sdkCreateVideoMessageFromFullPath(methodCall[string: "operationID"], methodCall[string: "videoPath"], methodCall[string: "videoType"], |
|
|
|
|
methodCall[int64: "duration"], methodCall[string: "snapshotPath"]) |
|
|
|
|
methodCall[int64: "duration"], methodCall[string: "snapshotPath"]) |
|
|
|
|
callBack(result, prama) |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
func createFileMessage(methodCall: FlutterMethodCall, result: @escaping FlutterResult){ |
|
|
|
|
callBack(result, Open_im_sdkCreateFileMessage(methodCall[string: "operationID"], methodCall[string: "filePath"], methodCall[string: "fileName"])) |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
func createFileMessageFromFullPath(methodCall: FlutterMethodCall, result: @escaping FlutterResult){ |
|
|
|
|
callBack(result, Open_im_sdkCreateFileMessageFromFullPath(methodCall[string: "operationID"], methodCall[string: "filePath"], methodCall[string: "fileName"])) |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
func createFileMessageFromFullPath(methodCall: FlutterMethodCall, result: @escaping FlutterResult){ |
|
|
|
|
callBack(result, Open_im_sdkCreateFileMessageFromFullPath(methodCall[string: "operationID"], methodCall[string: "filePath"], methodCall[string: "fileName"])) |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
func createMergerMessage(methodCall: FlutterMethodCall, result: @escaping FlutterResult){ |
|
|
|
|
let prama = Open_im_sdkCreateMergerMessage(methodCall[string: "operationID"], methodCall[jsonString: "messageList"], methodCall[string: "title"], |
|
|
|
|
methodCall[jsonString: "summaryList"]) |
|
|
|
@ -158,35 +159,38 @@ public class MessageManager: BaseServiceManager { |
|
|
|
|
func createCardMessage(methodCall: FlutterMethodCall, result: @escaping FlutterResult){ |
|
|
|
|
callBack(result, Open_im_sdkCreateCardMessage(methodCall[string: "operationID"], methodCall[jsonString: "cardMessage"])) |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
func createFaceMessage(methodCall: FlutterMethodCall, result: @escaping FlutterResult){ |
|
|
|
|
callBack(result, Open_im_sdkCreateFaceMessage(methodCall[string: "operationID"], methodCall[int: "index"], methodCall[string: "data"])) |
|
|
|
|
} |
|
|
|
|
// func forceSyncMsg(methodCall: FlutterMethodCall, result: @escaping FlutterResult){ |
|
|
|
|
// Open_im_sdkForceSyncMsg() |
|
|
|
|
// callBack(result) |
|
|
|
|
// } |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
func clearC2CHistoryMessage(methodCall: FlutterMethodCall, result: @escaping FlutterResult){ |
|
|
|
|
Open_im_sdkClearC2CHistoryMessage(BaseCallback(result: result), methodCall[string: "operationID"], methodCall[string: "userID"]) |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
func clearGroupHistoryMessage(methodCall: FlutterMethodCall, result: @escaping FlutterResult){ |
|
|
|
|
Open_im_sdkClearGroupHistoryMessage(BaseCallback(result: result), methodCall[string: "operationID"], methodCall[string: "groupID"]) |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
public class SendMsgProgressListener: NSObject, Open_im_sdk_callbackSendMsgCallBackProtocol { |
|
|
|
|
private let channel: FlutterMethodChannel |
|
|
|
|
private let result: FlutterResult |
|
|
|
|
private let call: FlutterMethodCall |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
init(channel: FlutterMethodChannel, result: @escaping FlutterResult, methodCall: FlutterMethodCall) { |
|
|
|
|
self.channel = channel |
|
|
|
|
self.result = result |
|
|
|
|
self.call = methodCall |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
public func onError(_ errCode: Int32, errMsg: String?) { |
|
|
|
|
DispatchQueue.main.async { self.result(FlutterError(code: "\(errCode)", message: errMsg, details: nil)) } |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
public func onProgress(_ progress: Int) { |
|
|
|
|
var values: [String: Any] = [:] |
|
|
|
|
let message = call[dict: "message"] |
|
|
|
@ -194,36 +198,36 @@ public class MessageManager: BaseServiceManager { |
|
|
|
|
values["progress"] = progress |
|
|
|
|
CommonUtil.emitEvent(channel: channel, method: "msgSendProgressListener", type: "onProgress", errCode: nil, errMsg: nil, data: values) |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
public func onSuccess(_ data: String?) { |
|
|
|
|
DispatchQueue.main.async { self.result(data) } |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
public class AdvancedMsgListener: NSObject, Open_im_sdk_callbackOnAdvancedMsgListenerProtocol { |
|
|
|
|
private let channel: FlutterMethodChannel |
|
|
|
|
private let id: String |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
init(channel: FlutterMethodChannel, id: String) { |
|
|
|
|
self.channel = channel |
|
|
|
|
self.id = id |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
public func onRecvC2CReadReceipt(_ msgReceiptList: String?) { |
|
|
|
|
var values: [String: Any] = [:] |
|
|
|
|
values["id"] = id |
|
|
|
|
values["haveReadMessage"] = msgReceiptList |
|
|
|
|
CommonUtil.emitEvent(channel: channel, method: "advancedMsgListener", type: "onRecvC2CReadReceipt", errCode: nil, errMsg: nil, data: values) |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
public func onRecvMessageRevoked(_ msgId: String?) { |
|
|
|
|
var values: [String: Any] = [:] |
|
|
|
|
values["id"] = id |
|
|
|
|
values["revokedMessage"] = msgId |
|
|
|
|
CommonUtil.emitEvent(channel: channel, method: "advancedMsgListener", type: "onRecvMessageRevoked", errCode: nil, errMsg: nil, data: values) |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
public func onRecvNewMessage(_ message: String?) { |
|
|
|
|
var values: [String: Any] = [:] |
|
|
|
|
values["id"] = id |
|
|
|
|