StrafesNET/maps-service
5
Fork 0
Code Issues15 Pull Requests1 Packages Projects Releases Wiki Activity

submissions: mark operation as completed

Browse Source
This commit is contained in:
Quaternions 2025-04-03 13:31:32 -07:00
parent e36244b9b8
commit 5e633721c8
Signed by: Quaternions
GPG Key ID: D0DF5964F79AC131
2 changed files with 22 additions and 0 deletions
pkg/service_internal
mapfixes.gosubmissions.go

11
pkg/service_internal/mapfixes.go

@ -3,6 +3,7 @@ package service_internal
import ( import (
"context" "context"
"errors" "errors"
"fmt"
"git.itzana.me/strafesnet/maps-service/pkg/datastore" "git.itzana.me/strafesnet/maps-service/pkg/datastore"
internal "git.itzana.me/strafesnet/maps-service/pkg/internal" internal "git.itzana.me/strafesnet/maps-service/pkg/internal"
@ -125,6 +126,16 @@ func (svc *Service) CreateMapfix(ctx context.Context, request *internal.MapfixCr
if err != nil { if err != nil {
return nil, err return nil, err
} }
// mark the operation as completed and provide the path
pmap := datastore.Optional()
pmap.Add("status_id", model.OperationStatusCompleted)
pmap.Add("path", fmt.Sprintf("/mapfixes/%d", mapfix.ID))
err = svc.DB.Operations().Update(ctx, request.OperationID, pmap)
if err != nil {
return nil, err
}
return &internal.MapfixID{ return &internal.MapfixID{
MapfixID: mapfix.ID, MapfixID: mapfix.ID,
}, nil }, nil

11
pkg/service_internal/submissions.go

@ -3,6 +3,7 @@ package service_internal
import ( import (
"context" "context"
"errors" "errors"
"fmt"
"git.itzana.me/strafesnet/maps-service/pkg/datastore" "git.itzana.me/strafesnet/maps-service/pkg/datastore"
internal "git.itzana.me/strafesnet/maps-service/pkg/internal" internal "git.itzana.me/strafesnet/maps-service/pkg/internal"
@ -124,6 +125,16 @@ func (svc *Service) CreateSubmission(ctx context.Context, request *internal.Subm
if err != nil { if err != nil {
return nil, err return nil, err
} }
// mark the operation as completed and provide the path
pmap := datastore.Optional()
pmap.Add("status_id", model.OperationStatusCompleted)
pmap.Add("path", fmt.Sprintf("/submissions/%d", submission.ID))
err = svc.DB.Operations().Update(ctx, request.OperationID, pmap)
if err != nil {
return nil, err
}
return &internal.SubmissionID{ return &internal.SubmissionID{
SubmissionID: submission.ID, SubmissionID: submission.ID,
}, nil }, nil