Updated functions to be more in line with erlang and elixir function calls

Author: bryanjos

README.md

@@ -1,8 +1,5 @@
 Experiment to reproduce Erlang style processes in browser. The api follows the one from Erlang. All are found on the `ProcessSystem` class
 
-One example is an implementation of a GenServer. The other example is 2 processes talking
-to each other.
-
 #### Usage
 
 * First, import the ProcessSystem create a new instance of one.
@@ -49,8 +46,9 @@ to each other.
     * `link(pid) : void` - links the current process with the process from the given pid
     * `unlink(pid) : void` - unlinks the current process from the process from the given pid
     * `register(name, pid) : void` - registers the given name to the pid
-    * `registered(name) : pid` - returns the pid registered by the given name or null if not registered
+    * `whereis(name) : pid` - returns the pid registered by the given name or null if not registered
     * `unregister(pid) : void` - unregisters the names associated with the pid
+    * `registered() : Array` - returns the liast of names that are registered
     * `pid()` : pid` - returns the current process's pid
     * `pidof(obj) : pid` - takes the input and tries to find the pid. Input can be a `pid`, `Process`, or name the pid is associated with
     * `send(pid, msg) : msg` - sends a message the the process represented by the pid
@@ -59,61 +57,18 @@ to each other.
     * `exit(reason)` - terminates the current process with the given reason.
     * `exit(pid, reason)` - tells the process with the pid to exit with the given reason
     * `error(reason)` - terminates the current process with an error
+    * `process_flag(pid, flag, value)` - Sets flags on the given process.
     * `process_flag(flag, value)` - Sets flags on the current process.
         * Note: the only flag respected is the `Symbol.for("trap_exit")` flag. If value is `true`, then exit signals from linked processes are turned into messages and sent to the current processes mailbox. If value is `false`, the exit is treated as normal and terminates the process. Setting it to `true` is useful for supervising processes.
     * `put(key, value)` - Adds a value to the current process's dictionary
-    * `get(key)` - Gets a value from the current process's dictionary
-    * `get()` - Gets the current process's dictionary
+    * `get(key, default_value = null)` - Gets a value from the current process's dictionary or the default if key not in dictionary
+    * `get_process_dict()` - Gets the current process's dictionary
     * `get_keys()` - Gets all the keys from the current process's dictionary
-    * `erase(key)` - Removes the key and the associated value from the current process`s dictionary
+    * `get_keys(value)` - Gets all the keys from the current process's dictionary with the given value
+    * `erase(key)` - Removes the key and the associated value from the current process's dictionary
     * `erase()` - Removes all entries from the current process's dictionary
+    * `is_alive(pid)` - Returns if the given pid is alive
+    * `make_ref()` - Returns a unique reference
+    * `list()` - Returns a list of all the pids
 
 * `ProcessSystem.run(fun, args, context = null)` - A static generator function used to wrap a normal function or generator. If fun is a function, it returns the value, if it's a generator, then it delegates yielding to the generator.
-
-* GenServer
-    * `start(module, args)` - Starts a GenServer with the given module and args
-    * `start_link(module, args)` - Starts a GenServer with the given module and args
-    * `call* (server, action)` - Sends the GenServer a action and waits for it to respond with a value.
-    * `cast* (server, action)` - Sends the GenServer a action to update a value.
-    * `stop (server)` - Stops the GenServer.
-    * **Note**: Genserver expects a module the has the following functions:
-        * `init(args)` - Must return an array containing a symbol and the initial state
-        * `handle_call(action, from, state)` - Called when `GenServer.call` is called. This function is given the action, the pid of the calling process, and the current state. Must return `[reply, return_value, new_state]` where reply is a symbol ,usually `Symbol.for("reply"), the value to return to the process, and lastly, the new state of the GenServer.
-        * `handle_cast(action, state)` - Called when `GenServer.cast` is called. his function is given the action, and the current state. Must return `[reply, return_value, new_state]` where reply is a symbol ,usually `Symbol.for("noreply")`, and lastly, the new state of the GenServer.
-
-#### GenServer Example
-
-An example of a Stack using a GenServer
-
-```javascript
-const Processes = require("erlang-processes");
-self.system = self.system || new Processes.default.ProcessSystem();
-
-const Stack = {
-  init: function(args){
-    return [Symbol.for("ok"), args];
-  },
-
-  handle_call: function(action, pid, state){
-    return [Symbol.for("reply"), state[0], state.slice(1)];
-  },
-
-
-  handle_cast: function(action, state){
-    return [Symbol.for("noreply"), [action[1]].concat(state)];
-  }
-}
-
-self.system.spawn(function*(){
-  const [ok, pid] = yield* ProcessSystem.run(GenServer.start, [Stack, ["hello"]]);
-
-  let a = yield* ProcessSystem.run(GenServer.call, [pid, "pop"]);
-  console.log(a); // "hello"
-
-  let b = yield* ProcessSystem.run(GenServer.cast, [pid, ["push", "world"]]);
-  console.log(b); // Symbol.for("ok")
-
-  let c = yield* ProcessSystem.run(GenServer.call, [pid, "pop"]);
-  console.log(c); // "world"
-});
-```

examples/gen_server.html

@@ -1,6 +1,6 @@
 {
   "name": "erlang-processes",
-  "version": "1.0.2",
+  "version": "2.0.0",
   "description": "Erlang style processes in JavaScript",
     "main": "lib/processes.js",
     "jsnext:main": "src/index.js",

examples/gen_server.js

@@ -2,6 +2,5 @@ import ProcessSystem from "./processes/process_system";
 import GenServer from "./processes/otp/gen_server";
 
 export default {
-  ProcessSystem,
-  GenServer
+  ProcessSystem
 };

package.json

@@ -43,9 +43,9 @@ class Process {
     let machine = this.main();
 
     this.system.schedule(function() {
-      function_scope.system.set_current(function_scope.pid); 
-      function_scope.run(machine, machine.next()); 
-    }, this.pid);  
+      function_scope.system.set_current(function_scope.pid);
+      function_scope.run(machine, machine.next());
+    }, this.pid);
   }
 
   *main() {
@@ -62,7 +62,9 @@ class Process {
   }
 
   process_flag(flag, value){
+    const old_value = this.flags[flag];
     this.flags[flag] = value;
+    return old_value;
   }
 
   is_trapping_exits(){
@@ -89,7 +91,9 @@ class Process {
           break;
         }
       }catch(e){
-        this.exit(e);
+        if(e.constructor.name != "MatchError"){
+          this.exit(e);
+        }
       }
     }
 
@@ -105,43 +109,43 @@ class Process {
       if(is_sleep(value)){
 
         this.system.delay(function() {
-          function_scope.system.set_current(function_scope.pid); 
-          function_scope.run(machine, machine.next()); 
+          function_scope.system.set_current(function_scope.pid);
+          function_scope.run(machine, machine.next());
         }, value[1]);
 
       }else if(is_receive(value) && receive_timed_out(value)){
 
         let result = value[3]();
 
-        this.system.schedule(function() { 
-          function_scope.system.set_current(function_scope.pid); 
-          function_scope.run(machine, machine.next(result)); 
+        this.system.schedule(function() {
+          function_scope.system.set_current(function_scope.pid);
+          function_scope.run(machine, machine.next(result));
         });
 
       }else if(is_receive(value)){
 
         let result = function_scope.receive(value[1]);
 
         if(result === States.NOMATCH){
-          this.system.suspend(function() { 
-            function_scope.system.set_current(function_scope.pid); 
-            function_scope.run(machine, step); 
-          });         
+          this.system.suspend(function() {
+            function_scope.system.set_current(function_scope.pid);
+            function_scope.run(machine, step);
+          });
         }else{
-          this.system.schedule(function() { 
-            function_scope.system.set_current(function_scope.pid); 
-            function_scope.run(machine, machine.next(result)); 
-          });          
+          this.system.schedule(function() {
+            function_scope.system.set_current(function_scope.pid);
+            function_scope.run(machine, machine.next(result));
+          });
         }
 
       }else{
-        this.system.schedule(function() { 
-          function_scope.system.set_current(function_scope.pid); 
-          function_scope.run(machine, machine.next(value)); 
-        });  
+        this.system.schedule(function() {
+          function_scope.system.set_current(function_scope.pid);
+          function_scope.run(machine, machine.next(value));
+        });
       }
     }
   }
 }
 
-export default Process;
+export default Process;