feat: add simple OAuth for testing MCP flows

cdk-deploy-all.sh

@@ -11,8 +11,10 @@ cdk deploy --require-approval never
 popd
 
 # Service deployments in parallel
-pushd src/inventory-service/cdk
+pushd src/inventory-service
 mvn clean package -DskipTests -q
+popd
+pushd  src/inventory-service/cdk
 cdk deploy --require-approval never &>../../../deployment-logs/inventory-service.log &
 popd
 
@@ -41,8 +43,16 @@ cdk deploy --require-approval never &>../../deployment-logs/loyalty-point-servic
 popd
 
 pushd src/activity-service
-npm i
-./package.sh
+pip install --upgrade pip pre-commit poetry
+pre-commit install
+poetry config --local virtualenvs.in-project true
+poetry install --no-root
+npm ci
+poetry export --only=dev --format=requirements.txt > dev_requirements.txt
+poetry export --without=dev --format=requirements.txt > lambda_requirements.txt
+rm -rf .build
+mkdir -p .build/lambdas ; cp -r activity_service .build/lambdas
+mkdir -p .build/common_layer ; poetry export --without=dev --format=requirements.txt > .build/common_layer/requirements.txt
 cdk deploy --require-approval=never &>../../deployment-logs/activity-service.log &
 popd
 

loadtest/Dockerfile-longrunning

@@ -0,0 +1,9 @@
+FROM node:22-alpine
+
+WORKDIR /usr/app
+COPY ./ /usr/app
+RUN npm install -g artillery@latest
+RUN npm install
+RUN chmod +x start.sh
+
+CMD ["./start.sh"]

loadtest/docker-compose-long-running.yml

@@ -0,0 +1,15 @@
+version: "3.8"
+
+services:
+  loadtest:
+    restart: always
+    build:
+      context: .
+      dockerfile: Dockerfile-longrunning
+    environment:
+      - ENV=${ENV}
+      - PRODUCT_API_ENDPOINT=${PRODUCT_API_ENDPOINT}
+      - USER_API_ENDPOINT=${USER_API_ENDPOINT}
+      - ORDER_API_ENDPOINT=${ORDER_API_ENDPOINT}
+      - INVENTORY_API_ENDPOINT=${INVENTORY_API_ENDPOINT}
+      - LOYALTY_API_ENDPOINT=${LOYALTY_API_ENDPOINT}

loadtest/generator.js

@@ -12,8 +12,6 @@ module.exports = {
       Math.random() * context.vars.products.length
     );
 
-    console.log(context.vars.products[randomIndex]);
-
     context.vars.OrderProducts = [context.vars.products[randomIndex].productId];
 
     return done();

loadtest/loadsimulator-low.yml

@@ -0,0 +1,145 @@
+config:
+  target: "https://"
+  http:
+    timeout: 60
+  processor: "generator.js"
+  phases:
+    # Arrival count is a fixed number of requests to be sent over the duration
+    # Over the course of 10 seconds, 2 requests will be sent
+    - duration: 10
+      arrivalCount: 2
+    - duration: 90
+      arrivalCount: 20
+    - duration: 120
+      arrivalCount: 5
+    - duration: 30
+      arrivalCount: 10
+    - duration: 10
+      arrivalCount: 10
+
+scenarios:
+  - name: "User create order"
+    flow:
+      - function: "generateEmailAddress"
+      - post:
+          url: "{{ $processEnvironment.USER_API_ENDPOINT }}/user"
+          headers:
+            Content-Type: "application/json"
+          json:
+            email_address: "{{ Email }}"
+            first_name: "Test"
+            last_name: "User"
+            password: "{{ Password }}"
+      - post:
+          url: "{{ $processEnvironment.USER_API_ENDPOINT }}/login"
+          headers:
+            Content-Type: "application/json"
+          json:
+            email_address: "{{ Email }}"
+            password: "{{ Password }}"
+          capture:
+            json: "$.data.token"
+            as: jwt
+      - get:
+          url: "{{ $processEnvironment.PRODUCT_API_ENDPOINT }}/product"
+          capture:
+            json: "$.data"
+            as: products
+      - function: setOrderProducts
+      - post:
+          url: "{{ $processEnvironment.ORDER_API_ENDPOINT }}/orders"
+          headers:
+            Content-Type: "application/json"
+            Authorization: "Bearer {{jwt}}"
+          json:
+            products: "{{ OrderProducts }}"
+          capture:
+            json: "$.data.orderId"
+            as: OrderId
+  - name: "Admin complete order"
+    flow:
+      - post:
+          url: "{{ $processEnvironment.USER_API_ENDPOINT }}/login"
+          headers:
+            Content-Type: "application/json"
+          json:
+            email_address: "[email protected]"
+            password: "Admin!23"
+          capture:
+            json: "$.data.token"
+            as: adminJwt
+      - get:
+          url: "{{ $processEnvironment.ORDER_API_ENDPOINT }}/orders/confirmed"
+          headers:
+            Authorization: "Bearer {{adminJwt}}"
+          capture:
+            json: "$"
+            as: confirmedOrders
+      - function: getLatestConfirmedOrder
+      - post:
+          url: "{{ $processEnvironment.ORDER_API_ENDPOINT }}/orders/{{ ConfirmedOrderId }}/complete"
+          ifTrue: 'ConfirmedOrderId'
+          headers:
+            Content-Type: "application/json"
+            Authorization: "Bearer {{adminJwt}}"
+          json:
+            orderId: "{{ ConfirmedOrderId }}"
+            userId: "{{ ConfirmedOrderUserId }}"
+  - name: "Admin re-stock products"
+    flow:
+      - post:
+          url: "{{ $processEnvironment.USER_API_ENDPOINT }}/login"
+          headers:
+            Content-Type: "application/json"
+          json:
+            email_address: "[email protected]"
+            password: "Admin!23"
+          capture:
+            json: "$.data.token"
+            as: adminJwt
+      - get:
+          url: "{{ $processEnvironment.PRODUCT_API_ENDPOINT }}/product"
+          capture:
+            json: "$.data"
+            as: products
+      - function: setOutOfStockProductId
+      - get:
+          url: "{{ $processEnvironment.INVENTORY_API_ENDPOINT }}/inventory/{{ ProductId }}"
+          ifTrue: 'ProductId'
+          headers:
+            Authorization: "Bearer {{adminJwt}}"
+          capture:
+            json: "$.data.currentStockLevel"
+            as: currentStockLevel
+      - function: generateRestockAmount
+      - post:
+          url: "{{ $processEnvironment.INVENTORY_API_ENDPOINT }}/inventory"
+          ifTrue: 'ProductId'
+          headers:
+            Content-Type: "application/json"
+            Authorization: "Bearer {{adminJwt}}"
+          json:
+            productId: "{{ProductId}}"
+            stockLevel: "{{NewStockLevel}}"
+  - name: "Admin create products"
+    flow:
+      - post:
+          url: "{{ $processEnvironment.USER_API_ENDPOINT }}/login"
+          headers:
+            Content-Type: "application/json"
+          json:
+            email_address: "[email protected]"
+            password: "Admin!23"
+          capture:
+            json: "$.data.token"
+            as: adminJwt
+      - function: generateProductName
+      - post:
+          url: "{{ $processEnvironment.INVENTORY_API_ENDPOINT }}/product"
+          ifTrue: 'ProductName'
+          headers:
+            Content-Type: "application/json"
+            Authorization: "Bearer {{adminJwt}}"
+          json:
+            name: "{{ProductName}}"
+            price: "{{Price}}"

loadtest/loadsimulator.yml

@@ -4,6 +4,8 @@ config:
     timeout: 60
   processor: "generator.js"
   phases:
+    # Arrival count is a fixed number of requests to be sent over the duration
+    # Over the course of 10 seconds, 10 requests will be sent
     - duration: 10
       arrivalCount: 10
     - duration: 30

loadtest/loadsimulator_1.yml

@@ -0,0 +1,139 @@
+config:
+  target: "https://"
+  http:
+    timeout: 60
+  processor: "generator.js"
+  phases:
+    # Arrival count is a fixed number of requests to be sent over the duration
+    # Over the course of 10 seconds, 10 requests will be sent
+    - duration: 10
+      arrivalCount: 10
+    - duration: 30
+      arrivalCount: 10
+
+scenarios:
+  - name: "User create order"
+    flow:
+      - function: "generateEmailAddress"
+      - post:
+          url: "{{ $processEnvironment.USER_API_ENDPOINT }}/user"
+          headers:
+            Content-Type: "application/json"
+          json:
+            email_address: "{{ Email }}"
+            first_name: "Test"
+            last_name: "User"
+            password: "{{ Password }}"
+      - post:
+          url: "{{ $processEnvironment.USER_API_ENDPOINT }}/login"
+          headers:
+            Content-Type: "application/json"
+          json:
+            email_address: "{{ Email }}"
+            password: "{{ Password }}"
+          capture:
+            json: "$.data.token"
+            as: jwt
+      - get:
+          url: "{{ $processEnvironment.PRODUCT_API_ENDPOINT }}/product"
+          capture:
+            json: "$.data"
+            as: products
+      - function: setOrderProducts
+      - post:
+          url: "{{ $processEnvironment.ORDER_API_ENDPOINT }}/orders"
+          headers:
+            Content-Type: "application/json"
+            Authorization: "Bearer {{jwt}}"
+          json:
+            products: "{{ OrderProducts }}"
+          capture:
+            json: "$.data.orderId"
+            as: OrderId
+  - name: "Admin complete order"
+    flow:
+      - post:
+          url: "{{ $processEnvironment.USER_API_ENDPOINT }}/login"
+          headers:
+            Content-Type: "application/json"
+          json:
+            email_address: "[email protected]"
+            password: "Admin!23"
+          capture:
+            json: "$.data.token"
+            as: adminJwt
+      - get:
+          url: "{{ $processEnvironment.ORDER_API_ENDPOINT }}/orders/confirmed"
+          headers:
+            Authorization: "Bearer {{adminJwt}}"
+          capture:
+            json: "$"
+            as: confirmedOrders
+      - function: getLatestConfirmedOrder
+      - post:
+          url: "{{ $processEnvironment.ORDER_API_ENDPOINT }}/orders/{{ ConfirmedOrderId }}/complete"
+          ifTrue: 'ConfirmedOrderId'
+          headers:
+            Content-Type: "application/json"
+            Authorization: "Bearer {{adminJwt}}"
+          json:
+            orderId: "{{ ConfirmedOrderId }}"
+            userId: "{{ ConfirmedOrderUserId }}"
+  - name: "Admin re-stock products"
+    flow:
+      - post:
+          url: "{{ $processEnvironment.USER_API_ENDPOINT }}/login"
+          headers:
+            Content-Type: "application/json"
+          json:
+            email_address: "[email protected]"
+            password: "Admin!23"
+          capture:
+            json: "$.data.token"
+            as: adminJwt
+      - get:
+          url: "{{ $processEnvironment.PRODUCT_API_ENDPOINT }}/product"
+          capture:
+            json: "$.data"
+            as: products
+      - function: setOutOfStockProductId
+      - get:
+          url: "{{ $processEnvironment.INVENTORY_API_ENDPOINT }}/inventory/{{ ProductId }}"
+          ifTrue: 'ProductId'
+          headers:
+            Authorization: "Bearer {{adminJwt}}"
+          capture:
+            json: "$.data.currentStockLevel"
+            as: currentStockLevel
+      - function: generateRestockAmount
+      - post:
+          url: "{{ $processEnvironment.INVENTORY_API_ENDPOINT }}/inventory"
+          ifTrue: 'ProductId'
+          headers:
+            Content-Type: "application/json"
+            Authorization: "Bearer {{adminJwt}}"
+          json:
+            productId: "{{ProductId}}"
+            stockLevel: "{{NewStockLevel}}"
+  - name: "Admin create products"
+    flow:
+      - post:
+          url: "{{ $processEnvironment.USER_API_ENDPOINT }}/login"
+          headers:
+            Content-Type: "application/json"
+          json:
+            email_address: "[email protected]"
+            password: "Admin!23"
+          capture:
+            json: "$.data.token"
+            as: adminJwt
+      - function: generateProductName
+      - post:
+          url: "{{ $processEnvironment.INVENTORY_API_ENDPOINT }}/product"
+          ifTrue: 'ProductName'
+          headers:
+            Content-Type: "application/json"
+            Authorization: "Bearer {{adminJwt}}"
+          json:
+            name: "{{ProductName}}"
+            price: "{{Price}}"