Start decoding notification input

package.json

@@ -7,6 +7,7 @@
   "type": "module",
   "dependencies": {
     "@effect/platform-node": "^0.33.5",
+    "@effect/schema": "^0.51.3",
     "effect": "^2.0.0-next.58"
   },
   "devDependencies": {

src/CoarNotify.ts

@@ -0,0 +1,9 @@
+import { Schema } from '@effect/schema'
+
+export const ReviewActionSchema = Schema.struct({
+  '@context': Schema.tuple(
+    Schema.literal('https://www.w3.org/ns/activitystreams'),
+    Schema.literal('https://purl.org/coar/notify'),
+  ),
+  id: Schema.string,
+})

src/index.ts

@@ -1,10 +1,23 @@
 import { HttpServer, Runtime } from '@effect/platform-node'
 import { Effect, Layer } from 'effect'
 import { createServer } from 'node:http'
+import * as CoarNotify from './CoarNotify.js'
 
 const serve = HttpServer.router.empty.pipe(
   HttpServer.router.get('/health', HttpServer.response.json({ status: 'ok' })),
-  HttpServer.router.post('/inbox', HttpServer.response.empty({ status: 503 })),
+  HttpServer.router.post(
+    '/inbox',
+    Effect.gen(function* (_) {
+      yield* _(HttpServer.request.schemaBodyJson(CoarNotify.ReviewActionSchema))
+
+      return yield* _(HttpServer.response.empty({ status: 503 }))
+    }).pipe(
+      Effect.catchTags({
+        ParseError: () => HttpServer.response.empty({ status: 400 }),
+        RequestError: () => HttpServer.response.empty({ status: 400 }),
+      }),
+    ),
+  ),
   Effect.catchTag('RouteNotFound', () => HttpServer.response.empty({ status: 404 })),
   HttpServer.server.serve(HttpServer.middleware.logger),
 )

test.json

@@ -0,0 +1,25 @@
+{
+  "id": "10.1111/234567",
+  "updated": "2023-08-09T17:01:32.340000",
+  "@context": ["https://www.w3.org/ns/activitystreams", "https://purl.org/coar/notify"],
+  "type": ["Offer", "coar-notify:ReviewAction"],
+  "origin": {
+    "id": "https://www.repo.org",
+    "inbox": "https://api.repo.org/inbox",
+    "type": "Service"
+  },
+  "target": {
+    "id": "https://www.review-service.org",
+    "inbox": "https://api.review-service.org/inbox",
+    "type": "Service"
+  },
+  "object": {
+    "id": "10.1101/234567",
+    "ietf:cite-as": "https://doi.org/10.1101/234567"
+  },
+  "actor": {
+    "id": "mailto:[email protected]",
+    "type": "Person",
+    "name": "Chris Wilkinson"
+  }
+}