sugos

#!/usr/bin/env node
/**
 * This is an example of SUGO-Hub
 * @see https://github.com/realglobe-Inc/sugo-hub
 */
'use strict'
 
const sugoHub = require('sugo-hub')
const co = require('co')
 
co(function * () {
  // Start sugo-hub server
  let hub = yield sugoHub({}).listen(3000)
  console.log(`SUGO Hub started at port: ${hub.port}`)
}).catch((err) => console.error(err))
 

#!/usr/bin/env
 
/**
 * This is an example of SUGO-Actor
 * @see https://github.com/realglobe-Inc/sugo-actor
 */
'use strict'
 
const sugoActor = require('sugo-actor')
const { Module } = sugoActor
const co = require('co')
 
co(function * () {
  let actor = sugoActor({
    /** Host of hub to connect */
    hostname: 'localhost',
    port: 3000,
    /** Name to identify this actor on the hub */
    key: 'my-actor-01',
    /** Modules to provide */
    modules: {
      // Example of a simple call-return function module
      tableTennis: new Module({
        ping (pong = 'default pong!') {
          return co(function * () {
            /* ... */
            return `"${pong}" from actor!` // Return to the remote caller
          })
        }
      }),
      // Load plugin module
      timeBomb: require('./example-time-bomb-module')({})
    }
  })
  yield actor.connect() // Connect to the hub server
}).catch((err) => console.error(err))
 

#!/usr/bin/env
 
/**
 * This is an example of SUGO-Caller
 * @see https://github.com/realglobe-Inc/sugo-caller
 */
'use strict'
 
const sugoCaller = require('sugo-caller')
const co = require('co')
 
co(function * () {
  let caller = sugoCaller({
    // Host of hub to connect
    hostname: 'localhost',
    port: 3000
  })
  // Connect to an actor with key
  let actor01 = yield caller.connect('my-actor-01')
 
  // Using call-return function
  {
    let tableTennis = actor01.get('tableTennis')
    let pong = yield tableTennis.ping('hey!')
    console.log(pong) // -> `"hey!" from actor!`
  }
 
}).catch((err) => console.error(err))
 

/**
 * This is an example module
 */
'use strict'
 
const co = require('co')
const { Module } = require('sugo-actor')
 
class TimeBomb extends Module {
  // Example of event emitting function
  countDown (count) {
    const s = this
    return co(function * () {
      let abort = () => { count = -1 }
      s.on('abort', abort) // Listen to events from the caller
      while (count > 0) {
        count--
        s.emit('tick', { count }) // Emit an event to the caller
        yield new Promise((resolve) =>
          setTimeout(() => resolve(), 1000)
        )
      }
      s.off('abort', abort) // Remove event listener
      return count === -1 ? 'hiss...' : 'booom!!!'
    })
  }
}
 
function newTimeBomb (...args) {
  return new TimeBomb(...args)
}
 
module.exports = newTimeBomb // Pass factory method
 

#!/usr/bin/env
 
/**
 * This is an example of SUGO-Caller to use event emit
 */
'use strict'
 
const sugoCaller = require('sugo-caller')
const co = require('co')
 
co(function * () {
  let caller = sugoCaller({ /* ... */ })
  let actor01 = yield caller.connect('my-actor-01')
 
  // Using event emitting interface
  {
    let timeBomb = actor01.get('timeBomb')
    let tick = (data) => console.log(`tick: ${data.count}`)
    timeBomb.on('tick', tick) // Add listener
    let booom = yield timeBomb.countDown(10)
    console.log(booom)
    timeBomb.off('tick', tick) // Remove listener
  }
}).catch((err) => console.error(err))