diff options
| -rwxr-xr-x | Run/Que/client.py | 19 |
1 files changed, 19 insertions, 0 deletions
diff --git a/Run/Que/client.py b/Run/Que/client.py index 43517ff..ed128b8 100755 --- a/Run/Que/client.py +++ b/Run/Que/client.py @@ -4,6 +4,8 @@ simple client for que.run """ import argparse +import configparser +import os import subprocess import sys import time @@ -13,11 +15,24 @@ import urllib.request as request MAX_TIMEOUT = 99999999 # basically never timeout +def auth(): + conf_file = os.path.expanduser("~/.config/que.conf") + if not os.path.exists(conf_file): + sys.exit("you need a ~/.config/que.conf") + cfg = configparser.ConfigParser() + cfg.read(conf_file) + return cfg + + def send(args): "Send a message to the que." + ns = args.target.split("/")[0] + key = auth()[ns]["key"] data = args.infile.read().encode("utf-8").strip() req = request.Request(f"{args.host}/{args.target}") req.add_header("User-AgenT", "Que/Client") + if key: + req.add_header("Authorization", key) if args.serve: while not time.sleep(1): with request.urlopen(req, data=data, timeout=MAX_TIMEOUT) as req: @@ -29,6 +44,8 @@ def send(args): def recv(args): "Receive a message from the que." + ns = args.target.split("/")[0] + key = auth()[ns]["key"] def _recv(_req): msg = _req.readline().decode("utf-8").strip() @@ -41,6 +58,8 @@ def recv(args): params = urllib.parse.urlencode({"poll": args.poll}) req = request.Request(f"{args.host}/{args.target}?{params}") req.add_header("User-Agent", "Que/Client") + if key: + req.add_header("Authorization", key) with request.urlopen(req) as _req: if args.poll: |