🚀 VidPipe

import fs from 'fs';
import fetch from 'node-fetch';

async function uploadVideo(accessToken, videoPath, caption) {
  try {
    const formData = new FormData();
    const videoBuffer = fs.readFileSync(videoPath);
    const videoBlob = new Blob([videoBuffer], { type: 'video/mp4' });

    formData.append('video', videoBlob, 'video.mp4');
    formData.append('caption', caption || 'Uploaded via VidPipe');

    const response = await fetch('https://tikbridge.onrender.com/upload', {
      method: 'POST',
      headers: { 'Authorization': `Bearer ${accessToken}` }, // Replace accessToken with your actual token
      body: formData
    });

    const result = await response.json();

    if (response.status === 429) {
      console.log(`Rate limited: ${result.message}`);
      console.log(`Wait ${result.retryAfter} seconds before trying again`);
      return { success: false, rateLimited: true, retryAfter: result.retryAfter };
    }

    if (response.ok) {
      console.log('Upload successful:', result);
      return { success: true, data: result };
    } else {
      console.error('Upload failed:', result);
      return { success: false, error: result };
    }
  } catch (error) {
    console.error('Upload error:', error);
    return { success: false, error: error.message };
  }
}

// Usage example - You can use either access token OR refresh token
const myToken = 'act.XI74axcyeKsljoutizKrdEkSAyPrhsDLfCydn9IYBwme04yEzjVTgloGcajgl4686.e2'; // Access token
// OR use refresh token (starts with 'rft.') - we'll automatically get fresh access token
// const myToken = 'rft.example_refresh_token_here';
const result = await uploadVideo(
  myToken, // Works with both access tokens and refresh tokens!
  './my-video.mp4',
  'My awesome video! 🚀'
);

if (result.rateLimited) {
  console.log(`Waiting ${result.retryAfter} seconds...`);
  setTimeout(() => {
    // Retry upload after cooldown
    uploadVideo(myToken, './my-video.mp4', 'My awesome video! 🚀');
  }, result.retryAfter * 1000);
}