less logs

This commit is contained in:
boufni95 2025-01-29 17:46:07 +00:00
parent 9a8213591a
commit e6c3e9654e
4 changed files with 6 additions and 19 deletions

View file

@ -53,7 +53,6 @@ export default class {
const user = await this.storage.userStorage.GetUser(ctx.user_id) const user = await this.storage.userStorage.GetUser(ctx.user_id)
const app = await this.storage.applicationStorage.GetApplication(ctx.app_id) const app = await this.storage.applicationStorage.GetApplication(ctx.app_id)
const appUser = await this.storage.applicationStorage.GetAppUserFromUser(app, user.user_id) const appUser = await this.storage.applicationStorage.GetAppUserFromUser(app, user.user_id)
console.log("User Identifier/pointer here", appUser?.identifier)
if (!appUser) { if (!appUser) {
throw new Error(`app user ${ctx.user_id} not found`) // TODO: fix logs doxing throw new Error(`app user ${ctx.user_id} not found`) // TODO: fix logs doxing

View file

@ -194,9 +194,7 @@ export class DebitManager {
if (!this._nostrSend) { if (!this._nostrSend) {
throw new Error("No nostrSend attached") throw new Error("No nostrSend attached")
} }
console.log({ pointerdata, event })
const res = await this.payNdebitInvoice(event, pointerdata) const res = await this.payNdebitInvoice(event, pointerdata)
console.log({ debitRes: res })
if (res.status === 'fail' || res.status === 'authOk') { if (res.status === 'fail' || res.status === 'authOk') {
const e = newNdebitResponse(JSON.stringify(res.debitRes), event) const e = newNdebitResponse(JSON.stringify(res.debitRes), event)
this.nostrSend({ type: 'app', appId: event.appId }, { type: 'event', event: e, encrypt: { toPub: event.pub } }) this.nostrSend({ type: 'app', appId: event.appId }, { type: 'event', event: e, encrypt: { toPub: event.pub } })

View file

@ -212,7 +212,6 @@ export default class Handler {
tags: [['p', data.pub]], tags: [['p', data.pub]],
} }
} else { } else {
console.log(data)
toSign = data.event toSign = data.event
if (data.encrypt) { if (data.encrypt) {
try { try {

View file

@ -55,7 +55,7 @@ export default class webRTC {
} }
private connect = async (u: UserInfo, offer: string): Promise<Types.WebRtcAnswer> => { private connect = async (u: UserInfo, offer: string): Promise<Types.WebRtcAnswer> => {
const key = this.getConnectionsKey(u) const key = this.getConnectionsKey(u)
console.log("connect", key) this.log("connect", key)
if (this.connections[key]) { if (this.connections[key]) {
this.connections[key].close() this.connections[key].close()
} }
@ -71,11 +71,13 @@ export default class webRTC {
} }
this.sendCandidate(u, JSON.stringify(message)) this.sendCandidate(u, JSON.stringify(message))
} }
conn.onconnectionstatechange = (event) => { conn.onconnectionstatechange = () => {
console.log('onconnectionstatechange', conn.connectionState) if (conn.connectionState === 'disconnected') {
conn.close()
delete this.connections[key]
}
} }
conn.ondatachannel = (event) => { conn.ondatachannel = (event) => {
console.log('ondatachannel', event)
const channel = event.channel const channel = event.channel
channel.addEventListener('message', async (event) => { channel.addEventListener('message', async (event) => {
try { 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 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) const id = j.request_id || Math.floor(Math.random() * 100_000_000)
console.log("processing req:", j, "id:", id)
let i = 0 let i = 0
const packets: Buffer[] = [] const packets: Buffer[] = []
while (i < res.length) { while (i < res.length) {
@ -102,9 +103,6 @@ export default class webRTC {
const packet = packets[i] const packet = packets[i]
const tlv = encodeTLVDataPacket({ dataId: id, packetNum: i + 1, totalPackets: packets.length, data: packet }) const tlv = encodeTLVDataPacket({ dataId: id, packetNum: i + 1, totalPackets: packets.length, data: packet })
const bytes = encodeTLbV(tlv) const bytes = encodeTLbV(tlv)
if (i === 0) {
console.log("sending first packet", tlv)
}
channel.send(bytes) channel.send(bytes)
} }
} catch (e: any) { } 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)) await conn.setRemoteDescription(JSON.parse(offer))
const answer = await conn.createAnswer() const answer = await conn.createAnswer()
await conn.setLocalDescription(answer) await conn.setLocalDescription(answer)
this.connections[key] = conn this.connections[key] = conn
console.log("answer", answer)
return { answer: JSON.stringify(answer) } return { answer: JSON.stringify(answer) }
} }