Seshat/lib/data/services/api_client.dart

import 'dart:convert';

import 'package:flutter/cupertino.dart';
import 'package:flutter_secure_storage/flutter_secure_storage.dart';
import 'package:http/http.dart';
import 'package:seshat/config/constants.dart';
import 'package:seshat/domain/models/bal.dart';
import 'package:seshat/domain/models/book.dart';
import 'package:seshat/domain/models/book_instance.dart';
import 'package:seshat/domain/models/owner.dart';
import 'package:seshat/utils/command.dart';
import 'package:seshat/utils/result.dart';

typedef AuthHeaderProvider = String? Function();

class ApiClient {
  ApiClient({String? host, int? port});

  late final Command0 load;
  String? token;
  bool isReady = false;
  FlutterSecureStorage? _secureStorage;

  Future<void> _initStore() async {
    _secureStorage ??= const FlutterSecureStorage(
      aOptions: AndroidOptions(encryptedSharedPreferences: true),
    );
  }

  Future<Map<String, String>> _getHeaders([
    Map<String, String>? additionalHeaders,
  ]) async {
    await _initStore();
    final token = await _secureStorage!.read(key: "token");
    final headers = {"Authorization": "Bearer $token", ...?additionalHeaders};
    return headers;
  }

  /*
 * ===================
 * =====[ BOOKS ]=====
 * ===================
*/

  Future<Result<Book>> getBookByEAN(String ean) async {
    final client = Client();
    try {
      final headers = await _getHeaders();
      final response = await client.get(
        Uri.parse("https://$apiBasePath/book/ean/$ean"),
        headers: headers,
      );
      debugPrint("\n\n\n\nGOT : ${response.statusCode}\n\n\n\n");
      if (response.statusCode == 200) {
        debugPrint("\n\n\n\nWITH : ${response.body}\n\n\n\n");
        final json = jsonDecode(response.body);
        return Result.ok(Book.fromJSON(json));
      } else {
        debugPrintStack();
        return Result.error(Exception("The book was not found"));
      }
    } catch (e, stackTrace) {
      debugPrintStack(stackTrace: stackTrace);
      return Result.error(Exception("API $e"));
    } finally {
      client.close();
    }
  }

  /*
 * =============================
 * =====[ BOOKS INSTANCES ]=====
 * =============================
*/

  Future<Result<BookInstance>> sendBook(
    Book book,
    Owner owner,
    Bal bal,
    double price,
  ) async {
    final client = Client();
    try {
      final headers = await _getHeaders({"Content-Type": "application/json"});
      final body = jsonEncode({
        "bal_id": bal.id,
        "book_id": book.id,
        "owner_id": owner.id,
        "price": price,
      });
      debugPrint("\n\n\n\nSENDING : ${body}\n\n\n\n");
      final response = await client.post(
        Uri.parse("https://$apiBasePath/book_instance"),
        headers: headers,
        body: body,
      );
      if (response.statusCode == 201) {
        final json = jsonDecode(response.body);
        debugPrint("\n\n\n\nRECEIVED : ${json}\n\n\n\n");
        return Result.ok(BookInstance.fromJSON(json));
      } else if (response.statusCode == 403) {
        return Result.error(Exception("You don't own that book instance"));
      } else {
        return Result.error(Exception("Something wrong happened"));
      }
    } catch (e, stack) {
      debugPrintStack(stackTrace: stack);
      return Result.error(Exception(e));
    } finally {
      client.close();
    }
  }

  /*
 * ====================
 * =====[ OWNERS ]=====
 * ====================
*/

  /// Call on `/owners` to get a list of all [Owner]s
  Future<Result<List<Owner>>> getOwners() async {
    final client = Client();
    try {
      final headers = await _getHeaders();
      final response = await client.get(
        Uri.parse("https://$apiBasePath/owners"),
        headers: headers,
      );
      if (response.statusCode == 200) {
        final json = jsonDecode(response.body) as List<dynamic>;
        return Result.ok(
          json.map((element) => Owner.fromJSON(element)).toList(),
        );
      } else {
        return Result.error(Exception("Invalid request"));
      }
    } on Exception catch (error) {
      return Result.error(error);
    } finally {
      client.close();
    }
  }

  /// Adds an owner to the database
  Future<Result<Owner>> addOwner(
    String firstName,
    String lastName,
    String contact,
  ) async {
    final client = Client();
    try {
      final headers = await _getHeaders({"Content-Type": "application/json"});
      final body = {
        "first_name": firstName,
        "last_name": lastName,
        "contact": contact,
      };
      final response = await client.post(
        Uri.parse("https://$apiBasePath/owner"),
        headers: headers,
        body: jsonEncode(body),
      );
      if (response.statusCode == 201) {
        final json = jsonDecode(response.body);
        return Result.ok(Owner.fromJSON(json));
      } else {
        return Result.error(Exception("Invalid request"));
      }
    } on Exception catch (error) {
      return Result.error(error);
    } finally {
      client.close();
    }
  }
}