Class Counter

Durable Object implementation for a real-time Counter. Extends BaseDurableObject to reuse WebSocket logic.

Hierarchy

BaseDurableObject
- Counter

Constructors

constructor

new Counter(state: any, env: any): Counter
Parameters
- state: any
- env: any
Returns Counter
Overrides BaseDurableObject.constructor
- Defined in src/objects/Counter.js:9

Properties

env

env: Env

heartbeatIntervalMs

heartbeatIntervalMs: number

heartbeatTimeoutMs

heartbeatTimeoutMs: number

history

history: any

state

state: DurableObjectState

value

value: any

Methods

alarm

alarm(): Promise<void>
Alarm handler for heartbeat cleanup

Returns Promise<void>
Inherited from BaseDurableObject.alarm
- Defined in src/core/BaseDurableObject.js:110

broadcast

broadcast(message: any, excludeWs?: WebSocket): void
Broadcasts a message to all connected clients
Parameters
- message: any
- OptionalexcludeWs: WebSocket = null
Returns void
Inherited from BaseDurableObject.broadcast
- Defined in src/core/BaseDurableObject.js:67

broadcastUserCount

broadcastUserCount(closingWs?: any): void
Parameters
- closingWs: any = null
Returns void
- Defined in src/objects/Counter.js:113

ensureAlarm

ensureAlarm(): Promise<void>
Ensures an alarm is set for heartbeat cleanup

Returns Promise<void>
Inherited from BaseDurableObject.ensureAlarm
- Defined in src/core/BaseDurableObject.js:55

fetch

fetch(request: any): Promise<Response>
Handle incoming HTTP requests.
Parameters
- request: any
Returns Promise<Response>
- Defined in src/objects/Counter.js:25

getUserCount

getUserCount(excludeWs?: WebSocket): number
Gets current user count
Parameters
- OptionalexcludeWs: WebSocket = null
Returns number
Inherited from BaseDurableObject.getUserCount
- Defined in src/core/BaseDurableObject.js:84

handleDashboard

handleDashboard(): Promise<Response>
Returns Promise<Response>
- Defined in src/objects/Counter.js:120

handleWebSocketUpgrade

handleWebSocketUpgrade(request: Request): Promise<Response>
Common WebSocket upgrade handler
Parameters
- request: Request
Returns Promise<Response>
Inherited from BaseDurableObject.handleWebSocketUpgrade
- Defined in src/core/BaseDurableObject.js:24

jsonResponse

jsonResponse(data: any, indent?: any): Response
Parameters
- data: any
- indent: any = null
Returns Response
- Defined in src/objects/Counter.js:132

onWebSocketConnect

onWebSocketConnect(ws: any): Promise<void>
Hook called when a new WebSocket connects.
Parameters
- ws: any
Returns Promise<void>
- Defined in src/objects/Counter.js:53

onWebSocketDisconnect

onWebSocketDisconnect(ws: any): Promise<void>
Hook called when a WebSocket disconnects.
Parameters
- ws: any
Returns Promise<void>
- Defined in src/objects/Counter.js:66

updateAndBroadcast

updateAndBroadcast(type: any, user?: string): Promise<void>
Business logic: update value and notify subscribers.
Parameters
- type: any
- user: string = CONFIG.DEFAULT_USER
Returns Promise<void>
- Defined in src/objects/Counter.js:90

webSocketClose

webSocketClose(ws: any): Promise<void>
Common close/error handlers
Parameters
- ws: any
Returns Promise<void>
Inherited from BaseDurableObject.webSocketClose
- Defined in src/core/BaseDurableObject.js:140

webSocketError

webSocketError(ws: any): Promise<void>
Parameters
- ws: any
Returns Promise<void>
Inherited from BaseDurableObject.webSocketError
- Defined in src/core/BaseDurableObject.js:146

webSocketMessage

webSocketMessage(ws: any, message: any): Promise<void>
Custom message handler.
Parameters
- ws: any
- message: any
Returns Promise<void>
Overrides BaseDurableObject.webSocketMessage
- Defined in src/objects/Counter.js:73