feat(users): user wf tests

Author: abcxff

Cargo.lock

@@ -560,6 +560,9 @@ path = "packages/services/external/ops/request-validate"
 [workspace.dependencies.external-worker]
 path = "packages/services/external/worker"
 
+[workspace.dependencies.faker]
+path = "packages/services/faker"
+
 [workspace.dependencies.faker-build]
 path = "packages/services/faker/ops/build"
 

Cargo.toml

@@ -0,0 +1,10 @@
+[package]
+name = "faker"
+version.workspace = true
+authors.workspace = true
+license.workspace = true
+edition.workspace = true
+
+[dependencies]
+chirp-workflow.workspace = true
+user.workspace = true

packages/services/faker/Cargo.toml

@@ -0,0 +1 @@
+pub mod ops;

packages/services/faker/src/lib.rs

@@ -0,0 +1 @@
+pub mod user;

packages/services/faker/src/ops/mod.rs

@@ -0,0 +1,36 @@
+use chirp_workflow::prelude::*;
+
+#[derive(Debug, Default)]
+pub struct Input {}
+
+#[derive(Debug)]
+pub struct Output {
+	pub user_id: Uuid,
+}
+
+#[operation]
+pub async fn user(ctx: &OperationCtx, input: &Input) -> GlobalResult<Output>  {
+	let user_id = Uuid::new_v4();
+
+    let mut creation_sub = chirp_workflow::compat::subscribe::<
+        user::workflows::user::CreateComplete, _
+    >(&ctx.op_ctx(), ("user_id", user_id)).await?;
+
+    chirp_workflow::compat::workflow(
+        &ctx.op_ctx(),
+        user::workflows::user::Input {
+            user_id,
+            display_name: None,
+        }
+    )
+    .await?
+	.tag("user_id", user_id)
+	.dispatch()
+	.await?;
+
+    creation_sub.next().await?;
+
+	Ok(Output {
+		user_id: user_id,
+	})
+}

packages/services/faker/src/ops/user.rs

@@ -0,0 +1,14 @@
+use chirp_workflow::prelude::*;
+
+#[workflow_test]
+async fn empty(ctx: TestCtx) {
+	let res = ctx.op(faker::ops::user::Input {}).await.unwrap();
+
+	let get_res = ctx.op(::user::ops::get::Input {
+		user_ids: vec![res.user_id],
+	})
+	.await
+	.unwrap();
+
+	assert_eq!(1, get_res.users.len(), "user not created");
+}

packages/services/faker/tests/user.rs

@@ -17,3 +17,4 @@ job-run.workspace = true
 linode.workspace = true
 pegboard.workspace = true
 rivet-config.workspace = true
+user.workspace = true

packages/services/monolith/standalone/workflow-worker/Cargo.toml

@@ -15,7 +15,8 @@ pub async fn run_from_env(
 		.merge(linode::registry()?)?
 		.merge(ds::registry()?)?
 		.merge(job_run::registry()?)?
-		.merge(pegboard::registry()?)?;
+		.merge(pegboard::registry()?)?
+		.merge(user::registry()?)?;
 
 	let db = db::DatabaseCrdbNats::from_pools(pools.crdb()?, pools.nats()?);
 	let worker = Worker::new(reg.handle(), db);

packages/services/monolith/standalone/workflow-worker/src/lib.rs

@@ -32,4 +32,6 @@ default-features = false
 faker-user.workspace = true
 reqwest = "0.11"
 upload-get.workspace = true
-upload-prepare.workspace = true
+upload-prepare.workspace = true
+
+faker.workspace = true