Sergey Matvienko
3 years ago
13 changed files with 245 additions and 61 deletions
@ -0,0 +1,47 @@ |
|||
/** |
|||
* Copyright © 2016-2023 The Thingsboard Authors |
|||
* |
|||
* Licensed under the Apache License, Version 2.0 (the "License"); |
|||
* you may not use this file except in compliance with the License. |
|||
* You may obtain a copy of the License at |
|||
* |
|||
* http://www.apache.org/licenses/LICENSE-2.0
|
|||
* |
|||
* Unless required by applicable law or agreed to in writing, software |
|||
* distributed under the License is distributed on an "AS IS" BASIS, |
|||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
|||
* See the License for the specific language governing permissions and |
|||
* limitations under the License. |
|||
*/ |
|||
package org.thingsboard.server.service.queue; |
|||
|
|||
import org.thingsboard.server.common.data.id.EntityIdFactory; |
|||
import org.thingsboard.server.common.data.id.TenantId; |
|||
import org.thingsboard.server.common.data.plugin.ComponentLifecycleEvent; |
|||
import org.thingsboard.server.common.msg.plugin.ComponentLifecycleMsg; |
|||
import org.thingsboard.server.gen.transport.TransportProtos; |
|||
|
|||
import java.util.UUID; |
|||
|
|||
public class ProtoUtils { |
|||
|
|||
public static TransportProtos.ComponentLifecycleMsgProto toProto(ComponentLifecycleMsg msg) { |
|||
return TransportProtos.ComponentLifecycleMsgProto.newBuilder() |
|||
.setTenantIdMSB(msg.getTenantId().getId().getMostSignificantBits()) |
|||
.setTenantIdLSB(msg.getTenantId().getId().getLeastSignificantBits()) |
|||
.setEntityType(TransportProtos.EntityType.forNumber(msg.getEntityId().getEntityType().ordinal())) |
|||
.setEntityIdMSB(msg.getEntityId().getId().getMostSignificantBits()) |
|||
.setEntityIdLSB(msg.getEntityId().getId().getLeastSignificantBits()) |
|||
.setEvent(TransportProtos.ComponentLifecycleEvent.forNumber(msg.getEvent().ordinal())) |
|||
.build(); |
|||
} |
|||
|
|||
public static ComponentLifecycleMsg fromProto(TransportProtos.ComponentLifecycleMsgProto proto) { |
|||
return new ComponentLifecycleMsg( |
|||
TenantId.fromUUID(new UUID(proto.getTenantIdMSB(), proto.getTenantIdLSB())), |
|||
EntityIdFactory.getByTypeAndUuid(proto.getEntityTypeValue(), new UUID(proto.getEntityIdMSB(), proto.getEntityIdLSB())), |
|||
ComponentLifecycleEvent.values()[proto.getEventValue()] |
|||
); |
|||
} |
|||
|
|||
} |
|||
@ -0,0 +1,71 @@ |
|||
/** |
|||
* Copyright © 2016-2023 The Thingsboard Authors |
|||
* |
|||
* Licensed under the Apache License, Version 2.0 (the "License"); |
|||
* you may not use this file except in compliance with the License. |
|||
* You may obtain a copy of the License at |
|||
* |
|||
* http://www.apache.org/licenses/LICENSE-2.0
|
|||
* |
|||
* Unless required by applicable law or agreed to in writing, software |
|||
* distributed under the License is distributed on an "AS IS" BASIS, |
|||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
|||
* See the License for the specific language governing permissions and |
|||
* limitations under the License. |
|||
*/ |
|||
package org.thingsboard.server.service.queue; |
|||
|
|||
import org.junit.jupiter.api.Test; |
|||
import org.thingsboard.server.common.data.id.EntityId; |
|||
import org.thingsboard.server.common.data.id.RuleChainId; |
|||
import org.thingsboard.server.common.data.id.TenantId; |
|||
import org.thingsboard.server.common.data.plugin.ComponentLifecycleEvent; |
|||
import org.thingsboard.server.common.msg.plugin.ComponentLifecycleMsg; |
|||
import org.thingsboard.server.gen.transport.TransportProtos; |
|||
import java.util.UUID; |
|||
|
|||
import static org.assertj.core.api.Assertions.assertThat; |
|||
|
|||
class ProtoUtilsTest { |
|||
|
|||
TenantId tenantId = TenantId.fromUUID(UUID.fromString("35e10f77-16e7-424d-ae46-ee780f87ac4f")); |
|||
EntityId entityId = new RuleChainId(UUID.fromString("c640b635-4f0f-41e6-b10b-25a86003094e")); |
|||
@Test |
|||
void toProtoComponentLifecycleMsg() { |
|||
ComponentLifecycleMsg msg = new ComponentLifecycleMsg(tenantId, entityId, ComponentLifecycleEvent.UPDATED); |
|||
|
|||
TransportProtos.ComponentLifecycleMsgProto proto = ProtoUtils.toProto(msg); |
|||
|
|||
assertThat(proto).as("to proto").isEqualTo(TransportProtos.ComponentLifecycleMsgProto.newBuilder() |
|||
.setTenantIdMSB(tenantId.getId().getMostSignificantBits()) |
|||
.setTenantIdLSB(tenantId.getId().getLeastSignificantBits()) |
|||
.setEntityType(TransportProtos.EntityType.forNumber(entityId.getEntityType().ordinal())) |
|||
.setEntityIdMSB(entityId.getId().getMostSignificantBits()) |
|||
.setEntityIdLSB(entityId.getId().getLeastSignificantBits()) |
|||
.setEvent(TransportProtos.ComponentLifecycleEvent.forNumber(ComponentLifecycleEvent.UPDATED.ordinal())) |
|||
.build() |
|||
); |
|||
|
|||
assertThat(ProtoUtils.fromProto(proto)).as("from proto").isEqualTo(msg); |
|||
} |
|||
|
|||
@Test |
|||
void fromProtoComponentLifecycleMsg() { |
|||
TransportProtos.ComponentLifecycleMsgProto proto = TransportProtos.ComponentLifecycleMsgProto.newBuilder() |
|||
.setTenantIdMSB(tenantId.getId().getMostSignificantBits()) |
|||
.setTenantIdLSB(tenantId.getId().getLeastSignificantBits()) |
|||
.setEntityType(TransportProtos.EntityType.forNumber(entityId.getEntityType().ordinal())) |
|||
.setEntityIdMSB(entityId.getId().getMostSignificantBits()) |
|||
.setEntityIdLSB(entityId.getId().getLeastSignificantBits()) |
|||
.setEvent(TransportProtos.ComponentLifecycleEvent.forNumber(ComponentLifecycleEvent.STARTED.ordinal())) |
|||
.build(); |
|||
|
|||
ComponentLifecycleMsg msg = ProtoUtils.fromProto(proto); |
|||
|
|||
assertThat(msg).as("from proto").isEqualTo( |
|||
new ComponentLifecycleMsg(tenantId, entityId, ComponentLifecycleEvent.STARTED)); |
|||
|
|||
assertThat(ProtoUtils.toProto(msg)).as("to proto").isEqualTo(proto); |
|||
} |
|||
|
|||
} |
|||
Loading…
Reference in new issue