Function waitForDocumentEngine

src/index.ts:40–82

* Polls the Document Engine API until it's ready * @returns Promise that resolves with the client when ready

()

 */
async function waitForDocumentEngine(): Promise<DocumentEngineClient> {
  const env = getEnvironment();
  const maxRetries = env.DOCUMENT_ENGINE_POLL_MAX_RETRIES;
  const retryDelay = env.DOCUMENT_ENGINE_POLL_RETRY_DELAY;
  let attempts = 0;

  while (attempts < maxRetries) {
    try {
      logger.info(
        null,
        `Attempting to connect to Document Engine (attempt ${attempts + 1}/${maxRetries})`
      );
      const client = await getDocumentEngineClient();

      // Test the connection with a health check
      await client.get('/healthcheck');

      logger.info(null, 'Document Engine is ready! Connection established successfully.');
      return client;
    } catch (error) {
      attempts++;
      const errorMessage = error instanceof Error ? error.message : String(error);

      if (attempts >= maxRetries) {
        logger.error(
          null,
          `Failed to connect to Document Engine after ${maxRetries} attempts. Last error: ${errorMessage}`
        );
        throw new Error(
          `Document Engine connection failed after ${maxRetries} attempts: ${errorMessage}`
        );
      }

      logger.warning(
        null,
        `Document Engine not ready yet (attempt ${attempts}/${maxRetries}): ${errorMessage}. Retrying in ${retryDelay}ms...`
      );
      await new Promise(resolve => setTimeout(resolve, retryDelay));
    }
  }

  throw new Error('Unexpected error in waitForDocumentEngine');
}

const client = await waitForDocumentEngine();

function createMCPServer(): McpServer {