Implement messaging

.gitignore

@@ -7,3 +7,4 @@ venv
 *.log
 *.log.*
 .env
+.pytest_cache

README.adoc

@@ -43,6 +43,9 @@ For more install options type:
 
 Python 3.6 or above is required.
 
+== Running unit tests
+
+`$ pytest`
 
 == External resources
 

agrirouter/__init__.py

@@ -0,0 +1,17 @@
+from agrirouter.auth.auth import Authorization
+from agrirouter.auth.parameters import AuthUrlParameter
+
+from agrirouter.onboarding.onboarding import SoftwareOnboarding
+from agrirouter.onboarding.parameters import SoftwareOnboardingParameter
+
+from agrirouter.revoking.revoking import Revoking
+from agrirouter.revoking.parameters import RevokingParameter
+
+from agrirouter.messaging.parameters.service import MessageHeaderParameters, MessagePayloadParameters, \
+    QueryMessageParameters, QueryHeaderParameters, CloudOffboardParameters, CloudOnboardParameters, \
+    CapabilityParameters, FeedConfirmParameters, FeedDeleteParameters, ListEndpointsParameters, MessageParameters, \
+    SubscriptionParameters
+from agrirouter.messaging.services.cloud import CloudOnboardService, CloudOffboardService
+from agrirouter.messaging.services.messaging import SubscriptionService, CapabilityService, FeedConfirmService,\
+    FeedDeleteService, QueryHeaderService, QueryMessagesService, ListEndpointsService
+

agrirouter/auth/auth.py

@@ -26,8 +26,8 @@ def extract_auth_response(self, url: str) -> AuthResponse:
         query_params = self._extract_query_params(parsed_url.query)
         return AuthResponse(query_params)
 
-    @staticmethod
-    def verify_auth_response(response, public_key):
+    def verify_auth_response(self, response, public_key=None):
+        public_key = public_key if public_key else self._environment.get_env_public_key()
         response.verify(public_key)
 
     @staticmethod

agrirouter/auth/response.py

@@ -22,7 +22,16 @@ def __init__(self, query_params):
         self._token = query_params.get(self.TOKEN_KEY, None)
         self._error = query_params.get(self.ERROR_KEY, None)
         self.is_successful = not bool(self._error)
-        self.is_valid = False
+        self._was_verified = False
+        self._is_valid = False
+
+    @property
+    def is_valid(self):
+        if not self._was_verified:
+            raise PermissionError("The response was not verified yet. Please verify first. "
+                                  "You can access is_valid only after verifying")
+
+        return self._is_valid
 
     def verify(self, public_key) -> None:
         """
@@ -37,13 +46,14 @@ def verify(self, public_key) -> None:
         encoded_data = self._state + self._token
         unquoted_signature = unquote(self._signature)
         encoded_signature = base64.b64decode(unquoted_signature.encode("utf-8"))
+        self._was_verified = True
         try:
             verify_signature(encoded_data, encoded_signature, public_key)
         except InvalidSignature:
             print("Response is invalid: invalid signature.")
-            self.is_valid = False
+            self._is_valid = False
 
-        self.is_valid = True
+        self._is_valid = True
 
     @staticmethod
     def decode_token(token: Union[str, bytes]) -> dict:
@@ -63,7 +73,3 @@ def get_auth_result(self) -> dict:
             self.TOKEN_KEY: self._token,
             self.CRED_KEY: decoded_token
         }
-
-
-def decorator(func):
-    pass

agrirouter/environments/environments.py

@@ -1,3 +1,5 @@
+from agrirouter.environments.keys import AR_QA_PUBLIC_KEY, AR_PROD_PUBLIC_KEY
+
 
 class BaseEnvironment:
     _AGRIROUTER_LOGIN_URL = "/app"
@@ -10,6 +12,8 @@ class BaseEnvironment:
     _API_PREFIX = ""
     _REGISTRATION_SERVICE_URL = ""
 
+    AR_PUBLIC_KEY = None
+
     def get_base_url(self) -> str:
         return self._ENV_BASE_URL
 
@@ -45,14 +49,21 @@ def get_secured_onboarding_authorization_url(self, application_id, response_type
     def get_mqtt_server_url(self, host, port) -> str:
         return self._MQTT_URL_TEMPLATE.format(host=host, port=port)
 
+    def get_env_public_key(self):
+        return self.AR_PUBLIC_KEY
+
 
 class ProductionEnvironment(BaseEnvironment):
     _ENV_BASE_URL = "https://goto.my-agrirouter.com"
     _API_PREFIX = "/api/v1.0"
     _REGISTRATION_SERVICE_URL = "https://onboard.my-agrirouter.com"
 
+    AR_PUBLIC_KEY = AR_PROD_PUBLIC_KEY
+
 
 class QAEnvironment(BaseEnvironment):
     _ENV_BASE_URL = "https://agrirouter-qa.cfapps.eu10.hana.ondemand.com"
     _API_PREFIX = "/api/v1.0"
     _REGISTRATION_SERVICE_URL = "https://agrirouter-registration-service-hubqa-eu10.cfapps.eu10.hana.ondemand.com"
+
+    AR_PUBLIC_KEY = AR_QA_PUBLIC_KEY

agrirouter/environments/keys.py

@@ -0,0 +1,19 @@
+AR_QA_PUBLIC_KEY = "-----BEGIN PUBLIC KEY-----\n" \
+                   "MIIBIjANBgkqhkiG9w0BAQEFAAOCAQ8AMIIBCgKCAQEAy8xF9661acn+iS+QS+9Y\n" \
+                   "3HvTfUVcismzbuvxHgHA7YeoOUFxyj3lkaTnXm7hzQe4wDEDgwpJSGAzxIIYSUXe\n" \
+                   "8EsWLorg5O0tRexx5SP3+kj1i83DATBJCXP7k+bAF4u2FVJphC1m2BfLxelGLjzx\n" \
+                   "VAS/v6+EwvYaT1AI9FFqW/a2o92IsVPOh9oM9eds3lBOAbH/8XrmVIeHofw+XbTH\n" \
+                   "1/7MLD6IE2+HbEeY0F96nioXArdQWXcjUQsTch+p0p9eqh23Ak4ef5oGcZhNd4yp\n" \
+                   "Y8M6ppvIMiXkgWSPJevCJjhxRJRmndY+ajYGx7CLePx7wNvxXWtkng3yh+7WiZ/Y\n" \
+                   "qwIDAQAB\n" \
+                   "-----END PUBLIC KEY-----"
+
+AR_PROD_PUBLIC_KEY = "-----BEGIN PUBLIC KEY-----\n" \
+                     "MIIBIjANBgkqhkiG9w0BAQEFAAOCAQ8AMIIBCgKCAQEAwCxD31sYtzH9NTfZ6n8H\n" \
+                     "+H/QgOaoTL9GAakplAsdwYSLjBpgYMZOHIgkdM9ksRP8WsITChtZtxrCnBjR8bap\n" \
+                     "ekPT/pM9zPZlNEPxUlylJNwwTWjzTJP03+Yr07Q8v8fTJ5VWzAHlHtGQ/sI7yXA8\n" \
+                     "pzruTNre1MzxO3lkljt2Q2e7CVXAp1b53BghgysppL9Bl7NK1R+vdWSs0B1Db/Gj\n" \
+                     "alOkWUnhivTjRMX61RGDCQSVSEaX12EvJX7FooAsW3NFeZCgeZGWEa5ZMALIiBL4\n" \
+                     "GNASOOHju7ewlYjkyGIRxxAoc3C0w5dg1qlLiAFWToYwgDOcUpLRjU/7bzGiGvp8\n" \
+                     "RwIDAQAB\n" \
+                     "-----END PUBLIC KEY-----"