package endpoints import ( "encoding/json" "fmt" "git.dragse.it/anthrove/e621-to-graph/internal/utils" "git.dragse.it/anthrove/e621-to-graph/pkg/e621/model" "log" "net/http" ) func GetPost(client http.Client, requestContext model.RequestContext, ID string) (model.Post, error) { // Create a new HTTP GET request to fetch user information from the specified 'host' and 'username'. r, err := http.NewRequest("GET", fmt.Sprintf("%s/posts/%s.json", requestContext.Host, ID), nil) if err != nil { // Log the error and return an empty User struct and the error. log.Println(err) return model.Post{}, err } r.Header.Set("User-Agent", requestContext.UserAgent) r.Header.Add("Accept", "application/json") r.SetBasicAuth(requestContext.Username, requestContext.APIKey) // Send the request using the provided HTTP client. resp, err := client.Do(r) if err != nil { // Log the error and return an empty User struct and the error. log.Println(err) return model.Post{}, err } // Check if the HTTP response status code indicates success (2xx range). if resp.StatusCode < 200 || resp.StatusCode > 300 { // If the status code is outside the 2xx range, return an error based on the status code. return model.Post{}, utils.StatusCodesToError(resp.StatusCode) } // Initialize a User struct to store the response data. var PostResponse model.PostResponse // Decode the JSON response into the model.PostResponse{} struct. err = json.NewDecoder(resp.Body).Decode(&PostResponse) if err != nil { // Log the error and return an empty User struct and the error. log.Println(err) return model.Post{}, err } // Return the user information and no error (nil). return PostResponse.Post, nil } func GetPosts(client http.Client, requestContext model.RequestContext, query map[string]string) ([]model.Post, error) { // Create a new HTTP GET request. r, err := http.NewRequest("GET", fmt.Sprintf("%s/posts.json", requestContext.Host), nil) if err != nil { log.Print(err) } // Append query parameters to the request URL. q := r.URL.Query() for k, v := range query { q.Add(k, v) } r.URL.RawQuery = q.Encode() r.Header.Set("User-Agent", requestContext.UserAgent) r.Header.Add("Accept", "application/json") r.SetBasicAuth(requestContext.Username, requestContext.APIKey) // Send the request using the provided HTTP client. resp, err := client.Do(r) if err != nil { log.Print(err) } // Send the request using the provided HTTP client. resp, err = client.Do(r) if err != nil { log.Print(err) } // Check if the HTTP response status code indicates success (2xx range). if resp.StatusCode < 200 || resp.StatusCode > 300 { // If the status code is outside the 2xx range, return an error based on the status code. return nil, utils.StatusCodesToError(resp.StatusCode) } // Initialize a User struct to store the response data. var postResponse model.PostResponse // Decode the JSON response into the user struct. err = json.NewDecoder(resp.Body).Decode(&postResponse) if err != nil { // Log the error and return an empty User struct and the error. log.Println(err) return nil, err } return postResponse.Posts, nil }