-
Notifications
You must be signed in to change notification settings - Fork 14
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge pull request #1507 from planetary-social/bdm/80
added support for NIP-62 Request to Vanish events #80
- Loading branch information
Showing
8 changed files
with
307 additions
and
201 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,27 @@ | ||
| import Foundation | ||
|
|
||
| extension JSONEvent { | ||
|
|
||
| /// An event that represents the user's request for all of their published notes to be removed from relays. | ||
| /// - Parameters: | ||
| /// - pubKey: The public key of the user making the request. | ||
| /// - relays: The relays to request removal from. Note: A nil or empty relay array will be interpreted to mean | ||
| /// that the user seeks removal from all relays. | ||
| /// - reason: The reason the user wishes to have their content removed. Optional. | ||
| /// - Returns: The ``JSONEvent`` representing the request. | ||
| static func requestToVanish(pubKey: String, relays: [URL]? = nil, reason: String? = nil) -> JSONEvent { | ||
| let tags: [[String]] | ||
| if let relays, !relays.isEmpty { | ||
| tags = relays.map { ["relay", $0.absoluteString] } | ||
| } else { | ||
| tags = [["relay", "ALL_RELAYS"]] | ||
| } | ||
|
|
||
| return JSONEvent( | ||
| pubKey: pubKey, | ||
| kind: .requestToVanish, | ||
| tags: tags, | ||
| content: reason ?? "" | ||
| ) | ||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,225 @@ | ||
| import Foundation | ||
| import Logger | ||
|
|
||
| extension CurrentUser { | ||
|
|
||
| /// Builds a dictionary to be used as content when publishing a kind 0 | ||
| /// event. | ||
| private func buildMetadataJSONObject(author: Author) -> [String: String] { | ||
| var metaEvent = MetadataEventJSON( | ||
| displayName: author.displayName, | ||
| name: author.name, | ||
| nip05: author.nip05, | ||
| uns: author.uns, | ||
| about: author.about, | ||
| website: author.website, | ||
| picture: author.profilePhotoURL?.absoluteString | ||
| ).dictionary | ||
| if let rawData = author.rawMetadata { | ||
| // Tack on any unsupported fields back onto the dictionary before | ||
| // publish. | ||
| do { | ||
| let rawJson = try JSONSerialization.jsonObject(with: rawData) | ||
| if let rawDictionary = rawJson as? [String: AnyObject] { | ||
| for key in rawDictionary.keys { | ||
| guard metaEvent[key] == nil else { | ||
| continue | ||
| } | ||
| if let rawValue = rawDictionary[key] as? String { | ||
| metaEvent[key] = rawValue | ||
| Log.debug("Added \(key) : \(rawValue)") | ||
| } | ||
| } | ||
| } | ||
| } catch { | ||
| Log.debug("Couldn't parse a JSON from the user raw metadata") | ||
| // Continue with the metaEvent object we built previously | ||
| } | ||
| } | ||
| return metaEvent | ||
| } | ||
|
|
||
| @MainActor func publishMetadata() async throws { | ||
| guard let pubKey = publicKeyHex else { | ||
| Log.debug("Error: no publicKeyHex") | ||
| throw CurrentUserError.authorNotFound | ||
| } | ||
| guard let pair = keyPair else { | ||
| Log.debug("Error: no keyPair") | ||
| throw CurrentUserError.authorNotFound | ||
| } | ||
| guard let context = viewContext else { | ||
| Log.debug("Error: no context") | ||
| throw CurrentUserError.authorNotFound | ||
| } | ||
| guard let author = try Author.find(by: pubKey, context: context) else { | ||
| Log.debug("Error: no author in DB") | ||
| throw CurrentUserError.authorNotFound | ||
| } | ||
|
|
||
| self.author = author | ||
|
|
||
| let jsonObject = buildMetadataJSONObject(author: author) | ||
| let data = try JSONSerialization.data(withJSONObject: jsonObject) | ||
| let content = String(decoding: data, as: UTF8.self) | ||
|
|
||
| let jsonEvent = JSONEvent( | ||
| pubKey: pubKey, | ||
| kind: .metaData, | ||
| tags: [], | ||
| content: content | ||
| ) | ||
|
|
||
| do { | ||
| try await relayService.publishToAll( | ||
| event: jsonEvent, | ||
| signingKey: pair, | ||
| context: viewContext | ||
| ) | ||
| } catch { | ||
| Log.error(error.localizedDescription) | ||
| throw CurrentUserError.errorWhilePublishingToRelays | ||
| } | ||
| } | ||
|
|
||
| @MainActor func publishMuteList(keys: [String]) async { | ||
| guard let pubKey = publicKeyHex else { | ||
| Log.debug("Error: no pubKey") | ||
| return | ||
| } | ||
|
|
||
| let jsonEvent = JSONEvent(pubKey: pubKey, kind: .mute, tags: keys.pTags, content: "") | ||
|
|
||
| if let pair = keyPair { | ||
| do { | ||
| try await relayService.publishToAll(event: jsonEvent, signingKey: pair, context: viewContext) | ||
| } catch { | ||
| Log.debug("Failed to update mute list \(error.localizedDescription)") | ||
| } | ||
| } | ||
| } | ||
|
|
||
| @MainActor func publishDelete(for identifiers: [String], reason: String = "") async { | ||
| guard let pubKey = publicKeyHex else { | ||
| Log.debug("Error: no pubKey") | ||
| return | ||
| } | ||
|
|
||
| let tags = identifiers.eTags | ||
| let jsonEvent = JSONEvent(pubKey: pubKey, kind: .delete, tags: tags, content: reason) | ||
|
|
||
| if let pair = keyPair { | ||
| do { | ||
| try await relayService.publishToAll(event: jsonEvent, signingKey: pair, context: viewContext) | ||
| } catch { | ||
| Log.debug("Failed to delete events \(error.localizedDescription)") | ||
| } | ||
| } | ||
| } | ||
|
|
||
| @MainActor func publishContactList(tags: [[String]]) async { | ||
| guard let pubKey = publicKeyHex else { | ||
| Log.debug("Error: no pubKey") | ||
| return | ||
| } | ||
|
|
||
| guard let relays = author?.relays else { | ||
| Log.debug("Error: No relay service") | ||
| return | ||
| } | ||
|
|
||
| var relayString = "{" | ||
| for relay in relays { | ||
| if let address = relay.address { | ||
| relayString += "\"\(address)\":{\"write\":true,\"read\":true}," | ||
| } | ||
| } | ||
| relayString.removeLast() | ||
| relayString += "}" | ||
|
|
||
| let jsonEvent = JSONEvent(pubKey: pubKey, kind: .contactList, tags: tags, content: relayString) | ||
|
|
||
| if let pair = keyPair { | ||
| do { | ||
| try await relayService.publishToAll(event: jsonEvent, signingKey: pair, context: viewContext) | ||
| } catch { | ||
| Log.debug("failed to update Follows \(error.localizedDescription)") | ||
| } | ||
| } | ||
| } | ||
|
|
||
| /// Follow by public hex key | ||
| @MainActor func follow(author toFollow: Author) async throws { | ||
| guard let followKey = toFollow.hexadecimalPublicKey else { | ||
| Log.debug("Error: followKey is nil") | ||
| return | ||
| } | ||
|
|
||
| Log.debug("Following \(followKey)") | ||
|
|
||
| var followKeys = await Array(socialGraph.followedKeys) | ||
| followKeys.append(followKey) | ||
|
|
||
| // Update author to add the new follow | ||
| if let followedAuthor = try? Author.find(by: followKey, context: viewContext), let currentUser = author { | ||
| let follow = try Follow.findOrCreate( | ||
| source: currentUser, | ||
| destination: followedAuthor, | ||
| context: viewContext | ||
| ) | ||
|
|
||
| // Add to the current user's follows | ||
| currentUser.follows.insert(follow) | ||
| } | ||
|
|
||
| try viewContext.save() | ||
| await publishContactList(tags: followKeys.pTags) | ||
| } | ||
|
|
||
| /// Unfollow by public hex key | ||
| @MainActor func unfollow(author toUnfollow: Author) async throws { | ||
| guard let unfollowedKey = toUnfollow.hexadecimalPublicKey else { | ||
| Log.debug("Error: unfollowedKey is nil") | ||
| return | ||
| } | ||
|
|
||
| Log.debug("Unfollowing \(unfollowedKey)") | ||
|
|
||
| let stillFollowingKeys = await Array(socialGraph.followedKeys) | ||
| .filter { $0 != unfollowedKey } | ||
|
|
||
| // Update author to only follow those still following | ||
| if let unfollowedAuthor = try? Author.find(by: unfollowedKey, context: viewContext), let currentUser = author { | ||
| // Remove from the current user's follows | ||
| let unfollows = Follow.follows(source: currentUser, destination: unfollowedAuthor, context: viewContext) | ||
|
|
||
| for unfollow in unfollows { | ||
| // Remove current user's follows | ||
| currentUser.follows.remove(unfollow) | ||
| } | ||
| } | ||
|
|
||
| try viewContext.save() | ||
| await publishContactList(tags: stillFollowingKeys.pTags) | ||
| } | ||
|
|
||
| @MainActor func publishRequestToVanish(to relays: [URL]? = nil, reason: String? = nil) async throws { | ||
| guard let keyPair else { | ||
| Log.debug("Error: no key pair") | ||
| return | ||
| } | ||
|
|
||
| let pubKey = keyPair.publicKey.hex | ||
| let jsonEvent = JSONEvent.requestToVanish(pubKey: pubKey, relays: relays, reason: reason) | ||
|
|
||
| do { | ||
| if let relays, !relays.isEmpty { | ||
| try await relayService.publish(event: jsonEvent, to: relays, signingKey: keyPair, context: viewContext) | ||
| } else { | ||
| try await relayService.publishToAll(event: jsonEvent, signingKey: keyPair, context: viewContext) | ||
| } | ||
| } catch { | ||
| Log.debug("Failed to publish request to vanish \(error.localizedDescription)") | ||
| } | ||
| } | ||
| } |
Oops, something went wrong.