73 lines
2.9 KiB
Python
73 lines
2.9 KiB
Python
import asyncio
|
|
import simpleobsws
|
|
import json
|
|
|
|
loop = asyncio.get_event_loop()
|
|
ws = simpleobsws.obsws(host='127.0.0.1', port=4444, password='MYSecurePassword', loop=loop) # Every possible argument has been passed, but none are required. See lib code for defaults.
|
|
|
|
|
|
async def default_request():
|
|
await ws.connect() # Make the connection to OBS-Websocket
|
|
result = await ws.call('GetVersion') # We get the current OBS version. More request data is not required
|
|
print(result) # Print the raw json output of the GetVersion request
|
|
await asyncio.sleep(1)
|
|
print("\n\n")
|
|
requests = result['available-requests'].split(',')
|
|
for r in requests:
|
|
print(r)
|
|
print("\n\n")
|
|
#data = {'source':'test_source', 'volume':0.5}
|
|
#result = await ws.call('SetVolume', data) # Make a request with the given data
|
|
#print(result)
|
|
await ws.disconnect() # Clean things up by disconnecting. Only really required in a few specific situations, but good practice if you are done making requests or listening to events.
|
|
|
|
async def make_custom_request(request, data=None):
|
|
await ws.connect() # Make the connection to OBS-Websocket
|
|
result = await ws.call(request) # We get the current OBS version. More request data is not required
|
|
print(result) # Print the raw json output of the GetVersion request
|
|
await asyncio.sleep(1)
|
|
if not data==None:
|
|
data = {'source':'test_source', 'volume':0.5}
|
|
result = await ws.call('SetVolume', data) # Make a request with the given data
|
|
print(result)
|
|
await ws.disconnect() # Clean things up by disconnecting. Only really required in a few specific situations, but good practice if you are done making requests or listening to events.
|
|
|
|
|
|
|
|
async def on_event(data):
|
|
print('New event! Type: {} | Raw Data: {}'.format(data['update-type'], data)) # Print the event data. Note that `update-type` is also provided in the data
|
|
|
|
async def on_switchscenes(data):
|
|
print("\n===========================================\n\n")
|
|
print('Scene switched to "{}". It has these sources: {}'.format(data['scene-name'], data['sources']))
|
|
|
|
|
|
|
|
def getRequests():
|
|
loop.run_until_complete(default_request())
|
|
|
|
def makeRequest(request):
|
|
loop.run_until_complete(make_custom_request(request))
|
|
|
|
|
|
|
|
def listenForData():
|
|
print("\n\nListener:")
|
|
|
|
loop = asyncio.get_event_loop()
|
|
ws = simpleobsws.obsws(host='127.0.0.1', port=4444, password='MYSecurePassword', loop=loop) # Every possible argument has been passed, but none are required. See lib code for defaults.
|
|
loop.run_until_complete(ws.connect())
|
|
ws.register(on_event) # By not specifying an event to listen to, all events are sent to this callback.
|
|
ws.register(on_switchscenes, 'SwitchScenes')
|
|
loop.run_forever()
|
|
|
|
|
|
|
|
if __name__ == "__main__":
|
|
#print("\n\nRequests:")
|
|
#loop.run_until_complete(get_requests())
|
|
|
|
#makeRequest("ToggleStudioMode")
|
|
#listenForData()
|
|
pass
|