mirror of
https://github.com/aljazceru/ditto.git
synced 2026-01-01 20:54:24 +01:00
fix(relays): get rid of custom kind 13314 conditional
This commit is contained in:
@@ -14,12 +14,9 @@ import { relayConnectionsGauge, relayEventCounter, relayMessageCounter } from '@
|
||||
import * as pipeline from '@/pipeline.ts';
|
||||
import { RelayError } from '@/RelayError.ts';
|
||||
import { Storages } from '@/storages.ts';
|
||||
import { prometheusParams } from '@/db/KyselyLogger.ts';
|
||||
import { AdminSigner } from '@/signers/AdminSigner.ts';
|
||||
|
||||
/** Limit of initial events returned for a subscription. */
|
||||
const FILTER_LIMIT = 100;
|
||||
const adminPubkey = await new AdminSigner().getPublicKey();
|
||||
|
||||
/** Set up the Websocket connection. */
|
||||
function connectStream(socket: WebSocket) {
|
||||
@@ -55,14 +52,7 @@ function connectStream(socket: WebSocket) {
|
||||
handleReq(msg);
|
||||
return;
|
||||
case 'EVENT':
|
||||
if (msg[1].kind === 13314 && msg[1].pubkey === adminPubkey) {
|
||||
try {
|
||||
const parsed = JSON.parse(msg[1].content);
|
||||
if (parsed.threshold) prometheusParams.threshold = parsed.threshold;
|
||||
} catch (e) {
|
||||
console.debug(`Error parsing kind 13314 ${msg[1].content}: ${e}`);
|
||||
}
|
||||
} else handleEvent(msg);
|
||||
handleEvent(msg);
|
||||
return;
|
||||
case 'CLOSE':
|
||||
handleClose(msg);
|
||||
|
||||
Reference in New Issue
Block a user