From 5b2eceb6b831e2f34e4eb77f024fc1c2f549529d Mon Sep 17 00:00:00 2001
From: Aaron Po <apo2@uwo.ca>
Date: Mon, 20 Jul 2026 00:55:21 -0400
Subject: [PATCH] Add sqlite load into Database.Seed

---
 tooling/pipeline/CMakeLists.txt               |   6 +-
 .../src/services/xeger/xeger_generator.cc     |  10 +-
 .../Database.Seed/Database.Seed.csproj        |   8 +-
 .../ConnectionStrings.cs}                     |  15 +-
 .../PipelineData/BreweryAddress.cs            |   8 ++
 .../PipelineData/BreweryRecord.cs             |   8 ++
 .../PipelineData/BreweryResult.cs             |  12 ++
 .../Database.Seed/PipelineData/City.cs        |  18 +++
 .../PipelineData/PostalCodeSpec.cs            |  10 ++
 .../Database.Seed/PipelineData/UserAddress.cs |   8 ++
 .../Database.Seed/PipelineData/UserRecord.cs  |  12 ++
 .../Database.Seed/PipelineData/UserResult.cs  |  16 +++
 web/backend/Database/Database.Seed/Program.cs |  53 +++++++
 .../Database.Seed/SeedData/seed.sqlite        | Bin 0 -> 61440 bytes
 .../Sqlite/PipelineSeedDataReader.cs          | 135 ++++++++++++++++++
 15 files changed, 298 insertions(+), 21 deletions(-)
 rename web/backend/Database/Database.Seed/{DatabaseHelpers.cs => DatabaseHelpers/ConnectionStrings.cs} (73%)
 create mode 100644 web/backend/Database/Database.Seed/PipelineData/BreweryAddress.cs
 create mode 100644 web/backend/Database/Database.Seed/PipelineData/BreweryRecord.cs
 create mode 100644 web/backend/Database/Database.Seed/PipelineData/BreweryResult.cs
 create mode 100644 web/backend/Database/Database.Seed/PipelineData/City.cs
 create mode 100644 web/backend/Database/Database.Seed/PipelineData/PostalCodeSpec.cs
 create mode 100644 web/backend/Database/Database.Seed/PipelineData/UserAddress.cs
 create mode 100644 web/backend/Database/Database.Seed/PipelineData/UserRecord.cs
 create mode 100644 web/backend/Database/Database.Seed/PipelineData/UserResult.cs
 create mode 100644 web/backend/Database/Database.Seed/Program.cs
 create mode 100644 web/backend/Database/Database.Seed/SeedData/seed.sqlite
 create mode 100644 web/backend/Database/Database.Seed/Sqlite/PipelineSeedDataReader.cs

diff --git a/tooling/pipeline/CMakeLists.txt b/tooling/pipeline/CMakeLists.txt
index 2716c490..220334bf 100644
--- a/tooling/pipeline/CMakeLists.txt
+++ b/tooling/pipeline/CMakeLists.txt
@@ -111,8 +111,9 @@ if(NOT BIERGARTEN_MOCK_ONLY)
                 )
                 FetchContent_MakeAvailable(llama-cpp)
         endif()
-
+        if (NOT APPLE)
         find_package(OpenMP REQUIRED)
+        endif()
 endif()
 
 # spdlog
@@ -249,9 +250,10 @@ target_include_directories(${PROJECT_NAME} PRIVATE
         includes
 )
 
+
 target_link_libraries(${PROJECT_NAME} PRIVATE
         $<$<NOT:$<BOOL:${BIERGARTEN_MOCK_ONLY}>>:llama>
-        $<$<NOT:$<BOOL:${BIERGARTEN_MOCK_ONLY}>>:OpenMP::OpenMP_CXX>
+        $<TARGET_NAME_IF_EXISTS:OpenMP::OpenMP_CXX>
         boost::di
         Boost::json
         Boost::program_options
diff --git a/tooling/pipeline/src/services/xeger/xeger_generator.cc b/tooling/pipeline/src/services/xeger/xeger_generator.cc
index e812d898..82aca295 100644
--- a/tooling/pipeline/src/services/xeger/xeger_generator.cc
+++ b/tooling/pipeline/src/services/xeger/xeger_generator.cc
@@ -54,11 +54,11 @@ void XegerGenerator::Visit(const Alternation& node) {
 }
 
 void XegerGenerator::Visit(const Repeat& node) {
-   const int lo = node.min;
-   const int hi = (node.max < 0) ? node.min + unbounded_cap_ : node.max;
-   std::uniform_int_distribution<int> dist(lo, hi);
-   const int count = dist(rng_);
-   for (int i = 0; i < count; ++i) {
+   const unsigned int low = node.min;
+   const unsigned int high = node.max.value_or(node.min + unbounded_cap_);
+   std::uniform_int_distribution<unsigned int> dist(low, high);
+   const unsigned int count = dist(rng_);
+   for (unsigned int i = 0; i < count; ++i) {
       node.child->Accept(*this);
    }
 }
diff --git a/web/backend/Database/Database.Seed/Database.Seed.csproj b/web/backend/Database/Database.Seed/Database.Seed.csproj
index 0d9b350c..887c52c3 100644
--- a/web/backend/Database/Database.Seed/Database.Seed.csproj
+++ b/web/backend/Database/Database.Seed/Database.Seed.csproj
@@ -16,7 +16,7 @@
 
         <!--
         remove this override once microsoft ships official fix to vulnerability
-        https://github.com/advisories/GHSA-2m69-gcr7-jv3q
+        https:
         -->
         <PackageReference Include="SQLitePCLRaw.lib.e_sqlite3" Version="3.50.3" />
     </ItemGroup>
@@ -24,4 +24,10 @@
     <ItemGroup>
         <ProjectReference Include="..\..\Domain\Domain.Entities\Domain.Entities.csproj" />
     </ItemGroup>
+
+    <ItemGroup>
+        <!-- Pipeline-generated seed data, copied to the output directory so it can be opened via
+             ConnectionStrings.SqliteConnectionString at runtime. -->
+        <None Include="SeedData\seed.sqlite" CopyToOutputDirectory="PreserveNewest" />
+    </ItemGroup>
 </Project>
diff --git a/web/backend/Database/Database.Seed/DatabaseHelpers.cs b/web/backend/Database/Database.Seed/DatabaseHelpers/ConnectionStrings.cs
similarity index 73%
rename from web/backend/Database/Database.Seed/DatabaseHelpers.cs
rename to web/backend/Database/Database.Seed/DatabaseHelpers/ConnectionStrings.cs
index 574296b4..6554b980 100644
--- a/web/backend/Database/Database.Seed/DatabaseHelpers.cs
+++ b/web/backend/Database/Database.Seed/DatabaseHelpers/ConnectionStrings.cs
@@ -1,19 +1,9 @@
 using Microsoft.Data.SqlClient;
 
-namespace Database.Seed;
+namespace Database.Seed.DatabaseHelpers;
 
 public class ConnectionStrings
 {
-    /// <summary>
-    /// Builds a SQL Server connection string from the <c>DB_SERVER</c>, <c>DB_NAME</c>,
-    /// <c>DB_USER</c>, <c>DB_PASSWORD</c>, and <c>DB_TRUST_SERVER_CERTIFICATE</c>
-    /// environment variables.
-    /// </summary>
-    /// <returns>A fully built SQL Server connection string.</returns>
-    /// <exception cref="InvalidOperationException">
-    /// Thrown when <c>DB_SERVER</c>, <c>DB_NAME</c>, <c>DB_USER</c>, or <c>DB_PASSWORD</c>
-    /// is not set.
-    /// </exception>
     private static string GetSqlServerConnectionString()
     {
         string server =
@@ -48,7 +38,6 @@ public class ConnectionStrings
         return builder.ConnectionString;
     }
 
-
     public static string SqlServerConnectionString => GetSqlServerConnectionString();
-    public static string SqliteConnectionString => "Data Source=seed.sqlite";
+    public static string SqliteConnectionString => "Data Source=SeedData/seed.sqlite";
 }
diff --git a/web/backend/Database/Database.Seed/PipelineData/BreweryAddress.cs b/web/backend/Database/Database.Seed/PipelineData/BreweryAddress.cs
new file mode 100644
index 00000000..b6902bb1
--- /dev/null
+++ b/web/backend/Database/Database.Seed/PipelineData/BreweryAddress.cs
@@ -0,0 +1,8 @@
+namespace Database.Seed.PipelineData;
+
+public sealed record BreweryAddress
+{
+    public required City City { get; init; }
+
+    public required string PostalCode { get; init; }
+}
diff --git a/web/backend/Database/Database.Seed/PipelineData/BreweryRecord.cs b/web/backend/Database/Database.Seed/PipelineData/BreweryRecord.cs
new file mode 100644
index 00000000..93c67e9a
--- /dev/null
+++ b/web/backend/Database/Database.Seed/PipelineData/BreweryRecord.cs
@@ -0,0 +1,8 @@
+namespace Database.Seed.PipelineData;
+
+public sealed record BreweryRecord
+{
+    public required BreweryAddress Address { get; init; }
+
+    public required BreweryResult Brewery { get; init; }
+}
diff --git a/web/backend/Database/Database.Seed/PipelineData/BreweryResult.cs b/web/backend/Database/Database.Seed/PipelineData/BreweryResult.cs
new file mode 100644
index 00000000..13d42f5f
--- /dev/null
+++ b/web/backend/Database/Database.Seed/PipelineData/BreweryResult.cs
@@ -0,0 +1,12 @@
+namespace Database.Seed.PipelineData;
+
+public sealed record BreweryResult
+{
+    public required string NameEn { get; init; }
+
+    public required string DescriptionEn { get; init; }
+
+    public required string NameLocal { get; init; }
+
+    public required string DescriptionLocal { get; init; }
+}
diff --git a/web/backend/Database/Database.Seed/PipelineData/City.cs b/web/backend/Database/Database.Seed/PipelineData/City.cs
new file mode 100644
index 00000000..88de9e2e
--- /dev/null
+++ b/web/backend/Database/Database.Seed/PipelineData/City.cs
@@ -0,0 +1,18 @@
+namespace Database.Seed.PipelineData;
+
+public sealed record City
+{
+    public required string CityName { get; init; }
+
+    public required string StateProvince { get; init; }
+
+    public required string Iso31662 { get; init; }
+
+    public required string Country { get; init; }
+
+    public required string Iso31661 { get; init; }
+
+    public IReadOnlyList<string> LocalLanguages { get; init; } = [];
+
+    public required PostalCodeSpec PostalCode { get; init; }
+}
diff --git a/web/backend/Database/Database.Seed/PipelineData/PostalCodeSpec.cs b/web/backend/Database/Database.Seed/PipelineData/PostalCodeSpec.cs
new file mode 100644
index 00000000..d367da6b
--- /dev/null
+++ b/web/backend/Database/Database.Seed/PipelineData/PostalCodeSpec.cs
@@ -0,0 +1,10 @@
+namespace Database.Seed.PipelineData;
+
+public sealed record PostalCodeSpec
+{
+    public required string CountryFormatRegex { get; init; }
+
+    public IReadOnlyList<string> CityRegexes { get; init; } = [];
+
+    public IReadOnlyList<string> Examples { get; init; } = [];
+}
diff --git a/web/backend/Database/Database.Seed/PipelineData/UserAddress.cs b/web/backend/Database/Database.Seed/PipelineData/UserAddress.cs
new file mode 100644
index 00000000..6b63a17c
--- /dev/null
+++ b/web/backend/Database/Database.Seed/PipelineData/UserAddress.cs
@@ -0,0 +1,8 @@
+namespace Database.Seed.PipelineData;
+
+public sealed record UserAddress
+{
+    public required City City { get; init; }
+
+    public required string PostalCode { get; init; }
+}
diff --git a/web/backend/Database/Database.Seed/PipelineData/UserRecord.cs b/web/backend/Database/Database.Seed/PipelineData/UserRecord.cs
new file mode 100644
index 00000000..fa8f0dc2
--- /dev/null
+++ b/web/backend/Database/Database.Seed/PipelineData/UserRecord.cs
@@ -0,0 +1,12 @@
+namespace Database.Seed.PipelineData;
+
+public sealed record UserRecord
+{
+    public required UserAddress Address { get; init; }
+
+    public required UserResult User { get; init; }
+
+    public required string Email { get; init; }
+
+    public required string DateOfBirth { get; init; }
+}
diff --git a/web/backend/Database/Database.Seed/PipelineData/UserResult.cs b/web/backend/Database/Database.Seed/PipelineData/UserResult.cs
new file mode 100644
index 00000000..0e53881d
--- /dev/null
+++ b/web/backend/Database/Database.Seed/PipelineData/UserResult.cs
@@ -0,0 +1,16 @@
+namespace Database.Seed.PipelineData;
+
+public sealed record UserResult
+{
+    public required string FirstName { get; init; }
+
+    public required string LastName { get; init; }
+
+    public required string Gender { get; init; }
+
+    public required string Username { get; init; }
+
+    public required string Bio { get; init; }
+
+    public required float ActivityWeight { get; init; }
+}
diff --git a/web/backend/Database/Database.Seed/Program.cs b/web/backend/Database/Database.Seed/Program.cs
new file mode 100644
index 00000000..6a025994
--- /dev/null
+++ b/web/backend/Database/Database.Seed/Program.cs
@@ -0,0 +1,53 @@
+using Database.Seed.DatabaseHelpers;
+using Database.Seed.PipelineData;
+using Database.Seed.Sqlite;
+using Microsoft.Data.Sqlite;
+
+namespace Database.Seed;
+
+public class Program
+{
+    public static int Main()
+    {
+        IReadOnlyList<BreweryRecord> breweries;
+        IReadOnlyList<UserRecord> users;
+        try
+        {
+            PipelineSeedDataReader reader = new(ConnectionStrings.SqliteConnectionString);
+            breweries = reader.ReadBreweryRecords();
+            users = reader.ReadUserRecords();
+        }
+        catch (SqliteException ex)
+        {
+            Console.ForegroundColor = ConsoleColor.Red;
+            Console.WriteLine($"Error opening database connection: {ex.Message}");
+            Console.ResetColor();
+            return 1;
+        }
+
+
+        Console.ForegroundColor = ConsoleColor.Green;
+        Console.WriteLine(
+            $"Loaded {breweries.Count} breweries."
+        );
+        Console.ResetColor();
+
+        for (int i = 0; i < breweries.Count; i++)
+        {
+            BreweryRecord brewery = breweries[i];
+            Console.WriteLine($"{i + 1}:\t{brewery.Brewery.NameEn}\t({brewery.Address.City.CityName}, {brewery.Address.City.Country})");
+        }
+        Console.ForegroundColor = ConsoleColor.Green;
+        Console.WriteLine($"Loaded {users.Count} users.");
+        Console.ResetColor();
+
+        for (int i = 0; i < users.Count; i++)
+        {
+            UserRecord user = users[i];
+            Console.WriteLine($"{i + 1}:\t{user.User.FirstName} {user.User.LastName}\t ({user.Email})");
+        }
+
+        return 0;
+
+    }
+}
diff --git a/web/backend/Database/Database.Seed/SeedData/seed.sqlite b/web/backend/Database/Database.Seed/SeedData/seed.sqlite
new file mode 100644
index 0000000000000000000000000000000000000000..06cd47a2ce47a2ab87dbcbc4d077327f667dd0f6
GIT binary patch
literal 61440
zcmeI5%WoV<e#beaC0f$T%my$B!AV?p7LXZ}G@p7z2)vX<c?IjSD^a!=w3euuu9<1E
zr)%5~jz(dS*lQ%G+!DZ>9COJfmj(8+e?fxe8X$)N$>y||0J&rlBst{stLk}BBxTE4
z@4|~BByy&^tLj(Z-?NHSU*7x9&A2eCX|s+l)at~qP1I@=-&AU1V&XLaXZSz(I>n3U
z25<OT8+(1+%hMB!fBv^;XZ~yAYbXDE;)T_jzd!qvvnS8|&6(dg{b#2xoQ|jeW4h!<
z_zDOF1Ofs9fq=j-41xaFre`<iY9GBAr;&LSM~`;O++;gCiZYYuCf{kqMSmxb4qiR`
z*4@pGtxa{~_O;FT)$y%PD|P3#I@tELs>iwhna>#7wR>{tuYK0gRjVV1uI|l!{MPB|
z*}1veCmV&XC+47l2j88k#@pJsdUNxMsi@Z&C60h$YxC{RyXxC_Z`|6r`(5?U=6BV`
z{jEDUZqxYI=IyO{o~y<lK79Mmmb!ia=1sX*L2~51uFVUb>@;j-)Yj(vG#YDo{m$LZ
z8*ks15nmfjPTk$SzIk`^_FJ3x+@SeuaWp4-xVCw76Q#Yiaqq2-Ynw9ec=Lf;#+!33
zHpjF-J@@g_^V74lv$ap&9HN+u5c#P?nB~s|RWr`=Vkgy|BW9fFV{f$#Hk=&>Nn|>@
zvwCa~Kdu`^yeC%QGjXe3fXBwo1E8CZj+2A!)cxBxzH{GU8tKC9*yc_>&WiTIr%un!
zojN)Dd$Y9(=WY3i303EgE(`14JJ-v1mK}ztKRPizJ^S_>wU1sIx@J8yJ(Kkhd*`7W
z&mZ!VLyrtR8#BN*4&5HQ=|?Y|oSwaf91Bm8W6(T~2Cs$@WcqW6GH4V>$4N7KV(#O2
zPfX9g@kZ^FZD)3aJHr7FT{wBb91q=oCes|W9`pKffBd;P@@R~?acA_GkM+m@zdwKU
z{&Ul_FTY&-_z%Z`WxV0QCyoG;`_BZRIO2{;4?2d(9+|w6#oZ#d>5=zc!^Af96R!7U
z+an%1J@@UYle4eCUi+?_Smk%Q`LHx;!#wf!xdW4Y;^u22#XK$NzW-uvdiLD8+8>{A
zefmi0zfT_M!C!kOjKqo#14J4iT68nJ7bErI`*ChpmoHq{Svh>GVav40j_7mHX8CX%
zhvQD7(^jcl6ao)(dxX};vJ)xFjk4pH(L0%GnMa5FJ<vkJtb6X5?tNHwv1nc$1Ylkb
zgkPCg)zEXN=U$&YIs4|h<07nA#?G?;IYpWEyp&pJ`9FE~@x<A`<6HO&2m}NI0s(=5
zKtLcM5D*9m1Ox&C0f8?8fm@TOC(ixmxtG3v?xi=cW+e;F>nu6h#>=m6F1&m5?W-nf
z#bxK}=Ju;;^6G={eGvWr+8=yl`_=DVdhN~M-CkOGu(Y(ly1l%1>A}+6H(q`4$y)8q
z#JShcz5Ml;U;2~$UO!4r|F-F=d$wdV?meBDeB=JY?R)QSlzEZqB-R`Ew_i2s!p8ma
z&gpxZ|4Z_JdwJpVgZ<^D{gv&dh1GR=v--gY(f%55FFcsrmj}03xGWc!wwIROBg@Ff
zwYmM3s*lz6i<bs1m-a8aUg!2#rSa0*g$GOf%WM0q>-+25OY5{+lk2PN59Hnc_Jxb`
z;=%*EU*`StWsya?7a`=zC4Q{&^YZr6>bi`&F71~uJy_qr;JUadLoTgf<kkhb<wo2_
zB6oLb1q_#H$nfizc;=!L>oQWwfbJQ2c-f8jVE@AU+`iz?Y(<>yWm>MROCKW4g{A$A
z+ak>+>1_Y<@?3?2bh@&@(1O(V#mjWOz;^*{VP)-t%m>&ii~(Y0{i0mEw7uq#bU-gJ
ztPYW0SmUl&gWyIV4DLF3fCMY6OvIzVv^wb9kFp{Hh_q`D=H|p~<d^)DGe4Y|`Qgkz
zehEe%x(o;e1Ofs9fq+0jARrJB2nYlO0s;YnfIvXt3nB38N!c~3J!Q*i@^?<kM$oCx
zvk7!|=C3DC%=}<t<{xJMbLJ;AKbZN^7ZNHo3J3%Q0s;YnfIvVXAP^7;2m}NI0s(=5
zKtSM&AaM4%sh4ZR^Cy!t|1@#-)Zlo`izlYusP2s&iJClJn>ttXpYNY!$Wy1}IMuID
zP0iKh#pvwR<f+N2S$8d;Ji&vtng0<9XZ#O&8NLDn0fApQ0-ttk&rhs>ny-I){<`H9
za+`1Joj6I=Rn9-=TW!N}pOnKuX)&)7+f(hbqij<(O~w%?leXfNGijap5#M_;ANwk3
zk+*f$Re8gtg*=-Zt#X|dD$3$!5vMI4%52&458EW7V;#x$y6)3U8rfdHsP2@Rs+Vyh
zcjlE=DMJ;8KHCe@bIJHQpI*xgn;O;AnQ2>sjw;H=u8CBf7S;*VwHYJFd;%?QFo(9z
zxoqV@lOzkA_C;RqX*mnW9NGo|BGb?uksAu%%@C}u_lz<{qfPILoAz)FC&Qw8&-~jT
z{eXuOqqCH!kRXY9KLn=BN9~YAaEWxMs~YV%Ne~Afl-v{rADA1--Q<85$6K9LQJD!m
zes}eJj!JC8;oFV{j9jo8=tyOzBPT~Q5nWV)Ch|77ImpXdK9lannN2$)K+h<PJREa#
z^2Mph4=YQf%vIayy*TMB4xvdWX{qJt-k{Hp&f6jmr{lQF__oQEL~_%jKe?sFRu*`m
zFmb9Z^V8A8GHviPv1u!hIbUtjuNYROvk1*+iRr64cr2=|cAUEgdErFW3BBc<uNFi*
zI^~F*lM5r1`<hmAh>s~tpUA+NIWI+Krr0!%BI(bAO<pEWJnoxE1y~s-*+5<CJjU5q
z2|Z_GAEJ;#bkopc=h$zVb+b5^xkaXnoikVia5=whvVp{1CafE6&dR0d3-ypsJt|%2
z!;qL-qn*ZbniA}2(7&SM0$X90>ccWNg-We67eN~_o$SprL1tT*Zt`xN#m<>9Es@y*
zV@!YEB<3r-MasQ+kINayE#nLm?AdHrgmxy_V_s$t<8Z^2tricAn}j>=7@5df0y8&=
zz+j>}WDsl<&QBX>i<R<4BPL~BT!WrPgHB8)0hs`j<Yh}|AOezIeAYy`piQmo!x<?4
zz`KUhExx0ll23}N)QDwOO6_Pj1$nx|`FsTNNVxGDneC1|50UZA$jREaT`^J2q2oLe
zEqm`8ejGJbdpZMsj@5GD(HJ+3^sX}tHxWY7z8Q;KI+N(cS!O+YrbL^4W|XTOD@yWF
zaEnv<P_6imW~y|CcVwxxIM`O(5P0fFj0||iO1yzIIceX%B6<OCu=H0sV(%UQLy!cF
zc^40{2HXL?5FaXCR)^;+2f%xPw7;lsG*#c0#75j5JuyS4c|5$Zodt=lg#>cvLlS5d
z=DZ6OA_mrp991yYJ>s7;f-d&!I>`+&C&Hfbr9t?PY-4xvnbL^p^iV1p+N<2Ha*1Fp
zKKBK4iHj(MWKsnR7dW3SsW=>%un2Z!UJ>;knOCa3aWG@3CU$mYvKd))9(TIvx`iPf
zN+-wX5GUby1|hGdRj^PkQw&lF=XwkB$*~Cpzb#y*9%PViqB#ydmOFgjIFGGlhB)2#
z8AM#r!zBL56bo1!o=hNv#6k5SDhJo&(}s&*5`m7(7({GbgcPcZp3%GHU?z!oe!g^(
zd+W}GgJNE_prk+`$v4hnIRZ}LitEhosma1s2nTXS6%B`(LMBO{9eh)8PtmGR6Jset
z3YA?+5Kb|lD?OxILaW&IQ`3V4gSK{whM4Mu!FWVHkRN>IFrFS-QUKA1OAivII)qL_
zHf2{8u#Qa;Za9}EFr6wBR0%^kMvl%JE@O8|-l7a~IUm?u9!(7<hC^V>zMsOCBvopV
zhX;w_JVNUvw@NH=p(tHpCY{-?7`GH_qr8yEW;`dfIb$z_bI2Y6q-Y#whAQg2yx@y2
z7i&cYqtq}gcu~9a^(S*fqzThoJ}XGQeK0FfjZ+P`&}-A@25~c=8mf$dRATr*NHp^S
zy`=K?`C(Xgj?x1tQ4)y{V_e7O2`b#iuFJ9xN0%**%@ZP0JB}j4%V#GDmNzfd-1+~R
zpHA@G|DXQC*E?arfIvVXAP^7;2m}NI0s(=5KtLcM5D*9m1O$Gr2%O<J{k7VQlarTL
zmX=P{PVnh~7gv_oF8K5RKbx5O-<hBNTn7xD1q1>D0fB%(Kp-Fx5C{ka1Ofs9fq+0j
zARzEdM&QI$tu{G1HFfG#SpWZ$RS|{{2m}NI0s(=5KtLcM5D*9m1Ox&C0fB(PmxjP-
z{qO(&-v<*f{OIflU)pe?<A6XwARrJB2nYlO0s;YnfIvVXAn+@Wz{l@So|$;@rI}Yg
zIXC_GE4Qs~Uo+|+=k#x-yoS<<mp9ILI1mq`2gl!q@Iy|R!?;vY{lJR@gO1@;c@OF(
zRkv^|@C1YfJYB+o;24ekfq3DDf}O%Vs)$;kKIlS8q*DVWfKWkrZV^uE-_)HtbSfO9
z*N{P&t{VK|L3NkA8;Ozr84xn043>dJH6e|WL2`@4?r1*@L77PwVCadI@T)Y-bXOQr
zplWioPwserCbR^QHxxYP4%5T)14R$A2)6-aB-ZXq$BS?Nd-t#Y6>AV&7CkWE<hXl1
zHW`F9@EI-YZg=_erPT%g_}}vS$KT>_9lmsK=KS|N)3;u^1vyL-Y5v6FuF0+oRSfTX
z?%fTDQ#y{=LHLlM!6}fJ<NxqDaHt-B8ZNbkapj84*fFy}Mj%8xhzeOzY@k{aG)(%?
z0wHWpqM$a+6bl<y-=zl#3vwZ>f#IU!T7tg{QYCfGcDp92L&Bn<?bFN#YABG(<8D{_
zsAvHk5do@7A>$J6qI-I8M8`9(P+<xZMh=>aU@#Ox9&iZ9>I{Dc!lFmvFqE7DSX)>I
z%4Pri{~u4x{PWC@f5qJ~OfMi15C{ka1Ofs9fq+0jARrJB2nYlO0s>z_1YVhXyY|%m
zlF8qmx^?Qab^-$b-&aueLF9lyKp-Fx5C{ka1Ofs9fq+0jARrJB2nZa5z=;2Eb$P)5
zw|r@7J)HkP2C#5BAP^7;2m}NI0s(=5KtLcM5D*9m1Ox&CUwH&Z=l{d{|0}P|FoA$T
zKp-Fx5C{ka1Ofs9fq+0jARrJB2nZa5z-aw1pZ~8-{pke%!dE~bAn?mX;L~pH`HA&U
z^Yu^9U$;U{!Z-C!oTTb%W_tM++$0T~=5V?cFpk)sYL^{ln?mi9_2DRK#VJH9o%j*o
zdvVcLu#Tv_t+TGm8?c<nv$=t7L??xcGAKuciKJ*}wru%_Ei5yM)sE$)t|4lH@x=D>
zMRljlRK0{*g%%K*sFa}!L!a#h>A7V59D0+yu&IGbB{OYUXN)S!#;&7WDXbHwYcocU
z;Yf)a%%QEJy>VPIg-McyLMO<}JvdyLC-f$8wm?zS&~U;Gh3{qv)`plynWE9AcPMeV
z4a18c!^yCy-ZPND@DL0wS;|w~b!<69V4zXSkwkEbbf>EtZAW<{)HFG4F3EVGO<Sf>
zB~?^r0^7ZQl$!qe9F^Dva+VHcJ8hU?^iW68!*sxpd*CjrKofbJ+Zq+ZFq7`ZP{j!S
zjOrO>kw+JRhvMQ?<cAukQRb>`^j-{Uj;%<6N)0KEgG2i4=-e^#bTi9U#<vj3q=JTN
z(Vs{vv@yK}9w-dlH<tP7=wX>Q_$hocc^ol1`W3^9bOz6m&JxpCb?{hJTWyGDq(NRd
zQFTIZxk4}y?dTM8A2+#*Ur5ucVjz+}k%2LDUW&|2v1x<>XdZ0xGI8Q@AD$zyGEB08
zy3%=!6K*4V&cr@MA&~kcssZazpXuaf*3IHv<`$VQb`HJ`z=d2$ICQ+kT_&s>ZD?}R
z^Mw-em9E>eP=#r<)3|{Kz>Ws}D=IFq6=o^KK&F5&$eD}4i<nM!IDwGa)}@=g8)va|
zCQM6Yw!j$EpErs5%5ITzFW%#FX6QD<1ba4f1W(Qcg}cWHtB)I|YzdXpxJe-X9-4`q
zB`|X%v_#C_X~O9%(Iw&w3YGFjBPL~BT!WrPgHB8)5l1DG<Rx@ULLAi4U3}I=xS&l(
zghQyh;9W!M7T?iNnb9gWVp)|^JK9abnVtm<K@|A?c#X_<N1lhscxL2eZQHI$i8*wf
zC!%HVu^S-DATjUvG=xh<EObh_F>V;?U1wHKF*c-qGZwdWCeewr3{EN$#FS{W&x~>f
zr&f~Wqu>^&iLfr=JDRD|nb0hy*5Y7WZ9{~r8!<BA6)W)u(oFEFE7CJ?gQdS}(#r8a
z1WCYv?TUDaHQ)~Dh4@hEvS*-&a-fI<cu4z@NHta8mKDpCl^HtO@$kZS7JOd=ACmB=
zgboZSL=3DGIjUd^w^iTUa~Jz{o#ckR5Mj^w(ja_CP){vBQyLK{52X?@uVKina*1Fp
zO8<hn#QEnSnMgn2<O1ijB^8GQ6Be<L%qybaBlAj?Hx6bD<*2xhN;V^l&SMzX`l^K?
z9ZDz1=MX31cm^S_rB$#{EmI6q$UJd~d~$38!EXzfsRtRPo9G4!W0X65-Z+n~KshGS
z!etO~K@XGoBO$ZUF+KwD0$r6r28n~}K~xT|$EOWv4`STMWeg%VE<y@bMbGG6VMlWr
z<MXA9+*@}hZZxl2F%)twmv5ZI#%Y7V71x>FQ<H_O5Dw&uDjE(mg-j9zI{2pGo}yKs
zCdN{P6e_!tAe>@8S9(abgjN?6pOzjZ7__xZG{jUN3_4>G^+0~`mBV;?Xh{J?A1*ye
zl!BU1LN;Yr6|h7>N2UljoXZlJPL&C&08Zp9j?Nk`V|Pj3q71Q{L9TEK0u#d_uw~zm
zR4}bUYLJHqiQzm#>m;{ArDqn3(iLXXneDoILbCrbFXS=wfuo$zE>kzSFcJEqahMsZ
zsPFQEFS=Z;mAo`c4a0&LwL4#bGB-q;Fumoog4EjwvjWvP)iASaHhpdoH}k2X$_Pj$
zh7W{9Gat}PDsP`3hB0)M9zcnbNPHOMIxbI8;X)zk>K4J#Ws3oqqbo?q^Mr`hj-!b1
z;w<^I6NFp;PyWjU|H4;5;8zWSzxb_5Sy7kke_4Bvayz5m$2YFB;O$X4Kg8LGtF?J(
zPN@id1u4;+U`z<0ta6#XE{Q-@s}2`FB(AX(gCn${lX{)XR93&NM5RKdl!_USR}wS`
zw4|4qZ0!r>j?E}`TGhImU?bJKwDap_SK3I#aA}x`mI^m1GHJEEKDOj;$%@>qv}N5%
zAze0H?un|(yH2NMURgm>ujabN4gt|S?$oJOo7Cb)mLxuIkyZ6BS^9`NR%YW@`4s04
z61hU*kjKRH14Zi|D+QCVVZib=%5={a|8XiyCLgULRzi*gc8H;)poJsVMOW4WQS8cJ
zSDpY#!`0dpMH#g_g$x+_bsIT{`H3W+BDZ5QQhUmLdu~gC$|GTI*kg~u2ji*;YFQf*
zcSU*uV{G>$Wj#liJ+Ty_<n`)-g|!p=wXbN%vJRoL%$T{1EsGM_9KZy|*>|reto>Q+
z%e<tBFP*-HP`8?%D?YVi$=#xs!7j%5X75O8MXrsTta?}ivRHMHBmzGsF-r9mL9V9q
zGcoFFnPG$RWB+`$EcD8-vcRbd*t(6AD`J!->+1M1n=XUVMhks6RhglKgABzQs}Zx|
zBrd_)y(ya&ew~7Fs#+XXhS8q)3sI5Fb}=}rgl1wJ6ewOa=U4bbVjUZ<G^<wE7%Tl3
zgM9>qj0|&xW0-ZIGbi>acJZ}&@lbI+hdX73L19~xQzhlHhhUNzI~OrYqG+S=KITYs
zQAC<kNpx}+OtKeH?Rhx0jChV^V?x`ET`!$c9AMOSdPQ!h`#kX_DrL+bVFiO@tH)Q`
zE))PAi_v*jCkeKIz2+TjF-dH!Wl|B%ZF6DiF2pn~do@gyA)9C(t8r^t&6oui2`H8s
zP-IY>r!4N-@o5j%`oK^o>=oRQ?Fr||VyI9)!~cxS&=*TiV3B>2v{i8tb4`FBu53q@
zE0F}$#N*tg=@Pl5prl3uF}H2zY|i)4hXt8UEMke2iGKS~dd}k(+jzdruC{_?Q^_+S
zV^?gsITw_zF7|R{M^b5OMFOuhZ?L<RJW<KW4y7xhs2SN|TvTsCN{tR-k{+$+sH<%c
zya6RE`m&`(kVfMTBc&Tf8b;zb7iCV35;AMzYh47AC@T>O8D&T2T3JWq@;pv2<>%s2
zc?4eX!Nx4mKJMvV3i_6z?>&@-nKHiGLtRD8Zdsi;%N`w<A}ZXHJsLLPj3FhZw&dk5
zp~;X|@EnGG*uv5ozb(bJ%V6S>tjQlL1LL)lUY&Nj1i)RWvelgwkH$KDj+3@*24Os1
z=8cuo*vh_>Tt_-dh%M5HX_s87q*-3~65+<&t`ZB=0TM|qF@lg6EtUA=_+ctD&X~Ad
zaOOo05%tJMBzt&Tckn^BPt`83cO{6+UWrVoMbt-rC&&;40gE>-zlf`i5{%iyn`Lj5
z$+vNMAd<Nb^9!T6^fH(R_;yE77)(H-udFI$1c`fvW)Do}2q!wbg|Zcld={P5O?v?M
zaI#3%l5JGAYi*Y}Acb}hl5*;Thr1Essb$z=>|voK9d^9rdCOCnm(#UFjEgDJ?O_#J
zdxltm2Jp&(?qVk8Y?K~(+RtK`Ukt*@1l~;mR(7yN(~@+F7b3OT5L>9j$<hfo=uy;x
z0my6%{FR7@k~3Lhxk^Nktnz@tuDlRLIA=AYtW=l17N~h_WKJT6+^Nz|PCzq0>3ALO
zS`3ok74XPoHt}>u(m{2gl$EjE8XHgRw93g`=Z(y~N;wN+5iaGph>7vaBqek(9T^{+
zMhW-|GxwfC!VwUhvHSdk9SswZ#60O=QVuIB=1nAxJA<qv2(wX2EXD%l_Z4oF#l$(S
zWXjIyBAdcDPh;|sAvO#Wkt}c}6I~PgV)L=}m@-SK@q2D0mx@4_0EDF_c2^VPWTTr>
zagdYTs7wvqT<wD5a1=HzrLJ=LC3rA1pa*7=hzl`<O*3pMk<C(~49V%CFz;8!j;Xtl
z(;;I3Oe@h5to%&79C-2|B~fF@B!}TjGN+4Q5?)N^-G!6{;-U$WpP%F^aURKn5|xI@
zNiGqb7uC1WQ%>n*2msRmAUR<&^X|d`E9p(3cRSk^;>@zne3&$^u%pPeU?ZP=;T_i_
zQ%4cbE4_-CzPBYYl7#q%&|FFBL4a$?%)EB9U81a5oqH11c}??Bfiw6dCb!tY*1+80
z*A7zR44do{0LFTDm`Tqr(n`Z!av4aG;~q9?%5Tp=*k;55H>3;vJ!4uDg%{O3IIVOk
z296BqNk?T*q6|R9DY=7v16@c3i-lbQcxL2$)lHmEBA;m_qY2s)L(n?*K_^`--Y2%j
F{{x*{4~hT)

literal 0
HcmV?d00001

diff --git a/web/backend/Database/Database.Seed/Sqlite/PipelineSeedDataReader.cs b/web/backend/Database/Database.Seed/Sqlite/PipelineSeedDataReader.cs
new file mode 100644
index 00000000..8657d121
--- /dev/null
+++ b/web/backend/Database/Database.Seed/Sqlite/PipelineSeedDataReader.cs
@@ -0,0 +1,135 @@
+using System.Text.Json;
+using Database.Seed.PipelineData;
+using Microsoft.Data.Sqlite;
+
+namespace Database.Seed.Sqlite;
+
+public sealed class PipelineSeedDataReader
+{
+    private readonly string _connectionString;
+
+    public PipelineSeedDataReader(string connectionString)
+    {
+        _connectionString = connectionString;
+    }
+
+    public IReadOnlyList<BreweryRecord> ReadBreweryRecords()
+    {
+        using SqliteConnection connection = new(_connectionString);
+        connection.Open();
+
+        IReadOnlyDictionary<long, City> cities = ReadCities(connection);
+
+        const string sql = """
+            SELECT b.name_en, b.description_en, b.name_local, b.description_local,
+                   ba.city_id, ba.postal_code
+            FROM breweries b
+            JOIN brewery_addresses ba ON ba.brewery_id = b.id;
+            """;
+
+        using SqliteCommand command = new(sql, connection);
+        using SqliteDataReader reader = command.ExecuteReader();
+
+        List<BreweryRecord> records = [];
+        while (reader.Read())
+            records.Add(
+                new BreweryRecord
+                {
+                    Brewery = new BreweryResult
+                    {
+                        NameEn = reader.GetString(0),
+                        DescriptionEn = reader.GetString(1),
+                        NameLocal = reader.GetString(2),
+                        DescriptionLocal = reader.GetString(3),
+                    },
+                    Address = new BreweryAddress
+                    {
+                        City = cities[reader.GetInt64(4)],
+                        PostalCode = reader.GetString(5),
+                    },
+                }
+            );
+
+        return records;
+    }
+
+    public IReadOnlyList<UserRecord> ReadUserRecords()
+    {
+        using SqliteConnection connection = new(_connectionString);
+        connection.Open();
+
+        IReadOnlyDictionary<long, City> cities = ReadCities(connection);
+
+        const string sql = """
+            SELECT u.first_name, u.last_name, u.gender, u.username, u.bio,
+                   u.activity_weight, u.email, u.date_of_birth,
+                   ua.city_id, ua.postal_code
+            FROM users u
+            JOIN user_addresses ua ON ua.user_id = u.id;
+            """;
+
+        using SqliteCommand command = new(sql, connection);
+        using SqliteDataReader reader = command.ExecuteReader();
+
+        List<UserRecord> records = [];
+        while (reader.Read())
+            records.Add(
+                new UserRecord
+                {
+                    User = new UserResult
+                    {
+                        FirstName = reader.GetString(0),
+                        LastName = reader.GetString(1),
+                        Gender = reader.GetString(2),
+                        Username = reader.GetString(3),
+                        Bio = reader.GetString(4),
+                        ActivityWeight = (float)reader.GetDouble(5),
+                    },
+                    Email = reader.GetString(6),
+                    DateOfBirth = reader.GetString(7),
+                    Address = new UserAddress
+                    {
+                        City = cities[reader.GetInt64(8)],
+                        PostalCode = reader.GetString(9),
+                    },
+                }
+            );
+
+        return records;
+    }
+
+    private static IReadOnlyDictionary<long, City> ReadCities(SqliteConnection connection)
+    {
+        const string sql = """
+            SELECT id, city, state_province, iso3166_2, country, iso3166_1,
+                   local_languages_json, postal_code_country_format_regex,
+                   postal_code_city_regex_json
+            FROM cities;
+            """;
+
+        using SqliteCommand command = new(sql, connection);
+        using SqliteDataReader reader = command.ExecuteReader();
+
+        Dictionary<long, City> cities = [];
+        while (reader.Read())
+            cities[reader.GetInt64(0)] = new City
+            {
+                CityName = reader.GetString(1),
+                StateProvince = reader.GetString(2),
+                Iso31662 = reader.GetString(3),
+                Country = reader.GetString(4),
+                Iso31661 = reader.GetString(5),
+                LocalLanguages = DeserializeStringArray(reader.GetString(6)),
+                PostalCode = new PostalCodeSpec
+                {
+                    CountryFormatRegex = reader.GetString(7),
+                    CityRegexes = DeserializeStringArray(reader.GetString(8)),
+                },
+            };
+
+        return cities;
+    }
+
+    private static IReadOnlyList<string> DeserializeStringArray(string json) =>
+        JsonSerializer.Deserialize<List<string>>(json) ?? [];
+}