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(); 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.id.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; } } }