Skip to content

Commit

Permalink
refactor: remove temp broadcast channel
Browse files Browse the repository at this point in the history
  • Loading branch information
geolffreym committed Jul 10, 2021
1 parent 0b245be commit 214104e
Showing 1 changed file with 9 additions and 9 deletions.
18 changes: 9 additions & 9 deletions src/main/core/index.js
Original file line number Diff line number Diff line change
Expand Up @@ -5,10 +5,10 @@
const log = require('logplease').create('CORE')
const Node = require('./node')
const Ingest = require('./ingest')
const BroadCast = require('./broadcast')
// const BroadCast = require('./broadcast')

module.exports = (ipcMain, runtime = 'node') => {
let nodeConf = { broker: BroadCast }
let nodeConf = { }
const isWebRuntime = runtime === 'web'
if (!isWebRuntime) {
const { ROOT_ORBIT_DIR } = require('./settings')
Expand Down Expand Up @@ -36,13 +36,13 @@ module.exports = (ipcMain, runtime = 'node') => {
ipcMain.emit('party')
})

orbit.on('node-raised', async () => {
// Node raised and ready to work with it
ipcMain.on('node-broadcast', (e, message) => {
// On new message broadcast message
orbit.pubsub.broadcast(message)
})
})
// orbit.on('node-raised', async () => {
// // Node raised and ready to work with it
// ipcMain.on('node-broadcast', (e, message) => {
// // On new message broadcast message
// orbit.pubsub.broadcast(message)
// })
// })

// Ingest process listener
ingest.on('ingest-step', (step) => e.reply('node-step', step))
Expand Down

0 comments on commit 214104e

Please sign in to comment.