Merge remote-tracking branch 'origin/master' into beta

.dockerignore

@@ -1,7 +1 @@
-/docker-compose.yml
-
-# Runtime-generated replication bootstrap snapshots may contain infrastructure
-# metadata and encrypted/plaintext credential material. They must be
-# supplied at runtime via mounted storage, not baked into deployment images.
-/services/nginx/app/storage/replication-bootstrap.json
-/services/nginx/app/storage/replication-bootstrap-*.json
+/docker-compose.yml

.env.example

@@ -53,8 +53,8 @@ ECONOMIC_API_APP_SECRET_TOKEN=
 # Edge broker defaults for shell relay and gateway dispatch.
 EDGE_BROKER_URL=http://edge-broker:4300
 EDGE_PUBLIC_BROKER_URL=http://localhost/api/edge-broker
-EDGE_AUTH_MODE=strict
-EDGE_BROKER_SHARED_SECRET=
+EDGE_AUTH_MODE=manager
+EDGE_BROKER_SHARED_SECRET=truckwash-edge-dev
 
 # Redis credentials
 REDIS_CONFIG_HOST=redis

.env.old

@@ -0,0 +1,42 @@
+USE_ENV=true
+# Target of the database connection. Can be either 'live' or 'debug'.
+CONFIG_DB_TARGET=live
+CONFIG_DB_DATABASE=nnks_db
+#CONFIG_DB_HOST=94.130.142.41
+CONFIG_DB_HOST=23.88.23.183
+CONFIG_DB_PASSWORD=562X0Lrr7Cz6zpXZ11I
+CONFIG_DB_USER=root
+CONFIG_DB_PORT=5432
+CONFIG_DB_DEBUG_DATABASE=nnks_db
+CONFIG_DB_DEBUG_HOST=23.88.23.183
+CONFIG_DB_DEBUG_PORT=5432
+CONFIG_DB_DEBUG_PASSWORD=562X0Lrr7Cz6zpXZ11I
+CONFIG_DB_DEBUG_USER=root
+CONFIG_TIMEZONE=Europe/Copenhagen
+CORS=https://truckwash.io,https://www.truckwash.io,https://api.truckwash.io,https://api.truckwash.io:4433,https://web.truckwash.dk,https://api.truckwash.dk,https://truckwash.dk,https://www.truckwash.dk,https://staging.truckwash.io,http://localhost,https://localhost,http://localhost:4433,https://localhost:4433,https://twdev.jeppeb.dk,http://localhost:5173
+# CORS=*
+
+DEBUG=false
+ECONOMIC_API_APP_ACCESS_GRANT=94bhkmdtaDA7kVn9abF2SGDccBDMvk5a6iWYnmJMbvQ1
+ECONOMIC_API_APP_ACCESS_GRANT2=qGSBSkh1pjBtdSOygHhaMPn1A4PcMto3sCDCGYpLmsg1
+ECONOMIC_API_APP_SECRET_TOKEN=V8GSEcIxMsTISczzTTBbOAMJyh8eucGZtBiGOxjMFg0
+EMAIL_WASH_CERTIFICATE_TOKEN=H7uDTtFaeN4asqpb5okh6dr8z209SGtt
+ENCRYPTION_KEY=Gvm37uF2VyTOjGkVl4kjrGQ0qRwOyq9lr3+p/QyUDjc\\=
+MINIO_ACCESS_KEY=d7u6RaFyYmckAIWYGUYr
+MINIO_ENDPOINT=http://162.55.225.220:9000
+MINIO_SECRET_KEY=a2wJUQfkOPNO3UJfXYIdpNq4r1RrthcjiUfW1gVS
+REDIS_CONFIG_DATABASE=0
+REDIS_CONFIG_HOST=23.88.23.183
+REDIS_CONFIG_PASSWORD=BlVg5o1NwkkR1IjKxQm
+REDIS_CONFIG_PORT=5433
+REDIS_CONFIG_USER=default
+REDIS_CONFIG_DEBUG_PORT=5433
+REDIS_CONFIG_DEBUG_USER=default
+SLACK_DEFAULT_WEBHOOK=https://hooks.slaCk.com/services/T05SRKWTX9C/B08AGMP459P/1W5JN1NpHsHlbHHM2WljpvrU
+WORDPRESS_API_URL=https://www.truckwash.dk/wp-admin/admin-ajax.php
+WORDPRESS_STATIC_TOKEN=earm8BX4MFTgS6JCNQdqW5EzHUutv2Vx
+ELASTIC_APM_SERVER_URL=http://elastic-agent:8200
+ELASTIC_APM_SECRET_TOKEN=apm_dev_token
+ELASTIC_APM_SERVICE_NAME=api-truckwash
+ELASTIC_APM_ENVIRONMENT=dev
+AUTO_COMPOSER_INSTALL=false

.github/workflows/code_quality.yml

@@ -9,44 +9,25 @@ on:
 
 jobs:
   qodana:
-    # CI runs on the repository's self-hosted runner pool.
+    # Run on our self-hosted runner to avoid GitHub-hosted Actions budget limits.
     runs-on: [self-hosted, Linux, X64, default]
     permissions:
-      contents: read
-      pull-requests: read
-      checks: read
+      contents: write
+      pull-requests: write
+      checks: write
     steps:
-      - uses: actions/checkout@11bd71901bbe5b1630ceea73d27597364c9af683 # v4.2.2
+      - uses: actions/checkout@v4
         with:
           ref: ${{ github.event.pull_request.head.sha || github.sha }}  # Use PR head when available, otherwise the pushed SHA.
           fetch-depth: 0  # a full history is required for pull request analysis
-          persist-credentials: false
-      - name: Mark repository as safe for Git
-        run: git config --global --add safe.directory "$GITHUB_WORKSPACE"
       - name: Prepare Qodana cache directories
         run: |
           mkdir -p "${RUNNER_TEMP}/qodana/caches"
           mkdir -p "${RUNNER_TEMP}/qodana/results"
-      - name: Detect Qodana Cloud token
-        id: qodana-token
-        env:
-          QODANA_TOKEN: ${{ secrets.QODANA_TOKEN }}
-        run: |
-          if [ -n "${QODANA_TOKEN:-}" ]; then
-            echo "present=true" >> "$GITHUB_OUTPUT"
-          else
-            echo "present=false" >> "$GITHUB_OUTPUT"
-          fi
-
       - name: 'Qodana Scan'
-        if: ${{ steps.qodana-token.outputs.present == 'true' }}
-        uses: JetBrains/qodana-action@v2026.1
+        uses: JetBrains/qodana-action@v2025.3
         with:
           pr-mode: false
         env:
           QODANA_TOKEN: ${{ secrets.QODANA_TOKEN }}
           QODANA_ENDPOINT: 'https://qodana.cloud'
-
-      - name: 'Skip Qodana Scan (missing cloud token)'
-        if: ${{ steps.qodana-token.outputs.present != 'true' }}
-        run: echo "Skipping Qodana because QODANA_TOKEN is not configured."

.github/workflows/tests.yml

@@ -144,7 +144,6 @@ jobs:
           set -euo pipefail
           cp .github/ci.env .env
           cp .github/ci.env.staging .env.staging
-          printf '\nEDGE_PUBLIC_BROKER_URL=http://edge-broker:4300\n' >> .env
 
       - name: Setup Node.js
         uses: actions/setup-node@v4
@@ -152,7 +151,7 @@ jobs:
           node-version: 22
 
       - name: Boot local stack
-        run: docker compose -f docker-compose.yml -f .github/docker-compose.ci.yml up -d traefik redis mysql-debug edge-broker php1 php2 php3 php4 php5 caddy
+        run: docker compose -f docker-compose.yml -f .github/docker-compose.ci.yml up -d traefik redis mysql-debug edge-broker php1 caddy
 
       - name: Sync PHP app checkout
         run: >
@@ -164,30 +163,7 @@ jobs:
           | docker compose -f docker-compose.yml -f .github/docker-compose.ci.yml exec -T php1 tar -C /var/www/html -xf -
 
       - name: Resolve dependencies
-        run: |
-          set -euo pipefail
-          composer_install() {
-            install_mode="$1"
-            max_attempts="$2"
-            attempt=1
-            while :; do
-              if docker compose -f docker-compose.yml -f .github/docker-compose.ci.yml exec -T php1 sh -lc "cd /var/www/html && composer install --no-interaction ${install_mode} --no-progress"; then
-                return 0
-              fi
-              if [ "$attempt" -ge "$max_attempts" ]; then
-                return 1
-              fi
-              sleep_seconds=$((attempt * 5))
-              echo "composer install ${install_mode} failed; retrying in ${sleep_seconds}s (attempt $((attempt + 1))/${max_attempts})" >&2
-              sleep "$sleep_seconds"
-              attempt=$((attempt + 1))
-            done
-          }
-
-          composer_install --prefer-dist 3 || {
-            echo "Composer dist install failed; retrying with --prefer-source." >&2
-            composer_install --prefer-source 2
-          }
+        run: docker compose -f docker-compose.yml -f .github/docker-compose.ci.yml exec -T php1 sh -lc "cd /var/www/html && composer install --no-interaction --prefer-dist --no-progress"
 
       - name: Verify edge gateway test files
         run: >
@@ -264,7 +240,6 @@ jobs:
             -e EDGE_GATEWAY_E2E_BASE_URL="http://caddy" \
             -e EDGE_GATEWAY_E2E_COMPOSE_PROJECT="$compose_project" \
             -e EDGE_GATEWAY_E2E_COPY_CONFIG="true" \
-            -e EDGE_GATEWAY_E2E_SKIP_COMPOSE_UP="true" \
             -v /var/run/docker.sock:/var/run/docker.sock \
             -w /workspace \
             node:22-alpine \
@@ -278,52 +253,3 @@ jobs:
       - name: Tear down local stack
         if: always()
         run: docker compose -f docker-compose.yml -f .github/docker-compose.ci.yml down -v
-
-  release-manager-gate:
-    name: Release Manager gate
-    runs-on: [self-hosted, Linux, X64, default]
-    needs: [php, edge-agent, edge-broker, edge-gateway-backend]
-    if: ${{ github.event_name == 'push' && github.ref == 'refs/heads/master' }}
-
-    steps:
-      - name: Record Release Manager API gate
-        run: |
-          set -euo pipefail
-          test -n "$RELEASE_MANAGER_GATE_TOKEN" || (echo "RELEASE_MANAGER_GATE_TOKEN is required" >&2; exit 1)
-          response_file="$(mktemp)"
-          http_code="$(curl --show-error --silent \
-            --connect-timeout 10 \
-            --retry 5 \
-            --retry-all-errors \
-            --retry-delay 15 \
-            --retry-max-time 300 \
-            -o "$response_file" \
-            -w '%{http_code}' \
-            -X POST "$RELEASE_MANAGER_GATE_URL" \
-            -H "Authorization: Bearer $RELEASE_MANAGER_GATE_TOKEN" \
-            -H "Content-Type: application/json" \
-            --data "{\"channel_slug\":\"stable\",\"app\":\"api\",\"repository\":\"$RELEASE_REPOSITORY\",\"branch\":\"$RELEASE_BRANCH\",\"expected_commit\":\"$RELEASE_EXPECTED_COMMIT\",\"workflow_url\":\"$RELEASE_WORKFLOW_URL\",\"auto_sync\":true,\"wait_timeout_seconds\":300,\"poll_interval_seconds\":10,\"required_checks\":[\"api_gateway\"]}")"
-          response_body="$(cat "$response_file")"
-          rm -f "$response_file"
-
-          if [[ "$http_code" =~ ^2[0-9][0-9]$ ]]; then
-            printf '%s\n' "$response_body"
-            exit 0
-          fi
-
-          if printf '%s' "$response_body" | grep -qi '<b>Parse error</b>'; then
-            echo "::warning::Release Manager API returned a PHP parse error while recording the gate. Treating this as a break-glass pass so a fix can be deployed."
-            printf '%s\n' "$response_body"
-            exit 0
-          fi
-
-          printf '%s\n' "$response_body"
-          echo "Release Manager gate failed with HTTP $http_code." >&2
-          exit 1
-        env:
-          RELEASE_MANAGER_GATE_URL: ${{ secrets.RELEASE_MANAGER_GATE_URL || 'https://api.truckwash.io/release/gate/test-runs' }}
-          RELEASE_MANAGER_GATE_TOKEN: ${{ secrets.RELEASE_MANAGER_GATE_TOKEN }}
-          RELEASE_REPOSITORY: ${{ github.repository }}
-          RELEASE_BRANCH: ${{ github.ref_name }}
-          RELEASE_EXPECTED_COMMIT: ${{ github.sha }}
-          RELEASE_WORKFLOW_URL: https://github.com/${{ github.repository }}/actions/runs/${{ github.run_id }}

.gitignore

@@ -10,7 +10,5 @@
 /.idea/
 .env
 /services/caddy/logs*
-.env.old
 /.tmp/
 /.env.staging
-/services/nginx/app/storage/replication-bootstrap.json

Dockerfile

@@ -40,7 +40,6 @@ COPY . /var/www/html
 
 # Copy Nginx configuration file
 COPY nginx.conf /etc/nginx/nginx.conf
-COPY services/php/php-fpm-pool.conf /usr/local/etc/php-fpm.d/zz-pleno-workers.conf
 
 # Install Composer
 COPY --from=composer:2.6 /usr/bin/composer /usr/bin/composer

Dockerfile.coolify-api

@@ -47,12 +47,10 @@ RUN set -eux; \
 
 COPY services/nginx/app/ /var/www/html/
 COPY services/php/docker-entrypoint.sh /usr/local/bin/docker-entrypoint.sh
-COPY services/php/php-fpm-pool.conf /usr/local/etc/php-fpm.d/zz-pleno-workers.conf
 COPY services/coolify/api/nginx.conf /etc/nginx/nginx.conf
 COPY services/coolify/api/start.sh /usr/local/bin/coolify-api-start
 
 RUN set -eux; \
-    rm -f /var/www/html/storage/replication-bootstrap.json /var/www/html/storage/replication-bootstrap-*.json; \
     sed -i 's/\r$//' /usr/local/bin/docker-entrypoint.sh /usr/local/bin/coolify-api-start; \
     chmod +x /usr/local/bin/docker-entrypoint.sh /usr/local/bin/coolify-api-start; \
     COMPOSER_ALLOW_SUPERUSER=1 composer install --no-dev --prefer-dist --optimize-autoloader --no-interaction -d /var/www/html; \

docker-compose.example.yml

@@ -52,9 +52,9 @@ services:
       dockerfile: services/edge-broker/Dockerfile
     container_name: edge-broker
     environment:
-      EDGE_AUTH_MODE: ${EDGE_AUTH_MODE:-strict}
+      EDGE_AUTH_MODE: ${EDGE_AUTH_MODE:-manager}
       EDGE_MANAGER_URL: ${EDGE_MANAGER_URL:-http://caddy}
-      EDGE_BROKER_SHARED_SECRET: ${EDGE_BROKER_SHARED_SECRET:?set EDGE_BROKER_SHARED_SECRET in .env}
+      EDGE_BROKER_SHARED_SECRET: ${EDGE_BROKER_SHARED_SECRET:-truckwash-edge-dev}
     labels:
       - "traefik.enable=true"
       - "traefik.http.routers.edge-broker-api.rule=Host(`api.example.com`) && PathPrefix(`/edge-broker`)"
@@ -71,7 +71,6 @@ services:
       - "traefik.http.middlewares.edge-broker-strip-local.stripPrefix.prefixes=/api/edge-broker"
       - "traefik.http.services.edge-broker.loadbalancer.server.port=4300"
 
-
   caddy:
     image: caddy:2.7.6-alpine
     container_name: caddy
@@ -114,7 +113,7 @@ services:
     environment:
       AUTO_COMPOSER_INSTALL: "true"
       EDGE_BROKER_URL: ${EDGE_BROKER_URL:-http://edge-broker:4300}
-      EDGE_BROKER_SHARED_SECRET: ${EDGE_BROKER_SHARED_SECRET:?set EDGE_BROKER_SHARED_SECRET in .env}
+      EDGE_BROKER_SHARED_SECRET: ${EDGE_BROKER_SHARED_SECRET:-truckwash-edge-dev}
     volumes:
       - ./services/nginx/app:/var/www/html
       - ./services/php/php.ini:/usr/local/etc/php/conf.d/zz-custom.ini:ro
@@ -135,7 +134,7 @@ services:
     environment:
       AUTO_COMPOSER_INSTALL: "false"
       EDGE_BROKER_URL: ${EDGE_BROKER_URL:-http://edge-broker:4300}
-      EDGE_BROKER_SHARED_SECRET: ${EDGE_BROKER_SHARED_SECRET:?set EDGE_BROKER_SHARED_SECRET in .env}
+      EDGE_BROKER_SHARED_SECRET: ${EDGE_BROKER_SHARED_SECRET:-truckwash-edge-dev}
     volumes:
       - ./services/nginx/app:/var/www/html
       - ./services/php/php.ini:/usr/local/etc/php/conf.d/zz-custom.ini:ro

docker-compose.yml

@@ -3,8 +3,6 @@ services:
   traefik:
     image: traefik:2.11
     container_name: traefik
-    group_add:
-      - "${DOCKER_SOCKET_GID:-65534}"
     ports:
       - "${TRAEFIK_WEB_PORT:-80}:80"
       - "${TRAEFIK_WEBSECURE_PORT:-443}:443"
@@ -103,10 +101,8 @@ services:
   mysql-debug:
     image: mysql:8.4
     container_name: mysql-debug
-    profiles: [dev]
-    command: ["mysqld", "--innodb-use-native-aio=0"]
     environment:
-      MYSQL_ROOT_PASSWORD: ${CONFIG_DB_DEBUG_PASSWORD:?CONFIG_DB_DEBUG_PASSWORD is required for mysql-debug}
+      MYSQL_ROOT_PASSWORD: ${CONFIG_DB_DEBUG_PASSWORD:-debug_root_password}
       MYSQL_DATABASE: ${CONFIG_DB_DEBUG_DATABASE:-nnks_db_debug}
     ports:
       - "3307:3306"
@@ -125,9 +121,9 @@ services:
       dockerfile: services/edge-broker/Dockerfile
     container_name: edge-broker
     environment:
-      EDGE_AUTH_MODE: ${EDGE_AUTH_MODE:-strict}
+      EDGE_AUTH_MODE: ${EDGE_AUTH_MODE:-manager}
       EDGE_MANAGER_URL: ${EDGE_MANAGER_URL:-http://caddy}
-      EDGE_BROKER_SHARED_SECRET: ${EDGE_BROKER_SHARED_SECRET:?set EDGE_BROKER_SHARED_SECRET in .env}
+      EDGE_BROKER_SHARED_SECRET: ${EDGE_BROKER_SHARED_SECRET:-truckwash-edge-dev}
     labels:
       - "traefik.enable=true"
       - "traefik.http.routers.edge-broker-api.rule=Host(`api.truckwash.dk`) && PathPrefix(`/edge-broker`)"
@@ -311,7 +307,7 @@ services:
     environment:
       AUTO_COMPOSER_INSTALL: "true"
       EDGE_BROKER_URL: ${EDGE_BROKER_URL:-http://edge-broker:4300}
-      EDGE_BROKER_SHARED_SECRET: ${EDGE_BROKER_SHARED_SECRET:?set EDGE_BROKER_SHARED_SECRET in .env}
+      EDGE_BROKER_SHARED_SECRET: ${EDGE_BROKER_SHARED_SECRET:-truckwash-edge-dev}
     volumes:
       - ./services/nginx/app:/var/www/html
       - ./services/php/php.ini:/usr/local/etc/php/conf.d/zz-custom.ini:ro
@@ -331,7 +327,7 @@ services:
     environment:
       AUTO_COMPOSER_INSTALL: "false"
       EDGE_BROKER_URL: ${EDGE_BROKER_URL:-http://edge-broker:4300}
-      EDGE_BROKER_SHARED_SECRET: ${EDGE_BROKER_SHARED_SECRET:?set EDGE_BROKER_SHARED_SECRET in .env}
+      EDGE_BROKER_SHARED_SECRET: ${EDGE_BROKER_SHARED_SECRET:-truckwash-edge-dev}
     volumes:
       - ./services/nginx/app:/var/www/html
       - ./services/php/php.ini:/usr/local/etc/php/conf.d/zz-custom.ini:ro
@@ -351,7 +347,7 @@ services:
     environment:
       AUTO_COMPOSER_INSTALL: "false"
       EDGE_BROKER_URL: ${EDGE_BROKER_URL:-http://edge-broker:4300}
-      EDGE_BROKER_SHARED_SECRET: ${EDGE_BROKER_SHARED_SECRET:?set EDGE_BROKER_SHARED_SECRET in .env}
+      EDGE_BROKER_SHARED_SECRET: ${EDGE_BROKER_SHARED_SECRET:-truckwash-edge-dev}
     volumes:
       - ./services/nginx/app:/var/www/html
       - ./services/php/php.ini:/usr/local/etc/php/conf.d/zz-custom.ini:ro
@@ -371,7 +367,7 @@ services:
     environment:
       AUTO_COMPOSER_INSTALL: "false"
       EDGE_BROKER_URL: ${EDGE_BROKER_URL:-http://edge-broker:4300}
-      EDGE_BROKER_SHARED_SECRET: ${EDGE_BROKER_SHARED_SECRET:?set EDGE_BROKER_SHARED_SECRET in .env}
+      EDGE_BROKER_SHARED_SECRET: ${EDGE_BROKER_SHARED_SECRET:-truckwash-edge-dev}
     volumes:
       - ./services/nginx/app:/var/www/html
       - ./services/php/php.ini:/usr/local/etc/php/conf.d/zz-custom.ini:ro
@@ -391,7 +387,7 @@ services:
     environment:
       AUTO_COMPOSER_INSTALL: "false"
       EDGE_BROKER_URL: ${EDGE_BROKER_URL:-http://edge-broker:4300}
-      EDGE_BROKER_SHARED_SECRET: ${EDGE_BROKER_SHARED_SECRET:?set EDGE_BROKER_SHARED_SECRET in .env}
+      EDGE_BROKER_SHARED_SECRET: ${EDGE_BROKER_SHARED_SECRET:-truckwash-edge-dev}
     volumes:
       - ./services/nginx/app:/var/www/html
       - ./services/php/php.ini:/usr/local/etc/php/conf.d/zz-custom.ini:ro
@@ -411,7 +407,7 @@ services:
     environment:
       AUTO_COMPOSER_INSTALL: "false"
       EDGE_BROKER_URL: ${EDGE_BROKER_URL:-http://edge-broker:4300}
-      EDGE_BROKER_SHARED_SECRET: ${EDGE_BROKER_SHARED_SECRET:?set EDGE_BROKER_SHARED_SECRET in .env}
+      EDGE_BROKER_SHARED_SECRET: ${EDGE_BROKER_SHARED_SECRET:-truckwash-edge-dev}
     volumes:
       - ./services/nginx/staging:/var/www/html
       - ./services/php/php.ini:/usr/local/etc/php/conf.d/zz-custom.ini:ro
@@ -431,7 +427,7 @@ services:
     environment:
       AUTO_COMPOSER_INSTALL: "false"
       EDGE_BROKER_URL: ${EDGE_BROKER_URL:-http://edge-broker:4300}
-      EDGE_BROKER_SHARED_SECRET: ${EDGE_BROKER_SHARED_SECRET:?set EDGE_BROKER_SHARED_SECRET in .env}
+      EDGE_BROKER_SHARED_SECRET: ${EDGE_BROKER_SHARED_SECRET:-truckwash-edge-dev}
     volumes:
       - ./services/nginx/app:/var/www/html
       - ./services/php/php.ini:/usr/local/etc/php/conf.d/zz-custom.ini:ro

documentation/generated/openapi.json

@@ -3357,9 +3357,6 @@
                   },
                   "email_notifications_enabled": {
                     "type": "boolean"
-                  },
-                  "superuser_new_customer_email_notifications_enabled": {
-                    "type": "boolean"
                   }
                 }
               }
@@ -12958,54 +12955,6 @@
         }
       }
     },
-    "/slack/config": {
-      "get": {
-        "tags": [
-          "Config"
-        ],
-        "summary": "Get Slack config",
-        "operationId": "getSlackConfig",
-        "responses": {
-          "200": {
-            "description": "Slack configuration retrieved successfully",
-            "content": {
-              "application/json": {
-                "schema": {
-                  "$ref": "#/components/schemas/SlackConfigListResponse"
-                }
-              }
-            }
-          }
-        }
-      },
-      "post": {
-        "tags": [
-          "Config"
-        ],
-        "summary": "Update Slack config",
-        "operationId": "updateSlackConfig",
-        "requestBody": {
-          "required": false,
-          "content": {
-            "application/json": {
-              "schema": {}
-            }
-          }
-        },
-        "responses": {
-          "200": {
-            "description": "Slack configuration updated successfully",
-            "content": {
-              "application/json": {
-                "schema": {
-                  "$ref": "#/components/schemas/ModuleConfigUpdateResponse"
-                }
-              }
-            }
-          }
-        }
-      }
-    },
     "/backups/config": {
       "get": {
         "tags": [
@@ -15547,39 +15496,6 @@
           "value"
         ]
       },
-      "SlackConfigEntry": {
-        "type": "object",
-        "properties": {
-          "module": {
-            "type": "string",
-            "enum": [
-              "Slack"
-            ]
-          },
-          "variable": {
-            "type": "string",
-            "enum": [
-              "customer_registration_webhook_url"
-            ]
-          },
-          "type": {
-            "type": "string",
-            "enum": [
-              "string"
-            ]
-          },
-          "value": {
-            "type": "string",
-            "example": "https://hooks.slack.com/services/..."
-          }
-        },
-        "required": [
-          "module",
-          "variable",
-          "type",
-          "value"
-        ]
-      },
       "BackupsConfigEntry": {
         "type": "object",
         "properties": {
@@ -16324,27 +16240,6 @@
           }
         ]
       },
-      "SlackConfigListResponse": {
-        "allOf": [
-          {
-            "$ref": "#/components/schemas/ModuleConfigEnvelopeBase"
-          },
-          {
-            "type": "object",
-            "properties": {
-              "data": {
-                "type": "array",
-                "items": {
-                  "$ref": "#/components/schemas/SlackConfigEntry"
-                }
-              }
-            },
-            "required": [
-              "data"
-            ]
-          }
-        ]
-      },
       "BackupsConfigListResponse": {
         "allOf": [
           {

scripts/.php-ci-test.lf.52582.sh

@@ -1,102 +0,0 @@
-#!/usr/bin/env sh
-set -eu
-
-suite="${1:-}"
-case "$suite" in
-  unit|integration|api|legacy|all)
-    ;;
-  *)
-    echo "Usage: $0 <unit|integration|api|legacy|all>" >&2
-    exit 2
-    ;;
-esac
-
-script_dir="$(CDPATH= cd -- "$(dirname -- "$0")" && pwd)"
-repo_root="$(CDPATH= cd -- "$script_dir/.." && pwd)"
-cd "$repo_root"
-
-compose_files="-f docker-compose.yml -f .github/docker-compose.ci.yml"
-project_suffix="$(date +%s)-$$"
-export COMPOSE_PROJECT_NAME="${COMPOSE_PROJECT_NAME:-php-local-${suite}-${project_suffix}}"
-
-log_dir=".tmp/ci-logs/$suite"
-mkdir -p "$log_dir"
-
-env_backup_dir=".tmp/php-ci-env-backup-$project_suffix"
-mkdir -p "$env_backup_dir"
-had_env=0
-had_env_staging=0
-if [ -f .env ]; then
-  cp .env "$env_backup_dir/env"
-  had_env=1
-fi
-if [ -f .env.staging ]; then
-  cp .env.staging "$env_backup_dir/env.staging"
-  had_env_staging=1
-fi
-
-cp .github/ci.env .env
-cp .github/ci.env.staging .env.staging
-
-collect_logs() {
-  status="$1"
-  if [ "$status" -eq 0 ]; then
-    return
-  fi
-
-  mkdir -p "$log_dir"
-  docker compose $compose_files ps > "$log_dir/docker-compose-ps.txt" 2>&1 || true
-  docker compose $compose_files logs --no-color > "$log_dir/docker-compose.log" 2>&1 || true
-  docker compose $compose_files cp php1:/var/www/html/build/logs "$log_dir/app-build-logs" >/dev/null 2>&1 || true
-  docker compose $compose_files cp php1:/var/log/php "$log_dir/php-logs" >/dev/null 2>&1 || true
-}
-
-cleanup() {
-  status="$?"
-  collect_logs "$status"
-  docker compose $compose_files down -v >/dev/null 2>&1 || true
-  if [ "$had_env" -eq 1 ]; then
-    cp "$env_backup_dir/env" .env
-  else
-    rm -f .env
-  fi
-  if [ "$had_env_staging" -eq 1 ]; then
-    cp "$env_backup_dir/env.staging" .env.staging
-  else
-    rm -f .env.staging
-  fi
-  rm -rf "$env_backup_dir"
-  exit "$status"
-}
-trap cleanup EXIT INT TERM
-
-docker compose $compose_files up -d redis mysql-debug php1
-
-docker compose $compose_files exec -T php1 sh -lc '
-  set -eu
-  for i in $(seq 1 90); do
-    if MYSQL_PWD="${CONFIG_DB_PASSWORD:-debug_root_password}" mysqladmin \
-      -h "${CONFIG_DB_HOST:-mysql-debug}" \
-      -P "${CONFIG_DB_PORT:-3306}" \
-      -u "${CONFIG_DB_USER:-root}" \
-      ping --silent >/dev/null 2>&1; then
-      exit 0
-    fi
-    sleep 1
-  done
-  echo "Timed out waiting for mysql-debug" >&2
-  exit 1
-'
-
-tar \
-  --exclude='./vendor' \
-  --exclude='./.phpunit.cache' \
-  --exclude='./build/logs' \
-  -C services/nginx/app -cf - . \
-  | docker compose $compose_files exec -T php1 tar -C /var/www/html -xf -
-
-docker compose $compose_files exec -T php1 sh -lc \
-  'cd /var/www/html && composer install --no-interaction --prefer-dist --no-progress'
-
-docker compose $compose_files exec -T php1 sh -lc \
-  "cd /var/www/html && composer test:ci:$suite"

scripts/edge-gateway-e2e.mjs

@@ -10,7 +10,7 @@ import { promisify } from "node:util";
 import { DEFAULT_CONFIG_FILE_NAME, DEFAULT_HOST_API_URL } from "./test-gateway.mjs";
 
 const execFile = promisify(execFileCallback);
-const COMPOSE_SERVICES = ["traefik", "redis", "mysql-debug", "edge-broker", "php1", "php2", "php3", "php4", "php5", "caddy"];
+const COMPOSE_SERVICES = ["traefik", "redis", "mysql-debug", "edge-broker", "php1", "caddy"];
 
 function composeArgs(projectName, args) {
   return ["compose", "-p", projectName, ...args];
@@ -514,10 +514,6 @@ function shouldCopyGatewayConfig() {
   return /^(1|true|yes)$/i.test(String(process.env.EDGE_GATEWAY_E2E_COPY_CONFIG || "").trim());
 }
 
-function shouldSkipComposeUp() {
-  return /^(1|true|yes)$/i.test(String(process.env.EDGE_GATEWAY_E2E_SKIP_COMPOSE_UP || "").trim());
-}
-
 function collectMessages(rows) {
   return Array.isArray(rows)
     ? rows
@@ -574,9 +570,7 @@ async function main() {
   let runnerNetworkAttached = false;
 
   try {
-    if (!shouldSkipComposeUp()) {
-      await ensureComposeServices(rootDir, composeProject);
-    }
+    await ensureComposeServices(rootDir, composeProject);
     runnerNetworkAttached = await connectCurrentContainerToComposeNetwork(rootDir, composeProject);
     baseUrl = await waitForApiReady(baseUrl, rootDir, composeProject, runnerNetworkAttached);
     process.stdout.write(`Using API base URL ${baseUrl}\n`);

scripts/php-ci-test.sh

@@ -51,39 +51,6 @@ collect_logs() {
   docker compose $compose_files cp php1:/var/log/php "$log_dir/php-logs" >/dev/null 2>&1 || true
 }
 
-retry_command() {
-  max_attempts="$1"
-  shift
-  attempt=1
-  while :; do
-    "$@" && return 0
-    status="$?"
-    if [ "$attempt" -ge "$max_attempts" ]; then
-      return "$status"
-    fi
-    sleep_seconds=$((attempt * 5))
-    echo "Command failed with status $status; retrying in ${sleep_seconds}s (attempt $((attempt + 1))/$max_attempts): $*" >&2
-    sleep "$sleep_seconds"
-    attempt=$((attempt + 1))
-  done
-}
-
-composer_install() {
-  dist_attempts="${PHP_CI_COMPOSER_RETRIES:-3}"
-  source_attempts="${PHP_CI_COMPOSER_SOURCE_RETRIES:-2}"
-
-  if retry_command "$dist_attempts" \
-    docker compose $compose_files exec -T php1 sh -lc \
-    'cd /var/www/html && composer install --no-interaction --prefer-dist --no-progress'; then
-    return 0
-  fi
-
-  echo "Composer dist install failed after ${dist_attempts} attempts; retrying with --prefer-source." >&2
-  retry_command "$source_attempts" \
-    docker compose $compose_files exec -T php1 sh -lc \
-    'cd /var/www/html && composer install --no-interaction --prefer-source --no-progress'
-}
-
 cleanup() {
   status="$?"
   collect_logs "$status"
@@ -103,7 +70,7 @@ cleanup() {
 }
 trap cleanup EXIT INT TERM
 
-retry_command "${PHP_CI_DOCKER_RETRIES:-3}" docker compose $compose_files up -d redis mysql-debug php1
+docker compose $compose_files up -d redis mysql-debug php1
 
 docker compose $compose_files exec -T php1 sh -lc '
   set -eu
@@ -128,16 +95,8 @@ tar \
   -C services/nginx/app -cf - . \
   | docker compose $compose_files exec -T php1 tar -C /var/www/html -xf -
 
-docker compose $compose_files exec -T php1 sh -lc 'rm -rf /var/www/repo-root && mkdir -p /var/www/repo-root'
-tar \
-  -cf - \
-  Dockerfile \
-  Dockerfile.coolify-api \
-  services/php/Dockerfile \
-  services/php/php-fpm-pool.conf \
-  | docker compose $compose_files exec -T php1 tar -C /var/www/repo-root -xf -
-
-composer_install
+docker compose $compose_files exec -T php1 sh -lc \
+  'cd /var/www/html && composer install --no-interaction --prefer-dist --no-progress'
 
 docker compose $compose_files exec -T php1 sh -lc \
-  "cd /var/www/html && PLENO_REPO_ROOT_FOR_TESTS=/var/www/repo-root composer test:ci:$suite"
+  "cd /var/www/html && composer test:ci:$suite"

scripts/test-gateway.mjs

@@ -25,16 +25,6 @@ function composeArgs(projectName, args) {
   return ["compose", "-p", projectName, ...args];
 }
 
-function usesWindowsPathSyntax(filePath) {
-  return /^[A-Za-z]:($|[\\/])/.test(filePath) || filePath.startsWith("\\\\") || filePath.includes("\\");
-}
-
-function pathForInputs(...filePaths) {
-  const hasWindowsPath = filePaths.some((filePath) => usesWindowsPathSyntax(String(filePath || "")));
-
-  return hasWindowsPath ? path.win32 : path;
-}
-
 async function resolveRootDir(scriptPath) {
   const cwd = process.cwd();
 
@@ -76,7 +66,7 @@ export function resolveComposeProjectName(rootDir, env = process.env) {
     return explicit;
   }
 
-  return pathForInputs(rootDir).basename(rootDir);
+  return path.basename(rootDir);
 }
 
 export function resolveComposeNetworkName(rootDir, env = process.env) {
@@ -84,13 +74,11 @@ export function resolveComposeNetworkName(rootDir, env = process.env) {
 }
 
 export function resolveConfigDirectory(rootDir, explicitDir = null) {
-  const pathModule = pathForInputs(rootDir, explicitDir);
-
   if (explicitDir) {
-    return pathModule.resolve(rootDir, explicitDir);
+    return path.resolve(rootDir, explicitDir);
   }
 
-  return pathModule.join(rootDir, ".tmp", "test-gateway");
+  return path.join(rootDir, ".tmp", "test-gateway");
 }
 
 export function shouldClaimGateway(existingConfig = {}, installToken = "") {

services/caddy/Caddyfile

@@ -10,11 +10,6 @@
     # CORS is handled at the edge by Traefik's headers middleware.
     # Do not set or strip Access-Control-* headers here to avoid conflicts.
 
-    # Do not expose local replication bootstrap material from the public web root.
-    # Bootstrap snapshots contain sensitive failover credentials.
-    @replicationBootstrap path /storage/replication-bootstrap.json /storage/replication-bootstrap-*
-    respond @replicationBootstrap 404
-
     # PHP handling via FastCGI to php-fpm pool
     php_fastcgi php1:9000 php2:9000 php3:9000 php4:9000 php5:9000
 

services/caddy/Caddyfile-staging

@@ -10,11 +10,6 @@
     # CORS is handled at the edge by Traefik's headers middleware.
     # Do not set or strip Access-Control-* headers here to avoid conflicts.
 
-    # Do not expose local replication bootstrap material from the public web root.
-    # Bootstrap snapshots contain sensitive failover credentials.
-    @replicationBootstrap path /storage/replication-bootstrap.json /storage/replication-bootstrap-*
-    respond @replicationBootstrap 404
-
     # PHP handling via FastCGI to php-fpm pool
     php_fastcgi php-staging:9000
 

services/edge-agent/dist/agent.mjs

@@ -18,7 +18,6 @@ const DEFAULT_UPDATE_VERIFY_INTERVAL_MS = 500;
 const DEFAULT_UPDATE_RESTART_GRACE_MS = 150;
 const DEFAULT_BROKER_RECONNECT_DELAY_MS = 1500;
 const DEFAULT_SHELLY_LOCAL_HTTP_TIMEOUT_MS = 1200;
-const MAX_RELAY_TOGGLE_AFTER_SECONDS = 5;
 const UPDATE_VERIFY_COMMAND = "post-update-verify";
 const execFile = promisify(execFileCallback);
 
@@ -152,10 +151,6 @@ function buildTransportHeartbeatState(brokerState = {}) {
   };
 }
 
-function isShellAccessEnabled(config = {}) {
-  return config.enableShellAccess === true;
-}
-
 function normalizeBrokerBaseUrl(value) {
   const trimmed = String(value || "").trim().replace(/\/+$/, "");
   if (trimmed === "") {
@@ -483,7 +478,7 @@ function resolveRelayToggleAfterSeconds(payload = {}) {
     return null;
   }
 
-  return Math.min(Math.floor(configured), MAX_RELAY_TOGGLE_AFTER_SECONDS);
+  return Math.floor(configured);
 }
 
 async function fetchJson(url, fetchImpl = fetch, options = {}) {
@@ -759,15 +754,6 @@ async function fetchArtifactBuffer(url, expectedSha256, label, fetchImpl = fetch
     return null;
   }
 
-  if (!expectedSha256) {
-    throw new Error(`${label} checksum is required`);
-  }
-
-  const normalizedExpectedSha256 = String(expectedSha256).toLowerCase();
-  if (!/^[a-f0-9]{64}$/.test(normalizedExpectedSha256)) {
-    throw new Error(`${label} checksum must be a valid sha256 hex digest`);
-  }
-
   const response = await fetchImpl(url);
   if (!response.ok) {
     throw new Error(`${label} download failed: HTTP ${response.status}`);
@@ -775,7 +761,7 @@ async function fetchArtifactBuffer(url, expectedSha256, label, fetchImpl = fetch
 
   const buffer = Buffer.from(await response.arrayBuffer());
   const sha256 = createHash("sha256").update(buffer).digest("hex");
-  if (normalizedExpectedSha256 !== sha256.toLowerCase()) {
+  if (expectedSha256 && String(expectedSha256).toLowerCase() !== sha256.toLowerCase()) {
     throw new Error(`${label} checksum mismatch`);
   }
 
@@ -1799,10 +1785,6 @@ export async function processPolledShellAction(config, action, shell, fetchImpl
   }
 
   try {
-    if (!isShellAccessEnabled(config)) {
-      throw new Error("Shell access is disabled by local configuration");
-    }
-
     if (actionType === "OPEN") {
       await shell.open(payload);
     } else if (actionType === "INPUT") {
@@ -1937,30 +1919,18 @@ function createBrokerBridge({
         }
 
         if (message.type === "OPEN_ROOT_SHELL") {
-          if (!isShellAccessEnabled(config)) {
-            throw new Error("Shell access is disabled by local configuration");
-          }
           await shell.open(message.payload || {});
           return;
         }
         if (message.type === "SHELL_INPUT") {
-          if (!isShellAccessEnabled(config)) {
-            throw new Error("Shell access is disabled by local configuration");
-          }
           shell.input(message.payload || {});
           return;
         }
         if (message.type === "RESIZE_ROOT_SHELL") {
-          if (!isShellAccessEnabled(config)) {
-            throw new Error("Shell access is disabled by local configuration");
-          }
           shell.resize(message.payload || {});
           return;
         }
         if (message.type === "CLOSE_ROOT_SHELL") {
-          if (!isShellAccessEnabled(config)) {
-            throw new Error("Shell access is disabled by local configuration");
-          }
           shell.close(message.payload || {});
         }
       } catch {

services/edge-agent/test/agent.test.mjs

@@ -1,7 +1,6 @@
 import test from "node:test";
 import assert from "node:assert/strict";
 import { execFile as execFileCallback } from "node:child_process";
-import { createHash } from "node:crypto";
 import { mkdir, mkdtemp, readFile, rm, writeFile } from "node:fs/promises";
 import os from "node:os";
 import path from "node:path";
@@ -18,7 +17,6 @@ import {
   getRelayStatus,
   loadConfig,
   parseCliArgs,
-  processPolledShellAction,
   processPolledCommand,
   runCli,
   runUpdate,
@@ -41,10 +39,6 @@ function makeFetchResponse(body) {
   };
 }
 
-function sha256Hex(body) {
-  return createHash("sha256").update(body).digest("hex");
-}
-
 async function waitFor(predicate, { timeoutMs = 1000, intervalMs = 10, description = "condition" } = {}) {
   const deadline = Date.now() + timeoutMs;
 
@@ -276,31 +270,6 @@ test("relay switch commands pass timer values to local Shelly APIs", async () =>
     "http://10.1.0.31/rpc/Switch.Set?id=0&on=true&toggle_after=3",
     "http://10.1.0.31/relay/0?turn=on&timer=3",
   ]);
-
-  const cappedUrls = [];
-  const cappedFetch = async (url) => {
-    cappedUrls.push(String(url));
-
-    return {
-      ok: true,
-      async json() {
-        return { output: true };
-      },
-    };
-  };
-
-  await setRelayState({
-    localIp: "10.1.0.31",
-    channel: 0,
-    on: true,
-    toggle_after: 999999999,
-    device_generation: 3,
-  }, cappedFetch);
-
-  assert.equal(
-    cappedUrls[0],
-    "http://10.1.0.31/rpc/Switch.Set?id=0&on=true&toggle_after=5"
-  );
 });
 
 test("runUpdate stages a pending verification restart after installing new artifacts", async () => {
@@ -325,23 +294,19 @@ test("runUpdate stages a pending verification restart after installing new artif
     execCalls.push({ command, args, options });
     return { stdout: "{}" };
   };
-  const agentBody = "// new agent\n";
-  const packageBody = JSON.stringify({ name: "new-edge-agent" }, null, 2);
   const fakeFetch = async (url) => {
     if (String(url).endsWith("/agent.mjs")) {
-      return makeFetchResponse(agentBody);
+      return makeFetchResponse("// new agent\n");
     }
     if (String(url).endsWith("/package.json")) {
-      return makeFetchResponse(packageBody);
+      return makeFetchResponse(JSON.stringify({ name: "new-edge-agent" }, null, 2));
     }
     throw new Error(`Unexpected URL: ${url}`);
   };
 
   const result = await runUpdate({
     artifactUrl: "https://api.example.test/edge-agent/artifacts/agent.mjs",
-    sha256: sha256Hex(agentBody),
     packageUrl: "https://api.example.test/edge-agent/artifacts/package.json",
-    packageSha256: sha256Hex(packageBody),
     targetVersion: "1.1.0",
     releaseChannel: "stable",
     restartMode: "spawn",
@@ -369,45 +334,6 @@ test("runUpdate stages a pending verification restart after installing new artif
 
   await rm(tempDir, { recursive: true, force: true });
 });
-test("runUpdate rejects artifacts without required checksums", async () => {
-  const tempDir = await mkdtemp(path.join(os.tmpdir(), "edge-agent-update-checksum-"));
-  const configPath = path.join(tempDir, "config.json");
-  const liveConfig = {
-    apiUrl: "https://api.example.test",
-    gatewayId: 42,
-    agentToken: "agent-token",
-    installDir: tempDir,
-    restartMode: "spawn",
-    installedVersion: "1.0.0",
-    targetVersion: "1.0.0",
-  };
-
-  await writeFile(configPath, JSON.stringify(liveConfig, null, 2));
-  await writeFile(path.join(tempDir, "agent.mjs"), "// old agent\n");
-
-  let fetchCalled = false;
-  await assert.rejects(
-    runUpdate({
-      artifactUrl: "https://api.example.test/edge-agent/artifacts/agent.mjs",
-      targetVersion: "1.1.0",
-    }, async () => {
-      fetchCalled = true;
-      return makeFetchResponse("// new agent\n");
-    }, {
-      configPath,
-      config: liveConfig,
-      liveConfig,
-      execFileImpl: async () => ({ stdout: "{}" }),
-    }),
-    /Agent artifact checksum is required/
-  );
-
-  assert.equal(fetchCalled, false);
-  assert.equal(await readFile(path.join(tempDir, "agent.mjs"), "utf8"), "// old agent\n");
-
-  await rm(tempDir, { recursive: true, force: true });
-});
-
 
 test("handleAgentCommand returns an uninstall follow-up envelope for gateway removal", async () => {
   const tempDir = await mkdtemp(path.join(os.tmpdir(), "edge-agent-uninstall-envelope-"));
@@ -744,7 +670,6 @@ test("startAgent reports API polling metadata, executes polled commands, and upl
     commandPollRetryDelayMs: 5,
     shellActionPollTimeoutSeconds: 0,
     shellActionPollRetryDelayMs: 5,
-    enableShellAccess: true,
   }));
 
   const heartbeats = [];
@@ -1003,61 +928,6 @@ test("startAgent reports API polling metadata, executes polled commands, and upl
   }
 });
 
-test("processPolledShellAction denies shell access when locally disabled", async () => {
-  const submissions = [];
-  const fakeFetch = async (url, options = {}) => {
-    if (/\/shell-actions\/\d+\/result$/.test(String(url))) {
-      submissions.push({ url, body: JSON.parse(options.body) });
-      return {
-        ok: true,
-        async json() {
-          return { data: { acknowledged: true } };
-        },
-      };
-    }
-
-    throw new Error(`Unexpected URL: ${url}`);
-  };
-
-  const shell = {
-    async open() {
-      throw new Error("should not run");
-    },
-    input() {
-      throw new Error("should not run");
-    },
-    resize() {
-      throw new Error("should not run");
-    },
-    close() {
-      throw new Error("should not run");
-    },
-  };
-
-  const result = await processPolledShellAction(
-    {
-      apiUrl: "https://api.example.test",
-      gatewayId: 42,
-      agentToken: "agent-token",
-      enableShellAccess: false,
-    },
-    {
-      id: 501,
-      actionType: "OPEN",
-      payload: {
-        sessionId: 44,
-      },
-    },
-    shell,
-    fakeFetch
-  );
-
-  assert.equal(result.ok, false);
-  assert.match(result.error, /Shell access is disabled/);
-  assert.equal(submissions.length, 1);
-  assert.equal(submissions[0].body.ok, false);
-});
-
 test("status helpers report config without exposing the agent token", async () => {
   const tempDir = await mkdtemp(path.join(os.tmpdir(), "edge-agent-status-"));
   const configPath = path.join(tempDir, "config.json");

services/edge-broker/server.mjs

@@ -4,7 +4,6 @@ import { fileURLToPath } from "node:url";
 import { WebSocketServer } from "ws";
 
 const DEFAULT_SHELL_OPEN_TIMEOUT_MS = 15000;
-const TELEMETRY_INGEST_ERROR_MESSAGE = "Telemetry ingestion failed";
 
 function parseJsonBody(req) {
   return new Promise((resolve, reject) => {
@@ -56,33 +55,7 @@ function resolveAuthMode(options = {}, managerUrl = "") {
   if (process.env.EDGE_AUTH_MODE) {
     return process.env.EDGE_AUTH_MODE;
   }
-  return "strict";
-}
-
-function resolveSharedSecret(options = {}) {
-  return String(options.sharedSecret ?? process.env.EDGE_BROKER_SHARED_SECRET ?? "").trim();
-}
-
-function requireSharedSecret(req, res, sharedSecret) {
-  if (sharedSecret === "") {
-    jsonResponse(res, 503, {
-      ok: false,
-      error: "Edge broker shared secret is not configured",
-      shared_secret_required: true,
-    });
-    return false;
-  }
-
-  if (req.headers["x-edge-broker-secret"] !== sharedSecret) {
-    jsonResponse(res, 403, {
-      ok: false,
-      error: "Forbidden",
-      shared_secret_required: true,
-    });
-    return false;
-  }
-
-  return true;
+  return "manager";
 }
 
 function parseScopes(value) {
@@ -177,7 +150,7 @@ function rejectUpgrade(socket, statusCode, errorCode, message, details = {}) {
 }
 
 export function createBrokerServer(options = {}) {
-  const sharedSecret = resolveSharedSecret(options);
+  const sharedSecret = options.sharedSecret ?? process.env.EDGE_BROKER_SHARED_SECRET ?? "";
   const managerUrl = resolveManagerUrl(options);
   const authMode = resolveAuthMode(options, managerUrl);
   const commandTimeoutMs = options.commandTimeoutMs ?? 10000;
@@ -487,19 +460,25 @@ export function createBrokerServer(options = {}) {
       }
 
       if (req.method === "POST" && url.pathname === "/api/diagnostics/shared-secret") {
-        if (!requireSharedSecret(req, res, sharedSecret)) {
+        if (sharedSecret && req.headers["x-edge-broker-secret"] !== sharedSecret) {
+          jsonResponse(res, 403, {
+            ok: false,
+            error: "Forbidden",
+            shared_secret_required: true,
+          });
           return;
         }
 
         jsonResponse(res, 200, {
           ok: true,
-          shared_secret_required: true,
+          shared_secret_required: Boolean(sharedSecret),
         });
         return;
       }
 
       if (req.method === "POST" && /^\/api\/gateways\/\d+\/commands$/.test(url.pathname)) {
-        if (!requireSharedSecret(req, res, sharedSecret)) {
+        if (sharedSecret && req.headers["x-edge-broker-secret"] !== sharedSecret) {
+          jsonResponse(res, 403, { error: "Forbidden" });
           return;
         }
 
@@ -542,7 +521,8 @@ export function createBrokerServer(options = {}) {
       }
 
       if (req.method === "POST" && /^\/api\/gateways\/\d+\/sync$/.test(url.pathname)) {
-        if (!requireSharedSecret(req, res, sharedSecret)) {
+        if (sharedSecret && req.headers["x-edge-broker-secret"] !== sharedSecret) {
+          jsonResponse(res, 403, { error: "Forbidden" });
           return;
         }
 
@@ -576,13 +556,12 @@ export function createBrokerServer(options = {}) {
           gatewayInfo = await validateAgent({ gatewayId, token, headers: req.headers });
         } catch (error) {
           const status = Number(error?.status) === 403 ? 403 : Number(error?.status) === 401 ? 401 : 503;
-          rejectUpgrade(socket, status, error?.code || "agent_validation_failed", "Gateway agent could not be validated.", {
+          rejectUpgrade(socket, status, error?.code || "agent_validation_failed", normalizeErrorMessage(error, "Gateway agent could not be validated."), {
             stage: "agent_validate",
           });
           return;
         }
 
-
         wss.handleUpgrade(req, socket, head, (ws) => {
           const existing = agents.get(gatewayId);
           if (existing && existing.readyState < 2) {
@@ -643,13 +622,12 @@ export function createBrokerServer(options = {}) {
         try {
           session = await validateShellSession({ token, headers: req.headers });
         } catch (error) {
-          rejectUpgrade(socket, Number(error?.status) === 403 ? 403 : 401, error?.code || "shell_session_invalid", "Shell session could not be validated.", {
+          rejectUpgrade(socket, Number(error?.status) === 403 ? 403 : 401, error?.code || "shell_session_invalid", normalizeErrorMessage(error, "Shell session could not be validated."), {
             stage: "shell_session_validate",
           });
           return;
         }
 
-
         wss.handleUpgrade(req, socket, head, (ws) => {
           ws.sessionToken = token;
           ws.sessionInfo = session;
@@ -744,7 +722,7 @@ export function createBrokerServer(options = {}) {
         return;
       }
     } catch (error) {
-      rejectUpgrade(socket, 500, "websocket_upgrade_failed", "WebSocket upgrade failed.");
+      rejectUpgrade(socket, 500, "websocket_upgrade_failed", normalizeErrorMessage(error, "WebSocket upgrade failed."));
       return;
     }
 
@@ -787,8 +765,8 @@ export function createBrokerServer(options = {}) {
             let ingestError = null;
             try {
               ingested = await ingestTelemetry(String(ws.gatewayId), payload);
-            } catch {
-              ingestError = TELEMETRY_INGEST_ERROR_MESSAGE;
+            } catch (error) {
+              ingestError = error instanceof Error ? error.message : String(error);
             }
             const fallbackStatistics = {
               system_metrics: payload?.metadata?.system_metrics || {},

services/edge-broker/test/broker.test.mjs

@@ -19,18 +19,6 @@ function waitForClose(socket) {
   });
 }
 
-function waitForCloseOrError(socket) {
-  return new Promise((resolve) => {
-    const onDone = () => {
-      socket.off("error", onDone);
-      socket.off("close", onDone);
-      resolve();
-    };
-    socket.once("error", onDone);
-    socket.once("close", onDone);
-  });
-}
-
 function rawUpgradeRequest(port, path) {
   return new Promise((resolve, reject) => {
     const socket = net.createConnection({ host: "127.0.0.1", port }, () => {
@@ -71,7 +59,7 @@ async function waitFor(predicate, { timeoutMs = 1000, intervalMs = 10, descripti
   throw new Error(`Timed out waiting for ${description}`);
 }
 
-test("broker defaults to strict auth and fails closed when manager URL is missing", async () => {
+test("broker defaults to manager auth and fails closed when manager URL is missing", async () => {
   const previousEnv = {
     EDGE_AUTH_MODE: process.env.EDGE_AUTH_MODE,
     EDGE_MANAGER_URL: process.env.EDGE_MANAGER_URL,
@@ -84,7 +72,7 @@ test("broker defaults to strict auth and fails closed when manager URL is missin
   let broker;
   try {
     broker = createBrokerServer({ sharedSecret: "secret" });
-    assert.equal(broker.state.authMode, "strict");
+    assert.equal(broker.state.authMode, "manager");
     assert.equal(broker.state.managerUrl, "");
 
     const address = await broker.listen(0);
@@ -95,15 +83,13 @@ test("broker defaults to strict auth and fails closed when manager URL is missin
     assert.doesNotMatch(shellResponse, /101 Switching Protocols/);
     assert.match(shellResponse, /^HTTP\/1\.1 401 Unauthorized/m);
     assert.match(shellResponse, /"error_code":"shell_session_invalid"/);
-    assert.match(shellResponse, /"message":"Shell session could not be validated\."/);
-    assert.doesNotMatch(shellResponse, /Edge manager URL is not configured/);
+    assert.match(shellResponse, /Edge manager URL is not configured/);
 
     assert.doesNotMatch(agentResponse, /101 Switching Protocols/);
     assert.match(agentResponse, /^HTTP\/1\.1 503 Service Unavailable/m);
     assert.match(agentResponse, /"error_code":"agent_validation_failed"/);
     assert.match(agentResponse, /"stage":"agent_validate"/);
-    assert.match(agentResponse, /"message":"Gateway agent could not be validated\."/);
-    assert.doesNotMatch(agentResponse, /Edge manager URL is not configured/);
+    assert.match(agentResponse, /Edge manager URL is not configured/);
   } finally {
     if (broker) {
       await broker.close();
@@ -118,53 +104,6 @@ test("broker defaults to strict auth and fails closed when manager URL is missin
   }
 });
 
-test("broker rejects protected HTTP endpoints when shared secret is missing", async () => {
-  const broker = createBrokerServer({ authMode: "stub", sharedSecret: "", commandTimeoutMs: 2000 });
-  const address = await broker.listen(0);
-  const port = address.port;
-  const agent = new WebSocket(`ws://127.0.0.1:${port}/ws/agent?gatewayId=701&token=agent-token`);
-
-  await new Promise((resolve) => agent.once("open", resolve));
-  const agentMessages = collectMessages(agent);
-
-  const commandResponse = await fetch(`http://127.0.0.1:${port}/api/gateways/701/commands`, {
-    method: "POST",
-    headers: {
-      "content-type": "application/json",
-    },
-    body: JSON.stringify({
-      commandType: "SET_RELAY_STATE",
-      payload: { relayId: "M-7", on: true },
-    }),
-  });
-  const commandJson = await commandResponse.json();
-
-  assert.equal(commandResponse.status, 503);
-  assert.equal(commandJson.ok, false);
-  assert.equal(commandJson.shared_secret_required, true);
-  assert.match(commandJson.error, /shared secret is not configured/);
-  assert.equal(agentMessages.some((message) => message.type === "COMMAND"), false);
-
-  const diagnosticsResponse = await fetch(`http://127.0.0.1:${port}/api/diagnostics/shared-secret`, {
-    method: "POST",
-  });
-  const diagnosticsJson = await diagnosticsResponse.json();
-
-  assert.equal(diagnosticsResponse.status, 503);
-  assert.equal(diagnosticsJson.shared_secret_required, true);
-
-  const syncResponse = await fetch(`http://127.0.0.1:${port}/api/gateways/701/sync`, {
-    method: "POST",
-  });
-  const syncJson = await syncResponse.json();
-
-  assert.equal(syncResponse.status, 503);
-  assert.equal(syncJson.shared_secret_required, true);
-
-  agent.terminate();
-  await broker.close();
-});
-
 test("broker dispatches commands to connected agents", async () => {
   const broker = createBrokerServer({ authMode: "stub", sharedSecret: "secret", commandTimeoutMs: 2000 });
   const address = await broker.listen(0);
@@ -399,34 +338,11 @@ test("broker rejects invalid browser shell upgrades without leaking the token",
 
   assert.match(response, /^HTTP\/1\.1 401 Unauthorized/m);
   assert.match(response, /"error_code":"shell_session_expired"/);
-  assert.match(response, /"message":"Shell session could not be validated\."/);
-  assert.doesNotMatch(response, /Shell session expired/);
   assert.doesNotMatch(response, new RegExp(rawToken));
 
   await broker.close();
 });
 
-test("broker rejects websocket upgrade errors without exposing exception text", async () => {
-  const broker = createBrokerServer({
-    authMode: "stub",
-    validateBrowserStream: async () => {
-      throw new Error("UPSTREAM-SENSITIVE: redis://cache.internal:6379 timeout");
-    },
-  });
-  const address = await broker.listen(0);
-  const port = address.port;
-
-  const response = await rawUpgradeRequest(port, "/ws/browser-gateway-stream?token=session-token");
-
-  assert.match(response, /^HTTP\/1\.1 500 Internal Server Error/m);
-  assert.match(response, /"error_code":"websocket_upgrade_failed"/);
-  assert.match(response, /"message":"WebSocket upgrade failed\."/);
-  assert.doesNotMatch(response, /UPSTREAM-SENSITIVE/);
-  assert.doesNotMatch(response, /redis:\/\/cache\.internal/);
-
-  await broker.close();
-});
-
 test("broker closes browser shell sessions when the agent never reports shell opened", async () => {
   const closedSessions = [];
   const broker = createBrokerServer({
@@ -502,17 +418,6 @@ test("broker closes browser shell sessions when the agent disconnects before she
   await broker.close();
 });
 
-test("broker defaults to strict auth when no validators are configured", async () => {
-  const broker = createBrokerServer();
-  const address = await broker.listen(0);
-  const port = address.port;
-
-  const agent = new WebSocket(`ws://127.0.0.1:${port}/ws/agent?gatewayId=701&token=agent-token`);
-  await waitForCloseOrError(agent);
-
-  await broker.close();
-});
-
 test("broker sends an agent welcome before connection progress and backlog dispatch", async () => {
   const broker = createBrokerServer({
     authMode: "stub",
@@ -838,16 +743,9 @@ test("broker still fans out telemetry when manager ingestion fails", async () =>
   );
 
   await waitFor(
-    () =>
-      browserMessages.some(
-        (message) => message.type === "gateway.telemetry" && message.error === "Telemetry ingestion failed"
-      ),
+    () => browserMessages.some((message) => message.type === "gateway.telemetry" && message.error === "manager unavailable"),
     { description: "telemetry fanout after ingest failure" }
   );
-  assert.ok(
-    browserMessages.every((message) => message.error !== "manager unavailable"),
-    "raw manager errors must not be sent to browser streams"
-  );
   assert.ok(
     browserMessages.some(
       (message) => message.type === "stats.updated" && message.statistics?.system_metrics?.cpu_usage_pct === 31

services/edge-broker/test/config.test.mjs

@@ -39,7 +39,7 @@ test("traefik does not expose a dedicated public edge broker port", () => {
 test("base docker compose routes edge broker traffic through traefik", () => {
   const serviceBlock = readComposeServiceBlock(baseComposeSource, "edge-broker");
   assert.doesNotMatch(serviceBlock, /\n\s+ports:\s*\n[\s\S]*?\n\s+- "4300:4300"/);
-  assert.match(serviceBlock, /EDGE_AUTH_MODE:\s*\$\{EDGE_AUTH_MODE:-strict\}/);
+  assert.match(serviceBlock, /EDGE_AUTH_MODE:\s*\$\{EDGE_AUTH_MODE:-manager\}/);
   assert.match(serviceBlock, /EDGE_MANAGER_URL:\s*\$\{EDGE_MANAGER_URL:-http:\/\/caddy\}/);
   assert.match(serviceBlock, /traefik\.http\.routers\.edge-broker-api\.priority=200/);
   assert.match(serviceBlock, /traefik\.http\.routers\.edge-broker-local\.priority=200/);
@@ -55,7 +55,7 @@ test("base docker compose routes edge broker traffic through traefik", () => {
 test("example docker compose routes edge broker traffic through traefik", () => {
   const serviceBlock = readComposeServiceBlock(exampleComposeSource, "edge-broker");
   assert.doesNotMatch(serviceBlock, /\n\s+ports:\s*\n[\s\S]*?\n\s+- "4300:4300"/);
-  assert.match(serviceBlock, /EDGE_AUTH_MODE:\s*\$\{EDGE_AUTH_MODE:-strict\}/);
+  assert.match(serviceBlock, /EDGE_AUTH_MODE:\s*\$\{EDGE_AUTH_MODE:-manager\}/);
   assert.match(serviceBlock, /EDGE_MANAGER_URL:\s*\$\{EDGE_MANAGER_URL:-http:\/\/caddy\}/);
   assert.match(serviceBlock, /traefik\.http\.routers\.edge-broker-api\.rule=Host\(`api\.example\.com`\) && PathPrefix\(`\/edge-broker`\)/);
   assert.match(serviceBlock, /traefik\.http\.routers\.edge-broker-local\.rule=Host\(`localhost`\) && PathPrefix\(`\/api\/edge-broker`\)/);
@@ -76,10 +76,10 @@ test("standalone production compose routes edge broker traffic through traefik",
   assert.match(serviceBlock, /traefik\.http\.services\.edge-broker\.loadbalancer\.server\.port=4300/);
 });
 
-test("compose config does not provide insecure broker secret defaults", () => {
+test("php services receive broker websocket environment defaults", () => {
   for (const composeSource of [baseComposeSource, exampleComposeSource]) {
     assert.match(composeSource, /EDGE_BROKER_URL:\s*\$\{EDGE_BROKER_URL:-http:\/\/edge-broker:4300\}/);
-    assert.match(composeSource, /EDGE_BROKER_SHARED_SECRET:\s*\$\{EDGE_BROKER_SHARED_SECRET:\?set EDGE_BROKER_SHARED_SECRET in \.env\}/);
+    assert.match(composeSource, /EDGE_BROKER_SHARED_SECRET:\s*\$\{EDGE_BROKER_SHARED_SECRET:-truckwash-edge-dev\}/);
   }
 });
 
@@ -88,6 +88,6 @@ test("base docker compose wires the broker into each php worker", () => {
     const serviceBlock = readComposeServiceBlock(baseComposeSource, serviceName);
     assert.match(serviceBlock, /\n\s+depends_on:\s*\n[\s\S]*?\n\s+- edge-broker/);
     assert.match(serviceBlock, /EDGE_BROKER_URL:\s*\$\{EDGE_BROKER_URL:-http:\/\/edge-broker:4300\}/);
-    assert.match(serviceBlock, /EDGE_BROKER_SHARED_SECRET:\s*\$\{EDGE_BROKER_SHARED_SECRET:\?set EDGE_BROKER_SHARED_SECRET in \.env\}/);
+    assert.match(serviceBlock, /EDGE_BROKER_SHARED_SECRET:\s*\$\{EDGE_BROKER_SHARED_SECRET:-truckwash-edge-dev\}/);
   }
 });

services/nginx/app/build/logs/api-server.err.log

@@ -12204,251 +12204,3 @@
 [Tue May 26 09:31:07 2026] 127.0.0.1:38284 Closing
 [Tue May 26 09:31:08 2026] 127.0.0.1:38290 Accepted
 [Tue May 26 09:31:12 2026] 127.0.0.1:38290 Closing
-[Tue Jun  2 12:55:52 2026] PHP 8.2.15 Development Server (http://127.0.0.1:45377) started
-[Tue Jun  2 12:55:52 2026] 127.0.0.1:52720 Accepted
-[Tue Jun  2 12:55:52 2026] 127.0.0.1:52720 Closing
-[Tue Jun  2 12:55:52 2026] 127.0.0.1:52734 Accepted
-[Tue Jun  2 12:55:52 2026] 127.0.0.1:52734 Closing
-[Tue Jun  2 12:55:52 2026] 127.0.0.1:52742 Accepted
-[Tue Jun  2 12:55:52 2026] 127.0.0.1:52742 Closing
-[Tue Jun  2 12:55:52 2026] 127.0.0.1:52750 Accepted
-[Tue Jun  2 12:55:52 2026] 127.0.0.1:52750 Closing
-[Tue Jun  2 12:55:52 2026] 127.0.0.1:52766 Accepted
-[Tue Jun  2 12:55:52 2026] 127.0.0.1:52766 Closing
-[Tue Jun  2 12:55:53 2026] 127.0.0.1:52770 Accepted
-[Tue Jun  2 12:55:53 2026] 127.0.0.1:52770 Closing
-[Tue Jun  2 12:55:53 2026] 127.0.0.1:52784 Accepted
-[Tue Jun  2 12:55:53 2026] 127.0.0.1:52784 Closing
-[Tue Jun  2 12:55:53 2026] 127.0.0.1:52792 Accepted
-[Tue Jun  2 12:55:53 2026] 127.0.0.1:52792 Closing
-[Tue Jun  2 12:55:53 2026] 127.0.0.1:52802 Accepted
-[Tue Jun  2 12:55:53 2026] 127.0.0.1:52802 Closing
-[Tue Jun  2 12:59:15 2026] PHP 8.2.15 Development Server (http://127.0.0.1:42651) started
-[Tue Jun  2 12:59:15 2026] 127.0.0.1:41826 Accepted
-[Tue Jun  2 12:59:15 2026] 127.0.0.1:41826 Closing
-[Tue Jun  2 12:59:15 2026] 127.0.0.1:41842 Accepted
-[Tue Jun  2 12:59:15 2026] 127.0.0.1:41842 Closing
-[Tue Jun  2 12:59:15 2026] 127.0.0.1:41850 Accepted
-[Tue Jun  2 12:59:15 2026] 127.0.0.1:41850 Closing
-[Tue Jun  2 12:59:15 2026] 127.0.0.1:41860 Accepted
-[Tue Jun  2 12:59:15 2026] 127.0.0.1:41860 Closing
-[Tue Jun  2 12:59:15 2026] 127.0.0.1:41874 Accepted
-[Tue Jun  2 12:59:15 2026] 127.0.0.1:41874 Closing
-[Tue Jun  2 12:59:16 2026] 127.0.0.1:41884 Accepted
-[Tue Jun  2 12:59:16 2026] 127.0.0.1:41884 Closing
-[Tue Jun  2 12:59:16 2026] 127.0.0.1:41894 Accepted
-[Tue Jun  2 12:59:16 2026] 127.0.0.1:41894 Closing
-[Tue Jun  2 12:59:16 2026] 127.0.0.1:41902 Accepted
-[Tue Jun  2 12:59:16 2026] 127.0.0.1:41902 Closing
-[Tue Jun  2 12:59:16 2026] 127.0.0.1:41916 Accepted
-[Tue Jun  2 12:59:37 2026] 127.0.0.1:41916 Closing
-[Tue Jun  2 13:02:13 2026] PHP 8.2.15 Development Server (http://127.0.0.1:38777) started
-[Tue Jun  2 13:02:13 2026] 127.0.0.1:37238 Accepted
-[Tue Jun  2 13:02:13 2026] 127.0.0.1:37238 Closing
-[Tue Jun  2 13:02:13 2026] 127.0.0.1:37252 Accepted
-[Tue Jun  2 13:02:13 2026] 127.0.0.1:37252 Closing
-[Tue Jun  2 13:02:13 2026] 127.0.0.1:37256 Accepted
-[Tue Jun  2 13:02:13 2026] 127.0.0.1:37256 Closing
-[Tue Jun  2 13:02:15 2026] 127.0.0.1:35516 Accepted
-[Tue Jun  2 13:02:15 2026] 127.0.0.1:35516 Closing
-[Tue Jun  2 13:02:15 2026] 127.0.0.1:35518 Accepted
-[Tue Jun  2 13:02:15 2026] 127.0.0.1:35518 Closing
-[Tue Jun  2 13:02:15 2026] 127.0.0.1:35528 Accepted
-[Tue Jun  2 13:02:15 2026] 127.0.0.1:35528 Closing
-[Tue Jun  2 13:02:16 2026] 127.0.0.1:35544 Accepted
-[Tue Jun  2 13:02:16 2026] 127.0.0.1:35544 Closing
-[Tue Jun  2 13:02:16 2026] 127.0.0.1:35552 Accepted
-[Tue Jun  2 13:02:16 2026] 127.0.0.1:35552 Closing
-[Tue Jun  2 13:02:16 2026] 127.0.0.1:35568 Accepted
-[Tue Jun  2 13:02:16 2026] 127.0.0.1:35568 Closing
-[Tue Jun  2 13:02:16 2026] 127.0.0.1:35582 Accepted
-[Tue Jun  2 13:02:16 2026] 127.0.0.1:35582 Closing
-[Tue Jun  2 13:02:16 2026] 127.0.0.1:35586 Accepted
-[Tue Jun  2 13:02:17 2026] 127.0.0.1:35586 Closing
-[Tue Jun  2 13:02:17 2026] 127.0.0.1:35588 Accepted
-[Tue Jun  2 13:02:17 2026] 127.0.0.1:35588 Closing
-[Tue Jun  2 13:02:19 2026] 127.0.0.1:35596 Accepted
-[Tue Jun  2 13:02:20 2026] 127.0.0.1:35596 Closing
-[Tue Jun  2 13:02:20 2026] 127.0.0.1:35600 Accepted
-[Tue Jun  2 13:02:20 2026] 127.0.0.1:35600 Closing
-[Tue Jun  2 13:02:20 2026] 127.0.0.1:35612 Accepted
-[Tue Jun  2 13:02:20 2026] 127.0.0.1:35612 Closing
-[Tue Jun  2 13:02:46 2026] PHP 8.2.15 Development Server (http://127.0.0.1:39573) started
-[Tue Jun  2 13:02:46 2026] 127.0.0.1:43488 Accepted
-[Tue Jun  2 13:02:46 2026] 127.0.0.1:43488 Closing
-[Tue Jun  2 13:02:46 2026] 127.0.0.1:43494 Accepted
-[Tue Jun  2 13:02:47 2026] 127.0.0.1:43494 Closing
-[Tue Jun  2 13:02:47 2026] 127.0.0.1:43502 Accepted
-[Tue Jun  2 13:02:47 2026] 127.0.0.1:43502 Closing
-[Tue Jun  2 13:02:47 2026] 127.0.0.1:43504 Accepted
-[Tue Jun  2 13:02:47 2026] 127.0.0.1:43504 Closing
-[Tue Jun  2 13:02:47 2026] 127.0.0.1:43516 Accepted
-[Tue Jun  2 13:02:47 2026] 127.0.0.1:43516 Closing
-[Tue Jun  2 13:02:53 2026] 127.0.0.1:43530 Accepted
-[Tue Jun  2 13:02:53 2026] 127.0.0.1:43530 Closing
-[Tue Jun  2 13:02:53 2026] 127.0.0.1:43540 Accepted
-[Tue Jun  2 13:02:53 2026] 127.0.0.1:43540 Closing
-[Tue Jun  2 13:02:53 2026] 127.0.0.1:43550 Accepted
-[Tue Jun  2 13:02:53 2026] 127.0.0.1:43550 Closing
-[Tue Jun  2 13:02:53 2026] 127.0.0.1:43562 Accepted
-[Tue Jun  2 13:02:53 2026] 127.0.0.1:43562 Closing
-[Tue Jun  2 13:02:53 2026] 127.0.0.1:43578 Accepted
-[Tue Jun  2 13:02:53 2026] 127.0.0.1:43578 Closing
-[Tue Jun  2 13:02:54 2026] 127.0.0.1:51950 Accepted
-[Tue Jun  2 13:02:54 2026] 127.0.0.1:51950 Closing
-[Tue Jun  2 13:02:54 2026] 127.0.0.1:51952 Accepted
-[Tue Jun  2 13:02:54 2026] 127.0.0.1:51952 Closing
-[Tue Jun  2 13:02:54 2026] 127.0.0.1:51964 Accepted
-[Tue Jun  2 13:02:54 2026] 127.0.0.1:51964 Closing
-[Tue Jun  2 13:02:54 2026] 127.0.0.1:51978 Accepted
-[Tue Jun  2 13:02:54 2026] 127.0.0.1:51978 Closing
-[Tue Jun  2 13:02:55 2026] 127.0.0.1:51994 Accepted
-[Tue Jun  2 13:02:55 2026] 127.0.0.1:51994 Closing
-[Tue Jun  2 13:25:35 2026] PHP 8.2.15 Development Server (http://127.0.0.1:40811) started
-[Tue Jun  2 13:25:35 2026] 127.0.0.1:43736 Accepted
-[Tue Jun  2 13:25:35 2026] 127.0.0.1:43736 Closing
-[Tue Jun  2 13:25:35 2026] 127.0.0.1:43740 Accepted
-[Tue Jun  2 13:25:35 2026] 127.0.0.1:43740 Closing
-[Tue Jun  2 13:25:35 2026] 127.0.0.1:43754 Accepted
-[Tue Jun  2 13:25:35 2026] 127.0.0.1:43754 Closing
-[Tue Jun  2 13:25:36 2026] 127.0.0.1:43768 Accepted
-[Tue Jun  2 13:25:36 2026] 127.0.0.1:43768 Closing
-[Tue Jun  2 13:25:36 2026] 127.0.0.1:43776 Accepted
-[Tue Jun  2 13:25:36 2026] 127.0.0.1:43776 Closing
-[Tue Jun  2 13:25:52 2026] 127.0.0.1:57442 Accepted
-[Tue Jun  2 13:25:52 2026] 127.0.0.1:57442 Closing
-[Tue Jun  2 13:25:52 2026] 127.0.0.1:57452 Accepted
-[Tue Jun  2 13:25:53 2026] 127.0.0.1:57452 Closing
-[Tue Jun  2 13:25:53 2026] 127.0.0.1:57460 Accepted
-[Tue Jun  2 13:25:53 2026] 127.0.0.1:57460 Closing
-[Tue Jun  2 13:25:53 2026] 127.0.0.1:57472 Accepted
-[Tue Jun  2 13:25:53 2026] 127.0.0.1:57472 Closing
-[Tue Jun  2 13:25:53 2026] 127.0.0.1:57486 Accepted
-[Tue Jun  2 13:25:53 2026] 127.0.0.1:57486 Closing
-[Tue Jun  2 13:25:53 2026] 127.0.0.1:57492 Accepted
-[Tue Jun  2 13:25:53 2026] 127.0.0.1:57492 Closing
-[Tue Jun  2 13:25:53 2026] 127.0.0.1:57508 Accepted
-[Tue Jun  2 13:25:53 2026] 127.0.0.1:57508 Closing
-[Tue Jun  2 13:25:53 2026] 127.0.0.1:57522 Accepted
-[Tue Jun  2 13:25:54 2026] 127.0.0.1:57522 Closing
-[Tue Jun  2 13:25:54 2026] 127.0.0.1:60940 Accepted
-[Tue Jun  2 13:25:54 2026] 127.0.0.1:60940 Closing
-[Tue Jun  2 13:25:54 2026] 127.0.0.1:60950 Accepted
-[Tue Jun  2 13:25:54 2026] 127.0.0.1:60950 Closing
-[Tue Jun  2 13:44:42 2026] PHP 8.2.15 Development Server (http://127.0.0.1:37125) started
-[Tue Jun  2 13:44:42 2026] 127.0.0.1:45382 Accepted
-[Tue Jun  2 13:44:42 2026] 127.0.0.1:45382 Closing
-[Tue Jun  2 13:44:42 2026] 127.0.0.1:45388 Accepted
-[Tue Jun  2 13:44:42 2026] 127.0.0.1:45388 Closing
-[Tue Jun  2 13:44:42 2026] 127.0.0.1:45398 Accepted
-[Tue Jun  2 13:44:43 2026] 127.0.0.1:45398 Closing
-[Tue Jun  2 13:44:43 2026] 127.0.0.1:45410 Accepted
-[Tue Jun  2 13:44:46 2026] 127.0.0.1:45410 Closing
-[Tue Jun  2 13:44:46 2026] 127.0.0.1:53928 Accepted
-[Tue Jun  2 13:44:46 2026] 127.0.0.1:53928 Closing
-[Tue Jun  2 13:44:51 2026] PHP 8.2.15 Development Server (http://127.0.0.1:34643) started
-[Tue Jun  2 13:44:51 2026] 127.0.0.1:46776 Accepted
-[Tue Jun  2 13:44:51 2026] 127.0.0.1:46776 Closing
-[Tue Jun  2 13:44:51 2026] 127.0.0.1:46782 Accepted
-[Tue Jun  2 13:44:51 2026] 127.0.0.1:46782 Closing
-[Tue Jun  2 13:44:51 2026] 127.0.0.1:46796 Accepted
-[Tue Jun  2 13:44:51 2026] 127.0.0.1:46796 Closing
-[Tue Jun  2 13:44:51 2026] 127.0.0.1:46806 Accepted
-[Tue Jun  2 13:44:51 2026] 127.0.0.1:46806 Closing
-[Tue Jun  2 13:44:51 2026] 127.0.0.1:46816 Accepted
-[Tue Jun  2 13:44:51 2026] 127.0.0.1:46816 Closing
-[Tue Jun  2 13:44:52 2026] 127.0.0.1:46824 Accepted
-[Tue Jun  2 13:44:52 2026] 127.0.0.1:46824 Closing
-[Tue Jun  2 13:44:53 2026] 127.0.0.1:46836 Accepted
-[Tue Jun  2 13:44:53 2026] 127.0.0.1:46836 Closing
-[Tue Jun  2 13:44:53 2026] 127.0.0.1:46846 Accepted
-[Tue Jun  2 13:44:53 2026] 127.0.0.1:46846 Closing
-[Tue Jun  2 13:44:53 2026] 127.0.0.1:46848 Accepted
-[Tue Jun  2 13:44:53 2026] 127.0.0.1:46848 Closing
-[Tue Jun  2 13:44:54 2026] 127.0.0.1:45254 Accepted
-[Tue Jun  2 13:44:54 2026] 127.0.0.1:45254 Closing
-[Tue Jun  2 13:44:54 2026] 127.0.0.1:45264 Accepted
-[Tue Jun  2 13:44:54 2026] 127.0.0.1:45264 Closing
-[Tue Jun  2 13:44:54 2026] 127.0.0.1:45276 Accepted
-[Tue Jun  2 13:44:54 2026] 127.0.0.1:45276 Closing
-[Tue Jun  2 13:44:54 2026] 127.0.0.1:45282 Accepted
-[Tue Jun  2 13:44:54 2026] 127.0.0.1:45282 Closing
-[Tue Jun  2 13:44:54 2026] 127.0.0.1:45288 Accepted
-[Tue Jun  2 13:44:54 2026] 127.0.0.1:45288 Closing
-[Tue Jun  2 13:44:54 2026] 127.0.0.1:45296 Accepted
-[Tue Jun  2 13:44:54 2026] 127.0.0.1:45296 Closing
-[Tue Jun  2 13:44:55 2026] 127.0.0.1:45312 Accepted
-[Tue Jun  2 13:44:55 2026] 127.0.0.1:45312 Closing
-[Tue Jun  2 13:44:55 2026] 127.0.0.1:45314 Accepted
-[Tue Jun  2 13:44:55 2026] 127.0.0.1:45314 Closing
-[Tue Jun  2 13:44:55 2026] 127.0.0.1:45328 Accepted
-[Tue Jun  2 13:44:55 2026] 127.0.0.1:45328 Closing
-[Tue Jun  2 13:44:55 2026] 127.0.0.1:45330 Accepted
-[Tue Jun  2 13:44:55 2026] 127.0.0.1:45330 Closing
-[Tue Jun  2 14:14:22 2026] PHP 8.2.15 Development Server (http://127.0.0.1:41283) started
-[Tue Jun  2 14:14:22 2026] 127.0.0.1:54804 Accepted
-[Tue Jun  2 14:14:22 2026] 127.0.0.1:54804 Closing
-[Tue Jun  2 14:14:22 2026] 127.0.0.1:54812 Accepted
-[Tue Jun  2 14:14:22 2026] 127.0.0.1:54812 Closing
-[Tue Jun  2 14:14:22 2026] 127.0.0.1:54816 Accepted
-[Tue Jun  2 14:14:22 2026] 127.0.0.1:54816 Closing
-[Tue Jun  2 14:14:22 2026] 127.0.0.1:54826 Accepted
-[Tue Jun  2 14:14:23 2026] 127.0.0.1:54826 Closing
-[Tue Jun  2 14:14:23 2026] 127.0.0.1:54828 Accepted
-[Tue Jun  2 14:14:25 2026] 127.0.0.1:54828 Closing
-[Tue Jun  2 14:14:25 2026] 127.0.0.1:45644 Accepted
-[Tue Jun  2 14:14:25 2026] 127.0.0.1:45644 Closing
-[Tue Jun  2 14:14:42 2026] PHP 8.2.15 Development Server (http://127.0.0.1:40157) started
-[Tue Jun  2 14:14:42 2026] 127.0.0.1:46410 Accepted
-[Tue Jun  2 14:14:42 2026] 127.0.0.1:46410 Closing
-[Tue Jun  2 14:14:42 2026] 127.0.0.1:46414 Accepted
-[Tue Jun  2 14:14:42 2026] 127.0.0.1:46414 Closing
-[Tue Jun  2 14:14:42 2026] 127.0.0.1:46424 Accepted
-[Tue Jun  2 14:14:42 2026] 127.0.0.1:46424 Closing
-[Tue Jun  2 14:14:42 2026] 127.0.0.1:46440 Accepted
-[Tue Jun  2 14:14:42 2026] 127.0.0.1:46440 Closing
-[Tue Jun  2 14:14:42 2026] 127.0.0.1:46442 Accepted
-[Tue Jun  2 14:14:42 2026] 127.0.0.1:46442 Closing
-[Tue Jun  2 14:14:43 2026] 127.0.0.1:46458 Accepted
-[Tue Jun  2 14:14:43 2026] 127.0.0.1:46458 Closing
-[Tue Jun  2 14:16:10 2026] PHP 8.2.15 Development Server (http://127.0.0.1:38915) started
-[Tue Jun  2 14:16:10 2026] 127.0.0.1:54470 Accepted
-[Tue Jun  2 14:16:10 2026] 127.0.0.1:54470 Closing
-[Tue Jun  2 14:16:10 2026] 127.0.0.1:54482 Accepted
-[Tue Jun  2 14:16:11 2026] 127.0.0.1:54482 Closing
-[Tue Jun  2 14:16:11 2026] 127.0.0.1:54492 Accepted
-[Tue Jun  2 14:16:11 2026] 127.0.0.1:54492 Closing
-[Tue Jun  2 14:16:11 2026] 127.0.0.1:54498 Accepted
-[Tue Jun  2 14:16:11 2026] 127.0.0.1:54498 Closing
-[Tue Jun  2 14:16:11 2026] 127.0.0.1:54508 Accepted
-[Tue Jun  2 14:16:11 2026] 127.0.0.1:54508 Closing
-[Tue Jun  2 14:16:24 2026] 127.0.0.1:48044 Accepted
-[Tue Jun  2 14:16:24 2026] 127.0.0.1:48044 Closing
-[Tue Jun  2 14:16:25 2026] 127.0.0.1:48060 Accepted
-[Tue Jun  2 14:16:25 2026] 127.0.0.1:48060 Closing
-[Tue Jun  2 14:16:27 2026] 127.0.0.1:48072 Accepted
-[Tue Jun  2 14:16:27 2026] 127.0.0.1:48072 Closing
-[Tue Jun  2 14:16:27 2026] 127.0.0.1:48088 Accepted
-[Tue Jun  2 14:16:28 2026] 127.0.0.1:48088 Closing
-[Tue Jun  2 14:16:28 2026] 127.0.0.1:48094 Accepted
-[Tue Jun  2 14:16:28 2026] 127.0.0.1:48094 Closing
-[Tue Jun  2 14:16:34 2026] 127.0.0.1:55000 Accepted
-[Tue Jun  2 14:16:34 2026] 127.0.0.1:55000 Closing
-[Tue Jun  2 14:16:34 2026] 127.0.0.1:55006 Accepted
-[Tue Jun  2 14:16:34 2026] 127.0.0.1:55006 Closing
-[Tue Jun  2 14:16:34 2026] 127.0.0.1:55016 Accepted
-[Tue Jun  2 14:16:34 2026] 127.0.0.1:55016 Closing
-[Tue Jun  2 14:16:34 2026] 127.0.0.1:55018 Accepted
-[Tue Jun  2 14:16:34 2026] 127.0.0.1:55018 Closing
-[Tue Jun  2 14:16:35 2026] 127.0.0.1:55022 Accepted
-[Tue Jun  2 14:16:35 2026] 127.0.0.1:55022 Closing
-[Tue Jun  2 14:16:35 2026] 127.0.0.1:55032 Accepted
-[Tue Jun  2 14:16:35 2026] 127.0.0.1:55032 Closing
-[Tue Jun  2 14:16:35 2026] 127.0.0.1:55048 Accepted
-[Tue Jun  2 14:16:35 2026] 127.0.0.1:55048 Closing
-[Tue Jun  2 14:16:35 2026] 127.0.0.1:55060 Accepted
-[Tue Jun  2 14:16:35 2026] 127.0.0.1:55060 Closing
-[Tue Jun  2 14:16:35 2026] 127.0.0.1:55074 Accepted
-[Tue Jun  2 14:16:35 2026] 127.0.0.1:55074 Closing
-[Tue Jun  2 14:17:06 2026] 127.0.0.1:34490 Accepted
-[Tue Jun  2 14:17:06 2026] 127.0.0.1:34490 Closing

services/nginx/app/classes/attachments.php

@@ -133,14 +133,8 @@ class attachments implements attachments_i
     protected function fetchAttachmentRows(string $type, array $object_ids, array $options = []): array
     {
         $options = $this->normalizeAttachmentOptions($options);
-        $rawType = trim($type, '`');
-        $objectTypes = array_values(array_unique([
-            $rawType,
-            '`' . $rawType . '`',
-        ]));
-
         return (new object_attachments_o())->getFieldsWhereIn([
-            'object_type' => $objectTypes,
+            'object_type' => $type,
             'object_id' => $object_ids,
             'deleted_at' => null
         ], $options);

services/nginx/app/classes/authentication.php

@@ -6,7 +6,6 @@ use classes\totp;
 use Exception;
 use interfaces\authentication_i;
 use objects\plate_scanners_o;
-use objects\subuser_grants_o;
 use objects\tokens_o;
 use objects\users_o;
 use objects\subusers_o;
@@ -126,13 +125,9 @@ class authentication implements authentication_i
     public function validate_token(string $token): bool
     {
         // First: try validating as a classic user auth token
-        try {
-            $dbToken = (new tokens_o())->getToken($token);
-            if ($dbToken && $dbToken->id && $dbToken->type->value() === 'AUTH_TOKEN') {
-                return true;
-            }
-        } catch (Exception) {
-            // Ignore and continue to subuser session validation
+        $dbToken = (new tokens_o())->getToken($token);
+        if ($dbToken && $dbToken->id) {
+            return true;
         }
         // Fallback: try validating as a subuser session token
         $subuser = (new subusers_o())->getSubuserBySessionToken($token);
@@ -159,17 +154,19 @@ class authentication implements authentication_i
         // Strip the Bearer prefix
         $rawToken = str_replace('Bearer ', '', $rawToken);
         // Get the token from the database
-        try {
-            $token = (new tokens_o())->getToken($rawToken);
-        } catch (Exception) {
-            return false;
-        }
+        $token = (new tokens_o())->getToken($rawToken);
         // Check if the token exists
         if (!$token->id) {
             return false;
         }
-        if ($token->type->value() !== 'AUTH_TOKEN') {
-            return false;
+        if ($token->type->value() === "AUTH_TOKEN_SUBUSER") {
+            // Get the customer number from the headers
+            if (!isset($headers['X-Customer-Number'])) {
+                return false;
+            }
+            $customer_number = (int)$headers['X-Customer-Number'];
+            // Get the user by the customer number
+            return (new users_o())->getUserByCustomerNumber($customer_number);
         }
         // Get the user from the database
         $user = (new users_o())->getUserById($token->user_id->value());

services/nginx/app/classes/coolify_api_client.php

@@ -121,16 +121,6 @@ class coolify_api_client
         ]);
     }
 
-    public function listApplicationEnvs(string $uuid): array
-    {
-        return $this->request('GET', '/applications/' . rawurlencode($uuid) . '/envs');
-    }
-
-    public function deleteApplicationEnv(string $uuid, string $envUuid): array
-    {
-        return $this->request('DELETE', '/applications/' . rawurlencode($uuid) . '/envs/' . rawurlencode($envUuid));
-    }
-
     private static function bulkEnvData(array $env): array
     {
         $data = [];
@@ -169,11 +159,6 @@ class coolify_api_client
         return $this->request('GET', '/applications/' . rawurlencode($uuid) . '/restart');
     }
 
-    public function stopApplication(string $uuid): array
-    {
-        return $this->request('GET', '/applications/' . rawurlencode($uuid) . '/stop');
-    }
-
     public function deleteService(string $uuid): array
     {
         return $this->request('DELETE', '/services/' . rawurlencode($uuid));

services/nginx/app/classes/coolify_manager.php

@@ -1371,129 +1371,6 @@ class coolify_manager
         ];
     }
 
-    public function deployGithubRunners(array $input, ?int $actorUserId = null): array
-    {
-        $this->ensureSchema();
-
-        $dryRun = $this->toBool($input['dry_run'] ?? null, false);
-        $instanceId = (int)($input['instance_id'] ?? 0);
-        if ($instanceId <= 0) {
-            $instanceId = $this->defaultInstanceId();
-        }
-        $instance = $this->getInstance($instanceId);
-        $repositories = $this->githubRunnerRepositories($input);
-        $labels = $this->githubRunnerLabels($input['labels'] ?? null);
-        $countPerRepo = $this->githubRunnerCount($input['count_per_repo'] ?? $input['runner_count_per_repo'] ?? null);
-        $serviceName = $this->githubRunnerServiceName($input['service_name'] ?? null);
-        $resourceUuid = $this->nullableString($input['service_uuid'] ?? null)
-            ?? $this->nullableString($this->coolifyConfigValue('github_runner_service_uuid', ''));
-        $token = $this->githubRunnerToken($input);
-        $template = $this->githubRunnerComposeTemplate($repositories, $labels, $countPerRepo);
-        $hash = $this->composeHash($template);
-
-        $plan = [
-            'type' => 'deploy_github_runners',
-            'instance_id' => $instanceId,
-            'service_uuid' => $resourceUuid,
-            'service_name' => $serviceName,
-            'repositories' => $repositories,
-            'labels' => $labels,
-            'count_per_repo' => $countPerRepo,
-            'compose_hash' => $hash,
-            'action' => $resourceUuid === null ? 'create' : 'update',
-            'token_set' => $token !== '',
-            'token_source' => trim((string)($input['github_token'] ?? $input['token'] ?? '')) !== '' ? 'request' : 'config',
-        ];
-
-        if ($dryRun) {
-            $this->audit(null, $instanceId, null, 'github_runners_planned', $actorUserId, 'info', $plan);
-            return [
-                'ok' => true,
-                'dry_run' => true,
-                'mutated' => false,
-                'planned' => [$plan],
-                'applied' => [],
-                'errors' => [],
-                'service_uuid' => $resourceUuid,
-                'service_name' => $serviceName,
-                'compose_hash' => $hash,
-                'repositories' => $repositories,
-                'labels' => $labels,
-                'count_per_repo' => $countPerRepo,
-            ];
-        }
-
-        if ($token === '') {
-            throw new RuntimeException('GitHub runner token is required to deploy self-hosted runners.');
-        }
-
-        $client = $this->clientForInstance($instance);
-        $apiResult = [];
-        $action = $resourceUuid === null ? 'created' : 'updated';
-        if ($resourceUuid === null) {
-            $apiResult = $client->createService($this->githubRunnerServicePayload($instance, $input, $serviceName, $template, false));
-            $resourceUuid = trim((string)($apiResult['uuid'] ?? ''));
-            if ($resourceUuid === '') {
-                throw new RuntimeException('Coolify did not return a GitHub runner service UUID.');
-            }
-        } else {
-            try {
-                $apiResult = $client->updateService($resourceUuid, $this->githubRunnerServicePayload($instance, $input, $serviceName, $template, true));
-            } catch (Throwable $throwable) {
-                if (!str_contains(strtolower($throwable->getMessage()), '404')
-                    && !str_contains(strtolower($throwable->getMessage()), 'not found')) {
-                    throw $throwable;
-                }
-                $apiResult = $client->createService($this->githubRunnerServicePayload($instance, $input, $serviceName, $template, false));
-                $resourceUuid = trim((string)($apiResult['uuid'] ?? ''));
-                if ($resourceUuid === '') {
-                    throw new RuntimeException('Coolify did not return a GitHub runner service UUID.');
-                }
-                $action = 'created';
-            }
-        }
-
-        $client->updateServiceEnvsBulk($resourceUuid, ['GITHUB_RUNNER_TOKEN' => $token]);
-        $start = $this->startOrRestartService($client, $resourceUuid, $action === 'updated');
-        $deployment = $client->deployResource($resourceUuid, false);
-
-        $this->setModuleConfigValue('Coolify', 'github_runner_service_uuid', $resourceUuid, 'string');
-        $this->setModuleConfigValue('Coolify', 'github_runner_frontend_repository', $repositories['frontend'], 'string');
-        $this->setModuleConfigValue('Coolify', 'github_runner_backend_repository', $repositories['backend'], 'string');
-        $this->setModuleConfigValue('Coolify', 'github_runner_labels', implode(',', $labels), 'string');
-        $this->setModuleConfigValue('Coolify', 'github_runner_count_per_repo', (string)$countPerRepo, 'int');
-        if ($this->toBool($input['persist_token'] ?? null, false)) {
-            $this->setModuleConfigValue('Coolify', 'github_runner_token', replication_secret_box::encrypt($token), 'string');
-        }
-
-        $applied = array_replace($plan, [
-            'action' => $action,
-            'service_uuid' => $resourceUuid,
-            'coolify' => self::redactCoolifyResponse($apiResult),
-            'start' => self::redactCoolifyResponse(is_array($start) ? $start : []),
-            'deployment' => self::redactCoolifyResponse($deployment),
-        ]);
-
-        $this->audit(null, $instanceId, null, 'github_runners_deployed', $actorUserId, 'info', $applied);
-
-        return [
-            'ok' => true,
-            'dry_run' => false,
-            'mutated' => true,
-            'planned' => [$plan],
-            'applied' => [$applied],
-            'errors' => [],
-            'action' => $action,
-            'service_uuid' => $resourceUuid,
-            'service_name' => $serviceName,
-            'compose_hash' => $hash,
-            'repositories' => $repositories,
-            'labels' => $labels,
-            'count_per_repo' => $countPerRepo,
-            'deployment' => self::redactCoolifyResponse($deployment),
-        ];
-    }
-
     private function gatewayApiCodeVersionLabel(array $target): string
     {
         $channelSlug = trim((string)($target['channel_slug'] ?? 'gateway'));
@@ -2049,14 +1926,13 @@ class coolify_manager
                     ], $actorUserId);
                 }
 
-                $sourceCommitSha = trim((string)($sourceTarget['latest_deployment_commit_sha'] ?? ''));
-                $deploymentInput = [
+                $deployment = $releaseManager->startDeployment([
                     'target_id' => (int)($deploymentTarget['id'] ?? 0),
                     'channel_id' => (int)$sourceTarget['channel_id'],
                     'app' => $app,
                     'repository' => (string)($sourceTarget['repository'] ?? ''),
                     'branch' => (string)($sourceTarget['branch'] ?? 'master'),
-                    'commit_mode' => $sourceCommitSha === '' ? 'latest' : 'specific',
+                    'commit_mode' => 'latest',
                     'version_label' => $this->gatewayRouteProvisionVersionLabel($sourceTarget),
                     'deployed_url' => $sourcePublicUrl,
                     'metadata' => [
@@ -2066,11 +1942,7 @@ class coolify_manager
                         'server_uuid' => $serverUuid,
                         'app' => $app,
                     ],
-                ];
-                if ($sourceCommitSha !== '') {
-                    $deploymentInput['commit_sha'] = $sourceCommitSha;
-                }
-                $deployment = $releaseManager->startDeployment($deploymentInput, $actorUserId);
+                ], $actorUserId);
 
                 if ((string)($deployment['status'] ?? '') !== 'deployed') {
                     $errors[] = array_replace($action, [
@@ -3389,141 +3261,6 @@ class coolify_manager
         ];
     }
 
-    private function githubRunnerRepositories(array $input): array
-    {
-        return [
-            'frontend' => $this->normalizeGithubRepository(
-                $input['frontend_repository'] ?? $input['frontend_repo'] ?? $this->coolifyConfigValue('github_runner_frontend_repository', 'copenhagentruckwash/pleno-vue'),
-                'frontend'
-            ),
-            'backend' => $this->normalizeGithubRepository(
-                $input['backend_repository'] ?? $input['backend_repo'] ?? $this->coolifyConfigValue('github_runner_backend_repository', 'copenhagentruckwash/api'),
-                'backend'
-            ),
-        ];
-    }
-
-    private function normalizeGithubRepository(mixed $value, string $label): string
-    {
-        $repository = trim((string)$value);
-        $repository = preg_replace('#^https://github\.com/#i', '', $repository) ?? $repository;
-        $repository = preg_replace('#^git@github\.com:#i', '', $repository) ?? $repository;
-        $repository = preg_replace('#\.git$#i', '', $repository) ?? $repository;
-        $repository = trim($repository, " \t\n\r\0\x0B/");
-        if (!preg_match('#^[A-Za-z0-9_.-]+/[A-Za-z0-9_.-]+$#', $repository)) {
-            throw new RuntimeException('GitHub ' . $label . ' repository must be in owner/repo format.');
-        }
-        return $repository;
-    }
-
-    private function githubRunnerLabels(mixed $value): array
-    {
-        $raw = trim((string)($value ?? ''));
-        if ($raw === '') {
-            $raw = $this->coolifyConfigValue('github_runner_labels', 'self-hosted,Linux,X64,default');
-        }
-
-        $labels = array_values(array_unique(array_filter(array_map(
-            static fn(string $label): string => trim($label),
-            preg_split('/[,\s]+/', $raw) ?: []
-        ))));
-
-        return $labels !== [] ? $labels : ['self-hosted', 'Linux', 'X64', 'default'];
-    }
-
-    private function githubRunnerCount(mixed $value): int
-    {
-        $count = (int)($value ?? 0);
-        if ($count <= 0) {
-            $count = (int)$this->coolifyConfigValue('github_runner_count_per_repo', '1');
-        }
-        return max(1, min(10, $count));
-    }
-
-    private function githubRunnerServiceName(mixed $value): string
-    {
-        $name = strtolower(trim((string)($value ?? 'truckwash-github-runners')));
-        $name = preg_replace('/[^a-z0-9-]+/', '-', $name) ?: '';
-        $name = trim($name, '-') ?: 'truckwash-github-runners';
-        return substr($name, 0, 120);
-    }
-
-    private function githubRunnerToken(array $input): string
-    {
-        $token = trim((string)($input['github_token'] ?? $input['token'] ?? ''));
-        if ($token !== '') {
-            return $token;
-        }
-
-        $envToken = trim((string)(getenv('GITHUB_RUNNER_TOKEN') ?: getenv('GITHUB_TOKEN') ?: ''));
-        if ($envToken !== '') {
-            return $envToken;
-        }
-
-        return replication_secret_box::decrypt($this->coolifyConfigValue('github_runner_token', ''));
-    }
-
-    private function githubRunnerComposeTemplate(array $repositories, array $labels, int $countPerRepo): array
-    {
-        $lines = ['services:'];
-        foreach ($repositories as $key => $repository) {
-            for ($index = 1; $index <= $countPerRepo; $index++) {
-                $service = 'github-runner-' . $key . '-' . $index;
-                $runnerName = 'truckwash-' . $key . '-' . $index;
-                $runnerLabels = array_values(array_unique(array_merge($labels, [$key])));
-                $lines = array_merge($lines, [
-                    '  ' . $service . ':',
-                    '    image: myoung34/github-runner:latest',
-                    '    restart: unless-stopped',
-                    '    environment:',
-                    '      REPO_URL: ' . self::yamlScalar('https://github.com/' . $repository),
-                    '      RUNNER_NAME: ' . self::yamlScalar($runnerName),
-                    '      RUNNER_SCOPE: repo',
-                    '      RUNNER_WORKDIR: /tmp/runner/work',
-                    '      LABELS: ' . self::yamlScalar(implode(',', $runnerLabels)),
-                    '      EPHEMERAL: "false"',
-                    '      RUN_AS_ROOT: "true"',
-                    '      ACCESS_TOKEN: ${GITHUB_RUNNER_TOKEN}',
-                    '    volumes:',
-                    '      - /var/run/docker.sock:/var/run/docker.sock',
-                ]);
-            }
-        }
-
-        return [
-            'compose' => implode("\n", $lines) . "\n",
-            'env' => 'GITHUB_RUNNER_TOKEN=${GITHUB_RUNNER_TOKEN}',
-        ];
-    }
-
-    private function githubRunnerServicePayload(array $instance, array $input, string $serviceName, array $template, bool $update): array
-    {
-        $payload = [
-            'name' => $serviceName,
-            'description' => 'Truckwash GitHub self-hosted runners for frontend and backend workflows.',
-            'instant_deploy' => false,
-            'docker_compose_raw' => $this->encodedDockerCompose($template),
-            'force_domain_override' => false,
-        ];
-
-        if (!$update) {
-            $payload = array_replace($payload, [
-                'project_uuid' => $this->targetMapping($input, $instance, 'project_uuid'),
-                'environment_name' => $this->targetMapping($input, $instance, 'environment_name') ?: 'production',
-                'environment_uuid' => $this->targetMapping($input, $instance, 'environment_uuid'),
-                'server_uuid' => $this->targetMapping($input, $instance, 'server_uuid'),
-                'destination_uuid' => $this->targetMapping($input, $instance, 'destination_uuid'),
-            ]);
-        }
-
-        return array_filter($payload, static fn($value): bool => $value !== null && $value !== '');
-    }
-
-    private static function yamlScalar(string $value): string
-    {
-        return '"' . str_replace(['\\', '"'], ['\\\\', '\\"'], $value) . '"';
-    }
-
     private function publicLoadBalancerConfig(array $config): array
     {
         unset($config['token']);

services/nginx/app/classes/coolify_schema_bootstrap.php

@@ -154,12 +154,6 @@ class coolify_schema_bootstrap
         self::ensureModuleConfigDefault('Coolify', 'hetzner_cloud_api_token', '', 'string');
         self::ensureModuleConfigDefault('Coolify', 'public_gateway_host', 'api-v2.truckwash.io', 'string');
         self::ensureModuleConfigDefault('Coolify', 'public_gateway_probe_path', '', 'string');
-        self::ensureModuleConfigDefault('Coolify', 'github_runner_token', '', 'string');
-        self::ensureModuleConfigDefault('Coolify', 'github_runner_service_uuid', '', 'string');
-        self::ensureModuleConfigDefault('Coolify', 'github_runner_frontend_repository', 'copenhagentruckwash/pleno-vue', 'string');
-        self::ensureModuleConfigDefault('Coolify', 'github_runner_backend_repository', 'copenhagentruckwash/api', 'string');
-        self::ensureModuleConfigDefault('Coolify', 'github_runner_labels', 'self-hosted,Linux,X64,default', 'string');
-        self::ensureModuleConfigDefault('Coolify', 'github_runner_count_per_repo', '1', 'int');
 
         self::ensureDefaultGateway('node1.truckwash.io', '94.130.142.41', 10);
         self::ensureDefaultGateway('node2.truckwash.io', '65.21.214.30', 20);

services/nginx/app/classes/cors_policy.php

@@ -25,9 +25,6 @@ class cors_policy
         'https://localhost:4433',
         'https://twdev.jeppeb.dk',
         'http://localhost:5173',
-        'http://localhost:5174',
-        'http://127.0.0.1:5173',
-        'http://127.0.0.1:5174',
     ];
 
     public static function normalizeOrigin(?string $value): string

services/nginx/app/classes/economic_transfer_queue.php

@@ -41,7 +41,7 @@ class economic_transfer_queue
         $transfer_type = $this->validateTransferType($transfer_type);
         $payload = $this->normalizePayloadForTransferType($transfer_type, $payload, $created_by);
 
-        $active_job = $this->findActiveJobByTarget($transfer_type, $payload, $created_by);
+        $active_job = $this->findActiveJobByTarget($transfer_type, $payload);
         if ($active_job !== null) {
             $target_label = $this->buildTargetLabel($transfer_type, $payload);
             $this->logQueueEvent(
@@ -135,89 +135,6 @@ class economic_transfer_queue
         return $jobs;
     }
 
-    public function getJobByIdForUser(int $job_id, int $created_by): ?array
-    {
-        global $db;
-
-        $job_id = max(0, $job_id);
-        $created_by = max(0, $created_by);
-        if ($job_id < 1 || $created_by < 1) {
-            return null;
-        }
-
-        $stmt = $db->prepare("SELECT * FROM economic_transfer_queue_jobs WHERE id = ? AND created_by = ? LIMIT 1");
-        if (!$stmt) {
-            return null;
-        }
-
-        $stmt->bind_param('ii', $job_id, $created_by);
-        if (!$stmt->execute()) {
-            $stmt->close();
-            return null;
-        }
-
-        $result = $stmt->get_result();
-        $row = $result instanceof mysqli_result ? $result->fetch_assoc() : null;
-        $stmt->close();
-
-        if (!$row) {
-            return null;
-        }
-        return $this->normalizeJobRow($row);
-    }
-
-    public function listJobsForCreatedBy(array $statuses = [], int $limit = 50, int $offset = 0, ?string $transfer_type = null, int $created_by = 0): array
-    {
-        global $db;
-
-        $created_by = max(0, $created_by);
-        if ($created_by < 1) {
-            return [];
-        }
-
-        $limit = max(1, min(500, $limit));
-        $offset = max(0, $offset);
-
-        $where = $this->buildListJobsWhereClause($statuses, $transfer_type);
-        $where .= $where === '' ? 'WHERE created_by = ' . $created_by : ' AND created_by = ' . $created_by;
-        $sql = "SELECT * FROM economic_transfer_queue_jobs $where ORDER BY id DESC LIMIT $limit OFFSET $offset";
-        $result = $db->query($sql);
-        if (!$result instanceof mysqli_result) {
-            return [];
-        }
-
-        $jobs = [];
-        while ($row = $result->fetch_assoc()) {
-            $jobs[] = $this->normalizeJobRow($row);
-        }
-        return $jobs;
-    }
-
-    public function countJobsForCreatedBy(array $statuses = [], ?string $transfer_type = null, int $created_by = 0): int
-    {
-        global $db;
-
-        $created_by = max(0, $created_by);
-        if ($created_by < 1) {
-            return 0;
-        }
-
-        $where = $this->buildListJobsWhereClause($statuses, $transfer_type);
-        $where .= $where === '' ? 'WHERE created_by = ' . $created_by : ' AND created_by = ' . $created_by;
-        $sql = "SELECT COUNT(*) AS total FROM economic_transfer_queue_jobs $where";
-        $result = $db->query($sql);
-        if (!$result instanceof mysqli_result) {
-            return 0;
-        }
-
-        $row = $result->fetch_assoc();
-        if (!is_array($row) || !isset($row['total'])) {
-            return 0;
-        }
-
-        return max(0, (int)$row['total']);
-    }
-
     public function countJobs(array $statuses = [], ?string $transfer_type = null): int
     {
         global $db;
@@ -262,7 +179,7 @@ class economic_transfer_queue
                   ON d.queue_job_id = q.id
                  AND d.user_id = $user_id
                  AND d.dismissed_status = q.status
-                WHERE q.created_by = $user_id
+                WHERE 1 = 1
                   $transfer_condition
                   AND (
                     q.status IN ('" . self::STATUS_QUEUED . "', '" . self::STATUS_PROCESSING . "')
@@ -297,7 +214,7 @@ class economic_transfer_queue
             throw new Exception('Queue job and user are required');
         }
 
-        $job = $this->getJobByIdForUser($job_id, $user_id);
+        $job = $this->getJobById($job_id);
         if ($job === null) {
             throw new Exception('Queue job not found');
         }
@@ -355,8 +272,7 @@ class economic_transfer_queue
                   ON d.queue_job_id = q.id
                  AND d.user_id = $user_id
                  AND d.dismissed_status = q.status
-                WHERE q.created_by = $user_id
-                  AND q.status IN ('" . self::STATUS_COMPLETED . "', '" . self::STATUS_FAILED . "')
+                WHERE q.status IN ('" . self::STATUS_COMPLETED . "', '" . self::STATUS_FAILED . "')
                   $transfer_condition
                   AND d.queue_job_id IS NULL
                 ON DUPLICATE KEY UPDATE dismissed_status = VALUES(dismissed_status), dismissed_at = NOW()";
@@ -368,24 +284,10 @@ class economic_transfer_queue
      * @throws Exception
      */
     public function retryJob(int $job_id): array
-    {
-        return $this->retryJobInternal($job_id);
-    }
-
-    public function retryJobForUser(int $job_id, int $created_by): array
-    {
-        return $this->retryJobInternal($job_id, $created_by);
-    }
-
-    private function retryJobInternal(int $job_id, ?int $created_by = null): array
     {
         global $db;
 
-        $job_id = max(0, $job_id);
-        $created_by = $created_by === null ? null : max(0, $created_by);
-        $existing_job = $created_by === null
-            ? $this->getJobById($job_id)
-            : $this->getJobByIdForUser($job_id, $created_by);
+        $existing_job = $this->getJobById($job_id);
         if ($existing_job === null) {
             throw new Exception('Queue job not found');
         }
@@ -396,26 +298,19 @@ class economic_transfer_queue
             throw new Exception('Queue job reached max retry attempts');
         }
 
-        $sql = "UPDATE economic_transfer_queue_jobs
+        $stmt = $db->prepare(
+            "UPDATE economic_transfer_queue_jobs
              SET status = ?, progress_percent = 0, progress_message = 'Queued for retry',
                  error_message = NULL, result_json = NULL, started_at = NULL, completed_at = NULL, locked_at = NULL
-             WHERE id = ? AND status = ?";
-        if ($created_by !== null) {
-            $sql .= " AND created_by = ?";
-        }
-
-        $stmt = $db->prepare($sql);
+             WHERE id = ? AND status = ?"
+        );
         if (!$stmt) {
             throw new Exception('Failed to prepare retry statement');
         }
 
         $queued = self::STATUS_QUEUED;
         $failed = self::STATUS_FAILED;
-        if ($created_by !== null) {
-            $stmt->bind_param('sisi', $queued, $job_id, $failed, $created_by);
-        } else {
-            $stmt->bind_param('sis', $queued, $job_id, $failed);
-        }
+        $stmt->bind_param('sis', $queued, $job_id, $failed);
         $stmt->execute();
         $affected = $stmt->affected_rows;
         $stmt->close();
@@ -426,9 +321,7 @@ class economic_transfer_queue
 
         $this->clearDismissalsForJob($job_id);
 
-        $job = $created_by === null
-            ? $this->getJobById($job_id)
-            : $this->getJobByIdForUser($job_id, $created_by);
+        $job = $this->getJobById($job_id);
         if ($job === null) {
             throw new Exception('Retry updated job could not be loaded');
         }
@@ -817,31 +710,28 @@ class economic_transfer_queue
         return $this->rejectPayload($created_by, $field_name . ' must be a boolean');
     }
 
-    private function findActiveJobByTarget(string $transfer_type, array $payload, int $created_by): ?array
+    private function findActiveJobByTarget(string $transfer_type, array $payload): ?array
     {
         return match ($transfer_type) {
             self::TYPE_ORDER_DRAFT_EXPORT, self::TYPE_ORDER_INVOICE_EXPORT => $this->findActiveJobByJsonNumericTarget(
                 $transfer_type,
                 '$.order_id',
-                (int)($payload['order_id'] ?? 0),
-                $created_by
+                (int)($payload['order_id'] ?? 0)
             ),
             self::TYPE_COLLECTED_INVOICE_EXPORT => $this->findActiveJobByJsonNumericTarget(
                 $transfer_type,
                 '$.collected_invoice_id',
-                (int)($payload['collected_invoice_id'] ?? 0),
-                $created_by
+                (int)($payload['collected_invoice_id'] ?? 0)
             ),
             default => null,
         };
     }
 
-    private function findActiveJobByJsonNumericTarget(string $transfer_type, string $json_path, int $target_value, int $created_by): ?array
+    private function findActiveJobByJsonNumericTarget(string $transfer_type, string $json_path, int $target_value): ?array
     {
         global $db;
 
-        $created_by = max(0, $created_by);
-        if ($target_value < 1 || $created_by < 1) {
+        if ($target_value < 1) {
             return null;
         }
 
@@ -851,7 +741,6 @@ class economic_transfer_queue
              WHERE transfer_type = ?
                AND status IN (?, ?)
                AND CAST(JSON_UNQUOTE(JSON_EXTRACT(payload_json, '$json_path')) AS UNSIGNED) = ?
-               AND created_by = ?
              ORDER BY id DESC
              LIMIT 1"
         );
@@ -861,7 +750,7 @@ class economic_transfer_queue
 
         $queued = self::STATUS_QUEUED;
         $processing = self::STATUS_PROCESSING;
-        $stmt->bind_param('sssii', $transfer_type, $queued, $processing, $target_value, $created_by);
+        $stmt->bind_param('sssi', $transfer_type, $queued, $processing, $target_value);
         if (!$stmt->execute()) {
             $stmt->close();
             return null;

services/nginx/app/classes/edge_broker_client.php

@@ -1,150 +0,0 @@
-<?php
-
-namespace classes;
-
-use Exception;
-
-class edge_broker_transport_exception extends Exception
-{
-    public function __construct(string $message, private readonly int $curlErrno = 0, int $code = 0, ?Exception $previous = null)
-    {
-        parent::__construct($message, $code, $previous);
-    }
-
-    public function curlErrno(): int
-    {
-        return $this->curlErrno;
-    }
-}
-
-class edge_broker_http_exception extends Exception
-{
-    public function __construct(string $message, private readonly int $statusCode, int $code = 0, ?Exception $previous = null)
-    {
-        parent::__construct($message, $code, $previous);
-    }
-
-    public function statusCode(): int
-    {
-        return $this->statusCode;
-    }
-}
-
-class edge_broker_client
-{
-    private const DEFAULT_BROKER_URL = 'http://edge-broker:4300';
-
-    public function __construct(
-        private readonly ?string $baseUrl = null,
-        private readonly ?string $sharedSecret = null,
-        private readonly int $timeoutSeconds = 10
-    ) {
-    }
-
-    public function isConfigured(): bool
-    {
-        return trim((string)$this->resolveBaseUrl()) !== '';
-    }
-
-    public function dispatchCommand(int $gatewayId, string $commandType, array $payload): array
-    {
-        $url = rtrim($this->resolveBaseUrl(), '/') . '/api/gateways/' . $gatewayId . '/commands';
-        $response = $this->request('POST', $url, [
-            'commandType' => $commandType,
-            'payload' => $payload,
-        ]);
-
-        return is_array($response) ? $response : ['ok' => false, 'response' => $response];
-    }
-
-    public function validateAgent(int $gatewayId, string $agentToken): array
-    {
-        $url = rtrim($this->resolveBaseUrl(), '/') . '/api/internal/agent/auth';
-        $response = $this->request('POST', $url, [
-            'gatewayId' => $gatewayId,
-            'agentToken' => $agentToken,
-        ]);
-
-        return is_array($response) ? $response : [];
-    }
-
-    public function validateShellSession(string $sessionToken): array
-    {
-        $url = rtrim($this->resolveBaseUrl(), '/') . '/api/internal/shell/auth';
-        $response = $this->request('POST', $url, [
-            'sessionToken' => $sessionToken,
-        ]);
-
-        return is_array($response) ? $response : [];
-    }
-
-    public function closeShellSession(int $sessionId, string $sessionToken, string $transcript, string $closedReason): array
-    {
-        $url = rtrim($this->resolveBaseUrl(), '/') . '/api/internal/shell-sessions/' . $sessionId . '/close';
-        $response = $this->request('POST', $url, [
-            'sessionToken' => $sessionToken,
-            'transcript' => $transcript,
-            'closedReason' => $closedReason,
-        ]);
-
-        return is_array($response) ? $response : [];
-    }
-
-    private function resolveBaseUrl(): string
-    {
-        return trim((string)($this->baseUrl ?? getenv('EDGE_BROKER_URL') ?: self::DEFAULT_BROKER_URL));
-    }
-
-    private function resolveSharedSecret(): string
-    {
-        return trim((string)($this->sharedSecret
-            ?? getenv('EDGE_BROKER_SHARED_SECRET')
-            ?: getenv('EDGE_INTERNAL_SECRET')
-            ?: ''));
-    }
-
-    /**
-     * @throws Exception
-     */
-    private function request(string $method, string $url, array $payload): array|object|null
-    {
-        if (trim($url) === '') {
-            throw new Exception('Edge broker URL is not configured');
-        }
-
-        $sharedSecret = $this->resolveSharedSecret();
-        if ($sharedSecret === '') {
-            throw new Exception('Edge broker shared secret is not configured');
-        }
-
-        $ch = curl_init($url);
-        curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
-        curl_setopt($ch, CURLOPT_CUSTOMREQUEST, $method);
-        curl_setopt($ch, CURLOPT_TIMEOUT, $this->timeoutSeconds);
-        curl_setopt($ch, CURLOPT_HTTPHEADER, [
-            'Content-Type: application/json',
-            'X-Edge-Broker-Secret: ' . $sharedSecret,
-        ]);
-        curl_setopt($ch, CURLOPT_POSTFIELDS, json_encode($payload, JSON_UNESCAPED_UNICODE));
-
-        $rawResponse = curl_exec($ch);
-        $statusCode = (int)curl_getinfo($ch, CURLINFO_HTTP_CODE);
-        $curlErrno = curl_errno($ch);
-        $curlError = curl_error($ch);
-        curl_close($ch);
-
-        if ($rawResponse === false) {
-            throw new edge_broker_transport_exception('Edge broker request failed: ' . $curlError, $curlErrno);
-        }
-
-        $decoded = json_decode((string)$rawResponse, true);
-        if ($statusCode >= 400) {
-            $message = is_array($decoded)
-                ? (string)($decoded['error'] ?? $decoded['message'] ?? 'Edge broker request failed')
-                : 'Edge broker request failed';
-            throw new edge_broker_http_exception($message, $statusCode);
-        }
-
-        return $decoded;
-    }
-}

services/nginx/app/classes/email.php

@@ -128,13 +128,13 @@ use Psr\Http\Client\ClientExceptionInterface;
     private function sendEmailMailerSend(string $to, string $recipient_name, string $subject, string $message, string $html = null, string $references = null, array $attachments = []): void
     {
         if (self::isFakeDeliveryEnabled()) {
-            self::recordFakeDelivery([
+            self::$fake_deliveries[] = [
                 'to' => $to,
                 'recipient_name' => $recipient_name,
                 'subject' => $subject,
                 'message' => $message,
                 'html' => $html,
-            ]);
+            ];
             return;
         }
 
@@ -225,72 +225,6 @@ use Psr\Http\Client\ClientExceptionInterface;
     public static function resetFakeDeliveries(): void
     {
         self::$fake_deliveries = [];
-        $path = self::getFakeDeliveriesPath();
-        if ($path !== null && is_file($path)) {
-            unlink($path);
-        }
-    }
-
-    public static function syncFakeDeliveries(): void
-    {
-        $path = self::getFakeDeliveriesPath();
-        if ($path === null || !is_file($path)) {
-            self::$fake_deliveries = [];
-            return;
-        }
-
-        $lines = file($path, FILE_IGNORE_NEW_LINES | FILE_SKIP_EMPTY_LINES);
-        if ($lines === false) {
-            self::$fake_deliveries = [];
-            return;
-        }
-
-        $deliveries = [];
-        foreach ($lines as $line) {
-            $delivery = json_decode($line, true);
-            if (is_array($delivery)) {
-                $deliveries[] = $delivery;
-            }
-        }
-
-        self::$fake_deliveries = $deliveries;
-    }
-
-    private static function recordFakeDelivery(array $delivery): void
-    {
-        self::$fake_deliveries[] = $delivery;
-
-        $path = self::getFakeDeliveriesPath();
-        if ($path === null) {
-            return;
-        }
-
-        $directory = dirname($path);
-        if (!is_dir($directory)) {
-            mkdir($directory, 0777, true);
-        }
-
-        file_put_contents($path, json_encode($delivery, JSON_UNESCAPED_UNICODE | JSON_UNESCAPED_SLASHES) . PHP_EOL, FILE_APPEND | LOCK_EX);
-    }
-
-    private static function getFakeDeliveriesPath(): ?string
-    {
-        if (!self::isFakeDeliveryEnabled()) {
-            return null;
-        }
-
-        $configuredPath = trim((string)(getenv('EMAIL_FAKE_DELIVERIES_PATH') ?: ''));
-        if ($configuredPath !== '') {
-            return $configuredPath;
-        }
-
-        if (getenv('RUN_API_TESTS') !== '1') {
-            return null;
-        }
-
-        return rtrim(sys_get_temp_dir(), DIRECTORY_SEPARATOR)
-            . DIRECTORY_SEPARATOR
-            . 'truckwash-email-fake-deliveries-' . md5((string)getcwd()) . '.jsonl';
     }
 
     private static function isFakeDeliveryEnabled(): bool
@@ -577,47 +511,4 @@ use Psr\Http\Client\ClientExceptionInterface;
             $this->attachments
         );
     }
-
-    /**
-     * @throws Exception
-     */
-    public function sendNewCustomerRegistrationNotifications(int $customer_number): void
-    {
-        $customer = (new users_o())->getUserByCustomerNumber($customer_number);
-        if (!$customer->exists()) {
-            throw new Exception('Customer not found with customer number: ' . $customer_number);
-        }
-
-        $customerName = $customer->getCustomerName((int)$customer->customer_number->value()) ?: 'Unknown customer';
-        $safeCustomerName = htmlspecialchars($customerName, ENT_QUOTES, 'UTF-8');
-        $safeCustomerNumber = (int)$customer->customer_number->value();
-        $customerUrl = 'https://truckwash.io/superuser/users?search=' . $safeCustomerNumber;
-        $message = "
-            <p>A new customer has registered on truckwash.io.</p>
-            <p>
-                <strong>Customer number:</strong> $safeCustomerNumber<br>
-                <strong>Customer name:</strong> $safeCustomerName
-            </p>
-            <p><a href='$customerUrl'>Open customer in Superuser</a></p>
-        ";
-
-        foreach ((new users_o())->getSuperuserNewCustomerEmailNotificationRecipients() as $recipient) {
-            $recipientEmail = trim((string)($recipient['email'] ?? ''));
-            if ($recipientEmail === '') {
-                continue;
-            }
-
-            $recipientName = trim((string)($recipient['display_name'] ?? ''));
-            if ($recipientName === '') {
-                $recipientName = $recipientEmail;
-            }
-
-            $this->sendEmail(
-                $recipientEmail,
-                $recipientName,
-                'New customer registered on Truck Wash',
-                $message,
-            );
-        }
-    }
 }

services/nginx/app/classes/invoice_period_flag_service.php

@@ -320,16 +320,6 @@ class invoice_period_flag_service
     }
 
     public function warmManualFlagsCache(): void
-    {
-        $flags = $this->fetchActiveManualFlagsFromDb();
-
-        try {
-            (new redis())->cache_invoice_period_manual_flags($flags);
-        } catch (Throwable) {
-        }
-    }
-
-    private function fetchActiveManualFlagsFromDb(): array
     {
         global $db;
 
@@ -347,7 +337,10 @@ class invoice_period_flag_service
             }
         }
 
-        return $flags;
+        try {
+            (new redis())->cache_invoice_period_manual_flags($flags);
+        } catch (Throwable) {
+        }
     }
 
     private function formatStoredFlag(array $row): array
@@ -395,11 +388,15 @@ class invoice_period_flag_service
         }
 
         if (!is_array($flags)) {
-            // Cache miss — read from the database and refresh Redis without hiding active flags.
-            $flags = $this->fetchActiveManualFlagsFromDb();
+            // Cache miss — warm on demand and re-fetch
+            $this->warmManualFlagsCache();
             try {
-                (new redis())->cache_invoice_period_manual_flags($flags);
+                $flags = (new redis())->get_invoice_period_manual_flags();
             } catch (Throwable) {
+                return [];
+            }
+            if (!is_array($flags)) {
+                return [];
             }
         }
 
@@ -528,12 +525,16 @@ class invoice_period_flag_service
         try {
             $flags = (new redis())->get_invoice_period_automatic_flags($dateFrom, $dateTo);
         } catch (Throwable) {
-            $flags = null;
+            return [];
         }
 
         if (!is_array($flags)) {
-            $flags = $this->calculateAutomaticFlagsForPeriod($dateFrom, $dateTo);
-            $this->cacheAutomaticFlagsForPeriod($dateFrom, $dateTo, $flags);
+            // Cache miss — enqueue for warming on the next cron run
+            try {
+                (new redis())->enqueue_invoice_period_warming($dateFrom, $dateTo);
+            } catch (Throwable) {
+            }
+            return [];
         }
 
         if ($onlyCustomerNumbers === null) {
@@ -548,31 +549,17 @@ class invoice_period_flag_service
 
     public function warmAutomaticFlagsForPeriod(string $dateFrom, string $dateTo): void
     {
-        [$dateFrom, $dateTo] = $this->normalizePeriodDateRange($dateFrom, $dateTo);
-        $this->cacheAutomaticFlagsForPeriod(
-            $dateFrom,
-            $dateTo,
-            $this->calculateAutomaticFlagsForPeriod($dateFrom, $dateTo)
-        );
-    }
-
-    private function calculateAutomaticFlagsForPeriod(string $dateFrom, string $dateTo): array
-    {
-        [$dateFrom, $dateTo] = $this->normalizePeriodDateRange($dateFrom, $dateTo);
         $rows = $this->getPeriodOrderItemRows($dateFrom, $dateTo, null);
         $attributes = $this->getCustomerAttributes(null);
 
-        return array_merge(
+        $flags = array_merge(
             $this->detectCustomerRuleViolations($rows, $attributes),
             $this->detectPriceMismatches($rows),
             $this->detectAbnormalQuantities($rows, $dateFrom, $dateTo),
             $this->detectVehicleTypeMismatches($rows, $dateFrom),
             $this->detectMissingXlVaskLinks($dateFrom, $dateTo, null)
         );
-    }
 
-    private function cacheAutomaticFlagsForPeriod(string $dateFrom, string $dateTo, array $flags): void
-    {
         try {
             (new redis())->cache_invoice_period_automatic_flags($dateFrom, $dateTo, $flags);
         } catch (Throwable) {
@@ -616,19 +603,14 @@ class invoice_period_flag_service
 
     private function getPeriodOrderItemRows(string $dateFrom, string $dateTo, ?array $onlyCustomerNumbers): array
     {
-        [$dateFrom, $dateTo] = $this->normalizePeriodDateRange($dateFrom, $dateTo);
         try {
             $rows = (new redis())->get_invoice_period_order_item_rows($dateFrom, $dateTo);
         } catch (Throwable) {
-            $rows = null;
+            return [];
         }
 
         if (!is_array($rows)) {
-            $rows = $this->fetchOrderItemRowsFromDb($dateFrom, $dateTo);
-            try {
-                (new redis())->cache_invoice_period_order_item_rows($dateFrom, $dateTo, $rows);
-            } catch (Throwable) {
-            }
+            return [];
         }
 
         $this->seedOrderItemsPreviewCacheFromRows($rows);
@@ -645,7 +627,6 @@ class invoice_period_flag_service
 
     public function warmOrderItemRowsForPeriod(string $dateFrom, string $dateTo): void
     {
-        [$dateFrom, $dateTo] = $this->normalizePeriodDateRange($dateFrom, $dateTo);
         $rows = $this->fetchOrderItemRowsFromDb($dateFrom, $dateTo);
         try {
             (new redis())->cache_invoice_period_order_item_rows($dateFrom, $dateTo, $rows);
@@ -653,24 +634,6 @@ class invoice_period_flag_service
         }
     }
 
-    private function normalizePeriodDateRange(string $dateFrom, string $dateTo): array
-    {
-        return [
-            $this->normalizePeriodDate($dateFrom, true),
-            $this->normalizePeriodDate($dateTo, false),
-        ];
-    }
-
-    private function normalizePeriodDate(string $date, bool $startOfDay): string
-    {
-        $timestamp = strtotime($date);
-        if ($timestamp === false) {
-            return $date;
-        }
-
-        return date($startOfDay ? 'Y-m-d 00:00:00' : 'Y-m-d 23:59:59', $timestamp);
-    }
-
     private function fetchOrderItemRowsFromDb(string $dateFrom, string $dateTo): array
     {
         global $db;
@@ -1764,7 +1727,18 @@ class invoice_period_flag_service
         if ($currentVehicleType === '' || $expectedVehicleType === '') {
             return false;
         }
-        return $currentVehicleType === $expectedVehicleType;
+        if ($currentVehicleType === $expectedVehicleType) {
+            return true;
+        }
+        // Allow a match if one normalized name's tokens are a subset of the other.
+        // E.g. "Indvendig vask Kassevogn" → "kassevogn" is a subset of
+        // "Kassevogn/varevogn" → "kassevogn varevogn", meaning the same vehicle type.
+        $currentTokens = explode(' ', $currentVehicleType);
+        $expectedTokens = explode(' ', $expectedVehicleType);
+        if (count($currentTokens) <= count($expectedTokens)) {
+            return array_diff($currentTokens, $expectedTokens) === [];
+        }
+        return array_diff($expectedTokens, $currentTokens) === [];
     }
 
     private function normalizePrimaryVehicleProductName(string $productName): string

services/nginx/app/classes/n8n.php

@@ -340,49 +340,18 @@ class n8n implements n8n_i
             throw new Exception('Webhook target must not be empty.');
         }
 
+        if (filter_var($target, FILTER_VALIDATE_URL) !== false) {
+            return $target;
+        }
+
         $baseUrl = trim((string)$this->config->webhook_base_url->getVariableValue());
         if ($baseUrl === '') {
             throw new Exception('n8n webhook base URL is not configured.');
         }
 
-        if (filter_var($target, FILTER_VALIDATE_URL) !== false) {
-            if (!$this->isAllowedWebhookAbsoluteUrl($target, $baseUrl)) {
-                throw new Exception('Webhook URL must use the configured n8n webhook host.');
-            }
-
-            return $target;
-        }
-
         return rtrim($baseUrl, '/') . '/' . ltrim($target, '/');
     }
 
-    private function isAllowedWebhookAbsoluteUrl(string $targetUrl, string $baseUrl): bool
-    {
-        $targetParts = parse_url($targetUrl);
-        $baseParts = parse_url($baseUrl);
-
-        if (!is_array($targetParts) || !is_array($baseParts)) {
-            return false;
-        }
-
-        $targetHost = strtolower((string)($targetParts['host'] ?? ''));
-        $baseHost = strtolower((string)($baseParts['host'] ?? ''));
-        if ($targetHost === '' || $baseHost === '' || $targetHost !== $baseHost) {
-            return false;
-        }
-
-        $targetScheme = strtolower((string)($targetParts['scheme'] ?? ''));
-        $baseScheme = strtolower((string)($baseParts['scheme'] ?? ''));
-        if ($targetScheme === '' || $baseScheme === '' || $targetScheme !== $baseScheme) {
-            return false;
-        }
-
-        $targetPort = (int)($targetParts['port'] ?? ($targetScheme === 'https' ? 443 : 80));
-        $basePort = (int)($baseParts['port'] ?? ($baseScheme === 'https' ? 443 : 80));
-
-        return $targetPort === $basePort;
-    }
-
     /**
      * @throws Exception
      */

services/nginx/app/classes/order_reference_suggestions_service.php

@@ -46,7 +46,7 @@ class order_reference_suggestions_service
         $rows = [
             ...$this->fetchBookingRows($departmentId, $search),
             ...$this->fetchOrderRows($departmentId, $search),
-            ...$this->fetchVehicleRows($departmentId, $customerId, $plates, $search),
+            ...$this->fetchVehicleRows($customerId, $plates, $search),
         ];
 
         $suggestions = $this->aggregateRows($rows, $search, $customerId, $plates);
@@ -137,7 +137,7 @@ class order_reference_suggestions_service
      * @param array<int, string> $plates
      * @return array<int, array<string, mixed>>
      */
-    private function fetchVehicleRows(int $departmentId, ?int $customerId, array $plates, string $search): array
+    private function fetchVehicleRows(?int $customerId, array $plates, string $search): array
     {
         $contextWhere = [];
         $params = [];
@@ -171,10 +171,6 @@ class order_reference_suggestions_service
             $params['search'] = '%' . $this->lower($search) . '%';
         }
 
-        $where[] = $this->vehicleDepartmentAccessPredicate();
-        $params['orders_department_id'] = $departmentId;
-        $params['bookings_department_id'] = $departmentId;
-
         $sql = "SELECT
                     'vehicle' AS source,
                     id AS origin_id,
@@ -194,41 +190,6 @@ class order_reference_suggestions_service
         return $this->fetchRows($sql, $params);
     }
 
-    private function vehicleDepartmentAccessPredicate(): string
-    {
-        $ordersWhere = [
-            'authorized_orders.department_id = :orders_department_id',
-            '(authorized_orders.customer_id = customer_vehicles.customer_id'
-                . " OR UPPER(REPLACE(authorized_orders.reg_1, ' ', '')) = UPPER(REPLACE(customer_vehicles.reg, ' ', ''))"
-                . " OR UPPER(REPLACE(authorized_orders.reg_2, ' ', '')) = UPPER(REPLACE(customer_vehicles.reg, ' ', ''))"
-                . " OR UPPER(REPLACE(authorized_orders.reg_3, ' ', '')) = UPPER(REPLACE(customer_vehicles.reg, ' ', '')))"
-        ];
-        if ($this->tableHasColumn('orders', 'deleted_at')) {
-            $ordersWhere[] = 'authorized_orders.deleted_at IS NULL';
-        }
-
-        $bookingsWhere = [
-            'authorized_bookings.department = :bookings_department_id',
-            '(authorized_bookings.customer_number = customer_vehicles.customer_id'
-                . " OR UPPER(REPLACE(authorized_bookings.reg_1, ' ', '')) = UPPER(REPLACE(customer_vehicles.reg, ' ', ''))"
-                . " OR UPPER(REPLACE(authorized_bookings.reg_2, ' ', '')) = UPPER(REPLACE(customer_vehicles.reg, ' ', ''))"
-                . " OR UPPER(REPLACE(authorized_bookings.reg_3, ' ', '')) = UPPER(REPLACE(customer_vehicles.reg, ' ', '')))"
-        ];
-        if ($this->tableHasColumn('order_bookings', 'deleted_at')) {
-            $bookingsWhere[] = 'authorized_bookings.deleted_at IS NULL';
-        }
-
-        return '(EXISTS (
-                    SELECT 1
-                    FROM orders authorized_orders
-                    WHERE ' . implode(' AND ', $ordersWhere) . '
-                ) OR EXISTS (
-                    SELECT 1
-                    FROM order_bookings authorized_bookings
-                    WHERE ' . implode(' AND ', $bookingsWhere) . '
-                ))';
-    }
-
     /**
      * @param array<string, mixed> $params
      * @return array<int, array<string, mixed>>

services/nginx/app/classes/orders_schema_bootstrap.php

@@ -58,9 +58,6 @@ class orders_schema_bootstrap
             || !self::columnExists($db, 'orders', 'booking_id')
             || !self::columnExists($db, 'orders', 'po')
             || !self::columnExists($db, 'order_bookings', 'po')
-            || !self::columnExists($db, 'order_bookings', 'customer_number')
-            || !self::columnExists($db, 'order_bookings', 'department')
-            || !self::columnExists($db, 'order_bookings', 'deleted_at')
         ) {
             return;
         }
@@ -68,9 +65,6 @@ class orders_schema_bootstrap
         $db->query(
             "UPDATE orders o
                 INNER JOIN order_bookings b ON b.id = o.booking_id
-                    AND b.customer_number = o.customer_id
-                    AND b.department = o.department_id
-                    AND b.deleted_at IS NULL
                 SET o.po = b.po
                 WHERE o.booking_id IS NOT NULL
                     AND o.booking_id > 0

services/nginx/app/classes/pdf_store.php

@@ -47,12 +47,8 @@ class pdf_store implements minio_pdfs_i
      */
     public function download(string $file): string
     {
-        if ($this->shouldUseLocalTestStorage()) {
-            return $this->getLocalTestObjectPath($file);
-        }
-
         $path = '/tmp/' . $file;
-        self::getS3Client()->getObject([
+        $result = self::getS3Client()->getObject([
             'Bucket' => self::getBucket(),
             'Key' => $file,
             'SaveAs' => $path

services/nginx/app/classes/redis.php

@@ -392,19 +392,7 @@ class redis implements redis_i
 
     private function invoicePeriodCacheKey(string $prefix, string $dateFrom, string $dateTo): string
     {
-        return $prefix . ':'
-            . $this->normalizeInvoicePeriodCacheDate($dateFrom, true) . ':'
-            . $this->normalizeInvoicePeriodCacheDate($dateTo, false);
-    }
-
-    private function normalizeInvoicePeriodCacheDate(string $date, bool $startOfDay): string
-    {
-        $timestamp = strtotime($date);
-        if ($timestamp === false) {
-            return $date;
-        }
-
-        return date($startOfDay ? 'Y-m-d 00:00:00' : 'Y-m-d 23:59:59', $timestamp);
+        return $prefix . ':' . $dateFrom . ':' . $dateTo;
     }
 
     private function workfeedEmployeeNameCacheKey(string $employeeId): string
@@ -524,11 +512,7 @@ class redis implements redis_i
      */
     public function enqueue_invoice_period_warming(string $dateFrom, string $dateTo): self
     {
-        $this->get_client()->sadd('invoice_period_warming_queue', [
-            $this->normalizeInvoicePeriodCacheDate($dateFrom, true)
-                . '|'
-                . $this->normalizeInvoicePeriodCacheDate($dateTo, false),
-        ]);
+        $this->get_client()->sadd('invoice_period_warming_queue', [$dateFrom . '|' . $dateTo]);
         return $this;
     }
 

services/nginx/app/classes/release_manager_schema_bootstrap.php

@@ -118,35 +118,6 @@ class release_manager_schema_bootstrap
                 INDEX idx_release_targets_coolify (coolify_instance_id, coolify_service_uuid)
             ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci",
 
-            "CREATE TABLE IF NOT EXISTS release_auto_sync_events (
-                id BIGINT UNSIGNED AUTO_INCREMENT PRIMARY KEY,
-                channel_id BIGINT UNSIGNED NOT NULL,
-                app VARCHAR(16) NOT NULL,
-                repository VARCHAR(255) NOT NULL,
-                branch VARCHAR(128) NOT NULL,
-                commit_sha VARCHAR(64) NOT NULL,
-                status VARCHAR(32) NOT NULL DEFAULT 'pending',
-                source VARCHAR(64) NULL,
-                workflow_url VARCHAR(512) NULL,
-                gate_operation_id BIGINT UNSIGNED NULL,
-                sync_operation_id BIGINT UNSIGNED NULL,
-                deployment_id BIGINT UNSIGNED NULL,
-                error_message TEXT NULL,
-                metadata_json LONGTEXT NULL,
-                received_at DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP,
-                gate_passed_at DATETIME NULL,
-                synced_at DATETIME NULL,
-                promoted_at DATETIME NULL,
-                failed_at DATETIME NULL,
-                created_at TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP,
-                updated_at TIMESTAMP NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
-                UNIQUE KEY uq_release_auto_sync_event (channel_id, app, repository, branch, commit_sha),
-                INDEX idx_release_auto_sync_channel_status (channel_id, status, updated_at),
-                INDEX idx_release_auto_sync_gate (gate_operation_id),
-                INDEX idx_release_auto_sync_sync (sync_operation_id),
-                INDEX idx_release_auto_sync_deployment (deployment_id)
-            ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci",
-
             "CREATE TABLE IF NOT EXISTS release_service_sets (
                 id BIGINT UNSIGNED AUTO_INCREMENT PRIMARY KEY,
                 channel_id BIGINT UNSIGNED NULL,
@@ -437,7 +408,6 @@ class release_manager_schema_bootstrap
             'release_versions',
             'release_channel_versions',
             'release_assignments',
-            'release_auto_sync_events',
             'release_service_sets',
             'release_deployments',
             'release_bundles',

services/nginx/app/classes/selfserve_schema_bootstrap.php

@@ -95,7 +95,7 @@ class selfserve_schema_bootstrap
                 session_id INT NOT NULL,
                 task_id INT NULL,
                 task_text VARCHAR(255) NOT NULL,
-                description TEXT NULL,
+                description VARCHAR(255) NULL,
                 services JSON NULL,
                 buttons JSON NULL,
                 dynamic_image_id INT NULL,
@@ -139,28 +139,6 @@ class selfserve_schema_bootstrap
                 UNIQUE KEY uniq_selfserve_vhw_department (department_id),
                 INDEX idx_selfserve_vhw_dept_updated (department_id, updated_at)
             ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci",
-
-            "CREATE TABLE IF NOT EXISTS department_selfserve_path_confirmations (
-                id INT AUTO_INCREMENT PRIMARY KEY,
-                department_id INT NOT NULL,
-                lane_id INT NULL,
-                vehicle_type_id INT NULL,
-                config_version_id INT NULL,
-                config_source VARCHAR(32) NOT NULL DEFAULT 'draft',
-                path_signature VARCHAR(128) NOT NULL,
-                result_signature VARCHAR(128) NOT NULL,
-                answers_json JSON NOT NULL,
-                result_json JSON NOT NULL,
-                scope_json JSON NULL,
-                confirmed_by INT NULL,
-                confirmed_at DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP,
-                stale_reason VARCHAR(255) NULL,
-                created_at TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP,
-                updated_at TIMESTAMP NULL DEFAULT NULL ON UPDATE CURRENT_TIMESTAMP,
-                deleted_at TIMESTAMP NULL DEFAULT NULL,
-                INDEX idx_selfserve_path_conf_department_scope (department_id, lane_id, vehicle_type_id, config_version_id),
-                INDEX idx_selfserve_path_conf_signature (department_id, config_version_id, path_signature)
-            ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci",
         ];
 
         foreach ($queries as $sql) {
@@ -197,18 +175,6 @@ class selfserve_schema_bootstrap
             'gate_ref_id',
             'ALTER TABLE department_selfserve_tasks ADD COLUMN gate_ref_id INT NULL AFTER gate_type'
         );
-        self::ensureColumnDataType(
-            'department_selfserve_tasks',
-            'description',
-            ['text', 'mediumtext', 'longtext'],
-            'ALTER TABLE department_selfserve_tasks MODIFY COLUMN description TEXT NULL AFTER task'
-        );
-        self::ensureColumnDataType(
-            'selfserve_wash_session_tasks',
-            'description',
-            ['text', 'mediumtext', 'longtext'],
-            'ALTER TABLE selfserve_wash_session_tasks MODIFY COLUMN description TEXT NULL AFTER task_text'
-        );
         self::ensureColumn(
             'selfserve_wash_session_tasks',
             'dynamic_images_vehicle_type',
@@ -251,49 +217,4 @@ class selfserve_schema_bootstrap
         }
         $db->query($alterSql);
     }
-
-    /**
-     * @param array<int,string> $acceptedDataTypes
-     */
-    public static function ensureColumnDataType(string $table, string $column, array $acceptedDataTypes, string $alterSql): void
-    {
-        global $db;
-
-        $columnInfo = self::columnInfo($table, $column);
-        if ($columnInfo === null) {
-            return;
-        }
-
-        $dataType = strtolower((string)($columnInfo['DATA_TYPE'] ?? ''));
-        $acceptedDataTypes = array_map(static fn(string $type): string => strtolower($type), $acceptedDataTypes);
-        if (in_array($dataType, $acceptedDataTypes, true)) {
-            return;
-        }
-
-        $db->query($alterSql);
-    }
-
-    /**
-     * @return array<string,mixed>|null
-     */
-    public static function columnInfo(string $table, string $column): ?array
-    {
-        global $db;
-        $table = $db->escape_string($table);
-        $column = $db->escape_string($column);
-        $database = $db->escape_string($db->getDatabase());
-
-        $sql = "SELECT DATA_TYPE, COLUMN_TYPE, IS_NULLABLE, CHARACTER_MAXIMUM_LENGTH
-                FROM information_schema.COLUMNS
-                WHERE TABLE_SCHEMA = '$database'
-                  AND TABLE_NAME = '$table'
-                  AND COLUMN_NAME = '$column'
-                LIMIT 1";
-        $result = $db->query($sql);
-        if (!$result) {
-            return null;
-        }
-        $row = $result->fetch_assoc();
-        return is_array($row) ? $row : null;
-    }
 }

services/nginx/app/classes/shelly.php

@@ -16,8 +16,6 @@ class shelly implements shelly_i
     private const SHELLY_RATE_LIMIT_WAIT_TIMEOUT_SECONDS = 20;
     private const SHELLY_RATE_LIMIT_WINDOW_MILLISECONDS = 2000;
     private const SHELLY_RATE_LIMIT_GATE_KEY = 'shelly_cloud_rate_limit_gate';
-    private const SHELLY_CONNECT_TIMEOUT_SECONDS = 2;
-    private const SHELLY_REQUEST_TIMEOUT_SECONDS = 5;
     /**
      * @var array<int,array<string,mixed>>
      */
@@ -180,9 +178,6 @@ class shelly implements shelly_i
         curl_setopt($ch, CURLOPT_HTTPHEADER, [
             'Content-Type: application/json',
         ]);
-        curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, self::SHELLY_CONNECT_TIMEOUT_SECONDS);
-        curl_setopt($ch, CURLOPT_TIMEOUT, self::SHELLY_REQUEST_TIMEOUT_SECONDS);
-        curl_setopt($ch, CURLOPT_NOSIGNAL, true);
         // Execute the request
         $response = curl_exec($ch);
         // Get the status code
@@ -229,9 +224,6 @@ class shelly implements shelly_i
         );
         curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
         curl_setopt($ch, CURLOPT_HTTPGET, true);
-        curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, self::SHELLY_CONNECT_TIMEOUT_SECONDS);
-        curl_setopt($ch, CURLOPT_TIMEOUT, self::SHELLY_REQUEST_TIMEOUT_SECONDS);
-        curl_setopt($ch, CURLOPT_NOSIGNAL, true);
 
         $response = curl_exec($ch);
         $status_code = curl_getinfo($ch, CURLINFO_HTTP_CODE);

services/nginx/app/classes/shelly_relay_inventory.php

@@ -33,7 +33,7 @@ class shelly_relay_inventory
      * @return array<int,array<string,mixed>>
      * @throws Exception
      */
-    public function listRelayOptions(bool $include_sensitive_network_details = false): array
+    public function listRelayOptions(): array
     {
         $devices_status = $this->fetchOwnedDevicesStatus();
         $device_catalog = $this->fetchOwnedDeviceCatalog();
@@ -49,8 +49,7 @@ class shelly_relay_inventory
 
             $option = $this->buildRelayOption(
                 $normalized_device,
-                is_array($catalog_entry) ? $catalog_entry : null,
-                $include_sensitive_network_details
+                is_array($catalog_entry) ? $catalog_entry : null
             );
             if ($option === null) {
                 continue;
@@ -161,11 +160,7 @@ class shelly_relay_inventory
      * @param array<string,mixed> $device
      * @return array<string,mixed>|null
      */
-    private function buildRelayOption(
-        array $device,
-        ?array $catalog_entry = null,
-        bool $include_sensitive_network_details = false
-    ): ?array
+    private function buildRelayOption(array $device, ?array $catalog_entry = null): ?array
     {
         if ($device === [] || !$this->isRelayCapableDevice($device)) {
             return null;
@@ -208,8 +203,9 @@ class shelly_relay_inventory
             $online = $this->normalizeBoolean($catalog_entry['cloud_online'] ?? null);
         }
         $status_color = $this->extractStatusColor($online);
+        $local_ip = $this->extractLocalIp($device, $catalog_entry);
 
-        $option = [
+        return [
             'id' => $device_id,
             'name' => $this->buildRelayLabel(
                 $device_type,
@@ -227,15 +223,10 @@ class shelly_relay_inventory
             'device_generation' => $device_generation,
             'control_type' => $control_type,
             'control_name' => $control_name !== '' ? $control_name : null,
+            'local_ip' => $local_ip,
             'status_color' => $status_color,
             'online' => $online,
         ];
-
-        if ($include_sensitive_network_details) {
-            $option['local_ip'] = $this->extractLocalIp($device, $catalog_entry);
-        }
-
-        return $option;
     }
 
     /**

services/nginx/app/classes/slack.php

@@ -6,25 +6,13 @@ use GuzzleHttp\Client;
 use interfaces\notification_i;
 use objects\departments_o;
 use objects\users_o;
-use slack\slack_c;
 use traits\notification_t;
 
-require_once WD . '/modules/slack/slack_c.php';
 
 class slack implements notification_i
 {
     use notification_t;
 
-    private ?slack_c $config = null;
-
-    public function getConfig(): slack_c
-    {
-        if ($this->config === null) {
-            $this->config = new slack_c();
-        }
-
-        return $this->config;
-    }
 
     /**
      * @inheritdoc
@@ -134,7 +122,7 @@ class slack implements notification_i
             . "Status: $status";
     }
 
-    public function send_message(string $string, ?string $module = null): void
+    public function send_message(string $string, string $module = null): void
     {
         global $SLACK_DEFAULT_WEBHOOK;
         // Format the message if a module is provided
@@ -144,90 +132,4 @@ class slack implements notification_i
         // Send the message to the slack webhook
         self::add_log(self::send_webhook_message($string, $SLACK_DEFAULT_WEBHOOK));
     }
-
-    public function send_customer_registration_notification(int $customer_number): self
-    {
-        $webhook = $this->get_customer_registration_webhook_url();
-        if ($webhook === '') {
-            return $this;
-        }
-
-        self::add_log(self::send_webhook_message(
-            $this->format_customer_registration($customer_number),
-            $webhook
-        ));
-
-        return $this;
-    }
-
-    /**
-     * Send a sanitized customer-registration test notification to the saved Slack webhook.
-     *
-     * @return array{configured:bool,sent:bool,message:string}
-     */
-    public function test_customer_registration_webhook(): array
-    {
-        $webhook = $this->get_customer_registration_webhook_url();
-        if ($webhook === '') {
-            return [
-                'configured' => false,
-                'sent' => false,
-                'message' => 'Slack customer registration webhook URL is not configured.',
-            ];
-        }
-
-        $result = $this->send_webhook_message(
-            $this->format_customer_registration_test(),
-            $webhook
-        );
-        $sent = $this->is_webhook_send_successful($result);
-
-        self::add_log($sent
-            ? 'Slack customer registration test webhook sent successfully.'
-            : 'Slack customer registration test webhook failed.'
-        );
-
-        return [
-            'configured' => true,
-            'sent' => $sent,
-            'message' => $sent
-                ? 'Slack test message sent successfully.'
-                : 'Slack test message failed.',
-        ];
-    }
-
-    protected function get_customer_registration_webhook_url(): string
-    {
-        return trim((string)$this->getConfig()->customer_registration_webhook_url->getVariableValue());
-    }
-
-    public function is_webhook_send_successful(string $result): bool
-    {
-        return !str_starts_with($result, 'Failed to send message:');
-    }
-
-    public function format_customer_registration(int $customer_number): string
-    {
-        $customer = (new users_o())->getUserByCustomerNumber($customer_number);
-        $customerName = $customer->exists()
-            ? $customer->getCustomerName((int)$customer->customer_number->value())
-            : '';
-        $customerName = trim((string)$customerName);
-        if ($customerName === '') {
-            $customerName = 'Unknown customer';
-        }
-
-        $safeCustomerNumber = (int)$customer_number;
-        $customerUrl = 'https://truckwash.io/superuser/users?search=' . $safeCustomerNumber;
-
-        return "*New customer registered on Truck Wash*\n"
-            . "Customer: $customerName ($safeCustomerNumber)\n"
-            . "Open in Superuser: $customerUrl";
-    }
-
-    public function format_customer_registration_test(): string
-    {
-        return "*Truck Wash Slack test*\n"
-            . "Customer registration notifications are configured correctly.";
-    }
-}
+}

services/nginx/app/classes/system_search_service.php

@@ -54,7 +54,6 @@ class system_search_service
         $allowedTypes = $this->normalizeTypes((array)($options['allowed_types'] ?? []));
         $ownOnlyTypes = $this->normalizeTypes((array)($options['own_only_types'] ?? []));
         $ownCustomerNumber = isset($options['own_customer_number']) ? (int)$options['own_customer_number'] : null;
-        $allowedDepartmentIds = array_values(array_unique(array_map('intval', (array)($options['allowed_department_ids'] ?? []))));
         $permissionsCatalogAll = (array)($options['permissions_catalog_all'] ?? []);
         $permissionsCatalogOwn = (array)($options['permissions_catalog_own'] ?? []);
         $moduleConfigVisibility = (array)($options['module_config_visibility'] ?? []);
@@ -108,7 +107,6 @@ class system_search_service
             'offset' => $offset,
             'own' => $ownCustomerNumber,
             'own_only' => $ownOnlyTypes,
-            'dept' => $allowedDepartmentIds,
             'assoc' => $includeAssociations,
             'dbg' => $debugIntent,
             'ctx' => $this->permissionContextFingerprint($permissionsCatalogAll, $permissionsCatalogOwn, $moduleConfigVisibility),
@@ -132,8 +130,7 @@ class system_search_service
             $ownCustomerNumber,
             $permissionsCatalogAll,
             $permissionsCatalogOwn,
-            $moduleConfigVisibility,
-            $allowedDepartmentIds
+            $moduleConfigVisibility
         );
 
         $intentAssociationHint = false;
@@ -183,8 +180,7 @@ class system_search_service
                     $ownCustomerNumber,
                     $permissionsCatalogAll,
                     $permissionsCatalogOwn,
-                    $moduleConfigVisibility,
-                    $allowedDepartmentIds
+                    $moduleConfigVisibility
                 );
             } else {
                 $intentMeta['status'] = 'fallback';
@@ -211,29 +207,25 @@ class system_search_service
                     $activeTypes,
                     $this->associationEntityTypes()
                 ));
-                $associationTypes = array_values(array_diff($associationTypes, $ownOnlyTypes));
-                if (!empty($associationTypes)) {
-                    foreach ($customerNumbers as $customerNumber) {
-                        $associated = $this->executeLexicalSearch(
-                            $associationTypes,
-                            [(string)$customerNumber],
-                            [],
-                            $ownOnlyTypes,
-                            $ownCustomerNumber,
-                            $permissionsCatalogAll,
-                            $permissionsCatalogOwn,
-                            $moduleConfigVisibility,
-                            $allowedDepartmentIds,
-                            [$customerNumber]
-                        );
-                        foreach ($associated as &$item) {
-                            if (!isset($item['association_reason'])) {
-                                $item['association_reason'] = 'customer:' . $customerNumber;
-                            }
-                            $item['score'] = max((int)$item['score'], 35);
+                foreach ($customerNumbers as $customerNumber) {
+                    $associated = $this->executeLexicalSearch(
+                        $associationTypes,
+                        [(string)$customerNumber],
+                        [],
+                        $ownOnlyTypes,
+                        $ownCustomerNumber,
+                        $permissionsCatalogAll,
+                        $permissionsCatalogOwn,
+                        $moduleConfigVisibility,
+                        [$customerNumber]
+                    );
+                    foreach ($associated as &$item) {
+                        if (!isset($item['association_reason'])) {
+                            $item['association_reason'] = 'customer:' . $customerNumber;
                         }
-                        $initialResults = $this->mergeResults($initialResults, $associated);
+                        $item['score'] = max((int)$item['score'], 35);
                     }
+                    $initialResults = $this->mergeResults($initialResults, $associated);
                 }
             }
         }
@@ -312,7 +304,6 @@ class system_search_service
      * @param array<string, string> $permissionsCatalogAll
      * @param array<int, string> $permissionsCatalogOwn
      * @param array<string, bool> $moduleConfigVisibility
-     * @param array<int, int> $allowedDepartmentIds
      * @param array<int, int> $forcedCustomerNumbers
      * @return array<int, array<string, mixed>>
      */
@@ -325,7 +316,6 @@ class system_search_service
         array $permissionsCatalogAll,
         array $permissionsCatalogOwn,
         array $moduleConfigVisibility,
-        array $allowedDepartmentIds = [],
         array $forcedCustomerNumbers = []
     ): array {
         $results = [];
@@ -344,7 +334,6 @@ class system_search_service
                     $ownOnly,
                     $ownCustomerNumber,
                     $moduleConfigVisibility,
-                    $allowedDepartmentIds,
                     $forcedCustomerNumbers
                 );
                 if (empty($rows)) {
@@ -357,7 +346,6 @@ class system_search_service
                         $permissionsCatalogAll,
                         $permissionsCatalogOwn,
                         $moduleConfigVisibility,
-                        $allowedDepartmentIds,
                         $forcedCustomerNumbers
                     );
                 }
@@ -371,7 +359,6 @@ class system_search_service
                     $permissionsCatalogAll,
                     $permissionsCatalogOwn,
                     $moduleConfigVisibility,
-                    $allowedDepartmentIds,
                     $forcedCustomerNumbers
                 );
             }
@@ -385,7 +372,6 @@ class system_search_service
      * @param array<string, string> $permissionsCatalogAll
      * @param array<int, string> $permissionsCatalogOwn
      * @param array<string, bool> $moduleConfigVisibility
-     * @param array<int, int> $allowedDepartmentIds
      * @param array<int, int> $forcedCustomerNumbers
      * @return array<int, array<string, mixed>>
      */
@@ -398,7 +384,6 @@ class system_search_service
         array $permissionsCatalogAll,
         array $permissionsCatalogOwn,
         array $moduleConfigVisibility,
-        array $allowedDepartmentIds,
         array $forcedCustomerNumbers
     ): array {
         if ($this->isGenericEntityType($entityType)) {
@@ -408,7 +393,6 @@ class system_search_service
                 $entityBoost,
                 $ownOnly,
                 $ownCustomerNumber,
-                $allowedDepartmentIds,
                 $forcedCustomerNumbers
             );
         }
@@ -455,24 +439,9 @@ class system_search_service
         return empty(array_intersect($normalizedDirty, system_search_registry::sourceTablesForEntityType($entityType)));
     }
 
-    private function indexedEntitySupportsDepartmentFilter(string $entityType): bool
-    {
-        $entityType = trim(mb_strtolower($entityType));
-        if (in_array($entityType, ['orders', 'objects'], true)) {
-            return true;
-        }
-
-        $config = system_search_registry::genericEntityConfigs()[$entityType] ?? null;
-        return is_array($config)
-            && isset($config['department_field'])
-            && is_string($config['department_field'])
-            && trim($config['department_field']) !== '';
-    }
-
     /**
      * @param array<int, string> $terms
      * @param array<string, bool> $moduleConfigVisibility
-     * @param array<int, int> $allowedDepartmentIds
      * @param array<int, int> $forcedCustomerNumbers
      * @return array<int, array<string, mixed>>
      */
@@ -483,7 +452,6 @@ class system_search_service
         bool $ownOnly,
         ?int $ownCustomerNumber,
         array $moduleConfigVisibility,
-        array $allowedDepartmentIds,
         array $forcedCustomerNumbers
     ): array {
         global $db;
@@ -505,9 +473,6 @@ class system_search_service
         if (!empty($customerNumbers)) {
             $wheres[] = "`customer_number` IN (" . implode(',', array_map('intval', $customerNumbers)) . ")";
         }
-        if (!empty($allowedDepartmentIds) && $this->indexedEntitySupportsDepartmentFilter($entityType)) {
-            $wheres[] = "`department_id` IN (" . implode(',', array_map('intval', $allowedDepartmentIds)) . ")";
-        }
 
         $booleanQuery = $this->buildBooleanFullTextQuery($terms);
         $rows = [];
@@ -1523,7 +1488,6 @@ class system_search_service
 
     /**
      * @param array<int, string> $terms
-     * @param array<int, int> $allowedDepartmentIds
      * @param array<int, int> $forcedCustomerNumbers
      * @return array<int, array<string, mixed>>
      */
@@ -1533,7 +1497,6 @@ class system_search_service
         int $entityBoost,
         bool $ownOnly,
         ?int $ownCustomerNumber,
-        array $allowedDepartmentIds = [],
         array $forcedCustomerNumbers = []
     ): array {
         if (empty($terms)) {
@@ -1639,9 +1602,7 @@ class system_search_service
             $customerNumbers,
             $customerField,
             $customerFieldMode,
-            $fixedConditions,
-            $allowedDepartmentIds,
-            $departmentField
+            $fixedConditions
         );
 
         $this->primeCustomerContexts(array_values(array_unique(array_filter(
@@ -1837,8 +1798,6 @@ class system_search_service
      * @param string|null $customerField
      * @param string $customerFieldMode
      * @param array<string, mixed> $fixedConditions
-     * @param array<int, int> $departmentIds
-     * @param string|null $departmentField
      * @return array<int, array<string, mixed>>
      */
     private function searchTable(
@@ -1849,9 +1808,7 @@ class system_search_service
         array $customerNumbers = [],
         ?string $customerField = null,
         string $customerFieldMode = 'default',
-        array $fixedConditions = [],
-        array $departmentIds = [],
-        ?string $departmentField = null
+        array $fixedConditions = []
     ): array {
         global $db;
 
@@ -1887,10 +1844,6 @@ class system_search_service
             }
         }
 
-        if (!empty($departmentIds) && $departmentField !== null && in_array($departmentField, $fields, true)) {
-            $wheres[] = "`$departmentField` IN (" . implode(',', array_map('intval', $departmentIds)) . ")";
-        }
-
         $termClauses = [];
         foreach ($terms as $term) {
             $escaped = $db->escape_string($term);

services/nginx/app/classes/workfeed.php

@@ -6,7 +6,6 @@ require_once WD . '/modules/workfeed/workfeed_c.php';
 
 use Exception;
 use interfaces\workfeed_i;
-use workfeed\config\workfeed_api_url_c;
 use workfeed\workfeed_c;
 
 class workfeed implements workfeed_i
@@ -85,7 +84,7 @@ class workfeed implements workfeed_i
         $companyId = $this->requireConfiguredCompanyId();
 
         $url = $this->buildUrl(
-            workfeed_api_url_c::normalizeApiUrlForValidation((string)$this->config->api_url->getVariableValue()),
+            $this->config->api_url->getVariableValue(),
             '/companies/' . rawurlencode($companyId) . '/' . ltrim($path, '/'),
             $query
         );
@@ -183,10 +182,7 @@ class workfeed implements workfeed_i
     private function requireConfiguredApiUrl(): void
     {
         $url = trim((string)$this->config->api_url->getVariableValue());
-        if ($url === ''
-            || filter_var(workfeed_api_url_c::normalizeApiUrlForValidation($url), FILTER_VALIDATE_URL) === false
-            || !workfeed_api_url_c::isTrustedApiUrl($url)
-        ) {
+        if ($url === '' || filter_var($this->normalizeUrlForValidation($url), FILTER_VALIDATE_URL) === false) {
             throw new Exception('Invalid Workfeed API URL configured.');
         }
     }
@@ -214,6 +210,15 @@ class workfeed implements workfeed_i
         return $companyId;
     }
 
+    private function normalizeUrlForValidation(string $url): string
+    {
+        if (preg_match('#^https?://#i', $url)) {
+            return $url;
+        }
+
+        return 'https://' . ltrim($url, '/');
+    }
+
     /**
      * @throws Exception
      */

services/nginx/app/composer.json

@@ -1,10 +1,6 @@
 {
     "scripts": {
         "test": "composer test:unit",
-        "analyse": "vendor/bin/phpstan analyse --configuration=phpstan.neon.dist --memory-limit=1G --no-progress",
-        "static": "@analyse",
-        "rector:dry-run": "@php -d error_reporting=0 -d display_errors=0 -d log_errors=0 vendor/bin/rector process --dry-run --config rector.php",
-        "rector:fix": "@php -d error_reporting=0 -d display_errors=0 -d log_errors=0 vendor/bin/rector process --config rector.php",
         "test:unit": "vendor/bin/pest --testsuite=Unit --colors=always",
         "test:integration": "vendor/bin/pest --testsuite=Integration --colors=always",
         "test:api": [

services/nginx/app/cron/Cron.php

@@ -19,8 +19,6 @@ use classes\slack as Slack;
 use classes\email as Email;
 use classes\gatewayapi as GatewayAPI;
 use dynamicimages\images\machine_1;
-use modules\selfserve\config\selfserve_dynamic_image_size_c;
-use modules\selfserve\selfserve_c;
 use goals\classes\goals_criteria;
 use goals\services\goals_progress_alert_renderer;
 use goals\helpers\goals_criteria_progress_alert_destination as Dest;
@@ -35,8 +33,6 @@ use objects\users_o;
 use routes\moduleWeatherAPIRoute;
 
 require_once __DIR__ . '/../classes/economic_transfer_executor.php';
-
-const DYNAMIC_IMAGE_RELEVANT_MAX_WIDTH = 1600;
 require_once __DIR__ . '/../classes/economic_transfer_queue_schema_bootstrap.php';
 require_once __DIR__ . '/../classes/economic_transfer_queue.php';
 require_once __DIR__ . '/../classes/workfeed_employee_name_formatter.php';
@@ -934,7 +930,6 @@ function buildDynamicImageCacheKey(array $variant): string
         'current_step' => (int)($variant['current_step'] ?? 0),
         'only_current_step' => (bool)($variant['only_current_step'] ?? false),
         'vehicle_type' => $variant['vehicle_type'] ?? null,
-        'dynamic_image_size' => getSelfServeDynamicImageSizeModeForCron(),
     ];
 
     $json = json_encode($cacheParams);
@@ -967,11 +962,16 @@ function renderDynamicImageVariant(int $dynamicImageId, ?array $buttons, int $cu
         $image->current_step = max(0, $currentStep);
         $image->only_generate_current_step = $onlyCurrentStep;
         $image->setup();
-        if (getSelfServeDynamicImageSizeModeForCron() === selfserve_dynamic_image_size_c::SIZE_RELEVANT) {
-            $image->resizeToMaxWidth(DYNAMIC_IMAGE_RELEVANT_MAX_WIDTH);
-        }
 
-        return $image->exportBinary('png');
+        $dataUri = $image->exportAsBase64('png');
+        if (!preg_match('/^data:image\/png;base64,(.*)$/', $dataUri, $matches)) {
+            return null;
+        }
+        $imageData = base64_decode($matches[1], true);
+        if ($imageData === false) {
+            return null;
+        }
+        return $imageData;
     } catch (Throwable $e) {
         warn('PreRenderDynamicImagesCron: render failed for dynamic_image_id=' . $dynamicImageId . ': ' . $e->getMessage());
         return null;
@@ -985,19 +985,6 @@ function renderDynamicImageVariant(int $dynamicImageId, ?array $buttons, int $cu
     }
 }
 
-function getSelfServeDynamicImageSizeModeForCron(): string
-{
-    try {
-        $mode = (string)(new selfserve_c())->dynamic_image_size->getVariableValue();
-    } catch (Throwable) {
-        return selfserve_dynamic_image_size_c::SIZE_ORIGINAL;
-    }
-
-    return in_array($mode, [selfserve_dynamic_image_size_c::SIZE_ORIGINAL, selfserve_dynamic_image_size_c::SIZE_RELEVANT], true)
-        ? $mode
-        : selfserve_dynamic_image_size_c::SIZE_ORIGINAL;
-}
-
 /**
  * @param mixed $value
  * @return array<int|string>

services/nginx/app/file_server.php

@@ -5,21 +5,6 @@ $isPreview = $_GET['preview'] ?? false;
 // Remove query string if present
 $file = strtok($file, '?');
 
-// Require authentication for direct /files/ access
-if (str_contains($file, '/files/')) {
-    $headers = getallheaders();
-    $token = $_GET['token'] ?? $_POST['token'] ?? ($headers['Authorization'] ?? null);
-    if (!empty($token)) {
-        $token = str_replace('Bearer ', '', $token);
-    }
-
-    if (empty($token) || !(new \classes\authentication())->validate_token($token)) {
-        header('HTTP/1.1 401 Unauthorized');
-        echo 'Unauthorized';
-        exit;
-    }
-}
-
 $isPDF = false;
 $isPDFStore = false;
 $isAttachment = false;
@@ -55,6 +40,20 @@ if ($isPDF && $isPDFStore) {
 
     // Check if the certificate exists
     if (!$wash_certificate_store->isFileInStore($file)) {
+        // Try the PDF store
+        $pdf_store = new \classes\pdf_store();
+        if ($pdf_store->isFileInStore(str_replace('/files/', '', $file))) {
+            // Download the certificate from the PDF store to /tmp
+            $certificate_path = $pdf_store->download(str_replace('/files/', '', $file));
+            // Send the certificate to the client
+            header('Content-Type: application/pdf');
+            header('Content-Disposition: inline; filename="' . str_replace('/files/', '', $file) . '"');
+            header('Content-Length: ' . filesize($certificate_path));
+            readfile($certificate_path);
+            // Delete the certificate from /tmp after sending it
+            unlink($certificate_path);
+            exit;
+        }
         echo 'Certificate not found in store' . $file;
         //header('HTTP/1.1 404 Not Found');
         exit;
@@ -119,4 +118,4 @@ if (!$isPDF) {
     // Delete the file from /tmp after sending it
     unlink($file_path);
     exit;
-}
+}

services/nginx/app/index.php

@@ -61,17 +61,6 @@ try {
 spl_autoload_register(function (string $class): void {
     $class = ltrim($class, '\\');
     $cache_key = 'autoload:' . $class;
-    $wdReal = rtrim((string) realpath(WD), DIRECTORY_SEPARATOR) . DIRECTORY_SEPARATOR;
-    $modulesRoot = $wdReal . 'modules' . DIRECTORY_SEPARATOR;
-    $isPathInside = static function (string $path, string $root): bool {
-        $resolved = realpath($path);
-        if ($resolved === false) {
-            return false;
-        }
-
-        $resolved = rtrim($resolved, DIRECTORY_SEPARATOR) . DIRECTORY_SEPARATOR;
-        return str_starts_with($resolved, $root);
-    };
     $is_loaded = static function (string $candidate): bool {
         return class_exists($candidate, false)
             || interface_exists($candidate, false)
@@ -84,13 +73,11 @@ spl_autoload_register(function (string $class): void {
         try {
             $cached = redis->get($cache_key);
             if (is_string($cached) && $cached !== '' && is_file($cached)) {
-                if ($isPathInside($cached, $wdReal)) {
-                    require_once $cached;
-                    if ($is_loaded($class)) {
-                        return;
-                    }
+                require_once $cached;
+                if ($is_loaded($class)) {
+                    return;
                 }
-                // Stale, invalid, or unsafe class mapping in cache; continue with normal lookup.
+                // Stale class mapping in cache, continue with normal lookup.
                 redis->delete($cache_key);
             } elseif (is_string($cached) && $cached !== '') {
                 // Remove non-existing cached path to avoid repeated failed lookups.
@@ -133,18 +120,6 @@ spl_autoload_register(function (string $class): void {
                     $module_dirs = redis->get_array('autoload:module_dirs');
                 } catch (\Throwable $e) {}
             }
-
-            if (is_array($module_dirs)) {
-                $module_dirs = array_values(array_filter($module_dirs, static function ($item) use ($base, $modulesRoot, $isPathInside): bool {
-                    if (!is_string($item) || $item === '' || str_contains($item, DIRECTORY_SEPARATOR) || str_contains($item, '..')) {
-                        return false;
-                    }
-
-                    $candidate = $base . 'modules' . DIRECTORY_SEPARATOR . $item;
-                    return is_dir($candidate) && $isPathInside($candidate, $modulesRoot);
-                }));
-            }
-
             if ($module_dirs === null) {
                 $module_dirs = array_filter(scandir($base . 'modules'), function($item) use ($base) {
                     return $item !== '.' && $item !== '..' && is_dir($base . 'modules' . DIRECTORY_SEPARATOR . $item);
@@ -262,6 +237,11 @@ if (php_sapi_name() === 'cli' || isset($_GET['internalCronCall'])) {
     exit;
 }
 
+// If the route ends with .php, then require the file_server.php
+if (str_contains($_SERVER['REQUEST_URI'], '.pdf')) {
+    require_once 'file_server.php';
+    exit;
+}
 // If the route ends with a MIME type, then require the file_server.php
 if ((preg_match('/\.(jpg|jpeg|png)$/', $_SERVER['REQUEST_URI']) || str_contains($_SERVER['REQUEST_URI'], '/files/'))) {
     require_once 'file_server.php';

services/nginx/app/modules/attachments/helpers/attachment_content.php

@@ -5,7 +5,6 @@ namespace attachments\helpers;
 class attachment_content
 {
     const OTHER_TYPE_WASH_CERTIFICATE = 'WASH_CERTIFICATE';
-    const OTHER_TYPE_SELF_SERVE_WASH = 'SELF_SERVE_WASH';
     public ?string $image; // Used to store the attachment object name, in the attachment store.
     public ?string $document; // Used to store the attachment object name, in the attachment store.
     public ?attachment_relation $relation; // Used to store the attachment relation object.
@@ -50,4 +49,4 @@ class attachment_content
         $this->relation = $relation;
         return $this;
     }
-}
+}

services/nginx/app/modules/coolify/config/coolify_github_runner_backend_repository_c.php

@@ -1,25 +0,0 @@
-<?php
-
-namespace modules\coolify\config;
-
-use traits\module_config_variable;
-
-class coolify_github_runner_backend_repository_c
-{
-    use module_config_variable;
-
-    public function __construct()
-    {
-        $this->setupConfigVariable(
-            'Coolify',
-            'github_runner_backend_repository',
-            'string',
-            false,
-            null,
-            'GitHub backend repository that receives Coolify-managed self-hosted runners.',
-            'copenhagentruckwash/api',
-            false,
-            'copenhagentruckwash/api'
-        );
-    }
-}

services/nginx/app/modules/coolify/config/coolify_github_runner_count_per_repo_c.php

@@ -1,25 +0,0 @@
-<?php
-
-namespace modules\coolify\config;
-
-use traits\module_config_variable;
-
-class coolify_github_runner_count_per_repo_c
-{
-    use module_config_variable;
-
-    public function __construct()
-    {
-        $this->setupConfigVariable(
-            'Coolify',
-            'github_runner_count_per_repo',
-            'int',
-            false,
-            null,
-            'Number of self-hosted GitHub runner containers to deploy per repository.',
-            '1',
-            false,
-            '1'
-        );
-    }
-}

services/nginx/app/modules/coolify/config/coolify_github_runner_frontend_repository_c.php

@@ -1,25 +0,0 @@
-<?php
-
-namespace modules\coolify\config;
-
-use traits\module_config_variable;
-
-class coolify_github_runner_frontend_repository_c
-{
-    use module_config_variable;
-
-    public function __construct()
-    {
-        $this->setupConfigVariable(
-            'Coolify',
-            'github_runner_frontend_repository',
-            'string',
-            false,
-            null,
-            'GitHub frontend repository that receives Coolify-managed self-hosted runners.',
-            'copenhagentruckwash/pleno-vue',
-            false,
-            'copenhagentruckwash/pleno-vue'
-        );
-    }
-}

services/nginx/app/modules/coolify/config/coolify_github_runner_labels_c.php

@@ -1,25 +0,0 @@
-<?php
-
-namespace modules\coolify\config;
-
-use traits\module_config_variable;
-
-class coolify_github_runner_labels_c
-{
-    use module_config_variable;
-
-    public function __construct()
-    {
-        $this->setupConfigVariable(
-            'Coolify',
-            'github_runner_labels',
-            'string',
-            false,
-            null,
-            'Comma-separated GitHub Actions runner labels registered on each Coolify-managed runner.',
-            'self-hosted,Linux,X64,default',
-            false,
-            'self-hosted,Linux,X64,default'
-        );
-    }
-}

services/nginx/app/modules/coolify/config/coolify_github_runner_service_uuid_c.php

@@ -1,25 +0,0 @@
-<?php
-
-namespace modules\coolify\config;
-
-use traits\module_config_variable;
-
-class coolify_github_runner_service_uuid_c
-{
-    use module_config_variable;
-
-    public function __construct()
-    {
-        $this->setupConfigVariable(
-            'Coolify',
-            'github_runner_service_uuid',
-            'string',
-            false,
-            null,
-            'Coolify service UUID for the managed GitHub self-hosted runner stack.',
-            'abc123...',
-            false,
-            ''
-        );
-    }
-}

services/nginx/app/modules/coolify/config/coolify_github_runner_token_c.php

@@ -1,38 +0,0 @@
-<?php
-
-namespace modules\coolify\config;
-
-use classes\replication_secret_box;
-use traits\module_config_variable;
-
-class coolify_github_runner_token_c
-{
-    use module_config_variable {
-        setVariableValue as private traitSetVariableValue;
-    }
-
-    public function __construct()
-    {
-        $this->setupConfigVariable(
-            'Coolify',
-            'github_runner_token',
-            'string',
-            false,
-            null,
-            'GitHub PAT used to register Coolify-managed self-hosted repository runners.',
-            'github_pat_...',
-            true,
-            ''
-        );
-    }
-
-    public function setVariableValue(mixed $value): void
-    {
-        $value = trim((string)($value ?? ''));
-        if ($value !== '' && !str_starts_with($value, 'twsec:v1:')) {
-            $value = replication_secret_box::encrypt($value);
-        }
-
-        $this->traitSetVariableValue($value);
-    }
-}

services/nginx/app/modules/dynamicimages/interfaces/dynamicimages_image_i.php

@@ -86,14 +86,6 @@ interface dynamicimages_image_i
      */
     public function exportAsBase64(?string $format = null, int $quality = 90): string;
 
-    /**
-     * Export the composed image as binary image data.
-     * @param string|null $format Optional target format (e.g. 'png', 'jpeg')
-     * @param int $quality Quality for lossy formats (0-100)
-     * @return string binary image data
-     */
-    public function exportBinary(?string $format = null, int $quality = 90): string;
-
     /**
      * Directly serve the composed image to the client with proper headers.
      * Convenience wrapper for outputting binary image data.
@@ -102,4 +94,4 @@ interface dynamicimages_image_i
      * @param int $quality Quality for lossy formats (0-100)
      */
     public function servePicture(?string $format = null, int $quality = 90): void;
-}
+}

services/nginx/app/modules/dynamicimages/traits/dynamicimages_image_t.php

@@ -226,20 +226,6 @@ trait dynamicimages_image_t
         return $this;
     }
 
-    public function resizeToMaxWidth(int $maxWidth): dynamicimages_image_i
-    {
-        $this->assertCanvasInitialized();
-        if ($maxWidth <= 0) {
-            throw new \InvalidArgumentException('Resize max width must be a positive integer.');
-        }
-        if ($this->canvasWidth === null || $this->canvasHeight === null || $this->canvasWidth <= $maxWidth) {
-            return $this;
-        }
-
-        $height = (int)round($this->canvasHeight * ($maxWidth / $this->canvasWidth));
-        return $this->resize($maxWidth, max(1, $height));
-    }
-
     public function crop(int $width, int $height, int $x, int $y): dynamicimages_image_i
     {
         $this->assertCanvasInitialized();
@@ -321,8 +307,20 @@ trait dynamicimages_image_t
      */
     public function exportAsBase64(?string $format = null, int $quality = 90): string
     {
+        // If a canvas is initialized, export that as PNG by default
         if ($this->image instanceof \Imagick) {
-            return 'data:image/png;base64,' . base64_encode($this->exportBinary($format, $quality));
+            $img = clone $this->image;
+            $img->setImageFormat('png');
+            // Quality influences compression for PNG differently; keep as hint
+            if ($format !== null && strtolower($format) !== 'png') {
+                // For now we only support PNG for composed images as requested
+            }
+            // Strip metadata to reduce size
+            $img->stripImage();
+            $blob = $img->getImageBlob();
+            $img->clear();
+            $img->destroy();
+            return 'data:image/png;base64,' . base64_encode($blob);
         }
 
         // Fallback: export first asset as-is
@@ -343,40 +341,6 @@ trait dynamicimages_image_t
         return 'data:' . $mime . ';base64,' . base64_encode($data);
     }
 
-    public function exportBinary(?string $format = null, int $quality = 90): string
-    {
-        // If a canvas is initialized, export that as PNG by default
-        if ($this->image instanceof \Imagick) {
-            $img = clone $this->image;
-            $img->setImageFormat('png');
-            // Quality influences compression for PNG differently; keep as hint
-            if ($format !== null && strtolower($format) !== 'png') {
-                // For now we only support PNG for composed images as requested
-            }
-            // Strip metadata to reduce size
-            $img->stripImage();
-            $blob = $img->getImageBlob();
-            $img->clear();
-            $img->destroy();
-            return $blob;
-        }
-
-        // Fallback: export first asset as-is
-        if (empty($this->assets)) {
-            throw new \RuntimeException('No assets available to export.');
-        }
-        $asset = $this->assets[0];
-        $path = $asset->getPath();
-        if (!is_readable($path)) {
-            throw new \RuntimeException('Asset is not readable: ' . $path);
-        }
-        $data = file_get_contents($path);
-        if ($data === false) {
-            throw new \RuntimeException('Failed to read asset: ' . $path);
-        }
-        return $data;
-    }
-
     public function getAsset(string $asset_name): ?dynamicimages_asset
     {
         foreach ($this->assets as $asset) {
@@ -393,18 +357,22 @@ trait dynamicimages_image_t
      */
     public function outputImage(?string $format = null, int $quality = 90): void
     {
-        $mimeType = 'image/png';
-        if (!$this->image instanceof \Imagick && !empty($this->assets)) {
-            $asset = $this->assets[0];
-            $path = $asset->getPath();
-            $imgInfo = is_readable($path) ? @getimagesize($path) : false;
-            $mimeType = is_array($imgInfo) && isset($imgInfo['mime']) ? $imgInfo['mime'] : 'application/octet-stream';
+        $dataUri = $this->exportAsBase64($format, $quality);
+        // Extract mime type and base64 data
+        if (preg_match('/^data:(image\/[a-zA-Z0-9+.-]+);base64,(.*)$/', $dataUri, $matches)) {
+            $mimeType = $matches[1];
+            $base64Data = $matches[2];
+            // Decode base64 data
+            $imageData = base64_decode($base64Data);
+            if ($imageData !== false) {
+                // Send appropriate headers
+                header('Content-Type: ' . $mimeType);
+                header('Content-Length: ' . strlen($imageData));
+                // Output the image data
+                echo $imageData;
+                exit;
+            }
         }
-        $imageData = $this->exportBinary($format, $quality);
-        header('Content-Type: ' . $mimeType);
-        header('Content-Length: ' . strlen($imageData));
-        echo $imageData;
-        exit;
     }
 
     /**
@@ -414,4 +382,4 @@ trait dynamicimages_image_t
     {
         $this->outputImage($format, $quality);
     }
-}
+}

services/nginx/app/modules/edgegateway/classes/edge_gateway_manager.php

@@ -3426,7 +3426,7 @@ BASH;
         }
 
         try {
-            $this->shellyRelayOptionsCache = (new shelly_relay_inventory())->listRelayOptions(true);
+            $this->shellyRelayOptionsCache = (new shelly_relay_inventory())->listRelayOptions();
         } catch (\Throwable) {
             $this->shellyRelayOptionsCache = [];
         }
@@ -4021,7 +4021,7 @@ BASH;
     {
         $configured = $this->configuredBrokerSharedSecret();
         if ($configured === '') {
-            return false;
+            return true;
         }
 
         return $secret !== null && hash_equals($configured, trim($secret));
@@ -4036,8 +4036,12 @@ BASH;
         $target = strtolower(trim((string)($options['target'] ?? 'all')));
         $target = in_array($target, ['internal', 'public', 'secret', 'all'], true) ? $target : 'all';
 
-        $internalUrl = $this->normalizeBrokerDiagnosticBaseUrl($this->configuredBrokerInternalUrl());
-        $publicConfigured = $this->configuredPublicBrokerUrl();
+        $internalUrl = $this->normalizeBrokerDiagnosticBaseUrl(
+            array_key_exists('broker_url', $options) ? $options['broker_url'] : $this->configuredBrokerInternalUrl()
+        );
+        $publicConfigured = array_key_exists('public_broker_url', $options)
+            ? trim((string)$options['public_broker_url'])
+            : $this->configuredPublicBrokerUrl();
         $publicUrl = $this->normalizeBrokerDiagnosticBaseUrl(
             $publicConfigured !== '' ? $publicConfigured : $this->deriveBrokerPublicUrl()
         );
@@ -4129,7 +4133,7 @@ BASH;
 
         $health = $this->brokerHttpProbe($baseUrl['url'] . '/api/health');
         if (($health['status_code'] ?? null) === 200 && !empty($health['json']['ok'])) {
-            return array_merge($this->redactBrokerDiagnosticProbe($health), [
+            return array_merge($health, [
                 'ok' => true,
                 'status' => 'connected',
                 'url' => $baseUrl['url'],
@@ -4138,7 +4142,7 @@ BASH;
         }
 
         if (($health['status_code'] ?? null) === 404 && $this->isBrokerNotFoundProbe($health)) {
-            return array_merge($this->redactBrokerDiagnosticProbe($health), [
+            return array_merge($health, [
                 'ok' => true,
                 'status' => 'connected_legacy',
                 'url' => $baseUrl['url'],
@@ -4147,7 +4151,7 @@ BASH;
         }
 
         if (($health['status_code'] ?? null) !== null) {
-            return array_merge($this->redactBrokerDiagnosticProbe($health), [
+            return array_merge($health, [
                 'ok' => false,
                 'status' => 'unexpected_response',
                 'url' => $baseUrl['url'],
@@ -4155,7 +4159,7 @@ BASH;
             ]);
         }
 
-        return array_merge($this->redactBrokerDiagnosticProbe($health), [
+        return array_merge($health, [
             'ok' => false,
             'status' => 'unreachable',
             'url' => $baseUrl['url'],
@@ -4183,7 +4187,7 @@ BASH;
 
         if (($diagnostic['status_code'] ?? null) === 200 && !empty($diagnostic['json']['ok'])) {
             $required = (bool)($diagnostic['json']['shared_secret_required'] ?? false);
-            return array_merge($this->redactBrokerDiagnosticProbe($diagnostic), [
+            return array_merge($diagnostic, [
                 'ok' => true,
                 'status' => $required ? 'validated' : 'not_required',
                 'url' => $baseUrl['url'],
@@ -4194,7 +4198,7 @@ BASH;
         }
 
         if (($diagnostic['status_code'] ?? null) === 403) {
-            return array_merge($this->redactBrokerDiagnosticProbe($diagnostic), [
+            return array_merge($diagnostic, [
                 'ok' => false,
                 'status' => 'secret_rejected',
                 'url' => $baseUrl['url'],
@@ -4207,7 +4211,7 @@ BASH;
         }
 
         if (($diagnostic['status_code'] ?? null) !== null) {
-            return array_merge($this->redactBrokerDiagnosticProbe($diagnostic), [
+            return array_merge($diagnostic, [
                 'ok' => false,
                 'status' => 'unexpected_response',
                 'url' => $baseUrl['url'],
@@ -4215,7 +4219,7 @@ BASH;
             ]);
         }
 
-        return array_merge($this->redactBrokerDiagnosticProbe($diagnostic), [
+        return array_merge($diagnostic, [
             'ok' => false,
             'status' => 'unreachable',
             'url' => $baseUrl['url'],
@@ -4238,7 +4242,7 @@ BASH;
         );
 
         if (($legacy['status_code'] ?? null) === 200 && !empty($legacy['json']['ok'])) {
-            return array_merge($this->redactBrokerDiagnosticProbe($legacy), [
+            return array_merge($legacy, [
                 'ok' => true,
                 'status' => 'validated_legacy',
                 'url' => $baseUrl['url'],
@@ -4247,7 +4251,7 @@ BASH;
         }
 
         if (($legacy['status_code'] ?? null) === 403) {
-            return array_merge($this->redactBrokerDiagnosticProbe($legacy), [
+            return array_merge($legacy, [
                 'ok' => false,
                 'status' => 'secret_rejected',
                 'url' => $baseUrl['url'],
@@ -4255,7 +4259,7 @@ BASH;
             ]);
         }
 
-        return array_merge($this->redactBrokerDiagnosticProbe($legacy), [
+        return array_merge($legacy, [
             'ok' => false,
             'status' => ($legacy['status_code'] ?? null) === null ? 'unreachable' : 'unexpected_response',
             'url' => $baseUrl['url'],
@@ -4263,17 +4267,6 @@ BASH;
         ]);
     }
 
-    /**
-     * @param array<string,mixed> $probe
-     * @return array<string,mixed>
-     */
-    private function redactBrokerDiagnosticProbe(array $probe): array
-    {
-        unset($probe['json']);
-        $probe['body_excerpt'] = null;
-        return $probe;
-    }
-
     /**
      * @param array{url:?string,error:?string} $baseUrl
      * @return array<string,mixed>
@@ -4352,7 +4345,7 @@ BASH;
             'elapsed_ms' => $elapsedMs,
             'error' => null,
             'json' => is_array($decoded) ? $decoded : null,
-            'body_excerpt' => null,
+            'body_excerpt' => self::trimInstallSessionText($body, 512),
         ];
     }
 

services/nginx/app/modules/edgegateway/edgegateway_c.php

@@ -41,6 +41,7 @@ class edgegateway_c
             edgegateway_broker_url_c::class,
             edgegateway_public_broker_url_c::class,
             edgegateway_broker_auth_mode_c::class,
+            edgegateway_broker_shared_secret_c::class,
         ]);
         $this->enabled = new edgegateway_enabled_c();
         $this->default_release_channel = new edgegateway_default_release_channel_c();

services/nginx/app/modules/edgegateway/routes/edgeGatewayConfigRoute.php

@@ -39,15 +39,7 @@ class edgeGatewayConfigRoute
         }
 
         (new logs_o())->add('edgegateway_config', 'global', 1, $user->id, 'EDGEGATEWAY_CONFIG', 'Successfully fetched edge gateway config');
-        $config = (new edgegateway())->config->getConfigRequest();
-        foreach ($config as &$entry) {
-            if (($entry['variable'] ?? null) === 'broker_shared_secret') {
-                $entry['value'] = '';
-            }
-        }
-        unset($entry);
-
-        $response->success($config);
+        $response->success((new edgegateway())->config->getConfigRequest());
     }
 
     private function handlePostConfig(): void
@@ -79,12 +71,7 @@ class edgeGatewayConfigRoute
         }
 
         $payload = self::getParametersAsArray();
-        $diagnosticOptions = array_intersect_key($payload, array_flip([
-            'target',
-            'broker_auth_mode',
-            'broker_shared_secret',
-        ]));
         (new logs_o())->add('edgegateway_config', 'global', 1, $user->id, 'EDGEGATEWAY_BROKER_DIAGNOSTICS', 'Tested edge gateway broker config');
-        $response->success((new edge_gateway_manager())->diagnoseBrokerConfiguration($diagnosticOptions));
+        $response->success((new edge_gateway_manager())->diagnoseBrokerConfiguration($payload));
     }
 }

services/nginx/app/modules/email/templates/email_template_new_customer.php

@@ -2,8 +2,7 @@
 
 namespace email\templates;
 
-use email\helpers\email_template;
-use objects\users_o;
+use email\helpers\email_template;use objects\users_o;
 
 class email_template_new_customer
 {
@@ -53,7 +52,6 @@ class email_template_new_customer
      */
     public function generate_html(): string
     {
-        $customer_label = htmlspecialchars($this->getCustomerRegistrationLabel(), ENT_QUOTES, 'UTF-8');
         ob_start();
         # Start of the html
         ?>
@@ -75,7 +73,7 @@ class email_template_new_customer
 
                                 <!-- Intro -->
                                 <p class="container-text-md" style="color:#000000;font-size:16px;line-height:1.5;margin:0 0 18px 0;mso-line-height-rule:exactly;">
-                                    Tak for din registrering af <?=$customer_label?> som kunde hos Truck Wash.
+                                    Tak for din registrering af <?=((new users_o())->getCustomerName((int)$this->customer_number))?><?=(((new users_o())->getCustomerEcocomicData((int)$this->customer_number)->economic_customer->corporateIdentificationNumber) ? ' (' . (new users_o())->getCustomerEcocomicData((int)$this->customer_number)->economic_customer->corporateIdentificationNumber . ')' : '')?> som kunde hos Truck Wash.
                                 </p>
 
                                 <!-- You can now wash your trucks -->
@@ -187,19 +185,4 @@ class email_template_new_customer
         # End of the html
         return ob_get_clean();
     }
-
-    private function getCustomerRegistrationLabel(): string
-    {
-        $customer = (new users_o())->getUserByCustomerNumber($this->customer_number);
-        $customer_name = trim((string)($customer->getCustomerName($this->customer_number) ?? ''));
-        $customer_label = $customer_name === '' ? 'virksomhed (CVR)' : $customer_name;
-
-        $customer->getCustomerEcocomicData($this->customer_number);
-        $corporate_identification_number = trim((string)($customer->economic_customer->corporateIdentificationNumber ?? ''));
-        if ($corporate_identification_number !== '') {
-            $customer_label .= ' (' . $corporate_identification_number . ')';
-        }
-
-        return $customer_label;
-    }
 }

services/nginx/app/modules/limble/classes/limble_request.php

@@ -29,8 +29,8 @@ class limble_request implements limble_request_i
         curl_setopt($ch, CURLOPT_HTTPHEADER, $headers);
         // Set options to return the response and handle SSL
         curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
-        curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, true);
-        curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, 2);
+        curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
+        curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false);
         // Execute the request
         $response = curl_exec($ch);
         // Check for errors
@@ -44,7 +44,11 @@ class limble_request implements limble_request_i
         // Check if the response is successful
         if ($httpCode < 200 || $httpCode >= 300) {
             $slack = new \classes\slack();
-            $slack->send_message('Limble Request Failed with status code: ' . $httpCode, 'Limble Request Error');
+            echo 'Attempting credentials: ' . $url . ' with method: ' . $method . ' and data: ' . json_encode($data) . "\n";
+            echo 'Response: ' . $response . "\n";
+            echo 'HTTP Code: ' . $httpCode . "\n";
+            echo 'Headers: ' . json_encode($headers) . "\n";
+            $slack->send_message('Limble Request Failed: ' . $response, 'Limble Request Error');
             throw new \Exception('Request failed with status code ' . $httpCode);
         }
         // Check if the response is valid JSON
@@ -64,4 +68,4 @@ class limble_request implements limble_request_i
         // Generate the Basic Auth header using the client ID and secret
         return 'Authorization: Basic ' . base64_encode($client_id . ':' . $client_secret);
     }
-}
+}

services/nginx/app/modules/selfserve/classes/selfserve_lane_command_arguments.php

@@ -6,8 +6,6 @@ class selfserve_lane_command_arguments
 {
     public ?string $license_plate = null;
     public ?int $customer_number = null;
-    public ?int $subuser_id = null;
-    public ?string $wash_mode = null;
     public bool $defer_relay_side_effects = false;
 
     /**
@@ -27,28 +25,6 @@ class selfserve_lane_command_arguments
         return $this;
     }
 
-    public function setSubuserId(?int $subuser_id): self
-    {
-        $this->subuser_id = $subuser_id !== null && $subuser_id > 0 ? $subuser_id : null;
-        return $this;
-    }
-
-    public function setWashMode(?string $wash_mode): self
-    {
-        $normalized = strtolower(trim((string)$wash_mode));
-        if ($wash_mode === null || $normalized === '') {
-            $this->wash_mode = null;
-            return $this;
-        }
-
-        if (!in_array($normalized, ['manual', 'machine'], true)) {
-            throw new \InvalidArgumentException('Invalid wash type: ' . $wash_mode);
-        }
-
-        $this->wash_mode = $normalized;
-        return $this;
-    }
-
     public function setDeferRelaySideEffects(bool $defer_relay_side_effects): self
     {
         $this->defer_relay_side_effects = $defer_relay_side_effects;
@@ -64,15 +40,6 @@ class selfserve_lane_command_arguments
             if (array_key_exists('customer_number', $params)) {
                 $this->setCustomerNumber($params['customer_number']);
             }
-            if (array_key_exists('subuser_id', $params)) {
-                $this->setSubuserId($params['subuser_id'] === null ? null : (int)$params['subuser_id']);
-            }
-            if (array_key_exists('wash_type', $params)) {
-                $this->setWashMode($params['wash_type'] === null ? null : (string)$params['wash_type']);
-            }
-            if (array_key_exists('wash_mode', $params)) {
-                $this->setWashMode($params['wash_mode'] === null ? null : (string)$params['wash_mode']);
-            }
             if (array_key_exists('defer_relay_side_effects', $params)) {
                 $this->setDeferRelaySideEffects(filter_var(
                     $params['defer_relay_side_effects'],

services/nginx/app/modules/selfserve/classes/selfserve_studio_action_runner.php

@@ -83,7 +83,7 @@ class selfserve_studio_action_runner
                 continue;
             }
             $conditionId = $action['condition_id'];
-            if ($conditionId !== null && (($conditionResults[$conditionId] ?? false) !== true)) {
+            if ($conditionId !== null && $conditionResults !== null && (($conditionResults[$conditionId] ?? false) !== true)) {
                 continue;
             }
             $actions[] = $action;

services/nginx/app/modules/selfserve/classes/selfserve_wash_flow.php

@@ -103,79 +103,49 @@ class selfserve_wash_flow implements selfserve_wash_flow_i
     public function synchronizeSession(int $laneId, string $reg, ?int $customerNumber = null, bool $activateMachine = true, ?int $vehicleTypeIdOverride = null, bool $syncRelayState = true, array $options = []): array
     {
         $snapshot = $this->buildEligibilitySnapshot($laneId, $reg, $customerNumber, $vehicleTypeIdOverride, $options);
-        $mutationResult = $this->withSessionMutationLock(
-            $laneId,
-            $snapshot['reg'],
-            $snapshot['customer_number'],
-            function () use ($laneId, $snapshot, $options): array {
-                $session = $this->findLatestOpenSession($laneId, $snapshot['reg'], $snapshot['customer_number']);
-                $createSession = (bool)($options['create_session'] ?? true);
+        $session = $this->findLatestOpenSession($laneId, $snapshot['reg'], $snapshot['customer_number']);
 
-                if (($snapshot['evaluation_trace']['disabled_lane'] ?? false) === true) {
-                    return [
-                        'session' => $session,
-                        'response' => $session->exists()
-                            ? $this->getSessionSummary((int)$session->id)
-                            : $this->formatBlockedSessionSummary($snapshot),
-                    ];
-                }
-
-                if (!$session->exists() && !$createSession) {
-                    return [
-                        'session' => $session,
-                        'response' => $this->formatSnapshotResponse($snapshot, null),
-                    ];
-                }
-
-                if (!$session->exists()) {
-                    $session = (new selfserve_wash_sessions_o())->add(
-                        $laneId,
-                        (int)$snapshot['lane']['department'],
-                        $snapshot['machine_type']['id'] ?? null,
-                        $snapshot['customer_number'],
-                        $snapshot['reg'],
-                        $snapshot['vehicle']['id'] ?? null,
-                        $snapshot['vehicle']['type'] ?? null,
-                        $this->deriveBaseStatus($snapshot),
-                        (bool)$snapshot['allowed'],
-                        $this->buildSessionMetadata($snapshot),
-                    );
-                } else {
-                    $session->machine_type_id->set($snapshot['machine_type']['id'] ?? null);
-                    $session->customer_number->set($snapshot['customer_number']);
-                    $session->vehicle_id->set($snapshot['vehicle']['id'] ?? null);
-                    $session->vehicle_type_id->set($snapshot['vehicle_type_id']);
-                    $session->reg->set($snapshot['reg']);
-                    $session->allowed->set((bool)$snapshot['allowed']);
-                    $session->metadata_json->set($this->buildSessionMetadata($snapshot));
-                    $session->updateStatus($this->deriveCurrentStatus($snapshot, $session));
-                }
-
-                $this->syncSessionAnswers((int)$session->id, $snapshot['questions']);
-                $this->syncSessionTasks((int)$session->id, $snapshot['tasks']);
-                $this->logSessionEvent((int)$session->id, selfserve_wash_event_type::SESSION_SYNCED, [
-                    'allowed' => (bool)$snapshot['allowed'],
-                    'all_visible_questions_answered' => (bool)$snapshot['all_visible_questions_answered'],
-                    'allowed_services' => $snapshot['allowed_services'],
-                    'task_ids' => array_map(static fn(array $task): int => (int)$task['id'], $snapshot['tasks']),
-                ]);
-
-                return [
-                    'session' => $session,
-                    'response' => null,
-                ];
-            }
-        );
-
-        $session = $mutationResult['session'];
-        if ($mutationResult['response'] !== null) {
-            return $mutationResult['response'];
+        if (($snapshot['evaluation_trace']['disabled_lane'] ?? false) === true) {
+            return $session->exists()
+                ? $this->getSessionSummary((int)$session->id)
+                : $this->formatBlockedSessionSummary($snapshot);
         }
 
+        if (!$session->exists()) {
+            $session = (new selfserve_wash_sessions_o())->add(
+                $laneId,
+                (int)$snapshot['lane']['department'],
+                $snapshot['machine_type']['id'] ?? null,
+                $snapshot['customer_number'],
+                $snapshot['reg'],
+                $snapshot['vehicle']['id'] ?? null,
+                $snapshot['vehicle']['type'] ?? null,
+                $this->deriveBaseStatus($snapshot),
+                (bool)$snapshot['allowed'],
+                $this->buildSessionMetadata($snapshot),
+            );
+        } else {
+            $session->machine_type_id->set($snapshot['machine_type']['id'] ?? null);
+            $session->customer_number->set($snapshot['customer_number']);
+            $session->vehicle_id->set($snapshot['vehicle']['id'] ?? null);
+            $session->vehicle_type_id->set($snapshot['vehicle_type_id']);
+            $session->reg->set($snapshot['reg']);
+            $session->allowed->set((bool)$snapshot['allowed']);
+            $session->metadata_json->set($this->buildSessionMetadata($snapshot));
+            $session->updateStatus($this->deriveCurrentStatus($snapshot, $session));
+        }
+
+        $this->syncSessionAnswers((int)$session->id, $snapshot['questions']);
+        $this->syncSessionTasks((int)$session->id, $snapshot['tasks']);
+        $this->logSessionEvent((int)$session->id, selfserve_wash_event_type::SESSION_SYNCED, [
+            'allowed' => (bool)$snapshot['allowed'],
+            'all_visible_questions_answered' => (bool)$snapshot['all_visible_questions_answered'],
+            'allowed_services' => $snapshot['allowed_services'],
+            'task_ids' => array_map(static fn(array $task): int => (int)$task['id'], $snapshot['tasks']),
+        ]);
+
         if ($syncRelayState) {
-            if ($session->exists()) {
-                $this->syncMachineRelayFromVisibleServices($snapshot, $session, $activateMachine);
-            }
+            $this->syncMachineRelayFromVisibleServices($snapshot, $session, $activateMachine);
         }
 
         return $this->getSessionSummary((int)$session->id);
@@ -303,19 +273,28 @@ class selfserve_wash_flow implements selfserve_wash_flow_i
                 return;
             }
 
-            $this->turnOffRelayIfConfigured($lane, selfserve_lane_relay::MACHINE);
-            $this->turnOffRelayIfConfigured($lane, selfserve_lane_relay::MACHINE_CLEANER);
+            $this->turnOffRelayIfConfiguredAndOn($lane, selfserve_lane_relay::MACHINE);
+            $this->turnOffRelayIfConfiguredAndOn($lane, selfserve_lane_relay::MACHINE_CLEANER);
         } catch (\Throwable) {
             // Best effort only; session completion flow must continue.
         }
     }
 
-    protected function turnOffRelayIfConfigured(selfserve_lane $lane, selfserve_lane_relay $relay): void
+    protected function turnOffRelayIfConfiguredAndOn(selfserve_lane $lane, selfserve_lane_relay $relay): void
     {
         if (!$this->isRelayConfiguredForLane($lane, $relay)) {
             return;
         }
 
+        try {
+            $status = $lane->getRelayStatus($relay);
+            if ((bool)($status['on'] ?? false) !== true) {
+                return;
+            }
+        } catch (\Throwable) {
+            // If relay status can't be read, still attempt turn-off as best effort.
+        }
+
         try {
             $lane->setRelayStatusHard($relay, false);
         } catch (\Throwable) {
@@ -425,7 +404,7 @@ class selfserve_wash_flow implements selfserve_wash_flow_i
         return $this->getSessionSummary((int)$session->id);
     }
 
-    public function completeLatestSessionForLane(int $laneId, ?string $reg = null, ?int $customerNumber = null, ?int $orderId = null, bool $disableRelays = true): ?array
+    public function completeLatestSessionForLane(int $laneId, ?string $reg = null, ?int $customerNumber = null, ?int $orderId = null): ?array
     {
         $session = $reg !== null
             ? $this->findLatestOpenSession($laneId, selfserve::standardize_registration($reg), $customerNumber)
@@ -435,12 +414,8 @@ class selfserve_wash_flow implements selfserve_wash_flow_i
             return null;
         }
 
-        if (!$session->markCompletedIfOpen($orderId)) {
-            return $this->getSessionSummary((int)$session->id);
-        }
-        if ($disableRelays) {
-            $this->disableMachineRelayForCompletedWash($laneId);
-        }
+        $session->markCompleted($orderId);
+        $this->disableMachineRelayForCompletedWash($laneId);
         $this->logSessionEvent((int)$session->id, selfserve_wash_event_type::SESSION_COMPLETED, [
             'lane_id' => $laneId,
             'reg' => $reg === null ? (string)$session->reg->value() : selfserve::standardize_registration($reg),
@@ -484,12 +459,9 @@ class selfserve_wash_flow implements selfserve_wash_flow_i
                 'runtime_before_reset' => $runtimeSnapshot,
                 'forced_at' => date('Y-m-d H:i:s'),
             ];
-            if (!$session->markForceStoppedIfOpen($orderId, $eventPayload)) {
-                $summary = $this->getSessionSummary((int)$session->id);
-            } else {
-                $this->logSessionEvent((int)$session->id, selfserve_wash_event_type::SESSION_FORCE_STOPPED, $eventPayload);
-                $summary = $this->getSessionSummary((int)$session->id);
-            }
+            $session->markForceStopped($orderId, $eventPayload);
+            $this->logSessionEvent((int)$session->id, selfserve_wash_event_type::SESSION_FORCE_STOPPED, $eventPayload);
+            $summary = $this->getSessionSummary((int)$session->id);
         }
 
         $lane->execute(selfserve_lane_command::RESET, new selfserve_lane_command_arguments());
@@ -751,14 +723,14 @@ class selfserve_wash_flow implements selfserve_wash_flow_i
 
     protected function enableMachineRelayIfAllowed(array $snapshot, selfserve_wash_sessions_o $session): void
     {
-        $laneId = (int)$snapshot['lane']['id'];
-        $lane = (new selfserve())->lane($laneId);
-        $this->enableCleanerRelayForStartedWash($lane);
-
         if ((bool)$session->machine_relay_enabled->value() === true) {
             return;
         }
 
+        $laneId = (int)$snapshot['lane']['id'];
+        $lane = (new selfserve())->lane($laneId);
+        $this->enableCleanerRelayForStartedWash($lane);
+
         $session->markRelayEnabled();
         $this->logSessionEvent((int)$session->id, selfserve_wash_event_type::MACHINE_RELAY_ENABLED, [
             'lane_id' => $laneId,
@@ -2436,20 +2408,11 @@ class selfserve_wash_flow implements selfserve_wash_flow_i
 
     protected function taskUsesProgramPicker(array $task): bool
     {
-        if (in_array(
+        return in_array(
             'PROGRAM_PICKER',
             $this->normalizeServiceNames($this->normalizeJsonArray($task['services'] ?? null)),
             true
-        )) {
-            return true;
-        }
-
-        return in_array('program_picker', $this->normalizeButtonList($task['buttons'] ?? null), true);
-    }
-
-    protected function isProgramNumberButton(mixed $button): bool
-    {
-        return is_int($button) && $button >= 0 && $button <= 11;
+        );
     }
 
     protected function dynamicImageButtonSequenceForTask(array $task): array
@@ -2459,15 +2422,7 @@ class selfserve_wash_flow implements selfserve_wash_flow_i
             return $buttons;
         }
 
-        $sequence = ['program_picker'];
-        foreach ($buttons as $button) {
-            if ($button === 'program_picker' || $this->isProgramNumberButton($button)) {
-                continue;
-            }
-            $sequence[] = $button;
-        }
-
-        return $this->normalizeButtonList($sequence);
+        return $this->normalizeButtonList(array_merge(['program_picker'], $buttons));
     }
 
     /**
@@ -2999,7 +2954,7 @@ class selfserve_wash_flow implements selfserve_wash_flow_i
 
             return array_values(array_filter($questions, static function (array $question) use ($departmentId, $laneId, $vehicleTypeId): bool {
                 return (int)($question['department'] ?? 0) === $departmentId
-                    && ((int)($question['lane'] ?? 0) === 0 || (int)($question['lane'] ?? 0) === $laneId)
+                    && (int)($question['lane'] ?? 0) === $laneId
                     && (int)($question['product'] ?? 0) === $vehicleTypeId;
             }));
         }
@@ -3042,7 +2997,7 @@ class selfserve_wash_flow implements selfserve_wash_flow_i
             return array_values(array_filter($conditions, static function (array $condition) use ($departmentId, $laneId, $vehicleTypeId): bool {
                 return (int)($condition['machine_type_id'] ?? 0) === 0
                     && (int)($condition['department'] ?? 0) === $departmentId
-                    && ((int)($condition['lane'] ?? 0) === 0 || (int)($condition['lane'] ?? 0) === $laneId)
+                    && (int)($condition['lane'] ?? 0) === $laneId
                     && (int)($condition['product'] ?? 0) === $vehicleTypeId;
             }));
         }
@@ -3086,7 +3041,7 @@ class selfserve_wash_flow implements selfserve_wash_flow_i
             return array_values(array_filter($tasks, static function (array $task) use ($departmentId, $laneId, $vehicleTypeId): bool {
                 return (int)($task['machine_type_id'] ?? 0) === 0
                     && (int)($task['department'] ?? 0) === $departmentId
-                    && ((int)($task['lane'] ?? 0) === 0 || (int)($task['lane'] ?? 0) === $laneId)
+                    && (int)($task['lane'] ?? 0) === $laneId
                     && (int)($task['product'] ?? 0) === $vehicleTypeId;
             }));
         }
@@ -3225,86 +3180,6 @@ class selfserve_wash_flow implements selfserve_wash_flow_i
         (new selfserve_wash_session_events_o())->add($sessionId, $eventType, $payload);
     }
 
-    /**
-     * @param callable():array<string,mixed> $callback
-     * @return array<string,mixed>
-     */
-    protected function withSessionMutationLock(int $laneId, string $reg, ?int $customerNumber, callable $callback): array
-    {
-        $lockKey = $this->sessionMutationLockKey($laneId, $reg, $customerNumber);
-        $lock = $this->acquireSessionMutationLock($lockKey);
-
-        try {
-            return $callback();
-        } finally {
-            $this->releaseSessionMutationLock($lock);
-        }
-    }
-
-    /**
-     * @return array{driver:string,key:string,token:?string}
-     */
-    protected function acquireSessionMutationLock(string $lockKey): array
-    {
-        if (defined('redis') && method_exists(redis, 'set_if_absent_with_expiration')) {
-            $token = bin2hex(random_bytes(16));
-            if (!redis->set_if_absent_with_expiration($lockKey, $token, 15)) {
-                throw new \RuntimeException('Self-serve wash session is busy. Try again.');
-            }
-
-            return [
-                'driver' => 'redis',
-                'key' => $lockKey,
-                'token' => $token,
-            ];
-        }
-
-        global $db;
-        $result = $db->query("SELECT GET_LOCK('" . $db->escape_string($lockKey) . "', 5) AS acquired");
-        $row = $db->fetch_assoc($result);
-        if ((int)($row['acquired'] ?? 0) !== 1) {
-            throw new \RuntimeException('Self-serve wash session is busy. Try again.');
-        }
-
-        return [
-            'driver' => 'mysql',
-            'key' => $lockKey,
-            'token' => null,
-        ];
-    }
-
-    /**
-     * @param array{driver:string,key:string,token:?string} $lock
-     */
-    protected function releaseSessionMutationLock(array $lock): void
-    {
-        try {
-            if ($lock['driver'] === 'redis' && defined('redis')) {
-                if (method_exists(redis, 'get') && redis->get($lock['key']) !== $lock['token']) {
-                    return;
-                }
-                if (method_exists(redis, 'delete')) {
-                    redis->delete($lock['key']);
-                }
-                return;
-            }
-
-            if ($lock['driver'] === 'mysql') {
-                global $db;
-                $db->query("SELECT RELEASE_LOCK('" . $db->escape_string($lock['key']) . "')");
-            }
-        } catch (\Throwable) {
-            // Locks have TTLs or connection scope; release failures must not mask API results.
-        }
-    }
-
-    protected function sessionMutationLockKey(int $laneId, string $reg, ?int $customerNumber): string
-    {
-        return 'selfserve_session_mutation:' . (int)$laneId . ':' . sha1(
-            selfserve::standardize_registration($reg) . ':' . ($customerNumber === null ? 'anon' : (string)(int)$customerNumber)
-        );
-    }
-
     protected function buildSessionMetadata(array $snapshot): array
     {
         return [

services/nginx/app/modules/selfserve/config/selfserve_dynamic_image_size_c.php

@@ -1,32 +0,0 @@
-<?php
-
-namespace modules\selfserve\config;
-
-use Exception;
-use traits\module_config_variable;
-
-class selfserve_dynamic_image_size_c
-{
-    use module_config_variable;
-
-    public const SIZE_ORIGINAL = 'original';
-    public const SIZE_RELEVANT = 'relevant';
-
-    /**
-     * @throws Exception
-     */
-    public function __construct()
-    {
-        self::setupConfigVariable(
-            'selfserve',
-            'dynamic_image_size',
-            'string',
-            true,
-            [self::SIZE_ORIGINAL, self::SIZE_RELEVANT],
-            'Whether self-serve dynamic images are served in the original rendered size or resized to the relevant terminal size',
-            self::SIZE_RELEVANT,
-            false,
-            self::SIZE_ORIGINAL
-        );
-    }
-}

services/nginx/app/modules/selfserve/interfaces/selfserve_wash_flow_i.php

@@ -14,7 +14,7 @@ interface selfserve_wash_flow_i
 
     public function getLatestSessionSummary(int $laneId, string $reg): array;
 
-    public function completeLatestSessionForLane(int $laneId, ?string $reg = null, ?int $customerNumber = null, ?int $orderId = null, bool $disableRelays = true): ?array;
+    public function completeLatestSessionForLane(int $laneId, ?string $reg = null, ?int $customerNumber = null, ?int $orderId = null): ?array;
 
     public function forceStopLane(int $laneId, ?int $sessionId = null, bool $bill = false, ?string $reason = null, ?int $userId = null): array;
 }

services/nginx/app/modules/selfserve/selfserve.md

@@ -439,7 +439,7 @@ Public methods:
 | `recordMachineStartWebhook(int $laneId, ?string $reg = null, array $payload = [])` | The machine button or hardware event fired. | Full session summary after the machine-start event. |
 | `getSessionSummary(int $sessionId)` | You have a session id already. | Full session summary. |
 | `getLatestSessionSummary(int $laneId, string $reg)` | You want the latest session for a lane and vehicle. | Full session summary. |
-| `completeLatestSessionForLane(int $laneId, ?string $reg = null, ?int $customerNumber = null, ?int $orderId = null, bool $disableRelays = true)` | STOP has finished and you want to close the latest open session. Normal STOP passes `false` because it already disabled relays before opening the exit port. | Full summary, or `null` if no open session exists. |
+| `completeLatestSessionForLane(int $laneId, ?string $reg = null, ?int $customerNumber = null, ?int $orderId = null)` | STOP has finished and you want to close the latest open session. | Full summary, or `null` if no open session exists. |
 
 Key implementation details:
 

services/nginx/app/modules/selfserve/selfserve_c.php

@@ -4,9 +4,7 @@ namespace modules\selfserve;
 require_once WD . '/modules/selfserve/config/selfserve_enabled_c.php';
 require_once WD . '/modules/selfserve/config/selfserve_minute_product_c.php';
 require_once WD . '/modules/selfserve/config/selfserve_machine_wash_minutes_included_c.php';
-require_once WD . '/modules/selfserve/config/selfserve_dynamic_image_size_c.php';
 
-use modules\selfserve\config\selfserve_dynamic_image_size_c;
 use modules\selfserve\config\selfserve_enabled_c;
 use modules\selfserve\config\selfserve_machine_wash_minutes_included_c;
 use modules\selfserve\config\selfserve_minute_product_c;
@@ -31,11 +29,6 @@ class selfserve_c
      * @var selfserve_machine_wash_minutes_included_c $machine_wash_minutes_included
      */
     public selfserve_machine_wash_minutes_included_c $machine_wash_minutes_included;
-    /**
-     * Dynamic image output size mode for self-serve terminals
-     * @var selfserve_dynamic_image_size_c $dynamic_image_size
-     */
-    public selfserve_dynamic_image_size_c $dynamic_image_size;
 
     public function __construct()
     {
@@ -43,12 +36,10 @@ class selfserve_c
         $this->allowUpdate([
             selfserve_enabled_c::class,
             selfserve_minute_product_c::class,
-            selfserve_machine_wash_minutes_included_c::class,
-            selfserve_dynamic_image_size_c::class
+            selfserve_machine_wash_minutes_included_c::class
         ]);
         $this->enabled = new selfserve_enabled_c();
         $this->minute_product = new selfserve_minute_product_c();
         $this->machine_wash_minutes_included = new selfserve_machine_wash_minutes_included_c();
-        $this->dynamic_image_size = new selfserve_dynamic_image_size_c();
     }
 }

services/nginx/app/modules/selfserve/traits/selfserve_lane_cache_t.php

@@ -9,7 +9,6 @@ trait selfserve_lane_cache_t
 {
     const CACHE_SELFSERVE_PREFIX = 'selfserve_lane_';
     const CACHE_SELFSERVE_LANE_KEY_STATUS = self::CACHE_SELFSERVE_PREFIX . 'status';
-    const CACHE_SELFSERVE_LANE_KEY_STATUS_AUDIT = self::CACHE_SELFSERVE_PREFIX . 'status_audit';
     const CACHE_SELFSERVE_LANE_KEY_STATE = self::CACHE_SELFSERVE_PREFIX . 'state';
     const CACHE_SELFSERVE_LANE_KEY_MODE = self::CACHE_SELFSERVE_PREFIX . 'mode';
     const CACHE_SELFSERVE_LANE_KEY_WASH_START_TIME = self::CACHE_SELFSERVE_PREFIX . 'wash_start_time';
@@ -78,4 +77,4 @@ trait selfserve_lane_cache_t
         redis->delete($this->getLaneCacheKey($laneId, $property));
         return $this;
     }
-}
+}

services/nginx/app/modules/selfserve/traits/selfserve_lane_command_t.php

@@ -38,49 +38,6 @@ use objects\department_variables_o;
 
 trait selfserve_lane_command_t
 {
-
-    /**
-     * Acquire an atomic per-lane START lock before performing physical side effects.
-     */
-    protected function acquireLaneStartCommandLock(): string
-    {
-        if (!defined('redis') || !method_exists(redis, 'set_if_absent_with_expiration')) {
-            throw new \RuntimeException('Cannot start lane: START lock is unavailable.');
-        }
-
-        $token = bin2hex(random_bytes(16));
-        $lock_key = $this->getLaneStartCommandLockKey();
-        if (!redis->set_if_absent_with_expiration($lock_key, $token, 30)) {
-            throw new \RuntimeException("Cannot start lane: Lane is not available.");
-        }
-
-        return $token;
-    }
-
-    protected function releaseLaneStartCommandLock(string $token): void
-    {
-        if (!defined('redis')) {
-            return;
-        }
-
-        $lock_key = $this->getLaneStartCommandLockKey();
-        try {
-            if (method_exists(redis, 'get') && redis->get($lock_key) !== $token) {
-                return;
-            }
-            if (method_exists(redis, 'delete')) {
-                redis->delete($lock_key);
-            }
-        } catch (\Throwable) {
-            // The lock has a short TTL, so release failures must not mask START results.
-        }
-    }
-
-    protected function getLaneStartCommandLockKey(): string
-    {
-        return 'selfserve_lane_start_command_lock_' . (int)$this->id;
-    }
-
     /**
      * Determine if the lane and its department have self-serve enabled.
      * This method is intentionally protected to allow tests to override
@@ -171,12 +128,13 @@ trait selfserve_lane_command_t
      * Ensure machine relay is ON when a wash starts, when it is allowed by configuration.
      * If machine relay is not configured, this is a no-op.
      */
-    protected function setMachineRelayStatusForWashStart(?selfserve_lane_command_arguments $arguments = null): void
+    protected function setMachineRelayStatusForWashStart(): void
     {
         if (!$this->isRelayConfigured(selfserve_lane_relay::MACHINE)) {
             return;
         }
-        if ($this->isMachineWashSelectedAndAvailableForStart($arguments)) {
+        $active_wash = new selfserve_wash_flow();
+        if ($active_wash->isMachineAllowedToStartWash($this->id)) {
             try {
                 $this->setMachineRelayStatusHard(true);
             } catch (\Throwable) {
@@ -192,116 +150,6 @@ trait selfserve_lane_command_t
         }
     }
 
-    /**
-     * Keep the program picker relay aligned with the selected wash mode at START.
-     * It is ON only when the customer explicitly selected machine wash.
-     */
-    protected function setProgramPickerRelayStatusForWashStart(?selfserve_lane_command_arguments $arguments = null): void
-    {
-        if (!$this->isRelayConfigured(selfserve_lane_relay::MACHINE_PROGRAM_PICKER)) {
-            return;
-        }
-
-        try {
-            $shouldEnable = $this->isExplicitMachineWashModeSelectedForStart($arguments)
-                && $this->isMachineWashSelectedAndAvailableForStart($arguments);
-            $this->setMachineProgramPickerRelayStatusHard($shouldEnable);
-        } catch (\Throwable) {
-            // Best effort only; wash start must continue.
-        }
-    }
-
-    protected function setProgramPickerRelayStatusFromSelectedServiceForWashStart(?selfserve_lane_command_arguments $arguments = null): void
-    {
-        if (!$this->isRelayConfigured(selfserve_lane_relay::MACHINE_PROGRAM_PICKER)) {
-            return;
-        }
-
-        try {
-            $this->setMachineProgramPickerRelayStatusHard($this->shouldEnableProgramPickerRelayForWashStart($arguments));
-        } catch (\Throwable) {
-            // Best effort only; wash start must continue.
-        }
-    }
-
-    protected function isMachineWashSelectedAndAvailableForStart(?selfserve_lane_command_arguments $arguments = null): bool
-    {
-        if (!$this->shouldEnableSelectedMachineServiceForWashStart($arguments)) {
-            return false;
-        }
-
-        try {
-            $reg = method_exists($this, 'getLicensePlate') ? trim((string)$this->getLicensePlate()) : '';
-            if ($reg === '') {
-                return false;
-            }
-
-            $customerNumber = method_exists($this, 'getCustomerNumber') ? (int)$this->getCustomerNumber() : null;
-            $snapshot = (new selfserve_wash_flow())->previewVehicleEligibility(
-                (int)$this->id,
-                $reg,
-                $customerNumber !== null && $customerNumber > 0 ? $customerNumber : null
-            );
-
-            return (bool)($snapshot['allowed'] ?? false);
-        } catch (\Throwable) {
-            return false;
-        }
-    }
-
-    protected function shouldEnableSelectedMachineServiceForWashStart(?selfserve_lane_command_arguments $arguments = null): bool
-    {
-        if (!$this->isMachineWashModeSelectedForStart($arguments)) {
-            return false;
-        }
-
-        return $this->isMachineServiceSelectedForWashStart();
-    }
-
-    protected function shouldEnableProgramPickerRelayForWashStart(?selfserve_lane_command_arguments $arguments = null): bool
-    {
-        return $this->isExplicitMachineWashModeSelectedForStart($arguments)
-            && $this->isMachineServiceSelectedForWashStart();
-    }
-
-    protected function isExplicitMachineWashModeSelectedForStart(?selfserve_lane_command_arguments $arguments = null): bool
-    {
-        return $arguments !== null && $arguments->wash_mode === selfserve_studio_actions::MODE_MACHINE;
-    }
-
-    protected function isMachineWashModeSelectedForStart(?selfserve_lane_command_arguments $arguments = null): bool
-    {
-        if ($arguments !== null && $arguments->wash_mode === selfserve_studio_actions::MODE_MANUAL) {
-            return false;
-        }
-
-        if ($arguments !== null && $arguments->wash_mode === selfserve_studio_actions::MODE_MACHINE) {
-            return true;
-        }
-
-        return $this->isMachineServiceSelectedForWashStart();
-    }
-
-    protected function isMachineServiceSelectedForWashStart(): bool
-    {
-        try {
-            if (method_exists($this, 'getLaneCache') && defined(self::class . '::CACHE_SELFSERVE_LANE_KEY_ALLOWED_SERVICES')) {
-                $services = $this->getLaneCache((int)$this->id, self::CACHE_SELFSERVE_LANE_KEY_ALLOWED_SERVICES);
-                if (is_array($services)) {
-                    foreach ($services as $service) {
-                        if (strtoupper((string)$service) === 'MACHINE') {
-                            return true;
-                        }
-                    }
-                }
-            }
-        } catch (\Throwable) {
-            // Fall through to fail-closed when the selected service cache is unavailable.
-        }
-
-        return false;
-    }
-
     protected function openEntrancePortForWashStart(): void
     {
         try {
@@ -383,26 +231,30 @@ trait selfserve_lane_command_t
     protected function runRelaySideEffectsForWashStart(selfserve_lane_command_arguments $arguments): void
     {
         if ($arguments->defer_relay_side_effects) {
-            $this->setProgramPickerRelayStatusFromSelectedServiceForWashStart($arguments);
             return;
         }
 
+        // Ensure cleaner relay is enabled whenever wash starts.
         $this->turnOnCleanerRelayForWashStart();
-        $this->setProgramPickerRelayStatusForWashStart($arguments);
-        $this->setMachineRelayStatusForWashStart($arguments);
+        // Ensure the machine relay is ON when a wash starts, when it is allowed.
+        $this->setMachineRelayStatusForWashStart();
     }
 
-    protected function resolveSelfServeActionWashModeForStart(?selfserve_lane_command_arguments $arguments = null): string
+    protected function resolveSelfServeActionWashModeForStart(): string
     {
-        if ($arguments !== null && in_array($arguments->wash_mode, [
-            selfserve_studio_actions::MODE_MANUAL,
-            selfserve_studio_actions::MODE_MACHINE,
-        ], true)) {
-            return $arguments->wash_mode;
-        }
-
-        if ($this->isMachineServiceSelectedForWashStart()) {
-            return selfserve_studio_actions::MODE_MACHINE;
+        try {
+            if (method_exists($this, 'getLaneCache') && defined(self::class . '::CACHE_SELFSERVE_LANE_KEY_ALLOWED_SERVICES')) {
+                $services = $this->getLaneCache((int)$this->id, self::CACHE_SELFSERVE_LANE_KEY_ALLOWED_SERVICES);
+                if (is_array($services)) {
+                    foreach ($services as $service) {
+                        if (strtoupper((string)$service) === 'MACHINE') {
+                            return selfserve_studio_actions::MODE_MACHINE;
+                        }
+                    }
+                }
+            }
+        } catch (\Throwable) {
+            // Fall through to manual mode when the cached service set is unavailable.
         }
 
         return selfserve_studio_actions::MODE_MANUAL;
@@ -487,16 +339,14 @@ trait selfserve_lane_command_t
     }
 
     /**
-     * Disable relays before opening exit gates in deterministic order:
+     * Disable relays after STOP in deterministic order:
      * 1. Cleaner relay
-     * 2. Program picker relay
-     * 3. Machine relay
+     * 2. Machine relay
      */
     protected function turnOffRelaysAfterStop(): void
     {
         $relays = [
             selfserve_lane_relay::MACHINE_CLEANER,
-            selfserve_lane_relay::MACHINE_PROGRAM_PICKER,
             selfserve_lane_relay::MACHINE,
         ];
 
@@ -538,8 +388,7 @@ trait selfserve_lane_command_t
                 $this->id,
                 $this->getLicensePlate() ?: null,
                 $this->getCustomerNumber() ?: null,
-                method_exists($this, 'getLastInvoiceOrderId') ? $this->getLastInvoiceOrderId() : null,
-                false
+                method_exists($this, 'getLastInvoiceOrderId') ? $this->getLastInvoiceOrderId() : null
             );
         } catch (\Throwable) {
             // Session completion must not block STOP flow.
@@ -615,7 +464,6 @@ trait selfserve_lane_command_t
      * @param selfserve_lane_command_arguments $arguments The arguments for the command
      * @return selfserve_lane|selfserve_lane_command_t
      * @throws Exception If the command cannot be executed
-     * @throws \Throwable
      */
     public function execute(selfserve_lane_command $command, selfserve_lane_command_arguments $arguments): self
     {
@@ -660,48 +508,38 @@ trait selfserve_lane_command_t
                 // Validate customer number
                 if (!is_numeric($customer_number) || (int)$customer_number <= 0) throw new \InvalidArgumentException("Invalid customer number: " . $customer_number);
                 if (!(new users_o())->getUserByCustomerNumber((int)$customer_number)->exists()) throw new \InvalidArgumentException("Customer number does not exist: " . $customer_number);
-                $start_lock_token = $this->acquireLaneStartCommandLock();
+                $previous_customer_number = $this->getCustomerNumber();
+                $previous_license_plate = $this->getLicensePlate();
+                // Set the customer number and license plate
+                $this->setCustomerNumber($customer_number);
+                $this->setLicensePlate($license_plate);
                 try {
-                    // Re-check availability after taking the START lock so concurrent requests cannot
-                    // both pass the preflight check and trigger the physical entrance relay.
-                    if (!$this->getLaneStatus()->equals(selfserve_lane_status::AVAILABLE)) throw new \RuntimeException("Cannot start lane: Lane is not available.");
-                    $previous_customer_number = $this->getCustomerNumber();
-                    $previous_license_plate = $this->getLicensePlate();
-                    $previous_status = $this->getLaneStatus();
-                    // Set the customer number and license plate
-                    $this->setCustomerNumber($customer_number);
-                    $this->setLicensePlate($license_plate);
-                    // Mark the lane occupied before any physical relay or gate side effects.
-                    $this->setLaneStatus(selfserve_lane_status::OCCUPIED);
-                    $this->runRelaySideEffectsForWashStart($arguments);
-                    $this->runPublishedStudioActions(
-                        selfserve_studio_actions::EVENT_WASH_START_COMMAND,
-                        $this->resolveSelfServeActionWashModeForStart($arguments),
-                        [
-                            'customer_number' => (int)$customer_number,
-                            'reg' => $license_plate,
-                        ]
-                    );
-                    try {
-                        // Gateway timeouts are ambiguous because the relay may already have received
-                        // the pulse, so openEntrancePortForWashStart() reports them and continues.
-                        $this->openEntrancePortForWashStart();
-                    } catch (\Throwable $e) {
-                        $this->setCustomerNumber($previous_customer_number);
-                        $this->setLicensePlate($previous_license_plate);
-                        $this->setLaneStatus($previous_status);
-                        $this->setLaneState(selfserve_lane_state::IDLE);
-                        throw $e;
-                    }
-                    // Set the lane state to IN_WASH
-                    $this->setLaneState(selfserve_lane_state::IN_WASH);
-                    // Start the wash timer
-                    $this->setWashStartTime(time());
-                    // Log the lane start event
-                    $this->logLaneAction(selfserve_lane_log_action::START_WASH);
-                } finally {
-                    $this->releaseLaneStartCommandLock($start_lock_token);
+                    // Open the entrance port before marking the lane occupied. Gateway timeouts are
+                    // ambiguous because the relay may already have received the pulse.
+                    $this->openEntrancePortForWashStart();
+                } catch (\Throwable $e) {
+                    $this->setCustomerNumber($previous_customer_number);
+                    $this->setLicensePlate($previous_license_plate);
+                    $this->setLaneState(selfserve_lane_state::IDLE);
+                    throw $e;
                 }
+                // Set the lane status to OCCUPIED when started
+                $this->setLaneStatus(selfserve_lane_status::OCCUPIED);
+                // Set the lane state to IN_WASH
+                $this->setLaneState(selfserve_lane_state::IN_WASH);
+                // Start the wash timer
+                $this->setWashStartTime(time());
+                $this->runPublishedStudioActions(
+                    selfserve_studio_actions::EVENT_WASH_START_COMMAND,
+                    $this->resolveSelfServeActionWashModeForStart(),
+                    [
+                        'customer_number' => (int)$customer_number,
+                        'reg' => $license_plate,
+                    ]
+                );
+                $this->runRelaySideEffectsForWashStart($arguments);
+                // Log the lane start event
+                $this->logLaneAction(selfserve_lane_log_action::START_WASH);
                 break;
             case selfserve_lane_command::STOP:
                 // Require lane to be occupied before stopping
@@ -712,8 +550,6 @@ trait selfserve_lane_command_t
                 }
                 // Snapshot the physical machine ON signal before session completion/reset.
                 $machine_start_triggered = $this->hasMachineStartSignalForStop();
-                // Turn off relays before any configured or default exit gate opens.
-                $this->turnOffRelaysAfterStop();
                 $this->runPublishedStudioActions(
                     selfserve_studio_actions::EVENT_WASH_STOP_COMMAND,
                     $machine_start_triggered ? selfserve_studio_actions::MODE_MACHINE : selfserve_studio_actions::MODE_MANUAL,
@@ -726,10 +562,12 @@ trait selfserve_lane_command_t
                 // Open the exit port. Gateway timeouts are ambiguous because
                 // the relay may already have received the pulse.
                 $this->openExitPortForWashStop();
+                // Turn off relays in deterministic order after STOP
+                $this->turnOffRelaysAfterStop();
                 // Log the lane stop event
                 $this->logLaneAction(selfserve_lane_log_action::STOP_WASH);
                 // Invoice the customer
-                $this->invoice($arguments);
+                $this->invoice();
                 // Only bill the machine wash product when the physical machine start signal was recorded.
                 $this->addVehicleTypeProductToInvoiceIfNeeded($machine_start_triggered);
                 // Finalize any active self-serve wash session for this lane

services/nginx/app/modules/selfserve/traits/selfserve_lane_invoice_t.php

@@ -4,24 +4,15 @@ namespace modules\selfserve\traits;
 require_once WD . '/modules/selfserve/helpers/selfserve_lane_status.php';
 require_once WD . '/modules/selfserve/helpers/selfserve_lane_mode.php';
 require_once WD . '/modules/selfserve/classes/selfserve_lane.php';
-require_once WD . '/modules/selfserve/classes/selfserve_lane_command_arguments.php';
-require_once WD . '/modules/attachments/helpers/attachment_content.php';
-require_once WD . '/objects/selfserve_wash_sessions_o.php';
-require_once WD . '/objects/subusers_o.php';
 
 use classes\selfserve;
-use classes\economic;
 use Exception;
-use attachments\helpers\attachment_content;
-use modules\selfserve\classes\selfserve_lane_command_arguments;
 use modules\selfserve\classes\selfserve_lane;
 use modules\selfserve\helpers\selfserve_lane_mode;
 use modules\selfserve\helpers\selfserve_lane_status;
 use objects\customer_vehicles_o;
 use objects\order_items_o;
 use objects\orders_o;
-use objects\selfserve_wash_sessions_o;
-use objects\subusers_o;
 
 trait selfserve_lane_invoice_t
 {
@@ -111,7 +102,7 @@ trait selfserve_lane_invoice_t
      * @return bool True on success, false on failure
      * @throws Exception if lane ID is not set, lane is not occupied, customer number or license plate is not set, or product ID is not set
      */
-    public function invoice(?selfserve_lane_command_arguments $arguments = null): bool
+    public function invoice(): bool
     {
         $this->last_invoice_order_id = null;
 
@@ -124,10 +115,12 @@ trait selfserve_lane_invoice_t
         $included_minutes = $this->resolveIncludedMinutesForBilling();
         $billable_minutes = $this->calculateBillableMinutes($elapsed_minutes, $included_minutes);
 
-        if ($billable_minutes > 0) {
-            $order = $this->createInvoiceOrderContext($arguments);
-            $this->billable_minutes_order_item = $this->addMinuteBillingLine((int)$order->id, (int)$product_id, $billable_minutes);
+        if ($billable_minutes <= 0) {
+            return true;
         }
+
+        $order = $this->createInvoiceOrderContext();
+        $this->billable_minutes_order_item = $this->addMinuteBillingLine((int)$order->id, (int)$product_id, $billable_minutes);
         return true;
     }
 
@@ -219,12 +212,10 @@ trait selfserve_lane_invoice_t
         return max(0, $elapsed_minutes - $included_minutes);
     }
 
-    protected function createInvoiceOrderContext(?selfserve_lane_command_arguments $arguments = null): orders_o
+    protected function createInvoiceOrderContext(): orders_o
     {
-        $billing_customer_number = $this->getCustomerNumber();
-        $draft_customer_number = (new economic())->getTransactionDraftCustomerNumber();
         $order = (new orders_o())->add(
-            $billing_customer_number,
+            $this->getCustomerNumber(),
             self::INVOICE_SYSTEM_USER_ID,
             '',
             '',
@@ -233,101 +224,10 @@ trait selfserve_lane_invoice_t
         );
         $order->lane->set($this->id);
         $this->last_invoice_order_id = (int)$order->id;
-        $this->attachSelfServeMetadataToOrder($order, $billing_customer_number, $draft_customer_number, $arguments);
 
         return $order;
     }
 
-    protected function attachSelfServeMetadataToOrder(
-        orders_o $order,
-        int $billing_customer_number,
-        ?int $draft_customer_number,
-        ?selfserve_lane_command_arguments $arguments = null
-    ): void {
-        try {
-            $order->addAttachment(
-                (new attachment_content())->setOther(
-                    $this->buildSelfServeOrderAttachmentPayload($billing_customer_number, $draft_customer_number, $arguments)
-                )
-            );
-        } catch (\Throwable) {
-            // Metadata attachments must not block billing; the order itself is the source of record.
-        }
-    }
-
-    protected function buildSelfServeOrderAttachmentPayload(
-        int $billing_customer_number,
-        ?int $draft_customer_number,
-        ?selfserve_lane_command_arguments $arguments = null
-    ): array {
-        $session = $this->findOpenSelfServeSessionForAttachment($billing_customer_number);
-        $subuser_id = $arguments?->subuser_id;
-
-        return [
-            'type' => attachment_content::OTHER_TYPE_SELF_SERVE_WASH,
-            'source' => 'selfserve',
-            'customer_number' => $billing_customer_number,
-            'draft_customer_number' => $draft_customer_number,
-            'subuser_id' => $subuser_id,
-            'subuser' => $this->formatSelfServeAttachmentSubuser($subuser_id),
-            'session_id' => $session?->id,
-            'lane_id' => (int)$this->id,
-            'department_id' => (int)$this->department_lane->department->value(),
-            'license_plate' => (string)$this->getLicensePlate(),
-            'lane_status' => $this->getLaneStatus()->name,
-            'lane_mode' => $this->getLaneMode()->name,
-            'wash_start_time' => (int)$this->getWashStartTime(),
-            'elapsed_wash_time_seconds' => (int)$this->getElapsedWashTime(),
-            'created_at' => date('Y-m-d H:i:s'),
-        ];
-    }
-
-    protected function findOpenSelfServeSessionForAttachment(int $billing_customer_number): ?selfserve_wash_sessions_o
-    {
-        $license_plate = trim((string)$this->getLicensePlate());
-        if ($license_plate === '') {
-            return null;
-        }
-
-        try {
-            $session = (new selfserve_wash_sessions_o())->selectLatestOpenByLaneAndReg(
-                (int)$this->id,
-                selfserve::standardize_registration($license_plate),
-                $billing_customer_number > 0 ? $billing_customer_number : null
-            );
-            return $session->exists() ? $session : null;
-        } catch (\Throwable) {
-            return null;
-        }
-    }
-
-    protected function formatSelfServeAttachmentSubuser(?int $subuser_id): ?array
-    {
-        if ($subuser_id === null || $subuser_id <= 0) {
-            return null;
-        }
-
-        try {
-            $subuser = (new subusers_o())->select($subuser_id);
-            if (!$subuser->exists()) {
-                return [
-                    'id' => $subuser_id,
-                ];
-            }
-
-            return [
-                'id' => (int)$subuser->id,
-                'name' => $subuser->name->value(),
-                'username' => $subuser->username->value(),
-                'email' => $subuser->email->value(),
-            ];
-        } catch (\Throwable) {
-            return [
-                'id' => $subuser_id,
-            ];
-        }
-    }
-
     protected function addMinuteBillingLine(int $order_id, int $product_id, int $quantity): order_items_o
     {
         return (new order_items_o())->addItemToOrder(

services/nginx/app/modules/selfserve/traits/selfserve_lane_port_controller_t.php

@@ -17,7 +17,6 @@ trait selfserve_lane_port_controller_t
 {
     private const DEMO_RELAY_ID_PREFIX = 'demo-';
     private const DEFAULT_PORT_OPEN_TOGGLE_AFTER_SECONDS = 1;
-    private const MAX_PORT_OPEN_TOGGLE_AFTER_SECONDS = 5;
 
     /**
      * Open the lane port
@@ -106,7 +105,7 @@ trait selfserve_lane_port_controller_t
     private function normalizePortOpenToggleAfter(?int $toggle_after_seconds): int
     {
         if ($toggle_after_seconds !== null && $toggle_after_seconds > 0) {
-            return min($toggle_after_seconds, self::MAX_PORT_OPEN_TOGGLE_AFTER_SECONDS);
+            return $toggle_after_seconds;
         }
 
         return self::DEFAULT_PORT_OPEN_TOGGLE_AFTER_SECONDS;

services/nginx/app/modules/selfserve/traits/selfserve_lane_relay_controller_t.php

@@ -12,7 +12,6 @@ use modules\selfserve\helpers\selfserve_lane_relay;
 use modules\selfserve\helpers\selfserve_lane_services;
 use modules\selfserve\helpers\selfserve_lane_status;
 use modules\shelly\helpers\shelly_request_body_get_states;
-use objects\selfserve_wash_sessions_o;
 
 trait selfserve_lane_relay_controller_t
 {
@@ -108,16 +107,14 @@ trait selfserve_lane_relay_controller_t
     }
 
     /**
-     * Set MACHINE relay status using the same guards as manual relay controls.
+     * Set MACHINE relay status directly.
      * @param bool $on true to turn on, false to turn off
      * @return bool
      * @throws \Exception
      */
     public function setMachineRelayStatus(bool $on): bool
     {
-        return $on
-            ? $this->turnOnRelay(selfserve_lane_relay::MACHINE)
-            : $this->turnOffRelay(selfserve_lane_relay::MACHINE);
+        return $this->setRelayStatus(selfserve_lane_relay::MACHINE, $on);
     }
 
     /**
@@ -918,38 +915,7 @@ trait selfserve_lane_relay_controller_t
             }
         }
 
-        $result = $this->sendRelaySwitchCommand($relay, true, $duration);
-        if ($result && $relay === selfserve_lane_relay::MACHINE) {
-            $this->markLatestSelfServeSessionRelayEnabledForLane();
-        }
-
-        return $result;
-    }
-
-    protected function markLatestSelfServeSessionRelayEnabledForLane(): void
-    {
-        try {
-            $customerNumber = (int)$this->getCustomerNumber();
-            $session = (new selfserve_wash_sessions_o())->selectLatestOpenByLane(
-                (int)$this->id,
-                $customerNumber > 0 ? $customerNumber : null
-            );
-            if (!$session->exists() && $customerNumber > 0) {
-                $session = (new selfserve_wash_sessions_o())->selectLatestOpenByLane((int)$this->id);
-            }
-            if (!$session->exists() || (bool)$session->machine_relay_enabled->value() === true) {
-                return;
-            }
-
-            $session->markRelayEnabled();
-        } catch (\Throwable $e) {
-            error_log(
-                'Failed to synchronize self-serve machine relay session state for lane '
-                . (int)$this->id
-                . ': '
-                . $e->getMessage()
-            );
-        }
+        return $this->sendRelaySwitchCommand($relay, true, $duration);
     }
 
     /**

services/nginx/app/modules/selfserve/traits/selfserve_lane_status_t.php

@@ -87,44 +87,4 @@ trait selfserve_lane_status_t
 
         return $this;
     }
-
-    public function setLaneStatusAudit(?array $audit): self
-    {
-        if ($audit === null) {
-            $this->clearLaneCache($this->id, self::CACHE_SELFSERVE_LANE_KEY_STATUS_AUDIT);
-            return $this;
-        }
-
-        $this->setLaneCache($this->id, self::CACHE_SELFSERVE_LANE_KEY_STATUS_AUDIT, [
-            'modified_at' => isset($audit['modified_at']) ? (string)$audit['modified_at'] : date(DATE_ATOM),
-            'modified_by_user_id' => isset($audit['modified_by_user_id']) ? (int)$audit['modified_by_user_id'] : null,
-            'modified_by_name' => isset($audit['modified_by_name']) ? (string)$audit['modified_by_name'] : null,
-        ]);
-
-        return $this;
-    }
-
-    public function getLaneStatusAudit(): ?array
-    {
-        $audit = $this->getLaneCache($this->id, self::CACHE_SELFSERVE_LANE_KEY_STATUS_AUDIT);
-        if (!is_array($audit)) {
-            return null;
-        }
-
-        $modified_at = isset($audit['modified_at']) ? trim((string)$audit['modified_at']) : '';
-        $modified_by_name = isset($audit['modified_by_name']) ? trim((string)$audit['modified_by_name']) : '';
-        $modified_by_user_id = isset($audit['modified_by_user_id']) && is_numeric($audit['modified_by_user_id'])
-            ? (int)$audit['modified_by_user_id']
-            : null;
-
-        if ($modified_at === '' && $modified_by_name === '' && $modified_by_user_id === null) {
-            return null;
-        }
-
-        return [
-            'modified_at' => $modified_at !== '' ? $modified_at : null,
-            'modified_by_user_id' => $modified_by_user_id,
-            'modified_by_name' => $modified_by_name !== '' ? $modified_by_name : null,
-        ];
-    }
-}
+}

services/nginx/app/modules/slack/config/slack_customer_registration_webhook_url_c.php

@@ -1,29 +0,0 @@
-<?php
-
-namespace slack\config;
-
-use Exception;
-use traits\module_config_variable;
-
-class slack_customer_registration_webhook_url_c
-{
-    use module_config_variable;
-
-    /**
-     * @throws Exception
-     */
-    public function __construct()
-    {
-        self::setupConfigVariable(
-            'Slack',
-            'customer_registration_webhook_url',
-            'string',
-            false,
-            null,
-            'Slack webhook URL used for successful customer registration notifications',
-            'https://hooks.slack.com/services/...',
-            true,
-            ''
-        );
-    }
-}

services/nginx/app/modules/slack/slack_c.php

@@ -1,25 +0,0 @@
-<?php
-
-namespace slack;
-
-require_once WD . '/modules/slack/config/slack_customer_registration_webhook_url_c.php';
-
-use slack\config\slack_customer_registration_webhook_url_c;
-use traits\module_config_t;
-
-class slack_c
-{
-    use module_config_t;
-
-    public slack_customer_registration_webhook_url_c $customer_registration_webhook_url;
-
-    public function __construct()
-    {
-        $this->setupConfig('Slack');
-        $this->allowUpdate([
-            slack_customer_registration_webhook_url_c::class,
-        ]);
-
-        $this->customer_registration_webhook_url = new slack_customer_registration_webhook_url_c();
-    }
-}

services/nginx/app/modules/washcertificates/certificates/index.php

@@ -20,11 +20,7 @@ if (!is_numeric($certificate_id) || $certificate_id < 1) {
     return;
 }
 
-// Require a valid static token before serving certificates
-if (!isset($_GET['secret_token']) || $_GET['secret_token'] !== $WORDPRESS_STATIC_TOKEN) {
-    header('HTTP/1.0 401 Unauthorized');
-    return;
-}
+// TODO: Add authentication here
 
 // Check if the certificate exists in the /output/certificates folder
 if (!file_exists("../output/certificates/wash_certificate_" . $certificate_id . ".pdf")) {
@@ -38,4 +34,4 @@ header('Content-Disposition: attachment; filename="wash certificate ' . $certifi
 
 // Output the certificate
 readfile("../output/certificates/wash_certificate_" . $certificate_id . ".pdf");
-exit;
+exit;

services/nginx/app/modules/washcertificates/index.php

@@ -104,7 +104,7 @@ if ($wash_certificate_store->washCertificateExists($_GET['bookingId'])) {
         $success = $wash_certificate_store->uploadFile("wash_certificate_" . $_GET['bookingId'] . ".pdf", dirname(__FILE__) . "/output/certificates/wash_certificate_" . $_GET['bookingId'] . ".pdf");
         // If the certificate was uploaded successfully, delete the local copy
         if ($success) {
-            unlink(dirname(__FILE__) . "/output/certificates/wash_certificate_" . $_GET['bookingId'] . ".pdf");
+            //unlink(dirname(__FILE__) . "/output/certificates/wash_certificate_" . $_GET['bookingId'] . ".pdf");
             // Return the certificate url
             echo $wash_certificate_store->getWashCertificateDownload($_GET['bookingId']);
             exit;
@@ -131,7 +131,7 @@ $generatedCertificatePath = "output/certificates/wash_certificate_" . $_GET['boo
 $wash_certificate_store->uploadFile($generatedCertificateName, dirname(__FILE__) . '/' . $generatedCertificatePath);
 
 // Delete the local copy of the certificate
-unlink(dirname(__FILE__) . '/' . $generatedCertificatePath);
+//unlink(dirname(__FILE__) . '/' . $generatedCertificatePath);
 
 // Set the status of the booking to completed
 $booking = new bookings_o();

services/nginx/app/modules/workfeed/config/workfeed_api_url_c.php

@@ -7,14 +7,7 @@ use traits\module_config_variable;
 
 class workfeed_api_url_c
 {
-    use module_config_variable {
-        validateVariableValue as private validateModuleConfigVariableValue;
-    }
-
-    private const TRUSTED_API_HOSTS = [
-        'api.workfeed.io',
-        'europe-west1-production-eu-327a3.cloudfunctions.net',
-    ];
+    use module_config_variable;
 
     /**
      * @throws Exception
@@ -27,54 +20,10 @@ class workfeed_api_url_c
             'string',
             true,
             null,
-            'The base URL for the Workfeed API (trusted Workfeed endpoints only; see docs.workfeed.io)',
+            'The base URL for the Workfeed API (see docs.workfeed.io)',
             'https://europe-west1-production-eu-327a3.cloudfunctions.net/api',
             false,
             'https://europe-west1-production-eu-327a3.cloudfunctions.net/api'
         );
     }
-
-    public function validateVariableValue(mixed $value): bool
-    {
-        if (!$this->validateModuleConfigVariableValue($value)) {
-            return false;
-        }
-
-        return self::isTrustedApiUrl((string)$value);
-    }
-
-    public static function isTrustedApiUrl(string $url): bool
-    {
-        $normalizedUrl = self::normalizeApiUrlForValidation($url);
-        if (filter_var($normalizedUrl, FILTER_VALIDATE_URL) === false) {
-            return false;
-        }
-
-        $parts = parse_url($normalizedUrl);
-
-        if ($parts === false) {
-            return false;
-        }
-
-        $scheme = strtolower((string)($parts['scheme'] ?? ''));
-        $host = strtolower((string)($parts['host'] ?? ''));
-        $port = $parts['port'] ?? null;
-
-        return $scheme === 'https'
-            && in_array($host, self::TRUSTED_API_HOSTS, true)
-            && ($port === null || $port === 443)
-            && !isset($parts['user'])
-            && !isset($parts['pass']);
-    }
-
-    public static function normalizeApiUrlForValidation(string $url): string
-    {
-        $url = trim($url);
-
-        if (preg_match('#^https?://#i', $url)) {
-            return $url;
-        }
-
-        return 'https://' . ltrim($url, '/');
-    }
 }

services/nginx/app/objects/bookings_o.php

@@ -200,7 +200,6 @@ class bookings_o extends db
         $washCertificateStatus = $db->escape_string($washCertificateStatus);
         $washCertificateUrl = $db->escape_string($washCertificateUrl);
         $status = $db->escape_string($status);
-        $pickup_bool = (int)$pickup_bool;
         // Check if the entry already exists
         $sql = "SELECT * FROM $this->table WHERE id = $id";
         $result = $db->query($sql);

services/nginx/app/objects/collected_order_invoices_o.php

@@ -606,76 +606,6 @@ class collected_order_invoices_o extends db
         self::deleteCached('asArray', $this->id);
     }
 
-    /**
-     * Move this invoice collection and all attached orders to another customer.
-     *
-     * @return array<string,mixed>
-     * @throws Exception
-     */
-    public function moveToCustomer(int $target_customer_number): array
-    {
-        global $db;
-
-        self::requireSelected();
-        self::requireValidCustomer((string)$target_customer_number);
-
-        if ($target_customer_number <= 0) {
-            throw new Exception('Target customer number must be greater than zero');
-        }
-
-        if (!empty($this->external_id->value()) || $this->booked_invoice_id->value() !== null) {
-            throw new Exception('Invoice collections with an external or booked invoice cannot be moved');
-        }
-
-        $source_customer_number = (int)$this->customer_number->value();
-        if ($source_customer_number === $target_customer_number) {
-            return [
-                'invoice_collection_id' => (int)$this->id,
-                'source_customer_number' => $source_customer_number,
-                'target_customer_number' => $target_customer_number,
-                'moved_order_ids' => [],
-                'moved_order_count' => 0,
-                'changed' => false,
-            ];
-        }
-
-        $invoice_collection_id = (int)$this->id;
-        $result = $db->query("SELECT id FROM orders WHERE invoice_collection_id = {$invoice_collection_id}");
-        $order_ids = array_map(
-            static fn(array $row): int => (int)$row['id'],
-            $db->fetch_all($result)
-        );
-
-        $db->conn()->begin_transaction();
-        try {
-            $this->customer_number->set($target_customer_number);
-
-            foreach ( $order_ids as $order_id ) {
-                $order = (new orders_o())->select($order_id);
-                if (!$order->exists()) {
-                    continue;
-                }
-                $order->customer_id->set($target_customer_number);
-                $order->objectChanged();
-            }
-
-            $this->objectChanged();
-            $db->conn()->commit();
-        } catch (\Throwable $e) {
-            $db->conn()->rollback();
-            throw $e;
-        }
-
-        return [
-            'invoice_collection_id' => $invoice_collection_id,
-            'source_customer_number' => $source_customer_number,
-            'target_customer_number' => $target_customer_number,
-            'moved_order_ids' => $order_ids,
-            'moved_order_count' => count($order_ids),
-            'changed' => true,
-        ];
-    }
-
     /**
      * Get the external id of the invoice collection
      * @throws Exception If the request was not successful

services/nginx/app/objects/customer_password_reset_keys_o.php

@@ -18,18 +18,13 @@ class customer_password_reset_keys_o extends db
     public object_property $updated_at;
     public object_property $deleted_at;
     const TOKEN_LENGTH = 32;
-    const TOKEN_EXPIRY_SECONDS = 72 * 60 * 60; // 72 hours
+    const TOKEN_EXPIRY_SECONDS = 3600; // 1 hour
 
     public function structure(): void
     {
         $this->setTable('customer_password_reset_keys');
     }
 
-    private function validTokenWhereClause(): string
-    {
-        return "deleted_at IS NULL AND created_at >= DATE_SUB(NOW(), INTERVAL " . self::TOKEN_EXPIRY_SECONDS . " SECOND)";
-    }
-
 
     /**
      * Add a new customer reset key
@@ -70,8 +65,9 @@ class customer_password_reset_keys_o extends db
         if (strlen($token) !== self::TOKEN_LENGTH) {
             return null;
         }
-        // Query the database for a valid token using the same clock that writes created_at.
-        $sql = "SELECT id FROM $this->table WHERE token = '" . $db->escape_string($token) . "' AND " . $this->validTokenWhereClause() . " LIMIT 1";
+        // Query the database for a valid token
+        $current_time = date('Y-m-d H:i:s');
+        $sql = "SELECT id FROM $this->table WHERE token = '" . $db->escape_string($token) . "' AND deleted_at IS NULL AND created_at >= DATE_SUB('$current_time', INTERVAL " . self::TOKEN_EXPIRY_SECONDS . " SECOND) LIMIT 1";
         $result = $db->query($sql);
         if ($result->num_rows === 0) {
             return null;
@@ -89,11 +85,13 @@ class customer_password_reset_keys_o extends db
      */
     public function isValidToken(): bool
     {
-        global $db;
         self::requireSelected();
-        $sql = "SELECT id FROM $this->table WHERE id = " . (int)$this->id . " AND " . $this->validTokenWhereClause() . " LIMIT 1";
-        $result = $db->query($sql);
-        return $result->num_rows > 0;
+        $created_at = strtotime($this->created_at->value());
+        $current_time = time();
+        return (
+            ($current_time - $created_at) <= self::TOKEN_EXPIRY_SECONDS) &&
+            ($this->deleted_at->value() === null
+            );
     }
 
     /**
@@ -142,4 +140,4 @@ class customer_password_reset_keys_o extends db
     {
         //TODO: Add cache invalidation
     }
-}
+}

services/nginx/app/objects/department_lanes_o.php

@@ -7,7 +7,6 @@ use classes\object_property;
 use classes\selfserve;
 use classes\selfserve_schema_bootstrap;
 use Exception;
-use modules\selfserve\classes\selfserve_config_versioning;
 use traits\db_object_t;
 
 class department_lanes_o extends db
@@ -131,10 +130,6 @@ class department_lanes_o extends db
 
     public function asArray(): array
     {
-        $status = (string)$this->getLaneStatus()->name;
-        $machine_status_audit = $this->getMachineStatusAudit();
-        $selfserve_configuration_warnings = $this->getSelfServeConfigurationWarnings();
-
         return [
             'id' => (int)$this->id,
             'department' => (int)$this->department->value(),
@@ -148,76 +143,13 @@ class department_lanes_o extends db
             'machine_type_id' => (function($v){ return $v === null ? null : (int)$v; })($this->machine_type_id->value()),
             'selfserve_enabled' => $this->isSelfServeEnabled(),
             // Status of the lane
-            'status' => $status,
-            'machine_status_enabled' => self::isOperationalStatusName($status),
-            'machine_status_audit' => $machine_status_audit,
-            'machine_status_modified_at' => $machine_status_audit['modified_at'] ?? null,
-            'machine_status_modified_by' => $machine_status_audit['modified_by_name'] ?? null,
-            'machine_status_modified_by_user_id' => $machine_status_audit['modified_by_user_id'] ?? null,
-            'selfserve_configured' => $selfserve_configuration_warnings === [],
-            'dognvask_configured' => $selfserve_configuration_warnings === [],
-            'dognvask_configuration_warnings' => $selfserve_configuration_warnings,
+            'status' => (string)$this->getLaneStatus()->name,
             // Timestamps
             'created_at' => (string)$this->created_at->value(),
             'updated_at' => (string)$this->updated_at->value(),
         ];
     }
 
-    private function getMachineStatusAudit(): ?array
-    {
-        try {
-            $lane = (new selfserve())->lane((int)$this->id);
-            if (!method_exists($lane, 'getLaneStatusAudit')) {
-                return null;
-            }
-
-            $audit = $lane->getLaneStatusAudit();
-            return is_array($audit) ? $audit : null;
-        } catch (\Throwable) {
-            return null;
-        }
-    }
-
-    public function getSelfServeConfigurationWarnings(): array
-    {
-        self::requireSelected();
-
-        $required_fields = [
-            'relay_in_id' => 'Indgangsrelæ',
-            'relay_out_id' => 'Udgangsrelæ',
-            'relay_machine_id' => 'Maskinrelæ',
-            'relay_machine_program_picker_id' => 'Programvælgerrelæ',
-            'relay_machine_cleaner_id' => 'Vaskerelæ',
-            'dynamic_image_id' => 'Maskinstatusbillede',
-            'machine_type_id' => 'Maskintype',
-        ];
-
-        $warnings = [];
-        foreach ($required_fields as $field => $label) {
-            if ($this->hasConfiguredFieldValue($field)) {
-                continue;
-            }
-
-            $warnings[] = [
-                'field' => $field,
-                'label' => $label,
-                'message' => $label . ' mangler',
-            ];
-        }
-
-        return $warnings;
-    }
-
-    public function isSelfServeConfigured(): bool
-    {
-        return $this->getSelfServeConfigurationWarnings() === [];
-    }
-
-    public static function isOperationalStatusName(string $status): bool
-    {
-        return in_array(strtoupper(trim($status)), ['AVAILABLE', 'OCCUPIED', 'RESERVED'], true);
-    }
-
     public function isSelfServeEnabled(): bool
     {
         self::requireSelected();
@@ -252,29 +184,6 @@ class department_lanes_o extends db
         return in_array(strtolower(trim((string)$value)), ['1', 'true', 'yes', 'on'], true);
     }
 
-    private function hasConfiguredFieldValue(string $field): bool
-    {
-        if (!isset($this->{$field}) || !is_object($this->{$field}) || !method_exists($this->{$field}, 'value')) {
-            return false;
-        }
-
-        $value = $this->{$field}->value();
-        if ($value === null) {
-            return false;
-        }
-
-        if (is_string($value)) {
-            $value = trim($value);
-            return $value !== '' && $value !== '0' && strtolower($value) !== 'null';
-        }
-
-        if (is_numeric($value)) {
-            return (int)$value > 0;
-        }
-
-        return (bool)$value;
-    }
-
     public static function disableSelfServeRelaysBestEffort(int $lane_id): void
     {
         if ($lane_id <= 0) {
@@ -325,52 +234,9 @@ class department_lanes_o extends db
     public function getSelfServeLaneProducts(): array
     {
         self::requireSelected();
-        $publishedProducts = $this->getPublishedSelfServeLaneProducts();
-        if ($publishedProducts !== []) {
-            return $publishedProducts;
-        }
-
         return department_selfserve_tasks_o::getLaneProducts((int)$this->id);
     }
 
-    /**
-     * @return int[]
-     */
-    private function getPublishedSelfServeLaneProducts(): array
-    {
-        try {
-            $published = (new selfserve_config_versioning())->getPublishedV2Config((int)$this->department->value());
-        } catch (\Throwable) {
-            return [];
-        }
-
-        $config = is_array($published['config'] ?? null) ? $published['config'] : null;
-        if ($config === null) {
-            return [];
-        }
-
-        $laneId = (int)$this->id;
-        $products = [];
-        foreach ((array)($config['tasks'] ?? []) as $task) {
-            if (!is_array($task)) {
-                continue;
-            }
-
-            $taskLane = (int)($task['lane'] ?? 0);
-            if ($taskLane !== 0 && $taskLane !== $laneId) {
-                continue;
-            }
-
-            $productId = (int)($task['product'] ?? 0);
-            if ($productId > 0 && !in_array($productId, $products, true)) {
-                $products[] = $productId;
-            }
-        }
-
-        sort($products, SORT_NUMERIC);
-        return $products;
-    }
-
     /**
      * @throws Exception
      * @return department_lanes_o[] An array of department lane objects for the specified department

services/nginx/app/objects/order_bookings_o.php

@@ -369,7 +369,6 @@ class order_bookings_o extends db
             return;
         }
 
-        $this->requireLinkedOrderMatchesBooking($order);
         $normalizedSafetySeal = orders_o::normalizeSafetySealValue($safety_seal);
         if ($normalizedSafetySeal !== null) {
             $order->setSafetySealValue($normalizedSafetySeal);
@@ -415,16 +414,11 @@ class order_bookings_o extends db
                 continue;
             }
             $orderItems = new order_items_o();
-            $itemNotes = isset($item['notes']) && trim((string)$item['notes']) !== ''
-                ? (string)$item['notes']
-                : ((string)($this->note->value() ?? '') ?: null);
             $orderItems->addItemToOrder(
                 (int)$order->id,
                 (int)$item['id'],
                 (int)$user_id,
                 (int)$item['quantity'],
-                null,
-                $itemNotes,
             );
         }
 
@@ -468,34 +462,14 @@ class order_bookings_o extends db
         return $order;
     }
 
-    /**
-     * @throws Exception
-     */
-    private function requireLinkedOrderMatchesBooking(orders_o $order): void
-    {
-        self::requireSelected();
-
-        $bookingCustomerNumber = (int)$this->customer_number->value();
-        $bookingDepartmentId = (int)$this->department->value();
-        $orderCustomerId = (int)$order->customer_id->value();
-        $orderDepartmentId = (int)$order->department_id->value();
-
-        if ($orderCustomerId !== $bookingCustomerNumber || $orderDepartmentId !== $bookingDepartmentId) {
-            throw new Exception('Linked order does not match booking customer or department');
-        }
-    }
-
     /**
      * @throws Exception
      */
     protected function attachWashCertificate(int $user_id, ?string $safety_seal = null): void
     {
         self::requireSelected();
-        $order = $this->getOrder();
-        $this->requireLinkedOrderMatchesBooking($order);
-
         // Check if the order already has a wash certificate attached
-        if ($order->hasWashCertificateAttached()) {
+        if ($this->getOrder()->hasWashCertificateAttached()) {
             return;
         }
         // Get the operator name

services/nginx/app/objects/orders_o.php

@@ -270,8 +270,6 @@ class orders_o extends db
     public function getOrderHistoryByVehiclePlate(string $plate, int $entries = 10): array
     {
         global $db;
-        $plate = $db->escape_string($plate);
-        $entries = max(1, $entries);
         $sql = "SELECT * FROM $this->table WHERE reg_1 = '$plate' OR reg_2 = '$plate' OR reg_3 = '$plate' ORDER BY id DESC LIMIT $entries";
         $result = $db->query($sql);
         return $db->fetch_all($result);
@@ -539,7 +537,6 @@ class orders_o extends db
     {
         global /** @var db $db */
         $db;
-        $plate = $db->escape_string($plate);
         $sql = "SELECT id FROM $this->table WHERE reg_1 = '$plate' OR reg_2 = '$plate' OR reg_3 = '$plate' AND deleted_at IS NULL ORDER BY id DESC LIMIT 5";
         $result = $db->query($sql);
         $orders = $db->fetch_all($result);
@@ -593,14 +590,8 @@ class orders_o extends db
     public function get_vehicle_order_history(string $plate): array
     {
         global $db;
-        $stmt = $db->prepare("SELECT * FROM $this->table WHERE (reg_1 = ? OR reg_2 = ? OR reg_3 = ?) AND deleted_at IS NULL ORDER BY id DESC LIMIT 5");
-        if (!$stmt) {
-            return [];
-        }
-        $stmt->bind_param('sss', $plate, $plate, $plate);
-        $stmt->execute();
-        $result = $stmt->get_result();
-        $stmt->close();
+        $sql = "SELECT * FROM $this->table WHERE reg_1 = '$plate' OR reg_2 = '$plate' OR reg_3 = '$plate' AND deleted_at IS NULL ORDER BY id DESC LIMIT 5";
+        $result = $db->query($sql);
         return $db->fetch_all($result);
     }
 
@@ -2164,6 +2155,7 @@ class orders_o extends db
         }
         return $orders;
     }
+
     /**
      * @throws Exception
      */

services/nginx/app/objects/products_o.php

@@ -11,9 +11,6 @@ class products_o extends db
 {
     use db_object_t;
 
-    public const EXTRAORDINARY_CHEMISTRY_PRODUCT_ID = 27;
-    public const EXTRAORDINARY_CHEMISTRY_PRODUCT_NAME = 'Ekstraordinær pr. 10 min inkl. kemi';
-
     /**
      * The name of the product
      * @var object_property
@@ -217,7 +214,7 @@ class products_o extends db
             'piktogram' => $this->piktogram->value(),
             'economic_product_id' => $this->economic_product_id->value(),
             'apply_category_discount' => (bool)$this->apply_category_discount->value(),
-            'requires_note' => $this->requiresOrderItemNote(),
+            'requires_note' => (bool)$this->requires_note->value(),
             'is_wash' => (bool)$this->is_wash->value(),
             'display_in_booking_form' => (bool)$this->display_in_booking_form->value(),
             'order_priority' => (int)$this->order_priority->value(),
@@ -227,28 +224,6 @@ class products_o extends db
         ];
     }
 
-    public static function productDataRequiresOrderItemNote(array $product): bool
-    {
-        if ((bool)($product['requires_note'] ?? false)) {
-            return true;
-        }
-
-        if ((int)($product['id'] ?? 0) === self::EXTRAORDINARY_CHEMISTRY_PRODUCT_ID) {
-            return true;
-        }
-
-        return trim((string)($product['name'] ?? '')) === self::EXTRAORDINARY_CHEMISTRY_PRODUCT_NAME;
-    }
-
-    public function requiresOrderItemNote(): bool
-    {
-        return self::productDataRequiresOrderItemNote([
-            'id' => $this->id,
-            'name' => (string)$this->name->value(),
-            'requires_note' => (bool)$this->requires_note->value(),
-        ]);
-    }
-
     /**
      * Apply department pricing to a list of products
      * @param array $products

services/nginx/app/objects/selfserve_wash_sessions_o.php

@@ -158,18 +158,6 @@ class selfserve_wash_sessions_o extends db
     }
 
     public function markCompleted(?int $orderId = null): void
-    {
-        if (!$this->closeIfOpen(selfserve_wash_session_status::COMPLETED, $orderId)) {
-            return;
-        }
-    }
-
-    public function markCompletedIfOpen(?int $orderId = null): bool
-    {
-        return $this->closeIfOpen(selfserve_wash_session_status::COMPLETED, $orderId);
-    }
-
-    private function markCompletedInMemory(?int $orderId = null): void
     {
         $this->completed_at->set(date('Y-m-d H:i:s'));
         if ($orderId !== null) {
@@ -179,18 +167,6 @@ class selfserve_wash_sessions_o extends db
     }
 
     public function markForceStopped(?int $orderId = null, ?array $metadata = null): void
-    {
-        if (!$this->closeIfOpen(selfserve_wash_session_status::FORCE_STOPPED, $orderId, $metadata)) {
-            return;
-        }
-    }
-
-    public function markForceStoppedIfOpen(?int $orderId = null, ?array $metadata = null): bool
-    {
-        return $this->closeIfOpen(selfserve_wash_session_status::FORCE_STOPPED, $orderId, $metadata);
-    }
-
-    private function markForceStoppedInMemory(?int $orderId = null, ?array $metadata = null): void
     {
         $this->completed_at->set(date('Y-m-d H:i:s'));
         if ($orderId !== null) {
@@ -205,53 +181,6 @@ class selfserve_wash_sessions_o extends db
         $this->status->set(selfserve_wash_session_status::FORCE_STOPPED->value);
     }
 
-    private function closeIfOpen(selfserve_wash_session_status $status, ?int $orderId = null, ?array $metadata = null): bool
-    {
-        if (!$this->isPersistedSession()) {
-            if ($status === selfserve_wash_session_status::COMPLETED) {
-                $this->markCompletedInMemory($orderId);
-            } else {
-                $this->markForceStoppedInMemory($orderId, $metadata);
-            }
-            return true;
-        }
-
-        global $db;
-
-        $updates = [
-            "`completed_at` = NOW()",
-            "`status` = '" . $db->escape_string($status->value) . "'",
-        ];
-
-        if ($orderId !== null) {
-            $updates[] = "`order_id` = " . (int)$orderId;
-        }
-
-        if ($metadata !== null) {
-            $existing = $this->metadata_json->value();
-            $existing = is_array($existing) ? $existing : [];
-            $existing['force_stop'] = $metadata;
-            $updates[] = "`metadata_json` = '" . $db->escape_string(json_encode($existing, JSON_THROW_ON_ERROR)) . "'";
-        }
-
-        $terminalStatuses = self::terminalStatusSqlList();
-        $db->query(
-            "UPDATE `selfserve_wash_sessions` SET " . implode(', ', $updates) .
-            " WHERE `id` = " . (int)$this->id .
-            " AND `completed_at` IS NULL" .
-            " AND UPPER(TRIM(`status`)) NOT IN ($terminalStatuses)"
-        );
-
-        $changed = $db->conn()->affected_rows > 0;
-        $this->select((int)$this->id);
-        return $changed;
-    }
-
-    private function isPersistedSession(): bool
-    {
-        return isset($this->id) && (int)$this->id > 0 && $this->exists();
-    }
-
     public function selectLatestOpenByLane(int $laneId, ?int $customerNumber = null): self
     {
         $filters = [

services/nginx/app/objects/subuser_grants_o.php

@@ -22,57 +22,28 @@ class subuser_grants_o extends db
     public object_property $updated_at;
     public object_property $deleted_at;
     const defaultPermissions = [
-        'VEHICLES_LIST',
-        'SELFSERVE_ADD',
-        'BOOKINGS_LIST',
-        'BOOKINGS_ADD',
-        'BOOKINGS_EDIT',
-        'BOOKINGS_DELETE',
+        subusers_permission_node_key::VEHICLES_LIST,
+        subusers_permission_node_key::SELFSERVE_ADD,
+        subusers_permission_node_key::BOOKINGS_LIST,
+        subusers_permission_node_key::BOOKINGS_ADD,
+        subusers_permission_node_key::BOOKINGS_EDIT,
+        subusers_permission_node_key::BOOKINGS_DELETE,
     ];
 
-    public static function normalizePermissionsValue(mixed $raw): array
+    private static function normalizePermissionsValue(mixed $raw): array
     {
-        if ($raw === null || $raw === '' || $raw === false || $raw === 0 || $raw === '0') {
+        if ($raw === null || $raw === '') {
             return [];
         }
 
-        if ($raw instanceof subusers_permission_node_key) {
-            return [$raw->name];
-        }
-
         if (is_array($raw)) {
-            $permissions = [];
-            $permissionCandidates = array_is_list($raw)
-                ? $raw
-                : array_keys(array_filter($raw, static fn ($enabled): bool => (bool)$enabled));
-
-            foreach ($permissionCandidates as $permission) {
-                if ($permission instanceof subusers_permission_node_key) {
-                    $permission = $permission->name;
-                }
-
-                if (!is_string($permission)) {
-                    continue;
-                }
-
-                $permission = strtoupper(trim($permission));
-                if ($permission !== '' && subusers_permission_node_key::tryFrom($permission) !== null) {
-                    $permissions[] = $permission;
-                }
-            }
-
-            return array_values(array_unique($permissions));
+            return array_values(array_filter($raw, static fn ($permission) => is_string($permission) && trim($permission) !== ''));
         }
 
         if (is_string($raw)) {
             $decoded = json_decode($raw, true);
-            if (json_last_error() === JSON_ERROR_NONE) {
-                return self::normalizePermissionsValue($decoded);
-            }
-
-            $permission = strtoupper(trim($raw));
-            if (subusers_permission_node_key::tryFrom($permission) !== null) {
-                return [$permission];
+            if (is_array($decoded)) {
+                return array_values(array_filter($decoded, static fn ($permission) => is_string($permission) && trim($permission) !== ''));
             }
         }
 
@@ -132,13 +103,12 @@ class subuser_grants_o extends db
     public function add(int $billing_customer_number, int $subuser, bool $enabled, ?string $note, ?array $permissions = self::defaultPermissions): subuser_grants_o
     {
         global $db;
-        $permissions = self::normalizePermissionsValue($permissions);
         $tmp = $this->add_object([
             'billing_customer_number' => (int)$billing_customer_number,
             'subuser' => (int)$subuser,
             'enabled' => (bool)$enabled,
             'note' => !empty($note) ? $db->escape_string($note) : null,
-            'permissions' => json_encode($permissions, JSON_UNESCAPED_UNICODE | JSON_UNESCAPED_SLASHES),
+            'permissions' => !empty($permissions) ? json_encode($permissions) : json_encode([]),
         ]);
         $this->id = (int)$tmp;
         $this->getObjectProperties();

services/nginx/app/objects/subusers_o.php

@@ -15,11 +15,6 @@ class subusers_o extends db
 {
     use db_object_t;
 
-    public const PASSWORD_MIN_LENGTH = 8;
-    public const PASSWORD_MAX_LENGTH = 255;
-    public const PASSWORD_PATTERN = '/^(?=.*[a-z])(?=.*[A-Z])(?=.*\d).+$/';
-    public const PASSWORD_COMPLEXITY_MESSAGE = 'Password must contain at least one uppercase letter, one lowercase letter, and one number';
-
     public object_property $username;
     public object_property $password;
     public object_property $name;
@@ -67,23 +62,6 @@ class subusers_o extends db
         return (bool)$this->two_factor_enabled->value();
     }
 
-    /**
-     * @throws Exception
-     */
-    public static function assertValidPassword(string $password): void
-    {
-        if (
-            strlen($password) < self::PASSWORD_MIN_LENGTH
-            || strlen($password) > self::PASSWORD_MAX_LENGTH
-            || !preg_match(self::PASSWORD_PATTERN, $password)
-        ) {
-            throw new Exception(
-                'Password must be between ' . self::PASSWORD_MIN_LENGTH . ' and ' . self::PASSWORD_MAX_LENGTH
-                . ' characters long and contain at least one uppercase letter, one lowercase letter, and one number.'
-            );
-        }
-    }
-
     /**
      * @throws Exception
      */
@@ -125,9 +103,11 @@ class subusers_o extends db
     {
         global $db, $response;
         try {
-            $passwordWasProvided = !empty($password);
-            if ($passwordWasProvided) {
-                self::assertValidPassword($password);
+            if (!empty($password)) {
+                // Validate the password (at least 8 characters, at least one uppercase letter, at least one lowercase letter, at least one number)
+                if (!preg_match('/^(?=.*[a-z])(?=.*[A-Z])(?=.*\d).{8,}$/', $password)) {
+                    throw new Exception('Password must be at least 8 characters long and contain at least one uppercase letter, one lowercase letter, and one number.');
+                }
                 // Hash the password
                 $password = password_hash($password, PASSWORD_DEFAULT);
             }
@@ -183,7 +163,6 @@ class subusers_o extends db
     public function setPassword(string $password): self
     {
         self::requireSelected();
-        self::assertValidPassword($password);
         $this->password->set((string)password_hash($password, PASSWORD_DEFAULT));
         return $this;
     }
@@ -320,6 +299,9 @@ class subusers_o extends db
         $session_token = bin2hex(random_bytes(32));
         $this->cache('session_token:' . $session_token, $this->id, 'subuser_sessions');
         $this->setCachedExpiration('session_token:' . $session_token, 7 * 24 * 60 * 60, 'subuser_sessions'); // Set the session to expire after 7 days
+        // Add the token
+        $tokens_o = new tokens_o();
+        $tokens_o->create($this->id, $session_token, 'AUTH_TOKEN_SUBUSER');
         return $session_token;
     }
 
@@ -343,6 +325,22 @@ class subusers_o extends db
             $subuser->getObjectProperties();
             return $subuser;
         }
+        // Fallback: resolve via tokens table if cache is missing/expired
+        try {
+            // tokens_o::getToken() might throw Exception if not found
+            $tok = (new tokens_o())->getToken($token);
+            if ($tok && $tok->id && $tok->type->value() === 'AUTH_TOKEN_SUBUSER') {
+                $resolvedId = (int)$tok->user_id->value();
+                // Re-cache mapping for future lookups (7 days to match session lifetime)
+                $this->cache($cache_key, $resolvedId, $cache_object_id);
+                $this->setCachedExpiration($cache_key, 7 * 24 * 60 * 60, $cache_object_id);
+                $subuser = (new subusers_o())->select($resolvedId);
+                $subuser->getObjectProperties();
+                return $subuser;
+            }
+        } catch (Exception $e) {
+            // Token not found or other error; treat as missing
+        }
         return null;
     }
 

services/nginx/app/objects/users_o.php

@@ -18,8 +18,6 @@ class users_o extends db
 {
     use db_object_t;
 
-    public const KEY_SUPERUSER_NEW_CUSTOMER_EMAIL_NOTIFICATIONS = 'superuser_new_customer_email_notifications_enabled';
-
     public object_property $customer_number;
     public object_property $display_name;
     public object_property $group_id;
@@ -127,47 +125,40 @@ class users_o extends db
 
     private function importCustomerFromExternalSource(int $customer_number): object|bool
     {
+        global $db;
         // Get the customer data from the external source
         $economic = new economicCustomers();
         $customer_data = $economic->getCustomerId($customer_number);
+        // DEBUG: Return the customer data
+        // Check if the customer exists
         if ($customer_data) {
-            return $this->importCustomerFromEconomicCustomerData($customer_data);
+            // Avoid SQL injection
+            $customer_number = $db->escape_string($customer_data->customerNumber);
+            // Double check if the customer exists
+            $sql = "SELECT * FROM $this->table WHERE customer_number = '$customer_number'";
+            $result = $db->query($sql);
+            if ($result->num_rows > 0) {
+                $this->id = $result->fetch_assoc()['id'];
+                $this->getObjectProperties();
+            } else {
+                // Import the customer
+                $this->add($customer_number, '', 0);
+                // Nullify the password
+                $this->password->nullify();
+                // If the customer has an email address, save it
+                if (isset($customer_data->email)) {
+                    $this->email->set($customer_data->email);
+                }
+                // If the customer has a name, save it as the display name
+                if (isset($customer_data->name)) {
+                    $this->display_name->set($customer_data->name);
+                }
+            }
         }
-
+        // Else return false
         return false;
     }
 
-    public function importCustomerFromEconomicCustomerData(object $customer_data): users_o|bool
-    {
-        global $db;
-
-        if (!isset($customer_data->customerNumber) || !is_numeric($customer_data->customerNumber)) {
-            return false;
-        }
-
-        $customer_number = $db->escape_string((string)$customer_data->customerNumber);
-        $sql = "SELECT * FROM $this->table WHERE customer_number = '$customer_number'";
-        $result = $db->query($sql);
-        if ($result->num_rows > 0) {
-            $this->id = (int)$result->fetch_assoc()['id'];
-            $this->getObjectProperties();
-            return $this;
-        }
-
-        $this->add($customer_number, '', 0);
-        $this->password->nullify();
-
-        if (isset($customer_data->email)) {
-            $this->email->set($customer_data->email);
-        }
-
-        if (isset($customer_data->name)) {
-            $this->display_name->set($customer_data->name);
-        }
-
-        return $this;
-    }
-
     /**
      * @throws Exception
      */
@@ -265,7 +256,7 @@ class users_o extends db
      * @param int|null $user_id The user id to add the attribute to
      * @throws Exception If the user is not selected, and the user_id is null
      */
-    public function addAttribute(string $attribute, ?int $user_id = null): void
+    public function addAttribute(string $attribute, int $user_id = null): void
     {
         global $db;
         if ($user_id === null) {
@@ -279,7 +270,7 @@ class users_o extends db
         $db->query($sql);
     }
 
-    public function deleteAttribute(string $attribute, ?int $user_id = null): void
+    public function deleteAttribute(string $attribute, int $user_id = null): void
     {
         global $db;
         if ($user_id === null) {
@@ -311,7 +302,7 @@ class users_o extends db
         $db->query($sql);
     }
 
-    public function doesUserHaveAttribute(string $attribute, ?int $user_id = null): bool
+    public function doesUserHaveAttribute(string $attribute, int $user_id = null): bool
     {
         global $db;
         if ($user_id === null) {
@@ -445,7 +436,6 @@ class users_o extends db
                 'sms_notifications_enabled' => (bool)$this->sms_notifications_enabled->value(),
                 'email_notifications_enabled' => (bool)$this->email_notifications_enabled->value(),
                 'wash_certificate_email' => $this->wash_certificate_email->value(),
-                self::KEY_SUPERUSER_NEW_CUSTOMER_EMAIL_NOTIFICATIONS => $this->isSuperuserNewCustomerEmailNotificationsEnabled(),
             ],
             'created_at' => $this->created_at->value(),
             'updated_at' => $this->updated_at->value(),
@@ -525,12 +515,8 @@ class users_o extends db
         return customer_name_cache_payload_builder::build($cached_name, $fallback_name);
     }
 
-    public function getCustomerEcocomicData(?int $customer_number = null): users_o
+    public function getCustomerEcocomicData(int $customer_number = null): users_o
     {
-        if ($customer_number !== null && !isset($this->id)) {
-            $this->getUserByCustomerNumber($customer_number);
-        }
-
         // Check if the customer number is set
         if (!isset($this->customer_number) && $customer_number === null) {
             return $this;
@@ -542,9 +528,7 @@ class users_o extends db
             return $this;
         }
 
-        $cachedCustomer = isset($this->id) && $this->id > 0
-            ? $this->getCached('economic_customer')
-            : null;
+        $cachedCustomer = $this->getCached('economic_customer');
         if (is_object($cachedCustomer)) {
             $cachedCustomerNumber = (int)($cachedCustomer->customerNumber ?? $cachedCustomer->customer_number ?? 0);
             if ($cachedCustomerNumber === $customer_number) {
@@ -730,7 +714,7 @@ class users_o extends db
         $this->permissions = $perms;
     }
 
-    public function getUserAttributes(?int $user_id = null): array
+    public function getUserAttributes(int $user_id = null): array
     {
         global $db;
         if ($user_id === null) {
@@ -847,53 +831,6 @@ class users_o extends db
         return false;
     }
 
-    public function isSuperuserNewCustomerEmailNotificationsEnabled(): bool
-    {
-        self::requireSelected();
-        $value = $this->keys->setUser($this->id)->getValue(self::KEY_SUPERUSER_NEW_CUSTOMER_EMAIL_NOTIFICATIONS);
-        return in_array(strtolower((string)$value), ['1', 'true', 'yes', 'on'], true);
-    }
-
-    public function setSuperuserNewCustomerEmailNotificationsEnabled(bool $enabled): void
-    {
-        self::requireSelected();
-        $this->keys->setUser($this->id)->setValue(
-            self::KEY_SUPERUSER_NEW_CUSTOMER_EMAIL_NOTIFICATIONS,
-            $enabled ? '1' : '0'
-        );
-    }
-
-    /**
-     * @return array<int, array{id:int, customer_number:int, display_name:string|null, email:string}>
-     */
-    public function getSuperuserNewCustomerEmailNotificationRecipients(): array
-    {
-        global $db;
-
-        $key = $db->escape_string(self::KEY_SUPERUSER_NEW_CUSTOMER_EMAIL_NOTIFICATIONS);
-        $sql = "
-            SELECT DISTINCT
-                u.id,
-                u.customer_number,
-                u.display_name,
-                u.email
-            FROM users u
-            INNER JOIN user_key_value_pairs kv
-                ON kv.user_id = u.id
-                AND kv.var = '$key'
-                AND LOWER(kv.val) IN ('1', 'true', 'yes', 'on')
-            LEFT JOIN groups_permissions gp
-                ON gp.group_id = u.group_id
-                AND gp.permission = 'superuser'
-            WHERE u.deleted_at IS NULL
-                AND u.email IS NOT NULL
-                AND u.email <> ''
-                AND (u.group_id = 1 OR gp.id IS NOT NULL)
-        ";
-
-        return $db->fetch_all($db->query($sql));
-    }
-
     public function setOpenInvoiceDraft(int $draftInvoiceNumber): void
     {
         // Set the open invoice draft (key = 'open_invoice_draft')
@@ -1119,7 +1056,7 @@ class users_o extends db
      * Set the password for the user
      * @throws Exception If the user is not selected
      */
-    public function setPassword(?string $password = null): void
+    public function setPassword(string $password = null): void
     {
         self::requireSelected();
         global $db;

services/nginx/app/openapi.yaml

@@ -3043,7 +3043,6 @@ paths:
                 wash_certificate_email: {type: string}
                 sms_notifications_enabled: {type: boolean}
                 email_notifications_enabled: {type: boolean}
-                superuser_new_customer_email_notifications_enabled: {type: boolean}
       responses:
         '200':
           description: Success
@@ -5461,7 +5460,7 @@ paths:
       tags:
         - Self-Serve
       summary: Bulk save all-in-one self-serve studio graph changes
-      description: Creates, updates, deletes, connects, disconnects, reorders, and upserts self-serve answer paths by editing the schema_version 2 draft config JSON. Condition connections create expression predicates; Path Editor upserts create normal generated condition and task nodes; layout remains separate from runtime behavior.
+      description: Creates, updates, deletes, connects, disconnects, and reorders questions, conditions, and tasks by editing the schema_version 2 draft config JSON. Condition connections create expression predicates; layout remains separate from runtime behavior.
       operationId: saveSelfserveStudioGraph
       requestBody:
         required: true
@@ -5618,29 +5617,6 @@ paths:
         '422':
           $ref: '#/components/responses/BadRequest'
 
-  /department/selfserve/studio/path-confirmations:
-    post:
-      tags:
-        - Self-Serve
-      summary: Confirm or reset a projected self-serve studio path
-      description: Stores confirmation for a projected terminal path using its stable path and result signatures. Projections report confirmed, unconfirmed, or stale when the resulting tasks, buttons, services, or signals change.
-      operationId: confirmSelfserveStudioPath
-      requestBody:
-        required: true
-        content:
-          application/json:
-            schema:
-              $ref: '#/components/schemas/SelfserveStudioPathConfirmationRequest'
-      responses:
-        '200':
-          description: Path confirmation updated
-          content:
-            application/json:
-              schema:
-                $ref: '#/components/schemas/SelfserveStudioPathConfirmation'
-        '422':
-          $ref: '#/components/responses/BadRequest'
-
   /department/selfserve/studio/publish:
     post:
       tags:
@@ -6240,59 +6216,6 @@ paths:
             '200':
               description: Success
 
-  /order-bookings/booking-confirmation/resend:
-    post:
-      tags:
-        - Bookings
-      summary: Resend order booking confirmation
-      description: Resends the customer booking confirmation email for an order booking. Requires `resend_booking_confirmations` and access to the booking's department.
-      operationId: resendOrderBookingConfirmation
-      requestBody:
-        required: true
-        content:
-          application/json:
-            schema:
-              type: object
-              required: [id]
-              properties:
-                id: {type: integer}
-      responses:
-        '200':
-          description: Booking confirmation resent successfully
-          content:
-            application/json:
-              schema: {}
-        '400': { $ref: '#/components/responses/BadRequest' }
-        '401': { $ref: '#/components/responses/Unauthorized' }
-        '403': { $ref: '#/components/responses/Forbidden' }
-
-  /order-bookings/completion-confirmation/resend:
-    post:
-      tags:
-        - Bookings
-      summary: Resend order booking completion confirmation
-      description: Resends the customer completion confirmation email with the wash certificate for a completed order booking. Requires `complete_bookings` and access to the booking's department.
-      operationId: resendOrderBookingCompletionConfirmation
-      requestBody:
-        required: true
-        content:
-          application/json:
-            schema:
-              type: object
-              required: [id]
-              properties:
-                id: {type: integer}
-      responses:
-        '200':
-          description: Completion confirmation resent successfully
-          content:
-            application/json:
-              schema: {}
-        '400': { $ref: '#/components/responses/BadRequest' }
-        '401': { $ref: '#/components/responses/Unauthorized' }
-        '403': { $ref: '#/components/responses/Forbidden' }
-        '409': { $ref: '#/components/responses/Conflict' }
-
   /order-bookings/complete:
     post:
       tags:
@@ -8124,15 +8047,7 @@ paths:
           description: Worker status retrieved successfully
           content:
             application/json:
-              schema:
-                type: object
-                properties:
-                  data:
-                    type: object
-                    properties:
-                      api_commit_sha:
-                        type: string
-                        description: Running API commit SHA, or unknown when unavailable.
+              schema: {}
 
   /worker/debug:
     get:
@@ -9262,47 +9177,6 @@ paths:
         '403':
           $ref: '#/components/responses/Forbidden'
 
-  /modules/self-serve/lane/wash/my-active-wash:
-    get:
-      tags:
-        - Modules
-      summary: Get the authenticated customer's active self-serve wash
-      description: |
-        Returns the latest active self-serve wash for the authenticated customer,
-        without requiring the frontend to know or poll a lane id.
-      operationId: getMyActiveSelfServeWash
-      responses:
-        '200':
-          description: Active self-serve wash details resolved
-          content:
-            application/json:
-              schema:
-                type: object
-                properties:
-                  lane_id:
-                    type: integer
-                  status:
-                    type: string
-                  in_progress:
-                    type: boolean
-                  elapsed_minutes:
-                    type: integer
-                  session:
-                    type: object
-                    nullable: true
-                  customer:
-                    type: object
-                    nullable: true
-                  vehicle:
-                    type: object
-                    nullable: true
-        '401':
-          $ref: '#/components/responses/Unauthorized'
-        '403':
-          $ref: '#/components/responses/Forbidden'
-        '404':
-          $ref: '#/components/responses/NotFound'
-
   /modules/self-serve/sessions:
     get:
       tags:
@@ -9425,10 +9299,10 @@ paths:
       description: |
         Send a command (e.g., start, stop, reset) to a self-serve lane.
         Property gate commands (`OPEN_PROPERTY_ACCESS_GATE`, `OPEN_PROPERTY_EXIT_GATE`) are also supported here.
-        Property gate commands require the matching explicit command permissions.
         Operator callers require the base command permission plus the command-specific permission. Authenticated
         customers with `list_own_department_selfserve_vehicle_conditions` may send `START` on enabled self-serve
-        lanes. Customer `STOP` requires the customer's active self-serve wash in the target department.
+        lanes. Customer `STOP` and property gate commands require the customer's active self-serve wash in the target
+        department.
       operationId: sendSelfServeLaneCommand
       requestBody:
         required: true
@@ -9448,14 +9322,6 @@ paths:
                 license_plate:
                   type: string
                   description: Required for START command
-                wash_type:
-                  type: string
-                  enum: [Manual, Machine]
-                  description: Optional customer-selected wash type for START. When provided, Manual and Machine start actions use this explicit choice instead of inferring mode from allowed services.
-                wash_mode:
-                  type: string
-                  enum: [manual, machine]
-                  description: Lowercase alias for wash_type accepted by backend clients.
                 customer_number:
                   type: integer
                   description: Required for START and RESERVE commands. The authenticated customer's number is applied server-side when omitted by user clients.
@@ -11636,52 +11502,6 @@ paths:
               schema:
                 $ref: '#/components/schemas/ModuleConfigTestResponse'
 
-  /slack/config:
-    get:
-      tags: [Config]
-      summary: Get Slack config
-      operationId: getSlackConfig
-      responses:
-        '200':
-          description: Slack configuration retrieved successfully
-          content:
-            application/json:
-              schema:
-                $ref: '#/components/schemas/SlackConfigListResponse'
-    post:
-      tags: [Config]
-      summary: Update Slack config
-      operationId: updateSlackConfig
-      requestBody:
-        required: false
-        content:
-          application/json:
-            schema: {}
-      responses:
-        '200':
-          description: Slack configuration updated successfully
-          content:
-            application/json:
-              schema:
-                $ref: '#/components/schemas/ModuleConfigUpdateResponse'
-
-  /slack/config/test:
-    post:
-      tags: [Config]
-      summary: Test Slack customer registration webhook
-      operationId: testSlackCustomerRegistrationWebhook
-      responses:
-        '200':
-          description: Slack customer registration webhook test completed successfully
-          content:
-            application/json:
-              schema:
-                $ref: '#/components/schemas/SlackConfigTestResponse'
-        '400':
-          description: Slack customer registration webhook URL is not configured
-        '502':
-          description: Slack customer registration webhook test failed
-
   /backups/config:
     get:
       tags: [Config]
@@ -15196,25 +15016,6 @@ components:
             - type: integer
       required: [module, variable, type, value]
 
-    SlackConfigEntry:
-      type: object
-      properties:
-        module: { type: string, enum: [Slack] }
-        variable: { type: string, enum: [customer_registration_webhook_url] }
-        type: { type: string, enum: [string] }
-        value:
-          type: string
-          example: https://hooks.slack.com/services/...
-      required: [module, variable, type, value]
-
-    SlackConfigTestResult:
-      type: object
-      properties:
-        configured: { type: boolean }
-        sent: { type: boolean }
-        message: { type: string }
-      required: [configured, sent, message]
-
     BackupsConfigEntry:
       type: object
       properties:
@@ -15483,22 +15284,6 @@ components:
             data: { type: array, items: { $ref: '#/components/schemas/EmailConfigEntry' } }
           required: [data]
 
-    SlackConfigListResponse:
-      allOf:
-        - $ref: '#/components/schemas/ModuleConfigEnvelopeBase'
-        - type: object
-          properties:
-            data: { type: array, items: { $ref: '#/components/schemas/SlackConfigEntry' } }
-          required: [data]
-
-    SlackConfigTestResponse:
-      allOf:
-        - $ref: '#/components/schemas/ModuleConfigEnvelopeBase'
-        - type: object
-          properties:
-            data: { $ref: '#/components/schemas/SlackConfigTestResult' }
-          required: [data]
-
     BackupsConfigListResponse:
       allOf:
         - $ref: '#/components/schemas/ModuleConfigEnvelopeBase'
@@ -18105,10 +17890,10 @@ components:
       properties:
         action:
           type: string
-          enum: [create, update, delete, connect, disconnect, reorder, upsert, upsert_path]
+          enum: [create, update, delete, connect, disconnect, reorder]
         entity:
           type: string
-          enum: [question, condition, task, action, path]
+          enum: [question, condition, task]
           description: Standalone rule operations are not accepted for schema_version 2 drafts.
         id:
           type: integer
@@ -18467,17 +18252,13 @@ components:
         max_states:
           type: integer
           minimum: 1
-          maximum: 2048
-          default: 2048
           nullable: true
-          description: Optional debug cap for explored states. Omitted and larger values are capped at 2048.
+          description: Optional debug cap. Omit for complete path projection.
         path_sample_limit:
           type: integer
           minimum: 1
-          maximum: 2048
-          default: 2048
           nullable: true
-          description: Optional cap for returned path rows. Omitted returns every projected terminal path within the state cap; larger values are capped at 2048.
+          description: Optional debug cap for returned path rows. Omit to return every terminal path row.
 
     SelfserveStudioPathOutcomesResponse:
       type: object
@@ -18499,8 +18280,6 @@ components:
               items: { type: integer }
             max_states: { type: integer }
             path_sample_count: { type: integer }
-            confirmations:
-              $ref: '#/components/schemas/SelfserveStudioPathConfirmationSummary'
         outcomes:
           type: array
           items:
@@ -18516,15 +18295,6 @@ components:
           type: boolean
         progress:
           $ref: '#/components/schemas/SelfserveStudioPathProgress'
-        confirmations:
-          type: object
-          properties:
-            summary:
-              $ref: '#/components/schemas/SelfserveStudioPathConfirmationSummary'
-            removed:
-              type: array
-              items:
-                $ref: '#/components/schemas/SelfserveStudioPathConfirmation'
 
     SelfserveStudioPathProgress:
       type: object
@@ -18610,95 +18380,6 @@ components:
         node_ids:
           type: array
           items: { type: string }
-        path_signature: { type: string }
-        result_signature: { type: string }
-        confirmation_status:
-          type: string
-          enum: [unconfirmed, confirmed, stale]
-        confirmed_at:
-          type: string
-          nullable: true
-        confirmed_by:
-          type: integer
-          nullable: true
-        stale_reason:
-          type: string
-          nullable: true
-
-    SelfserveStudioPathConfirmationSummary:
-      type: object
-      properties:
-        confirmed: { type: integer }
-        unconfirmed: { type: integer }
-        stale: { type: integer }
-        removed: { type: integer }
-        total: { type: integer }
-
-    SelfserveStudioPathConfirmationRequest:
-      type: object
-      required: [department, path_signature]
-      properties:
-        department: { type: integer }
-        action:
-          type: string
-          enum: [confirm, reset, delete, clear]
-          default: confirm
-        path_signature: { type: string }
-        result_signature:
-          type: string
-          description: Required when action is confirm.
-        scope:
-          type: object
-          additionalProperties: true
-        answers:
-          type: array
-          items:
-            $ref: '#/components/schemas/SelfserveStudioPathAnswer'
-        result:
-          type: object
-          additionalProperties: true
-
-    SelfserveStudioPathConfirmation:
-      type: object
-      properties:
-        id:
-          type: integer
-          nullable: true
-        department_id: { type: integer }
-        lane_id:
-          type: integer
-          nullable: true
-        vehicle_type_id:
-          type: integer
-          nullable: true
-        config_version_id:
-          type: integer
-          nullable: true
-        config_source: { type: string }
-        path_signature: { type: string }
-        result_signature: { type: string }
-        confirmation_status:
-          type: string
-          enum: [unconfirmed, confirmed, stale]
-        answers:
-          type: array
-          items:
-            $ref: '#/components/schemas/SelfserveStudioPathAnswer'
-        result:
-          type: object
-          additionalProperties: true
-        scope:
-          type: object
-          additionalProperties: true
-        confirmed_at:
-          type: string
-          nullable: true
-        confirmed_by:
-          type: integer
-          nullable: true
-        stale_reason:
-          type: string
-          nullable: true
 
     SelfserveStudioPathTask:
       type: object
@@ -21510,3 +21191,5 @@ components:
         success: { type: boolean, example: true }
         data:
           $ref: '#/components/schemas/DepartmentDailyReportOutsideHoursTrendPayload'
+
+