7 files changed, 381 insertions, 0 deletions
diff --git a/lib/kuksa-server/intial_connection.dart b/lib/kuksa-server/intial_connection.dart
new file mode 100644
index 0000000..0ba4e9f
--- /dev/null
+++ b/lib/kuksa-server/intial_connection.dart
@@ -0,0 +1,44 @@
+// SPDX-License-Identifier: Apache-2.0
+
+import 'dart:io';
+import 'package:flutter/material.dart';
+import 'package:flutter_riverpod/flutter_riverpod.dart';
+import 'package:flutter_hvac/kuksa-server/vehicle_config.dart';
+
+import 'on_boarding_page.dart';
+
+class InitialScreen extends ConsumerWidget {
+  InitialScreen({Key? key, required this.client}) : super(key: key);
+  final HttpClient client;
+  late WebSocket socket;
+
+  @override
+  Widget build(BuildContext context, ref) {
+    final sockConnect = ref.watch(sockConnectprovider(client));
+
+    return sockConnect.when(
+      data: (socket) {
+        this.socket = socket;
+        this.socket.pingInterval = const Duration(seconds: 2);
+        return OnBoardingPage(client: client, socket: this.socket);
+      },
+      error: (e, stk) {
+        print(e);
+        ref.refresh(sockConnectprovider(client));
+        return const Scaffold(
+          backgroundColor: Colors.black,
+          body: Center(
+              child: Text(
+            'error',
+            style: TextStyle(color: Colors.white),
+          )),
+        );
+      },
+      loading: () => const Scaffold(
+        backgroundColor: Colors.black,
+        body: Center(
+            child: Text('loading', style: TextStyle(color: Colors.white))),
+      ),
+    );
+  }
+}
diff --git a/lib/kuksa-server/on_boarding_page.dart b/lib/kuksa-server/on_boarding_page.dart
new file mode 100644
index 0000000..a14145c
--- /dev/null
+++ b/lib/kuksa-server/on_boarding_page.dart
@@ -0,0 +1,65 @@
+// SPDX-License-Identifier: Apache-2.0
+
+import 'dart:async';
+import 'dart:io';
+
+import 'package:flutter/material.dart';
+import 'package:flutter_riverpod/flutter_riverpod.dart';
+import 'package:flutter_hvac/kuksa-server/vehicle_config.dart';
+import 'package:flutter_hvac/kuksa-server/vehicle_methods.dart';
+
+import '../home_page.dart';
+
+class OnBoardingPage extends ConsumerStatefulWidget {
+  const OnBoardingPage({Key? key, required this.client, required this.socket})
+      : super(key: key);
+  final WebSocket socket;
+  final HttpClient client;
+
+  @override
+  ConsumerState<OnBoardingPage> createState() => _OnBoardingPageState();
+}
+
+class _OnBoardingPageState extends ConsumerState<OnBoardingPage> {
+  late Timer _timer;
+  late WebSocket _socket;
+
+
+  @override
+  void initState() {
+    super.initState();
+    _socket = widget.socket;
+    VISS.init(widget.socket,ref);
+    _timer = Timer.periodic(const Duration(seconds: 2), (timer) {
+
+      if (widget.socket.readyState == 3) {
+        ref.refresh(sockConnectprovider(widget.client));
+      }
+    });
+    WidgetsBinding.instance.addPostFrameCallback((timeStamp) {
+      widget.socket.listen(
+        (data) {
+
+        },
+        onError: (e, stk) {
+          print(e.toString());
+          ref.refresh(sockConnectprovider(widget.client));
+        },
+      );
+    });
+  }
+
+  @override
+  void dispose() {
+    super.dispose();
+    _timer.cancel();
+    widget.socket.close(786887, "Connection lost with server!");
+  }
+
+  @override
+  Widget build(BuildContext context) {
+    return MyHome_Page(
+      socket: _socket,
+    );
+  }
+}
diff --git a/lib/kuksa-server/vehicle-class.dart b/lib/kuksa-server/vehicle-class.dart
new file mode 100644
index 0000000..a04ad90
--- /dev/null
+++ b/lib/kuksa-server/vehicle-class.dart
@@ -0,0 +1,53 @@
+// SPDX-License-Identifier: Apache-2.0
+
+class vehicle {
+  late bool isAcActive;
+  late bool isFrontDefrosterActive;
+  late bool isRearDefrosterActive;
+  late bool isAcDirectionUp;
+  late bool isAcDirectionDown;
+  late bool isAcDirectionMiddle;
+  late bool isRecirculationActive;
+  late bool isAutoActive;
+  late bool isFreshAirCirculateActive;
+
+  vehicle({
+    required this.isAcActive,
+    required this.isAcDirectionDown,
+    required this.isAcDirectionMiddle,
+    required this.isAcDirectionUp,
+    required this.isFrontDefrosterActive,
+    required this.isRearDefrosterActive,
+    required this.isRecirculationActive,
+    required this.isAutoActive,
+    required this.isFreshAirCirculateActive,
+  });
+
+  vehicle copywith({
+    bool? isAcActive,
+    bool? isAcDirectionDown,
+    bool? isAcDirectionMiddle,
+    bool? isAcDirectionUp,
+    bool? isFrontDefrosterActive,
+    bool? isRearDefrosterActive,
+    bool? isRecirculationActive,
+    bool? isAutoActive,
+    bool? isFreshAirCirculateActive,
+  }) {
+    return vehicle(
+      isAcActive: isAcActive ?? this.isAcActive,
+      isAcDirectionDown: isAcDirectionDown ?? this.isAcDirectionDown,
+      isAcDirectionMiddle: isAcDirectionMiddle ?? this.isAcDirectionMiddle,
+      isAcDirectionUp: isAcDirectionUp ?? this.isAcDirectionUp,
+      isFrontDefrosterActive:
+          isFrontDefrosterActive ?? this.isFrontDefrosterActive,
+      isRearDefrosterActive:
+          isRearDefrosterActive ?? this.isRearDefrosterActive,
+      isRecirculationActive:
+          isRecirculationActive ?? this.isRecirculationActive,
+      isAutoActive: isAutoActive ?? this.isAutoActive,
+      isFreshAirCirculateActive: isFreshAirCirculateActive ?? this.isFreshAirCirculateActive,
+
+    );
+  }
+}
diff --git a/lib/kuksa-server/vehicle-provider.dart b/lib/kuksa-server/vehicle-provider.dart
new file mode 100644
index 0000000..f070a53
--- /dev/null
+++ b/lib/kuksa-server/vehicle-provider.dart
@@ -0,0 +1,47 @@
+// SPDX-License-Identifier: Apache-2.0
+
+import 'package:flutter_riverpod/flutter_riverpod.dart';
+import 'package:flutter_hvac/kuksa-server/vehicle-class.dart';
+
+final vehicleProvider = StateNotifierProvider<VehicleSignal, vehicle>(
+  (ref) => VehicleSignal(),
+);
+
+class VehicleSignal extends StateNotifier<vehicle> {
+  static vehicle intial_value = vehicle(
+    isAcActive: false,
+    isAcDirectionDown: false,
+    isAcDirectionMiddle: false,
+    isAcDirectionUp: false,
+    isFrontDefrosterActive: false,
+    isRearDefrosterActive: false,
+    isRecirculationActive: false,
+    isAutoActive: false,
+    isFreshAirCirculateActive : false,
+  );
+  VehicleSignal() : super(intial_value);
+
+  void update({
+    bool? isAcActive,
+    bool? isAcDirectionDown,
+    bool? isAcDirectionUp,
+    bool? isAcDirectionMiddle,
+    bool? isFrontDefrosterActive,
+    bool? isRearDefrosterActive,
+    bool? isRecirculationActive,
+    bool? isAutoActive,
+    bool? isFreshAirCirculateActive,
+  }) {
+    state = state.copywith(
+      isAcActive: isAcActive,
+      isAcDirectionDown: isAcDirectionDown,
+      isAcDirectionMiddle: isAcDirectionMiddle,
+      isAcDirectionUp: isAcDirectionUp,
+      isFrontDefrosterActive: isFrontDefrosterActive,
+      isRearDefrosterActive: isRearDefrosterActive,
+      isRecirculationActive: isRecirculationActive,
+      isAutoActive : isAutoActive,
+      isFreshAirCirculateActive : isFreshAirCirculateActive,
+    );
+  }
+}
diff --git a/lib/kuksa-server/vehicle_config.dart b/lib/kuksa-server/vehicle_config.dart
new file mode 100644
index 0000000..6eff800
--- /dev/null
+++ b/lib/kuksa-server/vehicle_config.dart
@@ -0,0 +1,39 @@
+// SPDX-License-Identifier: Apache-2.0
+
+
+import 'dart:io';
+import 'package:flutter_hvac/config.dart';
+import 'package:flutter_riverpod/flutter_riverpod.dart';
+import 'package:http/http.dart' as http;
+
+
+
+final sockConnectprovider = FutureProvider.family<WebSocket, HttpClient>(
+    (ref, client) => connect(client,ref));
+
+
+
+// load certificates and set context and returns http client
+Future<HttpClient> initializeClient() async {
+
+
+  SecurityContext ctx = SecurityContext.defaultContext;
+
+  HttpClient client = HttpClient(context: ctx)
+    ..findProxy = null
+    ..badCertificateCallback = (cert, host, port) {
+      return true;
+    };
+  return client;
+}
+
+
+
+Future<WebSocket> connect(HttpClient client, ref) async {
+  final config = ref.read(ConfigStateprovider);
+  WebSocket socket = await WebSocket.connect(
+      "wss://${config.hostname}:${config.port}",
+      customClient: client);
+  return socket;
+}
+
diff --git a/lib/kuksa-server/vehicle_methods.dart b/lib/kuksa-server/vehicle_methods.dart
new file mode 100644
index 0000000..2dda79f
--- /dev/null
+++ b/lib/kuksa-server/vehicle_methods.dart
@@ -0,0 +1,97 @@
+// SPDX-License-Identifier: Apache-2.0
+
+import 'dart:convert';
+import 'dart:io';
+
+import 'package:flutter_hvac/config.dart';
+import 'package:flutter_riverpod/flutter_riverpod.dart';
+import 'package:flutter_hvac/kuksa-server/vehicle_server_path.dart';
+
+
+class VISS {
+  static const requestId = "test-id";
+  static void init(WebSocket socket,WidgetRef ref) {
+    authorize(socket,ref);
+
+    subscribe(socket,ref, VSPath.vehicleFrontLeftTier);
+    subscribe(socket,ref, VSPath.vehicleFrontRightTier);
+    subscribe(socket,ref, VSPath.vehicleRearLeftTier);
+    subscribe(socket,ref, VSPath.vehicleRearRightTier);
+    subscribe(socket,ref, VSPath.vehicleIsChildLockActiveLeft);
+    subscribe(socket,ref, VSPath.vehicleIsChildLockActiveRight);
+    subscribe(socket,ref, VSPath.vehicleCurrentLatitude);
+    subscribe(socket,ref, VSPath.vehicleCurrentLongitude);
+    subscribe(socket,ref, VSPath.vehicleInsideTemperature);
+    subscribe(socket,ref, VSPath.vehicleAmbientAirTemperature);
+  }
+
+  static void update(WebSocket socket,WidgetRef ref) {
+    get(socket,ref, VSPath.vehicleAmbientAirTemperature);
+    get(socket,ref, VSPath.vehicleTrunkLocked);
+    get(socket, ref,VSPath.vehicleTrunkOpen);
+
+    get(socket,ref, VSPath.vehicleFrontLeftTier);
+    get(socket,ref, VSPath.vehicleFrontRightTier);
+    get(socket,ref, VSPath.vehicleRearLeftTier);
+    get(socket,ref, VSPath.vehicleRearRightTier);
+    get(socket,ref, VSPath.vehicleIsChildLockActiveLeft);
+    get(socket,ref, VSPath.vehicleIsChildLockActiveRight);
+    get(socket,ref, VSPath.vehicleCurrentLatitude);
+    get(socket,ref, VSPath.vehicleCurrentLongitude);
+    get(socket,ref, VSPath.vehicleInsideTemperature);
+  }
+
+  static void authorize(WebSocket socket,WidgetRef ref) {
+    final config = ref.read(ConfigStateprovider);
+    Map<String, dynamic> map = {
+      "action": "authorize",
+      "tokens": config.kuksaAuthToken,
+      "requestId": requestId
+    };
+    socket.add(jsonEncode(map));
+  }
+
+  static void get(WebSocket socket,WidgetRef ref ,String path) {
+    final config = ref.read(ConfigStateprovider);
+
+    Map<String, dynamic> map = {
+      "action": "get",
+      "tokens": config.kuksaAuthToken,
+      "path": path,
+      "requestId": requestId
+    };
+    socket.add(jsonEncode(map));
+  }
+
+  static void set(
+    WebSocket socket,
+    WidgetRef ref,
+    String path,
+    String value,
+  ) {
+    final config = ref.read(ConfigStateprovider);
+
+    Map<String, dynamic> map = {
+      "action": "set",
+      "tokens": config.kuksaAuthToken,
+      "path": path,
+      "requestId": requestId,
+      "value": value
+    };
+    socket.add(jsonEncode(map));
+  }
+
+  static void subscribe(WebSocket socket,WidgetRef ref, String path) {
+    final config = ref.read(ConfigStateprovider);
+
+    Map<String, dynamic> map = {
+      "action": "subscribe",
+      "tokens": config.kuksaAuthToken,
+      "path": path,
+      "requestId": requestId
+    };
+    socket.add(jsonEncode(map));
+  }
+
+
+}
diff --git a/lib/kuksa-server/vehicle_server_path.dart b/lib/kuksa-server/vehicle_server_path.dart
new file mode 100644
index 0000000..c61c3ca
--- /dev/null
+++ b/lib/kuksa-server/vehicle_server_path.dart
@@ -0,0 +1,36 @@
+// SPDX-License-Identifier: Apache-2.0
+
+
+class VSPath {
+
+
+  static const String vehicleTrunkLocked = "Vehicle.Body.Trunk.IsLocked";
+  static const String vehicleTrunkOpen = "Vehicle.Body.Trunk.IsOpen";
+
+
+  static const String vehicleAmbientAirTemperature =
+      "Vehicle.AmbientAirTemperature";
+
+  static const String vehicleFrontLeftTier =
+      "Vehicle.Chassis.Axle.Row1.Wheel.Left.Tire.Pressure";
+  static const String vehicleFrontRightTier =
+      "Vehicle.Chassis.Axle.Row1.Wheel.Right.Tire.Pressure";
+  static const String vehicleRearLeftTier =
+      "Vehicle.Chassis.Axle.Row2.Wheel.Left.Tire.Pressure";
+
+  static const String vehicleRearRightTier =
+      "Vehicle.Chassis.Axle.Row2.Wheel.Right.Tire.Pressure";
+  static const String vehicleIsChildLockActiveLeft =
+      "Vehicle.Cabin.Door.Row2.Left.IsChildLockActive";
+  static const String vehicleIsChildLockActiveRight =
+      "Vehicle.Cabin.Door.Row2.Right.IsChildLockActive";
+  static const String vehicleCurrentLongitude =
+      "Vehicle.CurrentLocation.Longitude";
+  static const String vehicleCurrentLatitude =
+      "Vehicle.CurrentLocation.Latitude";
+
+  static const String vehicleInsideTemperature =
+      "Vehicle.Cabin.HVAC.AmbientAirTemperature";
+  static const String vehicleFrontLeftAc =
+      "Vehicle.Cabin.HVAC.Station.Row1.Left.AirDistribution";
+}