fix: adapt to db-lib

NaturalCycles · Oct 18, 2024 · ee5cd1e · ee5cd1e
1 parent 9325445
commit ee5cd1e
Show file tree

Hide file tree

Showing 3 changed files with 160 additions and 168 deletions.
diff --git a/src/betterSqliteKeyValueDB.ts b/src/betterSqliteKeyValueDB.ts
@@ -2,9 +2,10 @@ import {
   CommonDBCreateOptions,
   CommonKeyValueDB,
   commonKeyValueDBFullSupport,
+  IncrementTuple,
   KeyValueDBTuple,
 } from '@naturalcycles/db-lib'
-import { AppError, CommonLogger, StringMap } from '@naturalcycles/js-lib'
+import { AppError, CommonLogger } from '@naturalcycles/js-lib'
 import { boldWhite, readableCreate, ReadableTyped } from '@naturalcycles/nodejs-lib'
 import type { Database, Options } from 'better-sqlite3'
 import BetterSqlite3 from 'better-sqlite3'
@@ -207,10 +208,7 @@ export class BetterSqliteKeyValueDB implements CommonKeyValueDB {
     throw new AppError('Not implemented')
   }
 
-  async incrementBatch(
-    _table: string,
-    _incrementMap: StringMap<number>,
-  ): Promise<StringMap<number>> {
+  async incrementBatch(_table: string, _entries: IncrementTuple[]): Promise<IncrementTuple[]> {
     throw new AppError('Not implemented')
   }
 }
diff --git a/src/sqliteKeyValueDB.ts b/src/sqliteKeyValueDB.ts
@@ -2,9 +2,10 @@ import {
   CommonDBCreateOptions,
   CommonKeyValueDB,
   commonKeyValueDBFullSupport,
+  IncrementTuple,
   KeyValueDBTuple,
 } from '@naturalcycles/db-lib'
-import { AppError, CommonLogger, pMap, StringMap } from '@naturalcycles/js-lib'
+import { AppError, CommonLogger, pMap } from '@naturalcycles/js-lib'
 import { boldWhite, readableCreate, ReadableTyped } from '@naturalcycles/nodejs-lib'
 import { Database, open } from 'sqlite'
 import * as sqlite3 from 'sqlite3'
@@ -226,14 +227,7 @@ export class SqliteKeyValueDB implements CommonKeyValueDB {
     return cnt
   }
 
-  async increment(_table: string, _id: string, _by?: number): Promise<number> {
-    throw new AppError('Not implemented')
-  }
-
-  async incrementBatch(
-    _table: string,
-    _incrementMap: StringMap<number>,
-  ): Promise<StringMap<number>> {
+  async incrementBatch(_table: string, _entries: IncrementTuple[]): Promise<IncrementTuple[]> {
     throw new AppError('Not implemented')
   }
 }