ceos/opencode
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

fix(console): restore referral reward status

Browse source
This commit is contained in:
Jack 2026-08-03 12:42:58 +00:00
commit 035a204b79
1 changed files with 35 additions and 29 deletions
Download patch file Download diff file Expand all files Collapse all files

64
packages/console/core/src/referral.ts
View file

@ -59,7 +59,16 @@ export namespace Referral {
const accountID = Actor.account() const accountID = Actor.account()
const code = await ensureCode(workspaceID) const code = await ensureCode(workspaceID)
const rows = await Database.use(async (tx) => { const rows = await Database.use(async (tx) => {
const [invites, inviteeReferral] = await Promise.all([ const [rewards, invites, inviteeReferral] = await Promise.all([
tx
.select({
referralID: ReferralRewardTable.referralID,
amount: ReferralRewardTable.amount,
timeCreated: ReferralRewardTable.timeCreated,
timeApplied: ReferralRewardTable.timeApplied,
})
.from(ReferralRewardTable)
.where(and(eq(ReferralRewardTable.workspaceID, workspaceID), isNull(ReferralRewardTable.timeDeleted))),
tx tx
.select({ id: ReferralTable.id, inviteeEmail: AuthTable.subject, timeCreated: ReferralTable.timeCreated }) .select({ id: ReferralTable.id, inviteeEmail: AuthTable.subject, timeCreated: ReferralTable.timeCreated })
.from(ReferralTable) .from(ReferralTable)
@ -84,36 +93,33 @@ export namespace Referral {
.orderBy(asc(UserTable.timeCreated)) .orderBy(asc(UserTable.timeCreated))
.then((rows) => rows.find((row) => row.inviterEmail) ?? rows[0]), .then((rows) => rows.find((row) => row.inviterEmail) ?? rows[0]),
]) ])
return { inviteeReferral, invites, rewards }
// Hide reward history until the referral_id index can be deployed and this lookup restored.
const rewards: {
referralID: string
workspaceID: string
referralWorkspaceID: string
inviteeEmail: string
amount: number
timeCreated: Date
timeApplied: Date | null
}[] = []
// Hide pending invitee rewards until the referral_id index can be deployed and this lookup restored.
const inviteeRewards = inviteeReferral ? [{ referralID: inviteeReferral.id }] : []
return { inviteeReferral, inviteeRewards, invites, rewards }
}) })
const rewardReferralIDs = new Set(rows.rewards.map((reward) => reward.referralID)) const invites = new Map(rows.invites.map((referral) => [referral.id, referral]))
const inviteeRewardReferralIDs = new Set(rows.inviteeRewards.map((reward) => reward.referralID)) const rewards = rows.rewards.flatMap((reward) => {
const rewards = rows.rewards.map((reward) => { const source = invites.has(reward.referralID)
const source = reward.workspaceID === reward.referralWorkspaceID ? ("inviter" as const) : ("invitee" as const) ? ("inviter" as const)
return { : rows.inviteeReferral?.id === reward.referralID
id: reward.referralID, ? ("invitee" as const)
source, : undefined
status: reward.timeApplied ? ("applied" as const) : ("available" as const), if (!source) return []
email: source === "invitee" ? (rows.inviteeReferral?.inviterEmail ?? null) : reward.inviteeEmail, return [
amount: microCentsToCents(reward.amount), {
timeCreated: reward.timeCreated, id: reward.referralID,
timeApplied: reward.timeApplied, source,
} status: reward.timeApplied ? ("applied" as const) : ("available" as const),
email:
source === "invitee"
? (rows.inviteeReferral?.inviterEmail ?? null)
: (invites.get(reward.referralID)?.inviteeEmail ?? null),
amount: microCentsToCents(reward.amount),
timeCreated: reward.timeCreated,
timeApplied: reward.timeApplied,
},
]
}) })
const rewardReferralIDs = new Set(rewards.map((reward) => reward.id))
const pending = [ const pending = [
...rows.invites ...rows.invites
.filter((referral) => !rewardReferralIDs.has(referral.id)) .filter((referral) => !rewardReferralIDs.has(referral.id))
@ -126,7 +132,7 @@ export namespace Referral {
timeCreated: referral.timeCreated, timeCreated: referral.timeCreated,
timeApplied: null, timeApplied: null,
})), })),
...(rows.inviteeReferral && !inviteeRewardReferralIDs.has(rows.inviteeReferral.id) ...(rows.inviteeReferral && !rewardReferralIDs.has(rows.inviteeReferral.id)
? [ ? [
{ {
id: `${rows.inviteeReferral.id}:invitee`, id: `${rows.inviteeReferral.id}:invitee`,