summaryrefslogtreecommitdiff
path: root/bilibili/request.go
diff options
context:
space:
mode:
authorKeuin <[email protected]>2022-09-07 02:48:46 +0800
committerKeuin <[email protected]>2022-09-07 02:48:46 +0800
commit8e15d802865ed57db0018c15ea5559c8bd44c01f (patch)
tree48f4632a1ad044bd7f7f8da3ebe2bb03ab4ca6fe /bilibili/request.go
parent88234ca8fffc4e120adbe0d38071b625ad2f43c7 (diff)
First working version. Just a POC.
Diffstat (limited to 'bilibili/request.go')
-rw-r--r--bilibili/request.go68
1 files changed, 68 insertions, 0 deletions
diff --git a/bilibili/request.go b/bilibili/request.go
new file mode 100644
index 0000000..cb989a7
--- /dev/null
+++ b/bilibili/request.go
@@ -0,0 +1,68 @@
+package bilibili
+
+import (
+ "encoding/json"
+ "io"
+ "log"
+ "net/http"
+ "strings"
+)
+
+// newRequest create an HTTP request with per-instance User-Agent set.
+func (b Bilibili) newRequest(
+ method string,
+ url string,
+ body io.Reader,
+) (req *http.Request, err error) {
+ req, err = http.NewRequestWithContext(b.ctx, method, url, body)
+ if err != nil {
+ b.error.Printf("Cannot create HTTP request instance: %v. Method: %v, URL: %v", err, method, url)
+ return
+ }
+ req.Header.Set("User-Agent", b.userAgent)
+ return
+}
+
+// newRequest create an HTTP GET request with an empty body and per-instance User-Agent set.
+func (b Bilibili) newGet(url string) (req *http.Request, err error) {
+ return b.newRequest("GET", url, strings.NewReader(""))
+}
+
+// callGet make a GET request and parse response as a JSON document with given model.
+func callGet[T BaseResponse[V], V any](b Bilibili, url string) (resp T, err error) {
+ logger := log.Default()
+ req, err := b.newGet(url)
+ if err != nil {
+ logger.Printf("ERROR: Cannot create HTTP request instance on API %v: %v", url, err)
+ return
+ }
+
+ r, err := b.http.Do(req)
+ defer func() { _ = r.Body.Close() }()
+ if err != nil {
+ logger.Printf("ERROR: HTTP Request failed on API %v: %v", url, err)
+ return
+ }
+
+ err = validateHttpStatus(r)
+ if err != nil {
+ b.error.Printf("%v", err)
+ return
+ }
+
+ data, err := io.ReadAll(r.Body)
+ if err != nil {
+ b.error.Printf("Error when reading HTTP response on API %v: %v", url, err)
+ return
+ }
+
+ err = json.Unmarshal(data, &resp)
+ if err != nil {
+ b.error.Printf("Invalid JSON body of HTTP response on API %v: %v. Text: \"%v\"",
+ url, err, string(data))
+ return
+ }
+
+ b.debug.Printf("HTTP %v, len: %v bytes, url: %v", r.StatusCode, len(data), url)
+ return
+}