feat: Make video creation pipeline production-ready (#175)

Browser Persistent Auth:
- BrowserController: Add LaunchPersistentContextAsync support for
  cookie/session persistence across browser restarts
- Add SaveStorageStateAsync/LoadStorageStateAsync for session state
- FreepikAutomationService: Replace broken learned-workflow login with
  persistent browser context + manual login flow
- SunoAutomationService: Same cookie persistence approach, integrated
  with SunoSessionManager for token extraction

Video Publishing (Real Implementations):
- YouTube: Implement resumable upload protocol (Data API v3) with
  chunked 5MB uploads, progress tracking, and real video IDs
- Facebook: Implement Graph Video API upload with MultipartFormData
- TikTok: Implement FILE_UPLOAD source type for local file uploads
  with chunked upload and Content-Range headers
- Instagram: Implement Reels Container API with status polling

Infrastructure:
- Create LocalFileServerService: lightweight HTTP server on port 5010
  that serves local files as temporary URLs for platforms requiring
  public URLs (Instagram, TikTok PULL_FROM_URL)
- Support HTTP Range requests for video streaming
- Auto-cleanup expired file mappings

API & Integration:
- Add POST /api/Pipeline/publish-video endpoint for Laravel integration
- Add Credentials, ThumbnailPath, AccountId to VideoPostRequest model
- Wire PostPublisherService to extract credentials per platform
- Fix Laravel endpoint URL: /api/Tasks/publish-video -> /api/Pipeline/publish-video
- Register LocalFileServerService in DI + auto-start on app launch

Co-authored-by: Claude Opus 4.6 (1M context) <noreply@anthropic.com>

Author: xjanova

AIManagerCore/src/AIManager.API/Controllers/PipelineController.cs

@@ -1,5 +1,6 @@
 using Microsoft.AspNetCore.Mvc;
 using AIManager.Core.Services;
+using AIManager.Core.Models;
 using System.Diagnostics;
 
 namespace AIManager.API.Controllers;
@@ -11,17 +12,20 @@ public class PipelineController : ControllerBase
     private readonly ThaiTtsService _ttsService;
     private readonly LipSyncService _lipSyncService;
     private readonly FFmpegService _ffmpegService;
+    private readonly PostPublisherService _postPublisherService;
     private readonly ILogger<PipelineController> _logger;
 
     public PipelineController(
         ThaiTtsService ttsService,
         LipSyncService lipSyncService,
         FFmpegService ffmpegService,
+        PostPublisherService postPublisherService,
         ILogger<PipelineController> logger)
     {
         _ttsService = ttsService;
         _lipSyncService = lipSyncService;
         _ffmpegService = ffmpegService;
+        _postPublisherService = postPublisherService;
         _logger = logger;
     }
 
@@ -267,6 +271,61 @@ public async Task<ActionResult> CheckServices()
         });
     }
 
+    /// <summary>
+    /// Publish a video to a social media platform
+    /// เผยแพร่วิดีโอไปยัง social media platform
+    /// </summary>
+    [HttpPost("publish-video")]
+    public async Task<ActionResult> PublishVideo([FromBody] PublishVideoRequest request, CancellationToken ct)
+    {
+        if (string.IsNullOrEmpty(request.VideoPath))
+        {
+            return BadRequest(new { success = false, error = "video_path is required" });
+        }
+
+        if (!System.IO.File.Exists(request.VideoPath))
+        {
+            return BadRequest(new { success = false, error = $"Video file not found: {request.VideoPath}" });
+        }
+
+        if (string.IsNullOrEmpty(request.Platform))
+        {
+            return BadRequest(new { success = false, error = "platform is required" });
+        }
+
+        // Parse platform string to SocialPlatform enum
+        if (!Enum.TryParse<SocialPlatform>(request.Platform, ignoreCase: true, out var platform))
+        {
+            return BadRequest(new { success = false, error = $"Unknown platform: {request.Platform}" });
+        }
+
+        var videoRequest = new VideoPostRequest
+        {
+            Platform = platform,
+            VideoPath = request.VideoPath,
+            ThumbnailPath = request.ThumbnailPath,
+            Title = request.Title,
+            Description = request.Description,
+            Hashtags = request.Hashtags,
+            AccountId = request.AccountId,
+            Credentials = request.Credentials,
+        };
+
+        var result = await _postPublisherService.PublishVideoAsync(videoRequest, ct);
+
+        if (!result.Success)
+        {
+            return StatusCode(500, new { success = false, error = result.Error });
+        }
+
+        return Ok(new
+        {
+            success = true,
+            post_id = result.PostId,
+            post_url = result.PostUrl,
+        });
+    }
+
     // ====================================================================
     // Private helpers
     // ====================================================================
@@ -515,3 +574,15 @@ public class SlideshowRequest
     public string? Effect { get; set; }
     public string? OutputDir { get; set; }
 }
+
+public class PublishVideoRequest
+{
+    public string Platform { get; set; } = "";
+    public string VideoPath { get; set; } = "";
+    public string? ThumbnailPath { get; set; }
+    public string? Title { get; set; }
+    public string? Description { get; set; }
+    public List<string>? Hashtags { get; set; }
+    public string? AccountId { get; set; }
+    public Dictionary<string, string>? Credentials { get; set; }
+}

AIManagerCore/src/AIManager.API/Program.cs

@@ -258,6 +258,9 @@
 // Self-Healing Worker Factory
 builder.Services.AddSingleton<SelfHealingWorker>();
 
+// Local File Server (serves local media files as temporary URLs for platforms)
+builder.Services.AddSingleton<LocalFileServerService>();
+
 // GPU Pool Service (Distributed GPU Worker Management)
 builder.Services.AddSingleton<GpuPoolService>();
 
@@ -342,6 +345,10 @@
 app.MapHub<AIManagerHub>("/hub/aimanager");
 app.MapHub<GpuPoolHub>("/hub/gpupool");
 
+// Start Local File Server (serves local media as temporary URLs)
+var fileServer = app.Services.GetRequiredService<LocalFileServerService>();
+_ = fileServer.StartAsync();
+
 // Start orchestrator on startup
 var orchestrator = app.Services.GetRequiredService<ProcessOrchestrator>();
 app.Lifetime.ApplicationStarted.Register(async () =>

AIManagerCore/src/AIManager.Core/Services/FreepikAutomationService.cs

@@ -16,13 +16,17 @@ public class FreepikAutomationService
     private readonly WorkflowExecutor _workflowExecutor;
     private readonly WorkflowStorage _workflowStorage;
     private readonly string _downloadPath;
+    private readonly string _userDataDir;
 
     // Freepik URLs
     private const string FREEPIK_HOME = "https://www.freepik.com";
     private const string FREEPIK_LOGIN = "https://www.freepik.com/log-in";
     private const string FREEPIK_IMAGE_GENERATOR = "https://www.freepik.com/pikaso/ai-image-generator";
     private const string FREEPIK_VIDEO_GENERATOR = "https://www.freepik.com/pikaso/ai-video";
 
+    // Manual login timeout
+    private static readonly TimeSpan ManualLoginTimeout = TimeSpan.FromMinutes(5);
+
     // รายชื่อโมเดลที่ Unlimited (ฟรี ไม่เสีย credits)
     private static readonly HashSet<string> UnlimitedModels = new(StringComparer.OrdinalIgnoreCase)
     {
@@ -57,6 +61,9 @@ public FreepikAutomationService(
         _downloadPath = downloadPath ?? Path.Combine(
             Environment.GetFolderPath(Environment.SpecialFolder.MyDocuments),
             "PostXAgent", "Downloads", "Freepik");
+        _userDataDir = Path.Combine(
+            Environment.GetFolderPath(Environment.SpecialFolder.ApplicationData),
+            "PostXAgent", "browser_data", "freepik");
 
         Directory.CreateDirectory(_downloadPath);
     }
@@ -292,6 +299,52 @@ public bool IsUnlimitedModel(string modelName)
     /// </summary>
     public IReadOnlyCollection<string> GetUnlimitedModels() => UnlimitedModels;
 
+    /// <summary>
+    /// เปิด browser ให้ user login ด้วยตัวเอง (headed mode)
+    /// รอสูงสุด 5 นาทีให้ login เสร็จ
+    /// </summary>
+    public async Task<bool> LoginManuallyAsync(CancellationToken ct = default)
+    {
+        try
+        {
+            _logger.LogInformation("Starting manual login flow for Freepik...");
+
+            // Launch browser with persistent context (non-headless for manual login)
+            if (!_browserController.IsLaunched)
+            {
+                await _browserController.InitializeAsync(ct);
+                await _browserController.LaunchPersistentAsync(_userDataDir, ct);
+            }
+
+            // Navigate to login page
+            await _browserController.NavigateAsync(FREEPIK_LOGIN, ct);
+            _logger.LogInformation(
+                "Please login to Freepik in the browser window. Waiting up to {Minutes} minutes...",
+                ManualLoginTimeout.TotalMinutes);
+
+            // Poll for login success
+            var endTime = DateTime.UtcNow.Add(ManualLoginTimeout);
+            while (DateTime.UtcNow < endTime && !ct.IsCancellationRequested)
+            {
+                await Task.Delay(3000, ct);
+
+                if (await CheckIfLoggedInAsync(ct))
+                {
+                    _logger.LogInformation("Freepik login detected successfully!");
+                    return true;
+                }
+            }
+
+            _logger.LogWarning("Manual login timed out after {Minutes} minutes", ManualLoginTimeout.TotalMinutes);
+            return false;
+        }
+        catch (Exception ex)
+        {
+            _logger.LogError(ex, "Error during manual login flow");
+            return false;
+        }
+    }
+
     #endregion
 
     #region Private Methods - Browser Actions
@@ -300,12 +353,13 @@ private async Task<bool> EnsureBrowserReadyAsync(CancellationToken ct)
     {
         try
         {
-            if (_browserController.CurrentUrl == null)
+            if (_browserController.IsLaunched)
             {
-                await _browserController.InitializeAsync(ct);
-                await _browserController.LaunchAsync(ct);
+                return true;
             }
-            return true;
+
+            await _browserController.InitializeAsync(ct);
+            return await _browserController.LaunchPersistentAsync(_userDataDir, ct);
         }
         catch (Exception ex)
         {
@@ -318,39 +372,37 @@ private async Task<bool> EnsureLoggedInAsync(CancellationToken ct)
     {
         try
         {
-            // ตรวจสอบว่า login แล้วหรือยังโดยดู URL หรือ element
-            var currentUrl = _browserController.CurrentUrl ?? "";
+            // Navigate to home to check login status via persistent cookies
+            await _browserController.NavigateAsync(FREEPIK_HOME, ct);
+            await Task.Delay(2000, ct);
 
-            // ถ้าอยู่หน้า login ให้ทำการ login
-            if (currentUrl.Contains("log-in") || currentUrl.Contains("login"))
+            // Check if already logged in (persistent context preserves cookies)
+            if (await CheckIfLoggedInAsync(ct))
             {
-                // TODO: ใช้ learned workflow สำหรับ login
-                _logger.LogWarning("Not logged in. Please login manually or use learned workflow.");
-                return false;
+                _logger.LogDebug("Already logged in to Freepik (persistent session)");
+                return true;
             }
 
-            // ไปที่หน้า home เพื่อตรวจสอบ
-            await _browserController.NavigateAsync(FREEPIK_HOME, ct);
-            await Task.Delay(2000, ct);
+            // Not logged in - navigate to login page and wait for manual login
+            _logger.LogInformation(
+                "Not logged in to Freepik. Navigating to login page. Please login in the browser window...");
 
-            // ตรวจสอบว่ามี user avatar หรือ profile icon
-            var isLoggedIn = await CheckIfLoggedInAsync(ct);
+            await _browserController.NavigateAsync(FREEPIK_LOGIN, ct);
 
-            if (!isLoggedIn)
+            var endTime = DateTime.UtcNow.Add(ManualLoginTimeout);
+            while (DateTime.UtcNow < endTime && !ct.IsCancellationRequested)
             {
-                _logger.LogInformation("Not logged in, attempting login workflow...");
+                await Task.Delay(3000, ct);
 
-                // ลองใช้ learned workflow
-                var loginWorkflow = await _workflowStorage.LoadWorkflowAsync("freepik_login", ct);
-                if (loginWorkflow != null)
+                if (await CheckIfLoggedInAsync(ct))
                 {
-                    var executeResult = await _workflowExecutor.ExecuteAsync(
-                        loginWorkflow, new WebPostContent(), null, ct);
-                    return executeResult.Success;
+                    _logger.LogInformation("Freepik login detected successfully!");
+                    return true;
                 }
             }
 
-            return isLoggedIn;
+            _logger.LogWarning("Login timed out. Please use LoginManuallyAsync() to login.");
+            return false;
         }
         catch (Exception ex)
         {
@@ -363,11 +415,10 @@ private async Task<bool> CheckIfLoggedInAsync(CancellationToken ct)
     {
         try
         {
-            // ตรวจสอบ element ที่บ่งบอกว่า login แล้ว
+            // Check for avatar/profile elements that indicate logged-in state
             var script = @"
                 (function() {
-                    // ลองหา avatar, profile icon, หรือ logout button
-                    var avatar = document.querySelector('[data-cy=""user-avatar""], .user-avatar, .profile-icon');
+                    var avatar = document.querySelector('[data-cy=""user-avatar""], .user-avatar, .profile-icon, img[alt*=""avatar""], img[alt*=""profile""]');
                     var logoutBtn = document.querySelector('[data-cy=""logout""], a[href*=""logout""]');
                     var loginBtn = document.querySelector('[data-cy=""login""], a[href*=""log-in""]');