mirror of https://github.com/icedream/ts3bot.git
76 lines
2.5 KiB
Plaintext
76 lines
2.5 KiB
Plaintext
|
Sync = require "sync"
|
||
|
|
|
||
|
|
log = require("./logger")("X11tools")
|
||
|
|
spawn = require("child_process").spawn
|
||
|
|
services = require("./services")
|
||
|
|
StreamSplitter = require("stream-splitter")
|
||
|
|
require_bin = require("./require_bin")
|
||
|
|
|
||
|
|
xdotoolBinPath = require_bin "xdotool"
|
||
|
|
|
||
|
|
# Just some tools to work with the X11 windows
|
||
|
|
module.exports =
|
||
|
|
getWindowIdByProcessId: (pid, cb) =>
|
||
|
|
wid = null
|
||
|
|
|
||
|
|
# We provide --name due to the bug mentioned at https://github.com/jordansissel/xdotool/issues/14
|
||
|
|
xdoproc = spawn xdotoolBinPath, [ "search", "--any", "--pid", pid, "--name", "xdosearch" ],
|
||
|
|
env:
|
||
|
|
DISPLAY: process.env.DISPLAY
|
||
|
|
XDG_RUNTIME_DIR: process.env.XDG_RUNTIME_DIR
|
||
|
|
stdoutTokenizer = xdoproc.stdout.pipe StreamSplitter "\n"
|
||
|
|
stdoutTokenizer.encoding = "utf8";
|
||
|
|
stdoutTokenizer.on "token", (token) =>
|
||
|
|
token = token.trim() # get rid of \r
|
||
|
|
newWid = parseInt(token)
|
||
|
|
if newWid != 0 and wid == null
|
||
|
|
wid = newWid
|
||
|
|
stderrTokenizer = xdoproc.stderr.pipe StreamSplitter "\n"
|
||
|
|
stderrTokenizer.encoding = "utf8";
|
||
|
|
stderrTokenizer.on "token", (token) =>
|
||
|
|
token = token.trim() # get rid of \r
|
||
|
|
log.warn token
|
||
|
|
await xdoproc.on "exit", defer(e)
|
||
|
|
|
||
|
|
if e.code
|
||
|
|
log.error "Failed to find window ID, error code #{e.code}"
|
||
|
|
err = new Error "Failed to find window ID."
|
||
|
|
cb? err
|
||
|
|
return
|
||
|
|
|
||
|
|
cb? null, parseInt(wid)
|
||
|
|
|
||
|
|
getWindowIdByProcessIdSync: (pid) => Sync() => @getWindowIdByProcessId.sync @, pid
|
||
|
|
|
||
|
|
sendKeys: (wid, keys, cb) =>
|
||
|
|
# blackbox needs to be running for windowactivate to work
|
||
|
|
blackboxService = services.find("BlackBox")
|
||
|
|
if blackboxService.state != "started"
|
||
|
|
await blackboxService.start defer(err)
|
||
|
|
if err
|
||
|
|
cb? new Error "Could not start compatible window manager."
|
||
|
|
return
|
||
|
|
|
||
|
|
xdoproc = spawn xdotoolBinPath, [ "windowactivate", "--sync", wid, "key", "--clearmodifiers", "--delay", "100" ].concat(keys),
|
||
|
|
env:
|
||
|
|
DISPLAY: process.env.DISPLAY
|
||
|
|
XDG_RUNTIME_DIR: process.env.XDG_RUNTIME_DIR
|
||
|
|
stdoutTokenizer = xdoproc.stdout.pipe StreamSplitter "\n"
|
||
|
|
stdoutTokenizer.encoding = "utf8";
|
||
|
|
stdoutTokenizer.on "token", (token) =>
|
||
|
|
token = token.trim() # get rid of \r
|
||
|
|
log.debug token
|
||
|
|
stderrTokenizer = xdoproc.stderr.pipe StreamSplitter "\n"
|
||
|
|
stderrTokenizer.encoding = "utf8";
|
||
|
|
stderrTokenizer.on "token", (token) =>
|
||
|
|
token = token.trim() # get rid of \r
|
||
|
|
log.warn token
|
||
|
|
await xdoproc.on "exit", defer(e)
|
||
|
|
|
||
|
|
err = null
|
||
|
|
if e.code
|
||
|
|
log.error "Failed to send keys, error code #{e.code}"
|
||
|
|
err = new Error "Failed to send keys."
|
||
|
|
cb? err
|
||
|
|
|
||
|
|
sendKeysSync: (keys) => Sync () => @sendKeys.sync @, keys
|