Skip to content

Commit

Permalink
fix cid root hash being sent in request
Browse files Browse the repository at this point in the history
  • Loading branch information
anomit committed Oct 8, 2024
1 parent 3039971 commit d70932c
Show file tree
Hide file tree
Showing 2 changed files with 1 addition and 26 deletions.
2 changes: 1 addition & 1 deletion pkgs/helpers/clients/txClient.go
Original file line number Diff line number Diff line change
Expand Up @@ -84,7 +84,7 @@ func SubmitSubmissionBatch(dataMarketAddress string, batchCid string, batchId st
EpochId: epochId,
ProjectIds: projectIds,
SnapshotCids: snapshotCids,
FinalizedCidsRootHash: finalizedCidsRootHash,
FinalizedCidsRootHash: fmt.Sprintf("0x%x", finalizedCidsRootHash),
AuthToken: config.SettingsObj.TxRelayerAuthWriteToken,
}

Expand Down
25 changes: 0 additions & 25 deletions pkgs/helpers/prost/processor.go
Original file line number Diff line number Diff line change
Expand Up @@ -178,31 +178,6 @@ func processEpoch(epochId, submissionLimit *big.Int, begin *types.Block) {
log.Errorln("TriggerCollectionFlow process log error: ", err.Error())
}

//go func(epochId *big.Int, headers []string, Day *big.Int) {
// epochSizeString, err := redis.Get(context.Background(), redis.EPOCH_SIZE())
// if err != nil {
// log.Fatalf("Error fetching EPOCH_SIZE from redis: %s", err.Error())
// }
//
// sourceChainBlockTimeString, err := redis.Get(context.Background(), redis.SOURCE_CHAIN_BLOCK_TIME())
// if err != nil {
// log.Fatalf("Error fetching SOURCE_CHAIN_BLOCK_TIME from redis: %s", err.Error())
// }
//
// epochSize, err := strconv.Atoi(epochSizeString)
// if err != nil {
// log.Fatalf("Error converting EPOCH_SIZE to int: %s", err.Error())
// }
//
// sourceChainBlockTime, err := strconv.Atoi(sourceChainBlockTimeString)
// if err != nil {
// log.Fatalf("Error converting SOURCE_CHAIN_BLOCK_TIME to int: %s", err.Error())
// }
//
// time.Sleep(time.Duration(epochSize*sourceChainBlockTime) * time.Millisecond)
// triggerCollectionFlow(epochId, headers, Day)
//}(epochId, headers, Day)

updatedDay := new(big.Int).SetUint64(((epochId.Uint64() - 1) / EpochsPerDay) + 1 + pkgs.DayBuffer) // 2828 / 10 = 282 + 1 == 283
if updatedDay.Cmp(Day) > 0 {
prev := new(big.Int).Set(Day)
Expand Down

0 comments on commit d70932c

Please sign in to comment.