Remove pusher

package.json

@@ -35,7 +35,6 @@
     "node-cache": "^5.1.2",
     "ora": "^5.4.1",
     "pg": "^8.11.1",
-    "pusher": "^5.1.3",
     "type-graphql": "^1.2.0-rc.1"
   },
   "devDependencies": {

src/config.ts

@@ -18,12 +18,6 @@ const config: ProcessorConfig = {
     redisDb: process.env.REDIS_DB ? parseInt(process.env.REDIS_DB, 10) : 0,
     redisSupportsTls: process.env.REDIS_SUPPORTS_TLS === 'true',
     redisPort: process.env.REDIS_PORT ? parseInt(process.env.REDIS_PORT, 10) : 6379,
-    pusher: {
-        appId: process.env.PUSHER_APP_ID,
-        key: process.env.PUSHER_APP_KEY,
-        secret: process.env.PUSHER_APP_SECRET,
-        cluster: process.env.PUSHER_APP_CLUSTER,
-    },
     marketplaceUrl: process.env.MARKETPLACE_URL || 'https://beta.nft.io',
     shouldFetchAccounts: process.env.FETCH_ACCOUNTS !== 'false',
     sentryDsn: process.env.SENTRY_DSN,

src/mappings/marketplace/events/auction_finalized.ts

@@ -17,8 +17,6 @@ import {
 import { CommonContext } from '../../types/contexts'
 import { Event } from '../../../types/generated/support'
 import { CollectionService } from '../../../services'
-import { Pusher } from '../../../common/pusher'
-import { safeJson } from '../../../common/tools'
 import { getBestListing } from '../../util/entities'
 
 function getEventData(ctx: CommonContext, event: Event) {
@@ -98,7 +96,7 @@ export async function auctionFinalized(
         }),
     })
 
-    const eventData: [EventModel, AccountTokenEvent] | undefined = [
+    return [
         event,
         new AccountTokenEvent({
             id: item.event.id,
@@ -108,8 +106,4 @@ export async function auctionFinalized(
             event,
         }),
     ]
-
-    await Pusher.getInstance().trigger('marketplace', 'auctionFinalized', safeJson(eventData))
-
-    return eventData
 }

src/mappings/marketplace/events/bid_placed.ts

@@ -18,8 +18,6 @@ import { CommonContext } from '../../types/contexts'
 import { Event } from '../../../types/generated/support'
 import { CollectionService } from '../../../services'
 import { getBestListing, getOrCreateAccount } from '../../util/entities'
-import { Pusher } from '../../../common/pusher'
-import { safeJson } from '../../../common/tools'
 
 function getEventData(ctx: CommonContext, event: Event) {
     const data = new MarketplaceBidPlacedEvent(ctx, event)
@@ -90,7 +88,7 @@ export async function bidPlaced(
         }),
     })
 
-    const eventData: [EventModel, AccountTokenEvent] | undefined = [
+    return [
         event,
         new AccountTokenEvent({
             id: item.event.id,
@@ -99,8 +97,4 @@ export async function bidPlaced(
             event,
         }),
     ]
-
-    await Pusher.getInstance().trigger('marketplace', 'bidPlaced', safeJson(eventData))
-
-    return eventData
 }

src/mappings/marketplace/events/listing_cancelled.ts

@@ -14,8 +14,6 @@ import {
 import { Event } from '../../../types/generated/support'
 import { CollectionService } from '../../../services'
 import { CommonContext } from '../../types/contexts'
-import { Pusher } from '../../../common/pusher'
-import { safeJson } from '../../../common/tools'
 import { getBestListing } from '../../util/entities'
 
 function getEventData(ctx: CommonContext, event: Event) {
@@ -79,7 +77,7 @@ export async function listingCancelled(
         }),
     })
 
-    const eventData: [EventModel, AccountTokenEvent] | undefined = [
+    return [
         event,
         new AccountTokenEvent({
             id: item.event.id,
@@ -88,8 +86,4 @@ export async function listingCancelled(
             event,
         }),
     ]
-
-    await Pusher.getInstance().trigger('marketplace', 'listingCancelled', safeJson(eventData))
-
-    return eventData
 }

src/mappings/marketplace/events/listing_created.ts

@@ -23,8 +23,6 @@ import { Event } from '../../../types/generated/support'
 import { CollectionService } from '../../../services'
 import { CommonContext } from '../../types/contexts'
 import { getOrCreateAccount } from '../../util/entities'
-import { Pusher } from '../../../common/pusher'
-import { safeJson } from '../../../common/tools'
 
 function getEventData(ctx: CommonContext, event: Event) {
     const data = new MarketplaceListingCreatedEvent(ctx, event)
@@ -119,12 +117,8 @@ export async function listingCreated(
         }),
     })
 
-    const eventData: [EventModel, AccountTokenEvent] | undefined = [
+    return [
         event,
         new AccountTokenEvent({ id: item.event.id, token: new Token({ id: makeAssetId.id }), from: listing.seller, event }),
     ]
-
-    await Pusher.getInstance().trigger('marketplace', 'listingCreated', safeJson(eventData))
-
-    return eventData
 }

src/mappings/marketplace/events/listing_filled.ts

@@ -19,8 +19,6 @@ import {
 import { Event } from '../../../types/generated/support'
 import { CollectionService } from '../../../services'
 import { CommonContext } from '../../types/contexts'
-import { Pusher } from '../../../common/pusher'
-import { safeJson } from '../../../common/tools'
 import { getBestListing } from '../../util/entities'
 
 function getEventData(ctx: CommonContext, event: Event) {
@@ -107,7 +105,7 @@ export async function listingFilled(
         }),
     })
 
-    const eventData: [EventModel, AccountTokenEvent] | undefined = [
+    return [
         event,
         new AccountTokenEvent({
             id: item.event.id,
@@ -117,8 +115,4 @@ export async function listingFilled(
             event,
         }),
     ]
-
-    await Pusher.getInstance().trigger('marketplace', 'listingFilled', safeJson(eventData))
-
-    return eventData
 }

src/types/custom/processorConfig.ts

@@ -1,5 +1,4 @@
 import { SubstrateProcessor } from '@subsquid/substrate-processor'
-import Queue from 'bull'
 
 type Parameters<T> = T extends (...args: infer T) => any ? T : never
 
@@ -23,7 +22,6 @@ export interface ProcessorConfig {
     redisDb: number
     redisSupportsTls: boolean
     redisPort: number
-    pusher: any
     marketplaceUrl: string
     shouldFetchAccounts: boolean
     sentryDsn?: string