import 'data/gateway.dart';

/// Call sites of the declarative gateway, resolved through adapters.json.
class ScheduledJobs {
  ScheduledJobs(this.gateway);

  final Gateway gateway;

  Future<void> reconcile(List<String> statuses) async {
    await gateway.queryCollectionGroup(
      'settlements',
      inFilter: WhereIn('status', statuses),
      limit: 200,
    );
  }

  Future<void> digest(String userId, DateTime from, DateTime to) async {
    await gateway.queryCollection(
      'notifications',
      filters: [
        WhereEquals('userId', userId),
        const WhereEquals('isRead', false),
      ],
      ranges: [WhereRange('createdAt', gte: from, lt: to)],
      orderBy: const [OrderBy('createdAt', descending: true)],
    );
  }

  Future<void> followers(
      String authorId, String? cursor, bool onlyActive) async {
    final filters = <WhereEquals>[];
    if (onlyActive) {
      filters.add(const WhereEquals('active', true));
    }
    await gateway.queryCollection(
      'users',
      filters: filters,
      arrayContains: WhereArrayContains('following', authorId),
      orderBy: const [OrderBy('__name__')],
      startAfterId: cursor,
      limit: 500,
    );
  }

  Future<void> storeScoped(String storeId, int threshold) async {
    await gateway.queryCollection(
      'stores/$storeId/payouts',
      ranges: [WhereCmp('amount', Cmp.greaterThan, threshold)],
    );
  }

  Future<void> confirm(String token) async {
    await gateway.runTransaction((txn) async {
      return txn.queryCollection(
        'confirmations',
        filters: [WhereEquals('token', token)],
        limit: 1,
      );
    });
  }

  Future<void> concrete(InMemoryGateway memory, List<String> ids) async {
    for (final id in ids) {
      await memory
          .queryCollection('carts', filters: [WhereEquals('owner', id)]);
    }
  }

  Future<void> notAQuery(String path) async {
    await gateway.getDocument(path);
  }
}