Compare commits

...

18 Commits

Author SHA1 Message Date
Florian Zevedei
98199f2e9b Adding additional intellisense documentation to refurbished Json serialization 2024-12-02 01:57:14 +01:00
Florian Zevedei
9146788ab0 Adding new legacy nuget package to recover old session serialization method 2024-12-02 01:56:32 +01:00
Florian Zevedei
d72ee38349 Adding null checks to StopReceiving methods of clients 2024-11-18 02:47:20 +01:00
Florian Zevedei
667ca5ba6c Updating json serializer to fit System.Text.Json 2024-11-09 16:04:42 +01:00
Florian Zevedei
19d8a23b98 Adding IDeviceSession fixes to extension projects 2024-10-15 15:36:14 +02:00
Florian Zevedei
db5dd7862c Adding IDeviceSession and IDeviceSessionMethods Interface 2024-10-15 15:32:32 +02:00
Florian Zevedei
bc1f1fc93d Updating source generator to add method optional parameters 2024-10-15 15:28:44 +02:00
Florian Zevedei
4f23c85d16 Replace old framework versions in image library 2024-10-14 01:53:15 +02:00
Florian Zevedei
b37b1e2a64 Preparation for version switch from 19 to 21 2024-10-14 01:45:46 +02:00
Florian Zevedei
fb88d15485 Marking V19 GroupForm as obsolete for future updates
- and adding V21 version as well (as in alpha)
2024-10-14 01:43:42 +02:00
Florian Zevedei
06d4fda9a4 Removing old json serilization in test project 2024-10-14 01:42:46 +02:00
Florian Zevedei
0e8e96f2d8 Replacing Newtonsoft.Json with System.Text.Json (experimental) 2024-09-25 16:56:03 +02:00
Florian Zevedei
f21dec5f1c Making xml property static 2024-07-15 23:50:56 +02:00
Florian Zevedei
a1c4629351 Adding xml loader to source generator to add comments from nuget package 2024-07-15 18:51:30 +02:00
Florian Zevedei
9bdea52df9 Changing comments 2024-07-12 14:04:50 +02:00
Florian Zevedei
80eecabda4 Fixing incorrect formatting (indention) 2024-07-12 14:04:30 +02:00
Florian Zevedei
9f16cb4969 Adding source generator to add all API methods to the DeviceSession 2024-07-11 21:13:54 +02:00
Florian Zevedei
eaa742e7df Adding .NET 8 to target frameworks 2024-07-11 21:13:14 +02:00
43 changed files with 16641 additions and 80 deletions

View File

@ -4,6 +4,7 @@ using System.IO;
using System.Threading.Tasks;
using Telegram.Bot.Types;
using TelegramBotBase.Form;
using TelegramBotBase.Interfaces;
using TelegramBotBase.Sessions;
using static IronSoftware.Drawing.AnyBitmap;
using SKImage = SixLabors.ImageSharp.Image;
@ -37,7 +38,7 @@ namespace TelegramBotBase.Extensions.Images.IronSoftware
/// <param name="replyTo"></param>
/// <param name="disableNotification"></param>
/// <returns></returns>
public static async Task<Message> SendPhoto(this DeviceSession session, AnyBitmap image, string name,
public static async Task<Message> SendPhoto(this IDeviceSession session, AnyBitmap image, string name,
string caption, ButtonForm buttons = null, int replyTo = 0,
bool disableNotification = false)
{
@ -58,7 +59,7 @@ namespace TelegramBotBase.Extensions.Images.IronSoftware
/// <param name="replyTo"></param>
/// <param name="disableNotification"></param>
/// <returns></returns>
public static async Task<Message> SendPhoto(this DeviceSession session, SKImage image, string name,
public static async Task<Message> SendPhoto(this IDeviceSession session, SKImage image, string name,
string caption, ButtonForm buttons = null, int replyTo = 0,
bool disableNotification = false)
{

View File

@ -1,7 +1,7 @@
<Project Sdk="Microsoft.NET.Sdk">
<PropertyGroup>
<TargetFrameworks>netstandard2.0;netcoreapp3.1;net6</TargetFrameworks>
<TargetFrameworks>netcoreapp3.1;net6</TargetFrameworks>
<RepositoryUrl>https://github.com/MajMcCloud/TelegramBotFramework/tree/development/TelegramBotBase.Extensions.Images.IronSoftware</RepositoryUrl>
<PackageProjectUrl>https://github.com/MajMcCloud/TelegramBotFramework/tree/development/TelegramBotBase.Extensions.Images.IronSoftware</PackageProjectUrl>
<Copyright>MIT</Copyright>
@ -19,11 +19,14 @@
<PrivateAssets>all</PrivateAssets>
<IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>
</PackageReference>
<PackageReference Include="TelegramBotBase" Version="6.0.0" />
</ItemGroup>
<ItemGroup>
<Folder Include="Properties\" />
</ItemGroup>
<ItemGroup>
<ProjectReference Include="..\TelegramBotBase\TelegramBotBase.csproj" />
</ItemGroup>
</Project>

View File

@ -4,7 +4,7 @@ using System.IO;
using System.Threading.Tasks;
using Telegram.Bot.Types;
using TelegramBotBase.Form;
using TelegramBotBase.Sessions;
using TelegramBotBase.Interfaces;
namespace TelegramBotBase.Extensions.Images
{
@ -27,7 +27,7 @@ namespace TelegramBotBase.Extensions.Images
/// <param name="replyTo"></param>
/// <param name="disableNotification"></param>
/// <returns></returns>
public static async Task<Message> SendPhoto(this DeviceSession session, Image image, string name,
public static async Task<Message> SendPhoto(this IDeviceSession session, Image image, string name,
string caption, ButtonForm buttons = null, int replyTo = 0,
bool disableNotification = false)
{
@ -48,7 +48,7 @@ namespace TelegramBotBase.Extensions.Images
/// <param name="replyTo"></param>
/// <param name="disableNotification"></param>
/// <returns></returns>
public static async Task<Message> SendPhoto(this DeviceSession session, Bitmap image, string name,
public static async Task<Message> SendPhoto(this IDeviceSession session, Bitmap image, string name,
string caption, ButtonForm buttons = null, int replyTo = 0,
bool disableNotification = false)
{

View File

@ -1,7 +1,7 @@
<Project Sdk="Microsoft.NET.Sdk">
<PropertyGroup>
<TargetFrameworks>netstandard2.0;netcoreapp3.1;net6</TargetFrameworks>
<TargetFrameworks>netcoreapp3.1;net6;net7;net8</TargetFrameworks>
<RepositoryUrl>https://github.com/MajMcCloud/TelegramBotFramework/tree/development/TelegramBotBase.Extensions.Images</RepositoryUrl>
<PackageProjectUrl>https://github.com/MajMcCloud/TelegramBotFramework/tree/development/TelegramBotBase.Extensions.Images</PackageProjectUrl>
<Copyright>MIT</Copyright>
@ -21,11 +21,14 @@
<IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>
</PackageReference>
<PackageReference Include="System.Drawing.Common" Version="6.0.0" />
<PackageReference Include="TelegramBotBase" Version="6.0.0" />
</ItemGroup>
<ItemGroup>
<Folder Include="Properties\" />
</ItemGroup>
<ItemGroup>
<ProjectReference Include="..\TelegramBotBase\TelegramBotBase.csproj" />
</ItemGroup>
</Project>

View File

@ -0,0 +1,41 @@
using System;
using System.IO;
using TelegramBotBase.Builder;
using TelegramBotBase.Builder.Interfaces;
namespace TelegramBotBase.Extensions.Serializer.Legacy.NewtonsoftJson
{
public static class BotBaseBuilderExtensions
{
/// <summary>
/// Using the complex version of .Net JSON, which can serialize all objects.
/// Saves in application directory.
/// </summary>
/// <param name="path"></param>
/// <returns></returns>
public static ILanguageSelectionStage UseNewtonsoftJson(this ISessionSerializationStage builder)
{
var path = Path.Combine(Directory.GetCurrentDirectory(), "states.json");
builder.UseNewtonsoftJson(path);
return builder as BotBaseBuilder;
}
/// <summary>
/// Using the complex version of .Net JSON, which can serialize all objects.
/// Saves in application directory.
/// </summary>
/// <param name="path"></param>
/// <returns></returns>
public static ILanguageSelectionStage UseNewtonsoftJson(this ISessionSerializationStage builder, String path)
{
var _stateMachine = new NewtonsoftJsonStateMachine(path);
builder.UseSerialization(_stateMachine);
return builder as BotBaseBuilder;
}
}
}

View File

@ -0,0 +1,94 @@
using System;
using System.Data;
using System.IO;
using Newtonsoft.Json;
using TelegramBotBase.Args;
using TelegramBotBase.Base;
using TelegramBotBase.Form;
using TelegramBotBase.Interfaces;
namespace TelegramBotBase.Extensions.Serializer.Legacy.NewtonsoftJson
{
/// <summary>
/// Is used for all complex data types. Use if other default machines are not working.
/// </summary>
public class NewtonsoftJsonStateMachine : IStateMachine
{
/// <summary>
/// Will initialize the state machine.
/// </summary>
/// <param name="file">Path of the file and name where to save the session details.</param>
/// <param name="fallbackStateForm">
/// Type of Form which will be saved instead of Form which has
/// <seealso cref="Attributes.IgnoreState" /> attribute declared. Needs to be subclass of
/// <seealso cref="Form.FormBase" />.
/// </param>
/// <param name="overwrite">Declares of the file could be overwritten.</param>
public NewtonsoftJsonStateMachine(string file, Type fallbackStateForm = null, bool overwrite = true)
{
FallbackStateForm = fallbackStateForm;
if (FallbackStateForm != null && !FallbackStateForm.IsSubclassOf(typeof(FormBase)))
{
throw new ArgumentException($"{nameof(FallbackStateForm)} is not a subclass of {nameof(FormBase)}");
}
FilePath = file ?? throw new ArgumentNullException(nameof(file));
Overwrite = overwrite;
}
public string FilePath { get; set; }
public bool Overwrite { get; set; }
public Type FallbackStateForm { get; }
public StateContainer LoadFormStates()
{
try
{
var content = File.ReadAllText(FilePath);
var sc = JsonConvert.DeserializeObject<StateContainer>(content, new JsonSerializerSettings
{
TypeNameHandling = TypeNameHandling.All,
TypeNameAssemblyFormatHandling = TypeNameAssemblyFormatHandling.Simple
});
return sc;
}
catch
{
}
return new StateContainer();
}
public void SaveFormStates(SaveStatesEventArgs e)
{
if (File.Exists(FilePath))
{
if (!Overwrite)
{
throw new Exception("File exists already.");
}
File.Delete(FilePath);
}
try
{
var content = JsonConvert.SerializeObject(e.States, Formatting.Indented, new JsonSerializerSettings
{
TypeNameHandling = TypeNameHandling.All,
TypeNameAssemblyFormatHandling = TypeNameAssemblyFormatHandling.Simple
});
File.WriteAllText(FilePath, content);
}
catch
{
}
}
}
}

View File

@ -0,0 +1,31 @@
# TelegramBotBase.Extensions.Serializer.Legacy.NewtonsoftJson
[![NuGet version (TelegramBotBase)](https://img.shields.io/nuget/v/TelegramBotBase.Extensions.Serializer.Legacy.NewtonsoftJson.svg?style=flat-square)](https://www.nuget.org/packages/TelegramBotBase.Extensions.Serializer.Legacy.NewtonsoftJson/)
[![Telegram chat](https://img.shields.io/badge/Support_Chat-Telegram-blue.svg?style=flat-square)](https://www.t.me/tgbotbase)
[![License](https://img.shields.io/github/license/MajMcCloud/telegrambotframework.svg?style=flat-square&maxAge=2592000&label=License)](https://raw.githubusercontent.com/MajMcCloud/TelegramBotFramework/master/LICENCE.md)
[![Package Downloads](https://img.shields.io/nuget/dt/TelegramBotBase.Extensions.Serializer.Legacy.NewtonsoftJson.svg?style=flat-square&label=Package%20Downloads)](https://www.nuget.org/packages/TelegramBotBase.Extensions.Serializer.Legacy.NewtonsoftJson)
### Legacy version to recover with old dependencies using Newtonsoft.Json for session serialization
## How to use
```csharp
using TelegramBotBase.Extensions.Serializer.Legacy.NewtonsoftJson;
var bot = BotBaseBuilder
.Create()
.WithAPIKey(APIKey)
.DefaultMessageLoop()
.WithStartForm<Start>()
.NoProxy()
.OnlyStart()
.UseNewtonsoftJson()
.UseEnglish()
.Build();
bot.Start();
```

View File

@ -0,0 +1,27 @@
<Project Sdk="Microsoft.NET.Sdk">
<PropertyGroup>
<TargetFrameworks>netstandard2.0;netcoreapp3.1;net6;net7;net8;net9</TargetFrameworks>
<GeneratePackageOnBuild>True</GeneratePackageOnBuild>
<RepositoryUrl>https://github.com/MajMcCloud/TelegramBotFramework</RepositoryUrl>
<PackageProjectUrl>https://github.com/MajMcCloud/TelegramBotFramework</PackageProjectUrl>
<Copyright>MIT</Copyright>
<IncludeSymbols>true</IncludeSymbols>
<SymbolPackageFormat>snupkg</SymbolPackageFormat>
<AssemblyVersion>1.0.1</AssemblyVersion>
<FileVersion>1.0.1</FileVersion>
<Version>1.0.1</Version>
<Description>A session serializer for Newtonsoft Json.
</Description>
</PropertyGroup>
<ItemGroup>
<PackageReference Include="Microsoft.SourceLink.GitHub" Version="1.1.1">
<PrivateAssets>all</PrivateAssets>
<IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>
</PackageReference>
<PackageReference Include="Newtonsoft.Json" Version="13.0.3" />
<PackageReference Include="TelegramBotBase" Version="6.0.0" />
</ItemGroup>
</Project>

File diff suppressed because it is too large Load Diff

View File

@ -0,0 +1,25 @@
<Project Sdk="Microsoft.NET.Sdk">
<PropertyGroup>
<TargetFramework>netstandard2.0</TargetFramework>
<ImplicitUsings>disable</ImplicitUsings>
<Nullable>enable</Nullable>
<EnforceExtendedAnalyzerRules>true</EnforceExtendedAnalyzerRules>
<OutputItemType>Analyzer</OutputItemType>
<GeneratePackageOnBuild>false</GeneratePackageOnBuild>
<LangVersion>latest</LangVersion>
</PropertyGroup>
<ItemGroup>
<EmbeddedResource Include="Resources\Telegram.Bot.xml" />
</ItemGroup>
<ItemGroup>
<PackageReference Include="Microsoft.CodeAnalysis.Analyzers" Version="3.3.4">
<PrivateAssets>all</PrivateAssets>
<IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>
</PackageReference>
<PackageReference Include="Microsoft.CodeAnalysis.CSharp" Version="4.10.0" />
</ItemGroup>
</Project>

View File

@ -0,0 +1,251 @@
using System;
using System.Collections.Generic;
using System.Diagnostics;
using System.IO;
using System.Linq;
using System.Reflection;
using System.Reflection.Metadata;
using System.Resources;
using System.Security.Cryptography.X509Certificates;
using System.Text;
using Microsoft.CodeAnalysis;
using Microsoft.CodeAnalysis.CSharp;
using Microsoft.CodeAnalysis.CSharp.Syntax;
using Microsoft.CodeAnalysis.Text;
using TelegramBotBase.SourceGenerators;
namespace TelegramBotBase
{
[Generator(LanguageNames.CSharp)]
public class TelegramDeviceExtensionGenerator : IIncrementalGenerator
{
static XmlDocumentationLoader xml;
public void Initialize(IncrementalGeneratorInitializationContext context)
{
var provider = context.SyntaxProvider.CreateSyntaxProvider(
predicate: (c, _) => c is ClassDeclarationSyntax,
transform: (n, _) => (ClassDeclarationSyntax)n.Node)
.Where(a => a is not null);
var compilation = context.CompilationProvider;
context.RegisterSourceOutput(compilation, (spc, source) => Execute(spc, source));
}
private void Execute(SourceProductionContext context, Compilation compilation)
{
//if (!Debugger.IsAttached) Debugger.Launch();
StringBuilder sb = new StringBuilder();
sb.AppendLine();
//Search for reference library
var telegram_package = compilation.References.FirstOrDefault(a => a.Display != null && a.Display.Contains("Telegram.Bot"));
if (telegram_package == null)
return;
//Load only once
if (xml == null)
{
xml = new XmlDocumentationLoader();
xml.ReadEmbeddedXml("Telegram.Bot.xml");
}
var assemblySymbol = compilation.GetAssemblyOrModuleSymbol(telegram_package) as IAssemblySymbol;
if (assemblySymbol == null)
return;
if (assemblySymbol.Name != "Telegram.Bot")
return;
//Get class which includes the existing methods
var apiClass = assemblySymbol.GetTypeByMetadataName("Telegram.Bot.TelegramBotClientExtensions");
if (apiClass == null)
return;
//Get existing list of methods
var methods = apiClass.GetMembers().OfType<IMethodSymbol>().ToList();
foreach (var method in methods)
{
if (!method.Parameters.Any(a => a.Type.Name == "ITelegramBotClient"))
continue;
if (!method.Parameters.Any(a => a.Type.Name == "ChatId"))
continue;
if (method.Name == ".ctor")
continue;
String parameters = "";
String subCallParameters = "";
foreach (var par in method.Parameters)
{
if (par.Name == "botClient")
continue;
if (!string.IsNullOrEmpty(parameters))
{
parameters += ", ";
}
if (!string.IsNullOrEmpty(subCallParameters))
{
subCallParameters += ", ";
}
if (par.Name == "chatId")
{
subCallParameters += $"device.DeviceId";
continue;
}
subCallParameters += $"{par.Name}";
parameters += $"{par.Type.ToDisplayString()} {par.Name}";
if (par.HasExplicitDefaultValue)
{
var defaultValue = par.ExplicitDefaultValue;
// Handle specific default value cases
if (defaultValue == null)
{
if(par.Name == "cancellationToken")
{
parameters += " = default";
}
else
{
parameters += " = null";
}
}
else if (defaultValue is string)
{
parameters += $" = \"{defaultValue}\""; // Add quotes around string default values
}
else if (defaultValue is bool)
{
parameters += $" = {defaultValue.ToString().ToLower()}"; // Use lower case for booleans (true/false)
}
else if (defaultValue is char)
{
parameters += $" = '{defaultValue}'"; // Use single quotes for char
}
else
{
parameters += $" = {defaultValue}"; // General case for other types (numbers, enums, etc.)
}
}
}
var returnStatement = "";
if (method.ReturnType is INamedTypeSymbol namedType && namedType.IsGenericType && namedType.ConstructedFrom.Name == "Task" && namedType.ContainingNamespace.ToDisplayString() == "System.Threading.Tasks")
{
returnStatement = "return await";
}
else if (method.ReturnType.Name == "Task" && method.ReturnType.ContainingNamespace.ToDisplayString() == "System.Threading.Tasks")
{
returnStatement = "await";
}
else if (method.ReturnsVoid)
{
returnStatement = "";
}
else
{
returnStatement = "return ";
}
String tmp = GenerateMethod(method, parameters, subCallParameters, returnStatement);
sb.Append(tmp);
}
//The generated source
var sourceCode = $$"""
using System;
using System.Threading.Tasks;
using TelegramBotBase.Interfaces;
using TelegramBotBase.Sessions;
using Telegram.Bot;
using Telegram.Bot.Extensions;
using Telegram.Bot.Requests;
using Telegram.Bot.Types.Enums;
using Telegram.Bot.Types.InlineQueryResults;
using Telegram.Bot.Types.Payments;
using Telegram.Bot.Types.ReplyMarkups;
using File = Telegram.Bot.Types.File;
#nullable enable
namespace TelegramBotBase;
public static class DeviceExtensions
{
{{sb.ToString()}}
}
""";
//Cleanup
sourceCode = sourceCode.Replace("System.Threading.Tasks.", "");
context.AddSource("DeviceExtensions.g.cs", SourceText.From(sourceCode, Encoding.UTF8));
}
/// <summary>
/// Test
/// </summary>
/// <param name="method"></param>
/// <param name="parameters"></param>
/// <param name="subCallParameters"></param>
/// <param name="returnStatement"></param>
/// <returns></returns>
private String GenerateMethod(IMethodSymbol? method, string parameters, string subCallParameters, string returnStatement)
{
//Adding xml comments from embedded xml file (Workaround)
String xml_comments = xml?.GetDocumentationLinesForSymbol(method);
StringBuilder sb = new StringBuilder();
sb.AppendLine(xml_comments);
sb.AppendLine($" public static async {method.ReturnType.ToDisplayString()} {method.Name}(this IDeviceSession device, {parameters})");
sb.AppendLine($" {{");
sb.AppendLine($" {returnStatement} device.Client.TelegramClient.{method.Name}({subCallParameters});");
sb.AppendLine($" }}");
sb.AppendLine();
sb.AppendLine();
return sb.ToString();
}
}
}

View File

@ -0,0 +1,89 @@
using Microsoft.CodeAnalysis;
using System;
using System.Collections.Generic;
using System.IO;
using System.Linq;
using System.Reflection;
using System.Text;
using System.Xml.Linq;
using System.Xml.XPath;
namespace TelegramBotBase.SourceGenerators
{
public class XmlDocumentationLoader
{
XDocument xDocument;
public string GetDocumentationLinesForSymbol(ISymbol symbol)
{
var docElement = xDocument?.Descendants("member")
.FirstOrDefault(e => e.Attribute("name")?.Value == GetDocumentationCommentId(symbol));
StringBuilder sb = new StringBuilder();
XNode first = docElement.FirstNode;
do
{
sb.AppendLine(first.ToString());
first = first.NextNode;
}
while (first.NextNode != null);
var lines = sb.ToString().Split('\n');
sb = new StringBuilder();
foreach (var line in lines)
{
if (line == "")
continue;
sb.AppendLine($" /// {line.Trim()}");
}
return sb.ToString().Trim();
}
private string GetDocumentationCommentId(ISymbol symbol)
{
// Returns the documentation comment ID for a symbol
return symbol.GetDocumentationCommentId();
}
public XDocument ReadEmbeddedXml(string resourceName)
{
// Get the assembly where the resource is embedded
Assembly assembly = Assembly.GetExecutingAssembly();
// Construct the full resource name
string fullResourceName = $"{assembly.GetName().Name}.Resources.{resourceName}";
var names = assembly.GetManifestResourceNames();
if (!names.Contains(fullResourceName))
return null;
// Open a stream to the embedded resource
using (Stream stream = assembly.GetManifestResourceStream(fullResourceName))
{
if (stream == null)
{
//throw new FileNotFoundException("Resource not found", fullResourceName);
return null;
}
xDocument = XDocument.Load(stream);
// Load the stream into an XDocument
return xDocument;
}
}
}
}

View File

@ -3,7 +3,7 @@ using System.Collections.Generic;
using System.Globalization;
using System.IO;
using System.Linq;
using Newtonsoft.Json;
using System.Text.Json;
using TelegramBotBase.Controls.Hybrid;
using TelegramBotBase.DataSources;
using TelegramBotBase.Form;
@ -36,7 +36,7 @@ public class CustomDataSource : ButtonFormDataSource
{
try
{
var list = JsonConvert.DeserializeObject<List<string>>(File.ReadAllText("countries.json"));
var list = JsonSerializer.Deserialize<List<string>>(File.ReadAllText("countries.json"));
Countries = list;
@ -56,7 +56,7 @@ public class CustomDataSource : ButtonFormDataSource
Countries = countries;
var tmp = JsonConvert.SerializeObject(countries);
var tmp = JsonSerializer.Serialize(countries);
File.WriteAllText(AppContext.BaseDirectory + "countries.json", tmp);
}

View File

@ -1,7 +1,7 @@
using System;
using System.Collections.Generic;
using Telegram.Bot.Types;
using TelegramBotBase.Sessions;
using TelegramBotBase.Interfaces;
namespace TelegramBotBase.Args;
@ -15,7 +15,7 @@ public class BotCommandEventArgs : EventArgs
}
public BotCommandEventArgs(string command, List<string> parameters, Message message, long deviceId,
DeviceSession device)
IDeviceSession device)
{
Command = command;
Parameters = parameters;
@ -30,7 +30,7 @@ public class BotCommandEventArgs : EventArgs
public long DeviceId { get; set; }
public DeviceSession Device { get; set; }
public IDeviceSession Device { get; set; }
public bool Handled { get; set; } = false;

View File

@ -1,11 +1,11 @@
using System;
using TelegramBotBase.Sessions;
using TelegramBotBase.Interfaces;
namespace TelegramBotBase.Base;
public class MessageIncomeEventArgs : EventArgs
{
public MessageIncomeEventArgs(long deviceId, DeviceSession device, MessageResult message)
public MessageIncomeEventArgs(long deviceId, IDeviceSession device, MessageResult message)
{
DeviceId = deviceId;
Device = device;
@ -14,7 +14,7 @@ public class MessageIncomeEventArgs : EventArgs
public long DeviceId { get; set; }
public DeviceSession Device { get; set; }
public IDeviceSession Device { get; set; }
public MessageResult Message { get; set; }
}

View File

@ -1,11 +1,11 @@
using System;
using TelegramBotBase.Sessions;
using TelegramBotBase.Interfaces;
namespace TelegramBotBase.Base;
public class SessionBeginEventArgs : EventArgs
{
public SessionBeginEventArgs(long deviceId, DeviceSession device)
public SessionBeginEventArgs(long deviceId, IDeviceSession device)
{
DeviceId = deviceId;
Device = device;
@ -13,5 +13,5 @@ public class SessionBeginEventArgs : EventArgs
public long DeviceId { get; set; }
public DeviceSession Device { get; set; }
public IDeviceSession Device { get; set; }
}

View File

@ -1,5 +1,5 @@
using System;
using TelegramBotBase.Sessions;
using TelegramBotBase.Interfaces;
namespace TelegramBotBase.Args;
@ -9,7 +9,7 @@ public class SystemExceptionEventArgs : EventArgs
{
}
public SystemExceptionEventArgs(string command, long deviceId, DeviceSession device, Exception error)
public SystemExceptionEventArgs(string command, long deviceId, IDeviceSession device, Exception error)
{
Command = command;
DeviceId = deviceId;
@ -21,7 +21,7 @@ public class SystemExceptionEventArgs : EventArgs
public long DeviceId { get; set; }
public DeviceSession Device { get; set; }
public IDeviceSession Device { get; set; }
public Exception Error { get; set; }
}

View File

@ -1,6 +1,6 @@
using System;
using Telegram.Bot.Types;
using TelegramBotBase.Sessions;
using TelegramBotBase.Interfaces;
namespace TelegramBotBase.Args;
@ -12,7 +12,7 @@ public class UnhandledCallEventArgs : EventArgs
}
public UnhandledCallEventArgs(string command, string rawData, long deviceId, int messageId, Message message,
DeviceSession device) : this()
IDeviceSession device) : this()
{
Command = command;
RawData = rawData;
@ -26,7 +26,7 @@ public class UnhandledCallEventArgs : EventArgs
public long DeviceId { get; set; }
public DeviceSession Device { get; set; }
public IDeviceSession Device { get; set; }
public string RawData { get; set; }

View File

@ -1,5 +1,5 @@
using System.Threading.Tasks;
using TelegramBotBase.Sessions;
using TelegramBotBase.Interfaces;
namespace TelegramBotBase.Base;
@ -8,7 +8,7 @@ namespace TelegramBotBase.Base;
/// </summary>
public class ControlBase
{
public DeviceSession Device { get; set; }
public IDeviceSession Device { get; set; }
public int Id { get; set; }

View File

@ -6,7 +6,7 @@ using System.Threading.Tasks;
using TelegramBotBase.Args;
using TelegramBotBase.Base;
using TelegramBotBase.Form.Navigation;
using TelegramBotBase.Sessions;
using TelegramBotBase.Interfaces;
using static TelegramBotBase.Base.Async;
namespace TelegramBotBase.Form;
@ -28,7 +28,7 @@ public class FormBase : IDisposable
public NavigationController NavigationController { get; set; }
public DeviceSession Device { get; set; }
public IDeviceSession Device { get; set; }
public MessageClient Client { get; set; }

View File

@ -111,7 +111,7 @@ public class MessageClient
public virtual void StopReceiving()
{
_cancellationTokenSource.Cancel();
_cancellationTokenSource?.Cancel();
}

View File

@ -1,8 +1,8 @@
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text.Json;
using System.Threading.Tasks;
using Newtonsoft.Json;
using Telegram.Bot.Types;
using Telegram.Bot.Types.Enums;
@ -126,7 +126,7 @@ public class MessageResult : ResultBase
T cd = null;
try
{
cd = JsonConvert.DeserializeObject<T>(RawData);
cd = JsonSerializer.Deserialize<T>(RawData);
return cd;
}

View File

@ -2,13 +2,13 @@
using System.Threading.Tasks;
using Telegram.Bot;
using Telegram.Bot.Types;
using TelegramBotBase.Sessions;
using TelegramBotBase.Interfaces;
namespace TelegramBotBase.Base;
public class ResultBase : EventArgs
{
public DeviceSession Device { get; set; }
public IDeviceSession Device { get; set; }
public virtual long DeviceId { get; set; }

View File

@ -81,7 +81,7 @@ public class ThreadPoolMessageClient : MessageClient
public override void StopReceiving()
{
_cancellationTokenSource.Cancel();
_cancellationTokenSource?.Cancel();
}

View File

@ -1,11 +1,11 @@
using Telegram.Bot.Types;
using TelegramBotBase.Sessions;
using TelegramBotBase.Interfaces;
namespace TelegramBotBase.Base;
public class UpdateResult : ResultBase
{
public UpdateResult(Update rawData, DeviceSession device)
public UpdateResult(Update rawData, IDeviceSession device)
{
RawData = rawData;
Device = device;

View File

@ -1,4 +1,5 @@
using TelegramBotBase.Interfaces;
using System;
using TelegramBotBase.Interfaces;
namespace TelegramBotBase.Builder.Interfaces;
@ -22,15 +23,32 @@ public interface ISessionSerializationStage
/// Using the complex version of .Net JSON, which can serialize all objects.
/// Saves in application directory.
/// </summary>
/// <remarks>
/// <para>
/// Has been changed lately to not use Newtonsoft.Json anymore.
/// For the legacy version add the nuget package below and use the <seealso cref="UseNewtonsoftJson"></seealso> method.
/// </para>
/// <seealso href="https://www.nuget.org/packages/TelegramBotBase.Extensions.Serializer.Legacy.NewtonsoftJson/">TelegramBotBase.Extensions.Serializer.Legacy.NewtonsoftJson</seealso>
/// </remarks>
/// <param name="path"></param>
/// <returns></returns>
/// <seealso cref="UseNewtonsoftJson"/>
ILanguageSelectionStage UseJSON();
/// <summary>
/// Using the complex version of .Net JSON, which can serialize all objects.
/// Saves in application directory.
/// </summary>
/// <remarks>
/// <para>
/// Has been changed lately to not use Newtonsoft.Json anymore.
/// For the legacy version add the nuget package below and use the <seealso cref="UseNewtonsoftJson"></seealso> method.
/// </para>
/// <seealso href="https://www.nuget.org/packages/TelegramBotBase.Extensions.Serializer.Legacy.NewtonsoftJson/">TelegramBotBase.Extensions.Serializer.Legacy.NewtonsoftJson</seealso>
/// </remarks>
/// <param name="path"></param>
/// <returns></returns>
/// <seealso cref="UseNewtonsoftJson"/>
ILanguageSelectionStage UseJSON(string path);
/// <summary>
@ -39,6 +57,7 @@ public interface ISessionSerializationStage
/// </summary>
/// <param name="path"></param>
/// <returns></returns>
[Obsolete("Use UseJSON instead.")]
ILanguageSelectionStage UseSimpleJSON();
/// <summary>
@ -46,6 +65,7 @@ public interface ISessionSerializationStage
/// </summary>
/// <param name="path"></param>
/// <returns></returns>
[Obsolete("Use UseJSON instead.")]
ILanguageSelectionStage UseSimpleJSON(string path);
/// <summary>

View File

@ -1,16 +1,18 @@
using Newtonsoft.Json;
using System.Text.Json;
using System.Text;
using TelegramBotBase.Exceptions;
using System.Text.Json.Serialization;
namespace TelegramBotBase.Form;
/// <summary>
/// Base class for serializing buttons and data
/// Base class for serializing buttons and data
/// </summary>
public class CallbackData
{
public CallbackData()
{
}
public CallbackData(string method, string value)
@ -19,9 +21,9 @@ public class CallbackData
Value = value;
}
[JsonProperty("m")] public string Method { get; set; }
[JsonPropertyName("m")] public string Method { get; set; }
[JsonProperty("v")] public string Value { get; set; }
[JsonPropertyName("v")] public string Value { get; set; }
public static string Create(string method, string value)
{
@ -36,7 +38,7 @@ public class CallbackData
{
var s = string.Empty;
s = JsonConvert.SerializeObject(this);
s = JsonSerializer.Serialize(this);
//Is data over 64 bytes ?
int byte_count = Encoding.UTF8.GetByteCount(s);
@ -55,7 +57,7 @@ public class CallbackData
/// <returns></returns>
public static CallbackData Deserialize(string data)
{
return JsonConvert.DeserializeObject<CallbackData>(data);
return JsonSerializer.Deserialize<CallbackData>(data);
}
public static implicit operator string(CallbackData callbackData) => callbackData.Serialize(true);

View File

@ -1,4 +1,5 @@
using System.Threading.Tasks;
using System;
using System.Threading.Tasks;
using Telegram.Bot.Types.Enums;
using TelegramBotBase.Args;
using TelegramBotBase.Base;
@ -7,6 +8,8 @@ namespace TelegramBotBase.Form;
public class GroupForm : FormBase
{
//Prior V21
[Obsolete("Check Telegram.Bot nuget package changes.")]
public override async Task Load(MessageResult message)
{
switch (message.MessageType)
@ -46,6 +49,46 @@ public class GroupForm : FormBase
}
}
//Past V21
//public override async Task Load(MessageResult message)
//{
// switch (message.MessageType)
// {
// case MessageType.NewChatMembers:
// await OnMemberChanges(new MemberChangeEventArgs(MessageType.NewChatMembers, message,
// message.Message.NewChatMembers));
// break;
// case MessageType.LeftChatMember:
// await OnMemberChanges(new MemberChangeEventArgs(MessageType.LeftChatMember, message,
// message.Message.LeftChatMember));
// break;
// case MessageType.NewChatPhoto:
// case MessageType.DeleteChatPhoto:
// case MessageType.NewChatTitle:
// case MessageType.MigrateFromChatId:
// case MessageType.MigrateToChatId:
// case MessageType.PinnedMessage:
// case MessageType.GroupChatCreated:
// case MessageType.SupergroupChatCreated:
// case MessageType.ChannelChatCreated:
// await OnGroupChanged(new GroupChangedEventArgs(message.MessageType, message));
// break;
// default:
// await OnMessage(message);
// break;
// }
//}
public override async Task Edited(MessageResult message)
{
await OnMessageEdit(message);

View File

@ -82,7 +82,7 @@ public class PromptDialog : ModalDialog
{
var bf = new ButtonForm();
bf.AddButtonRow(new ButtonBase(BackLabel, "back"));
await Device.Send(Message, (ReplyMarkupBase)bf);
await Device.Send(Message, (IReplyMarkup)bf);
return;
}

View File

@ -1,10 +1,24 @@
using System;
using System.Threading.Tasks;
using Telegram.Bot.Types.Enums;
using Telegram.Bot.Types;
using TelegramBotBase.Form;
using Telegram.Bot.Types.ReplyMarkups;
using TelegramBotBase.Args;
using TelegramBotBase.Base;
using Telegram.Bot;
using TelegramBotBase.Sessions;
namespace TelegramBotBase.Interfaces;
internal interface IDeviceSession
public interface IDeviceSession : IDeviceSessionMethods
{
MessageClient Client => ActiveForm.Client;
int LastMessageId => LastMessage?.MessageId ?? -1;
Message LastMessage { get; set; }
/// <summary>
/// Device or chat id
/// </summary>
@ -35,4 +49,6 @@ internal interface IDeviceSession
/// contains if the form has been switched (navigated)
/// </summary>
bool FormSwitched { get; set; }
}

View File

@ -0,0 +1,117 @@
using System;
using System.Collections.Generic;
using System.Text;
using System.Threading.Tasks;
using Telegram.Bot.Types.Enums;
using Telegram.Bot.Types.ReplyMarkups;
using Telegram.Bot.Types;
using TelegramBotBase.Form;
using Telegram.Bot;
using TelegramBotBase.Base;
using TelegramBotBase.Args;
namespace TelegramBotBase.Interfaces
{
public interface IDeviceSessionMethods
{
string GetChatTitle();
Task BanUser(long userId, DateTime until = default);
Task UnbanUser(long userId);
Task ChangeChatPermissions(ChatPermissions permissions);
Task RestrictUser(long userId, ChatPermissions permissions, bool? useIndependentGroupPermission = null, DateTime until = default);
Task ConfirmAction(string callbackQueryId, string message = "", bool showAlert = false,
string urlToOpen = null);
Task<bool> DeleteMessage(int messageId = -1);
Task<bool> DeleteMessage(Message message);
Task<Message> HideReplyKeyboard(string closedMsg = "Closed", bool autoDeleteResponse = true);
Task<Message> Send(string text, ButtonForm buttons = null, int replyTo = 0,
bool disableNotification = false, ParseMode parseMode = ParseMode.Markdown,
bool markdownV2AutoEscape = true);
Task<Message> Send(string text, IReplyMarkup markup, int replyTo = 0,
bool disableNotification = false, ParseMode parseMode = ParseMode.Markdown,
bool markdownV2AutoEscape = true);
Task<Message> Send(string text, InlineKeyboardMarkup markup, int replyTo = 0,
bool disableNotification = false, ParseMode parseMode = ParseMode.Markdown,
bool markdownV2AutoEscape = true);
Task SetAction(ChatAction action);
Task<Message> SendTextFile(string filename, string textcontent, Encoding encoding = null,
string caption = "", ButtonForm buttons = null, int replyTo = 0,
bool disableNotification = false);
Task<Message> SendDocument(InputFile document, string caption = "",
ButtonForm buttons = null, int replyTo = 0,
bool disableNotification = false);
Task<Message> SendPhoto(InputFile file, string caption = null, ButtonForm buttons = null,
int replyTo = 0, bool disableNotification = false,
ParseMode parseMode = ParseMode.Markdown);
Task<Message> SendVideo(InputFile file, string caption = null, ButtonForm buttons = null,
int replyTo = 0, bool disableNotification = false,
ParseMode parseMode = ParseMode.Markdown);
Task<Message> SendVideo(string url, ButtonForm buttons = null, int replyTo = 0,
bool disableNotification = false, ParseMode parseMode = ParseMode.Markdown);
Task<Message> SendVideo(string filename, byte[] video, ButtonForm buttons = null, int replyTo = 0,
bool disableNotification = false, ParseMode parseMode = ParseMode.Markdown);
Task<Message> SendLocalVideo(string filepath, ButtonForm buttons = null, int replyTo = 0,
bool disableNotification = false,
ParseMode parseMode = ParseMode.Markdown);
Task<Message> Edit(int messageId, string text, ButtonForm buttons = null,
ParseMode parseMode = ParseMode.Markdown);
Task<Message> Edit(int messageId, string text, InlineKeyboardMarkup markup,
ParseMode parseMode = ParseMode.Markdown);
Task<Message> Edit(Message message, ButtonForm buttons = null,
ParseMode parseMode = ParseMode.Markdown);
Task<Message> EditReplyMarkup(int messageId, ButtonForm bf);
Task<Message> RequestContact(string buttonText = "Send your contact",
string requestMessage = "Give me your phone number!",
bool oneTimeOnly = true);
Task<Message> RequestLocation(string buttonText = "Send your location",
string requestMessage = "Give me your location!",
bool oneTimeOnly = true);
Task<ChatMember> GetChatUser(long userId);
event Async.AsyncEventHandler<MessageSentEventArgs> MessageSent;
event EventHandler<MessageReceivedEventArgs> MessageReceived;
event EventHandler<MessageDeletedEventArgs> MessageDeleted;
Task Api(Func<ITelegramBotClient, Task> call);
Task<T> Api<T>(Func<ITelegramBotClient, Task<T>> call);
T Raw<T>(Func<ITelegramBotClient, T> call);
}
}

View File

@ -2,13 +2,12 @@
using System.Threading.Tasks;
using TelegramBotBase.Args;
using TelegramBotBase.Base;
using TelegramBotBase.Sessions;
namespace TelegramBotBase.Interfaces;
public interface IMessageLoopFactory
{
Task MessageLoop(BotBase bot, DeviceSession session, UpdateResult ur, MessageResult e);
Task MessageLoop(BotBase bot, IDeviceSession session, UpdateResult ur, MessageResult e);
event EventHandler<UnhandledCallEventArgs> UnhandledCall;
}

View File

@ -5,7 +5,6 @@ using Telegram.Bot.Types.Enums;
using TelegramBotBase.Args;
using TelegramBotBase.Base;
using TelegramBotBase.Interfaces;
using TelegramBotBase.Sessions;
namespace TelegramBotBase.MessageLoops;
@ -18,7 +17,7 @@ public class FormBaseMessageLoop : IMessageLoopFactory
private readonly EventHandlerList _events = new();
public async Task MessageLoop(BotBase bot, DeviceSession session, UpdateResult ur, MessageResult mr)
public async Task MessageLoop(BotBase bot, IDeviceSession session, UpdateResult ur, MessageResult mr)
{
var update = ur.RawData;

View File

@ -5,7 +5,6 @@ using Telegram.Bot.Types.Enums;
using TelegramBotBase.Args;
using TelegramBotBase.Base;
using TelegramBotBase.Interfaces;
using TelegramBotBase.Sessions;
namespace TelegramBotBase.MessageLoops;
@ -18,7 +17,7 @@ public class FullMessageLoop : IMessageLoopFactory
private readonly EventHandlerList _events = new();
public async Task MessageLoop(BotBase bot, DeviceSession session, UpdateResult ur, MessageResult mr)
public async Task MessageLoop(BotBase bot, IDeviceSession session, UpdateResult ur, MessageResult mr)
{
var update = ur.RawData;

View File

@ -4,7 +4,6 @@ using System.Threading.Tasks;
using TelegramBotBase.Args;
using TelegramBotBase.Base;
using TelegramBotBase.Interfaces;
using TelegramBotBase.Sessions;
namespace TelegramBotBase.MessageLoops;
@ -17,7 +16,7 @@ public class MinimalMessageLoop : IMessageLoopFactory
private readonly EventHandlerList _events = new();
public async Task MessageLoop(BotBase bot, DeviceSession session, UpdateResult ur, MessageResult mr)
public async Task MessageLoop(BotBase bot, IDeviceSession session, UpdateResult ur, MessageResult mr)
{
var update = ur.RawData;

View File

@ -21,7 +21,7 @@ public class SessionManager
public SessionManager(BotBase botBase)
{
BotBase = botBase;
SessionList = new Dictionary<long, DeviceSession>();
SessionList = new Dictionary<long, IDeviceSession>();
}
/// <summary>
@ -32,7 +32,7 @@ public class SessionManager
/// <summary>
/// A list of all active sessions.
/// </summary>
public Dictionary<long, DeviceSession> SessionList { get; set; }
public Dictionary<long, IDeviceSession> SessionList { get; set; }
/// <summary>
@ -45,7 +45,7 @@ public class SessionManager
/// </summary>
/// <param name="deviceId"></param>
/// <returns></returns>
public DeviceSession GetSession(long deviceId)
public IDeviceSession GetSession(long deviceId)
{
var ds = SessionList.FirstOrDefault(a => a.Key == deviceId).Value ?? null;
return ds;
@ -57,7 +57,7 @@ public class SessionManager
/// <typeparam name="T"></typeparam>
/// <param name="deviceId"></param>
/// <returns></returns>
public async Task<DeviceSession> StartSession(long deviceId)
public async Task<IDeviceSession> StartSession(long deviceId)
{
var start = BotBase.StartFormFactory.CreateForm();
@ -91,7 +91,7 @@ public class SessionManager
/// Returns all active User Sessions.
/// </summary>
/// <returns></returns>
public List<DeviceSession> GetUserSessions()
public List<IDeviceSession> GetUserSessions()
{
return SessionList.Where(a => a.Key > 0).Select(a => a.Value).ToList();
}
@ -100,7 +100,7 @@ public class SessionManager
/// Returns all active Group Sessions.
/// </summary>
/// <returns></returns>
public List<DeviceSession> GetGroupSessions()
public List<IDeviceSession> GetGroupSessions()
{
return SessionList.Where(a => a.Key < 0).Select(a => a.Value).ToList();
}

View File

@ -312,7 +312,7 @@ public class DeviceSession : IDeviceSession
/// <param name="replyTo"></param>
/// <param name="disableNotification"></param>
/// <returns></returns>
public async Task<Message> Send(string text, ReplyMarkupBase markup, int replyTo = 0,
public async Task<Message> Send(string text, IReplyMarkup markup, int replyTo = 0,
bool disableNotification = false, ParseMode parseMode = ParseMode.Markdown,
bool markdownV2AutoEscape = true)
{

View File

@ -0,0 +1,155 @@
using System;
using System.Collections.Generic;
using System.Text;
using System.Text.Json;
using System.Text.Json.Serialization;
namespace TelegramBotBase.States.Converter
{
public class DictionaryObjectJsonConverter : JsonConverter<Dictionary<string, object>>
{
public override Dictionary<string, object> Read(ref Utf8JsonReader reader, Type typeToConvert, JsonSerializerOptions options)
{
var dictionary = new Dictionary<string, object>();
var jsonDocument = JsonDocument.ParseValue(ref reader);
foreach (var element in jsonDocument.RootElement.EnumerateObject())
{
switch (element.Value.ValueKind)
{
case JsonValueKind.String:
dictionary[element.Name] = element.Value.GetString();
break;
case JsonValueKind.Number:
if (element.Value.TryGetInt32(out var number))
{
dictionary[element.Name] = number;
continue;
}
if (element.Value.TryGetInt64(out long l))
dictionary[element.Name] = l;
else
dictionary[element.Name] = element.Value.GetDouble();
break;
case JsonValueKind.True:
case JsonValueKind.False:
dictionary[element.Name] = element.Value.GetBoolean();
break;
case JsonValueKind.Object:
dictionary[element.Name] = JsonSerializer.Deserialize<Dictionary<string, object>>(element.Value.GetRawText(), options);
break;
case JsonValueKind.Array:
dictionary[element.Name] = HandleArray(element.Value);
break;
default:
dictionary[element.Name] = element.Value.GetRawText();
break;
}
}
return dictionary;
}
private object HandleArray(JsonElement jsonArray)
{
// Hier wird geprüft, ob alle Elemente einer bestimmten Art angehören (z. B. int, string)
if (jsonArray.GetArrayLength() > 0)
{
var firstElement = jsonArray[0];
switch (firstElement.ValueKind)
{
case JsonValueKind.Number:
// Prüfen, ob alle Elemente ganze Zahlen sind
var isIntArray = true;
var isLongArray = false;
foreach (var element in jsonArray.EnumerateArray())
{
if (!element.TryGetInt32(out _))
{
isIntArray = false;
isLongArray = true;
if (!element.TryGetInt64(out _))
{
isLongArray = false;
break;
}
}
}
if (isIntArray)
{
var list = new List<int>();
foreach (var element in jsonArray.EnumerateArray())
{
list.Add(element.GetInt32());
}
return list;
}
else if (isLongArray)
{
var list = new List<long>();
foreach (var element in jsonArray.EnumerateArray())
{
list.Add(element.GetInt64());
}
return list;
}
else
{
var list = new List<double>();
foreach (var element in jsonArray.EnumerateArray())
{
list.Add(element.GetDouble());
}
return list;
}
case JsonValueKind.String:
var stringList = new List<string>();
foreach (var element in jsonArray.EnumerateArray())
{
stringList.Add(element.GetString());
}
return stringList;
case JsonValueKind.True:
case JsonValueKind.False:
var boolList = new List<bool>();
foreach (var element in jsonArray.EnumerateArray())
{
boolList.Add(element.GetBoolean());
}
return boolList;
default:
// Fallback: Liste von Objekten (z. B. wenn es sich um komplexe Objekte handelt)
var objectList = new List<object>();
foreach (var element in jsonArray.EnumerateArray())
{
objectList.Add(JsonSerializer.Deserialize<object>(element.GetRawText()));
}
return objectList;
}
}
// Leeres Array als Liste von Objekten zurückgeben
return new List<object>();
}
public override void Write(Utf8JsonWriter writer, Dictionary<string, object> value, JsonSerializerOptions options)
{
writer.WriteStartObject();
foreach (var kvp in value)
{
writer.WritePropertyName(kvp.Key);
JsonSerializer.Serialize(writer, kvp.Value, kvp.Value?.GetType() ?? typeof(object), options);
}
writer.WriteEndObject();
}
}
}

View File

@ -0,0 +1,296 @@
using System;
using System.Collections;
using System.Collections.Generic;
using System.Diagnostics;
using System.Reflection;
using System.Text;
using System.Text.Json;
using System.Text.Json.Serialization;
namespace TelegramBotBase.States.Converter
{
public class JsonTypeConverter : JsonConverter<object>
{
public override object Read(ref Utf8JsonReader reader, Type typeToConvert, JsonSerializerOptions options)
{
using (JsonDocument doc = JsonDocument.ParseValue(ref reader))
{
return ParseElement(doc.RootElement, options, typeof(object));
}
}
private object ParseElement(JsonElement element, JsonSerializerOptions options, Type expected_type)
{
// Wenn das Element ein JSON-Objekt ist
if (element.ValueKind == JsonValueKind.Object)
{
// Wenn es einen $type enthält, dann den Typ dynamisch instanziieren
if (element.TryGetProperty("$type", out JsonElement typeElement))
{
string typeName = typeElement.GetString();
Type type = Type.GetType(typeName);
if (type == null)
throw new InvalidOperationException($"Typ '{typeName}' konnte nicht gefunden werden.");
// Liste verarbeiten, falls $values enthalten ist
if (element.TryGetProperty("$values", out JsonElement valuesElement))
{
return ParseArray(valuesElement, type);
}
else if (expected_type.IsGenericType && expected_type.GetGenericTypeDefinition() == typeof(Dictionary<,>))
{
var dictionary = new Dictionary<string, object>();
foreach (var property in element.EnumerateObject())
{
dictionary[property.Name] = ParseElement(property.Value, options, typeof(object));
}
return dictionary;
}
else
{
var instance = type.GetConstructor(new Type[] { }).Invoke(new object[] { });
var properties = type.GetProperties();
foreach (var p in properties)
{
if (!element.TryGetProperty(p.Name, out JsonElement value))
continue;
switch (value.ValueKind)
{
case JsonValueKind.Number:
if (p.PropertyType == typeof(int))
{
if (value.TryGetInt32(out int i))
{
p.SetValue(instance, i);
}
}
else if (p.PropertyType == typeof(long))
{
if (value.TryGetInt64(out long l))
{
p.SetValue(instance, l);
}
}
break;
case JsonValueKind.String:
p.SetValue(instance, value.ToString());
break;
default:
//if (p.PropertyType.IsGenericType && p.PropertyType.GetGenericTypeDefinition() == typeof(Dictionary<,>))
//{
// var dictionary = new Dictionary<string, object>();
// foreach (var property in element.EnumerateObject())
// {
// dictionary[property.Name] = ParseElement(property.Value, options, p.PropertyType);
// }
// p.SetValue(instance, dictionary);
//}
//else
//{
var obj = ParseElement(value, options, p.PropertyType);
if (obj == null)
continue;
try
{
p.SetValue(instance, obj);
}
catch
{
}
//}
break;
}
}
return instance;
// Objekt dynamisch deserialisieren
//return JsonSerializer.Deserialize(element.GetRawText(), type, options);
}
}
else
{
// Falls kein $type vorhanden ist, als Dictionary verarbeiten
var dictionary = new Dictionary<string, object>();
foreach (var property in element.EnumerateObject())
{
dictionary[property.Name] = ParseElement(property.Value, options, typeof(object));
}
return dictionary;
}
}
// Wenn das Element ein Array ist
else if (element.ValueKind == JsonValueKind.Array)
{
return ParseArray(element, typeof(object));
}
// Primitive Typen (String, Number, Bool)
else if (element.ValueKind == JsonValueKind.Number)
{
if (expected_type == typeof(Int64))
{
if (element.TryGetInt64(out long l))
return l;
}
else if (expected_type == typeof(Int32))
{
if (element.TryGetInt32(out int i))
return i;
}
if (element.TryGetInt32(out int i2))
return i2;
return 0;
}
else if (element.ValueKind == JsonValueKind.String)
{
return element.ToString();
}
else
{
#if NETCOREAPP3_1
return JsonSerializer.Deserialize(element.ToString(), typeof(object), options);
#else
return element.Deserialize<object>(options);
#endif
}
}
private object ParseElement(JsonElement element)
{
return null;
}
private object ParseArray(JsonElement arrayElement, Type listType)
{
// Wenn der Typ eine generische Liste ist
if (listType.IsGenericType && listType.GetGenericTypeDefinition() == typeof(List<>))
{
Type elementType = listType.GetGenericArguments()[0];
var list = (IList)Activator.CreateInstance(typeof(List<>).MakeGenericType(elementType));
foreach (var item in arrayElement.EnumerateArray())
{
list.Add(ParseElement(item, new JsonSerializerOptions(), elementType));
}
return list;
}
else
{
// Standardmäßig als List<object>
var list = new List<object>();
foreach (var item in arrayElement.EnumerateArray())
{
list.Add(ParseElement(item, new JsonSerializerOptions(), typeof(object)));
}
return list;
}
}
public override void Write(Utf8JsonWriter writer, object value, JsonSerializerOptions options)
{
WriteWithTypeInfo(writer, value, options);
}
private void WriteWithTypeInfo(Utf8JsonWriter writer, object value, JsonSerializerOptions options)
{
if (value == null)
{
writer.WriteNullValue();
return;
}
Type type = value.GetType();
// Primitives und grundlegende Typen (int, string, bool, etc.)
if (type.IsPrimitive || type == typeof(string) || type == typeof(decimal))
{
JsonSerializer.Serialize(writer, value, type, options);
}
// Behandlung für Sammlungen
else if (value is IList list)
{
writer.WriteStartObject();
writer.WriteString("$type", type.AssemblyQualifiedName);
writer.WritePropertyName("$values");
writer.WriteStartArray();
foreach (var item in list)
{
WriteWithTypeInfo(writer, item, options);
}
writer.WriteEndArray();
writer.WriteEndObject();
}
// Behandlung für Dictionaries
else if (value is IDictionary dictionary)
{
writer.WriteStartObject();
writer.WriteString("$type", type.AssemblyQualifiedName);
foreach (DictionaryEntry entry in dictionary)
{
writer.WritePropertyName(entry.Key.ToString());
WriteWithTypeInfo(writer, entry.Value, options);
}
writer.WriteEndObject();
}
// Komplexe Objekte
else if (value is Enum e)
{
int eValue = (int)value;
writer.WriteNumberValue(eValue);
}
else
{
writer.WriteStartObject();
writer.WriteString("$type", type.AssemblyQualifiedName);
foreach (var property in type.GetProperties())
{
if (property.CanRead)
{
var propValue = property.GetValue(value);
writer.WritePropertyName(property.Name);
WriteWithTypeInfo(writer, propValue, options);
}
}
writer.WriteEndObject();
}
}
}
}

View File

@ -1,6 +1,6 @@
using System;
using System.IO;
using Newtonsoft.Json;
using System.Text.Json;
using TelegramBotBase.Args;
using TelegramBotBase.Base;
using TelegramBotBase.Form;
@ -48,16 +48,24 @@ public class JsonStateMachine : IStateMachine
{
var content = File.ReadAllText(FilePath);
var sc = JsonConvert.DeserializeObject<StateContainer>(content, new JsonSerializerSettings
var options = new JsonSerializerOptions
{
TypeNameHandling = TypeNameHandling.All,
TypeNameAssemblyFormatHandling = TypeNameAssemblyFormatHandling.Simple
});
Converters = {
new Converter.JsonTypeConverter(),
//new Converter.DictionaryObjectJsonConverter(),
},
PropertyNameCaseInsensitive = true
};
var obj = JsonSerializer.Deserialize<object>(content, options) ;
var sc = obj as StateContainer;
return sc;
}
catch
catch(Exception ex)
{
throw ex;
}
return new StateContainer();
@ -77,16 +85,23 @@ public class JsonStateMachine : IStateMachine
try
{
var content = JsonConvert.SerializeObject(e.States, Formatting.Indented, new JsonSerializerSettings
var options = new JsonSerializerOptions
{
TypeNameHandling = TypeNameHandling.All,
TypeNameAssemblyFormatHandling = TypeNameAssemblyFormatHandling.Simple
});
WriteIndented = true,
Converters = {
new Converter.JsonTypeConverter(),
},
PropertyNameCaseInsensitive = true
};
var content = JsonSerializer.Serialize<object>(e.States, options);
File.WriteAllText(FilePath, content);
}
catch
{
}
}
}

View File

@ -1,6 +1,6 @@
using System;
using System.IO;
using Newtonsoft.Json;
using System.Text.Json;
using TelegramBotBase.Args;
using TelegramBotBase.Base;
using TelegramBotBase.Form;
@ -49,7 +49,15 @@ public class SimpleJsonStateMachine : IStateMachine
{
var content = File.ReadAllText(FilePath);
var sc = JsonConvert.DeserializeObject<StateContainer>(content);
var options = new JsonSerializerOptions
{
Converters = {
new Converter.DictionaryObjectJsonConverter(),
new Converter.JsonTypeConverter()
}
};
var sc = JsonSerializer.Deserialize<StateContainer>(content, options);
return sc;
}
@ -74,7 +82,16 @@ public class SimpleJsonStateMachine : IStateMachine
try
{
var content = JsonConvert.SerializeObject(e.States, Formatting.Indented);
var options = new JsonSerializerOptions
{
WriteIndented = true,
Converters = {
new Converter.DictionaryObjectJsonConverter(),
new Converter.JsonTypeConverter()
}
};
var content = JsonSerializer.Serialize(e.States, options);
File.WriteAllText(FilePath, content);
}

View File

@ -1,7 +1,7 @@
<Project Sdk="Microsoft.NET.Sdk">
<PropertyGroup>
<TargetFrameworks>netstandard2.0;netcoreapp3.1;net6;net7</TargetFrameworks>
<TargetFrameworks>netcoreapp3.1;net6;net7;net8</TargetFrameworks>
<LangVersion>10</LangVersion>
<GenerateAssemblyInfo>false</GenerateAssemblyInfo>
<GeneratePackageOnBuild>False</GeneratePackageOnBuild>
@ -22,8 +22,8 @@
</PropertyGroup>
<ItemGroup>
<PackageReference Include="Microsoft.Extensions.DependencyInjection.Abstractions" Version="6.0.0" />
<PackageReference Include="Microsoft.SourceLink.GitHub" Version="1.1.1" PrivateAssets="All" />
<PackageReference Include="Microsoft.Extensions.DependencyInjection.Abstractions" Version="8.0.0" />
<PackageReference Include="Microsoft.SourceLink.GitHub" Version="8.0.0" PrivateAssets="All" />
</ItemGroup>
@ -60,4 +60,9 @@
<PackageReference Include="Telegram.Bot" Version="19.0.0" />
</ItemGroup>
<ItemGroup>
<ProjectReference Include="..\TelegramBotBase.SourceGenerators\TelegramBotBase.SourceGenerators.csproj" OutputItemType="Analyzer" ReferenceOutputAssembly="false" TargetFramework="netstandard2.0" />
</ItemGroup>
</Project>

View File

@ -38,6 +38,10 @@ Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "TelegramBotBase.Extensions.
EndProject
Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "TelegramBotBase.Extensions.Images.IronSoftware", "TelegramBotBase.Extensions.Images.IronSoftware\TelegramBotBase.Extensions.Images.IronSoftware.csproj", "{DC521A4C-7446-46F7-845B-AAF10EDCF8C6}"
EndProject
Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "TelegramBotBase.SourceGenerators", "TelegramBotBase.SourceGenerators\TelegramBotBase.SourceGenerators.csproj", "{B78455D6-8AF2-459C-B56A-210DC89D7793}"
EndProject
Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "TelegramBotBase.Extensions.Serializer.Legacy.NewtonsoftJson", "TelegramBotBase.Extensions.Serializer.Legacy.NewtonsoftJson\TelegramBotBase.Extensions.Serializer.Legacy.NewtonsoftJson.csproj", "{21C44B20-1ED8-4BE6-A629-C2EC737C06E0}"
EndProject
Global
GlobalSection(SolutionConfigurationPlatforms) = preSolution
Debug|Any CPU = Debug|Any CPU
@ -96,6 +100,14 @@ Global
{DC521A4C-7446-46F7-845B-AAF10EDCF8C6}.Debug|Any CPU.Build.0 = Debug|Any CPU
{DC521A4C-7446-46F7-845B-AAF10EDCF8C6}.Release|Any CPU.ActiveCfg = Release|Any CPU
{DC521A4C-7446-46F7-845B-AAF10EDCF8C6}.Release|Any CPU.Build.0 = Release|Any CPU
{B78455D6-8AF2-459C-B56A-210DC89D7793}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
{B78455D6-8AF2-459C-B56A-210DC89D7793}.Debug|Any CPU.Build.0 = Debug|Any CPU
{B78455D6-8AF2-459C-B56A-210DC89D7793}.Release|Any CPU.ActiveCfg = Release|Any CPU
{B78455D6-8AF2-459C-B56A-210DC89D7793}.Release|Any CPU.Build.0 = Release|Any CPU
{21C44B20-1ED8-4BE6-A629-C2EC737C06E0}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
{21C44B20-1ED8-4BE6-A629-C2EC737C06E0}.Debug|Any CPU.Build.0 = Debug|Any CPU
{21C44B20-1ED8-4BE6-A629-C2EC737C06E0}.Release|Any CPU.ActiveCfg = Release|Any CPU
{21C44B20-1ED8-4BE6-A629-C2EC737C06E0}.Release|Any CPU.Build.0 = Release|Any CPU
EndGlobalSection
GlobalSection(SolutionProperties) = preSolution
HideSolutionNode = FALSE
@ -112,6 +124,7 @@ Global
{689B16BC-200E-4C68-BB2E-8B209070849B} = {BFA71E3F-31C0-4FC1-A320-4DCF704768C5}
{7C55D9FF-7DC1-41D0-809C-469EBFA20992} = {E3193182-6FDA-4FA3-AD26-A487291E7681}
{DC521A4C-7446-46F7-845B-AAF10EDCF8C6} = {E3193182-6FDA-4FA3-AD26-A487291E7681}
{21C44B20-1ED8-4BE6-A629-C2EC737C06E0} = {E3193182-6FDA-4FA3-AD26-A487291E7681}
EndGlobalSection
GlobalSection(ExtensibilityGlobals) = postSolution
SolutionGuid = {59CB40E1-9FA7-4867-A56F-4F418286F057}