import 'dart:convert';

import 'package:pocketbase/pocketbase.dart';
import 'package:uae_stat/config/api_config.dart';

abstract class PocketBaseService {
  static const _host = apiUrl;
  // static const _host = 'https://pb.venbait.in';
  // static const _host = 'http://127.0.0.1:8090';
  static final _pb = PocketBase(_host);
  static final users = _pb.collection('users');
  static final authStore = _pb.authStore;
}

/// must assign [T] as entity, which must have
/// [jsonEncode] and [jsonDecode] methods. In
/// pocketbase, records must be stored in one
/// column: data as type json. [V] is entity id
/// type
class PbCollection<T> {
  PbCollection(
    this.collectionIdOrName, {
    required this.fromJson,
    this.isNestedInJsonData = true,
  });

  final String collectionIdOrName;
  final T Function(dynamic json) fromJson;
  final bool isNestedInJsonData;
  Map<T, String>? _entityIdToModelId;

  RecordService get _collection => PocketBaseService._pb.collection(
        collectionIdOrName,
      );

  Future<List<T>> getAll([
    Map<String, dynamic>? filter,
  ]) async {
    final modelList = await _collection.getFullList(
      filter: filter?.entries
          .map(
            (e) => isNestedInJsonData
                ? 'data.${e.key}=${e.value}'
                : '${e.key} = "${e.value}"',
          )
          .join(' '),
    );
    final entityList = modelList.map(
      (model) {
        final source = isNestedInJsonData ? model.data['data'] : model.data;
        if (!isNestedInJsonData) source['id'] = model.id;
        final entity = fromJson(source);
        _entityIdToModelId ??= {};
        _entityIdToModelId![entity] = model.id;
        return entity;
      },
    ).toList();
    return entityList;
  }

  Future<T> get([
    Map<String, dynamic> filter = const {},
  ]) {
    final filterString = filter.isEmpty
        ? ''
        : filter.entries
            .map(
              (e) => isNestedInJsonData
                  ? 'data.${e.key}=${jsonEncode(e.value)}'
                  : '${e.key} = ${jsonEncode(e.value)}',
            )
            .join(' ');
    return _collection
        .getFirstListItem(
          filterString,
        )
        .then(
          (value) => fromJson(value.data['data']),
        );
  }

  Future<void> delete(
    T entity,
  ) =>
      _collection.delete(
        _entityIdToModelId![entity]!,
      );

  Future<void> write(T e) => _collection.create(
        body: isNestedInJsonData
            ? {'data': e}
            : jsonDecode(
                jsonEncode(e),
              ),
      );
}