1 files changed, 74 insertions, 0 deletions

diff --git a/packages/preload/src/contextBridge/SophieRendererImpl.ts b/packages/preload/src/contextBridge/SophieRendererImpl.ts
new file mode 100644
index 0000000..5d29071
--- /dev/null
+++ b/packages/preload/src/contextBridge/SophieRendererImpl.ts
@@ -0,0 +1,74 @@
+/*
+ * Copyright (C)  2021-2022 Kristóf Marussy <kristof@marussy.com>
+ *
+ * This file is part of Sophie.
+ *
+ * Sophie is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU Affero General Public License as
+ * published by the Free Software Foundation, version 3.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ * GNU Affero General Public License for more details.
+ *
+ * You should have received a copy of the GNU Affero General Public License
+ * along with this program.  If not, see <https://www.gnu.org/licenses/>.
+ *
+ * SPDX-License-Identifier: AGPL-3.0-only
+ */
+
+import type { IJsonPatch } from 'mobx-state-tree';
+import {
+  Action,
+  action,
+  sharedStore,
+  SharedStoreListener,
+  SophieRenderer,
+} from '@sophie/shared';
+
+import { RendererToMainIpcService } from '../services/RendererToMainIpcService';
+
+class SophieRendererImpl implements SophieRenderer {
+  readonly #ipcService: RendererToMainIpcService;
+
+  #listener: SharedStoreListener | null = null;
+
+  constructor(ipcService: RendererToMainIpcService) {
+    this.#ipcService = ipcService;
+    ipcService.onSharedStorePatch((patch) => {
+      // `mobx-state-tree` will validate the patch, so we can safely cast here.
+      this.#listener?.onPatch(patch as IJsonPatch);
+    });
+  }
+
+  onSharedStoreChange(listener: SharedStoreListener): void {
+    this.#ipcService.getSharedStoreSnapshot().then((snapshot) => {
+      if (sharedStore.is(snapshot)) {
+        listener.onSnapshot(snapshot);
+        this.#listener = listener;
+      } else {
+        console.error('Got invalid initial shared store snapshot', snapshot);
+      }
+    }).catch((err) => {
+      console.error('Failed set initial shared store snapshot', err);
+    });
+  }
+
+  dispatchAction(actionToDispatch: Action): void {
+    const parsedAction = action.safeParse(actionToDispatch);
+    if (parsedAction.success) {
+      this.#ipcService.dispatchAction(parsedAction.data);
+    } else {
+      console.error('Trying to dispatch invalid action', actionToDispatch, parsedAction.error);
+    }
+  }
+}
+
+export function createSophieRenderer(ipcService: RendererToMainIpcService): SophieRenderer {
+  const impl = new SophieRendererImpl(ipcService);
+  return {
+    onSharedStoreChange: impl.onSharedStoreChange.bind(impl),
+    dispatchAction: impl.dispatchAction.bind(impl),
+  };
+}