"""DID Document Object."""

import json
from typing import Any, List, Set, Union

from voluptuous import ALLOW_EXTRA, All, Coerce, Switch, Url

from ..did import DID
from ..did_url import DIDUrl
from ..validation import (
    Option,
    Properties,
    serialize,
    single_to_list,
    unwrap_if_list_of_one,
    wrap_validation_error,
)
from . import DIDDocumentError
from .doc_options import DIDDocumentOption
from .service import Service
from .didcomm_service import DIDCommService
from .verification_method import VerificationMethod
from .verification_relationship import VerificationRelationship


class IdentifiedResourceMismatch(DIDDocumentError):
    """Raised when two or more of the same ID point to differing resources."""


class ResourceIDNotFound(DIDDocumentError):
    """Raised when Resource ID not found in DID Document."""


class DIDDocumentValidationError(DIDDocumentError):
    """Raised when Document validation fails."""


def _didcomm_or_service_discriminant(value, validators):
    """Return the validator to use for the service."""
    if value["type"] == "did-communication" or value["type"] == "IndyAgent":
        yield validators[0]
    else:
        yield validators[1]


class DIDDocument:
    """Representation of DID Document."""

    properties = Properties(extra=ALLOW_EXTRA)

    def __init__(
        self,
        id: str,
        context: List[Any],
        *,
        also_known_as: List[str] = None,
        controller: List[str] = None,
        verification_method: List[VerificationMethod] = None,
        authentication: VerificationRelationship = None,
        assertion_method: VerificationRelationship = None,
        key_agreement: VerificationRelationship = None,
        capability_invocation: VerificationRelationship = None,
        capability_delegation: VerificationRelationship = None,
        service: List[Service] = None,
        **extra
    ):
        """Create DIDDocument."""
        self._id = id
        self._context = context
        self._also_known_as = also_known_as
        self._controller = controller
        self._verification_method = verification_method
        self._authentication = authentication
        self._assertion_method = assertion_method
        self._key_agreement = key_agreement
        self._capability_invocation = capability_invocation
        self._capability_delegation = capability_delegation
        self._service = service
        self.extra = extra

        self._index = {}
        self._index_resources()

    def _index_resources(self):
        """Index resources by ID.

        IDs are not guaranteed to be unique within the document.
        The first instance is stored in the index and subsequent id collisions
        are checked against the original. If they do not match, an error will
        be thrown.
        """

        def _indexer(item):
            if not item:
                # Attribute isn't set
                return
            if isinstance(item, DIDUrl):
                # We don't index references
                return
            if isinstance(item, list):
                for subitem in item:
                    _indexer(subitem)
                return
            if isinstance(item, VerificationRelationship):
                for subitem in item.items:
                    _indexer(subitem)
                return

            assert isinstance(item, (VerificationMethod, Service))
            if item.id in self._index and item != self._index[item.id]:
                raise IdentifiedResourceMismatch(
                    "ID {} already found in Index and Items do not match".format(
                        item.id
                    )
                )

            self._index[item.id] = item

        for item in (
            self.verification_method,
            self.authentication,
            self.assertion_method,
            self.key_agreement,
            self.capability_invocation,
            self.capability_delegation,
            self.service,
        ):
            _indexer(item)

    @property
    @properties.add(
        data_key="@context",
        required=True,
        validate=Switch(Url(), [Url()], dict, [dict]),
        serialize=unwrap_if_list_of_one,
        deserialize=single_to_list,
    )
    def context(self):
        """Return context."""
        return self._context

    @property
    @properties.add(
        required=True,
        validate=All(str, DID.validate),
        serialize=str,
        deserialize=str,
    )
    def id(self):
        """Return id."""
        return self._id

    @property
    def did(self):
        """Return the DID representation of id."""
        return DID(self._id)

    @property
    @properties.add(data_key="alsoKnownAs", validate=[str])
    def also_known_as(self):
        """Return also_known_as."""
        return self._also_known_as

    @property
    @properties.add(
        validate=Switch(All(str, DID.validate), [DID.validate]),
        serialize=All([Coerce(str)], unwrap_if_list_of_one),
        deserialize=All(single_to_list, [Coerce(DID)]),
    )
    def controller(self):
        """Return controller."""
        return self._controller

    @property
    @properties.add(
        data_key="verificationMethod",
        validate=[VerificationMethod.validate],
        serialize=[serialize],
        deserialize=[VerificationMethod.deserialize],
    )
    def verification_method(self):
        """Return verification_method."""
        return self._verification_method

    @property
    @properties.add(
        validate=VerificationRelationship.validate,
        serialize=serialize,
        deserialize=VerificationRelationship.deserialize,
    )
    def authentication(self):
        """Return authentication."""
        return self._authentication

    @property
    @properties.add(
        data_key="assertionMethod",
        validate=VerificationRelationship.validate,
        serialize=serialize,
        deserialize=VerificationRelationship.deserialize,
    )
    def assertion_method(self):
        """Return assertion_method."""
        return self._assertion_method

    @property
    @properties.add(
        data_key="keyAgreement",
        validate=VerificationRelationship.validate,
        serialize=serialize,
        deserialize=VerificationRelationship.deserialize,
    )
    def key_agreement(self):
        """Return key_agreement."""
        return self._key_agreement

    @property
    @properties.add(
        data_key="capabilityInvocation",
        validate=VerificationRelationship.validate,
        serialize=serialize,
        deserialize=VerificationRelationship.deserialize,
    )
    def capability_invocation(self):
        """Return capability_invocation."""
        return self._capability_invocation

    @property
    @properties.add(
        data_key="capabilityDelegation",
        validate=VerificationRelationship.validate,
        serialize=serialize,
        deserialize=VerificationRelationship.deserialize,
    )
    def capability_delegation(self):
        """Return capability_delegation."""
        return self._capability_delegation

    @property
    @properties.add(
        validate=[Service.validate],
        serialize=[serialize],
        deserialize=[
            Switch(
                DIDCommService.deserialize,
                Service.deserialize,
                discriminant=_didcomm_or_service_discriminant,
            )
        ],
    )
    def service(self):
        """Return service."""
        return self._service

    def dereference(self, reference: Union[str, DIDUrl]):
        """Dereference a DID URL to a document resource."""
        if isinstance(reference, str):
            reference = DIDUrl.parse(reference)

        if reference not in self._index:
            raise ResourceIDNotFound("ID {} not found in document".format(reference))
        return self._index[reference]

    @classmethod
    @wrap_validation_error(
        DIDDocumentValidationError, message="Failed to validate DID Document"
    )
    def validate(cls, value):
        """Validate against expected schema."""
        return cls.properties.validate(value)

    @wrap_validation_error(DIDDocumentError, message="Failed to serialize DID Document")
    def serialize(self):
        """Serialize DID Document."""
        value = self.properties.serialize(self)
        return {**value, **self.extra}

    @classmethod
    @wrap_validation_error(
        DIDDocumentValidationError, message="Failed to deserialize DID Document"
    )
    def deserialize(cls, value: dict, options: Set[Option] = None):
        """Deserialize DID Document."""
        if options:
            value = DIDDocumentOption.apply(value, options)
        value = cls.validate(value)
        value = cls.properties.deserialize(value)
        return cls(**value)

    @classmethod
    @wrap_validation_error(
        DIDDocumentValidationError, message="Failed to deserialize DID Document"
    )
    def from_json(cls, value: str, options: Set[Option] = None):
        """Deserialize DID Document from JSON."""
        doc_raw: dict = json.loads(value)
        return cls.deserialize(doc_raw, options)

    def to_json(self):
        """Serialize DID Document to JSON."""
        return json.dumps(self.serialize())

78083bda8bed87c1e95343688f31b02e404a658b
<mask token>


class DIDDocument:
    <mask token>
    <mask token>

    def __init__(self, id: str, context: List[Any], *, also_known_as: List[
        str]=None, controller: List[str]=None, verification_method: List[
        VerificationMethod]=None, authentication: VerificationRelationship=
        None, assertion_method: VerificationRelationship=None,
        key_agreement: VerificationRelationship=None, capability_invocation:
        VerificationRelationship=None, capability_delegation:
        VerificationRelationship=None, service: List[Service]=None, **extra):
        """Create DIDDocument."""
        self._id = id
        self._context = context
        self._also_known_as = also_known_as
        self._controller = controller
        self._verification_method = verification_method
        self._authentication = authentication
        self._assertion_method = assertion_method
        self._key_agreement = key_agreement
        self._capability_invocation = capability_invocation
        self._capability_delegation = capability_delegation
        self._service = service
        self.extra = extra
        self._index = {}
        self._index_resources()
    <mask token>
    <mask token>

    @property
    @properties.add(required=True, validate=All(str, DID.validate),
        serialize=str, deserialize=str)
    def id(self):
        """Return id."""
        return self._id

    @property
    def did(self):
        """Return the DID representation of id."""
        return DID(self._id)

    @property
    @properties.add(data_key='alsoKnownAs', validate=[str])
    def also_known_as(self):
        """Return also_known_as."""
        return self._also_known_as

    @property
    @properties.add(validate=Switch(All(str, DID.validate), [DID.validate]),
        serialize=All([Coerce(str)], unwrap_if_list_of_one), deserialize=
        All(single_to_list, [Coerce(DID)]))
    def controller(self):
        """Return controller."""
        return self._controller
    <mask token>

    @property
    @properties.add(validate=VerificationRelationship.validate, serialize=
        serialize, deserialize=VerificationRelationship.deserialize)
    def authentication(self):
        """Return authentication."""
        return self._authentication

    @property
    @properties.add(data_key='assertionMethod', validate=
        VerificationRelationship.validate, serialize=serialize, deserialize
        =VerificationRelationship.deserialize)
    def assertion_method(self):
        """Return assertion_method."""
        return self._assertion_method

    @property
    @properties.add(data_key='keyAgreement', validate=
        VerificationRelationship.validate, serialize=serialize, deserialize
        =VerificationRelationship.deserialize)
    def key_agreement(self):
        """Return key_agreement."""
        return self._key_agreement

    @property
    @properties.add(data_key='capabilityInvocation', validate=
        VerificationRelationship.validate, serialize=serialize, deserialize
        =VerificationRelationship.deserialize)
    def capability_invocation(self):
        """Return capability_invocation."""
        return self._capability_invocation

    @property
    @properties.add(data_key='capabilityDelegation', validate=
        VerificationRelationship.validate, serialize=serialize, deserialize
        =VerificationRelationship.deserialize)
    def capability_delegation(self):
        """Return capability_delegation."""
        return self._capability_delegation

    @property
    @properties.add(validate=[Service.validate], serialize=[serialize],
        deserialize=[Switch(DIDCommService.deserialize, Service.deserialize,
        discriminant=_didcomm_or_service_discriminant)])
    def service(self):
        """Return service."""
        return self._service

    def dereference(self, reference: Union[str, DIDUrl]):
        """Dereference a DID URL to a document resource."""
        if isinstance(reference, str):
            reference = DIDUrl.parse(reference)
        if reference not in self._index:
            raise ResourceIDNotFound('ID {} not found in document'.format(
                reference))
        return self._index[reference]

    @classmethod
    @wrap_validation_error(DIDDocumentValidationError, message=
        'Failed to validate DID Document')
    def validate(cls, value):
        """Validate against expected schema."""
        return cls.properties.validate(value)

    @wrap_validation_error(DIDDocumentError, message=
        'Failed to serialize DID Document')
    def serialize(self):
        """Serialize DID Document."""
        value = self.properties.serialize(self)
        return {**value, **self.extra}

    @classmethod
    @wrap_validation_error(DIDDocumentValidationError, message=
        'Failed to deserialize DID Document')
    def deserialize(cls, value: dict, options: Set[Option]=None):
        """Deserialize DID Document."""
        if options:
            value = DIDDocumentOption.apply(value, options)
        value = cls.validate(value)
        value = cls.properties.deserialize(value)
        return cls(**value)

    @classmethod
    @wrap_validation_error(DIDDocumentValidationError, message=
        'Failed to deserialize DID Document')
    def from_json(cls, value: str, options: Set[Option]=None):
        """Deserialize DID Document from JSON."""
        doc_raw: dict = json.loads(value)
        return cls.deserialize(doc_raw, options)

    def to_json(self):
        """Serialize DID Document to JSON."""
        return json.dumps(self.serialize())

<mask token>


class DIDDocument:
    <mask token>
    <mask token>

    def __init__(self, id: str, context: List[Any], *, also_known_as: List[
        str]=None, controller: List[str]=None, verification_method: List[
        VerificationMethod]=None, authentication: VerificationRelationship=
        None, assertion_method: VerificationRelationship=None,
        key_agreement: VerificationRelationship=None, capability_invocation:
        VerificationRelationship=None, capability_delegation:
        VerificationRelationship=None, service: List[Service]=None, **extra):
        """Create DIDDocument."""
        self._id = id
        self._context = context
        self._also_known_as = also_known_as
        self._controller = controller
        self._verification_method = verification_method
        self._authentication = authentication
        self._assertion_method = assertion_method
        self._key_agreement = key_agreement
        self._capability_invocation = capability_invocation
        self._capability_delegation = capability_delegation
        self._service = service
        self.extra = extra
        self._index = {}
        self._index_resources()

    def _index_resources(self):
        """Index resources by ID.

        IDs are not guaranteed to be unique within the document.
        The first instance is stored in the index and subsequent id collisions
        are checked against the original. If they do not match, an error will
        be thrown.
        """

        def _indexer(item):
            if not item:
                return
            if isinstance(item, DIDUrl):
                return
            if isinstance(item, list):
                for subitem in item:
                    _indexer(subitem)
                return
            if isinstance(item, VerificationRelationship):
                for subitem in item.items:
                    _indexer(subitem)
                return
            assert isinstance(item, (VerificationMethod, Service))
            if item.id in self._index and item != self._index[item.id]:
                raise IdentifiedResourceMismatch(
                    'ID {} already found in Index and Items do not match'.
                    format(item.id))
            self._index[item.id] = item
        for item in (self.verification_method, self.authentication, self.
            assertion_method, self.key_agreement, self.
            capability_invocation, self.capability_delegation, self.service):
            _indexer(item)

    @property
    @properties.add(data_key='@context', required=True, validate=Switch(Url
        (), [Url()], dict, [dict]), serialize=unwrap_if_list_of_one,
        deserialize=single_to_list)
    def context(self):
        """Return context."""
        return self._context

    @property
    @properties.add(required=True, validate=All(str, DID.validate),
        serialize=str, deserialize=str)
    def id(self):
        """Return id."""
        return self._id

    @property
    def did(self):
        """Return the DID representation of id."""
        return DID(self._id)

    @property
    @properties.add(data_key='alsoKnownAs', validate=[str])
    def also_known_as(self):
        """Return also_known_as."""
        return self._also_known_as

    @property
    @properties.add(validate=Switch(All(str, DID.validate), [DID.validate]),
        serialize=All([Coerce(str)], unwrap_if_list_of_one), deserialize=
        All(single_to_list, [Coerce(DID)]))
    def controller(self):
        """Return controller."""
        return self._controller
    <mask token>

    @property
    @properties.add(validate=VerificationRelationship.validate, serialize=
        serialize, deserialize=VerificationRelationship.deserialize)
    def authentication(self):
        """Return authentication."""
        return self._authentication

    @property
    @properties.add(data_key='assertionMethod', validate=
        VerificationRelationship.validate, serialize=serialize, deserialize
        =VerificationRelationship.deserialize)
    def assertion_method(self):
        """Return assertion_method."""
        return self._assertion_method

    @property
    @properties.add(data_key='keyAgreement', validate=
        VerificationRelationship.validate, serialize=serialize, deserialize
        =VerificationRelationship.deserialize)
    def key_agreement(self):
        """Return key_agreement."""
        return self._key_agreement

    @property
    @properties.add(data_key='capabilityInvocation', validate=
        VerificationRelationship.validate, serialize=serialize, deserialize
        =VerificationRelationship.deserialize)
    def capability_invocation(self):
        """Return capability_invocation."""
        return self._capability_invocation

    @property
    @properties.add(data_key='capabilityDelegation', validate=
        VerificationRelationship.validate, serialize=serialize, deserialize
        =VerificationRelationship.deserialize)
    def capability_delegation(self):
        """Return capability_delegation."""
        return self._capability_delegation

    @property
    @properties.add(validate=[Service.validate], serialize=[serialize],
        deserialize=[Switch(DIDCommService.deserialize, Service.deserialize,
        discriminant=_didcomm_or_service_discriminant)])
    def service(self):
        """Return service."""
        return self._service

    def dereference(self, reference: Union[str, DIDUrl]):
        """Dereference a DID URL to a document resource."""
        if isinstance(reference, str):
            reference = DIDUrl.parse(reference)
        if reference not in self._index:
            raise ResourceIDNotFound('ID {} not found in document'.format(
                reference))
        return self._index[reference]

    @classmethod
    @wrap_validation_error(DIDDocumentValidationError, message=
        'Failed to validate DID Document')
    def validate(cls, value):
        """Validate against expected schema."""
        return cls.properties.validate(value)

    @wrap_validation_error(DIDDocumentError, message=
        'Failed to serialize DID Document')
    def serialize(self):
        """Serialize DID Document."""
        value = self.properties.serialize(self)
        return {**value, **self.extra}

    @classmethod
    @wrap_validation_error(DIDDocumentValidationError, message=
        'Failed to deserialize DID Document')
    def deserialize(cls, value: dict, options: Set[Option]=None):
        """Deserialize DID Document."""
        if options:
            value = DIDDocumentOption.apply(value, options)
        value = cls.validate(value)
        value = cls.properties.deserialize(value)
        return cls(**value)

    @classmethod
    @wrap_validation_error(DIDDocumentValidationError, message=
        'Failed to deserialize DID Document')
    def from_json(cls, value: str, options: Set[Option]=None):
        """Deserialize DID Document from JSON."""
        doc_raw: dict = json.loads(value)
        return cls.deserialize(doc_raw, options)

    def to_json(self):
        """Serialize DID Document to JSON."""
        return json.dumps(self.serialize())

<mask token>


class DIDDocumentValidationError(DIDDocumentError):
    """Raised when Document validation fails."""


<mask token>


class DIDDocument:
    """Representation of DID Document."""
    properties = Properties(extra=ALLOW_EXTRA)

    def __init__(self, id: str, context: List[Any], *, also_known_as: List[
        str]=None, controller: List[str]=None, verification_method: List[
        VerificationMethod]=None, authentication: VerificationRelationship=
        None, assertion_method: VerificationRelationship=None,
        key_agreement: VerificationRelationship=None, capability_invocation:
        VerificationRelationship=None, capability_delegation:
        VerificationRelationship=None, service: List[Service]=None, **extra):
        """Create DIDDocument."""
        self._id = id
        self._context = context
        self._also_known_as = also_known_as
        self._controller = controller
        self._verification_method = verification_method
        self._authentication = authentication
        self._assertion_method = assertion_method
        self._key_agreement = key_agreement
        self._capability_invocation = capability_invocation
        self._capability_delegation = capability_delegation
        self._service = service
        self.extra = extra
        self._index = {}
        self._index_resources()

    def _index_resources(self):
        """Index resources by ID.

        IDs are not guaranteed to be unique within the document.
        The first instance is stored in the index and subsequent id collisions
        are checked against the original. If they do not match, an error will
        be thrown.
        """

        def _indexer(item):
            if not item:
                return
            if isinstance(item, DIDUrl):
                return
            if isinstance(item, list):
                for subitem in item:
                    _indexer(subitem)
                return
            if isinstance(item, VerificationRelationship):
                for subitem in item.items:
                    _indexer(subitem)
                return
            assert isinstance(item, (VerificationMethod, Service))
            if item.id in self._index and item != self._index[item.id]:
                raise IdentifiedResourceMismatch(
                    'ID {} already found in Index and Items do not match'.
                    format(item.id))
            self._index[item.id] = item
        for item in (self.verification_method, self.authentication, self.
            assertion_method, self.key_agreement, self.
            capability_invocation, self.capability_delegation, self.service):
            _indexer(item)

    @property
    @properties.add(data_key='@context', required=True, validate=Switch(Url
        (), [Url()], dict, [dict]), serialize=unwrap_if_list_of_one,
        deserialize=single_to_list)
    def context(self):
        """Return context."""
        return self._context

    @property
    @properties.add(required=True, validate=All(str, DID.validate),
        serialize=str, deserialize=str)
    def id(self):
        """Return id."""
        return self._id

    @property
    def did(self):
        """Return the DID representation of id."""
        return DID(self._id)

    @property
    @properties.add(data_key='alsoKnownAs', validate=[str])
    def also_known_as(self):
        """Return also_known_as."""
        return self._also_known_as

    @property
    @properties.add(validate=Switch(All(str, DID.validate), [DID.validate]),
        serialize=All([Coerce(str)], unwrap_if_list_of_one), deserialize=
        All(single_to_list, [Coerce(DID)]))
    def controller(self):
        """Return controller."""
        return self._controller

    @property
    @properties.add(data_key='verificationMethod', validate=[
        VerificationMethod.validate], serialize=[serialize], deserialize=[
        VerificationMethod.deserialize])
    def verification_method(self):
        """Return verification_method."""
        return self._verification_method

    @property
    @properties.add(validate=VerificationRelationship.validate, serialize=
        serialize, deserialize=VerificationRelationship.deserialize)
    def authentication(self):
        """Return authentication."""
        return self._authentication

    @property
    @properties.add(data_key='assertionMethod', validate=
        VerificationRelationship.validate, serialize=serialize, deserialize
        =VerificationRelationship.deserialize)
    def assertion_method(self):
        """Return assertion_method."""
        return self._assertion_method

    @property
    @properties.add(data_key='keyAgreement', validate=
        VerificationRelationship.validate, serialize=serialize, deserialize
        =VerificationRelationship.deserialize)
    def key_agreement(self):
        """Return key_agreement."""
        return self._key_agreement

    @property
    @properties.add(data_key='capabilityInvocation', validate=
        VerificationRelationship.validate, serialize=serialize, deserialize
        =VerificationRelationship.deserialize)
    def capability_invocation(self):
        """Return capability_invocation."""
        return self._capability_invocation

    @property
    @properties.add(data_key='capabilityDelegation', validate=
        VerificationRelationship.validate, serialize=serialize, deserialize
        =VerificationRelationship.deserialize)
    def capability_delegation(self):
        """Return capability_delegation."""
        return self._capability_delegation

    @property
    @properties.add(validate=[Service.validate], serialize=[serialize],
        deserialize=[Switch(DIDCommService.deserialize, Service.deserialize,
        discriminant=_didcomm_or_service_discriminant)])
    def service(self):
        """Return service."""
        return self._service

    def dereference(self, reference: Union[str, DIDUrl]):
        """Dereference a DID URL to a document resource."""
        if isinstance(reference, str):
            reference = DIDUrl.parse(reference)
        if reference not in self._index:
            raise ResourceIDNotFound('ID {} not found in document'.format(
                reference))
        return self._index[reference]

    @classmethod
    @wrap_validation_error(DIDDocumentValidationError, message=
        'Failed to validate DID Document')
    def validate(cls, value):
        """Validate against expected schema."""
        return cls.properties.validate(value)

    @wrap_validation_error(DIDDocumentError, message=
        'Failed to serialize DID Document')
    def serialize(self):
        """Serialize DID Document."""
        value = self.properties.serialize(self)
        return {**value, **self.extra}

    @classmethod
    @wrap_validation_error(DIDDocumentValidationError, message=
        'Failed to deserialize DID Document')
    def deserialize(cls, value: dict, options: Set[Option]=None):
        """Deserialize DID Document."""
        if options:
            value = DIDDocumentOption.apply(value, options)
        value = cls.validate(value)
        value = cls.properties.deserialize(value)
        return cls(**value)

    @classmethod
    @wrap_validation_error(DIDDocumentValidationError, message=
        'Failed to deserialize DID Document')
    def from_json(cls, value: str, options: Set[Option]=None):
        """Deserialize DID Document from JSON."""
        doc_raw: dict = json.loads(value)
        return cls.deserialize(doc_raw, options)

    def to_json(self):
        """Serialize DID Document to JSON."""
        return json.dumps(self.serialize())

<mask token>


class IdentifiedResourceMismatch(DIDDocumentError):
    """Raised when two or more of the same ID point to differing resources."""


class ResourceIDNotFound(DIDDocumentError):
    """Raised when Resource ID not found in DID Document."""


class DIDDocumentValidationError(DIDDocumentError):
    """Raised when Document validation fails."""


def _didcomm_or_service_discriminant(value, validators):
    """Return the validator to use for the service."""
    if value['type'] == 'did-communication' or value['type'] == 'IndyAgent':
        yield validators[0]
    else:
        yield validators[1]


class DIDDocument:
    """Representation of DID Document."""
    properties = Properties(extra=ALLOW_EXTRA)

    def __init__(self, id: str, context: List[Any], *, also_known_as: List[
        str]=None, controller: List[str]=None, verification_method: List[
        VerificationMethod]=None, authentication: VerificationRelationship=
        None, assertion_method: VerificationRelationship=None,
        key_agreement: VerificationRelationship=None, capability_invocation:
        VerificationRelationship=None, capability_delegation:
        VerificationRelationship=None, service: List[Service]=None, **extra):
        """Create DIDDocument."""
        self._id = id
        self._context = context
        self._also_known_as = also_known_as
        self._controller = controller
        self._verification_method = verification_method
        self._authentication = authentication
        self._assertion_method = assertion_method
        self._key_agreement = key_agreement
        self._capability_invocation = capability_invocation
        self._capability_delegation = capability_delegation
        self._service = service
        self.extra = extra
        self._index = {}
        self._index_resources()

    def _index_resources(self):
        """Index resources by ID.

        IDs are not guaranteed to be unique within the document.
        The first instance is stored in the index and subsequent id collisions
        are checked against the original. If they do not match, an error will
        be thrown.
        """

        def _indexer(item):
            if not item:
                return
            if isinstance(item, DIDUrl):
                return
            if isinstance(item, list):
                for subitem in item:
                    _indexer(subitem)
                return
            if isinstance(item, VerificationRelationship):
                for subitem in item.items:
                    _indexer(subitem)
                return
            assert isinstance(item, (VerificationMethod, Service))
            if item.id in self._index and item != self._index[item.id]:
                raise IdentifiedResourceMismatch(
                    'ID {} already found in Index and Items do not match'.
                    format(item.id))
            self._index[item.id] = item
        for item in (self.verification_method, self.authentication, self.
            assertion_method, self.key_agreement, self.
            capability_invocation, self.capability_delegation, self.service):
            _indexer(item)

    @property
    @properties.add(data_key='@context', required=True, validate=Switch(Url
        (), [Url()], dict, [dict]), serialize=unwrap_if_list_of_one,
        deserialize=single_to_list)
    def context(self):
        """Return context."""
        return self._context

    @property
    @properties.add(required=True, validate=All(str, DID.validate),
        serialize=str, deserialize=str)
    def id(self):
        """Return id."""
        return self._id

    @property
    def did(self):
        """Return the DID representation of id."""
        return DID(self._id)

    @property
    @properties.add(data_key='alsoKnownAs', validate=[str])
    def also_known_as(self):
        """Return also_known_as."""
        return self._also_known_as

    @property
    @properties.add(validate=Switch(All(str, DID.validate), [DID.validate]),
        serialize=All([Coerce(str)], unwrap_if_list_of_one), deserialize=
        All(single_to_list, [Coerce(DID)]))
    def controller(self):
        """Return controller."""
        return self._controller

    @property
    @properties.add(data_key='verificationMethod', validate=[
        VerificationMethod.validate], serialize=[serialize], deserialize=[
        VerificationMethod.deserialize])
    def verification_method(self):
        """Return verification_method."""
        return self._verification_method

    @property
    @properties.add(validate=VerificationRelationship.validate, serialize=
        serialize, deserialize=VerificationRelationship.deserialize)
    def authentication(self):
        """Return authentication."""
        return self._authentication

    @property
    @properties.add(data_key='assertionMethod', validate=
        VerificationRelationship.validate, serialize=serialize, deserialize
        =VerificationRelationship.deserialize)
    def assertion_method(self):
        """Return assertion_method."""
        return self._assertion_method

    @property
    @properties.add(data_key='keyAgreement', validate=
        VerificationRelationship.validate, serialize=serialize, deserialize
        =VerificationRelationship.deserialize)
    def key_agreement(self):
        """Return key_agreement."""
        return self._key_agreement

    @property
    @properties.add(data_key='capabilityInvocation', validate=
        VerificationRelationship.validate, serialize=serialize, deserialize
        =VerificationRelationship.deserialize)
    def capability_invocation(self):
        """Return capability_invocation."""
        return self._capability_invocation

    @property
    @properties.add(data_key='capabilityDelegation', validate=
        VerificationRelationship.validate, serialize=serialize, deserialize
        =VerificationRelationship.deserialize)
    def capability_delegation(self):
        """Return capability_delegation."""
        return self._capability_delegation

    @property
    @properties.add(validate=[Service.validate], serialize=[serialize],
        deserialize=[Switch(DIDCommService.deserialize, Service.deserialize,
        discriminant=_didcomm_or_service_discriminant)])
    def service(self):
        """Return service."""
        return self._service

    def dereference(self, reference: Union[str, DIDUrl]):
        """Dereference a DID URL to a document resource."""
        if isinstance(reference, str):
            reference = DIDUrl.parse(reference)
        if reference not in self._index:
            raise ResourceIDNotFound('ID {} not found in document'.format(
                reference))
        return self._index[reference]

    @classmethod
    @wrap_validation_error(DIDDocumentValidationError, message=
        'Failed to validate DID Document')
    def validate(cls, value):
        """Validate against expected schema."""
        return cls.properties.validate(value)

    @wrap_validation_error(DIDDocumentError, message=
        'Failed to serialize DID Document')
    def serialize(self):
        """Serialize DID Document."""
        value = self.properties.serialize(self)
        return {**value, **self.extra}

    @classmethod
    @wrap_validation_error(DIDDocumentValidationError, message=
        'Failed to deserialize DID Document')
    def deserialize(cls, value: dict, options: Set[Option]=None):
        """Deserialize DID Document."""
        if options:
            value = DIDDocumentOption.apply(value, options)
        value = cls.validate(value)
        value = cls.properties.deserialize(value)
        return cls(**value)

    @classmethod
    @wrap_validation_error(DIDDocumentValidationError, message=
        'Failed to deserialize DID Document')
    def from_json(cls, value: str, options: Set[Option]=None):
        """Deserialize DID Document from JSON."""
        doc_raw: dict = json.loads(value)
        return cls.deserialize(doc_raw, options)

    def to_json(self):
        """Serialize DID Document to JSON."""
        return json.dumps(self.serialize())

"""DID Document Object."""

import json
from typing import Any, List, Set, Union

from voluptuous import ALLOW_EXTRA, All, Coerce, Switch, Url

from ..did import DID
from ..did_url import DIDUrl
from ..validation import (
    Option,
    Properties,
    serialize,
    single_to_list,
    unwrap_if_list_of_one,
    wrap_validation_error,
)
from . import DIDDocumentError
from .doc_options import DIDDocumentOption
from .service import Service
from .didcomm_service import DIDCommService
from .verification_method import VerificationMethod
from .verification_relationship import VerificationRelationship


class IdentifiedResourceMismatch(DIDDocumentError):
    """Raised when two or more of the same ID point to differing resources."""


class ResourceIDNotFound(DIDDocumentError):
    """Raised when Resource ID not found in DID Document."""


class DIDDocumentValidationError(DIDDocumentError):
    """Raised when Document validation fails."""


def _didcomm_or_service_discriminant(value, validators):
    """Return the validator to use for the service."""
    if value["type"] == "did-communication" or value["type"] == "IndyAgent":
        yield validators[0]
    else:
        yield validators[1]


class DIDDocument:
    """Representation of DID Document."""

    properties = Properties(extra=ALLOW_EXTRA)

    def __init__(
        self,
        id: str,
        context: List[Any],
        *,
        also_known_as: List[str] = None,
        controller: List[str] = None,
        verification_method: List[VerificationMethod] = None,
        authentication: VerificationRelationship = None,
        assertion_method: VerificationRelationship = None,
        key_agreement: VerificationRelationship = None,
        capability_invocation: VerificationRelationship = None,
        capability_delegation: VerificationRelationship = None,
        service: List[Service] = None,
        **extra
    ):
        """Create DIDDocument."""
        self._id = id
        self._context = context
        self._also_known_as = also_known_as
        self._controller = controller
        self._verification_method = verification_method
        self._authentication = authentication
        self._assertion_method = assertion_method
        self._key_agreement = key_agreement
        self._capability_invocation = capability_invocation
        self._capability_delegation = capability_delegation
        self._service = service
        self.extra = extra

        self._index = {}
        self._index_resources()

    def _index_resources(self):
        """Index resources by ID.

        IDs are not guaranteed to be unique within the document.
        The first instance is stored in the index and subsequent id collisions
        are checked against the original. If they do not match, an error will
        be thrown.
        """

        def _indexer(item):
            if not item:
                # Attribute isn't set
                return
            if isinstance(item, DIDUrl):
                # We don't index references
                return
            if isinstance(item, list):
                for subitem in item:
                    _indexer(subitem)
                return
            if isinstance(item, VerificationRelationship):
                for subitem in item.items:
                    _indexer(subitem)
                return

            assert isinstance(item, (VerificationMethod, Service))
            if item.id in self._index and item != self._index[item.id]:
                raise IdentifiedResourceMismatch(
                    "ID {} already found in Index and Items do not match".format(
                        item.id
                    )
                )

            self._index[item.id] = item

        for item in (
            self.verification_method,
            self.authentication,
            self.assertion_method,
            self.key_agreement,
            self.capability_invocation,
            self.capability_delegation,
            self.service,
        ):
            _indexer(item)

    @property
    @properties.add(
        data_key="@context",
        required=True,
        validate=Switch(Url(), [Url()], dict, [dict]),
        serialize=unwrap_if_list_of_one,
        deserialize=single_to_list,
    )
    def context(self):
        """Return context."""
        return self._context

    @property
    @properties.add(
        required=True,
        validate=All(str, DID.validate),
        serialize=str,
        deserialize=str,
    )
    def id(self):
        """Return id."""
        return self._id

    @property
    def did(self):
        """Return the DID representation of id."""
        return DID(self._id)

    @property
    @properties.add(data_key="alsoKnownAs", validate=[str])
    def also_known_as(self):
        """Return also_known_as."""
        return self._also_known_as

    @property
    @properties.add(
        validate=Switch(All(str, DID.validate), [DID.validate]),
        serialize=All([Coerce(str)], unwrap_if_list_of_one),
        deserialize=All(single_to_list, [Coerce(DID)]),
    )
    def controller(self):
        """Return controller."""
        return self._controller

    @property
    @properties.add(
        data_key="verificationMethod",
        validate=[VerificationMethod.validate],
        serialize=[serialize],
        deserialize=[VerificationMethod.deserialize],
    )
    def verification_method(self):
        """Return verification_method."""
        return self._verification_method

    @property
    @properties.add(
        validate=VerificationRelationship.validate,
        serialize=serialize,
        deserialize=VerificationRelationship.deserialize,
    )
    def authentication(self):
        """Return authentication."""
        return self._authentication

    @property
    @properties.add(
        data_key="assertionMethod",
        validate=VerificationRelationship.validate,
        serialize=serialize,
        deserialize=VerificationRelationship.deserialize,
    )
    def assertion_method(self):
        """Return assertion_method."""
        return self._assertion_method

    @property
    @properties.add(
        data_key="keyAgreement",
        validate=VerificationRelationship.validate,
        serialize=serialize,
        deserialize=VerificationRelationship.deserialize,
    )
    def key_agreement(self):
        """Return key_agreement."""
        return self._key_agreement

    @property
    @properties.add(
        data_key="capabilityInvocation",
        validate=VerificationRelationship.validate,
        serialize=serialize,
        deserialize=VerificationRelationship.deserialize,
    )
    def capability_invocation(self):
        """Return capability_invocation."""
        return self._capability_invocation

    @property
    @properties.add(
        data_key="capabilityDelegation",
        validate=VerificationRelationship.validate,
        serialize=serialize,
        deserialize=VerificationRelationship.deserialize,
    )
    def capability_delegation(self):
        """Return capability_delegation."""
        return self._capability_delegation

    @property
    @properties.add(
        validate=[Service.validate],
        serialize=[serialize],
        deserialize=[
            Switch(
                DIDCommService.deserialize,
                Service.deserialize,
                discriminant=_didcomm_or_service_discriminant,
            )
        ],
    )
    def service(self):
        """Return service."""
        return self._service

    def dereference(self, reference: Union[str, DIDUrl]):
        """Dereference a DID URL to a document resource."""
        if isinstance(reference, str):
            reference = DIDUrl.parse(reference)

        if reference not in self._index:
            raise ResourceIDNotFound("ID {} not found in document".format(reference))
        return self._index[reference]

    @classmethod
    @wrap_validation_error(
        DIDDocumentValidationError, message="Failed to validate DID Document"
    )
    def validate(cls, value):
        """Validate against expected schema."""
        return cls.properties.validate(value)

    @wrap_validation_error(DIDDocumentError, message="Failed to serialize DID Document")
    def serialize(self):
        """Serialize DID Document."""
        value = self.properties.serialize(self)
        return {**value, **self.extra}

    @classmethod
    @wrap_validation_error(
        DIDDocumentValidationError, message="Failed to deserialize DID Document"
    )
    def deserialize(cls, value: dict, options: Set[Option] = None):
        """Deserialize DID Document."""
        if options:
            value = DIDDocumentOption.apply(value, options)
        value = cls.validate(value)
        value = cls.properties.deserialize(value)
        return cls(**value)

    @classmethod
    @wrap_validation_error(
        DIDDocumentValidationError, message="Failed to deserialize DID Document"
    )
    def from_json(cls, value: str, options: Set[Option] = None):
        """Deserialize DID Document from JSON."""
        doc_raw: dict = json.loads(value)
        return cls.deserialize(doc_raw, options)

    def to_json(self):
        """Serialize DID Document to JSON."""
        return json.dumps(self.serialize())
