import 'dart:convert'; import 'package:logging/logging.dart'; import 'package:nc_photos/account.dart'; import 'package:nc_photos/api/api.dart'; import 'package:nc_photos/entity/person.dart'; import 'package:nc_photos/entity/sqlite_table_converter.dart'; import 'package:nc_photos/exception.dart'; import 'package:nc_photos/type.dart'; import 'package:nc_photos/entity/sqlite_table.dart' as sql; import 'package:nc_photos/entity/sqlite_table_extension.dart' as sql; class PersonRemoteDataSource implements PersonDataSource { const PersonRemoteDataSource(); @override list(Account account) async { _log.info("[list] $account"); final response = await Api(account).ocs().facerecognition().persons().get(); if (!response.isGood) { _log.severe("[list] Failed requesting server: $response"); throw ApiException( response: response, message: "Server responed with an error: HTTP ${response.statusCode}"); } final json = jsonDecode(response.body); final List dataJson = json["ocs"]["data"].cast(); return _PersonParser().parseList(dataJson); } static final _log = Logger("entity.person.data_source.PersonRemoteDataSource"); } class PersonSqliteDbDataSource implements PersonDataSource { const PersonSqliteDbDataSource(this.sqliteDb); @override list(Account account) async { _log.info("[list] $account"); final dbPersons = await sqliteDb.use((db) async { return await db.allPersons(appAccount: account); }); return dbPersons.convertToAppPerson(); } final sql.SqliteDb sqliteDb; static final _log = Logger("entity.person.data_source.PersonSqliteDbDataSource"); } class _PersonParser { List parseList(List jsons) { final product = []; for (final j in jsons) { try { product.add(parseSingle(j)); } catch (e) { _log.severe("[parseList] Failed parsing json: ${jsonEncode(j)}", e); } } return product; } Person parseSingle(JsonObj json) { return Person( name: json["name"], thumbFaceId: json["thumbFaceId"], count: json["count"], ); } static final _log = Logger("entity.person.data_source._PersonParser"); }