using System;

using System.Threading.Tasks;

using System.Security.Cryptography.X509Certificates;

using DotPulsar;

using DotPulsar.Extensions;

​

namespace TestPulsar

{

    internal class MySimpleConsumer

    {

        private static async Task Main(string[] args)

        {

            var certStr = "MIIFiTCCA3GgAwIBAgIUJHlzNS+X19lE2FuzflPH+JtPiFswDQYJKoZIhvcNAQEL\n" + "BQAwTDELMAkGA1UEBhMCVVMxETAPBgNVBAgMCE1pY2hpZ2FuMQ8wDQYDVQQHDAZX\n" + "YXJyZW4xCzAJBgNVBAoMAkdNMQwwCgYDVQQLDANFVFMwHhcNMjEwMjA5MTE0MjQw\n" + "WhcNNDEwMjA0MTE0MjQwWjBMMQswCQYDVQQGEwJVUzERMA8GA1UECAwITWljaGln\n" + "YW4xDzANBgNVBAcMBldhcnJlbjELMAkGA1UECgwCR00xDDAKBgNVBAsMA0VUUzCC\n" + "AiIwDQYJKoZIhvcNAQEBBQADggIPADCCAgoCggIBALk8gdWBbCg9j8Zl/r0Oh+p1\n" + "jXlES35BgDe7PS8uZkDI3/aS0RIBrpPGmqwKMFLZBWgmrfvfu1yzdd8CUcggg1XP\n" + "rekSBmxaBvAy1mtetvTj0PBCsJ4oshawwrBOJDpZOsLYpgy12nrngqF7a9Io4vWH\n" + "pZHEPU11hMmVXB5CB6R0uDLqsDsIQO7Tao7JgyF0//J5Pxde+uSWIn2d+9NeP+TF\n" + "Pcz2UxjJSCEuth17QhryVaos6FRuYbhdLOdw8ydxyoDRaLo84yaBBkIPsUF7JVeG\n" + "Kf5y6KJmwD07fMzO7+9H2N0tLyW+mLHBfO58Ri9xltRbmKwODko3qP3BIaLnDqBu\n" + "Jjh1InBH3Wkk3rc+onvHJjAePhOSTXI7GWPKehsMXtw055q2Bk/SXupIDC/cYQTN\n" + "mIn0tqJeQrptVFZKmrXQHRmG8q1eqsac7UZ3mwIH62DWYkxl/w460APwy3V88OMW\n" + "lJOY88kknDVaN7h8qENbTpPslBDeEtilQv7ZmgzM5P/3oAdaMp1wzvqv7InSmh5a\n" + "mov8ubA0J32GK/lL33mbig/lslThaYAP+tRcTPZINuGfkDm7TwZ7T8QRoAkVLLy+\n" + "Jk9zOQ2SAkUDSauOcqOgvGg66k/XlZBs6M3eoYyaRPjHVpmIXGPlMRvyq/tV8eyg\n" + "NRb0xrXqcv/RNKunkmu3AgMBAAGjYzBhMB0GA1UdDgQWBBQ6pmL18/T+1/J2eP2H\n" + "ck2coKR+/jAfBgNVHSMEGDAWgBQ6pmL18/T+1/J2eP2Hck2coKR+/jAPBgNVHRMB\n" + "Af8EBTADAQH/MA4GA1UdDwEB/wQEAwIBhjANBgkqhkiG9w0BAQsFAAOCAgEAm5Dr\n" + "fEoEKVTPaSa7JhHHEVz7BDKnO/5+aNHrjNlT2me/090LwmZbXrBse2WEs0s3sgaC\n" + "qbHCtMBLALdhs2TM5StJrU3Sn8VV1MDljC5UO03duO9NvMnRSkt2Njm+cXyXFPON\n" + "4NOD5HhWPB2M1cmswQourcL4O89QwfyePfSmf+hfxd9g4WZx7nSPB1nOJewX/S5t\n" + "KZDxgg0sBzY/fJeobRJ9XlVgxVSWTAo0WLK+8ldKqltVFAkYAFqhpt7NEoksKLoK\n" + "ZU1FOxuyY+Jzx1yp/Meudlos4Y+5UPJZ9NUNDC6Ie17H2vzkjCjZzYBLG1m+L7vd\n" + "zLP+AmYA8AJixmuDK/fz6oZkoyTxibT7m6XTpv92eeQts9tiJgY6AocPXcaq+sEi\n" + "8gAIeZe2kr8ROChskQzx49c4iUYRD+8ncX/tQGkVZQ6ZAx4rWUhZqu+DyWbXJEJT\n" + "FQzDkIAJqbAv/OQOpjsjh1tNFxjbn3ddA/Pd07gFW904Vcbe7EaE7gW5QV6EBFPf\n" + "XEUVvPb5K56gO2oK2guHoDBHgGqthN9FaIsqU3eiKchdg2lOlIdSMQjrr5LwF3cu\n" + "VuEFDOetyQ8JYKDfJmuxWkGSdlQRYO4EKEcNKDmIwN7tQwTaHvciMhkVPI6HfXjH\n" + "2g03wOFzx25pGhSDS1qqBc+d+M40KkjK7rPK5QM=";

            var cert = new X509Certificate2(Convert.FromBase64String(certStr));

            const string serviceUrl = "pulsar+ssl://eaimxtprxy-dv.dev.gm.com:16651";

            const string subscriptionName = "162609-CVC-CBPS-VERISK-EXT-SUB";

            var topicName = "persistent://162609-CVC/CBPS-NA-CG1/VERISK_ENROLLMENT";

            //var pulsarToken = "test:test1";

            var pulsarToken = "53066549-85d9-4324-9a32-7bbcc008bde5:Zaa8Q~LN7_10F7SnrWXv--6vmmqwsBwePHV3PddW";

​

            await using var client = PulsarClient.Builder().ServiceUrl(new System.Uri(serviceUrl)).Authentication(AuthenticationFactory.Token(pulsarToken)).TrustedCertificateAuthority(cert).Build();

            await using var consumer = client.NewConsumer(Schema.String).Topic(topicName).SubscriptionName(subscriptionName).Create();

            await foreach (var message in consumer.Messages())

            {

                Console.WriteLine($"Received: {message.Value()}");

                //await consumer.Acknowledge(message);

            }

        }

    }

}