sensorconnector.dart

import 'dart:convert';
import 'package:flutter/cupertino.dart';
import 'package:http/http.dart' as http;
import 'datamodel.dart';

class SensorConnector {
  final String baseUrl = 'https://sandbox.sensor.awi.de/rest/';
  final String loginUrl = 'sensors/contacts/login';
  final String collectionsUrl = 'sensors/collections/getAllCollections?pointInTime=2018-07-03T12%3A30%3A55.389Z';
  final String eventTypesUrl = 'sensors/events/getAllEventTypes';
  final String collectionItemsUrl = 'sensors/collections/getItemsOfCollection/';  // + collectionId
  final String putEventUrl = 'sensors/events/putEvent/';  // + eventId;

  Future<String> getAuthToken(String username, String password) async {
    String url = baseUrl + loginUrl;
    String? token;

    Map<String, dynamic> body = {
      'username': username,
      'authPassword': password
    };
    String encodedBody = body.keys.map((key) => "$key=${body[key]}").join("&");

    final response = await http.post(Uri.parse(url),
        body: encodedBody,
        headers: {
          'Accept': 'application/json',
          'Content-Type': 'application/x-www-form-urlencoded'
        },
        encoding: Encoding.getByName("utf-8")
    );
    if (response.statusCode == 200) {
      token = response.headers['set-cookie']?.split(';')[0];
      debugPrint('Login success. Token: ' + token!.toString());

    } else {
      debugPrint('Failed to login'
      'Header: ' + response.headers.toString() +
          ' StatusCode: ' +response.statusCode.toString() +
          ' Body: ' +response.body.toString());

      throw Exception('Failed to login');
    }
    return token;
  }

  Future<List<Collection>> fetchCollections() async {
    String url = baseUrl + collectionsUrl;
    List<Collection> collectionList = [];

    final response = await http.get(Uri.parse(url));
    if (response.statusCode == 200) {
      collectionList = (json.decode(response.body) as List)
          .map((i) => Collection.fromJson(i))
          .toList();
      debugPrint("Fetching Collections Success: " + collectionList.toString());
    } else {
      throw Exception('Failed to fetch Collections. '
          'Header: ' + response.headers.toString() +
          ' StatusCode: ' +response.statusCode.toString() +
          ' Body: ' +response.body.toString());
    }
    return collectionList;
  }

  Future<List<EventType>> fetchEventTypes() async {
    String url = baseUrl + eventTypesUrl;
    List<EventType> eventTypeList = [];

    final response = await http.get(Uri.parse(url));
    if (response.statusCode == 200) {
      //eventTypeList =  (json.decode(response.body) as List)
      //    .map((i) => EventType.fromSensorJson(i))
      //    .toList();

      List<dynamic> data = json.decode(response.body);
      for (var entry in data) {
        eventTypeList.add(EventType.fromSensorJson(entry));
      }
      debugPrint("Fetching Event Types Success: " + eventTypeList.toString());
    } else{
      throw Exception('Failed to fetch event types. '
          'Header: ' + response.headers.toString() +
          ' StatusCode: ' +response.statusCode.toString() +
          ' Body: ' +response.body.toString());
    }
    return eventTypeList;
  }

  Future<List<Device>> fetchCollectionDevices(int collectionId) async {
    String url = baseUrl + collectionItemsUrl + collectionId.toString();
    List<Device> collectionDevices = [];

    final response = await http.get(Uri.parse(url));
    if (response.statusCode == 200) {
      List<dynamic> data = json.decode(response.body);
      for (var entry in data) {
        collectionDevices.add(Device.fromJson(entry));
      }
      debugPrint("Fetching Collection Devices Success: " + collectionDevices.toString());

    } else {
      throw Exception('Failed to load Collection Devices. '
          'Header: ' + response.headers.toString() +
          ' StatusCode: ' +response.statusCode.toString() +
          ' Body: ' +response.body.toString());
    }
    return collectionDevices;
  }


  Future<bool> putEvent(Event event, String authToken) async {
    // Create url with corresponding device id:
    String url = baseUrl + putEventUrl + event.urnId.toString() + '?createVersion=false';
    final response = await http.put(Uri.parse(url),
      headers: {
        "Content-Type": "application/json",
        "Cookie": authToken
      },
      body: event.toSensorJson().toString(),
      encoding: Encoding.getByName("utf-8"),
    );
    if (response.statusCode == 201) {
      return true;
    } else {
      throw Exception('Failed to put event. '
          'Header: ' + response.headers.toString() +
          ' StatusCode: ' +response.statusCode.toString() +
          ' Body: ' +response.body.toString());
      return false;
    }
  }

}