Merge pull request 'make scoped' (#12) from 1.1.4 into main

Reviewed-on: #12

index.js

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

interactor.js

@@ -1,52 +1,81 @@
-import { Stream } from './stream.js';
+import { Stream } from "stream";
 
 export class Interactor {
-  _actions = new Stream();
-  _reactions = new Stream();
-  _latestReaction;
+  #actions = new Stream();
+  #reactions = new Stream();
+  #latestReaction;
+  #latestReactions = {};
 
   constructor(initialReaction = new Reaction()) {
-    this._latestReactions = {};
-    this._actions.listen((action) => this._interaction(action));
+    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);
+    if (!(action instanceof Action)) throw "invalid action";
+    this.#actions.add(action);
   }
 
   observe(reactionHandler, provideLatestReaction = true) {
-    if (provideLatestReaction) reactionHandler(this._latestReaction);
+    if (provideLatestReaction) reactionHandler(this.#latestReaction);
     let listener = (reaction) => {
-      if (!(reaction instanceof Reaction)) throw 'invalid reaction';
+      if (!(reaction instanceof Reaction)) throw "invalid reaction";
       reactionHandler(reaction);
     };
-    this._reactions.listen(listener);
+    this.#reactions.listen(listener);
     return listener;
   }
 
   ignore(listener) {
-    this._reactions.ignore(listener);
+    this.#reactions.ignore(listener);
   }
 
-  _interaction(action) {}
-
   _react(reaction) {
-    if (!(reaction instanceof Reaction)) throw 'invalid reaction';
-    let latest = this._latestReactions[reaction.constructor.name];
+    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);
+      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.json

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