feat: add gh repository #1
There are no files selected for viewing
|
There was a problem hiding this comment. This commit adds new dependencies to the project, which are not needed for this PR, consider removing unused libraries. |
|
There was a problem hiding this comment. This commit adds a new dependency, There was a problem hiding this comment. This commit adds new dependencies to the project, which are not needed for this PR, consider removing unused libraries. |
|
There was a problem hiding this comment. This commit adds a new case to the There was a problem hiding this comment. This commit adds a new |
|
There was a problem hiding this comment. This commit changes the type of the There was a problem hiding this comment. The |
|
There was a problem hiding this comment. This commit adds a new file, There was a problem hiding this comment. The |
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,35 @@ | ||
| package github | ||
|
|
||
| import ( | ||
| "codebleu/internal/domain/gitrepo" | ||
| "context" | ||
| "fmt" | ||
| "net/http" | ||
| ) | ||
|
|
||
| type client struct { | ||
| accessToken string | ||
| owner string | ||
| repoSlug string | ||
| httpClient *http.Client | ||
| } | ||
|
|
||
| // PostPullRequestComment implements gitrepo.Repository. | ||
| func (c *client) PostPullRequestComment(ctx context.Context, input gitrepo.PostPullRequestCommentInput) error { | ||
| fmt.Println(input.Comment) | ||
| return nil | ||
| } | ||
|
|
||
| func NewClient( | ||
| owner string, | ||
| repoSlug string, | ||
| accessToken string, | ||
| ) gitrepo.Repository { | ||
| httpClient := &http.Client{} | ||
| return &client{ | ||
| owner: owner, | ||
| repoSlug: repoSlug, | ||
| accessToken: accessToken, | ||
| httpClient: httpClient, | ||
| } | ||
| } |
|
There was a problem hiding this comment. This commit adds a new file, There was a problem hiding this comment. This commit adds the logic for fetching the pull request data from GitHub API. Consider adding tests to ensure its functionality and robustness. |
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,71 @@ | ||
| package github | ||
|
|
||
| import ( | ||
| "codebleu/internal/domain/gitrepo" | ||
| infraHttp "codebleu/internal/infrastructure/http" | ||
| "context" | ||
| "encoding/json" | ||
| "errors" | ||
| "fmt" | ||
| "io" | ||
| "net/http" | ||
| ) | ||
|
|
||
| // GetPullRequest implements gitrepo.Repository. | ||
| func (c *client) GetPullRequest(ctx context.Context, id string) (*gitrepo.PullRequest, error) { | ||
| pullRequest, err := c.getPullRequest(ctx, id) | ||
| if err != nil { | ||
| return nil, err | ||
| } | ||
| diff, err := c.getPullRequestDiff(ctx, id) | ||
| if err != nil { | ||
| return nil, err | ||
| } | ||
| return &gitrepo.PullRequest{ | ||
| Id: id, | ||
| Title: pullRequest.Title, | ||
| Description: pullRequest.Body, | ||
| DiffPatch: diff, | ||
| }, nil | ||
| } | ||
|
|
||
| func (c *client) getPullRequestDiff(ctx context.Context, id string) (string, error) { | ||
| url := fmt.Sprintf("%s/repos/%s/%s/pulls/%s", c.getBaseUrl(), c.owner, c.repoSlug, id) | ||
| req, err := c.buildRequest(ctx, http.MethodGet, url, nil) | ||
| if err != nil { | ||
| return "", err | ||
| } | ||
| req.Header.Add("Accept", "application/vnd.github.v3.diff") | ||
| httpResponse, err := c.httpClient.Do(req) | ||
| if err != nil { | ||
| return "", err | ||
| } | ||
| defer httpResponse.Body.Close() | ||
| body, err := io.ReadAll(httpResponse.Body) | ||
| if err != nil { | ||
| return "", err | ||
| } | ||
| if httpResponse.StatusCode != http.StatusOK { | ||
| return "", infraHttp.NewHttpClientError(fmt.Sprintf("response failed %s", string(body)), url) | ||
| } | ||
| return string(body), nil | ||
| } | ||
|
|
||
| func (c *client) getPullRequest(ctx context.Context, id string) (*PullRequestResponse, error) { | ||
| url := fmt.Sprintf("%s/repos/%s/%s/pulls/%s", c.getBaseUrl(), c.owner, c.repoSlug, id) | ||
| req, err := c.buildRequest(ctx, http.MethodGet, url, nil) | ||
| if err != nil { | ||
| return nil, err | ||
| } | ||
| httpResponse, err := c.httpClient.Do(req) | ||
| if err != nil { | ||
| return nil, err | ||
| } | ||
| defer httpResponse.Body.Close() | ||
| var responseBody *PullRequestResponse | ||
| err = json.NewDecoder(httpResponse.Body).Decode(&responseBody) | ||
| if err != nil { | ||
| return nil, errors.Join(infraHttp.NewHttpClientError("failed decode repsonse", url)) | ||
| } | ||
| return responseBody, nil | ||
| } |
|
There was a problem hiding this comment. This commit adds a new file, There was a problem hiding this comment. The |
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,27 @@ | ||
| package github | ||
|
|
||
| import ( | ||
| infraHttp "codebleu/internal/infrastructure/http" | ||
| "context" | ||
| "errors" | ||
| "fmt" | ||
| "io" | ||
| "net/http" | ||
| ) | ||
|
|
||
| func (c *client) getBaseUrl() string { | ||
| return "https://api.github.com" | ||
| } | ||
|
|
||
| func (c *client) buildRequest(ctx context.Context, method string, requestUrl string, bodyPayload io.Reader) (*http.Request, error) { | ||
| request, err := http.NewRequestWithContext(ctx, method, requestUrl, bodyPayload) | ||
| if err != nil { | ||
| return nil, errors.Join(infraHttp.NewHttpClientError("failed construct request", requestUrl), err) | ||
| } | ||
| if bodyPayload != nil { | ||
| request.Header.Add("Accept", "application/vnd.github+json") | ||
| request.Header.Add("X-GitHub-Api-Version", "2022-11-28") | ||
| } | ||
| request.Header.Add("Authorization", fmt.Sprintf("Bearer %s", c.accessToken)) | ||
| return request, nil | ||
| } |
|
There was a problem hiding this comment. This commit adds a new file, There was a problem hiding this comment. Consider adding documentation to the |
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,7 @@ | ||
| package github | ||
|
|
||
| type PullRequestResponse struct { | ||
| ID int `json:"id"` | ||
| Title string `json:"title"` | ||
| Body string `json:"body"` | ||
| } |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
This commit adds a new dependency,
go.uber.org/goleak, to the project. This dependency is used to detect potential memory leaks in Go code. You can find more information about it here: https://pkg.go.dev/go.uber.org/goleak. It is important to make sure that you are not introducing any new vulnerabilities by adding this dependency. You should review the source code of the dependency, as well as any associated documentation, to make sure that you are comfortable with the security implications of adding it. If you have any concerns, please ask the author of this commit for more information.