Function processRequestAsync

worker/model-worker.ts:107–170

()

}

async function processRequestAsync(): Promise<void> {
  let requestFile = '';
  let responseFile = '';
  let requestId = 'unknown';
  
  try {
    const requestFileLen = view[1];
    if (requestFileLen <= 0 || requestFileLen > FILENAME_MAX_LENGTH) {
      log('error', `[Worker] Invalid request filename length: ${requestFileLen}`);
      finishProcessing('', 'unknown', false, undefined, 'Invalid request filename length');
      return;
    }
    
    requestFile = decoder.decode(
      dataBuffer.slice(REQUEST_FILENAME_DATA_OFFSET, REQUEST_FILENAME_DATA_OFFSET + requestFileLen)
    );
    const requestFilePath = join(tmpDir, requestFile);
    
    const responseFileLen = view[RESPONSE_FILENAME_LENGTH_INDEX];
    if (responseFileLen <= 0 || responseFileLen > FILENAME_MAX_LENGTH) {
      log('error', `[Worker] Invalid response filename length: ${responseFileLen}`);
      finishProcessing('', 'unknown', false, undefined, 'Invalid response filename length');
      return;
    }
    
    responseFile = decoder.decode(
      dataBuffer.slice(RESPONSE_FILENAME_DATA_OFFSET, RESPONSE_FILENAME_DATA_OFFSET + responseFileLen)
    );
    
    const requestJson = decrypt(new Uint8Array(readFileSync(requestFilePath)), aesKey);
    const request = JSON.parse(requestJson);
    requestId = request.requestId;
    
    let result: any;
    
    if (request.type === 'llm') {
      const llmResponse = await callLLM(request.data as syncLLMRequest<Api>);
      if (llmResponse) {
        result = llmResponse;
      } else {
        throw new Error('LLM call returned null');
      }
    } else if (request.type === 'add') {
      const { a, b } = request.data as { a: number; b: number };
      result = {
        calculation: `${a} + ${b}`,
        sum: a + b,
        processedAt: Date.now(),
      };
    } else {
      result = {
        message: 'Unknown operation',
        type: request.type,
        processedAt: Date.now(),
      };
    }
    
    finishProcessing(responseFile, requestId, true, result);