// # Copyright (C) 2010-2016 RhodeCode GmbH // # // # This program is free software: you can redistribute it and/or modify // # it under the terms of the GNU Affero General Public License, version 3 // # (only), as published by the Free Software Foundation. // # // # This program is distributed in the hope that it will be useful, // # but WITHOUT ANY WARRANTY; without even the implied warranty of // # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the // # GNU General Public License for more details. // # // # You should have received a copy of the GNU Affero General Public License // # along with this program. If not, see . // # // # This program is dual-licensed. If you wish to learn more about the // # AppEnlight Enterprise Edition, including its added features, Support // # services, and proprietary license terms, please see // # https://rhodecode.com/licenses/ angular.module('appenlight.controllers').controller('LogsController', LogsController); LogsController.$inject = ['$scope', '$location', 'stateHolder', 'typeAheadTagHelper', 'logsNoIdResource', 'sectionViewResource']; function LogsController($scope, $location, stateHolder, typeAheadTagHelper, logsNoIdResource, sectionViewResource) { var vm = this; vm.logEventsChartConfig = { data: { json: [], xFormat: '%Y-%m-%dT%H:%M:%S' }, color: { pattern: ['#6baed6', '#e6550d', '#74c476', '#fdd0a2', '#8c564b'] }, axis: { x: { type: 'timeseries', tick: { format: '%Y-%m-%d' } }, y: { tick: { count: 5, format: d3.format('.2s') } } }, subchart: { show: true, size: { height: 20 } }, size: { height: 250 }, zoom: { rescale: true }, grid: { x: { show: true }, y: { show: true } }, tooltip: { format: { title: function (d) { return '' + d; }, value: function (v) { return v } } } }; vm.logEventsChartData = {}; stateHolder.section = 'logs'; vm.today = function () { vm.pickerDate = new Date(); }; vm.today(); vm.applications = stateHolder.AeUser.applications_map; vm.logsPage = []; vm.itemCount = 0; vm.itemsPerPage = 250; vm.searchParams = parseSearchToTags($location.search()); vm.$location = $location; vm.isLoading = { logs: true, series: true }; vm.filterTypeAheadOptions = [ { type: 'message', text: 'message:', 'description': 'Full-text search in your logs', tag: 'Message', example: 'message:text-im-looking-for' }, { type: 'namespace', text: 'namespace:', 'description': 'Query logs from specific namespace', tag: 'Namespace', example: "namespace:module.foo" }, { type: 'resource', text: 'resource:', 'description': 'Restrict resultset to application', tag: 'Application', example: "resource:ID" }, { type: 'request_id', text: 'request_id:', 'description': 'Show logs with specific request id', example: "request_id:883143dc572e4c38aceae92af0ea5ae0", tag: 'Request ID' }, { type: 'level', text: 'level:', 'description': 'Show entries with specific log level', example: 'level:warning', tag: 'Level' }, { type: 'server_name', text: 'server_name:', 'description': 'Show entries tagged with this key/value pair', example: 'server_name:hostname', tag: 'Tag' }, { type: 'start_date', text: 'start_date:', 'description': 'Show results newer than this date (press TAB for dropdown)', example: 'start_date:2014-08-15T13:00', tag: 'Start Date' }, { type: 'end_date', text: 'end_date:', 'description': 'Show results older than this date (press TAB for dropdown)', example: 'start_date:2014-08-15T23:59', tag: 'End Date' }, {type: 'level', value: 'debug', text: 'level:debug'}, {type: 'level', value: 'info', text: 'level:info'}, {type: 'level', value: 'warning', text: 'level:warning'}, {type: 'level', value: 'critical', text: 'level:critical'} ]; vm.filterTypeAhead = null; vm.showDatePicker = false; vm.manualOpen = false; vm.aheadFilter = typeAheadTagHelper.aheadFilter; vm.removeSearchTag = function (tag) { $location.search(tag.type, null); }; vm.addSearchTag = function (tag) { $location.search(tag.type, tag.value); }; vm.paginationChange = function(){ $location.search('page', vm.searchParams.page); }; _.each(vm.applications, function (item) { vm.filterTypeAheadOptions.push({ type: 'resource', text: 'resource:' + item.resource_id + ':' + item.resource_name, example: 'resource:' + item.resource_id, 'tag': item.resource_name, 'description': 'Restrict resultset to this application' }); }); vm.typeAheadTag = function (event) { var text = vm.filterTypeAhead; if (_.isObject(vm.filterTypeAhead)) { text = vm.filterTypeAhead.text; } ; if (!vm.filterTypeAhead) { return } var parsed = text.split(':'); var tag = {'type': null, 'value': null}; // app tags have : twice if (parsed.length > 2 && parsed[0] == 'resource') { tag.type = 'resource'; tag.value = parsed[1]; } // normal tag:value else if (parsed.length > 1) { tag.type = parsed[0]; tag.value = parsed.slice(1).join(':'); } else { tag.type = 'message'; tag.value = parsed.join(':'); } // set datepicker hour based on type of field if ('start_date:' == text) { vm.showDatePicker = true; vm.filterTypeAhead = 'start_date:' + moment(vm.pickerDate).utc().format(); } else if ('end_date:' == text) { vm.showDatePicker = true; vm.filterTypeAhead = 'end_date:' + moment(vm.pickerDate).utc().hour(23).minute(59).format(); } if (event.keyCode != 13 || !tag.type || !tag.value) { return } vm.showDatePicker = false; // aka we selected one of main options $location.search(tag.type, tag.value); // clear typeahead vm.filterTypeAhead = undefined; }; vm.pickerDateChanged = function(){ if (vm.filterTypeAhead.indexOf('start_date:') == '0') { vm.filterTypeAhead = 'start_date:' + moment(vm.pickerDate).utc().format(); } else if (vm.filterTypeAhead.indexOf('end_date:') == '0') { vm.filterTypeAhead = 'end_date:' + moment(vm.pickerDate).utc().hour(23).minute(59).format(); } vm.showDatePicker = false; }; vm.fetchLogs = function (searchParams) { vm.isLoading.logs = true; logsNoIdResource.query(searchParams, function (data, getResponseHeaders) { vm.isLoading.logs = false; var headers = getResponseHeaders(); vm.logsPage = data; vm.itemCount = headers['x-total-count']; vm.itemsPerPage = headers['x-items-per-page']; }, function () { vm.isLoading.logs = false; }); }; vm.fetchSeriesData = function (searchParams) { searchParams['section'] = 'logs_section'; searchParams['view'] = 'fetch_series'; vm.isLoading.series = true; sectionViewResource.query(searchParams, function (data) { console.log('show node here'); vm.logEventsChartData = { json: data, xFormat: '%Y-%m-%dT%H:%M:%S', keys: { x: 'x', value: ["logs"] }, names: { logs: 'Log events' }, type: 'bar' }; vm.isLoading.series = false; }, function () { vm.isLoading.series = false; }); }; vm.filterId = function (log) { $location.search('request_id', log.request_id); }; var params = parseTagsToSearch(vm.searchParams); vm.fetchLogs(params); vm.fetchSeriesData(params); $scope.$on('$locationChangeSuccess', function () { console.log('$locationChangeSuccess LogsController'); vm.searchParams = parseSearchToTags($location.search()); var params = parseTagsToSearch(vm.searchParams); console.log($location.path()); if (vm.isLoading.logs === false) { console.log(params); vm.fetchLogs(params); vm.fetchSeriesData(params); } }); }