storeAllFromJson method

FutureOr<Map<String, List<Object>>> storeAllFromJson(Map<String, Iterable<Map<String, dynamic>>> entries, { Transaction? transaction, EntityResolutionRules? resolutionRules, Map<String, dynamic>? variables, })

Implementation

FutureOr<Map<String, List<Object>>> storeAllFromJson(
    Map<String, Iterable<Map<String, dynamic>>> entries,
    {Transaction? transaction,
    EntityResolutionRules? resolutionRules,
    Map<String, dynamic>? variables}) async {
  var results = <String, List<Object>>{};

  var allRepositoriesBuildOrder =
      allRepositories().values.toList(growable: false);

  var entriesRepositoriesOrdered = entries.entries.map((e) {
    var typeName = e.key;
    var entities = e.value;
    var entityRepository = getEntityRepository(name: typeName);
    return MapEntry(typeName, (entities, entityRepository));
  }).sorted((a, b) {
    var rep1 = a.value.$2;
    var rep2 = b.value.$2;

    var idx1 = rep1 != null ? allRepositoriesBuildOrder.indexOf(rep1) : -1;
    var idx2 = rep2 != null ? allRepositoriesBuildOrder.indexOf(rep2) : -1;

    if (idx1 < 0) {
      idx1 = 9999999;
    }

    if (idx2 < 0) {
      idx2 = 9999999;
    }

    return idx1.compareTo(idx2);
  }).toMapFromEntries();

  _log.info('Repositories build order:');
  for (var e in entriesRepositoriesOrdered.entries) {
    var typeName = e.key;
    _log.info('  -- $typeName');
  }

  for (var e in entriesRepositoriesOrdered.entries) {
    var typeName = e.key;
    var typeEntries = e.value.$1;
    var entityRepository = e.value.$2;

    if (typeEntries.isEmpty) {
      results[typeName] = [];
      continue;
    }

    _log.info(
        'Populating `$typeName`: ${typeEntries.length} JSON entries...$_logSectionOpen');

    if (entityRepository == null) {
      throw StateError(
          "Can't find `EntityRepository` for type name: $typeName");
    }

    try {
      var os = await entityRepository.storeAllFromJson(typeEntries,
          resolutionRules: resolutionRules);
      results[typeName] = os;

      _log.info(
          'Populated `$typeName` entries: ${os.length}$_logSectionClose');
    } catch (e, s) {
      _log.severe('Error population `$typeName` entries.', e, s);
      rethrow;
    }
  }

  return results;
}