YunoHost/webhooks
1
0
Fork 0
mirror of https://github.com/YunoHost/webhooks.git synced 2024-09-03 19:56:54 +02:00
Code Issues Projects Releases Packages Wiki Activity

Switch to matrix for notifications

Browse source
This commit is contained in:
Alexandre Aubin 2023-01-10 16:27:30 +01:00
parent 698f13ef32
commit 3489e10774
1 changed files with 14 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

18
server.py
View file

@ -37,11 +37,21 @@ async def notify(message, repository="dev"):
chan = other_chans.get(repository, "dev") chan = other_chans.get(repository, "dev")
print(f"{chan} -> {message}") print(f"{chan} -> {message}")
for char in ["'", "`", "!", ";", "$"]:
message = message.replace(char, "")
proc = await asyncio.create_subprocess_shell( proc = await asyncio.create_subprocess_shell(
f"python ./to_room.py '{gitbot_password}' '{message}' '{chan}'" f"/var/www/webhooks/matrix-commander -m '{message}' -c /var/www/webhooks/credentials.json --store /var/www/webhooks/store --room 'yunohost-{chan}'"
) )
await proc.communicate() try:
await proc.wait() await proc.communicate()
await proc.wait()
except Exception as e:
if type(e).__name__ == "CancelledError":
pass
else:
raise Exception(f" {type(e).__name__} while trying to notify about commit '{commit_message}' on {repository}/{branch}: {e}")
@app.route("/github", methods=["GET"]) @app.route("/github", methods=["GET"])
@ -500,4 +510,4 @@ async def index(request):
if __name__ == "__main__": if __name__ == "__main__":
app.run("localhost", port="4567") app.run('127.0.0.1', port="4567")