Very basic webserver module to listen for webhooks and forward requests to predefined functions.
Project description
Webhook Listener
Very basic webserver module to listen for webhooks and forward requests to predefined functions.
Author: Todd Roberts
https://pypi.org/project/webhook_listener/
https://github.com/toddrob99/Webhooks
Install
Install from PyPI using pip
pip install webhook_listener
Use
- Define a function to process requests
request
parameter will be a cherrypy request object*args
parameter will be a tuple of URL path components**kwargs
parameter will be a dictionary of URL parameters- Get the body of a
POST
request fromrequest.body.read
passing the length ofrequest.headers['Content-Length']
:request.body.read(int(request.headers['Content-Length'])) if int(request.headers.get('Content-Length',0)) > 0 else ''
- Note: The body will be a byte array, and not a string. You may need to decode it to a string. For example:
import json body_raw = request.body.read(int(request.headers['Content-Length'])) if int(request.headers.get('Content-Length',0)) > 0 else '{}' body = json.loads(body_raw.decode('utf-8'))
- Include webhook-listener in your project
- Create an instance of the webhook_listener.Listener class
- handlers = Dictionary of functions/callables for each supported HTTP method. (Example: {'POST':process_post_request, 'GET':process_get_request})
- port = Port for the web server to listen on (default: 8090)
- host = Host for the web server to listen on (default: '0.0.0.0')
- threadPool = Number of worker threads for the web server (default: 10)
- logScreen = Setting for cherrypy to log to screen (default: False)
- autoReload = Setting for cherrypy to auto reload when python files are changed (default: False)
- sslModule = Select which SSL library to use (default: 'builtin')
- sslCert = Path to the certificate (SSL is disabled when empty)
- sslPrivKey = Path to the certificate's private key (SSL is disabled when empty)
- sslCertChain = Path to the full certificate chain see https://cherrypydocrework.readthedocs.io/deploy.html#ssl-support for more information on SSL support
- Start the Listener
- Keep your application running so the Listener can run in a separate thread
Example
import time
import webhook_listener
def process_post_request(request, *args, **kwargs):
print(
"Received request:\n"
+ "Method: {}\n".format(request.method)
+ "Headers: {}\n".format(request.headers)
+ "Args (url path): {}\n".format(args)
+ "Keyword Args (url parameters): {}\n".format(kwargs)
+ "Body: {}".format(
request.body.read(int(request.headers["Content-Length"]))
if int(request.headers.get("Content-Length", 0)) > 0
else ""
)
)
# Process the request!
# ...
return
webhooks = webhook_listener.Listener(handlers={"POST": process_post_request})
webhooks.start()
while True:
print("Still alive...")
time.sleep(300)
Project details
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
Webhook_Listener-1.2.0.tar.gz
(4.5 kB
view hashes)
Built Distribution
Close
Hashes for Webhook_Listener-1.2.0-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 247384452ba4000dd62e1f6bd5a3bc0c4dbd78375620cc61afd6f436ac739661 |
|
MD5 | d7f71f17c6bcc3cdcff1f799ecdc78d1 |
|
BLAKE2b-256 | 2271780e62259e87f8b582f35553f905de72dd16bbaccb52b7077ea52af313dc |