feat: batch store key records

src/app/services/key-record.service.spec.ts

@@ -0,0 +1,16 @@
+import { TestBed } from '@angular/core/testing';
+
+import { KeyRecordService } from './key-record.service';
+
+describe('KeyRecordService', () => {
+  let service: KeyRecordService;
+
+  beforeEach(() => {
+    TestBed.configureTestingModule({});
+    service = TestBed.inject(KeyRecordService);
+  });
+
+  it('should be created', () => {
+    expect(service).toBeTruthy();
+  });
+});

src/app/services/key-record.service.ts

@@ -0,0 +1,24 @@
+import { Injectable } from '@angular/core';
+import { Subject, bufferTime } from 'rxjs';
+import { db } from '../db';
+import { KeyRecord } from '../models/key-record.models';
+
+@Injectable({
+  providedIn: 'root',
+})
+export class KeyRecordService {
+  private queueSubject = new Subject<KeyRecord>();
+
+  constructor() {
+    this.queueSubject
+      .asObservable()
+      .pipe(bufferTime(2000))
+      .subscribe((keyRecords) => {
+        db.keyRecords.bulkAdd(keyRecords);
+      });
+  }
+
+  public pushIntoQueue(keyRecord: KeyRecord) {
+    this.queueSubject.next(keyRecord);
+  }
+}

src/app/stores/lesson.store.ts

@@ -1,14 +1,14 @@
 import { withDevtools } from '@angular-architects/ngrx-toolkit';
-import { computed } from '@angular/core';
+import { computed, inject } from '@angular/core';
 import {
   patchState,
   signalStore,
   withComputed,
   withMethods,
   withState,
 } from '@ngrx/signals';
-import { db } from '../db';
 import { Lesson } from '../models/topic.models';
+import { KeyRecordService } from '../services/key-record.service';
 import { pickRandomItem, pickRandomItemNTimes } from '../utils/random.utils';
 
 const QUEUE_SIZE = 20;
@@ -40,7 +40,7 @@ const initialState: LessonState = {
 export const LessonStore = signalStore(
   withDevtools('lesson'),
   withState(initialState),
-  withMethods((store) => ({
+  withMethods((store, keyRecordService = inject(KeyRecordService)) => ({
     setLesson(lesson: Lesson) {
       patchState(store, () => ({
         topicId: lesson.topic.id,
@@ -72,7 +72,7 @@ export const LessonStore = signalStore(
           inputKey: component,
         };
         if (component !== state.queue[0]) {
-          db.keyRecords.add({
+          keyRecordService.pushIntoQueue({
             ...commonKeyRecord,
             isCorrect: false,
             intervalToPreviousCorrectKey: keyInterval,
@@ -81,7 +81,7 @@ export const LessonStore = signalStore(
           });
           return { error: true, combo: 0 };
         }
-        db.keyRecords.add({
+        keyRecordService.pushIntoQueue({
           ...commonKeyRecord,
           isCorrect: true,
           intervalToPreviousCorrectKey: keyInterval,