import vk_api
import random
import time
import requests
import mysql.connector
from vk_api import VkUpload
from vk_api.bot_longpoll import VkBotLongPoll, VkBotEventType
from vk_api.utils import get_random_id

vk_session = vk_api.VkApi(token=' ')
vk = vk_session.get_api()
longpoll = VkBotLongPoll(vk_session, '185760866')

connection = mysql.connector.connect(host='localhost',
                             database='guiz',
                             user='root',
                             password='root')


cursor = connection.cursor()

def save_work(event):

    # сохранение файла
    url = event.obj['attachments'][0]['audio_message']['link_ogg']
    my_file = requests.get(url)
    file_name = time.strftime("%d-%m-%Y__%H-%M-%S") + "__id" + str(event.obj['from_id']) + ".ogg"
    open(file_name, 'wb').write(my_file.content)

    # загрузка файла на сервер ВК и создание вложения (attachment)
    upload = vk_api.VkUpload(vk_session)
    audio_message = upload.audio_message(file_name, group_id = '185760866')
    attachment_string = 'doc{}_{}'.format(audio_message['audio_message']['owner_id'], audio_message['audio_message']['id'])

    # добавление записи в базу данных
    sql_query = "INSERT INTO works (user_id, file_name, date_time, attachment_string) VALUES (%s, %s, %s, %s)"
    values = (event.obj['from_id'], file_name, time.strftime('%Y-%m-%d %H:%M:%S'),attachment_string)
    cursor.execute(sql_query, values)
    connection.commit()


for event in longpoll.listen():
    if event.type == VkBotEventType.MESSAGE_NEW:
        save_work(event)