diff --git a/src/services/main/appUserManager.ts b/src/services/main/appUserManager.ts index 89f25494..de130262 100644 --- a/src/services/main/appUserManager.ts +++ b/src/services/main/appUserManager.ts @@ -53,7 +53,6 @@ export default class { const user = await this.storage.userStorage.GetUser(ctx.user_id) const app = await this.storage.applicationStorage.GetApplication(ctx.app_id) const appUser = await this.storage.applicationStorage.GetAppUserFromUser(app, user.user_id) - console.log("User Identifier/pointer here", appUser?.identifier) if (!appUser) { throw new Error(`app user ${ctx.user_id} not found`) // TODO: fix logs doxing diff --git a/src/services/main/debitManager.ts b/src/services/main/debitManager.ts index 881039e8..23fd8b2c 100644 --- a/src/services/main/debitManager.ts +++ b/src/services/main/debitManager.ts @@ -194,9 +194,7 @@ export class DebitManager { if (!this._nostrSend) { throw new Error("No nostrSend attached") } - console.log({ pointerdata, event }) const res = await this.payNdebitInvoice(event, pointerdata) - console.log({ debitRes: res }) if (res.status === 'fail' || res.status === 'authOk') { const e = newNdebitResponse(JSON.stringify(res.debitRes), event) this.nostrSend({ type: 'app', appId: event.appId }, { type: 'event', event: e, encrypt: { toPub: event.pub } }) diff --git a/src/services/nostr/handler.ts b/src/services/nostr/handler.ts index 33d1263b..c84a2c5f 100644 --- a/src/services/nostr/handler.ts +++ b/src/services/nostr/handler.ts @@ -212,7 +212,6 @@ export default class Handler { tags: [['p', data.pub]], } } else { - console.log(data) toSign = data.event if (data.encrypt) { try { diff --git a/src/services/webRTC/index.ts b/src/services/webRTC/index.ts index f3e70db0..0358e398 100644 --- a/src/services/webRTC/index.ts +++ b/src/services/webRTC/index.ts @@ -55,7 +55,7 @@ export default class webRTC { } private connect = async (u: UserInfo, offer: string): Promise => { const key = this.getConnectionsKey(u) - console.log("connect", key) + this.log("connect", key) if (this.connections[key]) { this.connections[key].close() } @@ -71,11 +71,13 @@ export default class webRTC { } this.sendCandidate(u, JSON.stringify(message)) } - conn.onconnectionstatechange = (event) => { - console.log('onconnectionstatechange', conn.connectionState) + conn.onconnectionstatechange = () => { + if (conn.connectionState === 'disconnected') { + conn.close() + delete this.connections[key] + } } conn.ondatachannel = (event) => { - console.log('ondatachannel', event) const channel = event.channel channel.addEventListener('message', async (event) => { try { @@ -90,7 +92,6 @@ export default class webRTC { } const res = await this.storage.metricsEventStorage.LoadRawMetricsFile(j.app_id, j.metrics_name, j.page) const id = j.request_id || Math.floor(Math.random() * 100_000_000) - console.log("processing req:", j, "id:", id) let i = 0 const packets: Buffer[] = [] while (i < res.length) { @@ -102,9 +103,6 @@ export default class webRTC { const packet = packets[i] const tlv = encodeTLVDataPacket({ dataId: id, packetNum: i + 1, totalPackets: packets.length, data: packet }) const bytes = encodeTLbV(tlv) - if (i === 0) { - console.log("sending first packet", tlv) - } channel.send(bytes) } } catch (e: any) { @@ -112,17 +110,10 @@ export default class webRTC { } }) } - /* conn.oniceconnectionstatechange = (event) => { - console.log('oniceconnectionstatechange', event) - } - conn.onicegatheringstatechange = (event) => { - console.log('onicegatheringstatechange', event) - } */ await conn.setRemoteDescription(JSON.parse(offer)) const answer = await conn.createAnswer() await conn.setLocalDescription(answer) this.connections[key] = conn - console.log("answer", answer) return { answer: JSON.stringify(answer) } }