from apscheduler.executors.pool import ThreadPoolExecutor, ProcessPoolExecutor
from apscheduler.schedulers.blocking import BlockingScheduler

from queue_message.CookiesPublisher import MORNING_DATA_CACHE
from request_sender_test import send_request_for_file_list


def start_book_appointment():
    file_list = ['~/Desktop/contact_list_2024-08-09.xlsx',
                 '~/Desktop/contact_list_2024-05-27.xlsx']
    send_request_for_file_list(file_list=file_list, thread_number=10,
                               data_queue_name=MORNING_DATA_CACHE, stop_at_hour=11, stop_at_mins=40)


def start_check_results_job(sched):
    sched.add_job(start_book_appointment, 'cron', day_of_week='mon-sat', hour='10',
                  minute='30',
                  misfire_grace_time=10,
                  second='10', timezone='Europe/Paris', max_instances=1, args=[])


def config_and_start_jobs():
    executors = {
        'default': ThreadPoolExecutor(30),
        'processpool': ProcessPoolExecutor(12)
    }
    sched = BlockingScheduler(executors=executors)
    start_check_results_job(sched)
    sched.print_jobs()
    sched.start()


if __name__ == '__main__':
    config_and_start_jobs()