#!/usr/bin/env python
# Copyright 2018 Cisco Systems, Inc.  All rights reserved.
#
#    Licensed 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.

import requests
import time


class Prometheus():
    def __init__(self, config):
        self.server_address = "http://{}:{}/api/v1/".format(config['server_ip'],
                                                            config['server_port'])
        self.step_size = config['step_size']
        self.wait_time = config['wait_time']

    def get_results(self, start_time, end_time=None):
        if not end_time:
            end_time = time.time()
        if end_time - start_time <= self.wait_time * 2:
            return None
        try:
            return requests.get(
                url="{}query_range?query=cpu_usage_system{{"
                    "tag=%22ceph%22}}&start={}&end={}&step={}".format(self.server_address,
                                                                      start_time + self.wait_time,
                                                                      end_time - self.wait_time,
                                                                      self.step_size)).json()

        except requests.exceptions.RequestException as e:
            print(e)
            return None