Remove PNMessageType"

Author: Sebastian Molenda

pubnub/endpoints/fetch_messages.py

@@ -32,6 +32,7 @@ def __init__(self, pubnub):
         self._include_meta = None
         self._include_message_actions = None
         self._include_message_type = True
+        self._include_type = True
         self._include_space_id = None
         self._include_uuid = None
 
@@ -72,6 +73,11 @@ def include_message_type(self, include_message_type):
         self._include_message_type = include_message_type
         return self
 
+    def include_type(self, include_type):
+        assert isinstance(include_type, bool)
+        self._include_type = include_type
+        return self
+
     def include_uuid(self, include_uuid):
         assert isinstance(include_uuid, bool)
         self._include_uuid = include_uuid
@@ -85,7 +91,7 @@ def include_space_id(self, include_space_id):
     def custom_params(self):
         params = {
             'max': int(self._count),
-            'include_type': 'true' if self._include_message_type else 'false',
+            'include_type': 'true' if self._include_type else 'false',
             'include_message_type': 'true' if self._include_message_type else 'false',
         }
 
@@ -165,6 +171,7 @@ def create_response(self, envelope):  # pylint: disable=W0221
             json_input=envelope,
             include_message_actions=self._include_message_actions,
             include_message_type=self._include_message_type,
+            include_type=self._include_type,
             include_space_id=self._include_space_id,
             start_timetoken=self._start,
             end_timetoken=self._end)

pubnub/endpoints/file_operations/publish_file_message.py

@@ -3,8 +3,6 @@
 from pubnub import utils
 from pubnub.models.consumer.file import PNPublishFileMessageResult
 from pubnub.endpoints.mixins import TimeTokenOverrideMixin
-from pubnub.models.consumer.message_type import PNMessageType
-from typing import Union
 
 
 class PublishFileMessage(FileOperationEndpoint, TimeTokenOverrideMixin):
@@ -22,7 +20,7 @@ def __init__(self, pubnub):
         self._cipher_key = None
         self._replicate = None
         self._ptto = None
-        self._message_type = None
+        self._type = None
         self._space_id = None
 
     def meta(self, meta):
@@ -53,11 +51,11 @@ def file_name(self, file_name):
         self._file_name = file_name
         return self
 
-    def message_type(self, message_type: Union[PNMessageType, str]):
-        self._message_type = message_type
+    def type(self, type: str):
+        self._type = type
         return self
 
-    def space_id(self, space_id):
+    def space_id(self, space_id: str):
         self._space_id = space_id
         return self
 
@@ -99,11 +97,11 @@ def custom_params(self):
             "ttl": self._ttl,
             "store": 1 if self._should_store else 0
         })
-        if self._message_type:
-            params['type'] = str(self._message_type)
+        if self._type:
+            params['type'] = self._type
 
         if self._space_id:
-            params['space-id'] = str(self._space_id)
+            params['space-id'] = self._space_id
 
         return params
 

pubnub/endpoints/file_operations/send_file.py

@@ -6,8 +6,6 @@
 from pubnub.endpoints.file_operations.fetch_upload_details import FetchFileUploadS3Data
 from pubnub.request_handlers.requests_handler import RequestsRequestHandler
 from pubnub.endpoints.mixins import TimeTokenOverrideMixin
-from pubnub.models.consumer.message_type import PNMessageType
-from typing import Union
 
 
 class SendFileNative(FileOperationEndpoint, TimeTokenOverrideMixin):
@@ -24,7 +22,7 @@ def __init__(self, pubnub):
         self._file_object = None
         self._replicate = None
         self._ptto = None
-        self._message_type = None
+        self._type = None
         self._space_id = None
 
     def file_object(self, fd):
@@ -73,8 +71,8 @@ def is_compressable(self):
 
     def custom_params(self):
         params = {}
-        if self._message_type:
-            params['type'] = str(self._message_type)
+        if self._type:
+            params['type'] = str(self._type)
 
         if self._space_id:
             params['space-id'] = self._space_id
@@ -120,11 +118,11 @@ def cipher_key(self, cipher_key):
         self._cipher_key = cipher_key
         return self
 
-    def message_type(self, message_type: Union[PNMessageType, str]):
-        self._message_type = message_type
+    def type(self, type: str):
+        self._type = type
         return self
 
-    def space_id(self, space_id):
+    def space_id(self, space_id: str):
         self._space_id = space_id
         return self
 
@@ -158,7 +156,7 @@ def sync(self):
             replicate(self._replicate).\
             ptto(self._ptto).\
             cipher_key(self._cipher_key).\
-            message_type(self._message_type).\
+            type(self._type).\
             space_id(self._space_id).sync()
 
         response_envelope.result.timestamp = publish_file_response.result.timestamp

pubnub/endpoints/pubsub/publish.py

@@ -5,8 +5,6 @@
 from pubnub.models.consumer.pubsub import PNPublishResult
 from pubnub.enums import HttpMethod, PNOperationType
 from pubnub.endpoints.mixins import TimeTokenOverrideMixin
-from pubnub.models.consumer.message_type import PNMessageType
-from typing import Union
 
 
 class Publish(Endpoint, TimeTokenOverrideMixin):
@@ -31,15 +29,15 @@ def channel(self, channel):
         self._channel = str(channel)
         return self
 
-    def space_id(self, space_id):
+    def space_id(self, space_id: str):
         self._space_id = str(space_id)
         return self
 
     def message(self, message):
         self._message = message
         return self
 
-    def message_type(self, message_type: Union[PNMessageType, str]):
+    def message_type(self, message_type: str):
         self._message_type = message_type
         return self
 
@@ -104,10 +102,10 @@ def custom_params(self):
             params["auth"] = utils.url_encode(self.pubnub.config.auth_key)
 
         if self._message_type is not None:
-            params['type'] = str(self._message_type)
+            params['type'] = self._message_type
 
         if self._space_id is not None:
-            params['space-id'] = str(self._space_id)
+            params['space-id'] = self._space_id
 
         return params
 

pubnub/endpoints/signal.py

@@ -2,8 +2,6 @@
 from pubnub.endpoints.endpoint import Endpoint
 from pubnub.enums import HttpMethod, PNOperationType
 from pubnub.models.consumer.signal import PNSignalResult
-from pubnub.models.consumer.message_type import PNMessageType
-from typing import Union
 
 
 class Signal(Endpoint):
@@ -13,7 +11,7 @@ def __init__(self, pubnub):
         Endpoint.__init__(self, pubnub)
         self._channel = None
         self._message = None
-        self._space = None
+        self._space_id = None
         self._message_type = None
 
     def channel(self, channel):
@@ -24,11 +22,11 @@ def message(self, message):
         self._message = message
         return self
 
-    def space_id(self, space):
-        self._space = str(space)
+    def space_id(self, space_id: str):
+        self._space_id = str(space_id)
         return self
 
-    def message_type(self, message_type: Union[PNMessageType, str]):
+    def message_type(self, message_type: str):
         self._message_type = message_type
         return self
 
@@ -44,10 +42,10 @@ def custom_params(self):
         params = {}
 
         if self._message_type is not None:
-            params['type'] = str(self._message_type)
+            params['type'] = self._message_type
 
-        if self._space is not None:
-            params['space-id'] = str(self._space)
+        if self._space_id is not None:
+            params['space-id'] = self._space_id
 
         return params
 

pubnub/models/consumer/history.py

@@ -1,6 +1,3 @@
-from pubnub.models.consumer.message_type import PNMessageType
-
-
 class PNHistoryResult(object):
     def __init__(self, messages, start_timetoken, end_timetoken):
         self.messages = messages
@@ -66,14 +63,15 @@ def __str__(self):
         return "Fetch messages result for range %d..%d" % (self.start_timetoken, self.end_timetoken)
 
     @classmethod
-    def from_json(cls, json_input, include_message_actions=False, include_message_type=False, include_space_id=False,
-                  start_timetoken=None, end_timetoken=None):
+    def from_json(cls, json_input, include_message_actions=False, include_message_type=False, include_type=False,
+                  include_space_id=False, start_timetoken=None, end_timetoken=None):
         channels = {}
 
         for key, entry in json_input['channels'].items():
             channels[key] = []
             for item in entry:
-                message = PNFetchMessageItem(item, include_message_actions, include_message_type, include_space_id)
+                message = PNFetchMessageItem(item, include_message_actions, include_message_type, include_type,
+                                             include_space_id)
                 channels[key].append(message)
 
         return PNFetchMessagesResult(
@@ -89,7 +87,7 @@ class PNFetchMessageItem(object):
     timetoken = None
     actions = None
 
-    def __init__(self, item, include_message_actions, include_message_type, include_space_id):
+    def __init__(self, item, include_message_actions, include_message_type, include_type, include_space_id):
         self.message = item['message']
         self.timetoken = item['timetoken']
 
@@ -106,9 +104,13 @@ def __init__(self, item, include_message_actions, include_message_type, include_
                 self.actions = {}
 
         if include_message_type:
-            self.message_type = PNMessageType.from_response(
-                message_type=item['type'] if 'type' in item.keys() else None,
-                pn_message_type=item['message_type'])
+            if 'message_type' in item:
+                self.message_type = str(item['message_type']) if item['message_type'] is not None else '0'
+            else:
+                self.message_type = None
+
+        if include_type:
+            self.type = item['type'] if 'type' in item.keys() else None
 
         if include_space_id:
             self.space_id = item['space_id']

pubnub/models/consumer/message_type.py

@@ -3,7 +3,7 @@
 
 class PNMessageResult(object):
     def __init__(self, message, subscription, channel, timetoken, user_metadata=None, publisher=None, message_type=None,
-                 space_id=None):
+                 type=None, space_id=None):
         if subscription is not None:
             assert isinstance(subscription, str)
 
@@ -29,7 +29,8 @@ def __init__(self, message, subscription, channel, timetoken, user_metadata=None
         self.timetoken = timetoken
         self.user_metadata = user_metadata
         self.publisher = publisher
-        self.type = message_type
+        self.message_type = message_type
+        self.type = type
         self.space_id = space_id
 
 

pubnub/models/consumer/pubsub.py

@@ -1,6 +1,3 @@
-from pubnub.models.consumer.message_type import PNMessageType
-
-
 class SubscribeEnvelope:
     def __init__(self, messages=None, metadata=None):
         assert isinstance(messages, (list, None))
@@ -58,11 +55,13 @@ def from_json(cls, json_input):
         if 'si' in json_input:
             message.space_id = json_input['si']
 
+        # customers message type set during publish
         if 'mt' in json_input:
-            if 'e' in json_input:
-                message.message_type = PNMessageType.from_response(json_input['mt'], json_input['e'])
-            else:
-                message.message_type = PNMessageType(json_input['mt'])
+            message.type = json_input['mt']
+
+        # internal message type (None|0 = message, 1 = file, etc)
+        if 'e' in json_input:
+            message.message_type = json_input['mt']
 
         return message
 

pubnub/models/server/subscribe.py

@@ -174,6 +174,7 @@ def _process_incoming_payload(self, message):
                     timetoken=publish_meta_data.publish_timetoken,
                     publisher=publisher,
                     message_type=message.message_type,
+                    type=message.type,
                     space_id=message.space_id
                 )
                 self._listener_manager.announce_message(pn_message_result)