import cPickle
from slavealloc.data import model, setup


def setup_argparse(subparsers):

    subparser = subparsers.add_parser('dbinit', help="""Initialize a fresh
            database, optionally from a dump file.  Note that this does not use
            the REST API, but writes to the database directly.""")

    subparser.add_argument('-D', '--db', dest='dburl',
                           default='sqlite:///slavealloc.db',
                           help="""SQLAlchemy database URL; defaults to slavealloc.db in the
            current dir""")

    subparser.add_argument('dumpfile', nargs='?',
                           help="""dump file as generated by 'slavealloc dbdump'; if not
            specified, then an empty database will be initialized.""")

    return subparser


def process_args(subparser, args):
    pass


def main(args):
    setup.setup(args.dburl)

    model.metadata.drop_all()
    model.metadata.create_all()

    if args.dumpfile:
        load_data(args)


def load_data(args):
    # see dbdump.py for the data format here
    dumpdict = cPickle.load(open(args.dumpfile))
    for tbl in model.metadata.sorted_tables:
        tname = tbl.name
        if tname not in dumpdict or not dumpdict[tname]:
            continue
        tbl = model.metadata.tables[tname]
        tbl.insert().execute(dumpdict[tname])