50 lines
1.6 KiB
TypeScript
50 lines
1.6 KiB
TypeScript
import { Injectable } from '@nestjs/common';
|
|
import { DateTime } from 'luxon';
|
|
import { AuthDto } from 'src/dtos/auth.dto';
|
|
import { SessionResponseDto, mapSession } from 'src/dtos/session.dto';
|
|
import { Permission } from 'src/enum';
|
|
import { JobStatus } from 'src/interfaces/job.interface';
|
|
import { BaseService } from 'src/services/base.service';
|
|
|
|
@Injectable()
|
|
export class SessionService extends BaseService {
|
|
async handleCleanup() {
|
|
const sessions = await this.sessionRepository.search({
|
|
updatedBefore: DateTime.now().minus({ days: 90 }).toJSDate(),
|
|
});
|
|
|
|
if (sessions.length === 0) {
|
|
return JobStatus.SKIPPED;
|
|
}
|
|
|
|
for (const session of sessions) {
|
|
await this.sessionRepository.delete(session.id);
|
|
this.logger.verbose(`Deleted expired session token: ${session.deviceOS}/${session.deviceType}`);
|
|
}
|
|
|
|
this.logger.log(`Deleted ${sessions.length} expired session tokens`);
|
|
|
|
return JobStatus.SUCCESS;
|
|
}
|
|
|
|
async getAll(auth: AuthDto): Promise<SessionResponseDto[]> {
|
|
const sessions = await this.sessionRepository.getByUserId(auth.user.id);
|
|
return sessions.map((session) => mapSession(session, auth.session?.id));
|
|
}
|
|
|
|
async delete(auth: AuthDto, id: string): Promise<void> {
|
|
await this.requireAccess({ auth, permission: Permission.AUTH_DEVICE_DELETE, ids: [id] });
|
|
await this.sessionRepository.delete(id);
|
|
}
|
|
|
|
async deleteAll(auth: AuthDto): Promise<void> {
|
|
const sessions = await this.sessionRepository.getByUserId(auth.user.id);
|
|
for (const session of sessions) {
|
|
if (session.id === auth.session?.id) {
|
|
continue;
|
|
}
|
|
await this.sessionRepository.delete(session.id);
|
|
}
|
|
}
|
|
}
|