From f0df4c7297a05bd592d8717b8997284c80fd0500 Mon Sep 17 00:00:00 2001 From: polwex Date: Wed, 17 Sep 2025 15:56:00 +0700 Subject: argh --- front/src/logic/requests/nostril.ts | 139 ----------------------------------- front/src/logic/requests/nostrill.ts | 139 +++++++++++++++++++++++++++++++++++ 2 files changed, 139 insertions(+), 139 deletions(-) delete mode 100644 front/src/logic/requests/nostril.ts create mode 100644 front/src/logic/requests/nostrill.ts (limited to 'front/src/logic/requests') diff --git a/front/src/logic/requests/nostril.ts b/front/src/logic/requests/nostril.ts deleted file mode 100644 index 6f0edcf..0000000 --- a/front/src/logic/requests/nostril.ts +++ /dev/null @@ -1,139 +0,0 @@ -import type Urbit from "urbit-api"; -import type { Cursor, PostID, SentPoast } from "@/types/trill"; -import type { Ship } from "@/types/urbit"; -import { FeedPostCount } from "../constants"; -import type { UserProfile } from "@/types/nostril"; - -// Subscribe -type Handler = (date: any) => void; -export default class IO { - airlock; - constructor(airlock: Urbit) { - this.airlock = airlock; - } - private async poke(json: any) { - return this.airlock.poke({ app: "nostril", mark: "json", json }); - } - private async scry(path: string) { - return this.airlock.scry({ app: "nostril", path }); - } - private async sub(path: string, handler: Handler) { - const err = (err: any, _id: string) => - console.log(err, "error on nostril subscription"); - const quit = (data: any) => - console.log(data, "nostril subscription kicked"); - const res = await this.airlock.subscribe({ - app: "nostril", - path, - event: handler, - err, - quit, - }); - console.log(res, "subscribed to nostril agent"); - } - async unsub(sub: number) { - return await this.airlock.unsubscribe(sub); - } - // subs - async subscribeStore(handler: Handler) { - const res = await this.sub("/ui", handler); - return res; - } - // scries - - async scryFeed(start: Cursor, end: Cursor, desc = true) { - const order = desc ? 1 : 0; - const term = "feed"; - - const path = `/j/feed/${term}/${start}/${end}/${FeedPostCount}/${order}`; - return await this.scry(path); - } - async scryPost( - host: Ship, - id: PostID, - start: Cursor, - end: Cursor, - desc = true, - ) { - const order = desc ? 1 : 0; - - const path = `/j/post/${host}/${id}/${start}/${end}/${FeedPostCount}/${order}`; - return await this.scry(path); - } - // pokes - - async pokeAlive() { - return await this.poke({ alive: true }); - } - async addPost(pubkey: string, content: string) { - const json = { add: { pubkey, content } }; - return this.poke({ post: json }); - } - // async addPost(post: SentPoast, gossip: boolean) { - // const json = { - // "new-post": { - // "sent-post": post, - // gossip, - // }, - // }; - // return this.poke(json); - // } - - async deletePost(id: string) { - const host = `~${this.airlock.ship}`; - const json = { - "del-post": { - ship: host, - id: id, - }, - }; - return this.poke(json); - } - - async addReact(ship: Ship, id: PostID, reaction: string) { - const json = { - "new-react": { - react: reaction, - pid: { - id: id, - ship: ship, - }, - }, - }; - - return this.poke(json); - } - - // follows - async follow(ship: Ship) { - const json = { add: ship }; - return this.poke({ fols: json }); - } - - async unfollow(ship: Ship) { - const json = { del: ship }; - return await this.poke({ fols: json }); - } - // profiles - async createProfile(pubkey: string, profile: UserProfile) { - const json = { add: { pubkey, profile } }; - return await this.poke({ prof: json }); - } - async createKey() { - const json = { add: null }; - return await this.poke({ keys: json }); - } - async removeKey(pubkey: string) { - const json = { del: pubkey }; - return await this.poke({ keys: json }); - } - // relaying - async relayPost(host: string, id: string, relays: string[]) { - const json = { send: { host, id, relays } }; - return await this.poke({ rela: json }); - } -} - -// notifications - -// mark as read diff --git a/front/src/logic/requests/nostrill.ts b/front/src/logic/requests/nostrill.ts new file mode 100644 index 0000000..6334c34 --- /dev/null +++ b/front/src/logic/requests/nostrill.ts @@ -0,0 +1,139 @@ +import type Urbit from "urbit-api"; +import type { Cursor, PostID } from "@/types/trill"; +import type { Ship } from "@/types/urbit"; +import { FeedPostCount } from "../constants"; +import type { UserProfile } from "@/types/nostrill"; + +// Subscribe +type Handler = (date: any) => void; +export default class IO { + airlock; + constructor(airlock: Urbit) { + this.airlock = airlock; + } + private async poke(json: any) { + return this.airlock.poke({ app: "nostrill", mark: "json", json }); + } + private async scry(path: string) { + return this.airlock.scry({ app: "nostrill", path }); + } + private async sub(path: string, handler: Handler) { + const err = (err: any, _id: string) => + console.log(err, "error on nostrill subscription"); + const quit = (data: any) => + console.log(data, "nostrill subscription kicked"); + const res = await this.airlock.subscribe({ + app: "nostrill", + path, + event: handler, + err, + quit, + }); + console.log(res, "subscribed to nostrill agent"); + } + async unsub(sub: number) { + return await this.airlock.unsubscribe(sub); + } + // subs + async subscribeStore(handler: Handler) { + const res = await this.sub("/ui", handler); + return res; + } + // scries + + async scryFeed(start: Cursor, end: Cursor, desc = true) { + const order = desc ? 1 : 0; + const term = "feed"; + + const path = `/j/feed/${term}/${start}/${end}/${FeedPostCount}/${order}`; + return await this.scry(path); + } + async scryPost( + host: Ship, + id: PostID, + start: Cursor, + end: Cursor, + desc = true, + ) { + const order = desc ? 1 : 0; + + const path = `/j/post/${host}/${id}/${start}/${end}/${FeedPostCount}/${order}`; + return await this.scry(path); + } + // pokes + + async pokeAlive() { + return await this.poke({ alive: true }); + } + async addPost(content: string) { + const json = { add: { content } }; + return this.poke({ post: json }); + } + // async addPost(post: SentPoast, gossip: boolean) { + // const json = { + // "new-post": { + // "sent-post": post, + // gossip, + // }, + // }; + // return this.poke(json); + // } + + async deletePost(id: string) { + const host = `~${this.airlock.ship}`; + const json = { + "del-post": { + ship: host, + id: id, + }, + }; + return this.poke(json); + } + + async addReact(ship: Ship, id: PostID, reaction: string) { + const json = { + "new-react": { + react: reaction, + pid: { + id: id, + ship: ship, + }, + }, + }; + + return this.poke(json); + } + + // follows + async follow(ship: Ship) { + const json = { add: ship }; + return this.poke({ fols: json }); + } + + async unfollow(ship: Ship) { + const json = { del: ship }; + return await this.poke({ fols: json }); + } + // profiles + async createProfile(pubkey: string, profile: UserProfile) { + const json = { add: { pubkey, profile } }; + return await this.poke({ prof: json }); + } + async createKey() { + const json = { add: null }; + return await this.poke({ keys: json }); + } + async removeKey(pubkey: string) { + const json = { del: pubkey }; + return await this.poke({ keys: json }); + } + // relaying + async relayPost(host: string, id: string, relays: string[]) { + const json = { send: { host, id, relays } }; + return await this.poke({ rela: json }); + } +} + +// notifications + +// mark as read -- cgit v1.2.3