chore(user/avatar-upload-complete): migrate ops & refs

packages/api/identity/Cargo.toml

@@ -52,7 +52,6 @@ token-get.workspace = true
 token-revoke.workspace = true
 upload-prepare.workspace = true
 user.workspace = true
-user-avatar-upload-complete.workspace = true
 user-identity-get.workspace = true
 rivet-config.workspace = true
 rivet-env.workspace = true

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

@@ -290,9 +290,9 @@ pub async fn complete_avatar_upload(
 ) -> GlobalResult<serde_json::Value> {
 	let user_ent = ctx.auth().user(ctx.op_ctx()).await?;
 
-	op!([ctx] user_avatar_upload_complete {
-		user_id: Some(user_ent.user_id.into()),
-		upload_id: Some(upload_id.into()),
+	(*ctx).op(::user::ops::avatar_upload_complete::Input {
+		user_id: user_ent.user_id,
+		upload_id: upload_id,
 	})
 	.await?;
 

packages/services/user/Cargo.toml

@@ -17,7 +17,7 @@ rivet-operation.workspace = true
 token-create.workspace = true
 upload-file-list.workspace = true
 upload-get.workspace = true
-user-get.workspace = true
+upload-complete.workspace = true
 user-identity-get.workspace = true
 
 [dependencies.sqlx]

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

@@ -0,0 +1,63 @@
+use chirp_workflow::prelude::*;
+use rivet_operation::prelude::proto;
+use proto::backend::{pkg::*};
+use serde_json::json;
+
+#[derive(Debug)]
+pub struct Input {
+    pub user_id: Uuid,
+    pub upload_id: Uuid,
+}
+
+#[derive(Debug)]
+pub struct Output {}
+
+
+#[operation]
+pub async fn avatar_upload_complete(
+    ctx: &OperationCtx,
+    input: &Input
+) -> GlobalResult<Output> {
+	let user_id = input.user_id;
+
+	op!([ctx] upload_complete {
+		upload_id: Some(input.upload_id.into()),
+		bucket: Some("bucket-user-avatar".into()),
+	})
+	.await?;
+
+	// Set avatar id
+	sql_execute!(
+		[ctx]
+		"
+		UPDATE db_user.users set profile_id = $2
+		WHERE user_id = $1
+		",
+		user_id,
+		input.upload_id,
+	)
+	.await?;
+
+	ctx.cache().purge("user", [user_id]).await?;
+
+	msg!([ctx] user::msg::update(user_id) {
+		user_id: Some(user_id.into()),
+	})
+	.await?;
+
+	msg!([ctx] analytics::msg::event_create() {
+		events: vec![
+			analytics::msg::event_create::Event {
+				event_id: Some(Uuid::new_v4().into()),
+				name: "user.avatar_set".into(),
+				properties_json: Some(serde_json::to_string(&json!({
+					"user_id": user_id,
+				}))?),
+				..Default::default()
+			}
+		],
+	})
+	.await?;
+
+	Ok(Output {})
+}

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

@@ -1,3 +1,4 @@
+pub mod avatar_upload_complete;
 pub mod get;
 pub mod pending_delete_toggle;
 pub mod profile_validate;

packages/services/user/worker/Cargo.toml

@@ -21,7 +21,6 @@ team-get.workspace = true
 team-member-list.workspace = true
 upload-list-for-user.workspace = true
 user.workspace = true
-user-get.workspace = true
 user-identity-delete.workspace = true
 rivet-config.workspace = true