Quickstart

import { Actor, Emittable, Persisted, type ActorSocket } from "terse-sdk/actor"

export class Counter extends Actor<{ userId: string }, { by: number }, { count: number }> {
    // Save the count and sync it to connected clients.
    @Persisted
    @Emittable
    count = 0

    async increment(by = 1): Promise<number> {
        this.count += by
        return this.count
    }

    async onMessage(socket: ActorSocket<{ userId: string }, { count: number }>, message: { by: number }): Promise<void> {
        await this.increment(message.by)
        // Send the new count to every connected client.
        this.broadcast({ count: this.count })
    }
}