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;
}