chore: publish user-create-complete

svc/api/auth/src/route/identity.rs

@@ -96,14 +96,14 @@ pub async fn complete(
 	}
 
 	let email_res = op!([ctx] user_resolve_email {
-		emails: vec![res.email.clone()]
+		emails: vec![res.email.clone()],
 	})
 	.await?;
 
-	tracing::info!(email = %res.email, "resolved email");
-
 	// Switch to new user
 	if let Some(new_user) = email_res.users.first() {
+		tracing::info!(email = %new_user.email, "resolved email");
+
 		let new_user_id = unwrap_ref!(new_user.user_id).as_uuid();
 
 		tracing::info!(old_user_id = %user_ent.user_id, %new_user_id, "identity found, switching user");

svc/pkg/user-identity/ops/create/src/lib.rs

@@ -78,6 +78,12 @@ async fn handle(
 		.purge("user_identity.identity", [user_id])
 		.await?;
 
+	msg!([ctx] user_identity::msg::create_complete(user_id) {
+		user_id: ctx.user_id,
+		identity: ctx.identity.clone(),
+	})
+	.await?;
+
 	msg!([ctx] user::msg::update(user_id) {
 		user_id: ctx.user_id,
 	})

svc/pkg/user-identity/types/msg/create-complete.proto

@@ -0,0 +1,16 @@
+syntax = "proto3";
+
+package rivet.backend.pkg.user_identity.msg.create_complete;
+
+import "proto/common.proto";
+import "proto/backend/user_identity.proto";
+
+/// name = "msg-user-identity-create-complete"
+/// deduplicate = true
+/// parameters = [
+/// 	{ name = "run_id" },
+/// ]
+message Message {
+	rivet.common.Uuid user_id = 1;
+	rivet.backend.user_identity.Identity identity = 2;
+}