Rename IndexNotFound to IndexNotFoundException (#488)

Renames `IndexNotFound` to `IndexNotFoundException` across the codebase
to align with naming conventions.

Related to #487

Author: kbeaugrand

extensions/AzureAISearch/AzureAISearch/AzureAISearchMemory.cs

@@ -150,7 +150,7 @@ await client.IndexDocumentsAsync(
         }
         catch (RequestFailedException e) when (IsIndexNotFoundException(e))
         {
-            throw new IndexNotFound(e.Message, e);
+            throw new IndexNotFoundException(e.Message, e);
         }
 
         foreach (var record in records)

extensions/Postgres/Postgres/Internals/PostgresDbClient.cs

@@ -365,7 +365,7 @@ DO UPDATE SET
         }
         catch (Npgsql.PostgresException e) when (IsTableNotFoundException(e))
         {
-            throw new IndexNotFound(e.Message, e);
+            throw new IndexNotFoundException(e.Message, e);
         }
         catch (Exception e)
         {

extensions/Qdrant/Qdrant/Internals/QdrantClient.cs

@@ -431,7 +431,7 @@ private void ValidateResponse(HttpResponseMessage response, string content, stri
             if (response.StatusCode == HttpStatusCode.NotFound && responseContent.Contains("Not found: Collection", StringComparison.OrdinalIgnoreCase))
             {
                 this._log.LogWarning("Qdrant collection not found: {0}, {1}", response.StatusCode, responseContent);
-                throw new IndexNotFound(responseContent);
+                throw new IndexNotFoundException(responseContent);
             }
 
             if (!responseContent.Contains("already exists", StringComparison.OrdinalIgnoreCase))

extensions/Qdrant/Qdrant/QdrantMemory.cs

@@ -78,7 +78,7 @@ public Task DeleteIndexAsync(
             index = NormalizeIndexName(index);
             return this._qdrantClient.DeleteCollectionAsync(index, cancellationToken);
         }
-        catch (IndexNotFound)
+        catch (IndexNotFoundException)
         {
             this._log.LogInformation("Index not found, nothing to delete");
         }
@@ -163,7 +163,7 @@ public async Task<string> UpsertAsync(
                 withVectors: withEmbeddings,
                 cancellationToken: cancellationToken).ConfigureAwait(false);
         }
-        catch (IndexNotFound e)
+        catch (IndexNotFoundException e)
         {
             this._log.LogWarning(e, "Index not found");
             // Nothing to return
@@ -207,7 +207,7 @@ public async IAsyncEnumerable<MemoryRecord> GetListAsync(
                 withVectors: withEmbeddings,
                 cancellationToken: cancellationToken).ConfigureAwait(false);
         }
-        catch (IndexNotFound e)
+        catch (IndexNotFoundException e)
         {
             this._log.LogWarning(e, "Index not found");
             // Nothing to return
@@ -242,7 +242,7 @@ public async Task DeleteAsync(
             this._log.LogTrace("Point ID {0} found, deleting...", existingPoint.Id);
             await this._qdrantClient.DeleteVectorsAsync(index, new List<Guid> { existingPoint.Id }, cancellationToken).ConfigureAwait(false);
         }
-        catch (IndexNotFound e)
+        catch (IndexNotFoundException e)
         {
             this._log.LogInformation(e, "Index not found, nothing to delete");
         }

service/Abstractions/MemoryStorage/IMemoryDb.cs

@@ -45,7 +45,7 @@ Task DeleteIndexAsync(
     /// <param name="record">Vector + payload to save</param>
     /// <param name="cancellationToken">Task cancellation token</param>
     /// <returns>Record ID</returns>
-    /// <exception cref="IndexNotFound">Error returned if the index where to write doesn't exist</exception>
+    /// <exception cref="IndexNotFoundException">Error returned if the index where to write doesn't exist</exception>
     Task<string> UpsertAsync(
         string index,
         MemoryRecord record,

service/Abstractions/MemoryStorage/IMemoryDbBatchUpsert.cs

@@ -19,7 +19,7 @@ public interface IMemoryDbBatchUpsert
     /// <param name="records">Vectors + payload to save</param>
     /// <param name="cancellationToken">Task cancellation token</param>
     /// <returns>Record IDs</returns>
-    /// <exception cref="IndexNotFound">Error returned if the index where to write doesn't exist</exception>
+    /// <exception cref="IndexNotFoundException">Error returned if the index where to write doesn't exist</exception>
     IAsyncEnumerable<string> BatchUpsertAsync(
         string index,
         IEnumerable<MemoryRecord> records,

service/Abstractions/MemoryStorage/IndexNotFound.cs

@@ -0,0 +1,17 @@
+// Copyright (c) Microsoft. All rights reserved.
+
+using System;
+
+namespace Microsoft.KernelMemory.MemoryStorage;
+
+public class IndexNotFoundException : KernelMemoryException
+{
+    /// <inheritdoc />
+    public IndexNotFoundException() { }
+
+    /// <inheritdoc />
+    public IndexNotFoundException(string message) : base(message) { }
+
+    /// <inheritdoc />
+    public IndexNotFoundException(string message, Exception? innerException) : base(message, innerException) { }
+}

service/Abstractions/MemoryStorage/IndexNotFoundException.cs

@@ -265,7 +265,7 @@ private async Task SaveRecordAsync(DataPipeline pipeline, IMemoryDb db, MemoryRe
             this._log.LogTrace("Saving record {0} in index '{1}'", record.Id, pipeline.Index);
             await db.UpsertAsync(pipeline.Index, record, cancellationToken).ConfigureAwait(false);
         }
-        catch (IndexNotFound e)
+        catch (IndexNotFoundException e)
         {
             this._log.LogWarning(e, "Index {0} not found, attempting to create it", pipeline.Index);
             await this.CreateIndexOnceAsync(db, createdIndexes, pipeline.Index, record.Vector.Length, cancellationToken, true).ConfigureAwait(false);
@@ -284,7 +284,7 @@ private async Task SaveRecordsBatchAsync(DataPipeline pipeline, IMemoryDb db, Li
             this._log.LogTrace("Saving batch of {0} records in index '{1}'", records.Count, pipeline.Index);
             await dbBatch.BatchUpsertAsync(pipeline.Index, records, cancellationToken).ToListAsync(cancellationToken).ConfigureAwait(false);
         }
-        catch (IndexNotFound e)
+        catch (IndexNotFoundException e)
         {
             this._log.LogWarning(e, "Index {0} not found, attempting to create it", pipeline.Index);
             await this.CreateIndexOnceAsync(db, createdIndexes, pipeline.Index, records[0].Vector.Length, cancellationToken, true).ConfigureAwait(false);