flush method

Future<void> flush(File flushFile, IOSink flushSink)

Flushes data to the file, compress, encrypt, and close it.

Implementation

Future<void> flush(File flushFile, IOSink flushSink) async {
  // fast exit if we're already flushing this file/sink
  if (flushSink.hashCode == _flushingSink) return;

  _flushingSink = flushSink.hashCode;

  // Reset the file (setting it and its name and sink to null),
  // so a new file (and sink) can be created.
  _sink = null;
  _initialized = false;
  _filename = null;
  _file = null;

  final jsonFilePath = flushFile.path;
  var finalFilePath = jsonFilePath;

  info("Written JSON to file '$jsonFilePath'. Closing it.");
  flushSink.write('\n]\n');

  // once finished closing the file, then zip and encrypt it
  flushSink.close().then((value) {
    if (fileDataEndPoint.zip) {
      // create a new zip file and add the JSON file to this zip file
      final encoder = ZipFileEncoder();
      final jsonFile = File(jsonFilePath);
      finalFilePath = '$jsonFilePath.zip';
      encoder.create(finalFilePath);
      encoder.addFile(jsonFile);
      encoder.close();

      // once the file is zipped to a new zip file, delete the old JSON file
      jsonFile.delete();
    }

    // encrypt the zip file
    if (fileDataEndPoint.encrypt) {
      //TODO : implement encryption
      // if the encrypted file gets another name, remember to
      // update _jsonFilePath
      addEvent(FileDataManagerEvent(
          FileDataManagerEventTypes.fileEncrypted, finalFilePath));
    }

    addEvent(FileDataManagerEvent(
        FileDataManagerEventTypes.fileClosed, finalFilePath));
  });
}