Decode the rest of the notification

package.json

@@ -9,12 +9,14 @@
     "@effect/platform-node": "^0.33.5",
     "@effect/schema": "^0.51.3",
     "@js-temporal/polyfill": "^0.4.4",
+    "doi-regex": "^0.1.13",
     "effect": "^2.0.0-next.58",
     "ioredis": "^5.3.2"
   },
   "devDependencies": {
     "@trivago/prettier-plugin-sort-imports": "^4.3.0",
     "@tsconfig/node20": "^20.1.2",
+    "@types/doi-regex": "^0.1.3",
     "@types/node": "^20.10.3",
     "@typescript-eslint/eslint-plugin": "^6.13.1",
     "@typescript-eslint/parser": "^6.13.1",

src/CoarNotify.ts

@@ -1,9 +1,31 @@
 import { Schema } from '@effect/schema'
+import * as Doi from './Doi.js'
+import * as Url from './Url.js'
 
 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,
+  type: Schema.tuple(Schema.literal('Offer'), Schema.literal('coar-notify:ReviewAction')),
+  origin: Schema.struct({
+    id: Url.UrlFromStringSchema(Schema.string),
+    inbox: Url.UrlFromStringSchema(Schema.string),
+    type: Schema.literal('Organization', 'Service'),
+  }),
+  target: Schema.struct({
+    id: Url.UrlFromStringSchema(Schema.string),
+    inbox: Url.UrlFromStringSchema(Schema.string),
+    type: Schema.literal('Organization', 'Service'),
+  }),
+  object: Schema.struct({
+    id: Schema.string,
+    'ietf:cite-as': Doi.DoiUrlSchema,
+  }),
+  actor: Schema.struct({
+    id: Url.UrlFromStringSchema(Schema.string),
+    type: Schema.literal('Application', 'Group', 'Organization', 'Person', 'Service'),
+    name: Schema.string,
+  }),
 })

src/Doi.ts

@@ -0,0 +1,32 @@
+import { ParseResult, Schema } from '@effect/schema'
+import doiRegex from 'doi-regex'
+import { Brand, Either, type Option, type Predicate, String, flow } from 'effect'
+
+export type Doi = Brand.Branded<string, 'Doi'>
+
+const isDoi: Predicate.Refinement<unknown, Doi> = (u): u is Doi =>
+  typeof u === 'string' && doiRegex({ exact: true }).test(u) && !u.endsWith('/.') && !u.endsWith('/..')
+
+export const Doi = Brand.refined<Doi>(isDoi, s => Brand.error(`Expected ${s} to be a DOI`))
+
+const toUrl: (doi: Doi) => URL = doi => {
+  const url = new URL('https://doi.org')
+  url.pathname = doi.replace(/\/(\.{1,2})\//g, '/$1%2F').replace(/\\/g, '%5C')
+
+  return url
+}
+
+const parse: (s: string) => Option.Option<Doi> = flow(
+  String.trim,
+  String.replace(/^(?:https?:\/\/(?:dx\.)?doi\.org\/|doi:)?/i, ''),
+  s => Doi.option(s),
+)
+
+export const DoiSchema = Schema.string.pipe(Schema.fromBrand(Doi))
+
+export const DoiUrlSchema: Schema.Schema<string, Doi> = Schema.transformOrFail(
+  Schema.string,
+  Schema.to(DoiSchema),
+  s => Either.fromOption(parse(s), () => ParseResult.parseError([ParseResult.type(DoiSchema.ast, s)])),
+  doi => ParseResult.succeed(toUrl(doi).href),
+)

src/Url.ts

@@ -0,0 +1,16 @@
+import { ParseResult, Schema } from '@effect/schema'
+
+export const UrlSchema: Schema.Schema<URL> = Schema.instanceOf(URL)
+
+export const UrlFromStringSchema = <I, A extends string>(self: Schema.Schema<I, A>): Schema.Schema<I, URL> =>
+  Schema.transformOrFail(
+    self,
+    UrlSchema,
+    (s, _, ast) =>
+      ParseResult.try({
+        try: () => new URL(s),
+        catch: () => ParseResult.parseError([ParseResult.type(ast, s)]),
+      }),
+    url => ParseResult.succeed(url.href),
+    { strict: false },
+  )