Crystalnix / omaha-server

def get_hourly_data_by_platform(app_id, end, n_hours, versions, platform, channel, tz='UTC'):

    def build_event_name(app_id, platform, channel, v):

        if channel:

            return "request:{}:{}:{}:{}".format(app_id, platform, channel, v)

        else:

            return "request:{}:{}:{}".format(app_id, platform, v)

    tzinfo = pytz.timezone(tz)

    start = end - timezone.timedelta(hours=n_hours)

    hours = [datetime(start.year, start.month, start.day, start.hour, tzinfo=pytz.UTC)

             + timezone.timedelta(hours=x) for x in range(1, n_hours + 1)]

    data = [(v, [[hour.astimezone(tzinfo).strftime("%Y-%m-%dT%H:%M:%S.%fZ"),

                  len(HourEvents.from_date(build_event_name(app_id, platform, channel, v), hour))]

                 for hour in hours])

            for v in versions]

    data = filter(lambda version_data: sum([data[1] for data in version_data[1]]), data)

    return dict(data)

def get_daily_data_by_platform(app_id, end, n_days, versions, platform, channel):

    return dict(data)

def get_daily_data_by_platform(app_id, end, n_days, versions, platform, channel):

    def build_event_name(app_id, platform, channel, v):

        if channel:

            return "request:{}:{}:{}:{}".format(app_id, platform, channel, v)

        else:

            return "request:{}:{}:{}".format(app_id, platform, v)

    start = end - timezone.timedelta(days=n_days)

    days = [start + timezone.timedelta(days=x) for x in range(0, n_days+1)]

    data = [(v, [[day.strftime("%Y-%m-%dT00:%M:%S.%fZ"),

                  len(DayEvents.from_date(build_event_name(app_id, platform, channel, v), day))]

                 for day in days])

            for v in versions]

    data = filter(lambda version_data: sum([data[1] for data in version_data[1]]), data)

    return dict(data)

def get_users_live_versions(app_id, start, end, channel, tz='UTC'):