Spaces:

variphx
/

aic-server

Runtime error

aic-server / src /services /keyframes /mod.rs

add/fix: refactor some error handling and add keyframes semantic search functionalities

a8c4fcf about 1 year ago

812 Bytes

use deadpool_diesel::postgres::Pool;

use crate::{
    models::{dtos::keyframes::KeyframeDto, states::AppState},
    repositories::keyframes::KeyframeRepository,
};

#[derive(Clone, Copy)]
pub struct KeyframeService<'a> {
    pool: &'a Pool,
}

impl<'a> From<&'a AppState> for KeyframeService<'a> {
    fn from(value: &'a AppState) -> Self {
        Self {
            pool: value.diesel_pool(),
        }
    }
}

impl<'a> KeyframeService<'a> {
    pub const fn pool(&self) -> &'a Pool {
        self.pool
    }
}

impl<'a> KeyframeService<'a> {
    pub async fn find_by_id(&self, id: i64) -> anyhow::Result<Option<KeyframeDto>> {
        let repository = KeyframeRepository::from(self);
        Ok(repository
            .find_by_id_and_join_video(id)
            .await?
            .map(Into::into))
    }
}

	use deadpool_diesel::postgres::Pool;

	use crate::{
	models::{dtos::keyframes::KeyframeDto, states::AppState},
	repositories::keyframes::KeyframeRepository,
	};

	#[derive(Clone, Copy)]
	pub struct KeyframeService<'a> {
	pool: &'a Pool,
	}

	impl<'a> From<&'a AppState> for KeyframeService<'a> {
	fn from(value: &'a AppState) -> Self {
	Self {
	pool: value.diesel_pool(),
	}
	}
	}

	impl<'a> KeyframeService<'a> {
	pub const fn pool(&self) -> &'a Pool {
	self.pool
	}
	}

	impl<'a> KeyframeService<'a> {
	pub async fn find_by_id(&self, id: i64) -> anyhow::Result<Option<KeyframeDto>> {
	let repository = KeyframeRepository::from(self);
	Ok(repository
	.find_by_id_and_join_video(id)
	.await?
	.map(Into::into))
	}
	}