from ishtar_common.serializers import generic_get_results, archive_serialization
from archaeological_context_records import models


CR_MODEL_LIST = [
    models.Dating, models.ContextRecord, models.RecordRelations
]

# TODO: associated documents


def cr_serialization(archive=False, return_empty_types=False,
                     archive_name=None, operation_queryset=None,
                     site_queryset=None, cr_queryset=None, find_queryset=None):
    result_queryset = {}
    if operation_queryset:
        operation_ids = operation_queryset.values_list("id", flat=True)
        result_queryset = {
            models.ContextRecord.__name__:
                models.ContextRecord.objects.filter(
                    operation_id__in=operation_ids),
            models.RecordRelations.__name__:
                models.RecordRelations.objects.filter(
                    left_record__operation_id__in=operation_ids,
                    right_record__operation_id__in=operation_ids,
                )
        }
    elif site_queryset:
        site_ids = site_queryset.values_list("id", flat=True)
        result_queryset = {
            models.ContextRecord.__name__:
                models.ContextRecord.objects.filter(
                    archaeological_site_id__in=site_ids),
            models.RecordRelations.__name__:
                models.RecordRelations.objects.filter(
                    left_record__archaeological_site_id__in=site_ids,
                    right_record__archaeological_site_id__in=site_ids,
                )
        }
    elif cr_queryset:
        cr_ids = cr_queryset.values_list("id", flat=True)
        result_queryset = {
            models.ContextRecord.__name__: cr_queryset,
            models.RecordRelations.__name__:
                models.RecordRelations.objects.filter(
                    left_record_id__in=cr_ids,
                    right_record_id__in=cr_ids,
                )
        }
    elif find_queryset:
        find_ids = find_queryset.values_list("id", flat=True)
        result_queryset = {
            models.ContextRecord.__name__: models.ContextRecord.objects.filter(
                base_finds__find__id__in=find_ids,
            ),
            models.RecordRelations.__name__:
                models.RecordRelations.objects.filter(
                    left_record__base_finds__find__id__in=find_ids,
                    right_record__base_finds__find__id__in=find_ids,
                )
        }

    result = generic_get_results(CR_MODEL_LIST, "context_records",
                                 result_queryset=result_queryset)
    full_archive = archive_serialization(
        result, archive_dir="context_records", archive=archive,
        return_empty_types=return_empty_types, archive_name=archive_name,
    )
    return full_archive