Use GQL schema stitching to proxy queries to multiple watchers (#18)

* Use apollo federation router to proxy gql queries to multiple watchers * Use graphql stitch to proxy requests to all watchers * Load watcher endpoints and prefixes from json * Transpile typescript and setup lint * Change conflicting metrics ports * Add comments
cerc-io · May 2, 2023 · 86fe1c0 · 86fe1c0
1 parent a44de43
commit 86fe1c0
Show file tree

Hide file tree

Showing 19 changed files with 1,639 additions and 51 deletions.
diff --git a/packages/azimuth-watcher/environments/local.toml b/packages/azimuth-watcher/environments/local.toml
@@ -1,6 +1,6 @@
 [server]
   host = "127.0.0.1"
-  port = 3009
+  port = 3001
   kind = "lazy"
 
   # Checkpointing state.
@@ -48,8 +48,8 @@
 
 [upstream]
   [upstream.ethServer]
-    gqlApiEndpoint = "http://127.0.0.1:8082/graphql"
-    rpcProviderEndpoint = "http://127.0.0.1:8081"
+    gqlApiEndpoint = "http://127.0.0.1:8083/graphql"
+    rpcProviderEndpoint = "http://127.0.0.1:8082"
 
   [upstream.cache]
     name = "requests"

diff --git a/packages/censures-watcher/environments/local.toml b/packages/censures-watcher/environments/local.toml
@@ -1,6 +1,6 @@
 [server]
   host = "127.0.0.1"
-  port = 3009
+  port = 3002
   kind = "lazy"
 
   # Checkpointing state.
@@ -32,9 +32,9 @@
 
 [metrics]
   host = "127.0.0.1"
-  port = 9000
+  port = 9002
   [metrics.gql]
-    port = 9001
+    port = 9003
 
 [database]
   type = "postgres"
@@ -48,8 +48,8 @@
 
 [upstream]
   [upstream.ethServer]
-    gqlApiEndpoint = "http://127.0.0.1:8082/graphql"
-    rpcProviderEndpoint = "http://127.0.0.1:8081"
+    gqlApiEndpoint = "http://127.0.0.1:8083/graphql"
+    rpcProviderEndpoint = "http://127.0.0.1:8082"
 
   [upstream.cache]
     name = "requests"

diff --git a/packages/claims-watcher/environments/local.toml b/packages/claims-watcher/environments/local.toml
@@ -1,6 +1,6 @@
 [server]
   host = "127.0.0.1"
-  port = 3009
+  port = 3003
   kind = "lazy"
 
   # Checkpointing state.
@@ -32,9 +32,9 @@
 
 [metrics]
   host = "127.0.0.1"
-  port = 9000
+  port = 9004
   [metrics.gql]
-    port = 9001
+    port = 9005
 
 [database]
   type = "postgres"
@@ -48,8 +48,8 @@
 
 [upstream]
   [upstream.ethServer]
-    gqlApiEndpoint = "http://127.0.0.1:8082/graphql"
-    rpcProviderEndpoint = "http://127.0.0.1:8081"
+    gqlApiEndpoint = "http://127.0.0.1:8083/graphql"
+    rpcProviderEndpoint = "http://127.0.0.1:8082"
 
   [upstream.cache]
     name = "requests"

diff --git a/packages/conditional-star-release-watcher/environments/local.toml b/packages/conditional-star-release-watcher/environments/local.toml
@@ -1,6 +1,6 @@
 [server]
   host = "127.0.0.1"
-  port = 3009
+  port = 3004
   kind = "lazy"
 
   # Checkpointing state.
@@ -32,9 +32,9 @@
 
 [metrics]
   host = "127.0.0.1"
-  port = 9000
+  port = 9006
   [metrics.gql]
-    port = 9001
+    port = 9007
 
 [database]
   type = "postgres"
@@ -48,8 +48,8 @@
 
 [upstream]
   [upstream.ethServer]
-    gqlApiEndpoint = "http://127.0.0.1:8082/graphql"
-    rpcProviderEndpoint = "http://127.0.0.1:8081"
+    gqlApiEndpoint = "http://127.0.0.1:8083/graphql"
+    rpcProviderEndpoint = "http://127.0.0.1:8082"
 
   [upstream.cache]
     name = "requests"

diff --git a/packages/delegated-sending-watcher/environments/local.toml b/packages/delegated-sending-watcher/environments/local.toml
@@ -1,6 +1,6 @@
 [server]
   host = "127.0.0.1"
-  port = 3009
+  port = 3005
   kind = "lazy"
 
   # Checkpointing state.
@@ -32,9 +32,9 @@
 
 [metrics]
   host = "127.0.0.1"
-  port = 9000
+  port = 9008
   [metrics.gql]
-    port = 9001
+    port = 9009
 
 [database]
   type = "postgres"
@@ -48,8 +48,8 @@
 
 [upstream]
   [upstream.ethServer]
-    gqlApiEndpoint = "http://127.0.0.1:8082/graphql"
-    rpcProviderEndpoint = "http://127.0.0.1:8081"
+    gqlApiEndpoint = "http://127.0.0.1:8083/graphql"
+    rpcProviderEndpoint = "http://127.0.0.1:8082"
 
   [upstream.cache]
     name = "requests"

diff --git a/packages/ecliptic-watcher/environments/local.toml b/packages/ecliptic-watcher/environments/local.toml
@@ -1,6 +1,6 @@
 [server]
   host = "127.0.0.1"
-  port = 3009
+  port = 3006
   kind = "lazy"
 
   # Checkpointing state.
@@ -32,9 +32,9 @@
 
 [metrics]
   host = "127.0.0.1"
-  port = 9000
+  port = 9010
   [metrics.gql]
-    port = 9001
+    port = 9011
 
 [database]
   type = "postgres"
@@ -48,8 +48,8 @@
 
 [upstream]
   [upstream.ethServer]
-    gqlApiEndpoint = "http://127.0.0.1:8082/graphql"
-    rpcProviderEndpoint = "http://127.0.0.1:8081"
+    gqlApiEndpoint = "http://127.0.0.1:8083/graphql"
+    rpcProviderEndpoint = "http://127.0.0.1:8082"
 
   [upstream.cache]
     name = "requests"

diff --git a/packages/gateway-server/.eslintignore b/packages/gateway-server/.eslintignore
@@ -0,0 +1,2 @@
+# Don't lint build output.
+dist
diff --git a/packages/gateway-server/.eslintrc.json b/packages/gateway-server/.eslintrc.json
@@ -0,0 +1,28 @@
+{
+    "env": {
+        "browser": true,
+        "es2021": true
+    },
+    "extends": [
+        "semistandard",
+        "plugin:@typescript-eslint/recommended"
+    ],
+    "parser": "@typescript-eslint/parser",
+    "parserOptions": {
+        "ecmaVersion": 12,
+        "sourceType": "module"
+    },
+    "plugins": [
+        "@typescript-eslint"
+    ],
+    "rules": {
+        "indent": ["error", 2, { "SwitchCase": 1 }],
+        "@typescript-eslint/no-explicit-any": "off",
+        "@typescript-eslint/explicit-module-boundary-types": [
+            "warn",
+            {
+                "allowArgumentsExplicitlyTypedAsAny": true
+            }
+        ]
+    }
+}
diff --git a/packages/gateway-server/.gitignore b/packages/gateway-server/.gitignore
@@ -0,0 +1,5 @@
+node_modules/
+dist/
+
+.vscode
+.idea