58 lines
1.5 KiB
Swift
58 lines
1.5 KiB
Swift
import Foundation
|
|
import Martin
|
|
|
|
/// Martin 3.2.4 does not expose `DefaultRoomStore.init()` outside its module.
|
|
/// This mirrors its in-memory behavior so the app can register XEP-0045 MUC.
|
|
final class LumaRoomStore: RoomStore {
|
|
typealias Room = RoomBase
|
|
|
|
private let queue = DispatchQueue(label: "LumaRoomStore")
|
|
private var roomsByJID: [BareJID: RoomBase] = [:]
|
|
|
|
func rooms(for context: Context) -> [RoomBase] {
|
|
queue.sync {
|
|
Array(roomsByJID.values)
|
|
}
|
|
}
|
|
|
|
func room(for context: Context, with jid: BareJID) -> RoomBase? {
|
|
queue.sync {
|
|
roomsByJID[jid]
|
|
}
|
|
}
|
|
|
|
func createRoom(
|
|
for context: Context,
|
|
with jid: BareJID,
|
|
nickname: String,
|
|
password: String?
|
|
) -> ConversationCreateResult<RoomBase> {
|
|
queue.sync {
|
|
if let room = roomsByJID[jid] {
|
|
return .found(room)
|
|
}
|
|
let room = RoomBase(
|
|
context: context,
|
|
jid: jid,
|
|
nickname: nickname,
|
|
password: password,
|
|
dispatcher: QueueDispatcher(queue: queue)
|
|
)
|
|
roomsByJID[jid] = room
|
|
return .created(room)
|
|
}
|
|
}
|
|
|
|
func close(room: RoomBase) -> Bool {
|
|
queue.sync {
|
|
guard roomsByJID[room.jid] === room else { return false }
|
|
roomsByJID.removeValue(forKey: room.jid)
|
|
return true
|
|
}
|
|
}
|
|
|
|
func initialize(context: Context) {}
|
|
|
|
func deinitialize(context: Context) {}
|
|
}
|