Sinner

.codecov.yml

@@ -67,6 +67,10 @@ flags:
     paths:
       - services/scribe/
     carryforward: true
+  sinner:
+    paths:
+      - services/sinner/
+    carryforward: true
   solidity:
     paths:
       - packages/contracts-core/

.github/workflows/go.yml

@@ -200,6 +200,12 @@ jobs:
               fi
             done
 
+            # Check if max retries is exceeded for this package.
+            if [ $retries -eq $max_num_retries ]; then
+                echo "Max retries exceeded for $pkg"
+                exit 1
+            fi
+
             if [ -f profile.cov ]; then
               tail -n +2 profile.cov >> coverage.txt
               rm profile.cov

README.md

@@ -66,10 +66,12 @@ root
 │   ├── <a href="./packages/explorer-ui">explorer-ui</a>: Explorer UI
 │   ├── <a href="./packages/sdk-router">sdk-router</a>: SDK router
 │   ├── <a href="./packages/sdk-router">synapse-interface</a>: Synapse frontend code
-├── <a href="./tools">services</a>
+├── <a href="./services">services</a>
+│   ├── <a href="./services/cctp-relayer">CCTP Relayer</a>: CCTP message relayer
 │   ├── <a href="./services/explorer">explorer</a>: Bridge/messaging explorer backend
-│   ├── <a href="./services/omnirpc">omnirpc</a>: Latency aware RPC Client used across multiple-chains at once
 │   ├── <a href="./services/scribe">scribe</a>: Generalized ethereum event logger
+│   ├── <a href="./services/omnirpc">omnirpc</a>: Latency aware RPC Client used across multiple-chains at once
+│   ├── <a href="./services/sinner">sinner</a>: [Synapse Interchain Network](https://interchain.synapseprotocol.com/) indexer & query interface
 ├── <a href="./tools">tools</a>
 │   ├── <a href="./tools/abigen">abigen</a>: Used to generate abigen bindings for go
 │   ├── <a href="./tools/bundle">bundle</a>: Modified version of <a href="https://pkg.go.dev/golang.org/x/[email protected]/cmd/bundle"> go bundler </a> with improved shadowing support

docker/sinner.Dockerfile

@@ -0,0 +1,15 @@
+FROM gcr.io/distroless/static:latest
+
+LABEL org.label-schema.description="Sinner Docker file"
+LABEL org.label-schema.name="ghcr.io/synapsecns/sanguine/sinner"
+LABEL org.label-schema.schema-version="1.0.0"
+LABEL org.label-schema.vcs-url="https://github.com/synapsecns/sanguine"
+LABEL org.opencontainers.image.source="https://github.com/synapsecns/sanguine"
+LABEL org.opencontainers.image.description="Sinner Docker image"
+
+USER nonroot:nonroot
+
+WORKDIR /app
+COPY --chown=nonroot:nonroot sinner /app/sinner
+
+ENTRYPOINT ["/app/sinner"]

go.work

@@ -16,5 +16,6 @@ use (
 	./services/explorer
 	./services/omnirpc
 	./services/scribe
+	./services/sinner
 	./tools
 )

services/scribe/api/data_test.go

@@ -5,6 +5,7 @@ import (
 	"github.com/ethereum/go-ethereum/common"
 	"github.com/ethereum/go-ethereum/core/types"
 	. "github.com/stretchr/testify/assert"
+	"github.com/synapsecns/sanguine/core"
 	"github.com/synapsecns/sanguine/services/scribe/db"
 	"github.com/synapsecns/sanguine/services/scribe/graphql"
 	"github.com/synapsecns/sanguine/services/scribe/grpc/client/rest"
@@ -50,11 +51,17 @@ func (g APISuite) TestRetrieveData() {
 	logs, err := g.gqlClient.GetLogs(g.GetTestContext(), int(chainID), 1)
 	Nil(g.T(), err)
 	// there were 20 logs created (2 per loop, in a loop of 10)
-	Equal(g.T(), len(logs.Response), 20)
-	logsRange, err := g.gqlClient.GetLogsRange(g.GetTestContext(), int(chainID), 2, 5, 1)
+	Equal(g.T(), 20, len(logs.Response))
+	logsRange, err := g.gqlClient.GetLogsRange(g.GetTestContext(), int(chainID), 2, 5, 1, nil)
 	Nil(g.T(), err)
 	// from 2-5, there were 8 logs created (2 per loop, in a range of 4)
-	Equal(g.T(), len(logsRange.Response), 8)
+	Equal(g.T(), 8, len(logsRange.Response))
+
+	// Test getting logs in a range in ascending order.
+	logsRangeAsc, err := g.gqlClient.GetLogsRange(g.GetTestContext(), int(chainID), 2, 5, 1, core.PtrTo(true))
+	Nil(g.T(), err)
+	Equal(g.T(), 8, len(logsRangeAsc.Response))
+	Equal(g.T(), 2, logsRangeAsc.Response[0].BlockNumber)
 
 	// test get logs and get logs in a range (GRPC)
 	grpcLogs, res, err := g.grpcRestClient.ScribeServiceApi.ScribeServiceFilterLogs(g.GetTestContext(), rest.V1FilterLogsRequest{
@@ -213,17 +220,17 @@ func (g APISuite) TestBlockTimeDataEquality() {
 	Nil(g.T(), err)
 
 	// check that the data is equal
-	Equal(g.T(), *retrievedBlockTime.Response, int(blockTime))
+	Equal(g.T(), int(blockTime), *retrievedBlockTime.Response)
 
 	// check that the last stored block is correct
 	lastBlock, err := g.gqlClient.GetLastStoredBlockNumber(g.GetTestContext(), int(chainID))
 	Nil(g.T(), err)
-	Equal(g.T(), *lastBlock.Response, int(blockNumber))
+	Equal(g.T(), int(blockNumber), *lastBlock.Response)
 
 	// check that the first stored block is correct
 	firstBlock, err := g.gqlClient.GetFirstStoredBlockNumber(g.GetTestContext(), int(chainID))
 	Nil(g.T(), err)
-	Equal(g.T(), *firstBlock.Response, int(blockNumber))
+	Equal(g.T(), int(blockNumber), *firstBlock.Response)
 }
 
 func (g *APISuite) buildLog(contractAddress common.Address, blockNumber uint64) types.Log {
@@ -291,7 +298,7 @@ func (g APISuite) TestLastContractIndexed() {
 	Nil(g.T(), err)
 
 	// check that the data is equal
-	Equal(g.T(), *retrievedBlockTime.Response, int(blockNumber))
+	Equal(g.T(), int(blockNumber), *retrievedBlockTime.Response)
 }
 
 // nolint:dupl
@@ -390,7 +397,7 @@ func (g APISuite) TestLastConfirmedBlock() {
 	Nil(g.T(), err)
 
 	// check that the data is equal
-	Equal(g.T(), *retrievedBlockTime.Response, int(blockNumber))
+	Equal(g.T(), int(blockNumber), *retrievedBlockTime.Response)
 }
 
 // nolint:dupl

services/scribe/cmd/cmd.md

@@ -2,10 +2,10 @@
 [![Go Reference](https://pkg.go.dev/badge/github.com/synapsecns/sanguine/services/scribe.svg)](https://pkg.go.dev/github.com/synapsecns/sanguine/services/scribe)
 [![Go Report Card](https://goreportcard.com/badge/github.com/synapsecns/sanguine/services/scribe)](https://goreportcard.com/report/github.com/synapsecns/sanguine/services/scribe)
 
-Scribe is a multi chain indexing service. Scribe is designed to take a list of contracts specified by chain id and store logs, receipts, and txs for every event, past to present, in a mysql database.
+Scribe is a multi-chain indexing service. Scribe is designed to take a list of contracts specified by chain id and store logs, receipts, and txs for every event, past to present, in a mysql database.
 
 Use cases
-- Analytics for on chain events
+- Analytics for on-chain events
 - Stream events occurring across chains
 - Monitor activity on your contracts
 

services/scribe/db/suite_test.go

@@ -43,7 +43,6 @@ func NewEventDBSuite(tb testing.TB) *DBSuite {
 
 func (t *DBSuite) SetupTest() {
 	t.TestSuite.SetupTest()
-
 	t.logIndex.Store(0)
 
 	sqliteStore, err := sqlite.NewSqliteStore(t.GetTestContext(), filet.TmpDir(t.T(), ""), t.scribeMetrics, false)

services/scribe/graphql/client/queries/queries.graphql

@@ -13,8 +13,8 @@ query GetLogs ($chain_id: Int!, $page: Int!) {
     }
 }
 
-query GetLogsRange ($chain_id: Int!, $start_block: Int!, $end_block: Int!, $page: Int!) {
-    response: logsRange (chain_id: $chain_id, start_block: $start_block, end_block: $end_block, page: $page) {
+query GetLogsRange ($chain_id: Int!, $start_block: Int!, $end_block: Int!, $page: Int!, $asc: Boolean = false) {
+    response: logsRange (chain_id: $chain_id, start_block: $start_block, end_block: $end_block, page: $page,asc: $asc) {
         contract_address
         chain_id
         topics