|
|
@ -43,7 +43,7 @@ async def play_sound(filename): |
|
|
|
|
|
|
|
|
|
|
|
async def barkbark(sound): |
|
|
|
async def barkbark(sound): |
|
|
|
global COOLDOWN |
|
|
|
global COOLDOWN |
|
|
|
if time.time() - COOLDOWN < 15.0: |
|
|
|
if time.time() - COOLDOWN < 20.0: |
|
|
|
logging.info('Cooldown skipping.') |
|
|
|
logging.info('Cooldown skipping.') |
|
|
|
return |
|
|
|
return |
|
|
|
COOLDOWN = time.time() |
|
|
|
COOLDOWN = time.time() |
|
|
@ -84,7 +84,7 @@ async def process_mqtt(message): |
|
|
|
|
|
|
|
|
|
|
|
async def fetch_mqtt(): |
|
|
|
async def fetch_mqtt(): |
|
|
|
await asyncio.sleep(3) |
|
|
|
await asyncio.sleep(3) |
|
|
|
async with Client('192.168.0.100') as client: |
|
|
|
async with Client('192.168.0.106') as client: |
|
|
|
async with client.filtered_messages('iot/cameras') as messages: |
|
|
|
async with client.filtered_messages('iot/cameras') as messages: |
|
|
|
await client.subscribe('#') |
|
|
|
await client.subscribe('#') |
|
|
|
async for message in messages: |
|
|
|
async for message in messages: |
|
|
|