Repository Docs & Knowledge Base

Consolidated Spensara documentation repository (722 Markdown & architecture documents in ../repository)

Built Word Documents (.docx): Spensara Overview (.docx) Capability Assessment (.docx) Brink POS Ingestion Analysis (.docx) The Borg Ingestion Architecture (.docx)

Implementation Specs (157)

Detailed engineering and feature implementation specifications.

implementation-specs/specs/BrinkPosOrdersFirstEtlJob/TASK2.1.md 2,852 bytes · Updated Oct 23, 2026 10:44 AM EDT

Raw File

TASK 2.1: Implement Child Extract Orchestration And Business-Date Resolution

Summary

Implement the tenant-day child extract entry point and the Warehouse/app-layer orchestration flow that starts one extract_raw run for Brink POS orders. This subtask should turn the dispatch contract from TASK1.md into a concrete execution path that resolves the effective business date, resolves the active Brink binding for the tenant, and prepares endpoint execution metadata.

Dependencies

TASK 1 - source binding and dispatch

Files to Create

1. Extract orchestration services

Create or finalize the Warehouse/app-layer services responsible for one tenant-day extract_raw execution.

Recommended logical services:

BrinkPosExtractJobs
IBrinkConnectionBindingService or equivalent Warehouse-side binding resolver
BrinkPosBusinessDateResolver
BrinkPosExtractOrchestrator
BrinkPosEndpointCatalog

2. Endpoint catalog for the narrowed v1 scope

Create the fixed catalog for this slice with:

GetCurrentBusinessDate as the control helper
GetOrders as the only replayable raw endpoint

Required Behavior

child extract accepts BrinkPosExtractJobInput
child extract resolves BrinkConnectionDefinition outside Kds.Ai.Integrations.BrinkPos
explicit BusinessDate wins when provided
otherwise the resolver calls GetCurrentBusinessDate
the resolved date becomes the single tenant-day execution boundary
the catalog remains strict and does not include any additional Brink endpoint
the orchestration layer passes the resolved Brink connection context into the integration boundary rather than relying on ambient tenant or DB resolution inside the integration module

Testing

Unit tests

Add unit tests for:

Warehouse-side binding resolution and handoff of BrinkConnectionDefinition
explicit business-date override
missing business-date path through GetCurrentBusinessDate
endpoint catalog correctness for the narrowed scope
orchestration handoff from child job to endpoint execution

Acceptance Criteria

[x] Child extract job entry exists
[x] Warehouse/app-layer binding resolution exists for the child extract path
[x] Business-date resolver exists
[x] Explicit BusinessDate is honored directly
[x] Missing BusinessDate resolves through GetCurrentBusinessDate
[x] Endpoint catalog includes only the narrowed v1 scope
[x] Child orchestration passes explicit Brink connection context into the integration boundary
[x] Unit tests cover business-date and catalog behavior

Notes

Keep this subtask focused on orchestration readiness.
Keep tenant resolution and source-binding lookup out of Kds.Ai.Integrations.BrinkPos.
Do not implement raw S3 persistence or validation here; those belong to later subtasks in TASK 2.