ALLOWED_TYPE = "push_msg"  # 允许的信息详情类型


def init_db():
    import public
    from db import Sql

    db = Sql()
    db.dbfile("msg_box")
    create_sql_str = (
        "CREATE TABLE IF NOT EXISTS 'push_msg' ("
        "id INTEGER PRIMARY KEY AUTOINCREMENT, "
        "pid INTEGER NOT NULL UNIQUE DEFAULT 0, "
        "push_type TEXT NOT NULL DEFAULT '', "
        "push_title TEXT NOT NULL DEFAULT '', "
        "data TEXT NOT NULL DEFAULT '{}'"
        ");"
    )
    res = db.execute(create_sql_str)
    if isinstance(res, str) and res.startswith("error"):
        public.WriteLog("消息盒子", "建表push_msg失败")
        return

    index_sql_str = "CREATE INDEX IF NOT EXISTS 'push_pid_index' ON 'push_msg' ('pid');"

    res = db.execute(index_sql_str)
    if isinstance(res, str) and res.startswith("error"):
        public.WriteLog("消息盒子", "为push_msg建立索引push_pid_index失败")
        return