Skip to content

Commit

Permalink
Move value helper under metadata (#180)
Browse files Browse the repository at this point in the history
  • Loading branch information
actions-user committed Nov 20, 2023
1 parent d7a5fcf commit 8fac456
Show file tree
Hide file tree
Showing 5 changed files with 20 additions and 13 deletions.
7 changes: 4 additions & 3 deletions src/Drivers/Thermostat.php
Original file line number Diff line number Diff line change
Expand Up @@ -25,6 +25,7 @@
use FastyBird\DateTimeFactory;
use FastyBird\Library\Metadata\Exceptions as MetadataExceptions;
use FastyBird\Library\Metadata\Types as MetadataTypes;
use FastyBird\Library\Metadata\Utilities as MetadataUtilities;
use FastyBird\Module\Devices\Entities as DevicesEntities;
use FastyBird\Module\Devices\Exceptions as DevicesExceptions;
use FastyBird\Module\Devices\Utilities as DevicesUtilities;
Expand Down Expand Up @@ -126,7 +127,7 @@ public function connect(): Promise\PromiseInterface
$actualValue = Helpers\Transformer::fromMappedParent($actor, $actualValue);
}

$actualValue = DevicesUtilities\ValueHelper::normalizeValue(
$actualValue = MetadataUtilities\ValueHelper::normalizeValue(
$actor->getDataType(),
$actualValue,
$actor->getFormat(),
Expand All @@ -153,7 +154,7 @@ public function connect(): Promise\PromiseInterface
$actualValue = Helpers\Transformer::fromMappedParent($sensor, $actualValue);
}

$actualValue = DevicesUtilities\ValueHelper::normalizeValue(
$actualValue = MetadataUtilities\ValueHelper::normalizeValue(
$sensor->getDataType(),
$actualValue,
$sensor->getFormat(),
Expand Down Expand Up @@ -183,7 +184,7 @@ public function connect(): Promise\PromiseInterface
$actualValue = Helpers\Transformer::fromMappedParent($opening, $actualValue);
}

$actualValue = DevicesUtilities\ValueHelper::normalizeValue(
$actualValue = MetadataUtilities\ValueHelper::normalizeValue(
$opening->getDataType(),
$actualValue,
$opening->getFormat(),
Expand Down
11 changes: 7 additions & 4 deletions src/Queue/Consumers/StoreChannelPropertyState.php
Original file line number Diff line number Diff line change
Expand Up @@ -26,6 +26,7 @@
use FastyBird\Library\Exchange\Publisher as ExchangePublisher;
use FastyBird\Library\Metadata\Exceptions as MetadataExceptions;
use FastyBird\Library\Metadata\Types as MetadataTypes;
use FastyBird\Library\Metadata\Utilities as MetadataUtilities;
use FastyBird\Module\Devices\Entities as DevicesEntities;
use FastyBird\Module\Devices\Exceptions as DevicesExceptions;
use FastyBird\Module\Devices\Models as DevicesModels;
Expand Down Expand Up @@ -185,7 +186,7 @@ public function consume(Entities\Messages\Entity $entity): bool
}

$valueToStore = $entity->getValue();
$valueToStore = DevicesUtilities\ValueHelper::normalizeValue(
$valueToStore = MetadataUtilities\ValueHelper::normalizeValue(
$property->getDataType(),
$valueToStore,
$property->getFormat(),
Expand All @@ -200,12 +201,14 @@ public function consume(Entities\Messages\Entity $entity): bool
$this->channelsPropertiesManager->update(
$property,
Utils\ArrayHash::from([
'value' => DevicesUtilities\ValueHelper::flattenValue($valueToStore),
'value' => MetadataUtilities\ValueHelper::flattenValue($valueToStore),
]),
);
} elseif ($property instanceof DevicesEntities\Channels\Properties\Dynamic) {
$this->channelPropertiesStateManager->setValue($property, Utils\ArrayHash::from([
DevicesStates\Property::ACTUAL_VALUE_FIELD => DevicesUtilities\ValueHelper::flattenValue($valueToStore),
DevicesStates\Property::ACTUAL_VALUE_FIELD => MetadataUtilities\ValueHelper::flattenValue(
$valueToStore,
),
DevicesStates\Property::VALID_FIELD => true,
]));
} elseif ($property instanceof DevicesEntities\Channels\Properties\Mapped) {
Expand All @@ -224,7 +227,7 @@ public function consume(Entities\Messages\Entity $entity): bool
'device' => $device->getId()->toString(),
'channel' => $channel->getId()->toString(),
'property' => $property->getId()->toString(),
'expected_value' => DevicesUtilities\ValueHelper::flattenValue($valueToStore),
'expected_value' => MetadataUtilities\ValueHelper::flattenValue($valueToStore),
]),
MetadataTypes\RoutingKey::get(
MetadataTypes\RoutingKey::CHANNEL_PROPERTY_ACTION,
Expand Down
3 changes: 2 additions & 1 deletion src/Queue/Consumers/WriteChannelPropertyState.php
Original file line number Diff line number Diff line change
Expand Up @@ -27,6 +27,7 @@
use FastyBird\Library\Bootstrap\Helpers as BootstrapHelpers;
use FastyBird\Library\Metadata\Exceptions as MetadataExceptions;
use FastyBird\Library\Metadata\Types as MetadataTypes;
use FastyBird\Library\Metadata\Utilities as MetadataUtilities;
use FastyBird\Module\Devices\Entities as DevicesEntities;
use FastyBird\Module\Devices\Exceptions as DevicesExceptions;
use FastyBird\Module\Devices\Models as DevicesModels;
Expand Down Expand Up @@ -249,7 +250,7 @@ public function consume(Entities\Messages\Entity $entity): bool
$valueToWrite = Helpers\Transformer::fromMappedParent($property, $valueToWrite);
}

$valueToWrite = DevicesUtilities\ValueHelper::normalizeValue(
$valueToWrite = MetadataUtilities\ValueHelper::normalizeValue(
$property->getDataType(),
$valueToWrite,
$property->getFormat(),
Expand Down
7 changes: 5 additions & 2 deletions src/Writers/Periodic.php
Original file line number Diff line number Diff line change
Expand Up @@ -24,6 +24,7 @@
use FastyBird\DateTimeFactory;
use FastyBird\Library\Metadata\Exceptions as MetadataExceptions;
use FastyBird\Library\Metadata\Types as MetadataTypes;
use FastyBird\Library\Metadata\Utilities as MetadataUtilities;
use FastyBird\Module\Devices\Entities as DevicesEntities;
use FastyBird\Module\Devices\Exceptions as DevicesExceptions;
use FastyBird\Module\Devices\Models as DevicesModels;
Expand Down Expand Up @@ -181,8 +182,10 @@ private function writeChannelsProperty(Entities\VirtualDevice $device): bool
}

$valueToWrite = $property instanceof DevicesEntities\Channels\Properties\Mapped
? DevicesUtilities\ValueHelper::flattenValue($state->getExpectedValue() ?? $state->getActualValue())
: DevicesUtilities\ValueHelper::flattenValue($state->getExpectedValue());
? MetadataUtilities\ValueHelper::flattenValue(
$state->getExpectedValue() ?? $state->getActualValue(),
)
: MetadataUtilities\ValueHelper::flattenValue($state->getExpectedValue());

if (
(
Expand Down
5 changes: 2 additions & 3 deletions tests/fixtures/dummy/DummyChannelPropertyState.php
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,6 @@
use Exception;
use FastyBird\Library\Metadata\Types as MetadataTypes;
use FastyBird\Module\Devices\States as DevicesStates;
use FastyBird\Module\Devices\Utilities as DevicesUtilities;
use Nette\Utils;
use Ramsey\Uuid;
use function is_bool;
Expand Down Expand Up @@ -126,8 +125,8 @@ public function toArray(): array
{
return [
'id' => $this->getId()->toString(),
'actual_value' => DevicesUtilities\ValueHelper::flattenValue($this->getActualValue()),
'expected_value' => DevicesUtilities\ValueHelper::flattenValue($this->getExpectedValue()),
'actual_value' => MetadataUtilities\ValueHelper::flattenValue($this->getActualValue()),
'expected_value' => MetadataUtilities\ValueHelper::flattenValue($this->getExpectedValue()),
'pending' => $this->getPending() instanceof DateTimeInterface ? $this->getPending()->format(
DateTimeInterface::ATOM,
) : $this->getPending(),
Expand Down

0 comments on commit 8fac456

Please sign in to comment.