fix: increase db transactions timeout

Author: sneko

src/features/domain.ts

@@ -1,5 +1,6 @@
 import { Prisma } from '@prisma/client';
 import { parse } from 'csv-parse';
+import { minutesToMilliseconds } from 'date-fns/minutesToMilliseconds';
 import fsSync from 'fs';
 import fs from 'fs/promises';
 import https from 'https';
@@ -293,7 +294,7 @@ export async function formatDomainsIntoDatabase() {
           }
         },
         {
-          timeout: 1 * 60 * 1000, // Since dealing with a lot of data, prevent closing whereas everything is alright
+          timeout: minutesToMilliseconds(5), // Since dealing with a lot of data, prevent closing whereas everything is alright
           isolationLevel: Prisma.TransactionIsolationLevel.ReadCommitted,
         }
       );

src/features/initiative.ts

@@ -3,6 +3,8 @@ import { FunctionalUseCase, Prisma, RawDomain, RawRepository } from '@prisma/cli
 import assert from 'assert';
 import chalk from 'chalk';
 import { differenceInDays } from 'date-fns/differenceInDays';
+import { minutesToMilliseconds } from 'date-fns/minutesToMilliseconds';
+import { secondsToMilliseconds } from 'date-fns/secondsToMilliseconds';
 import { EventEmitter } from 'eventemitter3';
 import { $ } from 'execa';
 import fastFolderSize from 'fast-folder-size';
@@ -402,7 +404,7 @@ export async function inferInitiativesFromDatabase() {
       }
     },
     {
-      timeout: 1 * 60 * 1000, // Since dealing with a lot of data, prevent closing whereas everything is alright
+      timeout: minutesToMilliseconds(5), // Since dealing with a lot of data, prevent closing whereas everything is alright
       isolationLevel: Prisma.TransactionIsolationLevel.ReadCommitted,
     }
   );
@@ -883,7 +885,7 @@ export async function feedInitiativesFromDatabase() {
               });
             },
             {
-              timeout: 15 * 1000, // Since dealing with a lot of data, prevent closing whereas everything is alright
+              timeout: secondsToMilliseconds(30), // Since dealing with a lot of data, prevent closing whereas everything is alright
               isolationLevel: Prisma.TransactionIsolationLevel.ReadCommitted,
             }
           );

src/features/llm-langchain.ts

@@ -5,6 +5,7 @@ import { ChainValues } from '@langchain/core/utils/types';
 import { ChatMistralAI, MistralAIEmbeddings } from '@langchain/mistralai';
 import { InitiativeLlmDocument, Prisma, Settings, ToolLlmDocument } from '@prisma/client';
 import assert from 'assert';
+import { minutesToMilliseconds } from 'date-fns/minutesToMilliseconds';
 import fs from 'fs/promises';
 import { LLMChain } from 'langchain/chains';
 import { createStuffDocumentsChain } from 'langchain/chains/combine_documents';
@@ -151,7 +152,7 @@ export class LangchainWithLocalVectorStoreLlmManager implements LlmManager {
         return toolDocumentsToCalculate;
       },
       {
-        timeout: 1 * 60 * 1000,
+        timeout: minutesToMilliseconds(1),
         isolationLevel: Prisma.TransactionIsolationLevel.ReadCommitted,
       }
     );
@@ -265,7 +266,7 @@ export class LangchainWithLocalVectorStoreLlmManager implements LlmManager {
         return initiativeDocumentsToCalculate;
       },
       {
-        timeout: 1 * 60 * 1000,
+        timeout: minutesToMilliseconds(1),
         isolationLevel: Prisma.TransactionIsolationLevel.ReadCommitted,
       }
     );

src/features/repository.ts

@@ -1,4 +1,5 @@
 import { Prisma } from '@prisma/client';
+import { minutesToMilliseconds } from 'date-fns/minutesToMilliseconds';
 import fsSync from 'fs';
 import fs from 'fs/promises';
 import linkifyit from 'linkify-it';
@@ -317,7 +318,7 @@ export async function formatRepositoriesIntoDatabase() {
       }
     },
     {
-      timeout: 1 * 60 * 1000, // Since dealing with a lot of data, prevent closing whereas everything is alright
+      timeout: minutesToMilliseconds(5), // Since dealing with a lot of data, prevent closing whereas everything is alright
       isolationLevel: Prisma.TransactionIsolationLevel.ReadCommitted,
     }
   );

src/features/tool.ts

@@ -1,5 +1,6 @@
 import { Prisma } from '@prisma/client';
 import { parse } from 'csv-parse';
+import { minutesToMilliseconds } from 'date-fns/minutesToMilliseconds';
 import fsSync from 'fs';
 import fs from 'fs/promises';
 import path from 'path';
@@ -193,7 +194,7 @@ export async function formatToolsIntoDatabase() {
           }
         },
         {
-          timeout: 1 * 60 * 1000, // Since dealing with a lot of data, prevent closing whereas everything is alright
+          timeout: minutesToMilliseconds(2), // Since dealing with a lot of data, prevent closing whereas everything is alright
           isolationLevel: Prisma.TransactionIsolationLevel.ReadCommitted,
         }
       );