50 lines
1.6 KiB
TypeScript
50 lines
1.6 KiB
TypeScript
|
import type { GetHabitProgressesRepository } from "@/data/domain/repositories/GetHabitProgresses"
|
||
|
|
import { SupabaseRepository } from "./_SupabaseRepository"
|
||
|
|
import { HabitProgress } from "@/data/domain/entities/HabitProgress"
|
||
|
|
import type { GoalProgress } from "@/data/domain/entities/Goal"
|
||
|
|
import {
|
||
|
|
GoalBooleanProgress,
|
||
|
|
GoalNumericProgress,
|
||
|
|
} from "@/data/domain/entities/Goal"
|
||
|
|
|
||
|
|
export class GetHabitProgressesSupabaseRepository
|
||
|
|
extends SupabaseRepository
|
||
|
|
implements GetHabitProgressesRepository
|
||
|
|
{
|
||
|
|
execute: GetHabitProgressesRepository["execute"] = async (options) => {
|
||
|
|
const { habit } = options
|
||
|
|
const { data, error } = await this.supabaseClient
|
||
|
|
.from("habits_progresses")
|
||
|
|
.select("*")
|
||
|
|
.eq("habit_id", habit.id)
|
||
|
|
if (error != null) {
|
||
|
|
throw new Error(error.message)
|
||
|
|
}
|
||
|
|
const habitProgresses = data.map((item) => {
|
||
|
|
let goalProgress: GoalProgress | null = null
|
||
|
|
if (habit.goal.isNumeric()) {
|
||
|
|
goalProgress = new GoalNumericProgress({
|
||
|
|
goal: habit.goal,
|
||
|
|
progress: item.goal_progress,
|
||
|
|
})
|
||
|
|
} else if (habit.goal.isBoolean()) {
|
||
|
|
goalProgress = new GoalBooleanProgress({
|
||
|
|
goal: habit.goal,
|
||
|
|
progress: item.goal_progress === 1,
|
||
|
|
})
|
||
|
|
}
|
||
|
|
if (goalProgress == null) {
|
||
|
|
throw new Error("Goal progress is null.")
|
||
|
|
}
|
||
|
|
const habitProgress = new HabitProgress({
|
||
|
|
id: item.id.toString(),
|
||
|
|
habitId: item.habit_id.toString(),
|
||
|
|
goalProgress,
|
||
|
|
date: new Date(item.date),
|
||
|
|
})
|
||
|
|
return habitProgress
|
||
|
|
})
|
||
|
|
return habitProgresses
|
||
|
|
}
|
||
|
|
}
|