lfx-object-store-design

name	lfx-object-store-design
description	Central explainer for adding object storage capability to an LFX V2 service. Covers the S3-compatible storage decision, hard requirements (no presigned uploads, private buckets only, 20 MB cap, per-service bucket ownership, metadata/payload separation), Go AWS SDK v2 code patterns, the singleton and collection API shapes, the Helm chart credential-mode contract (static creds for local, IRSA for deployed), the nats-s3 sidecar local backend, the nginx-s3-gateway local CDN model, and the S3_BUCKET/AWS_REGION/S3_ENDPOINT_URL/S3_CREATE_MISSING_BUCKET/ CDN_URL_PREFIX env var contract. Fires on prompts like "object storage", "S3", "file upload", "upload endpoint", "attachments", "logo upload", "bucket", "nats-s3", "nginx-s3-gateway", "CDN_URL_PREFIX", "presigned URL", "PutObject", "IRSA S3", "S3_ENDPOINT_URL", "public_url", "download endpoint", "multipart upload". Read-only; routes implementation work to the owning service repo and provisioning to `/lfx-skills:lfx-object-store-ops`.
allowed-tools	Read, Glob, Grep

LFX Object Store Design

How an LFX V2 service adds object storage capability: upload/download endpoints, S3-compatible backend wiring, Helm chart credential modes, and the local development stack. This is the shared design baseline; service repos own their implementation.

S3-compatible object storage is the standard backend for LFX V2 services. Deployed environments use AWS S3. Local development uses a nats-s3 sidecar over NATS Object Store.

"S3-compatible" is an app-side portability statement: the code targets the S3 API, so any S3-compatible backend works. It is not a deployment commitment — which backend is actually deployed is an ops concern, handled by /lfx-skills:lfx-object-store-ops.

When to invoke

• A service is adding file upload, download, attachment, logo, avatar, or document storage endpoints.
• A chart needs S3 backend configuration, credential-mode values, or the nats-s3 sidecar.
• Questions about CDN_URL_PREFIX, public_url, presigned URLs, bucket ownership, or local object-storage development.

Do not invoke for:

• Provisioning buckets, CloudFront, IAM roles, or certificates (/lfx-skills:lfx-object-store-ops).
• FGA relation modeling detail (owning service's FGA contract docs).

Where the upload endpoint lives

Everything in this skill (Heimdall middleware, the ruleset-driven Cache-Control, NATS indexing events) assumes the upload/download endpoint is implemented in the owning Go backend resource-API service, reached through the Traefik LFX API Gateway route, which authorizes the request via Heimdall before it ever reaches the service. That placement is preferred and should be the default for any new attachment/logo/document capability on a service that already has an HTTP resource API — the gateway terminates the request there, Heimdall authorizes it against the real user identity, and the rest of this skill applies as written.

The Angular UI's SSR/BFF (lfx-self-serve) is a separate route on the same Traefik ingress (a UI route, not the API gateway route) — the browser talks to the SSR there, never directly to the API gateway route or a resource API, so the SSR is what terminates the user's browser connection for every request, uploads included. When the SSR needs data from a resource API, it acts as a client of the Traefik LFX API Gateway route, the same way any other caller would. Implementing the S3 client directly inside the SSR (rather than proxying to a backend resource API) is the exception, justified only when the owning capability has no HTTP resource API to proxy to — for example, user profile data (including the avatar) is owned by lfx-v2-auth-service exclusively via NATS, with no API-gateway-routed HTTP surface for the SSR to call. Don't default to an SSR-local implementation out of convenience when a backend resource API already exists or is planned; route the upload there instead.

When the SSR does need to proxy an upload through to a backend resource API (the common case going forward, as more services gain HTTP surfaces), see "SSR/BFF proxy transport" below for the required streaming and auth-forwarding pattern.

Hard requirements

These are non-negotiable across all services:

1. No presigned uploads. All uploads go through the service API. Browsers never write directly to the store.
2. Private buckets only. Public reads are served via a CDN with origin authorization to the private bucket, never via bucket ACLs or public bucket policies.
3. Per-file maximum size: 20 MB (logos, meeting attachments, PDFs, docx).
4. Per-service bucket ownership. Each service manages its own bucket(s). FGA relation shapes, allowed content types, and access semantics differ per service. There is no shared attachment service. CDN-fronted (public) and service-API-only (private) files must live in separate buckets — this is mandatory, not optional: the CDN's origin authorization can read every key in its origin bucket, so mixing private objects into a CDN-fronted bucket makes them anonymously retrievable to anyone who knows the key.
5. Metadata/payload separation. Binary payloads never appear in Query Service indexed objects, list responses, or NATS events. Only metadata (filename, content type, size, uploader, timestamps, download URL) is indexed or published.

API patterns

Singleton file (exactly one file of a type per resource)

POST   /resources/{uid}/logo-upload      Upload or replace (raw body)
GET    /resources/{uid}/logo-download    Download
DELETE /resources/{uid}/logo             Remove

The download route is not "public" by contract — access is whatever the Heimdall ruleset says for that route. Set Cache-Control on the response to match the ruleset (public, ... when the ruleset allows anonymous reads; private, ... otherwise).

Collection (multiple files per resource)

POST   /resources/{uid}/documents                     Upload (multipart/form-data: file + sibling metadata fields)
GET    /resources/{uid}/documents/{doc_uid}            Fetch metadata (including CDN URL, if applicable)
GET    /resources/{uid}/documents/{doc_uid}/download   Download binary
DELETE /resources/{uid}/documents/{doc_uid}            Delete

Collection uploads are multipart because there is no separate metadata-create step: the document's identity and metadata (for example, a required display name, an optional description or folder placement) arrive in the same request as the binary — the sibling-fields case described under "Upload body encoding" below. committee-service's upload-committee-document endpoint is the reference shape.

There is no collection-listing REST endpoint. Listing multiple attachments (or the parent resources that carry a singleton file as an attribute) is a Query Service concern, not a service API concern. Set Cache-Control on the download response per the ruleset, same as the singleton case.

Upload body encoding

Prefer a raw request body (Content-Type set to the file's own MIME type, body is the file bytes) when the upload carries nothing but the file itself — this is the common case for a singleton like logo/avatar upload. Content-Type already conveys the one thing multipart's per-part headers exist to convey; there's no second field to disambiguate, so a multipart parser adds a dependency and code path for no benefit.

Use multipart/form-data only when the request needs to carry sibling fields alongside the file in the same request — for example, a collection upload that also takes a caption, a document-type field, or a client-supplied filename. Multiple files in one request is the other case that requires it. Don't default to multipart out of habit; pick it because a specific sibling field is actually needed.

Progress reporting (XHR.upload.onprogress, or a fetch request body stream) is a property of the transport — one HTTP request carrying a body — not of the body's encoding. Either raw or multipart give identical progress-event granularity in the browser; this is not a reason to prefer one over the other.

Resumable/chunked uploads are out of scope. This is a deliberate scope/complexity decision, not an impossibility claim: at ≤ 20 MB (see "Hard requirements"), a failed upload is cheap to retry from the start, so the machinery a resumable protocol adds — offset tracking, part reassembly, expiry of abandoned sessions (tus.io, or S3's own multipart-upload API: CreateMultipartUpload/UploadPart/ CompleteMultipartUpload) — is not worth carrying for this file-size class. If a future use case genuinely needs larger files, that's a design-change conversation (revisiting the 20 MB cap and this skill), not something to bolt on per-service. Also don't confuse S3's "multipart upload" (an API for large objects) with the HTTP body encoding multipart/form-data above; they share a word but are unrelated.

SSR/BFF proxy transport

When lfx-self-serve's SSR proxies an upload through to a backend resource API (see "Where the upload endpoint lives" above), the browser's request terminates at the SSR — the browser cannot reach the resource API's Traefik LFX API Gateway route directly, and the SSR holds the session/access token, not the browser. The SSR therefore makes a second, server-to-server HTTP call that must:

• Forward the user's own access token, not an M2M token. Heimdall authorizes the request against the real user's FGA relations for that route; substituting a service-to-service M2M token would authorize as the wrong principal (or fail entirely if the ruleset requires a user relation the M2M identity doesn't have).
• Reuse the already-buffered body; don't introduce streaming machinery. The SSR already buffers the incoming request once (express.raw or a multipart parser, per "Upload body encoding" above) to validate content type and size against the 20 MB cap. Pass that same buffer as the outgoing request body rather than copying it or piping it through an intermediate stream — at 20 MB, a second in-memory reference costs nothing, and true request-body streaming is unnecessary for the same reason resumable uploads are out of scope above. This differs from the download direction: lfx-self-serve's existing streamRequest / proxyStreamRequest (ApiClientService / MicroserviceProxyService) pipe a fetch Response.body straight to the Express response instead of buffering a full download, because the response size isn't bounded by the same 20 MB contract the way uploads are — don't reach for that pattern on the upload side, it solves a problem that doesn't exist here.
• Propagate the resource API's response, not a re-derived one. The BFF should return the backend's 201 + metadata (or its error) as-is rather than reshaping the response, so public_url and any validation errors originate from the single source of truth (the resource API), not from SSR-side assumptions about what the backend did.

Upload flow

1. Validate the JWT via Heimdall middleware. The ruleset enforces authorization for the route; there is no separate access-check step here.
2. Validate the file: allowed content types, size ≤ 20 MB.
3. Write to the S3 bucket (standard PutObject), setting Content-Type and Cache-Control object metadata.
4. Publish standard NATS indexing events (metadata only, no binary).
5. Return 201 with metadata, including public_url when CDN_URL_PREFIX is configured. Reserve 204 for responses with no body (for example, DELETE).

Download flow

The service's own download route always exists and is always authoritative — it is not replaced by the CDN, only supplemented by it for public reads:

• CDN-fronted files (public assets such as logos and avatars): when CDN_URL_PREFIX is configured, the CDN serves the file directly from the private bucket via origin authorization, and public_url in the upload response points clients there instead of the service route. Use a cache-busting query parameter (not a path segment) for the version hint — for example ?v=<upload-unix-timestamp> or ?v=<content-hash-prefix>. Either works; pick one convention per service and use it consistently. The S3 object VersionId is not recommended for this hint, even though it also changes on every overwrite: VersionId is an addressing mechanism (GetObject accepts it to fetch that exact historical version), and code will eventually be tempted to use it that way. If it ever is, a stale persisted public_url stops self-healing — instead of the CDN converging to the current object after its TTL expires, the origin fetch pins to that literal old version until an ops lifecycle rule prunes it. Make sure the CDN's cache policy includes the cache-busting query parameter in its cache key (a cache policy that strips query strings will keep serving a stale object after the version parameter changes).

  Because the version hint is only a cache-busting signal and not an immutable identifier, set a short TTL, not a long or "immutable" one: Cache-Control: public, max-age=86400 (1 day) is the baseline recommendation. This bounds how long any copy of the URL that was persisted elsewhere (for example, denormalized into another service's search index or a downstream record) can keep serving stale bytes after the underlying file changes — that copy converges to the current image within the TTL window even if nothing ever refreshes the persisted URL string itself. Do not set a multi-year or immutable Cache-Control on these responses; that only makes sense for content-addressed paths (for example, hashed static JS bundle filenames), which this is not.

  When CDN_URL_PREFIX is unset, the service's own download route is the only path and serves the file after the ruleset authorizes the request.

• Service-API-only files (attachments, legal docs): never CDN-fronted, regardless of CDN_URL_PREFIX. The service streams from S3 after the ruleset authorizes the request, with Content-Disposition: attachment and Range header pass-through (206 Partial Content) for PDF viewer compatibility.

Gateway sizing

Upload routes must accommodate 20 MB request bodies plus multipart overhead (boundaries, part headers): Traefik maxRequestBodyBytes should be set above 20971520, with margin for the overhead, not exactly at it. Upload timeout 120s. Download routes should set responseBuffering: false.

Go code patterns

• AWS SDK v2 with the default credential chain — no code branching. The chain resolves static env credentials (local sidecar) or the IRSA web-identity token (deployed EKS) transparently. Never write credential-mode conditionals in service code.
• Endpoint override: when S3_ENDPOINT_URL is set, apply it via config.WithBaseEndpoint. Empty means real AWS S3.
• Path-style addressing: set o.UsePathStyle = true on the S3 client; required by nats-s3 and most S3-compatible endpoints.
• Startup: run an idempotent EnsureBucket with a retry loop (~10 attempts, 3s apart) before accepting traffic — the local sidecar may not be ready immediately. Gate the CreateBucket call on an explicit S3_CREATE_MISSING_BUCKET boolean, not on whether S3_ENDPOINT_URL is set — an endpoint override is also used for non-local S3-compatible backends where the app should never create buckets. Set S3_CREATE_MISSING_BUCKET=true only in local values; leave it unset (false) everywhere else, including deployed environments, where the bucket is provisioned ahead of time (/lfx-skills:lfx-object-store-ops) and the IRSA role should not grant s3:CreateBucket. When the flag is false, EnsureBucket should be a HeadBucket-only existence check, not a create-on-missing retry loop that could mask a permissions error as "bucket not ready yet".
• Readiness: back /readyz with a HeadBucket ping.
• Delete semantics: S3 DeleteObject is idempotent; HeadObject first if the API must return not-found for missing keys.
• No client-facing listing. ListObjectsV2 is useful internally (for example, to traverse a bucket for maintenance), but it is not how a service serves a list of files to a client — that's a Query Service concern (see "API patterns" above).
• Cache-Control: set the native CacheControl field on PutObject and restore it on download. For CDN-fronted objects, use the short-TTL value from "Download flow" above (public, max-age=86400), not a long-lived or immutable value. The value stored at upload must match the file's access model — public, max-age=86400 only in CDN-fronted (public) buckets; for service-API-only files — so restoring it on download is always ruleset-consistent (the mandatory public/private bucket split in "Hard requirements" is what guarantees a bucket never mixes the two).

Helm chart contract

The service chart must support both credential modes, selected purely by values (mirroring the SDK credential chain — no code change):

Mode	When	Chart behavior
Static credentials	Local (nats-s3 sidecar)	AWS_ACCESS_KEY_ID / AWS_SECRET_ACCESS_KEY injected from a Secret (inline values or existingSecret).
Role-based (IRSA)	Deployed (AWS S3 on EKS)	No credential env vars — only AWS_REGION. SDK discovers the projected web-identity token.

Chart requirements:

• Externally managed ServiceAccount support: serviceAccount.create: false plus serviceAccount.name, so the chart references — rather than renders — a ServiceAccount created outside the chart. In deployed environments the IRSA-annotated ServiceAccount is created in the lfx-v2-argocd deployment manifests (that is where the eks.amazonaws.com/role-arn annotation lives); the chart never applies the annotation itself in this mode. This is a prerequisite for deployed environments.

• s3.endpointURL value mapped to S3_ENDPOINT_URL (empty = real AWS).

• s3.createMissingBucket value mapped to S3_CREATE_MISSING_BUCKET, true only in local values (never in deployed values, regardless of whether s3.endpointURL happens to be set there too).

• nats-s3 sidecar block for local mode: a second container in the service pod listening on localhost:5222 (loopback only), translating SigV4-signed S3 calls into NATS JetStream Object Store operations. The chart renders a locally generated SigV4 key pair into a credentials.json Secret mounted at /etc/nats-s3 and injects the same pair as AWS env vars into the service container — for example:

  natsS3:
    enabled: true
    credentials:
      accessKey: "local-dev-access-key"
      secretKey: "local-dev-secret-key"
  

• cdnURLPrefix value mapped to CDN_URL_PREFIX.

A service may need more than one bucket (and CDN prefix) — and must use separate buckets when it has both a CDN-fronted public use case and a service-API-only private use case (see "Hard requirements"). Repeat the above per bucket, using the env var namespacing convention below.

The platform umbrella chart (lfx-v2-helm) sets the nats-s3 sidecar values as the local-mode default for service charts; deployed values (IRSA role ARN, real bucket name, CDN prefix) come from lfx-v2-argocd.

Local development stack

No AWS account required. Two components:

1. nats-s3 sidecar (per service pod): the S3-compatible write/read backend at http://localhost:5222, backed by NATS Object Store in the local cluster. Requires a locally generated SigV4 credential pair (see above) — not an AWS account, but not "zero credentials" either.
2. nginx-s3-gateway (umbrella chart): a local stand-in for the production CDN shape, demonstrating the public_url pattern end to end.

Local CDN model (nginx-s3-gateway)

The umbrella chart deploys a standalone pair, independent of any service's sidecar:

• A dedicated, cluster-reachable nats-s3 instance (Deployment+Service) per bucket needing a CDN-fronted public URL locally — the "private bucket" the local CDN gateway fronts. (Separate from service sidecars, which are loopback-only.) A service with more than one CDN-fronted bucket needs one of these per bucket.
• An nginx-s3-gateway Deployment that proxies unauthenticated GET requests to that backend, signing them with SigV4 on the way through — matching the private-origin, signing-proxy, edge-cache shape used in deployed environments, without naming a specific deployed CDN product here.

CDN_URL_PREFIX must always be a browser-reachable URL — this is a hard requirement of the contract, local or deployed, since it ends up directly in public_url responses consumed by clients. The gateway's bare in-cluster Service name does not satisfy this and must not be used as the value directly.

Expose the gateway the same way every other local service is reached: an IngressRoute on the platform's k8s.orb.local wildcard domain (matching lfx-v2-helm's lfx-platform chart pattern, for example https://<service>-cdn.k8s.orb.local), routed through Traefik. Set CDN_URL_PREFIX to that address. A manual kubectl port-forward can stand in for one-off testing, but it does not give a stable value a service can commit to its local chart values, so it is not a substitute for the IngressRoute.

Setting CDN_URL_PREFIX="" omits public_url entirely and clients fall back to the service's authenticated download route — a valid degraded mode, and the simplest option until that ingress wiring exists.

Example gateway container env, illustrating the required variables:

env:
  - name: S3_BUCKET_NAME
    value: "my-service-objects"
  - name: S3_SERVER
    value: "my-service-nats-s3.my-namespace.svc.cluster.local" # FQDN required
  - name: S3_SERVER_PORT
    value: "5222"
  - name: S3_SERVER_PROTO
    value: "http"
  - name: S3_REGION
    value: "us-west-2"
  - name: S3_STYLE
    value: "path"
  - name: S3_SERVICE
    value: "s3"
  - name: ALLOW_DIRECTORY_LIST
    value: "false"
  - name: AWS_SIGS_VERSION
    value: "4"
  - name: CORS_ENABLED
    value: "false"
  - name: AWS_ACCESS_KEY_ID # must match the fronted nats-s3 instance's pair
     
    
     
  
  

Notes on the fields above:

• Image: ghcr.io/nginx/nginx-s3-gateway/nginx-oss-s3-gateway (the org moved from nginxinc); use an unprivileged-oss-* tag (non-root, port 8080).
• S3_SERVER must be the fully qualified in-cluster name — nginx's async resolver does not apply /etc/resolv.conf search suffixes the way libc-based tools do, so a short Service name resolves via kubectl exec ... curl but fails inside nginx itself.
• Use AWS_ACCESS_KEY_ID / AWS_SECRET_ACCESS_KEY, not the deprecated S3_ACCESS_KEY_ID / S3_SECRET_KEY.

Environment variable contract

The values/env contract every object-storing service chart exposes (per bucket — see "Multi-bucket namespacing" below for how the names scale when a service owns more than one):

Variable	Required	Description
S3_BUCKET	yes	Bucket name. Local default may be chart-derived; deployed value comes from lfx-v2-argocd.
AWS_REGION	yes	AWS region. Any non-empty string is accepted by nats-s3; us-west-2 is the conventional local default, matching the deployed environment's region. No code fallback — required, like S3_BUCKET.
S3_ENDPOINT_URL	no	Endpoint override. Local: http://localhost:5222 (sidecar). Empty: real AWS S3. Also used for non-AWS S3-compatible backends — do not use its presence to infer "local".
S3_CREATE_MISSING_BUCKET	no	Explicit boolean gate for the service calling CreateBucket at startup. true only in local values. false/unset everywhere else, including any deployed environment that happens to set S3_ENDPOINT_URL.
CDN_URL_PREFIX	no	Public, browser-reachable CDN base URL interpolated into public_url responses — never an in-cluster-only address. Local: an IngressRoute address on k8s.orb.local for the nginx-s3-gateway. Empty: omit public_url.
AWS_ACCESS_KEY_ID / AWS_SECRET_ACCESS_KEY	local only	Injected by the chart in static-credential mode. Never set in deployed environments (IRSA).

This is a contract, not an implementation recipe: env vars injected via the chart's env: block are the platform standard, but how the service reads them (plain os.Getenv, koanf, viper, etc.) follows the owning repo's local conventions.

Multi-bucket namespacing

The fixed names above are the single-bucket case. A process cannot resolve two values for S3_BUCKET, so a service that owns more than one bucket namespaces the bucket-scoped variables with an uppercase purpose token as a prefix, keeping the suffix contract identical:

LOGOS_S3_BUCKET            ATTACHMENTS_S3_BUCKET
LOGOS_S3_ENDPOINT_URL      ATTACHMENTS_S3_ENDPOINT_URL
LOGOS_S3_CREATE_MISSING_BUCKET
LOGOS_CDN_URL_PREFIX       # public bucket only; private buckets have none

Process-wide variables (AWS_REGION, AWS_ACCESS_KEY_ID / AWS_SECRET_ACCESS_KEY) are not namespaced — they apply to every bucket the service touches. The chart values mirror the same structure (for example, a map of bucket entries keyed by purpose instead of a single s3: block).

What this skill is not

• Not a provisioning guide. Buckets, CloudFront, wildcard certs, and IRSA roles are provisioned via /lfx-skills:lfx-object-store-ops.
• Not an FGA modeling guide. Relation shapes per service live in the owning service's FGA contract docs.
• Not a Goa or Go conventions guide. The owning repo's path-scoped dev skill governs implementation style.
• Not a NATS Object Store guide. NATS Object Store should not be used directly (other than as the backend to nats-s3) for object storage in LFX.

Handoff boundary

Once routed to the owning service repo, its local AGENTS.md/CLAUDE.md, docs/, and repo-local skills control implementation detail. For backend provisioning (bucket, CDN, IAM), hand off to /lfx-skills:lfx-object-store-ops.