add continuity middleware + health check api

Author: tudddorrr

src/config/api-routes.ts

@@ -1,5 +1,6 @@
 import Koa, { Context, Next } from 'koa'
 import { service } from 'koa-clay'
+import HealthCheckAPIService from '../services/api/health-check-api.service'
 import GameFeedbackAPIService from '../services/api/game-feedback-api.service'
 import GameConfigAPIService from '../services/api/game-config-api.service'
 import GameStatAPIService from '../services/api/game-stat-api.service'
@@ -13,6 +14,7 @@ import { apiRouteAuthMiddleware, getRouteInfo } from '../middlewares/route-middl
 import apiKeyMiddleware from '../middlewares/api-key-middleware'
 import playerAuthMiddleware from '../middlewares/player-auth-middleware'
 import PlayerAuthAPIService from '../services/api/player-auth-api.service'
+import continunityMiddleware from '../middlewares/continunity-middleware'
 
 export default (app: Koa) => {
   app.use(apiKeyMiddleware)
@@ -27,7 +29,9 @@ export default (app: Koa) => {
 
   app.use(currentPlayerMiddleware)
   app.use(playerAuthMiddleware)
+  app.use(continunityMiddleware)
 
+  app.use(service('/v1/health-check', new HealthCheckAPIService()))
   app.use(service('/v1/game-feedback', new GameFeedbackAPIService()))
   app.use(service('/v1/game-config', new GameConfigAPIService()))
   app.use(service('/v1/game-stats', new GameStatAPIService()))

src/middlewares/continunity-middleware.ts

@@ -0,0 +1,15 @@
+import { isValid } from 'date-fns'
+import { Context, Next } from 'koa'
+
+export default async (ctx: Context, next: Next): Promise<void> => {
+  const header = ctx.headers['x-talo-continuity-timestamp']
+
+  if (header) {
+    const date = new Date(Number(header))
+    if (isValid(date)) {
+      ctx.state.continuityDate = date
+    }
+  }
+
+  await next()
+}

src/migrations/20210725211129InitialMigration.ts

@@ -26,10 +26,6 @@ export class InitialMigration extends Migration {
     this.addSql('create table `player_alias` (`id` int unsigned not null auto_increment primary key, `service` varchar(255) not null, `identifier` varchar(255) not null, `player_id` varchar(255) null, `created_at` datetime not null, `updated_at` datetime not null) default character set utf8mb4 engine = InnoDB')
     this.addSql('alter table `player_alias` add index `player_alias_player_id_index`(`player_id`)')
 
-    this.addSql('create table `event` (`id` int unsigned not null auto_increment primary key, `name` varchar(255) not null, `props` json not null, `game_id` int(11) unsigned not null, `player_alias_id` int(11) unsigned not null, `created_at` datetime not null, `updated_at` datetime not null) default character set utf8mb4 engine = InnoDB')
-    this.addSql('alter table `event` add index `event_game_id_index`(`game_id`)')
-    this.addSql('alter table `event` add index `event_player_alias_id_index`(`player_alias_id`)')
-
     this.addSql('create table `apikey` (`id` int unsigned not null auto_increment primary key, `scopes` text not null, `game_id` int(11) unsigned not null, `created_by_user_id` int(11) unsigned not null, `created_at` datetime not null, `revoked_at` datetime null) default character set utf8mb4 engine = InnoDB')
     this.addSql('alter table `apikey` add index `apikey_game_id_index`(`game_id`)')
     this.addSql('alter table `apikey` add index `apikey_created_by_user_id_index`(`created_by_user_id`)')
@@ -46,9 +42,6 @@ export class InitialMigration extends Migration {
 
     this.addSql('alter table `player_alias` add constraint `player_alias_player_id_foreign` foreign key (`player_id`) references `player` (`id`) on delete cascade')
 
-    this.addSql('alter table `event` add constraint `event_game_id_foreign` foreign key (`game_id`) references `game` (`id`) on update cascade')
-    this.addSql('alter table `event` add constraint `event_player_alias_id_foreign` foreign key (`player_alias_id`) references `player_alias` (`id`) on update cascade')
-
     this.addSql('alter table `apikey` add constraint `apikey_game_id_foreign` foreign key (`game_id`) references `game` (`id`) on update cascade')
     this.addSql('alter table `apikey` add constraint `apikey_created_by_user_id_foreign` foreign key (`created_by_user_id`) references `user` (`id`) on update cascade')
   }

src/migrations/20211221195514CascadeDeletePlayerAliasEvents.ts

@@ -3,7 +3,6 @@ import { CreateDataExportsTable } from './20210926160859CreateDataExportsTable'
 import { CreateLeaderboardsTable } from './20211107233610CreateLeaderboardsTable'
 import { CreateUserTwoFactorAuthTable } from './20211205171927CreateUserTwoFactorAuthTable'
 import { CreateUserRecoveryCodeTable } from './20211209003017CreateUserRecoveryCodeTable'
-import { CascadeDeletePlayerAliasEvents } from './20211221195514CascadeDeletePlayerAliasEvents'
 import { AddLeaderboardEntryHiddenColumn } from './20211224154919AddLeaderboardEntryHiddenColumn'
 import { CreateGameSavesTable } from './20220109144435CreateGameSavesTable'
 import { CreateGameActivitiesTable } from './20220125220401CreateGameActivitiesTable'
@@ -49,10 +48,6 @@ export default [
     name: 'CreateUserRecoveryCodeTable',
     class: CreateUserRecoveryCodeTable
   },
-  {
-    name: 'CascadeDeletePlayerAliasEvents',
-    class: CascadeDeletePlayerAliasEvents
-  },
   {
     name: 'AddLeaderboardEntryHiddenColumn',
     class: AddLeaderboardEntryHiddenColumn

src/migrations/index.ts

@@ -0,0 +1,17 @@
+import { Response, Request, Routes } from 'koa-clay'
+import APIService from './api-service'
+
+@Routes([
+  {
+    method: 'GET'
+  }
+])
+export default class HealthCheckAPIService extends APIService {
+  async index(req: Request): Promise<Response> {
+    console.log(req.ctx.state.continuityDate)
+
+    return {
+      status: 200
+    }
+  }
+}

src/services/api/health-check-api.service.ts

@@ -0,0 +1,13 @@
+import request from 'supertest'
+import createAPIKeyAndToken from '../../../utils/createAPIKeyAndToken'
+
+describe('Health check API service - index', () => {
+  it('should return a 200', async () => {
+    const [, token] = await createAPIKeyAndToken([])
+
+    await request(global.app)
+      .get('/v1/health-check')
+      .auth(token, { type: 'bearer' })
+      .expect(204)
+  })
+})