#
# This file is part of pyasn1-modules software.
#
# Copyright (c) 2005-2020, Ilya Etingof <etingof@gmail.com>
# License: https://www.pysnmp.com/pyasn1/license.html
#
import sys
import unittest

from pyasn1.codec.der import decoder as der_decoder
from pyasn1.codec.der import encoder as der_encoder
from pyasn1.type import char, namedtype, univ

from pyasn1_modules import pem, rfc5652, rfc6402


class ContentInfoTestCase(unittest.TestCase):
    pem_text = """\
MIIEJQYJKoZIhvcNAQcCoIIEFjCCBBICAQMxCzAJBgUrDgMCGgUAMIIDAgYIKwYBBQUHDAKgggL0
BIIC8DCCAuwweDB2AgECBgorBgEEAYI3CgoBMWUwYwIBADADAgEBMVkwVwYJKwYBBAGCNxUUMUow
SAIBBQwZcGl0dWNoYTEuZW1lYS5ocHFjb3JwLm5ldAwMRU1FQVxwaXR1Y2hhDBpDTUNSZXFHZW5l
cmF0b3IudnNob3N0LmV4ZTCCAmqgggJmAgEBMIICXzCCAcgCAQAwADCBnzANBgkqhkiG9w0BAQEF
AAOBjQAwgYkCgYEA0jm7SSSm2wyEAzuNKtFZFJKo91SrJq9wQwEhEKHDavZwMQOm1rZ2PF8NWCEb
PqrhToQ7rtiGLSZa4dF4bzgmBqQ9aoSfEX4jISt31Vy+skHidXjHHpbsjT24NPhrZgANivL7CxD6
Ft+s7qS1gL4HRm2twQkqSwOLrE/q2QeXl2UCAwEAAaCCAR0wGgYKKwYBBAGCNw0CAzEMFgo2LjIu
OTIwMC4yMD4GCSqGSIb3DQEJDjExMC8wHQYDVR0OBBYEFMW2skn88gxhONWZQA4sWGBDb68yMA4G
A1UdDwEB/wQEAwIHgDBXBgkrBgEEAYI3FRQxSjBIAgEFDBlwaXR1Y2hhMS5lbWVhLmhwcWNvcnAu
bmV0DAxFTUVBXHBpdHVjaGEMGkNNQ1JlcUdlbmVyYXRvci52c2hvc3QuZXhlMGYGCisGAQQBgjcN
AgIxWDBWAgECHk4ATQBpAGMAcgBvAHMAbwBmAHQAIABTAHQAcgBvAG4AZwAgAEMAcgB5AHAAdABv
AGcAcgBhAHAAaABpAGMAIABQAHIAbwB2AGkAZABlAHIDAQAwDQYJKoZIhvcNAQEFBQADgYEAJZlu
mxjtCxSOQi27jsVdd3y8NSIlzNv0b3LqmzvAly6L+CstXcnuG2MPQqPH9R7tbJonGUniBQO9sQ7C
KhYWj2gfhiEkSID82lV5chINVUFKoUlSiEhWr0tPGgvOaqdsKQcrHfzrsBbFkhDqrFSVy7Yivbnh
qYszKrOjJKiiCPMwADAAMYH5MIH2AgEDgBTFtrJJ/PIMYTjVmUAOLFhgQ2+vMjAJBgUrDgMCGgUA
oD4wFwYJKoZIhvcNAQkDMQoGCCsGAQUFBwwCMCMGCSqGSIb3DQEJBDEWBBTFTkK/OifaFjwqHiJu
xM7qXcg/VzANBgkqhkiG9w0BAQEFAASBgKfC6jOi1Wgy4xxDCQVK9+e5tktL8wE/j2cb9JSqq+aU
5UxEgXEw7q7BoYZCAzcxMRriGzakXr8aXHcgkRJ7XcFvLPUjpmGg9SOZ2sGW4zQdWAwImN/i8loc
xicQmJP+VoMHo/ZpjFY9fYCjNZUArgKsEwK/s+p9yrVVeB1Nf8Mn
"""

    def setUp(self):
        self.asn1Spec = rfc5652.ContentInfo()

    def testDerCodec(self):

        substrate = pem.readBase64fromText(self.pem_text)

        layers = {
            rfc5652.id_ct_contentInfo: rfc5652.ContentInfo(),
            rfc5652.id_signedData: rfc5652.SignedData(),
            rfc6402.id_cct_PKIData: rfc6402.PKIData(),
        }

        getNextLayer = {
            rfc5652.id_ct_contentInfo: lambda x: x["contentType"],
            rfc5652.id_signedData: lambda x: x["encapContentInfo"]["eContentType"],
            rfc6402.id_cct_PKIData: lambda x: None,
        }

        getNextSubstrate = {
            rfc5652.id_ct_contentInfo: lambda x: x["content"],
            rfc5652.id_signedData: lambda x: x["encapContentInfo"]["eContent"],
            rfc6402.id_cct_PKIData: lambda x: None,
        }

        next_layer = rfc5652.id_ct_contentInfo

        while next_layer:

            asn1Object, rest = der_decoder.decode(
                substrate, asn1Spec=layers[next_layer]
            )

            self.assertFalse(rest)
            self.assertTrue(asn1Object.prettyPrint())
            self.assertEqual(substrate, der_encoder.encode(asn1Object))

            substrate = getNextSubstrate[next_layer](asn1Object)
            next_layer = getNextLayer[next_layer](asn1Object)

    def testOpenTypes(self):
        class ClientInformation(univ.Sequence):
            pass

        ClientInformation.componentType = namedtype.NamedTypes(
            namedtype.NamedType("clientId", univ.Integer()),
            namedtype.NamedType("MachineName", char.UTF8String()),
            namedtype.NamedType("UserName", char.UTF8String()),
            namedtype.NamedType("ProcessName", char.UTF8String()),
        )

        class EnrollmentCSP(univ.Sequence):
            pass

        EnrollmentCSP.componentType = namedtype.NamedTypes(
            namedtype.NamedType("KeySpec", univ.Integer()),
            namedtype.NamedType("Name", char.BMPString()),
            namedtype.NamedType("Signature", univ.BitString()),
        )

        openTypeMap = {
            # attributes
            univ.ObjectIdentifier("1.3.6.1.4.1.311.13.2.3"): char.IA5String(),
            univ.ObjectIdentifier("1.3.6.1.4.1.311.13.2.2"): EnrollmentCSP(),
            univ.ObjectIdentifier("1.3.6.1.4.1.311.21.20"): ClientInformation(),
            # algorithm identifier parameters
            univ.ObjectIdentifier("1.2.840.113549.1.1.1"): univ.Null(""),
            univ.ObjectIdentifier("1.2.840.113549.1.1.5"): univ.Null(""),
            univ.ObjectIdentifier("1.2.840.113549.1.1.11"): univ.Null(""),
        }

        openTypeMap.update(rfc5652.cmsAttributesMap)
        openTypeMap.update(rfc6402.cmcControlAttributesMap)

        substrate = pem.readBase64fromText(self.pem_text)
        asn1Object, rest = der_decoder.decode(
            substrate, asn1Spec=rfc5652.ContentInfo(), decodeOpenTypes=True
        )
        self.assertFalse(rest)
        self.assertTrue(asn1Object.prettyPrint())
        self.assertEqual(substrate, der_encoder.encode(asn1Object))

        eci = asn1Object["content"]["encapContentInfo"]

        self.assertIn(eci["eContentType"], rfc5652.cmsContentTypesMap)
        self.assertEqual(rfc6402.id_cct_PKIData, eci["eContentType"])

        pkid, rest = der_decoder.decode(
            eci["eContent"],
            asn1Spec=rfc5652.cmsContentTypesMap[eci["eContentType"]],
            openTypes=openTypeMap,
            decodeOpenTypes=True,
        )

        self.assertFalse(rest)
        self.assertTrue(pkid.prettyPrint())
        self.assertEqual(eci["eContent"], der_encoder.encode(pkid))

        for req in pkid["reqSequence"]:
            cr = req["tcr"]["certificationRequest"]

            sig_alg = cr["signatureAlgorithm"]

            self.assertIn(sig_alg["algorithm"], openTypeMap)
            self.assertEqual(univ.Null(""), sig_alg["parameters"])

            cri = cr["certificationRequestInfo"]
            spki_alg = cri["subjectPublicKeyInfo"]["algorithm"]

            self.assertIn(spki_alg["algorithm"], openTypeMap)
            self.assertEqual(univ.Null(""), spki_alg["parameters"])

            attrs = cr["certificationRequestInfo"]["attributes"]

            for attr in attrs:
                self.assertIn(attr["attrType"], openTypeMap)

                if attr["attrType"] == univ.ObjectIdentifier("1.3.6.1.4.1.311.13.2.3"):
                    self.assertEqual("6.2.9200.2", attr["attrValues"][0])

                else:
                    self.assertTrue(attr["attrValues"][0].hasValue())


suite = unittest.TestLoader().loadTestsFromModule(sys.modules[__name__])

if __name__ == "__main__":
    result = unittest.TextTestRunner(verbosity=2).run(suite)
    sys.exit(not result.wasSuccessful())