Service and identifier cannot be empty

src/services/api/player-api.service.ts

@@ -1,5 +1,5 @@
 import { EntityManager } from '@mikro-orm/mysql'
-import { Request, Response, Routes, Validate, HasPermission, ForwardTo, forwardRequest } from 'koa-clay'
+import { Request, Response, Routes, Validate, HasPermission, ForwardTo, forwardRequest, ValidationCondition } from 'koa-clay'
 import APIKey, { APIKeyScope } from '../../entities/api-key'
 import Player from '../../entities/player'
 import GameSave from '../../entities/game-save'
@@ -70,6 +70,15 @@ export async function createPlayerFromIdentifyRequest(
   }
 }
 
+function validateIdentifyQueryParam(param: 'service' | 'identifier') {
+  return async (val?: string): Promise<ValidationCondition[]> => [
+    {
+      check: val.trim().length > 0,
+      error: `Invalid ${param}, must be a non-empty string`
+    }
+  ]
+}
+
 @Routes([
   {
     method: 'GET',
@@ -90,7 +99,16 @@ export async function createPlayerFromIdentifyRequest(
 ])
 export default class PlayerAPIService extends APIService {
   @Validate({
-    query: ['service', 'identifier']
+    query: {
+      service: {
+        required: true,
+        validation: validateIdentifyQueryParam('service')
+      },
+      identifier: {
+        required: true,
+        validation: validateIdentifyQueryParam('identifier')
+      }
+    }
   })
   @HasPermission(PlayerAPIPolicy, 'identify')
   @ForwardTo('games.players', 'post')

tests/services/_api/player-api/identify.test.ts

@@ -124,4 +124,76 @@ describe('Player API service - identify', () => {
 
     expect(res.body).toStrictEqual({ message: 'Player not found: Talo aliases must be created using the /v1/players/auth API' })
   })
+
+  it('should require the service to be set', async () => {
+    const [apiKey, token] = await createAPIKeyAndToken([APIKeyScope.READ_PLAYERS])
+    const player = await new PlayerFactory([apiKey.game]).one()
+    await (<EntityManager>global.em).persistAndFlush(player)
+
+    const res = await request(global.app)
+      .get('/v1/players/identify')
+      .query({ identifier: player.aliases[0].identifier })
+      .auth(token, { type: 'bearer' })
+      .expect(400)
+
+    expect(res.body).toStrictEqual({
+      errors: {
+        service: ['service is missing from the request query']
+      }
+    })
+  })
+
+  it('should require the service to be a non-empty string', async () => {
+    const [apiKey, token] = await createAPIKeyAndToken([APIKeyScope.READ_PLAYERS])
+    const player = await new PlayerFactory([apiKey.game]).one()
+    await (<EntityManager>global.em).persistAndFlush(player)
+
+    const res = await request(global.app)
+      .get('/v1/players/identify')
+      .query({ service: '', identifier: player.aliases[0].identifier })
+      .auth(token, { type: 'bearer' })
+      .expect(400)
+
+    expect(res.body).toStrictEqual({
+      errors: {
+        service: ['Invalid service, must be a non-empty string']
+      }
+    })
+  })
+
+  it('should require the identifier to be set', async () => {
+    const [apiKey, token] = await createAPIKeyAndToken([APIKeyScope.READ_PLAYERS])
+    const player = await new PlayerFactory([apiKey.game]).one()
+    await (<EntityManager>global.em).persistAndFlush(player)
+
+    const res = await request(global.app)
+      .get('/v1/players/identify')
+      .query({ service: player.aliases[0].service })
+      .auth(token, { type: 'bearer' })
+      .expect(400)
+
+    expect(res.body).toStrictEqual({
+      errors: {
+        identifier: ['identifier is missing from the request query']
+      }
+    })
+  })
+
+  it('should require the identifier to be a non-empty string', async () => {
+    const [apiKey, token] = await createAPIKeyAndToken([APIKeyScope.READ_PLAYERS])
+    const player = await new PlayerFactory([apiKey.game]).one()
+    await (<EntityManager>global.em).persistAndFlush(player)
+
+    const res = await request(global.app)
+      .get('/v1/players/identify')
+      .query({ service: player.aliases[0].service, identifier: '' })
+      .auth(token, { type: 'bearer' })
+      .expect(400)
+
+    expect(res.body).toStrictEqual({
+      errors: {
+        identifier: ['Invalid identifier, must be a non-empty string']
+      }
+    })
+  })
 })