from __future__ import absolute_import, division, print_function, unicode_literals

import logging
from datetime import datetime
from uuid import uuid4

import scout_apm.core.backtrace
from scout_apm.core.n_plus_one_call_set import NPlusOneCallSet
from scout_apm.core.request_manager import RequestManager
from scout_apm.core.samplers import Memory, Samplers
from scout_apm.core.thread_local import ThreadLocalSingleton

try:
    from scout_apm.core import objtrace
except ImportError:
    objtrace = None

logger = logging.getLogger(__name__)


class TrackedRequest(ThreadLocalSingleton):
    """
    This is a container which keeps track of all module instances for a single
    request. For convenience they are made available as attributes based on
    their keyname
    """

    def __init__(self, *args, **kwargs):
        self.req_id = "req-" + str(uuid4())
        self.start_time = kwargs.get("start_time", datetime.utcnow())
        self.end_time = kwargs.get("end_time", None)
        self.active_spans = kwargs.get("active_spans", [])
        self.complete_spans = kwargs.get("complete_spans", [])
        self.tags = kwargs.get("tags", {})
        self.real_request = kwargs.get("real_request", False)
        self.memory_start = kwargs.get("memory_start", Memory.rss_in_mb())
        self.callset = NPlusOneCallSet()
        logger.debug("Starting request: %s", self.req_id)

    def mark_real_request(self):
        self.real_request = True

    def is_real_request(self):
        return self.real_request

    def tag(self, key, value):
        if key in self.tags:
            logger.debug(
                "Overwriting previously set tag for request %s: %s", self.req_id, key
            )
        self.tags[key] = value

    def start_span(self, *args, **kwargs):
        maybe_parent = self.current_span()

        if maybe_parent is not None:
            parent_id = maybe_parent.span_id
            if maybe_parent.ignore_children:
                kwargs["ignore"] = True
                kwargs["ignore_children"] = True
        else:
            parent_id = None

        kwargs["parent"] = parent_id
        kwargs["request_id"] = self.req_id

        new_span = Span(**kwargs)
        self.active_spans.append(new_span)
        return new_span

    def stop_span(self):
        try:
            stopping_span = self.active_spans.pop()
        except IndexError as e:
            logger.debug("Exception when stopping span: %r", e)
        else:
            stopping_span.stop()
            if not stopping_span.ignore:
                stopping_span.annotate()
                self.complete_spans.append(stopping_span)

        if len(self.active_spans) == 0:
            self.finish()

    def current_span(self):
        if len(self.active_spans) > 0:
            return self.active_spans[-1]
        else:
            return None

    # Request is done, release any info we have about it.
    def finish(self):
        logger.debug("Stopping request: %s", self.req_id)
        if self.end_time is None:
            self.end_time = datetime.utcnow()
        if self.is_real_request():
            self.tag("mem_delta", Memory.get_delta(self.memory_start))
            if not self.is_ignored():
                RequestManager.instance().add_request(self)
            Samplers.ensure_running()

        # This can fail if the Tracked Request was created directly,
        # not through instance()
        try:
            self.release()
        except Exception:
            pass

    # A request is ignored if the tag "ignore_transaction" is set to True
    def is_ignored(self):
        return self.tags.get("ignore_transaction", False)


class Span(object):
    def __init__(self, *args, **kwargs):
        self.span_id = kwargs.get("span_id", "span-" + str(uuid4()))
        self.start_time = kwargs.get("start_time", datetime.utcnow())
        self.end_time = kwargs.get("end_time", None)
        self.request_id = kwargs.get("request_id", None)
        self.operation = kwargs.get("operation", None)
        self.ignore = kwargs.get("ignore", False)
        self.ignore_children = kwargs.get("ignore_children", False)
        self.parent = kwargs.get("parent", None)
        self.tags = kwargs.get("tags", {})
        if objtrace is not None:
            self.start_objtrace_counts = kwargs.get(
                "start_objtrace_counts", objtrace.get_counts()
            )
        else:
            self.start_objtrace_counts = kwargs.get(
                "start_objtrace_counts", (0, 0, 0, 0)
            )
        self.end_objtrace_counts = kwargs.get("end_objtrace_counts", (0, 0, 0, 0))

    def stop(self):
        self.end_time = datetime.utcnow()
        if objtrace is not None:
            self.end_objtrace_counts = objtrace.get_counts()
        else:
            self.end_objtrace_counts = (0, 0, 0, 0)

    def tag(self, key, value):
        if key in self.tags:
            logger.debug(
                "Overwriting previously set tag for span %s: %s", self.span_id, key
            )
        self.tags[key] = value

    # In seconds
    def duration(self):
        if self.end_time is not None:
            return (self.end_time - self.start_time).total_seconds()
        else:
            # Current, running duration
            return (datetime.utcnow() - self.start_time).total_seconds()

    # Add any interesting annotations to the span. Assumes that we are in the
    # process of stopping this span.
    def annotate(self):
        self.tag("allocations", self.calculate_allocations())
        # Don't capture backtraces for Controller or Middleware
        if self.operation is not None:
            if self.operation.startswith("Controller") or self.operation.startswith(
                "Middleware"
            ):
                return
        slow_threshold = 0.500
        if self.duration() > slow_threshold:
            self.capture_backtrace()

    def calculate_allocations(self):
        if objtrace is None:
            return 0

        start_allocs = (
            self.start_objtrace_counts[0]
            + self.start_objtrace_counts[1]
            + self.start_objtrace_counts[2]
        )
        end_allocs = (
            self.end_objtrace_counts[0]
            + self.end_objtrace_counts[1]
            + self.end_objtrace_counts[2]
        )
        try:
            # If even one of the counters rolled over, we're pretty much
            # guaranteed to have end_allocs be less than start_allocs.
            # This should rarely happen. Max Unsigned Long Long is a big number
            if end_allocs - start_allocs < 0:
                logger.debug(
                    "End allocation count smaller than start allocation "
                    "count for span %s: start = %d, end = %d",
                    self.span_id,
                    start_allocs,
                    end_allocs,
                )
                return 0
            return end_allocs - start_allocs
        except TypeError as e:
            logger.debug("Exception in calculate_allocations: %r", e)
            return 0

    def capture_backtrace(self):
        stack = scout_apm.core.backtrace.capture()
        self.tag("stack", stack)

from __future__ import absolute_import, division, print_function, unicode_literals

import logging
from datetime import datetime
from uuid import uuid4

import scout_apm.core.backtrace
from scout_apm.core.n_plus_one_call_set import NPlusOneCallSet
from scout_apm.core.request_manager import RequestManager
from scout_apm.core.samplers import Memory, Samplers
from scout_apm.core.thread_local import ThreadLocalSingleton

try:
    from scout_apm.core import objtrace
except ImportError:
    objtrace = None

logger = logging.getLogger(__name__)


class TrackedRequest(ThreadLocalSingleton):
    """
    This is a container which keeps track of all module instances for a single
    request. For convenience they are made available as attributes based on
    their keyname
    """

    def __init__(self, *args, **kwargs):
        self.req_id = "req-" + str(uuid4())
        self.start_time = kwargs.get("start_time", datetime.utcnow())
        self.end_time = kwargs.get("end_time", None)
        self.active_spans = kwargs.get("active_spans", [])
        self.complete_spans = kwargs.get("complete_spans", [])
        self.tags = kwargs.get("tags", {})
        self.real_request = kwargs.get("real_request", False)
        self.memory_start = kwargs.get("memory_start", Memory.rss_in_mb())
        self.callset = NPlusOneCallSet()
        logger.debug("Starting request: %s", self.req_id)

    def mark_real_request(self):
        self.real_request = True

    def is_real_request(self):
        return self.real_request

    def tag(self, key, value):
        if key in self.tags:
            logger.debug(
                "Overwriting previously set tag for request %s: %s", self.req_id, key
            )
        self.tags[key] = value

    def start_span(self, *args, **kwargs):
        maybe_parent = self.current_span()

        if maybe_parent is not None:
            parent_id = maybe_parent.span_id
            if maybe_parent.ignore_children:
                kwargs["ignore"] = True
                kwargs["ignore_children"] = True
        else:
            parent_id = None

        kwargs["parent"] = parent_id
        kwargs["request_id"] = self.req_id

        new_span = Span(**kwargs)
        self.active_spans.append(new_span)
        return new_span

    def stop_span(self):
        try:
            stopping_span = self.active_spans.pop()
        except IndexError as e:
            logger.debug("Exception when stopping span: %r", e)
        else:
            stopping_span.stop()
            if not stopping_span.ignore:
                stopping_span.annotate()
                self.complete_spans.append(stopping_span)

        if len(self.active_spans) == 0:
            self.finish()

    def current_span(self):
        if len(self.active_spans) > 0:
            return self.active_spans[-1]
        else:
            return None

    # Request is done, release any info we have about it.
    def finish(self):
        logger.debug("Stopping request: %s", self.req_id)
        if self.end_time is None:
            self.end_time = datetime.utcnow()
        if self.is_real_request():
            self.tag("mem_delta", Memory.get_delta(self.memory_start))
            if not self.is_ignored():
                RequestManager.instance().add_request(self)
            Samplers.ensure_running()

        # This can fail if the Tracked Request was created directly,
        # not through instance()
        try:
            self.release()
        except Exception:
            pass

    # A request is ignored if the tag "ignore_transaction" is set to True
    def is_ignored(self):
        return self.tags.get("ignore_transaction", False)


class Span(object):
    def __init__(self, *args, **kwargs):
        self.span_id = kwargs.get("span_id", "span-" + str(uuid4()))
        self.start_time = kwargs.get("start_time", datetime.utcnow())
        self.end_time = kwargs.get("end_time", None)
        self.request_id = kwargs.get("request_id", None)
        self.operation = kwargs.get("operation", None)
        self.ignore = kwargs.get("ignore", False)
        self.ignore_children = kwargs.get("ignore_children", False)
        self.parent = kwargs.get("parent", None)
        self.tags = kwargs.get("tags", {})
        if objtrace is not None:
            self.start_objtrace_counts = kwargs.get(
                "start_objtrace_counts", objtrace.get_counts()
            )
        else:
            self.start_objtrace_counts = kwargs.get(
                "start_objtrace_counts", (0, 0, 0, 0)
            )
        self.end_objtrace_counts = kwargs.get("end_objtrace_counts", (0, 0, 0, 0))

    def stop(self):
        self.end_time = datetime.utcnow()
        if objtrace is not None:
            self.end_objtrace_counts = objtrace.get_counts()
        else:
            self.end_objtrace_counts = (0, 0, 0, 0)

    def tag(self, key, value):
        if key in self.tags:
            logger.debug(
                "Overwriting previously set tag for span %s: %s", self.span_id, key
            )
        self.tags[key] = value

    # In seconds
    def duration(self):
        if self.end_time is not None:
            return (self.end_time - self.start_time).total_seconds()
        else:
            # Current, running duration
            return (datetime.utcnow() - self.start_time).total_seconds()

    # Add any interesting annotations to the span. Assumes that we are in the
    # process of stopping this span.
    def annotate(self):
        self.tag("allocations", self.calculate_allocations())
        # Don't capture backtraces for Controller or Middleware
        if self.operation is not None:
            if self.operation.startswith("Controller") or self.operation.startswith(
                "Middleware"
            ):
                return
        slow_threshold = 0.500
        if self.duration() > slow_threshold:
            self.capture_backtrace()

    def calculate_allocations(self):
        if objtrace is None:
            return 0

        start_allocs = (
            self.start_objtrace_counts[0]
            + self.start_objtrace_counts[1]
            + self.start_objtrace_counts[2]
        )
        end_allocs = (
            self.end_objtrace_counts[0]
            + self.end_objtrace_counts[1]
            + self.end_objtrace_counts[2]
        )
        try:
            # If even one of the counters rolled over, we're pretty much
            # guaranteed to have end_allocs be less than start_allocs.
            # This should rarely happen. Max Unsigned Long Long is a big number
            if end_allocs - start_allocs < 0:
                logger.debug(
                    "End allocation count smaller than start allocation "
                    "count for span %s: start = %d, end = %d",
                    self.span_id,
                    start_allocs,
                    end_allocs,
                )
                return 0
            return end_allocs - start_allocs
        except TypeError as e:
            logger.debug("Exception in calculate_allocations: %r", e)
            return 0

    def capture_backtrace(self):
        stack = scout_apm.core.backtrace.capture()
        self.tag("stack", stack)

This is a container which keeps track of all module instances for a single     request. For convenience they are made available as attributes based on     their keyname # Request is done, release any info we have about it. # This can fail if the Tracked Request was created directly, # not through instance() # A request is ignored if the tag "ignore_transaction" is set to True # In seconds # Current, running duration # Add any interesting annotations to the span. Assumes that we are in the # process of stopping this span. # Don't capture backtraces for Controller or Middleware # If even one of the counters rolled over, we're pretty much # guaranteed to have end_allocs be less than start_allocs. # This should rarely happen. Max Unsigned Long Long is a big number