# Copyright 2017 Workiva
# Licensed under the Apache License, Version 2.0 (the "License");
# you may not use this file except in compliance with the License.
# You may obtain a copy of the License at
#     http://www.apache.org/licenses/LICENSE-2.0
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.

import logging
from struct import pack_into
from struct import unpack_from

from thrift.protocol.TProtocol import TProtocolException

logger = logging.getLogger(__name__)

_V0 = 0
# Code for big endian unsigned char
_UCHAR = '!B'
# Code for big endian unsigned int
_UINT = '!I'
_UINT_LENGTH = 4


class _Headers(object):

    @staticmethod
    def _write_to_bytearray(headers):
        """
        Writes a given dictionary to a bytearray object and returns it
        TODO : Point to Protocol doc in the repo

        Args:
            headers: dict of frugal headers to write
        Returns:
            bytearray containing binary headers
        """
        utf8_headers = [(key.encode('utf8'), val.encode('utf8'))
                        for (key, val) in headers.items()]
        size = sum([8 + len(key) + len(val) for (key, val) in utf8_headers])
        buff = bytearray(size + 5)

        pack_into(_UCHAR, buff, 0, _V0)
        pack_into(_UINT, buff, 1, size)

        offset = 5

        for key, value in utf8_headers:
            key_len = len(key)
            pack_into(_UINT, buff, offset, key_len)
            offset += 4

            pack_into('>{0}s'.format(str(key_len)), buff, offset, key)
            offset += key_len

            val_len = len(value)
            pack_into(_UINT, buff, offset, val_len)
            offset += 4

            pack_into('>{0}s'.format(str(val_len)), buff, offset, value)
            offset += val_len

        return buff

    @staticmethod
    def _read(buff1):
        buff = buff1.read(1)
        version = unpack_from(_UCHAR, buff[:1])[0]

        if version is not _V0:
            ex = TProtocolException(
                TProtocolException.BAD_VERSION,
                "Wrong Frugal version. Found {0}, wanted {1}.".format(
                    version, _V0)
            )
            logger.exception(ex)
            raise ex

        buff = buff1.read(4)
        size = unpack_from(_UINT, buff[0:4])[0]

        buff = buff1.read(size)

        return _Headers._read_pairs(buff, 0, size)

    @staticmethod
    def decode_from_frame(frame):
        """
        Decode a frugal message from a frame.
        """
        if len(frame) < 5:
            ex = TProtocolException(TProtocolException.INVALID_DATA,
                                    "Invalid frame size: {}".format(len(frame))
                                    )
            logger.exception(ex)
            raise ex

        version = unpack_from(_UCHAR, frame[0:1])[0]

        if version is not _V0:
            ex = TProtocolException(
                TProtocolException.BAD_VERSION,
                "Wrong Frugal version. Found {0}, wanted {1}."
                .format(version, _V0)
            )
            logger.exception(ex)
            raise ex

        headers_size = unpack_from(_UINT, frame[1:5])[0]

        return _Headers._read_pairs(frame, 5, headers_size + 5)

    @staticmethod
    def _read_pairs(buff, start, end):
        parsed_headers = {}
        i = start
        while i < end:
            name_size = unpack_from(_UINT, buff[i:i + 4])[0]
            i += 4

            if i > end or i + name_size > end:
                ex = TProtocolException(TProtocolException.INVALID_DATA,
                                        "invalid protocol header name size: {}"
                                        .format(name_size))
                logger.exception(ex)
                raise ex

            name = unpack_from('>{0}s'.format(name_size),
                               buff[i:i + name_size])[0]
            i += name_size

            val_size = unpack_from(_UINT, buff[i: i + 4])[0]
            i += 4

            if i > end or i + val_size > end:
                ex = TProtocolException(
                    TProtocolException.INVALID_DATA,
                    "invalid protocol header value size: {}".format(val_size)
                )
                logger.exception(ex)
                raise ex

            val = unpack_from('>{0}s'.format(val_size),
                              buff[i:i + val_size])[0]
            i += val_size
            parsed_headers[name.decode('utf8')] = val.decode('utf8')

        return parsed_headers

# Copyright 2017 Workiva
# Licensed under the Apache License, Version 2.0 (the "License");
# you may not use this file except in compliance with the License.
# You may obtain a copy of the License at
#     http://www.apache.org/licenses/LICENSE-2.0
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.

import logging
from struct import pack_into
from struct import unpack_from

from thrift.protocol.TProtocol import TProtocolException

logger = logging.getLogger(__name__)

_V0 = 0
# Code for big endian unsigned char
_UCHAR = '!B'
# Code for big endian unsigned int
_UINT = '!I'
_UINT_LENGTH = 4


class _Headers(object):

    @staticmethod
    def _write_to_bytearray(headers):
        """
        Writes a given dictionary to a bytearray object and returns it
        TODO : Point to Protocol doc in the repo

        Args:
            headers: dict of frugal headers to write
        Returns:
            bytearray containing binary headers
        """
        utf8_headers = [(key.encode('utf8'), val.encode('utf8'))
                        for (key, val) in headers.items()]
        size = sum([8 + len(key) + len(val) for (key, val) in utf8_headers])
        buff = bytearray(size + 5)

        pack_into(_UCHAR, buff, 0, _V0)
        pack_into(_UINT, buff, 1, size)

        offset = 5

        for key, value in utf8_headers:
            key_len = len(key)
            pack_into(_UINT, buff, offset, key_len)
            offset += 4

            pack_into('>{0}s'.format(str(key_len)), buff, offset, key)
            offset += key_len

            val_len = len(value)
            pack_into(_UINT, buff, offset, val_len)
            offset += 4

            pack_into('>{0}s'.format(str(val_len)), buff, offset, value)
            offset += val_len

        return buff

    @staticmethod
    def _read(buff1):
        buff = buff1.read(1)
        version = unpack_from(_UCHAR, buff[:1])[0]

        if version is not _V0:
            ex = TProtocolException(
                TProtocolException.BAD_VERSION,
                "Wrong Frugal version. Found {0}, wanted {1}.".format(
                    version, _V0)
            )
            logger.exception(ex)
            raise ex

        buff = buff1.read(4)
        size = unpack_from(_UINT, buff[0:4])[0]

        buff = buff1.read(size)

        return _Headers._read_pairs(buff, 0, size)

    @staticmethod
    def decode_from_frame(frame):
        """
        Decode a frugal message from a frame.
        """
        if len(frame) < 5:
            ex = TProtocolException(TProtocolException.INVALID_DATA,
                                    "Invalid frame size: {}".format(len(frame))
                                    )
            logger.exception(ex)
            raise ex

        version = unpack_from(_UCHAR, frame[0:1])[0]

        if version is not _V0:
            ex = TProtocolException(
                TProtocolException.BAD_VERSION,
                "Wrong Frugal version. Found {0}, wanted {1}."
                .format(version, _V0)
            )
            logger.exception(ex)
            raise ex

        headers_size = unpack_from(_UINT, frame[1:5])[0]

        return _Headers._read_pairs(frame, 5, headers_size + 5)

    @staticmethod
    def _read_pairs(buff, start, end):
        parsed_headers = {}
        i = start
        while i < end:
            name_size = unpack_from(_UINT, buff[i:i + 4])[0]
            i += 4

            if i > end or i + name_size > end:
                ex = TProtocolException(TProtocolException.INVALID_DATA,
                                        "invalid protocol header name size: {}"
                                        .format(name_size))
                logger.exception(ex)
                raise ex

            name = unpack_from('>{0}s'.format(name_size),
                               buff[i:i + name_size])[0]
            i += name_size

            val_size = unpack_from(_UINT, buff[i: i + 4])[0]
            i += 4

            if i > end or i + val_size > end:
                ex = TProtocolException(
                    TProtocolException.INVALID_DATA,
                    "invalid protocol header value size: {}".format(val_size)
                )
                logger.exception(ex)
                raise ex

            val = unpack_from('>{0}s'.format(val_size),
                              buff[i:i + val_size])[0]
            i += val_size
            parsed_headers[name.decode('utf8')] = val.decode('utf8')

        return parsed_headers

# Copyright 2017 Workiva # Licensed under the Apache License, Version 2.0 (the "License"); # you may not use this file except in compliance with the License. # You may obtain a copy of the License at #     http://www.apache.org/licenses/LICENSE-2.0 # Unless required by applicable law or agreed to in writing, software # distributed under the License is distributed on an "AS IS" BASIS, # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. # See the License for the specific language governing permissions and # limitations under the License. # Code for big endian unsigned char # Code for big endian unsigned int Writes a given dictionary to a bytearray object and returns it         TODO : Point to Protocol doc in the repo          Args:             headers: dict of frugal headers to write         Returns:             bytearray containing binary headers Decode a frugal message from a frame.