Merge pull request 'added better error handling for missing action handlers' (#11) from 1.1.3 into main

Reviewed-on: #11

.gitea/workflows/push_to_main.yaml

@@ -17,4 +17,4 @@ jobs:
         uses: https://git.thorup.us/actions/npm_publish@v1
         with:
           npm_repo_key: ${{ secrets.NPM_REPO_KEY }}
-          npm_repo_domain: "npm.thorup.us"
+          npm_repo_domain: ${{ vars.NPM_REPO_DOMAIN }}

index.js

@@ -1,2 +0,0 @@
-import { Interactor, Action, Reaction } from "./src/interactor.js";
-export { Interactor, Action, Reaction };

interactor.js

@@ -0,0 +1,81 @@
+import { Stream } from "stream";
+
+export class Interactor {
+  #actions = new Stream();
+  #reactions = new Stream();
+  #latestReaction;
+  #latestReactions = {};
+
+  constructor(initialReaction = new Reaction()) {
+    this.#actions.listen((action) => {
+      let funcRef = `_handle${action.constructor.name}`;
+      if (!this[funcRef])
+        throw `${this.constructor.name} does not have a handler defined for the action "${action.constructor.name}". Create one by adding a function definition named "${funcRef}" in the ${this.constructor.name} class.`;
+      this[funcRef](action);
+    });
+    this._react(initialReaction);
+  }
+
+  act(action) {
+    if (!(action instanceof Action)) throw "invalid action";
+    this.#actions.add(action);
+  }
+
+  observe(reactionHandler, provideLatestReaction = true) {
+    if (provideLatestReaction) reactionHandler(this.#latestReaction);
+    let listener = (reaction) => {
+      if (!(reaction instanceof Reaction)) throw "invalid reaction";
+      reactionHandler(reaction);
+    };
+    this.#reactions.listen(listener);
+    return listener;
+  }
+
+  ignore(listener) {
+    this.#reactions.ignore(listener);
+  }
+
+  _react(reaction) {
+    if (!(reaction instanceof Reaction)) throw "invalid reaction";
+    let latest = this.#latestReactions[reaction.constructor.name];
+    if (!reaction.equals(latest)) {
+      this.#latestReaction = reaction;
+      this.#latestReactions[reaction.constructor.name] = reaction;
+      this.#reactions.add(reaction);
+    }
+  }
+}
+
+export class Action {}
+
+export class ActionBundle {
+  add(action) {
+    if (!(action.prototype instanceof Action)) {
+      throw "Only classes extended by `Action` can be added to a `ActionBundle`";
+    }
+    let actionName = action.name;
+    this[`#${actionName}`] = action;
+    Object.defineProperty(this, actionName, {
+      get: () => this[`#${actionName}`],
+    });
+  }
+}
+
+export class Reaction {
+  equals(reaction) {
+    return false;
+  }
+}
+
+export class ReactionBundle {
+  add(reaction) {
+    if (!(reaction.prototype instanceof Reaction)) {
+      throw "Only classes extended by `Reaction` can be added to a `ReactionBundle`";
+    }
+    let reactionName = reaction.name;
+    this[`#${reactionName}`] = reaction;
+    Object.defineProperty(this, reactionName, {
+      get: () => this[`#${reactionName}`],
+    });
+  }
+}

package-lock.json

@@ -0,0 +1,20 @@
+{
+  "name": "interactor",
+  "version": "1.0.4",
+  "lockfileVersion": 3,
+  "requires": true,
+  "packages": {
+    "": {
+      "name": "interactor",
+      "version": "1.0.4",
+      "dependencies": {
+        "stream": "^1.0.0"
+      }
+    },
+    "node_modules/stream": {
+      "version": "1.0.0",
+      "resolved": "https://git.thorup.us/api/packages/bryce/npm/stream/-/1.0.0/stream-1.0.0.tgz",
+      "integrity": "sha512-JGDjmgbnZcPCiQUxsboU7UufAryyivajDR3sCD790N/xfGpzlfl7OpPXf7EodDc43ojE+8dU8c3MOGbsH/Er4g=="
+    }
+  }
+}

package.json

@@ -1,8 +1,11 @@
 {
   "name": "interactor",
-  "version": "1.0.1",
+  "version": "1.1.3",
   "description": "Cross-element communications and state management utility.",
   "author": "Bryce Thorup",
   "type": "module",
-  "main": "index.js"
+  "main": "interactor.js",
+  "dependencies": {
+    "stream": "^1.0.1"
+  }
 }