feature(database-connection): Adapt new requests to database

This commit is contained in:
2021-01-12 13:38:03 +01:00
parent 9ea9fa410c
commit 83d956a8aa
2 changed files with 79 additions and 17 deletions

View File

@@ -1,8 +1,8 @@
import { Injectable } from '@nestjs/common';
import { PrismaClient } from '@prisma/client';
import { PrismaClient, seasons, timetracker, user, ranks } from '@prisma/client';
import logger from 'src/logger/Logger';
import { TableEntry } from 'src/models/TableEntry';
import { TimeTrackerPredicate } from './timetracking.predicate';
import { SeasonInfo, TimeTrackerStats, UserStatsResponse } from '../models/aliases';
@Injectable()
export class DatabaseService {
@@ -19,17 +19,78 @@ export class DatabaseService {
private readonly timetrackerPredicate: TimeTrackerPredicate
) {}
public fetchStats(): Promise<TableEntry[]> {
return new Promise((resolve, reject) => {
this.prismaClient.timetracker.findMany({
include: {
user: true,
ranks: true
public fetchSeasonInfos = async (seasonId: string): Promise<SeasonInfo> => {
let seasons
return this.prismaClient.seasons.findOne({
where: {
// eslint-disable-next-line @typescript-eslint/camelcase
season_id: Number(seasonId)
}
})
.then(result => seasons = result)
.then(this.fetchMaxSeasonId)
.then(result => {
seasons.maxSeasonId = result
return seasons
})
};
public fetchStats = async (seasonId: string): Promise<UserStatsResponse> => {
let response
return this.fetchSeasonInfos(seasonId)
.then(result => {
response = {
seasonId: result.season_id,
maxSeasonid: result.maxSeasonId,
dates: {
start: result.start_date,
end: result.end_date
}
}
return result.season_id.toString()
})
.then(this.fetchTimeTrackerStats)
.then(this.timetrackerPredicate.process)
.then(result => {
response.stats = result
return response
})
};
// public fetchStats = async (seasonId: string): Promise<TableEntry[]> => this.prismaClient.timetracker.findMany({
// include: {
// user: true,
// ranks: true
// },
// where: {
// // eslint-disable-next-line @typescript-eslint/camelcase
// season_id: Number(seasonId)
// }
// })
// .then(this.timetrackerPredicate.process);
fetchTimeTrackerStats: (string) => Promise<TimeTrackerStats[]> = (seasonId: string) => this.prismaClient.timetracker.findMany({
include: {
user: true,
ranks: true
},
where: {
// eslint-disable-next-line @typescript-eslint/camelcase
season_id: Number(seasonId)
}
})
fetchMaxSeasonId: () => Promise<number> = () => new Promise(
(resolve, reject) => {
this.prismaClient.seasons.aggregate({
max: {
// eslint-disable-next-line @typescript-eslint/camelcase
season_id: true
}
})
.then(this.timetrackerPredicate.process)
.then(result => resolve(result))
.catch(err => reject(err));
});
}
.then(result => result.max.season_id)
.then(resolve)
.catch(reject)
}
)
}