maps-service/pkg/api/oas_handlers_gen.go

761 lines
20 KiB
Go
Raw Normal View History

2024-11-26 01:22:45 +00:00
// Code generated by ogen, DO NOT EDIT.
package api
import (
"context"
"net/http"
"time"
"github.com/go-faster/errors"
"go.opentelemetry.io/otel/attribute"
"go.opentelemetry.io/otel/codes"
"go.opentelemetry.io/otel/metric"
2024-11-26 20:39:10 +00:00
semconv "go.opentelemetry.io/otel/semconv/v1.26.0"
2024-11-26 01:22:45 +00:00
"go.opentelemetry.io/otel/trace"
ht "github.com/ogen-go/ogen/http"
"github.com/ogen-go/ogen/middleware"
"github.com/ogen-go/ogen/ogenerrors"
"github.com/ogen-go/ogen/otelogen"
)
2024-11-26 20:39:10 +00:00
// handleCreateSubmissionRequest handles createSubmission operation.
2024-11-26 01:22:45 +00:00
//
2024-11-26 20:39:10 +00:00
// Create new submission.
2024-11-26 01:22:45 +00:00
//
2024-11-26 20:39:10 +00:00
// POST /submissions
func (s *Server) handleCreateSubmissionRequest(args [0]string, argsEscaped bool, w http.ResponseWriter, r *http.Request) {
2024-11-26 01:22:45 +00:00
otelAttrs := []attribute.KeyValue{
2024-11-26 20:39:10 +00:00
otelogen.OperationID("createSubmission"),
semconv.HTTPRequestMethodKey.String("POST"),
semconv.HTTPRouteKey.String("/submissions"),
2024-11-26 01:22:45 +00:00
}
// Start a span for this request.
2024-11-26 20:39:10 +00:00
ctx, span := s.cfg.Tracer.Start(r.Context(), "CreateSubmission",
trace.WithAttributes(otelAttrs...),
serverSpanKind,
)
defer span.End()
// Add Labeler to context.
labeler := &Labeler{attrs: otelAttrs}
ctx = contextWithLabeler(ctx, labeler)
// Run stopwatch.
startTime := time.Now()
defer func() {
elapsedDuration := time.Since(startTime)
attrOpt := metric.WithAttributeSet(labeler.AttributeSet())
// Increment request counter.
s.requests.Add(ctx, 1, attrOpt)
// Use floating point division here for higher precision (instead of Millisecond method).
s.duration.Record(ctx, float64(float64(elapsedDuration)/float64(time.Millisecond)), attrOpt)
}()
var (
recordError = func(stage string, err error) {
span.RecordError(err)
span.SetStatus(codes.Error, stage)
s.errors.Add(ctx, 1, metric.WithAttributeSet(labeler.AttributeSet()))
}
err error
)
2024-11-28 00:13:43 +00:00
var response *ID
2024-11-26 20:39:10 +00:00
if m := s.cfg.Middleware; m != nil {
mreq := middleware.Request{
Context: ctx,
OperationName: "CreateSubmission",
OperationSummary: "Create new submission",
OperationID: "createSubmission",
Body: nil,
Params: middleware.Parameters{},
Raw: r,
}
type (
Request = struct{}
Params = struct{}
2024-11-28 00:13:43 +00:00
Response = *ID
2024-11-26 20:39:10 +00:00
)
response, err = middleware.HookMiddleware[
Request,
Params,
Response,
](
m,
mreq,
nil,
func(ctx context.Context, request Request, params Params) (response Response, err error) {
response, err = s.h.CreateSubmission(ctx)
return response, err
},
)
} else {
response, err = s.h.CreateSubmission(ctx)
}
if err != nil {
if errRes, ok := errors.Into[*ErrorStatusCode](err); ok {
if err := encodeErrorResponse(errRes, w, span); err != nil {
defer recordError("Internal", err)
}
return
}
if errors.Is(err, ht.ErrNotImplemented) {
s.cfg.ErrorHandler(ctx, w, r, err)
return
}
if err := encodeErrorResponse(s.h.NewError(ctx, err), w, span); err != nil {
defer recordError("Internal", err)
}
return
}
if err := encodeCreateSubmissionResponse(response, w, span); err != nil {
defer recordError("EncodeResponse", err)
if !errors.Is(err, ht.ErrInternalServerErrorResponse) {
s.cfg.ErrorHandler(ctx, w, r, err)
}
return
}
}
// handleGetSubmissionRequest handles getSubmission operation.
//
// Retrieve map with ID.
//
// GET /submissions/{SubmissionID}
func (s *Server) handleGetSubmissionRequest(args [1]string, argsEscaped bool, w http.ResponseWriter, r *http.Request) {
otelAttrs := []attribute.KeyValue{
otelogen.OperationID("getSubmission"),
semconv.HTTPRequestMethodKey.String("GET"),
semconv.HTTPRouteKey.String("/submissions/{SubmissionID}"),
}
// Start a span for this request.
ctx, span := s.cfg.Tracer.Start(r.Context(), "GetSubmission",
2024-11-26 01:22:45 +00:00
trace.WithAttributes(otelAttrs...),
serverSpanKind,
)
defer span.End()
// Add Labeler to context.
labeler := &Labeler{attrs: otelAttrs}
ctx = contextWithLabeler(ctx, labeler)
// Run stopwatch.
startTime := time.Now()
defer func() {
elapsedDuration := time.Since(startTime)
attrOpt := metric.WithAttributeSet(labeler.AttributeSet())
// Increment request counter.
s.requests.Add(ctx, 1, attrOpt)
// Use floating point division here for higher precision (instead of Millisecond method).
s.duration.Record(ctx, float64(float64(elapsedDuration)/float64(time.Millisecond)), attrOpt)
}()
var (
recordError = func(stage string, err error) {
span.RecordError(err)
span.SetStatus(codes.Error, stage)
s.errors.Add(ctx, 1, metric.WithAttributeSet(labeler.AttributeSet()))
}
err error
opErrContext = ogenerrors.OperationContext{
2024-11-26 20:39:10 +00:00
Name: "GetSubmission",
ID: "getSubmission",
2024-11-26 01:22:45 +00:00
}
)
2024-11-26 20:39:10 +00:00
params, err := decodeGetSubmissionParams(args, argsEscaped, r)
2024-11-26 01:22:45 +00:00
if err != nil {
err = &ogenerrors.DecodeParamsError{
OperationContext: opErrContext,
Err: err,
}
defer recordError("DecodeParams", err)
s.cfg.ErrorHandler(ctx, w, r, err)
return
}
2024-11-26 20:39:10 +00:00
var response *Submission
2024-11-26 01:22:45 +00:00
if m := s.cfg.Middleware; m != nil {
mreq := middleware.Request{
Context: ctx,
2024-11-26 20:39:10 +00:00
OperationName: "GetSubmission",
OperationSummary: "Retrieve map with ID",
OperationID: "getSubmission",
2024-11-26 01:22:45 +00:00
Body: nil,
Params: middleware.Parameters{
{
2024-11-26 20:39:10 +00:00
Name: "SubmissionID",
2024-11-26 01:22:45 +00:00
In: "path",
2024-11-26 20:39:10 +00:00
}: params.SubmissionID,
2024-11-26 01:22:45 +00:00
},
Raw: r,
}
type (
Request = struct{}
2024-11-26 20:39:10 +00:00
Params = GetSubmissionParams
Response = *Submission
2024-11-26 01:22:45 +00:00
)
response, err = middleware.HookMiddleware[
Request,
Params,
Response,
](
m,
mreq,
2024-11-26 20:39:10 +00:00
unpackGetSubmissionParams,
2024-11-26 01:22:45 +00:00
func(ctx context.Context, request Request, params Params) (response Response, err error) {
2024-11-26 20:39:10 +00:00
response, err = s.h.GetSubmission(ctx, params)
2024-11-26 01:22:45 +00:00
return response, err
},
)
} else {
2024-11-26 20:39:10 +00:00
response, err = s.h.GetSubmission(ctx, params)
2024-11-26 01:22:45 +00:00
}
if err != nil {
if errRes, ok := errors.Into[*ErrorStatusCode](err); ok {
if err := encodeErrorResponse(errRes, w, span); err != nil {
defer recordError("Internal", err)
}
return
}
if errors.Is(err, ht.ErrNotImplemented) {
s.cfg.ErrorHandler(ctx, w, r, err)
return
}
if err := encodeErrorResponse(s.h.NewError(ctx, err), w, span); err != nil {
defer recordError("Internal", err)
}
return
}
2024-11-26 20:39:10 +00:00
if err := encodeGetSubmissionResponse(response, w, span); err != nil {
2024-11-26 01:22:45 +00:00
defer recordError("EncodeResponse", err)
if !errors.Is(err, ht.ErrInternalServerErrorResponse) {
s.cfg.ErrorHandler(ctx, w, r, err)
}
return
}
}
2024-11-26 20:39:10 +00:00
// handleListSubmissionsRequest handles listSubmissions operation.
2024-11-26 01:22:45 +00:00
//
2024-11-26 20:39:10 +00:00
// Get list of submissions.
2024-11-26 01:22:45 +00:00
//
2024-11-26 20:39:10 +00:00
// GET /submissions
func (s *Server) handleListSubmissionsRequest(args [0]string, argsEscaped bool, w http.ResponseWriter, r *http.Request) {
2024-11-26 01:22:45 +00:00
otelAttrs := []attribute.KeyValue{
2024-11-26 20:39:10 +00:00
otelogen.OperationID("listSubmissions"),
semconv.HTTPRequestMethodKey.String("GET"),
semconv.HTTPRouteKey.String("/submissions"),
2024-11-26 01:22:45 +00:00
}
// Start a span for this request.
2024-11-26 20:39:10 +00:00
ctx, span := s.cfg.Tracer.Start(r.Context(), "ListSubmissions",
2024-11-26 01:22:45 +00:00
trace.WithAttributes(otelAttrs...),
serverSpanKind,
)
defer span.End()
// Add Labeler to context.
labeler := &Labeler{attrs: otelAttrs}
ctx = contextWithLabeler(ctx, labeler)
// Run stopwatch.
startTime := time.Now()
defer func() {
elapsedDuration := time.Since(startTime)
attrOpt := metric.WithAttributeSet(labeler.AttributeSet())
// Increment request counter.
s.requests.Add(ctx, 1, attrOpt)
// Use floating point division here for higher precision (instead of Millisecond method).
s.duration.Record(ctx, float64(float64(elapsedDuration)/float64(time.Millisecond)), attrOpt)
}()
var (
recordError = func(stage string, err error) {
span.RecordError(err)
span.SetStatus(codes.Error, stage)
s.errors.Add(ctx, 1, metric.WithAttributeSet(labeler.AttributeSet()))
}
err error
opErrContext = ogenerrors.OperationContext{
2024-11-26 20:39:10 +00:00
Name: "ListSubmissions",
ID: "listSubmissions",
2024-11-26 01:22:45 +00:00
}
)
2024-11-26 20:39:10 +00:00
params, err := decodeListSubmissionsParams(args, argsEscaped, r)
2024-11-26 01:22:45 +00:00
if err != nil {
err = &ogenerrors.DecodeParamsError{
OperationContext: opErrContext,
Err: err,
}
defer recordError("DecodeParams", err)
s.cfg.ErrorHandler(ctx, w, r, err)
return
}
2024-11-26 20:39:10 +00:00
var response []Submission
2024-11-26 01:22:45 +00:00
if m := s.cfg.Middleware; m != nil {
mreq := middleware.Request{
Context: ctx,
2024-11-26 20:39:10 +00:00
OperationName: "ListSubmissions",
OperationSummary: "Get list of submissions",
OperationID: "listSubmissions",
2024-11-26 01:22:45 +00:00
Body: nil,
Params: middleware.Parameters{
{
2024-11-26 20:39:10 +00:00
Name: "page",
2024-11-26 01:22:45 +00:00
In: "query",
2024-11-26 20:39:10 +00:00
}: params.Page,
2024-11-26 01:22:45 +00:00
{
2024-11-26 20:39:10 +00:00
Name: "filter",
2024-11-26 01:22:45 +00:00
In: "query",
2024-11-26 20:39:10 +00:00
}: params.Filter,
},
Raw: r,
}
type (
Request = struct{}
Params = ListSubmissionsParams
Response = []Submission
)
response, err = middleware.HookMiddleware[
Request,
Params,
Response,
](
m,
mreq,
unpackListSubmissionsParams,
func(ctx context.Context, request Request, params Params) (response Response, err error) {
response, err = s.h.ListSubmissions(ctx, params)
return response, err
},
)
} else {
response, err = s.h.ListSubmissions(ctx, params)
}
if err != nil {
if errRes, ok := errors.Into[*ErrorStatusCode](err); ok {
if err := encodeErrorResponse(errRes, w, span); err != nil {
defer recordError("Internal", err)
}
return
}
if errors.Is(err, ht.ErrNotImplemented) {
s.cfg.ErrorHandler(ctx, w, r, err)
return
}
if err := encodeErrorResponse(s.h.NewError(ctx, err), w, span); err != nil {
defer recordError("Internal", err)
}
return
}
if err := encodeListSubmissionsResponse(response, w, span); err != nil {
defer recordError("EncodeResponse", err)
if !errors.Is(err, ht.ErrInternalServerErrorResponse) {
s.cfg.ErrorHandler(ctx, w, r, err)
}
return
}
}
// handlePatchSubmissionCompletedRequest handles patchSubmissionCompleted operation.
//
// Retrieve map with ID.
//
// PATCH /submissions/{SubmissionID}/completed
func (s *Server) handlePatchSubmissionCompletedRequest(args [1]string, argsEscaped bool, w http.ResponseWriter, r *http.Request) {
otelAttrs := []attribute.KeyValue{
otelogen.OperationID("patchSubmissionCompleted"),
semconv.HTTPRequestMethodKey.String("PATCH"),
semconv.HTTPRouteKey.String("/submissions/{SubmissionID}/completed"),
}
// Start a span for this request.
ctx, span := s.cfg.Tracer.Start(r.Context(), "PatchSubmissionCompleted",
trace.WithAttributes(otelAttrs...),
serverSpanKind,
)
defer span.End()
// Add Labeler to context.
labeler := &Labeler{attrs: otelAttrs}
ctx = contextWithLabeler(ctx, labeler)
// Run stopwatch.
startTime := time.Now()
defer func() {
elapsedDuration := time.Since(startTime)
attrOpt := metric.WithAttributeSet(labeler.AttributeSet())
// Increment request counter.
s.requests.Add(ctx, 1, attrOpt)
// Use floating point division here for higher precision (instead of Millisecond method).
s.duration.Record(ctx, float64(float64(elapsedDuration)/float64(time.Millisecond)), attrOpt)
}()
var (
recordError = func(stage string, err error) {
span.RecordError(err)
span.SetStatus(codes.Error, stage)
s.errors.Add(ctx, 1, metric.WithAttributeSet(labeler.AttributeSet()))
}
err error
opErrContext = ogenerrors.OperationContext{
Name: "PatchSubmissionCompleted",
ID: "patchSubmissionCompleted",
}
)
params, err := decodePatchSubmissionCompletedParams(args, argsEscaped, r)
if err != nil {
err = &ogenerrors.DecodeParamsError{
OperationContext: opErrContext,
Err: err,
}
defer recordError("DecodeParams", err)
s.cfg.ErrorHandler(ctx, w, r, err)
return
}
var response *PatchSubmissionCompletedOK
if m := s.cfg.Middleware; m != nil {
mreq := middleware.Request{
Context: ctx,
OperationName: "PatchSubmissionCompleted",
OperationSummary: "Retrieve map with ID",
OperationID: "patchSubmissionCompleted",
Body: nil,
Params: middleware.Parameters{
{
Name: "SubmissionID",
In: "path",
}: params.SubmissionID,
2024-11-26 01:22:45 +00:00
{
2024-11-26 20:39:10 +00:00
Name: "Completed",
2024-11-26 01:22:45 +00:00
In: "query",
2024-11-26 20:39:10 +00:00
}: params.Completed,
2024-11-26 01:22:45 +00:00
},
Raw: r,
}
type (
Request = struct{}
2024-11-26 20:39:10 +00:00
Params = PatchSubmissionCompletedParams
Response = *PatchSubmissionCompletedOK
2024-11-26 01:22:45 +00:00
)
response, err = middleware.HookMiddleware[
Request,
Params,
Response,
](
m,
mreq,
2024-11-26 20:39:10 +00:00
unpackPatchSubmissionCompletedParams,
2024-11-26 01:22:45 +00:00
func(ctx context.Context, request Request, params Params) (response Response, err error) {
2024-11-26 20:39:10 +00:00
err = s.h.PatchSubmissionCompleted(ctx, params)
2024-11-26 01:22:45 +00:00
return response, err
},
)
} else {
2024-11-26 20:39:10 +00:00
err = s.h.PatchSubmissionCompleted(ctx, params)
2024-11-26 01:22:45 +00:00
}
if err != nil {
if errRes, ok := errors.Into[*ErrorStatusCode](err); ok {
if err := encodeErrorResponse(errRes, w, span); err != nil {
defer recordError("Internal", err)
}
return
}
if errors.Is(err, ht.ErrNotImplemented) {
s.cfg.ErrorHandler(ctx, w, r, err)
return
}
if err := encodeErrorResponse(s.h.NewError(ctx, err), w, span); err != nil {
defer recordError("Internal", err)
}
return
}
2024-11-26 20:39:10 +00:00
if err := encodePatchSubmissionCompletedResponse(response, w, span); err != nil {
2024-11-26 01:22:45 +00:00
defer recordError("EncodeResponse", err)
if !errors.Is(err, ht.ErrInternalServerErrorResponse) {
s.cfg.ErrorHandler(ctx, w, r, err)
}
return
}
}
2024-11-26 20:39:10 +00:00
// handlePatchSubmissionModelRequest handles patchSubmissionModel operation.
2024-11-26 01:22:45 +00:00
//
2024-11-26 20:39:10 +00:00
// Update model following role restrictions.
2024-11-26 01:22:45 +00:00
//
2024-11-26 20:39:10 +00:00
// PATCH /submissions/{SubmissionID}/model
func (s *Server) handlePatchSubmissionModelRequest(args [1]string, argsEscaped bool, w http.ResponseWriter, r *http.Request) {
2024-11-26 01:22:45 +00:00
otelAttrs := []attribute.KeyValue{
2024-11-26 20:39:10 +00:00
otelogen.OperationID("patchSubmissionModel"),
semconv.HTTPRequestMethodKey.String("PATCH"),
semconv.HTTPRouteKey.String("/submissions/{SubmissionID}/model"),
2024-11-26 01:22:45 +00:00
}
// Start a span for this request.
2024-11-26 20:39:10 +00:00
ctx, span := s.cfg.Tracer.Start(r.Context(), "PatchSubmissionModel",
2024-11-26 01:22:45 +00:00
trace.WithAttributes(otelAttrs...),
serverSpanKind,
)
defer span.End()
// Add Labeler to context.
labeler := &Labeler{attrs: otelAttrs}
ctx = contextWithLabeler(ctx, labeler)
// Run stopwatch.
startTime := time.Now()
defer func() {
elapsedDuration := time.Since(startTime)
attrOpt := metric.WithAttributeSet(labeler.AttributeSet())
// Increment request counter.
s.requests.Add(ctx, 1, attrOpt)
// Use floating point division here for higher precision (instead of Millisecond method).
s.duration.Record(ctx, float64(float64(elapsedDuration)/float64(time.Millisecond)), attrOpt)
}()
var (
recordError = func(stage string, err error) {
span.RecordError(err)
span.SetStatus(codes.Error, stage)
s.errors.Add(ctx, 1, metric.WithAttributeSet(labeler.AttributeSet()))
}
err error
opErrContext = ogenerrors.OperationContext{
2024-11-26 20:39:10 +00:00
Name: "PatchSubmissionModel",
ID: "patchSubmissionModel",
2024-11-26 01:22:45 +00:00
}
)
2024-11-26 20:39:10 +00:00
params, err := decodePatchSubmissionModelParams(args, argsEscaped, r)
2024-11-26 01:22:45 +00:00
if err != nil {
err = &ogenerrors.DecodeParamsError{
OperationContext: opErrContext,
Err: err,
}
defer recordError("DecodeParams", err)
s.cfg.ErrorHandler(ctx, w, r, err)
return
}
2024-11-26 20:39:10 +00:00
var response *PatchSubmissionModelOK
2024-11-26 01:22:45 +00:00
if m := s.cfg.Middleware; m != nil {
mreq := middleware.Request{
Context: ctx,
2024-11-26 20:39:10 +00:00
OperationName: "PatchSubmissionModel",
OperationSummary: "Update model following role restrictions",
OperationID: "patchSubmissionModel",
2024-11-26 01:22:45 +00:00
Body: nil,
Params: middleware.Parameters{
{
2024-11-26 20:39:10 +00:00
Name: "SubmissionID",
In: "path",
}: params.SubmissionID,
{
Name: "ModelID",
2024-11-26 01:22:45 +00:00
In: "query",
2024-11-26 20:39:10 +00:00
}: params.ModelID,
2024-11-26 01:22:45 +00:00
{
2024-11-26 20:39:10 +00:00
Name: "VersionID",
2024-11-26 01:22:45 +00:00
In: "query",
2024-11-26 20:39:10 +00:00
}: params.VersionID,
2024-11-26 01:22:45 +00:00
},
Raw: r,
}
type (
Request = struct{}
2024-11-26 20:39:10 +00:00
Params = PatchSubmissionModelParams
Response = *PatchSubmissionModelOK
2024-11-26 01:22:45 +00:00
)
response, err = middleware.HookMiddleware[
Request,
Params,
Response,
](
m,
mreq,
2024-11-26 20:39:10 +00:00
unpackPatchSubmissionModelParams,
2024-11-26 01:22:45 +00:00
func(ctx context.Context, request Request, params Params) (response Response, err error) {
2024-11-26 20:39:10 +00:00
err = s.h.PatchSubmissionModel(ctx, params)
2024-11-26 01:22:45 +00:00
return response, err
},
)
} else {
2024-11-26 20:39:10 +00:00
err = s.h.PatchSubmissionModel(ctx, params)
2024-11-26 01:22:45 +00:00
}
if err != nil {
if errRes, ok := errors.Into[*ErrorStatusCode](err); ok {
if err := encodeErrorResponse(errRes, w, span); err != nil {
defer recordError("Internal", err)
}
return
}
if errors.Is(err, ht.ErrNotImplemented) {
s.cfg.ErrorHandler(ctx, w, r, err)
return
}
if err := encodeErrorResponse(s.h.NewError(ctx, err), w, span); err != nil {
defer recordError("Internal", err)
}
return
}
2024-11-26 20:39:10 +00:00
if err := encodePatchSubmissionModelResponse(response, w, span); err != nil {
2024-11-26 01:22:45 +00:00
defer recordError("EncodeResponse", err)
if !errors.Is(err, ht.ErrInternalServerErrorResponse) {
s.cfg.ErrorHandler(ctx, w, r, err)
}
return
}
}
2024-11-26 20:39:10 +00:00
// handlePatchSubmissionStatusRequest handles patchSubmissionStatus operation.
2024-11-26 01:22:45 +00:00
//
2024-11-26 20:39:10 +00:00
// Update status following role restrictions.
2024-11-26 01:22:45 +00:00
//
2024-11-26 20:39:10 +00:00
// PATCH /submissions/{SubmissionID}/status
func (s *Server) handlePatchSubmissionStatusRequest(args [1]string, argsEscaped bool, w http.ResponseWriter, r *http.Request) {
2024-11-26 01:22:45 +00:00
otelAttrs := []attribute.KeyValue{
2024-11-26 20:39:10 +00:00
otelogen.OperationID("patchSubmissionStatus"),
semconv.HTTPRequestMethodKey.String("PATCH"),
semconv.HTTPRouteKey.String("/submissions/{SubmissionID}/status"),
2024-11-26 01:22:45 +00:00
}
// Start a span for this request.
2024-11-26 20:39:10 +00:00
ctx, span := s.cfg.Tracer.Start(r.Context(), "PatchSubmissionStatus",
2024-11-26 01:22:45 +00:00
trace.WithAttributes(otelAttrs...),
serverSpanKind,
)
defer span.End()
// Add Labeler to context.
labeler := &Labeler{attrs: otelAttrs}
ctx = contextWithLabeler(ctx, labeler)
// Run stopwatch.
startTime := time.Now()
defer func() {
elapsedDuration := time.Since(startTime)
attrOpt := metric.WithAttributeSet(labeler.AttributeSet())
// Increment request counter.
s.requests.Add(ctx, 1, attrOpt)
// Use floating point division here for higher precision (instead of Millisecond method).
s.duration.Record(ctx, float64(float64(elapsedDuration)/float64(time.Millisecond)), attrOpt)
}()
var (
recordError = func(stage string, err error) {
span.RecordError(err)
span.SetStatus(codes.Error, stage)
s.errors.Add(ctx, 1, metric.WithAttributeSet(labeler.AttributeSet()))
}
err error
opErrContext = ogenerrors.OperationContext{
2024-11-26 20:39:10 +00:00
Name: "PatchSubmissionStatus",
ID: "patchSubmissionStatus",
2024-11-26 01:22:45 +00:00
}
)
2024-11-26 20:39:10 +00:00
params, err := decodePatchSubmissionStatusParams(args, argsEscaped, r)
2024-11-26 01:22:45 +00:00
if err != nil {
err = &ogenerrors.DecodeParamsError{
OperationContext: opErrContext,
Err: err,
}
defer recordError("DecodeParams", err)
s.cfg.ErrorHandler(ctx, w, r, err)
return
}
2024-11-26 20:39:10 +00:00
var response *PatchSubmissionStatusOK
2024-11-26 01:22:45 +00:00
if m := s.cfg.Middleware; m != nil {
mreq := middleware.Request{
Context: ctx,
2024-11-26 20:39:10 +00:00
OperationName: "PatchSubmissionStatus",
OperationSummary: "Update status following role restrictions",
OperationID: "patchSubmissionStatus",
2024-11-26 01:22:45 +00:00
Body: nil,
Params: middleware.Parameters{
{
2024-11-26 20:39:10 +00:00
Name: "SubmissionID",
In: "path",
}: params.SubmissionID,
2024-11-26 01:22:45 +00:00
{
2024-11-26 20:39:10 +00:00
Name: "Status",
2024-11-26 01:22:45 +00:00
In: "query",
2024-11-26 20:39:10 +00:00
}: params.Status,
2024-11-26 01:22:45 +00:00
},
Raw: r,
}
type (
Request = struct{}
2024-11-26 20:39:10 +00:00
Params = PatchSubmissionStatusParams
Response = *PatchSubmissionStatusOK
2024-11-26 01:22:45 +00:00
)
response, err = middleware.HookMiddleware[
Request,
Params,
Response,
](
m,
mreq,
2024-11-26 20:39:10 +00:00
unpackPatchSubmissionStatusParams,
2024-11-26 01:22:45 +00:00
func(ctx context.Context, request Request, params Params) (response Response, err error) {
2024-11-26 20:39:10 +00:00
err = s.h.PatchSubmissionStatus(ctx, params)
2024-11-26 01:22:45 +00:00
return response, err
},
)
} else {
2024-11-26 20:39:10 +00:00
err = s.h.PatchSubmissionStatus(ctx, params)
2024-11-26 01:22:45 +00:00
}
if err != nil {
if errRes, ok := errors.Into[*ErrorStatusCode](err); ok {
if err := encodeErrorResponse(errRes, w, span); err != nil {
defer recordError("Internal", err)
}
return
}
if errors.Is(err, ht.ErrNotImplemented) {
s.cfg.ErrorHandler(ctx, w, r, err)
return
}
if err := encodeErrorResponse(s.h.NewError(ctx, err), w, span); err != nil {
defer recordError("Internal", err)
}
return
}
2024-11-26 20:39:10 +00:00
if err := encodePatchSubmissionStatusResponse(response, w, span); err != nil {
2024-11-26 01:22:45 +00:00
defer recordError("EncodeResponse", err)
if !errors.Is(err, ht.ErrInternalServerErrorResponse) {
s.cfg.ErrorHandler(ctx, w, r, err)
}
return
}
}