fix(prisma): silence the "Record to delete does not exist" error (gra…

…mmyjs#186)

packages/prisma/__tests__/delete.ts

@@ -0,0 +1,38 @@
+import { test, expect, describe, beforeEach } from 'vitest';
+import { session } from 'grammy';
+import { PrismaAdapter } from '../src';
+import { createBot, createMessage } from '@grammyjs/storage-utils';
+import prisma from './helpers/prisma';
+
+beforeEach(async () => {
+  await prisma.session.deleteMany({});
+});
+
+describe('Delete test', () => {
+  test('A not yet stored record should be nullable without throwing', async () => {
+    const bot = createBot();
+
+    bot.use(
+      session({
+        initial() {
+          return { pizzaCount: 0 };
+        },
+        storage: new PrismaAdapter(prisma.session),
+      })
+    );
+
+    bot.hears('first', (ctx) => {
+      ctx.session = null;
+    });
+
+    bot.hears('second', (ctx) => {
+      expect(ctx.session).toHaveProperty('pizzaCount');
+    });
+
+    const firstMessage = createMessage(bot, 'first');
+    const secondMessage = createMessage(bot, 'second');
+
+    await bot.handleUpdate(firstMessage.update);
+    await bot.handleUpdate(secondMessage.update);
+  });
+});

packages/prisma/src/index.ts

@@ -25,6 +25,10 @@ export class PrismaAdapter<T> implements StorageAdapter<T> {
   }
 
   async delete(key: string) {
-    await this.sessionDelegate.delete({ where: { key } });
+    await this.sessionDelegate.delete({ where: { key } }).catch((err) => {
+      // Record does not exist in database
+      if (err?.code === 'P2025') return;
+      return Promise.reject(err);
+    });
   }
 }