andras/vault-link
1
0
Fork 0
Code Issues Pull requests 18 Projects Releases 55 Packages Wiki Activity Actions 1

Small clean up

Browse source
This commit is contained in:
Andras Schmelczer 2025-11-29 14:24:15 +00:00
parent 84f077f36b
commit 5417c1ddd0
3 changed files with 11 additions and 9 deletions
Download patch file Download diff file Expand all files Collapse all files

3
frontend/sync-client/src/persistence/database.ts
View file

@ -198,6 +198,9 @@ export class Database {
relativePath: RelativePath,
promise: Promise<unknown>
): DocumentRecord {
this.logger.debug(
`Creating new pending document: ${relativePath} (${documentId})`
);
const previousEntry =
this.getLatestDocumentByRelativePath(relativePath);

5
frontend/sync-client/src/services/websocket-manager.ts
View file

@ -282,13 +282,10 @@ export class WebSocketManager {
this.logger.debug(
`Received cursor positions for ${JSON.stringify(message.clients)}`
);
const filteredClients = message.clients.filter(
(client) => client.deviceId !== this.deviceId
);
await awaitAll(
this.remoteCursorsUpdateListeners.map(async (listener) => {
await listener(filteredClients).catch((error: unknown) => {
await listener(message.clients).catch((error: unknown) => {
this.logger.error(
`Error in cursor positions listener: ${String(error)}`
);

12
frontend/sync-client/src/sync-operations/unrestricted-syncer.ts
View file

@ -69,19 +69,18 @@ export class UnrestrictedSyncer {
};
return this.executeSync(updateDetails, async () => {
const originalRelativePath = document.relativePath;
if (document.isDeleted) {
this.logger.debug(
`Document ${document.relativePath} has been already deleted, no need to create it`
`Document ${originalRelativePath} has been already deleted, no need to create it`
);
return;
}
const contentBytes = await this.operations.read(
document.relativePath
); // this can throw FileNotFoundError
const contentBytes =
await this.operations.read(originalRelativePath); // this can throw FileNotFoundError
const contentHash = hash(contentBytes);
const originalRelativePath = document.relativePath;
const response = await this.syncService.create({
documentId: document.documentId,
relativePath: originalRelativePath,
@ -99,6 +98,9 @@ export class UnrestrictedSyncer {
// In case a document with the same name (but different ID) had existed remotely that we haven't known about
if (response.relativePath != originalRelativePath) {
this.logger.debug(
`Document ${originalRelativePath} has been created remotely at a different path: ${response.relativePath}, moving it locally`
);
await this.operations.move(
document.relativePath,
response.relativePath