1use async_trait::async_trait;
2
3use crate::client::{GitHttpClient, GitHttpClientImpl};
4use crate::dto::{GitHttpResponse, InfoRefsRequest, ReceivePackRequest, UploadPackRequest};
5use crate::error::GitHttpError;
6
7#[async_trait]
8pub trait GitHttpService: Send + Sync + 'static {
9    async fn info_refs(&self, request: InfoRefsRequest) -> Result<GitHttpResponse, GitHttpError>;
10
11    async fn upload_pack(
12        &self,
13        request: UploadPackRequest,
14    ) -> Result<GitHttpResponse, GitHttpError>;
15
16    async fn receive_pack(
17        &self,
18        request: ReceivePackRequest,
19    ) -> Result<GitHttpResponse, GitHttpError>;
20}
21
22#[derive(Debug, Clone)]
23pub struct GitHttpServiceImpl<G>
24where
25    G: GitHttpClient,
26{
27    git_http_client: G,
28}
29
30impl GitHttpServiceImpl<GitHttpClientImpl> {
31    pub fn new(git_http_client: GitHttpClientImpl) -> Self {
32        Self { git_http_client }
33    }
34}
35
36#[async_trait]
37impl<G> GitHttpService for GitHttpServiceImpl<G>
38where
39    G: GitHttpClient,
40{
41    async fn info_refs(&self, request: InfoRefsRequest) -> Result<GitHttpResponse, GitHttpError> {
42        self.git_http_client
43            .info_refs(&request.owner, &request.repo, &request.service)
44            .await
45    }
46
47    async fn upload_pack(
48        &self,
49        request: UploadPackRequest,
50    ) -> Result<GitHttpResponse, GitHttpError> {
51        self.git_http_client
52            .service_rpc(
53                &request.owner,
54                &request.repo,
55                "upload-pack",
56                &request.content_type,
57                &request.body,
58            )
59            .await
60    }
61
62    async fn receive_pack(
63        &self,
64        request: ReceivePackRequest,
65    ) -> Result<GitHttpResponse, GitHttpError> {
66        // TODO: After successful receive-pack, we can parse the pack data
67        // to extract commit information and persist it in DB (e.g. via CommitRepository)
68        self.git_http_client
69            .service_rpc(
70                &request.owner,
71                &request.repo,
72                "receive-pack",
73                &request.content_type,
74                &request.body,
75            )
76            .await
77    }
78}
79