stacker.news/api/resolvers/growth.js

279 lines
12 KiB
JavaScript
Raw Normal View History

2022-06-10 19:20:33 +00:00
const PLACEHOLDERS_NUM = 616
2022-12-19 22:27:52 +00:00
export function interval (when) {
2022-12-01 21:31:04 +00:00
switch (when) {
case 'week':
return '1 week'
case 'month':
return '1 month'
case 'year':
return '1 year'
case 'forever':
return null
default:
return '1 day'
}
}
2022-12-19 22:27:52 +00:00
export function timeUnit (when) {
2022-12-01 21:31:04 +00:00
switch (when) {
case 'week':
case 'month':
return 'day'
case 'year':
case 'forever':
return 'month'
default:
return 'hour'
}
}
2022-12-19 22:27:52 +00:00
export function withClause (when) {
2022-12-01 21:31:04 +00:00
const ival = interval(when)
const unit = timeUnit(when)
return `
WITH range_values AS (
SELECT date_trunc('${unit}', ${ival ? "now_utc() - interval '" + ival + "'" : "'2021-06-07'::timestamp"}) as minval,
date_trunc('${unit}', now_utc()) as maxval),
times AS (
SELECT generate_series(minval, maxval, interval '1 ${unit}') as time
FROM range_values
)
`
}
2022-12-01 23:14:16 +00:00
// HACKY AF this is a performance enhancement that allows us to use the created_at indices on tables
2022-12-19 22:27:52 +00:00
export function intervalClause (when, table, and) {
2023-05-19 23:22:28 +00:00
const unit = timeUnit(when)
2022-12-01 23:14:16 +00:00
if (when === 'forever') {
return and ? '' : 'TRUE'
}
2023-05-19 23:22:28 +00:00
return `"${table}".created_at >= date_trunc('${unit}', now_utc() - interval '${interval(when)}') ${and ? 'AND' : ''} `
2022-12-01 23:14:16 +00:00
}
2023-05-18 23:41:56 +00:00
export function viewIntervalClause (when, view, and) {
if (when === 'forever') {
return and ? '' : 'TRUE'
}
return `"${view}".day >= date_trunc('day', timezone('America/Chicago', now() - interval '${interval(when)}')) ${and ? 'AND' : ''} `
}
2022-06-10 19:20:33 +00:00
export default {
Query: {
2022-12-01 21:31:04 +00:00
registrationGrowth: async (parent, { when }, { models }) => {
2023-05-18 23:41:56 +00:00
if (when !== 'day') {
2023-07-26 16:01:31 +00:00
return await models.$queryRawUnsafe(`
2023-05-18 23:41:56 +00:00
SELECT date_trunc('${timeUnit(when)}', day) as time, json_build_array(
json_build_object('name', 'referrals', 'value', sum(referrals)),
json_build_object('name', 'organic', 'value', sum(organic))
) AS data
FROM reg_growth_days
WHERE ${viewIntervalClause(when, 'reg_growth_days', false)}
GROUP BY time
ORDER BY time ASC`)
}
2023-07-26 16:01:31 +00:00
return await models.$queryRawUnsafe(
2022-12-01 21:31:04 +00:00
`${withClause(when)}
SELECT time, json_build_array(
2022-12-19 22:27:52 +00:00
json_build_object('name', 'referrals', 'value', count("referrerId")),
2022-12-01 21:31:04 +00:00
json_build_object('name', 'organic', 'value', count(users.id) FILTER(WHERE id > ${PLACEHOLDERS_NUM}) - count("inviteId"))
) AS data
FROM times
2022-12-01 23:14:16 +00:00
LEFT JOIN users ON ${intervalClause(when, 'users', true)} time = date_trunc('${timeUnit(when)}', created_at)
2022-06-10 19:20:33 +00:00
GROUP BY time
ORDER BY time ASC`)
},
2022-12-01 21:31:04 +00:00
spenderGrowth: async (parent, { when }, { models }) => {
2023-05-18 23:41:56 +00:00
if (when !== 'day') {
2023-07-26 16:01:31 +00:00
return await models.$queryRawUnsafe(`
2023-05-18 23:41:56 +00:00
SELECT date_trunc('${timeUnit(when)}', day) as time, json_build_array(
2023-05-19 23:12:48 +00:00
json_build_object('name', 'any', 'value', floor(avg("any"))),
json_build_object('name', 'jobs', 'value', floor(avg(jobs))),
json_build_object('name', 'boost', 'value', floor(avg(boost))),
json_build_object('name', 'fees', 'value', floor(avg(fees))),
2023-06-19 18:21:55 +00:00
json_build_object('name', 'zaps', 'value', floor(avg(tips))),
2023-05-19 23:12:48 +00:00
json_build_object('name', 'donation', 'value', floor(avg(donations)))
2023-05-18 23:41:56 +00:00
) AS data
FROM spender_growth_days
WHERE ${viewIntervalClause(when, 'spender_growth_days', false)}
GROUP BY time
ORDER BY time ASC`)
}
2023-07-26 16:01:31 +00:00
return await models.$queryRawUnsafe(
2022-12-01 21:31:04 +00:00
`${withClause(when)}
SELECT time, json_build_array(
2022-12-06 19:26:33 +00:00
json_build_object('name', 'any', 'value', count(DISTINCT "userId")),
json_build_object('name', 'jobs', 'value', count(DISTINCT "userId") FILTER (WHERE act = 'STREAM')),
json_build_object('name', 'boost', 'value', count(DISTINCT "userId") FILTER (WHERE act = 'BOOST')),
json_build_object('name', 'fees', 'value', count(DISTINCT "userId") FILTER (WHERE act = 'FEE')),
2023-06-19 18:21:55 +00:00
json_build_object('name', 'zaps', 'value', count(DISTINCT "userId") FILTER (WHERE act = 'TIP')),
2022-12-08 00:04:02 +00:00
json_build_object('name', 'donation', 'value', count(DISTINCT "userId") FILTER (WHERE act = 'DONATION'))
2022-12-01 21:31:04 +00:00
) AS data
FROM times
2022-12-08 00:04:02 +00:00
LEFT JOIN
((SELECT "ItemAct".created_at, "userId", act::text as act
FROM "ItemAct"
WHERE ${intervalClause(when, 'ItemAct', false)})
UNION ALL
(SELECT created_at, "userId", 'DONATION' as act
FROM "Donation"
WHERE ${intervalClause(when, 'Donation', false)})) u ON time = date_trunc('${timeUnit(when)}', u.created_at)
2022-06-10 19:20:33 +00:00
GROUP BY time
ORDER BY time ASC`)
},
2022-12-01 21:31:04 +00:00
itemGrowth: async (parent, { when }, { models }) => {
2023-05-18 23:41:56 +00:00
if (when !== 'day') {
2023-07-26 16:01:31 +00:00
return await models.$queryRawUnsafe(`
2023-05-18 23:41:56 +00:00
SELECT date_trunc('${timeUnit(when)}', day) as time, json_build_array(
json_build_object('name', 'posts', 'value', sum(posts)),
json_build_object('name', 'comments', 'value', sum(comments)),
json_build_object('name', 'jobs', 'value', sum(jobs))
) AS data
FROM item_growth_days
WHERE ${viewIntervalClause(when, 'item_growth_days', false)}
GROUP BY time
ORDER BY time ASC`)
}
2023-07-26 16:01:31 +00:00
return await models.$queryRawUnsafe(
2022-12-01 21:31:04 +00:00
`${withClause(when)}
SELECT time, json_build_array(
json_build_object('name', 'comments', 'value', count("parentId")),
2023-05-04 18:13:55 +00:00
json_build_object('name', 'jobs', 'value', count("subName") FILTER (WHERE "subName" = 'jobs')),
json_build_object('name', 'posts', 'value', count("Item".id)-count("parentId")-(count("subName") FILTER (WHERE "subName" = 'jobs')))
2022-12-01 21:31:04 +00:00
) AS data
FROM times
2022-12-01 23:14:16 +00:00
LEFT JOIN "Item" ON ${intervalClause(when, 'Item', true)} time = date_trunc('${timeUnit(when)}', created_at)
2022-06-10 19:20:33 +00:00
GROUP BY time
ORDER BY time ASC`)
},
2022-12-01 21:31:04 +00:00
spendingGrowth: async (parent, { when }, { models }) => {
2023-05-18 23:41:56 +00:00
if (when !== 'day') {
2023-07-26 16:01:31 +00:00
return await models.$queryRawUnsafe(`
2023-05-18 23:41:56 +00:00
SELECT date_trunc('${timeUnit(when)}', day) as time, json_build_array(
json_build_object('name', 'jobs', 'value', sum(jobs)),
json_build_object('name', 'boost', 'value', sum(boost)),
json_build_object('name', 'fees', 'value', sum(fees)),
2023-06-19 18:21:55 +00:00
json_build_object('name', 'zaps', 'value', sum(tips)),
2023-05-18 23:41:56 +00:00
json_build_object('name', 'donations', 'value', sum(donations))
) AS data
FROM spending_growth_days
WHERE ${viewIntervalClause(when, 'spending_growth_days', false)}
GROUP BY time
ORDER BY time ASC`)
}
2023-07-26 16:01:31 +00:00
return await models.$queryRawUnsafe(
2022-12-01 21:31:04 +00:00
`${withClause(when)}
SELECT time, json_build_array(
2022-12-08 00:04:02 +00:00
json_build_object('name', 'jobs', 'value', coalesce(floor(sum(CASE WHEN act = 'STREAM' THEN msats ELSE 0 END)/1000),0)),
json_build_object('name', 'boost', 'value', coalesce(floor(sum(CASE WHEN act = 'BOOST' THEN msats ELSE 0 END)/1000),0)),
json_build_object('name', 'fees', 'value', coalesce(floor(sum(CASE WHEN act NOT IN ('BOOST', 'TIP', 'STREAM', 'DONATION') THEN msats ELSE 0 END)/1000),0)),
2023-06-19 18:21:55 +00:00
json_build_object('name', 'zaps', 'value', coalesce(floor(sum(CASE WHEN act = 'TIP' THEN msats ELSE 0 END)/1000),0)),
2022-12-08 00:04:02 +00:00
json_build_object('name', 'donations', 'value', coalesce(floor(sum(CASE WHEN act = 'DONATION' THEN msats ELSE 0 END)/1000),0))
2022-12-01 21:31:04 +00:00
) AS data
FROM times
2022-12-08 00:04:02 +00:00
LEFT JOIN
((SELECT "ItemAct".created_at, msats, act::text as act
FROM "ItemAct"
WHERE ${intervalClause(when, 'ItemAct', false)})
UNION ALL
(SELECT created_at, sats * 1000 as msats, 'DONATION' as act
FROM "Donation"
WHERE ${intervalClause(when, 'Donation', false)})) u ON time = date_trunc('${timeUnit(when)}', u.created_at)
2022-06-10 19:20:33 +00:00
GROUP BY time
ORDER BY time ASC`)
2022-06-22 21:13:51 +00:00
},
2022-12-01 21:31:04 +00:00
stackerGrowth: async (parent, { when }, { models }) => {
2023-05-18 23:41:56 +00:00
if (when !== 'day') {
2023-07-26 16:01:31 +00:00
return await models.$queryRawUnsafe(`
2023-05-18 23:41:56 +00:00
SELECT date_trunc('${timeUnit(when)}', day) as time, json_build_array(
2023-05-19 23:12:48 +00:00
json_build_object('name', 'any', 'value', floor(avg("any"))),
json_build_object('name', 'posts', 'value', floor(avg(posts))),
json_build_object('name', 'comments', 'value', floor(floor(avg(comments)))),
json_build_object('name', 'rewards', 'value', floor(avg(rewards))),
json_build_object('name', 'referrals', 'value', floor(avg(referrals)))
2023-05-18 23:41:56 +00:00
) AS data
FROM stackers_growth_days
WHERE ${viewIntervalClause(when, 'stackers_growth_days', false)}
GROUP BY time
ORDER BY time ASC`)
}
2023-07-26 16:01:31 +00:00
return await models.$queryRawUnsafe(
2022-12-01 21:31:04 +00:00
`${withClause(when)}
SELECT time, json_build_array(
2022-12-06 19:26:33 +00:00
json_build_object('name', 'any', 'value', count(distinct user_id)),
json_build_object('name', 'posts', 'value', count(distinct user_id) FILTER (WHERE type = 'POST')),
json_build_object('name', 'comments', 'value', count(distinct user_id) FILTER (WHERE type = 'COMMENT')),
2022-12-19 22:27:52 +00:00
json_build_object('name', 'rewards', 'value', count(distinct user_id) FILTER (WHERE type = 'EARN')),
json_build_object('name', 'referrals', 'value', count(distinct user_id) FILTER (WHERE type = 'REFERRAL'))
2022-12-01 21:31:04 +00:00
) AS data
FROM times
LEFT JOIN
2022-12-06 19:26:33 +00:00
((SELECT "ItemAct".created_at, "Item"."userId" as user_id, CASE WHEN "Item"."parentId" IS NULL THEN 'POST' ELSE 'COMMENT' END as type
2022-06-22 21:13:51 +00:00
FROM "ItemAct"
2022-12-01 21:31:04 +00:00
JOIN "Item" on "ItemAct"."itemId" = "Item".id
2022-12-01 23:14:16 +00:00
WHERE ${intervalClause(when, 'ItemAct', true)} "ItemAct".act = 'TIP')
2022-06-22 21:13:51 +00:00
UNION ALL
2022-12-06 19:26:33 +00:00
(SELECT created_at, "userId" as user_id, 'EARN' as type
2022-12-01 23:14:16 +00:00
FROM "Earn"
2022-12-19 22:27:52 +00:00
WHERE ${intervalClause(when, 'Earn', false)})
UNION ALL
(SELECT created_at, "referrerId" as user_id, 'REFERRAL' as type
FROM "ReferralAct"
WHERE ${intervalClause(when, 'ReferralAct', false)})) u ON time = date_trunc('${timeUnit(when)}', u.created_at)
2022-06-22 21:13:51 +00:00
GROUP BY time
ORDER BY time ASC`)
2022-06-24 15:38:00 +00:00
},
2022-12-01 21:31:04 +00:00
stackingGrowth: async (parent, { when }, { models }) => {
2023-05-18 23:41:56 +00:00
if (when !== 'day') {
2023-07-26 16:01:31 +00:00
return await models.$queryRawUnsafe(`
2023-05-18 23:41:56 +00:00
SELECT date_trunc('${timeUnit(when)}', day) as time, json_build_array(
json_build_object('name', 'rewards', 'value', sum(rewards)),
json_build_object('name', 'posts', 'value', sum(posts)),
json_build_object('name', 'comments', 'value', sum(comments)),
json_build_object('name', 'referrals', 'value', sum(referrals))
) AS data
FROM stacking_growth_days
WHERE ${viewIntervalClause(when, 'stacking_growth_days', false)}
GROUP BY time
ORDER BY time ASC`)
}
2023-07-26 16:01:31 +00:00
return await models.$queryRawUnsafe(
2022-12-01 21:31:04 +00:00
`${withClause(when)}
SELECT time, json_build_array(
json_build_object('name', 'rewards', 'value', coalesce(floor(sum(airdrop)/1000),0)),
json_build_object('name', 'posts', 'value', coalesce(floor(sum(post)/1000),0)),
2022-12-19 22:27:52 +00:00
json_build_object('name', 'comments', 'value', coalesce(floor(sum(comment)/1000),0)),
json_build_object('name', 'referrals', 'value', coalesce(floor(sum(referral)/1000),0))
2022-12-01 21:31:04 +00:00
) AS data
FROM times
LEFT JOIN
((SELECT "ItemAct".created_at, 0 as airdrop,
2022-11-15 20:51:55 +00:00
CASE WHEN "Item"."parentId" IS NULL THEN 0 ELSE "ItemAct".msats END as comment,
2022-12-19 22:27:52 +00:00
CASE WHEN "Item"."parentId" IS NULL THEN "ItemAct".msats ELSE 0 END as post,
0 as referral
2022-06-24 15:38:00 +00:00
FROM "ItemAct"
2022-12-01 21:31:04 +00:00
JOIN "Item" on "ItemAct"."itemId" = "Item".id
2022-12-01 23:14:16 +00:00
WHERE ${intervalClause(when, 'ItemAct', true)} "ItemAct".act = 'TIP')
2022-06-24 15:38:00 +00:00
UNION ALL
2022-12-19 22:27:52 +00:00
(SELECT created_at, 0 as airdrop, 0 as post, 0 as comment, msats as referral
FROM "ReferralAct"
WHERE ${intervalClause(when, 'ReferralAct', false)})
UNION ALL
(SELECT created_at, msats as airdrop, 0 as post, 0 as comment, 0 as referral
2022-12-01 23:14:16 +00:00
FROM "Earn"
WHERE ${intervalClause(when, 'Earn', false)})) u ON time = date_trunc('${timeUnit(when)}', u.created_at)
2022-06-24 15:38:00 +00:00
GROUP BY time
ORDER BY time ASC`)
2022-06-10 19:20:33 +00:00
}
}
}