silvanocerza_github-gitless-sync/src/metadata-store.ts

import { Vault, normalizePath } from "obsidian";

/**
 * A file metadata.
 * Store info that makes easier to track a file locally and in the remote repo.
 */
export interface FileMetadata {
  // Local path to the file
  localPath: string;
  // Path to the file in the remote repository.
  remotePath: string;
  // SHA of the file in the remote repository.
  // This is necessary to update the file remotely.
  // If this is null the file has not yet been pushed to the remote repository.
  sha: string | null;
  // Whether the file has been modified locally.
  dirty: boolean;
  // This is mostly used to track if the file has been just downloaded from the remote.
  // This is necessary since even when creating a file programatically after it has been
  // downloaded it will trigger a 'create' or 'modify' event.
  // This is a problem as we can't know whether an event has been triggered by us or the user.
  justDownloaded: boolean;
}

export interface Metadata {
  [key: string]: FileMetadata;
}

/**
 * Stores files metadata between sesssions.
 * Data is saved as JSON in the .obsidian folder in the current Vault.
 */
export default class MetadataStore {
  data: Metadata;
  private metadataFile: string;
  private writeQueue: Promise<void> = Promise.resolve();

  constructor(private vault: Vault) {
    this.metadataFile = normalizePath(
      `${this.vault.configDir}/github-sync-metadata.json`,
    );
  }

  /**
   * Loads the metadata from disk.
   */
  async load() {
    const fileExists = await this.vault.adapter.exists(this.metadataFile);
    if (fileExists) {
      const content = await this.vault.adapter.read(this.metadataFile);
      this.data = JSON.parse(content);
    } else {
      this.data = {};
    }
  }

  /**
   * Save current metadata to disk.
   */
  async save() {
    this.writeQueue = this.writeQueue.then(async () => {
      await this.vault.adapter.write(
        this.metadataFile,
        JSON.stringify(this.data),
      );
    });
    return this.writeQueue;
  }
}