Modeling checkout-api

- Adding load test for checkout

src/backend/backend.code-workspace

@@ -4,14 +4,7 @@
 			"name": "github",
 			"path": "../../.github"
 		},
-		{
-			"name": "k8s-kustomize",
-			"path": "../../k8s-kustomize"
-		},
-		{
-			"name": "docker",
-			"path": "./docker"
-		},
+
 		{
 			"name": "checkout-api",
 			"path": "./services/checkout-api"
@@ -36,10 +29,7 @@
 			"name": "order-api",
 			"path": "./services/order-api"
 		},
-		{
-			"name": "nginx",
-			"path": "./nginx"
-		},
+
 		{
 			"name": "dashboard-app",
 			"path": "./web/web.admin/dashboard"
@@ -53,6 +43,21 @@
 		},
 		{
 			"path": "./services/protobuff"
+		},
+		{
+			"path": "./load-tests"
+		},
+		{
+			"name": "k8s-kustomize",
+			"path": "../../k8s-kustomize"
+		},
+		{
+			"name": "docker",
+			"path": "./docker"
+		},	
+		{
+			"name": "nginx",
+			"path": "./nginx"
 		}
 	],
 	"settings": {

src/backend/docker/otel-connector-config.yaml

@@ -15,7 +15,7 @@ exporters:
   prometheus:
     endpoint: "0.0.0.0:8889"
     const_labels:
-      label1: value1
+      env: local
 
   otlp:
     endpoint: tempo:4317

src/backend/load-tests/checkout.js

@@ -25,9 +25,11 @@ export default function () {
         picture: food.image,
         quantity: Math.floor(Math.random() * 20),
         unit_price: food.price,
-      }
+      }      
     ]
   }))
 
   sleep(1);
+
+  http.post(baseUrl + '')
 }

src/backend/services/checkout-api/src/cartService.spec.ts → src/backend/services/checkout-api/src/cart/cartService.spec.ts

@@ -1,7 +1,7 @@
 import { expect } from 'chai';
 import sinon from 'sinon';
-import { GetCustomerCartRequest } from './gen/cart/GetCustomerCartRequest';
-import { GetCustomerCartResponse } from './gen/cart/GetCustomerCartResponse';
+import { GetCustomerCartRequest } from '../gen/cart/GetCustomerCartRequest';
+import { GetCustomerCartResponse } from '../gen/cart/GetCustomerCartResponse';
 import  { cartService } from './cartService';
 
 describe('CartService', () => {

src/backend/services/checkout-api/src/cartService.ts → src/backend/services/checkout-api/src/cart/cartService.ts

@@ -1,11 +1,11 @@
-import { config } from './config';
+import { config } from '../config';
 import * as grpc from '@grpc/grpc-js'
 import * as protoLoader from '@grpc/proto-loader'
-import { ProtoGrpcType } from './gen/cart';
+import { ProtoGrpcType } from '../gen/cart';
 import path from 'path'
-import { GetCustomerCartResponse } from './gen/cart/GetCustomerCartResponse';
-import { GetCustomerCartRequest } from './gen/cart/GetCustomerCartRequest';
-import { logger } from './logger';
+import { GetCustomerCartResponse } from '../gen/cart/GetCustomerCartResponse';
+import { GetCustomerCartRequest } from '../gen/cart/GetCustomerCartRequest';
+import { logger } from '../logger';
 
 
 const packageDefinition = protoLoader.loadSync(

src/backend/services/checkout-api/src/checkout.ts → src/backend/services/checkout-api/src/checkout/checkout.ts

@@ -1,10 +1,10 @@
 import * as api from '@opentelemetry/api';
 import { randomUUID } from "crypto";
-import { CartItem, CheckoutEvent, UserCheckout } from "./model";
-import getCustomerCartItems from "./cartService";
-import Payment from "./paymentService";
-import { logger } from "./logger";
-import checkoutPublisher from "./publisher";
+import { CartItem, CheckoutEvent, UserCheckout } from "../model";
+import getCustomerCartItems from "../cart/cartService";
+import Payment from "../payment/paymentService";
+import { logger } from "../logger";
+import checkoutPublisher from "../messagging/publisher";
 
 export default async function Checkout(checkout: UserCheckout) {
     const span = api.trace.getTracer('checkout-api').startSpan('checkout-api.Checkout');

src/backend/services/checkout-api/src/publisher.ts → src/backend/services/checkout-api/src/messagging/publisher.ts

@@ -1,6 +1,6 @@
 import { Kafka, Producer, ProducerRecord } from 'kafkajs'
-import { config } from './config'
-import { logger } from './logger'
+import { config } from '../config'
+import { logger } from '../logger'
 
 export class Publisher {
   private producer: Producer

src/backend/services/checkout-api/src/paymentService.spec.ts → src/backend/services/checkout-api/src/payment/paymentService.spec.ts

@@ -2,9 +2,9 @@ import sinon from 'sinon';
 import { expect } from "chai";
 import type * as grpc from '@grpc/grpc-js'
 import { paymentService, pay } from "./paymentService";
-import { CartItem, UserCheckout } from "./model";
-import { PaymentResponse } from './gen/payment/PaymentResponse';
-import { PaymentRequest } from './gen/payment/PaymentRequest';
+import { CartItem, UserCheckout } from "../model";
+import { PaymentResponse } from '../gen/payment/PaymentResponse';
+import { PaymentRequest } from '../gen/payment/PaymentRequest';
 
 
 describe("pay", () => {

src/backend/services/checkout-api/src/paymentService.ts → src/backend/services/checkout-api/src/payment/paymentService.ts

@@ -1,12 +1,12 @@
-import { config } from './config';
+import { config } from '../config';
 import * as grpc from '@grpc/grpc-js'
 import * as protoLoader from '@grpc/proto-loader'
-import { ProtoGrpcType } from './gen/payments';
+import { ProtoGrpcType } from '../gen/payments';
 import path from 'path'
-import { UserCheckout } from './model';
-import { PaymentResponse } from './gen/payment/PaymentResponse';
-import { PaymentRequest } from './gen/payment/PaymentRequest';
-import { CartItem } from './gen/cart/CartItem';
+import { UserCheckout } from '../model';
+import { PaymentResponse } from '../gen/payment/PaymentResponse';
+import { PaymentRequest } from '../gen/payment/PaymentRequest';
+import { CartItem } from '../gen/cart/CartItem';
 
 const packageDefinition = protoLoader.loadSync(
   path.resolve(__dirname, '../pb/payments.proto'),

src/backend/services/checkout-api/src/routes.ts

@@ -1,6 +1,6 @@
 import express, { Request, Response } from "express";
 import { UserCheckout } from "./model";
-import Checkout from "./checkout";
+import Checkout from "./usecases/checkout";
 
 const router = express.Router();