john/ad-nix
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

tweaks

Browse Source
This commit is contained in:
John Lancaster
2024-06-11 23:21:54 -05:00
parent 8bbe64a9ec
commit 2355aadab7
1 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
apps/scene_detect.py
View File

@@ -1,5 +1,5 @@
import asyncio
import json import json
import re
from appdaemon.plugins.hass.hassapi import Hass from appdaemon.plugins.hass.hassapi import Hass
from room_control import Motion from room_control import Motion
@@ -17,7 +17,7 @@ class SceneDetector(Hass):
self.listen_event( self.listen_event(
self.event_callback, event='call_service', domain='scene', service='turn_on' self.event_callback, event='call_service', domain='scene', service='turn_on'
) )
self.log(f'Waiting for {self.scene_entity.friendly_name} to activate') self.log(f"Waiting for scene '{self.scene_entity.friendly_name}' to activate")
async def event_callback(self, event_name, data, cb_args): async def event_callback(self, event_name, data, cb_args):
entity_id = data['service_data']['entity_id'] entity_id = data['service_data']['entity_id']
@@ -26,19 +26,19 @@ class SceneDetector(Hass):
async def scene_detected(self): async def scene_detected(self):
self.log(f'Detected scene activation: {self.scene_entity.friendly_name}') self.log(f'Detected scene activation: {self.scene_entity.friendly_name}')
await asyncio.sleep(1.0)
class MotionCanceller(SceneDetector): class MotionCanceller(SceneDetector):
async def scene_detected(self): async def scene_detected(self):
await super().scene_detected() await super().scene_detected()
app: Motion = await self.get_app(self.args['app']) app: Motion = await self.get_app(self.args['app'])
all_callbacks = await self.get_callback_entries() callbacks = await self.get_callback_entries()[app.name]
app_callbacks = all_callbacks[app.name]
for handle, info in app_callbacks.items(): for handle, info in callbacks.items():
if info['entity'] == app.sensor.entity_id and 'new=off' in info['kwargs']: if info['entity'] == app.sensor.entity_id and 'new=off' in info['kwargs']:
self.log(f'Cancelling motion callback for {app.name}')
await self.AD.state.cancel_state_callback(handle, app.name) await self.AD.state.cancel_state_callback(handle, app.name)
self.log(f'Cancelled motion callback for {app.name}')
# self.log(json.dumps(info, indent=4)) # self.log(json.dumps(info, indent=4))
break break
else: else: