File Processing with Samvyo SDK

import samvyo from "samvyo-js-sdk";
 
async function initializeSDK() {
  const sessionToken = "your-session-token"; // Obtain this from your backend server
  const roomId = "your-room-id";
 
  try {
    // Initialize the SDK
    const sdkInstance = await samvyo.JsSdk.init({
      sessionToken,
      roomId
    });
 
    // Listen for initialization success
    sdkInstance.on('initSuccess', () => {
      console.log("SDK initialized successfully");
    });
 
    // Handle initialization errors
    sdkInstance.on('initError', (error) => {
      console.error("Error initializing SDK:", error);
    });
 
    return sdkInstance;
  } catch (error) {
    console.error("Error in initialization process:", error);
    throw error;
  }
}

startProcessing({
  inputFiles: [{
    type: "mp4",
    url: "https://your-bucket.region.digitaloceanspaces.com/videos/input.mp4",
    key: "videos/folder1/folder2" // optional
  }],
  outputQualities: ["360p", "720p", "1080p"], // optional
  bucket: "your-bucket", // optional
  region: "your-region" // optional
})

async function processFiles(sdkInstance) {
  try {
    // Example with all parameters
    const result = await sdkInstance.startProcessing({
      inputFiles: [
        {
          url: "https://your-bucket.region.digitaloceanspaces.com/videos/input1.mp4",
          type: "mp4",
          key: "videos/processed/input1"
        }
      ],
      outputQualities: ['1080p', '360p', '240p'],
      bucket: "custom-bucket",
      region: "custom-region"
    });
 
    // Example using default settings
    const resultWithDefaults = await sdkInstance.startProcessing({
      inputFiles: [
        {
          url: "https://your-bucket.region.digitaloceanspaces.com/videos/input2.mp4",
          type: "mp4"
        }
      ]
    });
 
    console.log("Processing started:", result);
  } catch (error) {
    console.error("Error processing files:", error);
  }
}
 
// Example of processing multiple batches
async function processMultipleBatches(sdkInstance) {
  const batchSize = 10;
  const allFiles = [/* array of file objects */];
  
  // Process files in batches of 10
  for (let i = 0; i < allFiles.length; i += batchSize) {
    const batch = allFiles.slice(i, i + batchSize);
    await sdkInstance.startProcessing({
      inputFiles: batch,
      outputQualities: ['720p', '360p']
    });
  }
}

// Listen for processing start
sdkInstance.on('processingStarted', (data) => {
  console.log("Processing started:", data);
  // data contains:
  // - processingStartTime: Timestamp when processing started
  // - requestId: Unique identifier for the processing request
});
 
// Listen for processing errors
sdkInstance.on('processingError', (error) => {
  console.error("Error during file processing:", error);
  // error contains:
  // - processingError: The error that occurred
  // - requestId: The request identifier
  // - error details: Additional error information
});
 
// Listen for processing completion
sdkInstance.on('processingCompleted', (details) => {
  console.log("Processing completed successfully:", details);
  // details contains:
  // - totalProcessingTime: Total time taken for processing in sec
  // - hlsfileKey: Key of the generated HLS file
  // - size: Size of the processed file in mb
  // - originalFile: Information about the original input file
  // - lastFile: Boolean indicating if this is the last file in the processing array
  // - requestId: The request identifier
});

async function processFilesWithEvents(sdkInstance) {
  try {
    // Set up event listeners before starting processing
    sdkInstance.on('processingStarted', (data) => {
      console.log("Processing started at:", new Date(data.processingStartTime));
      console.log("Request ID:", data.requestId);
      // Update UI to show processing status
      updateProcessingStatus("Processing started...");
    });
 
    sdkInstance.on('processingError', (error) => {
      console.error("Processing failed for request:", error.requestId);
      console.error("Error details:", error.processingError);
      // Update UI to show error
      updateProcessingStatus("Processing failed: " + error.processingError);
    });
 
    sdkInstance.on('processingCompleted', (details) => {
      console.log("Processing completed successfully");
      console.log("Total processing time:", details.totalProcessingTime);
      console.log("HLS file key:", details.hlsfileKey);
      console.log("File size:", details.size);
      console.log("Is last file:", details.lastFile);
      
      // Update UI with processed file information
      updateProcessingStatus("Processing completed!");
      if (details.lastFile) {
        console.log("All files have been processed");
      }
    });
 
    // Start the processing
    const result = await sdkInstance.startProcessing({
      inputFiles: [
        {
          url: "https://your-bucket.region.digitaloceanspaces.com/videos/input1.mp4",
          type: "mp4"
        }
      ],
      outputQualities: ['1080p', '360p', '240p']
    });
 
  } catch (error) {
    console.error("Error initiating file processing:", error);
  }
}