feat: implement adaptive cache for Tizen

src/withStreamingServer/getFreeSpace.js

@@ -0,0 +1,29 @@
+function getFreeSpace() {
+    return new Promise(function (resolve, reject) {
+        function onStorageInfo(info) {
+            if (info && info.units) {
+                var internalStorage = info.units.find(function (unit) {
+                    return unit.type === 'INTERNAL';
+                });
+
+                if (internalStorage && typeof internalStorage.availableCapacity === 'number') {
+                    return resolve(internalStorage.availableCapacity);
+                }
+
+                return reject(new Error('No internal storage found'));
+            }
+        }
+
+        function onStorageInfoError(error) {
+            return reject(error);
+        }
+
+        if (window.tizen) {
+            window.tizen.systeminfo.getPropertyValue('STORAGE', onStorageInfo, onStorageInfoError);
+        } else {
+            reject('Tizen api not available');
+        }
+    });
+}
+
+module.exports = getFreeSpace;

src/withStreamingServer/setFreeSpace.js

@@ -0,0 +1,28 @@
+var url = require('url');
+
+function setFreeSpace(streamingServerURL, freeSpace) {
+    var endpoint = url.resolve(streamingServerURL, '/setFreeSpace');
+
+    var body = JSON.stringify({
+        freeSpace: freeSpace,
+    });
+
+    var options = {
+        method: 'POST',
+        headers: {
+            'Content-Type': 'application/json'
+        },
+        body: body,
+    };
+
+    return fetch(endpoint, options)
+        .then(function(resp) {
+            if (resp.ok) {
+                return resp.json();
+            }
+
+            throw new Error(resp.status + ' (' + resp.statusText + ')');
+        });
+}
+
+module.exports = setFreeSpace;

src/withStreamingServer/wipeAll.js

@@ -0,0 +1,23 @@
+var url = require('url');
+
+function wipeAll(streamingServerURL) {
+    var endpoint = url.resolve(streamingServerURL, '/wipeAll');
+
+    var options = {
+        method: 'GET',
+        headers: {
+            'Content-Type': 'application/json'
+        },
+    };
+
+    return fetch(endpoint, options)
+        .then(function(resp) {
+            if (resp.ok) {
+                return resp.json();
+            }
+
+            throw new Error(resp.status + ' (' + resp.statusText + ')');
+        });
+}
+
+module.exports = wipeAll;

src/withStreamingServer/withStreamingServer.js

@@ -6,6 +6,9 @@ var deepFreeze = require('deep-freeze');
 var mediaCapabilities = require('../mediaCapabilities');
 var convertStream = require('./convertStream');
 var fetchVideoParams = require('./fetchVideoParams');
+var getFreeSpace = require('./getFreeSpace');
+var setFreeSpace = require('./setFreeSpace');
+var wipeAll = require('./wipeAll');
 var ERROR = require('../error');
 
 function withStreamingServer(Video) {
@@ -102,6 +105,17 @@ function withStreamingServer(Video) {
                         video.dispatch({ type: 'command', commandName: 'unload' });
                         loadArgs = commandArgs;
                         onPropChanged('stream');
+
+                        getFreeSpace()
+                            .then(function(freeSpace) {
+                                setFreeSpace(commandArgs.streamingServerURL, freeSpace)
+                                    .catch(function(error) {
+                                        console.warn('Failed to set free space', error);
+                                    });
+                            }).catch(function(error) {
+                                console.warn('Failed to get free space', error);
+                            });
+
                         convertStream(commandArgs.streamingServerURL, commandArgs.stream, commandArgs.seriesInfo)
                             .then(function(result) {
                                 var mediaURL = result.url;
@@ -273,6 +287,12 @@ function withStreamingServer(Video) {
                     return true;
                 }
                 case 'unload': {
+                    if (loadArgs && loadArgs.streamingServerURL) {
+                        wipeAll(loadArgs.streamingServerURL)
+                            .catch(function(error) {
+                                console.warn('Failed to remove all streams', error);
+                            });
+                    }
                     loadArgs = null;
                     loaded = false;
                     actionsQueue = [];