bansho/app/components/live/get_objects.js

'use strict';

angular.module('adagios.live')

    .constant('filterSuffixes', { contains: '__contains',
                                  has_fields: '__has_field',
                                  startswith: '__startswith',
                                  endswith: '__endswith',
                                  exists: '__exists',
                                  in: '__in',
                                  isnot: '__isnot',
                                  regex: '__regex'
                                })

    .service('getObjects', ['$http', 'filterSuffixes',
        function ($http, filterSuffixes) {
            return function (columns, filters, apiName, additionnalFields) {
                var filtersQuery = '',
                    additionnalQuery = '';

                function createFiltersQuery(filters) {
                    var builtQuery = '';
                    angular.forEach(filters, function (value, key) {
                        var filterType = filterSuffixes[key];
                        angular.forEach(value, function (fieldValues, fieldName) {
                            var filter = fieldName + filterType;
                            angular.forEach(fieldValues, function (_value) {
                                var filterQuery = '&' + filter + '=' + _value;
                                builtQuery += filterQuery;
                            });
                        });
                    });

                    return builtQuery;
                }

                function createAdditionnalQuery(additionnalFields) {
                    var query = '';
                    angular.forEach(additionnalFields, function (value, key) {
                        query += '&' + key + '=' + value;
                    });

                    return query;
                }

                filtersQuery = createFiltersQuery(filters);
                additionnalQuery = createAdditionnalQuery(additionnalFields);

                return $http.get('/rest/status/json/' + apiName + '/?fields=' + columns + filtersQuery + additionnalQuery)
                    .error(function () {
                        throw new Error('getObjects : GET Request failed');
                    });
            };
        }])

    .service('getService', ['$http',
        function ($http) {
            return function (hostName, description) {
            return $http.get('/rest/status/json/services/?host_name=' + hostName + '&description=' + description)
                .error(function () {
                    throw new Error('getService : GET Request failed');
                });
            }
        }])

    // This service is used to count the number of host open problems
    .service('getHostOpenProblems', ['$http', 'getObjects',
        function ($http, getObjects) {
            var fields = ['state'],
                filters = {},
                apiName = 'hosts',
                additionnalQueryFields = {'acknowledged': 0, 'state': 1};

            return getObjects(fields, filters, apiName, additionnalQueryFields)
                .error(function () {
                    throw new Error('getObjects : GET Request failed');
                });
        }])

    // This service is used to count the number of service open problems
    .service('getServiceOpenProblems', ['$http', 'getObjects',
        function ($http, getObjects) {
            var fields = ['state'],
                filters = { "isnot": { "state": [ "0" ], "host_state": [ "2" ] }},
                apiName = 'services',
                additionnalQueryFields = {'acknowledged': 0};

            return getObjects(fields, filters, apiName, additionnalQueryFields)
                .error(function () {
                    throw new Error('getObjects : GET Request failed');
                });
        }])

    // This service is used to count the number of host problems
    .service('getHostProblems', ['$http', 'getObjects',
        function ($http, getObjects) {
            var fields = ['state'],
                filters = { 'isnot': {'state': [0]} },
                apiName = 'hosts',
                additionnalQueryFields = {};

            return getObjects(fields, filters, apiName, additionnalQueryFields)
                .error(function () {
                    throw new Error('getObjects : GET Request failed');
                });
        }])

    // This service is used to count the number of service problems
    .service('getServiceProblems', ['$http', 'getObjects',
        function ($http, getObjects) {
            var fields = ['state'],
                filters = { 'isnot': {'state': [0]} },
                apiName = 'services',
                additionnalQueryFields = {};

            return getObjects(fields, filters, apiName, additionnalQueryFields)
                .error(function () {
                    throw new Error('getObjects : GET Request failed');
                });
        }])

    .service('getObjectId', ['$http', function ($http) {
        return function (objectType, objectIdentifier) {

            var postString, req;

            postString = "with_fields=id&object_type=" + objectType;
            angular.forEach(objectIdentifier, function (value, key) {
                if (key === "description") {
                    key = "service_description";
                }
                postString += "&" + key + "=" + value;
            });

            req = {
                method: 'POST',
                url: '/rest/pynag/json/get_objects',
                headers: {
                    'Content-Type': 'application/x-www-form-urlencoded'
                },
                data: postString
            };

            return $http(req)
                .error(function () {
                    throw new Error('getObjectId : POST Request failed');
                });
        };
    }])

    .service('getObjectById', ['$http', function ($http) {
        return function (objectId) {

            var postString, req;

            postString = "with_fields=&id=" + objectId;

            req = {
                method: 'POST',
                url: '/rest/pynag/json/get_object',
                headers: {
                    'Content-Type': 'application/x-www-form-urlencoded'
                },
                data: postString
            };


            return $http(req)
                .error(function () {
                    throw new Error('getHostById : POST Request failed');
                });
        };
    }])

    // Add object of specified type to $scope.data
    .service('addObjectToScope', ['$http', 'getObjectId', 'getObjectById', function ($http, getObjectId, getObjectById) {
        return function (objectType, objectIdentifier, scope) {
            var objectData = {},
                url = "/rest/status/json/",
                firstParameter = true,
                endpoints = {
                    "host" : "hosts",
                    "service" : "services"
                };

            url += endpoints[objectType];
            url += "/?";

            angular.forEach(objectIdentifier, function (value, key) {
                if (!firstParameter) {
                    url += "&";
                }
                url += key + "=" + value;
                firstParameter = false;

            });

            $http.get(url)
                .success(function (data) {
                    objectData.live = data[0];
                    getObjectId(objectType, objectIdentifier)
                        .success(function (data) {
                            var objectId = data[0].id;
                            scope.data.id = objectId;
                            getObjectById(objectId)
                                .success(function (data) {
                                    objectData.config = data;
                                    scope.data = objectData;
                                });
                        });
                });
        };
    }]);