Skip to content

Commit

Permalink
Decapitalise the name of the tables
Browse files Browse the repository at this point in the history
  • Loading branch information
af-afk committed May 26, 2024
1 parent 2e97d47 commit a6c0e1e
Show file tree
Hide file tree
Showing 2 changed files with 8 additions and 8 deletions.
14 changes: 7 additions & 7 deletions cmd/ingestor.logs.ethereum/func.go
Original file line number Diff line number Diff line change
Expand Up @@ -223,37 +223,37 @@ func handleLogCallback(seawaterAddr ethCommon.Address, l ethTypes.Log, cb func(t
case seawater.TopicMintPosition:
a, err = seawater.UnpackMintPosition(topic1, topic2, topic3, data)
logEvent("MintPosition")
table = "events_seawater_mintPosition"
table = "events_seawater_mintposition"

case seawater.TopicBurnPosition:
a, err = seawater.UnpackBurnPosition(topic1, topic2, data)
logEvent("BurnPosition")
table = "events_seawater_burnPosition"
table = "events_seawater_burnposition"

case seawater.TopicTransferPosition:
a, err = seawater.UnpackTransferPosition(topic1, topic2, topic3, data)
logEvent("TransferPosition")
table = "events_seawater_transferPosition"
table = "events_seawater_transferposition"

case seawater.TopicUpdatePositionLiquidity:
a, err = seawater.UnpackUpdatePositionLiquidity(topic1, topic2, data)
logEvent("UpdatePositionLiquidity")
table = "events_seawater_updatePositionLiquidity"
table = "events_seawater_updatepositionliquidity"

case seawater.TopicCollectFees:
a, err = seawater.UnpackCollectFees(topic1, topic2, topic3, data)
logEvent("CollectFees")
table = "events_seawater_collectFees"
table = "events_seawater_collectfees"

case seawater.TopicNewPool:
a, err = seawater.UnpackNewPool(topic1, topic2, topic3, data)
logEvent("NewPool")
table = "events_seawater_newPool"
table = "events_seawater_newpool"

case seawater.TopicCollectProtocolFees:
a, err = seawater.UnpackCollectProtocolFees(topic1, topic2, data)
logEvent("CollectProtocolFees")
table = "events_seawater_collectProtocolFees"
table = "events_seawater_collectprotocolfees"

case seawater.TopicSwap2:
a, err = seawater.UnpackSwap2(topic1, topic2, topic3, data)
Expand Down
2 changes: 1 addition & 1 deletion cmd/ingestor.logs.ethereum/func_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -36,7 +36,7 @@ func TestHandleLogCallbackNewPool(t *testing.T) {
var l ethTypes.Log
assert.Nilf(t, json.NewDecoder(s).Decode(&l), "failed to decode log")
handleLogCallback(seawaterAddr, l, func(table string, a any) error {
assert.Equalf(t, "events_seawater_newPool", table, "table not equal")
assert.Equalf(t, "events_seawater_newpool", table, "table not equal")
// This test is captured in a unit test, so we can focus on just testing
// this one field.
newPool, ok := a.(*seawater.NewPool)
Expand Down

0 comments on commit a6c0e1e

Please sign in to comment.