GitJournal/lib/storage/git_storage.dart

import 'dart:async';

import 'package:flutter/foundation.dart';
import 'package:journal/apis/git.dart';
import 'package:journal/note.dart';
import 'package:journal/settings.dart';
import 'package:journal/storage/file_storage.dart';
import 'package:journal/storage/notes_repository.dart';
import 'package:journal/storage/serializers.dart';
import 'package:path/path.dart' as p;

class GitNoteRepository implements NoteRepository {
  final FileStorage _fileStorage;
  final String dirName;
  final String subDirName;

  bool cloned = false;
  bool checkForCloned = false;

  GitNoteRepository({
    @required this.dirName,
    @required this.subDirName,
    @required String baseDirectory,
  }) : _fileStorage = FileStorage(
          noteSerializer: MarkdownYAMLSerializer(),
          baseDirectory: p.join(baseDirectory, dirName, subDirName),
        );

  @override
  Future<NoteRepoResult> addNote(Note note) async {
    return _addNote(note, "Added Journal Entry");
  }

  Future<NoteRepoResult> _addNote(Note note, String commitMessage) async {
    var result = await _fileStorage.addNote(note);
    if (result.error) {
      return result;
    }

    await gitAdd(dirName, '.');
    await gitCommit(
      gitFolder: dirName,
      authorEmail: Settings.instance.gitAuthorEmail,
      authorName: Settings.instance.gitAuthor,
      message: commitMessage,
    );

    return result;
  }

  @override
  Future<NoteRepoResult> removeNote(Note note) async {
    var result = await _fileStorage.addNote(note);
    if (result.error) {
      return result;
    }

    // FIXME: '/' is not valid on all platforms
    var baseDir = _fileStorage.baseDirectory;
    var filePath = result.noteFilePath.replaceFirst(baseDir + "/", "");

    await gitRm(dirName, filePath);
    await gitCommit(
      gitFolder: dirName,
      authorEmail: Settings.instance.gitAuthorEmail,
      authorName: Settings.instance.gitAuthor,
      message: "Removed Journal entry",
    );

    return result;
  }

  Future<NoteRepoResult> resetLastCommit() async {
    await gitResetLast(dirName);
    return NoteRepoResult(error: false);
  }

  @override
  Future<NoteRepoResult> updateNote(Note note) async {
    return _addNote(note, "Edited Journal Entry");
  }

  @override
  Future<List<Note>> listNotes() {
    return _fileStorage.listNotes();
  }

  @override
  Future<bool> sync() async {
    try {
      await gitPull(dirName);
    } on GitException catch (ex) {
      print(ex);
    }

    try {
      await gitPush(dirName);
    } on GitException catch (ex) {
      print(ex);
      rethrow;
    }

    return true;
  }
}