-
Notifications
You must be signed in to change notification settings - Fork 0
Request processor to queue respective announcements #37
Conversation
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Added some comments. Activity content creation needs a bit more love since we are duplicating a lot of same code.
apps/worker/src/request_processor/dsnp.announcement.processor.ts
Outdated
Show resolved
Hide resolved
apps/worker/src/request_processor/dsnp.announcement.processor.ts
Outdated
Show resolved
Hide resolved
apps/worker/src/request_processor/dsnp.announcement.processor.ts
Outdated
Show resolved
Hide resolved
apps/worker/src/request_processor/dsnp.announcement.processor.ts
Outdated
Show resolved
Hide resolved
apps/worker/src/request_processor/dsnp.announcement.processor.ts
Outdated
Show resolved
Hide resolved
apps/worker/src/request_processor/dsnp.announcement.processor.ts
Outdated
Show resolved
Hide resolved
apps/worker/src/request_processor/dsnp.announcement.processor.ts
Outdated
Show resolved
Hide resolved
apps/worker/src/request_processor/dsnp.announcement.processor.ts
Outdated
Show resolved
Hide resolved
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Looks great!
apps/worker/src/request_processor/dsnp.announcement.processor.ts
Outdated
Show resolved
Hide resolved
private async prepareImageAttachment(asset: AssetDto): Promise<ActivityContentImage> { | ||
const imageLinks: ActivityContentImageLink[] = []; | ||
asset.references?.forEach(async (reference) => { | ||
const assetMetaData = await this.assetQueue.getJob(reference.referenceId); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
So each job should be independent from other jobs. We should not expect this to resolve. This is not a blocker and going to address it in another PR.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Yeah i was a bit confused about it, but lets fix it in next
Co-authored-by: Aramik <[email protected]>
Details
DsnpAnnouncementProcessor
DsnpAnnouncementProcessor
: takes aIRequestJob
and parses it in respective DSNPAnnouncements
Closes: Request processor #11