refactor: smartrouter - lava

.github/workflows/build-package.yml

@@ -0,0 +1,39 @@
+name: Build and Package
+
+on:
+  workflow_dispatch:
+  pull_request:
+
+jobs:
+  build_docker:
+    permissions:
+      contents: write
+      packages: write
+      id-token: write
+    runs-on: ubuntu-latest
+    strategy:
+      matrix:
+        binary: [lavap]
+    env:
+      REGISTRY: ghcr.io
+      IMAGE_NAME: "lavanet/lava/${{ matrix.binary }}"
+    steps:
+      - name: Checkout code
+        uses: actions/checkout@v4
+      - name: Set up Docker Buildx
+        uses: docker/setup-buildx-action@v3
+      - name: Log into registry ${{ env.REGISTRY }}
+        uses: docker/login-action@v3
+        with:
+          registry: ${{ env.REGISTRY }}
+          username: ${{ github.actor }}
+          password: ${{ secrets.GITHUB_TOKEN }}
+      - name: Build and push
+        uses: docker/build-push-action@v5
+        with:
+          context: .
+          file: cmd/${{ matrix.binary }}/Dockerfile
+          push: true
+          tags: ${{ env.REGISTRY }}/${{ env.IMAGE_NAME }}:test-delete-later
+          cache-from: type=gha
+          cache-to: type=gha,mode=max

.github/workflows/lava.yml

@@ -4,9 +4,11 @@ on:
   push:
     branches:
       - main
+      - smart-router-v1.1
   pull_request:
     branches:
       - main
+      - smart-router-v1.1
 
 concurrency:
   group: ${{ github.workflow }}-${{ github.head_ref || github.run_id }}
@@ -106,6 +108,7 @@ jobs:
 
       - name: tail -n 1000 Lavad Logs
         if: always()
+        continue-on-error: true
         run: tail -n 1000 testutil/e2e/protocolLogs/00_StartLava.log
 
       - name: Print all warnings and errors from lavad
@@ -115,6 +118,7 @@ jobs:
 
       - name: Stake Lava All Logs
         if: always()
+        continue-on-error: true
         run: cat testutil/e2e/protocolLogs/01_stakeLava.log
 
       - name: Stake Lava Error Only Logs
@@ -124,10 +128,12 @@ jobs:
 
       - name: head -n 300 JSON Proxy Logs
         if: always()
+        continue-on-error: true
         run: head -n 300 testutil/e2e/protocolLogs/02_jsonProxy.log
 
       - name: tail -n 300 JSON Proxy Logs
         if: always()
+        continue-on-error: true
         run: tail -n 300 testutil/e2e/protocolLogs/02_jsonProxy.log
 
       - name: JSON Proxy Error Only Logs
@@ -137,6 +143,7 @@ jobs:
 
       - name: JSON Provider All Logs
         if: always()
+        continue-on-error: true
         run: grep "" testutil/e2e/protocolLogs/03_EthProvider* --exclude="*errors*"
 
       - name: JSON Provider Error Only Logs
@@ -146,6 +153,7 @@ jobs:
 
       - name: JSON Consumer All Logs
         if: always()
+        continue-on-error: true
         run: grep "" testutil/e2e/protocolLogs/04_jsonConsumer* --exclude="*errors*"
 
       - name: JSON Consumer Error Only Logs
@@ -155,6 +163,7 @@ jobs:
 
       - name: Lava Provider All Logs
         if: always()
+        continue-on-error: true
         run: grep "" testutil/e2e/protocolLogs/05_LavaProvider* --exclude="*errors*"
 
       - name: Lava Provider Error Only Logs
@@ -164,6 +173,7 @@ jobs:
 
       - name: Lava over Lava All Logs
         if: always()
+        continue-on-error: true
         run: cat testutil/e2e/protocolLogs/07_lavaOverLava.log
 
       - name: Lava over Lava Error Only Logs
@@ -173,6 +183,7 @@ jobs:
 
       - name: RPCConsumer Consumer All Logs
         if: always()
+        continue-on-error: true
         run: grep "" testutil/e2e/protocolLogs/06_RPCConsumer* --exclude="*errors*"
 
       - name: RPCConsumer Consumer Error Only Logs
@@ -372,10 +383,12 @@ jobs:
 
       - name: Lavad Logs
         if: always()
+        continue-on-error: true
         run: grep 'err\|lava_' testutil/e2e/protocolLogs/00_StartLava.log
 
       - name: Stake Lava All Logs
         if: always()
+        continue-on-error: true
         run: cat testutil/e2e/protocolLogs/01_stakeLavaForPayment.log
 
       - name: Stake Lava Error Only Logs
@@ -385,6 +398,7 @@ jobs:
 
       - name: Lava Provider All Logs
         if: always()
+        continue-on-error: true
         run: grep "" testutil/e2e/protocolLogs/05_LavaProvider* --exclude="*errors*"
 
       - name: Lava Provider Error Only Logs
@@ -394,6 +408,7 @@ jobs:
 
       - name: RPCConsumer Consumer All Logs
         if: always()
+        continue-on-error: true
         run: grep "" testutil/e2e/protocolLogs/06_RPCConsumer* --exclude="*errors*"
 
       - name: RPCConsumer Consumer Error Only Logs

.gitignore

@@ -31,6 +31,11 @@ scripts/vars/
 rpcprovider.yml
 rpcconsumer.yml
 
+# Environment variables and generated configs (secrets should not be committed)
+.env
+.env.local
+provider*_eth.yml
+
 # Node modules
 **/node_modules
 
@@ -99,4 +104,8 @@ config/health_examples/health_template_gen.yml
 **/dist/
 
 docs/
-agent_docs/
+agent_docs/
+readme-docs/
+mock-node-server/
+.claude/
+Claude.md

.golangci.yml

@@ -70,6 +70,9 @@ issues:
 linters-settings:
   dogsled:
     max-blank-identifiers: 5
+  gocritic:
+    disabled-checks:
+      - elseif
   nolintlint:
     allow-unused: false
     require-explanation: false

cmd/lavap/main.go

@@ -21,6 +21,7 @@ import (
 	validators "github.com/lavanet/lava/v5/protocol/performance/validators"
 	"github.com/lavanet/lava/v5/protocol/rpcconsumer"
 	"github.com/lavanet/lava/v5/protocol/rpcprovider"
+	"github.com/lavanet/lava/v5/protocol/rpcsmartrouter"
 	"github.com/lavanet/lava/v5/protocol/statetracker"
 	"github.com/lavanet/lava/v5/protocol/upgrade"
 	"github.com/spf13/cobra"
@@ -36,8 +37,10 @@ func main() {
 
 	// version cobra command
 	cmdVersion := versionCommand()
-	// rpc consumer cobra command
+	// rpc consumer cobra command (decentralized)
 	cmdRPCConsumer := rpcconsumer.CreateRPCConsumerCobraCommand()
+	// rpc smart router cobra command (centralized)
+	cmdRPCSmartRouter := rpcsmartrouter.CreateRPCSmartRouterCobraCommand()
 	// rpc provider cobra command
 	cmdRPCProvider := rpcprovider.CreateRPCProviderCobraCommand()
 	// badge generator cobra command
@@ -51,6 +54,8 @@ func main() {
 	rootCmd.AddCommand(cmdVersion)
 	// Add RPC Consumer Command
 	rootCmd.AddCommand(cmdRPCConsumer)
+	// Add RPC Smart Router Command
+	rootCmd.AddCommand(cmdRPCSmartRouter)
 	// Add RPC Provider Command
 	rootCmd.AddCommand(cmdRPCProvider)
 	// Add Badge Generator Command
@@ -67,6 +72,7 @@ func main() {
 	}
 	rootCmd.AddCommand(testCmd)
 	testCmd.AddCommand(rpcconsumer.CreateTestRPCConsumerCobraCommand())
+	testCmd.AddCommand(rpcsmartrouter.CreateTestRPCSmartRouterCobraCommand())
 	testCmd.AddCommand(rpcprovider.CreateTestRPCProviderCobraCommand())
 	testCmd.AddCommand(statetracker.CreateEventsCobraCommand())
 	testCmd.AddCommand(statetracker.CreateRelayPaymentCSVCobraCommand())

config/consumer_examples/lava_consumer_static_peers.yml

@@ -9,27 +9,54 @@ endpoints:
       api-interface: grpc
       network-address: 127.0.0.1:3362
 static-providers:
-  - api-interface: tendermintrpc
+  - name: provider-2220-tendermintrpc
+    api-interface: tendermintrpc
     chain-id: LAV1
     node-urls:
       - url: 127.0.0.1:2220
-  - api-interface: grpc
+  - name: provider-2220-grpc
+    api-interface: grpc
     chain-id: LAV1
     node-urls:
       - url: 127.0.0.1:2220
-  - api-interface: rest
+  - name: provider-2220-rest
+    api-interface: rest
     chain-id: LAV1
     node-urls:
       - url: 127.0.0.1:2220
-  - api-interface: tendermintrpc
+  - name: provider-2221-tendermintrpc
+    api-interface: tendermintrpc
     chain-id: LAV1
     node-urls:
       - url: 127.0.0.1:2221
-  - api-interface: grpc
+  - name: provider-2221-grpc
+    api-interface: grpc
     chain-id: LAV1
     node-urls:
       - url: 127.0.0.1:2221
-  - api-interface: rest
+  - name: provider-2221-rest
+    api-interface: rest
     chain-id: LAV1
     node-urls:
-      - url: 127.0.0.1:2221
+      - url: 127.0.0.1:2221
+  - name: provider-2222-tendermintrpc
+    api-interface: tendermintrpc
+    chain-id: LAV1
+    node-urls:
+      - url: 127.0.0.1:2222
+        addons:
+          - archive
+  - name: provider-2222-grpc
+    api-interface: grpc
+    chain-id: LAV1
+    node-urls:
+      - url: 127.0.0.1:2222
+        addons:
+          - archive
+  - name: provider-2222-rest
+    api-interface: rest
+    chain-id: LAV1
+    node-urls:
+      - url: 127.0.0.1:2222
+        addons:
+          - archive

config/consumer_examples/lava_consumer_static_with_backup.yml

@@ -9,53 +9,68 @@ endpoints:
       api-interface: grpc
       network-address: 127.0.0.1:3362
 static-providers:
-  - api-interface: tendermintrpc
+  - name: primary-2220-tendermintrpc
+    api-interface: tendermintrpc
     chain-id: LAV1
     node-urls:
-      - url: 127.0.0.1:5550
-  - api-interface: grpc
+      - url: 127.0.0.1:2220
+        addons:
+          - archive
+          - debug
+  - name: primary-2220-grpc
+    api-interface: grpc
     chain-id: LAV1
     node-urls:
-      - url: 127.0.0.1:5550
-  - api-interface: rest
+      - url: 127.0.0.1:2220
+  - name: primary-2220-rest
+    api-interface: rest
     chain-id: LAV1
     node-urls:
-      - url: 127.0.0.1:5550
-  - api-interface: tendermintrpc
+      - url: 127.0.0.1:2220
+  - name: primary-2221-tendermintrpc
+    api-interface: tendermintrpc
     chain-id: LAV1
     node-urls:
-      - url: 127.0.0.1:5551
-  - api-interface: grpc
+      - url: 127.0.0.1:2221
+  - name: primary-2221-grpc
+    api-interface: grpc
     chain-id: LAV1
     node-urls:
-      - url: 127.0.0.1:5551
-  - api-interface: rest
+      - url: 127.0.0.1:2221
+  - name: primary-2221-rest
+    api-interface: rest
     chain-id: LAV1
     node-urls:
-      - url: 127.0.0.1:5551
+      - url: 127.0.0.1:2221
 
 backup-providers:
-  - api-interface: tendermintrpc
+  - name: backup-2220-tendermintrpc
+    api-interface: tendermintrpc
     chain-id: LAV1
     node-urls:
       - url: 127.0.0.1:2220
-  - api-interface: grpc
+  - name: backup-2220-grpc
+    api-interface: grpc
     chain-id: LAV1
     node-urls:
       - url: 127.0.0.1:2220
-  - api-interface: rest
+  - name: backup-2220-rest
+    api-interface: rest
     chain-id: LAV1
     node-urls:
       - url: 127.0.0.1:2220
-  - api-interface: tendermintrpc
+  - name: backup-2221-tendermintrpc
+    api-interface: tendermintrpc
     chain-id: LAV1
     node-urls:
       - url: 127.0.0.1:2221
-  - api-interface: grpc
+  - name: backup-2221-grpc
+    api-interface: grpc
     chain-id: LAV1
     node-urls:
       - url: 127.0.0.1:2221
-  - api-interface: rest
+  - name: backup-2221-rest
+    api-interface: rest
     chain-id: LAV1
     node-urls:
       - url: 127.0.0.1:2221