/usr/bin/execute-json-from-fifo is in subuser 0.6.1-3.
This file is owned by root:root, with mode 0o755.
The actual contents of the file can be viewed below.
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 | #!/usr/bin/python3
# -*- coding: utf-8 -*-
# This file is copyright Timothy Hobbs
# And is released under the LGPLv3 license
import json
import subprocess
import fileinput
import sys
import optparse
usage = "usage: execute-json-from-fifo PATH_TO_NAMED_PIPE"
description = """
This is a very simple script which executes commands passed as JSON to a given named pipe.
To launch this script run:
$ execute-json-from-fifo PATH_TO_NAMED_PIPE
The protocol is as follows:
{
"command":["echo","some","command"],
"stdin":"path",
"stdout":"path",
"stderr":"path",
"cwd":"path"
"env":{"ENVVAR":"value"}
}
``stdin``,``stdout``,``stderr``,``cwd`` and ``env`` are all optional.
Passing ``["exit"]`` to command stops the script.
"""
parser=optparse.OptionParser(usage=usage,description=description)
options,args = parser.parse_args()
while True:
with open(args[0],"r") as fd:
for line in fd:
print(line)
try:
rpc = json.loads(line)
except ValueError as e:
print(e)
continue
if "stdin" in rpc:
stdin = open(rpc["stdin"],"r+")
del rpc["stdin"]
else:
stdin = open("/dev/null","r")
if "stdout" in rpc:
stdout = open(rpc["stdout"],"w")
del rpc["stdout"]
else:
stdout = open("/dev/null","w")
if "stderr" in rpc:
stderr = open(rpc["stderr"],"w")
del rpc["stderr"]
else:
stderr = open("/dev/null","w")
cwd = None
if "cwd" in rpc:
cwd = rpc["cwd"]
del rpc["cwd"]
env = None
if "env" in rpc:
env = rpc["env"]
del rpc["env"]
if "command" in rpc:
command = rpc["command"]
del rpc["command"]
else:
print("Warning, no command specified.")
continue
if rpc != {}:
print("Warning, unsupported options passed "+str(rpc))
if command == ["exit"]:
sys.exit()
else:
try:
subprocess.Popen(command,stdin=stdin,stdout=stdout,stderr=stderr,cwd=cwd,env=env,close_fds=True)
except FileNotFoundError:
print("Warning, command "+str(command)+" not found.")
|