IPC

ipc provides an event listeners and event emitter methods or functions for ipc(Inter-process communication) using the process stdin as it's meduim.

What's the motive behind this package creation?

I was having one or more issues with any of Nodejs based fs-watcher module I could find, So I extended my search outside Node and found a package written in Go that addressed all those issues for me but the biggest challenge I was facing then was communicating with the two process (electron (Nodjs) and Go process) I tried using websocket but it didn't work out well until I found a post on how to read/scan the stdin using bufio.NewReader(os.Stdin) which drived the idea from to create this package.

Note: To use this package you must not log/print stuffs with fmt package because fmt writes to process stdout

This package was made with Nodejs as the parent process in mind.

Usage

To use this package you will surely need it's Nodejs version ipc-node-go

go get github.com/Akumzy/ipc

// main.go binarypackage main
import (
"encoding/json""log""github.com/Akumzy/ipc"
)
varipcIO*ipc.IPCtypeWhostruct {
Namestring`json:"name,omitempty"`
}
funcmain() {
ipcIO=ipc.New()
gofunc() {
// Me trying to write spanishipcIO.SendAndReceive("hola", "Hola amigo, coma este nombre?", func(payloadinterface{}) {
log.Println(payload)
})
ipcIO.On("who", func(payloadinterface{}) {
varwhoWhotext:=payload.(string)
iferr:=json.Unmarshal([]byte(text), &who); err!=nil {
log.Println(err)
return
}
log.Println(who.Name)
})
ipcIO.OnReceiveAndReply("yoo", func(replystring, payloadinterface{}) {
log.Println(payload)
ipcIO.Reply(reply, "Sup Node", nil)
})
}()
// You either start the IPC in it's routine// or start your own code in a go routineipcIO.Start()
}

// In Nodejs appconstIPC=require('ipc-node-go')constipc=newIPC('path-to-your-go-binary')ipc.init()ipc.on('log',console.log)// Log all error from stderripc.on('error',console.error)//ipc.send('who',{name: 'Akuma Nodejs'})// send and receive and an acknowledgement// listen for event and reply to the channelipc.onReceiveAnSend('hola',(channel,data)=>{console.log(data)ipc.send(channel,'cool thanks')})setInterval(()=>{ipc.sendAndReceive('yoo','Hello, how are you doing?',(err,data)=>{err ? console.error(err) : console.log(data)})},20000)