Differential D11402 Diff 38500 services/identity/src/database/farcaster.rs

Changeset View

Standalone View

services/identity/src/database/farcaster.rs

	use comm_lib::aws::ddb::types::AttributeValue;			use comm_lib::aws::ddb::types::AttributeValue;
	use comm_lib::database::AttributeExtractor;			use comm_lib::database::AttributeExtractor;
	use comm_lib::database::AttributeMap;			use comm_lib::database::AttributeMap;
	use comm_lib::database::DBItemAttributeError;			use comm_lib::database::DBItemAttributeError;
	use comm_lib::database::DBItemError;			use comm_lib::database::DBItemError;
	use comm_lib::database::Value;			use comm_lib::database::Value;
	use grpc_clients::identity::protos::unauth::FarcasterUser;
	use tracing::error;			use tracing::error;

	use crate::constants::USERS_TABLE;			use crate::constants::USERS_TABLE;
	use crate::constants::USERS_TABLE_FARCASTER_ID_ATTRIBUTE_NAME;			use crate::constants::USERS_TABLE_FARCASTER_ID_ATTRIBUTE_NAME;
	use crate::constants::USERS_TABLE_FARCASTER_ID_INDEX;			use crate::constants::USERS_TABLE_FARCASTER_ID_INDEX;
	use crate::constants::USERS_TABLE_PARTITION_KEY;			use crate::constants::USERS_TABLE_PARTITION_KEY;
	use crate::constants::USERS_TABLE_USERNAME_ATTRIBUTE;			use crate::constants::USERS_TABLE_USERNAME_ATTRIBUTE;
	use crate::constants::USERS_TABLE_WALLET_ADDRESS_ATTRIBUTE;			use crate::constants::USERS_TABLE_WALLET_ADDRESS_ATTRIBUTE;
				use crate::grpc_services::protos::unauth::FarcasterUser;

	use super::DatabaseClient;			use super::DatabaseClient;
	use super::Error;			use super::Error;

	struct FarcasterUserData(FarcasterUser);			pub struct FarcasterUserData(pub FarcasterUser);

	impl DatabaseClient {			impl DatabaseClient {
	async fn get_farcaster_users(			pub async fn get_farcaster_users(
	&self,			&self,
	farcaster_ids: Vec<String>,			farcaster_ids: Vec<String>,
	) -> Result<Vec<FarcasterUserData>, Error> {			) -> Result<Vec<FarcasterUserData>, Error> {
	let mut users: Vec<FarcasterUserData> = Vec::new();			let mut users: Vec<FarcasterUserData> = Vec::new();

	for id in farcaster_ids {			for id in farcaster_ids {
	let query_response = self			let query_response = self
	.client			.client
	▲ Show 20 Lines • Show All 57 Lines • Show Last 20 Lines