squash everything since there was profanity in the commit log and maybe people won't like thatHEADmain

5 files changed, 124 insertions, 0 deletions

diff --git a/src/api/Chessh.ts b/src/api/Chessh.ts
new file mode 100644
index 0000000..7a35444
--- /dev/null
+++ b/src/api/Chessh.ts
@@ -0,0 +1,18 @@
+export interface BotMoveRequest {
+  bot_id: number;
+  bot_name: string;
+  game_id: number;
+  fen: string;
+  turn: string;
+  bot_turn: boolean;
+  last_move: string;
+  status: string;
+}
+
+export interface BotMoveAttempt {
+  attempted_move: string;
+}
+
+export interface BotMoveResponse {
+  message: string;
+}
diff --git a/src/api/index.ts b/src/api/index.ts
new file mode 100644
index 0000000..c55bb21
--- /dev/null
+++ b/src/api/index.ts
@@ -0,0 +1,57 @@
+import express from 'express';
+import {
+  BotMoveRequest,
+  BotMoveAttempt,
+  BotMoveResponse,
+} from './Chessh';
+import axios from 'axios';
+import { aiMove } from 'js-chess-engine';
+
+const router = express.Router();
+
+const chesshMovePath = (gameId: number) =>
+  process.env.CHESSH_MOVE_PATH!.replace(
+    ':gameId',
+    gameId.toString(),
+  );
+
+const sendNextMove = (gameId: number, move: string): Promise<BotMoveResponse> =>
+  axios
+    .post(chesshMovePath(gameId), {
+      attempted_move: move.toLowerCase(),
+    } as BotMoveAttempt, {
+      headers: {
+        "authorization": process.env.BOT_TOKEN!
+      }
+    })
+    .then((r): BotMoveResponse => {
+      const body = r.data as BotMoveResponse;
+      if (r.status === 200) {
+        return body;
+      }
+      throw new Error(
+        'Move request unsuccessful, got back from cheSSH: ' +
+          JSON.stringify(body),
+      );
+    });
+
+router.post<BotMoveRequest, string>('/move', async (req, res) => {
+  const updateMessages: BotMoveRequest[] = Array.isArray(req.body)
+    ? req.body
+    : [req.body];
+
+  for (const update of updateMessages) {
+    if (update.bot_turn) {
+      const move = aiMove(update.fen, 3);
+
+      const moveFrom = Object.keys(move)[0];
+      const moveTo = move[moveFrom];
+
+      await sendNextMove(update.game_id, moveFrom + moveTo);
+    }
+  }
+
+  res.status(200).send('OK');
+});
+
+export default router;
diff --git a/src/app.ts b/src/app.ts
new file mode 100644
index 0000000..7fc395f
--- /dev/null
+++ b/src/app.ts
@@ -0,0 +1,24 @@
+import express from 'express';
+import morgan from 'morgan';
+import helmet from 'helmet';
+import cors from 'cors';
+
+import * as middlewares from './middlewares';
+import api from './api';
+
+import * as dotenv from 'dotenv';
+dotenv.config();
+
+const app = express();
+
+app.use(morgan('dev'));
+app.use(helmet());
+app.use(cors());
+app.use(express.json());
+
+app.use('/api', api);
+
+app.use(middlewares.notFound);
+app.use(middlewares.errorHandler);
+
+export default app;
diff --git a/src/index.ts b/src/index.ts
new file mode 100644
index 0000000..6265d20
--- /dev/null
+++ b/src/index.ts
@@ -0,0 +1,8 @@
+import app from './app';
+
+const port = process.env.PORT || 4200;
+app.listen(port, () => {
+  /* eslint-disable no-console */
+  console.log(`Listening: http://localhost:${port}`);
+  /* eslint-enable no-console */
+});
diff --git a/src/middlewares.ts b/src/middlewares.ts
new file mode 100644
index 0000000..dc98a6c
--- /dev/null
+++ b/src/middlewares.ts
@@ -0,0 +1,17 @@
+import { NextFunction, Request, Response } from 'express';
+
+export function notFound(req: Request, res: Response, next: NextFunction) {
+  res.status(404);
+  const error = new Error(`🔍 - Not Found - ${req.originalUrl}`);
+  next(error);
+}
+
+// eslint-disable-next-line @typescript-eslint/no-unused-vars
+export function errorHandler(err: Error, req: Request, res: Response<{message: string, stack?: string | any[]}>, next: NextFunction) {
+  const statusCode = res.statusCode !== 200 ? res.statusCode : 500;
+  res.status(statusCode);
+  res.json({
+    message: err.message,
+    stack: process.env.NODE_ENV === 'production' ? '🥞' : err.stack,
+  });
+}