stacker.news/worker/earn.js

116 lines
4.4 KiB
JavaScript
Raw Normal View History

2022-03-17 20:13:19 +00:00
const serialize = require('../api/resolvers/serial')
2022-07-07 19:14:22 +00:00
const ITEM_EACH_REWARD = 3.0
const UPVOTE_EACH_REWARD = 6.0
const TOP_PERCENTILE = 21
2022-07-07 19:14:22 +00:00
2022-03-17 20:13:19 +00:00
// TODO: use a weekly trust measure or make trust decay
function earn ({ models }) {
return async function ({ name }) {
console.log('running', name)
// compute how much sn earned today
let [{ sum }] = await models.$queryRaw`
2022-03-17 20:13:19 +00:00
SELECT sum("ItemAct".sats)
FROM "ItemAct"
JOIN "Item" on "ItemAct"."itemId" = "Item".id
WHERE ("ItemAct".act in ('BOOST', 'STREAM')
2022-07-30 13:25:46 +00:00
OR ("ItemAct".act IN ('VOTE','POLL') AND "Item"."userId" = "ItemAct"."userId"))
2022-03-17 20:13:19 +00:00
AND "ItemAct".created_at > now_utc() - INTERVAL '1 day'`
// convert to msats
sum = sum * 1000
2022-07-07 19:14:22 +00:00
/*
How earnings work:
1/3: top 21% posts over last 36 hours, scored on a relative basis
1/3: top 21% comments over last 36 hours, scored on a relative basis
2022-07-07 19:14:22 +00:00
1/3: top upvoters of top posts/comments, scored on:
- their trust
- how much they tipped
- how early they upvoted it
- how the post/comment scored
*/
2022-03-18 12:29:02 +00:00
if (sum <= 0) {
console.log('done', name, 'no earning')
return
}
// get earners { userId, id, type, rank, proportion }
2022-03-18 12:29:02 +00:00
const earners = await models.$queryRaw(`
2022-07-07 19:14:22 +00:00
WITH item_ratios AS (
SELECT *,
CASE WHEN "parentId" IS NULL THEN 'POST' ELSE 'COMMENT' END as type,
CASE WHEN "weightedVotes" > 0 THEN "weightedVotes"/(sum("weightedVotes") OVER (PARTITION BY "parentId" IS NULL)) ELSE 0 END AS ratio
FROM (
SELECT *,
NTILE(100) OVER (PARTITION BY "parentId" IS NULL ORDER BY "weightedVotes" desc) AS percentile,
ROW_NUMBER() OVER (PARTITION BY "parentId" IS NULL ORDER BY "weightedVotes" desc) AS rank
FROM
"Item"
WHERE created_at >= now_utc() - interval '36 hours'
AND "weightedVotes" > 0
) x
WHERE x.percentile <= ${TOP_PERCENTILE}
),
2022-07-07 19:14:22 +00:00
upvoters AS (
SELECT "ItemAct"."userId", item_ratios.id, item_ratios.ratio, item_ratios."parentId",
sum("ItemAct".sats) as tipped, min("ItemAct".created_at) as acted_at
FROM item_ratios
JOIN "ItemAct" on "ItemAct"."itemId" = item_ratios.id
WHERE act IN ('VOTE','TIP')
AND "ItemAct"."userId" <> item_ratios."userId"
GROUP BY "ItemAct"."userId", item_ratios.id, item_ratios.ratio, item_ratios."parentId"
),
upvoter_ratios AS (
SELECT "userId", sum(early_multiplier*tipped_ratio*ratio*users.trust) as upvoter_ratio,
"parentId" IS NULL as "isPost", CASE WHEN "parentId" IS NULL THEN 'TIP_POST' ELSE 'TIP_COMMENT' END as type
2022-07-07 19:14:22 +00:00
FROM (
SELECT *,
1/(ROW_NUMBER() OVER (partition by id order by acted_at asc)) AS early_multiplier,
2022-07-07 19:14:22 +00:00
tipped::float/(sum(tipped) OVER (partition by id)) tipped_ratio
FROM upvoters
) u
JOIN users on "userId" = users.id
GROUP BY "userId", "parentId" IS NULL
)
SELECT "userId", NULL as id, type, ROW_NUMBER() OVER (PARTITION BY "isPost" ORDER BY upvoter_ratio DESC) as rank,
upvoter_ratio/(sum(upvoter_ratio) OVER (PARTITION BY "isPost"))/${UPVOTE_EACH_REWARD} as proportion
FROM upvoter_ratios
WHERE upvoter_ratio > 0
UNION ALL
SELECT "userId", id, type, rank, ratio/${ITEM_EACH_REWARD} as proportion
FROM item_ratios`)
// in order to group earnings for users we use the same createdAt time for
// all earnings
const now = new Date(new Date().getTime())
// this is just a sanity check because it seems like a good idea
let total = 0
2022-03-18 12:29:02 +00:00
// for each earner, serialize earnings
// we do this for each earner because we don't need to serialize
// all earner updates together
earners.forEach(async earner => {
const earnings = Math.floor(earner.proportion * sum)
total += earnings
if (total > sum) {
console.log('total exceeds sum', name)
return
}
if (earnings > 0) {
2022-03-18 12:29:02 +00:00
await serialize(models,
models.$executeRaw`SELECT earn(${earner.userId}, ${earnings},
${now}, ${earner.type}, ${earner.id}, ${earner.rank})`)
2022-03-18 12:29:02 +00:00
}
})
console.log('done', name)
}
}
2022-07-07 19:14:22 +00:00
module.exports = { earn }