06b7e49e98
* Store view counts & last viewed time * Schedule updating user recommendations. Compute using tf-idf. * Update contract's lastBetTime and lastCommentTime on new bets and comments. * Remove contract's lastUpdatedTime * Remove folds activity feed * Implement getFeed cloud function * Hook up client to use getFeed * Script to cache viewCounts and lastViewTime * Batched wait all userRecommendations * Cache view script runs on all users * Update user feed each hour and get feed from cache doc. * Delete view cache script * Update feed script * Tweak feed algorithm * Compute recommendation scores from updateUserFeed * Disable lastViewedScore factor * Update lastCommentTime script * Comment out console.log * Fix timeout issue by calling new cloud functions with part of the work. * Listen for contract updates to feed. * Handle new user: use default feed of top markets this week * Track lastUpdatedTime * Tweak logic of calling cloud functions in batches * Tweak cloud function batching
125 lines
2.8 KiB
TypeScript
125 lines
2.8 KiB
TypeScript
import { PHANTOM_ANTE } from './antes'
|
|
import {
|
|
Binary,
|
|
Contract,
|
|
CPMM,
|
|
DPM,
|
|
FreeResponse,
|
|
outcomeType,
|
|
} from './contract'
|
|
import { User } from './user'
|
|
import { parseTags } from './util/parse'
|
|
import { removeUndefinedProps } from './util/object'
|
|
import { calcDpmInitialPool } from './calculate-dpm'
|
|
|
|
export function getNewContract(
|
|
id: string,
|
|
slug: string,
|
|
creator: User,
|
|
question: string,
|
|
outcomeType: outcomeType,
|
|
description: string,
|
|
initialProb: number,
|
|
ante: number,
|
|
closeTime: number,
|
|
extraTags: string[]
|
|
) {
|
|
const tags = parseTags(
|
|
`${question} ${description} ${extraTags.map((tag) => `#${tag}`).join(' ')}`
|
|
)
|
|
const lowercaseTags = tags.map((tag) => tag.toLowerCase())
|
|
|
|
const propsByOutcomeType =
|
|
outcomeType === 'BINARY'
|
|
? getBinaryCpmmProps(initialProb, ante) // getBinaryDpmProps(initialProb, ante)
|
|
: getFreeAnswerProps(ante)
|
|
|
|
const volume = outcomeType === 'BINARY' ? 0 : ante
|
|
|
|
const contract: Contract = removeUndefinedProps({
|
|
id,
|
|
slug,
|
|
...propsByOutcomeType,
|
|
|
|
creatorId: creator.id,
|
|
creatorName: creator.name,
|
|
creatorUsername: creator.username,
|
|
creatorAvatarUrl: creator.avatarUrl,
|
|
|
|
question: question.trim(),
|
|
description: description.trim(),
|
|
tags,
|
|
lowercaseTags,
|
|
visibility: 'public',
|
|
isResolved: false,
|
|
createdTime: Date.now(),
|
|
closeTime,
|
|
|
|
volume,
|
|
volume24Hours: 0,
|
|
volume7Days: 0,
|
|
|
|
collectedFees: {
|
|
creatorFee: 0,
|
|
liquidityFee: 0,
|
|
platformFee: 0,
|
|
},
|
|
})
|
|
|
|
return contract as Contract
|
|
}
|
|
|
|
const getBinaryDpmProps = (initialProb: number, ante: number) => {
|
|
const { sharesYes, sharesNo, poolYes, poolNo, phantomYes, phantomNo } =
|
|
calcDpmInitialPool(initialProb, ante, PHANTOM_ANTE)
|
|
|
|
const system: DPM & Binary = {
|
|
mechanism: 'dpm-2',
|
|
outcomeType: 'BINARY',
|
|
initialProbability: initialProb / 100,
|
|
phantomShares: { YES: phantomYes, NO: phantomNo },
|
|
pool: { YES: poolYes, NO: poolNo },
|
|
totalShares: { YES: sharesYes, NO: sharesNo },
|
|
totalBets: { YES: poolYes, NO: poolNo },
|
|
}
|
|
|
|
return system
|
|
}
|
|
|
|
const getBinaryCpmmProps = (initialProb: number, ante: number) => {
|
|
const pool = { YES: ante, NO: ante }
|
|
const p = initialProb / 100
|
|
|
|
const system: CPMM & Binary = {
|
|
mechanism: 'cpmm-1',
|
|
outcomeType: 'BINARY',
|
|
totalLiquidity: ante,
|
|
initialProbability: p,
|
|
p,
|
|
pool: pool,
|
|
}
|
|
|
|
return system
|
|
}
|
|
|
|
const getFreeAnswerProps = (ante: number) => {
|
|
const system: DPM & FreeResponse = {
|
|
mechanism: 'dpm-2',
|
|
outcomeType: 'FREE_RESPONSE',
|
|
pool: { '0': ante },
|
|
totalShares: { '0': ante },
|
|
totalBets: { '0': ante },
|
|
answers: [],
|
|
}
|
|
|
|
return system
|
|
}
|
|
|
|
const getMultiProps = (
|
|
outcomes: string[],
|
|
initialProbs: number[],
|
|
ante: number
|
|
) => {
|
|
// Not implemented.
|
|
}
|