Add ChallengesApi, RewardManager to SDK (#7026)

AudiusProject · Jan 24, 2024 · 439f10b · 439f10b
1 parent 3f55d5d
commit 439f10b
Show file tree

Hide file tree

Showing 95 changed files with 4,642 additions and 1,493 deletions.
diff --git a/dev-tools/compose/docker-compose.yml b/dev-tools/compose/docker-compose.yml
@@ -41,7 +41,7 @@ services:
   db:
     image: postgres:11.4
     shm_size: 2g
-    command: postgres -c shared_buffers=2GB
+    command: postgres -c shared_buffers=2GB -c max_connections=300
     restart: unless-stopped
     ports:
       - 5432:5432

diff --git a/dev-tools/compose/nginx_ingress.conf b/dev-tools/compose/nginx_ingress.conf
@@ -281,6 +281,21 @@ server {
     server_name audius-protocol-solana-test-validator-1;
 
     location / {
+        try_files /nonexistent @$http_upgrade;
+    }
+
+    location @websocket {
+        resolver 127.0.0.11 valid=30s;
+        set $upstream audius-protocol-solana-test-validator-1:8900;
+        proxy_http_version 1.1;
+        proxy_pass http://$upstream;
+        proxy_read_timeout 300s;
+        proxy_connect_timeout 75s;
+        proxy_set_header Upgrade $http_upgrade;
+        proxy_set_header Connection $connection_upgrade;
+    }
+
+    location @ {
         resolver 127.0.0.11 valid=30s;
         set $upstream audius-protocol-solana-test-validator-1:8899;
         proxy_pass http://$upstream;

diff --git a/package-lock.json b/package-lock.json
diff --git a/packages/discovery-provider/integration_tests/queries/test_get_attestation.py b/packages/discovery-provider/integration_tests/queries/test_get_attestation.py
@@ -274,15 +274,17 @@ def test_get_attestation_weekly_pool_exhausted(app):
 
 
 @pytest.fixture
-def patch_get_all_other_nodes():
+def patch_get_all_nodes():
     with patch(
-        "src.queries.get_attestation.get_all_other_discovery_nodes_wallets_cached",
-        return_value=["0x94e140D27F3d5EE9EcA0109A71CcBa0109964DCa"],
+        "src.queries.get_attestation.get_all_discovery_nodes_cached",
+        return_value=[
+            {"delegateOwnerWallet": "0x94e140D27F3d5EE9EcA0109A71CcBa0109964DCa"}
+        ],
     ):
         yield
 
 
-def test_get_create_sender_attestation(app, patch_get_all_other_nodes):
+def test_get_create_sender_attestation(app, patch_get_all_nodes):
     new_sender_address = "0x94e140D27F3d5EE9EcA0109A71CcBa0109964DCa"
     owner_wallet, sender_attestation = get_create_sender_attestation(new_sender_address)
 
@@ -315,7 +317,7 @@ def test_get_create_sender_attestation(app, patch_get_all_other_nodes):
     )
 
 
-def test_get_create_sender_attestation_not_registered(app, patch_get_all_other_nodes):
+def test_get_create_sender_attestation_not_registered(app, patch_get_all_nodes):
     new_sender_address = "0x04e140D27F3d5EE9EcA0109A71CcBa0109964DCa"
     with pytest.raises(
         Exception,

diff --git a/packages/discovery-provider/integration_tests/tasks/entity_manager/test_index_skip_tx.py b/packages/discovery-provider/integration_tests/tasks/entity_manager/test_index_skip_tx.py
@@ -31,8 +31,12 @@ def get_events_side_effect(_, tx_receipt):
     )
 
     mocker.patch(
-        "src.queries.confirm_indexing_transaction_error.get_all_other_discovery_nodes_cached",
-        return_value=["node1", "node2", "node3"],
+        "src.queries.confirm_indexing_transaction_error.get_all_discovery_nodes_cached",
+        return_value=[
+            {"endpoint": "node1", "delegateOwnerWallet": "wallet1"},
+            {"endpoint": "node2", "delegateOwnerWallet": "wallet2"},
+            {"endpoint": "node3", "delegateOwnerWallet": "wallet3"},
+        ],
         autospec=True,
     )
 

diff --git a/packages/discovery-provider/plugins/pedalboard/apps/relay/src/scripts/sandbox.ts b/packages/discovery-provider/plugins/pedalboard/apps/relay/src/scripts/sandbox.ts
@@ -27,7 +27,7 @@ export const main = async () => {
   console.log(`using ${initialSelectedNode}`);
 
   const discoveryNodeSelector = new DiscoveryNodeSelector({
-    initialSelectedNode,
+    initialSelectedNode: initialSelectedNode.endpoint,
   });
 
   const entityManager = new EntityManager({