package gateway

import (

context "context"

"github.com/railwayapp/cli/entity"

"github.com/railwayapp/cli/errors"

)

func (g *Gateway) GetWorkflowStatus(ctx context.Context, workflowID string) (entity.WorkflowStatus, error) {

gqlReq, err := g.NewRequestWithAuth(`

query($workflowId: String!) {

getWorkflowStatus(workflowId: $workflowId) {

status

}

}

`)

if err != nil {

return "", err

}

gqlReq.Var("workflowId", workflowID)

var resp struct {

WorkflowStatus *entity.WorkflowStatusResponse `json:"getWorkflowStatus"`

}

if err := gqlReq.Run(ctx, &resp); err != nil {

return "", errors.ProjectCreateFailed

}

return resp.WorkflowStatus.Status, nil

}