Function sync_identity_document_features

api/edge_api/identities/tasks.py:94–108

(identity_uuid: str)

@register_task_handler(priority=TaskPriority.HIGH)
def sync_identity_document_features(identity_uuid: str):  # type: ignore[no-untyped-def]
    from .models import EdgeIdentity

    identity = EdgeIdentity.from_identity_document(
        EdgeIdentity.dynamo_wrapper.get_item_from_uuid(identity_uuid)
    )

    valid_feature_names = set(
        FeatureState.objects.filter(
            environment__api_key=identity.environment_api_key
        ).values_list("feature__name", flat=True)
    )

    identity.synchronise_features(valid_feature_names)
    identity.save()


@register_task_handler()