import datetime
from fastapi import APIRouter, Body, Depends, Header, HTTPException, Query, Response, status
from pydantic import BaseModel, EmailStr, Field
from typing import Dict, List, Optional, Set, Union

from app.lib_general import log, logging
from app.config import settings
from app.db_sql import *

from app.routers.api_crud import delete_obj_template, get_obj_template, get_obj_li_template, patch_obj_template, post_obj_template

from app.methods.event_presentation_methods import get_event_presentation_rec_list, load_event_presentation_obj

from app.models.event_presentation_models import Event_Presentation_Base
from app.models.response_models import *


router = APIRouter()


@router.post('/event/presentation', response_model=Resp_Body_Base)
async def post_event_presentation_obj(
        obj: Event_Presentation_Base,
        x_account_id: str = Header(...),
        return_obj: Optional[bool] = True,
        by_alias: Optional[bool] = True,
        exclude_unset: Optional[bool] = True,
        response: Response = Response,
        ):
    log.setLevel(logging.WARNING) # DEBUG, INFO, WARNING, ERROR, EXCEPTION, CRITICAL
    log.debug(locals())

    obj_type = 'event_presentation'
    obj_data_dict = obj.dict(by_alias=False, exclude_unset=True)
    result = post_obj_template(
        obj_type=obj_type,
        data=obj_data_dict,
        return_obj=True,
        by_alias=True,
        exclude_unset=True,
        )
    return result


@router.patch('/event/presentation/{obj_id}', response_model=Resp_Body_Base)
async def patch_event_presentation_obj(
        obj: Event_Presentation_Base,
        obj_id: str = Query(..., min_length=1, max_length=22),
        x_account_id: Optional[str] = Header(..., ),
        return_obj: Optional[bool] = True,
        by_alias: Optional[bool] = True,
        exclude_unset: Optional[bool] = True,
        response: Response = Response,
        ):
    log.setLevel(logging.WARNING) # DEBUG, INFO, WARNING, ERROR, EXCEPTION, CRITICAL
    log.debug(locals())

    obj_type = 'event_presentation'
    obj_data_dict = obj.dict(by_alias=False, exclude_unset=True)
    obj_data_dict['id'] = redis_lookup_id_random(record_id_random=obj_id, table_name=obj_type)
    obj_data_dict['id_random'] = obj_id
    result = patch_obj_template(
        obj_type=obj_type,
        data=obj_data_dict,
        obj_id=obj_id,
        return_obj=True,
        by_alias=True,
        exclude_unset=True,
        )
    return result


# ### BEGIN ### API Event Presentation ### patch_event_presentation_json() ###
@router.patch('/event/presentation/{event_presentation_id}/json', response_model=Resp_Body_Base)
async def patch_event_presentation_json(
        event_presentation_obj: Event_Presentation_Base,
        event_presentation_id: str = Query(..., min_length=1, max_length=22),
        create_sub_obj: bool = False,
        x_account_id: Optional[str] = Header(..., ),
        return_obj: Optional[bool] = True,
        by_alias: Optional[bool] = True,
        include: Optional[list] = [],
        exclude: Optional[list] = [],
        exclude_unset: Optional[bool] = True,
        exclude_none: Optional[bool] = True,
        response: Response = Response,
        ):
    log.setLevel(logging.WARNING) # DEBUG, INFO, WARNING, ERROR, EXCEPTION, CRITICAL
    log.debug(locals())

    if event_presentation_id := redis_lookup_id_random(record_id_random=event_presentation_id, table_name='event_presentation'): pass
    else:
        return mk_resp(data=None, status_code=404, response=response)

    if event_presentation_obj_up_result := update_event_presentation_obj(
        event_presentation_id=event_presentation_id,
        event_presentation_obj_up=event_presentation_obj,
        create_sub_obj=create_sub_obj,
        ):

        log.debug(event_presentation_obj_up_result)
        if return_obj:
            event_presentation_obj = load_event_presentation_obj(event_presentation_id=event_presentation_id)
            event_presentation_dict = event_presentation_obj.dict(by_alias=by_alias, exclude_unset=exclude_unset)
            return mk_resp(data=event_presentation_dict, response=response)
        else:
            return mk_resp(data=event_presentation_obj_up_result, response=response)
    else:
        return mk_resp(data=False, status_code=400, response=response) # Bad Request
# ### END ### API Event Presentation ### patch_event_presentation_json() ###


# ### BEGIN ### API Event Presentation ### get_event_presentation_obj() ###
# Working well as of 2021-06-07. Using as a template for other routes.
@router.get('/event/presentation/{event_presentation_id}', response_model=Resp_Body_Base)
async def get_event_presentation_obj(
        event_presentation_id: str = Query(..., min_length=1, max_length=22),
        enabled: str = 'enabled', # enabled, disabled, all; For now this covers any included objects or object lists
        limit: int = 500, # For now this covers any included objects or object lists
        inc_address: bool = False, # Under contact
        inc_contact: bool = False, # Under person
        inc_event_abstract_list: bool = False,
        inc_event_badge: bool = False,
        inc_event_badge_list: bool = False,
        inc_event_device_list: bool = False,
        inc_event_file_list: bool = False,
        inc_event_person_list: bool = False,
        inc_event_presenter_list: bool = False,
        inc_event_registration: bool = False,
        inc_event_registration_list: bool = False,
        # inc_event_session: bool = False, # NOTE: Placehold for future?
        inc_person: bool = False,
        inc_user: bool = False,
        review: str = 'ready', # ready, not_ready, all
        approved: str = 'approved', # approved, not_approved, all
        hidden: str = 'not_hidden', # hidden, not_hidden, all
        inc_file_count: bool = False, # NOTE: file counts are from separate views
        x_account_id: str = Header(...),
        by_alias: Optional[bool] = True,
        exclude_unset: Optional[bool] = True,
        response: Response = Response,
        ):
    log.setLevel(logging.INFO) # DEBUG, INFO, WARNING, ERROR, EXCEPTION, CRITICAL
    log.debug(locals())

    if event_presentation_id := redis_lookup_id_random(record_id_random=event_presentation_id, table_name='event_presentation'): pass
    else:
        return mk_resp(data=None, status_code=404, response=response)

    if event_presentation_obj := load_event_presentation_obj(
            event_presentation_id = event_presentation_id,
            enabled = enabled,
            # review = review,
            # approved = approved,
            hidden = hidden,
            inc_file_count = inc_file_count,
            limit = limit,
            inc_address = inc_address,
            inc_contact = inc_contact,
            inc_event_abstract_list = inc_event_abstract_list,
            inc_event_badge = inc_event_badge,
            # inc_event_badge_list = inc_event_badge_list,
            inc_event_device_list = inc_event_device_list,
            inc_event_file_list = inc_event_file_list,
            inc_event_person_list = inc_event_person_list,
            inc_event_presenter_list = inc_event_presenter_list,
            inc_event_registration = inc_event_registration,
            # inc_event_registration_list = inc_event_registration_list,
            inc_person = inc_person,
            inc_user = inc_user,
            ):
        event_presentation_dict = event_presentation_obj.dict(by_alias=by_alias, exclude_unset=exclude_unset)
        pass
    else:
        return mk_resp(data=False, status_code=400, response=response) # Bad Request

    return mk_resp(data=event_presentation_dict, response=response)
    #return mk_resp(data=event_presentation_obj)
# ### END ### API Event Presentation ### get_event_presentation_obj() ###


# ### BEGIN ### API Event Presentation ### get_event_session_event_presentation_li() ###
# Updated 2021-10-20
@router.get('/event/session/{event_session_id}/event/presentation/list', response_model=Resp_Body_Base)
async def get_event_session_event_presentation_li(
        event_session_id: str = Query(..., min_length=11, max_length=22),
        enabled: str = 'enabled', # enabled, disabled, all
        limit: int = 50,
        # inc_address: bool = False,
        # inc_contact: bool = False,
        inc_event_file_list: bool = False,
        inc_event_presenter_list: bool = False,
        inc_event_person: bool = False, # Intended for event_presenter
        # inc_event_person_list: bool = False,
        inc_person: bool = False, # Intended for event_presenter > event_person
        review: str = 'all', # ready, not_ready, all
        approved: str = 'all', # approved, not_approved, all
        hidden: str = 'not_hidden', # hidden, not_hidden, all
        inc_file_count: bool = False, # NOTE: file counts are from separate views
        x_account_id: str = Header(...),
        by_alias: Optional[bool] = True,
        exclude_unset: Optional[bool] = True,
        response: Response = Response,
        ):
    log.setLevel(logging.INFO) # DEBUG, INFO, WARNING, ERROR, EXCEPTION, CRITICAL
    log.debug(locals())

    if event_session_id := redis_lookup_id_random(record_id_random=event_session_id, table_name='event_session'): pass
    else: return mk_resp(data=None, status_code=404, response=response)

    # Updated 2021-10-20
    if event_presentation_rec_list_result := get_event_presentation_rec_list(
            event_session_id = event_session_id,
            review = review, # ready, not_ready, all
            approved = approved, # approve(d), not_approved, all
            hidden = hidden, # hidden, not_hidden, all
            enabled = enabled,
            limit = limit,
            ):
        event_presentation_result_list = []
        for event_presentation_rec in event_presentation_rec_list_result:
            if load_event_presentation_result := load_event_presentation_obj(
                    event_presentation_id = event_presentation_rec.get('event_presentation_id', None),
                    enabled = enabled,
                    # review = review,
                    # approved = approved,
                    hidden = hidden,
                    inc_file_count = inc_file_count,
                    inc_event_file_list = inc_event_file_list,
                    inc_event_presenter_list = inc_event_presenter_list,
                    inc_person = inc_person,
                    limit = limit,
                    by_alias = by_alias,
                    exclude_unset = exclude_unset,
                    # model_as_dict = model_as_dict,
                    ):
                event_presentation_result_list.append(load_event_presentation_result)
            else:
                event_presentation_result_list.append(None)
        response_data = event_presentation_result_list
    elif isinstance(event_presentation_rec_list_result, list):
        return mk_resp(data=False, status_code=404, response=response) # Not Found
    else:
        return mk_resp(data=False, status_code=400, response=response) # Bad Request

    return mk_resp(data=response_data, response=response)
# ### END ### API Event Presentation ### get_event_session_event_presentation_li() ###


@router.delete('/event/presentation/{obj_id}', response_model=Resp_Body_Base)
async def delete_event_presentation_obj(
        obj_id: str = Query(..., min_length=1, max_length=22),
        x_account_id: str = Header(...),
        response: Response = Response,
        ):
    log.setLevel(logging.WARNING) # DEBUG, INFO, WARNING, ERROR, EXCEPTION, CRITICAL
    log.debug(locals())

    obj_type = 'event_presentation'
    result = delete_obj_template(
        obj_type=obj_type,
        obj_id=obj_id,
        )
    return result