new ipcs principle

src/renderer/services/ipc.service.ts

@@ -0,0 +1,40 @@
+import { Observable } from "rxjs";
+import { IpcRequest, IpcResponse } from "../../shared/models/ipc-models.model";
+
+export class IpcService {
+
+    private static instance: IpcService;
+
+    public static getInstance(): IpcService{
+        if(!IpcService.instance){ IpcService.instance = new IpcService(); }
+        return IpcService.instance;
+    }
+
+    private constructor(){}
+
+    public send<T>(channel: string, request?: IpcRequest<any>): Promise<IpcResponse<T>>{
+        if(!request){ request = {args: null, responceChannel: null}; }
+        if(!request.responceChannel){ request.responceChannel = `${channel}_responce_${new Date().getTime()}`; }
+
+        const promise = new Promise<IpcResponse<T>>(resolve => {
+            window.electron.ipcRenderer.once(request.responceChannel, (response: IpcResponse<T>) => resolve(response));
+        });
+
+        window.electron.ipcRenderer.sendMessage(channel, request);
+
+        return promise;
+    }
+
+    public sendLazy(channel: string, request?: IpcRequest<any>): void{
+        window.electron.ipcRenderer.sendMessage(channel, request);
+    }
+
+    public watch<T>(channel: string): Observable<T>{
+        return new Observable<T>(observer => {
+            window.electron.ipcRenderer.on(channel, res => {
+                observer.next(res);
+            });
+        });
+    }
+
+}