1use async_trait::async_trait;
2use sqlx::{Error, PgPool};
3use uuid::Uuid;
4
5use crate::model::Commit;
6
7#[async_trait]
8pub trait CommitRepository: Send + Sync + Clone + 'static {
9    async fn create(
10        &self,
11        author_id: Uuid,
12        repo_id: Uuid,
13        sha: &str,
14        message: &str,
15    ) -> Result<Commit, Error>;
16}
17
18#[derive(Debug, Clone)]
19pub struct CommitRepositoryImpl {
20    pool: PgPool,
21}
22
23impl CommitRepositoryImpl {
24    pub fn new(pool: PgPool) -> Self {
25        Self { pool }
26    }
27}
28
29#[async_trait]
30impl CommitRepository for CommitRepositoryImpl {
31    async fn create(
32        &self,
33        author_id: Uuid,
34        repo_id: Uuid,
35        sha: &str,
36        message: &str,
37    ) -> Result<Commit, Error> {
38        let commit = sqlx::query_as::<_, Commit>(
39            r#"
40            INSERT INTO commits (author_id, repo_id, sha, message)
41            VALUES ($1, $2, $3, $4)
42            RETURNING id, author_id, repo_id, sha, message, created_at
43            "#,
44        )
45        .bind(author_id)
46        .bind(repo_id)
47        .bind(sha)
48        .bind(message)
49        .fetch_one(&self.pool)
50        .await?;
51
52        Ok(commit)
53    }
54}
55