aljaz/gitpear
1
0
Fork 0
mirror of https://github.com/aljazceru/gitpear.git synced 2025-12-17 14:14:22 +01:00
Code Issues Packages Projects Releases Wiki Activity

tmp: assume daemon is always running

Browse Source 
Signed-off-by: dzdidi <deniszalessky@gmail.com>
This commit is contained in:
dzdidi
2024-01-24 11:33:31 +00:00
parent c4b6be5527
commit b7d9749a11
1 changed files with 17 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files

34
src/git-remote-pear.js
View File

@@ -28,21 +28,21 @@ const repoName = matches[2]
const store = new Corestore(RAM) const store = new Corestore(RAM)
const swarm = new Hyperswarm({ keypair: home.getKeyPair() }) const swarm = new Hyperswarm({ keypair: home.getKeyPair() })
let daemonPid // let daemonPid
if (!home.isDaemonRunning()) { // if (!home.isDaemonRunning()) {
const opts = { // const opts = {
detached: true, // detached: true,
stdio: [ 'ignore', home.getOutStream(), home.getErrStream() ] // stdio: [ 'ignore', home.getOutStream(), home.getErrStream() ]
} // }
const daemon = spawn('git-peard', opts) // const daemon = spawn('git-peard', opts)
daemonPid = daemon.pid // daemonPid = daemon.pid
home.storeDaemonPid(daemonPid) // home.storeDaemonPid(daemonPid)
// TODO: remove in case of error or exit but allow unref // // TODO: remove in case of error or exit but allow unref
// daemon.on('error', home.removeDaemonPid) // // daemon.on('error', home.removeDaemonPid)
// daemon.on('exit', home.removeDaemonPid) // // daemon.on('exit', home.removeDaemonPid)
console.error('started daemon', daemonPid) // console.error('started daemon', daemonPid)
daemon.unref() // daemon.unref()
} // }
swarm.join(crypto.discoveryKey(Buffer.from(targetKey, 'hex')), { server: false }) swarm.join(crypto.discoveryKey(Buffer.from(targetKey, 'hex')), { server: false })
@@ -121,8 +121,8 @@ async function talkToGit (refs, drive, repoName, rpc) {
const publicKey = home.readPk() const publicKey = home.readPk()
const res = await rpc.request(command, Buffer.from(`${publicKey}/${repoName}:${dst}`)) const res = await rpc.request(command, Buffer.from(`${publicKey}/${repoName}:${dst}`))
process.kill(daemonPid || home.getDaemonPid()) // process.kill(daemonPid || home.getDaemonPid())
home.removeDaemonPid() // home.removeDaemonPid()
process.stdout.write(res.toString()) process.stdout.write(res.toString())
process.stdout.write('\n\n') process.stdout.write('\n\n')