Merge branch 'main-2.0' into planning/pipeline-architecture

pipeline/diagrams/future-activity-diagram.puml

@@ -0,0 +1,262 @@
+@startuml biergarten_activity
+skinparam defaultFontName "DM Sans"
+skinparam defaultFontSize 13
+skinparam titleFontName "Volkhov"
+skinparam titleFontSize 20
+skinparam backgroundColor #FCFCF7
+skinparam defaultFontColor #14180C
+skinparam titleFontColor #14180C
+skinparam ArrowColor #656F33
+skinparam activityStartColor #EBECE3
+skinparam activityEndColor #4A5837
+skinparam activityStopColor #4A5837
+skinparam ActivityBackgroundColor #EBECE3
+skinparam ActivityBorderColor #4A5837
+skinparam ActivityDiamondBackgroundColor #CBD2B5
+skinparam ActivityDiamondBorderColor #4A5837
+skinparam NoteBackgroundColor #DBEEDD
+skinparam NoteFontColor #14180C
+skinparam NoteBorderColor #4A5837
+skinparam SwimlaneBorderColor #4A5837
+skinparam SwimlaneBorderThickness 1
+skinparam monochrome reverse
+
+
+title The Biergarten Data Pipeline — Activity Diagram
+
+|Main|
+start
+:ParseArguments(argc, argv);
+if (Invalid args?) then (yes)
+  :spdlog::error;
+  stop
+else (no)
+endif
+:Init CurlGlobalState & LlamaBackendState;
+:Build DI injector;
+
+
+:Initialize SqliteExportService;
+note right
+  Opens SQLite connection.
+  Begins a single transaction
+  covering all five fixture types.
+end note
+
+:Create BoundedChannel<LogEntry> log_ch;
+:Spawn Log Worker thread;
+note right
+  Log worker drains log_ch for the
+  entire pipeline lifetime.
+  All workers emit LogEntry structs
+  via PipelineLogger — never spdlog directly.
+end note
+
+:BiergartenPipelineOrchestrator::Run();
+|BiergartenPipelineOrchestrator::Run()|
+:JsonLoader::LoadLocations("locations.json");
+:JsonLoader::LoadBeerStyles("beer-styles.json");
+:JsonLoader::LoadPersonas("personas.json");
+:JsonLoader::LoadNamesByCountry("names-by-country.json");
+
+:EnrichmentService::PreWarmBeerStyleCache(beer_styles);
+note right
+  Beer styles do not need location context.
+  Wikipedia summaries for the entire palette are
+  fetched and cached globally at startup.
+end note
+
+:EnrichmentService::PreWarmPersonaCache(personas);
+note right
+  Persona descriptions do not need location context.
+  All persona lookups are resolved and cached
+  globally at startup.
+end note
+
+
+' ═══════════════════════════════════════════
+' PHASE 0 — USER GENERATION
+' ═══════════════════════════════════════════
+|Orchestrator|
+:RunUserPhase(sampled_locations);
+:Create BoundedChannels\n(loc_ch, llm_ch, exp_ch);
+
+fork
+  |Orchestrator|
+  :Loop: Send Locations → loc_ch;
+  :Close loc_ch;
+fork again
+  |LLM Worker|
+  while (loc_ch has items?) is (yes)
+    :Receive Location;
+
+    :IPersonaSelectionStrategy::SelectPersona(\n  personas_palette_);
+    note right
+      Guaranteed cache hit from startup.
+      Returns a Persona struct carrying
+      style_affinities, abv_range,
+      ibu_preference, checkin_weight.
+    end note
+
+    :NamesByCountry::SampleName(\n  location.iso3166_1);
+    note right
+      Deterministic lookup — no LLM involved.
+      Name selected from pre-keyed table
+      and passed into the generation prompt.
+    end note
+
+    :GenerateUser(location, persona, sampled_name)\nvia DataGenerator;
+    note right
+      LLM receives: Location fields + persona
+      description + sampled name. Generates
+      bio and preference signals grounded
+      in locale and persona.
+    end note
+
+    :PipelineLogger::Log(Info, UserGeneration,\n  city, user_id, "llm");
+    :Send GeneratedUser → llm_ch;
+  endwhile (no)
+  :Close llm_ch;
+fork again
+  |SQLite Worker|
+  while (llm_ch has items?) is (yes)
+    :Receive GeneratedUser;
+    :ProcessUser(user) → sqlite3_int64;
+    :PipelineLogger::Log(Info, UserGeneration,\n  city, user_id, "sqlite");
+    :Append → user_pool_;
+  endwhile (no)
+end fork
+
+|Orchestrator|
+:Join LLM Worker, SQLite Worker;
+
+' ═══════════════════════════════════════════
+' PHASE 1 — BREWERY & BEER GENERATION
+' ═══════════════════════════════════════════
+:RunBreweryAndBeerPhase(sampled_locations);
+:Create BoundedChannels\n(loc_ch, llm_ch, exp_ch);
+
+fork
+  |Orchestrator|
+  :Loop: Send Locations → loc_ch;
+  :Close loc_ch;
+fork again
+  |Enrichment Workers (xN)|
+  while (loc_ch has items?) is (yes)
+    :Receive Location;
+    :GetLocationContext(location,\nBreweryContextStrategy);
+    :PipelineLogger::Log(Info,\n  BreweryAndBeerGeneration,\n  city, nullopt, "enrichment");
+    :Send EnrichedCity → llm_ch;
+  endwhile (no)
+  |Orchestrator|
+  :Join Enrichment Workers;
+  :Close llm_ch;
+fork again
+  |LLM Worker|
+  while (llm_ch has items?) is (yes)
+    :Receive EnrichedCity;
+
+    :GenerateBrewery(location, context)\nvia DataGenerator;
+
+    :IBeerSelectionStrategy::SelectStyles(\n  brewery, beer_style_palette_);
+
+    while (For each selected BeerStyle?) is (remaining)
+      :GetStyleContextFromCache(style);
+      note right
+        Guaranteed cache hit from startup.
+      end note
+      :GenerateBeer(brewery, style_context)\nvia DataGenerator;
+      :Attach GeneratedBeer to Brewery bundle;
+    endwhile (done)
+
+    :PipelineLogger::Log(Info,\n  BreweryAndBeerGeneration,\n  city, brewery_id, "llm");
+    :Send BreweryWithBeers Bundle → exp_ch;
+  endwhile (no)
+  :Close exp_ch;
+fork again
+  |SQLite Worker|
+  while (exp_ch has items?) is (yes)
+    :Receive BreweryWithBeers Bundle;
+    :ProcessBrewery(brewery) → brewery_id;
+    :Append → brewery_pool_;
+
+    while (For each beer in bundle?) is (remaining)
+      :Set beer.brewery_id = brewery_id;
+      :ProcessBeer(beer) → sqlite3_int64;
+      :Append → beer_pool_;
+    endwhile (done)
+
+    :PipelineLogger::Log(Info,\n  BreweryAndBeerGeneration,\n  city, brewery_id, "sqlite");
+  endwhile (no)
+end fork
+
+|Orchestrator|
+:Join LLM Worker, SQLite Worker;
+note right
+  Both brewery_pool_ and beer_pool_
+  are now completely populated.
+end note
+
+' ═══════════════════════════════════════════
+' PHASE 2 — CHECKIN GENERATION
+' ═══════════════════════════════════════════
+:RunCheckinPhase();
+:ICheckinDistributionStrategy::\nAssignActivityWeights(user_pool_);
+note right
+  Weights seeded from each user's
+  persona.checkin_weight. J-curve profile
+  emerges from persona distribution.
+end note
+
+while (For each GeneratedUser in user_pool_?) is (remaining)
+  :CheckinsForUser(user, brewery_pool_.size());
+  while (For each checkin index?) is (remaining)
+    :TimestampFor(user, index);
+    :Select brewery from brewery_pool_;
+    :GenerateCheckin(user, brewery, timestamp)\nvia DataGenerator;
+    :ProcessCheckin(checkin) → sqlite3_int64;
+    :PipelineLogger::Log(Info, CheckinGeneration,\n  nullopt, checkin_id, "sqlite");
+    :Append → checkin_pool_;
+  endwhile (done)
+endwhile (done)
+
+' ═══════════════════════════════════════════
+' PHASE 3 — RATING GENERATION
+' ═══════════════════════════════════════════
+:RunRatingPhase();
+note right
+  Beer selection biased by
+  user.persona.style_affinities and abv_range.
+  Rating skew modulated per persona.
+end note
+
+while (For each GeneratedCheckin in checkin_pool_?) is (remaining)
+  :Match brewery_id → select beer from beer_pool_\n(same brewery_id, biased by persona affinities);
+  if (Beer exists for brewery?) then (yes)
+    :GenerateRating(user, beer, checkin_id)\nvia DataGenerator;
+    :ProcessRating(rating);
+    :PipelineLogger::Log(Info, RatingGeneration,\n  nullopt, rating_id, "sqlite");
+  else (no)
+    :PipelineLogger::Log(Warn, RatingGeneration,\n  nullopt, brewery_id, "sqlite");
+    :Skip — brewery has no beers;
+  endif
+endwhile (done)
+
+' ═══════════════════════════════════════════
+' TEARDOWN
+' ═══════════════════════════════════════════
+|Main|
+:Finalize SqliteExportService;
+note right
+  COMMIT covers all five fixture types.
+end note
+:Close log_ch;
+:Join Log Worker;
+note right
+  Drain guarantees no LogEntry is
+  dropped at shutdown.
+end note
+:spdlog::info "Pipeline complete in X ms";
+stop
+
+@enduml

pipeline/diagrams/future-class-diagram.puml

@@ -0,0 +1,568 @@
+@startuml future_possible_architecture
+
+' ==========================================
+' CONFIGURATION & STYLING
+' ==========================================
+left to right direction
+skinparam linetype ortho
+
+' --- Typography ---
+skinparam defaultFontName "DM Sans"
+skinparam defaultFontSize 14
+skinparam titleFontName "Volkhov"
+skinparam titleFontSize 20
+
+' --- Global Colors ---
+skinparam backgroundColor #FCFCF7
+skinparam defaultFontColor #14180C
+skinparam titleFontColor #14180C
+skinparam ArrowColor #656F33
+
+skinparam class {
+  BackgroundColor #EBECE3
+  HeaderBackgroundColor #CBD2B5
+  BorderColor #4A5837
+  ArrowColor #656F33
+  FontColor #14180C
+}
+
+skinparam package {
+  BackgroundColor #DBEEDD
+  BorderColor #4A5837
+  FontColor #14180C
+}
+
+skinparam note {
+  BackgroundColor #DBEEDD
+  BorderColor #4A5837
+  FontColor #14180C
+}
+
+skinparam monochrome reverse
+
+title The Biergarten Data Pipeline — Planned Architecture
+
+' ==========================================
+' DOMAIN MODELS
+' ==========================================
+package "Domain Models" {
+
+  class Location {
+    + city : std::string
+    + state_province : std::string
+    + iso3166_2 : std::string
+    + country : std::string
+    + iso3166_1 : std::string
+    + local_languages : std::vector<std::string>
+    + latitude : double
+    + longitude : double
+  }
+
+  class LocationContext {
+    + text : std::string
+    + completeness : Completeness
+    + char_count : size_t
+    --
+    <<enum>> Completeness
+    Full
+    Partial
+    Absent
+  }
+
+  class EnrichedCity {
+    + location : Location
+    + context : LocationContext
+  }
+
+  class BeerStyle {
+    + name : std::string
+    + description : std::string
+    + min_abv : float
+    + max_abv : float
+    + min_ibu : int
+    + max_ibu : int
+  }
+
+  class BreweryResult {
+    + name_en : std::string
+    + description_en : std::string
+    + name_local : std::string
+    + description_local : std::string
+  }
+
+  class BeerResult {
+    + name_en : std::string
+    + description_en : std::string
+    + name_local : std::string
+    + description_local : std::string
+    + style : std::string
+    + abv : float
+    + ibu : int
+  }
+
+  class UserResult {
+    + username : std::string
+    + bio : std::string
+    + activity_weight : float
+  }
+
+  class CheckinResult {
+    + checked_in_at : std::string
+    + note : std::string
+  }
+
+  class RatingResult {
+    + score : float
+    + note : std::string
+  }
+
+  class GeneratedBrewery {
+    + brewery_id : sqlite3_int64
+    + location : Location
+    + brewery : BreweryResult
+    + context_completeness : LocationContext::Completeness
+    + generated_at : std::string
+  }
+
+  class GeneratedBeer {
+    + beer_id : sqlite3_int64
+    + brewery_id : sqlite3_int64
+    + location : Location
+    + style : BeerStyle
+    + beer : BeerResult
+    + generated_at : std::string
+  }
+
+  class GeneratedUser {
+    + user_id : sqlite3_int64
+    + location : Location
+    + user : UserResult
+    + generated_at : std::string
+  }
+
+  class GeneratedCheckin {
+    + checkin_id : sqlite3_int64
+    + user_id : sqlite3_int64
+    + brewery_id : sqlite3_int64
+    + checkin : CheckinResult
+    + generated_at : std::string
+  }
+
+  class GeneratedRating {
+    + user_id : sqlite3_int64
+    + beer_id : sqlite3_int64
+    + checkin_id : sqlite3_int64
+    + rating : RatingResult
+    + generated_at : std::string
+  }
+
+  class SamplingOptions {
+    + temperature : float = 1.0F
+    + top_p : float = 0.95F
+    + top_k : uint32_t = 64
+    + n_ctx : uint32_t = 8192
+    + seed : int = -1
+  }
+
+  class GeneratorOptions {
+    + model_path : std::filesystem::path
+    + use_mocked : bool = false
+    + sampling : SamplingOptions
+  }
+
+  class PipelineOptions {
+    + output_path : std::filesystem::path
+    + log_path : std::filesystem::path
+  }
+
+  class ApplicationOptions {
+    + generator : GeneratorOptions
+    + pipeline : PipelineOptions
+  }
+
+  ' --- Domain Model Relationships ---
+  ApplicationOptions *-- GeneratorOptions
+  ApplicationOptions *-- PipelineOptions
+  GeneratorOptions   *-- SamplingOptions
+  LocationContext    *-- Completeness
+}
+
+
+' ==========================================
+' LOGGING
+' ==========================================
+package "Logging" {
+
+  enum LogLevel {
+    Debug
+    Info
+    Warn
+    Error
+  }
+
+  enum PipelinePhase {
+    Startup
+    UserGeneration
+    BreweryAndBeerGeneration
+    CheckinGeneration
+    RatingGeneration
+    Teardown
+  }
+
+  class LogEntry {
+    + timestamp : std::chrono::system_clock::time_point
+    + level : LogLevel
+    + phase : PipelinePhase
+    + message : std::string
+    + city : std::optional<std::string>
+    + entity_id : std::optional<std::string>
+    + worker : std::optional<std::string>
+  }
+
+  interface Logger <<interface>> {
+    + Log(level, phase, message,\n  city, entity_id, worker) : void
+  }
+
+  class PipelineLogger {
+    - log_ch_ : BoundedChannel<LogEntry>&
+    + Log(level, phase, message,\n  city, entity_id, worker) : void
+  }
+
+  class LogWorker {
+    - log_ch_ : BoundedChannel<LogEntry>&
+    + Run() : void
+    - FormatTimestamp(tp) : std::string
+    - ToSpdlogLevel(level) : spdlog::level::level_enum
+    - ToString(phase) : std::string
+  }
+
+  ' --- Logging Relationships ---
+  LogEntry       *--  LogLevel
+  LogEntry       *--  PipelinePhase
+  PipelineLogger ..>  LogEntry       : emits
+  LogWorker      ..>  LogEntry       : consumes
+}
+
+
+' ==========================================
+' DOMAIN POLICY
+' ==========================================
+package "Domain Policy" {
+
+  interface ContextStrategy <<interface>> {
+    + QueriesFor(loc : const Location&) : std::vector<std::string>
+    + MaxContextChars() : size_t
+  }
+
+  class BreweryContextStrategy {
+    + QueriesFor(loc : const Location&) : std::vector<std::string>
+    + MaxContextChars() : size_t
+  }
+
+  class BeerContextStrategy {
+    + QueriesFor(loc : const Location&) : std::vector<std::string>
+    + MaxContextChars() : size_t
+  }
+
+  interface SamplingStrategy <<interface>> {
+    + Sample(locations : const std::vector<Location>&) : std::vector<Location>
+  }
+
+  class UniformSamplingStrategy {
+    - sample_size_ : size_t
+    + Sample(locations : const std::vector<Location>&) : std::vector<Location>
+  }
+
+  interface BeerSelectionStrategy <<interface>> {
+    + SelectStyles(brewery : const GeneratedBrewery&,\n  palette : std::span<const BeerStyle>) : std::vector<BeerStyle>
+  }
+
+  class RandomBeerSelectionStrategy {
+    - rng_ : std::mt19937
+    - min_beers_ : size_t
+    - max_beers_ : size_t
+    + SelectStyles(brewery : const GeneratedBrewery&,\n  palette : std::span<const BeerStyle>) : std::vector<BeerStyle>
+  }
+
+  interface CheckinDistributionStrategy <<interface>> {
+    + AssignActivityWeights(users : std::vector<GeneratedUser>&) : void
+    + CheckinsForUser(user : const GeneratedUser&,\n  brewery_count : size_t) : size_t
+    + TimestampFor(user : const GeneratedUser&,\n  index : size_t) : std::string
+  }
+
+  class JCurveCheckinStrategy {
+    - rng_ : std::mt19937
+    + AssignActivityWeights(users : std::vector<GeneratedUser>&) : void
+    + CheckinsForUser(user : const GeneratedUser&,\n  brewery_count : size_t) : size_t
+    + TimestampFor(user : const GeneratedUser&,\n  index : size_t) : std::string
+  }
+
+}
+
+
+' ==========================================
+' ORCHESTRATION
+' ==========================================
+package "Orchestration" {
+
+  interface DataPreloader <<interface>> {
+    + LoadLocations(filepath : const std::filesystem::path&) : std::vector<Location>
+    + LoadBeerStyles(filepath : const std::filesystem::path&) : std::vector<BeerStyle>
+    + LoadPersonas(filepath : const std::filesystem::path&) : std::vector<Persona>
+    + LoadNamesByCountry(filepath : const std::filesystem::path&) : NamesByCountry
+  }
+
+  class BiergartenPipelineOrchestrator {
+    - preloader_ : std::unique_ptr<DataPreloader>
+    - enrichment_service_ : std::unique_ptr<EnrichmentService>
+    - generator_ : std::unique_ptr<DataGenerator>
+    - logger_ : std::unique_ptr<Logger>
+    - exporter_ : std::unique_ptr<ExportService>
+    - brewery_context_strategy_ : std::unique_ptr<ContextStrategy>
+    - sampling_strategy_ : std::unique_ptr<SamplingStrategy>
+    - beer_selection_strategy_ : std::unique_ptr<BeerSelectionStrategy>
+    - checkin_strategy_ : std::unique_ptr<CheckinDistributionStrategy>
+    - beer_style_palette_ : std::vector<BeerStyle>
+    - options_ : ApplicationOptions
+    --
+    - user_pool_ : std::vector<GeneratedUser>
+    - brewery_pool_ : std::vector<GeneratedBrewery>
+    - beer_pool_ : std::vector<GeneratedBeer>
+    - checkin_pool_ : std::vector<GeneratedCheckin>
+    --
+    + Run() : bool
+    - RunUserPhase(locations : const std::vector<Location>&) : void
+    - RunBreweryAndBeerPhase(locations : const std::vector<Location>&) : void
+    - RunCheckinPhase() : void
+    - RunRatingPhase() : void
+  }
+}
+
+
+' ==========================================
+' INFRASTRUCTURE: PRELOADING
+' ==========================================
+package "Infrastructure: Preloading" {
+
+  class JsonLoader {
+    + LoadLocations(filepath : const std::filesystem::path&) : std::vector<Location>
+    + LoadBeerStyles(filepath : const std::filesystem::path&) : std::vector<BeerStyle>
+    + LoadPersonas(filepath : const std::filesystem::path&) : std::vector<Persona>
+    + LoadNamesByCountry(filepath : const std::filesystem::path&) : NamesByCountry
+  }
+
+}
+
+
+' ==========================================
+' INFRASTRUCTURE: ENRICHMENT
+' ==========================================
+package "Infrastructure: Enrichment" {
+
+  interface EnrichmentService <<interface>> {
+    + GetLocationContext(loc : const Location&,\n  strategy : const ContextStrategy&) : LocationContext
+  }
+
+  class WikipediaService {
+    - client_ : std::unique_ptr<WebClient>
+    - extract_cache_ : std::unordered_map<std::string, std::string>
+    + GetLocationContext(loc : const Location&,\n  strategy : const ContextStrategy&) : LocationContext
+    - FetchExtract(query : std::string_view) : std::string
+  }
+
+  interface WebClient <<interface>> {
+    + Get(url : const std::string&) : std::string
+    + UrlEncode(value : const std::string&) : std::string
+  }
+
+  class CURLWebClient {
+    + Get(url : const std::string&) : std::string
+    + UrlEncode(value : const std::string&) : std::string
+  }
+
+}
+
+
+' ==========================================
+' INFRASTRUCTURE: GENERATION
+' ==========================================
+package "Infrastructure: Generation" {
+
+  interface DataGenerator <<interface>> {
+    + GenerateBrewery(location : const Location&,\n  context : const LocationContext&) : BreweryResult
+    + GenerateBeer(brewery_id : sqlite3_int64,\n  location : const Location&,\n  context : const LocationContext&,\n  style : const BeerStyle&) : BeerResult
+    + GenerateUser(location : const Location&) : UserResult
+    + GenerateCheckin(user : const GeneratedUser&,\n  brewery : const GeneratedBrewery&,\n  timestamp : const std::string&) : CheckinResult
+    + GenerateRating(user : const GeneratedUser&,\n  beer : const GeneratedBeer&,\n  checkin_id : sqlite3_int64) : RatingResult
+  }
+
+  class MockGenerator {
+    + GenerateBrewery(...) : BreweryResult
+    + GenerateBeer(...) : BeerResult
+    + GenerateUser(...) : UserResult
+    + GenerateCheckin(...) : CheckinResult
+    + GenerateRating(...) : RatingResult
+    - DeterministicHash(location : const Location&) : size_t
+  }
+
+  class LlamaGenerator {
+    - model_ : ModelHandle
+    - context_ : ContextHandle
+    - prompt_formatter_ : std::unique_ptr<PromptFormatter>
+    - rng_ : std::mt19937
+    + GenerateBrewery(...) : BreweryResult
+    + GenerateBeer(...) : BeerResult
+    + GenerateUser(...) : UserResult
+    + GenerateCheckin(...) : CheckinResult
+    + GenerateRating(...) : RatingResult
+    - Load(opts : const GeneratorOptions&) : void
+    - Infer(system_prompt, user_prompt,\n  max_tokens, grammar) : std::string
+    - ValidateModelArchitecture() : void
+  }
+
+  interface PromptFormatter <<interface>> {
+    + Format(system_prompt : std::string_view,\n  user_prompt : std::string_view) : std::string
+    + ExpectedArchitecture() : std::string_view
+  }
+
+  class Gemma4JinjaPromptFormatter {
+    + Format(...) : std::string
+    + ExpectedArchitecture() : std::string_view
+  }
+
+}
+
+
+' ==========================================
+' INFRASTRUCTURE: PIPELINE CHANNEL
+' ==========================================
+package "Infrastructure: Pipeline Channel" {
+
+  class "BoundedChannel<T>" as BoundedChannel {
+    - queue_ : std::queue<T>
+    - mutex_ : std::mutex
+    - not_full_ : std::condition_variable
+    - not_empty_ : std::condition_variable
+    - capacity_ : size_t
+    - closed_ : bool
+    + Send(item : T) : void
+    + Receive() : std::optional<T>
+    + Close() : void
+  }
+
+}
+
+
+' ==========================================
+' INFRASTRUCTURE: EXPORT
+' ==========================================
+package "Infrastructure: Export" {
+
+  interface ExportService <<interface>> {
+    + Initialize() : void
+    + ProcessBrewery(brewery : const GeneratedBrewery&) : sqlite3_int64
+    + ProcessBeer(beer : const GeneratedBeer&) : sqlite3_int64
+    + ProcessUser(user : const GeneratedUser&) : sqlite3_int64
+    + ProcessCheckin(checkin : const GeneratedCheckin&) : sqlite3_int64
+    + ProcessRating(rating : const GeneratedRating&) : void
+    + Finalize() : void
+  }
+
+  class SqliteExportService {
+    - date_time_provider_ : std::unique_ptr<DateTimeProvider>
+    - db_handle_ : SqliteDatabaseHandle
+    - insert_location_stmt_ : SqliteStatementHandle
+    - insert_brewery_stmt_ : SqliteStatementHandle
+    - insert_beer_stmt_ : SqliteStatementHandle
+    - insert_user_stmt_ : SqliteStatementHandle
+    - insert_checkin_stmt_ : SqliteStatementHandle
+    - insert_rating_stmt_ : SqliteStatementHandle
+    - transaction_open_ : bool
+    - location_cache_ : std::unordered_map<std::string, sqlite3_int64>
+    - brewery_cache_ : std::unordered_map<std::string, sqlite3_int64>
+    + Initialize() : void
+    + ProcessBrewery(brewery : const GeneratedBrewery&) : sqlite3_int64
+    + ProcessBeer(beer : const GeneratedBeer&) : sqlite3_int64
+    + ProcessUser(user : const GeneratedUser&) : sqlite3_int64
+    + ProcessCheckin(checkin : const GeneratedCheckin&) : sqlite3_int64
+    + ProcessRating(rating : const GeneratedRating&) : void
+    + Finalize() : void
+    - InitializeSchema() : void
+    - PrepareStatements() : void
+    - RollbackAndCloseNoThrow() : void
+    - FinalizeStatements() : void
+  }
+
+  interface DateTimeProvider <<interface>> {
+    + GetUtcTimestamp() : std::string
+  }
+
+  class SystemDateTimeProvider {
+    + GetUtcTimestamp() : std::string
+  }
+
+}
+
+
+' ==========================================
+' GLOBAL RELATIONSHIPS
+' ==========================================
+
+' --- Orchestration Aggregations (Services & Strategies) ---
+BiergartenPipelineOrchestrator *--  DataPreloader
+BiergartenPipelineOrchestrator *--  EnrichmentService
+BiergartenPipelineOrchestrator *--  DataGenerator
+BiergartenPipelineOrchestrator *--  ExportService
+BiergartenPipelineOrchestrator *--  CheckinDistributionStrategy
+BiergartenPipelineOrchestrator *--  SamplingStrategy
+BiergartenPipelineOrchestrator *--  BeerSelectionStrategy
+BiergartenPipelineOrchestrator *--  ApplicationOptions
+BiergartenPipelineOrchestrator *--  Logger
+
+' --- Orchestration Aggregations (Data Pools) ---
+BiergartenPipelineOrchestrator *-- "0..*" GeneratedUser    : user_pool_
+BiergartenPipelineOrchestrator *-- "0..*" GeneratedBrewery : brewery_pool_
+BiergartenPipelineOrchestrator *-- "0..*" GeneratedBeer    : beer_pool_
+BiergartenPipelineOrchestrator *-- "0..*" GeneratedCheckin : checkin_pool_
+
+' --- Interfaces & Implementations ---
+DataPreloader                  <|.. JsonLoader
+Logger                         <|.. PipelineLogger
+ContextStrategy                <|.. BreweryContextStrategy
+ContextStrategy                <|.. BeerContextStrategy
+SamplingStrategy               <|.. UniformSamplingStrategy
+BeerSelectionStrategy          <|.. RandomBeerSelectionStrategy
+CheckinDistributionStrategy    <|.. JCurveCheckinStrategy
+EnrichmentService              <|.. WikipediaService
+WebClient                      <|.. CURLWebClient
+DataGenerator                  <|.. MockGenerator
+DataGenerator                  <|.. LlamaGenerator
+PromptFormatter                <|.. Gemma4JinjaPromptFormatter
+ExportService                  <|.. SqliteExportService
+DateTimeProvider               <|.. SystemDateTimeProvider
+
+' --- Service Compositions & Dependencies ---
+WikipediaService               *--  WebClient
+WikipediaService               ..>  ContextStrategy
+LlamaGenerator                 *--  PromptFormatter
+LlamaGenerator                 ..>  GeneratorOptions
+SqliteExportService            *--  DateTimeProvider
+
+' --- Cross-Component Aggregations (Held References) ---
+PipelineLogger                 o--  BoundedChannel : logs to
+LogWorker                      o--  BoundedChannel : drains from
+
+' --- Domain Containment ---
+EnrichedCity                   *--  Location
+EnrichedCity                   *--  LocationContext
+GeneratedBrewery               *--  Location
+GeneratedBrewery               *--  BreweryResult
+GeneratedBeer                  *--  Location
+GeneratedBeer                  *--  BeerStyle
+GeneratedBeer                  *--  BeerResult
+GeneratedUser                  *--  Location
+GeneratedUser                  *--  UserResult
+GeneratedCheckin               *--  CheckinResult
+GeneratedRating                *--  RatingResult
+
+@enduml