Skip to content

Commit c298cf6

Browse files
committed
chore(rivetkit): rename onstart/onstop to onwake/onsleep
1 parent 47cb55f commit c298cf6

File tree

12 files changed

+50
-50
lines changed

12 files changed

+50
-50
lines changed

examples/crdt/src/backend/registry.ts

Lines changed: 1 addition & 1 deletion
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

examples/game/src/backend/registry.ts

Lines changed: 2 additions & 2 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

examples/kitchen-sink/SPEC.md

Lines changed: 4 additions & 4 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

examples/kitchen-sink/src/backend/actors/demo.ts

Lines changed: 2 additions & 2 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

rivetkit-typescript/packages/rivetkit/fixtures/driver-test-suite/lifecycle.ts

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -10,8 +10,8 @@ export const counterWithLifecycle = actor({
1010
createConnState: (c, opts, params: ConnParams) => ({
1111
joinTime: Date.now(),
1212
}),
13-
onStart: (c) => {
14-
c.state.events.push("onStart");
13+
onWake: (c) => {
14+
c.state.events.push("onWake");
1515
},
1616
onBeforeConnect: (c, opts, params: ConnParams) => {
1717
if (params?.trackLifecycle) c.state.events.push("onBeforeConnect");

rivetkit-typescript/packages/rivetkit/fixtures/driver-test-suite/metadata.ts

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -11,7 +11,7 @@ export const metadataActor = actor({
1111
storedTags: {} as Record<string, string>,
1212
storedRegion: null as string | null,
1313
},
14-
onStart: (c) => {
14+
onWake: (c) => {
1515
// Store the actor name during initialization
1616
c.state.actorName = c.name;
1717
},
@@ -62,7 +62,7 @@ export const metadataActor = actor({
6262
return c.state.storedRegion;
6363
},
6464

65-
// Get the stored actor name (from onStart)
65+
// Get the stored actor name (from onWake)
6666
getStoredActorName: (c) => {
6767
return c.state.actorName;
6868
},

rivetkit-typescript/packages/rivetkit/fixtures/driver-test-suite/sleep.ts

Lines changed: 10 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -5,10 +5,10 @@ export const SLEEP_TIMEOUT = 1000;
55

66
export const sleep = actor({
77
state: { startCount: 0, sleepCount: 0 },
8-
onStart: (c) => {
8+
onWake: (c) => {
99
c.state.startCount += 1;
1010
},
11-
onStop: (c) => {
11+
onSleep: (c) => {
1212
c.state.sleepCount += 1;
1313
},
1414
actions: {
@@ -37,10 +37,10 @@ export const sleepWithLongRpc = actor({
3737
state: { startCount: 0, sleepCount: 0 },
3838
createVars: () =>
3939
({}) as { longRunningResolve: PromiseWithResolvers<void> },
40-
onStart: (c) => {
40+
onWake: (c) => {
4141
c.state.startCount += 1;
4242
},
43-
onStop: (c) => {
43+
onSleep: (c) => {
4444
c.state.sleepCount += 1;
4545
},
4646
actions: {
@@ -66,10 +66,10 @@ export const sleepWithLongRpc = actor({
6666

6767
export const sleepWithRawHttp = actor({
6868
state: { startCount: 0, sleepCount: 0, requestCount: 0 },
69-
onStart: (c) => {
69+
onWake: (c) => {
7070
c.state.startCount += 1;
7171
},
72-
onStop: (c) => {
72+
onSleep: (c) => {
7373
c.state.sleepCount += 1;
7474
},
7575
onFetch: async (c, request) => {
@@ -106,10 +106,10 @@ export const sleepWithRawHttp = actor({
106106

107107
export const sleepWithRawWebSocket = actor({
108108
state: { startCount: 0, sleepCount: 0, connectionCount: 0 },
109-
onStart: (c) => {
109+
onWake: (c) => {
110110
c.state.startCount += 1;
111111
},
112-
onStop: (c) => {
112+
onSleep: (c) => {
113113
c.state.sleepCount += 1;
114114
},
115115
onWebSocket: (c, websocket: UniversalWebSocket, opts) => {
@@ -175,10 +175,10 @@ export const sleepWithRawWebSocket = actor({
175175

176176
export const sleepWithNoSleepOption = actor({
177177
state: { startCount: 0, sleepCount: 0 },
178-
onStart: (c) => {
178+
onWake: (c) => {
179179
c.state.startCount += 1;
180180
},
181-
onStop: (c) => {
181+
onSleep: (c) => {
182182
c.state.sleepCount += 1;
183183
},
184184
actions: {

rivetkit-typescript/packages/rivetkit/src/actor/config.ts

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -38,8 +38,8 @@ export interface ActorTypes<
3838
export const ActorConfigSchema = z
3939
.object({
4040
onCreate: z.function().optional(),
41-
onStart: z.function().optional(),
42-
onStop: z.function().optional(),
41+
onWake: z.function().optional(),
42+
onSleep: z.function().optional(),
4343
onStateChange: z.function().optional(),
4444
onBeforeConnect: z.function().optional(),
4545
onConnect: z.function().optional(),
@@ -255,7 +255,7 @@ interface BaseActorConfig<
255255
*
256256
* @returns Void or a Promise that resolves when startup is complete
257257
*/
258-
onStart?: (
258+
onWake?: (
259259
c: ActorContext<
260260
TState,
261261
TConnParams,
@@ -276,7 +276,7 @@ interface BaseActorConfig<
276276
*
277277
* @returns Void or a Promise that resolves when shutdown is complete
278278
*/
279-
onStop?: (
279+
onSleep?: (
280280
c: ActorContext<
281281
TState,
282282
TConnParams,
@@ -471,7 +471,7 @@ export type ActorConfig<
471471
z.infer<typeof ActorConfigSchema>,
472472
| "actions"
473473
| "onCreate"
474-
| "onStart"
474+
| "onWake"
475475
| "onStateChange"
476476
| "onBeforeConnect"
477477
| "onConnect"
@@ -530,8 +530,8 @@ export type ActorConfigInput<
530530
z.input<typeof ActorConfigSchema>,
531531
| "actions"
532532
| "onCreate"
533-
| "onStart"
534-
| "onStop"
533+
| "onWake"
534+
| "onSleep"
535535
| "onStateChange"
536536
| "onBeforeConnect"
537537
| "onConnect"

rivetkit-typescript/packages/rivetkit/src/actor/instance/mod.ts

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -864,19 +864,19 @@ export class ActorInstance<S, CP, CS, V, I, DB extends AnyDatabaseProvider> {
864864

865865
async #callOnStart() {
866866
this.#rLog.info({ msg: "actor starting" });
867-
if (this.#config.onStart) {
868-
const result = this.#config.onStart(this.actorContext);
867+
if (this.#config.onWake) {
868+
const result = this.#config.onWake(this.actorContext);
869869
if (result instanceof Promise) {
870870
await result;
871871
}
872872
}
873873
}
874874

875875
async #callOnStop() {
876-
if (this.#config.onStop) {
876+
if (this.#config.onSleep) {
877877
try {
878878
this.#rLog.debug({ msg: "calling onStop" });
879-
const result = this.#config.onStop(this.actorContext);
879+
const result = this.#config.onSleep(this.actorContext);
880880
if (result instanceof Promise) {
881881
await deadline(result, this.#config.options.onStopTimeout);
882882
}

rivetkit-typescript/packages/rivetkit/src/driver-test-suite/tests/actor-conn.ts

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -261,7 +261,7 @@ export function runActorConnTests(driverTestConfig: DriverTestConfig) {
261261
// Verify lifecycle events were triggered
262262
const events = await connection.getEvents();
263263
expect(events).toEqual([
264-
"onStart",
264+
"onWake",
265265
"onBeforeConnect",
266266
"onConnect",
267267
]);
@@ -279,18 +279,18 @@ export function runActorConnTests(driverTestConfig: DriverTestConfig) {
279279
expect(finalEvents).toBeOneOf([
280280
// Still active
281281
[
282-
"onStart",
282+
"onWake",
283283
"onBeforeConnect",
284284
"onConnect",
285285
"onDisconnect",
286286
],
287287
// Went to sleep and woke back up
288288
[
289-
"onStart",
289+
"onWake",
290290
"onBeforeConnect",
291291
"onConnect",
292292
"onDisconnect",
293-
"onStart",
293+
"onWake",
294294
],
295295
]);
296296
},

0 commit comments

Comments
 (0)