import re

from struct import unpack

from vertica_python.vertica.messages.message import BackendMessage


class CommandComplete(BackendMessage):

    def __init__(self, data):

        data = unpack('{0}sx'.format(len(data) - 1), data)[0]

        if re.match(b"INSERT", data) is not None:
            splitstr = data.split(b' ', 3)
            self.tag = splitstr[0]
            if len(splitstr) >= 2:
                self.oid = int(splitstr[1])
            if len(splitstr) >= 3:
                self.rows = int(splitstr[2])
        elif re.match(b"(DELETE|UPDATE|MOVE|FETCH|COPY)", data) is not None:
            splitstr = data.split(b' ', 2)
            self.tag = splitstr[0]
            if len(splitstr) >= 2:
                self.rows = int(splitstr[1])
        else:
            self.tag = data


CommandComplete._message_id(b'C')