feat: commandReverted from Processor (#61)

Fixes #60

lib/commands/Processor.ts

@@ -10,7 +10,8 @@ import { Transaction } from './Transaction'
  */
 export class Processor<TContext> {
   private stack = new ExecutionStack()
-  private commandExecutedEvent = new Event<Command<TContext, AnyResult>>()
+  public readonly commandExecuted = new Event<Command<TContext, AnyResult>>()
+  public readonly commandReverted = new Event<Command<TContext, AnyResult>>()
 
   /**
    * Initialize a new instance of the Processor class.
@@ -20,10 +21,6 @@ export class Processor<TContext> {
     public readonly context: TContext
   ) { }
 
-  get commandExecuted(): Event<Command<TContext, AnyResult>> {
-    return this.commandExecutedEvent
-  }
-
   /**
    * Excecute the command.
    * @param command Command to process.
@@ -54,6 +51,7 @@ export class Processor<TContext> {
 
     for (const command of commands) {
       await command.revert(this.context)
+      this.commandReverted.notify(command)
     }
     return new ProcessorResult(Ok())
   }

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@akdasa-studios/framework",
-  "version": "0.2.7",
+  "version": "0.2.8",
   "description": "Framework to build every app",
   "main": "dist/index.js",
   "typings": "dist/index.d.ts",

tests/commands/Processor.spec.ts

@@ -143,7 +143,6 @@ describe('Processor', () => {
     const command = new DivCommand(2)
     let lastCommand: Command<CalculatorContext, AnyResult>|undefined = undefined
     function commandHandler(command) {
-      console.log('OLOLO', command)
       lastCommand = command
     }
 
@@ -163,4 +162,29 @@ describe('Processor', () => {
       expect(lastCommand).toBeUndefined()
     })
   })
+
+  describe('.commandReverted', () => {
+    const command = new DivCommand(2)
+    let lastCommand: Command<CalculatorContext, AnyResult>|undefined = undefined
+    function commandHandler(command) {
+      lastCommand = command
+    }
+
+    beforeEach(async () => {
+      lastCommand = undefined
+      processor.commandReverted.subscribe(commandHandler)
+      await processor.execute(command)
+    })
+
+    it('notifies subscribers', async () => {
+      await processor.revert()
+      expect(lastCommand).not.toBeUndefined()
+    })
+
+    it('notifies subscribers', async () => {
+      processor.commandReverted.unsubscribe(commandHandler)
+      await processor.revert()
+      expect(lastCommand).toBeUndefined()
+    })
+  })
 })