|
1 | 1 | import time |
| 2 | +import agrirouter as ar |
| 3 | +from agrirouter.onboarding.enums import Gateways |
| 4 | +from agrirouter.generated.messaging.request.payload.endpoint.subscription_pb2 import Subscription |
| 5 | +from agrirouter.generated.messaging.request.payload.endpoint.capabilities_pb2 import CapabilitySpecification |
| 6 | +from agrirouter.messaging.services.commons import HttpMessagingService, MqttMessagingService |
| 7 | +from agrirouter.utils.uuid_util import new_uuid |
2 | 8 |
|
3 | 9 | from google.protobuf.timestamp_pb2 import Timestamp |
4 | 10 |
|
5 | | -from src.agrirouter.generated.messaging.request.payload.account.endpoints_pb2 import ListEndpointsQuery |
6 | | -from src.agrirouter.generated.messaging.request.payload.feed.feed_requests_pb2 import ValidityPeriod |
7 | | -from src.agrirouter.onboarding.response import OnboardResponse |
| 11 | +from agrirouter.generated.messaging.request.payload.account.endpoints_pb2 import ListEndpointsQuery |
| 12 | +from agrirouter.generated.messaging.request.payload.feed.feed_requests_pb2 import ValidityPeriod |
| 13 | +from agrirouter.onboarding.response import OnboardResponse |
8 | 14 |
|
9 | 15 | public_key = """-----BEGIN PUBLIC KEY----- |
10 | 16 | MIIBIjANBgkqhkiG9w0BAQEFAAOCAQ8AMIIBCgKCAQEAzGt41/+kSOTlO1sJvLIN |
|
64 | 70 | } |
65 | 71 | } |
66 | 72 |
|
67 | | -import src as ar |
68 | | -from src.agrirouter.onboarding.enums import Gateways |
69 | | -from src.agrirouter.api.enums import CapabilityType |
70 | | -from src.agrirouter.generated.messaging.request.payload.endpoint.subscription_pb2 import Subscription |
71 | | -from src.agrirouter.generated.messaging.request.payload.endpoint.capabilities_pb2 import CapabilitySpecification |
72 | | -from src.agrirouter.messaging.services.commons import HttpMessagingService, MqttMessagingService |
73 | | -from src import ListEndpointsParameters, ListEndpointsService, SubscriptionService, SubscriptionParameters, \ |
74 | | - QueryHeaderService, QueryHeaderParameters, CapabilitiesService, CapabilitiesParameters |
75 | | -from src.agrirouter.utils.uuid_util import new_uuid |
76 | 73 |
|
77 | 74 | application_id = "8c947a45-c57d-42d2-affc-206e21d63a50" # # store here your application id. You can find it in AR UI |
78 | 75 | certification_version_id = "edd5d6b7-45bb-4471-898e-ff9c2a7bf56f" # # store here your certification version id. You can find it in AR UI |
@@ -298,9 +295,9 @@ def example_query_header_message_mqtt(onboarding_response_data, on_msg_callback) |
298 | 295 | def on_message_callback(client, userdata, msg): |
299 | 296 | # Define here the way receiving messages will be processed |
300 | 297 |
|
301 | | - from src.agrirouter.messaging.decode import decode_response |
302 | | - from src.agrirouter.messaging.decode import decode_details |
303 | | - from src.agrirouter.messaging.messages import OutboxMessage |
| 298 | + from agrirouter.messaging.decode import decode_response |
| 299 | + from agrirouter.messaging.decode import decode_details |
| 300 | + from agrirouter.messaging.messages import OutboxMessage |
304 | 301 |
|
305 | 302 | outbox_message = OutboxMessage() |
306 | 303 | outbox_message.json_deserialize(msg.payload.decode().replace("'", '"')) |
|
0 commit comments