feat(dbaas.logs): add kibana endpoints (#290)

Signed-off-by: Pierre De Paepe <[email protected]>

src/api/dbaas/logs/logs.service.js

@@ -53,6 +53,9 @@ angular.module('ovh-api-services').service('OvhApiDbaasLogs', ($injector) => ({
   Dashboard() {
     return $injector.get('OvhApiDbaasLogsDashboard');
   },
+  Output() {
+    return $injector.get('OvhApiDbaasLogsOutput');
+  },
   User() {
     return $injector.get('OvhApiDbaasLogsUser');
   },

src/api/dbaas/logs/output/elasticsearch/elasticsearch.service.js

@@ -0,0 +1,5 @@
+angular.module('ovh-api-services').service('OvhApiDbaasLogsOutputElasticsearchKibana', ($injector) => ({
+  Kibana() {
+    return $injector.get('OvhApiDbaasLogsOutputElasticsearch');
+  },
+}));

src/api/dbaas/logs/output/elasticsearch/kibana/kibana.aapi.service.js

@@ -0,0 +1,25 @@
+angular.module('ovh-api-services').service('OvhApiDbaasLogsOutputElasticsearchKibanaAapi', ($resource, $cacheFactory) => {
+  const cache = $cacheFactory('OvhApiDbaasLogsOutputElasticsearchKibanaAapi');
+
+  const kibana = $resource('/dbaas/logs/:serviceName/kibana/:kibanaId', {
+    serviceName: '@serviceName',
+    kibanaId: '@kibanaId',
+  }, {
+    get: {
+      method: 'GET',
+      serviceType: 'aapi',
+      cache,
+      isArray: false,
+    },
+  });
+
+  kibana.resetAllCache = function () {
+    kibana.resetCache();
+  };
+
+  kibana.resetCache = function () {
+    cache.removeAll();
+  };
+
+  return kibana;
+});

src/api/dbaas/logs/output/elasticsearch/kibana/kibana.iceberg.service.js

@@ -0,0 +1,10 @@
+angular.module('ovh-api-services').service('OvhApiDbaasLogsOutputElasticsearchKibanaIceberg', (iceberg) => {
+  const kibanaResource = iceberg('/dbaas/logs/:serviceName/output/elasticsearch/kibana/:kibanaId', {
+    serviceName: '@serviceName',
+    kibanaId: '@kibanaId',
+  }, {
+    create: { method: 'POST' },
+  });
+
+  return kibanaResource;
+});  

src/api/dbaas/logs/output/elasticsearch/kibana/kibana.service.js

@@ -0,0 +1,11 @@
+angular.module('ovh-api-services').service('OvhApiDbaasLogsOutputElasticsearchKibana', ($injector) => ({
+  v6() {
+    return $injector.get('OvhApiDbaasLogsOutputElasticsearchKibanaV6');
+  },
+  Iceberg() {
+    return $injector.get('OvhApiDbaasLogsOutputElasticsearchKibanaIceberg');
+  },
+  Aapi() {
+    return $injector.get('OvhApiDbaasLogsOutputElasticsearchKibanaAapi');
+  },
+}));

src/api/dbaas/logs/output/elasticsearch/kibana/kibana.v6.service.js

@@ -0,0 +1,35 @@
+angular.module('ovh-api-services').service('OvhApiDbaasLogsOutputElasticsearchKibanaV6', ($resource, $cacheFactory) => {
+  const cache = $cacheFactory('OvhApiDbaasLogsOutputElasticsearchKibanaV6');
+  const queryCache = $cacheFactory('OvhApiDbaasLogsOutputElasticsearchKibanaV6Query');
+  const interceptor = {
+    response(response) {
+      cache.remove(response.config.url);
+      queryCache.removeAll();
+      return response;
+    },
+  };
+
+  const kibanaResource = $resource('/dbaas/logs/:serviceName/output/elasticsearch/kibana/:kibanaId', {
+    serviceName: '@serviceName',
+    kibanaId: '@kibanaId',
+  }, {
+    query: { method: 'GET', isArray: true, cache: queryCache },
+    create: { method: 'POST', interceptor },
+    remove: { method: 'DELETE', interceptor },
+  });
+
+  kibanaResource.resetAllCache = function () {
+    kibanaResource.resetCache();
+    kibanaResource.resetQueryCache();
+  };
+
+  kibanaResource.resetCache = function () {
+    cache.removeAll();
+  };
+
+  kibanaResource.resetQueryCache = function () {
+    queryCache.removeAll();
+  };
+
+  return kibanaResource;
+});

src/api/dbaas/logs/output/output.service.js

@@ -0,0 +1,5 @@
+angular.module('ovh-api-services').service('OvhApiDbaasLogsOutput', ($injector) => ({
+  Elasticsearch() {
+    return $injector.get('OvhApiDbaasLogsOutputElasticsearch');
+  },
+}));