from __future__ import annotations import datetime, hashlib, logging, os, pytz, redis, secrets from typing import Dict, List, Optional, Set, Union from pydantic import BaseModel, EmailStr, Field, Json, PrivateAttr, ValidationError, validator from app.db_sql import redis_lookup_id_random from app.lib_general import log, logging from .common_field_schema import base_fields, default_num_bytes #from .event_models import Event_Base from .event_person_models import Event_Person_Base from .event_presentation_models import Event_Presentation_Base #from .event_presenter_models import Event_Presenter_Base # This creates an import loop from .event_session_models import Event_Session_Base from .event_track_models import Event_Track_Base from .person_models import Person_Base class Event_Abstract_Base(BaseModel): log.setLevel(logging.WARNING) # DEBUG, INFO, WARNING, ERROR, EXCEPTION, CRITICAL log.debug(locals()) id_random: Optional[str] = Field( **base_fields['event_abstract_id_random'], alias = 'event_abstract_id_random', default_factory = lambda:secrets.token_urlsafe(default_num_bytes), ) id: Optional[int] = Field( alias = 'event_abstract_id' ) event_id_random: Optional[str] event_id: Optional[int] event_person_id_random: Optional[str] event_person_id: Optional[int] event_presentation_id_random: Optional[str] event_presentation_id: Optional[int] event_presenter_id_random: Optional[str] event_presenter_id: Optional[int] event_session_id_random: Optional[str] event_session_id: Optional[int] event_track_id_random: Optional[str] event_track_id: Optional[int] poc_event_person_id_random: Optional[str] # Maybe change this to primary_event_person? poc_event_person_id: Optional[int] # Maybe change this to primary_event_person? poc_person_id_random: Optional[str] # Maybe change this to primary_person? poc_person_id: Optional[int] # Maybe change this to primary_person? code: Optional[str] name: Optional[str] description: Optional[str] abstract: Optional[str] hide: Optional[bool] public: Optional[bool] public_hide: Optional[bool] priority: Optional[bool] sort: Optional[int] group: Optional[str] notes: Optional[str] created_on: Optional[datetime.datetime] = None updated_on: Optional[datetime.datetime] = None # Including other related objects #event: Optional[Event_Base] event_file_list: Optional[list] # Optional[Event_File_Base] event_person: Optional[Event_Person_Base] event_presentation: Optional[Event_Presentation_Base] #event_presenter: Optional[Event_Presenter_Base] # This creates an import loop event_presenter_list: Optional[list] # Optional[Event_Presenter_Base] event_session: Optional[Event_Session_Base] event_track: Optional[Event_Track_Base] poc_event_person: Optional[Event_Person_Base] # Maybe change this to primary_event_person? poc_person: Optional[Person_Base] # Maybe change this to primary_person? _processed_at: datetime.datetime = PrivateAttr(default_factory=datetime.datetime.now) #@validator('event_abstract_id_random', always=True) def event_abstract_id_random_copy(cls, v, values, **kwargs): log.setLevel(logging.WARNING) log.debug(locals()) if values['id_random']: return values['id_random'] return None @validator('id', always=True) def event_abstract_id_lookup(cls, v, values, **kwargs): log.setLevel(logging.WARNING) log.debug(locals()) if values['id_random']: log.debug(values['id_random']) return redis_lookup_id_random(record_id_random=values['id_random'], table_name='event_abstract') return None @validator('event_id', always=True) def event_id_lookup(cls, v, values, **kwargs): log.setLevel(logging.WARNING) log.debug(locals()) if values['event_id_random']: return redis_lookup_id_random(record_id_random=values['event_id_random'], table_name='event') return None @validator('event_person_id', always=True) def event_person_id_lookup(cls, v, values, **kwargs): log.setLevel(logging.WARNING) log.debug(locals()) if values['event_person_id_random']: return redis_lookup_id_random(record_id_random=values['event_person_id_random'], table_name='event_person') return None @validator('event_presentation_id', always=True) def event_presentation_id_lookup(cls, v, values, **kwargs): log.setLevel(logging.WARNING) log.debug(locals()) if values['event_presentation_id_random']: return redis_lookup_id_random(record_id_random=values['event_presentation_id_random'], table_name='event_presentation') return None @validator('event_presenter_id', always=True) def event_presenter_id_lookup(cls, v, values, **kwargs): log.setLevel(logging.WARNING) log.debug(locals()) if values['event_presenter_id_random']: return redis_lookup_id_random(record_id_random=values['event_presenter_id_random'], table_name='event_presenter') return None @validator('event_session_id', always=True) def event_session_id_lookup(cls, v, values, **kwargs): log.setLevel(logging.WARNING) log.debug(locals()) if values['event_session_id_random']: return redis_lookup_id_random(record_id_random=values['event_session_id_random'], table_name='event_session') return None @validator('event_track_id', always=True) def event_track_id_lookup(cls, v, values, **kwargs): log.setLevel(logging.WARNING) log.debug(locals()) if values['event_track_id_random']: return redis_lookup_id_random(record_id_random=values['event_track_id_random'], table_name='event_track') return None @validator('poc_event_person_id', always=True) def poc_event_person_id_lookup(cls, v, values, **kwargs): log.setLevel(logging.WARNING) log.debug(locals()) if values['poc_event_person_id_random']: return redis_lookup_id_random(record_id_random=values['poc_event_person_id_random'], table_name='poc_event_person') return None @validator('poc_person_id', always=True) def poc_person_id_lookup(cls, v, values, **kwargs): log.setLevel(logging.WARNING) log.debug(locals()) if values['poc_person_id_random']: return redis_lookup_id_random(record_id_random=values['poc_person_id_random'], table_name='poc_person') return None class Config: underscore_attrs_are_private = True allow_population_by_field_name = True fields = base_fields #Event_Abstract_Base.update_forward_refs()