15f5d55075
Reviewed-on: https://gitea.coracle.social/coracle/flotilla/pulls/398 Co-authored-by: Coracle-Bot <npub1klq6260@nostr.local>
72 lines
2.3 KiB
TypeScript
72 lines
2.3 KiB
TypeScript
import {
|
|
MESSAGE,
|
|
RELAY_JOIN,
|
|
ROOM_ADD_MEMBER,
|
|
ROOM_CREATE,
|
|
ROOM_EDIT_META,
|
|
makeEvent,
|
|
} from "@welshman/util"
|
|
import type {SignedEvent, StampedEvent} from "@welshman/util"
|
|
import {users} from "../keys"
|
|
import type {TestUser} from "../keys"
|
|
import type {PublishOptions, TestRelay} from "./types"
|
|
|
|
export type TestRelayOptions = {
|
|
name: string
|
|
url: string
|
|
publish: (event: SignedEvent, options?: PublishOptions) => Promise<void>
|
|
}
|
|
|
|
// Seeding signs the events a real client would send and publishes them over a socket. Room
|
|
// administration is signed by `admin`, the only test identity the tomls grant can_manage.
|
|
//
|
|
// Every timestamp is the caller's. Reading the wall clock here would stamp two fixtures that
|
|
// describe the same thing seconds apart, which is enough to decide which of them wins.
|
|
export const makeTestRelay = ({name, url, publish}: TestRelayOptions): TestRelay => {
|
|
const event = async (user: TestUser, template: StampedEvent) => {
|
|
const signed = await user.signer.sign(template)
|
|
|
|
await publish(signed)
|
|
|
|
return signed
|
|
}
|
|
|
|
return {
|
|
name,
|
|
url,
|
|
event,
|
|
publish,
|
|
room: async (h, meta, createdAt) => {
|
|
// A relay stamps the metadata it derives from these ops with the op's own created_at, so
|
|
// creation has to be strictly older than the edit or the edit is dropped as stale.
|
|
await event(
|
|
users.admin,
|
|
makeEvent(ROOM_CREATE, {tags: [["h", h]], created_at: createdAt - 1}),
|
|
)
|
|
|
|
const tags = [["h", h]]
|
|
|
|
if (meta.name) tags.push(["name", meta.name])
|
|
if (meta.about) tags.push(["about", meta.about])
|
|
if (meta.picture) tags.push(["picture", meta.picture])
|
|
if (meta.closed) tags.push(["closed"])
|
|
if (meta.private) tags.push(["private"])
|
|
|
|
await event(users.admin, makeEvent(ROOM_EDIT_META, {tags, created_at: createdAt}))
|
|
},
|
|
message: (user, h, content, createdAt) =>
|
|
event(user, makeEvent(MESSAGE, {content, tags: [["h", h]], created_at: createdAt})),
|
|
member: async (user, h, createdAt) => {
|
|
await event(user, makeEvent(RELAY_JOIN, {created_at: createdAt}))
|
|
|
|
if (h) {
|
|
const tags = [
|
|
["h", h],
|
|
["p", user.pubkey],
|
|
]
|
|
|
|
await event(users.admin, makeEvent(ROOM_ADD_MEMBER, {tags, created_at: createdAt}))
|
|
}
|
|
},
|
|
}
|
|
}
|