StrafesNET/maps-service
6
Fork 0
Code Issues19 Pull Requests Packages Projects Releases Wiki Activity

nats: rename types

Browse Source
This commit is contained in:
Quaternions 2025-04-01 13:32:30 -07:00
parent b0f1e42a06
commit 1d7f6ea79a
Signed by: Quaternions
GPG Key ID: D0DF5964F79AC131
2 changed files with 7 additions and 7 deletions
pkg
model
nats.go
service
submissions.go

8
pkg/model/nats.go

@ -5,7 +5,7 @@ package model
// Requests are sent from maps-service to validator // Requests are sent from maps-service to validator
type ValidateRequest struct { type ValidateSubmissionRequest struct {
// submission_id is passed back in the response message // submission_id is passed back in the response message
SubmissionID int64 SubmissionID int64
ModelID int64 ModelID int64
@ -14,15 +14,15 @@ type ValidateRequest struct {
} }
// Create a new map // Create a new map
type UploadNewRequest struct { type UploadSubmissionRequest struct {
SubmissionID int64 SubmissionID int64
ModelID int64 ModelID int64
ModelVersion int64 ModelVersion int64
ModelName string ModelName string
} }
type UploadFixRequest struct { type UploadMapfixRequest struct {
SubmissionID int64 MapfixID int64
ModelID int64 ModelID int64
ModelVersion int64 ModelVersion int64
TargetAssetID int64 TargetAssetID int64

6
pkg/service/submissions.go

@ -398,7 +398,7 @@ func (svc *Service) ActionSubmissionTriggerUpload(ctx context.Context, params ap
// sentinel value because we are not using rust // sentinel value because we are not using rust
if submission.UploadedAssetID == 0 { if submission.UploadedAssetID == 0 {
// this is a new map // this is a new map
upload_new_request := model.UploadNewRequest{ upload_new_request := model.UploadSubmissionRequest{
SubmissionID: submission.ID, SubmissionID: submission.ID,
ModelID: submission.ValidatedAssetID, ModelID: submission.ValidatedAssetID,
ModelVersion: submission.ValidatedAssetVersion, ModelVersion: submission.ValidatedAssetVersion,
@ -499,7 +499,7 @@ func (svc *Service) ActionSubmissionTriggerValidate(ctx context.Context, params
return err return err
} }
validate_request := model.ValidateRequest{ validate_request := model.ValidateSubmissionRequest{
SubmissionID: submission.ID, SubmissionID: submission.ID,
ModelID: submission.AssetID, ModelID: submission.AssetID,
ModelVersion: submission.AssetVersion, ModelVersion: submission.AssetVersion,
@ -549,7 +549,7 @@ func (svc *Service) ActionSubmissionRetryValidate(ctx context.Context, params ap
return err return err
} }
validate_request := model.ValidateRequest{ validate_request := model.ValidateSubmissionRequest{
SubmissionID: submission.ID, SubmissionID: submission.ID,
ModelID: submission.AssetID, ModelID: submission.AssetID,
ModelVersion: submission.AssetVersion, ModelVersion: submission.AssetVersion,