f50b4775a1
* Allow to follow/unfollow markets, backfill as well * remove yarn script edit * add decrement comment * Lint * Decrement follow count on unfollow * Follow/unfollow button logic * Unfollow/follow => heart * Add user to followers in place-bet and sell-shares * Add tracking * Show contract follow modal for first time following * Increment follower count as well * Remove add follow from bet trigger * restore on-create-bet * Add pubsub to dev.sh, show heart on FR, remove from answer trigger
66 lines
2.3 KiB
TypeScript
66 lines
2.3 KiB
TypeScript
import * as functions from 'firebase-functions'
|
|
import { getUser } from './utils'
|
|
import { createCommentOrAnswerOrUpdatedContractNotification } from './create-notification'
|
|
import { Contract } from '../../common/contract'
|
|
|
|
export const onUpdateContract = functions.firestore
|
|
.document('contracts/{contractId}')
|
|
.onUpdate(async (change, context) => {
|
|
const contract = change.after.data() as Contract
|
|
const { eventId } = context
|
|
|
|
const contractUpdater = await getUser(contract.creatorId)
|
|
if (!contractUpdater) throw new Error('Could not find contract updater')
|
|
|
|
const previousValue = change.before.data() as Contract
|
|
if (previousValue.isResolved !== contract.isResolved) {
|
|
let resolutionText = contract.resolution ?? contract.question
|
|
if (contract.outcomeType === 'FREE_RESPONSE') {
|
|
const answerText = contract.answers.find(
|
|
(answer) => answer.id === contract.resolution
|
|
)?.text
|
|
if (answerText) resolutionText = answerText
|
|
} else if (contract.outcomeType === 'BINARY') {
|
|
if (resolutionText === 'MKT' && contract.resolutionProbability)
|
|
resolutionText = `${contract.resolutionProbability}%`
|
|
else if (resolutionText === 'MKT') resolutionText = 'PROB'
|
|
} else if (contract.outcomeType === 'PSEUDO_NUMERIC') {
|
|
if (resolutionText === 'MKT' && contract.resolutionValue)
|
|
resolutionText = `${contract.resolutionValue}`
|
|
}
|
|
|
|
await createCommentOrAnswerOrUpdatedContractNotification(
|
|
contract.id,
|
|
'contract',
|
|
'resolved',
|
|
contractUpdater,
|
|
eventId,
|
|
resolutionText,
|
|
contract
|
|
)
|
|
} else if (
|
|
previousValue.closeTime !== contract.closeTime ||
|
|
previousValue.question !== contract.question
|
|
) {
|
|
let sourceText = ''
|
|
if (
|
|
previousValue.closeTime !== contract.closeTime &&
|
|
contract.closeTime
|
|
) {
|
|
sourceText = contract.closeTime.toString()
|
|
} else if (previousValue.question !== contract.question) {
|
|
sourceText = contract.question
|
|
}
|
|
|
|
await createCommentOrAnswerOrUpdatedContractNotification(
|
|
contract.id,
|
|
'contract',
|
|
'updated',
|
|
contractUpdater,
|
|
eventId,
|
|
sourceText,
|
|
contract
|
|
)
|
|
}
|
|
})
|