ビデオワークフローを自動化するにはSnapencode APIを使用する

const axios = require('axios');
const FormData = require('form-data');
const fs = require('fs');
const path = require('path');
const chokidar = require('chokidar');
 
// --- 設定 ---
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'; // 最善の実践: 環境変数を使用する
const TARGET_FOLDER = 'root/automated-uploads'; // Snapencode のコレクションパス
const WATCH_DIRECTORY = './videos-to-upload';
 
// 処理中のファイルを追跡するセット
const processingFiles = new Set();

// (設定セクションの下に追加)
 
async function uploadVideo(filePath) {
console.log(`[UPLOADING] ビデオアップロード開始: ${path.basename(filePath)}`);
processingFiles.add(filePath); // 処理中のファイルとしてマーク
 
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(`[成功] アップロード受け入れ! ビデオID: ${response.data.data.id}`);
return response.data.data.id;
} catch (error) {
console.error(`[失敗] アップロードに失敗しました: ${path.basename(filePath)}:`, error.response?.data?.message || error.message);
return null;
}
}
 
async function monitorStatus(videoId, filePath) {
if (!videoId) {
processingFiles.delete(filePath); // 処理中のセットから削除
return;
}
 
console.log(`[監視] ビデオID: ${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) { // 完了
console.log(`✅ [完了] ビデオID: ${videoId} の処理が完了しました!`);
clearInterval(interval);
processingFiles.delete(filePath); // 処理中のセットから削除
} else if (status === 7) { // 失敗
console.error(`❌ [失敗] ビデオID: ${videoId} の処理に失敗しました。`);
clearInterval(interval);
processingFiles.delete(filePath);
} else {
console.log(`[ステータス] ビデオID ${videoId}: ${status_text} (${status})`);
}
} catch (error) {
console.error(`[エラー] ビデオID: ${videoId} のステータスを取得できませんでした:`, error.message);
clearInterval(interval);
processingFiles.delete(filePath);
}
}, 5000); // 5 秒ごとにチェック
}

// (ファイルの末尾に追加)
 
function initializeWatcher() {
console.log(`--- Snapencode Watch Folder Initialized ---`);
console.log(`ディレクトリを監視中: ${path.resolve(WATCH_DIRECTORY)}`);
 
if (!fs.existsSync(WATCH_DIRECTORY)) {
console.log(`ウォッチフォルダを作成します...`);
fs.mkdirSync(WATCH_DIRECTORY, { recursive: true });
}
 
const watcher = chokidar.watch(WATCH_DIRECTORY, {
ignored: /(^|[\/\\])\../, // ドットファイルを無視
persistent: true,
ignoreInitial: true, // 起動時には既存のファイルをアップロードしないようにする
});
 
watcher.on('add', (filePath) => {
if (processingFiles.has(filePath)) {
return; // 既に処理中の場合はスキップ
}
console.log(`[検出] 新しいファイル: ${path.basename(filePath)}`);
// ファイルが完全に書き込まれるまで待ってからアップロードする
setTimeout(async () => {
const videoId = await uploadVideo(filePath);
await monitorStatus(videoId, filePath);
}, 2000);
});
}
 
initializeWatcher();

# 最善の実践: API キーを環境変数として設定する
export Snapencode_API_KEY="sk_your_api_key_here"
 
# スクリプトを実行します
node upload-watcher.js