x integration testing.

social_media_publishers/app.py

@@ -132,6 +132,8 @@ async def oauth2callback(request: Request):
         platform = 'tiktok'
     elif state.startswith('threads_'):
         platform = 'threads'
+    elif state.startswith('twitter_'):
+        platform = 'twitter'
     else:
         platform = 'youtube'  # Default for backward compatibility
     
@@ -291,11 +293,7 @@ async def publish_video(
 
         
         # 1. Get Publisher
-        publisher = PublisherFactory.get_publisher(platform)
-        
         # 2. Authenticate
-        publisher.authenticate(account_id=account_email)
-        
         # 3. Publish
         is_public = (privacy == 'public')
         privacy_level = 'PUBLIC_TO_EVERYONE' if is_public else 'SELF_ONLY'
@@ -330,37 +328,80 @@ async def publish_video(
         # --- ONEUP PROVIDER FLOW ---
         if provider == 'oneup':
             from social_media_publishers.oneup_service import OneUpService
-            
             try:
                 service = OneUpService()
-                # Use account_email as the identifier (it might be username/email/name)
-                # If None, it will fail inside service if strictly required, or fallback if designed.
                 result = service.publish_video(
                     platform=platform,
                     content_path=content_path,
                     metadata=metadata,
                     account_identifier=account_email
                 )
-                
                 if result.get('error'):
                      return JSONResponse(content=result, status_code=400)
-                
                 return result
-                
             except Exception as e:
                 logger.error(f"OneUp Publish Error: {e}", exc_info=True)
                 return JSONResponse(content={'error': f"OneUp Error: {str(e)}"}, status_code=500)
 
+        # --- DIRECT API FLOW ---
+        # 1. Get Publisher
+        logger.info(f"📍 STEP 1: Getting Publisher for platform {platform}")
+        publisher = PublisherFactory.get_publisher(platform)
+        if not publisher:
+            logger.error(f"❌ Publisher for {platform} not found")
+            return JSONResponse(content={"error": f"Publisher for {platform} not found"}, status_code=404)
+
+        # 2. Resolve target accounts
+        logger.info(f"📍 STEP 2: Resolving target accounts (Select: {account_email})")
+        target_accounts = []
+        if account_email == 'all':
+            creator = PublisherFactory.get_auth_creator(platform)
+            if creator:
+                accounts_info = creator.list_connected_accounts()
+                for acc in accounts_info:
+                    # Clean ID extractor
+                    clean_id = acc['filename'].replace(f"{platform}_token_", '').replace('.json', '')
+                    target_accounts.append(clean_id)
+            
+            if not target_accounts:
+                logger.warning(f"⚠️ No connected accounts found for {platform}")
+                return JSONResponse(content={"error": f"No connected accounts found for {platform}"}, status_code=400)
+        else:
+            target_accounts = [account_email]
 
-        # --- DIRECT API FLOW (Default) ---
-        
-        logger.info(f"🚀 Publishing to {platform}: {title}")
-        result = publisher.publish(content_path, metadata)
-        
-        if result.get('error'):
-                return JSONResponse(content=result, status_code=400)
+        # 3. Iterate and Publish
+        logger.info(f"🚀 STEP 3: Starting publishing loop for {len(target_accounts)} accounts")
+        results = []
+        for i, acc_id in enumerate(target_accounts, 1):
+            logger.info(f"⏳ [{i}/{len(target_accounts)}] Processing account: {acc_id}")
+            try:
+                # 3a. Authenticate
+                logger.info(f"   🔑 Authenticating {acc_id}...")
+                publisher.authenticate(account_id=acc_id)
+                
+                # 3b. Publish
+                logger.info(f"   ⬆️ Publishing to {acc_id} (Title: {title})...")
+                res = publisher.publish(content_path, metadata)
+                
+                if res.get("success"):
+                    logger.info(f"   ✅ Successfully posted to {acc_id}! Post ID: {res.get('post_id') or res.get('media_id')}")
+                else:
+                    logger.error(f"   ❌ Failed to post to {acc_id}: {res.get('error')}")
+                
+                results.append({"account": acc_id, "success": res.get("success", False), "result": res})
+            except Exception as e:
+                logger.error(f"   💥 Fatal error for {acc_id}: {e}", exc_info=True)
+                results.append({"account": acc_id, "success": False, "error": str(e)})
+
+        # Return single result if only one account, else list
+        if len(results) == 1:
+            final_res = results[0]["result"] if results[0]["success"] else {"success": False, "error": results[0].get("error") or results[0]["result"].get("error")}
+            if not results[0]["success"]:
+                return JSONResponse(content=final_res, status_code=400)
+            return final_res
         
-        return result
+        logger.info(f"🏁 Finished publishing loop. Results: {results}")
+        return {"success": True, "multi_results": results}
 
     except Exception as e:
         logger.error(f"Publish Error: {e}", exc_info=True)

social_media_publishers/factory.py

@@ -1,8 +1,6 @@
-from .youtube.auth import YoutubeAuthCreator
-from .instagram.auth import InstagramAuthCreator
-from .facebook.auth import FacebookAuthCreator
 from .threads.auth import ThreadsAuthCreator
 from .tiktok.auth import TikTokAuthCreator
+from .twitter.auth import TwitterAuthCreator
 
 class PublisherFactory:
     """Factory to create social media auth creators and publishers."""
@@ -20,6 +18,8 @@ class PublisherFactory:
             return TikTokAuthCreator()
         if platform_lower == 'threads':
             return ThreadsAuthCreator()
+        if platform_lower == 'twitter':
+            return TwitterAuthCreator()
         raise ValueError(f"Unknown platform: {platform}")
 
     @staticmethod
@@ -40,6 +40,9 @@ class PublisherFactory:
         if platform_lower == 'threads':
             from .threads.publisher import ThreadsPublisher
             return ThreadsPublisher()
+        if platform_lower == 'twitter':
+            from .twitter.publisher import TwitterPublisher
+            return TwitterPublisher()
         raise ValueError(f"Unknown platform: {platform}")
 
 

social_media_publishers/frontend/src/components/GlobalUploadModal.jsx

@@ -0,0 +1,326 @@
+import React, { useState } from 'react';
+import { Upload, X, Calendar, Check, Globe, Layout, Smartphone, Share2, AlertCircle, Youtube, Twitter as TwitterIcon, Music2, Instagram, Facebook, AtSign, Loader2 } from 'lucide-react';
+import axios from 'axios';
+
+const API_URL = '/social/api';
+
+const AVAILABLE_PLATFORMS = [
+    { id: 'youtube', name: 'YouTube', icon: Youtube },
+    { id: 'tiktok', name: 'TikTok', icon: Music2 },
+    { id: 'instagram', name: 'Instagram', icon: Instagram },
+    { id: 'facebook', name: 'Facebook', icon: Facebook },
+    { id: 'threads', name: 'Threads', icon: AtSign },
+    { id: 'twitter', name: 'X (Twitter)', icon: TwitterIcon },
+];
+
+export default function GlobalUploadModal({ onClose, onSuccess }) {
+    const [selectedPlatforms, setSelectedPlatforms] = useState(['youtube']);
+    const [provider, setProvider] = useState('direct'); // Global provider for now
+
+    const [file, setFile] = useState(null);
+    const [title, setTitle] = useState('');
+    const [description, setDescription] = useState('');
+    const [privacy, setPrivacy] = useState('private');
+    const [scheduledTime, setScheduledTime] = useState('');
+
+    const [loading, setLoading] = useState(false);
+    const [error, setError] = useState(null);
+    const [results, setResults] = useState(null);
+
+    const [inputType, setInputType] = useState('file'); // 'file' or 'url'
+    const [videoUrl, setVideoUrl] = useState('');
+
+    const togglePlatform = (id) => {
+        setSelectedPlatforms(prev =>
+            prev.includes(id) ? prev.filter(p => p !== id) : [...prev, id]
+        );
+    };
+
+    const handleSubmit = async (e) => {
+        e.preventDefault();
+
+        if (selectedPlatforms.length === 0) return setError("Select at least one platform");
+        if (inputType === 'file' && !file) return setError("File is required");
+        if (inputType === 'url' && !videoUrl) return setError("Video URL is required");
+        if (!title) return setError("Title is required");
+
+        setLoading(true);
+        setError(null);
+        setResults([]); // Initialize empty results list
+
+        const uploadResults = [];
+
+        // Iterate through platforms
+        for (const platform of selectedPlatforms) {
+            // Update UI to show "Processing" for this specific platform
+            setResults(prev => [...prev.filter(r => r.platform !== platform), { platform, status: 'processing', success: false }]);
+
+            const formData = new FormData();
+            formData.append('platform', platform);
+            formData.append('provider', provider);
+            formData.append('account_email', 'all'); // Post to all accounts
+
+            if (inputType === 'file') formData.append('file', file);
+            else formData.append('video_url', videoUrl);
+
+            formData.append('title', title);
+            formData.append('description', description);
+            formData.append('privacy', privacy);
+            if (scheduledTime) formData.append('scheduled_time', new Date(scheduledTime).toISOString());
+
+            try {
+                const response = await axios.post(`${API_URL}/publish`, formData, {
+                    headers: { 'Content-Type': 'multipart/form-data' }
+                });
+
+                const platformResult = {
+                    platform,
+                    status: 'completed',
+                    success: true,
+                    data: response.data
+                };
+                uploadResults.push(platformResult);
+                setResults(prev => [...prev.filter(r => r.platform !== platform), platformResult]);
+            } catch (err) {
+                console.error(`Upload to ${platform} failed`, err);
+                const platformError = {
+                    platform,
+                    status: 'failed',
+                    success: false,
+                    error: err.response?.data?.error || "Upload failed"
+                };
+                uploadResults.push(platformError);
+                setResults(prev => [...prev.filter(r => r.platform !== platform), platformError]);
+            }
+        }
+
+        // Final summary check
+        const allSuccess = uploadResults.every(r => r.success);
+        setLoading(false);
+
+        if (allSuccess) {
+            setTimeout(() => {
+                onSuccess(uploadResults);
+                onClose();
+            }, 5000); // 5s to let them see all green
+        }
+    };
+
+    return (
+        <div className="fixed inset-0 bg-black/70 backdrop-blur-md flex items-center justify-center z-50 p-4 transition-all animate-in fade-in duration-300">
+            <div className="bg-surface border border-border shadow-[0_0_50px_-12px_rgba(0,0,0,0.5)] rounded-3xl w-full max-w-4xl max-h-[90vh] overflow-hidden flex flex-col animate-in zoom-in-95 duration-300">
+
+                {/* Header */}
+                <div className="p-6 border-b border-border flex items-center justify-between bg-white/50 backdrop-blur-sm sticky top-0 z-10">
+                    <div>
+                        <h2 className="text-2xl font-bold text-slate-900 flex items-center gap-3">
+                            <div className="p-2 rounded-xl bg-primary/10 text-primary">
+                                <Globe className="w-6 h-6" />
+                            </div>
+                            Global Publisher
+                        </h2>
+                        <p className="text-sm text-secondary mt-1">Scedule & post to all your connected accounts at once.</p>
+                    </div>
+                    <button onClick={onClose} className="p-2 hover:bg-slate-100 rounded-full transition-colors">
+                        <X className="w-6 h-6 text-gray-400" />
+                    </button>
+                </div>
+
+                <div className="flex-1 overflow-y-auto p-8 custom-scrollbar">
+                    <form onSubmit={handleSubmit} className="grid grid-cols-1 lg:grid-cols-2 gap-10">
+                        {/* Left Column: Config */}
+                        <div className="space-y-8">
+                            {/* Platform Selection */}
+                            <div className="space-y-4">
+                                <label className="text-xs font-bold text-slate-500 uppercase tracking-widest flex items-center gap-2">
+                                    <Globe className="w-3 h-3" /> Select Platforms
+                                </label>
+                                <div className="grid grid-cols-2 gap-3">
+                                    {AVAILABLE_PLATFORMS.map(p => (
+                                        <button
+                                            key={p.id}
+                                            type="button"
+                                            onClick={() => togglePlatform(p.id)}
+                                            className={`flex items-center gap-3 p-3 rounded-2xl border transition-all ${selectedPlatforms.includes(p.id)
+                                                ? 'bg-primary/5 border-primary text-primary shadow-sm'
+                                                : 'bg-white border-border text-slate-600 hover:border-slate-300'
+                                                }`}
+                                        >
+                                            <div className={`w-8 h-8 rounded-lg flex items-center justify-center ${selectedPlatforms.includes(p.id) ? 'bg-primary text-white' : 'bg-slate-100 text-slate-500'}`}>
+                                                <p.icon className="w-5 h-5" />
+                                            </div>
+                                            <span className="font-semibold text-sm">{p.name}</span>
+                                        </button>
+                                    ))}
+                                </div>
+                            </div>
+
+                            {/* Provider Toggle */}
+                            <div className="space-y-4">
+                                <label className="text-xs font-bold text-slate-500 uppercase tracking-widest flex items-center gap-2">
+                                    <Share2 className="w-3 h-3" /> Publishing Flow
+                                </label>
+                                <div className="flex p-1.5 bg-slate-100 rounded-2xl border border-border">
+                                    <button
+                                        type="button"
+                                        onClick={() => setProvider('direct')}
+                                        className={`flex-1 py-3 text-sm font-bold rounded-xl transition-all ${provider === 'direct' ? 'bg-white text-slate-900 shadow-md' : 'text-slate-500 hover:text-slate-900'}`}
+                                    >
+                                        Direct API
+                                    </button>
+                                    <button
+                                        type="button"
+                                        onClick={() => setProvider('oneup')}
+                                        className={`flex-1 py-3 text-sm font-bold rounded-xl transition-all ${provider === 'oneup' ? 'bg-white text-slate-900 shadow-md' : 'text-slate-500 hover:text-slate-900'}`}
+                                    >
+                                        OneUp
+                                    </button>
+                                </div>
+                                <p className="text-[10px] text-slate-400 px-2 italic">
+                                    {provider === 'direct' ? 'Posts directly via official APIs. Best for immediate results.' : 'Schedules via OneUp. Best for avoiding API tier restrictions.'}
+                                </p>
+                            </div>
+
+                            {/* Media Type */}
+                            <div className="space-y-4">
+                                <div className="flex bg-slate-100 p-1.5 rounded-2xl border border-border">
+                                    <button type="button" onClick={() => setInputType('file')} className={`flex-1 py-2.5 text-xs font-bold rounded-xl transition-all ${inputType === 'file' ? 'bg-primary text-white shadow-lg' : 'text-slate-500'}`}>File Upload</button>
+                                    <button type="button" onClick={() => setInputType('url')} className={`flex-1 py-2.5 text-xs font-bold rounded-xl transition-all ${inputType === 'url' ? 'bg-primary text-white shadow-lg' : 'text-slate-500'}`}>Direct URL</button>
+                                </div>
+
+                                {inputType === 'file' ? (
+                                    <div className="border-2 border-dashed border-slate-200 rounded-3xl p-8 text-center hover:border-primary/50 transition-colors bg-slate-50/50 group cursor-pointer relative">
+                                        <div className="w-16 h-16 bg-white rounded-2xl shadow-sm flex items-center justify-center mx-auto mb-4 group-hover:scale-110 transition-transform">
+                                            <Upload className="w-8 h-8 text-primary" />
+                                        </div>
+                                        <p className="text-sm font-bold text-slate-900 mb-1">{file ? file.name : 'Select video or image'}</p>
+                                        <p className="text-xs text-slate-400">{file ? `${(file.size / (1024 * 1024)).toFixed(1)} MB` : 'Drag and drop your file here'}</p>
+                                        <input
+                                            type="file"
+                                            accept="video/*,image/*"
+                                            onChange={(e) => setFile(e.target.files?.[0])}
+                                            className="absolute inset-0 opacity-0 cursor-pointer z-10"
+                                        />
+                                    </div>
+                                ) : (
+                                    <input
+                                        type="url"
+                                        value={videoUrl}
+                                        onChange={(e) => setVideoUrl(e.target.value)}
+                                        placeholder="https://example.com/video.mp4"
+                                        className="w-full bg-slate-50 border border-slate-200 rounded-2xl px-5 py-4 focus:ring-2 focus:ring-primary/20 outline-none font-medium text-sm"
+                                    />
+                                )}
+                            </div>
+                        </div>
+
+                        {/* Right Column: Metadata */}
+                        <div className="space-y-6">
+                            <div className="space-y-2">
+                                <label className="text-xs font-bold text-slate-500 uppercase tracking-widest pl-1">Title</label>
+                                <input
+                                    type="text"
+                                    value={title}
+                                    onChange={(e) => setTitle(e.target.value)}
+                                    placeholder="Enter post title..."
+                                    className="w-full bg-white border border-border rounded-2xl px-5 py-4 focus:ring-2 focus:ring-primary/20 outline-none font-bold text-slate-900"
+                                />
+                            </div>
+
+                            <div className="space-y-2">
+                                <label className="text-xs font-bold text-slate-500 uppercase tracking-widest pl-1">Description</label>
+                                <textarea
+                                    value={description}
+                                    onChange={(e) => setDescription(e.target.value)}
+                                    placeholder="Add description and hashtags..."
+                                    className="w-full bg-white border border-border rounded-3xl px-5 py-4 h-48 resize-none focus:ring-2 focus:ring-primary/20 outline-none text-slate-600 leading-relaxed"
+                                />
+                            </div>
+
+                            <div className="grid grid-cols-2 gap-4">
+                                <div className="space-y-2">
+                                    <label className="text-xs font-bold text-slate-500 uppercase tracking-widest pl-1">Privacy</label>
+                                    <select
+                                        value={privacy}
+                                        onChange={(e) => setPrivacy(e.target.value)}
+                                        className="w-full bg-white border border-border rounded-2xl px-5 py-4 focus:ring-2 focus:ring-primary/20 outline-none appearance-none font-semibold text-slate-900"
+                                    >
+                                        <option value="private">Private</option>
+                                        <option value="public">Public</option>
+                                        <option value="unlisted">Unlisted</option>
+                                    </select>
+                                </div>
+                                <div className="space-y-2">
+                                    <label className="text-xs font-bold text-slate-500 uppercase tracking-widest pl-1 flex items-center gap-1.5"><Calendar className="w-3 h-3" /> Schedule</label>
+                                    <input
+                                        type="datetime-local"
+                                        value={scheduledTime}
+                                        onChange={(e) => setScheduledTime(e.target.value)}
+                                        className="w-full bg-white border border-border rounded-2xl px-5 py-4 focus:ring-2 focus:ring-primary/20 outline-none text-sm font-semibold text-slate-900"
+                                    />
+                                </div>
+                            </div>
+                        </div>
+                    </form>
+                </div>
+
+                {/* Footer */}
+                <div className="p-8 border-t border-border bg-slate-50/50 flex flex-col gap-6">
+                    {results && results.length > 0 && (
+                        <div className="space-y-3">
+                            <label className="text-[10px] font-bold text-slate-400 uppercase tracking-widest pl-1">Processing Status</label>
+                            <div className="grid grid-cols-1 sm:grid-cols-2 lg:grid-cols-3 gap-3">
+                                {results.map(r => (
+                                    <div key={r.platform} className={`flex items-center justify-between gap-2 px-4 py-3 rounded-2xl border transition-all ${r.status === 'completed' ? 'bg-emerald-50 border-emerald-200 text-emerald-700 shadow-sm' :
+                                        r.status === 'failed' ? 'bg-red-50 border-red-200 text-red-700' :
+                                            'bg-blue-50 border-blue-200 text-blue-700 animate-pulse'
+                                        }`}>
+                                        <div className="flex items-center gap-3 min-w-0">
+                                            {r.status === 'completed' && <div className="p-1 bg-emerald-500 rounded-full text-white"><Check className="w-3 h-3" /></div>}
+                                            {r.status === 'failed' && <div className="p-1 bg-red-500 rounded-full text-white"><X className="w-3 h-3" /></div>}
+                                            {r.status === 'processing' && <Loader2 className="w-4 h-4 animate-spin" />}
+                                            <span className="font-bold text-sm capitalize truncate">{r.platform}</span>
+                                        </div>
+                                        <div className="text-[10px] font-medium opacity-80 italic">
+                                            {r.status === 'completed' ? (r.data?.multi_results ? `Posted to ${r.data.multi_results.length} accounts` : 'Success') :
+                                                r.status === 'failed' ? r.error :
+                                                    'Publishing...'}
+                                        </div>
+                                    </div>
+                                ))}
+                            </div>
+                        </div>
+                    )}
+
+                    {error && (
+                        <div className="p-4 bg-red-500/10 border border-red-500/20 text-red-600 rounded-2xl text-sm font-bold flex items-center gap-3 animate-head-shake">
+                            <AlertCircle className="w-5 h-5" />
+                            {error}
+                        </div>
+                    )}
+
+                    <div className="flex items-center gap-4">
+                        <button
+                            onClick={onClose}
+                            className="px-8 py-4 rounded-2xl font-bold text-slate-600 hover:bg-slate-200 transition-colors"
+                        >
+                            Cancel
+                        </button>
+                        <button
+                            onClick={handleSubmit}
+                            disabled={loading}
+                            className="flex-1 bg-primary hover:bg-primary/90 text-white font-bold py-4 rounded-2xl transition-all shadow-xl shadow-primary/20 hover:shadow-primary/30 disabled:opacity-50 flex items-center justify-center gap-3 text-lg"
+                        >
+                            {loading ? (
+                                <div className="w-6 h-6 border-3 border-white/30 border-t-white rounded-full animate-spin" />
+                            ) : (
+                                <Share2 className="w-6 h-6" />
+                            )}
+                            {loading ? 'Processing Queue...' : `Publish to ${selectedPlatforms.length} Platforms`}
+                        </button>
+                    </div>
+                </div>
+            </div>
+        </div>
+    );
+}

social_media_publishers/frontend/src/components/TikTokUploadModal.jsx

@@ -11,6 +11,7 @@ export default function TikTokUploadModal({ platform, onClose, accountEmail, onS
     const [description, setDescription] = useState('');
     const [inputType, setInputType] = useState('file'); // 'file' or 'url'
     const [videoUrl, setVideoUrl] = useState('');
+    const [provider, setProvider] = useState('direct'); // 'direct' or 'oneup'
     const [loading, setLoading] = useState(false);
     const [error, setError] = useState(null);
     const videoRef = useRef(null);
@@ -110,6 +111,7 @@ export default function TikTokUploadModal({ platform, onClose, accountEmail, onS
 
         const formData = new FormData();
         formData.append('platform', platform);
+        formData.append('provider', provider);
         if (inputType === 'file') formData.append('file', file);
         else formData.append('video_url', videoUrl);
 
@@ -204,8 +206,22 @@ export default function TikTokUploadModal({ platform, onClose, accountEmail, onS
 
                     <form onSubmit={handleSubmit} className="flex flex-col lg:flex-row h-full overflow-hidden">
 
+                        {/* Provider Selection Bar */}
+                        <div className="lg:absolute lg:top-14 lg:left-0 lg:right-0 bg-slate-100/50 px-5 py-1.5 border-b border-border flex items-center gap-3 shrink-0 z-10">
+                            <div className="text-[10px] font-semibold text-secondary uppercase tracking-wider">Provider</div>
+                            <div className="flex bg-white p-0.5 rounded-lg border border-border">
+                                <button type="button" onClick={() => setProvider('direct')} className={`px-2 py-0.5 text-[10px] font-medium rounded-md transition-all ${provider === 'direct' ? 'bg-primary text-white shadow-sm' : 'text-secondary hover:text-primary'}`}>Direct API</button>
+                                <button type="button" onClick={() => setProvider('oneup')} className={`px-2 py-0.5 text-[10px] font-medium rounded-md transition-all ${provider === 'oneup' ? 'bg-primary text-white shadow-sm' : 'text-secondary hover:text-primary'}`}>OneUp</button>
+                            </div>
+                            {provider === 'oneup' && (
+                                <div className="text-[9px] text-amber-600 flex items-center gap-1 bg-amber-50 px-2 py-0.5 rounded">
+                                    <Info className="w-2.5 h-2.5" /> Note: Advanced settings (duet/stitch/branded) may be ignored by OneUp.
+                                </div>
+                            )}
+                        </div>
+
                         {/* LEFT COLUMN: Media Only */}
-                        <div className="w-full lg:w-1/2 p-5 lg:border-r border-border overflow-y-auto custom-scrollbar flex flex-col justify-center">
+                        <div className="w-full lg:w-1/2 p-5 lg:pt-12 lg:border-r border-border overflow-y-auto custom-scrollbar flex flex-col justify-center">
                             {/* 1. Media */}
                             <div className="space-y-3 w-full flex flex-col items-center">
                                 <div className="flex items-center justify-between w-full max-w-[260px]">

social_media_publishers/frontend/src/components/UploadModal.jsx

@@ -18,6 +18,7 @@ export default function UploadModal({ platform, onClose, accountEmail, onSuccess
     const [videoUrl, setVideoUrl] = useState('');
     const [downloadVideo, setDownloadVideo] = useState(false);
     const [inputType, setInputType] = useState('file'); // 'file' or 'url'
+    const [provider, setProvider] = useState('direct'); // 'direct' or 'oneup'
 
     const handleFileChange = (e) => {
         if (e.target.files && e.target.files[0]) {
@@ -47,6 +48,7 @@ export default function UploadModal({ platform, onClose, accountEmail, onSuccess
 
         const formData = new FormData();
         formData.append('platform', platform);
+        formData.append('provider', provider);
 
         if (inputType === 'file') {
             formData.append('file', file);
@@ -102,6 +104,33 @@ export default function UploadModal({ platform, onClose, accountEmail, onSuccess
                 )}
 
                 <form onSubmit={handleSubmit} className="space-y-5">
+                    {/* Provider Selection */}
+                    <div className="space-y-2">
+                        <label className="text-xs font-semibold text-secondary uppercase tracking-wider">Publishing Provider</label>
+                        <div className="flex bg-bg p-1 rounded-xl border border-border">
+                            <button
+                                type="button"
+                                onClick={() => setProvider('direct')}
+                                className={`flex-1 py-1.5 text-sm font-medium rounded-lg transition-all ${provider === 'direct'
+                                    ? 'bg-primary text-white shadow-sm'
+                                    : 'text-secondary hover:text-primary'
+                                    }`}
+                            >
+                                Direct API
+                            </button>
+                            <button
+                                type="button"
+                                onClick={() => setProvider('oneup')}
+                                className={`flex-1 py-1.5 text-sm font-medium rounded-lg transition-all ${provider === 'oneup'
+                                    ? 'bg-primary text-white shadow-sm'
+                                    : 'text-secondary hover:text-primary'
+                                    }`}
+                            >
+                                OneUp
+                            </button>
+                        </div>
+                    </div>
+
                     {/* Input Type Toggle */}
                     <div className="flex bg-bg p-1 rounded-xl border border-border">
                         <button

social_media_publishers/frontend/src/pages/Dashboard.jsx

@@ -1,9 +1,11 @@
 import React, { useState } from 'react';
 import { Link } from 'react-router-dom';
-import { Youtube, Music2, Instagram, Facebook, ArrowRight, Download, Loader2, AtSign, ShieldCheck } from 'lucide-react';
+import { Youtube, Music2, Instagram, Facebook, ArrowRight, Download, Loader2, AtSign, ShieldCheck, Twitter } from 'lucide-react';
 import { generateDashboardReport } from '../utils/pdfGenerator';
 import { LoadingButton } from '../components/Skeletons';
 import ProgressModal from '../components/ProgressModal';
+import GlobalUploadModal from '../components/GlobalUploadModal';
+import { Upload } from 'lucide-react';
 
 const platforms = [
     {
@@ -55,6 +57,16 @@ const platforms = [
         borderColor: 'group-hover:border-slate-800/50',
         bgHover: 'group-hover:shadow-[0_0_40px_-5px_rgba(30,41,59,0.3)]',
         status: 'Active'
+    },
+    {
+        id: 'twitter',
+        name: 'X (Twitter)',
+        description: 'Publish tweets, images & videos',
+        icon: Twitter,
+        color: 'text-sky-500',
+        borderColor: 'group-hover:border-sky-500/50',
+        bgHover: 'group-hover:shadow-[0_0_40px_-5px_rgba(14,165,233,0.3)]',
+        status: 'Active'
     }
 ];
 
@@ -64,6 +76,7 @@ export default function Dashboard() {
     const [progressLogs, setProgressLogs] = useState([]);
     const [isComplete, setIsComplete] = useState(false);
     const [pdfResult, setPdfResult] = useState(null);
+    const [showGlobalUpload, setShowGlobalUpload] = useState(false);
 
     const handleDownloadReport = async () => {
         try {
@@ -130,6 +143,14 @@ export default function Dashboard() {
 
     return (
         <div>
+            {showGlobalUpload && (
+                <GlobalUploadModal
+                    onClose={() => setShowGlobalUpload(false)}
+                    onSuccess={() => {
+                        // success handled in modal for now
+                    }}
+                />
+            )}
             <ProgressModal
                 isOpen={showProgress}
                 title={isComplete ? "Report Generated!" : "Generating Report..."}
@@ -193,6 +214,14 @@ export default function Dashboard() {
                 </div>
 
                 <div className="flex gap-3">
+                    <LoadingButton
+                        onClick={() => setShowGlobalUpload(true)}
+                        className="flex items-center gap-2 bg-primary hover:bg-primary/90 text-white px-5 py-2.5 rounded-xl font-medium transition-all shadow-lg shadow-primary/20"
+                    >
+                        <Upload className="w-4 h-4" />
+                        Global Upload
+                    </LoadingButton>
+
                     <LoadingButton
                         onClick={handleVerifyAppReview}
                         loading={verifying}

social_media_publishers/oneup_client.py

@@ -137,14 +137,26 @@ class OneUpClient:
         accounts = self.get_all_accounts()
         platform_type = platform_type.lower()
         
-        # Normalize platform names from OneUp to internal
-        # OneUp types: Facebook, X, Instagram, GBP, LinkedIn, TikTok, Threads, YouTube
-        
         for acc in accounts:
             net_type = acc.get('social_network_type', '').lower()
             
-            # Simple mapping/check
-            if platform_type not in net_type and net_type not in platform_type:
+            # Normalize platform names from OneUp to internal
+            # OneUp types: Facebook, X, Instagram, GBP, LinkedIn, TikTok, Threads, YouTube
+            # Internal types: facebook, twitter, instagram, tiktok, youtube, threads
+            
+            # Platform name mapping
+            mapping = {
+                "twitter": "x",
+                "x": "twitter"
+            }
+            
+            match = False
+            if platform_type in net_type or net_type in platform_type:
+                match = True
+            elif mapping.get(platform_type) == net_type:
+                match = True
+                
+            if not match:
                 continue
                 
             # Check identifier

social_media_publishers/oneup_service.py

@@ -49,22 +49,39 @@ class OneUpService:
         target_social_network_ids = []
         category_id = None
         
-        if account_identifier:
+        logger.info(f"📍 STEP 1: Resolving OneUp account for {platform} (Identifier: {account_identifier})")
+        if account_identifier == 'all':
+            logger.info(f"OneUpService: Resolving ALL accounts for platform {platform}")
+            accounts = self.client.get_all_accounts()
+            # Handle platform mapping consistency
+            mapping = {"twitter": "x", "x": "twitter"}
+            p_lower = platform.lower()
+            
+            for acc in accounts:
+                net_type = acc.get('social_network_type', '').lower()
+                match = False
+                if p_lower in net_type or net_type in p_lower:
+                    match = True
+                elif mapping.get(p_lower) == net_type:
+                    match = True
+                
+                if match:
+                    logger.info(f"OneUpService: Adding account {acc.get('social_network_name')} (ID: {acc.get('social_network_id')})")
+                    target_social_network_ids.append(acc.get('social_network_id'))
+                    if not category_id:
+                        category_id = acc.get('category_id')
+                        
+            if not target_social_network_ids:
+                return {"error": f"No OneUp accounts found for platform {platform}"}
+
+        elif account_identifier:
             account = self.client.find_account(platform, account_identifier)
             if account:
                 logger.info(f"OneUpService: Found account {account.get('social_network_name')} (ID: {account.get('social_network_id')})")
                 target_social_network_ids.append(account.get('social_network_id'))
-                # If the account has a category link (simulated in my client helper), use it.
-                # However, the API *list_social_accounts* doesn't strictly return category_id.
-                # The *list_category_accounts* does.
-                # My client helper tries to inject it.
                 category_id = account.get('category_id')
             else:
                 logger.warning(f"OneUpService: Could not find specific account for '{account_identifier}'.")
-                # Fallback? Maybe publish to ALL in a default category?
-                # For now, let's fail if specific account requested but not found, 
-                # OR if user wanted specific account but we are unsure.
-                # But if we can't find it, we can't get its ID.
                 return {"error": f"OneUp account not found for {platform} user {account_identifier}"}
         
         # If we didn't get a category_id from the account lookup (e.g. if we used list_social_accounts and it didn't have it),
@@ -78,7 +95,9 @@ class OneUpService:
             
             # Just pick the first one for now
             category_id = categories[0]['id']
-            logger.info(f"OneUpService: Using fallback category {categories[0]['category_name']} ({category_id})")
+            logger.info(f"✅ OneUpService: Using fallback category {categories[0]['category_name']} ({category_id})")
+
+        logger.info(f"📍 STEP 2: Preparing media for OneUp (Path: {content_path})")
 
         # If no specific account found/requested, are we broadcasting?
         # The logic in app.py implies one account focus.
@@ -112,8 +131,11 @@ class OneUpService:
                 return {"error": f"Failed to upload video for OneUp: {e}"}
 
         if not video_url:
+            logger.error("❌ OneUpService: No video URL available after media prep.")
             return {"error": "No video URL available for OneUp publishing."}
 
+        logger.info(f"📍 STEP 3: Scheduling post to OneUp (Category: {category_id}, Accounts: {target_social_network_ids})")
+
         # 3. Publish
         try:
             logger.info(f"OneUpService: Scheduling post to category {category_id}, accounts {target_social_network_ids}")
@@ -129,6 +151,7 @@ class OneUpService:
             if result.get('error'):
                 return {"error": result.get('message')}
             
+            logger.info(f"🚀 OneUpService: Successfully scheduled post! Result: {result.get('message')}")
             return {
                 "success": True, 
                 "message": result.get("message"), 

social_media_publishers/publisher.py

@@ -323,6 +323,8 @@ def run_official_publisher():
                         account_id = get_config_value("INSTAGRAM_USERNAME")
                     elif platform == 'facebook':
                         account_id = get_config_value("FACEBOOK_USERNAME")
+                    elif platform == 'twitter':
+                        account_id = get_config_value("X_USERNAME")
                     
                     if not account_id:
                         logger.warning(f"⚠️ No account configured for {platform} (e.g. {platform.upper()}_USERNAME/EMAIL). Using default auth.")

social_media_publishers/requirements.txt

@@ -25,4 +25,5 @@ cryptography
 git+https://github.com/jebin2/youtube_auto_pub.git
 aiohttp
 aiofiles
-itsdangerous
+itsdangerous
+xdk

social_media_publishers/twitter/auth.py

@@ -0,0 +1,71 @@
+import os
+from typing import Dict, List, Optional, Any
+from xdk.oauth2_auth import OAuth2PKCEAuth
+from ..base import SocialAuthCreator
+from src.config import get_config_value
+
+class TwitterAuthCreator(SocialAuthCreator):
+    """Auth creator for X (Twitter) using xdk."""
+    
+    def __init__(self):
+        super().__init__(platform_name="twitter")
+        self.scopes = [
+            "tweet.read",
+            "tweet.write",
+            "users.read",
+            "offline.access",
+            "media.write"
+        ]
+
+    def _get_auth_client(self, redirect_uri: str) -> OAuth2PKCEAuth:
+        client_id = get_config_value("x_client_id")
+        client_secret = get_config_value("x_client_secret")
+        
+        if not client_id:
+            raise ValueError("x_client_id not found in configuration")
+            
+        return OAuth2PKCEAuth(
+            client_id=client_id,
+            client_secret=client_secret,
+            redirect_uri=redirect_uri,
+            scope=self.scopes
+        )
+
+    def get_auth_url(self, redirect_uri: str) -> Dict[str, Any]:
+        """Generate X OAuth 2.0 auth URL with PKCE."""
+        auth = self._get_auth_client(redirect_uri)
+        url = auth.get_authorization_url()
+        
+        return {
+            "url": url,
+            "state": "twitter_auth", # xdk manages state internally if desired, or we can pass it
+            "code_verifier": auth.get_code_verifier()
+        }
+
+    def handle_callback(self, request_url: str, state: str, redirect_uri: str, **kwargs) -> Dict[str, Any]:
+        """Handle the OAuth 2.0 callback."""
+        code_verifier = kwargs.get("code_verifier")
+        if not code_verifier:
+            return {"success": False, "error": "Missing code_verifier"}
+
+        auth = self._get_auth_client(redirect_uri)
+        auth.set_pkce_parameters(code_verifier=code_verifier)
+        
+        token = auth.fetch_token(request_url)
+        
+        if token:
+            # We might want to get the username/id to save it in a identifiable way
+            # But SocialAuthCreator's save_token_data usually expects a name
+            # For now, let's just save it. 
+            # We can use get_me to find the username
+            from xdk import Client
+            client = Client(token=token)
+            me_resp = client.users.get_me()
+            username = getattr(me_resp.data, "username", "twitter_user") if me_resp.data else "twitter_user"
+            
+            filename = f"{self.token_prefix}{username.replace('@', '_at_')}.json"
+            self.save_token_data(token, filename)
+            
+            return {"success": True, "account": username}
+            
+        return {"success": False, "error": "Failed to fetch token"}

social_media_publishers/twitter/publisher.py

@@ -0,0 +1,279 @@
+import os
+import json
+import glob
+from typing import Dict, List, Optional, Any
+from xdk import Client
+from xdk.oauth2_auth import OAuth2PKCEAuth
+from xdk.posts.models import CreateRequest, CreateRequestMedia
+from xdk.media.models import UploadRequest, InitializeUploadRequest, AppendUploadRequest
+from ..base import SocialPublisher, SocialAuthCreator
+from src.config import get_config_value
+
+class TwitterPublisher(SocialPublisher):
+    """Publisher for X (Twitter) using xdk."""
+    
+    def __init__(self):
+        super().__init__()
+        self.platform_name = "twitter"
+        self.token_prefix = "twitter_token_"
+
+    def _get_token_manager(self):
+        # We can reuse the one from SocialAuthCreator if we want, 
+        # but SocialPublisher doesn't inherit from SocialAuthCreator. 
+        # We need a way to get the token.
+        # Standard pattern in this codebase seems to be checking 'encrypt' folder.
+        from .auth import TwitterAuthCreator
+        return TwitterAuthCreator()._get_token_manager()
+
+    def authenticate(self, account_id: Optional[str] = None) -> Optional[Client]:
+        """Authenticate with X using stored tokens."""
+        tm = self._get_token_manager()
+        if not tm:
+            print("❌ TokenManager not available")
+            return None
+
+        # If account_id is not provided, try to find the first connected account
+        if not account_id:
+            from .auth import TwitterAuthCreator
+            accounts = TwitterAuthCreator().list_connected_accounts()
+            if not accounts:
+                print("❌ No connected X accounts found")
+                return None
+            account_id = accounts[0]['name']
+
+        # Construct filename
+        filename = f"{self.token_prefix}{account_id.replace('@', '_at_')}.json"
+        
+        # Ensure token is downloaded and decrypted
+        try:
+            tm.download_and_decrypt(filename)
+        except Exception as e:
+            print(f"⚠️ Failed to sync token from HF: {e}")
+
+        encrypt_path = "encrypt"
+        if hasattr(tm, 'config') and hasattr(tm.config, 'encrypt_path'):
+            encrypt_path = tm.config.encrypt_path
+            
+        token_path = os.path.join(encrypt_path, filename)
+        if not os.path.exists(token_path):
+            print(f"❌ Token file not found: {token_path}")
+            return None
+
+        with open(token_path, 'r') as f:
+            token = json.load(f)
+
+        client_id = get_config_value("x_client_id")
+        client_secret = get_config_value("x_client_secret")
+        
+        # Initialize xdk Client with token and OAuth2PKCEAuth for refresh support
+        auth = OAuth2PKCEAuth(
+            client_id=client_id,
+            client_secret=client_secret,
+            token=token,
+            redirect_uri="https://localhost/callback" # Dummy, matching what was used in auth
+        )
+        
+        return Client(token=token, client_id=client_id, client_secret=client_secret)
+
+    def publish(self, content_path: str, metadata: Dict[str, Any]) -> Dict[str, Any]:
+        """Publish a tweet with optional media."""
+        client = self.authenticate(metadata.get('account_id'))
+        if not client:
+            return {"success": False, "error": "Authentication failed"}
+
+        text = metadata.get('text') or metadata.get('title') or metadata.get('caption', "")
+        
+        # Prepare media if path provided
+        media_id = None
+        if content_path:
+            local_path = self.prepare_content(content_path, metadata)
+            if local_path and os.path.exists(local_path):
+                print(f"📤 Uploading media to X: {local_path}")
+                try:
+                    # In xdk, upload seems to expect media as a field. 
+                    # If it's a file path, we might need to read it if the SDK doesn't.
+                    # Based on my research into xdk/media/client.py, it uses requests with json=...
+                    # This suggests media might need to be base64 or a URL, or the SDK is incomplete for files.
+                    # HOWEVER, many X libraries use chunked upload for videos.
+                    
+                    # Let's try a simple upload first if it's an image.
+                    # For videos, we might need chunked.
+                    is_video = local_path.lower().endswith(('.mp4', '.mov', '.avi'))
+                    category = "TWEET_VIDEO" if is_video else "TWEET_IMAGE"
+                    
+                    if is_video:
+                        media_id = self._upload_media_chunked(client, local_path, category)
+                    else:
+                        # For images, simple upload might work, but chunked is safer for large ones too
+                        import base64
+                        with open(local_path, "rb") as image_file:
+                            encoded_string = base64.b64encode(image_file.read()).decode('utf-8')
+                        
+                        upload_req = UploadRequest(media=encoded_string, media_category=category.lower())
+                        upload_res = client.media.upload(body=upload_req)
+                        
+                        if upload_res and upload_res.data:
+                            media_id = upload_res.data.id
+                            print(f"✅ Image uploaded successfully, ID: {media_id}")
+                except Exception as e:
+                    print(f"❌ Error uploading media: {e}")
+                    # If media upload fails, we might still try to post text if it's allowed
+                    # but usually better to report failure if media was requested.
+
+        # Create Tweet
+        try:
+            media_info = None
+            if media_id:
+                media_info = CreateRequestMedia(media_ids=[media_id])
+                
+            create_req = CreateRequest(text=text, media=media_info)
+            response = client.posts.create(body=create_req)
+            
+            if response and response.data:
+                tweet_id = response.data.id
+                print(f"🚀 Tweet published! ID: {tweet_id}")
+                return {
+                    "success": True, 
+                    "platform": "twitter", 
+                    "post_id": tweet_id,
+                    "url": f"https://x.com/i/status/{tweet_id}"
+                }
+            else:
+                return {"success": False, "error": f"Failed to create tweet: {response}"}
+        except Exception as e:
+            msg = str(e)
+            if "402" in msg:
+                print("❌ X API Error: Payment Required (402).")
+                print("💡 This usually means your X Developer App is on the 'Free' tier, which has very low limits (500 posts/month) or restricts media-posts.")
+                print("💡 Check your Developer Portal: https://developer.x.com/en/portal/dashboard")
+                return {"success": False, "error": "X API Payment Required (Check Tier)"}
+            
+            print(f"❌ Error creating tweet: {e}")
+            return {"success": False, "error": str(e)}
+
+    def _upload_media_chunked(self, client: Client, file_path: str, media_category: str) -> Optional[str]:
+        """Upload media in chunks (for videos)."""
+        import base64
+        import time
+        from xdk.media.models import InitializeUploadRequest, AppendUploadRequest
+        
+        file_size = os.path.getsize(file_path)
+        # category should be UPPERCASE like TWEET_VIDEO per X docs
+        
+        try:
+            # 1. INIT
+            print(f"🎬 Initializing chunked upload for {file_path} ({file_size} bytes)")
+            init_req = InitializeUploadRequest(
+                media_category=media_category,
+                media_type="video/mp4",
+                total_bytes=file_size
+            )
+            init_res = client.media.initialize_upload(body=init_req)
+            media_id = init_res.data.id
+            if not media_id:
+                print("❌ Failed to get media_id during INIT")
+                return None
+                
+            # 2. APPEND
+            segment_index = 0
+            chunk_size = 1024 * 1024 # 1MB chunks
+            with open(file_path, 'rb') as f:
+                while True:
+                    chunk = f.read(chunk_size)
+                    if not chunk:
+                        break
+                    
+                    encoded_chunk = base64.b64encode(chunk).decode('utf-8')
+                    append_req = AppendUploadRequest(
+                        media=encoded_chunk,
+                        segment_index=segment_index
+                    )
+                    client.media.append_upload(id=media_id, body=append_req)
+                    segment_index += 1
+            
+            print(f"📤 Uploaded {segment_index} chunks.")
+            
+            # 3. FINALIZE
+            client.media.finalize_upload(id=media_id)
+            
+            # 4. STATUS CHECK (wait for processing)
+            print(f"⌛ Waiting for video processing for ID: {media_id}")
+            for i in range(12): # Wait up to 1 minute
+                status = client.media.get_upload_status(media_id=media_id)
+                # Correctly handle model attributes
+                if status and status.data and status.data.processing_info:
+                    info = status.data.processing_info
+                    state = getattr(info, "state", "pending")
+                    if state == "succeeded":
+                        print(f"✅ Video processing complete!")
+                        return media_id
+                    if state == "failed":
+                        print(f"❌ Video processing failed: {info}")
+                        return None
+                    
+                    check_after = getattr(info, "check_after_secs", 5) or 5
+                    print(f"...processing ({state}, {getattr(info, 'progress_percent', 0)}%). Waiting {check_after}s...")
+                    time.sleep(check_after)
+                else:
+                    # If no processing info yet, just wait a bit
+                    print(f"...waiting for status...")
+                    time.sleep(5)
+            
+            return media_id
+        except Exception as e:
+            print(f"❌ Error in chunked upload: {e}")
+            return None
+
+    def get_uploaded_videos(self, account_id: str, limit: int = 10, page_token: str = None, start_date: str = None, end_date: str = None) -> Dict[str, Any]:
+        """Get recent tweets (optionally filtered)."""
+        client = self.authenticate(account_id)
+        if not client:
+            return {"videos": []}
+            
+        try:
+            # Get user ID
+            me_resp = client.users.get_me()
+            user_id = me_resp.data.id if me_resp and me_resp.data else None
+            if not user_id:
+                return {"videos": []}
+                
+            # Get tweets
+            # xdk often has helper methods or we use client.users.get_posts
+            response = client.users.get_posts(id=user_id, max_results=limit, pagination_token=page_token)
+            tweets = response.data or []
+            
+            return {
+                "videos": [
+                    {
+                        "id": getattr(t, "id", None),
+                        "title": (getattr(t, "text", "")[:50] + "...") if getattr(t, "text", None) else "No text",
+                        "published_at": getattr(t, "created_at", None),
+                        "views": 0, # X API v2 requires specific fields for public metrics
+                        "thumbnail": ""
+                    } for t in tweets
+                ],
+                "next_page_token": response.meta.next_token if response and response.meta else None
+            }
+        except Exception as e:
+            print(f"❌ Error fetching tweets: {e}")
+            return {"videos": []}
+
+    def get_account_stats(self, account_id: str, start_date: str = None, end_date: str = None) -> Dict[str, Any]:
+        """Get account stats (followers count etc)."""
+        client = self.authenticate(account_id)
+        if not client:
+            return {}
+            
+        try:
+            me_resp = client.users.get_me(user_fields=["public_metrics"])
+            me = me_resp.data
+            metrics = getattr(me, "public_metrics", None)
+            
+            return {
+                "total_followers": getattr(metrics, "followers_count", 0) if metrics else 0,
+                "total_tweets": getattr(metrics, "tweet_count", 0) if metrics else 0,
+                "username": getattr(me, "username", "unknown") if me else "unknown"
+            }
+        except Exception as e:
+            print(f"❌ Error fetching account stats: {e}")
+            return {}

src/config.py

@@ -164,6 +164,10 @@ def load_configuration(force_reload: bool = False) -> Dict[str, Any]:
         "encryption_key": os.getenv("ENCRYPTION_KEY"),
         "hf_token": os.getenv("HF_TOKEN"),
         "hf_space_url": os.getenv("HF_SPACE_URL"),
+
+        # X (Twitter)
+        "x_client_id": os.getenv("X_CLIENT_ID"),
+        "x_client_secret": os.getenv("X_CLIENT_SECRET"),
     }
 
     # On-screen CTA options