493 lines
14 KiB
C#
493 lines
14 KiB
C#
using System;
|
|
using System.Collections.Generic;
|
|
using System.ComponentModel;
|
|
using System.Linq;
|
|
using System.Text;
|
|
using System.Threading.Tasks;
|
|
using Telegram.Bot;
|
|
using TelegramBotBase.Base;
|
|
using TelegramBotBase.Form;
|
|
using TelegramBotBase.Sessions;
|
|
|
|
namespace TelegramBotBase
|
|
{
|
|
/// <summary>
|
|
/// Bot base class for full Device/Context and Messagehandling
|
|
/// </summary>
|
|
/// <typeparam name="T"></typeparam>
|
|
public class BotBase<T>
|
|
where T : FormBase
|
|
{
|
|
public MessageClient Client { get; set; }
|
|
|
|
/// <summary>
|
|
/// Your TelegramBot APIKey
|
|
/// </summary>
|
|
public String APIKey { get; set; } = "";
|
|
|
|
/// <summary>
|
|
/// List of all running/active sessions
|
|
/// </summary>
|
|
public SessionBase Sessions { get; set; }
|
|
|
|
/// <summary>
|
|
/// Contains System commands which will be available at everytime and didnt get passed to forms, i.e. /start
|
|
/// </summary>
|
|
public List<String> SystemCalls { get; set; }
|
|
|
|
private EventHandlerList __Events = new EventHandlerList();
|
|
|
|
private static object __evSessionBegins = new object();
|
|
|
|
private static object __evMessage = new object();
|
|
|
|
private static object __evSystemCall = new object();
|
|
|
|
public delegate Task SystemCallEventHandler(object sender, SystemCallEventArgs e);
|
|
|
|
private static object __evException = new object();
|
|
|
|
private static object __evUnhandledCall = new object();
|
|
|
|
|
|
/// <summary>
|
|
/// Skips all messages during running (good for big delay updates)
|
|
/// </summary>
|
|
public bool SkipAllMessages { get; set; } = false;
|
|
|
|
/// <summary>
|
|
/// Loggs all messages and sent them to the event handler
|
|
/// </summary>
|
|
public bool LogAllMessages { get; set; } = false;
|
|
|
|
/// <summary>
|
|
/// How often could a form navigate to another (within one user action/call/message)
|
|
/// </summary>
|
|
private const int NavigationMaximum = 10;
|
|
|
|
/// <summary>
|
|
/// Simple start of your Bot with the APIKey
|
|
/// </summary>
|
|
/// <param name="apiKey"></param>
|
|
public BotBase(String apiKey)
|
|
{
|
|
this.APIKey = apiKey;
|
|
|
|
this.Client = new Base.MessageClient(this.APIKey);
|
|
|
|
this.SystemCalls = new List<string>();
|
|
|
|
this.Sessions = new SessionBase();
|
|
this.Sessions.Client = this.Client;
|
|
}
|
|
|
|
/// <summary>
|
|
/// Simple start of your Bot with the APIKey and a proxyAdress
|
|
/// </summary>
|
|
/// <param name="apiKey"></param>
|
|
/// <param name="proxyBaseAddress">i.e. https://127.0.0.1:10000</param>
|
|
public BotBase(String apiKey, System.Net.Http.HttpClient proxy)
|
|
{
|
|
this.APIKey = apiKey;
|
|
|
|
this.Client = new Base.MessageClient(this.APIKey, proxy);
|
|
|
|
this.SystemCalls = new List<string>();
|
|
|
|
this.Sessions = new SessionBase();
|
|
this.Sessions.Client = this.Client;
|
|
}
|
|
|
|
/// <summary>
|
|
/// Simple start of your Bot with the APIKey and a TelegramBotClient instance.
|
|
/// </summary>
|
|
/// <param name="apiKey"></param>
|
|
/// <param name="client"></param>
|
|
public BotBase(String apiKey, TelegramBotClient client)
|
|
{
|
|
this.APIKey = apiKey;
|
|
|
|
this.Client = new Base.MessageClient(this.APIKey, client);
|
|
|
|
this.SystemCalls = new List<string>();
|
|
|
|
this.Sessions = new SessionBase();
|
|
this.Sessions.Client = this.Client;
|
|
}
|
|
|
|
/// <summary>
|
|
/// Simple start of your Bot with the APIKey and a proxyAdress
|
|
/// </summary>
|
|
/// <param name="apiKey"></param>
|
|
/// <param name="proxyBaseAddress">i.e. https://127.0.0.1:10000</param>
|
|
public BotBase(String apiKey, String proxyBaseAddress)
|
|
{
|
|
this.APIKey = apiKey;
|
|
|
|
var url = new Uri(proxyBaseAddress);
|
|
|
|
this.Client = new Base.MessageClient(this.APIKey, url);
|
|
|
|
this.SystemCalls = new List<string>();
|
|
|
|
this.Sessions = new SessionBase();
|
|
this.Sessions.Client = this.Client;
|
|
}
|
|
|
|
/// <summary>
|
|
/// Simple start of your Bot with the APIKey and a proxyAdress
|
|
/// </summary>
|
|
/// <param name="apiKey"></param>
|
|
/// <param name="proxyHost">i.e. 127.0.0.1</param>
|
|
/// <param name="proxyPort">i.e. 10000</param>
|
|
public BotBase(String apiKey, String proxyHost, int proxyPort)
|
|
{
|
|
this.APIKey = apiKey;
|
|
|
|
this.Client = new Base.MessageClient(this.APIKey, proxyHost, proxyPort);
|
|
|
|
this.SystemCalls = new List<string>();
|
|
|
|
this.Sessions = new SessionBase();
|
|
this.Sessions.Client = this.Client;
|
|
}
|
|
|
|
/// <summary>
|
|
/// Start your Bot
|
|
/// </summary>
|
|
public void Start()
|
|
{
|
|
if (this.Client == null)
|
|
return;
|
|
|
|
this.Client.Message += Client_Message;
|
|
this.Client.Action += Client_Action;
|
|
|
|
|
|
this.Client.TelegramClient.StartReceiving();
|
|
}
|
|
|
|
/// <summary>
|
|
/// Stop your Bot
|
|
/// </summary>
|
|
public void Stop()
|
|
{
|
|
if (this.Client == null)
|
|
return;
|
|
|
|
this.Client.TelegramClient.StopReceiving();
|
|
}
|
|
|
|
/// <summary>
|
|
/// Send a message to all active Sessions.
|
|
/// </summary>
|
|
/// <param name="message"></param>
|
|
/// <returns></returns>
|
|
public async Task SentToAll(String message)
|
|
{
|
|
if (this.Client == null)
|
|
return;
|
|
|
|
foreach (var s in this.Sessions.SessionList)
|
|
{
|
|
await this.Client.TelegramClient.SendTextMessageAsync(s.Key, message);
|
|
}
|
|
}
|
|
|
|
private void Client_Message(object sender, MessageResult e)
|
|
{
|
|
if (this.SkipAllMessages)
|
|
return;
|
|
|
|
try
|
|
{
|
|
DeviceSession ds = this.Sessions.GetSession(e.DeviceId);
|
|
e.Device = ds;
|
|
|
|
if (LogAllMessages)
|
|
{
|
|
OnMessage(new MessageIncomeResult(e.DeviceId, ds, e));
|
|
}
|
|
|
|
ds?.OnMessageReceived(new MessageReceivedEventArgs(e.Message));
|
|
|
|
Client_TryMessage(sender, e);
|
|
}
|
|
catch (Telegram.Bot.Exceptions.ApiRequestException ex)
|
|
{
|
|
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
DeviceSession ds = this.Sessions.GetSession(e.DeviceId);
|
|
OnException(new SystemExceptionEventArgs(e.Message.Text, ds?.DeviceId ?? -1, ds, ex));
|
|
}
|
|
}
|
|
|
|
private async void Client_TryMessage(object sender, MessageResult e)
|
|
{
|
|
DeviceSession ds = e.Device;
|
|
if (ds == null)
|
|
{
|
|
ds = await this.Sessions.StartSession<T>(e.DeviceId);
|
|
e.Device = ds;
|
|
|
|
ds.LastMessage = e.Message;
|
|
|
|
OnSessionBegins(new SessionBeginResult(e.DeviceId, ds));
|
|
}
|
|
|
|
ds.LastAction = DateTime.Now;
|
|
ds.LastMessage = e.Message;
|
|
|
|
//Is this a systemcall ?
|
|
if (e.IsSystemCall && this.SystemCalls.Contains(e.SystemCommand))
|
|
{
|
|
var sce = new SystemCallEventArgs(e.SystemCommand, e.SystemCallParameters, e.Message, ds.DeviceId, ds);
|
|
await OnSystemCall(sce);
|
|
|
|
if (sce.Handled)
|
|
return;
|
|
}
|
|
|
|
FormBase activeForm = null;
|
|
|
|
int i = 0;
|
|
|
|
//Should formulars get navigated (allow maximum of 10, to dont get loops)
|
|
do
|
|
{
|
|
i++;
|
|
|
|
//Reset navigation
|
|
ds.FormSwitched = false;
|
|
|
|
activeForm = ds.ActiveForm;
|
|
|
|
//Pre Loading Event
|
|
await activeForm.PreLoad(e);
|
|
|
|
//Send Load event to controls
|
|
await activeForm.LoadControls(e);
|
|
|
|
//Loading Event
|
|
await activeForm.Load(e);
|
|
|
|
//Is Attachment ? (Photo, Audio, Video, Contact, Location, Document)
|
|
if (e.Message.Type == Telegram.Bot.Types.Enums.MessageType.Contact | e.Message.Type == Telegram.Bot.Types.Enums.MessageType.Document | e.Message.Type == Telegram.Bot.Types.Enums.MessageType.Location |
|
|
e.Message.Type == Telegram.Bot.Types.Enums.MessageType.Photo | e.Message.Type == Telegram.Bot.Types.Enums.MessageType.Video | e.Message.Type == Telegram.Bot.Types.Enums.MessageType.Audio)
|
|
{
|
|
await activeForm.SentData(new DataResult(e));
|
|
}
|
|
|
|
//Render Event
|
|
if (!ds.FormSwitched)
|
|
{
|
|
|
|
await activeForm.RenderControls(e);
|
|
|
|
await activeForm.Render(e);
|
|
}
|
|
|
|
|
|
} while (ds.FormSwitched && i < NavigationMaximum);
|
|
|
|
}
|
|
|
|
private void Client_Action(object sender, MessageResult e)
|
|
{
|
|
try
|
|
{
|
|
DeviceSession ds = this.Sessions.GetSession(e.DeviceId);
|
|
e.Device = ds;
|
|
|
|
if (LogAllMessages)
|
|
{
|
|
OnMessage(new MessageIncomeResult(e.DeviceId, ds, e));
|
|
}
|
|
|
|
Client_TryAction(sender, e);
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
DeviceSession ds = this.Sessions.GetSession(e.DeviceId);
|
|
OnException(new SystemExceptionEventArgs(e.Message.Text, ds?.DeviceId ?? -1, ds, ex));
|
|
}
|
|
}
|
|
|
|
private async void Client_TryAction(object sender, MessageResult e)
|
|
{
|
|
DeviceSession ds = e.Device;
|
|
if (ds == null)
|
|
{
|
|
ds = await this.Sessions.StartSession<T>(e.DeviceId);
|
|
e.Device = ds;
|
|
}
|
|
|
|
|
|
ds.LastAction = DateTime.Now;
|
|
ds.LastMessage = e.Message;
|
|
|
|
FormBase activeForm = null;
|
|
|
|
int i = 0;
|
|
|
|
//Should formulars get navigated (allow maximum of 10, to dont get loops)
|
|
do
|
|
{
|
|
i++;
|
|
|
|
//Reset navigation
|
|
ds.FormSwitched = false;
|
|
|
|
activeForm = ds.ActiveForm;
|
|
|
|
//Pre Loading Event
|
|
await activeForm.PreLoad(e);
|
|
|
|
//Send Load event to controls
|
|
await activeForm.LoadControls(e);
|
|
|
|
//Loading Event
|
|
await activeForm.Load(e);
|
|
|
|
//Action Event
|
|
if (!ds.FormSwitched)
|
|
{
|
|
//Send Action event to controls
|
|
await activeForm.ActionControls(e);
|
|
|
|
//Send Action event to form itself
|
|
await activeForm.Action(e);
|
|
|
|
if (!e.Handled)
|
|
{
|
|
var uhc = new UnhandledCallEventArgs(e.Message.Text, e.RawData, ds.DeviceId, e.MessageId, e.Message, ds);
|
|
OnUnhandledCall(uhc);
|
|
|
|
if (uhc.Handled)
|
|
{
|
|
if (ds.FormSwitched)
|
|
{
|
|
continue;
|
|
}
|
|
else
|
|
{
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
|
|
}
|
|
|
|
//Render Event
|
|
if (!ds.FormSwitched)
|
|
{
|
|
await activeForm.RenderControls(e);
|
|
|
|
await activeForm.Render(e);
|
|
}
|
|
|
|
} while (ds.FormSwitched && i < NavigationMaximum);
|
|
|
|
}
|
|
|
|
/// <summary>
|
|
/// Will be called if a session/context gets started
|
|
/// </summary>
|
|
|
|
public event EventHandler<SessionBeginResult> SessionBegins
|
|
{
|
|
add
|
|
{
|
|
this.__Events.AddHandler(__evSessionBegins, value);
|
|
}
|
|
remove
|
|
{
|
|
this.__Events.RemoveHandler(__evSessionBegins, value);
|
|
}
|
|
}
|
|
|
|
public void OnSessionBegins(SessionBeginResult e)
|
|
{
|
|
(this.__Events[__evSessionBegins] as EventHandler<SessionBeginResult>)?.Invoke(this, e);
|
|
|
|
}
|
|
|
|
/// <summary>
|
|
/// Will be called on incomming message
|
|
/// </summary>
|
|
public event EventHandler<MessageIncomeResult> Message
|
|
{
|
|
add
|
|
{
|
|
this.__Events.AddHandler(__evMessage, value);
|
|
}
|
|
remove
|
|
{
|
|
this.__Events.RemoveHandler(__evMessage, value);
|
|
}
|
|
}
|
|
|
|
public void OnMessage(MessageIncomeResult e)
|
|
{
|
|
(this.__Events[__evMessage] as EventHandler<MessageIncomeResult>)?.Invoke(this, e);
|
|
|
|
}
|
|
|
|
/// <summary>
|
|
/// Will be called if a system call gets raised
|
|
/// </summary>
|
|
public event SystemCallEventHandler SystemCall;
|
|
|
|
|
|
public async Task OnSystemCall(SystemCallEventArgs e)
|
|
{
|
|
if (this.SystemCall != null)
|
|
await SystemCall(this, e);
|
|
}
|
|
|
|
/// <summary>
|
|
/// Will be called on an inner exception
|
|
/// </summary>
|
|
public event EventHandler<SystemExceptionEventArgs> Exception
|
|
{
|
|
add
|
|
{
|
|
this.__Events.AddHandler(__evException, value);
|
|
}
|
|
remove
|
|
{
|
|
this.__Events.RemoveHandler(__evException, value);
|
|
}
|
|
}
|
|
|
|
public void OnException(SystemExceptionEventArgs e)
|
|
{
|
|
(this.__Events[__evException] as EventHandler<SystemExceptionEventArgs>)?.Invoke(this, e);
|
|
|
|
}
|
|
|
|
/// <summary>
|
|
/// Will be called if no form handeled this call
|
|
/// </summary>
|
|
public event EventHandler<UnhandledCallEventArgs> UnhandledCall
|
|
{
|
|
add
|
|
{
|
|
this.__Events.AddHandler(__evUnhandledCall, value);
|
|
}
|
|
remove
|
|
{
|
|
this.__Events.RemoveHandler(__evUnhandledCall, value);
|
|
}
|
|
}
|
|
|
|
public void OnUnhandledCall(UnhandledCallEventArgs e)
|
|
{
|
|
(this.__Events[__evUnhandledCall] as EventHandler<UnhandledCallEventArgs>)?.Invoke(this, e);
|
|
|
|
}
|
|
}
|
|
}
|