<reponame>bingrao/mapreduce_sss
import pickle


class MessageEvent:
    """
    Message Event format: {"Type": type, "Name": name, "Value": value}
    """
    def __init__(self):
        # Event Type
        self.type = EventType()

    @staticmethod
    def serialization(message):
        """
        sent to/(recieved from) servers must be bytes, str, or iterable
        """
        return pickle.dumps(message)

    @staticmethod
    def deserialization(message):
        return pickle.loads(message)


class EventType:
    def __init__(self):
        self.data = "Data"
        self.add = "Add"
        self.sub = "Sub"
        self.mul = "Multiply"
        self.match = "Match"
        self.count = "Count"
        self.string_count = "String_Count"
        self.select = "Select"
        self.join = "Join"
        self.search = "Range_Search"