Function getOrgMemberRefreshBounds

apps/sim/lib/billing/credits/daily-refresh.ts:158–179

(
  organizationId: string,
  periodStart: Date,
  executor: DbClient = db
)

}

export async function getOrgMemberRefreshBounds(
  organizationId: string,
  periodStart: Date,
  executor: DbClient = db
): Promise<Record<string, { userStart: Date }>> {
  const rows = await executor
    .select({
      userId: member.userId,
      snapshotAt: userStats.proPeriodCostSnapshotAt,
    })
    .from(member)
    .leftJoin(userStats, eq(member.userId, userStats.userId))
    .where(eq(member.organizationId, organizationId))

  const bounds: Record<string, { userStart: Date }> = {}
  for (const row of rows) {
    if (row.snapshotAt && row.snapshotAt > periodStart) {
      bounds[row.userId] = { userStart: row.snapshotAt }
    }
  }
  return bounds
}