Adding routes and controllers for reading data

src/controllers/readController.ts

@@ -0,0 +1,22 @@
+import { getOrbisContext } from '@/utils/context.js'
+import { Request, Response, NextFunction } from 'express'
+
+const readValidations = async (_req: Request, res: Response, next: NextFunction): Promise<void> => {
+  try {
+    const { orbis, table, context } = await getOrbisContext()
+    const validationResults = await orbis.select().from(table).context(context).run()
+
+    res.locals = {
+      ...res.locals,
+      validations: validationResults.rows.length ? validationResults.rows : null,
+    }
+    return next()
+  } catch (error) {
+    console.error(error)
+    next(error)
+  }
+}
+
+export const readController = {
+  readValidations,
+}

src/index.ts

@@ -1,6 +1,6 @@
 import express, { json, Request, Response, NextFunction } from 'express'
 import cors from 'cors'
-import writeRouter from './routes/write.js'
+import router from './routes/all.js'
 
 const app = express()
 const port = process.env.PORT || 8080
@@ -22,7 +22,7 @@ const allowCrossDomain = (_req: Request, res: Response, next: NextFunction) => {
 
 app.use(allowCrossDomain)
 
-app.use('/', writeRouter)
+app.use('/', router)
 
 app.listen(port, () => {
   console.log(`server started at http://localhost:${port}`)

src/routes/all.ts

@@ -0,0 +1,41 @@
+import { RequestHandler, Request, Response, Router } from 'express'
+import { writeController } from '@/controllers/writeController.js'
+import { readController } from '@/controllers/readController.js'
+
+const router: Router = Router()
+
+type PostResponse = Response & {
+  locals: {
+    validationUpdate: unknown
+    streamID: string
+  }
+}
+
+type ReadResponse = Response & {
+  locals: {
+    validations: unknown
+  }
+}
+
+router.post(
+  '/write',
+  writeController.writeValidation as RequestHandler,
+  (_req: Request, res: PostResponse) => {
+    return res.json({
+      validationUpdate: res.locals.validationUpdate,
+      streamID: res.locals.streamID,
+    })
+  },
+)
+
+router.get(
+  '/read',
+  readController.readValidations as RequestHandler,
+  (_req: Request, res: ReadResponse) => {
+    return res.json({
+      validations: res.locals.validations,
+    })
+  },
+)
+
+export default router