Add graphs and retention metrics to admin dashboard (#16829)
Eugen Rochko
3 years ago
committed by
GitHub
parent
15d35ed5fa
commit
cad446611c
@ -0,0 +1,23 @@
|
|||||||
|
# frozen_string_literal: true
|
||||||
|
|
||||||
|
class Api::V1::Admin::DimensionsController < Api::BaseController
|
||||||
|
protect_from_forgery with: :exception
|
||||||
|
|
||||||
|
before_action :require_staff!
|
||||||
|
before_action :set_dimensions
|
||||||
|
|
||||||
|
def create
|
||||||
|
render json: @dimensions, each_serializer: REST::Admin::DimensionSerializer
|
||||||
|
end
|
||||||
|
|
||||||
|
private
|
||||||
|
|
||||||
|
def set_dimensions
|
||||||
|
@dimensions = Admin::Metrics::Dimension.retrieve(
|
||||||
|
params[:keys],
|
||||||
|
params[:start_at],
|
||||||
|
params[:end_at],
|
||||||
|
params[:limit]
|
||||||
|
)
|
||||||
|
end
|
||||||
|
end
|
||||||
@ -0,0 +1,22 @@
|
|||||||
|
# frozen_string_literal: true
|
||||||
|
|
||||||
|
class Api::V1::Admin::MeasuresController < Api::BaseController
|
||||||
|
protect_from_forgery with: :exception
|
||||||
|
|
||||||
|
before_action :require_staff!
|
||||||
|
before_action :set_measures
|
||||||
|
|
||||||
|
def create
|
||||||
|
render json: @measures, each_serializer: REST::Admin::MeasureSerializer
|
||||||
|
end
|
||||||
|
|
||||||
|
private
|
||||||
|
|
||||||
|
def set_measures
|
||||||
|
@measures = Admin::Metrics::Measure.retrieve(
|
||||||
|
params[:keys],
|
||||||
|
params[:start_at],
|
||||||
|
params[:end_at]
|
||||||
|
)
|
||||||
|
end
|
||||||
|
end
|
||||||
@ -0,0 +1,22 @@
|
|||||||
|
# frozen_string_literal: true
|
||||||
|
|
||||||
|
class Api::V1::Admin::RetentionController < Api::BaseController
|
||||||
|
protect_from_forgery with: :exception
|
||||||
|
|
||||||
|
before_action :require_staff!
|
||||||
|
before_action :set_cohorts
|
||||||
|
|
||||||
|
def create
|
||||||
|
render json: @cohorts, each_serializer: REST::Admin::CohortSerializer
|
||||||
|
end
|
||||||
|
|
||||||
|
private
|
||||||
|
|
||||||
|
def set_cohorts
|
||||||
|
@cohorts = Admin::Metrics::Retention.new(
|
||||||
|
params[:start_at],
|
||||||
|
params[:end_at],
|
||||||
|
params[:frequency]
|
||||||
|
).cohorts
|
||||||
|
end
|
||||||
|
end
|
||||||
@ -0,0 +1,16 @@
|
|||||||
|
# frozen_string_literal: true
|
||||||
|
|
||||||
|
class Api::V1::Admin::TrendsController < Api::BaseController
|
||||||
|
before_action :require_staff!
|
||||||
|
before_action :set_trends
|
||||||
|
|
||||||
|
def index
|
||||||
|
render json: @trends, each_serializer: REST::Admin::TagSerializer
|
||||||
|
end
|
||||||
|
|
||||||
|
private
|
||||||
|
|
||||||
|
def set_trends
|
||||||
|
@trends = TrendingTags.get(10, filtered: false)
|
||||||
|
end
|
||||||
|
end
|
||||||
@ -0,0 +1,115 @@
|
|||||||
|
import React from 'react';
|
||||||
|
import PropTypes from 'prop-types';
|
||||||
|
import api from 'mastodon/api';
|
||||||
|
import { FormattedNumber } from 'react-intl';
|
||||||
|
import { Sparklines, SparklinesCurve } from 'react-sparklines';
|
||||||
|
import classNames from 'classnames';
|
||||||
|
import Skeleton from 'mastodon/components/skeleton';
|
||||||
|
|
||||||
|
const percIncrease = (a, b) => {
|
||||||
|
let percent;
|
||||||
|
|
||||||
|
if (b !== 0) {
|
||||||
|
if (a !== 0) {
|
||||||
|
percent = (b - a) / a;
|
||||||
|
} else {
|
||||||
|
percent = 1;
|
||||||
|
}
|
||||||
|
} else if (b === 0 && a === 0) {
|
||||||
|
percent = 0;
|
||||||
|
} else {
|
||||||
|
percent = - 1;
|
||||||
|
}
|
||||||
|
|
||||||
|
return percent;
|
||||||
|
};
|
||||||
|
|
||||||
|
export default class Counter extends React.PureComponent {
|
||||||
|
|
||||||
|
static propTypes = {
|
||||||
|
measure: PropTypes.string.isRequired,
|
||||||
|
start_at: PropTypes.string.isRequired,
|
||||||
|
end_at: PropTypes.string.isRequired,
|
||||||
|
label: PropTypes.string.isRequired,
|
||||||
|
href: PropTypes.string,
|
||||||
|
};
|
||||||
|
|
||||||
|
state = {
|
||||||
|
loading: true,
|
||||||
|
data: null,
|
||||||
|
};
|
||||||
|
|
||||||
|
componentDidMount () {
|
||||||
|
const { measure, start_at, end_at } = this.props;
|
||||||
|
|
||||||
|
api().post('/api/v1/admin/measures', { keys: [measure], start_at, end_at }).then(res => {
|
||||||
|
this.setState({
|
||||||
|
loading: false,
|
||||||
|
data: res.data,
|
||||||
|
});
|
||||||
|
}).catch(err => {
|
||||||
|
console.error(err);
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
|
render () {
|
||||||
|
const { label, href } = this.props;
|
||||||
|
const { loading, data } = this.state;
|
||||||
|
|
||||||
|
let content;
|
||||||
|
|
||||||
|
if (loading) {
|
||||||
|
content = (
|
||||||
|
<React.Fragment>
|
||||||
|
<span className='sparkline__value__total'><Skeleton width={43} /></span>
|
||||||
|
<span className='sparkline__value__change'><Skeleton width={43} /></span>
|
||||||
|
</React.Fragment>
|
||||||
|
);
|
||||||
|
} else {
|
||||||
|
const measure = data[0];
|
||||||
|
const percentChange = percIncrease(measure.previous_total * 1, measure.total * 1);
|
||||||
|
|
||||||
|
content = (
|
||||||
|
<React.Fragment>
|
||||||
|
<span className='sparkline__value__total'><FormattedNumber value={measure.total} /></span>
|
||||||
|
<span className={classNames('sparkline__value__change', { positive: percentChange > 0, negative: percentChange < 0 })}>{percentChange > 0 && '+'}<FormattedNumber value={percentChange} style='percent' /></span>
|
||||||
|
</React.Fragment>
|
||||||
|
);
|
||||||
|
}
|
||||||
|
|
||||||
|
const inner = (
|
||||||
|
<React.Fragment>
|
||||||
|
<div className='sparkline__value'>
|
||||||
|
{content}
|
||||||
|
</div>
|
||||||
|
|
||||||
|
<div className='sparkline__label'>
|
||||||
|
{label}
|
||||||
|
</div>
|
||||||
|
|
||||||
|
<div className='sparkline__graph'>
|
||||||
|
{!loading && (
|
||||||
|
<Sparklines width={259} height={55} data={data[0].data.map(x => x.value * 1)}>
|
||||||
|
<SparklinesCurve />
|
||||||
|
</Sparklines>
|
||||||
|
)}
|
||||||
|
</div>
|
||||||
|
</React.Fragment>
|
||||||
|
);
|
||||||
|
|
||||||
|
if (href) {
|
||||||
|
return (
|
||||||
|
<a href={href} className='sparkline'>
|
||||||
|
{inner}
|
||||||
|
</a>
|
||||||
|
);
|
||||||
|
} else {
|
||||||
|
return (
|
||||||
|
<div className='sparkline'>
|
||||||
|
{inner}
|
||||||
|
</div>
|
||||||
|
);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
@ -0,0 +1,92 @@
|
|||||||
|
import React from 'react';
|
||||||
|
import PropTypes from 'prop-types';
|
||||||
|
import api from 'mastodon/api';
|
||||||
|
import { FormattedNumber } from 'react-intl';
|
||||||
|
import { roundTo10 } from 'mastodon/utils/numbers';
|
||||||
|
import Skeleton from 'mastodon/components/skeleton';
|
||||||
|
|
||||||
|
export default class Dimension extends React.PureComponent {
|
||||||
|
|
||||||
|
static propTypes = {
|
||||||
|
dimension: PropTypes.string.isRequired,
|
||||||
|
start_at: PropTypes.string.isRequired,
|
||||||
|
end_at: PropTypes.string.isRequired,
|
||||||
|
limit: PropTypes.number.isRequired,
|
||||||
|
label: PropTypes.string.isRequired,
|
||||||
|
};
|
||||||
|
|
||||||
|
state = {
|
||||||
|
loading: true,
|
||||||
|
data: null,
|
||||||
|
};
|
||||||
|
|
||||||
|
componentDidMount () {
|
||||||
|
const { start_at, end_at, dimension, limit } = this.props;
|
||||||
|
|
||||||
|
api().post('/api/v1/admin/dimensions', { keys: [dimension], start_at, end_at, limit }).then(res => {
|
||||||
|
this.setState({
|
||||||
|
loading: false,
|
||||||
|
data: res.data,
|
||||||
|
});
|
||||||
|
}).catch(err => {
|
||||||
|
console.error(err);
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
|
render () {
|
||||||
|
const { label, limit } = this.props;
|
||||||
|
const { loading, data } = this.state;
|
||||||
|
|
||||||
|
let content;
|
||||||
|
|
||||||
|
if (loading) {
|
||||||
|
content = (
|
||||||
|
<table>
|
||||||
|
<tbody>
|
||||||
|
{Array.from(Array(limit)).map((_, i) => (
|
||||||
|
<tr className='dimension__item' key={i}>
|
||||||
|
<td className='dimension__item__key'>
|
||||||
|
<Skeleton width={100} />
|
||||||
|
</td>
|
||||||
|
|
||||||
|
<td className='dimension__item__value'>
|
||||||
|
<Skeleton width={60} />
|
||||||
|
</td>
|
||||||
|
</tr>
|
||||||
|
))}
|
||||||
|
</tbody>
|
||||||
|
</table>
|
||||||
|
);
|
||||||
|
} else {
|
||||||
|
const sum = data[0].data.reduce((sum, cur) => sum + (cur.value * 1), 0);
|
||||||
|
|
||||||
|
content = (
|
||||||
|
<table>
|
||||||
|
<tbody>
|
||||||
|
{data[0].data.map(item => (
|
||||||
|
<tr className='dimension__item' key={item.key}>
|
||||||
|
<td className='dimension__item__key'>
|
||||||
|
<span className={`dimension__item__indicator dimension__item__indicator--${roundTo10(((item.value * 1) / sum) * 100)}`} />
|
||||||
|
<span title={item.key}>{item.human_key}</span>
|
||||||
|
</td>
|
||||||
|
|
||||||
|
<td className='dimension__item__value'>
|
||||||
|
{typeof item.human_value !== 'undefined' ? item.human_value : <FormattedNumber value={item.value} />}
|
||||||
|
</td>
|
||||||
|
</tr>
|
||||||
|
))}
|
||||||
|
</tbody>
|
||||||
|
</table>
|
||||||
|
);
|
||||||
|
}
|
||||||
|
|
||||||
|
return (
|
||||||
|
<div className='dimension'>
|
||||||
|
<h4>{label}</h4>
|
||||||
|
|
||||||
|
{content}
|
||||||
|
</div>
|
||||||
|
);
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
@ -0,0 +1,141 @@
|
|||||||
|
import React from 'react';
|
||||||
|
import PropTypes from 'prop-types';
|
||||||
|
import api from 'mastodon/api';
|
||||||
|
import { FormattedMessage, FormattedNumber, FormattedDate } from 'react-intl';
|
||||||
|
import classNames from 'classnames';
|
||||||
|
import { roundTo10 } from 'mastodon/utils/numbers';
|
||||||
|
|
||||||
|
const dateForCohort = cohort => {
|
||||||
|
switch(cohort.frequency) {
|
||||||
|
case 'day':
|
||||||
|
return <FormattedDate value={cohort.period} month='long' day='2-digit' />;
|
||||||
|
default:
|
||||||
|
return <FormattedDate value={cohort.period} month='long' year='numeric' />;
|
||||||
|
}
|
||||||
|
};
|
||||||
|
|
||||||
|
export default class Retention extends React.PureComponent {
|
||||||
|
|
||||||
|
static propTypes = {
|
||||||
|
start_at: PropTypes.string,
|
||||||
|
end_at: PropTypes.string,
|
||||||
|
frequency: PropTypes.string,
|
||||||
|
};
|
||||||
|
|
||||||
|
state = {
|
||||||
|
loading: true,
|
||||||
|
data: null,
|
||||||
|
};
|
||||||
|
|
||||||
|
componentDidMount () {
|
||||||
|
const { start_at, end_at, frequency } = this.props;
|
||||||
|
|
||||||
|
api().post('/api/v1/admin/retention', { start_at, end_at, frequency }).then(res => {
|
||||||
|
this.setState({
|
||||||
|
loading: false,
|
||||||
|
data: res.data,
|
||||||
|
});
|
||||||
|
}).catch(err => {
|
||||||
|
console.error(err);
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
|
render () {
|
||||||
|
const { loading, data } = this.state;
|
||||||
|
|
||||||
|
let content;
|
||||||
|
|
||||||
|
if (loading) {
|
||||||
|
content = <FormattedMessage id='loading_indicator.label' defaultMessage='Loading...' />;
|
||||||
|
} else {
|
||||||
|
content = (
|
||||||
|
<table className='retention__table'>
|
||||||
|
<thead>
|
||||||
|
<tr>
|
||||||
|
<th>
|
||||||
|
<div className='retention__table__date retention__table__label'>
|
||||||
|
<FormattedMessage id='admin.dashboard.retention.cohort' defaultMessage='Sign-up month' />
|
||||||
|
</div>
|
||||||
|
</th>
|
||||||
|
|
||||||
|
<th>
|
||||||
|
<div className='retention__table__number retention__table__label'>
|
||||||
|
<FormattedMessage id='admin.dashboard.retention.cohort_size' defaultMessage='New users' />
|
||||||
|
</div>
|
||||||
|
</th>
|
||||||
|
|
||||||
|
{data[0].data.slice(1).map((retention, i) => (
|
||||||
|
<th key={retention.date}>
|
||||||
|
<div className='retention__table__number retention__table__label'>
|
||||||
|
{i + 1}
|
||||||
|
</div>
|
||||||
|
</th>
|
||||||
|
))}
|
||||||
|
</tr>
|
||||||
|
|
||||||
|
<tr>
|
||||||
|
<td>
|
||||||
|
<div className='retention__table__date retention__table__average'>
|
||||||
|
<FormattedMessage id='admin.dashboard.retention.average' defaultMessage='Average' />
|
||||||
|
</div>
|
||||||
|
</td>
|
||||||
|
|
||||||
|
<td>
|
||||||
|
<div className='retention__table__size'>
|
||||||
|
<FormattedNumber value={data.reduce((sum, cohort, i) => sum + ((cohort.data[0].value * 1) - sum) / (i + 1), 0)} maximumFractionDigits={0} />
|
||||||
|
</div>
|
||||||
|
</td>
|
||||||
|
|
||||||
|
{data[0].data.slice(1).map((retention, i) => {
|
||||||
|
const average = data.reduce((sum, cohort, k) => cohort.data[i + 1] ? sum + (cohort.data[i + 1].percent - sum)/(k + 1) : sum, 0);
|
||||||
|
|
||||||
|
return (
|
||||||
|
<td key={retention.date}>
|
||||||
|
<div className={classNames('retention__table__box', 'retention__table__average', `retention__table__box--${roundTo10(average * 100)}`)}>
|
||||||
|
<FormattedNumber value={average} style='percent' />
|
||||||
|
</div>
|
||||||
|
</td>
|
||||||
|
);
|
||||||
|
})}
|
||||||
|
</tr>
|
||||||
|
</thead>
|
||||||
|
|
||||||
|
<tbody>
|
||||||
|
{data.slice(0, -1).map(cohort => (
|
||||||
|
<tr key={cohort.period}>
|
||||||
|
<td>
|
||||||
|
<div className='retention__table__date'>
|
||||||
|
{dateForCohort(cohort)}
|
||||||
|
</div>
|
||||||
|
</td>
|
||||||
|
|
||||||
|
<td>
|
||||||
|
<div className='retention__table__size'>
|
||||||
|
<FormattedNumber value={cohort.data[0].value} />
|
||||||
|
</div>
|
||||||
|
</td>
|
||||||
|
|
||||||
|
{cohort.data.slice(1).map(retention => (
|
||||||
|
<td key={retention.date}>
|
||||||
|
<div className={classNames('retention__table__box', `retention__table__box--${roundTo10(retention.percent * 100)}`)}>
|
||||||
|
<FormattedNumber value={retention.percent} style='percent' />
|
||||||
|
</div>
|
||||||
|
</td>
|
||||||
|
))}
|
||||||
|
</tr>
|
||||||
|
))}
|
||||||
|
</tbody>
|
||||||
|
</table>
|
||||||
|
);
|
||||||
|
}
|
||||||
|
|
||||||
|
return (
|
||||||
|
<div className='retention'>
|
||||||
|
<h4><FormattedMessage id='admin.dashboard.retention' defaultMessage='Retention' /></h4>
|
||||||
|
|
||||||
|
{content}
|
||||||
|
</div>
|
||||||
|
);
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
@ -0,0 +1,73 @@
|
|||||||
|
import React from 'react';
|
||||||
|
import PropTypes from 'prop-types';
|
||||||
|
import api from 'mastodon/api';
|
||||||
|
import { FormattedMessage } from 'react-intl';
|
||||||
|
import classNames from 'classnames';
|
||||||
|
import Hashtag from 'mastodon/components/hashtag';
|
||||||
|
|
||||||
|
export default class Trends extends React.PureComponent {
|
||||||
|
|
||||||
|
static propTypes = {
|
||||||
|
limit: PropTypes.number.isRequired,
|
||||||
|
};
|
||||||
|
|
||||||
|
state = {
|
||||||
|
loading: true,
|
||||||
|
data: null,
|
||||||
|
};
|
||||||
|
|
||||||
|
componentDidMount () {
|
||||||
|
const { limit } = this.props;
|
||||||
|
|
||||||
|
api().get('/api/v1/admin/trends', { params: { limit } }).then(res => {
|
||||||
|
this.setState({
|
||||||
|
loading: false,
|
||||||
|
data: res.data,
|
||||||
|
});
|
||||||
|
}).catch(err => {
|
||||||
|
console.error(err);
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
|
render () {
|
||||||
|
const { limit } = this.props;
|
||||||
|
const { loading, data } = this.state;
|
||||||
|
|
||||||
|
let content;
|
||||||
|
|
||||||
|
if (loading) {
|
||||||
|
content = (
|
||||||
|
<div>
|
||||||
|
{Array.from(Array(limit)).map((_, i) => (
|
||||||
|
<Hashtag key={i} />
|
||||||
|
))}
|
||||||
|
</div>
|
||||||
|
);
|
||||||
|
} else {
|
||||||
|
content = (
|
||||||
|
<div>
|
||||||
|
{data.map(hashtag => (
|
||||||
|
<Hashtag
|
||||||
|
key={hashtag.name}
|
||||||
|
name={hashtag.name}
|
||||||
|
href={`/admin/tags/${hashtag.id}`}
|
||||||
|
people={hashtag.history[0].accounts * 1 + hashtag.history[1].accounts * 1}
|
||||||
|
uses={hashtag.history[0].uses * 1 + hashtag.history[1].uses * 1}
|
||||||
|
history={hashtag.history.reverse().map(day => day.uses)}
|
||||||
|
className={classNames(hashtag.requires_review && 'trends__item--requires-review', !hashtag.trendable && !hashtag.requires_review && 'trends__item--disabled')}
|
||||||
|
/>
|
||||||
|
))}
|
||||||
|
</div>
|
||||||
|
);
|
||||||
|
}
|
||||||
|
|
||||||
|
return (
|
||||||
|
<div className='trends trends--compact'>
|
||||||
|
<h4><FormattedMessage id='trends.trending_now' defaultMessage='Trending now' /></h4>
|
||||||
|
|
||||||
|
{content}
|
||||||
|
</div>
|
||||||
|
);
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
@ -0,0 +1,11 @@
|
|||||||
|
import React from 'react';
|
||||||
|
import PropTypes from 'prop-types';
|
||||||
|
|
||||||
|
const Skeleton = ({ width, height }) => <span className='skeleton' style={{ width, height }}>‌</span>;
|
||||||
|
|
||||||
|
Skeleton.propTypes = {
|
||||||
|
width: PropTypes.number,
|
||||||
|
height: PropTypes.number,
|
||||||
|
};
|
||||||
|
|
||||||
|
export default Skeleton;
|
||||||
@ -0,0 +1,26 @@
|
|||||||
|
import React from 'react';
|
||||||
|
import PropTypes from 'prop-types';
|
||||||
|
import { IntlProvider, addLocaleData } from 'react-intl';
|
||||||
|
import { getLocale } from '../locales';
|
||||||
|
|
||||||
|
const { localeData, messages } = getLocale();
|
||||||
|
addLocaleData(localeData);
|
||||||
|
|
||||||
|
export default class AdminComponent extends React.PureComponent {
|
||||||
|
|
||||||
|
static propTypes = {
|
||||||
|
locale: PropTypes.string.isRequired,
|
||||||
|
children: PropTypes.node.isRequired,
|
||||||
|
};
|
||||||
|
|
||||||
|
render () {
|
||||||
|
const { locale, children } = this.props;
|
||||||
|
|
||||||
|
return (
|
||||||
|
<IntlProvider locale={locale} messages={messages}>
|
||||||
|
{children}
|
||||||
|
</IntlProvider>
|
||||||
|
);
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
@ -1,29 +1,73 @@
|
|||||||
# frozen_string_literal: true
|
# frozen_string_literal: true
|
||||||
|
|
||||||
class ActivityTracker
|
class ActivityTracker
|
||||||
|
include Redisable
|
||||||
|
|
||||||
EXPIRE_AFTER = 6.months.seconds
|
EXPIRE_AFTER = 6.months.seconds
|
||||||
|
|
||||||
class << self
|
def initialize(prefix, type)
|
||||||
include Redisable
|
@prefix = prefix
|
||||||
|
@type = type
|
||||||
|
end
|
||||||
|
|
||||||
def increment(prefix)
|
def add(value = 1, at_time = Time.now.utc)
|
||||||
key = [prefix, current_week].join(':')
|
key = key_at(at_time)
|
||||||
|
|
||||||
redis.incrby(key, 1)
|
case @type
|
||||||
redis.expire(key, EXPIRE_AFTER)
|
when :basic
|
||||||
|
redis.incrby(key, value)
|
||||||
|
when :unique
|
||||||
|
redis.pfadd(key, value)
|
||||||
end
|
end
|
||||||
|
|
||||||
def record(prefix, value)
|
redis.expire(key, EXPIRE_AFTER)
|
||||||
key = [prefix, current_week].join(':')
|
end
|
||||||
|
|
||||||
redis.pfadd(key, value)
|
def get(start_at, end_at = Time.now.utc)
|
||||||
redis.expire(key, EXPIRE_AFTER)
|
(start_at.to_date...end_at.to_date).map do |date|
|
||||||
|
key = key_at(date.to_time(:utc))
|
||||||
|
|
||||||
|
value = begin
|
||||||
|
case @type
|
||||||
|
when :basic
|
||||||
|
redis.get(key).to_i
|
||||||
|
when :unique
|
||||||
|
redis.pfcount(key)
|
||||||
|
end
|
||||||
|
end
|
||||||
|
|
||||||
|
[date, value]
|
||||||
|
end
|
||||||
|
end
|
||||||
|
|
||||||
|
def sum(start_at, end_at = Time.now.utc)
|
||||||
|
keys = (start_at.to_date...end_at.to_date).flat_map { |date| [key_at(date.to_time(:utc)), legacy_key_at(date)] }.uniq
|
||||||
|
|
||||||
|
case @type
|
||||||
|
when :basic
|
||||||
|
redis.mget(*keys).map(&:to_i).sum
|
||||||
|
when :unique
|
||||||
|
redis.pfcount(*keys)
|
||||||
end
|
end
|
||||||
|
end
|
||||||
|
|
||||||
private
|
class << self
|
||||||
|
def increment(prefix)
|
||||||
|
new(prefix, :basic).add
|
||||||
|
end
|
||||||
|
|
||||||
def current_week
|
def record(prefix, value)
|
||||||
Time.zone.today.cweek
|
new(prefix, :unique).add(value)
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
|
||||||
|
private
|
||||||
|
|
||||||
|
def key_at(at_time)
|
||||||
|
"#{@prefix}:#{at_time.beginning_of_day.to_i}"
|
||||||
|
end
|
||||||
|
|
||||||
|
def legacy_key_at(at_time)
|
||||||
|
"#{@prefix}:#{at_time.to_date.cweek}"
|
||||||
|
end
|
||||||
end
|
end
|
||||||
|
|||||||
@ -0,0 +1,15 @@
|
|||||||
|
# frozen_string_literal: true
|
||||||
|
|
||||||
|
class Admin::Metrics::Dimension
|
||||||
|
DIMENSIONS = {
|
||||||
|
languages: Admin::Metrics::Dimension::LanguagesDimension,
|
||||||
|
sources: Admin::Metrics::Dimension::SourcesDimension,
|
||||||
|
servers: Admin::Metrics::Dimension::ServersDimension,
|
||||||
|
space_usage: Admin::Metrics::Dimension::SpaceUsageDimension,
|
||||||
|
software_versions: Admin::Metrics::Dimension::SoftwareVersionsDimension,
|
||||||
|
}.freeze
|
||||||
|
|
||||||
|
def self.retrieve(dimension_keys, start_at, end_at, limit)
|
||||||
|
Array(dimension_keys).map { |key| DIMENSIONS[key.to_sym]&.new(start_at, end_at, limit) }.compact
|
||||||
|
end
|
||||||
|
end
|
||||||
@ -0,0 +1,31 @@
|
|||||||
|
# frozen_string_literal: true
|
||||||
|
|
||||||
|
class Admin::Metrics::Dimension::BaseDimension
|
||||||
|
def initialize(start_at, end_at, limit)
|
||||||
|
@start_at = start_at&.to_datetime
|
||||||
|
@end_at = end_at&.to_datetime
|
||||||
|
@limit = limit&.to_i
|
||||||
|
end
|
||||||
|
|
||||||
|
def key
|
||||||
|
raise NotImplementedError
|
||||||
|
end
|
||||||
|
|
||||||
|
def data
|
||||||
|
raise NotImplementedError
|
||||||
|
end
|
||||||
|
|
||||||
|
def self.model_name
|
||||||
|
self.class.name
|
||||||
|
end
|
||||||
|
|
||||||
|
def read_attribute_for_serialization(key)
|
||||||
|
send(key) if respond_to?(key)
|
||||||
|
end
|
||||||
|
|
||||||
|
protected
|
||||||
|
|
||||||
|
def time_period
|
||||||
|
(@start_at...@end_at)
|
||||||
|
end
|
||||||
|
end
|
||||||
@ -0,0 +1,23 @@
|
|||||||
|
# frozen_string_literal: true
|
||||||
|
|
||||||
|
class Admin::Metrics::Dimension::LanguagesDimension < Admin::Metrics::Dimension::BaseDimension
|
||||||
|
def key
|
||||||
|
'languages'
|
||||||
|
end
|
||||||
|
|
||||||
|
def data
|
||||||
|
sql = <<-SQL.squish
|
||||||
|
SELECT locale, count(*) AS value
|
||||||
|
FROM users
|
||||||
|
WHERE current_sign_in_at BETWEEN $1 AND $2
|
||||||
|
AND locale IS NOT NULL
|
||||||
|
GROUP BY locale
|
||||||
|
ORDER BY count(*) DESC
|
||||||
|
LIMIT $3
|
||||||
|
SQL
|
||||||
|
|
||||||
|
rows = ActiveRecord::Base.connection.select_all(sql, nil, [[nil, @start_at], [nil, @end_at], [nil, @limit]])
|
||||||
|
|
||||||
|
rows.map { |row| { key: row['locale'], human_key: SettingsHelper::HUMAN_LOCALES[row['locale'].to_sym], value: row['value'].to_s } }
|
||||||
|
end
|
||||||
|
end
|
||||||
@ -0,0 +1,23 @@
|
|||||||
|
# frozen_string_literal: true
|
||||||
|
|
||||||
|
class Admin::Metrics::Dimension::ServersDimension < Admin::Metrics::Dimension::BaseDimension
|
||||||
|
def key
|
||||||
|
'servers'
|
||||||
|
end
|
||||||
|
|
||||||
|
def data
|
||||||
|
sql = <<-SQL.squish
|
||||||
|
SELECT accounts.domain, count(*) AS value
|
||||||
|
FROM statuses
|
||||||
|
INNER JOIN accounts ON accounts.id = statuses.account_id
|
||||||
|
WHERE statuses.id BETWEEN $1 AND $2
|
||||||
|
GROUP BY accounts.domain
|
||||||
|
ORDER BY count(*) DESC
|
||||||
|
LIMIT $3
|
||||||
|
SQL
|
||||||
|
|
||||||
|
rows = ActiveRecord::Base.connection.select_all(sql, nil, [[nil, Mastodon::Snowflake.id_at(@start_at)], [nil, Mastodon::Snowflake.id_at(@end_at)], [nil, @limit]])
|
||||||
|
|
||||||
|
rows.map { |row| { key: row['domain'] || Rails.configuration.x.local_domain, human_key: row['domain'] || Rails.configuration.x.local_domain, value: row['value'].to_s } }
|
||||||
|
end
|
||||||
|
end
|
||||||
@ -0,0 +1,69 @@
|
|||||||
|
# frozen_string_literal: true
|
||||||
|
|
||||||
|
class Admin::Metrics::Dimension::SoftwareVersionsDimension < Admin::Metrics::Dimension::BaseDimension
|
||||||
|
include Redisable
|
||||||
|
|
||||||
|
def key
|
||||||
|
'software_versions'
|
||||||
|
end
|
||||||
|
|
||||||
|
def data
|
||||||
|
[mastodon_version, ruby_version, postgresql_version, redis_version]
|
||||||
|
end
|
||||||
|
|
||||||
|
private
|
||||||
|
|
||||||
|
def mastodon_version
|
||||||
|
value = Mastodon::Version.to_s
|
||||||
|
|
||||||
|
{
|
||||||
|
key: 'mastodon',
|
||||||
|
human_key: 'Mastodon',
|
||||||
|
value: value,
|
||||||
|
human_value: value,
|
||||||
|
}
|
||||||
|
end
|
||||||
|
|
||||||
|
def ruby_version
|
||||||
|
value = "#{RUBY_VERSION}p#{RUBY_PATCHLEVEL}"
|
||||||
|
|
||||||
|
{
|
||||||
|
key: 'ruby',
|
||||||
|
human_key: 'Ruby',
|
||||||
|
value: value,
|
||||||
|
human_value: value,
|
||||||
|
}
|
||||||
|
end
|
||||||
|
|
||||||
|
def postgresql_version
|
||||||
|
value = ActiveRecord::Base.connection.execute('SELECT VERSION()').first['version'].match(/\A(?:PostgreSQL |)([^\s]+).*\z/)[1]
|
||||||
|
|
||||||
|
{
|
||||||
|
key: 'postgresql',
|
||||||
|
human_key: 'PostgreSQL',
|
||||||
|
value: value,
|
||||||
|
human_value: value,
|
||||||
|
}
|
||||||
|
end
|
||||||
|
|
||||||
|
def redis_version
|
||||||
|
value = redis_info['redis_version']
|
||||||
|
|
||||||
|
{
|
||||||
|
key: 'redis',
|
||||||
|
human_key: 'Redis',
|
||||||
|
value: value,
|
||||||
|
human_value: value,
|
||||||
|
}
|
||||||
|
end
|
||||||
|
|
||||||
|
def redis_info
|
||||||
|
@redis_info ||= begin
|
||||||
|
if redis.is_a?(Redis::Namespace)
|
||||||
|
redis.redis.info
|
||||||
|
else
|
||||||
|
redis.info
|
||||||
|
end
|
||||||
|
end
|
||||||
|
end
|
||||||
|
end
|
||||||
@ -0,0 +1,23 @@
|
|||||||
|
# frozen_string_literal: true
|
||||||
|
|
||||||
|
class Admin::Metrics::Dimension::SourcesDimension < Admin::Metrics::Dimension::BaseDimension
|
||||||
|
def key
|
||||||
|
'sources'
|
||||||
|
end
|
||||||
|
|
||||||
|
def data
|
||||||
|
sql = <<-SQL.squish
|
||||||
|
SELECT oauth_applications.name, count(*) AS value
|
||||||
|
FROM users
|
||||||
|
LEFT JOIN oauth_applications ON oauth_applications.id = users.created_by_application_id
|
||||||
|
WHERE users.created_at BETWEEN $1 AND $2
|
||||||
|
GROUP BY oauth_applications.name
|
||||||
|
ORDER BY count(*) DESC
|
||||||
|
LIMIT $3
|
||||||
|
SQL
|
||||||
|
|
||||||
|
rows = ActiveRecord::Base.connection.select_all(sql, nil, [[nil, @start_at], [nil, @end_at], [nil, @limit]])
|
||||||
|
|
||||||
|
rows.map { |row| { key: row['name'] || 'web', human_key: row['name'] || I18n.t('admin.dashboard.website'), value: row['value'].to_s } }
|
||||||
|
end
|
||||||
|
end
|
||||||
@ -0,0 +1,70 @@
|
|||||||
|
# frozen_string_literal: true
|
||||||
|
|
||||||
|
class Admin::Metrics::Dimension::SpaceUsageDimension < Admin::Metrics::Dimension::BaseDimension
|
||||||
|
include Redisable
|
||||||
|
include ActionView::Helpers::NumberHelper
|
||||||
|
|
||||||
|
def key
|
||||||
|
'space_usage'
|
||||||
|
end
|
||||||
|
|
||||||
|
def data
|
||||||
|
[postgresql_size, redis_size, media_size]
|
||||||
|
end
|
||||||
|
|
||||||
|
private
|
||||||
|
|
||||||
|
def postgresql_size
|
||||||
|
value = ActiveRecord::Base.connection.execute('SELECT pg_database_size(current_database())').first['pg_database_size']
|
||||||
|
|
||||||
|
{
|
||||||
|
key: 'postgresql',
|
||||||
|
human_key: 'PostgreSQL',
|
||||||
|
value: value.to_s,
|
||||||
|
unit: 'bytes',
|
||||||
|
human_value: number_to_human_size(value),
|
||||||
|
}
|
||||||
|
end
|
||||||
|
|
||||||
|
def redis_size
|
||||||
|
value = redis_info['used_memory']
|
||||||
|
|
||||||
|
{
|
||||||
|
key: 'redis',
|
||||||
|
human_key: 'Redis',
|
||||||
|
value: value.to_s,
|
||||||
|
unit: 'bytes',
|
||||||
|
human_value: number_to_human_size(value),
|
||||||
|
}
|
||||||
|
end
|
||||||
|
|
||||||
|
def media_size
|
||||||
|
value = [
|
||||||
|
MediaAttachment.sum(Arel.sql('COALESCE(file_file_size, 0) + COALESCE(thumbnail_file_size, 0)')),
|
||||||
|
CustomEmoji.sum(:image_file_size),
|
||||||
|
PreviewCard.sum(:image_file_size),
|
||||||
|
Account.sum(Arel.sql('COALESCE(avatar_file_size, 0) + COALESCE(header_file_size, 0)')),
|
||||||
|
Backup.sum(:dump_file_size),
|
||||||
|
Import.sum(:data_file_size),
|
||||||
|
SiteUpload.sum(:file_file_size),
|
||||||
|
].sum
|
||||||
|
|
||||||
|
{
|
||||||
|
key: 'media',
|
||||||
|
human_key: I18n.t('admin.dashboard.media_storage'),
|
||||||
|
value: value.to_s,
|
||||||
|
unit: 'bytes',
|
||||||
|
human_value: number_to_human_size(value),
|
||||||
|
}
|
||||||
|
end
|
||||||
|
|
||||||
|
def redis_info
|
||||||
|
@redis_info ||= begin
|
||||||
|
if redis.is_a?(Redis::Namespace)
|
||||||
|
redis.redis.info
|
||||||
|
else
|
||||||
|
redis.info
|
||||||
|
end
|
||||||
|
end
|
||||||
|
end
|
||||||
|
end
|
||||||
@ -0,0 +1,15 @@
|
|||||||
|
# frozen_string_literal: true
|
||||||
|
|
||||||
|
class Admin::Metrics::Measure
|
||||||
|
MEASURES = {
|
||||||
|
active_users: Admin::Metrics::Measure::ActiveUsersMeasure,
|
||||||
|
new_users: Admin::Metrics::Measure::NewUsersMeasure,
|
||||||
|
interactions: Admin::Metrics::Measure::InteractionsMeasure,
|
||||||
|
opened_reports: Admin::Metrics::Measure::OpenedReportsMeasure,
|
||||||
|
resolved_reports: Admin::Metrics::Measure::ResolvedReportsMeasure,
|
||||||
|
}.freeze
|
||||||
|
|
||||||
|
def self.retrieve(measure_keys, start_at, end_at)
|
||||||
|
Array(measure_keys).map { |key| MEASURES[key.to_sym]&.new(start_at, end_at) }.compact
|
||||||
|
end
|
||||||
|
end
|
||||||
@ -0,0 +1,33 @@
|
|||||||
|
# frozen_string_literal: true
|
||||||
|
|
||||||
|
class Admin::Metrics::Measure::ActiveUsersMeasure < Admin::Metrics::Measure::BaseMeasure
|
||||||
|
def key
|
||||||
|
'active_users'
|
||||||
|
end
|
||||||
|
|
||||||
|
def total
|
||||||
|
activity_tracker.sum(time_period.first, time_period.last)
|
||||||
|
end
|
||||||
|
|
||||||
|
def previous_total
|
||||||
|
activity_tracker.sum(previous_time_period.first, previous_time_period.last)
|
||||||
|
end
|
||||||
|
|
||||||
|
def data
|
||||||
|
activity_tracker.get(time_period.first, time_period.last).map { |date, value| { date: date.to_time(:utc).iso8601, value: value.to_s } }
|
||||||
|
end
|
||||||
|
|
||||||
|
protected
|
||||||
|
|
||||||
|
def activity_tracker
|
||||||
|
@activity_tracker ||= ActivityTracker.new('activity:logins', :unique)
|
||||||
|
end
|
||||||
|
|
||||||
|
def time_period
|
||||||
|
(@start_at.to_date...@end_at.to_date)
|
||||||
|
end
|
||||||
|
|
||||||
|
def previous_time_period
|
||||||
|
((@start_at.to_date - length_of_period)...(@end_at.to_date - length_of_period))
|
||||||
|
end
|
||||||
|
end
|
||||||
@ -0,0 +1,46 @@
|
|||||||
|
# frozen_string_literal: true
|
||||||
|
|
||||||
|
class Admin::Metrics::Measure::BaseMeasure
|
||||||
|
def initialize(start_at, end_at)
|
||||||
|
@start_at = start_at&.to_datetime
|
||||||
|
@end_at = end_at&.to_datetime
|
||||||
|
end
|
||||||
|
|
||||||
|
def key
|
||||||
|
raise NotImplementedError
|
||||||
|
end
|
||||||
|
|
||||||
|
def total
|
||||||
|
raise NotImplementedError
|
||||||
|
end
|
||||||
|
|
||||||
|
def previous_total
|
||||||
|
raise NotImplementedError
|
||||||
|
end
|
||||||
|
|
||||||
|
def data
|
||||||
|
raise NotImplementedError
|
||||||
|
end
|
||||||
|
|
||||||
|
def self.model_name
|
||||||
|
self.class.name
|
||||||
|
end
|
||||||
|
|
||||||
|
def read_attribute_for_serialization(key)
|
||||||
|
send(key) if respond_to?(key)
|
||||||
|
end
|
||||||
|
|
||||||
|
protected
|
||||||
|
|
||||||
|
def time_period
|
||||||
|
(@start_at...@end_at)
|
||||||
|
end
|
||||||
|
|
||||||
|
def previous_time_period
|
||||||
|
((@start_at - length_of_period)...(@end_at - length_of_period))
|
||||||
|
end
|
||||||
|
|
||||||
|
def length_of_period
|
||||||
|
@length_of_period ||= @end_at - @start_at
|
||||||
|
end
|
||||||
|
end
|
||||||
@ -0,0 +1,33 @@
|
|||||||
|
# frozen_string_literal: true
|
||||||
|
|
||||||
|
class Admin::Metrics::Measure::InteractionsMeasure < Admin::Metrics::Measure::BaseMeasure
|
||||||
|
def key
|
||||||
|
'interactions'
|
||||||
|
end
|
||||||
|
|
||||||
|
def total
|
||||||
|
activity_tracker.sum(time_period.first, time_period.last)
|
||||||
|
end
|
||||||
|
|
||||||
|
def previous_total
|
||||||
|
activity_tracker.sum(previous_time_period.first, previous_time_period.last)
|
||||||
|
end
|
||||||
|
|
||||||
|
def data
|
||||||
|
activity_tracker.get(time_period.first, time_period.last).map { |date, value| { date: date.to_time(:utc).iso8601, value: value.to_s } }
|
||||||
|
end
|
||||||
|
|
||||||
|
protected
|
||||||
|
|
||||||
|
def activity_tracker
|
||||||
|
@activity_tracker ||= ActivityTracker.new('activity:interactions', :basic)
|
||||||
|
end
|
||||||
|
|
||||||
|
def time_period
|
||||||
|
(@start_at.to_date...@end_at.to_date)
|
||||||
|
end
|
||||||
|
|
||||||
|
def previous_time_period
|
||||||
|
((@start_at.to_date - length_of_period)...(@end_at.to_date - length_of_period))
|
||||||
|
end
|
||||||
|
end
|
||||||
@ -0,0 +1,35 @@
|
|||||||
|
# frozen_string_literal: true
|
||||||
|
|
||||||
|
class Admin::Metrics::Measure::NewUsersMeasure < Admin::Metrics::Measure::BaseMeasure
|
||||||
|
def key
|
||||||
|
'new_users'
|
||||||
|
end
|
||||||
|
|
||||||
|
def total
|
||||||
|
User.where(created_at: time_period).count
|
||||||
|
end
|
||||||
|
|
||||||
|
def previous_total
|
||||||
|
User.where(created_at: previous_time_period).count
|
||||||
|
end
|
||||||
|
|
||||||
|
def data
|
||||||
|
sql = <<-SQL.squish
|
||||||
|
SELECT axis.*, (
|
||||||
|
WITH new_users AS (
|
||||||
|
SELECT users.id
|
||||||
|
FROM users
|
||||||
|
WHERE date_trunc('day', users.created_at)::date = axis.period
|
||||||
|
)
|
||||||
|
SELECT count(*) FROM new_users
|
||||||
|
) AS value
|
||||||
|
FROM (
|
||||||
|
SELECT generate_series(date_trunc('day', $1::timestamp)::date, date_trunc('day', $2::timestamp)::date, interval '1 day') AS period
|
||||||
|
) AS axis
|
||||||
|
SQL
|
||||||
|
|
||||||
|
rows = ActiveRecord::Base.connection.select_all(sql, nil, [[nil, @start_at], [nil, @end_at]])
|
||||||
|
|
||||||
|
rows.map { |row| { date: row['period'], value: row['value'].to_s } }
|
||||||
|
end
|
||||||
|
end
|
||||||
@ -0,0 +1,35 @@
|
|||||||
|
# frozen_string_literal: true
|
||||||
|
|
||||||
|
class Admin::Metrics::Measure::OpenedReportsMeasure < Admin::Metrics::Measure::BaseMeasure
|
||||||
|
def key
|
||||||
|
'opened_reports'
|
||||||
|
end
|
||||||
|
|
||||||
|
def total
|
||||||
|
Report.where(created_at: time_period).count
|
||||||
|
end
|
||||||
|
|
||||||
|
def previous_total
|
||||||
|
Report.where(created_at: previous_time_period).count
|
||||||
|
end
|
||||||
|
|
||||||
|
def data
|
||||||
|
sql = <<-SQL.squish
|
||||||
|
SELECT axis.*, (
|
||||||
|
WITH new_reports AS (
|
||||||
|
SELECT reports.id
|
||||||
|
FROM reports
|
||||||
|
WHERE date_trunc('day', reports.created_at)::date = axis.period
|
||||||
|
)
|
||||||
|
SELECT count(*) FROM new_reports
|
||||||
|
) AS value
|
||||||
|
FROM (
|
||||||
|
SELECT generate_series(date_trunc('day', $1::timestamp)::date, date_trunc('day', $2::timestamp)::date, interval '1 day') AS period
|
||||||
|
) AS axis
|
||||||
|
SQL
|
||||||
|
|
||||||
|
rows = ActiveRecord::Base.connection.select_all(sql, nil, [[nil, @start_at], [nil, @end_at]])
|
||||||
|
|
||||||
|
rows.map { |row| { date: row['period'], value: row['value'].to_s } }
|
||||||
|
end
|
||||||
|
end
|
||||||
@ -0,0 +1,36 @@
|
|||||||
|
# frozen_string_literal: true
|
||||||
|
|
||||||
|
class Admin::Metrics::Measure::ResolvedReportsMeasure < Admin::Metrics::Measure::BaseMeasure
|
||||||
|
def key
|
||||||
|
'resolved_reports'
|
||||||
|
end
|
||||||
|
|
||||||
|
def total
|
||||||
|
Report.resolved.where(updated_at: time_period).count
|
||||||
|
end
|
||||||
|
|
||||||
|
def previous_total
|
||||||
|
Report.resolved.where(updated_at: previous_time_period).count
|
||||||
|
end
|
||||||
|
|
||||||
|
def data
|
||||||
|
sql = <<-SQL.squish
|
||||||
|
SELECT axis.*, (
|
||||||
|
WITH resolved_reports AS (
|
||||||
|
SELECT reports.id
|
||||||
|
FROM reports
|
||||||
|
WHERE action_taken
|
||||||
|
AND date_trunc('day', reports.updated_at)::date = axis.period
|
||||||
|
)
|
||||||
|
SELECT count(*) FROM resolved_reports
|
||||||
|
) AS value
|
||||||
|
FROM (
|
||||||
|
SELECT generate_series(date_trunc('day', $1::timestamp)::date, date_trunc('day', $2::timestamp)::date, interval '1 day') AS period
|
||||||
|
) AS axis
|
||||||
|
SQL
|
||||||
|
|
||||||
|
rows = ActiveRecord::Base.connection.select_all(sql, nil, [[nil, @start_at], [nil, @end_at]])
|
||||||
|
|
||||||
|
rows.map { |row| { date: row['period'], value: row['value'].to_s } }
|
||||||
|
end
|
||||||
|
end
|
||||||
@ -0,0 +1,67 @@
|
|||||||
|
# frozen_string_literal: true
|
||||||
|
|
||||||
|
class Admin::Metrics::Retention
|
||||||
|
class Cohort < ActiveModelSerializers::Model
|
||||||
|
attributes :period, :frequency, :data
|
||||||
|
end
|
||||||
|
|
||||||
|
class CohortData < ActiveModelSerializers::Model
|
||||||
|
attributes :date, :percent, :value
|
||||||
|
end
|
||||||
|
|
||||||
|
def initialize(start_at, end_at, frequency)
|
||||||
|
@start_at = start_at&.to_date
|
||||||
|
@end_at = end_at&.to_date
|
||||||
|
@frequency = %w(day month).include?(frequency) ? frequency : 'day'
|
||||||
|
end
|
||||||
|
|
||||||
|
def cohorts
|
||||||
|
sql = <<-SQL.squish
|
||||||
|
SELECT axis.*, (
|
||||||
|
WITH new_users AS (
|
||||||
|
SELECT users.id
|
||||||
|
FROM users
|
||||||
|
WHERE date_trunc($3, users.created_at)::date = axis.cohort_period
|
||||||
|
),
|
||||||
|
retained_users AS (
|
||||||
|
SELECT users.id
|
||||||
|
FROM users
|
||||||
|
INNER JOIN new_users on new_users.id = users.id
|
||||||
|
WHERE date_trunc($3, users.current_sign_in_at) >= axis.retention_period
|
||||||
|
)
|
||||||
|
SELECT ARRAY[count(*), (count(*) + 1)::float / (SELECT count(*) + 1 FROM new_users)] AS retention_value_and_percent
|
||||||
|
FROM retained_users
|
||||||
|
)
|
||||||
|
FROM (
|
||||||
|
WITH cohort_periods AS (
|
||||||
|
SELECT generate_series(date_trunc($3, $1::timestamp)::date, date_trunc($3, $2::timestamp)::date, ('1 ' || $3)::interval) AS cohort_period
|
||||||
|
),
|
||||||
|
retention_periods AS (
|
||||||
|
SELECT cohort_period AS retention_period FROM cohort_periods
|
||||||
|
)
|
||||||
|
SELECT *
|
||||||
|
FROM cohort_periods, retention_periods
|
||||||
|
WHERE retention_period >= cohort_period
|
||||||
|
) as axis
|
||||||
|
SQL
|
||||||
|
|
||||||
|
rows = ActiveRecord::Base.connection.select_all(sql, nil, [[nil, @start_at], [nil, @end_at], [nil, @frequency]])
|
||||||
|
|
||||||
|
rows.each_with_object([]) do |row, arr|
|
||||||
|
current_cohort = arr.last
|
||||||
|
|
||||||
|
if current_cohort.nil? || current_cohort.period != row['cohort_period']
|
||||||
|
current_cohort = Cohort.new(period: row['cohort_period'], frequency: @frequency, data: [])
|
||||||
|
arr << current_cohort
|
||||||
|
end
|
||||||
|
|
||||||
|
value, percent = row['retention_value_and_percent'].delete('{}').split(',')
|
||||||
|
|
||||||
|
current_cohort.data << CohortData.new(
|
||||||
|
date: row['retention_period'],
|
||||||
|
percent: percent.to_f,
|
||||||
|
value: value.to_s
|
||||||
|
)
|
||||||
|
end
|
||||||
|
end
|
||||||
|
end
|
||||||
@ -0,0 +1,19 @@
|
|||||||
|
# frozen_string_literal: true
|
||||||
|
|
||||||
|
class REST::Admin::CohortSerializer < ActiveModel::Serializer
|
||||||
|
attributes :period, :frequency
|
||||||
|
|
||||||
|
class CohortDataSerializer < ActiveModel::Serializer
|
||||||
|
attributes :date, :percent, :value
|
||||||
|
|
||||||
|
def date
|
||||||
|
object.date.iso8601
|
||||||
|
end
|
||||||
|
end
|
||||||
|
|
||||||
|
has_many :data, serializer: CohortDataSerializer
|
||||||
|
|
||||||
|
def period
|
||||||
|
object.period.iso8601
|
||||||
|
end
|
||||||
|
end
|
||||||
@ -0,0 +1,5 @@
|
|||||||
|
# frozen_string_literal: true
|
||||||
|
|
||||||
|
class REST::Admin::DimensionSerializer < ActiveModel::Serializer
|
||||||
|
attributes :key, :data
|
||||||
|
end
|
||||||
@ -0,0 +1,13 @@
|
|||||||
|
# frozen_string_literal: true
|
||||||
|
|
||||||
|
class REST::Admin::MeasureSerializer < ActiveModel::Serializer
|
||||||
|
attributes :key, :total, :previous_total, :data
|
||||||
|
|
||||||
|
def total
|
||||||
|
object.total.to_s
|
||||||
|
end
|
||||||
|
|
||||||
|
def previous_total
|
||||||
|
object.previous_total.to_s
|
||||||
|
end
|
||||||
|
end
|
||||||
@ -0,0 +1,13 @@
|
|||||||
|
# frozen_string_literal: true
|
||||||
|
|
||||||
|
class REST::Admin::TagSerializer < REST::TagSerializer
|
||||||
|
attributes :id, :trendable, :usable, :requires_review
|
||||||
|
|
||||||
|
def id
|
||||||
|
object.id.to_s
|
||||||
|
end
|
||||||
|
|
||||||
|
def requires_review
|
||||||
|
object.requires_review?
|
||||||
|
end
|
||||||
|
end
|
||||||
Loading…
Reference in new issue