| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112 |
- (in-package :cl-user)
- (defpackage chatikbot.server
- (:use :cl :chatikbot.utils)
- (:import-from :chatikbot.bot
- :handle-update)
- (:import-from :chatikbot.telegram
- :*telegram-token*)
- (:export :def-webhook-handler
- :get-webhook-url
- :get-oauth-url))
- (in-package :chatikbot.server)
- (defvar *web-path* nil "Set to externally accessible url")
- (defvar *web-iface* nil "Interface to listen on")
- (defvar *web-port* 4242 "Port to listen on")
- (defvar *web-acceptor* nil "Running hunchentoot acceptor")
- (defun web-start ()
- (when *web-acceptor* (hunchentoot:stop *web-acceptor*))
- (when *web-path*
- (setf *web-acceptor*
- (hunchentoot:start
- (make-instance 'hunchentoot:easy-acceptor
- :address *web-iface* :port *web-port*)))))
- (add-hook :starting #'(lambda () (web-start) (values)))
- (defun telegram-hook-p (request)
- (and (equal (hunchentoot:request-method request) :post)
- (equal (concatenate 'string "/" *telegram-token*)
- (hunchentoot:script-name request))))
- (hunchentoot:define-easy-handler (telegram-webhook-handler :uri #'telegram-hook-p) ()
- (handler-case
- (let ((stream (hunchentoot:raw-post-data :want-stream t)))
- (setf *random-state* (make-random-state t))
- (setf (flex:flexi-stream-external-format stream) :utf-8)
- (handle-update (yason:parse stream :object-as :alist)))
- (error (e) (log:error e)))
- "OK")
- (defun get-oauth-url ()
- (quri:render-uri
- (quri:merge-uris (quri:uri "/oauth")
- (quri:uri *web-path*))))
- (hunchentoot:define-easy-handler (oauth-handler :uri "/oauth") (code error state)
- (handler-case
- (run-hooks :oauth code error state)
- (error (e)
- (log:error e)
- (hunchentoot:redirect "/error"))))
- (hunchentoot:define-easy-handler (error-handler :uri "/error") ()
- "<html>
- <head><title>Internal error</title></head>
- <body>
- <h1>Error :'(</h1>
- <p>Internal server error</p>
- </html>")
- (hunchentoot:define-easy-handler (oauth-success-handler :uri "/oauth/success") ()
- "<html>
- <head><title>Auth Success</title></head>
- <body>
- <h1>Success!</h1>
- <p>OAuth successfully completed. You could close this tab and go back to telegram bot</p>
- </html>")
- (hunchentoot:define-easy-handler (oauth-fail-handler :uri "/oauth/fail") ()
- "<html>
- <head><title>Auth failed</title></head>
- <body>
- <h1>Failed :(</h1>
- <p>OAuth failed. You probably didn't allow the access. Try again.</p>
- </html>")
- (defun webhookp (request)
- (let ((name (hunchentoot:script-name request)))
- (and (> (length name) 6)
- (equal (subseq name 0 6) "/hook/"))))
- (hunchentoot:define-easy-handler (webhook-handler :uri #'webhookp) ()
- (handler-case
- (let ((hook (subseq (hunchentoot:script-name*) 6))
- (data (hunchentoot:raw-post-data :external-format :utf-8)))
- (setf *random-state* (make-random-state t))
- (run-hooks :webhook hook
- (when data (yason:parse data :object-as :alist))
- (hunchentoot:headers-in*)))
- (error (e) (log:error e)))
- "OK")
- (defmacro def-webhook-handler (name (&rest routes) &body body)
- (let ((parts (gensym "parts")))
- `(progn
- (defun ,name (hook data headers)
- (declare (ignorable data headers))
- (let ((,parts (split-sequence:split-sequence #\/ hook)))
- (when (member (car ,parts) (list ,@routes) :test #'equal)
- (log:info ,parts)
- (handler-case
- (let ((paths (rest ,parts)))
- ,@body)
- (error (e) (log:error "~A" e))))))
- (add-hook :webhook ',name))))
- (defun get-webhook-url (route &rest path)
- (when *web-path*
- (quri:render-uri
- (quri:merge-uris (quri:uri (format nil "/hook/~A~{/~A~}" route path))
- (quri:uri *web-path*)))))
|
