geckon01/decky-loader
1
0
Fork 0
mirror of https://github.com/SteamDeckHomebrew/decky-loader.git synced 2026-07-11 22:31:59 +00:00
Code Issues Packages Projects Releases Wiki Activity

disable file watcher until after 10 seconds

Browse Source
This commit is contained in:
AAGaming
2022-10-07 22:37:29 -04:00
parent 86dc706892
commit a3809222f9
1 changed files with 9 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
backend/loader.py
+9 -1
View File
@@ -25,7 +25,7 @@ class FileChangeHandler(RegexMatchingEventHandler):
self.logger = getLogger("file-watcher") self.logger = getLogger("file-watcher")
self.plugin_path = plugin_path self.plugin_path = plugin_path
self.queue = queue self.queue = queue
self.disabled = False self.disabled = True
def maybe_reload(self, src_path): def maybe_reload(self, src_path):
if self.disabled: if self.disabled:
@@ -70,6 +70,7 @@ class Loader:
self.logger.info(f"plugin_path: {self.plugin_path}") self.logger.info(f"plugin_path: {self.plugin_path}")
self.plugins = {} self.plugins = {}
self.watcher = None self.watcher = None
self.live_reload = live_reload
if live_reload: if live_reload:
self.reload_queue = Queue() self.reload_queue = Queue()
@@ -78,6 +79,7 @@ class Loader:
self.observer.schedule(self.watcher, self.plugin_path, recursive=True) self.observer.schedule(self.watcher, self.plugin_path, recursive=True)
self.observer.start() self.observer.start()
self.loop.create_task(self.handle_reloads()) self.loop.create_task(self.handle_reloads())
self.loop.create_task(self.enable_reload_wait())
server_instance.add_routes([ server_instance.add_routes([
web.get("/frontend/{path:.*}", self.handle_frontend_assets), web.get("/frontend/{path:.*}", self.handle_frontend_assets),
@@ -92,6 +94,12 @@ class Loader:
web.get("/steam_resource/{path:.+}", self.get_steam_resource) web.get("/steam_resource/{path:.+}", self.get_steam_resource)
]) ])
async def enable_reload_wait(self):
if self.live_reload:
await sleep(10)
self.logger.info("Hot reload enabled")
self.watcher.disabled = False
async def handle_frontend_assets(self, request): async def handle_frontend_assets(self, request):
file = path.join(path.dirname(__file__), "static", request.match_info["path"]) file = path.join(path.dirname(__file__), "static", request.match_info["path"])