8000 cli/gateway/up.go at v1.1.3 · hmmhmmhm/cli · GitHub
[go: up one dir, main page]
Skip to content

up.go

Latest commit

 

History

History
52 lines (46 loc) · 1.17 KB

up.go

File metadata and controls

52 lines (46 loc) · 1.17 KB
Raw
package gateway
import (
"context"
"encoding/json"
"errors"
"fmt"
"io/ioutil"
"net/http"
"github.com/railwayapp/cli/entity"
)
func constructReq(ctx context.Context, req *entity.UpRequest) (*http.Request, error) {
url := fmt.Sprintf("%s/project/%s/environment/%s/up?serviceId=%s", GetHost(), req.ProjectID, req.EnvironmentID, req.ServiceID)
httpReq, err := http.NewRequestWithContext(ctx, "POST", url, &req.Data)
if err != nil {
return nil, err
}
httpReq.Header.Set("Content-Type", "multipart/form-data")
return httpReq, nil
}
func (g *Gateway) Up(ctx context.Context, req *entity.UpRequest) (*entity.UpResponse, error) {
httpReq, err := constructReq(ctx, req)
if err != nil {
return nil, err
}
err = g.authorize(httpReq.Header)
if err != nil {
return nil, err
}
client := &http.Client{}
resp, err := client.Do(httpReq)
if err != nil {
return nil, err
}
bodyBytes, err := ioutil.ReadAll(resp.Body)
if err != nil {
return nil, err
}
if resp.StatusCode < 200 || resp.StatusCode >= 400 {
return nil, errors.New(string(bodyBytes))
}
var res entity.UpResponse
if err := json.Unmarshal(bodyBytes, &res); err != nil {
return nil, err
}
return &res, nil
}
0