#!/usr/bin/env python2

import sys
import os

from google.protobuf.internal.enum_type_wrapper import EnumTypeWrapper

def process_type(t, cls):
    imports = ["from protobuf import protobuf as p",]

    out = ["t = p.MessageType()", ]

    print("  * type %s" % t)

    TYPE_STRING = 9
    TYPE_BYTES = 12

    TYPE_MESSAGE = 11

    for v in sorted(cls.DESCRIPTOR.fields_by_name.values(), key=lambda x: x.number):
        number = v.number
        fieldname = v.name
        type = None
        repeated = v.label == 3
        required = v.label == 2

        #print v.has_default_value, v.default_value

        if v.type in (4, 13, 14):
            # TYPE_UINT64 = 4
            # TYPE_UINT32 = 13
            # TYPE_ENUM = 14
            type = 'p.UVarintType'

        elif v.type == 9:
            # TYPE_STRING = 9
            type = 'p.UnicodeType'

        elif v.type == 8:
            # TYPE_BOOL = 8
            type = 'p.BoolType'

        elif v.type == 12:
            # TYPE_BYTES = 12
            type = 'p.BytesType'

        elif v.type == 11:
            # TYPE_MESSAGE = 1
            type = "p.EmbeddedMessage(%s)" % v.message_type.name
            imports.append("from .%s import %s" % (v.message_type.name, v.message_type.name))

        else:
            raise Exception("Unknown field type %s for field %s" % (v.type, k))

        if repeated:
            flags = ', flags=p.FLAG_REPEATED'
        elif required:
            flags = ', flags=p.FLAG_REQUIRED'
        else:
            flags = ''

        if v.has_default_value:
            default = ', default=%s' % repr(v.default_value)
        else:
            default = ''

        out.append("t.add_field(%d, '%s', %s%s%s)" % \
                   (number, fieldname, type, flags, default))

        #print fieldname, number, type, repeated, default
        #print v.__dict__
        #print v.CPPTYPE_STRING
        #print v.LABEL_REPEATED
        #print v.enum_type
        # v.has_default_value, v.default_value
        # v.label == 3 # repeated
        #print v.number

    out.append("%s = t" % t)
    return imports + out

def process_enum(t, cls):
    out = []

    print("  * enum %s" % t)

    for k, v in cls.items():
        # Remove type name from the beginning of the constant
        # For example "PinMatrixRequestType_Current" -> "Current"
        if k.startswith("%s_" % t):
            k = k.replace("%s_" % t, '')

        # If type ends with *Type, but constant use type name without *Type, remove it too :)
        # For example "ButtonRequestType & ButtonRequest_Other" => "Other"
        if t.endswith("Type") and k.startswith("%s_" % t.replace("Type", '')):
            k = k.replace("%s_" % t.replace("Type", ''), '')

        out.append("%s = const(%s)" % (k, v))

    return out

def process_module(mod, genpath):

    print("Processing module %s" % mod.__name__)
    types = dict([(name, cls) for name, cls in mod.__dict__.items() if isinstance(cls, type)])

    for t, cls in types.iteritems():
        out = process_type(t, cls)
        write_to_file(genpath, t, out)

    enums = dict([(name, cls) for name, cls in mod.__dict__.items() if isinstance(cls, EnumTypeWrapper)])

    for t, cls in enums.iteritems():
        out = process_enum(t, cls)
        write_to_file(genpath, t, out)

def write_to_file(genpath, t, out):
    # Write generated sourcecode to given file
    f = open(os.path.join(genpath, "%s.py" % t), 'w')
    out = ["# Automatically generated by pb2py"] + out

    data = "\n".join(out)

    f.write(data)
    f.close()

if __name__ == '__main__':
    if len(sys.argv) < 2:
        print("Usage: ./pb2py modulename genpath")
        sys.exit()

    modulename = sys.argv[1]
    genpath = sys.argv[2]

    # Dynamically load module from argv[1]
    tmp = __import__('pb2', globals(), locals(), ['%s_pb2' % modulename])
    mod = getattr(tmp, "%s_pb2" % modulename)

    process_module(mod, genpath)