Fix CI: update workflow and E2E tests for current app

- workflow: deploy app (build ECR image + tflocal apply) then run pytest
- tests: update status checks from 'processed' to 'fulfilled', increase
  timeout for ECS pipeline, add products test, update item names

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>

Author: whummer

.github/workflows/build-test.yml

@@ -13,32 +13,45 @@ jobs:
       - name: Checkout
         uses: actions/checkout@v2
 
-      - name: Start up LocalStack
-        env:
-          LOCALSTACK_AUTH_TOKEN: ${{ secrets.LOCALSTACK_AUTH_TOKEN }}
+      - name: Install tools
         run: |
-          docker pull localstack/localstack-pro &
+          pip install --pre localstack awscli-local[ver1] terraform-local pytest requests
 
-          # install CLI tools
-          pip install --pre localstack localstack-ext awscli-local[ver1]
-
-          # start LocalStack
-          DEBUG=1 localstack start -d
-          localstack wait
+          # Terraform
+          curl -fsSL https://apt.releases.hashicorp.com/gpg | sudo gpg --dearmor -o /usr/share/keyrings/hashicorp-archive-keyring.gpg
+          echo "deb [signed-by=/usr/share/keyrings/hashicorp-archive-keyring.gpg] https://apt.releases.hashicorp.com $(lsb_release -cs) main" \
+            | sudo tee /etc/apt/sources.list.d/hashicorp.list
+          sudo apt-get update -qq && sudo apt-get install -y terraform
 
-      - name: Run simple test
+      - name: Start LocalStack
         env:
           LOCALSTACK_AUTH_TOKEN: ${{ secrets.LOCALSTACK_AUTH_TOKEN }}
         run: |
-          set -e
+          docker pull localstack/localstack-pro &
+          DEBUG=1 LOCALSTACK_APPINSPECTOR_ENABLE=1 localstack start -d
+          localstack wait
 
-          # deploy test resources
-          (cd 00-hello-world; ./deploy.sh)
+      - name: Build fulfillment image
+        run: |
+          ECR_REGISTRY="000000000000.dkr.ecr.us-east-1.localhost.localstack.cloud:4566"
+          awslocal ecr create-repository --repository-name fulfillment 2>/dev/null || true
+          awslocal ecr get-login-password | \
+            docker login --username AWS --password-stdin "$ECR_REGISTRY"
+          docker build -t "$ECR_REGISTRY/fulfillment:latest" 01-serverless-app/services/fulfillment
+          docker push "$ECR_REGISTRY/fulfillment:latest"
+
+      - name: Deploy app via Terraform
+        run: |
+          cd 01-serverless-app/terraform
+          tflocal init
+          tflocal apply -auto-approve
 
-          # run assertion
-          curl http://testwebsite.s3-website.localhost.localstack.cloud:4566 | grep 'You are running LocalStack'
+      - name: Run E2E tests
+        run: |
+          cd 02-e2e-testing && pytest tests/ -v
 
       - name: Print LocalStack logs
+        if: always()
         run: |
           localstack logs
           localstack stop

02-e2e-testing/tests/test_order_flow.py

@@ -4,39 +4,51 @@
 
 
 def test_create_order_returns_order_id(api_endpoint):
-    resp = requests.post(f"{api_endpoint}/orders", json={"item": "book", "quantity": 2})
+    resp = requests.post(f"{api_endpoint}/orders", json={"item": "LocalStack T-Shirt", "quantity": 2})
     assert resp.status_code == 201
     data = resp.json()
     assert "order_id" in data
     assert data["status"] == "pending"
 
 
 def test_order_persisted_in_dynamodb(api_endpoint, dynamodb):
-    resp = requests.post(f"{api_endpoint}/orders", json={"item": "mug", "quantity": 1})
+    resp = requests.post(f"{api_endpoint}/orders", json={"item": "LocalStack Mug", "quantity": 1})
     order_id = resp.json()["order_id"]
 
     table = dynamodb.Table("orders")
     item = table.get_item(Key={"order_id": order_id})["Item"]
-    assert item["item"] == "mug"
+    assert item["item"] == "LocalStack Mug"
     assert item["status"] == "pending"
 
 
-def test_order_processed_and_receipt_in_s3(api_endpoint, dynamodb, s3):
-    resp = requests.post(f"{api_endpoint}/orders", json={"item": "t-shirt", "quantity": 3})
+def test_order_fulfilled_and_receipt_in_s3(api_endpoint, dynamodb, s3):
+    resp = requests.post(f"{api_endpoint}/orders", json={"item": "LocalStack Hoodie", "quantity": 1})
+    assert resp.status_code == 201
     order_id = resp.json()["order_id"]
 
-    # Wait for async SQS → Lambda processing (up to 10s)
+    # Wait for full pipeline: SQS → Lambda → Step Functions → ECS (up to 60s)
     table = dynamodb.Table("orders")
-    for _ in range(20):
+    for _ in range(120):
         item = table.get_item(Key={"order_id": order_id})["Item"]
-        if item["status"] == "processed":
+        if item["status"] in ("fulfilled", "failed"):
             break
         time.sleep(0.5)
     else:
-        raise AssertionError(f"Order {order_id} never reached 'processed' status")
+        raise AssertionError(f"Order {order_id} never reached terminal status (last: {item['status']})")
+
+    assert item["status"] == "fulfilled", f"Expected fulfilled, got {item['status']}"
 
-    # Verify receipt uploaded to S3
+    # Verify receipt uploaded to S3 by the ECS fulfillment task
     obj = s3.get_object(Bucket="order-receipts", Key=f"receipts/{order_id}.json")
     receipt = json.loads(obj["Body"].read())
     assert receipt["order_id"] == order_id
-    assert receipt["status"] == "processed"
+    assert receipt["status"] == "fulfilled"
+
+
+def test_products_listed(api_endpoint):
+    resp = requests.get(f"{api_endpoint}/products")
+    assert resp.status_code == 200
+    products = resp.json()
+    assert len(products) > 0
+    names = [p["name"] for p in products]
+    assert any("LocalStack" in n for n in names)