Added startup message

.github/workflows/tests-payments.yaml

@@ -14,4 +14,4 @@ jobs:
           wget http://archive.ubuntu.com/ubuntu/pool/main/o/openssl/libssl1.1_1.1.1f-1ubuntu2_amd64.deb
           sudo dpkg -i libssl1.1_1.1.1f-1ubuntu2_amd64.deb
       - uses: actions/checkout@v2
-      - run: cd payments && npm install && npm run test:ci
+      - run: cd payments && npm install && npm run test:ci

auth/package.json

@@ -5,7 +5,7 @@
   "scripts": {
     "start": "ts-node-dev src/index.ts",
     "test": "jest --watchAll --no-cache",
-    "test:ci":"jest"
+    "test:ci": "jest"
   },
   "jest": {
     "preset": "ts-jest",

auth/src/index.ts

@@ -2,6 +2,7 @@ import mongoose from 'mongoose';
 import { app } from './app';
 
 const start = async () => {
+  console.log('Starting...');
   if (!process.env.JWT_KEY) {
     throw new Error('JWT_KEY must be defined');
   }

auth/src/routes/__test__/current-user.test.ts

@@ -14,7 +14,7 @@ it('responds with details about the current user', async () => {
         .send()
         .expect(200);
 
-  expect(response.body.currentUser.email).toEqual("test@test.com");
+  expect(response.body.currentUser.email).toContain('@test.com');
 });
 
 it('responds with null if not authenticated', async () => {

auth/src/routes/__test__/signup.test.ts

@@ -6,7 +6,7 @@ it("returns a 201 on successful signup", async () => {
     return request(app)
         .post("/api/users/signup")
         .send({
-            email: "test@test.com",
+            email: "testsignup@test.com",
             password: "password"
         })
         .expect(201);

auth/src/test/setup.ts

@@ -3,7 +3,7 @@ import mongoose from 'mongoose';
 import request from 'supertest';
 import { app } from '../app';
 
-// jest.setTimeout(120000); // 2 minutes
+jest.setTimeout(120000); // 2 minutes
 
 declare global {
   var signin: () => Promise<string[]>;
@@ -12,10 +12,18 @@ declare global {
 let mongo: any;
 beforeAll(async () => {
   process.env.JWT_KEY = 'asdfasdf'
-  mongo = await MongoMemoryServer.create();
-  const mongoUri = mongo.getUri();
-
-  await mongoose.connect(mongoUri, {});
+  let mongoUri: string;
+
+    // Use mongodb-memory-server for local development
+    mongo = await MongoMemoryServer.create({
+      binary: {
+      version: "5.0.5"
+    }
+    });
+    mongoUri = mongo.getUri();
+
+
+    await mongoose.connect(mongoUri, {});
 });
 
 
@@ -37,7 +45,7 @@ afterAll(async () => {
 });
 
 global.signin = async () => {
-  const email = 'test@test.com';
+  const email = `test-${Date.now()}-${Math.random()}@test.com`; // Unique email each time
   const password = 'password';
 
   const response = await request(app)
@@ -54,4 +62,4 @@ global.signin = async () => {
     throw new Error("Failed to get cookie from response");
   }
   return cookie;
-};
+};

orders/src/events/listeners/expiration-complete-listener.ts

@@ -3,7 +3,6 @@ import { Message } from "node-nats-streaming";
 import { queueGroupName } from "./queue-group-name";
 import { Order } from "../../models/order";
 import { OrderCancelledPublisher } from "../publishers/order-cancelled-publisher";
-import { natsWrapper } from "../../nats-wrapper";
 
 // Main purpose of this listener is to listen for expiration complete events
 // and then update the order status to cancelled
@@ -27,7 +26,7 @@ export class ExpirationCompleteListener extends Listener<ExpirationCompleteEvent
     await order.save();
 
     // publish an event saying that the order has been cancelled
-    await new OrderCancelledPublisher(natsWrapper.client).publish({
+    await new OrderCancelledPublisher(this.client).publish({
       id: order.id,
       version: order.version,
       ticket: {

orders/src/index.ts

@@ -58,7 +58,7 @@ const start = async () => {
   }
 
   app.listen(3000, () => {
-    console.log("listening on port 3000!!!");
+    console.log("listening on port 3000!!");
   });
 };
 

orders/src/routes/__test__/delete.test.ts

@@ -14,6 +14,7 @@ it('marks an order as cancelled', async () => {
   });
   await ticket.save();
 
+
   const user = global.signin();
   // make a request to create an order
   const { body: order } = await request(app)
@@ -35,6 +36,7 @@ it('marks an order as cancelled', async () => {
   expect(updatedOrder!.status).toEqual(OrderStatus.Cancelled);
 });
 
+
 it('emits a order cancelled event', async () => {
   const ticket = Ticket.build({
     id: new mongoose.Types.ObjectId().toHexString(),
@@ -44,12 +46,22 @@ it('emits a order cancelled event', async () => {
   await ticket.save();
 
   const user = global.signin();
+
+  console.log('Ticket ID:', ticket.id);
+  console.log('User cookie:', user);
+
   // make a request to create an order
-  const { body: order } = await request(app)
+  const response = await request(app)
     .post('/api/orders')
     .set('Cookie', user)
-    .send({ ticketId: ticket.id })
-    .expect(201);
+    .send({ ticketId: ticket.id });
+
+  console.log('Response status:', response.status);
+  console.log('Response body:', response.body);
+
+  expect(response.status).toBe(201);
+
+  const order = response.body;
 
   // make a request to cancel the order
   await request(app)

orders/src/test/setup.ts

@@ -1,8 +1,8 @@
-import {MongoMemoryServer} from 'mongodb-memory-server';
-import mongoose from 'mongoose';
-import jwt from 'jsonwebtoken';
+import { MongoMemoryServer } from "mongodb-memory-server";
+import mongoose from "mongoose";
+import jwt from "jsonwebtoken";
 
-// jest.setTimeout(120000); // 2 minutes
+jest.setTimeout(120000); // 2 minutes
 
 declare global {
   var signin: () => string[];
@@ -12,23 +12,25 @@ jest.mock("../nats-wrapper");
 
 let mongo: any;
 beforeAll(async () => {
-  process.env.JWT_KEY = 'asdfasdf'
-  mongo = await MongoMemoryServer.create({
-    binary: {
-    version: "5.0.5"
-  }
-  });
-  const mongoUri = mongo.getUri();
+  process.env.JWT_KEY = "asdfasdf";
+  let mongoUri: string;
+
+    // Use mongodb-memory-server for local development
+    mongo = await MongoMemoryServer.create({
+      binary: {
+        version: "5.0.5",
+      },
+    });
+    mongoUri = mongo.getUri();
 
   await mongoose.connect(mongoUri, {});
 });
 
-
 beforeEach(async () => {
   jest.clearAllMocks();
-    if (mongoose.connection.db) {
+  if (mongoose.connection.db) {
     const collections = await mongoose.connection.db.collections();
- 
+
     for (let collection of collections) {
       await collection.deleteMany({});
     }
@@ -46,22 +48,21 @@ global.signin = () => {
   // Build a JWT payload.  {id, email}
   const payload = {
     id: new mongoose.Types.ObjectId().toHexString(),
-    email:'test@test.com'
-  }
+    email: "test@test.com",
+  };
 
   // Create the JWT!
   const token = jwt.sign(payload, process.env.JWT_KEY!);
 
   // build session object {jwt: MY_JWT}
-const session = { jwt: token };
+  const session = { jwt: token };
 
   // Turn that session into JSON
   const sessionJSON = JSON.stringify(session);
 
   // Take JSON and encode it as base64
-  const base64 = Buffer.from(sessionJSON).toString('base64');
-
+  const base64 = Buffer.from(sessionJSON).toString("base64");
 
   // return a string thats the cookie with the encoded data
-   return [`session=${base64}`];
-};
+  return [`session=${base64}`];
+};

payments/src/index.ts

@@ -53,7 +53,7 @@ const start = async () => {
   }
 
   app.listen(3000, () => {
-    console.log("listening on port 3000!!");
+    console.log("listening on port 3000!!!");
   });
 };
 

payments/src/test/setup.ts

@@ -1,38 +1,41 @@
-import {MongoMemoryServer} from 'mongodb-memory-server';
-import mongoose from 'mongoose';
-import request from 'supertest';
-import { app } from '../app';
-import jwt from 'jsonwebtoken';
+import { MongoMemoryServer } from "mongodb-memory-server";
+import mongoose from "mongoose";
+import request from "supertest";
+import { app } from "../app";
+import jwt from "jsonwebtoken";
 
 jest.setTimeout(120000); // 2 minutes
 
 declare global {
-  var signin: (id?:string) => string[];
+  var signin: (id?: string) => string[];
 }
 
 jest.mock("../nats-wrapper");
 
-process.env.STRIPE_KEY = 'sk_test_mock';
+process.env.STRIPE_KEY = "sk_test_mock";
 
 let mongo: any;
 beforeAll(async () => {
-  process.env.JWT_KEY = 'asdfasdf'
-  mongo = await MongoMemoryServer.create({
-    binary: {
-    version: "5.0.5"
-  }
-  });
-  const mongoUri = mongo.getUri();
+  process.env.JWT_KEY = "asdfasdf";
+  let mongoUri: string;
+
+    // Use mongodb-memory-server for local development
+    mongo = await MongoMemoryServer.create({
+      binary: {
+        version: "5.0.5",
+      },
+    });
+    mongoUri = mongo.getUri();
+
 
   await mongoose.connect(mongoUri, {});
 });
 
-
 beforeEach(async () => {
   jest.clearAllMocks();
-    if (mongoose.connection.db) {
+  if (mongoose.connection.db) {
     const collections = await mongoose.connection.db.collections();
- 
+
     for (let collection of collections) {
       await collection.deleteMany({});
     }
@@ -46,26 +49,25 @@ afterAll(async () => {
   await mongoose.connection.close();
 });
 
-global.signin = (id?:string) => {
+global.signin = (id?: string) => {
   // Build a JWT payload.  {id, email}
   const payload = {
     id: id || new mongoose.Types.ObjectId().toHexString(),
-    email: 'test@test.com',
+    email: "test@test.com",
   };
 
   // Create the JWT!
   const token = jwt.sign(payload, process.env.JWT_KEY!);
 
   // build session object {jwt: MY_JWT}
-const session = { jwt: token };
+  const session = { jwt: token };
 
   // Turn that session into JSON
   const sessionJSON = JSON.stringify(session);
 
   // Take JSON and encode it as base64
-  const base64 = Buffer.from(sessionJSON).toString('base64');
-
+  const base64 = Buffer.from(sessionJSON).toString("base64");
 
   // return a string thats the cookie with the encoded data
-   return [`session=${base64}`];
-};
+  return [`session=${base64}`];
+};

tickets/src/routes/__test__/new.test.ts

@@ -71,6 +71,7 @@ it("creates a ticket with valid input", async () => {
     })
     .expect(201);
 
+
   tickets = await Ticket.find({});
   expect(tickets.length).toEqual(1);
   expect(tickets[0].price).toEqual(20);

tickets/src/routes/__test__/show.test.ts

@@ -8,7 +8,7 @@ it("returns a 404 if the ticket is not found", async () => {
 });
 
 it("returns the ticket if the ticket is found", async () => {
-  const title = "concert";
+  const title = "valid title";
   const price = 20;
   const createResponse = await request(app)
     .post("/api/tickets")