1.9.1-0.0.1: [fix] - Duplicate Notifications

package.json

@@ -1,6 +1,6 @@
 {
   "name": "bnc-notify",
-  "version": "1.9.1",
+  "version": "1.9.1-0.0.1",
   "description": "Show web3 users realtime transaction notifications",
   "keywords": [
     "ethereum",

src/interfaces.ts

@@ -1,7 +1,8 @@
 import type {
   BitcoinTransactionLog,
   EthereumTransactionLog,
-  SDKError
+  SDKError,
+  TransactionHandler
 } from 'bnc-sdk/dist/types/src/interfaces'
 
 export interface InitOptions extends ConfigOptions {
@@ -14,10 +15,6 @@ export interface InitOptions extends ConfigOptions {
 
 export type ErrorHandler = (error: SDKError) => void
 
-export interface TransactionHandler {
-  (transaction: TransactionEvent): void
-}
-
 export interface TransactionEvent {
   emitterResult: void | boolean | CustomNotificationObject
   transaction: TransactionData

src/notify.ts

@@ -1,5 +1,6 @@
 import 'regenerator-runtime/runtime'
 import BlocknativeSdk from 'bnc-sdk'
+import type { TransactionHandler } from 'bnc-sdk/dist/types/src/interfaces'
 import { get } from 'svelte/store'
 
 import uuid from 'uuid/v4'
@@ -13,7 +14,6 @@ import { createNotification } from './notifications'
 
 import type {
   InitOptions,
-  TransactionHandler,
   AppStore,
   API,
   Emitter,
@@ -26,7 +26,6 @@ import type {
 
 export {
   InitOptions,
-  TransactionHandler,
   TransactionEvent,
   System,
   TransactionEventCode,

src/transactions.ts

@@ -68,19 +68,18 @@ export function handlePreFlightEvent(
   })
 }
 
-export function handleTransactionEvent(event: {
-  transaction: TransactionData
-  emitterResult: boolean | void | CustomNotificationObject
-}) {
+export function handleTransactionEvent(event) {
   const { transaction, emitterResult } = event
+
   if (!transaction.id) {
     transaction.id = transaction.hash || transaction.txid
   }
 
-  const predicate = (tx: TransactionData) =>
-    transaction.replaceHash
-      ? tx.id === transaction.replaceHash
-      : tx.id === transaction.id
+  const predicate = (tx: TransactionData) => {
+    return transaction.replaceHash
+      ? tx.id === transaction.replaceHash || tx.hash === transaction.replaceHash
+      : tx.id === transaction.id || tx.hash === transaction.hash
+  }
 
   transactions.updateQueue(transaction, predicate)
 

src/utilities.ts

@@ -19,7 +19,7 @@ export function replaceOrAdd(
   const index = clone.findIndex(predicate)
 
   if (index !== -1) {
-    const { startTime, contractCall, status } = clone[index]
+    const { startTime, contractCall, status, id } = clone[index]
 
     // if current transaction is a speedup or cancel and new status is pending, ignore update
     if (
@@ -35,7 +35,8 @@ export function replaceOrAdd(
     clone[index] = {
       ...data,
       ...contractCallMerge,
-      startTime: startTime || serverStartTime
+      startTime: startTime || serverStartTime,
+      id
     }
     return clone
   }