// k6 basic load test - smoke then load
import http from 'k6/http';
import { sleep, check } from 'k6';

export const options = {
  stages: [
    { duration: '30s', target: 10 },  // ramp up
    { duration: '1m',  target: 10 },  // hold
    { duration: '15s', target: 0 },   // ramp down
  ],
  thresholds: {
    http_req_duration: ['p(95)<300'],   // 95% of requests under 300ms
    http_req_failed:   ['rate<0.01'],   // less than 1% errors
  },
};

export default function () {
  const res = http.get('https://api.example.com/health');

  check(res, {
    'status is 200':       (r) => r.status === 200,
    'response time < 500ms': (r) => r.timings.duration < 500,
  });

  sleep(1);
}

// k6 staged ramp - warm up, load, stress, cool down
import http from 'k6/http';
import { sleep, check } from 'k6';

export const options = {
  stages: [
    { duration: '2m',  target: 20  },  // warm up to expected load
    { duration: '5m',  target: 20  },  // hold at expected load
    { duration: '2m',  target: 100 },  // ramp to stress level
    { duration: '5m',  target: 100 },  // hold under stress
    { duration: '2m',  target: 200 },  // push further
    { duration: '3m',  target: 200 },  // hold to find saturation point
    { duration: '2m',  target: 0   },  // ramp down
  ],
  thresholds: {
    http_req_duration: ['p(99)<1000'],
    http_req_failed:   ['rate<0.05'],
  },
};

export default function () {
  http.get('https://api.example.com/products');
  sleep(Math.random() * 2 + 1);  // think time: 1-3s
}

// k6 with structured checks and per-endpoint thresholds
import http from 'k6/http';
import { check, group, sleep } from 'k6';

export const options = {
  vus: 50,
  duration: '5m',
  thresholds: {
    'http_req_duration{endpoint:list}':   ['p(95)<200'],
    'http_req_duration{endpoint:detail}': ['p(95)<400'],
    'http_req_failed':                    ['rate<0.01'],
    'checks':                             ['rate>0.99'],
  },
};

const BASE_URL = 'https://api.example.com';

export default function () {
  group('list products', () => {
    const res = http.get(`${BASE_URL}/products`, {
      tags: { endpoint: 'list' },
    });
    check(res, {
      'list: status 200':    (r) => r.status === 200,
      'list: has items':     (r) => JSON.parse(r.body).items.length > 0,
    });
  });

  sleep(1);

  group('product detail', () => {
    const res = http.get(`${BASE_URL}/products/42`, {
      tags: { endpoint: 'detail' },
    });
    check(res, {
      'detail: status 200': (r) => r.status === 200,
      'detail: has price':  (r) => JSON.parse(r.body).price !== undefined,
    });
  });

  sleep(Math.random() * 2 + 1);
}

// k6 multi-step user journey with shared data
import http from 'k6/http';
import { check, sleep } from 'k6';
import { SharedArray } from 'k6/data';

// Load test data once, shared across VUs
const users = new SharedArray('users', () =>
  JSON.parse(open('./data/users.json'))
);

export const options = {
  stages: [
    { duration: '1m', target: 30 },
    { duration: '3m', target: 30 },
    { duration: '1m', target: 0  },
  ],
  thresholds: {
    http_req_duration: ['p(95)<500'],
    http_req_failed:   ['rate<0.01'],
  },
};

export default function () {
  const user = users[Math.floor(Math.random() * users.length)];

  // Step 1: Login
  const loginRes = http.post('https://api.example.com/auth/login', JSON.stringify({
    email:    user.email,
    password: user.password,
  }), { headers: { 'Content-Type': 'application/json' } });

  check(loginRes, { 'login: status 200': (r) => r.status === 200 });
  const token = JSON.parse(loginRes.body).token;
  const authHeaders = { headers: { Authorization: `Bearer ${token}` } };

  sleep(1);

  // Step 2: Browse catalog
  const listRes = http.get('https://api.example.com/products', authHeaders);
  check(listRes, { 'browse: status 200': (r) => r.status === 200 });

  sleep(Math.random() * 3 + 1);  // user reads the list

  // Step 3: Add to cart
  const cartRes = http.post('https://api.example.com/cart', JSON.stringify({
    product_id: 42, quantity: 1,
  }), { ...authHeaders, headers: { ...authHeaders.headers, 'Content-Type': 'application/json' } });

  check(cartRes, { 'cart: status 201': (r) => r.status === 201 });
  sleep(2);
}

// k6 stress test with open arrival rate model
import http from 'k6/http';
import { check, sleep } from 'k6';

export const options = {
  scenarios: {
    stress: {
      executor:          'ramping-arrival-rate',
      startRate:         10,          // 10 req/s at start
      timeUnit:          '1s',
      preAllocatedVUs:   50,
      maxVUs:            500,
      stages: [
        { duration: '2m', target: 50  },   // ramp to 50 req/s
        { duration: '3m', target: 100 },   // ramp to 100 req/s
        { duration: '3m', target: 200 },   // ramp to 200 req/s - find saturation
        { duration: '2m', target: 50  },   // check recovery
      ],
    },
  },
  thresholds: {
    // Test continues even on failure - we want to observe breakdown
    http_req_duration: [{ threshold: 'p(95)<2000', abortOnFail: false }],
    http_req_failed:   [{ threshold: 'rate<0.10',  abortOnFail: false }],
  },
};

export default function () {
  const res = http.get('https://api.example.com/search?q=laptop');
  check(res, { 'status 200': (r) => r.status === 200 });
  sleep(0.5);
}

undefined

  - name: Install k6
    run: |
      sudo gpg -k
      sudo gpg --no-default-keyring \
        --keyring /usr/share/keyrings/k6-archive-keyring.gpg \
        --keyserver hkp://keyserver.ubuntu.com:80 \
        --recv-keys C5AD17C747E3415A3642D57D77C6C491D6AC1D69
      echo "deb [signed-by=/usr/share/keyrings/k6-archive-keyring.gpg] \
        https://dl.k6.io/deb stable main" | sudo tee /etc/apt/sources.list.d/k6.list
      sudo apt-get update && sudo apt-get install k6

  - name: Run smoke test
    env:
      BASE_URL: ${{ secrets.STAGING_URL }}
      K6_CLOUD_TOKEN: ${{ secrets.K6_CLOUD_TOKEN }}
    run: k6 run --env BASE_URL=$BASE_URL tests/smoke.js

  - name: Upload results
    if: always()
    uses: actions/upload-artifact@v4
    with:
      name: k6-results
      path: results.json

Gate PRs on smoke tests (1-5 VUs, 2 min). Run full load tests on merge to main.
Run soak tests nightly. Keep load tests in `tests/load/` and treat them like
production code - review them, version them, maintain them.

scenarios: (100.00%) 1 scenario, 50 max VUs, 6m30s max duration
default: 50 looping VUs for 6m0s (gracefulStop: 30s)

checks.........................: 99.34%  12841 out of 12921
data_received..................: 48 MB   130 kB/s
data_sent......................: 2.4 MB  6.6 kB/s
http_req_blocked...............: avg=1.2ms    p(95)=2.1ms    p(99)=250ms
http_req_duration..............: avg=142ms    p(95)=389ms    p(99)=1204ms
http_req_failed................: 0.52%   67 out of 12921
http_reqs......................: 12921   35.89/s