refactor: 💡 Node updated to use latest types and changes

Author: kostysh

src/node/index.ts

@@ -10,20 +10,16 @@ import { PeerId } from '@libp2p/interface-peer-id';
 import { peerIdFromString } from '@libp2p/peer-id';
 import { AbstractProvider, AbstractSigner, Wallet } from 'ethers';
 import { noncePeriod as defaultNoncePeriod } from '../constants.js';
-import {
-  buildOffer,
-  BuildOfferOptions,
-  GenericOfferOptions,
-  GenericQuery,
-  OfferData,
-} from '../shared/messages.js';
+import { GenericOfferOptions, GenericQuery, OfferData } from '../shared/types.js';
+import { buildOffer, BuildOfferOptions } from '../shared/messages.js';
 import { CenterSub, centerSub } from '../shared/pubsub.js';
 import { RequestManager, RequestEvent } from './requestManager.js';
 import { decodeText, encodeText } from '../utils/text.js';
 import { ContractConfig } from '../utils/contract.js';
 import { NodeOptions } from '../shared/options.js';
 import { parseSeconds } from '../utils/time.js';
 import { createLogger } from '../utils/logger.js';
+import { stringify } from '../utils/hash.js';
 
 const logger = createLogger('Node');
 
@@ -156,7 +152,7 @@ export class Node<
 
     this.serverPeerId = peerIdFromString(serverPeerIdString);
     this.requestManager = new RequestManager<CustomRequestQuery>({
-      noncePeriod: parseSeconds(noncePeriod ?? defaultNoncePeriod),
+      noncePeriod: Number(parseSeconds(noncePeriod ?? defaultNoncePeriod)),
     });
     this.requestManager.addEventListener('request', (e) => this.handleRequest(e));
     logger.trace('Node instantiated');
@@ -261,7 +257,7 @@ export class Node<
     });
     logger.trace(`Offer #${offer.id} is built`);
 
-    await this.libp2p.pubsub.publish(offer.request.id, encodeText(JSON.stringify(offer)));
+    await this.libp2p.pubsub.publish(offer.request.id, encodeText(stringify(offer)));
     logger.trace(`Offer #${offer.id} is published`);
 
     return offer;

src/node/requestManager.ts

@@ -1,5 +1,5 @@
 import { EventEmitter, CustomEvent } from '@libp2p/interfaces/events';
-import { RequestData, GenericQuery } from '../shared/messages.js';
+import { RequestData, GenericQuery } from '../shared/types.js';
 import { RequestManagerOptions } from '../shared/options.js';
 import { isExpired, nowSec, parseSeconds } from '../utils/time.js';
 import { createLogger } from '../utils/logger.js';
@@ -40,7 +40,7 @@ export class RequestManager<CustomRequestQuery extends GenericQuery> extends Eve
 
     this.cache = new Map<string, RequestData<CustomRequestQuery>>(); // requestId => request
     this.cacheTopic = new Map<string, string>(); // requestId => topic
-    this.noncePeriod = parseSeconds(noncePeriod);
+    this.noncePeriod = Number(parseSeconds(noncePeriod));
   }
 
   add(topic: string, data: string) {
@@ -51,7 +51,7 @@ export class RequestManager<CustomRequestQuery extends GenericQuery> extends Eve
       return;
     }
 
-    if (nowSec() + this.noncePeriod > requestData.expire) {
+    if (BigInt(nowSec() + this.noncePeriod) > BigInt(requestData.expire)) {
       logger.trace(`Request #${requestData.id} will expire before it can bee processed`);
       return;
     }