73 lines
2.2 KiB
JavaScript
73 lines
2.2 KiB
JavaScript
const cloud = require('wx-server-sdk')
|
|
|
|
cloud.init({ env: cloud.DYNAMIC_CURRENT_ENV })
|
|
const db = cloud.database()
|
|
const _ = db.command
|
|
const POST_LIKES_COLLECTION = 'postLikes'
|
|
|
|
function isCollectionMissing(error) {
|
|
const text = String(error?.errMsg || error?.message || error || '')
|
|
return (
|
|
text.includes('collection not exist') ||
|
|
text.includes('collection not exists') ||
|
|
text.includes('collection is not exists') ||
|
|
text.includes('DATABASE_COLLECTION_NOT_EXIST') ||
|
|
text.includes('-502005')
|
|
)
|
|
}
|
|
|
|
function isCollectionAlreadyExists(error) {
|
|
const text = String(error?.errMsg || error?.message || error || '')
|
|
return text.includes('collection already exists') || text.includes('DATABASE_COLLECTION_ALREADY_EXIST')
|
|
}
|
|
|
|
async function ensurePostLikesCollection() {
|
|
if (typeof db.createCollection !== 'function') {
|
|
throw new Error('postLikes collection does not exist')
|
|
}
|
|
|
|
try {
|
|
await db.createCollection(POST_LIKES_COLLECTION)
|
|
} catch (error) {
|
|
if (!isCollectionAlreadyExists(error)) throw error
|
|
}
|
|
}
|
|
|
|
async function getExistingLike(postId, openid) {
|
|
try {
|
|
return await db.collection(POST_LIKES_COLLECTION).where({ postId, openid }).limit(1).get()
|
|
} catch (error) {
|
|
if (!isCollectionMissing(error)) throw error
|
|
await ensurePostLikesCollection()
|
|
return { data: [] }
|
|
}
|
|
}
|
|
|
|
exports.main = async event => {
|
|
const { OPENID } = cloud.getWXContext()
|
|
const { postId, liked } = event
|
|
if (!OPENID) throw new Error('no openid in wx context')
|
|
if (!postId) throw new Error('postId is required')
|
|
|
|
const existed = await getExistingLike(postId, OPENID)
|
|
const collection = db.collection(POST_LIKES_COLLECTION)
|
|
let delta = 0
|
|
|
|
if (liked && !existed.data.length) {
|
|
await collection.add({ data: { postId, openid: OPENID, createdAt: Date.now() } })
|
|
delta = 1
|
|
}
|
|
|
|
if (!liked && existed.data.length) {
|
|
await collection.doc(existed.data[0]._id).remove()
|
|
delta = -1
|
|
}
|
|
|
|
if (delta) {
|
|
await db.collection('posts').doc(postId).update({ data: { 'counts.likes': _.inc(delta) } })
|
|
}
|
|
|
|
const post = await db.collection('posts').doc(postId).get()
|
|
return { liked: Boolean(liked), likes: post.data.counts?.likes || 0 }
|
|
}
|