Cell - @ry/cells

Constructors

new



Cell(args?: { tenant?: string; id?: string; dbPath?: string; ctlSockPath?: string;  })



ctlClient: Deno.HttpClient

readonly



db: DatabaseSync



id: string



sockets: Map<string, WebSocket>



tenant: string

readonly



workflow: WorkflowRuntime



alarm(cb: () => Promise<void> | void): void



broadcast(message: string
 | ArrayBuffer
 | ArrayBufferView,
without?: string[],
): void



close(cb: (socket: WebSocket,
id: string,
) => Promise<void> | void): void



connect(cb: (socket: WebSocket,
id: string,
) => Promise<void> | void): void



deleteAlarm(id: ScheduledTaskId): boolean



error(cb: (error: Error
 | ErrorEvent
 | Event) => Promise<void> | void): void



getAlarm(id?: ScheduledTaskId): number | null

Get the scheduled time of the next alarm.



getWebSocket(id: string): WebSocket | undefined



getWebSockets(): Iterable<WebSocket>



message(cb: (event: MessageEvent,
socket: WebSocket,
id: string,
) => Promise<void> | void): void



request(cb: (req: Request) => Promise<Response>
 | Response
 | void): void



schedule(task: Task): Promise<ScheduledTaskId>



setAlarm(scheduledTimeUnixMs: number): Promise<ScheduledTaskId>



shutdown(): Promise<never>