9d5490cf9a
* initial commit * antes * rename path, compute to contractPath, contractMetrics * merge * Include antes as bets; more calculations * fees on estimated winnings * mkt payout calculation * contract: remove startPool, add phantomShares * Merge branch 'main' into new-dpm * dpm migration script * my service account
123 lines
3.5 KiB
TypeScript
123 lines
3.5 KiB
TypeScript
import * as functions from 'firebase-functions'
|
|
import * as admin from 'firebase-admin'
|
|
import * as _ from 'lodash'
|
|
|
|
import { Contract } from '../../common/contract'
|
|
import { User } from '../../common/user'
|
|
import { Bet } from '../../common/bet'
|
|
import { getUser, payUser } from './utils'
|
|
import { sendMarketResolutionEmail } from './emails'
|
|
import {
|
|
getCancelPayouts,
|
|
getMktPayouts,
|
|
getStandardPayouts,
|
|
} from '../../common/payouts'
|
|
|
|
export const resolveMarket = functions
|
|
.runWith({ minInstances: 1 })
|
|
.https.onCall(
|
|
async (
|
|
data: {
|
|
outcome: 'YES' | 'NO' | 'CANCEL' | 'MKT'
|
|
contractId: string
|
|
},
|
|
context
|
|
) => {
|
|
const userId = context?.auth?.uid
|
|
if (!userId) return { status: 'error', message: 'Not authorized' }
|
|
|
|
const { outcome, contractId } = data
|
|
|
|
if (!['YES', 'NO', 'MKT', 'CANCEL'].includes(outcome))
|
|
return { status: 'error', message: 'Invalid outcome' }
|
|
|
|
const contractDoc = firestore.doc(`contracts/${contractId}`)
|
|
const contractSnap = await contractDoc.get()
|
|
if (!contractSnap.exists)
|
|
return { status: 'error', message: 'Invalid contract' }
|
|
const contract = contractSnap.data() as Contract
|
|
|
|
if (contract.creatorId !== userId)
|
|
return { status: 'error', message: 'User not creator of contract' }
|
|
|
|
if (contract.resolution)
|
|
return { status: 'error', message: 'Contract already resolved' }
|
|
|
|
const creator = await getUser(contract.creatorId)
|
|
if (!creator) return { status: 'error', message: 'Creator not found' }
|
|
|
|
await contractDoc.update({
|
|
isResolved: true,
|
|
resolution: outcome,
|
|
resolutionTime: Date.now(),
|
|
})
|
|
|
|
console.log('contract ', contractId, 'resolved to:', outcome)
|
|
|
|
const betsSnap = await firestore
|
|
.collection(`contracts/${contractId}/bets`)
|
|
.get()
|
|
|
|
const bets = betsSnap.docs.map((doc) => doc.data() as Bet)
|
|
const openBets = bets.filter((b) => !b.isSold && !b.sale)
|
|
|
|
const truePool = contract.pool.YES + contract.pool.NO
|
|
|
|
const payouts =
|
|
outcome === 'CANCEL'
|
|
? getCancelPayouts(truePool, openBets)
|
|
: outcome === 'MKT'
|
|
? getMktPayouts(truePool, contract, openBets)
|
|
: getStandardPayouts(outcome, truePool, contract, openBets)
|
|
|
|
console.log('payouts:', payouts)
|
|
|
|
const groups = _.groupBy(payouts, (payout) => payout.userId)
|
|
const userPayouts = _.mapValues(groups, (group) =>
|
|
_.sumBy(group, (g) => g.payout)
|
|
)
|
|
|
|
const payoutPromises = Object.entries(userPayouts).map(
|
|
([userId, payout]) => payUser(userId, payout)
|
|
)
|
|
|
|
const result = await Promise.all(payoutPromises)
|
|
.catch((e) => ({ status: 'error', message: e }))
|
|
.then(() => ({ status: 'success' }))
|
|
|
|
await sendResolutionEmails(
|
|
openBets,
|
|
userPayouts,
|
|
creator,
|
|
contract,
|
|
outcome
|
|
)
|
|
|
|
return result
|
|
}
|
|
)
|
|
|
|
const sendResolutionEmails = async (
|
|
openBets: Bet[],
|
|
userPayouts: { [userId: string]: number },
|
|
creator: User,
|
|
contract: Contract,
|
|
outcome: 'YES' | 'NO' | 'CANCEL' | 'MKT'
|
|
) => {
|
|
const nonWinners = _.difference(
|
|
_.uniq(openBets.map(({ userId }) => userId)),
|
|
Object.keys(userPayouts)
|
|
)
|
|
const emailPayouts = [
|
|
...Object.entries(userPayouts),
|
|
...nonWinners.map((userId) => [userId, 0] as const),
|
|
]
|
|
await Promise.all(
|
|
emailPayouts.map(([userId, payout]) =>
|
|
sendMarketResolutionEmail(userId, payout, creator, contract, outcome)
|
|
)
|
|
)
|
|
}
|
|
|
|
const firestore = admin.firestore()
|