fix query

rainlanguage · Nov 11, 2024 · 3c2fd82 · 3c2fd82
1 parent cafaf5d
commit 3c2fd82
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 7 deletions.
diff --git a/src/index.ts b/src/index.ts
@@ -9,7 +9,7 @@ import { processOrders } from "./processOrders";
 import { Context, Span } from "@opentelemetry/api";
 import { checkSgStatus, handleSgResults } from "./sg";
 import { Tracer } from "@opentelemetry/sdk-trace-base";
-import { getQuery, SgOrder, statusCheckQuery } from "./query";
+import { querySgOrders, SgOrder, statusCheckQuery } from "./query";
 import { BotConfig, BundledOrders, CliOptions, RoundReport, SgFilter, RpcRecord } from "./types";
 import {
     getChainConfig,
@@ -62,7 +62,7 @@ export async function getOrderDetails(
             availableSgs.forEach((v) => {
                 if (v && typeof v === "string")
                     promises.push(
-                        getQuery(
+                        querySgOrders(
                             v,
                             sgFilters?.orderHash,
                             sgFilters?.orderOwner,

diff --git a/src/query.ts b/src/query.ts
@@ -94,7 +94,7 @@ export function getQueryPaginated(
  * @param orderbook - orderbook filter
  * @param timeout - timeout
  */
-export async function getQuery(
+export async function querySgOrders(
     subgraph: string,
     orderHash?: string,
     owner?: string,
@@ -142,7 +142,7 @@ export const statusCheckQuery = `{
 }`;
 
 export const getRemoveOrdersQuery = (start: number, end: number) => {
-    return `removeOrders(where: { transaction_: { timestamp_gt: "${start.toString()}", timestamp_lte: "${end.toString()}" } }) {
+    return `{removeOrders(where: { transaction_: { timestamp_gt: "${start.toString()}", timestamp_lte: "${end.toString()}" } }) {
     order {
         id
         owner
@@ -175,11 +175,11 @@ export const getRemoveOrdersQuery = (start: number, end: number) => {
     transaction {
       timestamp
     }
-}`;
+}}`;
 };
 
 export const getAddOrdersQuery = (start: number, end: number) => {
-    return `addOrders(where: { transaction_: { timestamp_gt: "${start.toString()}", timestamp_gt: "${end.toString()}" } }) {
+    return `{addOrders(where: { transaction_: { timestamp_gt: "${start.toString()}", timestamp_lte: "${end.toString()}" } }) {
     order {
         id
         owner
@@ -212,7 +212,7 @@ export const getAddOrdersQuery = (start: number, end: number) => {
     transaction {
       timestamp
     }
-}`;
+}}`;
 };
 
 /**