chore(engine): move smoke test to engine/tests/ (#3337)

Author: NathanFlurry

engine/tests/load/package.json

@@ -1,5 +1,5 @@
 {
-	"name": "@rivet/load-tests",
+	"name": "test-load",
 	"private": true,
 	"scripts": {
 		"build": "tsc",

examples/smoke-test/.gitignore renamed to engine/tests/smoke/.gitignore

@@ -1,11 +1,5 @@
 # Smoke Test for RivetKit
 
-Example project demonstrating a simple getOrCreate smoke test with [RivetKit](https://rivetkit.org).
-
-[Learn More →](https://github.com/rivet-dev/rivetkit)
-
-[Discord](https://rivet.dev/discord) — [Documentation](https://rivetkit.org) — [Issues](https://github.com/rivet-dev/rivetkit/issues)
-
 ## Getting Started
 
 ### Prerequisites
@@ -34,6 +28,5 @@ npm run smoke
 
 Set `TOTAL_ACTOR_COUNT` and `SPAWN_ACTOR_INTERVAL` environment variables to adjust the workload.
 
-## License
+Set `BEHAVIOR` to change the test type.
 
-Apache 2.0

examples/smoke-test/README.md renamed to engine/tests/smoke/README.md

@@ -1,5 +1,5 @@
 {
-	"name": "example-smoke-test",
+	"name": "test-smoke",
 	"version": "2.0.21",
 	"private": true,
 	"type": "module",

examples/smoke-test/package.json renamed to engine/tests/smoke/package.json

@@ -7,6 +7,12 @@ const counter = actor({
 	state: {
 		count: 0,
 	},
+	onStart: async () => {
+		await new Promise((resolve) => setTimeout(resolve, 1000));
+	},
+	onStop: async () => {
+		await new Promise((resolve) => setTimeout(resolve, 1000));
+	},
 	actions: {
 		increment: (c, x: number) => {
 			c.state.count += x;

examples/smoke-test/scripts/connect.ts renamed to engine/tests/smoke/scripts/connect.ts

@@ -33,7 +33,7 @@ export async function spawnActor(opts: SpawnActorOptions): Promise<void> {
 	}
 }
 
-export async function spawnActorSleepCycle({
+export async function spawnActorHttp({
 	client,
 	index,
 	testId,
@@ -52,15 +52,14 @@ export async function spawnActorSleepCycle({
 		const iterationDuration = iterationEnd - iterationStart;
 		iterationDurations.push(iterationDuration);
 
-		succeeded = true;
 		onSuccess();
 	} catch (error) {
 		errors.push({ index, error });
 		onFailure();
 	}
 }
 
-export async function spawnActorHttp({
+export async function spawnActorSleepCycle({
 	client,
 	index,
 	testId,
@@ -89,6 +88,13 @@ export async function spawnActorHttp({
 			const iterationEnd = performance.now();
 			const iterationDuration = iterationEnd - iterationStart;
 			iterationDurations.push(iterationDuration);
+
+			// Wait for actor to sleep
+			// const sleepTime = 1_100 + Math.random() * 800;
+			const sleepTime = Math.random() * 2500;
+			console.log("sleeping", sleepTime);
+			// const sleepTime = 1000;
+			await new Promise((res) => setTimeout(res, sleepTime));
 		}
 
 		succeeded = true;