Release vintasend-prisma@0.11.1

Author: hugobessa

package.json

@@ -1,6 +1,6 @@
 {
   "name": "vintasend-prisma",
-  "version": "0.11.0",
+  "version": "0.11.1",
   "description": "VintaSend Backend implementation for Prisma",
   "main": "dist/index.js",
   "scripts": {
@@ -21,7 +21,7 @@
   "dependencies": {
     "@prisma/client": "^7.4.2",
     "prisma": "^7.4.2",
-    "vintasend": "^0.11.0"
+    "vintasend": "^0.11.1"
   },
   "devDependencies": {
     "@biomejs/biome": "^2.4.5",

src/__tests__/prisma-notification-backend-attachments.test.ts

@@ -3,7 +3,7 @@ import type {
   BaseAttachmentManager,
   NotificationAttachment,
 } from 'vintasend';
-import { type Mock, type Mocked, vi } from 'vitest';
+import { beforeEach, describe, expect, it, type Mock, type Mocked, vi } from 'vitest';
 import { PrismaNotificationBackendFactory } from '../index';
 import type {
   NotificationPrismaClientInterface,

src/__tests__/prisma-notification-backend.test.ts

@@ -4,7 +4,7 @@ import type {
   NotificationFilter,
   NotificationOrderBy,
 } from 'vintasend';
-import { type Mock, type Mocked, vi } from 'vitest';
+import { beforeEach, describe, expect, it, type Mock, type Mocked, vi } from 'vitest';
 import { PrismaNotificationBackendFactory } from '../index';
 import type {
   NotificationPrismaClientInterface,
@@ -905,8 +905,9 @@ describe('PrismaNotificationBackend', () => {
       const createMock = mockPrismaClient.notification.create as Mock;
       createMock.mockResolvedValue(invalidInput);
 
-      // @ts-expect-error - testing invalid input
-      await expect(backend.persistNotification(invalidInput)).rejects.toThrow('Invalid JSON value');
+      await expect(backend.persistNotification(invalidInput as any)).rejects.toThrow(
+        'Invalid JSON value',
+      );
     });
   });
 
@@ -1088,8 +1089,9 @@ describe('PrismaNotificationBackend', () => {
       const createMock = mockPrismaClient.notification.create as Mock;
       createMock.mockResolvedValue(invalidInput);
 
-      // @ts-expect-error - testing invalid input
-      await expect(backend.persistNotification(invalidInput)).rejects.toThrow('Invalid JSON value');
+      await expect(backend.persistNotification(invalidInput as any)).rejects.toThrow(
+        'Invalid JSON value',
+      );
     });
 
     it('should handle missing user email in getUserEmailFromNotification', async () => {

src/prisma-notification-backend.ts

@@ -144,10 +144,15 @@ type PrismaNotificationWhereInput<NotificationIdType, UserIdType> = {
   sentAt?: PrismaDateRangeFilter;
 };
 
-export interface NotificationPrismaClientInterface<NotificationIdType, UserIdType> {
-  $transaction<R>(
-    fn: (prisma: NotificationPrismaClientInterface<NotificationIdType, UserIdType>) => Promise<R>,
-  ): Promise<R>;
+type AwaitedTuple<T extends readonly unknown[]> = {
+  [K in keyof T]: Awaited<T[K]>;
+};
+
+type PrismaTransactionOptions = {
+  isolationLevel?: unknown;
+};
+
+interface NotificationPrismaDelegates<NotificationIdType, UserIdType> {
   notification: {
     findMany(args?: {
       where?: PrismaNotificationWhereInput<NotificationIdType, UserIdType>;
@@ -232,6 +237,27 @@ export interface NotificationPrismaClientInterface<NotificationIdType, UserIdTyp
   };
 }
 
+export interface NotificationPrismaTransactionClientInterface<NotificationIdType, UserIdType>
+  extends NotificationPrismaDelegates<NotificationIdType, UserIdType> {}
+
+export interface NotificationPrismaClientInterface<NotificationIdType, UserIdType> {
+  $transaction: {
+    <R>(
+      fn: (
+        prisma: NotificationPrismaTransactionClientInterface<NotificationIdType, UserIdType>,
+      ) => Promise<R>,
+      options?: PrismaTransactionOptions,
+    ): Promise<R>;
+    <P extends readonly unknown[]>(
+      arg: [...P],
+      options?: PrismaTransactionOptions,
+    ): Promise<AwaitedTuple<P>>;
+  };
+}
+
+export interface NotificationPrismaClientInterface<NotificationIdType, UserIdType>
+  extends NotificationPrismaDelegates<NotificationIdType, UserIdType> {}
+
 // cause typescript not to expand types and preserve names
 type NoExpand<T> = T extends unknown ? T : never;
 
@@ -835,7 +861,10 @@ export class PrismaNotificationBackend<
    * @private
    */
   private async getOrCreateFileRecordForUploadInTransaction(
-    tx: NotificationPrismaClientInterface<Config['NotificationIdType'], Config['UserIdType']>,
+    tx: NotificationPrismaTransactionClientInterface<
+      Config['NotificationIdType'],
+      Config['UserIdType']
+    >,
     att: Extract<NotificationAttachment, { file: unknown }>,
   ): Promise<AttachmentFileRecord> {
     const manager = this.getAttachmentManager();
@@ -866,7 +895,10 @@ export class PrismaNotificationBackend<
    * @private`
    */
   private async createNotificationAttachmentLinkInTransaction(
-    tx: NotificationPrismaClientInterface<Config['NotificationIdType'], Config['UserIdType']>,
+    tx: NotificationPrismaTransactionClientInterface<
+      Config['NotificationIdType'],
+      Config['UserIdType']
+    >,
     notificationId: Config['NotificationIdType'],
     fileId: string,
     description?: string | null,
@@ -885,7 +917,10 @@ export class PrismaNotificationBackend<
    * @private
    */
   private async getAttachmentFileInTransaction(
-    tx: NotificationPrismaClientInterface<Config['NotificationIdType'], Config['UserIdType']>,
+    tx: NotificationPrismaTransactionClientInterface<
+      Config['NotificationIdType'],
+      Config['UserIdType']
+    >,
     fileId: string,
   ): Promise<AttachmentFileRecord | null> {
     const file = await tx.attachmentFile.findUnique({
@@ -902,7 +937,10 @@ export class PrismaNotificationBackend<
    * @private
    */
   private async findAttachmentFileByChecksumInTransaction(
-    tx: NotificationPrismaClientInterface<Config['NotificationIdType'], Config['UserIdType']>,
+    tx: NotificationPrismaTransactionClientInterface<
+      Config['NotificationIdType'],
+      Config['UserIdType']
+    >,
     checksum: string,
   ): Promise<AttachmentFileRecord | null> {
     const file = await tx.attachmentFile.findUnique({
@@ -1613,7 +1651,10 @@ export class PrismaNotificationBackend<
    * @private
    */
   private async processAndStoreAttachmentsInTransaction(
-    tx: NotificationPrismaClientInterface<Config['NotificationIdType'], Config['UserIdType']>,
+    tx: NotificationPrismaTransactionClientInterface<
+      Config['NotificationIdType'],
+      Config['UserIdType']
+    >,
     notificationId: Config['NotificationIdType'],
     attachments: NotificationAttachment[],
   ): Promise<void> {