test: migrate server to typescript

Author: Akryum

packages/test-server/bin.mjs

@@ -1,4 +1,4 @@
 #!/usr/bin/env node
 'use strict'
 
-import './src/index.mjs'
+import './dist/index.js'

packages/test-server/package.json

@@ -5,6 +5,11 @@
   "bin": {
     "test-server": "./bin.mjs"
   },
+  "type": "module",
+  "scripts": {
+    "build": "tsc -d",
+    "prepare": "pnpm run build"
+  },
   "dependencies": {
     "@apollo/server": "^4.7.3",
     "@graphql-tools/schema": "^10.0.0",
@@ -19,6 +24,11 @@
     "ws": "^8.13.0"
   },
   "devDependencies": {
-    "@types/shortid": "^0.0.29"
+    "@types/body-parser": "^1.19.2",
+    "@types/cors": "^2.8.13",
+    "@types/express": "^4.17.17",
+    "@types/shortid": "^0.0.29",
+    "@types/ws": "^8.5.5",
+    "typescript": "^4.7.4"
   }
 }

packages/test-server/src/data.mjs

@@ -0,0 +1,30 @@
+export interface Channel {
+  id: string
+  label: string
+  messages: Message[]
+}
+
+export interface Message {
+  id: string
+  channel: Channel
+  text: string
+}
+
+export let channels: Channel[] = []
+
+export function resetDatabase (): void {
+  channels = [
+    {
+      id: 'general',
+      label: 'General',
+      messages: [],
+    },
+    {
+      id: 'random',
+      label: 'Random',
+      messages: [],
+    },
+  ]
+}
+
+resetDatabase()

packages/test-server/src/data.ts

@@ -6,12 +6,15 @@ import { ApolloServer } from '@apollo/server'
 import { expressMiddleware } from '@apollo/server/express4'
 import { WebSocketServer } from 'ws'
 import { useServer } from 'graphql-ws/lib/use/ws'
-import { schema } from './schema.mjs'
-import { resetDatabase } from './data.mjs'
+import { schema } from './schema.js'
+import { resetDatabase } from './data.js'
+import { simulateLatency } from './util.js'
 
 const app = express()
 
-app.use(cors('*'))
+app.use(cors({
+  origin: '*',
+}))
 
 app.use(bodyParser.json())
 
@@ -22,9 +25,6 @@ app.get('/_reset', (req, res) => {
 
 const server = new ApolloServer({
   schema,
-  context: () => new Promise(resolve => {
-    setTimeout(() => resolve({}), 50)
-  }),
   plugins: [
     // Proper shutdown for the WebSocket server.
     {
@@ -42,7 +42,12 @@ const server = new ApolloServer({
 
 await server.start()
 
-app.use('/graphql', expressMiddleware(server))
+app.use('/graphql', expressMiddleware(server, {
+  context: async () => {
+    await simulateLatency()
+    return {}
+  },
+}))
 
 const httpServer = createServer(app)
 

packages/test-server/src/index.mjs renamed to packages/test-server/src/index.ts

@@ -2,8 +2,8 @@ import { makeExecutableSchema } from '@graphql-tools/schema'
 import { PubSub, withFilter } from 'graphql-subscriptions'
 import shortid from 'shortid'
 import gql from 'graphql-tag'
-import { channels } from './data.mjs'
-import { simulateLatency, GraphQLErrorWithCode } from './util.mjs'
+import { channels } from './data.js'
+import { GraphQLErrorWithCode } from './util.js'
 
 const pubsub = new PubSub()
 
@@ -51,21 +51,31 @@ type Subscription {
 }
 `
 
+interface AddMessageInput {
+  channelId: string
+  text: string
+}
+
+interface UpdateMessageInput {
+  id: string
+  channelId: string
+  text: string
+}
+
 const resolvers = {
   Query: {
-    hello: () => simulateLatency().then(() => 'Hello world!'),
-    channels: () => simulateLatency().then(() => channels),
-    channel: (root, { id }) => simulateLatency().then(() => channels.find(c => c.id === id)),
-    list: () => simulateLatency().then(() => ['a', 'b', 'c']),
-    good: () => simulateLatency().then(() => 'good'),
+    hello: () => 'Hello world!',
+    channels: () => channels,
+    channel: (root: any, { id }: { id: string }) => channels.find(c => c.id === id),
+    list: () => ['a', 'b', 'c'],
+    good: () => 'good',
     bad: async () => {
-      await simulateLatency()
       throw new Error('An error')
     },
   },
 
   Mutation: {
-    addMessage: (root, { input }) => {
+    addMessage: (root: any, { input }: { input: AddMessageInput }) => {
       const channel = channels.find(c => c.id === input.channelId)
       if (!channel) {
         throw new GraphQLErrorWithCode(`Channel ${input.channelId} not found`, 'not-found')
@@ -80,12 +90,15 @@ const resolvers = {
       return message
     },
 
-    updateMessage: (root, { input }) => {
+    updateMessage: (root: any, { input }: { input: UpdateMessageInput }) => {
       const channel = channels.find(c => c.id === input.channelId)
       if (!channel) {
         throw new GraphQLErrorWithCode(`Channel ${input.channelId} not found`, 'not-found')
       }
       const message = channel.messages.find(m => m.id === input.id)
+      if (!message) {
+        throw new GraphQLErrorWithCode(`Message ${input.id} not found`, 'not-found')
+      }
       Object.assign(message, {
         text: input.text,
       })

packages/test-server/src/schema.mjs renamed to packages/test-server/src/schema.ts

@@ -1,4 +1,4 @@
-import { GraphQLError } from 'graphql'
+import { GraphQLError, GraphQLErrorExtensions } from 'graphql'
 
 const shouldSimulateLatency = process.argv.includes('--simulate-latency')
 
@@ -11,7 +11,7 @@ if (shouldSimulateLatency) {
 }
 
 export function simulateLatency () {
-  return new Promise(resolve => {
+  return new Promise<void>(resolve => {
     if (shouldSimulateLatency) {
       setTimeout(resolve, latency)
     } else {
@@ -21,8 +21,8 @@ export function simulateLatency () {
 }
 
 export class GraphQLErrorWithCode extends GraphQLError {
-  constructor (message, code, extensions) {
-    super(message, {
+  constructor (message: string, code: string, extensions?: GraphQLErrorExtensions) {
+    super(message, null, null, null, null, null, {
       extensions: {
         code,
         ...extensions,

packages/test-server/src/util.mjs renamed to packages/test-server/src/util.ts

@@ -0,0 +1,23 @@
+{
+  "compilerOptions": {
+    "target": "esnext",
+    "module": "esnext",
+    "strict": true,
+    "importHelpers": true,
+    "moduleResolution": "node",
+    "skipLibCheck": true,
+    "esModuleInterop": true,
+    "allowSyntheticDefaultImports": true,
+    "sourceMap": true,
+    "lib": [
+      "esnext"
+    ],
+    "outDir": "dist",
+  },
+  "include": [
+    "src/**/*.ts",
+  ],
+  "exclude": [
+    "node_modules"
+  ]
+}