moon
/
ditto
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix(pipeline): load custom policy if available

This commit is contained in:
P. Reis 2024-05-13 17:44:33 -03:00
parent 6105e00c80
commit 4029971407
1 changed files with 12 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
src/pipeline.ts
View File

@ -1,4 +1,4 @@
import { NostrEvent, NSchema as n } from '@nostrify/nostrify'; import { NostrEvent, NPolicy, NSchema as n } from '@nostrify/nostrify';
import { LNURL } from '@nostrify/nostrify/ln'; import { LNURL } from '@nostrify/nostrify/ln';
import { PipePolicy } from '@nostrify/nostrify/policies'; import { PipePolicy } from '@nostrify/nostrify/policies';
import Debug from '@soapbox/stickynotes/debug'; import Debug from '@soapbox/stickynotes/debug';
@ -55,10 +55,18 @@ async function handleEvent(event: DittoEvent, signal: AbortSignal): Promise<void
} }
async function policyFilter(event: NostrEvent): Promise<void> { async function policyFilter(event: NostrEvent): Promise<void> {
const policy = new PipePolicy([ const policies: NPolicy[] = [
new MuteListPolicy(Conf.pubkey, Storages.admin), new MuteListPolicy(Conf.pubkey, Storages.admin),
// put custom policy here ];
]);
try {
const customPolicy = (await import('../data/policy.ts')).default;
policies.push(new customPolicy());
} catch (_e) {
debug('policy not found - https://docs.soapbox.pub/ditto/policies/');
}
const policy = new PipePolicy(policies.reverse());
const result = await policy.call(event); const result = await policy.call(event);
debug(JSON.stringify(result)); debug(JSON.stringify(result));