mirror of
https://github.com/vrtmrz/obsidian-livesync.git
synced 2026-03-27 20:25:17 +00:00
88838872e7
- Rewrite the service's binding/handler assignment systems - Removed loopholes that allowed traversal between services to clarify dependencies. - Consolidated the hidden state-related state, the handler, and the addition of bindings to the handler into a single object. - Currently, functions that can have handlers added implement either addHandler or setHandler directly on the function itself. I understand there are differing opinions on this, but for now, this is how it stands. - Services now possess a Context. Please ensure each platform has a class that inherits from ServiceContext. - To permit services to be dynamically bound, the services themselves are now defined by interfaces.
35 lines
1.8 KiB
TypeScript
35 lines
1.8 KiB
TypeScript
import { REMOTE_P2P, type RemoteDBSettings } from "../../lib/src/common/types";
|
|
import type { LiveSyncAbstractReplicator } from "../../lib/src/replication/LiveSyncAbstractReplicator";
|
|
import { AbstractModule } from "../AbstractModule";
|
|
import { LiveSyncTrysteroReplicator } from "../../lib/src/replication/trystero/LiveSyncTrysteroReplicator";
|
|
import type { LiveSyncCore } from "../../main";
|
|
|
|
export class ModuleReplicatorP2P extends AbstractModule {
|
|
_anyNewReplicator(settingOverride: Partial<RemoteDBSettings> = {}): Promise<LiveSyncAbstractReplicator | false> {
|
|
const settings = { ...this.settings, ...settingOverride };
|
|
if (settings.remoteType == REMOTE_P2P) {
|
|
return Promise.resolve(new LiveSyncTrysteroReplicator(this.core));
|
|
}
|
|
return Promise.resolve(false);
|
|
}
|
|
_everyAfterResumeProcess(): Promise<boolean> {
|
|
if (this.settings.remoteType == REMOTE_P2P) {
|
|
// // If LiveSync enabled, open replication
|
|
// if (this.settings.liveSync) {
|
|
// fireAndForget(() => this.core.replicator.openReplication(this.settings, true, false, false));
|
|
// }
|
|
// // If sync on start enabled, open replication
|
|
// if (!this.settings.liveSync && this.settings.syncOnStart) {
|
|
// // Possibly ok as if only share the result
|
|
// fireAndForget(() => this.core.replicator.openReplication(this.settings, false, false, false));
|
|
// }
|
|
}
|
|
|
|
return Promise.resolve(true);
|
|
}
|
|
onBindFunction(core: LiveSyncCore, services: typeof core.services): void {
|
|
services.replicator.getNewReplicator.addHandler(this._anyNewReplicator.bind(this));
|
|
services.appLifecycle.onResumed.addHandler(this._everyAfterResumeProcess.bind(this));
|
|
}
|
|
}
|