(a TaskAdaptor, c *gin.Context, info *common.TaskRelayInfo, requestBody io.Reader)
| 253 | } |
| 254 | |
| 255 | func DoTaskApiRequest(a TaskAdaptor, c *gin.Context, info *common.TaskRelayInfo, requestBody io.Reader) (*http.Response, error) { |
| 256 | fullRequestURL, err := a.BuildRequestURL(info) |
| 257 | if err != nil { |
| 258 | return nil, err |
| 259 | } |
| 260 | req, err := http.NewRequest(c.Request.Method, fullRequestURL, requestBody) |
| 261 | if err != nil { |
| 262 | return nil, fmt.Errorf("new request failed: %w", err) |
| 263 | } |
| 264 | req.GetBody = func() (io.ReadCloser, error) { |
| 265 | return io.NopCloser(requestBody), nil |
| 266 | } |
| 267 | |
| 268 | err = a.BuildRequestHeader(c, req, info) |
| 269 | if err != nil { |
| 270 | return nil, fmt.Errorf("setup request header failed: %w", err) |
| 271 | } |
| 272 | resp, err := doRequest(c, req, info.RelayInfo) |
| 273 | if err != nil { |
| 274 | return nil, fmt.Errorf("do request failed: %w", err) |
| 275 | } |
| 276 | return resp, nil |
| 277 | } |
no test coverage detected