diff --git a/go/caching/redis.go b/go/caching/redis.go index 7f14dd2..e71b005 100644 --- a/go/caching/redis.go +++ b/go/caching/redis.go @@ -44,13 +44,7 @@ func (r *RedisCache) UpdateEpochProcessingStatus(ctx context.Context, projectID Error: err, Timestamp: time.Now().Unix(), } - state_update := datamodel.SnapshotterEpochProcessingReportItem{ - EpochID: epochId, - TransitionStatus: map[string]interface{}{ - projectID: transition_status_item, - }, - } - state_update_bytes, err2 := json.Marshal(state_update) + state_update_bytes, err2 := json.Marshal(transition_status_item) if err2 != nil { log.WithError(err2).Error("failed to marshal state update message on relayer submission") diff --git a/go/goutils/datamodel/data_model.go b/go/goutils/datamodel/data_model.go index 2eec8c9..999d790 100644 --- a/go/goutils/datamodel/data_model.go +++ b/go/goutils/datamodel/data_model.go @@ -18,11 +18,6 @@ type SnapshotterStateUpdate struct { const RELAYER_SEND_STATE_ID string = "RELAYER_SEND" -type SnapshotterEpochProcessingReportItem struct { - EpochID int `json:"epochId"` - TransitionStatus map[string]interface{} `json:"transitionStatus"` -} - type SummaryProjectVerificationStatus struct { ProjectId string `json:"projectId"` ProjectHeight string `json:"chainHeight"`