bitbot-3.11-fork/modules/rest_api.py

96 lines
3.2 KiB
Python
Raw Normal View History

import http.server, json, threading, uuid, urllib.parse
import flask
from src import utils
_bot = None
_events = None
class Handler(http.server.BaseHTTPRequestHandler):
timeout = 10
2018-10-05 22:14:32 +00:00
def _handle(self, method, path, data="", params={}):
_, _, endpoint = path[1:].partition("/")
endpoint, _, args = endpoint.partition("/")
args = list(filter(None, args.split("/")))
response = ""
code = 404
hooks = _events.on("api").on(method).on(endpoint).get_hooks()
if hooks:
hook = hooks[0]
authenticated = hook.get_kwarg("authenticated", True)
key = params.get("key", None)
if authenticated and (not key or not _bot.get_setting(
"api-key-%s" % key, False)):
code = 401
else:
if path.startswith("/api/"):
response = _events.on("api").on(method).on(endpoint
2018-10-05 22:14:32 +00:00
).call_for_result(params=params, path=args, data=data)
if response:
response = json.dumps(response, sort_keys=True,
indent=4)
code = 200
self.send_response(code)
self.send_header("Content-type", "application/json")
self.end_headers()
self.wfile.write(response.encode("utf8"))
def _safe_handle(self, method, path, params):
_bot.lock.acquire()
try:
self._handle(method, path, params)
except:
pass
finally:
_bot.lock.release()
def _decode_params(self, s):
params = urllib.parse.parse_qs(s)
return dict([(k, v[0]) for k, v in params.items()])
def do_GET(self):
parsed = urllib.parse.urlparse(self.path)
get_params = self._decode_params(parsed.query)
2018-10-05 22:14:32 +00:00
self._handle("get", parsed.path, params=get_params)
def do_POST(self):
parsed = urllib.parse.urlparse(self.path)
2018-10-05 22:14:32 +00:00
post_params = self._decode_params(parsed.query)
content_length = int(self.headers.get("content-length", 0))
post_body = self.rfile.read(content_length)
2018-10-05 22:14:32 +00:00
self._handle("post", parsed.path, data=post_body, params=post_params)
@utils.export("botset", {"setting": "rest-api",
"help": "Enable/disable REST API",
"validate": utils.bool_or_none})
class Module(object):
def __init__(self, bot, events, exports):
self.bot = bot
global _bot
_bot = bot
self.events = events
global _events
_events = events
if bot.get_setting("rest-api", False):
self.httpd = http.server.HTTPServer(("", 5000), Handler)
self.thread = threading.Thread(target=self.httpd.serve_forever)
self.thread.daemon = True
self.thread.start()
def unload(self):
self.httpd.shutdown()
@utils.hook("received.command.apikey", private_only=True)
def api_key(self, event):
"""
:help: Generate a new API key
:permission: api-key
:prefix: APIKey
"""
api_key = str(uuid.uuid4())
self.bot.set_setting("api-key-%s" % api_key, True)
event["stdout"].write(api_key)