Also handle denormalizing answer avatar URLs
This commit is contained in:
parent
d385bbd90e
commit
e79e0c2d30
|
@ -60,13 +60,32 @@ async function getCommentsByUserId(
|
||||||
return results
|
return results
|
||||||
}
|
}
|
||||||
|
|
||||||
|
async function getAnswersByUserId(
|
||||||
|
transaction: Transaction
|
||||||
|
): Promise<Map<string, DocumentSnapshot[]>> {
|
||||||
|
let n = 0
|
||||||
|
let results = new Map()
|
||||||
|
let answers = await transaction.get(firestore.collectionGroup('answers'))
|
||||||
|
answers.forEach((doc) => {
|
||||||
|
let userId = doc.get('userId')
|
||||||
|
let userAnswers = results.get(userId) || []
|
||||||
|
userAnswers.push(doc)
|
||||||
|
results.set(userId, userAnswers)
|
||||||
|
n++
|
||||||
|
})
|
||||||
|
console.log(`Found ${n} answers from ${results.size} unique users.`)
|
||||||
|
return results
|
||||||
|
}
|
||||||
|
|
||||||
if (require.main === module) {
|
if (require.main === module) {
|
||||||
admin.firestore().runTransaction(async (transaction) => {
|
admin.firestore().runTransaction(async (transaction) => {
|
||||||
let [usersById, contractsByUserId, commentsByUserId] = await Promise.all([
|
let [usersById, contractsByUserId, commentsByUserId, answersByUserId] =
|
||||||
getUsersById(transaction),
|
await Promise.all([
|
||||||
getContractsByUserId(transaction),
|
getUsersById(transaction),
|
||||||
getCommentsByUserId(transaction),
|
getContractsByUserId(transaction),
|
||||||
])
|
getCommentsByUserId(transaction),
|
||||||
|
getAnswersByUserId(transaction),
|
||||||
|
])
|
||||||
|
|
||||||
let usersContracts = Array.from(
|
let usersContracts = Array.from(
|
||||||
usersById.entries(),
|
usersById.entries(),
|
||||||
|
@ -97,5 +116,18 @@ if (require.main === module) {
|
||||||
console.log(describeDiff(d))
|
console.log(describeDiff(d))
|
||||||
applyDiff(transaction, d)
|
applyDiff(transaction, d)
|
||||||
})
|
})
|
||||||
|
|
||||||
|
let usersAnswers = Array.from(
|
||||||
|
usersById.entries(),
|
||||||
|
([id, doc]): DocumentCorrespondence => {
|
||||||
|
return [doc, answersByUserId.get(id) || []]
|
||||||
|
}
|
||||||
|
)
|
||||||
|
let answerDiffs = findDiffs(usersAnswers, 'avatarUrl', 'avatarUrl')
|
||||||
|
console.log(`Found ${answerDiffs.length} answers with mismatches.`)
|
||||||
|
answerDiffs.forEach((d) => {
|
||||||
|
console.log(describeDiff(d))
|
||||||
|
applyDiff(transaction, d)
|
||||||
|
})
|
||||||
})
|
})
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue
Block a user