hzhang/HangmanLab.Backend
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

improve: upgrade node to 20, upgrade react-query to v4

Browse Source
This commit is contained in:
h z
2025-04-27 00:36:42 +01:00
parent 84494827ad
commit 85d8124a0c
7 changed files with 36 additions and 20 deletions
Download Patch File Download Diff File Expand all files Collapse all files

32
events/WebhookEventHandlers/__init__.py
View File

@@ -1,7 +1,10 @@
from sqlalchemy.orm import Session
from db.models.Path import Path
from db.models.PathSetting import PathSetting
from db.models.Webhook import Webhook
from db.models.WebhookSetting import WebhookSetting
from events import MARKDOWN_CREATED_EVENT, MARKDOWN_UPDATED_EVENT, MARKDOWN_DELETED_EVENT, PATH_CREATED_EVENT, \
PATH_UPDATED_EVENT, PATH_DELETED_EVENT
import abc
import importlib
import json
@@ -9,6 +12,15 @@ import pkgutil
import requests
import db
event_type_map = {
MARKDOWN_CREATED_EVENT: 'markdown_created_event',
MARKDOWN_UPDATED_EVENT: 'markdown_updated_event',
MARKDOWN_DELETED_EVENT: 'markdown_deleted_event',
PATH_CREATED_EVENT: 'path_created_event',
PATH_UPDATED_EVENT: 'path_updated_event',
PATH_DELETED_EVENT: 'path_deleted_event',
}
class WebhookEventHandler(abc.ABC):
def __init__(self, event_type=0):
self.event_type = event_type
@@ -17,20 +29,21 @@ class WebhookEventHandler(abc.ABC):
def get_path_id(self, payload):
pass
def __call__(self, **kwargs):
def __call__(self, *args, **kwargs):
payload = kwargs['payload']
path_id = self.get_path_id(payload)
with db.get_db() as session:
setting = self.get_setting(session, path_id)
if setting is None:
return
headers = {'Content-Type': 'application/json'}
if setting["additional_headers"] is not None:
headers.update(json.loads(setting["additional_headers"]))
headers = {'Content-Type': 'application/json', 'x-alchegos-event': event_type_map[self.event_type]}
if setting.get("additional_header", None) is not None:
headers.update(json.loads(setting["additional_header"]))
body = json.dumps(payload, default=str)
try:
response = requests.post(setting["webhook_url"], json=payload, headers=headers, timeout=5)
response = requests.post(setting["webhook_url"], data=body, headers=headers, timeout=5)
response.raise_for_status()
except requests.RequestException as e:
except Exception as e:
print(e)
def get_setting(self, session: Session, path_id):
@@ -39,7 +52,10 @@ class WebhookEventHandler(abc.ABC):
if path is None:
return None
p = path.to_dict()
webhook_setting = session.query(WebhookSetting).filter(WebhookSetting.path_id == path_id).first()
path_setting = session.query(PathSetting).get(path.setting_id)
if path_setting is None:
return None
webhook_setting = session.query(WebhookSetting).get(path_setting.webhook_setting_id)
if webhook_setting is None and p["parent_id"] != 1:
return self.get_setting(session, p["parent_id"])
@@ -47,7 +63,7 @@ class WebhookEventHandler(abc.ABC):
setting = webhook_setting.to_dict()
if not setting["enabled"] or setting["on_events"] & self.event_type == 0:
return None
webhook = session.query(Webhook).filter(Webhook.id == webhook_setting.webhook_id).first()
webhook = session.query(Webhook).get(webhook_setting.webhook_id)
if webhook is None:
return None
setting["webhook_url"] = webhook.to_dict()["hook_url"]