AriaNg-Native/app/scripts/services/aria2HttpRpcService.js

(function () {
    'use strict';

    angular.module('ariaNg').factory('aria2HttpRpcService', ['ariaNgNativeElectronService', 'ariaNgConstants', 'ariaNgCommonService', 'ariaNgSettingService', 'ariaNgLogService', function (ariaNgNativeElectronService, ariaNgConstants, ariaNgCommonService, ariaNgSettingService, ariaNgLogService) {
        var rpcUrl = ariaNgSettingService.getCurrentRpcUrl();
        var method = ariaNgSettingService.getCurrentRpcHttpMethod();
        var requestHeaders = ariaNgSettingService.getCurrentRpcRequestHeaders();

        var getUrlWithQueryString = function (url, parameters) {
            if (!url || url.length < 1) {
                return url;
            }

            var queryString = '';

            for (var key in parameters) {
                if (!parameters.hasOwnProperty(key)) {
                    continue;
                }

                var value = parameters[key];

                if (value === null || angular.isUndefined(value)) {
                    continue;
                }

                if (queryString.length > 0) {
                    queryString += '&';
                }

                if (angular.isObject(value) || angular.isArray(value)) {
                    value = angular.toJson(value);
                    value = ariaNgCommonService.base64Encode(value);
                    value = encodeURIComponent(value);
                }

                queryString += key + '=' + value;
            }

            if (queryString.length < 1) {
                return url;
            }

            if (url.indexOf('?') < 0) {
                queryString = '?' + queryString;
            } else {
                queryString = '&' + queryString;
            }

            return url + queryString;
        };

        return {
            request: function (context) {
                if (!context) {
                    return;
                }

                var requestContext = {
                    url: rpcUrl,
                    method: method,
                    headers: {},
                    timeout: ariaNgConstants.httpRequestTimeout
                };

                if (requestContext.method === 'POST') {
                    requestContext.data = angular.toJson(context.requestBody);
                    requestContext.headers['Content-Type'] = 'application/json';
                } else if (requestContext.method === 'GET') {
                    requestContext.url = getUrlWithQueryString(requestContext.url, context.requestBody);
                }

                if (requestHeaders) {
                    var lines = requestHeaders.split('\n');

                    for (var i = 0; i < lines.length; i++) {
                        var items = lines[i].split(':');

                        if (items.length !== 2) {
                            continue;
                        }

                        var name = items[0].trim();
                        var value = items[1].trim();

                        requestContext.headers[name] = value;
                    }
                }

                ariaNgLogService.debug('[aria2HttpRpcService.request] ' + (context && context.requestBody && context.requestBody.method ? context.requestBody.method + ' ' : '') + 'request start', requestContext);

                return ariaNgNativeElectronService.requestHttp(requestContext).then(function onSuccess(response) {
                    var data = response.data;

                    ariaNgLogService.debug('[aria2HttpRpcService.request] ' + (context && context.requestBody && context.requestBody.method ? context.requestBody.method + ' ' : '') + 'response success', response);

                    if (!data) {
                        return;
                    }

                    if (context.connectionSuccessCallback) {
                        context.connectionSuccessCallback({
                            rpcUrl: rpcUrl,
                            method: method
                        });
                    }

                    if (context.successCallback) {
                        context.successCallback(data.id, data.result);
                    }
                }).catch(function onError(response) {
                    var data = response.data;

                    ariaNgLogService.debug('[aria2HttpRpcService.request] ' + (context && context.requestBody && context.requestBody.method ? context.requestBody.method + ' ' : '') + 'response error', response);

                    if (!data) {
                        data = {
                            id: '-1',
                            error: {
                                message: 'Cannot connect to aria2!'
                            }
                        };

                        if (context.connectionFailedCallback) {
                            context.connectionFailedCallback({
                                rpcUrl: rpcUrl,
                                method: method
                            });
                        }
                    }

                    if (context.errorCallback) {
                        context.errorCallback(data.id, data.error);
                    }
                });
            },
            reconnect: function () {
                //Not implement
            },
            on: function (eventName, callback) {
                //Not implement
            }
        };
    }]);
}());