Method initialize

src/storage/lancedb.ts:46–103

* Initialize the storage provider at the given path. * @param storagePath - Directory path for LanceDB storage * @param options - Optional configuration * @param options.expectExisting - If true, throws IndexCorruptedError if table doesn't exist * @param options.expectedDimensions - If s

(
    storagePath: string,
    options?: { expectExisting?: boolean; expectedDimensions?: number }
  )

   * @param options.expectedDimensions - If set, verifies the stored vector column has this many dimensions
   */
  async initialize(
    storagePath: string,
    options?: { expectExisting?: boolean; expectedDimensions?: number }
  ): Promise<void> {
    if (this.initialized) return;

    try {
      this.storagePath = storagePath;
      await fs.mkdir(storagePath, { recursive: true });

      const lancedb = await import('@lancedb/lancedb');
      this.db = await lancedb.connect(storagePath);

      // Check if table exists and validate schema
      const tableNames = await this.db.tableNames();
      if (tableNames.includes('code_chunks')) {
        this.table = await this.db.openTable('code_chunks');

        const schema = await this.table.schema();
        const hasVectorColumn = schema.fields.some((f: { name: string }) => f.name === 'vector');

        if (!hasVectorColumn) {
          throw new IndexCorruptedError('LanceDB index corrupted: missing vector column');
        }

        // Check vector dimensions if caller specifies expected dims (e.g. switching providers)
        if (options?.expectedDimensions !== undefined) {
          const vectorField = schema.fields.find((f: { name: string }) => f.name === 'vector');
          const storedDims = (vectorField?.type as { listSize?: number } | undefined)?.listSize;
          if (storedDims !== undefined && storedDims !== options.expectedDimensions) {
            throw new IndexCorruptedError(
              `LanceDB dimension mismatch: stored=${storedDims}, expected=${options.expectedDimensions} (rebuild required)`
            );
          }
        }

        if (process.env.CODEBASE_CONTEXT_DEBUG) console.error('Opened existing LanceDB table');
      } else if (options?.expectExisting) {
        throw new IndexCorruptedError(
          `LanceDB index missing: no code_chunks table found at ${storagePath}`
        );
      } else {
        this.table = null;
      }

      this.initialized = true;
      console.error(`LanceDB initialized at: ${storagePath}`);
    } catch (error) {
      if (error instanceof IndexCorruptedError) {
        throw error;
      }
      console.error('Failed to initialize LanceDB:', error);
      // Wrap connection/open failures as corruption errors for fail-closed behavior
      throw new IndexCorruptedError(
        `LanceDB initialization failed: ${error instanceof Error ? error.message : String(error)}`
      );
    }
  }