fix(loader): eplixcitly set process start method and import fsevents on mac

2 files changed, 10 insertions, 4 deletions

diff --git a/backend/loader.py b/backend/loader.py
index 493e7f10..c420fafe 100644
--- a/backend/loader.py
+++ b/backend/loader.py
@@ -8,7 +8,12 @@ from traceback import print_exc
 from aiohttp import web
 from genericpath import exists
 from watchdog.events import RegexMatchingEventHandler
-from watchdog.observers.inotify import InotifyObserver as Observer
+from watchdog.utils import UnsupportedLibc
+
+try:
+    from watchdog.observers.inotify import InotifyObserver as Observer
+except UnsupportedLibc:
+    from watchdog.observers.fsevents import FSEventsObserver as Observer
 
 from injector import get_tab, inject_to_tab
 from plugin import PluginWrapper
@@ -111,7 +116,7 @@ class Loader:
                 self.logger.info(f"Plugin {plugin.name} is passive")
             self.plugins[plugin.name] = plugin.start()
             self.logger.info(f"Loaded {plugin.name}")
-            #self.loop.create_task(self.dispatch_plugin(plugin.name))
+            self.loop.create_task(self.dispatch_plugin(plugin.name))
         except Exception as e:
             self.logger.error(f"Could not load {file}. {e}")
             print_exc()
diff --git a/backend/plugin.py b/backend/plugin.py
index e6cceffd..fb636a4c 100644
--- a/backend/plugin.py
+++ b/backend/plugin.py
@@ -1,10 +1,10 @@
+import multiprocessing
 from asyncio import (Lock, get_event_loop, new_event_loop,
                      open_unix_connection, set_event_loop, sleep,
                      start_unix_server)
 from concurrent.futures import ProcessPoolExecutor
 from importlib.util import module_from_spec, spec_from_file_location
 from json import dumps, load, loads
-from multiprocessing import Process
 from os import path, setuid
 from signal import SIGINT, signal
 from sys import exit
@@ -87,7 +87,8 @@ class PluginWrapper:
     def start(self):
         if self.passive:
             return self
-        Process(target=self._init).start()
+        multiprocessing.set_start_method("fork")
+        multiprocessing.Process(target=self._init).start()
         return self
 
     def stop(self):