feat: add element market addresses on more chains

package.json

@@ -24,7 +24,7 @@
   "dependencies": {
     "@bull-board/express": "^3.9.0",
     "@opensea/stream-js": "^0.0.20",
-    "@reservoir0x/sdk": "^0.0.342",
+    "@reservoir0x/sdk": "^0.0.360",
     "@types/date-fns": "^2.6.0",
     "@types/express": "^4.17.13",
     "@types/ioredis": "^4.28.7",

src/jobs/element-sync/index.ts

@@ -6,11 +6,11 @@ import * as realtimeQueueOffers from "./queues/realtime-queue-offers";
 import { logger } from "../../common/logger";
 import { acquireLock, redis } from "../../common/redis";
 import { config } from "../../config";
+import { Element } from "../../utils/element";
 
 if (config.doRealtimeWork) {
   cron.schedule("*/5 * * * * *", async () => {
-    // Element only supports mainnet
-    if (_.indexOf([1], config.chainId) !== -1) {
+    if (new Element().getChainName()) {
       const lockAcquired = await acquireLock("element-sync-lock", 60 * 5);
       if (lockAcquired) {
         const cacheKey = "element-sync-cursor";
@@ -31,8 +31,7 @@ if (config.doRealtimeWork) {
   });
 
   cron.schedule("*/5 * * * * *", async () => {
-    // Element only supports mainnet
-    if (_.indexOf([1], config.chainId) !== -1) {
+    if (new Element().getChainName()) {
       const lockAcquired = await acquireLock("element-sync-offers-lock", 60 * 5);
       if (lockAcquired) {
         const cacheKey = "element-sync-offers-cursor";

src/jobs/element-sync/utils.ts

@@ -22,7 +22,7 @@ export const fetchOrders = async (side: "sell" | "buy", listedAfter = 0, listedB
   let done = false;
   while (!done) {
     const url = element.buildFetchOrdersURL({
-      chain: "eth",
+      chain: element.getChainName()!,
       side: side === "sell" ? "1" : "0",
       listed_after: listedAfter > 0 ? listedAfter : undefined,
       listed_before: listedBefore > 0 ? listedBefore : undefined,

src/utils/element.ts

@@ -3,7 +3,7 @@ import * as Sdk from "@reservoir0x/sdk";
 import { config } from "../config";
 
 type FetchOrdersParams = {
-  chain: "eth" | "bsc" | "polygon" | "avalanche" | "base";
+  chain: string;
   token_ids?: string;
   asset_contract_address?: string;
   sale_kind?: string;
@@ -54,6 +54,29 @@ export enum SaleKind {
 }
 
 export class Element {
+  public getChainName() {
+    switch (config.chainId) {
+      case 1:
+        return "eth";
+      case 56:
+        return "bsc";
+      case 137:
+        return "polygon";
+      case 324:
+        return "zksync";
+      case 8453:
+        return "base";
+      case 42161:
+        return "arbitrum";
+      case 43114:
+        return "avalanche";
+      case 59144:
+        return "linea";
+      default:
+        return undefined;
+    }
+  }
+
   // https://api.element.market/openapi/#/
   public buildFetchOrdersURL(params: FetchOrdersParams) {
     // For now there's no support for testnets

yarn.lock

@@ -1920,10 +1920,10 @@
   resolved "https://registry.npmjs.org/@protobufjs/utf8/-/utf8-1.1.0.tgz"
   integrity sha1-p3c2C1s5oaLlEG+OhY8v0tBgxXA=
 
-"@reservoir0x/sdk@^0.0.342":
-  version "0.0.342"
-  resolved "https://registry.yarnpkg.com/@reservoir0x/sdk/-/sdk-0.0.342.tgz#cd29d0744134c260b7b3bb56c53b4d8850e9a4e0"
-  integrity sha512-sNAvs9x/UtQorUWZzjSvcK3MpmesidmSi3sDFWbmQUyKddiHcE9bIq7kU8WyqNAIzvHxxjZhSfxx7naoUyavkA==
+"@reservoir0x/sdk@^0.0.360":
+  version "0.0.360"
+  resolved "https://registry.yarnpkg.com/@reservoir0x/sdk/-/sdk-0.0.360.tgz#b30cd4dd8279ae1510e21b76164cab521b072bf3"
+  integrity sha512-3VfY5fAvqNMq6bAikZ2kpSb1k5CZ1zudKUne8lg9X5MQf9SZTwvnwL6coCRiNUdjjW1BtfydYR56nNW1d0AO3g==
   dependencies:
     "@uniswap/smart-order-router" "^3.0.4"
     decimal.js "^10.4.3"