Skip to content

Commit 683bb48

Browse files
committed
reverted evtype in process staged
1 parent e248451 commit 683bb48

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

gateway/modules/eventing/handle_staged.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -113,7 +113,7 @@ func (m *Module) processStagedEvent(eventDoc *model.EventDocument) {
113113
_ = json.Unmarshal([]byte(eventDoc.Payload.(string)), &doc)
114114
eventDoc.Payload = doc
115115

116-
cloudEvent := model.CloudEventPayload{SpecVersion: "1.0", Type: fmt.Sprintf("com.spaceuptech.%s", evType), Source: m.syncMan.GetEventSource(), ID: eventDoc.ID,
116+
cloudEvent := model.CloudEventPayload{SpecVersion: "1.0", Type: evType, Source: m.syncMan.GetEventSource(), ID: eventDoc.ID,
117117
Time: eventDoc.Timestamp, Data: eventDoc.Payload}
118118

119119
doc = structs.Map(&cloudEvent)

0 commit comments

Comments
 (0)