removed old code

This commit is contained in:
Michael 2022-10-04 03:37:26 +01:00
parent 043db0446b
commit fb01b63b0d
Signed by: michael
GPG Key ID: 523BD9EF68BDD44C
1 changed files with 0 additions and 112 deletions

112
api.go
View File

@ -1,112 +0,0 @@
package request
import (
"fmt"
"io"
"io/ioutil"
"net/http"
"net/url"
"time"
)
// Response API return request
type Response struct {
Method string
StatusCode int
URL *url.URL
Body []byte
}
// Request sends RESTful requests
func Request(method, url string, headers map[string]string, data io.Reader) (*Response, error) {
req, err := http.NewRequest(method, url, data)
if err != nil {
return &Response{method, http.StatusInternalServerError, req.URL, nil}, err
}
for k, v := range headers {
req.Header.Set(k, v)
}
client := &http.Client{Timeout: time.Second * 10}
resp, err := client.Do(req)
if err != nil {
return &Response{method, http.StatusInternalServerError, req.URL, nil}, err
}
body, err := ioutil.ReadAll(resp.Body)
if err != nil {
return &Response{method, http.StatusInternalServerError, req.URL, nil}, err
}
defer resp.Body.Close()
if resp.StatusCode == 200 {
return &Response{method, resp.StatusCode, resp.Request.URL, body}, nil
}
err = fmt.Errorf("request: %s - %d %s", url, resp.StatusCode, http.StatusText(resp.StatusCode))
return &Response{method, resp.StatusCode, resp.Request.URL, nil}, err
}
// Get sends GET request
func Get(url string, headers map[string]string, data io.Reader) (*Response, error) {
resp, err := Request(http.MethodGet, url, headers, data)
if err != nil {
return nil, err
}
return resp, nil
}
// Post sends POST request
func Post(url string, headers map[string]string, data io.Reader) (*Response, error) {
resp, err := Request(http.MethodPost, url, headers, data)
if err != nil {
return nil, err
}
return resp, nil
}
// Put sends PUT request
func Put(url string, headers map[string]string, data io.Reader) (*Response, error) {
resp, err := Request(http.MethodPut, url, headers, data)
if err != nil {
return nil, err
}
return resp, nil
}
// Delete sends DELETE request
func Delete(url string, headers map[string]string, data io.Reader) (*Response, error) {
resp, err := Request(http.MethodDelete, url, headers, data)
if err != nil {
return nil, err
}
return resp, nil
}
// AsyncRequest send requests concurrently
func AsyncRequest(method, url string, headers map[string]string, data io.Reader, ch chan<- *Response, chErr chan<- error, chDone chan<- bool) {
defer func() {
chDone <- true
}()
resp, err := Request(method, url, headers, data)
if err != nil {
chErr <- err
}
ch <- resp
}
// AsyncGet sends GET requests concurrently
func AsyncGet(url string, headers map[string]string, data io.Reader, ch chan<- *Response, chErr chan<- error, chDone chan<- bool) {
AsyncRequest(http.MethodGet, url, headers, data, ch, chErr, chDone)
}
// AsyncPost sends POST requests concurrently
func AsyncPost(url string, headers map[string]string, data io.Reader, ch chan<- *Response, chErr chan<- error, chDone chan<- bool) {
AsyncRequest(http.MethodPost, url, headers, data, ch, chErr, chDone)
}
// AsyncPut sends PUT requests concurrently
func AsyncPut(url string, headers map[string]string, data io.Reader, ch chan<- *Response, chErr chan<- error, chDone chan<- bool) {
AsyncRequest(http.MethodPut, url, headers, data, ch, chErr, chDone)
}
// AsyncDelete sends DELETE requests concurrently
func AsyncDelete(url string, headers map[string]string, data io.Reader, ch chan<- *Response, chErr chan<- error, chDone chan<- bool) {
AsyncRequest(http.MethodDelete, url, headers, data, ch, chErr, chDone)
}