Skip to content

Commit

Permalink
Tests: api routes (#214)
Browse files Browse the repository at this point in the history
  • Loading branch information
@aopoltorzhicky
aopoltorzhicky committed Jun 10, 2024
1 parent a394096 commit bff4039
Show file tree
Hide file tree
Showing 2 changed files with 152 additions and 4 deletions.
7 changes: 3 additions & 4 deletions cmd/api/init.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -455,14 +455,13 @@ func initHandlers(ctx context.Context, e *echo.Echo, cfg Config, db postgres.Sto
return key == os.Getenv("API_AUTH_KEY"), nil
},
})
auth.Use(keyMiddleware)

rollupAuthHandler := handler.NewRollupAuthHandler(db.Rollup, db.Address, db.Namespace, db.Transactable)
rollup := auth.Group("/rollup")
{
rollup.POST("/new", rollupAuthHandler.Create)
rollup.PATCH("/:id", rollupAuthHandler.Update)
rollup.DELETE("/:id", rollupAuthHandler.Delete)
rollup.POST("/new", rollupAuthHandler.Create, keyMiddleware)
rollup.PATCH("/:id", rollupAuthHandler.Update, keyMiddleware)
rollup.DELETE("/:id", rollupAuthHandler.Delete, keyMiddleware)
}
}

Expand Down
149 changes: 149 additions & 0 deletions cmd/api/routes_test.go
View file
Original file line number Diff line number Diff line change
@@ -0,0 +1,149 @@
package main

import (
"context"
"fmt"
"strings"
"testing"

"github.com/celenium-io/celestia-indexer/internal/storage/postgres"
"github.com/dipdup-net/go-lib/config"
pg "github.com/dipdup-net/indexer-sdk/pkg/storage/postgres"
"github.com/stretchr/testify/require"
)

func TestRoutes(t *testing.T) {
var expectedRoutes = map[string]struct{}{
"/v1/address/:hash/redelegations GET": {},
"/v1/namespace/count GET": {},
"/v1/validators/count GET": {},
"/v1/validators/:id/blocks GET": {},
"/v1/validators/:id/delegators GET": {},
"/v1/rollup/:id/stats/:name/:timeframe GET": {},
"/v1/stats/histogram/:table/:function/:timeframe GET": {},
"/v1/gas/estimate_for_pfb GET": {},
"/v1/tx/count GET": {},
"/v1/namespace/:id/:version/rollups GET": {},
"/v1/namespace_by_hash/:hash/:height GET": {},
"/v1/validators GET": {},
"/v1/validators/:id GET": {},
"/v1/stats/tps GET": {},
"/v1/stats/namespace/series/:id/:name/:timeframe GET": {},
"/v1/stats/series/:name/:timeframe GET": {},
"/v1/search GET": {},
"/v1/stats/staking/series/:id/:name/:timeframe GET": {},
"/v1/rollup/:id GET": {},
"/v1/auth/rollup/new POST": {},
"/v1/address/:hash GET": {},
"/v1/address/:hash/txs GET": {},
"/v1/address/:hash/delegations GET": {},
"/v1/namespace/:id/:version GET": {},
"/v1/tx GET": {},
"/v1/namespace/:id/:version/blobs GET": {},
"/v1/rollup/:id/namespaces GET": {},
"/v1/block GET": {},
"/v1/tx/:hash/namespace GET": {},
"/v1/tx/:hash/blobs/count GET": {},
"/v1/rollup GET": {},
"/v1/address/:hash/vestings GET": {},
"/v1/tx/:hash/events GET": {},
"/v1/stats/tx_count_24h GET": {},
"/v1/rollup/count GET": {},
"/v1/auth/rollup/:id PATCH": {},
"/v1/address/:hash/undelegations GET": {},
"/v1/block/:height/messages GET": {},
"/v1/namespace/active GET": {},
"/v1/namespace_by_hash/:hash GET": {},
"/v1/vesting/:id/periods GET": {},
"/v1/constants GET": {},
"/v1/address GET": {},
"/v1/block/:height/blobs GET": {},
"/v1/namespace GET": {},
"/v1/address/count GET": {},
"/v1/address/:hash/blobs GET": {},
"/v1/block/:height/blobs/count GET": {},
"/v1/namespace/:id GET": {},
"/v1/stats/summary/:table/:function GET": {},
"/v1/rollup/:id/blobs GET": {},
"/v1/rollup/:id/distribution/:name/:timeframe GET": {},
"/v1/address/:hash/messages GET": {},
"/v1/address/:hash/grants GET": {},
"/v1/address/:hash/granters GET": {},
"/v1/tx/:hash/namespace/count GET": {},
"/v1/blob POST": {},
"/v1/stats/price/current GET": {},
"/v1/swagger/* GET": {},
"/v1/auth/rollup/:id DELETE": {},
"/v1/enums GET": {},
"/v1/block/count GET": {},
"/v1/block/:height/namespace GET": {},
"/v1/tx/genesis GET": {},
"/v1/blob/metadata POST": {},
"/v1/validators/:id/jails GET": {},
"/v1/head GET": {},
"/v1/address/:hash/stats/:name/:timeframe GET": {},
"/v1/block/:height GET": {},
"/v1/block/:height/namespace/count GET": {},
"/v1/tx/:hash GET": {},
"/v1/tx/:hash/messages GET": {},
"/v1/stats/price/series/:timeframe GET": {},
"/v1/gas/price GET": {},
"/v1/block/:height/ods GET": {},
"/v1/tx/:hash/blobs GET": {},
"/v1/namespace/:id/:version/messages GET": {},
"/v1/validators/:id/uptime GET": {},
"/v1/stats/namespace/usage GET": {},
"/v1/rollup/slug/:slug GET": {},
"/v1/block/:height/events GET": {},
"/v1/block/:height/stats GET": {},
"/v1/rollup/:id/export GET": {},
}

ctx, cancel := context.WithCancel(context.Background())
defer cancel()

db := postgres.Storage{
Storage: &pg.Storage{},
}
apiCfg := ApiConfig{
Bind: "127.0.0.1:9876",
BlobReceiver: "dal_node",
}

e := initEcho(apiCfg, db, "development")
defer func() {
err := e.Close()
require.NoError(t, err)
}()

initHandlers(ctx, e, Config{
Config: &config.Config{
DataSources: map[string]config.DataSource{
"node_rpc": {},
"dal_node": {},
},
},
ApiConfig: apiCfg,
}, db)

for _, route := range e.Routes() {
key := fmt.Sprintf("%s %s", route.Path, route.Method)
_, ok := expectedRoutes[key]
require.True(t, ok, "routes in expected", key)
}

for key := range expectedRoutes {
parts := strings.Split(key, " ")
method := parts[1]
path := parts[0]

var found bool
for _, route := range e.Routes() {
if route.Path == path && route.Method == method {
found = true
break
}
}
require.True(t, found, "expected in routes", key)
}
}

0 comments on commit bff4039

Please sign in to comment.