Something went wrong. Try again.
This repository has no description
Something went wrong. Try again.
5.8 kB · 197 lines
TypeScript
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198import { ChatMessageViewHydrated } from "streamplace";
export enum SystemMessageType { stream_start = "stream_start", stream_end = "stream_end", notification = "notification", command_error = "command_error",}
export interface SystemMessageMetadata { username?: string; action?: string; count?: number; duration?: string; reason?: string; streamerName?: string;}
/** * Creates a system message with the proper structure * @param type The type of system message * @param text The message text * @param metadata Optional metadata for the message * @returns A properly formatted ChatMessageViewHydrated object */let systemMessageCounter = 0;
export const createSystemMessage = ( type: SystemMessageType, text: string, metadata?: SystemMessageMetadata, date: Date = new Date(),): ChatMessageViewHydrated => { const now = date; const uniqueId = `${now.getTime()}-${systemMessageCounter++}`;
return { uri: `at://did:sys:system/place.stream.chat.message/${uniqueId}`, cid: `system-${uniqueId}`, author: { did: "did:sys:system", handle: type as any, // Use handle to specify the type of system message }, record: { text, createdAt: now.toISOString() as any, streamer: "system" as any, $type: "place.stream.chat.message", }, indexedAt: now.toISOString() as any, chatProfile: { color: { red: 128, green: 128, blue: 128 }, // Gray color for system messages $type: "place.stream.chat.profile", }, };};
/** * System message factory functions for common scenarios */export const SystemMessages = { streamStart: (streamerName: string): ChatMessageViewHydrated => createSystemMessage( SystemMessageType.stream_start, `Now streaming - ${streamerName}`, { streamerName, }, ),
// technically, streams can't 'end' on Streamplace // possibly we could use deleting or editing streams (`endedAt` param) for this? streamEnd: (duration?: string): ChatMessageViewHydrated => createSystemMessage( SystemMessageType.stream_end, duration ? `Stream has ended. Duration: ${duration}` : "Stream has ended", { duration }, ),
teleportArrival: ( streamerName: string, streamerDid: string, count: number, chatProfile?: ChatMessageViewHydrated["chatProfile"], teleportUri?: string, ): ChatMessageViewHydrated => { const text = count > 0 ? `${count} viewer${count !== 1 ? "s" : ""} teleported from ${streamerName}'s stream! Say hi!` : `Someone teleported from ${streamerName}'s stream! Say hi!`; const message = createSystemMessage(SystemMessageType.notification, text, { streamerName, count, });
// The live event and the target stream's initial burst can both carry the // same arrival. Use the teleport record as the message identity so chat // reducer deduplication keeps only one announcement. if (teleportUri) { const id = encodeURIComponent(teleportUri); message.uri = `at://did:sys:system/place.stream.chat.message/teleport-${id}` as ChatMessageViewHydrated["uri"]; message.cid = `system-teleport-${id}` as ChatMessageViewHydrated["cid"]; }
// create a mention facet for the streamer name so it gets colored using existing mention rendering if (chatProfile && streamerDid) { const nameStart = text.indexOf(streamerName);
// encode byte positions const encoder = new TextEncoder(); const byteStart = encoder.encode(text.substring(0, nameStart)).length; const byteEnd = byteStart + encoder.encode(streamerName).length;
message.record.facets = [ { index: { byteStart, byteEnd, }, features: [ { $type: "app.bsky.richtext.facet#mention", did: streamerDid as ChatMessageViewHydrated["author"]["did"], }, ], }, ]; }
return message; },
notification: (message: string): ChatMessageViewHydrated => createSystemMessage(SystemMessageType.notification, message),
commandError: (message: string): ChatMessageViewHydrated => createSystemMessage(SystemMessageType.command_error, message),};
/** * Checks if a message is a system message * @param message The message to check * @returns True if the message is a system message */export const isSystemMessage = (message: ChatMessageViewHydrated): boolean => { return message.author.did === "did:sys:system";};
/** * Gets the system message type from a message * @param message The message to check * @returns The system message type or null if not a system message */export const getSystemMessageType = ( message: ChatMessageViewHydrated,): SystemMessageType | null => { if (!isSystemMessage(message)) { return null; } return message.author.handle as SystemMessageType;};
/** * Parses metadata from a system message based on its type * @param message The system message to parse * @returns The parsed metadata */export const parseSystemMessageMetadata = ( message: ChatMessageViewHydrated,): SystemMessageMetadata => { const metadata: SystemMessageMetadata = {}; const type = getSystemMessageType(message); const text = message.record.text;
if (!type) return metadata;
switch (type) { case "stream_end": { const durationMatch = text.match(/Duration:\s*(\d+:\d+(?::\d+)?)/); if (durationMatch) { metadata.duration = durationMatch[1]; } break; }
case "stream_start": { const streamerMatch = text.match(/^(.+?)\s+is now live!/); if (streamerMatch) { metadata.streamerName = streamerMatch[1]; } break; } }
return metadata;};