CI/CD: ship a build on every commit

"%UE_ROOT%\Engine\Build\BatchFiles\RunUAT.bat" ^
  BuildCookRun ^
  -project="%WORKSPACE%\MyProject.uproject" ^
  -platform=Win64 ^
  -clientconfig=Shipping ^
  -cook -build -stage -package -archive ^
  -archivedirectory="%WORKSPACE%\Build" ^
  -pak -nodebuginfo -utf8output

Compress-Archive `
  -Path "$env:WORKSPACE\Build\WindowsNoEditor\*" `
  -DestinationPath "$env:WORKSPACE\$env:COMMIT_SHA.zip" `
  -CompressionLevel Optimal

aws s3 cp "$COMMIT_SHA.zip" "s3://$BUCKET/builds/$COMMIT_SHA.zip" --no-progress

FILE_URL=$(aws s3 presign "s3://$BUCKET/builds/$COMMIT_SHA.zip" --expires-in 3600)

RESPONSE=$(curl -sS -X POST \
  https://api.streampixel.io/pixelStripeApi/projects/upload-file \
  -H "Content-Type: application/json" \
  -d @- <<EOF
{
  "apiKey": "$STREAMPIXEL_API_KEY",
  "userId": "$STREAMPIXEL_USER_ID",
  "projectId": "$STREAMPIXEL_PROJECT_ID",
  "fileUrl": "$FILE_URL",
  "autoRelease": false
}
EOF
)

UPLOAD_ID=$(echo "$RESPONSE" | jq -r '.uploadId')
if [ "$UPLOAD_ID" = "null" ] || [ -z "$UPLOAD_ID" ]; then
  echo "Upload failed: $RESPONSE"
  exit 1
fi

echo "Upload accepted, uploadId=$UPLOAD_ID"

// webhook-listener.js
import express from 'express';
import axios from 'axios';

const app = express();
app.use(express.json({ limit: '1mb' }));

const STREAMPIXEL_API_KEY = process.env.STREAMPIXEL_API_KEY;
const STREAMPIXEL_USER_ID = process.env.STREAMPIXEL_USER_ID;
const STREAMPIXEL_PROJECT_ID = process.env.STREAMPIXEL_PROJECT_ID;
const WEBHOOK_PATH = process.env.WEBHOOK_PATH; // e.g. "/webhooks/streampixel/9f3a...c2"

// Idempotency: don't distribute the same uploadId twice.
const distributed = new Set();

app.post(WEBHOOK_PATH, async (req, res) => {
  // Respond fast — Streampixel times out after 10s and does not retry.
  res.status(200).end();

  const { event, data } = req.body || {};
  if (!event || !data) return;

  // Defense-in-depth: confirm this event is for our project.
  if (data.projectId && data.projectId !== STREAMPIXEL_PROJECT_ID) {
    console.warn('Ignoring event for unknown project:', data.projectId);
    return;
  }

  console.log(`[${event}]`, data.uploadId || '');

  if (event !== 'build.approved') return;
  if (distributed.has(data.uploadId)) return;
  distributed.add(data.uploadId);

  try {
    const resp = await axios.post(
      'https://api.streampixel.io/pixelStripeApi/projects/distribute-file',
      {
        apiKey: STREAMPIXEL_API_KEY,
        userId: STREAMPIXEL_USER_ID,
        projectId: STREAMPIXEL_PROJECT_ID,
        uploadId: data.uploadId,
      },
    );
    console.log('Distribute OK:', resp.data);
  } catch (err) {
    // Common cause: rate limit (1 call / 2 min / user). Back off and retry.
    distributed.delete(data.uploadId);
    console.error('Distribute failed:', err.response?.data || err.message);
  }
});

app.get('/healthz', (_req, res) => res.status(200).send('ok'));

app.listen(8080, () => console.log('listening on :8080'));

STREAMPIXEL_API_KEY=... \
STREAMPIXEL_USER_ID=... \
STREAMPIXEL_PROJECT_ID=... \
WEBHOOK_PATH=/webhooks/streampixel/9f3a4c1ee21b4f2c \
node webhook-listener.js

const distributeQueue = [];
let lastDistributeAt = 0;
const COOLDOWN_MS = 2 * 60 * 1000 + 5_000; // 2 min + 5s safety

setInterval(async () => {
  if (distributeQueue.length === 0) return;
  if (Date.now() - lastDistributeAt < COOLDOWN_MS) return;

  const uploadId = distributeQueue.shift();
  lastDistributeAt = Date.now();

  try {
    await axios.post(
      'https://api.streampixel.io/pixelStripeApi/projects/distribute-file',
      {
        apiKey: STREAMPIXEL_API_KEY,
        userId: STREAMPIXEL_USER_ID,
        projectId: STREAMPIXEL_PROJECT_ID,
        uploadId,
      },
    );
  } catch (err) {
    // Put it back at the front and try again next tick.
    distributeQueue.unshift(uploadId);
    lastDistributeAt = 0;
  }
}, 5_000);