diff options
Diffstat (limited to 'request_handlers.go')
-rw-r--r-- | request_handlers.go | 130 |
1 files changed, 130 insertions, 0 deletions
diff --git a/request_handlers.go b/request_handlers.go new file mode 100644 index 0000000..2c23afb --- /dev/null +++ b/request_handlers.go @@ -0,0 +1,130 @@ +/* mg - MyAnimeList to Go API wrapper + * Copyright (C) 2023 Vidhu Kant Sharma <vidhukant@vidhukant.com> + + * This program is free software: you can redistribute it and/or modify + * it under the terms of the GNU General Public License as published by + * the Free Software Foundation, either version 3 of the License, or + * (at your option) any later version. + + * This program is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + * GNU General Public License for more details. + + * You should have received a copy of the GNU General Public License + * along with this program. If not, see <https://www.gnu.org/licenses/>. + */ + +package mg + +import ( + "encoding/json" + "net/http" + "net/url" + "strconv" + "strings" + "errors" + "io" +) + +func (c Client) get(endpoint string) ([]byte, error) { + // can safely ignore error with http.NewRequest + req, _ := http.NewRequest(http.MethodGet, endpoint, nil) + + // add authorization headers + // TODO: implement client auth + //req.Header.Add("X-MAL-CLIENT-ID", c.ClientAuth) + req.Header.Add("Authorization", c.MainAuth) + + // send request + res, err := c.httpClient.Do(req) + if err != nil { + return []byte{}, err + } + defer res.Body.Close() + + // read response body + body, err := io.ReadAll(res.Body) + if err != nil { + return body, err + } + + // in case MAL returns error + var e MALError + json.Unmarshal(body, &e) + if e.Err != "" { + return body, errors.New("MyAnimeList Error: " + e.Err + " " + e.Msg) + } + + return body, nil +} + +func (c Client) delete(endpoint string) error { + // can safely ignore error with http.NewRequest + req, _ := http.NewRequest(http.MethodDelete, endpoint, nil) + + // add authorization headers + req.Header.Add("Authorization", c.MainAuth) + + // send request + res, err := c.httpClient.Do(req) + if err != nil { + return err + } + defer res.Body.Close() + + // read response body + body, err := io.ReadAll(res.Body) + if err != nil { + return err + } + + // in case MAL returns error + var e MALError + json.Unmarshal(body, &e) + if e.Err != "" { + return errors.New("MyAnimeList Error: " + e.Err + " " + e.Msg) + } + + // if anime wasn't in the list from the start + if res.StatusCode == 404 { + // TODO: write better error message + return errors.New("anime not in list") + } + + return nil +} + +func (c Client) put(endpoint string, params url.Values) ([]byte, error) { + encodedParams := params.Encode() + + // can safely ignore error with http.NewRequest + req, _ := http.NewRequest(http.MethodPatch, endpoint, strings.NewReader(encodedParams)) + + // add authorization headers + req.Header.Add("Authorization", c.MainAuth) + req.Header.Add("Content-Type", "application/x-www-form-urlencoded") + req.Header.Add("Content-Length", strconv.Itoa(len(encodedParams))) + + // send request + res, err := c.httpClient.Do(req) + if err != nil { + return []byte{}, err + } + defer res.Body.Close() + + // read response body + body, err := io.ReadAll(res.Body) + if err != nil { + return body, err + } + + // in case MAL returns error + var e MALError + json.Unmarshal(body, &e) + if e.Err != "" { + return body, errors.New("MyAnimeList Error: " + e.Err + " " + e.Msg) + } + + return body, nil +} |