mirror of https://github.com/oxen-io/session-ios
Fix conversion to JSON, use ISO8601DateFormatter & clean
Niels Andriesse
5 years ago
parent
a9a403a703
commit
a234019cb9
@ -1,81 +1,71 @@
|
||||
import PromiseKit
|
||||
|
||||
public enum LokiGroupChatAPIError: Error {
|
||||
case failedToParseMessage
|
||||
case failedToParseTimestamp
|
||||
}
|
||||
|
||||
@objc(LKGroupChatAPI)
|
||||
public final class LokiGroupChatAPI : NSObject {
|
||||
internal static let storage = OWSPrimaryStorage.shared()
|
||||
internal static let contactsManager = SSKEnvironment.shared.contactsManager
|
||||
internal static var userHexEncodedPublicKey: String { return OWSIdentityManager.shared().identityKeyPair()!.hexEncodedPublicKey }
|
||||
|
||||
@objc public static let serverURL = "https://chat.lokinet.org"
|
||||
private static let batchCount = 8
|
||||
@objc public static let publicChatMessageType = "network.loki.messenger.publicChat"
|
||||
@objc public static let publicChatID = 1
|
||||
|
||||
private static let batchCount = 8
|
||||
internal static var userDisplayName: String {
|
||||
return SSKEnvironment.shared.contactsManager.displayName(forPhoneIdentifier: userHexEncodedPublicKey) ?? "Anonymous"
|
||||
}
|
||||
|
||||
public static func getMessages(for groupID: UInt) -> Promise<[LokiGroupMessage]> {
|
||||
print("[Loki] Getting messages for group chat with ID: \(groupID)")
|
||||
let url = URL(string: "\(serverURL)/channels/\(groupID)/messages?include_annotations=1&count=-\(batchCount)")!
|
||||
private static var userHexEncodedPublicKey: String {
|
||||
return OWSIdentityManager.shared().identityKeyPair()!.hexEncodedPublicKey
|
||||
}
|
||||
|
||||
public enum Error : Swift.Error {
|
||||
case messageParsingFailed
|
||||
}
|
||||
|
||||
public static func getMessages(for group: UInt) -> Promise<[LokiGroupMessage]> {
|
||||
print("[Loki] Getting messages for group chat with ID: \(group).")
|
||||
let queryParameters = "include_annotations=1&count=-\(batchCount)"
|
||||
let url = URL(string: "\(serverURL)/channels/\(group)/messages?\(queryParameters)")!
|
||||
let request = TSRequest(url: url)
|
||||
return TSNetworkManager.shared().makePromise(request: request).map { $0.responseObject }.map { rawResponse in
|
||||
guard let json = rawResponse as? JSON, let rawMessages = json["data"] as? [JSON] else {
|
||||
print("[Loki] Failed to parse group messages from: \(rawResponse).")
|
||||
return []
|
||||
print("[Loki] Couldn't parse messages for group chat with ID: \(group) from: \(rawResponse).")
|
||||
throw Error.messageParsingFailed
|
||||
}
|
||||
return rawMessages.flatMap { message in
|
||||
guard let annotations = message["annotations"] as? [JSON], let annotation = annotations.first, let value = annotation["value"] as? JSON,
|
||||
let serverID = message["id"] as? UInt, let body = message["text"] as? String, let hexEncodedPublicKey = value["source"] as? String, let displayName = value["from"] as? String, let timestamp = value["timestamp"] as? UInt64 else {
|
||||
print("[Loki] Failed to parse message from: \(message).")
|
||||
print("[Loki] Couldn't parse message for group chat with ID: \(group) from: \(message).")
|
||||
return nil
|
||||
}
|
||||
|
||||
guard hexEncodedPublicKey != userHexEncodedPublicKey else { return nil }
|
||||
|
||||
return LokiGroupMessage(serverID: serverID, hexEncodedPublicKey: hexEncodedPublicKey, displayName: displayName, body: body, type: publicChatMessageType, timestamp: timestamp)
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
public static func sendMessage(_ message: LokiGroupMessage, groupID: UInt) -> Promise<LokiGroupMessage> {
|
||||
let url = URL(string: "\(serverURL)/channels/\(groupID)/messages")!
|
||||
let request = TSRequest(url: url, method: "POST", parameters: message.toJSON())
|
||||
request.allHTTPHeaderFields = [ "Authorization": "Bearer loki", "Content-Type": "application/json" ]
|
||||
public static func sendMessage(_ message: LokiGroupMessage, to group: UInt) -> Promise<LokiGroupMessage> {
|
||||
print("[Loki] Sending message to group chat with ID: \(group).")
|
||||
let url = URL(string: "\(serverURL)/channels/\(group)/messages")!
|
||||
let parameters = message.toJSON()
|
||||
let request = TSRequest(url: url, method: "POST", parameters: parameters)
|
||||
request.allHTTPHeaderFields = [ "Content-Type" : "application/json", "Authorization" : "Bearer loki" ]
|
||||
let displayName = userDisplayName
|
||||
return TSNetworkManager.shared().makePromise(request: request).map { $0.responseObject }.map { rawResponse in
|
||||
guard let json = rawResponse as? JSON, let message = json["data"] as? JSON, let serverID = message["id"] as? UInt, let body = message["text"] as? String, let dateAsString = message["created_at"] as? String else {
|
||||
print("[Loki] Failed to parse group messages from: \(rawResponse).")
|
||||
throw LokiGroupChatAPIError.failedToParseMessage
|
||||
}
|
||||
|
||||
let formatter = DateFormatter()
|
||||
formatter.dateFormat = "yyyy-MM-dd'T'HH:mm:ssZZZ"
|
||||
|
||||
guard let date = formatter.date(from: dateAsString) else {
|
||||
print("[Loki] Failed to parse message timestamp from: \(message).")
|
||||
throw LokiGroupChatAPIError.failedToParseTimestamp
|
||||
guard let json = rawResponse as? JSON, let message = json["data"] as? JSON, let serverID = message["id"] as? UInt, let body = message["text"] as? String, let dateAsString = message["created_at"] as? String, let date = ISO8601DateFormatter().date(from: dateAsString) else {
|
||||
print("[Loki] Couldn't parse messages for group chat with ID: \(group) from: \(rawResponse).")
|
||||
throw Error.messageParsingFailed
|
||||
}
|
||||
|
||||
// Timestmap needs to be in milliseconds
|
||||
let timestamp = UInt64(date.timeIntervalSince1970) * 1000
|
||||
let displayName = contactsManager.displayName(forPhoneIdentifier: userHexEncodedPublicKey) ?? "Anonymous"
|
||||
|
||||
return LokiGroupMessage(serverID: serverID, hexEncodedPublicKey: userHexEncodedPublicKey, displayName: displayName, body: body, type: publicChatMessageType, timestamp: timestamp)
|
||||
}
|
||||
}
|
||||
|
||||
// MARK: Public API (Obj-C)
|
||||
@objc(getMessagesForGroupID:)
|
||||
public static func objc_getMessages(groupID: UInt) -> AnyPromise {
|
||||
let promise = getMessages(for: groupID)
|
||||
return AnyPromise.from(promise)
|
||||
@objc(getMessagesForGroup:)
|
||||
public static func objc_getMessages(for group: UInt) -> AnyPromise {
|
||||
return AnyPromise.from(getMessages(for: group))
|
||||
}
|
||||
|
||||
@objc(sendMessage:groupID:)
|
||||
public static func objc_sendMessage(message: LokiGroupMessage, groupID: UInt) -> AnyPromise {
|
||||
let promise = sendMessage(message, groupID: groupID)
|
||||
return AnyPromise.from(promise)
|
||||
@objc(sendMessage:toGroup:)
|
||||
public static func objc_sendMessage(_ message: LokiGroupMessage, to group: UInt) -> AnyPromise {
|
||||
return AnyPromise.from(sendMessage(message, to: group))
|
||||
}
|
||||
}
|
||||
|
||||
Loading…
Reference in New Issue