From 6bda0e006cbdafbd33dc444920115560d3780576 Mon Sep 17 00:00:00 2001
From: Colin McFadden <colin@hedge.video>
Date: Tue, 25 Jun 2024 12:37:12 -0500
Subject: [PATCH] add aws batch queueing

---
 .../models/filehandlers/Filehandlerbase.php   | 27 ++++++++++++++++++-
 1 file changed, 26 insertions(+), 1 deletion(-)

diff --git a/application/models/filehandlers/Filehandlerbase.php b/application/models/filehandlers/Filehandlerbase.php
index 1cdb508c..c2a1eb3c 100644
--- a/application/models/filehandlers/Filehandlerbase.php
+++ b/application/models/filehandlers/Filehandlerbase.php
@@ -1,6 +1,9 @@
 <?php
 
 //use Aws\S3\S3Client;
+use Aws\Batch\BatchClient;
+use Aws\Exception\AwsException;
+
 
 if ( ! defined('BASEPATH')) exit('No direct script access allowed');
 
@@ -409,7 +412,29 @@ public function save() {
 	}
 
 	public function queueBatchItem($fileObjectId) {
-		// do AWS batch queueing here
+		$batchClient = new BatchClient([
+			'region' => $this->config->item('awsQueueRegion'), // e.g., 'us-west-2'
+			'version' => 'latest',
+			'credentials' => [
+				'key'    => $this->config->item('awsQueueAccessKey'),
+				'secret' => $this->config->item('awsQueueSecretKey'),
+			],
+		]);
+		$params = [
+			'jobName' => 'transcode_' . $fileObjectId,
+			'jobQueue' => 'PrimaryJobQueue',
+			'jobDefinition' => $this->config->item('awsQueueJobDefinition'),
+			'containerOverrides' => [
+        		'command' => ['php', 'index.php', 'beltdrive', 'processAWSBatchJob', $fileObjectId],
+    		],
+		];
+		try {
+			$result = $batchClient->submitJob($params);
+		} catch (AwsException $e) {
+			$this->logging->processingInfo("taskFailed",get_class($this),"Failed to submit job to AWS Batch" . $e->getMessage(),$fileObjectId,0);
+		}
+		
+
 	}
 
 	/**