Differential D11406 Diff 38504 services/identity/src/database/farcaster.rs

Changeset View

Standalone View

Show First 20 Lines • Show All 49 Lines • ▼ Show 20 Lines	for id in farcaster_ids {
.map_err(Error::from)?;		.map_err(Error::from)?;
if let Some(data) = query_response {		if let Some(data) = query_response {
users.push(data);		users.push(data);
}		}
}		}

Ok(users)		Ok(users)
}		}

		pub async fn add_farcaster_id(
		&self,
		user_id: String,
		farcaster_id: String,
		) -> Result<(), Error> {
		let update_expression =
		format!("SET {} = :val", USERS_TABLE_FARCASTER_ID_ATTRIBUTE_NAME);

		self
		.client
		.update_item()
		.table_name(USERS_TABLE)
		.key(USERS_TABLE_PARTITION_KEY, AttributeValue::S(user_id))
		.update_expression(update_expression)
		.expression_attribute_values(":val", AttributeValue::S(farcaster_id))
		.send()
		.await
		.map_err(\|e\| Error::AwsSdk(e.into()))?;

		Ok(())
		}
}		}

impl TryFrom<AttributeMap> for FarcasterUserData {		impl TryFrom<AttributeMap> for FarcasterUserData {
type Error = DBItemError;		type Error = DBItemError;

fn try_from(mut attrs: AttributeMap) -> Result<Self, Self::Error> {		fn try_from(mut attrs: AttributeMap) -> Result<Self, Self::Error> {
let user_id = attrs.take_attr(USERS_TABLE_PARTITION_KEY)?;		let user_id = attrs.take_attr(USERS_TABLE_PARTITION_KEY)?;
let maybe_username = attrs.take_attr(USERS_TABLE_USERNAME_ATTRIBUTE)?;		let maybe_username = attrs.take_attr(USERS_TABLE_USERNAME_ATTRIBUTE)?;
Show All 23 Lines