mirror of
https://github.com/onyx-and-iris/streamlabs-socketio-py
synced 2024-11-23 07:40:49 +00:00
38 lines
887 B
Python
38 lines
887 B
Python
|
import logging
|
||
|
|
from threading import Thread
|
||
|
|
|
||
|
|
import streamlabsio
|
||
|
|
|
||
|
|
logging.basicConfig(level=logging.INFO)
|
||
|
|
|
||
|
|
|
||
|
|
def on_youtube_event(event, msg):
|
||
|
|
print(f"{event}: {msg.attrs()}")
|
||
|
|
|
||
|
|
|
||
|
|
def on_twitch_event(event, msg):
|
||
|
|
if event == "follow":
|
||
|
|
print(f"Received follow from {msg.name}")
|
||
|
|
elif event == "bits":
|
||
|
|
print(f"{msg.name} donated {msg.amount} bits! With message: {msg.message}")
|
||
|
|
|
||
|
|
|
||
|
|
def register_callbacks(client):
|
||
|
|
client.obs.on("streamlabs", on_twitch_event)
|
||
|
|
client.obs.on("twitch_account", on_twitch_event)
|
||
|
|
client.obs.on("youtube_account", on_youtube_event)
|
||
|
|
|
||
|
|
|
||
|
|
def main():
|
||
|
|
with streamlabsio.connect() as client:
|
||
|
|
worker = Thread(target=register_callbacks, args=(client,), daemon=True)
|
||
|
|
worker.start()
|
||
|
|
|
||
|
|
while cmd := input("<Enter> to exit\n"):
|
||
|
|
if not cmd:
|
||
|
|
break
|
||
|
|
|
||
|
|
|
||
|
|
if __name__ == "__main__":
|
||
|
|
main()
|