From bd46f804010ff7bd6234ec02a7ef16ebf08b7522 Mon Sep 17 00:00:00 2001
From: Sipke Schoorstra <sipkeschoorstra@outlook.com>
Date: Tue, 6 Oct 2020 15:13:02 +0200
Subject: [PATCH] Remove DocumentDB provider

---
 .../DocumentDbStorage.cs                      |  57 -----
 .../DocumentDbStorageOptions.cs               |  62 ------
 .../WorkflowDefinitionVersionDocument.cs      |  44 ----
 .../Documents/WorkflowInstanceDocument.cs     |  61 ------
 .../Elsa.Persistence.DocumentDb.csproj        |  36 ---
 .../Extensions/ElsaOptionsExtensions.cs       |  48 ----
 .../WorkflowDefinitionDocumentExtensions.cs   |  31 ---
 .../Helpers/ClientHelper.cs                   | 205 ------------------
 .../Helpers/QueryHelper.cs                    |  24 --
 .../Helpers/TimeHelper.cs                     |  26 ---
 .../Mapping/DocumentProfile.cs                |  15 --
 .../CosmosDbWorkflowDefinitionStore.cs        | 114 ----------
 .../Services/CosmosDbWorkflowInstanceStore.cs | 173 ---------------
 .../Elsa.Persistence.DocumentDb/icon.png      | Bin 16374 -> 0 bytes
 14 files changed, 896 deletions(-)
 delete mode 100644 src/providers/Elsa.Persistence.DocumentDb/DocumentDbStorage.cs
 delete mode 100644 src/providers/Elsa.Persistence.DocumentDb/DocumentDbStorageOptions.cs
 delete mode 100644 src/providers/Elsa.Persistence.DocumentDb/Documents/WorkflowDefinitionVersionDocument.cs
 delete mode 100644 src/providers/Elsa.Persistence.DocumentDb/Documents/WorkflowInstanceDocument.cs
 delete mode 100644 src/providers/Elsa.Persistence.DocumentDb/Elsa.Persistence.DocumentDb.csproj
 delete mode 100644 src/providers/Elsa.Persistence.DocumentDb/Extensions/ElsaOptionsExtensions.cs
 delete mode 100644 src/providers/Elsa.Persistence.DocumentDb/Extensions/WorkflowDefinitionDocumentExtensions.cs
 delete mode 100644 src/providers/Elsa.Persistence.DocumentDb/Helpers/ClientHelper.cs
 delete mode 100644 src/providers/Elsa.Persistence.DocumentDb/Helpers/QueryHelper.cs
 delete mode 100644 src/providers/Elsa.Persistence.DocumentDb/Helpers/TimeHelper.cs
 delete mode 100644 src/providers/Elsa.Persistence.DocumentDb/Mapping/DocumentProfile.cs
 delete mode 100644 src/providers/Elsa.Persistence.DocumentDb/Services/CosmosDbWorkflowDefinitionStore.cs
 delete mode 100644 src/providers/Elsa.Persistence.DocumentDb/Services/CosmosDbWorkflowInstanceStore.cs
 delete mode 100644 src/providers/Elsa.Persistence.DocumentDb/icon.png

diff --git a/src/providers/Elsa.Persistence.DocumentDb/DocumentDbStorage.cs b/src/providers/Elsa.Persistence.DocumentDb/DocumentDbStorage.cs
deleted file mode 100644
index 3da860753..000000000
--- a/src/providers/Elsa.Persistence.DocumentDb/DocumentDbStorage.cs
+++ /dev/null
@@ -1,57 +0,0 @@
-using Microsoft.Azure.Documents;
-using Microsoft.Azure.Documents.Client;
-using Newtonsoft.Json;
-using Newtonsoft.Json.Serialization;
-using System;
-using System.Threading;
-using System.Threading.Tasks;
-
-namespace Elsa.Persistence.DocumentDb
-{
-    public class DocumentDbStorage
-    {
-        private DocumentDbStorageOptions Options { get; }
-        internal DocumentClient Client { get; }
-
-        public DocumentDbStorage(DocumentDbStorageOptions options)
-        {
-            Options = options;
-
-            var settings = new JsonSerializerSettings
-            {
-                NullValueHandling = NullValueHandling.Ignore,
-                DateTimeZoneHandling = DateTimeZoneHandling.Utc,
-                ContractResolver = new CamelCasePropertyNamesContractResolver
-                {
-                    NamingStrategy = new CamelCaseNamingStrategy(false, false)
-                }
-            };
-
-            var connectionPolicy = ConnectionPolicy.Default;
-            connectionPolicy.ConnectionMode = Options.ConnectionMode;
-            connectionPolicy.ConnectionProtocol = Options.ConnectionProtocol;
-            connectionPolicy.RequestTimeout = Options.RequestTimeout;
-            connectionPolicy.RetryOptions = new RetryOptions
-            {
-                MaxRetryWaitTimeInSeconds = 10,
-                MaxRetryAttemptsOnThrottledRequests = 5
-            };
-
-            Client = new DocumentClient(options.Url, options.Secret, settings, connectionPolicy);
-        }
-
-        public override string ToString() => $"DocumentDb Database: {Options.DatabaseName}";
-
-        public async Task<Uri> GetCollectionAsync(string collectionName, CancellationToken cancellationToken = default)
-        {
-            var database = await Client.CreateDatabaseIfNotExistsAsync(new Database { Id = Options.DatabaseName });
-            var databaseUri = UriFactory.CreateDatabaseUri(database.Resource.Id);
-            
-            var collection = await Client.CreateDocumentCollectionIfNotExistsAsync(
-                databaseUri,
-                new DocumentCollection { Id = collectionName });
-
-            return UriFactory.CreateDocumentCollectionUri(Options.DatabaseName, collection.Resource.Id);
-        }
-    }
-}
\ No newline at end of file
diff --git a/src/providers/Elsa.Persistence.DocumentDb/DocumentDbStorageOptions.cs b/src/providers/Elsa.Persistence.DocumentDb/DocumentDbStorageOptions.cs
deleted file mode 100644
index f67fa5019..000000000
--- a/src/providers/Elsa.Persistence.DocumentDb/DocumentDbStorageOptions.cs
+++ /dev/null
@@ -1,62 +0,0 @@
-using Microsoft.Azure.Documents.Client;
-using System;
-using System.ComponentModel.DataAnnotations;
-
-namespace Elsa.Persistence.DocumentDb
-{
-    public class DocumentDbStorageOptions
-    {
-        [Required]
-        public Uri Url { get; set; }
-        
-        [Required]
-        public string Secret { get; set; }
-        
-        [Required]
-        public string DatabaseName { get; set; }
-
-        /// <summary>
-        /// Get or sets the request timeout for DocumentDB client. Default value set to 30 seconds
-        /// </summary>
-        public TimeSpan RequestTimeout { get; set; }
-
-        /// <summary>
-        /// Get or set the interval timespan to process expired entries. Default value 15 minutes
-        /// Expired items under "locks", "jobs", "lists", "sets", "hashs", "counters/aggregated" will be checked 
-        /// </summary>
-        public TimeSpan ExpirationCheckInterval { get; set; }
-
-        /// <summary>
-        /// Get or sets the interval timespan to aggregated the counters. Default value 1 minute
-        /// </summary>
-        public TimeSpan CountersAggregateInterval { get; set; }
-
-        /// <summary>
-        /// Gets or sets the interval timespan to poll the queue for processing any new jobs. Default value 2 minutes
-        /// </summary>
-        public TimeSpan QueuePollInterval { get; set; }
-
-        /// <summary>
-        /// Gets or sets the connection mode for the DocumentDB client. Default value is Direct.
-        /// </summary>
-        public ConnectionMode ConnectionMode { get; set; }
-
-        /// <summary>
-        /// Gets or sets the connection protocol for the DocumentDB client. Default value is TCP.
-        /// </summary>
-        public Protocol ConnectionProtocol { get; set; }
-
-        /// <summary>
-        /// Create an instance of AzureDocumentDB Storage option with default values
-        /// </summary>
-        public DocumentDbStorageOptions()
-        {
-            RequestTimeout = TimeSpan.FromSeconds(30);
-            ExpirationCheckInterval = TimeSpan.FromMinutes(2);
-            CountersAggregateInterval = TimeSpan.FromMinutes(2);
-            QueuePollInterval = TimeSpan.FromSeconds(15);
-            ConnectionMode = ConnectionMode.Direct;
-            ConnectionProtocol = Protocol.Tcp;
-        }
-    }
-}
diff --git a/src/providers/Elsa.Persistence.DocumentDb/Documents/WorkflowDefinitionVersionDocument.cs b/src/providers/Elsa.Persistence.DocumentDb/Documents/WorkflowDefinitionVersionDocument.cs
deleted file mode 100644
index ef1ce0274..000000000
--- a/src/providers/Elsa.Persistence.DocumentDb/Documents/WorkflowDefinitionVersionDocument.cs
+++ /dev/null
@@ -1,44 +0,0 @@
-using Elsa.Models;
-using Newtonsoft.Json;
-using System.Collections.Generic;
-
-namespace Elsa.Persistence.DocumentDb.Documents
-{
-    public class WorkflowDefinitionVersionDocument
-    {
-        [JsonProperty(PropertyName = "id")] public string Id { get; set; }
-        [JsonProperty(PropertyName = "type")] public string Type { get; } = nameof(WorkflowDefinitionVersionDocument);
-
-        [JsonProperty(PropertyName = "definitionId")]
-        public string DefinitionId { get; set; }
-
-        [JsonProperty(PropertyName = "version")]
-        public int Version { get; set; }
-
-        [JsonProperty(PropertyName = "name")] public string Name { get; set; }
-
-        [JsonProperty(PropertyName = "description")]
-        public string Description { get; set; }
-
-        [JsonProperty(PropertyName = "activities")]
-        public IList<ActivityDefinition> Activities { get; set; }
-
-        [JsonProperty(PropertyName = "connections")]
-        public IList<ConnectionDefinition> Connections { get; set; }
-
-        [JsonProperty(PropertyName = "variables")]
-        public Variables Variables { get; set; }
-
-        [JsonProperty(PropertyName = "isSingleton")]
-        public bool IsSingleton { get; set; }
-
-        [JsonProperty(PropertyName = "isDisabled")]
-        public bool IsDisabled { get; set; }
-
-        [JsonProperty(PropertyName = "isPublished")]
-        public bool IsPublished { get; set; }
-
-        [JsonProperty(PropertyName = "isLatest")]
-        public bool IsLatest { get; set; }
-    }
-}
\ No newline at end of file
diff --git a/src/providers/Elsa.Persistence.DocumentDb/Documents/WorkflowInstanceDocument.cs b/src/providers/Elsa.Persistence.DocumentDb/Documents/WorkflowInstanceDocument.cs
deleted file mode 100644
index c785c6b38..000000000
--- a/src/providers/Elsa.Persistence.DocumentDb/Documents/WorkflowInstanceDocument.cs
+++ /dev/null
@@ -1,61 +0,0 @@
-using Elsa.Models;
-using Newtonsoft.Json;
-using System;
-using System.Collections.Generic;
-
-namespace Elsa.Persistence.DocumentDb.Documents
-{
-    public class WorkflowInstanceDocument
-    {
-        [JsonProperty(PropertyName = "id")] public string Id { get; set; }
-
-        [JsonProperty(PropertyName = "definitionId")]
-        public string DefinitionId { get; set; }
-
-        [JsonProperty(PropertyName = "type")] public string Type { get; } = nameof(WorkflowInstanceDocument);
-
-        [JsonProperty(PropertyName = "version")]
-        public int Version { get; set; }
-
-        [JsonProperty(PropertyName = "status")]
-        public WorkflowStatus Status { get; set; }
-
-        [JsonProperty(PropertyName = "correlationId")]
-        public string CorrelationId { get; set; }
-
-        [JsonProperty(PropertyName = "createdAt")]
-        public DateTime CreatedAt { get; set; }
-
-        [JsonProperty(PropertyName = "startedAt")]
-        public DateTime? StartedAt { get; set; }
-
-        [JsonProperty(PropertyName = "finishedAt")]
-        public DateTime? FinishedAt { get; set; }
-
-        [JsonProperty(PropertyName = "faultedAt")]
-        public DateTime? FaultedAt { get; set; }
-
-        [JsonProperty(PropertyName = "abortedAt")]
-        public DateTime? AbortedAt { get; set; }
-
-        [JsonProperty(PropertyName = "activities")]
-        public IDictionary<string, ActivityInstance> Activities { get; set; } = new Dictionary<string, ActivityInstance>();
-
-        [JsonProperty(PropertyName = "variables")]
-        public Variables Variables { get; set; }
-
-        [JsonProperty(PropertyName = "input")] public Variable? Input { get; set; }
-        [JsonProperty(PropertyName = "input")] public Variable? Output { get; set; }
-
-        [JsonProperty(PropertyName = "blockingActivities")]
-        public HashSet<BlockingActivity> BlockingActivities { get; set; }
-
-        [JsonProperty(PropertyName = "scheduledActivities")]
-        public Stack<string> ScheduledActivities { get; set; }
-
-        [JsonProperty(PropertyName = "executionLog")]
-        public ICollection<ExecutionLogEntry> ExecutionLog { get; set; }
-
-        [JsonProperty(PropertyName = "fault")] public WorkflowFault Fault { get; set; }
-    }
-}
\ No newline at end of file
diff --git a/src/providers/Elsa.Persistence.DocumentDb/Elsa.Persistence.DocumentDb.csproj b/src/providers/Elsa.Persistence.DocumentDb/Elsa.Persistence.DocumentDb.csproj
deleted file mode 100644
index 4f603ca45..000000000
--- a/src/providers/Elsa.Persistence.DocumentDb/Elsa.Persistence.DocumentDb.csproj
+++ /dev/null
@@ -1,36 +0,0 @@
-<Project Sdk="Microsoft.NET.Sdk">
-
-    <PropertyGroup>
-        <TargetFramework>netstandard2.0</TargetFramework>
-        <LangVersion>8.0</LangVersion>
-        <PackageVersion>1.0.0</PackageVersion>
-        <Authors>Elsa Contributors</Authors>
-        <Description>
-            Elsa is a set of workflow libraries and tools that enable super-fast workflowing capabilities in any .NET Core application.
-            This package provides a CosmosDb persistence provider.
-        </Description>
-        <Copyright>2019</Copyright>
-        <PackageProjectUrl>https://github.com/elsa-workflows/elsa-core</PackageProjectUrl>
-        <RepositoryUrl>https://github.com/elsa-workflows/elsa-core</RepositoryUrl>
-        <RepositoryType>GitHub</RepositoryType>
-        <PackageTags>elsa, workflows, cosmosdb</PackageTags>
-        <PackageIcon>icon.png</PackageIcon>
-        <Nullable>enable</Nullable>
-    </PropertyGroup>
-
-    <ItemGroup>
-        <None Include="icon.png">
-            <Pack>True</Pack>
-            <PackagePath />
-        </None>
-    </ItemGroup>
-
-    <ItemGroup>
-        <PackageReference Include="Microsoft.Azure.DocumentDB.Core" Version="2.11.6" />
-    </ItemGroup>
-
-    <ItemGroup>
-        <ProjectReference Include="..\..\core\Elsa.Core\Elsa.Core.csproj" />
-    </ItemGroup>
-
-</Project>
diff --git a/src/providers/Elsa.Persistence.DocumentDb/Extensions/ElsaOptionsExtensions.cs b/src/providers/Elsa.Persistence.DocumentDb/Extensions/ElsaOptionsExtensions.cs
deleted file mode 100644
index 30c61b90e..000000000
--- a/src/providers/Elsa.Persistence.DocumentDb/Extensions/ElsaOptionsExtensions.cs
+++ /dev/null
@@ -1,48 +0,0 @@
-using Elsa.Persistence.DocumentDb.Services;
-using Elsa.Extensions;
-using Elsa.Mapping;
-using Elsa.Persistence.DocumentDb.Mapping;
-using Microsoft.Extensions.DependencyInjection;
-
-namespace Elsa.Persistence.DocumentDb.Extensions
-{
-    public static class ElsaOptionsExtensions
-    {
-        public static ElsaOptions UseCosmosDbWorkflowDefinitionStore(this ElsaOptions options, DocumentDbStorageOptions dbOptions)
-        {
-            options
-                .AddCosmosDbProvider(dbOptions)
-                .UseWorkflowDefinitionStore(sp => sp.GetRequiredService<CosmosDbWorkflowDefinitionStore>());
-            
-            options.Services.AddSingleton<CosmosDbWorkflowDefinitionStore>();
-            return options;
-        }
-        
-        public static ElsaOptions UseCosmosDbWorkflowInstanceStore(this ElsaOptions options, DocumentDbStorageOptions dbOptions)
-        {
-            options
-                .AddCosmosDbProvider(dbOptions)
-                .UseWorkflowInstanceStore(sp => sp.GetRequiredService<CosmosDbWorkflowInstanceStore>());
-            
-            options.Services.AddSingleton<IWorkflowInstanceStore, CosmosDbWorkflowInstanceStore>();
-            return options;
-        }
-
-        private static ElsaOptions AddCosmosDbProvider(
-            this ElsaOptions options,
-            DocumentDbStorageOptions documentDbOptions)
-        {
-            if (options.HasService<DocumentDbStorage>())
-                return options;
-            
-            var storage = new DocumentDbStorage(documentDbOptions);
-
-            options.Services
-                .AddSingleton(storage)
-                .AddAutoMapperProfile<NodaTimeProfile>(ServiceLifetime.Singleton)
-                .AddAutoMapperProfile<DocumentProfile>(ServiceLifetime.Singleton);
-
-            return options;
-        }
-    }
-}
\ No newline at end of file
diff --git a/src/providers/Elsa.Persistence.DocumentDb/Extensions/WorkflowDefinitionDocumentExtensions.cs b/src/providers/Elsa.Persistence.DocumentDb/Extensions/WorkflowDefinitionDocumentExtensions.cs
deleted file mode 100644
index ab04569a2..000000000
--- a/src/providers/Elsa.Persistence.DocumentDb/Extensions/WorkflowDefinitionDocumentExtensions.cs
+++ /dev/null
@@ -1,31 +0,0 @@
-using Elsa.Models;
-using Elsa.Persistence.DocumentDb.Documents;
-using System.Linq;
-
-namespace Elsa.Persistence.DocumentDb.Extensions
-{
-    public static class WorkflowDefinitionDocumentExtensions
-    {
-        public static IQueryable<WorkflowDefinitionVersionDocument> WithVersion(
-            this IQueryable<WorkflowDefinitionVersionDocument> query,
-            VersionOptions version)
-        {
-            if (version.IsDraft)
-                query = query.Where(x => !x.IsPublished);
-            else if (version.IsLatest)
-                query = query.Where(x => x.IsLatest);
-            else if (version.IsPublished)
-                query = query.Where(x => x.IsPublished);
-            else if (version.IsLatestOrPublished)
-                query = query.Where(x => x.IsPublished || x.IsLatest);
-            else if (version.AllVersions)
-            {
-                // Nothing to filter.
-            }
-            else if (version.Version > 0)
-                query = query.Where(x => x.Version == version.Version);
-
-            return query.OrderByDescending(x => x.Version);
-        }
-    }
-}
\ No newline at end of file
diff --git a/src/providers/Elsa.Persistence.DocumentDb/Helpers/ClientHelper.cs b/src/providers/Elsa.Persistence.DocumentDb/Helpers/ClientHelper.cs
deleted file mode 100644
index 092a7d63d..000000000
--- a/src/providers/Elsa.Persistence.DocumentDb/Helpers/ClientHelper.cs
+++ /dev/null
@@ -1,205 +0,0 @@
-using Microsoft.Azure.Documents;
-using Microsoft.Azure.Documents.Client;
-using Microsoft.Azure.Documents.Linq;
-using System;
-using System.Threading;
-using System.Threading.Tasks;
-
-namespace Elsa.Persistence.DocumentDb.Helpers
-{
-    internal static class ClientHelper
-    {
-        /// <summary>
-        /// Creates a document as an asynchronous operation in the Azure Cosmos DB service.
-        /// </summary>
-        /// <param name="client"></param>
-        /// <param name="documentCollectionUri">the URI of the document collection to create the document in.</param>
-        /// <param name="document">the document object.</param>
-        /// <param name="options">The request options for the request.</param>
-        /// <param name="disableAutomaticIdGeneration">Disables the automatic id generation, will throw an exception if id is missing.</param>
-        /// <param name="cancellationToken">(Optional) <see cref="T:System.Threading.CancellationToken" /> representing request cancellation.</param>
-        /// <returns></returns>
-        internal static Task<ResourceResponse<Document>> CreateDocumentWithRetriesAsync(
-            this DocumentClient client,
-            Uri documentCollectionUri,
-            object document,
-            RequestOptions options = null,
-            bool disableAutomaticIdGeneration = false,
-            CancellationToken cancellationToken = default)
-        {
-            return Task.Run(
-                async () => await client.ExecuteWithRetries(
-                    () => client.CreateDocumentAsync(
-                        documentCollectionUri,
-                        document,
-                        options,
-                        disableAutomaticIdGeneration,
-                        cancellationToken)),
-                cancellationToken);
-        }
-
-        /// <summary>
-        /// Reads a <see cref="T:Microsoft.Azure.Documents.Document" /> as a generic type T from the Azure Cosmos DB service as an asynchronous operation.
-        /// </summary>
-        /// <typeparam name="T"></typeparam>
-        /// <param name="client"></param>
-        /// <param name="documentUri">A URI to the Document resource to be read.</param>
-        /// <param name="options">The request options for the request.</param>
-        /// <param name="cancellationToken">(Optional) <see cref="T:System.Threading.CancellationToken" /> representing request cancellation.</param>
-        /// <returns></returns>
-        internal static Task<DocumentResponse<T>> ReadDocumentWithRetriesAsync<T>(
-            this DocumentClient client,
-            Uri documentUri,
-            RequestOptions options = null,
-            CancellationToken cancellationToken = default)
-        {
-            return Task.Run(
-                async () => await client.ExecuteWithRetries(
-                    () => client.ReadDocumentAsync<T>(documentUri, options, cancellationToken)),
-                cancellationToken);
-        }
-
-        /// <summary>
-        /// Upserts a document as an asynchronous operation in the Azure Cosmos DB service.
-        /// </summary>
-        /// <param name="client"></param>
-        /// <param name="documentCollectionUri">the URI of the document collection to upsert the document in.</param>
-        /// <param name="document">The document object.</param>
-        /// <param name="options">The request options for the request.</param>
-        /// <param name="disableAutomaticIdGeneration">Disables the automatic id generation, will throw an exception if id is missing.</param>
-        /// <param name="cancellationToken">(Optional) <see cref="T:System.Threading.CancellationToken" /> representing request cancellation.</param>
-        internal static Task<ResourceResponse<Document>> UpsertDocumentWithRetriesAsync(
-            this DocumentClient client,
-            Uri documentCollectionUri,
-            object document,
-            RequestOptions options = null,
-            bool disableAutomaticIdGeneration = false,
-            CancellationToken cancellationToken = default)
-        {
-            return Task.Run(
-                async () => await client.ExecuteWithRetries(
-                    () => client.UpsertDocumentAsync(
-                        documentCollectionUri,
-                        document,
-                        options,
-                        disableAutomaticIdGeneration,
-                        cancellationToken)),
-                cancellationToken);
-        }
-
-        /// <summary>
-        /// Delete a document as an asynchronous operation from the Azure Cosmos DB service.
-        /// </summary>
-        /// <param name="client"></param>
-        /// <param name="documentUri">The URI of the document to delete.</param>
-        /// <param name="options">The request options for the request.</param>
-        /// <param name="cancellationToken">(Optional) <see cref="T:System.Threading.CancellationToken" /> representing request cancellation.</param>
-        internal static Task<ResourceResponse<Document>> DeleteDocumentWithRetriesAsync(
-            this DocumentClient client,
-            Uri documentUri,
-            RequestOptions options = null,
-            CancellationToken cancellationToken = default)
-        {
-            return Task.Run(
-                async () => await client.ExecuteWithRetries(
-                    () => client.DeleteDocumentAsync(documentUri, options, cancellationToken)),
-                cancellationToken);
-        }
-
-        /// <summary>
-        /// Replaces a document as an asynchronous operation in the Azure Cosmos DB service.
-        /// </summary>
-        /// <param name="client"></param>
-        /// <param name="documentUri">The URI of the document to be updated.</param>
-        /// <param name="document">The updated document.</param>
-        /// <param name="options">The request options for the request.</param>
-        /// <param name="cancellationToken">(Optional) <see cref="T:System.Threading.CancellationToken" /> representing request cancellation.</param>
-        /// <returns></returns>
-        internal static Task<ResourceResponse<Document>> ReplaceDocumentWithRetriesAsync(
-            this DocumentClient client,
-            Uri documentUri,
-            object document,
-            RequestOptions options = null,
-            CancellationToken cancellationToken = default)
-        {
-            return Task.Run(
-                async () => await client.ExecuteWithRetries(
-                    () => client.ReplaceDocumentAsync(documentUri, document, options, cancellationToken)),
-                cancellationToken);
-        }
-
-        /// <summary>
-        /// Executes a stored procedure against a collection as an asynchronous operation from the Azure Cosmos DB service.
-        /// </summary>
-        /// <typeparam name="T"></typeparam>
-        /// <param name="client"></param>
-        /// <param name="storedProcedureUri">The URI of the stored procedure to be executed.</param>
-        /// <param name="procedureParams">The parameters for the stored procedure execution.</param>
-        /// <returns></returns>
-        internal static Task<StoredProcedureResponse<T>> ExecuteStoredProcedureWithRetriesAsync<T>(
-            this DocumentClient client,
-            Uri storedProcedureUri,
-            params object[] procedureParams)
-        {
-            return Task.Run(
-                async () => await client.ExecuteWithRetries(
-                    () => client.ExecuteStoredProcedureAsync<T>(storedProcedureUri, procedureParams)));
-        }
-
-        /// <summary>
-        /// Execute the function with retries on throttle
-        /// </summary>
-        internal static async Task<FeedResponse<T>> ExecuteNextWithRetriesAsync<T>(this IDocumentQuery<T> query)
-        {
-            while (true)
-            {
-                TimeSpan timeSpan;
-
-                try
-                {
-                    return await query.ExecuteNextAsync<T>();
-                }
-                catch (DocumentClientException ex) when (ex.StatusCode != null && (int) ex.StatusCode == 429)
-                {
-                    timeSpan = ex.RetryAfter;
-                }
-                catch (AggregateException ex) when (ex.InnerException is DocumentClientException de &&
-                                                    de.StatusCode != null && (int) de.StatusCode == 429)
-                {
-                    timeSpan = de.RetryAfter;
-                }
-
-                await Task.Delay(timeSpan);
-            }
-        }
-
-        /// <summary>
-        /// Execute the function with retries on throttle
-        /// </summary>
-        internal static async Task<T> ExecuteWithRetries<T>(
-            this DocumentClient client,
-            Func<Task<T>> function)
-        {
-            while (true)
-            {
-                TimeSpan timeSpan;
-
-                try
-                {
-                    return await function();
-                }
-                catch (DocumentClientException ex) when (ex.StatusCode != null && (int) ex.StatusCode == 429)
-                {
-                    timeSpan = ex.RetryAfter;
-                }
-                catch (AggregateException ex) when (ex.InnerException is DocumentClientException de &&
-                                                    de.StatusCode != null && (int) de.StatusCode == 429)
-                {
-                    timeSpan = de.RetryAfter;
-                }
-
-                await Task.Delay(timeSpan);
-            }
-        }
-    }
-}
\ No newline at end of file
diff --git a/src/providers/Elsa.Persistence.DocumentDb/Helpers/QueryHelper.cs b/src/providers/Elsa.Persistence.DocumentDb/Helpers/QueryHelper.cs
deleted file mode 100644
index fd609139d..000000000
--- a/src/providers/Elsa.Persistence.DocumentDb/Helpers/QueryHelper.cs
+++ /dev/null
@@ -1,24 +0,0 @@
-using Microsoft.Azure.Documents.Linq;
-using System.Collections.Generic;
-using System.Linq;
-using System.Threading.Tasks;
-
-namespace Elsa.Persistence.DocumentDb.Helpers
-{
-    internal static class QueryHelper
-    {
-        internal static async Task<IList<T>> ToQueryResultAsync<T>(this IQueryable<T> source)
-        {
-            var query = source.AsDocumentQuery();
-            var results = new List<T>();
-
-            while (query.HasMoreResults)
-            {
-                var nextResults = await Task.Run(async () => await query.ExecuteNextWithRetriesAsync());
-                results.AddRange(nextResults);
-            }
-
-            return results;
-        }
-    }
-}
diff --git a/src/providers/Elsa.Persistence.DocumentDb/Helpers/TimeHelper.cs b/src/providers/Elsa.Persistence.DocumentDb/Helpers/TimeHelper.cs
deleted file mode 100644
index a6525f243..000000000
--- a/src/providers/Elsa.Persistence.DocumentDb/Helpers/TimeHelper.cs
+++ /dev/null
@@ -1,26 +0,0 @@
-using System;
-using System.Globalization;
-
-namespace Elsa.Persistence.DocumentDb.Helpers
-{
-    internal static class TimeHelper
-    {
-        private static readonly DateTime EpochDateTime = new DateTime(1970, 1, 1, 0, 0, 0, 0, DateTimeKind.Utc);
-
-        internal static int ToEpoch(this DateTime date)
-        {
-            if (date.Equals(DateTime.MinValue)) return int.MinValue;
-            var epochTimeSpan = date - EpochDateTime;
-            return (int) epochTimeSpan.TotalSeconds;
-        }
-
-        internal static DateTime ToDateTime(this int totalSeconds) => EpochDateTime.AddSeconds(totalSeconds);
-
-        internal static string TryParseToEpoch(this string s)
-        {
-            return DateTime.TryParse(s, CultureInfo.InvariantCulture, DateTimeStyles.RoundtripKind, out var date)
-                ? date.ToEpoch().ToString(CultureInfo.InvariantCulture)
-                : s;
-        }
-    }
-}
\ No newline at end of file
diff --git a/src/providers/Elsa.Persistence.DocumentDb/Mapping/DocumentProfile.cs b/src/providers/Elsa.Persistence.DocumentDb/Mapping/DocumentProfile.cs
deleted file mode 100644
index df3c3f431..000000000
--- a/src/providers/Elsa.Persistence.DocumentDb/Mapping/DocumentProfile.cs
+++ /dev/null
@@ -1,15 +0,0 @@
-using AutoMapper;
-using Elsa.Models;
-using Elsa.Persistence.DocumentDb.Documents;
-
-namespace Elsa.Persistence.DocumentDb.Mapping
-{
-    public class DocumentProfile : Profile
-    {
-        public DocumentProfile()
-        {
-            CreateMap<WorkflowDefinitionVersion, WorkflowDefinitionVersionDocument>().ReverseMap();
-            CreateMap<WorkflowInstance, WorkflowInstanceDocument>().ReverseMap();
-        }
-    }
-}
diff --git a/src/providers/Elsa.Persistence.DocumentDb/Services/CosmosDbWorkflowDefinitionStore.cs b/src/providers/Elsa.Persistence.DocumentDb/Services/CosmosDbWorkflowDefinitionStore.cs
deleted file mode 100644
index 01c9b591f..000000000
--- a/src/providers/Elsa.Persistence.DocumentDb/Services/CosmosDbWorkflowDefinitionStore.cs
+++ /dev/null
@@ -1,114 +0,0 @@
-using System;
-using System.Collections.Generic;
-using System.Linq;
-using System.Threading;
-using System.Threading.Tasks;
-using AutoMapper;
-using Elsa.Models;
-using Elsa.Persistence.DocumentDb.Documents;
-using Elsa.Persistence.DocumentDb.Extensions;
-using Elsa.Persistence.DocumentDb.Helpers;
-
-namespace Elsa.Persistence.DocumentDb.Services
-{
-    public class CosmosDbWorkflowDefinitionStore : IWorkflowDefinitionStore
-    {
-        private readonly IMapper mapper;
-        private readonly DocumentDbStorage storage;
-        private Uri? collectionUrl;
-
-        public CosmosDbWorkflowDefinitionStore(DocumentDbStorage storage, IMapper mapper)
-        {
-            this.storage = storage;
-            this.mapper = mapper;
-            collectionUrl = default;
-        }
-
-        public async Task<WorkflowDefinitionVersion> AddAsync(WorkflowDefinitionVersion definition, CancellationToken cancellationToken = default)
-        {
-            var document = Map(definition);
-            var client = storage.Client;
-            var collectionUrl = await GetCollectionUriAsync(cancellationToken);
-            await client.CreateDocumentWithRetriesAsync(collectionUrl, document, cancellationToken: cancellationToken);
-            return Map(document);
-        }
-
-        public async Task<WorkflowDefinitionVersion> GetByIdAsync(string id, CancellationToken cancellationToken = default)
-        {
-            var client = storage.Client;
-            var collectionUrl = await GetCollectionUriAsync(cancellationToken);
-            var query = client.CreateDocumentQuery<WorkflowDefinitionVersionDocument>(collectionUrl).Where(c => c.Id == id);
-            var document = query.FirstOrDefault();
-            return Map(document);
-        }
-
-        public async Task<WorkflowDefinitionVersion> GetByIdAsync(string definitionId, VersionOptions version, CancellationToken cancellationToken = default)
-        {
-            var client = storage.Client;
-            var collectionUrl = await GetCollectionUriAsync(cancellationToken);
-            var query = client.CreateDocumentQuery<WorkflowDefinitionVersionDocument>(collectionUrl)
-                .Where(c => c.DefinitionId == definitionId).WithVersion(version);
-            var document = query.AsEnumerable().FirstOrDefault();
-            return Map(document);
-        }
-        
-        public async Task<int> DeleteAsync(string id, CancellationToken cancellationToken = default)
-        {
-            var client = storage.Client;
-            var collectionUrl = await GetCollectionUriAsync(cancellationToken);
-            var workflowDefinitionDocuments = await client.CreateDocumentQuery<WorkflowDefinitionVersionDocument>(collectionUrl).Where(c => c.DefinitionId == id).ToQueryResultAsync();
-            foreach (var record in workflowDefinitionDocuments)
-            {
-                await client.DeleteDocumentAsync(record.Id, cancellationToken: cancellationToken);
-            }
-            return workflowDefinitionDocuments.Count;
-        }
-
-        public async Task<IEnumerable<WorkflowDefinitionVersion>> ListAsync(VersionOptions version, CancellationToken cancellationToken = default)
-        {
-            var client = storage.Client;
-            var collectionUrl = await GetCollectionUriAsync(cancellationToken);
-            var query = client
-                .CreateDocumentQuery<WorkflowDefinitionVersionDocument>(collectionUrl)
-                .WithVersion(version).ToList();
-           
-            return mapper.Map<IEnumerable<WorkflowDefinitionVersion>>(query);
-        }
-
-        public async Task<WorkflowDefinitionVersion> SaveAsync(WorkflowDefinitionVersion definition, CancellationToken cancellationToken = default)
-        {
-            var document = Map(definition);
-            var client = storage.Client;
-            var collectionUrl = await GetCollectionUriAsync(cancellationToken);
-            await client.UpsertDocumentWithRetriesAsync(collectionUrl, document, cancellationToken: cancellationToken);
-            return definition;
-        }
-
-        public async Task<WorkflowDefinitionVersion> UpdateAsync(WorkflowDefinitionVersion definition, CancellationToken cancellationToken = default)
-        {
-            var document = Map(definition);
-            var client = storage.Client;
-            var collectionUrl = await GetCollectionUriAsync(cancellationToken);
-            await client.UpsertDocumentWithRetriesAsync(collectionUrl, document, cancellationToken: cancellationToken);
-            return Map(document);
-        }
-        
-        private async Task<Uri> GetCollectionUriAsync(CancellationToken cancellationToken)
-        {
-            if (collectionUrl == null) 
-                collectionUrl = await storage.GetCollectionAsync("WorkflowDefinitions", cancellationToken);
-
-            return collectionUrl;
-        }
-
-        private WorkflowDefinitionVersionDocument Map(WorkflowDefinitionVersion source)
-        {
-            return mapper.Map<WorkflowDefinitionVersionDocument>(source);
-        }
-
-        private WorkflowDefinitionVersion Map(WorkflowDefinitionVersionDocument source)
-        {
-            return mapper.Map<WorkflowDefinitionVersion>(source);
-        }
-    }
-}
diff --git a/src/providers/Elsa.Persistence.DocumentDb/Services/CosmosDbWorkflowInstanceStore.cs b/src/providers/Elsa.Persistence.DocumentDb/Services/CosmosDbWorkflowInstanceStore.cs
deleted file mode 100644
index 4aa641b45..000000000
--- a/src/providers/Elsa.Persistence.DocumentDb/Services/CosmosDbWorkflowInstanceStore.cs
+++ /dev/null
@@ -1,173 +0,0 @@
-using System;
-using System.Collections.Generic;
-using System.Linq;
-using System.Threading;
-using System.Threading.Tasks;
-using AutoMapper;
-using Elsa.Extensions;
-using Elsa.Models;
-using Elsa.Persistence.DocumentDb.Documents;
-using Elsa.Persistence.DocumentDb.Helpers;
-
-namespace Elsa.Persistence.DocumentDb.Services
-{
-    public class CosmosDbWorkflowInstanceStore : IWorkflowInstanceStore
-    {
-        private readonly IMapper mapper;
-        private readonly DocumentDbStorage storage;
-        private Uri? collectionUrl;
-
-        public CosmosDbWorkflowInstanceStore(DocumentDbStorage storage, IMapper mapper)
-        {
-            this.storage = storage;
-            this.mapper = mapper;
-            collectionUrl = default;
-        }
-
-        public async Task DeleteAsync(
-            string id,
-            CancellationToken cancellationToken = default)
-        {
-            var client = storage.Client;
-            await client.DeleteDocumentAsync(id, cancellationToken: cancellationToken);
-        }
-
-        public async Task<WorkflowInstance> GetByCorrelationIdAsync(
-            string correlationId,
-            CancellationToken cancellationToken = default)
-        {
-            var client = storage.Client;
-            var collectionUrl = await GetCollectionUriAsync(cancellationToken);
-            var query = client.CreateDocumentQuery<WorkflowInstanceDocument>(collectionUrl)
-                .Where(c => c.CorrelationId == correlationId);
-            var document = query.AsEnumerable().FirstOrDefault();
-            return Map(document);
-        }
-
-        public async Task<WorkflowInstance> GetByIdAsync(
-            string id,
-            CancellationToken cancellationToken = default)
-        {
-            var client = storage.Client;
-            var collectionUrl = await GetCollectionUriAsync(cancellationToken);
-            var query = client.CreateDocumentQuery<WorkflowInstanceDocument>(collectionUrl)
-                .Where(c => c.Id == id);
-            var document = query.AsEnumerable().FirstOrDefault();
-            return Map(document);
-        }
-
-        public async Task<IEnumerable<WorkflowInstance>> ListAllAsync(CancellationToken cancellationToken = default)
-        {
-            var client = storage.Client;
-            var collectionUrl = await GetCollectionUriAsync(cancellationToken);
-            var query = client
-                .CreateDocumentQuery<WorkflowInstanceDocument>(collectionUrl)
-                .OrderByDescending(x => x.CreatedAt);
-            return mapper.Map<IEnumerable<WorkflowInstance>>(query);
-        }
-        public async Task<IEnumerable<(WorkflowInstance, BlockingActivity)>> ListByBlockingActivityTagAsync(
-            string activityType,
-            string tag,
-            string? correlationId = null,
-            CancellationToken cancellationToken = default)
-        {
-            var client = storage.Client;
-            var collectionUrl = await GetCollectionUriAsync(cancellationToken);
-            var query = client
-                .CreateDocumentQuery<WorkflowInstanceDocument>(collectionUrl)
-                .Where(x => x.Status == WorkflowStatus.Suspended);
-
-            if (!string.IsNullOrWhiteSpace(correlationId))
-                query = query.Where(x => x.CorrelationId == correlationId);
-
-            query = query.Where(x => x.BlockingActivities.Any(y => y.ActivityType == activityType && y.Tag == tag));
-            query = query.OrderByDescending(x => x.CreatedAt);
-
-            var instances = Map(query.ToList());
-            return instances.GetBlockingActivities(activityType);
-        }
-
-        public async Task<IEnumerable<(WorkflowInstance, BlockingActivity)>> ListByBlockingActivityAsync(
-            string activityType,
-            string? correlationId = null,
-            CancellationToken cancellationToken = default)
-        {
-            var client = storage.Client;
-            var collectionUrl = await GetCollectionUriAsync(cancellationToken);
-            var query = client
-                .CreateDocumentQuery<WorkflowInstanceDocument>(collectionUrl)
-                .Where(x => x.Status == WorkflowStatus.Suspended);
-
-            if (!string.IsNullOrWhiteSpace(correlationId))
-                query = query.Where(x => x.CorrelationId == correlationId);
-
-            query = query.Where(x => x.BlockingActivities.Any(y => y.ActivityType == activityType));
-            query = query.OrderByDescending(x => x.CreatedAt);
-
-            var instances = Map(query.ToList());
-            return instances.GetBlockingActivities(activityType);
-        }
-
-        public async Task<IEnumerable<WorkflowInstance>> ListByDefinitionAsync(
-            string definitionId,
-            CancellationToken cancellationToken = default)
-        {
-            var client = storage.Client;
-            var collectionUrl = await GetCollectionUriAsync(cancellationToken);
-            var query = client.CreateDocumentQuery<WorkflowInstanceDocument>(collectionUrl)
-                .Where(c => c.DefinitionId == definitionId)
-                .OrderByDescending(x => x.CreatedAt);
-            return Map(query.ToList());
-        }
-
-        public async Task<IEnumerable<WorkflowInstance>> ListByStatusAsync(
-            string definitionId,
-            WorkflowStatus status,
-            CancellationToken cancellationToken = default)
-        {
-            var client = storage.Client;
-            var collectionUrl = await GetCollectionUriAsync(cancellationToken);
-            var query = client.CreateDocumentQuery<WorkflowInstanceDocument>(collectionUrl)
-                .Where(c => c.DefinitionId == definitionId && c.Status == status)
-                .OrderByDescending(x => x.CreatedAt);
-            return Map(query.ToList());
-        }
-
-        public async Task<IEnumerable<WorkflowInstance>> ListByStatusAsync(WorkflowStatus status, CancellationToken cancellationToken = default)
-        {
-            var client = storage.Client;
-            var collectionUrl = await GetCollectionUriAsync(cancellationToken);
-            var query = client.CreateDocumentQuery<WorkflowInstanceDocument>(collectionUrl)
-                .Where(c => c.Status == status)
-                .OrderByDescending(x => x.CreatedAt);
-            return Map(query.ToList());
-        }
-
-        public async Task<WorkflowInstance> SaveAsync(WorkflowInstance instance, CancellationToken cancellationToken = default)
-        {
-            var document = Map(instance);
-            var client = storage.Client;
-            var collectionUrl = await GetCollectionUriAsync(cancellationToken);
-            var response = await client.UpsertDocumentWithRetriesAsync(
-                collectionUrl,
-                document,
-                cancellationToken: cancellationToken);
-
-            document = (dynamic)response.Resource;
-            return Map(document);
-        }
-
-        private async Task<Uri> GetCollectionUriAsync(CancellationToken cancellationToken)
-        {
-            if (collectionUrl == null)
-                collectionUrl = await storage.GetCollectionAsync("WorkflowInstances", cancellationToken);
-
-            return collectionUrl;
-        }
-
-        private WorkflowInstanceDocument Map(WorkflowInstance source) => mapper.Map<WorkflowInstanceDocument>(source);
-        private WorkflowInstance Map(WorkflowInstanceDocument source) => mapper.Map<WorkflowInstance>(source);
-
-        private IEnumerable<WorkflowInstance> Map(IEnumerable<WorkflowInstanceDocument> source) => mapper.Map<IEnumerable<WorkflowInstance>>(source);
-    }
-}
\ No newline at end of file
diff --git a/src/providers/Elsa.Persistence.DocumentDb/icon.png b/src/providers/Elsa.Persistence.DocumentDb/icon.png
deleted file mode 100644
index f978a28829e4f03aa270e4f0f2162bb8c41bed2a..0000000000000000000000000000000000000000
GIT binary patch
literal 0
HcmV?d00001

literal 16374
zcmaL8WmsH6vo1O_xCM6`Ah^4`1b3GJ8Jr-&oxxp#J0!Tf6WoHk2DjiA+%DffXP<L_
z+<oWI>a|wYTh&$7Q%|q1icnSlgoaFn3;+Po<YcAP0RZ6p5C}kof4>+yl~}xA2wkLg
zT{IjlT-;5a%mLzN4qwc{a(1Sc=IZ9AW}e@En+pK|FjUr>x-Pm(iUJS^I~LRb(6D&e
zIlglP079Z3j;0V>a~JRzb4zP`VaoINE=sVqnJ}dew-TF@qolc&wXBzuxrUdrCdA7Y
z!f!??DgqYr5O@c$Gj}lsd)R%ocNXvvru;8lf%ox$9<x${|BJ-MR+#dCDW$8V3YK(m
zG6!?B@GwKzx%j}m{4DG|Tx^^?OkfT+c79eiK2~;4W;S*KHXZ?PUhx0^QNBxaGP4j+
zmy-G4vfl56DXm;w90gce-QC?;+&NhsoGe+{`T5^5I9NG2nBOUwojvVcOg)(GovHpC
zLCV}2;$-dUV(nlL{tu$*7YA1tVaj(+|JM}k9RCljz4QMz)4Rb~Jxm>0*;&~BGo}9~
zR8so?C$+QtKh(}H>gNAf-~UfwXH8E>b5?b8X9rg&$h+e#sQx3$Q9#nk+|<RvNz=jM
z>wjBO)yl!e!P&~e5zO(f5|~cM+TP5;-I@Ns7?hL*<m{bYOzk1&a#F&S?+`53)@B0S
z()?1K;_Q5EQe2$u?9$@moNWA(oZ?(u>>RwDJRCCr%`4>qakVqIclmE#v;WJ>|3C8n
zCl>4+-z7_#J6XG#o5?si*n$6R&H~o|vo1XUBi{e!HT$1+;r$<ZS>Kgm{f}q=U!MN&
zNAKbDpW*+B+xMIQ6Zz)$@8RzB9@qE?oRjZM!dgyBT+?Ia#1|>eNGthlr7zp2O1_XI
zksp;JK7!3U4F_n4Q9Ca~RJeM0?W<zk>^FIa&~fG`)^+ZCI%Okz>bFu!IRUSlDF+8p
z75fc~q%ka8Bwwh0T`8F5eCua>YJkfz_e(3e4YGFAC%4w-de(Yy@@rwmw(=MJWwGch
zdlHCVr8`TTT)!BBEgle$w}Er!&*mXpBjyl*YjQCjFDK@*AWv{|448F?-G~jq5xMsR
zkmcxN4{F2=Od?+-2k2t-Ms0ClT#GM32NI*zG1k^#il_sP!D8+o0{z_>mx6)Dn;U^2
zp7r83!g7=0)x`-qq|pDgIO3j=@WBgueGrd9Y@ggl3q+?6_h2@0AreaNZpI1r#=R%X
zMem{n$sq=ZKK|p<6}>ZHEB9v~J2gb|J61#FE&#W>6NSekV0`Skhj(eft0smH_WV8R
zeTvX6i2!<tLnkR6qc6J8i@w+L$?~ya`jjJeoiX`Lq~A}tnCIJRr_nIZR4$BIko3R{
z9es1LxuE@w=D>KZk;6gFb%K<UF{Z*EF8Xx&7rWO5h4>6d`xcgRIe^>_znAQaxg(%?
zKBzep%l^!<>JJHldlv<@DModIB9fIIQaA66Z&WS`Ea41T6Gu^B(q$d<;*pY%T*GuD
zY22}9%eBR6gLH~q1T->3_lY9Vz3^MfjFO8hxdd>ci#$}b1cgf&YwZ_1o0TwMyC)A*
zg>8WG$sbsT1pww=K=*mdJ+IvpMd`{#F*;?DSeF~>0o9R6b(?y;?o_Y_#%2eis&zzM
zK>r?!Y_NKs5&;6*Tc|TznoLH&<$``dEs?|z!1lK+{DR|s?T)xP0xN+vlv+3kpx`lx
z4ws8<<U_wAP(8YFXv3x-!md8^aKGT=BaCj$+B>^X^__diTefH6dm1bD88ru^**Y;k
z(T2~%zNK6^Q36UrRr#Ndzv~xTSpJ8D5OgxZ%gSGp)y+GX0_zagY<#m_U_NROD38P>
z;zwu-3Y5kWnzA@}BCX%|1#)Ubzl-J5#p8UG8SN>cvP?0^3RR^%Yj!MCjo7Z{yf{GZ
zs2t@;2-^*A5970e5tN{)t<_#yyiCs-x@+2=-kHO<^<38jXj0V&&7y^T$YKb8Q^c1y
zDh<{Th}_;ACLZ-=w6XnCBEK5BpQumVja+#e$)>OA2bRr_-RUxrrn~a~(U0fTcEbmM
zYR@EVY?0m#GU1T;xso;YQj$|F#-IjC{K5Ea->PkOZetdSG7XNEl^!E&X>?nHE%7m+
zq3Q;C|A8%$Hac)3L^eKaS<AqQ?LqN#Kh@wV<dLQKi-K^;La4J#drW|;m!rZ&BVHy8
zKXa0K7mAB2&?J7_QV`l-B2b6N=T3u8;++x8`c<2T3Js*J{Lzr1+!7gGJ++56%Hz+4
zXAxh!*`N4dU%=&XOaKO(0qj9L5sc(XY2mlE`vo-mHSfLNGc8jU3pbQuWqhZ1<=hDA
zIrcGnu}f3-cgN5h&?cV5gyx<mdn0e|hd!x^i9}c5O)m)${^kgP6Vv<lf}uni&;+aI
z9hH2$AK&26tZltT;@q1KI6DFHAJPoS>K~4Mv}DjD9Bi&?1XrUeTze8@bs-mc$imiq
zP&p2?nMu<HBwd5{=a${+7)1cUj>WhP0n<2Jppe)DTRxK&aoysRskbmPl$C+PFVg>>
zBK8GaNQ4O>A3`{DWB`NvhEey#VO=o$H)Jb-K8XY)J$pug<QSd!LIjoJ7uvz5;QjjD
zC2N>x{2=<mr%#1~hJFPgdMOKGd`BepZQje5HPG(CWwbdP$<_c}3KPNOB1=AhUTYrz
zkJfMP6?{5emO_k702)OrtWpMCk4@rhT3MaApDzzgoo}i4Lv*V@sPBkSRWy_K`{gg0
zI<M&_=G)c9SH?-B06ajN?q|TX>}jsBx647X4@zpkW*S1#80PHOG5VljwJ68ZgP~o)
zJ|j|%Xbn@59t=U8(;@s|BzkCJmtOGh9k#fmoCzwnTF75mu6H${&iKg|oa1}4&SNG(
z#}&uCnR^ior+mOA;KKwm^31eE=OK(qQrEtW2!O%}iaSm*aRigjKhSEPU<qWyT9!RF
zJ}50hlL__v*j-WAp{+<15YG-AW5_VbfMnQ`rQ6^ESeDiUWf4q5bR*_2Iem`VNn)Gp
z6thltSvHRLi4L;%bF4P|&EW6=iECn9!}p!&P1?MVcCN-eIm^Mb{yV>q;UG@OFlQUY
z)@LtGE3B(4s#Md#3SBtw)?=lU{WMJ#g`SZy?B;KCS{#heW~@nXbru01ju%ctVn^@}
z>fSrs<K(a0$EpMwhoQtBb2}nWEi3(k1kNIqZNLC4Vc5wQV7}8SU)O66ow5|};;C+*
zYIDqTD(}Gp@vJ2&V=yW;6$XC(W(B|+B6oUd6MUPjL5Gg2vCHUx4D|)XYR6lUoYnwJ
zHu>RNMiHM-8N5>2LO2JT?ZXwq-NHk40h(kJ>>xh~;LNmG1VYJ(I32HcL5zcRPy?Xz
zCMX;C_g?xtj(3u**c06`3^c7qU7fN(y1M<{q{Jo%3mq4Vihql3TXhG|-Us#!(|!Su
zxs$~7ToN5J0Y-X1W7lXxS77sA17SP~LP8!<escfh#{-zxoY_*pa+U4UKu(=#lx5UV
zl?vWp{1hGq<rQFUlErTim4Kwum<Xk{1*u|h!{PM+IIg>g{>;)f%81_hw$IV(WqDFT
zAZtv9h8E>LM1ZZB)zMM;ff&X!CT{H=8yv?7L{37#VLxu6mqf!fMwL+p5UvXQoC8yC
zS9gvsafGYr7F~CRLU0s>=wA}CJU@tt2k_K>q=?@lPB22qt^fT>nAeg-kw1o`$%W8M
zAt?Fj#MzqM9)k&RMF(JdZoM3%%A=AuYqR1QU>{LOgoRH+I-!!Pe}5g+HMrw9u>sMH
zRq5V(rC2csvH|}@4B@905a33#qE54+KrfFqw$CqHQmw<)mfe7VqJ}o=0R*|oH(gU%
zkAg*HgS+v-3wNnmCcq$%e#=$gnj%lM91YwV%O|D0Kd{|K9ao$*)u<R!tM0V`KBK*2
z|F^c8oif7c=|X5rn3YitfG^@nG@Pn$-A|@bHh|U4s`KAekrbSA;E!|M!Ovmpmp~e1
zndD^{bZG5Rux4DUCV);WLt0c(O#^`MK_)aJE)s1cSrk?4!FB3ADj9J1rPNF1IGr<!
z<w1<TYz<$LcR?uqwv`hhUp^UX6(mdM_3+zeDAs)8$PF7&Gc<|`(10bq`=XexRVjvO
znu`@+wO8XOGj9V_|4FpjoB_VU(fu_CJCXpP+fOKYp%ei2$7etSHz{xs4z!JEW#D%T
za4~g6Bg!dcci|o|hNs#GE+q7rfK!?BIFiQ*AqxJ^bg=59-W83!?AM$Gv|g|$N)(4{
z5Fcmv<^ypt>8dCSz>M@%&-X1gK+D3I=D-0<jw3uo3hc1NYz-ktb?m{Bu7Pt&WT^pw
z>vP*`kcExu9w02M<0fX7c-!9}9j$5`d&sQqdT`CxD3J%^cc&Xnz5)UktYH2QDVg91
zz7Ry8umI~)j;S8MVcuIRY#`9%ATs8uq7<K@rAu6jy6T0<VhkFjZh#;u7dV^*`F(t!
zr#Fy;Tc|2QH8VJh-xho^tJ!8yb^LMZ!VA7M{{UW?+M-P|1+mN2>p>rDlCORTI35AX
zL!fl3P^i5kUR4a)`t?`F(`MN67u3OYtLcq0G|J-;1O((F;GE}l;96JpiKGmn-SXv-
zNwfx%qfkCXe3#-hA`1CNxDEWGSOAAUmc7txv+oNJ0lfm)%73x_Aq07n<K%5XZ}Y`P
zwD9ncq8LWi6&j}qPzU=PfxCrbX<>G-pPi7Nd2&Hw_+o&9y}0bzz@Yc3`z*n12EEkI
zTUf8di3t>5^*(?GlES?)BL518;2d05uoFBO=!S^pM2-snO7hRGL<_)uh(McaG>BDv
zevO7J|5$+E$b=!kKAP=K5Dgjz?lQw|BW&RdxJ7kCld*MbUB_S7BdlpX&^ZE-<)wo7
z-H%?hcZjX=0H`vZ;{al;JjtWi3}0afOnP!f#XhO#CD-SX<%imrzAb~wlvK$K7(asO
zKr6toK|kd381E1A;lI1<EtIL+;tz^{L3N^VrQDqP5!@P`MX}T#Det5<AiR#I$LfJs
zkIkN8a&&4XU$ZYDu<i_3?UNjwNyeAAPaiyDgalD#w!}MRgz&RA9<8y{)3A-7$8X;i
z0MNC93Aoy&W`+cJd`02&H^If;ngL~MDAFcwDzY#aj}t;Tsw-TGm_FkVfV2m~Xv$K+
zt`%>IZ)P<iV-+W*&prseO)8Y=nyc<ZL2Ba}m2^ZJ$oX#OpS{vR*@q91z~<mzl3mz1
z0q*eM-372nh~H9I0Trqk!I_;lC<%()CTxS0@JVdOG4R=pp`K2EKzXbjuX(~YU-HZx
z6Jgs)zII=Cn<Rl^@8+&vm-u<%WL^|=dOGt`;)#l{RB-*|<`I2!W_<{wu|}cMG#8$5
zrMaycfjhVWq|%|6WK-Zdx?X)avp;<PKUEVvPx($!yMegDO5n$Bi19$Fot$ErxXjB_
z$u2(QyL$+&fH<)Zd%irS{z(_Y7(3zU3kncO+{d5MUHLq|3RwLTEY|}jNf7`?(z}yh
zne0w;HM))oWPZ1tGZnPhhuwzDO@&pm)rCyuEOIRhGEew?#duU9E7YN;xA})fW|X)f
z-T`3)GNQN#e^+Ch3%Rlj#+FjnAT=3%sB}(}DtW9?P?rd|1@@-wTP^#AZ&58R$IFKF
zZv^PrBpx70O=S4uW5(ZzoUZ!8SR=q(&r%u40BIBiXB!3w3hJSwLNobmDHXEF05$LJ
zZemCJpjt8#cL<%lVB;jf1#Hi=Up0QvWGgeo1ZPh5wj>L`p~`sn&F|qlmaFb}>9Gkr
zbY@D!AYPoDgu!kAU>E$PbbIXI?S>T$xMH}h*fHAOG8C#h*5Gt9L=<I$k(Ch;F$IH_
zpr2BE=$r{Kp$$ja+@(#EjOE>tC+zKBdAC-|Fk*VO+OTdEh!%eE`5asTIdN~4#9D|g
zj5Y7>O3h+`{6Pa<Fgm%;dp00QE=C&uHxv_y)_QyD;=z`nkThq2`{xV)eppWlUCT36
zZ2jlV5%#@;zcx_S+r{h*F9&Mo?5I$-EK@Lv1??%}Llaw-Eg-j#a2s`4of_7Mp4kvB
z-xhC!w!&MD;K!a(WvBx^7OT0N-K`%^zryu3Ai+@~0~q^J%TKhjZbnTsX~Nynt{gFV
zI4c^%KH&fw8AJk+p}9$01|USB&WkA<!yGywog_y;xeZS7(byyyR)qPvX?7j803m?D
zr+Swr7gZ)i0f>?lf3DTEXRPVy#gr?e?ftibw@>`5S0%Zg0uT-rKEE!&?RCY&!^BIU
zdPRj3`$(hM{hz+?eQ2Cv`xDj1-$>H^X$Ttw33CMD#VFjy^WQ<jIKOKy;KgN(vA`+J
z_dGWvCM%CPOp!P;h}1m|w43PS@&c4Aua0J$H8Gcj!^iTGP7bL!eNmq-wRwV$rC>gO
z&KI4={5eJA4&<V7(2KnX438(r<SuRY<T#Z;MgdZiK$w$Y=*>u|Hxae6dPtG(gcgJo
z3AR@3<1bfSZsc!DT2MKKW`_SpfYD03gF+oqZCqfFB-PUJY+VMvaK<nMV<XdV1hwP_
z`mqA#e1!iN|DYvxU(9oI!gRM1GETW^!N|674z?87PWDgw3hgk&=IUTx5as^jn=SCo
zSmk)W`WHQYH^RB@tbX;cR`FnSAYud&0pTauK3v6-pblmN2&rktH$f3Nk3r{2JSgGT
z%6)YYuIlfxD_yl{l`#@AV}UL0XZmR`-6b~S3HuDBYoZks0S-S>WFWPcvJ!=z&tLgL
zQ~wU^SZajLDHHq?^1p#p5ue{Pij7+M)KWRem!d68@{5GCPUS)rh6qd5srjv6wmyCa
zgU$*lt*N2#!tK6x9`cjbV@PWq4FclS*o2Lzb|KpellRJB*4yr#nr-gQr!-W>WH5wZ
z2emyK58^YYF0Igg*TEfj3mm%30_2U*&4M4;l8bM90r;i{i+;`e+Q>VJGPBu7VQf`1
z_=@}}ELj}*DLj*I5+;Tp=*&I{*c?%^wO8%kKWX+~C7%Ud5XC+m|2lP~TZf}Bh<j8W
zvxeU@*^bw{K2TUkM*Bg;OGX=bAKH-N+WxkQ*ATC{CtSK<&FGK_@^k%JRQB|lZy9##
z$F3ITerwr#($qAIPn&a`o(qYk8$l8z`p`F+-#$bOP(7O6Wwp)%q7bdr<uvateb&sJ
z#ianqa^~ZThD^Ge9vgZ*RiJGC+1K-YBh$asX_#<EU|%e!L(LIwL-{Op3s0i-Pn;2%
z=x_|i00cyw3JUZcNb<Z$IXu`Ex+^?;xo~;1Wn*4ZT_{4mbZPswRo271qRb)FSS8o>
zur%24W4pc#V@$N84#R6UXy>yWGMc{Uu$;N6kFa*30g_X*&S;v@o&)2Ivpe{j`;*OP
zpQSO-b_EZ2&s%Qb^9sih>1mL#GDfxNGl$25yR*7Wd+vz^#N=iUE<eZn+v*pOBHyrU
znB>MFY)^eF|77Ii)!-!3KD;Q@$G8ANFG1B$<hqQ*#M&WgpJ&6HtO}UM64cp50@BV;
ziU==w8P|=t_C<ZkGB!`^Qv=9hV@u@&K9=2bUWg2z5TYIY(BmR+?3%_4s7tdf{8;d`
zadbxlob{h0<#3!}G`#yQPP<F3T9_6J0+&gaz-pOZU{@IyxK-O20CHP5jo5JKm({oN
zpLhhB*(syWQNX5ro79`n`}~rE#QC<+(P_<a@6yOLn>h^@6s89cj<8s6E>c>M?RX&`
zHLK><XFEmdJnc^uTX$OX&e%Y5@qOCK*W!sTKf_$=)n5pNjgXqfN~kqXPJ>rMby(BG
zFuM$c5R$h3vH_)QzSrZSz@+<0aGRs`Gj)Nh6^;;N@dWv`C5w#RVFU~-G;Gp%VnS@&
zjx^#kR^$T7#`hVH;S*zGlpC3q<U$KS${c_1L%C*4!-`u-FOul-ZF4?@A@`Vy2;s`U
z4eG!q<iLn?fAZH{BYBhidDx=&$`5oMg)jOJbZk~08$$K@9}S;j_<eqN*q|<Uk7ZcU
zezmd;cxEZyUZ$#+^!~Ycij@q)X=khUD{CLB{bExAoUqG)%ZxqyHZfYKlt(4NYf;G6
z^cneYar@kFuyeZ=X@xrIXW{z9N2HG8E|^%FC&N6sS{$lW?hvUm`CU(z2xG+DdeQ9Q
zxZFFQW`Veo`!$43OwCE_)!5tHW0yHN{*Z421-PQK!Zy0!n}+(xtb}G;9!bbf0@i#<
z39I=z#(#z$PE0p-xUOHGFFD@hmWWeiwMtxy_eKZLdXRcG)Zh3FvG5k{Rfz6Dq=jqB
z9R(I<eUEPQO=X`z`k61d8W}zp@`f*Ao!L#>R=F)Q`2O5gc>C@KMx}gNqUIkAd3=AD
z9QdE#Z1hy4+dH=tDzzjWt5MzeBaIXQu0*B9+Pf*fV68~Ly?kHXY>izs{kDVJVzHp!
z@PzFM8zSY)r=6e&W)5w#iAWzp!TM5vTqNdhlNXM%c>g0gWZm!A&w7JubXzWW3*|e`
z!?zih>(+ld^WCT+tj4?ty?;QMlTVMMU4a|T=g=ly;i}toB23GXygvRTv-JVT!eZ~G
zHTQl}92Y5zfZ%OgQ^Esdtdz#FZ?BP;fnWWd;9q?<WN-j#bc-AU{W~|V7J7CuslS(}
zX2Rls`r3F?Sib3?!v{5>90-#miQxOyJ@I=yUX)w4^O9P=`q&s0*d)q`GqR>*6(VEu
z#z$xxv41$&u(l9e1vNiDnRg`aj=WG*V^7)=LKTS{CZj7qiTktEOW#1X+pjY$_7tIB
zzwX$Cn*7TRFj0P|5&le~Rzjsja5SixmVPsbS-#%|jEB}A>2H1IvZMo+Ww}~!-?*3@
z&jtWXgL?yXaLx%JO(j@2<Zo1y&m<q0440scqUp#D94Z#4j=C?!c{zqZHsj7VKwZMm
zP7}73GR#nt0&_BDyhQaJDtZMieV|8H-&Zx^3$?4n72)zG>SO+-+xGfqQlg8F-)97*
zA9jqAC0|5SPQoN%)@q91N>ENGLX#^|3{yT@<LsfrU6I(_Q#BU6=<D|1`rkkaGP1N=
z-Sp^uQ^R$&#8nB9+WB2Ivf$&<3<U1lt_84P&Rlt>(pYTyN2xU<IJjXsXz-b4aEiBn
z)L|jE$G^PIe*_qgx(_Gcid#?MEYq6SX~@tJ9D&SM4AmktzaQEfp28pz$DNIM4sg%n
z2?7<w?e=W02x?G%tA3}f|2JvbR3ah@Fz<M`+lzd-969cm0lCfhT4(cDHItR9PAV4F
z=q7sOWB!xKbhEyM!NZ!GZyBTLbUK$2+LJy`n!^o_Rg0b#KuvTjE#AQv8=>VXk}B8o
zwCw)Et?X;o?BEczS!V$$dSU*EBT+cf=`_`!Sf_})y=4mz6J~Tf)0wFf+^X;<r3nLE
z7EwpQ^cziI%kIf_!Zv<=l=1HZ?(1eeA;Xj6^I3HPKVh0(e{F5!gr=u+1yp8xJ0TCv
zYv8wC92tJ-!-8bsOwr^6aFBj3A?XTFNl21ceL>hBa;k{!9q8AvIWfC|!Mbi9Br@5X
z^VFOCfh>&x-)1<s%{GiL)(%V}{;ma;u`#v2CP`(|D(d^B!WB06mOh3xUkr@zvsE$v
zG;z(6>BhrFL4nR^;N~P3u=UG-WILZ};Oo+#R_~I>^UO(=PRtR@`yD!q?u;fy<p6pO
z&Jpmrg6STY{hOX|i8!~L`}y~*etv3wg!A++crW#!iG1O7sqPEsgO#Uq<$<l_oFG+q
zc_*x2ML0HP2(n0u%VMSr&d2%`Iel{sg+Qqe*2Yph&IALf7BM9UECNEi^O-evRYogL
zmFTeqAI>@1kuMv6KY;(Q#e5?;F(>(kgeY^OzdJlRqL%?S`}b>>L0|#5>a+$&{)jSw
zauWMo!5FPcK0l4B4Al&T5g_8}xLR_s-gIBdVta96Qhgn&<K<4?_T-oP;I2J^Eb<<V
zd8gz=YP-|knlJ$qgyX1rR`S(jSi#{3q~}2wnLrQhnia8WsM(Xcou89SOelJ`FWmF;
z&ry?ZmDYVS5JRd>$ps_-jrPIt)5hY)p~R0;u5{9G&)uh}Cntj2+pu+}UP_!<t3vgt
z*ufX}@psfCfixCjHuIq1^2NKp>`AdNsBTB?`&Ge{pD$R_)MgRG;Jpo}Q{=gj=)}Sv
z`NpbqGj6hCvfGVDT&n(xMWW;ph5Mf@rC&d3H?la2>+Ge1KV}vTgh2Iv=r;l!^}Bm|
zSnmC+h4_mmRTJX{bvlQTV2-jSF~1e8YbSv7>WpbqC<K)xyAM1smpaul`^_4l1RYQ!
z&8l5;dG;dx@CXiPc&zh8k8(@xlF#wHS;&s|B5ep~8<(r>zM)???pQl;MBKNO93TGG
zXG>O6EgusU|A7M*9;ri>t2T2_jh;;3y4iIy9l7G+rR~O>$W}9bJ1$5fOX>OqfH!ls
zbt%hvZQ@dL$#(v(Cd5A1$;E@u{3Cf!e_M6>ELl8gE7IGBOUE?F8V$JvO%FEstrDB}
z|0*_G57+YIS<)u6=C2^X=lKcG^?~;_-zDkEom1P`(50pwA~wuFA0Z{xcw~ERX!yNK
zY4KwtZ%OY5u~tpJI@jWXjLqgS<8O?QpC($p6l2&CHRlpzNq>cHHHUo;t;~M<L*@nH
z+iwVQ0yf$g#&))9`$t~;7d~~%{piY{)}#^t3nn2vaYeI`0VNX|&+(DE{UdQw3pB^_
z#HIqOYKL5ue(#UD*6zzo9q~?tqZ~~A=431>QOUeBQdx-Av5QlXqHFfy8M1BK;yS&z
zV}mNMq<)w;v(aVik2}BZJMl?uOlqsXkl{u+I_aF>KuBk_di>K}@3fS^whS4PRIyPh
z@LqCAxnNC8Z!$l+&u(blaiW`JI<D8e7&s;Ga(aS-?B+}9=(G|qKm+ICpHqf}u@Zk@
zDs+c${H)?Jbb_)ajIt12-b(MeblCEtvBfg(1bPtLadxt+j|01_%NPO%CkB7LP$*{o
zU7Gw=xXH3)sOSFdJ6;lg?5XR-^j8;YwXnF3TF(-olAe_ed&YcOB#07074lI#SxIb&
z39%w1#VQ-JWDM?EZ+@Ui#S;A7FhI0PGq?XbG?KXmQ=+8$$!Z1>KJ;ogir$YtiT@*a
zh5dNWor;|3+`j_*=%csyEt#c*zvToh1qUwOeMxjyfV@O9HAvM-K{GUqd3gB43TYmO
z?h3_HT=b>Cu@|Vb?etrND|*b6z8T2Sf5E8*8?FZd-}nRC7C{587g+ootn^Ipa6#4v
z8*U2M_^{W9kQ;SdHeYzOI?e%&=wsV76dXcX3wu>EBnfRDV$(!O)YYH%*`U3jp~=7G
z#FQDGG7^+jkl66^(0upCuALU9h>^I~7k|o$>xDM#)Vxk9Onh4)DlGa@mN)RpI&8a_
zgu3hS;q%{>1E-fsmkO(pjdj;<eyn<Pf}B~dQ8@5450$GJ1NTQwQxditXO$H5Q0-Ra
zK*f2(6@l`e`K+-3f4@ui`=i?-Q-fH6hh;H_+wp7Gz{$!yzCh}U02yvXltQ$rrjP7q
zEH}AXeNRu;=Wk=#eY=8u`&hwFnF@2BX<RWJP%v6vMIFxY>+?;|Y1NQE-{i|yME5YH
z-9OKHj*fM3I1t)vTr5MJrSz-Oxw<?>lK&=ENtAd&(TI<Qh9>U$)8wx~&prRTWBy{a
z_zftD+ru3E@c!r6jqjuNT}bIEl*F{^2;XzEKtZwqL(b#piUT7qS4^SXL2dk`BnKjL
zTF|50h!#_(qX|0F@qst5fTbEm)6tkJ7Ag`T7LLzZT&$hDQZjIJ??>=YTB6U;<~(qV
z*~<1e?qS2(reRm)*Rx|4LBXslVl@HQ5U!JWuUy;nTv%BCb0P_BTX~zX2I3=US!pSJ
zo@hhsxFaUjMzBq^z<eV%D<RfLz=$$_4hI)q$jOJXv0PDcF+s+pBMI*JbD-KDYsXZu
zMwjbg>x4fW-c(gzajFse@$ED4)%o1Ql6>}AMH8_l#dvx!tM<(x_ADf}r}NwCizSS;
zY-zXqd|(|C0OX3{g$D-^&ZS#(bJ71`4L}_Xh6R?M;yiqMxfw>fon7+}e*3j&>fteY
zJr&dyhub{XMPM)bgsf8)r5~;m%y0PDK>(;=U~w=f+eET@EPx%=5iM=87^IkAkSi=6
z{)myK#XG=Hs}K&048XL+vJlG&&s7Z@;~~}2__B#`_l)`a?Yi$`xRZG^v)0;3XIu!~
z-uOzJR#wPRX)=l3x;%y}$#9}8=#ph=+W9{E_O;%W2}xq55j*!7*60wtZ3g<sdB}lG
zfoP)^QVi)<=|y)JhMCOw^}l|e=WpH#{kAt&=*UDEmV3VX_Y39(Y|^b@b0@bY-!=A=
zu?w7V35?VF5;DgPEctRXA&ZScT4Pc7fL+v@8=bkDjb4IBho24lf^91eU4Azakl)2x
z>v<+Bu9v$$rN^$NH?FB}qs|2F<jB@tPDX?BW@nu+uaYNHZ`fQ$b@=MkvO0U}c0(3i
zl%n1Ot^W!#v9ROJTH~56ByUavi-&uVa|34ksCx(oFkr{01&U`xYv15#QC~+N&Iw!v
zQz#M6m;Zr12FVv0<h<X^q7G~xlBc;Q7!Q}?Lu*={RU)v072{yb+gq9V^63J*E!wbV
zM?S6Ezy0fFm1zvHoLBy~8d;zomn<G?`>OG1SB3X?54tBg9~eoVW<ih9VsMmKlsFp5
z8Ci)oCPq<Hem9&Z|J{h)xiqSdxE%YtA{=s^o(R0LWa-vQL~5RXJR?eM2dgjP`DWc_
zw7L}xr%k3I>^duYN7}VvWVUE|=X~-<auh4_oS(Ql%9YVYi#UjTu!fir4MRQ0ZC}PQ
z%v&IvJdmMSdO2OCqjuizVGjg1A8kJA({i%t$y{$}W=w5@DY6O@8vaU8MvDwyUsUg=
z=wkuM$c+UkMl|&Wt(7311e9Ack9)CDQ^pi(Jve5ZmM#355S^ikoIecLuU(8ucxY~O
z?NpFuU|^&?w@oU2a;2dNKLyB4i=W`9P%JHb^A!W~x_=Upy4uuDsAY#A5vm81-t3LS
zj~LwF>Et?X4b~xo^4>p-dB2hyKBt_3^6V&tB#<PmI#o5l{1_sEQ;Pq%J~W@Zl95N)
zZ4^jYI0fS1CNex1$A*s7&FfS{Sj2}Dva=)s{c16tUi&jyXu>6mdY^t)TN!yL4)&e<
zkgj_!AX{EV!^*1)cA4`Ct-Ufdl!kt>0)4^>|3Lafq7-yn2QW#Rzy}-R(UCGlQOXAf
z*kJ9J6-c(jepJ-nTY4%!?O*iz(B2mIow9Iy5PYJZO|NusSD$Jwe7@Zzeera=_=gj(
z?sMUI3DCQbPU$zgB&N7`8Y*GoKRDHRbS=0M`&9&fUqC<0H&G-M;-Yq}Kg(j`yqXPE
z>it5`TLM4>r(JlA3A>z_yLIh~FBIO6TL>iZ3BWJ-Pe8&#&^%6_<CdZMW@#nf>1jJI
z<7k=8FXYq%x(B5^N}BIXr2Z(a+v)*Yk=}XwKs{~>!w8+mi9Smu+-JWe+;$1Bj81A|
zfZLS}I3EYxmS54s?^?+}DHvIPo0lr1VPXc{)b|UqH99=~nkV3+Swdwnv>`z$6(beI
zB_t}}S`#&eI^2MLha#}we=YJ#Rf>v5R?R`rA>a6z_?TO+#k=L$;azgpEep$>$C?dw
z&ai9^tX>x5X(@kXG@H(KZczrDip3X;5|>C5o3q}w4tMu5kIF3RTmt00lRV-9o4w%Z
z?W)(3D>oX1&EAyOnv!q&6VC2;?q+scGKB8C<ipALlHRYZZl{da?>SplW*24Xc26iS
zr;p%xWDyrJq8q+C!B{#pIk*Pvg%7`)O-?%>nT5nz^~|Rh1PMJ|gA6~%lr(LmK>Yu(
zi<X^wUxb?<E+}}v)gS8{&c=N8D0~8wh+%_^<QI`twwBbx3a8896UiZNYe|6*pzy^$
z^?y6S8D8WLC^B0l{t~*XFWUqRs}Vgbvb1o@5xLE^5#Q77^1lcXvq21>qi6RPFKDZn
z@Euks?-v0_nrqfQkiQe$RQ%mWbNXvoAt;?~4rlLu^HK%0*Y*#XQ%3xU59Z>7yhY)M
zANb~rli4iRoSPs%BJA>1da~xNOl8LQb+naUG&9-<s$|`{>6FI`+`fNv`9^4yq?4->
z-xnw0Pp@?6pwqEhc(M<&TUK-E*|$0khZCpchzA90H(K0LsOsdUwwLTU6zoQvH_T2a
z5|IRPI{qk!@GYPY*9LlId1QO!co?hXW=woVkzLwG*!ux9m7-$7+JG}lZHPb|`EgXo
z&TB+D|A1bamQwxjx7)<RNdk#_RHj9XmZkKuko(DrUD)Xwf+3@AS-LwHrh6IVsW~<<
z5!<d}T;g{HVtlxqQn6=Y+Up%l3#>h#?Lb<a=$qpK=S0t^070q&V1MbJj<10-Imngk
zr?!~}WKZp-lLp6)d9FIQUg((La=x)md33H!DEG8KV(8c=kePeByA(#CtpB2^yQo{g
zY(jM=me7S)>Z2Lepv&bcHzkMqudC&>z`4#tS)W#+xe!q4wb@2oe@#Q%Yzj8_EgxnB
z1A6t?6TCn+cxiD1=~H|}oBFrEeV0E#cs8;a@kl?y^u75*hk~?Oh!ip;ZJHYk>_atX
z>E+}0-I+YDHhC;rRepa*lnONWv_1Rvrj*^D{h-Pc!$uFZQF+7EIf_mbBDPXUBnf@!
zu-v^i8;(?xu&64FN$AT7@G~8^Acjp9M>_qekNbKQNc=}Kb(`g{ch}`eqJ4W2h03qh
z60`-SYi-=|9=93fh_N>n1OF|32WgdWP|Rzl?s-m~`K;C!tZ~wneA>Y?spRLF07#WD
z-~1oi(<0*W@XmjE*obrFaS2~#SASgQ2j*x3!>_J~U>LxUYoscYR8@WrccKXZzV$1{
zu)8j*>Ep831(lk^PoL)<NoXBP+{NsHH2^YCNYrfB)lXsd@LJ7GJK2Be=*7zaZp>ao
zu>^6Vgo~-BM=R*<W}~sRWQ9MhL=~3Q!4Jm)z=NvPOWrgXK~u=`(ZpJ`C~fbXj!b`{
zNpVzR_2kcqL-($A4{tk-H}<2kBq3DPr)F2L*j9C8?%Bb00bGbH8o79knfp4Dq`_Zm
zNb%Eq9u6ze9A!0h7laV}Tpb1bzic7d7D~_~s{ghOk^-5~<;gRM=S+`LbPM&_*DCTF
zvPU#Y$=C$RbcH2_I%ixb!lbb7`#VmOXTjqQN<+^C4F+>U6t5<&Jl_f=QhSp~(9}9;
zuM|4i<oy6zC_iiSprsvYOYg#1@)(?D^+a+1PASa-dT&(nkyLMl>x+gmvf707R>J1v
zzyK@3=-YnsmG<e=@2Nz)9tFx0qO0}4AE=$!yEu(inRC=;Veysu84tMcZpoQt<9;Kd
zj8Q1LH>5$Sl{gI#ot)g1b+5q=UrX$R?7zZji4Ksi{42*UC_BS2t(TK}j_Ss-M?(F5
zRV6Gz1E?h8`YiujZN62#^bP{Yj=VfY`>4gy4nyHlcnt1{1VKq$Qk4w0ku~w^A<S?G
z&-+uO7h~T^?LP%RUPn+QQsTouC)rA6*t!;b1??7FNd&0d6aR4$)vP;d%#pMob(M)7
z{OFMD3-mcHq;*vMX<210m-Xgim3S^KsO%DQ^oZN8TvP6I5!?7o<6Ck`i35W3ax}P=
z9xhEcgOtF>(s)y#dT9>Hw~DGTA~(bzH+efHB7foFaF_k{Q7ip}6Ji1+@@Q^cdYmnn
z)HzgK5PP-lw*5T+M5ruHQt;!P!Bn)VklYPz@zVRg+gvz|B$(Ch*Vfllr)=^W03FfQ
zL#&bGPKOqih@`s>0KP+NpI??P=LeuB0wdV+_O-}u<g@<YjgGMHoQf3i_h%yN9)H$;
znAs5tsr&3jp1chFaqoCZzpr|SPLs2P&er+)%fEIH{f;)>bSB4n#R;*}UEp|sqY_x(
z5S(2oWV;V5=5=Qpqr3DzO0tRzS7kN$$~8V5%r^@-h#&=DhR&+jD0_Dx+@g`VGVq7o
z&M1R^ZTxjZ&iLaS-6(-Bj37L@^JFX~o~M#eHKbeWhrg_=5qkSp`bv02(NbjhW3`If
z4jP;PTja0ezjiTZELiMyI1Iw|B6bn>Au*q`h}>M4lqo-{xdH*9@AeoxU1g_^Y{;Gt
z)-xm1lNKr_Uq^(=?Sv@<*u#Tmrk(d5g>WbhL?e}a8U7m1pvp3<v{_=u>PDDaf3<S|
zL2r2cdG;oZ8>KmL=eq<@-n`i=B%i~`s3qY$n1}@^BN6<Jaf^BwE_R7X6~eqqK{3Ua
zbgwZ%L=?kV_&Rf6c&R6ArB;3uKgCxyGN40;Z%HwE&tK7fyzH1u8r`6$Qmo7Y^eW0a
z3a%+FDSdIBb9g^-^;?f%-$^Qqb{dDMoyp}>#Mw8D>113kbWu?d&`?TMj=N5{f_hpK
z^pi4GZl3<SLpYTxLmN@N1Cdo$J`HO<evhRvP#qVoRmsg}Bb6R<`P@27kSs_gt^iru
zcFU9coGYEq)~~futr2rMD-`il#P#v@?@=GG&+f_^`Gbtk2^$*$1S0D_(l$tk-|*3*
zn-$;ZI-l55=y7}&wtI-j_r=9PI9#dvhAJ!?(SwXI8ab?CWYE>d;y>ri*O*EXxnzh~
zvej#gLBs{gIu{r01j%T|Uc@#tuBSIe4-H+`<$^Nt1bA^5Dlk8)0HgH1s4@c*h=_XE
z8W=_<H;2f-Vi6jtR$O``T`@_08Vxy0-s^1mJjpqf2R$(KEbTm`x}sBZh|~b!9rBdk
zXZZ23a$OJ`K{7(w6D#PFI5{N@Ejr7n+`y|&7F|WGPH#Qe=C(RP<OxI=Egz(YN9lX?
z+GY>r;ksg|+R><IKF4uGJdS^O!}X82aO5CJhTC0BGKM*Z|FTSF@7hMAlk)wq4zNO_
zvtzyvtJ_2~_C@8?KUohySjnG-HAh?g7Ln%wg>8ES@ND2I`)-O^0QlK~r-nbM&c(>b
z<^w$?1x8P(Spy^$x2M<V0G^E?`Z;LESFFTnx<3hRgf0~&UJLN=(}y@OcBF0NWUV(d
zPr>&J18B0bIH0HNLom8pip-gFa)DX!*DxTn(M_6zzNs*oK72li3$UxTtvA#@+}G-1
zSZ<;?@99<1uz?N`>F*SS&(E6ow|PO^z?ZoNMBCSC+@KJwzSqfbnX@qf`pY4^w!#1i
z6OWZiCZLw0tk<^QHQkhrps<HcrRez|yzObz*UCAS5c_gFvdOz=Nq>RMkGKICfiXb%
zd_yrf<KTGc^E3Jm{UG>J<B~l$>x0n!%<WL~O%e7%>d#5ipdJE3&8A9rlGRt8(JEuS
z6v%<n<-o?9*$M5=i2q!XgPhH!#sFl(B<cGyI>ybZcX8x}fZ&Hy!>%OR*atIPqrM4O
z_S18$UY1>T;CrFW(p#X7N4U{1KP#j5^R07;r6OrLX*KhC0OqZ-`2c$Q8(}mD24FZ`
zCQVS93ypgM$o2sZY%!?wz}xq4`%?hw8e=!p_Le1^eC6wCHphh@4r%_u+ee_u1b8-;
z;gJzhB+B@f&Guaql8%2f-RdO#@X!@%oBd(v+^A)q6Rb(dqn=Qc6=V2?Qw?wuHb~9o
zOlSDzu<|A%Ta<YF_cvpS;<+Twdy51v94WfDa-3W193=RBoSImK#4=oNAScV}n-UNs
z!*$S@)$Y-~H;pzL>h7qE5u~QLP^?e7k7T`fKJz2p(ub7PCQbH<wLu{1`6DWPJD5;a
zls<<LK7WdB_*D(<r;MLEJUq@lHU=P*X5m$#C~)mCJ;wObg2zX`z$b^~ovz%U3HFDi
zuQ3w&(V874Hp=f=n@^MduwwqmW=i+Y7Qd6wOOrN+XZuWWbb%!(HzPUy2XnW|7&qAE
zi{;ollR5XKNV1^<kD}Htf4%?6h4;{bOJ>opGDJC3{yFILZH*qT+#t{t#i|l~=|v!(
z-XL$Wzob=CG-8<vrH$+v=IzCjqP+J#-D&Sq*>8%l#=tgoxY^8#us!Y7b%GB(hifj6
z{{v^p2JIQX9*GNcAdN$tumfQd)Ob3!9p6V<d$tOSKMa3!Xht0~l8E&79DH9Wy_61c
zChq8;m*CT*yCSOV1W0~EaEuiLx%Wi~lA4hjCt%ib&DgHGA6WjKnH$)i&E8;L5qg$4
z<_?Ydeeu|N#yRgZ_%p#dWU?Dp-GFgk-(T)&zgX#72PhOS@coVGjIR&(6`73yd(R)}
zP9M)I&hW<27#i4rhKLx@Hi^FMPRv&BiA)&HY4BhU<~<Voqf=5n1@ptK$9`SDg&!;U
z77-((9hseA$CO;$tt(fxG*cQVcy+jL^%IQW)EoF=E+Cw|4JLQ5U8wN=4@?>wAP7%c
z3KM`VhEpQkY%d#v?D}>OxR1LetC2T?k?>1P2Eaq2SL$!Nn4>-OL@L!1wc(=5r(<%M
zmNeq=OezrIPe`?8SUCgqdh16`c0-e#5MU1llWr(T=rH_pjNWLGp)3a7<6dn|^Chr(
z0y|HO^EMA{7<qg~&>jNQ-!6=zurKs)0%hII-`&@v3+dyLrgrc}^oO=J=r3;P!l#~s
zwU7Cf(|U$~awGISJ<hJ@Kz#txe>)5Nr0=ni4K&jeq|vuUaflu9Rd|BF5uH(!At{I_
z`$b{NmJ?Ie{uCyaYwYe`)Atw!j45^3_M#5P`?C7)r%$cn9O{rG;h$zUB1Y;Agnjjw
zH*R2PAq;-QI)Xb0oayF<C7Azur$GI=R(p*p0+*UOsxBM^HWWhZzG0%E$Yaundz~M=
zYYt$q{9~P_R*4vW+MxZ}&aiGHo<miNJiW^JhL+mX5vgfS@ZSt~Y4+sT5M3$-fXqBa
zMWygUVKx6u;c6dsWb%B1=0yUU*k5Vm6=KzE&uD5u{z}EGDx$qAfVJpl26t|Oy0J5c
zk@}Ty1-^MJT&UZur-W>W+`eAw36YxqzL=|-V$_VUGmPqru;{%W*zwJhWIQ$CyqyVF
z%!1?uUyWgXyuT-Hm+@^)>Ugj2oO<-D$C<RoU-C40g2co-QoB^G?<9Jm`Ty=b{`Bqk
zrkVZmkIO&h2x1zlmALuqUq{oOrpPEd?ZUsF$+DwHWqk--#5L38x-%H@Zml-#TQ^Tf
zC!d$tSp&)xZgWa<88*e^vV|M>@3>9inP?)1THV}Iti0FUW0R@^H<IN$G~^KZ?4W8n
zWt{+p06Ra1c!~#Q0}59*Mo9o51g$UMPu?)$w%-&F6kR8|85F)i9@{k5CYAm#Klx|v
zh&-V&Ju@mzzsyEhRADf);<xBJ{etK&X(?is1*LjkeO4{@J0o@wR32WngRAQGNqm?a
zZ#U?@M4ZDkA3?m7+vNFW;nO~T0-RXDmO;6Ft@fW$=@5d#`X_5stUICt=?0A#`3hHh
zMjy}_JY*xRKK_f18IB&c68}p1#WSwn@^f67n2CP^>KFrkzjl$lj9MDJb&S=--Kh$L
z5imK?RH7mzl?k>S5cp<tWrpMS8|gL3D#ps5BQ4kIN)eSC%;Aru?T2Vgo2E<XDFae^
zM&~D@($D-jLCfE|FS|XK_B7jTKwqId$u&AWc}2NUT-Y@u=J;j?A>`*T9_wU)X+b7G
zvtOq+QH&QqOTnw^O|4d*Imn#DTm3Z?Im)zjkd{Qaqc2h6s~p&(*u6U;lbq;Jv!yq6
ztIl}3mJZKEIU5tu!)M)yLAX*A`|w@+r11W%UMp`)b7)r|a?Tx~M*(_bWXm!b<_nPu
zr-|nQLA2jn5=JR0%B>TWbnWJ!o~pEd1vM{+3z+mpt|n+T=b%f$NTFa^2U@}SZ|E!e
z<(FXr&a63KQafo8G!BmQFRPd0zsQtmzYew15`p!>8IBEVMkH$Hae})rHTpr}-oM(Y
zUabie%2hYtd}J|U&vb=KabI?>6`Ylws|Ddjn792{r~BWVAmGGsOZ@VJHQs_7Gr!F^
z^fp(0qS~^?-|0!KkO7mbw6_lO7q_}w<Y8&qBFoc6Qp{jHUaC&jYZINn;O){Zz|kyb
zs5r|zD>y4UkJpcaO!{$q1Mk^&>xqolLXQXVuHc^*pgp*Oazz{jIs1|O(fhIcQ`?3!
zS#7Q6XmN02_E&@ph$nXmGF7mXe~2`W_^GKc{KVmO-NnXvsHd{@vf3M_8Le49WkBFj
zpjkhm3(p=l7YM0M%xx~(cE`CNpZ`IGIQC+s;{Co_D2>LXDjT_23*o*6n5Mk9wotfY
z4TwpFh$}qgwzT~LNB_dvcyoV-T#a*wskPm#D`_U|OA)l-G`<l#R{3G7{fHJH3hD=$
ze31}?It23i0`PKR7)1ilS!+y0qAb6TW)0AFdf=^EeXwG&Qns>>eF8X6cxdYaaInH+
zF1qppS5OMjjPS)S>^`;t8TAgBaJt%S8=;V|oy-(2q%p$dz;QTq3=}BVbYa2ncUo1z
zAJf9L^294hFLvDb?d}AyDAm_*OxB885`L&5-G)>rr1xR8!RA-lbX@4-ekZExyp?rE
z4D?;54fito%dMDOU8~TR9%OIx%0+@(v-c)P0L>pJst6e$x^RhMDKOcQl7<>S(*AVA
zH2NpuT9rcJv;I-DXCylGy=%_U40ze(iqf@2Tk&SjC}A9XA5-tf?a)>$!fkHnZ1dRI
zd1FxV9W3#B@ms5-+n|OlWQ+1TN><1H-v#Rv)ez6vsou?X(up7<Xb4flJ}p!c@a`UD
z4ns_}uCvXFqH*Kg#rA*4l`z*f&uvwVE+2J|@8&);YdTUOVt!kV)xwHpfF00m>3>SP
znMY~kf7OgvC!P~qb7&_<M?bUs^TE>nGqBW=Tu}49^F|~Z5xl<`Bs0GN>!vF8Ysf`o
zo4vX|Lc8;@*F%R0hS7}9g&#R!j}E~mxsF9>O}ix&>=;r!_Xx)L$H@}BMC5U}p+Mb~
z=hm?9Rc6FH(DQGw`&PgBbyjyeja?U@s9e~M*q!V!oQ8YKgXl+azaK^ipu5PEv)0X#
zEsJUh9nepor$fZsiEzceEf_wj=|ji4arP0$W1lpjY6`>=?o5>^B+Jzb<6QS8LZR}g
zwFIhGN(5*R?aXcD7Z~Nrj@;DJ>30c0yH{j@PV6I5*Owg+bbR|iRCR+7CWi9UE22#g
zzgX`zq_0IhxAAf$*Mw-%5^dw4&c_Uqb-ZNXFa9d&Ibk<x&Of^Hl8yYlks9A!fAkZ0
z-&fiq;iSid2Z*j1v*28dSK0jjS%_zbLfJ%Ai0UN3?gI*+f-XCDx=R~REf1q&BJQEK
zEj3cuduQt93DGlQ9~H;HYfU6^wfZ>~isT1+_)AMsGGB=_duyuf-r*dvkAfHZrzI=o
zSHN|#A9F#?8G%3G{<O09|E2+OyP9tpd2YX<umN%jqq?@~s+j-Ni7zLuELA0868QfB
DTd86v