reworking examples

Author: clegginabox

.env

@@ -0,0 +1 @@
+GLOBAL_LOCK_TIMEOUT=2

Taskfile.yaml

@@ -4,7 +4,7 @@ tasks:
     test:
         desc: Runs all tests
         cmds:
-            - docker run --rm -v $(pwd):/app -v /var/run/docker.sock:/var/run/docker.sock airlock php vendor/bin/phpunit --display-phpunit-notices --testdox
+            - docker compose exec php vendor/bin/phpunit --display-phpunit-notices --testdox
 
     phpstan:
         desc: Runs PHPStan

compose.yaml

@@ -12,7 +12,9 @@ services:
     environment:
       REDIS_HOST: redis
       REDIS_PORT: 6379
-      SERVER_ROOT: /app
+      SERVER_ROOT: /app/examples/public
+    env_file:
+      - .env
     tty: true
     depends_on:
       - redis
@@ -29,9 +31,11 @@ services:
     environment:
       REDIS_HOST: redis
       REDIS_PORT: 6379
+    env_file:
+      - .env
     depends_on:
       - redis
-    command: php examples/worker.php
+    command: php examples/bin/console app:worker
 
   redis:
     image: redis:8.4.0
@@ -47,6 +51,8 @@ services:
       - ./e2e:/app/e2e
     environment:
       BASE_URL: http://php
+    env_file:
+      - .env
     depends_on:
       - worker
       - redis

composer.json

@@ -27,6 +27,7 @@
         "ext-memcached": "*",
         "ext-zookeeper": "*",
         "amphp/sync": "^2.3",
+        "clue/framework-x": "^0.17",
         "illuminate/cache": "^12.47",
         "phpstan/phpstan": "^2.1",
         "phpunit/phpunit": "12.5.4",
@@ -41,8 +42,7 @@
         "symfony/lock": "^8.0",
         "symfony/mercure": "^0.7.2",
         "symfony/rate-limiter": "^8.0",
-        "symfony/semaphore": "^8.0",
-        "testcontainers/testcontainers": "^1.0"
+        "symfony/semaphore": "^8.0"
     },
     "suggest": {
         "symfony/lock": "Recommended Lock implementation",

e2e/package-lock.json

@@ -8,6 +8,7 @@
     "test:debug": "playwright test --debug"
   },
   "devDependencies": {
-    "@playwright/test": "^1.50.0"
+    "@playwright/test": "^1.50.0",
+    "@types/node": "^25.0.9"
   }
-}
+}

e2e/package.json

@@ -1,25 +1,24 @@
-import { test, expect } from '@playwright/test';
+import {test, expect} from '@playwright/test';
 
-const EXAMPLE = '01-lock';
 const BASE_URL = process.env.BASE_URL || 'http://localhost';
 
-test.describe.serial('01-lock - Double-Click Protection', () => {
-  test.beforeEach(async ({ request }) => {
+test.describe.serial('01-global-lock - Double-Click Protection', () => {
+  test.beforeEach(async ({request}) => {
     // Clear all Redis keys for this example
-    const response = await request.get(`${BASE_URL}/examples/reset.php?example=${EXAMPLE}`);
+    const response = await request.get(`${BASE_URL}/reset`);
     console.log('Reset response:', await response.json());
   });
 
-  test('should display initial state correctly', async ({ page }) => {
-    await page.goto('/examples/01-lock/');
+  test('should display initial state correctly', async ({page}) => {
+    await page.goto('/global-lock/');
 
     await expect(page.locator('h1')).toHaveText('Airlock: Double-Click Protection');
     await expect(page.locator('#go')).toBeEnabled();
     await expect(page.locator('#status')).toBeEmpty();
   });
 
-  test('should process action and show done state', async ({ page }) => {
-    await page.goto('/examples/01-lock/');
+  test('should process action and show done state', async ({page}) => {
+    await page.goto('/global-lock/');
 
     await page.locator('#go').click();
 
@@ -28,12 +27,12 @@ test.describe.serial('01-lock - Double-Click Protection', () => {
     await expect(page.locator('#status')).toHaveClass(/wait/);
 
     // Wait for completion (5s work + buffer)
-    await expect(page.locator('#status')).toContainText('Done', { timeout: 10000 });
+    await expect(page.locator('#status')).toContainText('Done', {timeout: 4000});
     await expect(page.locator('#status')).toHaveClass(/ok/);
   });
 
-  test('should block double-click with instant rejection', async ({ page }) => {
-    await page.goto('/examples/01-lock/');
+  test('should block double-click with instant rejection', async ({page}) => {
+    await page.goto('/global-lock/');
 
     // First click - starts processing
     await page.locator('#go').click();
@@ -45,7 +44,7 @@ test.describe.serial('01-lock - Double-Click Protection', () => {
     await expect(page.locator('#status')).toHaveClass(/error/);
   });
 
-  test('second user should be blocked when lock is held', async ({ browser }) => {
+  test('second user should be blocked when lock is held', async ({browser}) => {
     // Create two browser contexts (simulating two users)
     const context1 = await browser.newContext();
     const context2 = await browser.newContext();
@@ -54,18 +53,18 @@ test.describe.serial('01-lock - Double-Click Protection', () => {
 
     try {
       // First user starts action
-      await page1.goto('/examples/01-lock/');
+      await page1.goto('/global-lock/');
       await page1.locator('#go').click();
       await expect(page1.locator('#status')).toContainText('Submitting');
 
       // Second user tries to start - should be instantly blocked
-      await page2.goto('/examples/01-lock/');
+      await page2.goto('/global-lock/');
       await page2.locator('#go').click();
       await expect(page2.locator('#status')).toContainText('Already processing');
       await expect(page2.locator('#status')).toHaveClass(/error/);
 
       // Wait for first user to complete
-      await expect(page1.locator('#status')).toContainText('Done', { timeout: 10000 });
+      await expect(page1.locator('#status')).toContainText('Done', {timeout: 5000});
 
       // Second user can now start
       await page2.locator('#go').click();

e2e/tests/01-lock.spec.ts

@@ -0,0 +1,11 @@
+{
+  "compilerOptions": {
+    "target": "ES2020",
+    "lib": ["ES2020", "DOM"],
+    "module": "CommonJS",
+    "moduleResolution": "node",
+    "types": ["node", "@playwright/test"],
+    "strict": true,
+    "skipLibCheck": true
+  }
+}

e2e/tsconfig.json

@@ -0,0 +1,11 @@
+# Symfony cache
+var/cache/
+
+# Composer dependencies
+vendor/
+composer.lock
+
+# IDE
+/.idea
+
+/config/reference.php