class ProfileDataSource {
  final ApiClient _client;

  ProfileDataSource(this._client);

  Future<Response> getMyProfile() => _client.get('/api/v1/profile');

  Future<Response> updateMyProfile(UpdateProfileBody body) =>
      _client.put('/api/v1/profile', data: body.toJson());

  Future<Response> getOrganisations({int page = 1, String? search}) =>
      _client.get('/api/v1/organisations', params: {'page': page, 'search': search});
}

Future<ProfileModel?> getIfFresh({
  Duration maxAge = const Duration(hours: 1),
}) async {
  final rows = await db.query(ProfileTable.table, limit: 1);
  if (rows.isEmpty) return null;

  final cachedAt = rows.first[ProfileTable.cachedAt] as int;
  final age = DateTime.now().millisecondsSinceEpoch - cachedAt;
  if (age > maxAge.inMilliseconds) return null; // stale

  return ProfileModel.fromMap(rows.first);
}

Future<void> upsert(ProfileModel model) async {
  await db.insert(ProfileTable.table, {
    ...model.toMap(),
    ProfileTable.cachedAt: DateTime.now().millisecondsSinceEpoch,
  }, conflictAlgorithm: ConflictAlgorithm.replace);
}