พัฒนา Webhook ด้วย LINE Messaging API และ .NET: คู่มือเชิงลึก

// ในโปรเจกต์ API Layer (e.g., YourProject.Api/Controllers/WebhookController.cs)
using Microsoft.AspNetCore.Mvc;
using YourProject.Application.UseCases.LineEvents;
using System.Threading.Tasks;

namespace YourProject.Api.Controllers
{
    [ApiController]
    [Route("webhook")] // หรือ Route ที่คุณตั้งค่าไว้ใน LINE Developers Console
    public class WebhookController : ControllerBase
    {
        private readonly ILineEventHandler _lineEventHandler;

        public WebhookController(ILineEventHandler lineEventHandler)
        {
            _lineEventHandler = lineEventHandler;
        }

        [HttpPost]
        public async Task Post([FromBody] LineEventRequest request)
        {
            // การตรวจสอบลายเซ็น (Signature Verification) จะถูกจัดการใน Middleware หรือ Filter
            await _lineEventHandler.HandleEventAsync(request);
            return Ok();
        }
    }
}

// ในโปรเจกต์ Application Layer (e.g., YourProject.Application/UseCases/LineEvents/ILineEventHandler.cs)
using System.Threading.Tasks;
using YourProject.Application.Dto;

namespace YourProject.Application.UseCases.LineEvents
{
    public interface ILineEventHandler
    {
        Task HandleEventAsync(LineEventRequest request);
    }

    // ในโปรเจกต์ Infrastructure Layer (e.g., YourProject.Infrastructure/Services/LineEventHandler.cs)
    using System;
    using System.Linq;
    using System.Threading.Tasks;
    using YourProject.Application.Dto;
    using YourProject.Domain.Interfaces;
    using YourProject.Application.Services;
    using Microsoft.Extensions.Logging;

    public class LineEventHandler : ILineEventHandler
    {
        private readonly ILogger _logger;
        private readonly ILineMessageService _lineMessageService;
        private readonly IEventLogRepository _eventLogRepository;

        public LineEventHandler(
            ILogger logger,
            ILineMessageService lineMessageService,
            IEventLogRepository eventLogRepository)
        {
            _logger = logger;
            _lineMessageService = lineMessageService;
            _eventLogRepository = eventLogRepository;
        }

        public async Task HandleEventAsync(LineEventRequest request)
        {
            foreach (var eventItem in request.Events)
            {
                try
                {
                    // บันทึก Event ลงฐานข้อมูล PostgreSQL เพื่อการตรวจสอบ
                    await _eventLogRepository.LogEventAsync(eventItem);

                    // ประมวลผล Event ตามประเภท
                    switch (eventItem.Type)
                    {
                        case "message":
                            await HandleMessageEventAsync(eventItem);
                            break;
                        // เพิ่ม Case สำหรับ Event ประเภทอื่นๆ เช่น follow, unfollow, postback เป็นต้น
                        default:
                            _logger.LogInformation("Received unhandled event type: {EventType}", eventItem.Type);
                            break;
                    }
                }
                catch (Exception ex)
                {
                    _logger.LogError(ex, "Error handling LINE event ID: {EventId}", eventItem.ReplyToken);
                }
            }
        }

        private async Task HandleMessageEventAsync(LineEvent eventItem)
        {
            if (eventItem.Message.Type == "text")
            {
                var userMessage = eventItem.Message.Text;
                var replyToken = eventItem.ReplyToken;
                var userId = eventItem.Source.UserId;

                _logger.LogInformation("Received message from User {UserId}: {UserMessage}", userId, userMessage);

                // ตัวอย่างการตอบกลับข้อความ
                var replyMessage = $"คุณพูดว่า: '{userMessage}'";
                await _lineMessageService.ReplyMessageAsync(replyToken, replyMessage);
            }
            // จัดการ Message ประเภทอื่นๆ เช่น image, sticker
        }
    }
}

// ในโปรเจกต์ Domain Layer (e.g., YourProject.Domain/Interfaces/IEventLogRepository.cs)
using System.Threading.Tasks;
using YourProject.Application.Dto;

namespace YourProject.Domain.Interfaces
{
    public interface IEventLogRepository
    {
        Task LogEventAsync(LineEvent eventItem);
    }
}

// ในโปรเจกต์ Infrastructure Layer (e.g., YourProject.Infrastructure/Data/EventLogRepository.cs)
using System.Threading.Tasks;
using Npgsql;
using YourProject.Application.Dto;
using YourProject.Domain.Interfaces;
using Microsoft.Extensions.Configuration;

namespace YourProject.Infrastructure.Data
{
    public class EventLogRepository : IEventLogRepository
    {
        private readonly string _connectionString;

        public EventLogRepository(IConfiguration configuration)
        {
            // ดึง Connection String จาก appsettings.json หรือ Azure Key Vault
            _connectionString = configuration.GetConnectionString("PostgreSqlConnection");
        }

        public async Task LogEventAsync(LineEvent eventItem)
        {
            using (var conn = new NpgsqlConnection(_connectionString))
            {
                await conn.OpenAsync();

                var cmd = new NpgsqlCommand(
                    "INSERT INTO line_events (event_id, reply_token, event_type, user_id, message_text, timestamp) VALUES (@eventId, @replyToken, @eventType, @userId, @messageText, @timestamp)",
                    conn);

                cmd.Parameters.AddWithValue("eventId", eventItem.EventId ?? (object)DBNull.Value);
                cmd.Parameters.AddWithValue("replyToken", eventItem.ReplyToken ?? (object)DBNull.Value);
                cmd.Parameters.AddWithValue("eventType", eventItem.Type ?? (object)DBNull.Value);
                cmd.Parameters.AddWithValue("userId", eventItem.Source?.UserId ?? (object)DBNull.Value);
                cmd.Parameters.AddWithValue("messageText", eventItem.Message?.Text ?? (object)DBNull.Value);
                cmd.Parameters.AddWithValue("timestamp", DateTimeOffset.FromUnixTimeMilliseconds(eventItem.Timestamp));

                await cmd.ExecuteNonQueryAsync();
            }
        }
    }
}

{
  "ConnectionStrings": {
    "PostgreSqlConnection": "Host=your_host;Database=your_db;Username=your_user;Password=your_password"
  }
}

// ในโปรเจกต์ API Layer (e.g., YourProject.Api/Middleware/LineSignatureValidationMiddleware.cs)
using Microsoft.AspNetCore.Http;
using Microsoft.Extensions.Configuration;
using System.IO;
using System.Security.Cryptography;
using System.Text;
using System.Threading.Tasks;

namespace YourProject.Api.Middleware
{
    public class LineSignatureValidationMiddleware
    {
        private readonly RequestDelegate _next;
        private readonly IConfiguration _configuration;

        public LineSignatureValidationMiddleware(RequestDelegate next, IConfiguration configuration)
        {
            _next = next;
            _configuration = configuration;
        }

        public async Task InvokeAsync(HttpContext context)
        {
            var lineSignature = context.Request.Headers["X-Line-Signature"].FirstOrDefault();
            var channelSecret = _configuration["LineChannelSecret"]; // ดึงจาก appsettings.json

            if (string.IsNullOrEmpty(lineSignature) || string.IsNullOrEmpty(channelSecret))
            {
                context.Response.StatusCode = StatusCodes.Status401Unauthorized;
                await context.Response.WriteAsync("Missing signature or channel secret.");
                return;
            }

            // อ่าน Body ของ Request เพื่อนำมา Hash
            context.Request.EnableBuffering(); // เปิดใช้งานการอ่าน Body ซ้ำได้
            string requestBody;
            using (var reader = new StreamReader(context.Request.Body, Encoding.UTF8, true, 1024, true))
            {
                requestBody = await reader.ReadToEndAsync();
            }
            context.Request.Body.Position = 0; // ตั้งค่า Position กลับไปที่จุดเริ่มต้น

            // คำนวณลายเซ็นจาก Body และ Channel Secret
            using (var hmac = new HMACSHA256(Encoding.UTF8.GetBytes(channelSecret)))
            {
                var hashBytes = hmac.ComputeHash(Encoding.UTF8.GetBytes(requestBody));
                var computedSignature = Convert.ToBase64String(hashBytes);

                if (lineSignature != computedSignature)
                {
                    context.Response.StatusCode = StatusCodes.Status401Unauthorized;
                    await context.Response.WriteAsync("Invalid signature.");
                    return;
                }
            }

            await _next(context);
        }
    }
}

// ใน Program.cs ของโปรเจกต์ API
app.UseMiddleware();

// ในโปรเจกต์ Infrastructure Layer (e.g., YourProject.Infrastructure/Services/LineMessageService.cs)
using System;
using System.Collections.Generic;
using System.IdentityModel.Tokens.Jwt;
using System.Security.Claims;
using System.Text;
using System.Threading.Tasks;
using Microsoft.Extensions.Configuration;
using System.Net.Http;
using System.Net.Http.Headers;
using Newtonsoft.Json;
using YourProject.Application.Services;

namespace YourProject.Infrastructure.Services
{
    public class LineMessageService : ILineMessageService
    {
        private readonly HttpClient _httpClient;
        private readonly string _channelSecret;
        private readonly string _channelAccessTokenUri;
        private readonly string _replyMessageUri;

        public LineMessageService(HttpClient httpClient, IConfiguration configuration)
        {
            _httpClient = httpClient;
            _channelSecret = configuration["LineChannelSecret"];
            _channelAccessTokenUri = "https://api.line.me/v2/oauth/accessToken"; // URI สำหรับการขอ Token (หากไม่ใช้ Stateless)
            _replyMessageUri = "https://api.line.me/v2/bot/message/reply";

            // ตั้งค่า Header พื้นฐานสำหรับ HttpClient
            _httpClient.DefaultRequestHeaders.Accept.Add(new MediaTypeWithQualityHeaderValue("application/json"));
        }

        // ฟังก์ชันนี้จะใช้สำหรับกรณีที่ต้องการขอ Channel Access Token แบบปกติ (Stateful)
        // สำหรับ Stateless จะใช้การสร้าง JWT โดยตรง
        private async Task GetChannelAccessTokenAsync()
        {
            // Logic สำหรับการขอ Channel Access Token แบบ Stateful (ถ้าจำเป็น)
            // ในที่นี้เราจะเน้นไปที่ Stateless
            throw new NotImplementedException("Stateful token retrieval not implemented for this example.");
        }

        public async Task ReplyMessageAsync(string replyToken, string messageText)
        {
            // สร้าง Stateless Channel Access Token โดยใช้ JWT
            var statelessToken = GenerateStatelessChannelAccessToken();

            var requestBody = new
            {
                replyToken = replyToken,
                messages = new[]
                {
                    new {
                        type = "text",
                        text = messageText
                    }
                }
            };

            var jsonBody = JsonConvert.SerializeObject(requestBody);
            var content = new StringContent(jsonBody, Encoding.UTF8, "application/json");

            _httpClient.DefaultRequestHeaders.Authorization = new AuthenticationHeaderValue("Bearer", statelessToken);

            var response = await _httpClient.PostAsync(_replyMessageUri, content);

            if (!response.IsSuccessStatusCode)
            {
                var errorContent = await response.Content.ReadAsStringAsync();
                // Log error appropriately
                Console.WriteLine($"Error replying to LINE message: {response.StatusCode} - {errorContent}");
                throw new Exception($"Failed to send LINE message: {errorContent}");
            }
        }

        private string GenerateStatelessChannelAccessToken()
        {
            var securityKey = new SymmetricSecurityKey(Encoding.UTF8.GetBytes(_channelSecret));
            var credentials = new SigningCredentials(securityKey, SecurityAlgorithms.HmacSha256);

            var tokenDescriptor = new SecurityTokenDescriptor
            {
                Issuer = "your-service-name", // สามารถกำหนดค่าได้ตามต้องการ
                Audience = "https://api.line.me/", // Audience สำหรับ LINE API\





หน้าแรก
Ai สร้างรูป
AI Agent
ADS FB
AI YT
ดูดวง เอไอ
top
_