This commit is contained in:
Jon Staab
2024-05-24 14:11:05 -07:00
parent 5ec54e3204
commit b7d5ce7ae2
6 changed files with 17 additions and 19 deletions
+3 -5
View File
@@ -106,11 +106,9 @@ export class FeedCompiler<E extends TrustedEvent> {
this.options.requestDVM({
...request,
onEvent: async (e: E) => {
const tags = Tags.fromEvent(e)
const request = await tryCatch(() => JSON.parse(tags.get("request")?.value()))
const responseTags = tags.rejectByValue([request?.id, request?.pubkey])
const tags = Tags.wrap(await tryCatch(() => JSON.parse(e.content)) || [])
for (const feed of feedsFromTags(responseTags, mappings)) {
for (const feed of feedsFromTags(tags, mappings)) {
feeds.push(feed)
}
},
@@ -118,7 +116,7 @@ export class FeedCompiler<E extends TrustedEvent> {
)
)
return this._compileUnion(feeds)
return await this._compileUnion(feeds)
}
async _compileIntersection(feeds: Feed[]): Promise<RequestItem[]> {