diff --git a/libs/psa/mqtt_request.py b/libs/psa/mqtt_request.py index 68fda28..364206e 100644 --- a/libs/psa/mqtt_request.py +++ b/libs/psa/mqtt_request.py @@ -16,6 +16,7 @@ class MQTTRequest: self.vin = vin self.req_parameters = req_parameters self.date = datetime.now() + self.data = {} def get_message_to_json(self, remote_access_token): return json.dumps(self.get_message(remote_access_token)) @@ -23,10 +24,10 @@ class MQTTRequest: def get_message(self, remote_access_token): date = datetime.utcnow() date_str = date.strftime(PSA_DATE_FORMAT) - data = {"access_token": remote_access_token, "customer_id": self.customer_id, + self.data = {"access_token": remote_access_token, "customer_id": self.customer_id, "correlation_id": self.__gen_correlation_id(date), "req_date": date_str, "vin": self.vin, "req_parameters": self.req_parameters} - return data + return self.data def is_expired(self): return self.date < datetime.now() - timedelta(seconds=self.TIME_BEFORE_EXPIRATION) @@ -36,4 +37,7 @@ class MQTTRequest: date_str = date.strftime(PSA_CORRELATION_DATE_FORMAT)[:-3] uuid_str = str(uuid4()).replace("-", "") correlation_id = uuid_str + date_str - return correlation_id \ No newline at end of file + return correlation_id + + def __str__(self): + return "topic: " + self.topic + ": " + str(self.data)