chore: 🤖 use superjson for serialisation

Author: Galeaf11

examples/client/package.json

@@ -25,6 +25,9 @@
     "@libp2p/interfaces": "^3.3.2",
     "luxon": "^3.3.0"
   },
+  "dependencies": {
+    "superjson": "^1.13.1"
+  },
   "eslintConfig": {
     "extends": [
       "react-app"

examples/client/src/components/MakeDeal.tsx

@@ -1,5 +1,6 @@
 import { useState, useCallback, useEffect } from 'react';
-import { Hash, stringify } from 'viem';
+import { Hash } from 'viem';
+import { stringify } from 'superjson';
 import { ClientDealsManager } from '@windingtree/sdk-client';
 import { OfferData } from '@windingtree/sdk-types';
 import { RequestQuery, OfferOptions } from 'wtmp-protocol-examples-shared-files';

examples/client/src/components/Offers.tsx

@@ -1,5 +1,5 @@
 import { useState, useEffect } from 'react';
-import { stringify } from 'viem';
+import { stringify } from 'superjson';
 import { isExpired } from '@windingtree/sdk-utils';
 import { OfferData } from '@windingtree/sdk-types';
 import { RequestQuery, OfferOptions } from 'wtmp-protocol-examples-shared-files';

examples/client/src/components/Requests.tsx

@@ -3,6 +3,7 @@ import { ClientRequestRecord } from '@windingtree/sdk-client';
 import { OfferData } from '@windingtree/sdk-types';
 import { RequestQuery, OfferOptions } from 'wtmp-protocol-examples-shared-files';
 import { centerEllipsis } from '@windingtree/sdk-react/utils';
+import { stringify } from 'superjson';
 
 export type RequestsRegistryRecord = Required<
   ClientRequestRecord<RequestQuery, OfferOptions>
@@ -49,7 +50,7 @@ export const Requests = ({
             <tr key={index}>
               <td>{r.data.topic}</td>
               <td>{centerEllipsis(r.data.id)}</td>
-              <td>{JSON.stringify(r.data.query)}</td>
+              <td>{stringify(r.data.query)}</td>
               <td>{subscribed && subscribed(r.data.id) ? '✅' : 'no'}</td>
               <td>{isExpired(r.data.expire) ? '✅' : 'no'}</td>
               <td>

examples/manager/package.json

@@ -27,7 +27,8 @@
   "dependencies": {
     "@windingtree/contracts": "1.0.0-beta.12",
     "@windingtree/sdk-types": "workspace:*",
-    "@windingtree/sdk-utils": "workspace:*"
+    "@windingtree/sdk-utils": "workspace:*",
+    "superjson": "^1.13.1"
   },
   "eslintConfig": {
     "extends": [

examples/manager/src/components/DealSeek.tsx

@@ -1,6 +1,7 @@
 import { useCallback, useState } from 'react';
 import { DateTime } from 'luxon';
-import { Hash, stringify } from 'viem';
+import { Hash } from 'viem';
+import { stringify } from 'superjson';
 import { useConfig, useNode } from '@windingtree/sdk-react/providers';
 import { DealRecord, DealStatus, GenericOfferOptions, GenericQuery } from '@windingtree/sdk-types';
 import { formatBalance } from '@windingtree/sdk-react/utils';

examples/manager/src/components/Deals.tsx

@@ -1,6 +1,6 @@
 import { useCallback, useEffect, useState } from 'react';
 import { DateTime } from 'luxon';
-import { stringify } from 'viem';
+import { stringify } from 'superjson';
 import { useConfig, useNode } from '@windingtree/sdk-react/providers';
 import { DealRecord, DealStatus, GenericOfferOptions, GenericQuery } from '@windingtree/sdk-types';
 import { centerEllipsis, formatBalance } from '@windingtree/sdk-react/utils';

packages/client/package.json

@@ -49,6 +49,7 @@
     "@windingtree/sdk-types": "workspace:*",
     "@windingtree/sdk-utils": "workspace:*",
     "libp2p": "^0.45.9",
+    "superjson": "^1.13.1",
     "viem": "^1.3.0"
   },
   "scripts": {

packages/client/src/index.ts

@@ -9,7 +9,8 @@ import { multiaddr, Multiaddr } from '@multiformats/multiaddr';
 import { peerIdFromString } from '@libp2p/peer-id';
 import { PeerId } from '@libp2p/interface-peer-id';
 import { OPEN } from '@libp2p/interface-connection/status';
-import { stringify } from 'viem';
+import { stringify, parse } from 'superjson';
+
 import {
   OfferData,
   GenericOfferOptions,
@@ -283,7 +284,7 @@ export class Client<
 
         try {
           /** Check is the message is an offer */
-          const offer = JSON.parse(decodeText(detail.data)) as OfferData<
+          const offer = parse(decodeText(detail.data)) as OfferData<
             CustomRequestQuery,
             CustomOfferOptions
           >;

packages/contracts-manger/package.json

@@ -31,6 +31,7 @@
     "@windingtree/contracts": "1.0.0-beta.12",
     "@windingtree/sdk-logger": "workspace:*",
     "@windingtree/sdk-types": "workspace:*",
+    "superjson": "^1.13.1",
     "viem": "^1.3.0"
   },
   "scripts": {

packages/contracts-manger/src/index.ts

@@ -15,8 +15,8 @@ import {
   stringToHex,
   getAddress,
   zeroAddress,
-  stringify,
 } from 'viem';
+import { stringify } from 'superjson';
 import {
   marketABI,
   erc20_18ABI,

packages/node/package.json

@@ -47,6 +47,7 @@
     "@windingtree/sdk-types": "workspace:*",
     "@windingtree/sdk-utils": "workspace:*",
     "libp2p": "^0.45.9",
+    "superjson": "^1.13.1",
     "viem": "^1.3.0"
   },
   "scripts": {

packages/node/src/index.ts

@@ -9,7 +9,9 @@ import { OPEN } from '@libp2p/interface-connection/status';
 import { multiaddr, Multiaddr } from '@multiformats/multiaddr';
 import { PeerId } from '@libp2p/interface-peer-id';
 import { peerIdFromString } from '@libp2p/peer-id';
-import { Hex, Hash, Chain, stringify } from 'viem';
+import { Hex, Hash, Chain } from 'viem';
+import { stringify } from 'superjson';
+
 import { mnemonicToAccount, privateKeyToAccount } from 'viem/accounts';
 import {
   Contracts,

packages/node/src/requestManager.ts

@@ -6,6 +6,7 @@ import {
 } from '@windingtree/sdk-types';
 import { isExpired, nowSec, parseSeconds } from '@windingtree/sdk-utils';
 import { createLogger } from '@windingtree/sdk-logger';
+import { parse } from 'superjson';
 
 const logger = createLogger('NodeRequestManager');
 
@@ -112,7 +113,7 @@ export class NodeRequestManager<
    */
   add(requestTopic: string, data: string) {
     try {
-      const requestData = JSON.parse(data) as RequestData<CustomRequestQuery>;
+      const requestData = parse<RequestData<CustomRequestQuery>>(data);
 
       // TODO: Implement validation of `data` type and `requestTopic`
 

packages/node/test/requestManager.spec.ts

@@ -1,4 +1,4 @@
-import { stringify } from 'viem';
+import { parse, stringify } from 'superjson';
 import { describe, expect, it, beforeEach } from '@windingtree/sdk-test-utils';
 import { NodeRequestManager } from '../src/index.js';
 
@@ -138,7 +138,7 @@ describe('Node.NodeRequestManager', () => {
           'request',
           (event) => {
             expect(event.detail.topic).to.equal(requestTopic);
-            expect(event.detail.data).to.deep.equal(JSON.parse(data));
+            expect(event.detail.data).to.deep.equal(parse(data));
             done(true);
           },
           { once: true },
@@ -151,12 +151,12 @@ describe('Node.NodeRequestManager', () => {
   describe('#prune', () => {
     it('should remove expired requests from cache', () => {
       const requestTopic = 'testTopic';
-      const data1 = JSON.stringify({
+      const data1 = stringify({
         id: '1',
         nonce: 1,
         expire: Math.floor(Date.now() / 1000) + 20,
       });
-      const data2 = JSON.stringify({
+      const data2 = stringify({
         id: '2',
         nonce: 1,
         expire: Math.floor(Date.now() / 1000) - 20,
@@ -174,7 +174,7 @@ describe('Node.NodeRequestManager', () => {
   describe('#clear', () => {
     it('should clear the cache', () => {
       const requestTopic = 'testTopic';
-      const data = JSON.stringify({
+      const data = stringify({
         id: '1',
         nonce: 1,
         expire: Math.floor(Date.now() / 1000) + 20,

packages/pubsub/package.json

@@ -38,7 +38,8 @@
     "@windingtree/sdk-storage": "workspace:*",
     "@windingtree/sdk-types": "workspace:*",
     "@windingtree/sdk-utils": "workspace:*",
-    "multiformats": "^12.0.1"
+    "multiformats": "^12.0.1",
+    "superjson": "^1.13.1"
   },
   "scripts": {
     "build": "tsup",

packages/pubsub/src/index.ts

@@ -18,6 +18,7 @@ import { GenericMessage } from '@windingtree/sdk-types';
 import { decodeText } from '@windingtree/sdk-utils';
 import { CashedMessageEntry, MessagesCache } from './cache.js';
 import { createLogger } from '@windingtree/sdk-logger';
+import { parse } from 'superjson';
 
 const logger = createLogger('CenterSub');
 
@@ -102,7 +103,7 @@ export class CenterSub extends GossipSub {
     this.isClient = !!isClient;
     this.messageTransformer = messageTransformer
       ? messageTransformer
-      : (message) => JSON.parse(decodeText(message)) as GenericMessage;
+      : (message) => parse(decodeText(message));
     this.addEventListener(
       'gossipsub:heartbeat',
       this.handleHeartbeat.bind(this),