import vk_api
import sqlite3
from vk_api.longpoll import VkLongPoll, VkEventType

connectionHandler = sqlite3.connect('database.db')
dbHandler = connectionHandler.cursor()

def query(sql_query, commit=0, back=1):
    try:
        dbHandler.execute(sql_query)
        if commit:
            connectionHandler.commit()
        if back:
            return dbHandler.fetchall()
        else:
            return None
    except:
        return None


def send_message(vk_session, event, message):
    try:
        peer_id = None
        if event.from_user:
            peer_id = event.user_id
        elif event.from_chat:
            peer_id = event.chat_id + 2000000000
        vk_session.method('messages.send', {'peer_id': peer_id, 'message': message, 'forward_messages': str(event.raw[1])})
        return True
    except:
        return False

def main():
    login, password = '', ''
    vk_session = vk_api.VkApi(login, password)

    try:
        vk_session.auth()
    except vk_api.AuthError as error_msg:
        print(error_msg)
        return

    long_poll = VkLongPoll(vk_session)

    for event in long_poll.listen():
        try:
            if event.type == VkEventType.MESSAGE_NEW:

        except Exception as e:
            print(e)


if __name__ == '__main__':
    try:
        main()
    except (vk_api.ApiError, vk_api.AuthError, vk_api.ApiHttpError):
        time.sleep(3)
        main()