fix: switch niftysave analyzer to pull from new queue endpoint (#369)

nftstorage · Sep 1, 2021 · 98bf9c7 · 98bf9c7
1 parent 6f6fc24
commit 98bf9c7
Show file tree

Hide file tree

Showing 8 changed files with 2,792 additions and 133 deletions.
diff --git a/packages/database/fauna/migrations/2021-09-01T22_20_52.420Z/schema.graphql b/packages/database/fauna/migrations/2021-09-01T22_20_52.420Z/schema.graphql
diff --git a/.../database/fauna/migrations/2021-09-01T22_20_52.420Z/update-function-scheduledAnalyses.fql b/.../database/fauna/migrations/2021-09-01T22_20_52.420Z/update-function-scheduledAnalyses.fql
@@ -0,0 +1,40 @@
+Update(Function("scheduledAnalyses"), {
+  "body": Query(Lambda(["size", "after", "before"], Let([{
+    "refs": Call("paginate", [Documents(Collection("ScheduledAnalyze")), {
+      "size": Var("size"),
+      "after": Var("after"),
+      "before": Var("before")
+    }])
+  }], Map(Var("refs"), Lambda("ref", Get(Var("ref"))))))),
+  "data": {
+    "gql": {
+      "meta": {
+        "location": "Query",
+        "field": {
+          "name": "scheduledAnalyses",
+          "directives": [{
+            "name": "resolver",
+            "args": {
+              "name": "scheduledAnalyses",
+              "paginated": true
+            }
+          }, {
+            "name": "relation",
+            "args": {}
+          }],
+          "description": "Returns page of scheduled analyze tasks",
+          "type": {
+            "NotNull": {
+              "List": {
+                "NotNull": {
+                  "Named": "ScheduledAnalyze"
+                }
+              }
+            }
+          }
+        }
+      }
+    }
+  },
+  "role": null
+})
diff --git a/packages/database/fauna/resources/Function/scheduledAnalyses.fql b/packages/database/fauna/resources/Function/scheduledAnalyses.fql
@@ -13,7 +13,7 @@ CreateFunction({
       ['size', 'after', 'before'],
       Let(
         {
-          refs: Call('paginate', Collection('ScheduledAnalyze'), {
+          refs: Call('paginate', Documents(Collection('ScheduledAnalyze')), {
             size: Var('size'),
             after: Var('after'),
             before: Var('before'),