diff --git a/alpha/apps/kaltura/lib/clipconcat/kClipManager.php b/alpha/apps/kaltura/lib/clipconcat/kClipManager.php index 13ca0874cb2..84910eda638 100644 --- a/alpha/apps/kaltura/lib/clipconcat/kClipManager.php +++ b/alpha/apps/kaltura/lib/clipconcat/kClipManager.php @@ -438,12 +438,13 @@ public function createTempEntryForClip($partnerId) /** * @param string $entryId - * @param FileSyncKey $concatSyncKey + * @param asset $concatAsset * @throws Exception * @throws KalturaAPIException */ - private function addDestinationEntryAsset($entryId, $concatSyncKey) + private function addDestinationEntryAsset($entryId, $concatAsset) { + $concatSyncKey = $concatAsset->getSyncKey(flavorAsset::FILE_SYNC_ASSET_SUB_TYPE_ASSET); $dbAsset = assetPeer::retrieveOriginalByEntryId($entryId); $dbEntry = entryPeer::retrieveByPK($entryId); $isNewAsset = false; @@ -451,6 +452,8 @@ private function addDestinationEntryAsset($entryId, $concatSyncKey) { $isNewAsset = true; $dbAsset = kFlowHelper::createOriginalFlavorAsset($dbEntry->getPartnerId(), $entryId); + $dbAsset->setFileExt($concatAsset->getFileExt()); + $dbAsset->save(); } if(!$dbAsset) @@ -472,10 +475,9 @@ private function concatDone(BatchJob $batchJob) /** @var kConcatJobData $concatJobData */ $concatJobData = $batchJob->getParentJob()->getData(); $concatAsset = assetPeer::retrieveById($concatJobData->getFlavorAssetId()); - $concatSyncKey = $concatAsset->getSyncKey(flavorAsset::FILE_SYNC_ASSET_SUB_TYPE_ASSET); /** @var kClipConcatJobData $clipConcatJobData */ $clipConcatJobData = $batchJob->getRootJob()->getData(); - $this->addDestinationEntryAsset($clipConcatJobData->getDestEntryId(), $concatSyncKey); + $this->addDestinationEntryAsset($clipConcatJobData->getDestEntryId(), $concatAsset); $this->deleteEntry($clipConcatJobData->getTempEntryId()); kJobsManager::updateBatchJob($batchJob->getRootJob(), BatchJob::BATCHJOB_STATUS_FINISHED); }