transition to python backend

.github/workflows/ci.yml

@@ -1,4 +1,4 @@
-name: CI   
+name: CI
 
 on: [push, pull_request]
 
@@ -6,22 +6,82 @@ jobs:
   build-and-test:
     runs-on: ubuntu-latest
 
+    # start postgres & minio for the Python backend
+    services:
+      postgres:
+        image: postgres:16
+        env:
+          POSTGRES_USER: promptaid
+          POSTGRES_PASSWORD: promptaid
+          POSTGRES_DB: promptaid
+        ports:
+          - 5433:5432
+        options: >-
+          --health-cmd "pg_isready -U promptaid -d promptaid"
+          --health-interval 10s
+          --health-timeout 5s
+          --health-retries 5
+
+      minio:
+        image: minio/minio
+        env:
+          MINIO_ROOT_USER: promptaid
+          MINIO_ROOT_PASSWORD: promptaid
+        ports:
+          - 9000:9000
+        options: >-
+          --health-cmd "curl -f http://localhost:9000/minio/health/live || exit 1"
+          --health-interval 10s
+          --health-timeout 5s
+          --health-retries 5
+
     steps:
-      - uses: actions/checkout@v4
+      - name: Check out code
+        uses: actions/checkout@v4
 
       # --- Front-end: React ---
-      - uses: actions/setup-node@v4
-        with: { node-version: 20 }
+      - name: Setup Node.js
+        uses: actions/setup-node@v4
+        with:
+          node-version: "20"
 
-      - run: |
+      - name: Install & build front-end
+        run: |
           cd frontend
-          npm ci            # 3) install deps
-          npm run build     # 4) make sure it builds
+          npm ci
+          npm run build
+        env:
+          CI: true
+
+      # --- Back-end: Python/FastAPI ---
+      - name: Setup Python
+        uses: actions/setup-python@v4
+        with:
+          python-version: "3.11"
+
+      - name: Install Python dependencies
+        run: |
+          cd py_backend
+          python -m venv .venv
+          source .venv/bin/activate
+          pip install --upgrade pip
+          pip install -r requirements.txt
+
+      - name: Run database migrations
+        env:
+          DATABASE_URL: postgresql://promptaid:promptaid@localhost:5433/promptaid
+          S3_ENDPOINT:    http://localhost:9000
+          S3_ACCESS_KEY:  promptaid
+          S3_SECRET_KEY:  promptaid
+          S3_BUCKET:      promptaid
+        run: |
+          cd py_backend
+          source .venv/bin/activate
+          alembic upgrade head
 
-      # --- Back-end: Go ---
-      - uses: actions/setup-go@v5
-        with: { go-version: 1.22 }
+      - name: Run back-end tests
+        run: |
+          cd py_backend
+          source .venv/bin/activate
+          pytest
 
-      - run: |
-          cd backend
-          go test ./...     # 6) run Go tests

README.md

@@ -2,4 +2,4 @@
 UCL IXN summer project - IFRC
 
 System architecture
-React => Go/Python => postgreSQL => fly.io
+React => Python => postgreSQL => fly.io

backend/go.mod

@@ -1,47 +0,0 @@
-module github.com/SCGR-1/promptaid-backend
-
-go 1.24.5
-
-require (
-	github.com/gin-gonic/gin v1.10.1
-	github.com/google/uuid v1.6.0
-	github.com/lib/pq v1.10.9
-	github.com/minio/minio-go/v7 v7.0.95
-)
-
-require (
-	github.com/bytedance/sonic v1.11.6 // indirect
-	github.com/bytedance/sonic/loader v0.1.1 // indirect
-	github.com/cloudwego/base64x v0.1.4 // indirect
-	github.com/cloudwego/iasm v0.2.0 // indirect
-	github.com/dustin/go-humanize v1.0.1 // indirect
-	github.com/gabriel-vasile/mimetype v1.4.3 // indirect
-	github.com/gin-contrib/sse v0.1.0 // indirect
-	github.com/go-ini/ini v1.67.0 // indirect
-	github.com/go-playground/locales v0.14.1 // indirect
-	github.com/go-playground/universal-translator v0.18.1 // indirect
-	github.com/go-playground/validator/v10 v10.20.0 // indirect
-	github.com/goccy/go-json v0.10.5 // indirect
-	github.com/json-iterator/go v1.1.12 // indirect
-	github.com/klauspost/compress v1.18.0 // indirect
-	github.com/klauspost/cpuid/v2 v2.2.11 // indirect
-	github.com/leodido/go-urn v1.4.0 // indirect
-	github.com/mattn/go-isatty v0.0.20 // indirect
-	github.com/minio/crc64nvme v1.0.2 // indirect
-	github.com/minio/md5-simd v1.1.2 // indirect
-	github.com/modern-go/concurrent v0.0.0-20180306012644-bacd9c7ef1dd // indirect
-	github.com/modern-go/reflect2 v1.0.2 // indirect
-	github.com/pelletier/go-toml/v2 v2.2.2 // indirect
-	github.com/philhofer/fwd v1.2.0 // indirect
-	github.com/rs/xid v1.6.0 // indirect
-	github.com/tinylib/msgp v1.3.0 // indirect
-	github.com/twitchyliquid64/golang-asm v0.15.1 // indirect
-	github.com/ugorji/go/codec v1.2.12 // indirect
-	golang.org/x/arch v0.8.0 // indirect
-	golang.org/x/crypto v0.39.0 // indirect
-	golang.org/x/net v0.41.0 // indirect
-	golang.org/x/sys v0.33.0 // indirect
-	golang.org/x/text v0.26.0 // indirect
-	google.golang.org/protobuf v1.34.1 // indirect
-	gopkg.in/yaml.v3 v3.0.1 // indirect
-)

backend/go.sum

@@ -1,111 +0,0 @@
-github.com/bytedance/sonic v1.11.6 h1:oUp34TzMlL+OY1OUWxHqsdkgC/Zfc85zGqw9siXjrc0=
-github.com/bytedance/sonic v1.11.6/go.mod h1:LysEHSvpvDySVdC2f87zGWf6CIKJcAvqab1ZaiQtds4=
-github.com/bytedance/sonic/loader v0.1.1 h1:c+e5Pt1k/cy5wMveRDyk2X4B9hF4g7an8N3zCYjJFNM=
-github.com/bytedance/sonic/loader v0.1.1/go.mod h1:ncP89zfokxS5LZrJxl5z0UJcsk4M4yY2JpfqGeCtNLU=
-github.com/cloudwego/base64x v0.1.4 h1:jwCgWpFanWmN8xoIUHa2rtzmkd5J2plF/dnLS6Xd/0Y=
-github.com/cloudwego/base64x v0.1.4/go.mod h1:0zlkT4Wn5C6NdauXdJRhSKRlJvmclQ1hhJgA0rcu/8w=
-github.com/cloudwego/iasm v0.2.0 h1:1KNIy1I1H9hNNFEEH3DVnI4UujN+1zjpuk6gwHLTssg=
-github.com/cloudwego/iasm v0.2.0/go.mod h1:8rXZaNYT2n95jn+zTI1sDr+IgcD2GVs0nlbbQPiEFhY=
-github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
-github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c=
-github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
-github.com/dustin/go-humanize v1.0.1 h1:GzkhY7T5VNhEkwH0PVJgjz+fX1rhBrR7pRT3mDkpeCY=
-github.com/dustin/go-humanize v1.0.1/go.mod h1:Mu1zIs6XwVuF/gI1OepvI0qD18qycQx+mFykh5fBlto=
-github.com/gabriel-vasile/mimetype v1.4.3 h1:in2uUcidCuFcDKtdcBxlR0rJ1+fsokWf+uqxgUFjbI0=
-github.com/gabriel-vasile/mimetype v1.4.3/go.mod h1:d8uq/6HKRL6CGdk+aubisF/M5GcPfT7nKyLpA0lbSSk=
-github.com/gin-contrib/sse v0.1.0 h1:Y/yl/+YNO8GZSjAhjMsSuLt29uWRFHdHYUb5lYOV9qE=
-github.com/gin-contrib/sse v0.1.0/go.mod h1:RHrZQHXnP2xjPF+u1gW/2HnVO7nvIa9PG3Gm+fLHvGI=
-github.com/gin-gonic/gin v1.10.1 h1:T0ujvqyCSqRopADpgPgiTT63DUQVSfojyME59Ei63pQ=
-github.com/gin-gonic/gin v1.10.1/go.mod h1:4PMNQiOhvDRa013RKVbsiNwoyezlm2rm0uX/T7kzp5Y=
-github.com/go-ini/ini v1.67.0 h1:z6ZrTEZqSWOTyH2FlglNbNgARyHG8oLW9gMELqKr06A=
-github.com/go-ini/ini v1.67.0/go.mod h1:ByCAeIL28uOIIG0E3PJtZPDL8WnHpFKFOtgjp+3Ies8=
-github.com/go-playground/assert/v2 v2.2.0 h1:JvknZsQTYeFEAhQwI4qEt9cyV5ONwRHC+lYKSsYSR8s=
-github.com/go-playground/assert/v2 v2.2.0/go.mod h1:VDjEfimB/XKnb+ZQfWdccd7VUvScMdVu0Titje2rxJ4=
-github.com/go-playground/locales v0.14.1 h1:EWaQ/wswjilfKLTECiXz7Rh+3BjFhfDFKv/oXslEjJA=
-github.com/go-playground/locales v0.14.1/go.mod h1:hxrqLVvrK65+Rwrd5Fc6F2O76J/NuW9t0sjnWqG1slY=
-github.com/go-playground/universal-translator v0.18.1 h1:Bcnm0ZwsGyWbCzImXv+pAJnYK9S473LQFuzCbDbfSFY=
-github.com/go-playground/universal-translator v0.18.1/go.mod h1:xekY+UJKNuX9WP91TpwSH2VMlDf28Uj24BCp08ZFTUY=
-github.com/go-playground/validator/v10 v10.20.0 h1:K9ISHbSaI0lyB2eWMPJo+kOS/FBExVwjEviJTixqxL8=
-github.com/go-playground/validator/v10 v10.20.0/go.mod h1:dbuPbCMFw/DrkbEynArYaCwl3amGuJotoKCe95atGMM=
-github.com/goccy/go-json v0.10.5 h1:Fq85nIqj+gXn/S5ahsiTlK3TmC85qgirsdTP/+DeaC4=
-github.com/goccy/go-json v0.10.5/go.mod h1:oq7eo15ShAhp70Anwd5lgX2pLfOS3QCiwU/PULtXL6M=
-github.com/google/go-cmp v0.5.5 h1:Khx7svrCpmxxtHBq5j2mp/xVjsi8hQMfNLvJFAlrGgU=
-github.com/google/go-cmp v0.5.5/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE=
-github.com/google/gofuzz v1.0.0/go.mod h1:dBl0BpW6vV/+mYPU4Po3pmUjxk6FQPldtuIdl/M65Eg=
-github.com/google/uuid v1.6.0 h1:NIvaJDMOsjHA8n1jAhLSgzrAzy1Hgr+hNrb57e+94F0=
-github.com/google/uuid v1.6.0/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo=
-github.com/json-iterator/go v1.1.12 h1:PV8peI4a0ysnczrg+LtxykD8LfKY9ML6u2jnxaEnrnM=
-github.com/json-iterator/go v1.1.12/go.mod h1:e30LSqwooZae/UwlEbR2852Gd8hjQvJoHmT4TnhNGBo=
-github.com/klauspost/compress v1.18.0 h1:c/Cqfb0r+Yi+JtIEq73FWXVkRonBlf0CRNYc8Zttxdo=
-github.com/klauspost/compress v1.18.0/go.mod h1:2Pp+KzxcywXVXMr50+X0Q/Lsb43OQHYWRCY2AiWywWQ=
-github.com/klauspost/cpuid/v2 v2.0.1/go.mod h1:FInQzS24/EEf25PyTYn52gqo7WaD8xa0213Md/qVLRg=
-github.com/klauspost/cpuid/v2 v2.0.9/go.mod h1:FInQzS24/EEf25PyTYn52gqo7WaD8xa0213Md/qVLRg=
-github.com/klauspost/cpuid/v2 v2.2.11 h1:0OwqZRYI2rFrjS4kvkDnqJkKHdHaRnCm68/DY4OxRzU=
-github.com/klauspost/cpuid/v2 v2.2.11/go.mod h1:hqwkgyIinND0mEev00jJYCxPNVRVXFQeu1XKlok6oO0=
-github.com/knz/go-libedit v1.10.1/go.mod h1:MZTVkCWyz0oBc7JOWP3wNAzd002ZbM/5hgShxwh4x8M=
-github.com/leodido/go-urn v1.4.0 h1:WT9HwE9SGECu3lg4d/dIA+jxlljEa1/ffXKmRjqdmIQ=
-github.com/leodido/go-urn v1.4.0/go.mod h1:bvxc+MVxLKB4z00jd1z+Dvzr47oO32F/QSNjSBOlFxI=
-github.com/lib/pq v1.10.9 h1:YXG7RB+JIjhP29X+OtkiDnYaXQwpS4JEWq7dtCCRUEw=
-github.com/lib/pq v1.10.9/go.mod h1:AlVN5x4E4T544tWzH6hKfbfQvm3HdbOxrmggDNAPY9o=
-github.com/mattn/go-isatty v0.0.20 h1:xfD0iDuEKnDkl03q4limB+vH+GxLEtL/jb4xVJSWWEY=
-github.com/mattn/go-isatty v0.0.20/go.mod h1:W+V8PltTTMOvKvAeJH7IuucS94S2C6jfK/D7dTCTo3Y=
-github.com/minio/crc64nvme v1.0.2 h1:6uO1UxGAD+kwqWWp7mBFsi5gAse66C4NXO8cmcVculg=
-github.com/minio/crc64nvme v1.0.2/go.mod h1:eVfm2fAzLlxMdUGc0EEBGSMmPwmXD5XiNRpnu9J3bvg=
-github.com/minio/md5-simd v1.1.2 h1:Gdi1DZK69+ZVMoNHRXJyNcxrMA4dSxoYHZSQbirFg34=
-github.com/minio/md5-simd v1.1.2/go.mod h1:MzdKDxYpY2BT9XQFocsiZf/NKVtR7nkE4RoEpN+20RM=
-github.com/minio/minio-go/v7 v7.0.95 h1:ywOUPg+PebTMTzn9VDsoFJy32ZuARN9zhB+K3IYEvYU=
-github.com/minio/minio-go/v7 v7.0.95/go.mod h1:wOOX3uxS334vImCNRVyIDdXX9OsXDm89ToynKgqUKlo=
-github.com/modern-go/concurrent v0.0.0-20180228061459-e0a39a4cb421/go.mod h1:6dJC0mAP4ikYIbvyc7fijjWJddQyLn8Ig3JB5CqoB9Q=
-github.com/modern-go/concurrent v0.0.0-20180306012644-bacd9c7ef1dd h1:TRLaZ9cD/w8PVh93nsPXa1VrQ6jlwL5oN8l14QlcNfg=
-github.com/modern-go/concurrent v0.0.0-20180306012644-bacd9c7ef1dd/go.mod h1:6dJC0mAP4ikYIbvyc7fijjWJddQyLn8Ig3JB5CqoB9Q=
-github.com/modern-go/reflect2 v1.0.2 h1:xBagoLtFs94CBntxluKeaWgTMpvLxC4ur3nMaC9Gz0M=
-github.com/modern-go/reflect2 v1.0.2/go.mod h1:yWuevngMOJpCy52FWWMvUC8ws7m/LJsjYzDa0/r8luk=
-github.com/pelletier/go-toml/v2 v2.2.2 h1:aYUidT7k73Pcl9nb2gScu7NSrKCSHIDE89b3+6Wq+LM=
-github.com/pelletier/go-toml/v2 v2.2.2/go.mod h1:1t835xjRzz80PqgE6HHgN2JOsmgYu/h4qDAS4n929Rs=
-github.com/philhofer/fwd v1.2.0 h1:e6DnBTl7vGY+Gz322/ASL4Gyp1FspeMvx1RNDoToZuM=
-github.com/philhofer/fwd v1.2.0/go.mod h1:RqIHx9QI14HlwKwm98g9Re5prTQ6LdeRQn+gXJFxsJM=
-github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=
-github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
-github.com/rs/xid v1.6.0 h1:fV591PaemRlL6JfRxGDEPl69wICngIQ3shQtzfy2gxU=
-github.com/rs/xid v1.6.0/go.mod h1:7XoLgs4eV+QndskICGsho+ADou8ySMSjJKDIan90Nz0=
-github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=
-github.com/stretchr/objx v0.4.0/go.mod h1:YvHI0jy2hoMjB+UWwv71VJQ9isScKT/TqJzVSSt89Yw=
-github.com/stretchr/objx v0.5.0/go.mod h1:Yh+to48EsGEfYuaHDzXPcE3xhTkx73EhmCGUpEOglKo=
-github.com/stretchr/objx v0.5.2/go.mod h1:FRsXN1f5AsAjCGJKqEizvkpNtU+EGNCLh3NxZ/8L+MA=
-github.com/stretchr/testify v1.3.0/go.mod h1:M5WIy9Dh21IEIfnGCwXGc5bZfKNJtfHm1UVUgZn+9EI=
-github.com/stretchr/testify v1.7.0/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg=
-github.com/stretchr/testify v1.7.1/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg=
-github.com/stretchr/testify v1.8.0/go.mod h1:yNjHg4UonilssWZ8iaSj1OCr/vHnekPRkoO+kdMU+MU=
-github.com/stretchr/testify v1.8.1/go.mod h1:w2LPCIKwWwSfY2zedu0+kehJoqGctiVI29o6fzry7u4=
-github.com/stretchr/testify v1.8.4/go.mod h1:sz/lmYIOXD/1dqDmKjjqLyZ2RngseejIcXlSw2iwfAo=
-github.com/stretchr/testify v1.9.0 h1:HtqpIVDClZ4nwg75+f6Lvsy/wHu+3BoSGCbBAcpTsTg=
-github.com/stretchr/testify v1.9.0/go.mod h1:r2ic/lqez/lEtzL7wO/rwa5dbSLXVDPFyf8C91i36aY=
-github.com/tinylib/msgp v1.3.0 h1:ULuf7GPooDaIlbyvgAxBV/FI7ynli6LZ1/nVUNu+0ww=
-github.com/tinylib/msgp v1.3.0/go.mod h1:ykjzy2wzgrlvpDCRc4LA8UXy6D8bzMSuAF3WD57Gok0=
-github.com/twitchyliquid64/golang-asm v0.15.1 h1:SU5vSMR7hnwNxj24w34ZyCi/FmDZTkS4MhqMhdFk5YI=
-github.com/twitchyliquid64/golang-asm v0.15.1/go.mod h1:a1lVb/DtPvCB8fslRZhAngC2+aY1QWCk3Cedj/Gdt08=
-github.com/ugorji/go/codec v1.2.12 h1:9LC83zGrHhuUA9l16C9AHXAqEV/2wBQ4nkvumAE65EE=
-github.com/ugorji/go/codec v1.2.12/go.mod h1:UNopzCgEMSXjBc6AOMqYvWC1ktqTAfzJZUZgYf6w6lg=
-golang.org/x/arch v0.0.0-20210923205945-b76863e36670/go.mod h1:5om86z9Hs0C8fWVUuoMHwpExlXzs5Tkyp9hOrfG7pp8=
-golang.org/x/arch v0.8.0 h1:3wRIsP3pM4yUptoR96otTUOXI367OS0+c9eeRi9doIc=
-golang.org/x/arch v0.8.0/go.mod h1:FEVrYAQjsQXMVJ1nsMoVVXPZg6p2JE2mx8psSWTDQys=
-golang.org/x/crypto v0.39.0 h1:SHs+kF4LP+f+p14esP5jAoDpHU8Gu/v9lFRK6IT5imM=
-golang.org/x/crypto v0.39.0/go.mod h1:L+Xg3Wf6HoL4Bn4238Z6ft6KfEpN0tJGo53AAPC632U=
-golang.org/x/net v0.41.0 h1:vBTly1HeNPEn3wtREYfy4GZ/NECgw2Cnl+nK6Nz3uvw=
-golang.org/x/net v0.41.0/go.mod h1:B/K4NNqkfmg07DQYrbwvSluqCJOOXwUjeb/5lOisjbA=
-golang.org/x/sys v0.6.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
-golang.org/x/sys v0.33.0 h1:q3i8TbbEz+JRD9ywIRlyRAQbM0qF7hu24q3teo2hbuw=
-golang.org/x/sys v0.33.0/go.mod h1:BJP2sWEmIv4KK5OTEluFJCKSidICx8ciO85XgH3Ak8k=
-golang.org/x/text v0.26.0 h1:P42AVeLghgTYr4+xUnTRKDMqpar+PtX7KWuNQL21L8M=
-golang.org/x/text v0.26.0/go.mod h1:QK15LZJUUQVJxhz7wXgxSy/CJaTFjd0G+YLonydOVQA=
-golang.org/x/xerrors v0.0.0-20191204190536-9bdfabe68543 h1:E7g+9GITq07hpfrRu66IVDexMakfv52eLZ2CXBWiKr4=
-golang.org/x/xerrors v0.0.0-20191204190536-9bdfabe68543/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
-google.golang.org/protobuf v1.34.1 h1:9ddQBjfCyZPOHPUiPxpYESBLc+T8P3E+Vo4IbKZgFWg=
-google.golang.org/protobuf v1.34.1/go.mod h1:c6P6GXX6sHbq/GpV6MGZEdwhWPcYBgnhAHhKbcUYpos=
-gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405 h1:yhCVgyC4o1eVCa2tZl7eS0r+SDo693bJlVdllGtEeKM=
-gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
-gopkg.in/yaml.v3 v3.0.0-20200313102051-9f266ea9e77c/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
-gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA=
-gopkg.in/yaml.v3 v3.0.1/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
-nullprogram.com/x/optparse v1.0.0/go.mod h1:KdyPE+Igbe0jQUrVfMqDMeJQIJZEuyV7pjYmp6pbG50=
-rsc.io/pdf v0.1.1/go.mod h1:n8OzWcQ6Sp37PL01nO98y4iUCRdTGarVfzxY20ICaU4=

backend/handlers/caption.go

@@ -1,65 +0,0 @@
-package handlers
-
-import (
-	"time"
-    "net/http"
-
-    "github.com/gin-gonic/gin"
-    "github.com/google/uuid"
-)
-
-// POST /api/maps/:id/caption
-func (d *UploadDeps) CreateCaption(c *gin.Context) {
-    ctx   := c.Request.Context()
-    mapID := c.Param("id")
-
-    // 1) look up the map’s file key
-    var key string
-    if err := d.DB.QueryRowContext(ctx,
-        `SELECT file_key FROM maps WHERE map_id = $1`, mapID).Scan(&key); err != nil {
-        c.JSON(http.StatusNotFound, gin.H{"error": "map not found"})
-        return
-    }
-
-    // 2) generate placeholder caption
-    text, model := d.Cap.Generate(ctx, key)
-
-    // 3) insert caption row
-    capID := uuid.New()
-    if _, err := d.DB.ExecContext(ctx, `
-        INSERT INTO captions (cap_id, map_id, generated, model, raw_json, created_at)
-        VALUES ($1,$2,$3,$4,$5,NOW())`,
-        capID, mapID, text, model, []byte("{}")); err != nil {
-        c.JSON(http.StatusInternalServerError, gin.H{"error": "db insert failed"})
-        return
-    }
-
-    // 4) respond to the front‑end
-    c.JSON(http.StatusOK, gin.H{
-        "captionId": capID,
-        "generated": text,
-    })
-}
-
-func (d *UploadDeps) GetCaption(c *gin.Context) {
-	ctx := c.Request.Context()
-	capID := c.Param("id")
-
-	var key, text string
-	if err := d.DB.QueryRowContext(ctx, `
-		SELECT m.file_key, c.generated
-			FROM captions c
-			JOIN maps m ON c.map_id = m.id
-			WHERE c.id = $1`, capID).Scan(&key, &text); err != nil {
-		c.JSON(http.StatusNotFound, gin.H{"error": "caption not found"})
-		return
-	}
-
-	// turn object key into a 24‑hour presigned URL
-	url, _ := d.Storage.Link(ctx, key, 24*time.Hour)
-
-	c.JSON(http.StatusOK, gin.H{
-		"imageUrl":  url,
-		"generated": text,
-	})
-}

backend/handlers/metadata.go

@@ -1,26 +0,0 @@
-package handlers
-
-import "github.com/gin-gonic/gin"
-
-// PUT /api/maps/:id/metadata
-func (d *UploadDeps) UpdateMapMetadata(c *gin.Context) {
-    mapID := c.Param("id")
-    var req struct {
-        Source   string `json:"source"`
-        Region   string `json:"region"`
-        Category string `json:"category"`
-    }
-    if err := c.BindJSON(&req); err != nil {
-        c.JSON(400, gin.H{"error": "invalid json"})
-        return
-    }
-    _, err := d.DB.Exec(`UPDATE maps
-                            SET source=$1, region=$2, category=$3
-                          WHERE id=$4`,
-        req.Source, req.Region, req.Category, mapID)
-    if err != nil {
-        c.JSON(500, gin.H{"error": "db update failed"})
-        return
-    }
-    c.Status(204)
-}

backend/handlers/upload.go

@@ -1,118 +0,0 @@
-package handlers
-
-import (
-    "bytes"
-    "crypto/sha256"
-    "database/sql"
-    "encoding/hex"
-    "io"
-    "log"
-    "net/http"
-    "time"
-
-    "github.com/gin-gonic/gin"
-    "github.com/google/uuid"
-    "github.com/lib/pq"
-    "github.com/SCGR-1/promptaid-backend/internal/storage"
-	"github.com/SCGR-1/promptaid-backend/internal/captioner"
-)
-
-
-// wire this in main.go: r.POST("/maps", deps.UploadMap)
-type UploadDeps struct {
-    DB       *sql.DB
-    Storage  storage.ObjectStore
-    Bucket   string
-    RegionOK map[string]bool
-    Cap      captioner.Captioner
-}
-
-func (d *UploadDeps) UploadMap(c *gin.Context) {
-    // ---- 1. Parse multipart form ----------------------------------------
-    file, fileHdr, err := c.Request.FormFile("file")
-    if err != nil {
-        c.JSON(http.StatusBadRequest, gin.H{"error": "file required"})
-        return
-    }
-    defer file.Close()
-
-    params := struct {
-        Source    string   `form:"source"    binding:"required"`
-        Region    string   `form:"region"    binding:"required"`
-        Category  string   `form:"category"  binding:"required"`
-        Countries []string `form:"countries"` // optional multi‑select
-    }{}
-    if err := c.ShouldBind(&params); err != nil {
-        c.JSON(http.StatusBadRequest, gin.H{"error": err.Error()})
-        return
-    }
-
-    // ---- 2. Validate lookup codes ---------------------------------------
-    if !d.RegionOK[params.Region] {
-        c.JSON(http.StatusBadRequest, gin.H{"error": "invalid region"})
-        return
-    }
-    // repeat for source / category / countries…
-
-    // ---- 3. Read file + hash it ----------------------------------------
-    var buf []byte
-	buf, err = io.ReadAll(file)
-	if err != nil {
-		c.JSON(http.StatusInternalServerError, gin.H{"error": "read failed"})
-		return
-	}
-    sha := sha256.Sum256(buf)
-    shaHex := hex.EncodeToString(sha[:])
-
-    // choose a deterministic object key
-    objKey := "maps/" + time.Now().Format("2006/01/02/") + shaHex + ".png"
-
-    // ---- 4. Upload to object storage -----------------------------------
-	ctx := c.Request.Context()
-	if err := d.Storage.Put(
-		ctx, objKey,
-		bytes.NewReader(buf), int64(len(buf)),
-		fileHdr.Header.Get("Content-Type"),
-	); err != nil {
-		c.JSON(http.StatusInternalServerError, gin.H{"error": "storage failed"})
-		return
-	}
-
-
-    // ---- 5. Insert into maps -------------------------------------------
-    mapID := uuid.New()
-    res, err := d.DB.Exec(`
-        INSERT INTO maps
-          (map_id, file_key, sha256, source, region, category, created_at)
-        VALUES ($1,$2,$3,$4,$5,$6,NOW())`,
-        mapID, objKey, shaHex,
-        params.Source, params.Region, params.Category,
-    )
-    if err != nil {
-        log.Printf("🔴 maps INSERT error: %v", err)
-        c.JSON(http.StatusInternalServerError, gin.H{"error": err.Error()})
-        return
-    }
-    rows, _ := res.RowsAffected()
-    log.Printf("🟢 maps INSERT succeeded, rows affected: %d", rows)
-
-    // ---- 6. Insert any countries ---------------------------------------
-    if len(params.Countries) > 0 {
-        _, err = d.DB.Exec(`
-            INSERT INTO map_countries (map_id, c_code)
-            SELECT $1, UNNEST($2::char(2)[])
-            ON CONFLICT DO NOTHING`,
-            mapID, pq.Array(params.Countries),
-        )
-        if err != nil {
-            c.JSON(http.StatusInternalServerError, gin.H{"error": "country insert failed"})
-            return
-        }
-    }
-
-    // ---- 7. Return success ---------------------------------------------
-    c.JSON(http.StatusOK, gin.H{
-        "mapId": mapID,
-        // front‑end can show a presigned preview if you want
-    })
-}

backend/internal/captioner/stub.go

@@ -1,16 +0,0 @@
-package captioner
-
-import "context"
-
-// A pluggable captioner interface (so you can swap to GPT‑4o later).
-type Captioner interface {
-    Generate(ctx context.Context, objectKey string) (text, model string)
-}
-
-// Minimal stub: always returns the same caption.
-type Stub struct{}
-
-func (Stub) Generate(_ context.Context, _ string) (string, string) {
-    return "🔧 Stub caption: replace me with GPT‑4o", "GPT‑4O"
-}
-

backend/internal/storage/local.go

@@ -1,36 +0,0 @@
-package storage
-
-import (
-	"context"
-	"io"
-	"os"
-	"path/filepath"
-	"time"
-)
-
-type LocalStore struct{ root string }
-
-func NewLocalStore(root string) *LocalStore { return &LocalStore{root: root} }
-
-func (l *LocalStore) Put(_ context.Context, key string, r io.Reader, _ int64, _ string) error {
-	full := filepath.Join(l.root, key)
-	if err := os.MkdirAll(filepath.Dir(full), 0o755); err != nil {
-		return err
-	}
-	f, err := os.Create(full)
-	if err != nil {
-		return err
-	}
-	defer f.Close()
-	_, err = io.Copy(f, r)
-	return err
-}
-
-func (l *LocalStore) Link(_ context.Context, key string, _ time.Duration) (string, error) {
-	// Served by Gin static handler: router.Static("/static", "./uploads")
-	return "/static/" + key, nil
-}
-
-func (l *LocalStore) Root() string {
-	return l.root
-}

backend/internal/storage/s3.go

@@ -1,40 +0,0 @@
-package storage
-
-import (
-	"context"
-	"time"
-	"io"
-
-	"github.com/minio/minio-go/v7"
-	"github.com/minio/minio-go/v7/pkg/credentials"
-)
-
-type S3Store struct {
-	cli    *minio.Client
-	bucket string
-}
-
-func NewS3Store(endpoint, accessKey, secretKey, bucket string, useSSL bool) (*S3Store, error) {
-	cli, err := minio.New(endpoint, &minio.Options{
-		Creds:  credentials.NewStaticV4(accessKey, secretKey, ""),
-		Secure: useSSL,
-	})
-	if err != nil {
-		return nil, err
-	}
-	return &S3Store{cli: cli, bucket: bucket}, nil
-}
-
-func (s *S3Store) Put(ctx context.Context, key string, r io.Reader, size int64, ctype string) error {
-	_, err := s.cli.PutObject(ctx, s.bucket, key, r, size,
-		minio.PutObjectOptions{ContentType: ctype})
-	return err
-}
-
-func (s *S3Store) Link(ctx context.Context, key string, ttl time.Duration) (string, error) {
-	u, err := s.cli.PresignedGetObject(ctx, s.bucket, key, ttl, nil)
-	if err != nil {
-		return "", err
-	}
-	return u.String(), nil
-}

backend/internal/storage/storage.go

@@ -1,16 +0,0 @@
-package storage
-
-import (
-	"context"
-	"time"
-	"io"
-)
-
-// ObjectStore is a minimal interface for saving and later linking to blobs.
-type ObjectStore interface {
-	// Put permanently stores the object under key.
-	Put(ctx context.Context, key string, r io.Reader, size int64, contentType string) error
-
-	// Link returns a URL valid for roughly ttl (ignored by LocalStore).
-	Link(ctx context.Context, key string, ttl time.Duration) (string, error)
-}

backend/main.go

@@ -1,88 +0,0 @@
-package main
-
-import (
-	"database/sql"
-	"log"
-	"os"
-
-	"github.com/gin-gonic/gin"
-	_ "github.com/lib/pq"
-
-	"github.com/SCGR-1/promptaid-backend/internal/storage"
-    "github.com/SCGR-1/promptaid-backend/handlers"
-    "github.com/SCGR-1/promptaid-backend/internal/captioner"
-)
-
-type Config struct {
-    S3Bucket  string
-    UploadDir string
-}
-
-func loadConfig() Config {
-    return Config{
-        S3Bucket:  os.Getenv("S3_BUCKET"),
-        UploadDir: os.Getenv("UPLOAD_DIR"),
-    }
-}
-
-
-func main() {
-
-    // ---- 1. connect DB  ----
-	dsn := os.Getenv("DATABASE_URL")
-    if dsn == "" {
-        dsn = "postgres://promptaid:promptaid@localhost:5432/promptaid?sslmode=disable"
-    }
-    db, err := sql.Open("postgres", dsn)
-    if err != nil {
-        log.Fatal(err)
-    }
-
-
-	// ---- 2. choose storage driver ----
-	var store storage.ObjectStore
-	switch os.Getenv("STORAGE_DRIVER") {
-	case "s3":
-		store, err = storage.NewS3Store(
-			os.Getenv("S3_ENDPOINT"),
-			os.Getenv("S3_KEY"),
-			os.Getenv("S3_SECRET"),
-			os.Getenv("S3_BUCKET"),
-			os.Getenv("S3_SSL") == "true",
-		)
-		if err != nil { log.Fatal(err) }
-	default: // local
-		uploadDir := os.Getenv("UPLOAD_DIR")
-		if uploadDir == "" { uploadDir = "./uploads" }
-		store = storage.NewLocalStore(uploadDir)
-	}
-
-    uploadDeps := handlers.UploadDeps{
-        DB:       db,
-        Storage:  store,
-        Bucket:   os.Getenv("S3_BUCKET"),
-        RegionOK: make(map[string]bool),
-		Cap:      captioner.Stub{},
-    }
-
-	// ---- 3. build server ----
-	r := gin.Default()
-
-	if l, ok := store.(*storage.LocalStore); ok {
-		r.Static("/static", l.Root()) // add Root() getter or hardcode "./uploads"
-	}
-
-	api := r.Group("/api")
-
-	api.POST("/maps",              uploadDeps.UploadMap)
-	api.POST("/maps/:id/caption",  uploadDeps.CreateCaption)
-	api.PUT ("/maps/:id/metadata", uploadDeps.UpdateMapMetadata)
-	api.GET ("/captions/:id",      uploadDeps.GetCaption)
-
-	uploadDeps.RegionOK = map[string]bool{
-		"_TBD_REGION": true,
-		"AFR": true, "AMR": true, "APA": true, "EUR": true, "MENA": true,
-	}
-
-	log.Fatal(r.Run(":8080"))
-}

backend/migrations/0001_init.sql

@@ -1,51 +0,0 @@
--- +goose Up
--- Initial schema
-
-CREATE TABLE sources   (s_code TEXT PRIMARY KEY, label TEXT NOT NULL);
-CREATE TABLE region    (r_code TEXT PRIMARY KEY, label TEXT NOT NULL);
-CREATE TABLE category  (cat_code TEXT PRIMARY KEY, label TEXT NOT NULL);
-CREATE TABLE country   (c_code CHAR(2) PRIMARY KEY, label TEXT NOT NULL);
-CREATE TABLE model     (m_code TEXT PRIMARY KEY, label TEXT NOT NULL);
-
-CREATE EXTENSION IF NOT EXISTS "pgcrypto";
-
-CREATE TABLE maps (
-    map_id     UUID PRIMARY KEY DEFAULT gen_random_uuid(),
-    file_key   TEXT NOT NULL,
-    sha256     TEXT NOT NULL,
-    created_at TIMESTAMPTZ NOT NULL DEFAULT NOW(),
-    source     TEXT NOT NULL REFERENCES sources(s_code),
-    region     TEXT NOT NULL REFERENCES region(r_code),
-    category   TEXT NOT NULL REFERENCES category(cat_code)
-);
-
-CREATE TABLE map_countries (
-    map_id UUID    REFERENCES maps(map_id) ON DELETE CASCADE,
-    c_code CHAR(2) REFERENCES country(c_code),
-    PRIMARY KEY (map_id, c_code)
-);
-
-CREATE TABLE captions (
-    cap_id    UUID PRIMARY KEY DEFAULT gen_random_uuid(),
-    map_id    UUID UNIQUE REFERENCES maps(map_id) ON DELETE CASCADE,
-    model     TEXT NOT NULL REFERENCES model(m_code),
-    raw_json  JSONB NOT NULL,
-    generated TEXT NOT NULL,
-    edited    TEXT,
-    accuracy  SMALLINT CHECK (accuracy  BETWEEN 0 AND 100),
-    context   SMALLINT CHECK (context   BETWEEN 0 AND 100),
-    usability SMALLINT CHECK (usability BETWEEN 0 AND 100),
-    created_at TIMESTAMPTZ NOT NULL DEFAULT NOW(),
-    updated_at TIMESTAMPTZ
-);
-
--- +goose Down
-DROP TABLE IF EXISTS captions;
-DROP TABLE IF EXISTS map_countries;
-DROP TABLE IF EXISTS maps;
-DROP TABLE IF EXISTS model;
-DROP TABLE IF EXISTS country;
-DROP TABLE IF EXISTS category;
-DROP TABLE IF EXISTS region;
-DROP TABLE IF EXISTS sources;
-

backend/migrations/0002_lookup.sql

@@ -1,37 +0,0 @@
--- +goose Up
-
--- Sources
-INSERT INTO sources (s_code, label) VALUES
-  ('WFP_ADAM',    'WFP ADAM – Automated Disaster Analysis & Mapping'),
-  ('PDC',         'Pacific Disaster Center (PDC)'),
-  ('GDACS',       'GDACS – Global Disaster Alert & Coordination System'),
-  ('GFL_HUB',     'Google Flood Hub'),
-  ('GFL_GENCAST', 'Google GenCast'),
-  ('USGS',        'USGS – United States Geological Survey')
-ON CONFLICT (s_code) DO NOTHING;
-
--- Regions
-INSERT INTO region (r_code, label) VALUES
-  ('AFR','Africa'), ('AMR','Americas'), ('APA','Asia‑Pacific'),
-  ('EUR','Europe'), ('MENA','Middle East & North Africa')
-ON CONFLICT (r_code) DO NOTHING;
-
--- Categories
-INSERT INTO category (cat_code, label) VALUES
-  ('FLOOD','Flood'), ('WILDFIRE','Wildfire'), ('EARTHQUAKE','Earthquake'), 
-  ('CYCLONE','Cyclone'), ('DROUGHT','Drought'), ('LANDSLIDE','Landslide'), 
-  ('TORNADO','Tornado'), ('VOLCANO','Volcano'), ('OTHER','Other')
-ON CONFLICT (cat_code) DO NOTHING;
-
--- Models
-INSERT INTO model (m_code, label) VALUES
-  ('GPT‑4O','GPT‑4o Vision'), ('GEMINI15','Gemini 1.5 Pro'), ('CLAUDE3','Claude 3 Sonnet')
-ON CONFLICT (m_code) DO NOTHING;
-
--- +goose Down
-DELETE FROM sources  WHERE s_code IN ('WFP_ADAM','PDC','GDACS','GFL_HUB','GFL_GENCAST','USGS');
-DELETE FROM region   WHERE r_code IN ('AFR','AMR','APA','EUR','MENA');
-DELETE FROM category WHERE cat_code IN ('FLOOD','WILDFIRE','EARTHQUAKE','CYCLONE','DROUGHT','LANDSLIDE','TORNADO','VOLCANO','OTHER');
-DELETE FROM model     WHERE m_code IN ('GPT‑4O','GEMINI15','CLAUDE3');
-
-

backend/migrations/0003_placeholder.sql

@@ -1,22 +0,0 @@
--- +goose Up
-
-INSERT INTO sources (s_code, label)
-VALUES
-  ('_TBD_SOURCE',   'TBD placeholder')
-ON CONFLICT (s_code) DO NOTHING;
-
-INSERT INTO region (r_code, label)
-VALUES
-  ('_TBD_REGION',   'TBD placeholder')
-ON CONFLICT (r_code) DO NOTHING;
-
-INSERT INTO category (cat_code, label)
-VALUES
-  ('_TBD_CATEGORY', 'TBD placeholder')
-ON CONFLICT (cat_code) DO NOTHING;
-
--- +goose Down
-
-DELETE FROM category WHERE cat_code = '_TBD_CATEGORY';
-DELETE FROM region   WHERE r_code    = '_TBD_REGION';
-DELETE FROM sources  WHERE s_code    = '_TBD_SOURCE';

backend/server/server.go

@@ -1,15 +0,0 @@
-package server //
-
-import (
-    "database/sql"
-    "github.com/SCGR-1/promptaid-backend/internal/storage"
-)
-
-type Server struct {
-	db    *sql.DB
-	store storage.ObjectStore
-}
-
-func NewServer(db *sql.DB, store storage.ObjectStore) *Server {
-	return &Server{db: db, store: store}
-}

docker-compose.yml

@@ -1,15 +1,44 @@
+version: "3.8"
+
 services:
-  db:
+  postgres:
     image: postgres:16
-    restart: unless-stopped
+    restart: always
     environment:
       POSTGRES_USER: promptaid
       POSTGRES_PASSWORD: promptaid
       POSTGRES_DB: promptaid
     ports:
-      - "5432:5432"   # host → container
+      - "5433:5432"
+    volumes:
+      - pgdata:/var/lib/postgresql/data
+
+  pgadmin:
+    image: dpage/pgadmin4
+    restart: always
+    environment:
+      PGADMIN_DEFAULT_EMAIL: [email protected]
+      PGADMIN_DEFAULT_PASSWORD: admin
+    ports:
+      - "5050:80"
+    depends_on:
+      - postgres
+
+  minio:
+    image: minio/minio
+    restart: always
+    command: server /data
+    environment:
+      MINIO_ROOT_USER: promptaid
+      MINIO_ROOT_PASSWORD: promptaid
+    ports:
+      - "9000:9000"
+      - "9001:9001"
     volumes:
-      - db_data:/var/lib/postgresql/data
+      - minio_data:/data
+    depends_on:
+      - postgres
 
 volumes:
-  db_data:
+  pgdata:
+  minio_data:

frontend/src/pages/UploadPage.tsx

@@ -9,18 +9,19 @@ import {
   UploadCloudLineIcon,
   ArrowRightLineIcon,
 } from '@ifrc-go/icons';
-import { Link, useNavigate } from 'react-router-dom';
+import { Link } from 'react-router-dom';
 
 export default function UploadPage() {
   const [step, setStep] = useState<1 | 2>(1);
   const [preview, setPreview] = useState<string | null>(null);
   /* ---------------- local state ----------------- */
-  const navigate = useNavigate();
 
   const PH_SOURCE   = "_TBD_SOURCE";
   const PH_REGION   = "_TBD_REGION";
   const PH_CATEGORY = "_TBD_CATEGORY";
 
+  const [mapId, setMapId] = useState<string | null>(null);
+
   const [file, setFile] = useState<File | null>(null);
   //const [source,    setSource]    = useState('');
   //const [region,    setRegion]    = useState('');
@@ -29,7 +30,6 @@ export default function UploadPage() {
   const [region,   setRegion]   = useState(PH_REGION);
   const [category, setCategory] = useState(PH_CATEGORY);
   const [countries, setCountries] = useState<string[]>([]);
-  const [captionId, setCaptionId] = useState<string | null>(null);
 
   // Wrapper functions to handle OptionKey to string conversion
   const handleSourceChange = (value: any) => setSource(String(value));
@@ -89,20 +89,23 @@ export default function UploadPage() {
 
     try {
       /* 1) upload */
-      const mapRes  = await fetch('/api/maps', { method: 'POST', body: fd });
+      const mapRes = await fetch('/api/maps/', { method: 'POST', body: fd });
       const mapJson = await readJsonSafely(mapRes);
       if (!mapRes.ok) throw new Error(mapJson.error || 'Upload failed');
+
+      const mapIdVal = mapJson.map_id;
+      if (!mapIdVal) throw new Error('Upload failed: map_id not found');
+      setMapId(mapIdVal);
     
       /* 2) caption */
       const capRes = await fetch(
-        `/api/maps/${mapJson.mapId}/caption`, 
+        `/api/maps/${mapIdVal}/caption/`, 
         { method: 'POST' },
       );
       const capJson = await readJsonSafely(capRes);
       if (!capRes.ok) throw new Error(capJson.error || 'Caption failed');
     
       /* 3) continue workflow */
-      setCaptionId(capJson.captionId);
       setDraft(capJson.generated);
       setStep(2);
     } catch (err) {

frontend/vite.config.ts

@@ -1,20 +1,20 @@
-console.log('⚙️ VITE CONFIG LOADED')
-
+// vite.config.ts
 import { defineConfig } from 'vite'
 import react from '@vitejs/plugin-react'
 
 export default defineConfig({
+  plugins: [react()],
   server: {
-    port: 5173,
     proxy: {
+      // proxy any /api/* request to localhost:8080
       '/api': {
         target: 'http://localhost:8080',
         changeOrigin: true,
         secure: false,
+        // rewrite: (path) => path.replace(/^\/api/, '/api'),  // not needed if same prefix
       },
     },
   },
-  plugins: [react()],
 })
 
 

py_backend/alembic.ini

@@ -0,0 +1,3 @@
+[alembic]
+script_location = alembic
+sqlalchemy.url = postgresql://promptaid:promptaid@localhost:5433/promptaid

py_backend/alembic/env.py

@@ -0,0 +1,38 @@
+import os
+import sys
+from dotenv import load_dotenv
+load_dotenv()
+
+# Add the project root (one level up from alembic/) to PYTHONPATH
+sys.path.insert(0, os.path.abspath(os.path.join(os.path.dirname(__file__), '..')))
+
+from alembic import context
+from sqlalchemy import engine_from_config, pool
+from app.models import Base
+
+target_metadata = Base.metadata
+config = context.config
+
+def run_migrations_offline():
+    url = config.get_main_option("sqlalchemy.url")
+    context.configure(
+        url=url, target_metadata=target_metadata, literal_binds=True, dialect_opts={"paramstyle": "named"}
+    )
+    with context.begin_transaction():
+        context.run_migrations()
+
+def run_migrations_online():
+    connectable = engine_from_config(
+        config.get_section(config.config_ini_section),
+        prefix='sqlalchemy.',
+        poolclass=pool.NullPool,
+    )
+    with connectable.connect() as connection:
+        context.configure(connection=connection, target_metadata=target_metadata)
+        with context.begin_transaction():
+            context.run_migrations()
+
+if context.is_offline_mode():
+    run_migrations_offline()
+else:
+    run_migrations_online()

py_backend/alembic/versions/0002_seed.py

@@ -0,0 +1,87 @@
+# py_backend/alembic/versions/0002_seed_lookups.py
+
+"""seed lookup tables
+
+Revision ID: 0002seed
+Revises: ad38fd571716
+Create Date: 2025-07-25 14:00:00.000000
+"""
+
+from alembic import op
+
+# revision identifiers, used by Alembic.
+revision = '0002seed'
+down_revision = 'ad38fd571716'
+branch_labels = None
+depends_on = None
+
+
+def upgrade():
+    # 1) sources
+    op.execute("""
+      INSERT INTO sources (s_code, label) VALUES
+        ('WFP_ADAM',    'WFP ADAM – Automated Disaster Analysis & Mapping'),
+        ('PDC',         'Pacific Disaster Center (PDC)'),
+        ('GDACS',       'GDACS – Global Disaster Alert & Coordination System'),
+        ('GFL_HUB',     'Google Flood Hub'),
+        ('GFL_GENCAST', 'Google GenCast'),
+        ('USGS',        'USGS – United States Geological Survey'),
+        ('_TBD_SOURCE','TBD placeholder')
+      ON CONFLICT (s_code) DO NOTHING;
+    """)
+
+    # 2) region
+    op.execute("""
+      INSERT INTO region (r_code, label) VALUES
+        ('AFR','Africa'),
+        ('AMR','Americas'),
+        ('APA','Asia‑Pacific'),
+        ('EUR','Europe'),
+        ('MENA','Middle East & North Africa'),
+        ('_TBD_REGION','TBD placeholder')
+      ON CONFLICT (r_code) DO NOTHING;
+    """)
+
+    # 3) category
+    op.execute("""
+      INSERT INTO category (cat_code, label) VALUES
+        ('FLOOD','Flood'),
+        ('WILDFIRE','Wildfire'),
+        ('EARTHQUAKE','Earthquake'),
+        ('CYCLONE','Cyclone'),
+        ('DROUGHT','Drought'),
+        ('LANDSLIDE','Landslide'),
+        ('TORNADO','Tornado'),
+        ('VOLCANO','Volcano'),
+        ('OTHER','Other'),
+        ('_TBD_CATEGORY','TBD placeholder')
+      ON CONFLICT (cat_code) DO NOTHING;
+    """)
+
+    # 4) model
+    op.execute("""
+      INSERT INTO model (m_code, label) VALUES
+        ('GPT-4O',   'GPT‑4o Vision'),
+        ('GEMINI15', 'Gemini 1.5 Pro'),
+        ('CLAUDE3',  'Claude 3 Sonnet'),
+        ('STUB_MODEL','Stub Captioner')
+      ON CONFLICT (m_code) DO NOTHING;
+    """)
+
+    # 5) country (example set; add more ISO‑2 codes as needed)
+    op.execute("""
+      INSERT INTO country (c_code, label) VALUES
+        ('PH','Philippines'),
+        ('ID','Indonesia'),
+        ('VN','Vietnam')
+      ON CONFLICT (c_code) DO NOTHING;
+    """)
+
+
+def downgrade():
+    # reverse in roughly the opposite order
+    op.execute("DELETE FROM country WHERE c_code IN ('PH','ID','VN');")
+    op.execute("DELETE FROM model WHERE m_code IN ('GPT-4O','GEMINI15','CLAUDE3','STUB_MODEL');")
+    op.execute("DELETE FROM category WHERE cat_code IN ('FLOOD','WILDFIRE','EARTHQUAKE','CYCLONE','DROUGHT','LANDSLIDE','TORNADO','VOLCANO','OTHER','_TBD_CATEGORY');")
+    op.execute("DELETE FROM region   WHERE r_code    IN ('AFR','AMR','APA','EUR','MENA','_TBD_REGION');")
+    op.execute("DELETE FROM sources  WHERE s_code   IN ('WFP_ADAM','PDC','GDACS','GFL_HUB','GFL_GENCAST','USGS','_TBD_SOURCE');")

py_backend/alembic/versions/ad38fd571716_init_schema.py

@@ -0,0 +1,113 @@
+"""init schema
+
+Revision ID: ad38fd571716
+Revises: 
+Create Date: 2025-07-24 15:30:00.000000
+
+"""
+from alembic import op
+import sqlalchemy as sa
+
+# revision identifiers, used by Alembic.
+revision = 'ad38fd571716'
+down_revision = None
+branch_labels = None
+depends_on = None
+
+
+def upgrade():
+    # 1) Enable pgcrypto extension for gen_random_uuid()
+    op.execute('CREATE EXTENSION IF NOT EXISTS "pgcrypto";')
+
+    # 2) Lookup tables
+    op.create_table(
+        'sources',
+        sa.Column('s_code',   sa.Text(), primary_key=True),
+        sa.Column('label',    sa.Text(), nullable=False),
+    )
+    op.create_table(
+        'region',
+        sa.Column('r_code',   sa.Text(), primary_key=True),
+        sa.Column('label',    sa.Text(), nullable=False),
+    )
+    op.create_table(
+        'category',
+        sa.Column('cat_code', sa.Text(), primary_key=True),
+        sa.Column('label',    sa.Text(), nullable=False),
+    )
+    op.create_table(
+        'country',
+        sa.Column('c_code',   sa.CHAR(length=2), primary_key=True),
+        sa.Column('label',    sa.Text(),    nullable=False),
+    )
+    op.create_table(
+        'model',
+        sa.Column('m_code',   sa.Text(), primary_key=True),
+        sa.Column('label',    sa.Text(), nullable=False),
+    )
+
+    # 3) maps table
+    op.create_table(
+        'maps',
+        sa.Column('map_id',    sa.UUID(), 
+                  server_default=sa.text('gen_random_uuid()'),
+                  primary_key=True),
+        sa.Column('file_key',  sa.Text(), nullable=False),
+        sa.Column('sha256',    sa.Text(), nullable=False),
+        sa.Column('source',    sa.Text(), nullable=False),
+        sa.Column('region',    sa.Text(), nullable=False),
+        sa.Column('category',  sa.Text(), nullable=False),
+        sa.Column('created_at',sa.TIMESTAMP(timezone=True), 
+                  server_default=sa.text('NOW()'),
+                  nullable=False),
+        sa.ForeignKeyConstraint(['source'],   ['sources.s_code']),
+        sa.ForeignKeyConstraint(['region'],   ['region.r_code']),
+        sa.ForeignKeyConstraint(['category'], ['category.cat_code']),
+    )
+
+    # 4) map_countries join table
+    op.create_table(
+        'map_countries',
+        sa.Column('map_id', sa.UUID(),   nullable=False),
+        sa.Column('c_code', sa.CHAR(length=2), nullable=False),
+        sa.PrimaryKeyConstraint('map_id', 'c_code'),
+        sa.ForeignKeyConstraint(['map_id'], ['maps.map_id'], ondelete='CASCADE'),
+        sa.ForeignKeyConstraint(['c_code'], ['country.c_code']),
+    )
+
+    # 5) captions table
+    op.create_table(
+        'captions',
+        sa.Column('cap_id',    sa.UUID(),
+                  server_default=sa.text('gen_random_uuid()'),
+                  primary_key=True),
+        sa.Column('map_id',    sa.UUID(),   nullable=False, unique=True),
+        sa.Column('model',     sa.Text(),    nullable=False),
+        sa.Column('raw_json',  sa.JSON(),    nullable=False),
+        sa.Column('generated', sa.Text(),    nullable=False),
+        sa.Column('edited',    sa.Text(),    nullable=True),
+        sa.Column('accuracy',  sa.SmallInteger(), 
+                  sa.CheckConstraint('accuracy BETWEEN 0 AND 100')),
+        sa.Column('context',   sa.SmallInteger(), 
+                  sa.CheckConstraint('context BETWEEN 0 AND 100')),
+        sa.Column('usability', sa.SmallInteger(), 
+                  sa.CheckConstraint('usability BETWEEN 0 AND 100')),
+        sa.Column('created_at',sa.TIMESTAMP(timezone=True), 
+                  server_default=sa.text('NOW()'),
+                  nullable=False),
+        sa.Column('updated_at',sa.TIMESTAMP(timezone=True), nullable=True),
+        sa.ForeignKeyConstraint(['map_id'], ['maps.map_id'], ondelete='CASCADE'),
+        sa.ForeignKeyConstraint(['model'],  ['model.m_code']),
+    )
+
+
+def downgrade():
+    # drop in reverse order to respect FKs
+    op.drop_table('captions')
+    op.drop_table('map_countries')
+    op.drop_table('maps')
+    op.drop_table('model')
+    op.drop_table('country')
+    op.drop_table('category')
+    op.drop_table('region')
+    op.drop_table('sources')

py_backend/app/config.py

@@ -0,0 +1,15 @@
+from pydantic import BaseSettings
+
+class Settings(BaseSettings):
+    DATABASE_URL: str
+    S3_ENDPOINT: str
+    S3_ACCESS_KEY: str
+    S3_SECRET_KEY: str
+    S3_BUCKET: str
+
+    class Config:
+        env_file = ".env"
+        env_file_encoding = "utf-8-sig"
+
+# instantiate a single global settings object
+settings = Settings()

py_backend/app/crud.py

@@ -0,0 +1,56 @@
+import io, hashlib
+from sqlalchemy.orm import Session
+from . import models
+
+def hash_bytes(data: bytes) -> str:
+    """Compute SHA‑256 hex digest of the data."""
+    return hashlib.sha256(data).hexdigest()
+
+def create_map(db: Session, src, reg, cat, key, sha, countries: list[str]):
+    """Insert into maps and map_countries."""
+    m = models.Map(
+        source=src, region=reg, category=cat,
+        file_key=key, sha256=sha
+    )
+    db.add(m)
+    db.flush()  # assign m.map_id
+
+    # link countries
+    for c in countries:
+        country = db.get(models.Country, c)
+        if country:
+            m.countries.append(country)
+
+    db.commit()
+    db.refresh(m)
+    return m
+
+def get_map(db: Session, map_id):
+    return db.get(models.Map, map_id)
+
+def create_caption(db: Session, map_id, model_code, raw_json, text):
+    c = models.Caption(
+        map_id=map_id,
+        model=model_code,
+        raw_json=raw_json,
+        generated=text
+    )
+    db.add(c)
+    db.commit()
+    db.refresh(c)
+    return c
+
+def get_caption(db: Session, cap_id):
+    return db.get(models.Caption, cap_id)
+
+def update_caption(db: Session, cap_id, edited, accuracy, context, usability):
+    c = get_caption(db, cap_id)
+    if not c:
+        return None
+    c.edited = edited
+    c.accuracy = accuracy
+    c.context = context
+    c.usability = usability
+    db.commit()
+    db.refresh(c)
+    return c

py_backend/app/database.py

@@ -0,0 +1,17 @@
+from sqlalchemy import create_engine
+from sqlalchemy.ext.declarative import declarative_base
+from sqlalchemy.orm import sessionmaker
+from .config import settings
+
+# Create the SQLAlchemy engine
+engine = create_engine(settings.DATABASE_URL, echo=True)
+
+# Each instance of SessionLocal is a database session
+SessionLocal = sessionmaker(
+    autocommit=False,
+    autoflush=False,
+    bind=engine
+)
+
+# Base class for ORM models
+Base = declarative_base()

py_backend/app/main.py

@@ -0,0 +1,27 @@
+# py_backend/app/main.py
+
+from fastapi import FastAPI
+from fastapi.middleware.cors import CORSMiddleware
+from app.routers import upload, caption, metadata
+from app.config import settings
+import boto3
+
+app = FastAPI(title="PromptAid Vision")
+
+# CORS: allow your React dev server(s)
+app.add_middleware(
+    CORSMiddleware,
+    allow_origins=[
+        "http://localhost:3000",
+        "http://localhost:5173"
+    ],
+    allow_credentials=True,
+    allow_methods=["*"],
+    allow_headers=["*"],
+)
+
+# Mount routers
+app.include_router(upload.router,   prefix="/api/maps", tags=["maps"])
+app.include_router(caption.router,  prefix="/api",      tags=["captions"])
+app.include_router(metadata.router, prefix="/api",      tags=["metadata"])
+

py_backend/app/models.py

@@ -0,0 +1,68 @@
+from sqlalchemy import (
+    Column, String, DateTime, JSON, SmallInteger, Table, ForeignKey
+)
+from sqlalchemy.dialects.postgresql import UUID, TIMESTAMP, CHAR
+from sqlalchemy.orm import relationship
+import datetime, uuid
+from .database import Base
+
+# association table maps ↔ countries
+map_countries = Table(
+    "map_countries", Base.metadata,
+    Column("map_id", UUID(as_uuid=True), ForeignKey("maps.map_id", ondelete="CASCADE")),
+    Column("c_code", CHAR(2), ForeignKey("country.c_code")),
+)
+
+class Source(Base):
+    __tablename__ = "sources"
+    s_code = Column(String, primary_key=True)
+    label  = Column(String, nullable=False)
+
+class Region(Base):
+    __tablename__ = "region"
+    r_code = Column(String, primary_key=True)
+    label  = Column(String, nullable=False)
+
+class Category(Base):
+    __tablename__ = "category"
+    cat_code = Column(String, primary_key=True)
+    label    = Column(String, nullable=False)
+
+class Country(Base):
+    __tablename__ = "country"
+    c_code = Column(CHAR(2), primary_key=True)
+    label  = Column(String, nullable=False)
+
+class ModelLookup(Base):
+    __tablename__ = "model"
+    m_code = Column(String, primary_key=True)
+    label  = Column(String, nullable=False)
+
+class Map(Base):
+    __tablename__ = "maps"
+    map_id     = Column(UUID(as_uuid=True), primary_key=True, default=uuid.uuid4)
+    file_key   = Column(String, nullable=False)
+    sha256     = Column(String, nullable=False)
+    source     = Column(String, ForeignKey("sources.s_code"), nullable=False)
+    region     = Column(String, ForeignKey("region.r_code"), nullable=False)
+    category   = Column(String, ForeignKey("category.cat_code"), nullable=False)
+    created_at = Column(TIMESTAMP(timezone=True), default=datetime.datetime.utcnow)
+
+    countries = relationship("Country", secondary=map_countries)
+    caption   = relationship("Caption", uselist=False, back_populates="map")
+
+class Caption(Base):
+    __tablename__ = "captions"
+    cap_id     = Column(UUID(as_uuid=True), primary_key=True, default=uuid.uuid4)
+    map_id     = Column(UUID(as_uuid=True), ForeignKey("maps.map_id", ondelete="CASCADE"), unique=True)
+    model      = Column(String, ForeignKey("model.m_code"), nullable=False)
+    raw_json   = Column(JSON, nullable=False)
+    generated  = Column(String, nullable=False)
+    edited     = Column(String)
+    accuracy   = Column(SmallInteger)
+    context    = Column(SmallInteger)
+    usability  = Column(SmallInteger)
+    created_at = Column(TIMESTAMP(timezone=True), default=datetime.datetime.utcnow)
+    updated_at = Column(TIMESTAMP(timezone=True), onupdate=datetime.datetime.utcnow)
+
+    map = relationship("Map", back_populates="caption")

py_backend/app/routers/caption.py

@@ -0,0 +1,50 @@
+from fastapi import APIRouter, HTTPException, Depends
+from sqlalchemy.orm import Session
+from .. import crud, database, schemas, storage
+import io
+
+router = APIRouter()
+
+def get_db():
+    db = database.SessionLocal()
+    try:
+        yield db
+    finally:
+        db.close()
+
+# --- Stub captioner for now ---
+class CaptionerStub:
+    def generate(self, image_bytes: bytes) -> tuple[str,str,dict]:
+        text = "This is a fake caption."
+        model = "STUB_MODEL"
+        raw = {"stub": True}
+        return text, model, raw
+
+cap = CaptionerStub()
+
+@router.post("/maps/{map_id}/caption", response_model=schemas.CaptionOut)
+def create_caption(map_id: str, db: Session = Depends(get_db)):
+    m = crud.get_map(db, map_id)
+    if not m:
+        raise HTTPException(404, "map not found")
+
+    # fetch image bytes from S3
+    url = storage.generate_presigned_url(m.file_key)
+    # (in real code, you might stream from S3 directly)
+    import requests
+    resp = requests.get(url)
+    img_bytes = resp.content
+
+    # generate caption
+    text, model, raw = cap.generate(img_bytes)
+
+    # insert into DB
+    c = crud.create_caption(db, map_id, model, raw, text)
+    return c
+
+@router.get("/captions/{cap_id}", response_model=schemas.CaptionOut)
+def get_caption(cap_id: str, db: Session = Depends(get_db)):
+    c = crud.get_caption(db, cap_id)
+    if not c:
+        raise HTTPException(404, "caption not found")
+    return c

py_backend/app/routers/metadata.py

@@ -0,0 +1,24 @@
+from fastapi import APIRouter, HTTPException, Depends
+from sqlalchemy.orm import Session
+from .. import crud, database, schemas
+
+router = APIRouter()
+
+def get_db():
+    db = database.SessionLocal()
+    try:
+        yield db
+    finally:
+        db.close()
+
+@router.put("/maps/{map_id}/metadata", response_model=schemas.CaptionOut)
+def update_metadata(
+    map_id: str,
+    update: schemas.CaptionUpdate,
+    db: Session = Depends(get_db)
+):
+    # we stored cap_id == map_id in Go; here cap_id is uuid on captions table
+    c = crud.update_caption(db, map_id, **update.dict())
+    if not c:
+        raise HTTPException(404, "caption not found")
+    return c

py_backend/app/routers/upload.py

@@ -0,0 +1,33 @@
+from fastapi import APIRouter, UploadFile, Form, Depends, HTTPException
+import io
+from sqlalchemy.orm import Session
+from .. import crud, schemas, storage, database
+
+router = APIRouter()
+
+def get_db():
+    db = database.SessionLocal()
+    try:
+        yield db
+    finally:
+        db.close()
+
+@router.post("/", response_model=schemas.MapOut)
+async def upload_map(
+    source: str = Form(...),
+    region: str = Form(...),
+    category: str = Form(...),
+    countries: list[str] = Form([]),
+    file: UploadFile = Form(...),
+    db: Session = Depends(get_db)
+):
+    # 1) read & hash
+    content = await file.read()
+    sha = crud.hash_bytes(content)
+
+    # 2) upload to S3
+    key = storage.upload_fileobj(io.BytesIO(content), file.filename)
+
+    # 3) insert into DB
+    m = crud.create_map(db, source, region, category, key, sha, countries)
+    return m

py_backend/app/schemas.py

@@ -0,0 +1,42 @@
+from pydantic import BaseModel, Field
+from typing import List, Optional
+from uuid import UUID
+
+#–– For the UploadPage ––
+class MapCreate(BaseModel):
+    source: str
+    region: str
+    category: str
+    countries: List[str] = []
+
+class MapOut(BaseModel):
+    map_id: UUID
+    file_key: str
+    sha256: str
+    source: str
+    region: str
+    category: str
+
+    class Config:
+        orm_mode = True
+
+#–– For the caption endpoints ––
+class CaptionOut(BaseModel):
+    cap_id: UUID
+    map_id: UUID
+    model: str
+    raw_json: dict
+    generated: str
+    edited: Optional[str]
+    accuracy: Optional[int]
+    context: Optional[int]
+    usability: Optional[int]
+
+    class Config:
+        orm_mode = True
+
+class CaptionUpdate(BaseModel):
+    edited: str
+    accuracy: int = Field(..., ge=0, le=100)
+    context:  int = Field(..., ge=0, le=100)
+    usability:int = Field(..., ge=0, le=100)

py_backend/app/storage.py

@@ -0,0 +1,47 @@
+# app/storage.py
+
+import io
+import boto3
+import botocore
+from uuid import uuid4
+from typing import BinaryIO
+from .config import settings
+
+# Initialize the S3/MinIO client
+s3 = boto3.client(
+    "s3",
+    endpoint_url=settings.S3_ENDPOINT,
+    aws_access_key_id=settings.S3_ACCESS_KEY,
+    aws_secret_access_key=settings.S3_SECRET_KEY,
+)
+
+def upload_fileobj(fileobj: BinaryIO, filename: str) -> str:
+    """
+    Uploads a file-like object to the configured S3 bucket,
+    automatically creating the bucket if it doesn't exist.
+    Returns the object key.
+    """
+    key = f"maps/{uuid4()}_{filename}"
+
+    # 1) Ensure the bucket exists
+    try:
+        s3.head_bucket(Bucket=settings.S3_BUCKET)
+    except botocore.exceptions.ClientError as e:
+        # A 404 or 403 here means the bucket doesn't exist or no access:
+        s3.create_bucket(Bucket=settings.S3_BUCKET)
+
+    # 2) Perform the upload
+    fileobj.seek(0)  # rewind in case .read() was called
+    s3.upload_fileobj(fileobj, settings.S3_BUCKET, key)
+
+    return key
+
+def generate_presigned_url(key: str, expires_in: int = 3600) -> str:
+    """
+    Returns a presigned URL for GETting the object.
+    """
+    return s3.generate_presigned_url(
+        ClientMethod="get_object",
+        Params={"Bucket": settings.S3_BUCKET, "Key": key},
+        ExpiresIn=expires_in,
+    )

py_backend/requirements.txt

@@ -0,0 +1,9 @@
+fastapi
+uvicorn[standard]
+sqlalchemy
+alembic
+psycopg2-binary
+boto3
+python-dotenv
+pydantic<2.0.0
+openai  # or other VLM client