bfad2ab42d
Since there may be situations where we close and re-open the database,
we need to make sure transactions fail when the database is not open.
Make NdbTxn an init?() constructor and check for ndb.closed. If it's
closed, then fail transaction construction.
This fixes crashes during high database activity when switching from
background to foreground and vice-versa.
Fixes: da2bdad18d ("nostrdb: close database when backgrounded")
76 lines
2.0 KiB
Swift
76 lines
2.0 KiB
Swift
//
|
|
// EventsModel.swift
|
|
// damus
|
|
//
|
|
// Created by William Casarin on 2022-05-24.
|
|
//
|
|
|
|
import Foundation
|
|
|
|
|
|
class EventsModel: ObservableObject {
|
|
let state: DamusState
|
|
let target: NoteId
|
|
let kind: NostrKind
|
|
let sub_id = UUID().uuidString
|
|
let profiles_id = UUID().uuidString
|
|
|
|
@Published var events: [NostrEvent] = []
|
|
|
|
init(state: DamusState, target: NoteId, kind: NostrKind) {
|
|
self.state = state
|
|
self.target = target
|
|
self.kind = kind
|
|
}
|
|
|
|
private func get_filter() -> NostrFilter {
|
|
var filter = NostrFilter(kinds: [kind])
|
|
filter.referenced_ids = [target]
|
|
filter.limit = 500
|
|
return filter
|
|
}
|
|
|
|
func subscribe() {
|
|
state.pool.subscribe(sub_id: sub_id,
|
|
filters: [get_filter()],
|
|
handler: handle_nostr_event)
|
|
}
|
|
|
|
func unsubscribe() {
|
|
state.pool.unsubscribe(sub_id: sub_id)
|
|
}
|
|
|
|
private func handle_event(relay_id: String, ev: NostrEvent) {
|
|
guard ev.kind == kind.rawValue,
|
|
ev.referenced_ids.last == target else {
|
|
return
|
|
}
|
|
|
|
if insert_uniq_sorted_event(events: &self.events, new_ev: ev, cmp: { a, b in a.created_at < b.created_at } ) {
|
|
objectWillChange.send()
|
|
}
|
|
}
|
|
|
|
func handle_nostr_event(relay_id: String, ev: NostrConnectionEvent) {
|
|
guard case .nostr_event(let nev) = ev else {
|
|
return
|
|
}
|
|
|
|
switch nev {
|
|
case .event(_, let ev):
|
|
handle_event(relay_id: relay_id, ev: ev)
|
|
case .notice:
|
|
break
|
|
case .ok:
|
|
break
|
|
case .auth:
|
|
break
|
|
case .eose:
|
|
guard let txn = NdbTxn(ndb: self.state.ndb) else {
|
|
return
|
|
}
|
|
load_profiles(context: "events_model", profiles_subid: profiles_id, relay_id: relay_id, load: .from_events(events), damus_state: state, txn: txn)
|
|
}
|
|
}
|
|
}
|