from logging import getLogger

import ch2.common.io
from .args import FIX
from ..lib.log import Record
from ..sql import ActivityTopicJournal, FileHash, FileScan, StatisticJournal, ActivityJournal

log = getLogger(__name__)


def validate(config):
    '''
## validate

    > ch2 validate

This is still in development.
    '''
    record = Record(log)
    check_all(record, config.db, fix=config.args[FIX])


def check_all(record, db, fix=False):
    # todo - add flags
    check_activity_diary_missing_files(record, db, fix=fix)
    check_activity_journal_groups(record, db, fix=fix)


def check_activity_diary_missing_files(record, db, fix=False):
    with record.record_exceptions(catch=True):
        with db.session_context() as s:
            bad = False
            for topic_journal in s.query(ActivityTopicJournal). \
                    join(StatisticJournal, StatisticJournal.source_id == ActivityTopicJournal.id). \
                    join(FileHash). \
                    outerjoin(FileScan). \
                    filter(FileScan.path == None).all():
                bad = True
                record.warning(f'{ActivityTopicJournal.__table__} with file hash '
                               f'{topic_journal.file_hash.hash[:6]} has associated entries but no activity')
                if fix:
                    record.warning('Deleting entry')
                    s.delete(topic_journal)
            if not bad:
                record.info('No missing activities from activity topic data')


def check_activity_journal_groups(record, db, fix=False):
    with record.record_exceptions(catch=True):
        with db.session_context() as s:
            bad = False
            for topic_journal, activity_journal in s.query(ActivityTopicJournal, ActivityJournal). \
                    select_from(ActivityTopicJournal). \
                    join(ActivityJournal, ActivityJournal.file_hash_id == ActivityTopicJournal.file_hash_id). \
                    filter(ActivityJournal.activity_group_id != ActivityTopicJournal.activity_group_id).all():
                bad = True
                record.warning(f'{topic_journal.activity_group.name} / {activity_journal.activity_group.name} '
                               f'for same activity ({activity_journal.start})')
                if fix:
                    record.warning('Changing topic to match activity')
                    topic_journal.activity_group = activity_journal.activity_group
            if not bad:
                record.info('No conflicting activity groups for activities')




# add flag fix to fix things

# check everything needed for power estimates
# (including weight)

# check constants defined

# check configure was run (version)

# check whether permanent directory present

# check whether file system ok (space?)

# check whether all files are scanned

# check whether all activity topics entries have an activity for the file hash

# all activity diary entries have corresponding activity - fix group

# check for activity without GPS datya (lyn in 2018)

# check for multiple activiy topic journals (or whatever we have)
