90 lines
3.4 KiB
C#
90 lines
3.4 KiB
C#
using System;
|
|
using System.Collections.Generic;
|
|
using System.Linq;
|
|
using System.Runtime.InteropServices;
|
|
using System.Text;
|
|
using System.Text.RegularExpressions;
|
|
using System.Threading.Tasks;
|
|
using Telegram.Bot;
|
|
using Telegram.Bot.Exceptions;
|
|
using Telegram.Bot.Polling;
|
|
using Telegram.Bot.Types;
|
|
using Telegram.Bot.Types.Enums;
|
|
namespace SignalsTest
|
|
{
|
|
public class Messenger
|
|
{
|
|
|
|
TelegramBotClient botClient;
|
|
|
|
private static Messenger m_instance;
|
|
public static Messenger instance { get { if (m_instance == null) { m_instance = new Messenger(); } return m_instance; } }
|
|
|
|
public const string chatId = "@doralockscryptosignals";
|
|
public const string chatId_test = "@SignalTestPrivate";
|
|
|
|
public List<MessageQueueItem> messagesSchedule = new List<MessageQueueItem>();
|
|
|
|
public void ScheduleMessage(string text, string symbol="", string interval=""){
|
|
messagesSchedule.Add(new MessageQueueItem(){
|
|
symbol = symbol,
|
|
interval=interval,
|
|
text=text
|
|
});
|
|
}
|
|
|
|
public async void InitializeScheduler(){
|
|
string _chatId = RuntimeInformation.IsOSPlatform(OSPlatform.Windows) ? chatId_test : chatId;
|
|
|
|
while(true){
|
|
await Task.Delay(1500);
|
|
|
|
if(messagesSchedule.Count <=0){
|
|
continue;
|
|
}
|
|
|
|
MessageQueueItem queueItem = messagesSchedule[0];
|
|
string message = queueItem.text;
|
|
string filename = queueItem.filename;
|
|
string symbol = queueItem.symbol;
|
|
try{
|
|
if(symbol.Length < 2){
|
|
await botClient.SendTextMessageAsync(_chatId, message);
|
|
}else{
|
|
FileStream fsSource = new FileStream(filename, FileMode.Open, FileAccess.Read);
|
|
InputFile photo = InputFile.FromStream(fsSource);
|
|
string url = $"https://www.tradingview.com/chart/?symbol=BINANCE%3A{symbol}";
|
|
// string formattedMessage = message.Replace($"`{filename}`", $"`{filename}`[Trading View]({url})");
|
|
string formattedMessage = message.Replace(
|
|
$"`{symbol}`",
|
|
$"<a href=\"{url}\">{symbol}</a>"
|
|
);
|
|
await botClient.SendPhotoAsync(_chatId, photo,caption: formattedMessage,parseMode: ParseMode.Html);
|
|
}
|
|
|
|
messagesSchedule.Remove(queueItem);
|
|
}catch(Exception e){
|
|
Console.WriteLine($"Error occured while sending {message} to {filename}");
|
|
Console.WriteLine(e.ToString());
|
|
}
|
|
await Task.Delay(1500);
|
|
|
|
}
|
|
}
|
|
|
|
public Messenger()
|
|
{
|
|
botClient = new TelegramBotClient(Secrets.TELEGRAM_BOT_TOKEN);
|
|
using CancellationTokenSource cts = new();
|
|
|
|
// StartReceiving does not block the caller thread. Receiving is done on the ThreadPool.
|
|
ReceiverOptions receiverOptions = new()
|
|
{
|
|
AllowedUpdates = Array.Empty<UpdateType>() // receive all update types except ChatMember related updates
|
|
};
|
|
|
|
InitializeScheduler();
|
|
}
|
|
}
|
|
}
|