Something went wrong. Try again.
Monorepo for Tangled
Something went wrong. Try again.
Go
12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485package xrpc
import ( "fmt" "net/http" "strconv"
"tangled.org/core/api/tangled" "tangled.org/core/spindle/models" pipelinecodec "tangled.org/core/spindle/pipeline" xrpcerr "tangled.org/core/xrpc/errors")
func (x *Xrpc) HandleCiQueryPipelines(w http.ResponseWriter, r *http.Request) { l := x.Logger fail := func(e xrpcerr.XrpcError, status int) { l.ErrorContext(r.Context(), "failed", "kind", e.Tag, "error", e.Message) writeError(w, e, status) }
repo := r.URL.Query().Get("repo") if repo == "" { fail(xrpcerr.GenericError(fmt.Errorf("missing repo parameter")), http.StatusBadRequest) return }
commits := r.URL.Query()["commits"] cursor := r.URL.Query().Get("cursor") kinds := r.URL.Query()["kinds"] limitStr := r.URL.Query().Get("limit")
limit := 30 if limitStr != "" { if val, err := strconv.Atoi(limitStr); err == nil && val > 0 { limit = val } }
records, nextCursor, total, err := x.Db.QueryPipelines(r.Context(), repo, commits, cursor, kinds, limit) if err != nil { fail(xrpcerr.GenericError(err), http.StatusInternalServerError) return } pipelines := make([]*tangled.CiPipeline, 0, len(records)) for _, record := range records { pipelines = append(pipelines, pipelinecodec.ToTangled(record)) }
output := tangled.CiQueryPipelines_Output{ Pipelines: pipelines, Total: total, } if nextCursor != "" { output.Cursor = &nextCursor }
if err := writeJson(w, http.StatusOK, output); err != nil { fail(xrpcerr.GenericError(err), http.StatusInternalServerError) }}
func (x *Xrpc) HandleCiGetPipeline(w http.ResponseWriter, r *http.Request) { l := x.Logger fail := func(e xrpcerr.XrpcError, status int) { l.ErrorContext(r.Context(), "failed", "kind", e.Tag, "error", e.Message) writeError(w, e, status) }
pipeline := r.URL.Query().Get("pipeline") if pipeline == "" { fail(xrpcerr.GenericError(fmt.Errorf("missing pipeline parameter")), http.StatusBadRequest) return }
record, err := x.Db.GetPipeline(r.Context(), models.PipelineId(pipeline)) if err != nil { fail(xrpcerr.GenericError(err), http.StatusInternalServerError) return }
if err := writeJson(w, http.StatusOK, pipelinecodec.ToTangled(record)); err != nil { fail(xrpcerr.GenericError(err), http.StatusInternalServerError) }}