140 lines
4.8 KiB
C#
140 lines
4.8 KiB
C#
/*
|
|
*
|
|
* (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 sales@onlyoffice.com
|
|
*
|
|
* 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.Collections.Generic;
|
|
using System.Reflection;
|
|
|
|
using ASC.Common;
|
|
using ASC.Core.Notify.Senders;
|
|
|
|
using Microsoft.Extensions.Options;
|
|
|
|
namespace ASC.Notify.Config
|
|
{
|
|
[Singletone]
|
|
public class ConfigureNotifyServiceCfg : IConfigureOptions<NotifyServiceCfg>
|
|
{
|
|
public ConfigureNotifyServiceCfg(IServiceProvider serviceProvider)
|
|
{
|
|
ServiceProvider = serviceProvider;
|
|
}
|
|
|
|
private IServiceProvider ServiceProvider { get; }
|
|
|
|
public void Configure(NotifyServiceCfg options)
|
|
{
|
|
options.Init(ServiceProvider);
|
|
}
|
|
}
|
|
|
|
[Singletone(typeof(ConfigureNotifyServiceCfg))]
|
|
public class NotifyServiceCfg
|
|
{
|
|
public string ConnectionStringName { get; set; }
|
|
public int StoreMessagesDays { get; set; }
|
|
public string ServerRoot { get; set; }
|
|
public NotifyServiceCfgProcess Process { get; set; }
|
|
public List<NotifyServiceCfgSender> Senders { get; set; }
|
|
public List<NotifyServiceCfgScheduler> Schedulers { get; set; }
|
|
|
|
public void Init(IServiceProvider serviceProvider)
|
|
{
|
|
ServerRoot = string.IsNullOrEmpty(ServerRoot) ? "http://*/" : ServerRoot;
|
|
|
|
Process.Init();
|
|
|
|
foreach (var s in Senders)
|
|
{
|
|
try
|
|
{
|
|
s.Init(serviceProvider);
|
|
}
|
|
catch (Exception)
|
|
{
|
|
|
|
}
|
|
}
|
|
foreach (var s in Schedulers)
|
|
{
|
|
try
|
|
{
|
|
s.Init();
|
|
}
|
|
catch (Exception)
|
|
{
|
|
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
public class NotifyServiceCfgProcess
|
|
{
|
|
public int MaxThreads { get; set; }
|
|
public int BufferSize { get; set; }
|
|
public int MaxAttempts { get; set; }
|
|
public string AttemptsInterval { get; set; }
|
|
|
|
public void Init()
|
|
{
|
|
if (MaxThreads == 0)
|
|
{
|
|
MaxThreads = Environment.ProcessorCount;
|
|
}
|
|
}
|
|
}
|
|
|
|
public class NotifyServiceCfgSender
|
|
{
|
|
public string Name { get; set; }
|
|
public string Type { get; set; }
|
|
public Dictionary<string, string> Properties { get; set; }
|
|
public INotifySender NotifySender { get; set; }
|
|
|
|
public void Init(IServiceProvider serviceProvider)
|
|
{
|
|
var sender = (INotifySender)serviceProvider.GetService(System.Type.GetType(Type, true));
|
|
sender.Init(Properties);
|
|
NotifySender = sender;
|
|
}
|
|
}
|
|
|
|
public class NotifyServiceCfgScheduler
|
|
{
|
|
public string Name { get; set; }
|
|
public string Register { get; set; }
|
|
public MethodInfo MethodInfo { get; set; }
|
|
|
|
public void Init()
|
|
{
|
|
var typeName = Register.Substring(0, Register.IndexOf(','));
|
|
var assemblyName = Register.Substring(Register.IndexOf(','));
|
|
var type = Type.GetType(typeName.Substring(0, typeName.LastIndexOf('.')) + assemblyName, true);
|
|
MethodInfo = type.GetMethod(typeName.Substring(typeName.LastIndexOf('.') + 1), BindingFlags.Static | BindingFlags.NonPublic | BindingFlags.Public);
|
|
}
|
|
}
|
|
}
|