| /* |
| Licensed to the Apache Software Foundation (ASF) under one or more |
| contributor license agreements. See the NOTICE file distributed with |
| this work for additional information regarding copyright ownership. |
| The ASF licenses this file to You under the Apache License, Version 2.0 |
| (the "License"); you may not use this file except in compliance with |
| the License. You may obtain a copy of the License at |
| |
| http://www.apache.org/licenses/LICENSE-2.0 |
| |
| Unless required by applicable law or agreed to in writing, software |
| distributed under the License is distributed on an "AS IS" BASIS, |
| WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
| See the License for the specific language governing permissions and |
| limitations under the License. |
| */ |
| |
| var solrAdminServices = angular.module('solrAdminServices', ['ngResource']); |
| |
| solrAdminServices.factory('System', |
| ['$resource', function($resource) { |
| return $resource('admin/info/system', {"wt":"json", "nodes": "@nodes", "_":Date.now()}); |
| }]) |
| .factory('Metrics', |
| ['$resource', function($resource) { |
| return $resource('admin/metrics', {"wt":"json", "nodes": "@nodes", "prefix":"@prefix", "_":Date.now()}); |
| }]) |
| .factory('Collections', |
| ['$resource', function($resource) { |
| return $resource('admin/collections', |
| {'wt':'json', '_':Date.now()}, { |
| "list": {params:{action: "LIST"}}, |
| "listaliases": {params:{action: "LISTALIASES"}}, |
| "status": {params:{action: "CLUSTERSTATUS"}}, |
| "add": {params:{action: "CREATE"}}, |
| "delete": {params:{action: "DELETE"}}, |
| "rename": {params:{action: "RENAME"}}, |
| "createAlias": {params:{action: "CREATEALIAS"}}, |
| "deleteAlias": {params:{action: "DELETEALIAS"}}, |
| "deleteReplica": {params:{action: "DELETEREPLICA"}}, |
| "addReplica": {params:{action: "ADDREPLICA"}}, |
| "deleteShard": {params:{action: "DELETESHARD"}}, |
| "reload": {method: "GET", params:{action:"RELOAD", core: "@core"}} |
| }); |
| }]) |
| .factory('Cores', |
| ['$resource', function($resource) { |
| return $resource('admin/cores', |
| {'wt':'json', '_':Date.now()}, { |
| "query": {}, |
| "list": {params:{indexInfo: false}}, |
| "add": {params:{action: "CREATE"}}, |
| "unload": {params:{action: "UNLOAD", core: "@core"}}, |
| "rename": {params:{action: "RENAME"}}, |
| "swap": {params:{action: "SWAP"}}, |
| "reload": {method: "GET", params:{action:"RELOAD", core: "@core"}, headers:{doNotIntercept: "true"}} |
| }); |
| }]) |
| .factory('Logging', |
| ['$resource', function($resource) { |
| return $resource('admin/info/logging', {'wt':'json', '_':Date.now()}, { |
| "events": {params: {since:'0'}}, |
| "levels": {}, |
| "setLevel": {} |
| }); |
| }]) |
| .factory('Zookeeper', |
| ['$resource', function($resource) { |
| return $resource('admin/zookeeper', {wt:'json', _:Date.now()}, { |
| "simple": {}, |
| "liveNodes": {params: {path: '/live_nodes'}}, |
| "clusterState": {params: {detail: "true", path: "/clusterstate.json"}}, |
| "detail": {params: {detail: "true", path: "@path"}}, |
| "configs": {params: {detail:false, path: "/configs/"}}, |
| "aliases": {params: {detail: "true", path: "/aliases.json"}, transformResponse:function(data) { |
| var znode = $.parseJSON(data).znode; |
| if (znode.data) { |
| return {aliases: $.parseJSON(znode.data).collection}; |
| } else { |
| return {aliases: {}}; |
| } |
| }} |
| }); |
| }]) |
| .factory('ZookeeperStatus', |
| ['$resource', function($resource) { |
| return $resource('admin/zookeeper/status', {wt:'json', _:Date.now()}, { |
| "monitor": {} |
| }); |
| }]) |
| .factory('Properties', |
| ['$resource', function($resource) { |
| return $resource('admin/info/properties', {'wt':'json', '_':Date.now()}); |
| }]) |
| .factory('Threads', |
| ['$resource', function($resource) { |
| return $resource('admin/info/threads', {'wt':'json', '_':Date.now()}); |
| }]) |
| .factory('Properties', |
| ['$resource', function($resource) { |
| return $resource('admin/info/properties', {'wt':'json', '_':Date.now()}); |
| }]) |
| .factory('Replication', |
| ['$resource', function($resource) { |
| return $resource(':core/replication', {'wt':'json', core: "@core", '_':Date.now()}, { |
| "details": {params: {command: "details"}}, |
| "command": {params: {}} |
| }); |
| }]) |
| .factory('CoreSystem', |
| ['$resource', function($resource) { |
| return $resource(':core/admin/system', {wt:'json', core: "@core", _:Date.now()}); |
| }]) |
| .factory('Update', |
| ['$resource', function($resource) { |
| return $resource(':core/:handler', {core: '@core', wt:'json', _:Date.now(), handler:'update'}, { |
| "commit": {params: {commit: "true"}}, |
| "post": {headers: {'Content-type': 'application/json'}, method: "POST", params: {handler: '@handler'}}, |
| "postJson": {headers: {'Content-type': 'application/json'}, method: "POST", params: {handler: '@handler'}}, |
| "postXml": {headers: {'Content-type': 'text/xml'}, method: "POST", params: {handler: '@handler'}}, |
| "postCsv": {headers: {'Content-type': 'application/csv'}, method: "POST", params: {handler: '@handler'}} |
| }); |
| }]) |
| .service('FileUpload', function ($http) { |
| this.upload = function(params, file, success, error){ |
| var url = "" + params.core + "/" + params.handler + "?"; |
| raw = params.raw; |
| delete params.core; |
| delete params.handler; |
| delete params.raw; |
| url += $.param(params); |
| if (raw && raw.length>0) { |
| if (raw[0] != "&") raw = "&" + raw; |
| url += raw; |
| } |
| var fd = new FormData(); |
| fd.append('file', file); |
| $http.post(url, fd, { |
| transformRequest: angular.identity, |
| headers: {'Content-Type': undefined} |
| }).success(success).error(error); |
| } |
| }) |
| .filter('splitByComma', function() { |
| return function(input) { |
| return input === undefined ? input : input.split(','); |
| } |
| }) |
| .factory('Luke', |
| ['$resource', function($resource) { |
| return $resource(':core/admin/luke', {core: '@core', wt:'json', _:Date.now()}, { |
| "index": {params: {numTerms: 0, show: 'index'}}, |
| "raw": {params: {numTerms: 0}}, |
| "schema": {params: {show:'schema'}}, |
| "field": {}, |
| "fields": {params: {show:'schema'}, interceptor: { |
| response: function(response) { |
| var fieldsAndTypes = []; |
| for (var field in response.data.schema.fields) { |
| fieldsAndTypes.push({group: "Fields", label: field, value: "fieldname=" + field}); |
| } |
| for (var type in response.data.schema.types) { |
| fieldsAndTypes.push({group: "Types", label: type, value: "fieldtype=" + type}); |
| } |
| return fieldsAndTypes; |
| } |
| }} |
| }); |
| }]) |
| .factory('Analysis', |
| ['$resource', function($resource) { |
| return $resource(':core/analysis/field', {core: '@core', wt:'json', _:Date.now()}, { |
| "field": {params: {"analysis.showmatch": true}} |
| }); |
| }]) |
| .factory('DataImport', |
| ['$resource', function($resource) { |
| return $resource(':core/:name', {core: '@core', name: '@name', indent:'on', wt:'json', _:Date.now()}, { |
| "config": {params: {command: "show-config"}, headers: {doNotIntercept: "true"}, |
| transformResponse: function(data) { |
| return {config: data}; |
| } |
| }, |
| "status": {params: {command: "status"}, headers: {doNotIntercept: "true"}}, |
| "reload": {params: {command: "reload-config"}}, |
| "post": {method: "POST", |
| headers: {'Content-type': 'application/x-www-form-urlencoded'}, |
| transformRequest: function(data) { return $.param(data) }} |
| }); |
| }]) |
| .factory('Ping', |
| ['$resource', function($resource) { |
| return $resource(':core/admin/ping', {wt:'json', core: '@core', ts:Date.now(), _:Date.now()}, { |
| "ping": {}, |
| "status": {params:{action:"status"}, headers: {doNotIntercept: "true"} |
| }}); |
| }]) |
| .factory('Mbeans', |
| ['$resource', function($resource) { |
| return $resource(':core/admin/mbeans', {'wt':'json', core: '@core', '_':Date.now()}, { |
| stats: {params: {stats: true}}, |
| info: {}, |
| reference: { |
| params: {wt: "xml", stats: true}, transformResponse: function (data) { |
| return {reference: data} |
| } |
| }, |
| delta: {method: "POST", |
| params: {stats: true, diff:true}, |
| headers: {'Content-type': 'application/x-www-form-urlencoded'}, |
| transformRequest: function(data) { |
| return "stream.body=" + encodeURIComponent(data); |
| } |
| } |
| }); |
| }]) |
| .factory('Files', |
| ['$resource', function($resource) { |
| return $resource(':core/admin/file', {'wt':'json', core: '@core', '_':Date.now()}, { |
| "list": {}, |
| "get": {method: "GET", interceptor: { |
| response: function(config) {return config;} |
| }, transformResponse: function(data) { |
| return data; |
| }} |
| }); |
| }]) |
| .factory('Query', |
| ['$resource', function($resource) { |
| var resource = $resource(':core/:handler', {core: '@core', handler: '@handler', '_':Date.now()}, { |
| "query": { |
| method: "GET", |
| transformResponse: function (data) { |
| return {data: data} |
| }, |
| headers: {doNotIntercept: "true"} |
| } |
| }); |
| resource.url = function(params) { |
| var qs = []; |
| for (key in params) { |
| if (key != "core" && key != "handler") { |
| for (var i in params[key]) { |
| qs.push(key + "=" + encodeURIComponent(params[key][i])); |
| } |
| } |
| } |
| return "" + params.core + "/" + params.handler + "?" + qs.sort().join("&"); |
| } |
| return resource; |
| }]) |
| .factory('Segments', |
| ['$resource', function($resource) { |
| return $resource(':core/admin/segments', {'wt':'json', core: '@core', _:Date.now()}, { |
| get: {} |
| }); |
| }]) |
| .factory('Schema', |
| ['$resource', function($resource) { |
| return $resource(':core/schema', {wt: 'json', core: '@core', _:Date.now()}, { |
| get: {method: "GET"}, |
| check: {method: "GET", headers: {doNotIntercept: "true"}}, |
| post: {method: "POST"} |
| }); |
| }]) |
| .factory('Config', |
| ['$resource', function($resource) { |
| return $resource(':core/config', {wt: 'json', core: '@core', _:Date.now()}, { |
| get: {method: "GET"} |
| }) |
| }]) |
| .factory('SchemaDesigner', |
| ['$resource', function($resource) { |
| return $resource('/api/schema-designer/:path', {wt: 'json', path: '@path', _:Date.now()}, { |
| get: {method: "GET"}, |
| post: {method: "POST", timeout: 90000}, |
| put: {method: "PUT"}, |
| postXml: {headers: {'Content-type': 'text/xml'}, method: "POST", timeout: 90000}, |
| postCsv: {headers: {'Content-type': 'application/csv'}, method: "POST", timeout: 90000}, |
| upload: {method: "POST", transformRequest: angular.identity, headers: {'Content-Type': undefined}, timeout: 90000} |
| }) |
| }]) |
| .factory('Security', |
| ['$resource', function($resource) { |
| return $resource('/api/cluster/security/:path', {wt: 'json', path: '@path', _:Date.now()}, { |
| get: {method: "GET"}, post: {method: "POST", timeout: 90000} |
| }) |
| }]) |
| .factory('AuthenticationService', |
| ['base64', function (base64) { |
| var service = {}; |
| |
| service.SetCredentials = function (username, password) { |
| var authdata = base64.encode(username + ':' + password); |
| |
| sessionStorage.setItem("auth.header", "Basic " + authdata); |
| sessionStorage.setItem("auth.username", username); |
| }; |
| |
| service.ClearCredentials = function () { |
| sessionStorage.removeItem("auth.header"); |
| sessionStorage.removeItem("auth.scheme"); |
| sessionStorage.removeItem("auth.realm"); |
| sessionStorage.removeItem("auth.username"); |
| sessionStorage.removeItem("auth.wwwAuthHeader"); |
| sessionStorage.removeItem("auth.statusText"); |
| localStorage.removeItem("auth.stateRandom"); |
| sessionStorage.removeItem("auth.nonce"); |
| }; |
| |
| service.getAuthDataHeader = function () { |
| try { |
| var header64 = sessionStorage.getItem("auth.authDataHeader"); |
| var headerJson = base64.decode(header64); |
| return JSON.parse(headerJson); |
| } catch (e) { |
| console.log("WARN: Wrong or missing X-Solr-AuthData header on 401 response " + e); |
| return null; |
| } |
| }; |
| |
| service.decodeJwtPart = function (jwtPart) { |
| try { |
| return JSON.parse(base64.urldecode(jwtPart)); |
| } catch (e) { |
| console.log("WARN: Invalid format of JWT part: " + e); |
| return {}; |
| } |
| }; |
| |
| service.isJwtCallback = function (hash) { |
| var hp = this.decodeHashParams(hash); |
| // console.log("Decoded hash as " + JSON.stringify(hp, undefined, 2)); // For debugging callbacks |
| return (hp['access_token'] && hp['token_type'] && hp['state']) || hp['error']; |
| }; |
| |
| service.decodeHashParams = function(hash) { |
| // access_token, token_type, expires_in, state |
| if (hash == null || hash.length === 0) { |
| return {}; |
| } |
| var params = {}; |
| var parts = hash.split("&"); |
| for (var p in parts) { |
| var kv = parts[p].split("="); |
| if (kv.length === 2) { |
| params[kv[0]] = decodeURIComponent(kv[1]); |
| } else { |
| console.log("Invalid callback URI, got parameter " + parts[p] + " but expected key=value"); |
| } |
| } |
| return params; |
| }; |
| |
| return service; |
| }]); |
