feat: Expose startDownload API (#50)

Clients needed a way to manually trigger video downloads from their own
custom UI, outside of the standard player interface. This change bridges
the native startDownload functionality to JavaScript so developers can
fully control when and how downloads are initiated, while maintaining
support for advanced native features like the resolution picker dialog.

Author: syed-tp

TPStreamsRNPlayerView.podspec

@@ -21,7 +21,7 @@ Pod::Spec.new do |s|
       'DEFINES_MODULE' => 'YES',
       'CLANG_ALLOW_NON_MODULAR_INCLUDES_IN_FRAMEWORK_MODULES' => 'YES'
     }
-  s.dependency "TPStreamsSDK" , "1.2.16"
+  s.dependency "TPStreamsSDK" , "1.2.23"
 
 
   # Ensure the module is not built as a framework to avoid bridging header conflicts

android/gradle.properties

@@ -3,4 +3,4 @@ Tpstreams_minSdkVersion=24
 Tpstreams_targetSdkVersion=34
 Tpstreams_compileSdkVersion=35
 Tpstreams_ndkVersion=27.1.12297006
-Tpstreams_tpstreamsAndroidPlayerVersion=1.1.8
+Tpstreams_tpstreamsAndroidPlayerVersion=1.1.9

android/src/main/java/com/tpstreams/JsonUtils.kt

@@ -1,5 +1,6 @@
 package com.tpstreams
 
+import org.json.JSONException
 import org.json.JSONObject
 
 object JsonUtils {
@@ -43,4 +44,16 @@ object JsonUtils {
         }
         return map
     }
-} 
+
+    fun jsonStringToMap(jsonString: String?): Map<String, String>? {
+        if (jsonString.isNullOrEmpty()) return null
+        return try {
+            val jsonObject = JSONObject(jsonString)
+            jsonObject.keys()
+                .asSequence()
+                .associate { it to jsonObject.getString(it) }
+        } catch (e: JSONException) {
+            null
+        }
+    }
+}

android/src/main/java/com/tpstreams/TPStreamsDownloadModule.kt

@@ -6,6 +6,7 @@ import com.facebook.react.bridge.Arguments
 import com.facebook.react.bridge.ReactMethod
 import com.facebook.react.bridge.ReactApplicationContext
 import com.facebook.react.bridge.ReactContextBaseJavaModule
+import com.facebook.react.bridge.ReadableMap
 import com.facebook.react.bridge.WritableMap
 import com.facebook.react.modules.core.DeviceEventManagerModule
 import com.tpstreams.player.download.DownloadClient
@@ -23,6 +24,37 @@ class TPStreamsDownloadModule(private val reactContext: ReactApplicationContext)
         return "TPStreamsDownload"
     }
 
+    @ReactMethod
+    fun startDownload(
+        videoId: String,
+        accessToken: String,
+        resolution: String?,
+        metadata: ReadableMap?,
+        promise: Promise
+    ) {
+        try {
+            val metadataString = metadata?.let { org.json.JSONObject(it.toHashMap()).toString() }
+            val metadataMap = JsonUtils.jsonStringToMap(metadataString)
+
+            val activity = currentActivity ?: run {
+                promise.reject("DOWNLOAD_START_ERROR", "No current activity available")
+                return
+            }
+
+            downloadClient.startDownload(
+                activity,
+                videoId,
+                accessToken,
+                resolution,
+                metadataMap
+            )
+            promise.resolve(null)
+        } catch (e: Exception) {
+            Log.e(TAG, "Error starting download: ${e.message}", e)
+            promise.reject("DOWNLOAD_START_ERROR", e.message, e)
+        }
+    }
+
     @ReactMethod
     fun addDownloadProgressListener(promise: Promise) {
         try {

android/src/main/java/com/tpstreams/TPStreamsRNPlayerViewManager.kt

@@ -96,20 +96,7 @@ class TPStreamsRNPlayerViewManager : SimpleViewManager<TPStreamsRNPlayerView>(),
 
   @ReactProp(name = "downloadMetadata")
   override fun setDownloadMetadata(view: TPStreamsRNPlayerView, metadata: String?) {
-    val metadataMap = if (!metadata.isNullOrEmpty()) {
-      try {
-        val jsonObject = org.json.JSONObject(metadata)
-        val map = jsonObject.keys()
-        .asSequence()
-        .associate { it to jsonObject.getString(it) }
-        .toMutableMap()
-        map
-      } catch (e: org.json.JSONException) {
-        android.util.Log.w("TPStreamsRN", "Error parsing download metadata: ${e.message}")
-        null
-      }
-    } else null
-    view.setDownloadMetadata(metadataMap)
+    view.setDownloadMetadata(JsonUtils.jsonStringToMap(metadata))
   }
 
   // Command implementations

ios/TPStreamsDownloadModule.mm

@@ -11,6 +11,13 @@ @interface RCT_EXTERN_MODULE(TPStreamsDownload, RCTEventEmitter)
                   rejecter:(RCTPromiseRejectBlock)reject)
 
 // Download Control Methods
+RCT_EXTERN_METHOD(startDownload:(NSString *)videoId
+                  accessToken:(NSString *)accessToken
+                  resolution:(NSString *)resolution
+                  metadata:(NSDictionary *)metadata
+                  resolver:(RCTPromiseResolveBlock)resolve
+                  rejecter:(RCTPromiseRejectBlock)reject)
+
 RCT_EXTERN_METHOD(pauseDownload:(NSString *)videoId
                   resolver:(RCTPromiseResolveBlock)resolve
                   rejecter:(RCTPromiseRejectBlock)reject)

ios/TPStreamsDownloadModule.swift

@@ -49,6 +49,20 @@ class TPStreamsDownloadModule: RCTEventEmitter, TPStreamsDownloadDelegate {
         return true
     }
 
+    @objc
+    func startDownload(_ videoId: String, accessToken: String, resolution: String?, metadata: NSDictionary?, resolver resolve: @escaping RCTPromiseResolveBlock, rejecter reject: @escaping RCTPromiseRejectBlock) {
+        DispatchQueue.main.async { [weak self] in
+            guard let self = self else { return }
+            
+            let metadataDict = metadata as? [String: Any]
+            let res = (resolution?.isEmpty ?? true) ? nil : resolution
+            let presentingVC = (res == nil) ? RCTPresentedViewController() : nil
+            
+            self.downloadManager.startDownload(assetID: videoId, accessToken: accessToken, resolution: res, allowResolutionFallback: true, metadata: metadataDict, presentingViewController: presentingVC, completion: nil)
+            resolve(nil)
+        }
+    }
+
     @objc
     func addDownloadProgressListener(_ resolve: @escaping RCTPromiseResolveBlock, rejecter reject: @escaping RCTPromiseRejectBlock) {
         isListening = true

src/TPStreamsDownload.tsx

@@ -31,6 +31,20 @@ export type DownloadStateChangeListener = (
 
 const downloadEventEmitter = new NativeEventEmitter(TPStreamsDownload);
 
+export function startDownload(
+  videoId: string,
+  accessToken: string,
+  resolution: string | null = null,
+  metadata: Record<string, any> | null = null
+): Promise<void> {
+  return TPStreamsDownload.startDownload(
+    videoId,
+    accessToken,
+    resolution,
+    metadata
+  );
+}
+
 export function addDownloadProgressListener(): Promise<void> {
   return TPStreamsDownload.addDownloadProgressListener();
 }

src/index.tsx

@@ -8,6 +8,7 @@ export { default as TPStreamsPlayerView } from './TPStreamsPlayer';
 export type { TPStreamsPlayerRef } from './TPStreamsPlayer';
 
 export {
+  startDownload,
   pauseDownload,
   resumeDownload,
   removeDownload,