package gateway

import (
	context "context"
	gql "github.com/machinebox/graphql"
	"github.com/railwayapp/cli/entity"
	"github.com/railwayapp/cli/errors"
)

func (g *Gateway) GetWorkflowStatus(ctx context.Context, workflowID string) (entity.WorkflowStatus, error) {
	gqlReq := gql.NewRequest(`
		query($workflowId: String!) {
			getWorkflowStatus(workflowId: $workflowId) {
				status
			}
		}
	`)

	err := g.authorize(ctx, gqlReq.Header)
	if err != nil {
		return "", err
	}

	gqlReq.Var("workflowId", workflowID)

	var resp struct {
		WorkflowStatus *entity.WorkflowStatusResponse `json:"getWorkflowStatus"`
	}
	if err := g.gqlClient.Run(ctx, gqlReq, &resp); err != nil {
		return "", errors.ProjectCreateFailed
	}
	return resp.WorkflowStatus.Status, nil
}