Update Command process to support TaskEither

Author: Lan2u

src/commands/command.ts

@@ -1,8 +1,11 @@
 import {Type} from 'io-ts';
 import {DomainEvent} from '../types/domain-event';
 import * as O from 'fp-ts/Option';
+import * as TE from 'fp-ts/TaskEither';
 import {Actor} from '../types/actor';
 import {Resource} from '../types/resource';
+import { FailureWithStatus } from '../types/failure-with-status';
+import { Dependencies } from '../dependencies';
 
 export type WithActor<T> = T & {actor: Actor};
 
@@ -11,7 +14,8 @@ export type Command<T> = {
   process: (input: {
     command: WithActor<T>;
     events: ReadonlyArray<DomainEvent>;
-  }) => O.Option<DomainEvent>;
+    deps: Dependencies;
+  }) => TE.TaskEither<FailureWithStatus, O.Option<DomainEvent>>;
   decode: Type<T, T, unknown>['decode'];
   isAuthorized: (input: {
     actor: Actor;

src/commands/exclusion-events/exclude-event-form.ts

@@ -21,11 +21,13 @@ const renderForm = (viewModel: ViewModel) =>
   pipe(
     html`
       <h1>Exclude an event</h1>
-      <p>Are you sure you want to exclude (delete) this event? This form should only be used
+      <p>Are you sure you want to exclude (delete) this event? This form should only be used in limited circumstances.
       </p>
       ${renderEvent(viewModel.event.value)}
       <form action="/events/exclude-event" method="post">
         <input type="hidden" name="event_id" value="${viewModel.event.value.event_id}"/>
+        <label for="reason">Whats the reason for deleting this event?</label>
+        <input type="text" name="reason" id="reason" value="" minlength="3" required/>
         <button type="submit">Confirm</button>
       </form>
     `,

src/commands/exclusion-events/exclude-event.ts

@@ -1,16 +1,31 @@
 import * as t from 'io-ts';
 import * as tt from 'io-ts-types';
 import * as O from 'fp-ts/Option';
+import * as TE from 'fp-ts/TaskEither';
 import {Command} from '../command';
 import {isAdminOrSuperUser} from '../is-admin-or-super-user';
+import { pipe } from 'fp-ts/lib/function';
+import { FailureWithStatus, failureWithStatus } from '../../types/failure-with-status';
+import { StatusCodes } from 'http-status-codes';
 
 const codec = t.strict({
-  event_id: tt.UUID
+  event_id: tt.UUID,
+  reason: t.string,
 });
 
 export type ExcludeEvent = t.TypeOf<typeof codec>;
 
-const process: Command<ExcludeEvent>['process'] = () => O.none;
+const process: Command<ExcludeEvent>['process'] = input => pipe(
+  input.command.actor.tag === 'user'
+  ? TE.right<FailureWithStatus, number>(input.command.actor.user.memberNumber)
+  : TE.left(failureWithStatus('Unknown user', StatusCodes.BAD_REQUEST)()),
+  TE.chain(memberNumber => input.deps.excludeEvent(
+    input.command.event_id,
+    memberNumber,
+    input.command.reason,
+  )),
+  TE.map(() => O.none)
+);
 
 const resource = () => ({
   type: 'ExcludeEvent',

src/init-dependencies/event-store/exclude-event.ts

@@ -40,7 +40,7 @@ export const excludeEvent =
         ]
       ),
     failureWithStatus(
-      'Failed to execlude event',
+      'Failed to exclude event',
       StatusCodes.INTERNAL_SERVER_ERROR
     )
   );