feat: Graphql layer

api/package.json

@@ -62,6 +62,7 @@
     "kafkajs": "^2.2.4",
     "koa": "^2.14.2",
     "koa-bodyparser": "^4.4.0",
+    "koa-graphql": "^0.12.0",
     "koa-logger": "^3.2.1",
     "koa-mount": "^4.0.0",
     "koa-static": "^5.0.0",

api/src/api.ts

@@ -17,6 +17,9 @@ import updateHandler from '@pokemon/handlers/update.handler';
 import healthcheckHandler from '@pokemon/handlers/healthcheck.handler';
 import { setupSequelize } from '@pokemon/utils/db';
 import { instrumentRoute } from '@pokemon/middlewares/instrumentation';
+import { graphqlHTTP } from 'koa-graphql';
+import schema from './schema';
+import resolvers from './graphql/resolvers';
 
 const { APP_PORT = 8081 } = process.env;
 
@@ -53,6 +56,7 @@ async function startApp() {
 
   ui.use(serve(resolve(__dirname, './ui')));
   app.use(mount('/', ui));
+  app.use(mount('/graphql', graphqlHTTP({ schema, rootValue: resolvers, graphiql: true })));
 
   console.log(`Starting server on port ${APP_PORT}`);
   app.listen(APP_PORT);

api/src/graphql/create.resolver.ts

@@ -0,0 +1,9 @@
+import { getPokemonRepository, Pokemon } from '@pokemon/repositories';
+
+const create = async (raw: Pokemon): Promise<Pokemon> => {
+  const repository = getPokemonRepository();
+
+  return repository.create(new Pokemon(raw));
+};
+
+export default create;

api/src/graphql/get.resolver.ts

@@ -0,0 +1,20 @@
+import { getPokemonRepository, Pokemon } from '@pokemon/repositories';
+import { SearchOptions } from '../repositories/pokemon.repository';
+
+type PokemonList = {
+  items: Pokemon[];
+  totalCount: number;
+};
+
+const get = async (query: SearchOptions): Promise<PokemonList> => {
+  const repository = getPokemonRepository();
+
+  const [items, totalCount] = await Promise.all([repository.findMany(query), repository.count()]);
+
+  return {
+    items,
+    totalCount,
+  };
+};
+
+export default get;

api/src/graphql/import.resolver.ts

@@ -0,0 +1,13 @@
+import PokeAPIService from '@pokemon/services/pokeApi.service';
+import PokemonSyncronizer from '@pokemon/services/pokemonSyncronizer.service';
+
+const pokeApiService = new PokeAPIService();
+const pokemonSyncronizer = PokemonSyncronizer(pokeApiService);
+
+const importPokemon = async ({ id = 0 }) => {
+  await pokemonSyncronizer.queue({ id });
+
+  return { id };
+};
+
+export default importPokemon;

api/src/graphql/resolvers.ts

@@ -0,0 +1,9 @@
+import createPokemon from './create.resolver';
+import getPokemonList from './get.resolver';
+import importPokemon from './import.resolver';
+
+export default {
+  getPokemonList,
+  createPokemon,
+  importPokemon,
+};

api/src/repositories/pokemon.repository.ts

@@ -1,5 +1,3 @@
-import { PokemonModel } from './pokemon.sequelize.repository';
-
 export class Pokemon {
   public id?: number;
   public name: string;

api/src/schema.ts

@@ -0,0 +1,31 @@
+import { buildSchema } from 'graphql';
+
+const schema = buildSchema(`
+  type Pokemon {
+    id: Int
+    name: String!
+    type: String!
+    isFeatured: Boolean!
+    imageUrl: String
+  }
+
+  type PokemonList {
+    items: [Pokemon]
+    totalCount: Int
+  }
+
+  type ImportPokemon {
+    id: Int!
+  }
+
+  type Query {
+    getPokemonList(where: String, skip: Int, take: Int): PokemonList
+  }
+
+  type Mutation {
+    createPokemon(name: String!, type: String!, isFeatured: Boolean!, imageUrl: String): Pokemon!
+    importPokemon(id: Int!): ImportPokemon!
+  }
+`);
+
+export default schema;