From 406fdbabb9d57ed17584e2fa512760748343890d Mon Sep 17 00:00:00 2001 From: anomit ghosh Date: Wed, 16 Aug 2023 21:22:02 +0530 Subject: [PATCH] fix: epoch processing status update data model in htable entry --- go/caching/redis.go | 8 +------- go/goutils/datamodel/data_model.go | 5 ----- 2 files changed, 1 insertion(+), 12 deletions(-) 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"`