diff --git a/src/cron.ts b/src/cron.ts index 60152716..bfaf773d 100644 --- a/src/cron.ts +++ b/src/cron.ts @@ -6,7 +6,7 @@ import { cidFromUrl } from '@/utils/ipfs.ts'; /** Delete files that aren't attached to any events. */ async function cleanupMedia() { - console.log('Deleting orphaned media files...'); + console.info('Deleting orphaned media files...'); const until = new Date(Date.now() - Time.minutes(15)); const media = await getUnattachedMedia(until); @@ -22,7 +22,7 @@ async function cleanupMedia() { } } - console.log(`Removed ${media?.length ?? 0} orphaned media files.`); + console.info(`Removed ${media?.length ?? 0} orphaned media files.`); } await cleanupMedia(); diff --git a/src/db.ts b/src/db.ts index 4f1a8d91..25d6d783 100644 --- a/src/db.ts +++ b/src/db.ts @@ -3,7 +3,7 @@ import path from 'node:path'; import { FileMigrationProvider, Kysely, Migrator, PolySqliteDialect } from '@/deps.ts'; import { Conf } from '@/config.ts'; -import { getPragma, setPragma } from '@/pragma.ts'; +import { setPragma } from '@/pragma.ts'; import SqliteWorker from '@/workers/sqlite.ts'; interface DittoDB { @@ -89,12 +89,6 @@ await Promise.all([ setPragma(db, 'mmap_size', Conf.sqlite.mmapSize), ]); -// Log out PRAGMA values for debugging. -['journal_mode', 'synchronous', 'temp_store', 'mmap_size'].forEach(async (pragma) => { - const value = await getPragma(db, pragma); - console.log(`PRAGMA ${pragma} = ${value};`); -}); - const migrator = new Migrator({ db, provider: new FileMigrationProvider({ @@ -106,7 +100,7 @@ const migrator = new Migrator({ /** Migrate the database to the latest version. */ async function migrate() { - console.log('Running migrations...'); + console.info('Running migrations...'); const results = await migrator.migrateToLatest(); if (results.error) { @@ -114,11 +108,11 @@ async function migrate() { Deno.exit(1); } else { if (!results.results?.length) { - console.log('Everything up-to-date.'); + console.info('Everything up-to-date.'); } else { - console.log('Migrations finished!'); + console.info('Migrations finished!'); for (const { migrationName, status } of results.results!) { - console.log(` - ${migrationName}: ${status}`); + console.info(` - ${migrationName}: ${status}`); } } } diff --git a/src/pipeline.ts b/src/pipeline.ts index 3f4993b6..7b829cb5 100644 --- a/src/pipeline.ts +++ b/src/pipeline.ts @@ -82,8 +82,8 @@ async function storeEvent(event: Event, data: EventData, opts: StoreEventOpts = return Promise.reject(new RelayError('blocked', 'event was deleted')); } else { await Promise.all([ - eventsDB.insertEvent(event, data).catch(console.warn), - updateStats(event).catch(console.warn), + eventsDB.insertEvent(event, data).catch(debug), + updateStats(event).catch(debug), ]); } } else { diff --git a/src/sign.ts b/src/sign.ts index 0662668d..de7149fe 100644 --- a/src/sign.ts +++ b/src/sign.ts @@ -1,13 +1,15 @@ import { type AppContext } from '@/app.ts'; import { Conf } from '@/config.ts'; import { decryptAdmin, encryptAdmin } from '@/crypto.ts'; -import { type Event, type EventTemplate, finishEvent, HTTPException } from '@/deps.ts'; +import { Debug, type Event, type EventTemplate, finishEvent, HTTPException } from '@/deps.ts'; import { connectResponseSchema } from '@/schemas/nostr.ts'; import { jsonSchema } from '@/schema.ts'; import { Sub } from '@/subs.ts'; import { eventMatchesTemplate, Time } from '@/utils.ts'; import { createAdminEvent } from '@/utils/web.ts'; +const debug = Debug('ditto:sign'); + interface SignEventOpts { /** Target proof-of-work difficulty for the signed event. */ pow?: number; @@ -28,10 +30,12 @@ async function signEvent( const header = c.req.header('x-nostr-sign'); if (seckey) { + debug(`Signing Event<${event.kind}> with secret key`); return finishEvent(event, seckey); } if (header) { + debug(`Signing Event<${event.kind}> with NIP-46`); return await signNostrConnect(event, c, opts); }