List zaps on posts

damus/Models/ZapsModel.swift

@@ -0,0 +1,69 @@
+//
+//  ZapsModel.swift
+//  damus
+//
+//  Created by William Casarin on 2023-02-10.
+//
+
+import Foundation
+
+class ZapsModel: ObservableObject {
+    let profiles: Profiles
+    let pool: RelayPool
+    let target: ZapTarget
+    var zaps: [Zap]
+    
+    let zaps_subid = UUID().description
+    
+    init(profiles: Profiles, pool: RelayPool, target: ZapTarget) {
+        self.target = target
+        self.profiles = profiles
+        self.pool = pool
+        self.zaps = []
+    }
+    
+    func subscribe() {
+        var filter = NostrFilter.filter_kinds([9735])
+        switch target {
+        case .profile(let profile_id):
+            filter.pubkeys = [profile_id]
+        case .note(let note_target):
+            filter.referenced_ids = [note_target.note_id]
+        }
+        pool.subscribe(sub_id: zaps_subid, filters: [filter], handler: handle_event)
+    }
+    
+    func unsubscribe() {
+        pool.unsubscribe(sub_id: zaps_subid)
+    }
+    
+    func handle_event(relay_id: String, conn_ev: NostrConnectionEvent) {
+        guard case .nostr_event(let resp) = conn_ev else {
+            return
+        }
+        
+        guard resp.subid == zaps_subid else {
+            return
+        }
+        
+        guard case .event(_, let ev) = resp else {
+            return
+        }
+        
+        guard ev.kind == 9735 else {
+            return
+        }
+        
+        guard let zapper = profiles.lookup_zapper(pubkey: target.pubkey) else {
+            return
+        }
+        
+        guard let zap = Zap.from_zap_event(zap_ev: ev, zapper: zapper) else {
+            return
+        }
+        
+        if insert_uniq_sorted_zap(zaps: &zaps, new_zap: zap) {
+            objectWillChange.send()
+        }
+    }
+}