From 06d23991c5a8b1ff2fe9fe1d1d3a92bc5fe3bd91 Mon Sep 17 00:00:00 2001 From: Juraj Piar Date: Wed, 10 Jun 2020 10:42:07 +0100 Subject: [PATCH] feat: adds optional emit fn to rns services --- src/services/rns/index.ts | 7 ++++--- src/services/rns/rns.processor.ts | 4 ++-- 2 files changed, 6 insertions(+), 5 deletions(-) diff --git a/src/services/rns/index.ts b/src/services/rns/index.ts index 54311729..8e2c3c94 100644 --- 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 { diff --git a/src/services/rns/rns.processor.ts b/src/services/rns/rns.processor.ts index b3cb9f33..bdced998 100644 --- 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 } })