fraqtal/agentic-dev
Template
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

refactor(media): binders take BindContext arg

Browse Source
This commit is contained in:
Danijel Martinek
2026-05-09 12:44:30 +02:00
parent a439038748
commit 3911405102
3 changed files with 12 additions and 28 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
packages/media/src/di/bind-dev-seed.test.ts
View File

@@ -33,7 +33,7 @@ describe("bindDevSeedMedia", () => {
}); });
it("populates the repository with the dev media entries", async () => { it("populates the repository with the dev media entries", async () => {
await bindDevSeedMedia(noop.tracer, noop.logger, new RecordingEventBus(), new RecordingJobQueue(), new RecordingRealtimeBroadcaster(), new RealtimeHandlerRegistry()); await bindDevSeedMedia({ ...noop, bus: new RecordingEventBus(), queue: new RecordingJobQueue(), realtime: new RecordingRealtimeBroadcaster(), realtimeRegistry: new RealtimeHandlerRegistry() });
const repo = mediaContainer.get<IMediaRepository>( const repo = mediaContainer.get<IMediaRepository>(
MEDIA_SYMBOLS.IMediaRepository, MEDIA_SYMBOLS.IMediaRepository,
@@ -44,7 +44,7 @@ describe("bindDevSeedMedia", () => {
}); });
it("seeds placeholder-1 reachable by id", async () => { it("seeds placeholder-1 reachable by id", async () => {
await bindDevSeedMedia(noop.tracer, noop.logger, new RecordingEventBus(), new RecordingJobQueue(), new RecordingRealtimeBroadcaster(), new RealtimeHandlerRegistry()); await bindDevSeedMedia({ ...noop, bus: new RecordingEventBus(), queue: new RecordingJobQueue(), realtime: new RecordingRealtimeBroadcaster(), realtimeRegistry: new RealtimeHandlerRegistry() });
const repo = mediaContainer.get<IMediaRepository>( const repo = mediaContainer.get<IMediaRepository>(
MEDIA_SYMBOLS.IMediaRepository, MEDIA_SYMBOLS.IMediaRepository,
@@ -57,13 +57,13 @@ describe("bindDevSeedMedia", () => {
}); });
it("is idempotent — calling twice rebuilds a fresh populated repo", async () => { it("is idempotent — calling twice rebuilds a fresh populated repo", async () => {
await bindDevSeedMedia(noop.tracer, noop.logger, new RecordingEventBus(), new RecordingJobQueue(), new RecordingRealtimeBroadcaster(), new RealtimeHandlerRegistry()); await bindDevSeedMedia({ ...noop, bus: new RecordingEventBus(), queue: new RecordingJobQueue(), realtime: new RecordingRealtimeBroadcaster(), realtimeRegistry: new RealtimeHandlerRegistry() });
const before = mediaContainer.get<IMediaRepository>( const before = mediaContainer.get<IMediaRepository>(
MEDIA_SYMBOLS.IMediaRepository, MEDIA_SYMBOLS.IMediaRepository,
); );
const beforeCount = (await before.listMedia()).length; const beforeCount = (await before.listMedia()).length;
await bindDevSeedMedia(noop.tracer, noop.logger, new RecordingEventBus(), new RecordingJobQueue(), new RecordingRealtimeBroadcaster(), new RealtimeHandlerRegistry()); await bindDevSeedMedia({ ...noop, bus: new RecordingEventBus(), queue: new RecordingJobQueue(), realtime: new RecordingRealtimeBroadcaster(), realtimeRegistry: new RealtimeHandlerRegistry() });
const after = mediaContainer.get<IMediaRepository>( const after = mediaContainer.get<IMediaRepository>(
MEDIA_SYMBOLS.IMediaRepository, MEDIA_SYMBOLS.IMediaRepository,
); );

15
packages/media/src/di/bind-dev-seed.ts
View File

@@ -5,9 +5,7 @@ import {
type ITracer, type ITracer,
type ILogger, type ILogger,
} from "@repo/core-shared/instrumentation"; } from "@repo/core-shared/instrumentation";
import type { IEventBus } from "@repo/core-events"; import type { BindContext } from "@repo/core-shared/di";
import type { IRealtimeBroadcaster, IRealtimeHandlerRegistry } from "@repo/core-realtime";
import type { IJobQueue } from "@repo/core-shared/jobs";
import { mediaContainer } from "./container.js"; import { mediaContainer } from "./container.js";
import { MEDIA_SYMBOLS } from "./symbols.js"; import { MEDIA_SYMBOLS } from "./symbols.js";
import { MockMediaRepository } from "../infrastructure/repositories/media.repository.mock.js"; import { MockMediaRepository } from "../infrastructure/repositories/media.repository.mock.js";
@@ -30,14 +28,9 @@ import type { IMediaRepository } from "../application/repositories/media.reposit
* Idempotent: safe to call multiple times; each call rebuilds a fresh * Idempotent: safe to call multiple times; each call rebuilds a fresh
* populated repo and rebinds the symbol. * populated repo and rebinds the symbol.
*/ */
export async function bindDevSeedMedia( export async function bindDevSeedMedia(ctx: BindContext): Promise<void> {
tracer: ITracer, const { tracer, logger, bus, queue, realtime, realtimeRegistry } = ctx;
logger: ILogger,
bus: IEventBus,
queue: IJobQueue,
realtime: IRealtimeBroadcaster,
realtimeRegistry: IRealtimeHandlerRegistry,
): Promise<void> {
// Bind shared instrumentation into feature container // Bind shared instrumentation into feature container
if (mediaContainer.isBound(INSTRUMENTATION_SYMBOLS.TRACER)) { if (mediaContainer.isBound(INSTRUMENTATION_SYMBOLS.TRACER)) {
mediaContainer.unbind(INSTRUMENTATION_SYMBOLS.TRACER); mediaContainer.unbind(INSTRUMENTATION_SYMBOLS.TRACER);

17
packages/media/src/di/bind-production.ts
View File

@@ -1,4 +1,3 @@
import type { SanitizedConfig } from "payload";
import { import {
withSpan, withSpan,
withCapture, withCapture,
@@ -6,9 +5,7 @@ import {
type ITracer, type ITracer,
type ILogger, type ILogger,
} from "@repo/core-shared/instrumentation"; } from "@repo/core-shared/instrumentation";
import type { IEventBus } from "@repo/core-events"; import type { BindProductionContext } from "@repo/core-shared/di";
import type { IRealtimeBroadcaster, IRealtimeHandlerRegistry } from "@repo/core-realtime";
import type { IJobQueue } from "@repo/core-shared/jobs";
import { mediaContainer } from "./container"; import { mediaContainer } from "./container";
import { MEDIA_SYMBOLS } from "./symbols"; import { MEDIA_SYMBOLS } from "./symbols";
import { MediaRepository } from "../infrastructure/repositories/media.repository"; import { MediaRepository } from "../infrastructure/repositories/media.repository";
@@ -19,15 +16,9 @@ import { getMediaController } from "../interface-adapters/controllers/get-media.
import { listMediaController } from "../interface-adapters/controllers/list-media.controller"; import { listMediaController } from "../interface-adapters/controllers/list-media.controller";
import { deleteMediaController } from "../interface-adapters/controllers/delete-media.controller"; import { deleteMediaController } from "../interface-adapters/controllers/delete-media.controller";
export function bindProductionMedia( export function bindProductionMedia(ctx: BindProductionContext): void {
config: SanitizedConfig, const { config, tracer, logger, bus, queue, realtime, realtimeRegistry } = ctx;
tracer: ITracer,
logger: ILogger,
bus: IEventBus,
queue: IJobQueue,
realtime: IRealtimeBroadcaster,
realtimeRegistry: IRealtimeHandlerRegistry,
): void {
// Bind shared instrumentation into feature container // Bind shared instrumentation into feature container
if (mediaContainer.isBound(INSTRUMENTATION_SYMBOLS.TRACER)) { if (mediaContainer.isBound(INSTRUMENTATION_SYMBOLS.TRACER)) {
mediaContainer.unbind(INSTRUMENTATION_SYMBOLS.TRACER); mediaContainer.unbind(INSTRUMENTATION_SYMBOLS.TRACER);