highperfocused/nostream
1
0
Fork 0
mirror of https://github.com/Cameri/nostream.git synced 2025-10-01 18:00:24 +02:00
Code Issues Packages Projects Releases Wiki Activity

chore: reduce heartbeat logging

Browse Source
This commit is contained in:
Ricardo Arturo Cabral Mejia
2022-11-06 19:31:12 -05:00
parent 502d56d648
commit 874d39b9a7
2 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
src/adapters/web-server-adapter.ts
View File

@@ -33,7 +33,7 @@ export class WebServerAdapter extends EventEmitter implements IWebServerAdapter
}
private onRequest(request: IncomingMessage, response: ServerResponse) {
debug('request received: %o', request)
debug('request received: %O', request.rawHeaders)
if (request.method === 'GET' && request.headers['accept'] === 'application/nostr+json') {
const {
info: { name, description, pubkey, contact },
@@ -56,7 +56,6 @@ export class WebServerAdapter extends EventEmitter implements IWebServerAdapter
response.setHeader('content-type', 'application/text')
response.end('Please use a Nostr client to connect.')
}
debug('send response: %o', response)
}
private onError(error: Error, socket: Duplex) {

5
src/adapters/web-socket-adapter.ts
View File

@@ -17,6 +17,7 @@ import { isEventMatchingFilter } from '../utils/event'
import { messageSchema } from '../schemas/message-schema'
const debug = createLogger('web-socket-adapter')
const debugHeartbeat = debug.extend('heartbeat')
export class WebSocketAdapter extends EventEmitter implements IWebSocketAdapter {
public clientId: string
@@ -103,7 +104,7 @@ export class WebSocketAdapter extends EventEmitter implements IWebSocketAdapter
this.alive = false
this.client.ping()
debug('client %s ping', this.clientId)
debugHeartbeat('client %s ping', this.clientId)
}
public getSubscriptions(): Map<string, SubscriptionFilter[]> {
@@ -145,7 +146,7 @@ export class WebSocketAdapter extends EventEmitter implements IWebSocketAdapter
}
private onClientPong() {
debug('client %s pong', this.clientId)
debugHeartbeat('client %s pong', this.clientId)
this.alive = true
}