mnemo_cards/mnemo_cards_backend/lib/cron/check_admins.dart

import 'dart:io';

import 'package:isar/isar.dart';
import 'package:mnemo_cards_backend/cron/task.dart';
import 'package:mnemo_cards_common_backend/mnemo_cards_common_backend.dart';

import '../main.dart';

class CheckAdminsTask with Task {
  @override
  String get name => 'check_admins';

  @override
  Future<void> task() async {
    final file = File('admins');
    if (!file.existsSync()) {
      return;
    }
    final lines = file.readAsLinesSync();
    List<int> adminIds = [];
    for (final line in lines) {
      final token = line.trim();
      print('$name lines: ${lines.length}');
      if (token.isNotEmpty) {
        await isar.writeTxn(() async {
          final tokenModel = await isar.tokenModels
              .filter()
              .externalUserIdEqualTo(token)
              .findFirst();
          if (tokenModel == null) {
            return;
          }
          final user = await isar.userModels.get(tokenModel.userId);
          if (user != null) {
            adminIds.add(user.id!);
            if (!user.admin) {
              await isar.userModels.put(user.copyWith.admin(true));
            }
          }
        });
      }
    }
    // isar.writeTxn(() async {
    //   final admins =
    //       await isar.userModels.filter().adminEqualTo(true).findAll();
    //   final notAdmins = admins
    //       .where((u) => !adminIds.contains(u.id))
    //       .map((u) => u.copyWith.admin(false))
    //       .toList();
    //   await isar.userModels.putAll(notAdmins);
    // });
  }

  @override
  int get intervalSeconds => 300;
}