Description

Cache Invalidation at model level extended features for sequelize-typescript (v2.1.0 or later)

Installation

1$ npm install base-repo sequelize@^6.x.x sequelize-typescript@^2.x.x

Your tsconfig.json needs the following flags:

1"target": "es6", // or a more recent ecmascript version
2"experimentalDecorators": true,
3"emitDecoratorMetadata": true

Module Definition

make sure defined all model of sequelize at this level and

1@Module({
2  ...
3  imports: [
4    RedisModule.register(cacheConfig() as RedisModuleOptions),
5
6    SequelizeCacheModule.register({
7      defaultTTL: 5, // DEFINE TTL FOR ALL PROJECT seconds
8      // DEFINE HOW TO GET CACHE FROM GIVEN KEY
9      callbackGet: async ({ key }) => CacheConfigModule.store.get(key),
10      // DEFINE HOW TO INVALIDATE CACHE FROM GIVEN KEY
11      callbackInvalidate: ({ key }) => (CacheConfigModule?.store?.del?.(key) || null),
12      // DEFINE HOW TO SET CACHE FROM GIVEN KEY VALUE AND TTL
13      callbackSet: async ({ key, value, ttl }) => CacheConfigModule.store.set(key, value, { ttl }),
14      callbackGetKey: async ({ keyPattern }) => CacheConfigModule.store.keys?.(`${process.env.CACHE_PREFIX}${keyPattern}`) || [],
15    }),
16
17    SequelizeModule.forRoot({
18      ...DBOptions,
19    }),
20   ...
21  ],
22})
23
24export class CacheConfigModule {
25  static store: Store;
26
27  constructor(@Inject(CACHE_MANAGER) private store: Store) {
28    CacheConfigModule.store = this.store;
29  }
30}

Model Definition

@Cache(options)

the @Cache is used for defined ttl and cache for findOne and automatically invalidate findOneCache/findByPkCache

@Cache API Options

Options	Description
options.ttl	set TTL for this model, this will override ttl at module (Optional)

1@Cache({
2  ttl: 100,
3})
4@Table()
5export class DmCourse extends BaseModel {}

Extend BaseModel

1@Cache({
2  ttl: 100,
3})
4@Table()
5export class DmCourse extends BaseModel {
6  // default `{modelName} data not found'
7  static notFoundMessage = 'your model not found message';
8
9  /**
10   *  @default `updatedAt`
11   * @description `this is for checking newest updated timestamp for cached list.`
12  */
13  static onUpdateAttribute = 'modifiedAt'
14
15   @UpdatedAt
16  @Column({ field: 'UpdatedAt' })
17    modifiedAt: Date;
18}

the Model need to extends BaseModel

More Strict

1interface DmCourseAtt {
2  id: number
3  name: string;
4  type: number;
5}
6
7interface DmCreateAtt extends DmCourseAtt Omit<DmCourseAtt, 'id'>
8
9@Cache({
10  ttl: 100,
11})
12@Table()
13export class DmCourse extends BaseModel<DmCourseAtt, DmCreateAtt> {}

for strict type that can used at default function from sequelize-typescript can be planted at generic type 2 and 3 sequelize-typescript strict

How to use

Model.findOneCache(cacheOptions)

• cacheOptions : FindOptions limited findOptions from sequelize-typescript

1// file: DmCourse.ts
2
3@Cache() //default ttl module
4@Table()
5export class DmCourse extends BaseModel<DmCourseAtt, DmCreateAtt> {}
6
7...
8
9// file: Course.controller.ts
10
11class CourseController {
12  async getCourse() {
13    const course = await DmCourse.findOneCache({
14      where: {
15        isDeleted: false,
16        name: 'Math',
17      },
18      rejectOnEmpty: true, // use model default throw, or use use throw Exception
19      // rejectOnEmpty: new BadRequestException('message')
20    })
21  }
22}

• you have to use All defined cache attributes that has name byIsDeletedAndName
• every query that outside of defined cache will not executed

findOneCache API Options

Options	Description
cacheOptions	some function from Sequelize FindOptions
cacheOptions.ttl	set TTL for this cache key, this will override ttl at module and model (Optional), (Required) when has include Query
cacheOptions.rejectOnEmpty	will throw error when set true (Optional)

Model.findByPkCache(id, options)

1class CourseController {
2  async getCourse() {
3    const course = await DmCourse.findByPkCache(1, {
4      ttl: 100,
5    });
6  }
7}

• find By Primary Cache will invalidate when any destroy or update

findByPkCache API Options

Options	Description
id	value of id
cacheOptions	some function from Sequelize FindOptions
cacheOptions.ttl	set TTL for this cache key, this will override ttl at module and model (Optional), (Required) when has include Query
cacheOptions.rejectOnEmpty	will throw error when set true (Optional)

Model.findAllCache(cacheOptions)

1class CourseController {
2  async getCourse() {
3    const course = await DmCourse.findAllCache({
4     ttl: 100,
5     attributes: ['id','name','type']
6     where: {
7       isDeleted: false,
8     },
9     order: [
10       ['id','desc']
11     ],
12     include: [
13       {
14         // any association
15       }
16     ],
17     limit: 10,
18    })
19  }
20}

• find all data and Cache it when has value. will invalidate and update cache when ttl reach 0 or when get max updates or count is different from before

findAllCache API Options

Options	Description
cacheOptions.ttl	set TTL for this cache key, this will override ttl at module and model (Optional), (Required) when has include Query
{...cacheOptions}	is same with FindOptions from sequelize-typescript

Stay in touch

• Author - Fauzi Fadhillah
• Email