dump method

Future<APIResponse<Object>> dump(bool zip)

Implementation

Future<APIResponse<Object>> dump(bool zip) async {
  if (onlyOnDevelopment && !development) {
    return APIResponse.error(error: "Unsupported request!");
  }

  _log.info("APIDBModule[REQUEST]> dump");

  var allRepositories = (await entityRepositoryProviders).allRepositories();

  var dump = await allRepositories.values
      .map((repo) => MapEntry(repo.name, repo.selectAll()))
      .toMapFromEntries()
      .resolveAllValues();

  var dumpJson = dump.entries
      .map((e) => MapEntry(e.key, _entitiesToJsonMap(e.value)))
      .where((e) => e.value.isNotEmpty)
      .toMapFromEntries();

  if (zip) {
    var apiName = apiRoot.name.toLowerCase().trim().replaceAll(
      RegExp(r'\W+'),
      '_',
    );

    var zipTime = DateTime.now().millisecondsSinceEpoch;

    var zipName = 'db-dump--$apiName--$zipTime';

    var archive = Archive();

    {
      var dumpJsonBytes = Json.encodeToBytes(dumpJson);

      var archiveFile = ArchiveFile(
        '$zipName/dump.json',
        dumpJsonBytes.length,
        dumpJsonBytes,
      );
      archive.addFile(archiveFile);
    }

    var zipEncoder = ZipEncoder();

    var encode = zipEncoder.encode(archive);
    var zipData = encode is Uint8List ? encode : Uint8List.fromList(encode);

    var zipFileName = '$zipName.zip';

    return APIResponse.ok(
      zipData,
      mimeType: 'application/zip',
      headers: {'Content-Disposition': 'attachment; filename="$zipFileName"'},
    );
  }

  return APIResponse.ok(dumpJson, mimeType: 'json');
}