minor update on database connection

Author: Nonnyjoe

.env.example

@@ -12,6 +12,7 @@ APP_LOG_LEVEL=INFO
 MCP_BASE_URL=http://localhost:8000/mcp
 
 # Read-only PostgreSQL URL (asyncpg). Use a DB user with SELECT-only privileges in production.
+# `postgres://` is normalized to `postgresql+asyncpg://`, and `sslmode` is converted to `ssl`.
 # Example: postgresql+asyncpg://mcp_reader:CHANGE_ME@localhost:5432/cartesi_mcp
 DATABASE_URL=postgresql+asyncpg://postgres:postgres@localhost:5432/mcp_server
 

.github/workflows/fly.yaml

@@ -0,0 +1,77 @@
+name: Deploy Release to Fly.io
+
+on:
+  release:
+    types: [published]
+
+concurrency:
+  group: production-deploy
+  cancel-in-progress: false
+
+env:
+  FLY_APP_NAME: cartesi-mcp-server
+  FLY_ORG: mugen-builders
+  IMAGE_NAME: ghcr.io/${{ github.repository }}
+
+jobs:
+  deploy-production:
+    runs-on: ubuntu-latest
+
+    environment:
+      name: production
+
+    permissions:
+      contents: read
+      packages: read
+
+    steps:
+      - name: Checkout repository
+        uses: actions/checkout@v4
+
+      - name: Extract release version
+        id: version
+        run: |
+          VERSION="${{ github.event.release.tag_name }}"
+          echo "version=${VERSION}" >> "$GITHUB_OUTPUT"
+
+      - name: Setup flyctl
+        uses: superfly/flyctl-actions/setup-flyctl@master
+
+      - name: Sync production secrets to Fly.io
+        env:
+          FLY_API_TOKEN: ${{ secrets.FLY_API_TOKEN }}
+          DATABASE_URL: ${{ secrets.DATABASE_URL }}
+          APP_NAME: ${{ secrets.APP_NAME }}
+          APP_ENV: ${{ secrets.APP_ENV }}
+          APP_HOST: ${{ secrets.APP_HOST }}
+          APP_PORT: ${{ secrets.APP_PORT }}
+          APP_LOG_LEVEL: ${{ secrets.APP_LOG_LEVEL }}
+          MCP_BASE_URL: ${{ secrets.MCP_BASE_URL }}
+          DEFAULT_PAGE_SIZE: ${{ secrets.DEFAULT_PAGE_SIZE }}
+          MAX_PAGE_SIZE: ${{ secrets.MAX_PAGE_SIZE }}
+          APP_ENV: production
+        run: |
+          flyctl secrets set \
+            --app "$FLY_APP_NAME" \
+            --stage \
+            DATABASE_URL="$DATABASE_URL" \
+            APP_NAME="$APP_NAME" \
+            APP_ENV="$APP_ENV" \
+            APP_HOST="$APP_HOST" \
+            APP_PORT="$APP_PORT" \
+            APP_LOG_LEVEL="$APP_LOG_LEVEL" \
+            MCP_BASE_URL="$MCP_BASE_URL" \
+            DEFAULT_PAGE_SIZE="$DEFAULT_PAGE_SIZE" \
+            MAX_PAGE_SIZE="$MAX_PAGE_SIZE" \
+            APP_ENV="$APP_ENV"
+
+
+      - name: Deploy release image to existing Fly.io app
+        env:
+          FLY_API_TOKEN: ${{ secrets.FLY_API_TOKEN }}
+        run: |
+          flyctl deploy \
+            --app "$FLY_APP_NAME" \
+            --image "$IMAGE_NAME:${{ steps.version.outputs.version }}" \
+            --strategy rolling \
+            --wait-timeout 300

README.md

@@ -21,7 +21,7 @@ Knowledge responses are **metadata and links** (titles, URIs, `canonical_url`, d
 
 ## Environment variables
 
-Copy `.env.example` to `.env` and adjust. Defaults and field names are defined in `src/core/config.py` (notably `DATABASE_URL`, `APP_HOST`, `APP_PORT`, `MCP_BASE_URL`, pagination limits).
+Copy `.env.example` to `.env` and adjust. Defaults and field names are defined in `src/core/config.py` (notably `DATABASE_URL`, `APP_HOST`, `APP_PORT`, `MCP_BASE_URL`, pagination limits). For PostgreSQL URLs, `postgres://...` is normalized to `postgresql+asyncpg://...`, and `sslmode` is translated to asyncpg-compatible `ssl` (for example, `sslmode=disable` becomes `ssl=false`).
 
 ## Install
 

src/core/config.py

@@ -1,9 +1,47 @@
 from functools import lru_cache
+from urllib.parse import parse_qsl, urlencode, urlsplit, urlunsplit
 
-from pydantic import Field
+from pydantic import Field, field_validator
 from pydantic_settings import BaseSettings, SettingsConfigDict
 
 
+def normalize_database_url_for_async(url: str) -> str:
+    u = url.strip()
+    if u.startswith("postgres://"):
+        u = "postgresql://" + u[len("postgres://") :]
+    if u.startswith("postgresql://") and not u.startswith("postgresql+"):
+        u = "postgresql+asyncpg://" + u[len("postgresql://") :]
+
+    # asyncpg does not accept sslmode=..., convert psycopg-style URLs.
+    if u.startswith("postgresql+asyncpg://"):
+        parsed = urlsplit(u)
+        query = parse_qsl(parsed.query, keep_blank_values=True)
+        has_ssl = any(key == "ssl" for key, _ in query)
+        if not has_ssl:
+            normalized_query: list[tuple[str, str]] = []
+            for key, value in query:
+                if key != "sslmode":
+                    normalized_query.append((key, value))
+                    continue
+
+                mode = value.strip().lower()
+                if mode == "disable":
+                    normalized_query.append(("ssl", "false"))
+                else:
+                    normalized_query.append(("ssl", "true"))
+
+            u = urlunsplit(
+                (
+                    parsed.scheme,
+                    parsed.netloc,
+                    parsed.path,
+                    urlencode(normalized_query, doseq=True),
+                    parsed.fragment,
+                )
+            )
+    return u
+
+
 class Settings(BaseSettings):
     app_name: str = Field(default="Cartesi Knowledge MCP Server", alias="APP_NAME")
     app_env: str = Field(default="development", alias="APP_ENV")
@@ -20,6 +58,13 @@ class Settings(BaseSettings):
 
     model_config = SettingsConfigDict(env_file=".env", env_file_encoding="utf-8", extra="ignore")
 
+    @field_validator("database_url", mode="before")
+    @classmethod
+    def _normalize_database_url(cls, v: object) -> object:
+        if not isinstance(v, str):
+            return v
+        return normalize_database_url_for_async(v)
+
 
 @lru_cache(maxsize=1)
 def get_settings() -> Settings: