Browse Source

start to extract functions out of contentview

in this case, is_friend_event

Signed-off-by: William Casarin <jb55@jb55.com>
profiles-everywhere
William Casarin 3 years ago
parent
commit
b72fb8ba31
  1. 113
      damus/ContentView.swift

113
damus/ContentView.swift

@ -44,7 +44,7 @@ struct ContentView: View {
@State var status: String = "Not connected" @State var status: String = "Not connected"
@State var active_sheet: Sheets? = nil @State var active_sheet: Sheets? = nil
@State var loading: Bool = true @State var loading: Bool = true
@State var damus: DamusState? = nil @State var damus_state: DamusState? = nil
@State var selected_timeline: Timeline? = .home @State var selected_timeline: Timeline? = .home
@State var is_thread_open: Bool = false @State var is_thread_open: Bool = false
@State var is_profile_open: Bool = false @State var is_profile_open: Bool = false
@ -139,7 +139,7 @@ struct ContentView: View {
var PostingTimelineView: some View { var PostingTimelineView: some View {
ZStack { ZStack {
if let damus = self.damus { if let damus = self.damus_state {
TimelineView(events: $friend_events, damus: damus) TimelineView(events: $friend_events, damus: damus)
} }
PostButtonContainer PostButtonContainer
@ -186,7 +186,7 @@ struct ContentView: View {
var MaybeSearchView: some View { var MaybeSearchView: some View {
Group { Group {
if let search = self.active_search { if let search = self.active_search {
SearchView(appstate: damus!, search: SearchModel(pool: damus!.pool, search: search)) SearchView(appstate: damus_state!, search: SearchModel(pool: damus_state!.pool, search: search))
} else { } else {
EmptyView() EmptyView()
} }
@ -196,8 +196,8 @@ struct ContentView: View {
var MaybeThreadView: some View { var MaybeThreadView: some View {
Group { Group {
if let evid = self.active_event_id { if let evid = self.active_event_id {
let thread_model = ThreadModel(evid: evid, pool: damus!.pool) let thread_model = ThreadModel(evid: evid, pool: damus_state!.pool)
ThreadView(thread: thread_model, damus: damus!) ThreadView(thread: thread_model, damus: damus_state!)
} else { } else {
EmptyView() EmptyView()
} }
@ -207,9 +207,9 @@ struct ContentView: View {
var MaybeProfileView: some View { var MaybeProfileView: some View {
Group { Group {
if let pk = self.active_profile { if let pk = self.active_profile {
let profile_model = ProfileModel(pubkey: pk, damus: damus!) let profile_model = ProfileModel(pubkey: pk, damus: damus_state!)
let fs = damus!.contacts.follow_state(pk) let fs = damus_state!.contacts.follow_state(pk)
ProfileView(damus: damus!, follow_state: fs, profile: profile_model) ProfileView(damus: damus_state!, follow_state: fs, profile: profile_model)
} else { } else {
EmptyView() EmptyView()
} }
@ -218,7 +218,7 @@ struct ContentView: View {
var body: some View { var body: some View {
VStack { VStack {
if let damus = self.damus { if let damus = self.damus_state {
ZStack { ZStack {
MainContent(damus: damus) MainContent(damus: damus)
.padding([.bottom], -8.0) .padding([.bottom], -8.0)
@ -237,7 +237,7 @@ struct ContentView: View {
case .post: case .post:
PostView(references: []) PostView(references: [])
case .reply(let event): case .reply(let event):
ReplyView(replying_to: event, damus: damus!) ReplyView(replying_to: event, damus: damus_state!)
} }
} }
.onOpenURL { url in .onOpenURL { url in
@ -265,7 +265,7 @@ struct ContentView: View {
.onReceive(handle_notify(.boost)) { notif in .onReceive(handle_notify(.boost)) { notif in
let ev = notif.object as! NostrEvent let ev = notif.object as! NostrEvent
let boost = make_boost_event(pubkey: pubkey, privkey: privkey, boosted: ev) let boost = make_boost_event(pubkey: pubkey, privkey: privkey, boosted: ev)
self.damus?.pool.send(.event(boost)) self.damus_state?.pool.send(.event(boost))
} }
.onReceive(handle_notify(.open_thread)) { obj in .onReceive(handle_notify(.open_thread)) { obj in
//let ev = obj.object as! NostrEvent //let ev = obj.object as! NostrEvent
@ -279,20 +279,20 @@ struct ContentView: View {
.onReceive(handle_notify(.boost)) { boost in .onReceive(handle_notify(.boost)) { boost in
let ev = boost.object as! NostrEvent let ev = boost.object as! NostrEvent
let boost_ev = make_boost_event(pubkey: pubkey, privkey: privkey, boosted: ev) let boost_ev = make_boost_event(pubkey: pubkey, privkey: privkey, boosted: ev)
self.damus?.pool.send(.event(boost_ev)) self.damus_state?.pool.send(.event(boost_ev))
} }
.onReceive(handle_notify(.like)) { like in .onReceive(handle_notify(.like)) { like in
let ev = like.object as! NostrEvent let ev = like.object as! NostrEvent
let like_ev = make_like_event(pubkey: pubkey, privkey: privkey, liked: ev) let like_ev = make_like_event(pubkey: pubkey, privkey: privkey, liked: ev)
self.damus?.pool.send(.event(like_ev)) self.damus_state?.pool.send(.event(like_ev))
} }
.onReceive(handle_notify(.broadcast_event)) { obj in .onReceive(handle_notify(.broadcast_event)) { obj in
let ev = obj.object as! NostrEvent let ev = obj.object as! NostrEvent
self.damus?.pool.send(.event(ev)) self.damus_state?.pool.send(.event(ev))
} }
.onReceive(handle_notify(.unfollow)) { notif in .onReceive(handle_notify(.unfollow)) { notif in
let pk = notif.object as! String let pk = notif.object as! String
guard let damus = self.damus else { guard let damus = self.damus_state else {
return return
} }
@ -308,7 +308,7 @@ struct ContentView: View {
} }
.onReceive(handle_notify(.follow)) { notif in .onReceive(handle_notify(.follow)) { notif in
let pk = notif.object as! String let pk = notif.object as! String
guard let damus = self.damus else { guard let damus = self.damus_state else {
return return
} }
@ -327,41 +327,20 @@ struct ContentView: View {
case .post(let post): case .post(let post):
print("post \(post.content)") print("post \(post.content)")
let new_ev = post_to_event(post: post, privkey: privkey, pubkey: pubkey) let new_ev = post_to_event(post: post, privkey: privkey, pubkey: pubkey)
self.damus?.pool.send(.event(new_ev)) self.damus_state?.pool.send(.event(new_ev))
case .cancel: case .cancel:
active_sheet = nil active_sheet = nil
print("post cancelled") print("post cancelled")
} }
} }
.onReceive(timer) { n in .onReceive(timer) { n in
self.damus?.pool.connect_to_disconnected() self.damus_state?.pool.connect_to_disconnected()
self.loading = (self.damus?.pool.num_connecting ?? 0) != 0 self.loading = (self.damus_state?.pool.num_connecting ?? 0) != 0
} }
} }
func is_friend_event(_ ev: NostrEvent) -> Bool { func is_friend_event(_ ev: NostrEvent) -> Bool {
// we should be able to see our own messages in our homefeed return damus.is_friend_event(ev, our_pubkey: self.pubkey, contacts: self.damus_state!.contacts)
if ev.pubkey == self.pubkey {
return true
}
if damus!.contacts.is_friend(ev.pubkey) {
return true
}
if ev.is_reply {
// show our replies?
if ev.pubkey == self.pubkey {
return true
}
for pk in ev.referenced_pubkeys {
if damus!.contacts.is_friend(pk.ref_id) {
return true
}
}
}
return false
} }
func switch_timeline(_ timeline: Timeline) { func switch_timeline(_ timeline: Timeline) {
@ -398,11 +377,11 @@ struct ContentView: View {
add_relay(pool, "wss://nostr.bitcoiner.social") add_relay(pool, "wss://nostr.bitcoiner.social")
add_relay(pool, "ws://monad.jb55.com:8080") add_relay(pool, "ws://monad.jb55.com:8080")
add_relay(pool, "wss://nostr-relay.freeberty.net") add_relay(pool, "wss://nostr-relay.freeberty.net")
//add_relay(pool, "wss://nostr-relay.untethr.me") add_relay(pool, "wss://nostr-relay.untethr.me")
pool.register_handler(sub_id: sub_id, handler: handle_event) pool.register_handler(sub_id: sub_id, handler: handle_event)
self.damus = DamusState(pool: pool, pubkey: pubkey, self.damus_state = DamusState(pool: pool, pubkey: pubkey,
likes: EventCounter(our_pubkey: pubkey), likes: EventCounter(our_pubkey: pubkey),
boosts: EventCounter(our_pubkey: pubkey), boosts: EventCounter(our_pubkey: pubkey),
contacts: Contacts(), contacts: Contacts(),
@ -415,11 +394,11 @@ struct ContentView: View {
func handle_contact_event(_ ev: NostrEvent) { func handle_contact_event(_ ev: NostrEvent) {
if ev.pubkey == self.pubkey { if ev.pubkey == self.pubkey {
damus!.contacts.event = ev damus_state!.contacts.event = ev
// our contacts // our contacts
for tag in ev.tags { for tag in ev.tags {
if tag.count > 1 && tag[0] == "p" { if tag.count > 1 && tag[0] == "p" {
damus!.contacts.friends.insert(tag[1]) damus_state!.contacts.friends.insert(tag[1])
} }
} }
} }
@ -441,7 +420,7 @@ struct ContentView: View {
return return
} }
switch damus!.boosts.add_event(ev, target: e) { switch damus_state!.boosts.add_event(ev, target: e) {
case .already_counted: case .already_counted:
break break
case .success(let n): case .success(let n):
@ -458,7 +437,7 @@ struct ContentView: View {
// CHECK SIGS ON THESE // CHECK SIGS ON THESE
switch damus!.likes.add_event(ev, target: e.ref_id) { switch damus_state!.likes.add_event(ev, target: e.ref_id) {
case .already_counted: case .already_counted:
break break
case .success(let n): case .success(let n):
@ -472,7 +451,7 @@ struct ContentView: View {
return return
} }
if let mprof = damus!.profiles.lookup_with_timestamp(id: ev.pubkey) { if let mprof = damus_state!.profiles.lookup_with_timestamp(id: ev.pubkey) {
if mprof.timestamp > ev.created_at { if mprof.timestamp > ev.created_at {
// skip if we already have an newer profile // skip if we already have an newer profile
return return
@ -480,7 +459,7 @@ struct ContentView: View {
} }
let tprof = TimestampedProfile(profile: profile, timestamp: ev.created_at) let tprof = TimestampedProfile(profile: profile, timestamp: ev.created_at)
damus!.profiles.add(id: ev.pubkey, profile: tprof) damus_state!.profiles.add(id: ev.pubkey, profile: tprof)
notify(.profile_updated, ProfileUpdate(pubkey: ev.pubkey, profile: profile)) notify(.profile_updated, ProfileUpdate(pubkey: ev.pubkey, profile: profile))
} }
@ -512,7 +491,7 @@ struct ContentView: View {
} }
print("-----") print("-----")
self.damus?.pool.send(.subscribe(.init(filters: filters, sub_id: sub_id)), to: [relay_id]) self.damus_state?.pool.send(.subscribe(.init(filters: filters, sub_id: sub_id)), to: [relay_id])
//self.pool?.send(.subscribe(.init(filters: [notification_filter], sub_id: "notifications"))) //self.pool?.send(.subscribe(.init(filters: [notification_filter], sub_id: "notifications")))
} }
@ -604,20 +583,20 @@ struct ContentView: View {
case .error(let merr): case .error(let merr):
let desc = merr.debugDescription let desc = merr.debugDescription
if desc.contains("Software caused connection abort") { if desc.contains("Software caused connection abort") {
self.damus?.pool.reconnect(to: [relay_id]) self.damus_state?.pool.reconnect(to: [relay_id])
} }
case .disconnected: fallthrough case .disconnected: fallthrough
case .cancelled: case .cancelled:
self.damus?.pool.reconnect(to: [relay_id]) self.damus_state?.pool.reconnect(to: [relay_id])
case .reconnectSuggested(let t): case .reconnectSuggested(let t):
if t { if t {
self.damus?.pool.reconnect(to: [relay_id]) self.damus_state?.pool.reconnect(to: [relay_id])
} }
default: default:
break break
} }
self.loading = (self.damus?.pool.num_connecting ?? 0) != 0 self.loading = (self.damus_state?.pool.num_connecting ?? 0) != 0
print("ws_event \(ev)") print("ws_event \(ev)")
@ -795,3 +774,29 @@ func update_filters_with_since(last_of_kind: [Int: NostrEvent], filters: [NostrF
return filter return filter
} }
} }
func is_friend_event(_ ev: NostrEvent, our_pubkey: String, contacts: Contacts) -> Bool
{
if ev.pubkey == our_pubkey {
return true
}
if contacts.is_friend(ev.pubkey) {
return true
}
if ev.is_reply {
// show our replies?
if ev.pubkey == our_pubkey {
return true
}
for pk in ev.referenced_pubkeys {
if contacts.is_friend(pk.ref_id) {
return true
}
}
}
return false
}

Loading…
Cancel
Save