Use optimistics state update (#314)

src/FastyBird/Bridge/RedisDbPluginDevicesModule/src/Models/States/ChannelPropertiesManager.php

@@ -62,6 +62,7 @@ public function create(Uuid\UuidInterface $id, Utils\ArrayHash $values): States\
 	}
 
 	/**
+	 * @throws RedisDbExceptions\InvalidArgument
 	 * @throws RedisDbExceptions\InvalidState
 	 */
 	public function update(Uuid\UuidInterface $id, Utils\ArrayHash $values): States\ChannelProperty|false

src/FastyBird/Bridge/RedisDbPluginDevicesModule/src/Models/States/ConnectorPropertiesManager.php

@@ -62,6 +62,7 @@ public function create(Uuid\UuidInterface $id, Utils\ArrayHash $values): States\
 	}
 
 	/**
+	 * @throws RedisDbExceptions\InvalidArgument
 	 * @throws RedisDbExceptions\InvalidState
 	 */
 	public function update(Uuid\UuidInterface $id, Utils\ArrayHash $values): States\ConnectorProperty|false

src/FastyBird/Bridge/RedisDbPluginDevicesModule/src/Models/States/DevicePropertiesManager.php

@@ -62,6 +62,7 @@ public function create(Uuid\UuidInterface $id, Utils\ArrayHash $values): States\
 	}
 
 	/**
+	 * @throws RedisDbExceptions\InvalidArgument
 	 * @throws RedisDbExceptions\InvalidState
 	 */
 	public function update(Uuid\UuidInterface $id, Utils\ArrayHash $values): States\DeviceProperty|false

src/FastyBird/Bridge/RedisDbPluginTriggersModule/src/Models/States/ActionsManager.php

@@ -62,6 +62,7 @@ public function create(Uuid\UuidInterface $id, Utils\ArrayHash $values): States\
 	}
 
 	/**
+	 * @throws RedisDbExceptions\InvalidArgument
 	 * @throws RedisDbExceptions\InvalidState
 	 */
 	public function update(Uuid\UuidInterface $id, Utils\ArrayHash $values): States\Action|false

src/FastyBird/Bridge/RedisDbPluginTriggersModule/src/Models/States/ConditionsManager.php

@@ -62,6 +62,7 @@ public function create(Uuid\UuidInterface $id, Utils\ArrayHash $values): States\
 	}
 
 	/**
+	 * @throws RedisDbExceptions\InvalidArgument
 	 * @throws RedisDbExceptions\InvalidState
 	 */
 	public function update(Uuid\UuidInterface $id, Utils\ArrayHash $values): States\Condition|false

src/FastyBird/Connector/Shelly/src/Queue/Consumers/WriteChannelPropertyState.php

@@ -34,9 +34,11 @@
 use FastyBird\Module\Devices\Exceptions as DevicesExceptions;
 use FastyBird\Module\Devices\Models as DevicesModels;
 use FastyBird\Module\Devices\Queries as DevicesQueries;
+use FastyBird\Module\Devices\States as DevicesStates;
 use FastyBird\Module\Devices\Types as DevicesTypes;
 use Fig\Http\Message\StatusCodeInterface;
 use Nette;
+use Nette\Utils;
 use RuntimeException;
 use Throwable;
 use TypeError;
@@ -419,7 +421,17 @@ public function consume(Queue\Messages\Message $message): bool
 		}
 
 		$result->then(
-			function () use ($message, $connector, $device, $channel, $property): void {
+			function () use ($message, $connector, $device, $channel, $property, $state): void {
+				await($this->channelPropertiesStatesManager->set(
+					$property,
+					Utils\ArrayHash::from([
+						DevicesStates\Property::ACTUAL_VALUE_FIELD => $state->getExpectedValue(),
+						DevicesStates\Property::EXPECTED_VALUE_FIELD => null,
+						DevicesStates\Property::PENDING_FIELD => false,
+					]),
+					MetadataTypes\Sources\Connector::SHELLY,
+				));
+
 				$this->logger->debug(
 					'Channel state was successfully sent to device',
 					[

src/FastyBird/Plugin/RedisDb/src/Models/States/StatesManager.php

@@ -112,6 +112,7 @@ public function create(
 	/**
 	 * @phpstan-return T
 	 *
+	 * @throws Exceptions\InvalidArgument
 	 * @throws Exceptions\InvalidState
 	 */
 	public function update(
@@ -125,6 +126,8 @@ public function update(
 
 		} catch (Exceptions\NotUpdated) {
 			return false;
+		} catch (Exceptions\NotFound) {
+			$raw = $this->createKey($id, $values, $this->entity::getCreateFields(), $database);
 		}
 
 		try {
@@ -253,7 +256,7 @@ private function updateKey(
 			$raw = $this->client->get($id->toString());
 
 			if (!is_string($raw)) {
-				throw new Exceptions\InvalidState('Stored record could not be loaded from database');
+				throw new Exceptions\NotFound('Stored record could not be loaded from database');
 			}
 
 			$data = Utils\Json::decode($raw);