open.source/manifold
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Send 6 trending emails to all users monday 12pm PT

Browse Source
This commit is contained in:
Ian Philips 2022-08-19 15:01:53 -06:00
parent 634196d8f1
commit 1196ec4375
1 changed files with 7 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
functions/src/weekly-markets-emails.ts
View File

@ -2,15 +2,15 @@ import * as functions from 'firebase-functions'
import * as admin from 'firebase-admin' import * as admin from 'firebase-admin'
import { Contract } from '../../common/contract' import { Contract } from '../../common/contract'
import { getPrivateUser, getUser, getValues, isProd, log } from './utils' import { getAllPrivateUsers, getUser, getValues, log } from './utils'
import { filterDefined } from '../../common/util/array'
import { sendInterestingMarketsEmail } from './emails' import { sendInterestingMarketsEmail } from './emails'
import { createRNG, shuffle } from '../../common/util/random' import { createRNG, shuffle } from '../../common/util/random'
import { DAY_MS } from '../../common/util/time' import { DAY_MS } from '../../common/util/time'
export const weeklyMarketsEmails = functions export const weeklyMarketsEmails = functions
.runWith({ secrets: ['MAILGUN_KEY'] }) .runWith({ secrets: ['MAILGUN_KEY'] })
.pubsub.schedule('every 1 minutes') // every Monday at 12pm PT (UTC -07:00)
.pubsub.schedule('0 19 * * 1')
.onRun(async () => { .onRun(async () => {
await sendTrendingMarketsEmailsToAllUsers() await sendTrendingMarketsEmailsToAllUsers()
}) })
@ -32,13 +32,8 @@ export async function getTrendingContracts() {
} }
async function sendTrendingMarketsEmailsToAllUsers() { async function sendTrendingMarketsEmailsToAllUsers() {
const numEmailsToSend = 6 const numContractsToSend = 6
// const privateUsers = await getAllPrivateUsers() const privateUsers = await getAllPrivateUsers()
// uses dev ian's private user for testing
const privateUser = await getPrivateUser(
isProd() ? 'AJwLWoo3xue32XIiAVrL5SyR1WB2' : '6hHpzvRG0pMq8PNJs7RZj2qlZGn2'
)
const privateUsers = filterDefined([privateUser])
// get all users that haven't unsubscribed from weekly emails // get all users that haven't unsubscribed from weekly emails
const privateUsersToSendEmailsTo = privateUsers.filter((user) => { const privateUsersToSendEmailsTo = privateUsers.filter((user) => {
return !user.unsubscribedFromWeeklyTrendingEmails return !user.unsubscribedFromWeeklyTrendingEmails
@ -60,14 +55,14 @@ async function sendTrendingMarketsEmailsToAllUsers() {
const contractsAvailableToSend = trendingContracts.filter((contract) => { const contractsAvailableToSend = trendingContracts.filter((contract) => {
return !contract.uniqueBettorIds?.includes(privateUser.id) return !contract.uniqueBettorIds?.includes(privateUser.id)
}) })
if (contractsAvailableToSend.length < numEmailsToSend) { if (contractsAvailableToSend.length < numContractsToSend) {
log('not enough new, unbet-on contracts to send to user', privateUser.id) log('not enough new, unbet-on contracts to send to user', privateUser.id)
continue continue
} }
// choose random subset of contracts to send to user // choose random subset of contracts to send to user
const contractsToSend = chooseRandomSubset( const contractsToSend = chooseRandomSubset(
contractsAvailableToSend, contractsAvailableToSend,
numEmailsToSend numContractsToSend
) )
const user = await getUser(privateUser.id) const user = await getUser(privateUser.id)