2022-01-05 05:51:26 +00:00
|
|
|
import * as admin from 'firebase-admin'
|
2022-05-26 21:37:51 +00:00
|
|
|
import { z } from 'zod'
|
2022-05-12 15:07:10 +00:00
|
|
|
|
2022-03-09 17:08:57 +00:00
|
|
|
import {
|
|
|
|
Contract,
|
2022-07-26 23:44:51 +00:00
|
|
|
CPMMBinaryContract,
|
2022-06-01 02:42:35 +00:00
|
|
|
FreeResponseContract,
|
2022-03-09 17:08:57 +00:00
|
|
|
MAX_QUESTION_LENGTH,
|
|
|
|
MAX_TAG_LENGTH,
|
2022-07-28 02:40:33 +00:00
|
|
|
MultipleChoiceContract,
|
2022-06-01 02:42:35 +00:00
|
|
|
NumericContract,
|
2022-05-19 17:42:03 +00:00
|
|
|
OUTCOME_TYPES,
|
2022-08-20 19:31:32 +00:00
|
|
|
VISIBILITIES,
|
2022-05-15 17:39:42 +00:00
|
|
|
} from '../../common/contract'
|
|
|
|
import { slugify } from '../../common/util/slugify'
|
|
|
|
import { randomString } from '../../common/util/random'
|
2022-05-19 17:42:03 +00:00
|
|
|
|
2022-08-18 16:02:52 +00:00
|
|
|
import { chargeUser, getContract, isProd } from './utils'
|
2022-05-26 21:37:51 +00:00
|
|
|
import { APIError, newEndpoint, validate, zTimestamp } from './api'
|
2022-05-19 17:42:03 +00:00
|
|
|
|
2022-02-17 23:00:19 +00:00
|
|
|
import {
|
2022-08-18 16:02:52 +00:00
|
|
|
DEV_HOUSE_LIQUIDITY_PROVIDER_ID,
|
2022-04-09 18:51:22 +00:00
|
|
|
FIXED_ANTE,
|
2022-03-15 22:27:51 +00:00
|
|
|
getCpmmInitialLiquidity,
|
2022-02-17 23:00:19 +00:00
|
|
|
getFreeAnswerAnte,
|
2022-07-28 02:40:33 +00:00
|
|
|
getMultipleChoiceAntes,
|
2022-05-19 17:42:03 +00:00
|
|
|
getNumericAnte,
|
2022-08-18 16:02:52 +00:00
|
|
|
HOUSE_LIQUIDITY_PROVIDER_ID,
|
2022-05-15 17:39:42 +00:00
|
|
|
} from '../../common/antes'
|
2022-07-28 02:40:33 +00:00
|
|
|
import { Answer, getNoneAnswer } from '../../common/answer'
|
2022-05-19 17:42:03 +00:00
|
|
|
import { getNewContract } from '../../common/new-contract'
|
|
|
|
import { NUMERIC_BUCKET_COUNT } from '../../common/numeric-constants'
|
2022-06-11 00:51:55 +00:00
|
|
|
import { User } from '../../common/user'
|
2022-08-02 03:15:09 +00:00
|
|
|
import { Group, GroupLink, MAX_ID_LENGTH } from '../../common/group'
|
2022-07-02 19:37:59 +00:00
|
|
|
import { getPseudoProbability } from '../../common/pseudo-numeric'
|
Rich content (#620)
* Add TipTap editor and renderer components
* Change market description editor to rich text
* Type description as JSON, fix string-based logic
- Delete make-predictions.tsx
- Delete feed logic that showed descriptions
* wip Fix API validation
* fix type error
* fix extension import (backend)
In firebase, typescript compiles imports into common js imports
like `const StarterKit = require("@tiptap/starter-kit")`
Even though StarterKit is exported from the cjs file, it gets imported
as undefined. But it magically works if we import *
If you're reading this in the future, consider replacing StarterKit with
the entire list of extensions.
* Stop load on fail create market, improve warning
* Refactor editor as hook / fix infinite submit bug
Move state of editor back up to parent
We have to do this later anyways to allow parent to edit
* Add images - display, paste + uploading
* add uploading state of image
* Fix placeholder, misc styling
min height, quote
* Fix appending to description
* code review fixes: rename, refactor, chop carets
* Add hint & upload button on new lines
- bump to Tailwind 3.1 for arbitrary variants
* clean up, run prettier
* rename FileButton to FileUploadButton
* add image extension as functions dependency
2022-07-13 18:58:22 +00:00
|
|
|
import { JSONContent } from '@tiptap/core'
|
2022-08-02 03:15:09 +00:00
|
|
|
import { uniq, zip } from 'lodash'
|
|
|
|
import { Bet } from '../../common/bet'
|
Rich content (#620)
* Add TipTap editor and renderer components
* Change market description editor to rich text
* Type description as JSON, fix string-based logic
- Delete make-predictions.tsx
- Delete feed logic that showed descriptions
* wip Fix API validation
* fix type error
* fix extension import (backend)
In firebase, typescript compiles imports into common js imports
like `const StarterKit = require("@tiptap/starter-kit")`
Even though StarterKit is exported from the cjs file, it gets imported
as undefined. But it magically works if we import *
If you're reading this in the future, consider replacing StarterKit with
the entire list of extensions.
* Stop load on fail create market, improve warning
* Refactor editor as hook / fix infinite submit bug
Move state of editor back up to parent
We have to do this later anyways to allow parent to edit
* Add images - display, paste + uploading
* add uploading state of image
* Fix placeholder, misc styling
min height, quote
* Fix appending to description
* code review fixes: rename, refactor, chop carets
* Add hint & upload button on new lines
- bump to Tailwind 3.1 for arbitrary variants
* clean up, run prettier
* rename FileButton to FileUploadButton
* add image extension as functions dependency
2022-07-13 18:58:22 +00:00
|
|
|
|
|
|
|
const descScehma: z.ZodType<JSONContent> = z.lazy(() =>
|
|
|
|
z.intersection(
|
|
|
|
z.record(z.any()),
|
|
|
|
z.object({
|
|
|
|
type: z.string().optional(),
|
|
|
|
attrs: z.record(z.any()).optional(),
|
|
|
|
content: z.array(descScehma).optional(),
|
|
|
|
marks: z
|
|
|
|
.array(
|
|
|
|
z.intersection(
|
|
|
|
z.record(z.any()),
|
|
|
|
z.object({
|
|
|
|
type: z.string(),
|
|
|
|
attrs: z.record(z.any()).optional(),
|
|
|
|
})
|
|
|
|
)
|
|
|
|
)
|
|
|
|
.optional(),
|
|
|
|
text: z.string().optional(),
|
|
|
|
})
|
|
|
|
)
|
|
|
|
)
|
2022-01-05 05:51:26 +00:00
|
|
|
|
2022-05-26 21:37:51 +00:00
|
|
|
const bodySchema = z.object({
|
|
|
|
question: z.string().min(1).max(MAX_QUESTION_LENGTH),
|
2022-08-16 22:01:03 +00:00
|
|
|
description: descScehma.or(z.string()).optional(),
|
2022-05-26 21:37:51 +00:00
|
|
|
tags: z.array(z.string().min(1).max(MAX_TAG_LENGTH)).optional(),
|
|
|
|
closeTime: zTimestamp().refine(
|
|
|
|
(date) => date.getTime() > new Date().getTime(),
|
|
|
|
'Close time must be in the future.'
|
|
|
|
),
|
|
|
|
outcomeType: z.enum(OUTCOME_TYPES),
|
2022-06-22 16:35:50 +00:00
|
|
|
groupId: z.string().min(1).max(MAX_ID_LENGTH).optional(),
|
2022-08-20 19:31:32 +00:00
|
|
|
visibility: z.enum(VISIBILITIES).optional(),
|
2022-05-26 21:37:51 +00:00
|
|
|
})
|
2022-05-17 04:43:40 +00:00
|
|
|
|
2022-05-26 21:37:51 +00:00
|
|
|
const binarySchema = z.object({
|
|
|
|
initialProb: z.number().min(1).max(99),
|
|
|
|
})
|
2022-05-19 17:42:03 +00:00
|
|
|
|
2022-07-11 16:38:51 +00:00
|
|
|
const finite = () =>
|
|
|
|
z.number().gte(Number.MIN_SAFE_INTEGER).lte(Number.MAX_SAFE_INTEGER)
|
2022-07-02 19:37:59 +00:00
|
|
|
|
2022-05-26 21:37:51 +00:00
|
|
|
const numericSchema = z.object({
|
2022-07-02 19:37:59 +00:00
|
|
|
min: finite(),
|
|
|
|
max: finite(),
|
|
|
|
initialValue: finite(),
|
|
|
|
isLogScale: z.boolean().optional(),
|
2022-05-26 21:37:51 +00:00
|
|
|
})
|
2022-05-17 04:43:40 +00:00
|
|
|
|
2022-07-28 02:40:33 +00:00
|
|
|
const multipleChoiceSchema = z.object({
|
|
|
|
answers: z.string().trim().min(1).array().min(2),
|
|
|
|
})
|
|
|
|
|
2022-06-29 23:47:06 +00:00
|
|
|
export const createmarket = newEndpoint({}, async (req, auth) => {
|
2022-08-20 19:31:32 +00:00
|
|
|
const {
|
|
|
|
question,
|
|
|
|
description,
|
|
|
|
tags,
|
|
|
|
closeTime,
|
|
|
|
outcomeType,
|
|
|
|
groupId,
|
|
|
|
visibility = 'public',
|
|
|
|
} = validate(bodySchema, req.body)
|
2022-05-19 17:42:03 +00:00
|
|
|
|
2022-07-28 02:40:33 +00:00
|
|
|
let min, max, initialProb, isLogScale, answers
|
2022-07-02 19:37:59 +00:00
|
|
|
|
|
|
|
if (outcomeType === 'PSEUDO_NUMERIC' || outcomeType === 'NUMERIC') {
|
|
|
|
let initialValue
|
|
|
|
;({ min, max, initialValue, isLogScale } = validate(
|
|
|
|
numericSchema,
|
|
|
|
req.body
|
|
|
|
))
|
2022-07-11 16:38:51 +00:00
|
|
|
if (max - min <= 0.01 || initialValue <= min || initialValue >= max)
|
2022-07-02 19:37:59 +00:00
|
|
|
throw new APIError(400, 'Invalid range.')
|
|
|
|
|
|
|
|
initialProb = getPseudoProbability(initialValue, min, max, isLogScale) * 100
|
2022-07-11 16:38:51 +00:00
|
|
|
|
|
|
|
if (initialProb < 1 || initialProb > 99)
|
2022-07-26 23:44:51 +00:00
|
|
|
if (outcomeType === 'PSEUDO_NUMERIC')
|
|
|
|
throw new APIError(
|
|
|
|
400,
|
|
|
|
`Initial value is too ${initialProb < 1 ? 'low' : 'high'}`
|
|
|
|
)
|
|
|
|
else throw new APIError(400, 'Invalid initial probability.')
|
2022-05-26 21:37:51 +00:00
|
|
|
}
|
2022-07-28 02:40:33 +00:00
|
|
|
|
2022-05-26 21:37:51 +00:00
|
|
|
if (outcomeType === 'BINARY') {
|
|
|
|
;({ initialProb } = validate(binarySchema, req.body))
|
|
|
|
}
|
2022-05-17 04:43:40 +00:00
|
|
|
|
2022-07-28 02:40:33 +00:00
|
|
|
if (outcomeType === 'MULTIPLE_CHOICE') {
|
|
|
|
;({ answers } = validate(multipleChoiceSchema, req.body))
|
|
|
|
}
|
|
|
|
|
2022-06-11 00:51:55 +00:00
|
|
|
const userDoc = await firestore.collection('users').doc(auth.uid).get()
|
|
|
|
if (!userDoc.exists) {
|
|
|
|
throw new APIError(400, 'No user exists with the authenticated user ID.')
|
|
|
|
}
|
|
|
|
const user = userDoc.data() as User
|
|
|
|
|
2022-05-17 04:43:40 +00:00
|
|
|
const ante = FIXED_ANTE
|
|
|
|
|
2022-06-12 21:23:23 +00:00
|
|
|
// TODO: this is broken because it's not in a transaction
|
2022-06-23 18:00:14 +00:00
|
|
|
if (ante > user.balance)
|
2022-06-12 21:23:23 +00:00
|
|
|
throw new APIError(400, `Balance must be at least ${ante}.`)
|
|
|
|
|
2022-08-16 05:12:43 +00:00
|
|
|
let group: Group | null = null
|
|
|
|
if (groupId) {
|
|
|
|
const groupDocRef = firestore.collection('groups').doc(groupId)
|
|
|
|
const groupDoc = await groupDocRef.get()
|
|
|
|
if (!groupDoc.exists) {
|
|
|
|
throw new APIError(400, 'No group exists with the given group ID.')
|
|
|
|
}
|
|
|
|
|
|
|
|
group = groupDoc.data() as Group
|
|
|
|
if (
|
|
|
|
!group.memberIds.includes(user.id) &&
|
|
|
|
!group.anyoneCanJoin &&
|
|
|
|
group.creatorId !== user.id
|
|
|
|
) {
|
|
|
|
throw new APIError(
|
|
|
|
400,
|
|
|
|
'User must be a member/creator of the group or group must be open to add markets to it.'
|
|
|
|
)
|
|
|
|
}
|
|
|
|
}
|
2022-06-22 22:19:17 +00:00
|
|
|
const slug = await getSlug(question)
|
|
|
|
const contractRef = firestore.collection('contracts').doc()
|
|
|
|
|
2022-05-17 04:43:40 +00:00
|
|
|
console.log(
|
|
|
|
'creating contract for',
|
2022-05-26 21:37:51 +00:00
|
|
|
user.username,
|
2022-05-17 04:43:40 +00:00
|
|
|
'on',
|
|
|
|
question,
|
|
|
|
'ante:',
|
|
|
|
ante || 0
|
|
|
|
)
|
|
|
|
|
2022-08-16 22:01:03 +00:00
|
|
|
// convert string descriptions into JSONContent
|
|
|
|
const newDescription =
|
|
|
|
typeof description === 'string'
|
|
|
|
? {
|
|
|
|
type: 'doc',
|
|
|
|
content: [
|
|
|
|
{
|
|
|
|
type: 'paragraph',
|
|
|
|
content: [{ type: 'text', text: description }],
|
|
|
|
},
|
|
|
|
],
|
|
|
|
}
|
|
|
|
: description ?? {}
|
|
|
|
|
2022-05-17 04:43:40 +00:00
|
|
|
const contract = getNewContract(
|
|
|
|
contractRef.id,
|
|
|
|
slug,
|
2022-05-26 21:37:51 +00:00
|
|
|
user,
|
2022-05-17 04:43:40 +00:00
|
|
|
question,
|
|
|
|
outcomeType,
|
2022-08-16 22:01:03 +00:00
|
|
|
newDescription,
|
2022-05-26 21:37:51 +00:00
|
|
|
initialProb ?? 0,
|
2022-05-17 04:43:40 +00:00
|
|
|
ante,
|
2022-05-26 21:37:51 +00:00
|
|
|
closeTime.getTime(),
|
2022-05-17 04:43:40 +00:00
|
|
|
tags ?? [],
|
2022-05-19 17:42:03 +00:00
|
|
|
NUMERIC_BUCKET_COUNT,
|
|
|
|
min ?? 0,
|
2022-07-02 19:37:59 +00:00
|
|
|
max ?? 0,
|
2022-07-28 02:40:33 +00:00
|
|
|
isLogScale ?? false,
|
2022-08-20 19:31:32 +00:00
|
|
|
answers ?? [],
|
|
|
|
visibility
|
2022-05-17 04:43:40 +00:00
|
|
|
)
|
|
|
|
|
2022-06-23 18:00:14 +00:00
|
|
|
if (ante) await chargeUser(user.id, ante, true)
|
2022-05-17 04:43:40 +00:00
|
|
|
|
|
|
|
await contractRef.create(contract)
|
|
|
|
|
2022-08-16 05:12:43 +00:00
|
|
|
if (group != null) {
|
2022-08-02 03:15:09 +00:00
|
|
|
if (!group.contractIds.includes(contractRef.id)) {
|
|
|
|
await createGroupLinks(group, [contractRef.id], auth.uid)
|
2022-08-16 05:12:43 +00:00
|
|
|
const groupDocRef = firestore.collection('groups').doc(group.id)
|
|
|
|
groupDocRef.update({
|
2022-08-02 03:15:09 +00:00
|
|
|
contractIds: uniq([...group.contractIds, contractRef.id]),
|
|
|
|
})
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2022-08-18 16:02:52 +00:00
|
|
|
const providerId = isProd()
|
|
|
|
? HOUSE_LIQUIDITY_PROVIDER_ID
|
|
|
|
: DEV_HOUSE_LIQUIDITY_PROVIDER_ID
|
2022-05-20 02:06:50 +00:00
|
|
|
|
2022-07-02 19:37:59 +00:00
|
|
|
if (outcomeType === 'BINARY' || outcomeType === 'PSEUDO_NUMERIC') {
|
2022-05-20 02:06:50 +00:00
|
|
|
const liquidityDoc = firestore
|
|
|
|
.collection(`contracts/${contract.id}/liquidity`)
|
|
|
|
.doc()
|
|
|
|
|
|
|
|
const lp = getCpmmInitialLiquidity(
|
|
|
|
providerId,
|
2022-06-01 02:42:35 +00:00
|
|
|
contract as CPMMBinaryContract,
|
2022-05-20 02:06:50 +00:00
|
|
|
liquidityDoc.id,
|
|
|
|
ante
|
|
|
|
)
|
|
|
|
|
|
|
|
await liquidityDoc.set(lp)
|
2022-07-28 02:40:33 +00:00
|
|
|
} else if (outcomeType === 'MULTIPLE_CHOICE') {
|
|
|
|
const betCol = firestore.collection(`contracts/${contract.id}/bets`)
|
|
|
|
const betDocs = (answers ?? []).map(() => betCol.doc())
|
|
|
|
|
|
|
|
const answerCol = firestore.collection(`contracts/${contract.id}/answers`)
|
|
|
|
const answerDocs = (answers ?? []).map((_, i) =>
|
|
|
|
answerCol.doc(i.toString())
|
|
|
|
)
|
|
|
|
|
|
|
|
const { bets, answerObjects } = getMultipleChoiceAntes(
|
|
|
|
user,
|
|
|
|
contract as MultipleChoiceContract,
|
|
|
|
answers ?? [],
|
|
|
|
betDocs.map((bd) => bd.id)
|
|
|
|
)
|
|
|
|
|
|
|
|
await Promise.all(
|
|
|
|
zip(bets, betDocs).map(([bet, doc]) => doc?.create(bet as Bet))
|
|
|
|
)
|
|
|
|
await Promise.all(
|
|
|
|
zip(answerObjects, answerDocs).map(([answer, doc]) =>
|
|
|
|
doc?.create(answer as Answer)
|
|
|
|
)
|
|
|
|
)
|
|
|
|
await contractRef.update({ answers: answerObjects })
|
2022-05-20 02:06:50 +00:00
|
|
|
} else if (outcomeType === 'FREE_RESPONSE') {
|
|
|
|
const noneAnswerDoc = firestore
|
|
|
|
.collection(`contracts/${contract.id}/answers`)
|
|
|
|
.doc('0')
|
|
|
|
|
2022-05-26 21:37:51 +00:00
|
|
|
const noneAnswer = getNoneAnswer(contract.id, user)
|
2022-05-20 02:06:50 +00:00
|
|
|
await noneAnswerDoc.set(noneAnswer)
|
|
|
|
|
|
|
|
const anteBetDoc = firestore
|
|
|
|
.collection(`contracts/${contract.id}/bets`)
|
|
|
|
.doc()
|
|
|
|
|
|
|
|
const anteBet = getFreeAnswerAnte(
|
|
|
|
providerId,
|
2022-06-01 02:42:35 +00:00
|
|
|
contract as FreeResponseContract,
|
2022-05-20 02:06:50 +00:00
|
|
|
anteBetDoc.id
|
|
|
|
)
|
|
|
|
await anteBetDoc.set(anteBet)
|
|
|
|
} else if (outcomeType === 'NUMERIC') {
|
|
|
|
const anteBetDoc = firestore
|
|
|
|
.collection(`contracts/${contract.id}/bets`)
|
|
|
|
.doc()
|
|
|
|
|
|
|
|
const anteBet = getNumericAnte(
|
2022-05-28 18:43:57 +00:00
|
|
|
providerId,
|
2022-06-01 02:42:35 +00:00
|
|
|
contract as NumericContract,
|
2022-05-20 02:06:50 +00:00
|
|
|
ante,
|
|
|
|
anteBetDoc.id
|
|
|
|
)
|
|
|
|
|
|
|
|
await anteBetDoc.set(anteBet)
|
2022-05-17 04:43:40 +00:00
|
|
|
}
|
|
|
|
|
2022-05-20 21:58:14 +00:00
|
|
|
return contract
|
2022-05-17 04:43:40 +00:00
|
|
|
})
|
2022-01-05 05:51:26 +00:00
|
|
|
|
|
|
|
const getSlug = async (question: string) => {
|
2022-01-10 22:49:04 +00:00
|
|
|
const proposedSlug = slugify(question)
|
2022-01-05 05:51:26 +00:00
|
|
|
|
|
|
|
const preexistingContract = await getContractFromSlug(proposedSlug)
|
|
|
|
|
|
|
|
return preexistingContract
|
|
|
|
? proposedSlug + '-' + randomString()
|
|
|
|
: proposedSlug
|
|
|
|
}
|
|
|
|
|
|
|
|
const firestore = admin.firestore()
|
|
|
|
|
|
|
|
export async function getContractFromSlug(slug: string) {
|
|
|
|
const snap = await firestore
|
|
|
|
.collection('contracts')
|
|
|
|
.where('slug', '==', slug)
|
|
|
|
.get()
|
|
|
|
|
|
|
|
return snap.empty ? undefined : (snap.docs[0].data() as Contract)
|
|
|
|
}
|
2022-08-02 03:15:09 +00:00
|
|
|
|
|
|
|
async function createGroupLinks(
|
|
|
|
group: Group,
|
|
|
|
contractIds: string[],
|
|
|
|
userId: string
|
|
|
|
) {
|
|
|
|
for (const contractId of contractIds) {
|
|
|
|
const contract = await getContract(contractId)
|
|
|
|
if (!contract?.groupSlugs?.includes(group.slug)) {
|
|
|
|
await firestore
|
|
|
|
.collection('contracts')
|
|
|
|
.doc(contractId)
|
|
|
|
.update({
|
|
|
|
groupSlugs: uniq([group.slug, ...(contract?.groupSlugs ?? [])]),
|
|
|
|
})
|
|
|
|
}
|
|
|
|
if (!contract?.groupLinks?.map((gl) => gl.groupId).includes(group.id)) {
|
|
|
|
await firestore
|
|
|
|
.collection('contracts')
|
|
|
|
.doc(contractId)
|
|
|
|
.update({
|
|
|
|
groupLinks: [
|
|
|
|
{
|
|
|
|
groupId: group.id,
|
|
|
|
name: group.name,
|
|
|
|
slug: group.slug,
|
|
|
|
userId,
|
|
|
|
createdTime: Date.now(),
|
|
|
|
} as GroupLink,
|
|
|
|
...(contract?.groupLinks ?? []),
|
|
|
|
],
|
|
|
|
})
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|