158 lines
7.0 KiB
JavaScript
158 lines
7.0 KiB
JavaScript
const PLACEHOLDERS_NUM = 616
|
|
|
|
export default {
|
|
Query: {
|
|
registrationGrowth: async (parent, args, { models }) => {
|
|
return await models.$queryRaw(
|
|
`SELECT date_trunc('month', created_at) AS time, count("inviteId") as invited, count(*) - count("inviteId") as organic
|
|
FROM users
|
|
WHERE id > ${PLACEHOLDERS_NUM} AND date_trunc('month', now_utc()) <> date_trunc('month', created_at)
|
|
GROUP BY time
|
|
ORDER BY time ASC`)
|
|
},
|
|
activeGrowth: async (parent, args, { models }) => {
|
|
return await models.$queryRaw(
|
|
`SELECT date_trunc('month', created_at) AS time, count(DISTINCT "userId") as num
|
|
FROM "ItemAct"
|
|
WHERE date_trunc('month', now_utc()) <> date_trunc('month', created_at)
|
|
GROUP BY time
|
|
ORDER BY time ASC`)
|
|
},
|
|
itemGrowth: async (parent, args, { models }) => {
|
|
return await models.$queryRaw(
|
|
`SELECT date_trunc('month', created_at) AS time, count("parentId") as comments,
|
|
count("subName") as jobs, count(*)-count("parentId")-count("subName") as posts
|
|
FROM "Item"
|
|
WHERE date_trunc('month', now_utc()) <> date_trunc('month', created_at)
|
|
GROUP BY time
|
|
ORDER BY time ASC`)
|
|
},
|
|
spentGrowth: async (parent, args, { models }) => {
|
|
// add up earn for each month
|
|
// add up non-self votes/tips for posts and comments
|
|
|
|
return await models.$queryRaw(
|
|
`SELECT date_trunc('month', "ItemAct".created_at) AS time,
|
|
sum(CASE WHEN act = 'STREAM' THEN sats ELSE 0 END) as jobs,
|
|
sum(CASE WHEN act = 'VOTE' AND "Item"."userId" = "ItemAct"."userId" THEN sats ELSE 0 END) as fees,
|
|
sum(CASE WHEN act = 'BOOST' THEN sats ELSE 0 END) as boost,
|
|
sum(CASE WHEN act = 'TIP' THEN sats ELSE 0 END) as tips
|
|
FROM "ItemAct"
|
|
JOIN "Item" on "ItemAct"."itemId" = "Item".id
|
|
WHERE date_trunc('month', now_utc()) <> date_trunc('month', "ItemAct".created_at)
|
|
GROUP BY time
|
|
ORDER BY time ASC`)
|
|
},
|
|
earnerGrowth: async (parent, args, { models }) => {
|
|
return await models.$queryRaw(
|
|
`SELECT time, count(distinct user_id) as num
|
|
FROM
|
|
((SELECT date_trunc('month', "ItemAct".created_at) AS time, "Item"."userId" as user_id
|
|
FROM "ItemAct"
|
|
JOIN "Item" on "ItemAct"."itemId" = "Item".id AND "Item"."userId" <> "ItemAct"."userId"
|
|
WHERE date_trunc('month', now_utc()) <> date_trunc('month', "ItemAct".created_at))
|
|
UNION ALL
|
|
(SELECT date_trunc('month', created_at) AS time, "userId" as user_id
|
|
FROM "Earn"
|
|
WHERE date_trunc('month', now_utc()) <> date_trunc('month', created_at))) u
|
|
GROUP BY time
|
|
ORDER BY time ASC`)
|
|
},
|
|
stackedGrowth: async (parent, args, { models }) => {
|
|
return await models.$queryRaw(
|
|
`SELECT time, sum(airdrop) as rewards, sum(post) as posts, sum(comment) as comments
|
|
FROM
|
|
((SELECT date_trunc('month', "ItemAct".created_at) AS time, 0 as airdrop,
|
|
CASE WHEN "Item"."parentId" IS NULL THEN 0 ELSE sats END as comment,
|
|
CASE WHEN "Item"."parentId" IS NULL THEN sats ELSE 0 END as post
|
|
FROM "ItemAct"
|
|
JOIN "Item" on "ItemAct"."itemId" = "Item".id AND "Item"."userId" <> "ItemAct"."userId"
|
|
WHERE date_trunc('month', now_utc()) <> date_trunc('month', "ItemAct".created_at) AND
|
|
"ItemAct".act IN ('VOTE', 'TIP'))
|
|
UNION ALL
|
|
(SELECT date_trunc('month', created_at) AS time, msats / 1000 as airdrop, 0 as post, 0 as comment
|
|
FROM "Earn"
|
|
WHERE date_trunc('month', now_utc()) <> date_trunc('month', created_at))) u
|
|
GROUP BY time
|
|
ORDER BY time ASC`)
|
|
},
|
|
registrationsWeekly: async (parent, args, { models }) => {
|
|
return await models.user.count({
|
|
where: {
|
|
createdAt: {
|
|
gte: new Date(new Date().setDate(new Date().getDate() - 7))
|
|
}
|
|
}
|
|
})
|
|
},
|
|
activeWeekly: async (parent, args, { models }) => {
|
|
const [{ active }] = await models.$queryRaw(
|
|
`SELECT count(DISTINCT "userId") as active
|
|
FROM "ItemAct"
|
|
WHERE created_at >= now_utc() - interval '1 week'`
|
|
)
|
|
return active
|
|
},
|
|
earnersWeekly: async (parent, args, { models }) => {
|
|
const [{ earners }] = await models.$queryRaw(
|
|
`SELECT count(distinct user_id) as earners
|
|
FROM
|
|
((SELECT "Item"."userId" as user_id
|
|
FROM "ItemAct"
|
|
JOIN "Item" on "ItemAct"."itemId" = "Item".id AND "Item"."userId" <> "ItemAct"."userId"
|
|
WHERE "ItemAct".created_at >= now_utc() - interval '1 week')
|
|
UNION ALL
|
|
(SELECT "userId" as user_id
|
|
FROM "Earn"
|
|
WHERE created_at >= now_utc() - interval '1 week')) u`)
|
|
return earners
|
|
},
|
|
itemsWeekly: async (parent, args, { models }) => {
|
|
const [stats] = await models.$queryRaw(
|
|
`SELECT json_build_array(
|
|
json_build_object('name', 'comments', 'value', count("parentId")),
|
|
json_build_object('name', 'jobs', 'value', count("subName")),
|
|
json_build_object('name', 'posts', 'value', count(*)-count("parentId")-count("subName"))) as array
|
|
FROM "Item"
|
|
WHERE created_at >= now_utc() - interval '1 week'`)
|
|
|
|
return stats?.array
|
|
},
|
|
spentWeekly: async (parent, args, { models }) => {
|
|
const [stats] = await models.$queryRaw(
|
|
`SELECT json_build_array(
|
|
json_build_object('name', 'jobs', 'value', sum(CASE WHEN act = 'STREAM' THEN sats ELSE 0 END)),
|
|
json_build_object('name', 'fees', 'value', sum(CASE WHEN act = 'VOTE' AND "Item"."userId" = "ItemAct"."userId" THEN sats ELSE 0 END)),
|
|
json_build_object('name', 'boost', 'value', sum(CASE WHEN act = 'BOOST' THEN sats ELSE 0 END)),
|
|
json_build_object('name', 'tips', 'value', sum(CASE WHEN act = 'TIP' THEN sats ELSE 0 END))) as array
|
|
FROM "ItemAct"
|
|
JOIN "Item" on "ItemAct"."itemId" = "Item".id
|
|
WHERE "ItemAct".created_at >= now_utc() - interval '1 week'`)
|
|
|
|
return stats?.array
|
|
},
|
|
stackedWeekly: async (parent, args, { models }) => {
|
|
const [stats] = await models.$queryRaw(
|
|
`SELECT json_build_array(
|
|
json_build_object('name', 'rewards', 'value', sum(airdrop)),
|
|
json_build_object('name', 'posts', 'value', sum(post)),
|
|
json_build_object('name', 'comments', 'value', sum(comment))
|
|
) as array
|
|
FROM
|
|
((SELECT 0 as airdrop,
|
|
CASE WHEN "Item"."parentId" IS NULL THEN 0 ELSE sats END as comment,
|
|
CASE WHEN "Item"."parentId" IS NULL THEN sats ELSE 0 END as post
|
|
FROM "ItemAct"
|
|
JOIN "Item" on "ItemAct"."itemId" = "Item".id AND "Item"."userId" <> "ItemAct"."userId"
|
|
WHERE "ItemAct".created_at >= now_utc() - interval '1 week' AND
|
|
"ItemAct".act IN ('VOTE', 'TIP'))
|
|
UNION ALL
|
|
(SELECT msats / 1000 as airdrop, 0 as post, 0 as comment
|
|
FROM "Earn"
|
|
WHERE created_at >= now_utc() - interval '1 week')) u`)
|
|
|
|
return stats?.array
|
|
}
|
|
}
|
|
}
|