From 1612b766cd0eda75525be8e5fcaa7adb71e41ea8 Mon Sep 17 00:00:00 2001 From: Arseniy Klempner Date: Wed, 10 Sep 2025 12:16:26 -0700 Subject: [PATCH] fix: add temporary logging --- packages/browser-tests/src/browser/index.ts | 11 +++ packages/browser-tests/src/server.ts | 11 ++- packages/browser-tests/web/index.ts | 74 ++++----------------- 3 files changed, 28 insertions(+), 68 deletions(-) diff --git a/packages/browser-tests/src/browser/index.ts b/packages/browser-tests/src/browser/index.ts index 5e917f099b..6dd537db0f 100644 --- a/packages/browser-tests/src/browser/index.ts +++ b/packages/browser-tests/src/browser/index.ts @@ -18,6 +18,17 @@ export async function initBrowser(appPort: number): Promise { page = await browser.newPage(); + // Forward browser console to server logs + page.on('console', msg => { + const type = msg.type(); + const text = msg.text(); + console.log(`[Browser Console ${type.toUpperCase()}] ${text}`); + }); + + page.on('pageerror', error => { + console.error('[Browser Page Error]', error.message); + }); + await page.goto(`http://localhost:${appPort}/app/index.html`, { waitUntil: "networkidle", }); diff --git a/packages/browser-tests/src/server.ts b/packages/browser-tests/src/server.ts index 8a68533601..fe04d8340b 100644 --- a/packages/browser-tests/src/server.ts +++ b/packages/browser-tests/src/server.ts @@ -97,7 +97,7 @@ async function startServer(port: number = 3000): Promise { const hasEnrBootstrap = Boolean(process.env.WAKU_ENR_BOOTSTRAP); const networkConfig: any = { - defaultBootstrap: !hasEnrBootstrap, + defaultBootstrap: false, ...(hasEnrBootstrap && { discovery: { dns: true, @@ -107,14 +107,11 @@ async function startServer(port: number = 3000): Promise { }), }; - console.log( - `Bootstrap mode: ${hasEnrBootstrap ? "ENR-only (defaultBootstrap=false)" : "default bootstrap (defaultBootstrap=true)"}`, - ); + // console.log( + // `Bootstrap mode: ${hasEnrBootstrap ? "ENR-only (defaultBootstrap=false)" : "default bootstrap (defaultBootstrap=true)"}`, + // ); if (hasEnrBootstrap) { console.log(`ENR bootstrap peers: ${process.env.WAKU_ENR_BOOTSTRAP}`); - console.log( - `Discovery options: peerExchange=true, dns=false, peerCache=true`, - ); } networkConfig.networkConfig = { diff --git a/packages/browser-tests/web/index.ts b/packages/browser-tests/web/index.ts index 3e2b2cfb11..f164a4f093 100644 --- a/packages/browser-tests/web/index.ts +++ b/packages/browser-tests/web/index.ts @@ -71,6 +71,7 @@ export class WakuHeadless { ) { this.waku = null as unknown as LightNode; this.networkConfig = this.buildNetworkConfig(networkConfig); + console.log("Network config on construction:", this.networkConfig); this.lightpushNode = lightpushNode || null; this.enrBootstrap = enrBootstrap || null; @@ -132,50 +133,6 @@ export class WakuHeadless { } as NetworkConfig; } - async pushMessage( - contentTopic: string, - payload: string, - ): Promise { - if (!this.waku) { - throw new Error("Waku node not started"); - } - - let processedPayload: Uint8Array; - try { - const binaryString = atob(payload); - const bytes = new Uint8Array(binaryString.length); - for (let i = 0; i < binaryString.length; i++) { - bytes[i] = binaryString.charCodeAt(i); - } - processedPayload = bytes; - } catch (e) { - processedPayload = new TextEncoder().encode(payload); - } - - try { - const lightPush = this.waku.lightPush; - if (!lightPush) { - throw new Error("Lightpush service not available"); - } - - const encoder = this.waku.createEncoder({ contentTopic }); - - const result = await lightPush.send(encoder, { - payload: processedPayload, - timestamp: new Date(), - }); - - const serializableResult = makeSerializable(result); - - return serializableResult; - } catch (error) { - console.error("Error sending message via lightpush:", error); - throw new Error( - `Failed to send message: ${error instanceof Error ? error.message : String(error)}`, - ); - } - } - async pushMessageV3( contentTopic: string, payload: string, @@ -184,6 +141,9 @@ export class WakuHeadless { if (!this.waku) { throw new Error("Waku node not started"); } + console.log("Pushing message via v3 lightpush:", contentTopic, payload, pubsubTopic); + console.log("Waku node:", this.waku); + console.log("Network config:", this.networkConfig); let processedPayload: Uint8Array; try { @@ -204,6 +164,9 @@ export class WakuHeadless { } const encoder = this.waku.createEncoder({ contentTopic }); + console.log("Encoder:", encoder); + console.log("Pubsub topic:", pubsubTopic); + console.log("Encoder pubsub topic:", encoder.pubsubTopic); if (pubsubTopic && pubsubTopic !== encoder.pubsubTopic) { console.warn( @@ -229,6 +192,7 @@ export class WakuHeadless { ); } } catch (error) { + console.error("Couldn't send message via preferred lightpush node:", error); result = await lightPush.send(encoder, { payload: processedPayload, timestamp: new Date(), @@ -290,27 +254,14 @@ export class WakuHeadless { console.warn("ignore previous waku stop error"); } - if (options.networkConfig) { - this.networkConfig = options.networkConfig; - } + // if (options.networkConfig) { + // this.networkConfig = options.networkConfig; + // console.log("Network config on createWakuNode:", this.networkConfig); + // } let libp2pConfig: any = { ...options.libp2p, filterMultiaddrs: false, - connectionManager: { - minConnections: 1, - maxConnections: 50, - connectionGater: { - denyDialPeer: () => false, - denyDialMultiaddr: () => false, - denyInboundConnection: () => false, - denyOutboundConnection: () => false, - denyInboundEncryptedConnection: () => false, - denyOutboundEncryptedConnection: () => false, - denyInboundUpgradedConnection: () => false, - denyOutboundUpgradedConnection: () => false, - }, - }, }; if (this.enrBootstrap && this.shouldUseCustomBootstrap(options)) { @@ -356,6 +307,7 @@ export class WakuHeadless { await this.waku.dial(this.lightpushNode); } catch { // Ignore dial errors + console.warn("Failed to dial preferred lightpush node:", this.lightpushNode); } }