kianenigma

/project-dir
  - client.js
  - worker.js
  - front.js
  - xyz.json
  // and probably:
  - node_modules
  - package.json
  - /log
    - front@127.0.0.1:4000.log

kianenigma

{
  "nodes": [
    {
      "path": "./front.js",
      "port": 4000,
      "stdio": "file"
    },
    {
      "path": "./client.js",
      "port": 5000,

kianenigma

$npm install -g xyz-cli

kianenigma

front.call({
  servicePath: req.query['service_path']}, () => {...})

kianenigma

front.js log
[2017-4-2 17:8:17][front.ms@127.0.0.1:4000] warn :: Sending a message to /task/io from first find strategy failed (Local Response)

kianenigma

$ curl -X POST  -i "http://localhost:4001/service?service_path=task/io"

kianenigma

HTTP/1.1 200 OK
X-Powered-By: Express
Content-Type: application/json; charset=utf-8
Content-Length: 31
ETag: W/"1f-5BgiCd8igfyPhK/4unDH1iI+hM0"
Date: Sun, 02 Apr 2017 12:38:17 GMT
Connection: keep-alive

{"err":"Not Found","body":null}%     

kianenigma

const express = require('express')
const XYZ = require('xyz-core')

const app = express()
const EXPRES_PORT = 4001

// setup xyz
const front = new XYZ({
  selfConf: {
    name: 'front.ms',

kianenigma

// client.js log
task/io response: null written
task/cpu response: null 9.33262154439441e+155
task/cpu response: null 9.33262154439441e+155
task/cpu response: null 9.33262154439441e+155
task/cpu response: null 9.33262154439441e+155
task/cpu response: null 9.33262154439441e+155

kianenigma

// worker.js log
[2017-4-2 16:33:6][worker.ms@127.0.0.1:6000] info :: JOIN PING ACCEPTED. response : {"services":{"":{}},"nodes":["127.0.0.1:5000"],"transportServers":{"5000":["CALL","PING"]}}
[2017-4-2 16:33:6][worker.ms@127.0.0.1:6000] info :: A new node {127.0.0.1:5000} added to systemConf
[2017-4-2 16:33:6][worker.ms@127.0.0.1:6000] info :: SR :: System Configuration changed new values: {"nodes":["127.0.0.1:6000","127.0.0.1:5000"]}

// client.js log
[2017-4-2 16:33:6][client.ms@127.0.0.1:5000] info :: A new node {127.0.0.1:6000} added to systemConf
[2017-4-2 16:33:6][client.ms@127.0.0.1:5000] info :: SR :: System Configuration changed new values: {"nodes":["127.0.0.1:5000","127.0.0.1:6000"]}