feat: adds optional emit fn to rns services

rsksmart · Jun 10, 2020 · 06d2399 · 06d2399
1 parent 2b4cd27
commit 06d2399
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 5 deletions.
diff --git a/src/services/rns/index.ts b/src/services/rns/index.ts
@@ -28,11 +28,12 @@ import eventProcessor from './rns.processor'
 const logger = loggingFactory('rns')
 
 export class RnsService extends Service {
+  emit?: Function
 }
 export interface RnsServices {
-  domains: RnsService
-  sold: RnsService
-  offers: RnsService
+  domains: RnsService & { emit?: Function }
+  sold: RnsService & { emit?: Function }
+  offers: RnsService & { emit?: Function }
 }
 
 function fetchEventsForService (eth: Eth, serviceName: string, abi: AbiItem[], dataPusher: (event: EventData) => void): Promise<void> {

diff --git a/src/services/rns/rns.processor.ts b/src/services/rns/rns.processor.ts
@@ -40,7 +40,7 @@ async function transferHandler (logger: Logger, eventData: EventData, _: Eth, se
     logger.info(`Transfer event: Transfer ${tokenId} created`)
   }
 
-  const domainsService = services.domains as any
+  const domainsService = services.domains
   const domain = await Domain.findByPk(tokenId)
 
   if (domain) {
@@ -69,7 +69,7 @@ async function expirationChangedHandler (logger: Logger, eventData: EventData, _
   const expirationDate = parseInt(normalizedTimestamp) * 1000
 
   const currentExpiration = await DomainExpiration.findByPk(tokenId)
-  const domainsService = services.domains as any
+  const domainsService = services.domains
 
   if (currentExpiration) {
     await DomainExpiration.update({ expirationDate }, { where: { tokenId } })