chore(users/pending-delete-toggle): migrate proto ops & refs

packages/api/identity/Cargo.toml

@@ -55,7 +55,6 @@ user.workspace = true
 user-avatar-upload-complete.workspace = true
 user-get.workspace = true
 user-identity-get.workspace = true
-user-pending-delete-toggle.workspace = true
 rivet-config.workspace = true
 rivet-env.workspace = true
 

packages/api/identity/src/route/identities.rs

@@ -306,8 +306,8 @@ pub async fn mark_deletion(
 ) -> GlobalResult<serde_json::Value> {
 	let user_ent = ctx.auth().user(ctx.op_ctx()).await?;
 
-	op!([ctx] user_pending_delete_toggle {
-		user_id: Some(user_ent.user_id.into()),
+	(*ctx).op(::user::ops::pending_delete_toggle::Input {
+		user_id: user_ent.user_id,
 		active: true,
 	})
 	.await?;
@@ -319,8 +319,8 @@ pub async fn mark_deletion(
 pub async fn unmark_deletion(ctx: Ctx<Auth>) -> GlobalResult<serde_json::Value> {
 	let user_ent = ctx.auth().user(ctx.op_ctx()).await?;
 
-	op!([ctx] user_pending_delete_toggle {
-		user_id: Some(user_ent.user_id.into()),
+	(*ctx).op(::user::ops::pending_delete_toggle::Input {
+		user_id: user_ent.user_id,
 		active: false,
 	})
 	.await?;

packages/services/user/Cargo.toml

@@ -16,6 +16,7 @@ rivet-config.workspace = true
 rivet-operation.workspace = true
 token-create.workspace = true
 user-get.workspace = true
+user-identity-get.workspace = true
 
 [dependencies.sqlx]
 workspace = true

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

@@ -1,3 +1,4 @@
+pub mod pending_delete_toggle;
 pub mod profile_validate;
 pub mod resolve_display_name;
 pub mod resolve_email;

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

@@ -0,0 +1,47 @@
+use chirp_workflow::prelude::*;
+use proto::backend::{self, pkg::*};
+use rivet_operation::prelude::proto;
+
+#[derive(Debug)]
+pub struct Input {
+    pub user_id: Uuid,
+    pub active: bool
+}
+
+#[derive(Debug)]
+pub struct Output {
+}
+
+
+#[operation]
+pub async fn pending_delete_toggle(
+    ctx: &OperationCtx,
+    input: &Input
+) -> GlobalResult<Output> {
+	let user_id = input.user_id;
+
+	// Verify the user is registered
+	let identity = op!([ctx] user_identity_get {
+		user_ids: vec![user_id.into()],
+	})
+	.await?;
+	let identities = &unwrap_ref!(identity.users.first()).identities;
+	ensure_with!(!identities.is_empty(), IDENTITY_NOT_REGISTERED);
+
+	sql_execute!(
+		[ctx]
+		"UPDATE db_user.users SET delete_request_ts = $2 WHERE user_id = $1",
+		user_id,
+		input.active.then(util::timestamp::now),
+	)
+	.await?;
+
+	ctx.cache().purge("user", [user_id]).await?;
+
+	msg!([ctx] user::msg::update(user_id) {
+		user_id: Some(user_id.into()),
+	})
+	.await?;
+
+	Ok(Output {})
+}