use super::ids::*; use crate::database::models::DatabaseError; use crate::database::redis::RedisPool; use crate::models::ids::base62_impl::{parse_base62, to_base62}; use crate::models::pats::Scopes; use chrono::{DateTime, Utc}; use serde::{Deserialize, Serialize}; const PATS_NAMESPACE: &str = "pats"; const PATS_TOKENS_NAMESPACE: &str = "pats_tokens"; const PATS_USERS_NAMESPACE: &str = "pats_users"; #[derive(Deserialize, Serialize, Clone, Debug)] pub struct PersonalAccessToken { pub id: PatId, pub name: String, pub access_token: String, pub scopes: Scopes, pub user_id: UserId, pub created: DateTime, pub expires: DateTime, pub last_used: Option>, } impl PersonalAccessToken { pub async fn insert( &self, transaction: &mut sqlx::Transaction<'_, sqlx::Postgres>, ) -> Result<(), DatabaseError> { sqlx::query!( " INSERT INTO pats ( id, name, access_token, scopes, user_id, expires ) VALUES ( $1, $2, $3, $4, $5, $6 ) ", self.id as PatId, self.name, self.access_token, self.scopes.bits() as i64, self.user_id as UserId, self.expires ) .execute(&mut **transaction) .await?; Ok(()) } pub async fn get<'a, E, T: ToString>( id: T, exec: E, redis: &RedisPool, ) -> Result, DatabaseError> where E: sqlx::Executor<'a, Database = sqlx::Postgres>, { Self::get_many(&[id], exec, redis) .await .map(|x| x.into_iter().next()) } pub async fn get_many_ids<'a, E>( pat_ids: &[PatId], exec: E, redis: &RedisPool, ) -> Result, DatabaseError> where E: sqlx::Executor<'a, Database = sqlx::Postgres>, { let ids = pat_ids .iter() .map(|x| crate::models::ids::PatId::from(*x)) .collect::>(); PersonalAccessToken::get_many(&ids, exec, redis).await } pub async fn get_many<'a, E, T: ToString>( pat_strings: &[T], exec: E, redis: &RedisPool, ) -> Result, DatabaseError> where E: sqlx::Executor<'a, Database = sqlx::Postgres>, { use futures::TryStreamExt; let mut redis = redis.connect().await?; if pat_strings.is_empty() { return Ok(Vec::new()); } let mut found_pats = Vec::new(); let mut remaining_strings = pat_strings .iter() .map(|x| x.to_string()) .collect::>(); let mut pat_ids = pat_strings .iter() .flat_map(|x| parse_base62(&x.to_string()).map(|x| x as i64)) .collect::>(); pat_ids.append( &mut redis .multi_get::( PATS_TOKENS_NAMESPACE, pat_strings.iter().map(|x| x.to_string()), ) .await? .into_iter() .flatten() .collect(), ); if !pat_ids.is_empty() { let pats = redis .multi_get::(PATS_NAMESPACE, pat_ids.iter().map(|x| x.to_string())) .await?; for pat in pats { if let Some(pat) = pat.and_then(|x| serde_json::from_str::(&x).ok()) { remaining_strings .retain(|x| &to_base62(pat.id.0 as u64) != x && &pat.access_token != x); found_pats.push(pat); continue; } } } if !remaining_strings.is_empty() { let pat_ids_parsed: Vec = remaining_strings .iter() .flat_map(|x| parse_base62(&x.to_string()).ok()) .map(|x| x as i64) .collect(); let db_pats: Vec = sqlx::query!( " SELECT id, name, access_token, scopes, user_id, created, expires, last_used FROM pats WHERE id = ANY($1) OR access_token = ANY($2) ORDER BY created DESC ", &pat_ids_parsed, &remaining_strings .into_iter() .map(|x| x.to_string()) .collect::>(), ) .fetch_many(exec) .try_filter_map(|e| async { Ok(e.right().map(|x| PersonalAccessToken { id: PatId(x.id), name: x.name, access_token: x.access_token, scopes: Scopes::from_bits(x.scopes as u64).unwrap_or(Scopes::NONE), user_id: UserId(x.user_id), created: x.created, expires: x.expires, last_used: x.last_used, })) }) .try_collect::>() .await?; for pat in db_pats { redis .set_serialized_to_json(PATS_NAMESPACE, pat.id.0, &pat, None) .await?; redis .set( PATS_TOKENS_NAMESPACE, &pat.access_token, &pat.id.0.to_string(), None, ) .await?; found_pats.push(pat); } } Ok(found_pats) } pub async fn get_user_pats<'a, E>( user_id: UserId, exec: E, redis: &RedisPool, ) -> Result, DatabaseError> where E: sqlx::Executor<'a, Database = sqlx::Postgres>, { let mut redis = redis.connect().await?; let res = redis .get_deserialized_from_json::>(PATS_USERS_NAMESPACE, &user_id.0.to_string()) .await?; if let Some(res) = res { return Ok(res.into_iter().map(PatId).collect()); } use futures::TryStreamExt; let db_pats: Vec = sqlx::query!( " SELECT id FROM pats WHERE user_id = $1 ORDER BY created DESC ", user_id.0, ) .fetch_many(exec) .try_filter_map(|e| async { Ok(e.right().map(|x| PatId(x.id))) }) .try_collect::>() .await?; redis .set( PATS_USERS_NAMESPACE, &user_id.0.to_string(), &serde_json::to_string(&db_pats)?, None, ) .await?; Ok(db_pats) } pub async fn clear_cache( clear_pats: Vec<(Option, Option, Option)>, redis: &RedisPool, ) -> Result<(), DatabaseError> { let mut redis = redis.connect().await?; if clear_pats.is_empty() { return Ok(()); } redis .delete_many(clear_pats.into_iter().flat_map(|(id, token, user_id)| { [ (PATS_NAMESPACE, id.map(|i| i.0.to_string())), (PATS_TOKENS_NAMESPACE, token), (PATS_USERS_NAMESPACE, user_id.map(|i| i.0.to_string())), ] })) .await?; Ok(()) } pub async fn remove( id: PatId, transaction: &mut sqlx::Transaction<'_, sqlx::Postgres>, ) -> Result, sqlx::error::Error> { sqlx::query!( " DELETE FROM pats WHERE id = $1 ", id as PatId, ) .execute(&mut **transaction) .await?; Ok(Some(())) } }