phylum/client/lib/libphylum/responses/shared_resources_response.dart

part of 'responses.dart';

class SharedResourcesResponse extends PhylumApiSuccessResponse {
  final Iterable<ResourcesCompanion> resources;

  @override
  Future<void> process(PhylumAccount account) async {
    final shared = resources.indexed.map((r) => SharedCompanion.insert(resourceId: r.$2.id.value, seq: r.$1));
    await account.db.batch((batch) {
      batch.insertAllOnConflictUpdate(account.db.resources, resources);
      batch.deleteAll(account.db.shared);
      batch.insertAll(account.db.shared, shared);
    });

    final repo = account.datastore.get<Resource>();
    for (final r in resources) {
      await repo.reloadRemoteData(r.id.value);
    }
  }

  SharedResourcesResponse({required this.resources});

  factory SharedResourcesResponse.fromResponse(Map<String, dynamic> data) {
    final resources = (data["shared"] as List).cast<Map>().map((u) => parsePartialResource(u.cast<String, dynamic>()));
    return SharedResourcesResponse(resources: resources);
  }
}