mirror/ditto
mirror/ditto
1
0
Fork 0
mirror of https://gitlab.com/soapbox-pub/ditto.git synced 2025-12-06 11:29:46 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

fmt

Browse source
This commit is contained in:
Siddharth Singh 2024-06-26 01:33:02 +05:30
parent 7c7c584b78
commit ab5f451929
No known key found for this signature in database
3 changed files with 11 additions and 13 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
src/controllers/nostr/relay.ts
View file

@ -14,7 +14,7 @@ import { relayConnectionsGauge, relayEventCounter, relayMessageCounter } from '@
import * as pipeline from '@/pipeline.ts'; import * as pipeline from '@/pipeline.ts';
import { RelayError } from '@/RelayError.ts'; import { RelayError } from '@/RelayError.ts';
import { Storages } from '@/storages.ts'; import { Storages } from '@/storages.ts';
import { prometheusParams } from "@/db/KyselyLogger.ts"; import { prometheusParams } from '@/db/KyselyLogger.ts';
/** Limit of initial events returned for a subscription. */ /** Limit of initial events returned for a subscription. */
const FILTER_LIMIT = 100; const FILTER_LIMIT = 100;
@ -57,12 +57,10 @@ function connectStream(socket: WebSocket) {
try { try {
const parsed = JSON.parse(msg[1].content); const parsed = JSON.parse(msg[1].content);
if (parsed.threshold) prometheusParams.threshold = parsed.threshold; if (parsed.threshold) prometheusParams.threshold = parsed.threshold;
} } catch (e) {
catch (e) {
console.debug(`Error parsing kind 13314 ${msg[1].content}: ${e}`); console.debug(`Error parsing kind 13314 ${msg[1].content}: ${e}`);
} }
} } else handleEvent(msg);
else handleEvent(msg);
return; return;
case 'CLOSE': case 'CLOSE':
handleClose(msg); handleClose(msg);

8
src/db/KyselyLogger.ts
View file

@ -3,7 +3,7 @@ import { Logger } from 'kysely';
import { dbQueryTime } from '@/metrics.ts'; import { dbQueryTime } from '@/metrics.ts';
export const prometheusParams = { export const prometheusParams = {
threshold: 10000 threshold: 10000,
}; };
/** Log the SQL for queries. */ /** Log the SQL for queries. */
@ -18,9 +18,9 @@ export const KyselyLogger: Logger = (event) => {
const labels = { const labels = {
sql, sql,
parameters: JSON.stringify( parameters: JSON.stringify(
parameters.filter((param: any) => ['string', 'number'].includes(typeof param)) as (string | number)[] parameters.filter((param: any) => ['string', 'number'].includes(typeof param)) as (string | number)[],
) ),
} };
dbQueryTime.observe(labels, queryDurationMillis); dbQueryTime.observe(labels, queryDurationMillis);
} }

8
src/metrics.ts
View file

@ -1,4 +1,4 @@
import { Counter, Histogram, Gauge } from 'prom-client'; import { Counter, Gauge, Histogram } from 'prom-client';
export const httpRequestCounter = new Counter({ export const httpRequestCounter = new Counter({
name: 'http_requests_total', name: 'http_requests_total',
@ -69,6 +69,6 @@ export const dbAvailableConnectionsGauge = new Gauge({
}); });
export const dbQueryTime = new Histogram({ export const dbQueryTime = new Histogram({
name: "db_query_time", name: 'db_query_time',
help: "Time taken per kysely query" help: 'Time taken per kysely query',
}) });