using var client = OpenILinkClient.Create(token);

// Builder模式
using var httpClient = new HttpClient();
using var client = OpenILinkClient.Builder()
    .Token(token)
    .BaseUri("https://ilinkai.weixin.qq.com/")
    .ApiTimeout(TimeSpan.FromSeconds(15))
    .Build();
// 配置类模式
var options = new OpenILinkClientOptions(token)
{
    BaseUri = new Uri("https://ilinkai.weixin.qq.com/"),
    LoginTimeout = TimeSpan.FromMinutes(8)
};
using var client = new OpenILinkClient(options);

var login = await client.LoginWithQrAsync(ShowQrCode, OnScanned, OnExpired);
if (login.Connected)
{
    // 保存Token到本地，下次启动直接使用
    File.WriteAllText("bot_token.txt", login.BotToken ?? string.Empty);
}
// 显示二维码，这里拿到的是一个网页地址，里面用Canvas绘制二维码，我这里直接调用系统浏览器打开
void ShowQrCode(string qrCodeImageUrl)
{
    Process.Start(new ProcessStartInfo(qrCodeImageUrl) { UseShellExecute = true });
}
void OnScanned() => Console.WriteLine("已扫码，请在微信端确认登录");
void OnExpired(int attempt, int maxAttempt) => Console.WriteLine($"二维码过期，正在刷新 ({attempt}/{maxAttempt})");

await client.MonitorAsync(HandleMessageAsync, new MonitorOptions
{
    // 上次保存的消息位置Buffer，避免重启后收到大量历史消息
    InitialBuffer = File.Exists("get_updates_buf.txt") ? File.ReadAllText("get_updates_buf.txt") : string.Empty,
    // Buffer更新时保存到本地
    OnBufferUpdated = buffer => File.WriteAllText("get_updates_buf.txt", buffer),
    OnError = exception => Console.Error.WriteLine($"出错：{exception.Message}"),
    OnSessionExpired = () => Console.Error.WriteLine("会话过期，请重新登录")
});
// 消息处理逻辑
Task HandleMessageAsync(WeixinMessage message)
{
    var text = message.ExtractText();
    if (string.IsNullOrWhiteSpace(text)) return Task.CompletedTask;
    // 直接回复消息
    return client.ReplyTextAsync(message, $"收到你的消息：{text}");
}

using Microsoft.Agents.AI;
using Microsoft.Extensions.AI;
using OpenAI;
using OpenILink.SDK;
using System.ClientModel;
using System.Diagnostics;
// 初始化豆包客户端，请替换成你自己的密钥和模型端点
var keyFile = @"C:\lindexi\Work\Doubao.txt";
var key = File.ReadAllText(keyFile);
var openAiClient = new OpenAIClient(new ApiKeyCredential(key), new OpenAIClientOptions()
{
    Endpoint = new Uri("https://ark.cn-beijing.volces.com/api/v3"),
});
var chatClient = openAiClient.GetChatClient("ep-20260306101224-c8mtg"); // 替换成你自己的豆包模型ID
var agent = chatClient.AsIChatClient()
    .AsBuilder()
    .BuildAIAgent(new ChatClientAgentOptions()
    {
        ChatOptions = new ChatOptions()
        {
            // 可以在这里添加自定义工具，让豆包支持调用本地能力
            Tools = []
        }
    });
// 读取本地保存的Token
var tokenFilePath = Path.Join(AppContext.BaseDirectory, "Token.txt");
string? initialToken = File.Exists(tokenFilePath) ? File.ReadAllText(tokenFilePath) : null;
// 读取本地保存的消息Buffer
var bufferPath = Path.Join(AppContext.BaseDirectory, "GetUpdatesBuffer.txt");
string? initBuffer = File.Exists(bufferPath) ? File.ReadAllText(bufferPath) : null;
// 创建OpenILink客户端
var client = OpenILinkClient.Create(initialToken);
// 没有Token就扫码登录
if (string.IsNullOrWhiteSpace(client.Token))
{
    var login = await client.LoginWithQrAsync(ShowQrCode, OnScanned);
    if (!login.Connected)
    {
        Console.Error.WriteLine($"登录失败: {login.Message}");
        return;
    }
    File.WriteAllText(tokenFilePath, client.Token);
}
// 开始监听消息
await client.MonitorAsync(HandleMessageAsync, new MonitorOptions
{
    InitialBuffer = initBuffer,
    OnBufferUpdated = SaveBuffer,
    OnError = ReportError,
    OnSessionExpired = ReportSessionExpired
});

// 显示登录二维码
void ShowQrCode(string qrCodeImageDownloadUrl)
{
    Process.Start(new ProcessStartInfo(qrCodeImageDownloadUrl)
    {
        UseShellExecute = true
    });
}

void OnScanned() => Console.WriteLine("已扫码，请在微信端确认。");

// 处理收到的消息
async Task HandleMessageAsync(WeixinMessage message)
{
    var getConfigResponse = await client.GetConfigAsync(message.FromUserId, message.ContextToken!);
    var text = message.ExtractText();
    if (string.IsNullOrWhiteSpace(text)) return;
    // 发送正在输入的状态，提升用户体验
    await client.SendTypingAsync(message.FromUserId, getConfigResponse.TypingTicket!, TypingStatus.Typing);
    Console.WriteLine($"[{message.FromUserId}] {text}");
    // 调用豆包获取回复
    var agentResponse = await agent.RunAsync
    (
        [
            new ChatMessage(ChatRole.System,"你是一个充满积极向上情绪的聊天机器人"),
            new ChatMessage(ChatRole.User, text)
        ]
    );
    // 拼接回复内容，包含思考过程和Token消耗
    var reason = string.Empty;
    foreach (ChatMessage agentResponseMessage in agentResponse.Messages)
    {
        foreach (var textReasoningContent in agentResponseMessage.Contents.OfType<TextReasoningContent>())
        {
            reason += textReasoningContent.Text;
        }
    }
    var responseText = string.Empty;
    if (!string.IsNullOrEmpty(reason))
    {
        responseText =
            $"""
             思考：
             {reason.Trim()}
             -----------
             {agentResponse.Text}
             """;
    }
    // 追加Token消耗统计
    if (agentResponse.Usage is { } usage)
    {
        var usageText = $"本次对话总Token消耗：{usage.TotalTokenCount};输入Token消耗：{usage.InputTokenCount};输出Token消耗：{usage.OutputTokenCount},其中思考占{usage.ReasoningTokenCount??0}";
        responseText += $"\r\n-----------\r\n{usageText}";
    }
    Console.WriteLine($"[Bot] {responseText}");
    // 回复给微信用户
    await client.ReplyTextAsync(message, responseText);
}
void SaveBuffer(string buffer) => File.WriteAllText(bufferPath, buffer);
void ReportError(Exception exception) => Console.Error.WriteLine(exception.Message);
void ReportSessionExpired() => Console.Error.WriteLine("会话过期，请重新登录。");