Feature/crm migrate

ASC.Web.sln

@@ -87,6 +87,8 @@ Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "ASC.Calendar", "products\AS
 EndProject
 Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "ASC.SsoAuth.Svc", "common\services\ASC.SsoAuth.Svc\ASC.SsoAuth.Svc.csproj", "{6AD828EA-FBA2-4D30-B969-756B3BE78E4E}"
 EndProject
+Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "ASC.CRM.BackgroundTasks", "products\ASC.CRM\BackgroundTasks\ASC.CRM.BackgroundTasks.csproj", "{E52C0E35-A05C-437F-8FF2-3E0AC9F81433}"
+EndProject
 Global
 	GlobalSection(SolutionConfigurationPlatforms) = preSolution
 		Debug|Any CPU = Debug|Any CPU
@@ -245,6 +247,10 @@ Global
 		{6AD828EA-FBA2-4D30-B969-756B3BE78E4E}.Debug|Any CPU.Build.0 = Debug|Any CPU
 		{6AD828EA-FBA2-4D30-B969-756B3BE78E4E}.Release|Any CPU.ActiveCfg = Release|Any CPU
 		{6AD828EA-FBA2-4D30-B969-756B3BE78E4E}.Release|Any CPU.Build.0 = Release|Any CPU
+		{E52C0E35-A05C-437F-8FF2-3E0AC9F81433}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{E52C0E35-A05C-437F-8FF2-3E0AC9F81433}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{E52C0E35-A05C-437F-8FF2-3E0AC9F81433}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{E52C0E35-A05C-437F-8FF2-3E0AC9F81433}.Release|Any CPU.Build.0 = Release|Any CPU
 	EndGlobalSection
 	GlobalSection(SolutionProperties) = preSolution
 		HideSolutionNode = FALSE

build/run/CrmBackgroundTasks.bat

@@ -0,0 +1,2 @@
+echo "RUN ASC.CRM.BackgroundTasks"
+call dotnet run --project ..\..\products\ASC.CRM\BackgroundTasks\ASC.CRM.BackgroundTasks.csproj --no-build --$STORAGE_ROOT=..\..\..\Data --log__dir=..\..\..\Logs --log__name=crm

build/run/CrmServer.bat

@@ -1,2 +1,2 @@
-echo "RUN ASC.CRM"
+echo "RUN ASC.CRM.Server"
 call dotnet run --project ..\..\products\ASC.CRM\Server\ASC.CRM.csproj --no-build --$STORAGE_ROOT=..\..\..\Data --log__dir=..\..\..\Logs --log__name=crm

common/ASC.Api.Core/ASC.Api.Core.csproj

@@ -9,6 +9,10 @@
     <DebugSymbols>false</DebugSymbols>
   </PropertyGroup>
 
+  <ItemGroup>
+    <PackageReference Include="AutoMapper.Extensions.Microsoft.DependencyInjection" Version="8.1.1" />
+  </ItemGroup>
+
   <ItemGroup>
     <ProjectReference Include="..\..\web\ASC.Web.Core\ASC.Web.Core.csproj" />
     <ProjectReference Include="..\ASC.Common\ASC.Common.csproj" />

common/ASC.Api.Core/Convention/ControllerNameAttributeConvention.cs

@@ -0,0 +1,30 @@
+using System;
+using System.Linq;
+
+using Microsoft.AspNetCore.Mvc.ApplicationModels;
+
+namespace ASC.Api.Core.Convention
+{
+    [AttributeUsage(AttributeTargets.Class)]
+    public class ControllerNameAttribute : Attribute
+    {
+        public string Name { get; }
+
+        public ControllerNameAttribute(string name)
+        {
+            Name = name;
+        }
+    }
+
+    public class ControllerNameAttributeConvention : IControllerModelConvention
+    {
+        public void Apply(ControllerModel controller)
+        {
+            var controllerNameAttribute = controller.Attributes.OfType<ControllerNameAttribute>().SingleOrDefault();
+            if (controllerNameAttribute != null)
+            {
+                controller.ControllerName = controllerNameAttribute.Name;
+            }
+        }
+    }
+}

common/ASC.Api.Core/Core/BaseStartup.cs

@@ -1,12 +1,15 @@
-using System.Text.Json.Serialization;
+using System.Reflection;
+using System.Text.Json.Serialization;
 
 using ASC.Api.Core.Auth;
+using ASC.Api.Core.Convention;
 using ASC.Api.Core.Core;
 using ASC.Api.Core.Middleware;
 using ASC.Common;
 using ASC.Common.Caching;
 using ASC.Common.DependencyInjection;
 using ASC.Common.Logging;
+using ASC.Common.Mapping;
 
 using Autofac;
 
@@ -81,13 +84,16 @@ public virtual void ConfigureServices(IServiceCollection services)
             DIHelper.RegisterProducts(Configuration, HostEnvironment.ContentRootPath);
 
             var builder = services.AddMvcCore(config =>
-            {
-                var policy = new AuthorizationPolicyBuilder().RequireAuthenticatedUser().Build();
-                config.Filters.Add(new AuthorizeFilter(policy));
-                config.Filters.Add(new TypeFilterAttribute(typeof(TenantStatusFilter)));
-                config.Filters.Add(new TypeFilterAttribute(typeof(PaymentFilter)));
-                config.Filters.Add(new TypeFilterAttribute(typeof(IpSecurityFilter)));
-                config.Filters.Add(new TypeFilterAttribute(typeof(ProductSecurityFilter)));
+            {
+                config.Conventions.Add(new ControllerNameAttributeConvention());
+
+                var policy = new AuthorizationPolicyBuilder().RequireAuthenticatedUser().Build();
+
+                config.Filters.Add(new AuthorizeFilter(policy));
+                config.Filters.Add(new TypeFilterAttribute(typeof(TenantStatusFilter)));
+                config.Filters.Add(new TypeFilterAttribute(typeof(PaymentFilter)));
+                config.Filters.Add(new TypeFilterAttribute(typeof(IpSecurityFilter)));
+                config.Filters.Add(new TypeFilterAttribute(typeof(ProductSecurityFilter)));
                 config.Filters.Add(new CustomResponseFilterAttribute());
                 config.Filters.Add(new CustomExceptionFilterAttribute());
                 config.Filters.Add(new TypeFilterAttribute(typeof(FormatFilter)));
@@ -108,7 +114,9 @@ public virtual void ConfigureServices(IServiceCollection services)
             if (LogParams != null)
             {
                 LogNLogExtension.ConfigureLog(DIHelper, LogParams);
-            }
+            }
+
+            services.AddAutoMapper(Assembly.GetAssembly(typeof(MappingProfile)));
         }
 
         public virtual void Configure(IApplicationBuilder app, IWebHostEnvironment env)

common/ASC.Common/ASC.Common.csproj

@@ -29,6 +29,7 @@
   <ItemGroup>
     <PackageReference Include="ARSoft.Tools.NetStandard.DXSdata" Version="1.0.0" />
     <PackageReference Include="Autofac.Configuration" Version="6.0.0" />
+    <PackageReference Include="AutoMapper" Version="10.1.1" />
     <PackageReference Include="Confluent.Kafka" Version="1.4.3" />
     <PackageReference Include="Google.Protobuf" Version="3.13.0" />
     <PackageReference Include="Grpc.Tools" Version="2.32.0">

common/ASC.Common/Mapping/IMapFrom.cs

@@ -0,0 +1,34 @@
+/*
+ *
+ * (c) Copyright Ascensio System Limited 2010-2018
+ *
+ * This program is freeware. You can redistribute it and/or modify it under the terms of the GNU 
+ * General Public License (GPL) version 3 as published by the Free Software Foundation (https://www.gnu.org/copyleft/gpl.html). 
+ * In accordance with Section 7(a) of the GNU GPL its Section 15 shall be amended to the effect that 
+ * Ascensio System SIA expressly excludes the warranty of non-infringement of any third-party rights.
+ *
+ * THIS PROGRAM IS DISTRIBUTED WITHOUT ANY WARRANTY; WITHOUT EVEN THE IMPLIED WARRANTY OF MERCHANTABILITY OR
+ * FITNESS FOR A PARTICULAR PURPOSE. For more details, see GNU GPL at https://www.gnu.org/copyleft/gpl.html
+ *
+ * You can contact Ascensio System SIA by email at [email protected]
+ *
+ * The interactive user interfaces in modified source and object code versions of ONLYOFFICE must display 
+ * Appropriate Legal Notices, as required under Section 5 of the GNU GPL version 3.
+ *
+ * Pursuant to Section 7 § 3(b) of the GNU GPL you must retain the original ONLYOFFICE logo which contains 
+ * relevant author attributions when distributing the software. If the display of the logo in its graphic 
+ * form is not reasonably feasible for technical reasons, you must include the words "Powered by ONLYOFFICE" 
+ * in every copy of the program you distribute. 
+ * Pursuant to Section 7 § 3(e) we decline to grant you any rights under trademark law for use of our trademarks.
+ *
+*/
+
+using AutoMapper;
+
+namespace ASC.Common.Mapping
+{
+    public interface IMapFrom<T>
+    {
+        void Mapping(Profile profile) => profile.CreateMap(typeof(T), GetType());
+    }
+}

common/ASC.Common/Mapping/MappingProfile.cs

@@ -0,0 +1,62 @@
+/*
+ *
+ * (c) Copyright Ascensio System Limited 2010-2018
+ *
+ * This program is freeware. You can redistribute it and/or modify it under the terms of the GNU 
+ * General Public License (GPL) version 3 as published by the Free Software Foundation (https://www.gnu.org/copyleft/gpl.html). 
+ * In accordance with Section 7(a) of the GNU GPL its Section 15 shall be amended to the effect that 
+ * Ascensio System SIA expressly excludes the warranty of non-infringement of any third-party rights.
+ *
+ * THIS PROGRAM IS DISTRIBUTED WITHOUT ANY WARRANTY; WITHOUT EVEN THE IMPLIED WARRANTY OF MERCHANTABILITY OR
+ * FITNESS FOR A PARTICULAR PURPOSE. For more details, see GNU GPL at https://www.gnu.org/copyleft/gpl.html
+ *
+ * You can contact Ascensio System SIA by email at [email protected]
+ *
+ * The interactive user interfaces in modified source and object code versions of ONLYOFFICE must display 
+ * Appropriate Legal Notices, as required under Section 5 of the GNU GPL version 3.
+ *
+ * Pursuant to Section 7 § 3(b) of the GNU GPL you must retain the original ONLYOFFICE logo which contains 
+ * relevant author attributions when distributing the software. If the display of the logo in its graphic 
+ * form is not reasonably feasible for technical reasons, you must include the words "Powered by ONLYOFFICE" 
+ * in every copy of the program you distribute. 
+ * Pursuant to Section 7 § 3(e) we decline to grant you any rights under trademark law for use of our trademarks.
+ *
+*/
+
+using System;
+using System.Linq;
+using System.Reflection;
+
+using AutoMapper;
+
+namespace ASC.Common.Mapping
+{
+    public class MappingProfile : Profile
+    {
+        public MappingProfile()
+        {
+            Array.ForEach(AppDomain.CurrentDomain.GetAssemblies(), a => ApplyMappingsFromAssembly(a));
+        }
+
+        private void ApplyMappingsFromAssembly(Assembly assembly)
+        {
+            if (!assembly.GetName().Name.StartsWith("ASC.")) return;
+
+            var types = assembly.GetExportedTypes()
+                .Where(t => t.GetInterfaces().Any(i =>
+                    i.IsGenericType && i.GetGenericTypeDefinition() == typeof(IMapFrom<>)))
+                .ToList();
+
+            foreach (var type in types)
+            {
+                var instance = Activator.CreateInstance(type);
+
+                var methodInfo = type.GetMethod("Mapping")
+                    ?? type.GetInterface("IMapFrom`1").GetMethod("Mapping");
+
+                methodInfo?.Invoke(instance, new object[] { this });
+
+            }
+        }
+    }
+}

config/autofac.products.json

@@ -28,7 +28,7 @@
 	  "instanceScope": "InstancePerLifetimeScope"
     },
     {
-      "type": "ASC.CRM.Configuration.ProductEntryPoint, ASC.CRM",
+      "type": "ASC.Web.CRM.Configuration.ProductEntryPoint, ASC.CRM",
       "services": [
         {
           "type": "ASC.Web.Core.IWebItem, ASC.Web.Core"

config/nlog.config

@@ -20,6 +20,6 @@
   <rules>
     <logger name="ASC.SQL" minlevel="Debug" writeTo="sql" final ="true" />
     <logger name="ASC*" minlevel="Debug" writeTo="web" />
-    <logger name="Microsoft.*" maxlevel="Info" writeTo="web" final="true" />
+    <logger name="Microsoft.*" maxlevel="Debug" writeTo="web" final="true" />
   </rules>
 </nlog>

products/ASC.CRM/BackgroundTasks/ASC.CRM.BackgroundTasks.csproj

@@ -0,0 +1,8 @@
+<Project Sdk="Microsoft.NET.Sdk.Worker">
+  <PropertyGroup>
+    <TargetFramework>net5.0</TargetFramework>
+  </PropertyGroup>
+  <ItemGroup>
+    <ProjectReference Include="..\Server\ASC.CRM.csproj" />
+  </ItemGroup>
+</Project>

products/ASC.CRM/BackgroundTasks/Program.cs

@@ -0,0 +1,93 @@
+using System;
+using System.Collections.Generic;
+using System.IO;
+using System.Threading.Tasks;
+
+using ASC.Common;
+using ASC.Common.Caching;
+using ASC.Common.Logging;
+using ASC.Common.Utils;
+using ASC.ElasticSearch;
+using ASC.Web.CRM.Core.Search;
+
+using Autofac;
+using Autofac.Extensions.DependencyInjection;
+
+using Microsoft.Extensions.Configuration;
+using Microsoft.Extensions.DependencyInjection;
+using Microsoft.Extensions.Hosting;
+using ASC.Common.DependencyInjection;
+
+
+namespace ASC.CRM.BackgroundTasks
+{
+    class Program
+    {
+        public async static Task Main(string[] args)
+        {
+            var host = CreateHostBuilder(args).Build();
+
+            await host.RunAsync();
+        }
+
+        public static IHostBuilder CreateHostBuilder(string[] args) =>
+            Host.CreateDefaultBuilder(args)
+                .UseSystemd()
+                .UseWindowsService()
+                .UseServiceProviderFactory(new AutofacServiceProviderFactory())
+                .ConfigureAppConfiguration((hostContext, config) =>
+                {
+                    var buided = config.Build();
+                    var path = buided["pathToConf"];
+                    if (!Path.IsPathRooted(path))
+                    {
+                        path = Path.GetFullPath(CrossPlatform.PathCombine(hostContext.HostingEnvironment.ContentRootPath, path));
+                    }
+                    config.SetBasePath(path);
+                    var env = hostContext.Configuration.GetValue("ENVIRONMENT", "Production");
+                    config
+                        .AddInMemoryCollection(new Dictionary<string, string>
+                            {
+                                        {"pathToConf", path }
+                            }
+                        )
+                        .AddJsonFile("appsettings.json")
+                        .AddJsonFile($"appsettings.{env}.json", true)
+                        .AddJsonFile($"appsettings.services.json", true)
+                        .AddJsonFile("storage.json")
+                        .AddJsonFile("notify.json")
+                        .AddJsonFile("kafka.json")
+                        .AddJsonFile($"kafka.{env}.json", true)
+                        .AddEnvironmentVariables()
+                        .AddCommandLine(args);
+                })
+                .ConfigureServices((hostContext, services) =>
+                {
+                    services.AddMemoryCache();
+
+                    var diHelper = new DIHelper(services);
+
+                    diHelper.TryAdd(typeof(ICacheNotify<>), typeof(KafkaCache<>));
+
+                    diHelper.RegisterProducts(hostContext.Configuration, hostContext.HostingEnvironment.ContentRootPath);
+
+                    services.AddHostedService<ServiceLauncher>();
+                    diHelper.TryAdd<ServiceLauncher>();
+
+                    LogNLogExtension.ConfigureLog(diHelper, "ASC.Files", "ASC.Feed.Agregator");
+
+                    diHelper.TryAdd<FactoryIndexerCase>();
+                    diHelper.TryAdd<FactoryIndexerContact>();
+                    diHelper.TryAdd<FactoryIndexerContactInfo>();
+                    diHelper.TryAdd<FactoryIndexerDeal>();
+                    diHelper.TryAdd<FactoryIndexerEvents>();
+                    diHelper.TryAdd<FactoryIndexerFieldValue>();
+                    diHelper.TryAdd<FactoryIndexerInvoice>();
+                    diHelper.TryAdd<FactoryIndexerTask>();
+                })
+                .ConfigureContainer<ContainerBuilder>((context, builder) =>
+                {
+                    builder.Register(context.Configuration, true, false, "search.json");
+                });
+    }
+}

products/ASC.CRM/BackgroundTasks/Properties/launchSettings.json

@@ -0,0 +1,27 @@
+{
+  "profiles": {
+    "Kestrel WebServer": {
+      "commandName": "Project",
+      "launchBrowser": false,
+      "environmentVariables": {
+        "$STORAGE_ROOT": "../../../Data",
+        "log__dir": "../../../Logs",
+        "log__name": "crm",
+        "ASPNETCORE_ENVIRONMENT": "Development",
+        "ASPNETCORE_URLS": "http://localhost:5026"
+      }
+    },
+    "WSL 2 : Ubuntu 20.04": {
+      "commandName": "WSL2",
+      "launchBrowser": false,
+      "environmentVariables": {
+        "$STORAGE_ROOT": "../../../Data",
+        "log__dir": "../../../Logs",
+        "log__name": "crm",
+        "ASPNETCORE_ENVIRONMENT": "Development",
+        "ASPNETCORE_URLS": "http://localhost:5026"
+      },
+      "distributionName": "Ubuntu-20.04"
+    }
+  }
+}

products/ASC.CRM/BackgroundTasks/appsettings.json

@@ -0,0 +1,3 @@
+{
+  "pathToConf": "..\\..\\..\\config"
+}