typescript 40 lines · 7 steps

Scheduled session cleanup in NestJS

A NestJS service runs two cron jobs that delete expired and stale sessions from the database on a schedule.

Explained by highlit
NestJS Intermediate cron-scheduling background-jobs repository-pattern dependency-injection
1import { Injectable, Logger } from '@nestjs/common';
2import { Cron, CronExpression } from '@nestjs/schedule';
3import { InjectRepository } from '@nestjs/typeorm';
4import { Repository, LessThan } from 'typeorm';
5import { Session } from './entities/session.entity';
6 
7@Injectable()
8export class SessionCleanupService {
9 private readonly logger = new Logger(SessionCleanupService.name);
10 
11 constructor(
12 @InjectRepository(Session)
13 private readonly sessions: Repository<Session>,
14 ) {}
15 
16 @Cron(CronExpression.EVERY_HOUR, { name: 'expired-session-cleanup' })
17 async removeExpiredSessions(): Promise<void> {
18 const cutoff = new Date();
19 
20 const { affected } = await this.sessions.delete({
21 expiresAt: LessThan(cutoff),
22 });
23 
24 if (affected) {
25 this.logger.log(`Purged ${affected} expired session(s)`);
26 }
27 }
28 
29 @Cron('0 3 * * 0', { name: 'stale-session-cleanup', timeZone: 'UTC' })
30 async removeStaleSessions(): Promise<void> {
31 const threshold = new Date();
32 threshold.setDate(threshold.getDate() - 30);
33 
34 const { affected } = await this.sessions.delete({
35 lastSeenAt: LessThan(threshold),
36 });
37 
38 this.logger.log(`Weekly sweep removed ${affected ?? 0} stale session(s)`);
39 }
40}
01 / 01
STEP 01

Walkthrough

Space play ←→ step click any line
Three takeaways
  1. 1The @Cron decorator turns ordinary methods into scheduled jobs without any manual timer wiring.
  2. 2TypeORM's delete with a LessThan operator expresses time-based purges declaratively as a single query.
  3. 3Naming each cron and reading affected row counts makes scheduled cleanup observable and traceable.

Related explainers

typescript 
type RequestState<T, E = string> =
  | { status: "idle" }
  | { status: "loading" }
  | { status: "success"; data: T; fetchedAt: number }

Modeling request state with discriminated unions

discriminated-unions exhaustiveness-checking state-machine
Intermediate 8 steps
typescript 
import {
  Directive,
  Input,
  TemplateRef,

Building a structural *appUnless directive in Angular

structural-directive template-rendering dependency-injection
Intermediate 8 steps
typescript 
type EventMap = Record<string, unknown[]>;
 
type Listener<Args extends unknown[]> = (...args: Args) => void;
 

A type-safe event emitter in TypeScript

generics mapped-types event-emitter
Advanced 8 steps
typescript 
import { inject } from '@angular/core';
import { ResolveFn, Router, ActivatedRouteSnapshot } from '@angular/router';
import { catchError, of, EMPTY } from 'rxjs';
import { Article } from './models/article';

Prefetching route data with an Angular resolver

route-resolver dependency-injection rxjs
Intermediate 6 steps
typescript 
interface Order {
  id: number;
  customerId: string;
  total: number;

A type-safe groupBy in TypeScript

generics reduce type-inference
Intermediate 6 steps
python 
import time
from dataclasses import dataclass, field
 
from fastapi import Depends, FastAPI, HTTPException, Request, status

Token-bucket rate limiting in FastAPI

rate-limiting token-bucket dependency-injection
Advanced 10 steps

Share this explainer

Here's the card — post it anywhere.

Scheduled session cleanup in NestJS — share card
Made with highlit — turn any snippet into a walkthrough like this in about a minute.
Explain your code