diff --git a/pkg/service/mapfixes.go b/pkg/service/mapfixes.go index b9ff7d7..18207f2 100644 --- a/pkg/service/mapfixes.go +++ b/pkg/service/mapfixes.go @@ -635,7 +635,7 @@ func (svc *Service) ActionMapfixTriggerUpload(ctx context.Context, params api.Ac return err } - _, err = svc.Nats.Publish("maptest.mapfixes.uploadfix", []byte(j)) + _, err = svc.Nats.Publish("maptest.mapfixes.upload", []byte(j)) if err != nil { return err } @@ -708,24 +708,6 @@ func (svc *Service) ActionMapfixValidated(ctx context.Context, params api.Action return err } - // this is a map fix - upload_fix_request := model.UploadMapfixRequest{ - MapfixID: mapfix.ID, - ModelID: mapfix.ValidatedAssetID, - ModelVersion: mapfix.ValidatedAssetVersion, - TargetAssetID: mapfix.TargetAssetID, - } - - j, err := json.Marshal(upload_fix_request) - if err != nil { - return err - } - - _, err = svc.Nats.Publish("maptest.mapfixes.uploadfix", []byte(j)) - if err != nil { - return err - } - event_data := model.AuditEventDataAction{ TargetStatus: uint32(target_status), }