Tự động hóa quy trình video của bạn với API Snapencode

const axios = require('axios');
const FormData = require('form-data');
const fs = require('fs');
const path = require('path');
const chokidar = require('chokidar');
 
// --- Cấu hình ---
const API_BASE_URL = 'https://your-Snapencode-domain.com/api/client/v1';
const API_KEY = process.env.Snapencode_API_KEY || 'sk_your_api_key_here'; // Lời khuyên tốt nhất: sử dụng biến môi trường
const TARGET_FOLDER = 'root/automated-uploads'; // Đường dẫn tập hợp dữ liệu trong Snapencode
const WATCH_DIRECTORY = './videos-to-upload';
 
// Một bộ để theo dõi các tệp tin đang được xử lý để tránh tải lên trùng lặp
const processingFiles = new Set();

// (Thêm mã này dưới phần cấu hình)
 
async function uploadVideo(filePath) {
console.log(`[UPLOADING] Bắt đầu tải lên cho: ${path.basename(filePath)}`);
processingFiles.add(filePath); // Xác định tệp tin đang được xử lý
 
const form = new FormData();
form.append('video', fs.createReadStream(filePath));
form.append('folder', TARGET_FOLDER);
 
try {
const response = await axios.post(`${API_BASE_URL}/uploads`, form, {
headers: { ...form.getHeaders(), 'Authorization': `Bearer ${API_KEY}` },
});
console.log(`[SUCCESS] Tải lên được chấp nhận! ID Video: ${response.data.data.id}`);
return response.data.data.id;
} catch (error) {
console.error(`[FAILURE] Tải lên thất bại cho ${path.basename(filePath)}:`, error.response?.data?.message || error.message);
return null;
}
}
 
async function monitorStatus(videoId, filePath) {
if (!videoId) {
processingFiles.delete(filePath); // Xóa khỏi bộ xử lý trên thất bại
return;
}
 
console.log(`[MONITORING] Theo dõi trạng thái cho ID Video: ${videoId}`);
const interval = setInterval(async () => {
try {
const response = await axios.get(`${API_BASE_URL}/uploads/${videoId}`, {
headers: { 'Authorization': `Bearer ${API_KEY}` },
});
const { status, status_text } = response.data.data;
 
if (status === 6) { // Hoàn thành
console.log(`✅ [COMPLETE] Xử lý hoàn thành cho ID Video: ${videoId}!`);
clearInterval(interval);
processingFiles.delete(filePath); // Xóa khỏi bộ xử lý trên thành công
} else if (status === 7) { // Thất bại
console.error(`❌ [FAILED] Xử lý thất bại cho ID Video: ${videoId}.`);
clearInterval(interval);
processingFiles.delete(filePath);
} else {
console.log(`[STATUS] ID Video ${videoId}: ${status_text} (${status})`);
}
} catch (error) {
console.error(`[ERROR] Không thể lấy trạng thái cho ${videoId}:`, error.message);
clearInterval(interval);
processingFiles.delete(filePath);
}
}, 5000); // Kiểm tra mỗi 5 giây
}

// (Thêm mã này đến cuối tệp tin)
 
function initializeWatcher() {
console.log(`--- Snapencode Watch Folder Được Khởi động ---`);
console.log(`Theo dõi các tệp tin mới trong: ${path.resolve(WATCH_DIRECTORY)}`);
 
if (!fs.existsSync(WATCH_DIRECTORY)) {
console.log(`Tạo thư mục theo dõi...`);
fs.mkdirSync(WATCH_DIRECTORY, { recursive: true });
}
 
const watcher = chokidar.watch(WATCH_DIRECTORY, {
ignored: /(^|[\/\\])\../, // bỏ qua tệp tin ẩn
persistent: true,
ignoreInitial: true, // Không tải lên các tệp tin đã có trên khởi động
});
 
watcher.on('add', (filePath) => {
if (processingFiles.has(filePath)) {
return; // Bỏ qua nếu đang được xử lý
}
console.log(`[DETECTED] Tệp tin mới: ${path.basename(filePath)}`);
// Chờ một chút để đảm bảo tệp tin đã được viết đầy đủ trước khi tải lên
setTimeout(async () => {
const videoId = await uploadVideo(filePath);
await monitorStatus(videoId, filePath);
}, 2000);
});
}
 
initializeWatcher();

# Lời khuyên tốt nhất: đặt chìa khóa API như một biến môi trường
export Snapencode_API_KEY="sk_your_api_key_here"
 
# Chạy kịch bản
node upload-watcher.js