From 8b39b727e1b26079ba0a72e7ffebb58ec5a877d0 Mon Sep 17 00:00:00 2001
From: JonatanRek <gamerclassn7@gmail.com>
Date: Thu, 30 Apr 2020 19:40:34 +0200
Subject: [PATCH] Google API Progress

---
 app/Routes.php                  |   3 +-
 app/api/GoogleHomeApi.php       | 142 ++++++++++++++++++++++++++++----
 app/models/SubDeviceManager.php |   5 +-
 3 files changed, 133 insertions(+), 17 deletions(-)

diff --git a/app/Routes.php b/app/Routes.php
index 9c99fa4..9158e65 100644
--- a/app/Routes.php
+++ b/app/Routes.php
@@ -21,7 +21,8 @@ $router->any('/rooms', 'Rooms');
 $router->post('/api/devices', 'DevicesApi@getAllDevices');
 $router->post('/api/login', 'AuthApi@login');
 
-$router->post('/api/HA', 'GoogleHome@response');
+$router->get('/api/HA/auth', 'GoogleHomeApi@autorize');
+$router->post('/api/HA', 'GoogleHomeApi@response');
 
 // examples
 $router->any('/api/example', 'ExampleApi@example');
diff --git a/app/api/GoogleHomeApi.php b/app/api/GoogleHomeApi.php
index aa42256..e4a24f2 100644
--- a/app/api/GoogleHomeApi.php
+++ b/app/api/GoogleHomeApi.php
@@ -1,19 +1,131 @@
 <?php
 class GoogleHomeApi {
-    function response()
-    {
-        header('Content-Type: application/json');
-        $update_response = file_get_contents("php://input");
-        $update = json_decode($update_response, true);
-        echo '"RichResponse": {
-            "items": [
-              {
-                "simpleResponse": {
-                  "textToSpeech": "test speech"
-                }
-              }
-            ]
-          }';
-    }
+	function response()
+	{
+		$json = file_get_contents('php://input');
+		$obj = json_decode($json, true);
 
+		$apiLogManager = new LogManager('../logs/api/HA/'. date("Y-m-d").'.log');
+
+		$apiLogManager->write("[API] request body\n" . json_encode($obj, JSON_PRETTY_PRINT), LogRecordType::INFO);
+		$apiLogManager->write("[API] POST  body\n" . json_encode($_POST, JSON_PRETTY_PRINT), LogRecordType::INFO);
+		$apiLogManager->write("[API] GET body\n" . json_encode($_GET, JSON_PRETTY_PRINT), LogRecordType::INFO);
+
+		header('Content-Type: application/json');
+		switch ($obj['inputs'][0]['intent']) {
+			case 'action.devices.SYNC':
+				self::sync($obj['requestId']);
+			break;
+
+			case 'action.devices.QUERY':
+
+			break;
+
+			case 'action.devices.EXECUTE':
+				self::execute($obj['requestId'], $obj['inputs'][0]['payload']);
+			break;
+		}
+	}
+
+	static function sync($requestId){
+		$devices = [];
+
+		$roomsData = RoomManager::getAllRooms();
+		foreach ($roomsData as $roomKey => $roomsData) {
+			$devicesData = DeviceManager::getAllDevicesInRoom($roomsData['room_id']);
+			foreach ($devicesData as $deviceKey => $deviceData) {
+				$subDevicesData = SubDeviceManager::getAllSubDevices($deviceData['device_id']);
+				foreach ($subDevicesData as $subDeviceKey => $subDeviceData) {
+					if ($subDeviceData['type'] != "on/off") continue;
+					$devices[] = [
+						'id' => $subDeviceData['subdevice_id'],
+						'type' => 'action.devices.types.OUTLET',
+						'traits' => [ 'action.devices.traits.OnOff' ],
+						'name' => [
+							'name' => [$deviceData['name']],
+						],
+						'willReportState' => false,
+					];
+				}
+			}
+		}
+
+		$response = [
+			'requestId' => $requestId,
+			'payload' => [
+				'agentUserId'=>'simple-Home',
+				'devices' => $devices,],
+		];
+
+		$apiLogManager = new LogManager('../logs/api/HA/'. date("Y-m-d").'.log');
+
+		$apiLogManager->write("[API] request response\n" . json_encode($response, JSON_PRETTY_PRINT), LogRecordType::INFO);
+		echo json_encode($response);
+	}
+
+	static function execute($subdeviceId, $payload){
+		$commands = [
+			'ids' => 
+		];
+		foreach ($payload['commands'] as $key => $command) {
+			foreach ($command['devices'] as $key => $device) {
+				$executionCommand = $command['execution'][$key];
+				$subDeviceId = $device['id'];
+
+				switch ($executionCommand) {
+					case 'action.devices.commands.OnOff':
+						if ($executionCommand['on'] == true){
+							//turn ddeivce on
+							
+						}
+						break;
+					default:
+						# code...
+						break;
+				}
+
+			}
+		}
+
+		$response = [
+			'requestId' => $requestId,
+			'payload' => [
+				'commands' => $commands,],
+		];
+
+		$apiLogManager = new LogManager('../logs/api/HA/'. date("Y-m-d").'.log');
+
+		$apiLogManager->write("[API] request response\n" . json_encode($response, JSON_PRETTY_PRINT), LogRecordType::INFO);
+		echo json_encode($response);
+	}
+
+	function autorize(){
+		$json = file_get_contents('php://input');
+		$obj = json_decode($json, true);
+
+		$apiLogManager = new LogManager('../logs/api/HA/'. date("Y-m-d").'.log');
+		$apiLogManager->write("[API] request body\n" . json_encode($obj, JSON_PRETTY_PRINT), LogRecordType::INFO);
+
+		$apiLogManager->write("[API] GET body\n" . json_encode($_GET, JSON_PRETTY_PRINT), LogRecordType::INFO);
+
+		//tel: zemanová 607979429
+
+		/*echo json_encode(array (
+			'access_token' => '',
+			'token_type' => 'bearer',
+			'expires_in' => 3600,
+			'refresh_token' => '',
+			'scope' => 'create',
+		));*/
+
+		$get = [
+			"access_token"=>"23165133",
+			"token_type"=>"Bearer",
+			"expires_in"=>600,
+			"state"=>$_GET["state"],
+		];
+
+		echo $_GET["redirect_uri"] . '#' . http_build_query($get) ;
+		echo '<a href="'.$_GET["redirect_uri"] . '#' . http_build_query($get) . '">FINISH</a>';
+	}
 }
diff --git a/app/models/SubDeviceManager.php b/app/models/SubDeviceManager.php
index 99dad60..edcca33 100644
--- a/app/models/SubDeviceManager.php
+++ b/app/models/SubDeviceManager.php
@@ -3,8 +3,11 @@ class SubDeviceManager
 {
 	public static $devices;
 
-	public static function getAllSubDevices($deviceId)
+	public static function getAllSubDevices($deviceId = null)
 	{
+		if ($deviceId == null){
+			return Db::loadAll("SELECT * FROM subdevices");
+		}
 		return Db::loadAll("SELECT * FROM subdevices WHERE device_id = ?", array($deviceId));
 	}