Mirroristas/pockethost
2
0
Fork 0
mirror of https://github.com/pockethost/pockethost.git synced 2025-09-15 21:20:11 +00:00
Code Issues Packages Projects Releases Wiki Activity

feat(pockethost): unsubscribe from filters

Browse Source
This commit is contained in:
Ben Allfree 2024-06-29 14:23:15 -07:00
parent 35edc77a9a
commit 879845a831
2 changed files with 16 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
.changeset/nice-roses-carry.md Normal file
View File

@ -0,0 +1,5 @@
---
'pockethost': minor
---
Enhancement: unsubscribe from filters

13
packages/pockethost/src/common/plugin/filter.ts
View File

@ -32,14 +32,23 @@ const filters: {
[key: string]: FilterEntry<any>[] [key: string]: FilterEntry<any>[]
} = {} } = {}
async function registerFilter<TCarry, TContext extends {} = {}>( function registerFilter<TCarry, TContext extends {} = {}>(
filter: string, filter: string,
handler: FilterHandler<TCarry, TContext>, handler: FilterHandler<TCarry, TContext>,
priority = 10, priority = 10,
) { ): () => void {
if (!(filter in filters)) filters[filter] = [] if (!(filter in filters)) filters[filter] = []
filters[filter]!.push({ priority, handler }) filters[filter]!.push({ priority, handler })
filters[filter]!.sort((a, b) => a.priority - b.priority) filters[filter]!.sort((a, b) => a.priority - b.priority)
return () => {
const index = filters[filter]!.findIndex(
(entry) => entry.handler === handler,
)
if (index !== -1) {
filters[filter]!.splice(index, 1)
}
}
} }
async function filter<TCarry, TContext extends {} = {}>( async function filter<TCarry, TContext extends {} = {}>(