todos-contra-el-fuego-mobile/lib/models/firesApi.dart

import 'dart:async';
import 'dart:convert';

import 'package:dio/dio.dart';
import 'package:fires_flutter/models/yourLocation.dart';
import 'package:flutter/material.dart';
import 'package:flutter_map/flutter_map.dart';
import 'package:latlong2/latlong.dart';

import '../globals.dart' as globals;
import '../objectIdUtils.dart';
import '../redux/actions.dart';
import 'appState.dart';
import 'falsePositiveTypes.dart';

class FiresApi {
  late final Dio _dio;

  FiresApi() {
    _dio = Dio();
  }

  Future<String> createUser(
      AppState state, String mobileToken, String lang) async {
    final params = {
      "token": state.firesApiKey,
      "mobileToken": mobileToken,
      "lang": lang
    };
    final String url = '${state.firesApiUrl}mobile/users';
    try {
      final response = await _dio.post(url, data: params);
      if (response.statusCode == 200) {
        return response.data['data']['userId'] as String;
      } else {
        throw "Unexpected error on create user";
      }
    } catch (e) {
      throw "Error creating user: $e";
    }
  }

  Future<List<YourLocation>> fetchYourLocations(AppState state) async {
    final apiKey = state.firesApiKey;
    final mobileToken = state.user.token;
    final String url =
        '${state.firesApiUrl}mobile/subscriptions/all/$apiKey/$mobileToken';
    try {
      final response = await _dio.get(url);
      if (response.statusCode == 200) {
        final dataSubscriptions =
            response.data['data']['subscriptions'] as List<dynamic>;
        List<YourLocation> subscribed = [];
        for (int i = 0; i < dataSubscriptions.length; i++) {
          var el = dataSubscriptions[i] as Map<String, dynamic>;
          var lat = (el['location']['lat'] as num).toDouble();
          var lon = (el['location']['lon'] as num).toDouble();
          subscribed.add(YourLocation(
              id: objectIdFromJson(el['_id']['_str'] as String),
              lat: lat,
              lon: lon,
              subscribed: true,
              distance: (el['distance'] as num).toInt()));
        }
        return subscribed;
      } else {
        throw "Unexpected error fetching your locations";
      }
    } catch (e) {
      throw "Error fetching locations: $e";
    }
  }

  Future<String> subscribe(AppState state, YourLocation loc) async {
    final params = {
      "token": state.firesApiKey,
      "mobileToken": state.user.token,
      "id": loc.id.hexString,
      "lat": loc.lat,
      "lon": loc.lon,
      "distance": loc.distance
    };
    final String url = '${state.firesApiUrl}mobile/subscriptions';
    try {
      final response = await _dio.post(url, data: params);
      if (response.statusCode == 200) {
        return response.data['data']['subsId'] as String;
      } else {
        print(response.data);
        throw "Unexpected error on subscribe";
      }
    } catch (e) {
      throw "Error subscribing: $e";
    }
  }

  Future<bool> unsubscribe(AppState state, String subsId) async {
    final apiKey = state.firesApiKey;
    final mobileToken = state.user.token;
    final String url =
        '${state.firesApiUrl}mobile/subscriptions/$apiKey/$mobileToken/$subsId';
    try {
      final response = await _dio.delete(url);
      if (response.statusCode == 200) {
        return true;
      } else {
        throw "Unexpected error on unsubscribe";
      }
    } catch (e) {
      throw "Error unsubscribing: $e";
    }
  }

  Future<UpdateFireMapStatsAction> getFiresInLocation(
      {required AppState state,
      required double lat,
      required double lon,
      required int distance}) async {
    var url =
        '${state.firesApiUrl}fires-in-full/${state.firesApiKey}/$lat/$lon/$distance';
    if (globals.isDevelopment) print(url);
    try {
      final response = await _dio.get(url);
      if (response.statusCode == 200) {
        var resultDecoded = response.data;
        int numFires = (resultDecoded['real'] as num).toInt();
        List<dynamic> fires = resultDecoded['fires'] as List<dynamic>;
        List<dynamic> falsePos = resultDecoded['falsePos'] as List<dynamic>;
        List<dynamic> industries = resultDecoded['industries'] as List<dynamic>;

        if (globals.isDevelopment) {
          var firesCount = fires.length;
          var industriesCount = industries.length;
          var falsePosCount = falsePos.length;
          print(
              '(Pos: $lat, $lon) real: $numFires, fire: $firesCount falsePos: $falsePosCount industries: $industriesCount');
        }
        return UpdateFireMapStatsAction(
            numFires: numFires,
            fires: fires,
            falsePos: falsePos,
            industries: industries);
      } else
        throw Exception('Wrong response trying to get fire data');
    } catch (e) {
      throw Exception('Error getting fires: $e');
    }
  }

  Future<List<Polyline>> getMonitoredAreas({required AppState state}) async {
    var url =
        '${state.firesApiUrl}status/subs-public-union/${state.firesApiKey}';
    var color = const Color(0xFF145A32);
    try {
      final response = await _dio.get(url);
      if (response.statusCode == 200) {
        var resultDecoded = response.data;
        List<Polyline> union = [];
        final multipolygon =
            (json.decode(resultDecoded['data']['union']['value'] as String)
                    as Map<String, dynamic>)['geometry']['coordinates']
                as List<dynamic>;
        for (dynamic polygonDynamic in multipolygon) {
          var polygon = polygonDynamic as List<dynamic>;
          for (dynamic holeDynamic in polygon) {
            var hole = holeDynamic as List<dynamic>;
            List<LatLng> points = [];
            for (dynamic pointDynamic in hole) {
              var point = pointDynamic as List<dynamic>;
              points.add(LatLng(
                  (point[1] as num).toDouble(), (point[0] as num).toDouble()));
            }
            union.add(Polyline(points: points, color: color, strokeWidth: 3.0));
          }
        }
        return union;
      } else
        throw Exception('Wrong response trying to get fire data');
    } catch (e) {
      throw Exception('Error getting monitored areas: $e');
    }
  }

  Future<bool> markFalsePositive(AppState state, String mobileToken,
      String sealed, FalsePositiveType type) async {
    final params = {
      "token": state.firesApiKey,
      "mobileToken": mobileToken,
      "sealed": sealed,
      "type": type.toString().split('.')[1]
    };
    final String url = '${state.firesApiUrl}mobile/falsepositive';
    try {
      final response = await _dio.post(url, data: params);
      if (response.statusCode == 200) {
        if (globals.isDevelopment) print(response.data['data']['upsert']);
        return true;
      } else {
        debugPrint(response.data.toString());
        return false;
      }
    } catch (e) {
      debugPrint("Error marking false positive: $e");
      return false;
    }
  }
}