Connect to AMQP and fix io-ts import issues

Author: jbreckmckye

Diff for: dev/Dockerfile

@@ -1,8 +1,8 @@
 FROM      node:10
 WORKDIR   /app
 
-COPY      src ./src
 COPY      package.json yarn.lock tsconfig.json ./
 RUN       yarn
+COPY      src ./src
 
 CMD       yarn run ts-node -r tsconfig-paths/register src/apps/webapp/index.ts

Diff for: docker-compose.yml

@@ -36,5 +36,5 @@ services:
       - "5672:5672"
       - "15672:15672"
     environment:
-      RABBITMQ_DEFAULT_USER: username
-      RABBITMQ_DEFAULT_PASS: password
+      RABBITMQ_DEFAULT_USER: guest
+      RABBITMQ_DEFAULT_PASS: guest

Diff for: package.json

@@ -21,7 +21,7 @@
     "amqplib": "0.5.5",
     "body-parser": "1.19.0",
     "express": "4.17.1",
-    "io-ts": "2.2.1",
+    "io-ts": "2.2.2",
     "io-ts-reporters": "1.0.0",
     "io-ts-types": "0.5.6",
     "pg": "8.0.3",

Diff for: src/adapters/rabbitmq/index.ts

@@ -1,8 +1,10 @@
 import * as amqp from 'amqplib'
 import { Ctx } from '@lib'
 
+const wait = (ms: number) => new Promise((resolve) => setTimeout(resolve, ms))
+
 export async function $adapter (): Promise<Ctx.ContextAdapter> {
-  const connection = await amqp.connect('amqp://localhost')
+  const connection = await attemptConnection()
   const channel = await connection.createChannel()
 
   await channel.assertQueue('messages')
@@ -26,3 +28,23 @@ export async function $adapter (): Promise<Ctx.ContextAdapter> {
     }
   }
 }
+
+async function attemptConnection (count: number = 6): Promise<amqp.Connection> {
+  try {
+    const connection = await amqp.connect('amqp://guest:guest@rabbitmq:5672')
+    console.log('Connected to AMQP')
+
+    return connection
+
+  } catch (err) {
+    if (!count) {
+      console.log('AMQP connection failed')
+      throw err
+
+    } else {
+      console.log('Retrying AMQP connection in 5 seconds...')
+      await wait(5000)
+      return await attemptConnection(count - 1)
+    }
+  }
+}

Diff for: src/lib/entities/Book.ts

@@ -1,4 +1,4 @@
-import t from 'io-ts'
+import * as t from 'io-ts'
 import { UUID } from 'io-ts-types/lib/UUID'
 import { $cast } from './cast'
 

Diff for: src/lib/entities/Loan.ts

@@ -1,4 +1,4 @@
-import t from 'io-ts'
+import * as t from 'io-ts'
 import { UUID } from 'io-ts-types/lib/UUID'
 
 import { User } from './User'

Diff for: src/lib/entities/User.ts

@@ -1,4 +1,4 @@
-import t from 'io-ts'
+import * as t from 'io-ts'
 import { UUID } from 'io-ts-types/lib/UUID'
 import { $cast } from './cast'
 

Diff for: src/lib/operations/book.ts

@@ -3,8 +3,8 @@ import { Context } from '../context'
 
 export async function addBook (ctx: Context, bookInput: BookInput): Promise<Book> {
   const {
-    backend:    { bookStore },
-    middleware: { events }
+    backend: { bookStore },
+    events
   } = ctx
 
   const book = await bookStore.add(bookInput)

Diff for: src/lib/operations/loan.ts

@@ -7,8 +7,8 @@ import { Book, LoanInput, LoanResolution, User } from '../entities'
 
 export async function loanBook (ctx: Context, loanInput: LoanInput): Promise<LoanResolution> {
   const {
-    backend:    { userStore, bookStore, loanStore },
-    middleware: { events }
+    backend: { userStore, bookStore, loanStore },
+    events
   } = ctx
 
   const user = await userStore.find(loanInput.userId)

Diff for: src/lib/operations/user.ts

@@ -3,11 +3,10 @@ import { User, UserInput } from '../entities'
 import { Context } from '../context'
 import { UserDoesNotExist, UserHasOutstandingLoans } from '../errors'
 
-
 export async function addUser (ctx: Context, userInput: UserInput): Promise<User> {
   const {
-    backend:    { userStore },
-    middleware: { events }
+    backend: { userStore },
+    events
   } = ctx
 
   const user = await userStore.add(userInput)
@@ -22,8 +21,8 @@ export async function addUser (ctx: Context, userInput: UserInput): Promise<User
 
 export async function removeUser (ctx: Context, userId: UUID): Promise<void> {
   const {
-    backend:    { loanStore, userStore },
-    middleware: { events }
+    backend: { loanStore, userStore },
+    events
   } = ctx
 
   const user = await userStore.find(userId)