diff --git a/src/libs/Zep/Generated/Zep.DataClient.AddData.g.cs b/src/libs/Zep/Generated/Zep.DataClient.AddData.g.cs index 27fccdd..c9923a6 100644 --- a/src/libs/Zep/Generated/Zep.DataClient.AddData.g.cs +++ b/src/libs/Zep/Generated/Zep.DataClient.AddData.g.cs @@ -513,6 +513,10 @@ partial void ProcessAddDataResponseContent( /// /// /// + /// + /// Optional document ID that groups episodes as chunks of the same document
+ /// on a graph. Parallel to thread_id for message threads. + /// /// /// graph_id is the ID of the graph to which the data will be added. If adding to the user graph, please use user_id field instead. /// @@ -534,6 +538,7 @@ partial void ProcessAddDataResponseContent( string data, global::Zep.ModelsGraphDataType type, string? createdAt = default, + string? documentId = default, string? graphId = default, object? metadata = default, string? sourceDescription = default, @@ -546,6 +551,7 @@ partial void ProcessAddDataResponseContent( { CreatedAt = createdAt, Data = data, + DocumentId = documentId, GraphId = graphId, Metadata = metadata, SourceDescription = sourceDescription, diff --git a/src/libs/Zep/Generated/Zep.DataClient.AddDataInBatchMode.g.cs b/src/libs/Zep/Generated/Zep.DataClient.AddDataInBatchMode.g.cs index 5703306..c379e59 100644 --- a/src/libs/Zep/Generated/Zep.DataClient.AddDataInBatchMode.g.cs +++ b/src/libs/Zep/Generated/Zep.DataClient.AddDataInBatchMode.g.cs @@ -514,6 +514,9 @@ partial void ProcessAddDataInBatchModeResponseContent( /// Deprecated. Use the [Batch API](/adding-batch-data) (`client.batch.*`) instead.
/// Adds data to the graph in batch mode, processing episodes concurrently. /// + /// + /// Optional document ID applied to every episode in this batch request. + /// /// /// /// graph_id is the ID of the graph to which the data will be added. If adding to the user graph, please use user_id field instead. @@ -529,6 +532,7 @@ partial void ProcessAddDataInBatchModeResponseContent( /// public async global::System.Threading.Tasks.Task> AddDataInBatchModeAsync( global::System.Collections.Generic.IList episodes, + string? documentId = default, string? graphId = default, bool? strictOntology = default, string? userId = default, @@ -537,6 +541,7 @@ partial void ProcessAddDataInBatchModeResponseContent( { var __request = new global::Zep.ApidataAddDataBatchRequest { + DocumentId = documentId, Episodes = episodes, GraphId = graphId, StrictOntology = strictOntology, diff --git a/src/libs/Zep/Generated/Zep.DocumentClient.GetEpisodesForADocument.g.cs b/src/libs/Zep/Generated/Zep.DocumentClient.GetEpisodesForADocument.g.cs new file mode 100644 index 0000000..ec5e2e5 --- /dev/null +++ b/src/libs/Zep/Generated/Zep.DocumentClient.GetEpisodesForADocument.g.cs @@ -0,0 +1,549 @@ + +#nullable enable + +namespace Zep +{ + public partial class DocumentClient + { + + + private static readonly global::Zep.EndPointSecurityRequirement s_GetEpisodesForADocumentSecurityRequirement0 = + new global::Zep.EndPointSecurityRequirement + { + Authorizations = new global::Zep.EndPointAuthorizationRequirement[] + { new global::Zep.EndPointAuthorizationRequirement + { + Type = "Http", + SchemeId = "BearerAuth", + Location = "Header", + Name = "Bearer", + FriendlyName = "Bearer", + }, + }, + }; + private static readonly global::Zep.EndPointSecurityRequirement[] s_GetEpisodesForADocumentSecurityRequirements = + new global::Zep.EndPointSecurityRequirement[] + { s_GetEpisodesForADocumentSecurityRequirement0, + }; + partial void PrepareGetEpisodesForADocumentArguments( + global::System.Net.Http.HttpClient httpClient, + ref string documentId, + ref string graphId); + partial void PrepareGetEpisodesForADocumentRequest( + global::System.Net.Http.HttpClient httpClient, + global::System.Net.Http.HttpRequestMessage httpRequestMessage, + string documentId, + string graphId); + partial void ProcessGetEpisodesForADocumentResponse( + global::System.Net.Http.HttpClient httpClient, + global::System.Net.Http.HttpResponseMessage httpResponseMessage); + + partial void ProcessGetEpisodesForADocumentResponseContent( + global::System.Net.Http.HttpClient httpClient, + global::System.Net.Http.HttpResponseMessage httpResponseMessage, + ref string content); + + /// + /// Get Episodes for a document
+ /// Returns episodes associated with a document on a graph. Documents group episodes as chunks, parallel to how threads group messages. + ///
+ /// + /// + /// Per-request overrides such as headers, query parameters, timeout, retries, and response buffering. + /// The token to cancel the operation with + /// + public async global::System.Threading.Tasks.Task GetEpisodesForADocumentAsync( + string documentId, + string graphId, + global::Zep.AutoSDKRequestOptions? requestOptions = default, + global::System.Threading.CancellationToken cancellationToken = default) + { + var __response = await GetEpisodesForADocumentAsResponseAsync( + documentId: documentId, + graphId: graphId, + requestOptions: requestOptions, + cancellationToken: cancellationToken + ).ConfigureAwait(false); + + return __response.Body; + } + /// + /// Get Episodes for a document
+ /// Returns episodes associated with a document on a graph. Documents group episodes as chunks, parallel to how threads group messages. + ///
+ /// + /// + /// Per-request overrides such as headers, query parameters, timeout, retries, and response buffering. + /// The token to cancel the operation with + /// + public async global::System.Threading.Tasks.Task> GetEpisodesForADocumentAsResponseAsync( + string documentId, + string graphId, + global::Zep.AutoSDKRequestOptions? requestOptions = default, + global::System.Threading.CancellationToken cancellationToken = default) + { + PrepareArguments( + client: HttpClient); + PrepareGetEpisodesForADocumentArguments( + httpClient: HttpClient, + documentId: ref documentId, + graphId: ref graphId); + + + var __authorizations = global::Zep.EndPointSecurityResolver.ResolveAuthorizations( + availableAuthorizations: Authorizations, + securityRequirements: s_GetEpisodesForADocumentSecurityRequirements, + operationName: "GetEpisodesForADocumentAsync"); + + using var __timeoutCancellationTokenSource = global::Zep.AutoSDKRequestOptionsSupport.CreateTimeoutCancellationTokenSource( + clientOptions: Options, + requestOptions: requestOptions, + cancellationToken: cancellationToken); + var __effectiveCancellationToken = __timeoutCancellationTokenSource?.Token ?? cancellationToken; + var __effectiveReadResponseAsString = global::Zep.AutoSDKRequestOptionsSupport.GetReadResponseAsString( + clientOptions: Options, + requestOptions: requestOptions, + fallbackValue: ReadResponseAsString); + var __maxAttempts = global::Zep.AutoSDKRequestOptionsSupport.GetMaxAttempts( + clientOptions: Options, + requestOptions: requestOptions, + supportsRetry: true); + + global::System.Net.Http.HttpRequestMessage __CreateHttpRequest() + { + + var __pathBuilder = new global::Zep.PathBuilder( + path: $"/graph/documents/{documentId}/episodes", + baseUri: HttpClient.BaseAddress); + __pathBuilder + .AddRequiredParameter("graph_id", graphId) + ; + var __path = __pathBuilder.ToString(); + __path = global::Zep.AutoSDKRequestOptionsSupport.AppendQueryParameters( + path: __path, + clientParameters: Options.QueryParameters, + requestParameters: requestOptions?.QueryParameters); + var __httpRequest = new global::System.Net.Http.HttpRequestMessage( + method: global::System.Net.Http.HttpMethod.Get, + requestUri: new global::System.Uri(__path, global::System.UriKind.RelativeOrAbsolute)); +#if NET6_0_OR_GREATER + __httpRequest.Version = global::System.Net.HttpVersion.Version11; + __httpRequest.VersionPolicy = global::System.Net.Http.HttpVersionPolicy.RequestVersionOrHigher; +#endif + + foreach (var __authorization in __authorizations) + { + if (__authorization.Type == "Http" || + __authorization.Type == "OAuth2" || + __authorization.Type == "OpenIdConnect") + { + __httpRequest.Headers.Authorization = new global::System.Net.Http.Headers.AuthenticationHeaderValue( + scheme: __authorization.Name, + parameter: __authorization.Value); + } + else if (__authorization.Type == "ApiKey" && + __authorization.Location == "Header") + { + __httpRequest.Headers.Add(__authorization.Name, __authorization.Value); + } + } + global::Zep.AutoSDKRequestOptionsSupport.ApplyHeaders( + request: __httpRequest, + clientHeaders: Options.Headers, + requestHeaders: requestOptions?.Headers); + + PrepareRequest( + client: HttpClient, + request: __httpRequest); + PrepareGetEpisodesForADocumentRequest( + httpClient: HttpClient, + httpRequestMessage: __httpRequest, + documentId: documentId!, + graphId: graphId!); + + return __httpRequest; + } + + global::System.Net.Http.HttpRequestMessage? __httpRequest = null; + global::System.Net.Http.HttpResponseMessage? __response = null; + var __attemptNumber = 0; + try + { + for (var __attempt = 1; __attempt <= __maxAttempts; __attempt++) + { + __attemptNumber = __attempt; + __httpRequest = __CreateHttpRequest(); + await global::Zep.AutoSDKRequestOptionsSupport.OnBeforeRequestAsync( + clientOptions: Options, + context: global::Zep.AutoSDKRequestOptionsSupport.CreateHookContext( + operationId: "GetEpisodesForADocument", + methodName: "GetEpisodesForADocumentAsync", + pathTemplate: "$\"/graph/documents/{documentId}/episodes\"", + httpMethod: "GET", + baseUri: BaseUri, + request: __httpRequest!, + response: null, + exception: null, + clientOptions: Options, + requestOptions: requestOptions, + attempt: __attempt, + maxAttempts: __maxAttempts, + willRetry: false, + retryDelay: null, + retryReason: global::System.String.Empty, + cancellationToken: __effectiveCancellationToken)).ConfigureAwait(false); + try + { + __response = await HttpClient.SendAsync( + request: __httpRequest, + completionOption: global::System.Net.Http.HttpCompletionOption.ResponseContentRead, + cancellationToken: __effectiveCancellationToken).ConfigureAwait(false); + } + catch (global::System.Net.Http.HttpRequestException __exception) + { + var __retryDelay = global::Zep.AutoSDKRequestOptionsSupport.GetRetryDelay( + clientOptions: Options, + requestOptions: requestOptions, + response: null, + attempt: __attempt); + var __willRetry = __attempt < __maxAttempts && !__effectiveCancellationToken.IsCancellationRequested; + await global::Zep.AutoSDKRequestOptionsSupport.OnAfterErrorAsync( + clientOptions: Options, + context: global::Zep.AutoSDKRequestOptionsSupport.CreateHookContext( + operationId: "GetEpisodesForADocument", + methodName: "GetEpisodesForADocumentAsync", + pathTemplate: "$\"/graph/documents/{documentId}/episodes\"", + httpMethod: "GET", + baseUri: BaseUri, + request: __httpRequest!, + response: null, + exception: __exception, + clientOptions: Options, + requestOptions: requestOptions, + attempt: __attempt, + maxAttempts: __maxAttempts, + willRetry: __willRetry, + retryDelay: __willRetry ? __retryDelay : (global::System.TimeSpan?)null, + retryReason: "exception", + cancellationToken: __effectiveCancellationToken)).ConfigureAwait(false); + if (!__willRetry) + { + throw; + } + + __httpRequest.Dispose(); + __httpRequest = null; + await global::Zep.AutoSDKRequestOptionsSupport.DelayBeforeRetryAsync( + retryDelay: __retryDelay, + cancellationToken: __effectiveCancellationToken).ConfigureAwait(false); + continue; + } + + if (__response != null && + __attempt < __maxAttempts && + global::Zep.AutoSDKRequestOptionsSupport.ShouldRetryStatusCode(__response.StatusCode)) + { + var __retryDelay = global::Zep.AutoSDKRequestOptionsSupport.GetRetryDelay( + clientOptions: Options, + requestOptions: requestOptions, + response: __response, + attempt: __attempt); + await global::Zep.AutoSDKRequestOptionsSupport.OnAfterErrorAsync( + clientOptions: Options, + context: global::Zep.AutoSDKRequestOptionsSupport.CreateHookContext( + operationId: "GetEpisodesForADocument", + methodName: "GetEpisodesForADocumentAsync", + pathTemplate: "$\"/graph/documents/{documentId}/episodes\"", + httpMethod: "GET", + baseUri: BaseUri, + request: __httpRequest!, + response: __response, + exception: null, + clientOptions: Options, + requestOptions: requestOptions, + attempt: __attempt, + maxAttempts: __maxAttempts, + willRetry: true, + retryDelay: __retryDelay, + retryReason: "status:" + ((int)__response.StatusCode).ToString(global::System.Globalization.CultureInfo.InvariantCulture), + cancellationToken: __effectiveCancellationToken)).ConfigureAwait(false); + __response.Dispose(); + __response = null; + __httpRequest.Dispose(); + __httpRequest = null; + await global::Zep.AutoSDKRequestOptionsSupport.DelayBeforeRetryAsync( + retryDelay: __retryDelay, + cancellationToken: __effectiveCancellationToken).ConfigureAwait(false); + continue; + } + + break; + } + + if (__response == null) + { + throw new global::System.InvalidOperationException("No response received."); + } + + using (__response) + { + + ProcessResponse( + client: HttpClient, + response: __response); + ProcessGetEpisodesForADocumentResponse( + httpClient: HttpClient, + httpResponseMessage: __response); + if (__response.IsSuccessStatusCode) + { + await global::Zep.AutoSDKRequestOptionsSupport.OnAfterSuccessAsync( + clientOptions: Options, + context: global::Zep.AutoSDKRequestOptionsSupport.CreateHookContext( + operationId: "GetEpisodesForADocument", + methodName: "GetEpisodesForADocumentAsync", + pathTemplate: "$\"/graph/documents/{documentId}/episodes\"", + httpMethod: "GET", + baseUri: BaseUri, + request: __httpRequest!, + response: __response, + exception: null, + clientOptions: Options, + requestOptions: requestOptions, + attempt: __attemptNumber, + maxAttempts: __maxAttempts, + willRetry: false, + retryDelay: null, + retryReason: global::System.String.Empty, + cancellationToken: __effectiveCancellationToken)).ConfigureAwait(false); + } + else + { + await global::Zep.AutoSDKRequestOptionsSupport.OnAfterErrorAsync( + clientOptions: Options, + context: global::Zep.AutoSDKRequestOptionsSupport.CreateHookContext( + operationId: "GetEpisodesForADocument", + methodName: "GetEpisodesForADocumentAsync", + pathTemplate: "$\"/graph/documents/{documentId}/episodes\"", + httpMethod: "GET", + baseUri: BaseUri, + request: __httpRequest!, + response: __response, + exception: null, + clientOptions: Options, + requestOptions: requestOptions, + attempt: __attemptNumber, + maxAttempts: __maxAttempts, + willRetry: false, + retryDelay: null, + retryReason: global::System.String.Empty, + cancellationToken: __effectiveCancellationToken)).ConfigureAwait(false); + } + // Bad Request + if ((int)__response.StatusCode == 400) + { + string? __content_400 = null; + global::System.Exception? __exception_400 = null; + global::Zep.ApidataAPIError? __value_400 = null; + try + { + if (__effectiveReadResponseAsString) + { + __content_400 = await __response.Content.ReadAsStringAsync(__effectiveCancellationToken).ConfigureAwait(false); + __value_400 = global::Zep.ApidataAPIError.FromJson(__content_400, JsonSerializerContext); + } + else + { + __content_400 = await __response.Content.ReadAsStringAsync(__effectiveCancellationToken).ConfigureAwait(false); + + __value_400 = global::Zep.ApidataAPIError.FromJson(__content_400, JsonSerializerContext); + } + } + catch (global::System.Exception __ex) + { + __exception_400 = __ex; + } + + + throw global::Zep.ApiException.Create( + statusCode: __response.StatusCode, + message: __content_400 ?? __response.ReasonPhrase ?? string.Empty, + innerException: __exception_400, + responseBody: __content_400, + responseObject: __value_400, + responseHeaders: global::System.Linq.Enumerable.ToDictionary( + __response.Headers, + h => h.Key, + h => h.Value)); + } + // Not Found + if ((int)__response.StatusCode == 404) + { + string? __content_404 = null; + global::System.Exception? __exception_404 = null; + global::Zep.ApidataAPIError? __value_404 = null; + try + { + if (__effectiveReadResponseAsString) + { + __content_404 = await __response.Content.ReadAsStringAsync(__effectiveCancellationToken).ConfigureAwait(false); + __value_404 = global::Zep.ApidataAPIError.FromJson(__content_404, JsonSerializerContext); + } + else + { + __content_404 = await __response.Content.ReadAsStringAsync(__effectiveCancellationToken).ConfigureAwait(false); + + __value_404 = global::Zep.ApidataAPIError.FromJson(__content_404, JsonSerializerContext); + } + } + catch (global::System.Exception __ex) + { + __exception_404 = __ex; + } + + + throw global::Zep.ApiException.Create( + statusCode: __response.StatusCode, + message: __content_404 ?? __response.ReasonPhrase ?? string.Empty, + innerException: __exception_404, + responseBody: __content_404, + responseObject: __value_404, + responseHeaders: global::System.Linq.Enumerable.ToDictionary( + __response.Headers, + h => h.Key, + h => h.Value)); + } + // Internal Server Error + if ((int)__response.StatusCode == 500) + { + string? __content_500 = null; + global::System.Exception? __exception_500 = null; + global::Zep.ApidataAPIError? __value_500 = null; + try + { + if (__effectiveReadResponseAsString) + { + __content_500 = await __response.Content.ReadAsStringAsync(__effectiveCancellationToken).ConfigureAwait(false); + __value_500 = global::Zep.ApidataAPIError.FromJson(__content_500, JsonSerializerContext); + } + else + { + __content_500 = await __response.Content.ReadAsStringAsync(__effectiveCancellationToken).ConfigureAwait(false); + + __value_500 = global::Zep.ApidataAPIError.FromJson(__content_500, JsonSerializerContext); + } + } + catch (global::System.Exception __ex) + { + __exception_500 = __ex; + } + + + throw global::Zep.ApiException.Create( + statusCode: __response.StatusCode, + message: __content_500 ?? __response.ReasonPhrase ?? string.Empty, + innerException: __exception_500, + responseBody: __content_500, + responseObject: __value_500, + responseHeaders: global::System.Linq.Enumerable.ToDictionary( + __response.Headers, + h => h.Key, + h => h.Value)); + } + + if (__effectiveReadResponseAsString) + { + var __content = await __response.Content.ReadAsStringAsync( + #if NET5_0_OR_GREATER + __effectiveCancellationToken + #endif + ).ConfigureAwait(false); + + ProcessResponseContent( + client: HttpClient, + response: __response, + content: ref __content); + ProcessGetEpisodesForADocumentResponseContent( + httpClient: HttpClient, + httpResponseMessage: __response, + content: ref __content); + + try + { + __response.EnsureSuccessStatusCode(); + + var __value = global::Zep.ApidataGraphEpisodeResponse.FromJson(__content, JsonSerializerContext) ?? + throw new global::System.InvalidOperationException($"Response deserialization failed for \"{__content}\" "); + return new global::Zep.AutoSDKHttpResponse( + statusCode: __response.StatusCode, + headers: global::Zep.AutoSDKHttpResponse.CreateHeaders(__response), + requestUri: __response.RequestMessage?.RequestUri, + body: __value); + } + catch (global::System.Exception __ex) + { + throw global::Zep.ApiException.Create( + statusCode: __response.StatusCode, + message: __content ?? __response.ReasonPhrase ?? string.Empty, + innerException: __ex, + responseBody: __content, + responseHeaders: global::System.Linq.Enumerable.ToDictionary( + __response.Headers, + h => h.Key, + h => h.Value)); + } + } + else + { + try + { + __response.EnsureSuccessStatusCode(); + using var __content = await __response.Content.ReadAsStreamAsync( + #if NET5_0_OR_GREATER + __effectiveCancellationToken + #endif + ).ConfigureAwait(false); + + var __value = await global::Zep.ApidataGraphEpisodeResponse.FromJsonStreamAsync(__content, JsonSerializerContext).ConfigureAwait(false) ?? + throw new global::System.InvalidOperationException("Response deserialization failed."); + return new global::Zep.AutoSDKHttpResponse( + statusCode: __response.StatusCode, + headers: global::Zep.AutoSDKHttpResponse.CreateHeaders(__response), + requestUri: __response.RequestMessage?.RequestUri, + body: __value); + } + catch (global::System.Exception __ex) + { + string? __content = null; + try + { + __content = await __response.Content.ReadAsStringAsync( + #if NET5_0_OR_GREATER + __effectiveCancellationToken + #endif + ).ConfigureAwait(false); + } + catch (global::System.Exception) + { + } + + throw global::Zep.ApiException.Create( + statusCode: __response.StatusCode, + message: __content ?? __response.ReasonPhrase ?? string.Empty, + innerException: __ex, + responseBody: __content, + responseHeaders: global::System.Linq.Enumerable.ToDictionary( + __response.Headers, + h => h.Key, + h => h.Value)); + } + } + + } + } + finally + { + __httpRequest?.Dispose(); + } + } + } +} \ No newline at end of file diff --git a/src/libs/Zep/Generated/Zep.DocumentClient.g.cs b/src/libs/Zep/Generated/Zep.DocumentClient.g.cs new file mode 100644 index 0000000..c58c372 --- /dev/null +++ b/src/libs/Zep/Generated/Zep.DocumentClient.g.cs @@ -0,0 +1,143 @@ + +#nullable enable + +namespace Zep +{ + /// + /// If no httpClient is provided, a new one will be created.
+ /// If no baseUri is provided, the default baseUri from OpenAPI spec will be used. + ///
+ public sealed partial class DocumentClient : global::Zep.IDocumentClient, global::System.IDisposable + { + /// + /// https://api.getzep.com/api/v2 + /// + public const string DefaultBaseUrl = "https://api.getzep.com/api/v2"; + + private bool _disposeHttpClient = true; + + /// + public global::System.Net.Http.HttpClient HttpClient { get; } + + /// + public System.Uri? BaseUri => HttpClient.BaseAddress; + + /// + public global::System.Collections.Generic.List Authorizations { get; } + + /// + public bool ReadResponseAsString { get; set; } +#if DEBUG + = true; +#endif + + /// + public global::Zep.AutoSDKClientOptions Options { get; } + + internal global::System.Lazy JsonSerializerContextProvider { get; set; } = new(() => global::Zep.SourceGenerationContext.Default); + + /// + /// + /// + public global::System.Text.Json.Serialization.JsonSerializerContext JsonSerializerContext + { + get => JsonSerializerContextProvider.Value; + set => JsonSerializerContextProvider = new(() => value); + } + + + /// + /// Creates a new instance of the DocumentClient. + /// If no httpClient is provided, a new one will be created. + /// If no baseUri is provided, the default baseUri from OpenAPI spec will be used. + /// + /// The HttpClient instance. If not provided, a new one will be created. + /// The base URL for the API. If not provided, the default baseUri from OpenAPI spec will be used. + /// The authorizations to use for the requests. + /// Dispose the HttpClient when the instance is disposed. True by default. + public DocumentClient( + global::System.Net.Http.HttpClient? httpClient = null, + global::System.Uri? baseUri = null, + global::System.Collections.Generic.List? authorizations = null, + bool disposeHttpClient = true) : this( + httpClient, + baseUri, + authorizations, + options: null, + disposeHttpClient: disposeHttpClient) + { + } + + /// + /// Creates a new instance of the DocumentClient with explicit options but no base URL override. + /// Skips passing baseUri so the default base URL from the OpenAPI spec applies. + /// + /// The HttpClient instance. If not provided, a new one will be created. + /// The authorizations to use for the requests. + /// Client-wide request defaults such as headers, query parameters, retries, and timeout. + /// Dispose the HttpClient when the instance is disposed. True by default. + public DocumentClient( + global::System.Net.Http.HttpClient? httpClient, + global::System.Collections.Generic.List? authorizations, + global::Zep.AutoSDKClientOptions? options, + bool disposeHttpClient = true) : this( + httpClient, + baseUri: null, + authorizations, + options, + disposeHttpClient: disposeHttpClient) + { + } + + /// + /// Creates a new instance of the DocumentClient. + /// If no httpClient is provided, a new one will be created. + /// If no baseUri is provided, the default baseUri from OpenAPI spec will be used. + /// + /// The HttpClient instance. If not provided, a new one will be created. + /// The base URL for the API. If not provided, the default baseUri from OpenAPI spec will be used. + /// The authorizations to use for the requests. + /// Client-wide request defaults such as headers, query parameters, retries, and timeout. + /// Dispose the HttpClient when the instance is disposed. True by default. + public DocumentClient( + global::System.Net.Http.HttpClient? httpClient, + global::System.Uri? baseUri, + global::System.Collections.Generic.List? authorizations, + global::Zep.AutoSDKClientOptions? options, + bool disposeHttpClient = true) + { + + HttpClient = httpClient ?? new global::System.Net.Http.HttpClient(); + HttpClient.BaseAddress ??= baseUri ?? new global::System.Uri(DefaultBaseUrl); + Authorizations = authorizations ?? new global::System.Collections.Generic.List(); + Options = options ?? new global::Zep.AutoSDKClientOptions(); + _disposeHttpClient = disposeHttpClient; + + Initialized(HttpClient); + } + + /// + public void Dispose() + { + if (_disposeHttpClient) + { + HttpClient.Dispose(); + } + } + + partial void Initialized( + global::System.Net.Http.HttpClient client); + partial void PrepareArguments( + global::System.Net.Http.HttpClient client); + partial void PrepareRequest( + global::System.Net.Http.HttpClient client, + global::System.Net.Http.HttpRequestMessage request); + partial void ProcessResponse( + global::System.Net.Http.HttpClient client, + global::System.Net.Http.HttpResponseMessage response); + partial void ProcessResponseContent( + global::System.Net.Http.HttpClient client, + global::System.Net.Http.HttpResponseMessage response, + ref string content); + } +} \ No newline at end of file diff --git a/src/libs/Zep/Generated/Zep.DocumentSummaryClient.GetGraphDocumentSummaries.g.cs b/src/libs/Zep/Generated/Zep.DocumentSummaryClient.GetGraphDocumentSummaries.g.cs new file mode 100644 index 0000000..25289cf --- /dev/null +++ b/src/libs/Zep/Generated/Zep.DocumentSummaryClient.GetGraphDocumentSummaries.g.cs @@ -0,0 +1,612 @@ + +#nullable enable + +namespace Zep +{ + public partial class DocumentSummaryClient + { + + + private static readonly global::Zep.EndPointSecurityRequirement s_GetGraphDocumentSummariesSecurityRequirement0 = + new global::Zep.EndPointSecurityRequirement + { + Authorizations = new global::Zep.EndPointAuthorizationRequirement[] + { new global::Zep.EndPointAuthorizationRequirement + { + Type = "Http", + SchemeId = "BearerAuth", + Location = "Header", + Name = "Bearer", + FriendlyName = "Bearer", + }, + }, + }; + private static readonly global::Zep.EndPointSecurityRequirement[] s_GetGraphDocumentSummariesSecurityRequirements = + new global::Zep.EndPointSecurityRequirement[] + { s_GetGraphDocumentSummariesSecurityRequirement0, + }; + partial void PrepareGetGraphDocumentSummariesArguments( + global::System.Net.Http.HttpClient httpClient, + ref string graphId, + global::Zep.ApidataGraphDocumentSummariesRequest request); + partial void PrepareGetGraphDocumentSummariesRequest( + global::System.Net.Http.HttpClient httpClient, + global::System.Net.Http.HttpRequestMessage httpRequestMessage, + string graphId, + global::Zep.ApidataGraphDocumentSummariesRequest request); + partial void ProcessGetGraphDocumentSummariesResponse( + global::System.Net.Http.HttpClient httpClient, + global::System.Net.Http.HttpResponseMessage httpResponseMessage); + + partial void ProcessGetGraphDocumentSummariesResponseContent( + global::System.Net.Http.HttpClient httpClient, + global::System.Net.Http.HttpResponseMessage httpResponseMessage, + ref string content); + + /// + /// Get Graph Document Summaries
+ /// Returns incremental document summaries associated with the graph. Document summaries are derived similarly to thread summaries. + ///
+ /// + /// + /// Per-request overrides such as headers, query parameters, timeout, retries, and response buffering. + /// The token to cancel the operation with + /// + public async global::System.Threading.Tasks.Task> GetGraphDocumentSummariesAsync( + string graphId, + + global::Zep.ApidataGraphDocumentSummariesRequest request, + global::Zep.AutoSDKRequestOptions? requestOptions = default, + global::System.Threading.CancellationToken cancellationToken = default) + { + var __response = await GetGraphDocumentSummariesAsResponseAsync( + graphId: graphId, + + request: request, + requestOptions: requestOptions, + cancellationToken: cancellationToken + ).ConfigureAwait(false); + + return __response.Body; + } + /// + /// Get Graph Document Summaries
+ /// Returns incremental document summaries associated with the graph. Document summaries are derived similarly to thread summaries. + ///
+ /// + /// + /// Per-request overrides such as headers, query parameters, timeout, retries, and response buffering. + /// The token to cancel the operation with + /// + public async global::System.Threading.Tasks.Task>> GetGraphDocumentSummariesAsResponseAsync( + string graphId, + + global::Zep.ApidataGraphDocumentSummariesRequest request, + global::Zep.AutoSDKRequestOptions? requestOptions = default, + global::System.Threading.CancellationToken cancellationToken = default) + { + request = request ?? throw new global::System.ArgumentNullException(nameof(request)); + + PrepareArguments( + client: HttpClient); + PrepareGetGraphDocumentSummariesArguments( + httpClient: HttpClient, + graphId: ref graphId, + request: request); + + + var __authorizations = global::Zep.EndPointSecurityResolver.ResolveAuthorizations( + availableAuthorizations: Authorizations, + securityRequirements: s_GetGraphDocumentSummariesSecurityRequirements, + operationName: "GetGraphDocumentSummariesAsync"); + + using var __timeoutCancellationTokenSource = global::Zep.AutoSDKRequestOptionsSupport.CreateTimeoutCancellationTokenSource( + clientOptions: Options, + requestOptions: requestOptions, + cancellationToken: cancellationToken); + var __effectiveCancellationToken = __timeoutCancellationTokenSource?.Token ?? cancellationToken; + var __effectiveReadResponseAsString = global::Zep.AutoSDKRequestOptionsSupport.GetReadResponseAsString( + clientOptions: Options, + requestOptions: requestOptions, + fallbackValue: ReadResponseAsString); + var __maxAttempts = global::Zep.AutoSDKRequestOptionsSupport.GetMaxAttempts( + clientOptions: Options, + requestOptions: requestOptions, + supportsRetry: true); + + global::System.Net.Http.HttpRequestMessage __CreateHttpRequest() + { + + var __pathBuilder = new global::Zep.PathBuilder( + path: $"/graph/document-summary/graph/{graphId}", + baseUri: HttpClient.BaseAddress); + var __path = __pathBuilder.ToString(); + __path = global::Zep.AutoSDKRequestOptionsSupport.AppendQueryParameters( + path: __path, + clientParameters: Options.QueryParameters, + requestParameters: requestOptions?.QueryParameters); + var __httpRequest = new global::System.Net.Http.HttpRequestMessage( + method: global::System.Net.Http.HttpMethod.Post, + requestUri: new global::System.Uri(__path, global::System.UriKind.RelativeOrAbsolute)); +#if NET6_0_OR_GREATER + __httpRequest.Version = global::System.Net.HttpVersion.Version11; + __httpRequest.VersionPolicy = global::System.Net.Http.HttpVersionPolicy.RequestVersionOrHigher; +#endif + + foreach (var __authorization in __authorizations) + { + if (__authorization.Type == "Http" || + __authorization.Type == "OAuth2" || + __authorization.Type == "OpenIdConnect") + { + __httpRequest.Headers.Authorization = new global::System.Net.Http.Headers.AuthenticationHeaderValue( + scheme: __authorization.Name, + parameter: __authorization.Value); + } + else if (__authorization.Type == "ApiKey" && + __authorization.Location == "Header") + { + __httpRequest.Headers.Add(__authorization.Name, __authorization.Value); + } + } + var __httpRequestContentBody = request.ToJson(JsonSerializerContext); + var __httpRequestContent = new global::System.Net.Http.StringContent( + content: __httpRequestContentBody, + encoding: global::System.Text.Encoding.UTF8, + mediaType: "application/json"); + __httpRequest.Content = __httpRequestContent; + global::Zep.AutoSDKRequestOptionsSupport.ApplyHeaders( + request: __httpRequest, + clientHeaders: Options.Headers, + requestHeaders: requestOptions?.Headers); + + PrepareRequest( + client: HttpClient, + request: __httpRequest); + PrepareGetGraphDocumentSummariesRequest( + httpClient: HttpClient, + httpRequestMessage: __httpRequest, + graphId: graphId!, + request: request); + + return __httpRequest; + } + + global::System.Net.Http.HttpRequestMessage? __httpRequest = null; + global::System.Net.Http.HttpResponseMessage? __response = null; + var __attemptNumber = 0; + try + { + for (var __attempt = 1; __attempt <= __maxAttempts; __attempt++) + { + __attemptNumber = __attempt; + __httpRequest = __CreateHttpRequest(); + await global::Zep.AutoSDKRequestOptionsSupport.OnBeforeRequestAsync( + clientOptions: Options, + context: global::Zep.AutoSDKRequestOptionsSupport.CreateHookContext( + operationId: "GetGraphDocumentSummaries", + methodName: "GetGraphDocumentSummariesAsync", + pathTemplate: "$\"/graph/document-summary/graph/{graphId}\"", + httpMethod: "POST", + baseUri: BaseUri, + request: __httpRequest!, + response: null, + exception: null, + clientOptions: Options, + requestOptions: requestOptions, + attempt: __attempt, + maxAttempts: __maxAttempts, + willRetry: false, + retryDelay: null, + retryReason: global::System.String.Empty, + cancellationToken: __effectiveCancellationToken)).ConfigureAwait(false); + try + { + __response = await HttpClient.SendAsync( + request: __httpRequest, + completionOption: global::System.Net.Http.HttpCompletionOption.ResponseContentRead, + cancellationToken: __effectiveCancellationToken).ConfigureAwait(false); + } + catch (global::System.Net.Http.HttpRequestException __exception) + { + var __retryDelay = global::Zep.AutoSDKRequestOptionsSupport.GetRetryDelay( + clientOptions: Options, + requestOptions: requestOptions, + response: null, + attempt: __attempt); + var __willRetry = __attempt < __maxAttempts && !__effectiveCancellationToken.IsCancellationRequested; + await global::Zep.AutoSDKRequestOptionsSupport.OnAfterErrorAsync( + clientOptions: Options, + context: global::Zep.AutoSDKRequestOptionsSupport.CreateHookContext( + operationId: "GetGraphDocumentSummaries", + methodName: "GetGraphDocumentSummariesAsync", + pathTemplate: "$\"/graph/document-summary/graph/{graphId}\"", + httpMethod: "POST", + baseUri: BaseUri, + request: __httpRequest!, + response: null, + exception: __exception, + clientOptions: Options, + requestOptions: requestOptions, + attempt: __attempt, + maxAttempts: __maxAttempts, + willRetry: __willRetry, + retryDelay: __willRetry ? __retryDelay : (global::System.TimeSpan?)null, + retryReason: "exception", + cancellationToken: __effectiveCancellationToken)).ConfigureAwait(false); + if (!__willRetry) + { + throw; + } + + __httpRequest.Dispose(); + __httpRequest = null; + await global::Zep.AutoSDKRequestOptionsSupport.DelayBeforeRetryAsync( + retryDelay: __retryDelay, + cancellationToken: __effectiveCancellationToken).ConfigureAwait(false); + continue; + } + + if (__response != null && + __attempt < __maxAttempts && + global::Zep.AutoSDKRequestOptionsSupport.ShouldRetryStatusCode(__response.StatusCode)) + { + var __retryDelay = global::Zep.AutoSDKRequestOptionsSupport.GetRetryDelay( + clientOptions: Options, + requestOptions: requestOptions, + response: __response, + attempt: __attempt); + await global::Zep.AutoSDKRequestOptionsSupport.OnAfterErrorAsync( + clientOptions: Options, + context: global::Zep.AutoSDKRequestOptionsSupport.CreateHookContext( + operationId: "GetGraphDocumentSummaries", + methodName: "GetGraphDocumentSummariesAsync", + pathTemplate: "$\"/graph/document-summary/graph/{graphId}\"", + httpMethod: "POST", + baseUri: BaseUri, + request: __httpRequest!, + response: __response, + exception: null, + clientOptions: Options, + requestOptions: requestOptions, + attempt: __attempt, + maxAttempts: __maxAttempts, + willRetry: true, + retryDelay: __retryDelay, + retryReason: "status:" + ((int)__response.StatusCode).ToString(global::System.Globalization.CultureInfo.InvariantCulture), + cancellationToken: __effectiveCancellationToken)).ConfigureAwait(false); + __response.Dispose(); + __response = null; + __httpRequest.Dispose(); + __httpRequest = null; + await global::Zep.AutoSDKRequestOptionsSupport.DelayBeforeRetryAsync( + retryDelay: __retryDelay, + cancellationToken: __effectiveCancellationToken).ConfigureAwait(false); + continue; + } + + break; + } + + if (__response == null) + { + throw new global::System.InvalidOperationException("No response received."); + } + + using (__response) + { + + ProcessResponse( + client: HttpClient, + response: __response); + ProcessGetGraphDocumentSummariesResponse( + httpClient: HttpClient, + httpResponseMessage: __response); + if (__response.IsSuccessStatusCode) + { + await global::Zep.AutoSDKRequestOptionsSupport.OnAfterSuccessAsync( + clientOptions: Options, + context: global::Zep.AutoSDKRequestOptionsSupport.CreateHookContext( + operationId: "GetGraphDocumentSummaries", + methodName: "GetGraphDocumentSummariesAsync", + pathTemplate: "$\"/graph/document-summary/graph/{graphId}\"", + httpMethod: "POST", + baseUri: BaseUri, + request: __httpRequest!, + response: __response, + exception: null, + clientOptions: Options, + requestOptions: requestOptions, + attempt: __attemptNumber, + maxAttempts: __maxAttempts, + willRetry: false, + retryDelay: null, + retryReason: global::System.String.Empty, + cancellationToken: __effectiveCancellationToken)).ConfigureAwait(false); + } + else + { + await global::Zep.AutoSDKRequestOptionsSupport.OnAfterErrorAsync( + clientOptions: Options, + context: global::Zep.AutoSDKRequestOptionsSupport.CreateHookContext( + operationId: "GetGraphDocumentSummaries", + methodName: "GetGraphDocumentSummariesAsync", + pathTemplate: "$\"/graph/document-summary/graph/{graphId}\"", + httpMethod: "POST", + baseUri: BaseUri, + request: __httpRequest!, + response: __response, + exception: null, + clientOptions: Options, + requestOptions: requestOptions, + attempt: __attemptNumber, + maxAttempts: __maxAttempts, + willRetry: false, + retryDelay: null, + retryReason: global::System.String.Empty, + cancellationToken: __effectiveCancellationToken)).ConfigureAwait(false); + } + // Bad Request + if ((int)__response.StatusCode == 400) + { + string? __content_400 = null; + global::System.Exception? __exception_400 = null; + global::Zep.ApidataAPIError? __value_400 = null; + try + { + if (__effectiveReadResponseAsString) + { + __content_400 = await __response.Content.ReadAsStringAsync(__effectiveCancellationToken).ConfigureAwait(false); + __value_400 = global::Zep.ApidataAPIError.FromJson(__content_400, JsonSerializerContext); + } + else + { + __content_400 = await __response.Content.ReadAsStringAsync(__effectiveCancellationToken).ConfigureAwait(false); + + __value_400 = global::Zep.ApidataAPIError.FromJson(__content_400, JsonSerializerContext); + } + } + catch (global::System.Exception __ex) + { + __exception_400 = __ex; + } + + + throw global::Zep.ApiException.Create( + statusCode: __response.StatusCode, + message: __content_400 ?? __response.ReasonPhrase ?? string.Empty, + innerException: __exception_400, + responseBody: __content_400, + responseObject: __value_400, + responseHeaders: global::System.Linq.Enumerable.ToDictionary( + __response.Headers, + h => h.Key, + h => h.Value)); + } + // Not Found + if ((int)__response.StatusCode == 404) + { + string? __content_404 = null; + global::System.Exception? __exception_404 = null; + global::Zep.ApidataAPIError? __value_404 = null; + try + { + if (__effectiveReadResponseAsString) + { + __content_404 = await __response.Content.ReadAsStringAsync(__effectiveCancellationToken).ConfigureAwait(false); + __value_404 = global::Zep.ApidataAPIError.FromJson(__content_404, JsonSerializerContext); + } + else + { + __content_404 = await __response.Content.ReadAsStringAsync(__effectiveCancellationToken).ConfigureAwait(false); + + __value_404 = global::Zep.ApidataAPIError.FromJson(__content_404, JsonSerializerContext); + } + } + catch (global::System.Exception __ex) + { + __exception_404 = __ex; + } + + + throw global::Zep.ApiException.Create( + statusCode: __response.StatusCode, + message: __content_404 ?? __response.ReasonPhrase ?? string.Empty, + innerException: __exception_404, + responseBody: __content_404, + responseObject: __value_404, + responseHeaders: global::System.Linq.Enumerable.ToDictionary( + __response.Headers, + h => h.Key, + h => h.Value)); + } + // Internal Server Error + if ((int)__response.StatusCode == 500) + { + string? __content_500 = null; + global::System.Exception? __exception_500 = null; + global::Zep.ApidataAPIError? __value_500 = null; + try + { + if (__effectiveReadResponseAsString) + { + __content_500 = await __response.Content.ReadAsStringAsync(__effectiveCancellationToken).ConfigureAwait(false); + __value_500 = global::Zep.ApidataAPIError.FromJson(__content_500, JsonSerializerContext); + } + else + { + __content_500 = await __response.Content.ReadAsStringAsync(__effectiveCancellationToken).ConfigureAwait(false); + + __value_500 = global::Zep.ApidataAPIError.FromJson(__content_500, JsonSerializerContext); + } + } + catch (global::System.Exception __ex) + { + __exception_500 = __ex; + } + + + throw global::Zep.ApiException.Create( + statusCode: __response.StatusCode, + message: __content_500 ?? __response.ReasonPhrase ?? string.Empty, + innerException: __exception_500, + responseBody: __content_500, + responseObject: __value_500, + responseHeaders: global::System.Linq.Enumerable.ToDictionary( + __response.Headers, + h => h.Key, + h => h.Value)); + } + + if (__effectiveReadResponseAsString) + { + var __content = await __response.Content.ReadAsStringAsync( + #if NET5_0_OR_GREATER + __effectiveCancellationToken + #endif + ).ConfigureAwait(false); + + ProcessResponseContent( + client: HttpClient, + response: __response, + content: ref __content); + ProcessGetGraphDocumentSummariesResponseContent( + httpClient: HttpClient, + httpResponseMessage: __response, + content: ref __content); + + try + { + __response.EnsureSuccessStatusCode(); + + var __value = (global::System.Collections.Generic.IList?)global::System.Text.Json.JsonSerializer.Deserialize(__content, typeof(global::System.Collections.Generic.IList), JsonSerializerContext) ?? + throw new global::System.InvalidOperationException($"Response deserialization failed for \"{__content}\" "); + return new global::Zep.AutoSDKHttpResponse>( + statusCode: __response.StatusCode, + headers: global::Zep.AutoSDKHttpResponse.CreateHeaders(__response), + requestUri: __response.RequestMessage?.RequestUri, + body: __value); + } + catch (global::System.Exception __ex) + { + throw global::Zep.ApiException.Create( + statusCode: __response.StatusCode, + message: __content ?? __response.ReasonPhrase ?? string.Empty, + innerException: __ex, + responseBody: __content, + responseHeaders: global::System.Linq.Enumerable.ToDictionary( + __response.Headers, + h => h.Key, + h => h.Value)); + } + } + else + { + try + { + __response.EnsureSuccessStatusCode(); + using var __content = await __response.Content.ReadAsStreamAsync( + #if NET5_0_OR_GREATER + __effectiveCancellationToken + #endif + ).ConfigureAwait(false); + + var __value = (global::System.Collections.Generic.IList?)await global::System.Text.Json.JsonSerializer.DeserializeAsync(__content, typeof(global::System.Collections.Generic.IList), JsonSerializerContext).ConfigureAwait(false) ?? + throw new global::System.InvalidOperationException("Response deserialization failed."); + return new global::Zep.AutoSDKHttpResponse>( + statusCode: __response.StatusCode, + headers: global::Zep.AutoSDKHttpResponse.CreateHeaders(__response), + requestUri: __response.RequestMessage?.RequestUri, + body: __value); + } + catch (global::System.Exception __ex) + { + string? __content = null; + try + { + __content = await __response.Content.ReadAsStringAsync( + #if NET5_0_OR_GREATER + __effectiveCancellationToken + #endif + ).ConfigureAwait(false); + } + catch (global::System.Exception) + { + } + + throw global::Zep.ApiException.Create( + statusCode: __response.StatusCode, + message: __content ?? __response.ReasonPhrase ?? string.Empty, + innerException: __ex, + responseBody: __content, + responseHeaders: global::System.Linq.Enumerable.ToDictionary( + __response.Headers, + h => h.Key, + h => h.Value)); + } + } + + } + } + finally + { + __httpRequest?.Dispose(); + } + } + /// + /// Get Graph Document Summaries
+ /// Returns incremental document summaries associated with the graph. Document summaries are derived similarly to thread summaries. + ///
+ /// + /// + /// Opaque cursor for pagination, obtained from the Zep-Next-Cursor response header
+ /// of the previous page. Encodes the sort field, direction, and continuation position. + /// + /// + /// Sort direction. One of "asc" or "desc" (default "desc"). + /// + /// + /// Optional filters applied to the listed artifacts. Reuses the graph.search filter type. + /// + /// + /// Maximum number of items to return + /// + /// + /// Field to sort by. One of "created_at", "valid_at", or "uuid" (default "uuid"). + /// + /// + /// UUID based cursor, used for pagination. Should be the UUID of the last item in the previous page.
+ /// Deprecated: prefer Cursor, the opaque cursor returned via the Zep-Next-Cursor response header. + /// + /// Per-request overrides such as headers, query parameters, timeout, retries, and response buffering. + /// The token to cancel the operation with + /// + public async global::System.Threading.Tasks.Task> GetGraphDocumentSummariesAsync( + string graphId, + string? cursor = default, + string? direction = default, + global::Zep.GraphitiSearchFilters? filters = default, + int? limit = default, + string? orderBy = default, + string? uuidCursor = default, + global::Zep.AutoSDKRequestOptions? requestOptions = default, + global::System.Threading.CancellationToken cancellationToken = default) + { + var __request = new global::Zep.ApidataGraphDocumentSummariesRequest + { + Cursor = cursor, + Direction = direction, + Filters = filters, + Limit = limit, + OrderBy = orderBy, + UuidCursor = uuidCursor, + }; + + return await GetGraphDocumentSummariesAsync( + graphId: graphId, + request: __request, + requestOptions: requestOptions, + cancellationToken: cancellationToken).ConfigureAwait(false); + } + } +} \ No newline at end of file diff --git a/src/libs/Zep/Generated/Zep.DocumentSummaryClient.g.cs b/src/libs/Zep/Generated/Zep.DocumentSummaryClient.g.cs new file mode 100644 index 0000000..04280af --- /dev/null +++ b/src/libs/Zep/Generated/Zep.DocumentSummaryClient.g.cs @@ -0,0 +1,143 @@ + +#nullable enable + +namespace Zep +{ + /// + /// If no httpClient is provided, a new one will be created.
+ /// If no baseUri is provided, the default baseUri from OpenAPI spec will be used. + ///
+ public sealed partial class DocumentSummaryClient : global::Zep.IDocumentSummaryClient, global::System.IDisposable + { + /// + /// https://api.getzep.com/api/v2 + /// + public const string DefaultBaseUrl = "https://api.getzep.com/api/v2"; + + private bool _disposeHttpClient = true; + + /// + public global::System.Net.Http.HttpClient HttpClient { get; } + + /// + public System.Uri? BaseUri => HttpClient.BaseAddress; + + /// + public global::System.Collections.Generic.List Authorizations { get; } + + /// + public bool ReadResponseAsString { get; set; } +#if DEBUG + = true; +#endif + + /// + public global::Zep.AutoSDKClientOptions Options { get; } + + internal global::System.Lazy JsonSerializerContextProvider { get; set; } = new(() => global::Zep.SourceGenerationContext.Default); + + /// + /// + /// + public global::System.Text.Json.Serialization.JsonSerializerContext JsonSerializerContext + { + get => JsonSerializerContextProvider.Value; + set => JsonSerializerContextProvider = new(() => value); + } + + + /// + /// Creates a new instance of the DocumentSummaryClient. + /// If no httpClient is provided, a new one will be created. + /// If no baseUri is provided, the default baseUri from OpenAPI spec will be used. + /// + /// The HttpClient instance. If not provided, a new one will be created. + /// The base URL for the API. If not provided, the default baseUri from OpenAPI spec will be used. + /// The authorizations to use for the requests. + /// Dispose the HttpClient when the instance is disposed. True by default. + public DocumentSummaryClient( + global::System.Net.Http.HttpClient? httpClient = null, + global::System.Uri? baseUri = null, + global::System.Collections.Generic.List? authorizations = null, + bool disposeHttpClient = true) : this( + httpClient, + baseUri, + authorizations, + options: null, + disposeHttpClient: disposeHttpClient) + { + } + + /// + /// Creates a new instance of the DocumentSummaryClient with explicit options but no base URL override. + /// Skips passing baseUri so the default base URL from the OpenAPI spec applies. + /// + /// The HttpClient instance. If not provided, a new one will be created. + /// The authorizations to use for the requests. + /// Client-wide request defaults such as headers, query parameters, retries, and timeout. + /// Dispose the HttpClient when the instance is disposed. True by default. + public DocumentSummaryClient( + global::System.Net.Http.HttpClient? httpClient, + global::System.Collections.Generic.List? authorizations, + global::Zep.AutoSDKClientOptions? options, + bool disposeHttpClient = true) : this( + httpClient, + baseUri: null, + authorizations, + options, + disposeHttpClient: disposeHttpClient) + { + } + + /// + /// Creates a new instance of the DocumentSummaryClient. + /// If no httpClient is provided, a new one will be created. + /// If no baseUri is provided, the default baseUri from OpenAPI spec will be used. + /// + /// The HttpClient instance. If not provided, a new one will be created. + /// The base URL for the API. If not provided, the default baseUri from OpenAPI spec will be used. + /// The authorizations to use for the requests. + /// Client-wide request defaults such as headers, query parameters, retries, and timeout. + /// Dispose the HttpClient when the instance is disposed. True by default. + public DocumentSummaryClient( + global::System.Net.Http.HttpClient? httpClient, + global::System.Uri? baseUri, + global::System.Collections.Generic.List? authorizations, + global::Zep.AutoSDKClientOptions? options, + bool disposeHttpClient = true) + { + + HttpClient = httpClient ?? new global::System.Net.Http.HttpClient(); + HttpClient.BaseAddress ??= baseUri ?? new global::System.Uri(DefaultBaseUrl); + Authorizations = authorizations ?? new global::System.Collections.Generic.List(); + Options = options ?? new global::Zep.AutoSDKClientOptions(); + _disposeHttpClient = disposeHttpClient; + + Initialized(HttpClient); + } + + /// + public void Dispose() + { + if (_disposeHttpClient) + { + HttpClient.Dispose(); + } + } + + partial void Initialized( + global::System.Net.Http.HttpClient client); + partial void PrepareArguments( + global::System.Net.Http.HttpClient client); + partial void PrepareRequest( + global::System.Net.Http.HttpClient client, + global::System.Net.Http.HttpRequestMessage request); + partial void ProcessResponse( + global::System.Net.Http.HttpClient client, + global::System.Net.Http.HttpResponseMessage response); + partial void ProcessResponseContent( + global::System.Net.Http.HttpClient client, + global::System.Net.Http.HttpResponseMessage response, + ref string content); + } +} \ No newline at end of file diff --git a/src/libs/Zep/Generated/Zep.IDataClient.AddData.g.cs b/src/libs/Zep/Generated/Zep.IDataClient.AddData.g.cs index 0a0d864..77519a4 100644 --- a/src/libs/Zep/Generated/Zep.IDataClient.AddData.g.cs +++ b/src/libs/Zep/Generated/Zep.IDataClient.AddData.g.cs @@ -36,6 +36,10 @@ public partial interface IDataClient /// /// /// + /// + /// Optional document ID that groups episodes as chunks of the same document
+ /// on a graph. Parallel to thread_id for message threads. + /// /// /// graph_id is the ID of the graph to which the data will be added. If adding to the user graph, please use user_id field instead. /// @@ -57,6 +61,7 @@ public partial interface IDataClient string data, global::Zep.ModelsGraphDataType type, string? createdAt = default, + string? documentId = default, string? graphId = default, object? metadata = default, string? sourceDescription = default, diff --git a/src/libs/Zep/Generated/Zep.IDataClient.AddDataInBatchMode.g.cs b/src/libs/Zep/Generated/Zep.IDataClient.AddDataInBatchMode.g.cs index 026d700..1a5c804 100644 --- a/src/libs/Zep/Generated/Zep.IDataClient.AddDataInBatchMode.g.cs +++ b/src/libs/Zep/Generated/Zep.IDataClient.AddDataInBatchMode.g.cs @@ -37,6 +37,9 @@ public partial interface IDataClient /// Deprecated. Use the [Batch API](/adding-batch-data) (`client.batch.*`) instead.
/// Adds data to the graph in batch mode, processing episodes concurrently. /// + /// + /// Optional document ID applied to every episode in this batch request. + /// /// /// /// graph_id is the ID of the graph to which the data will be added. If adding to the user graph, please use user_id field instead. @@ -52,6 +55,7 @@ public partial interface IDataClient /// global::System.Threading.Tasks.Task> AddDataInBatchModeAsync( global::System.Collections.Generic.IList episodes, + string? documentId = default, string? graphId = default, bool? strictOntology = default, string? userId = default, diff --git a/src/libs/Zep/Generated/Zep.IDocumentClient.GetEpisodesForADocument.g.cs b/src/libs/Zep/Generated/Zep.IDocumentClient.GetEpisodesForADocument.g.cs new file mode 100644 index 0000000..64acb0d --- /dev/null +++ b/src/libs/Zep/Generated/Zep.IDocumentClient.GetEpisodesForADocument.g.cs @@ -0,0 +1,36 @@ +#nullable enable + +namespace Zep +{ + public partial interface IDocumentClient + { + /// + /// Get Episodes for a document
+ /// Returns episodes associated with a document on a graph. Documents group episodes as chunks, parallel to how threads group messages. + ///
+ /// + /// + /// Per-request overrides such as headers, query parameters, timeout, retries, and response buffering. + /// The token to cancel the operation with + /// + global::System.Threading.Tasks.Task GetEpisodesForADocumentAsync( + string documentId, + string graphId, + global::Zep.AutoSDKRequestOptions? requestOptions = default, + global::System.Threading.CancellationToken cancellationToken = default); + /// + /// Get Episodes for a document
+ /// Returns episodes associated with a document on a graph. Documents group episodes as chunks, parallel to how threads group messages. + ///
+ /// + /// + /// Per-request overrides such as headers, query parameters, timeout, retries, and response buffering. + /// The token to cancel the operation with + /// + global::System.Threading.Tasks.Task> GetEpisodesForADocumentAsResponseAsync( + string documentId, + string graphId, + global::Zep.AutoSDKRequestOptions? requestOptions = default, + global::System.Threading.CancellationToken cancellationToken = default); + } +} \ No newline at end of file diff --git a/src/libs/Zep/Generated/Zep.IDocumentClient.g.cs b/src/libs/Zep/Generated/Zep.IDocumentClient.g.cs new file mode 100644 index 0000000..c460b29 --- /dev/null +++ b/src/libs/Zep/Generated/Zep.IDocumentClient.g.cs @@ -0,0 +1,48 @@ + +#nullable enable + +namespace Zep +{ + /// + /// If no httpClient is provided, a new one will be created.
+ /// If no baseUri is provided, the default baseUri from OpenAPI spec will be used. + ///
+ public partial interface IDocumentClient : global::System.IDisposable + { + /// + /// The HttpClient instance. + /// + public global::System.Net.Http.HttpClient HttpClient { get; } + + /// + /// The base URL for the API. + /// + public System.Uri? BaseUri { get; } + + /// + /// The authorizations to use for the requests. + /// + public global::System.Collections.Generic.List Authorizations { get; } + + /// + /// Gets or sets a value indicating whether the response content should be read as a string. + /// True by default in debug builds, false otherwise. + /// When false, successful responses are deserialized directly from the response stream for better performance. + /// Error responses are always read as strings regardless of this setting, + /// ensuring is populated. + /// + public bool ReadResponseAsString { get; set; } + /// + /// Client-wide request defaults such as headers, query parameters, retries, and timeout. + /// + public global::Zep.AutoSDKClientOptions Options { get; } + + + /// + /// + /// + global::System.Text.Json.Serialization.JsonSerializerContext JsonSerializerContext { get; set; } + + + } +} \ No newline at end of file diff --git a/src/libs/Zep/Generated/Zep.IDocumentSummaryClient.GetGraphDocumentSummaries.g.cs b/src/libs/Zep/Generated/Zep.IDocumentSummaryClient.GetGraphDocumentSummaries.g.cs new file mode 100644 index 0000000..3861451 --- /dev/null +++ b/src/libs/Zep/Generated/Zep.IDocumentSummaryClient.GetGraphDocumentSummaries.g.cs @@ -0,0 +1,76 @@ +#nullable enable + +namespace Zep +{ + public partial interface IDocumentSummaryClient + { + /// + /// Get Graph Document Summaries
+ /// Returns incremental document summaries associated with the graph. Document summaries are derived similarly to thread summaries. + ///
+ /// + /// + /// Per-request overrides such as headers, query parameters, timeout, retries, and response buffering. + /// The token to cancel the operation with + /// + global::System.Threading.Tasks.Task> GetGraphDocumentSummariesAsync( + string graphId, + + global::Zep.ApidataGraphDocumentSummariesRequest request, + global::Zep.AutoSDKRequestOptions? requestOptions = default, + global::System.Threading.CancellationToken cancellationToken = default); + /// + /// Get Graph Document Summaries
+ /// Returns incremental document summaries associated with the graph. Document summaries are derived similarly to thread summaries. + ///
+ /// + /// + /// Per-request overrides such as headers, query parameters, timeout, retries, and response buffering. + /// The token to cancel the operation with + /// + global::System.Threading.Tasks.Task>> GetGraphDocumentSummariesAsResponseAsync( + string graphId, + + global::Zep.ApidataGraphDocumentSummariesRequest request, + global::Zep.AutoSDKRequestOptions? requestOptions = default, + global::System.Threading.CancellationToken cancellationToken = default); + /// + /// Get Graph Document Summaries
+ /// Returns incremental document summaries associated with the graph. Document summaries are derived similarly to thread summaries. + ///
+ /// + /// + /// Opaque cursor for pagination, obtained from the Zep-Next-Cursor response header
+ /// of the previous page. Encodes the sort field, direction, and continuation position. + /// + /// + /// Sort direction. One of "asc" or "desc" (default "desc"). + /// + /// + /// Optional filters applied to the listed artifacts. Reuses the graph.search filter type. + /// + /// + /// Maximum number of items to return + /// + /// + /// Field to sort by. One of "created_at", "valid_at", or "uuid" (default "uuid"). + /// + /// + /// UUID based cursor, used for pagination. Should be the UUID of the last item in the previous page.
+ /// Deprecated: prefer Cursor, the opaque cursor returned via the Zep-Next-Cursor response header. + /// + /// Per-request overrides such as headers, query parameters, timeout, retries, and response buffering. + /// The token to cancel the operation with + /// + global::System.Threading.Tasks.Task> GetGraphDocumentSummariesAsync( + string graphId, + string? cursor = default, + string? direction = default, + global::Zep.GraphitiSearchFilters? filters = default, + int? limit = default, + string? orderBy = default, + string? uuidCursor = default, + global::Zep.AutoSDKRequestOptions? requestOptions = default, + global::System.Threading.CancellationToken cancellationToken = default); + } +} \ No newline at end of file diff --git a/src/libs/Zep/Generated/Zep.IDocumentSummaryClient.g.cs b/src/libs/Zep/Generated/Zep.IDocumentSummaryClient.g.cs new file mode 100644 index 0000000..da4084b --- /dev/null +++ b/src/libs/Zep/Generated/Zep.IDocumentSummaryClient.g.cs @@ -0,0 +1,48 @@ + +#nullable enable + +namespace Zep +{ + /// + /// If no httpClient is provided, a new one will be created.
+ /// If no baseUri is provided, the default baseUri from OpenAPI spec will be used. + ///
+ public partial interface IDocumentSummaryClient : global::System.IDisposable + { + /// + /// The HttpClient instance. + /// + public global::System.Net.Http.HttpClient HttpClient { get; } + + /// + /// The base URL for the API. + /// + public System.Uri? BaseUri { get; } + + /// + /// The authorizations to use for the requests. + /// + public global::System.Collections.Generic.List Authorizations { get; } + + /// + /// Gets or sets a value indicating whether the response content should be read as a string. + /// True by default in debug builds, false otherwise. + /// When false, successful responses are deserialized directly from the response stream for better performance. + /// Error responses are always read as strings regardless of this setting, + /// ensuring is populated. + /// + public bool ReadResponseAsString { get; set; } + /// + /// Client-wide request defaults such as headers, query parameters, retries, and timeout. + /// + public global::Zep.AutoSDKClientOptions Options { get; } + + + /// + /// + /// + global::System.Text.Json.Serialization.JsonSerializerContext JsonSerializerContext { get; set; } + + + } +} \ No newline at end of file diff --git a/src/libs/Zep/Generated/Zep.IThreadClient.GetEpisodesForAThread.g.cs b/src/libs/Zep/Generated/Zep.IThreadClient.GetEpisodesForAThread.g.cs new file mode 100644 index 0000000..ca38b3b --- /dev/null +++ b/src/libs/Zep/Generated/Zep.IThreadClient.GetEpisodesForAThread.g.cs @@ -0,0 +1,32 @@ +#nullable enable + +namespace Zep +{ + public partial interface IThreadClient + { + /// + /// Get Episodes for a thread
+ /// Returns graph episodes associated with a thread. Parallel to get_episodes_for_document for documents. + ///
+ /// + /// Per-request overrides such as headers, query parameters, timeout, retries, and response buffering. + /// The token to cancel the operation with + /// + global::System.Threading.Tasks.Task GetEpisodesForAThreadAsync( + string threadId, + global::Zep.AutoSDKRequestOptions? requestOptions = default, + global::System.Threading.CancellationToken cancellationToken = default); + /// + /// Get Episodes for a thread
+ /// Returns graph episodes associated with a thread. Parallel to get_episodes_for_document for documents. + ///
+ /// + /// Per-request overrides such as headers, query parameters, timeout, retries, and response buffering. + /// The token to cancel the operation with + /// + global::System.Threading.Tasks.Task> GetEpisodesForAThreadAsResponseAsync( + string threadId, + global::Zep.AutoSDKRequestOptions? requestOptions = default, + global::System.Threading.CancellationToken cancellationToken = default); + } +} \ No newline at end of file diff --git a/src/libs/Zep/Generated/Zep.IThreadClient.GetMessagesOfAThread.g.cs b/src/libs/Zep/Generated/Zep.IThreadClient.GetMessagesOfAThread.g.cs index e5e40c9..59de76e 100644 --- a/src/libs/Zep/Generated/Zep.IThreadClient.GetMessagesOfAThread.g.cs +++ b/src/libs/Zep/Generated/Zep.IThreadClient.GetMessagesOfAThread.g.cs @@ -18,7 +18,7 @@ public partial interface IThreadClient global::System.Threading.Tasks.Task GetMessagesOfAThreadAsync( string threadId, int? limit = default, - int? cursor = default, + long? cursor = default, int? lastn = default, global::Zep.AutoSDKRequestOptions? requestOptions = default, global::System.Threading.CancellationToken cancellationToken = default); @@ -36,7 +36,7 @@ public partial interface IThreadClient global::System.Threading.Tasks.Task> GetMessagesOfAThreadAsResponseAsync( string threadId, int? limit = default, - int? cursor = default, + long? cursor = default, int? lastn = default, global::Zep.AutoSDKRequestOptions? requestOptions = default, global::System.Threading.CancellationToken cancellationToken = default); diff --git a/src/libs/Zep/Generated/Zep.IZepClient.g.cs b/src/libs/Zep/Generated/Zep.IZepClient.g.cs index 064b47f..d4fbb1a 100644 --- a/src/libs/Zep/Generated/Zep.IZepClient.g.cs +++ b/src/libs/Zep/Generated/Zep.IZepClient.g.cs @@ -59,6 +59,16 @@ public partial interface IZepClient : global::System.IDisposable /// public DataClient Data { get; } + /// + /// + /// + public DocumentClient Document { get; } + + /// + /// + /// + public DocumentSummaryClient DocumentSummary { get; } + /// /// /// diff --git a/src/libs/Zep/Generated/Zep.JsonSerializerContext.g.cs b/src/libs/Zep/Generated/Zep.JsonSerializerContext.g.cs index 25a08a3..afde26f 100644 --- a/src/libs/Zep/Generated/Zep.JsonSerializerContext.g.cs +++ b/src/libs/Zep/Generated/Zep.JsonSerializerContext.g.cs @@ -17,6 +17,10 @@ namespace Zep typeof(global::Zep.JsonConverters.ApidataRoleTypeNullableJsonConverter), + typeof(global::Zep.JsonConverters.ModelsGraphDataTypeJsonConverter), + + typeof(global::Zep.JsonConverters.ModelsGraphDataTypeNullableJsonConverter), + typeof(global::Zep.JsonConverters.ModelsUserGroupKindJsonConverter), typeof(global::Zep.JsonConverters.ModelsUserGroupKindNullableJsonConverter), @@ -25,10 +29,6 @@ namespace Zep typeof(global::Zep.JsonConverters.ModelsEntityPropertyTypeNullableJsonConverter), - typeof(global::Zep.JsonConverters.ModelsGraphDataTypeJsonConverter), - - typeof(global::Zep.JsonConverters.ModelsGraphDataTypeNullableJsonConverter), - typeof(global::Zep.JsonConverters.ApidataRecencyWeightJsonConverter), typeof(global::Zep.JsonConverters.ApidataRecencyWeightNullableJsonConverter), @@ -79,6 +79,11 @@ namespace Zep [global::System.Text.Json.Serialization.JsonSerializable(typeof(bool))] [global::System.Text.Json.Serialization.JsonSerializable(typeof(global::Zep.ApidataThreadMessageListResponse))] [global::System.Text.Json.Serialization.JsonSerializable(typeof(global::System.Collections.Generic.IList))] + [global::System.Text.Json.Serialization.JsonSerializable(typeof(global::Zep.ModelsGraphDataType), TypeInfoPropertyName = "ModelsGraphDataType2")] + [global::System.Text.Json.Serialization.JsonSerializable(typeof(global::Zep.ApidataGraphEpisode))] + [global::System.Text.Json.Serialization.JsonSerializable(typeof(double))] + [global::System.Text.Json.Serialization.JsonSerializable(typeof(global::Zep.ApidataGraphEpisodeResponse))] + [global::System.Text.Json.Serialization.JsonSerializable(typeof(global::System.Collections.Generic.IList))] [global::System.Text.Json.Serialization.JsonSerializable(typeof(global::Zep.ApidataAddThreadMessagesRequest))] [global::System.Text.Json.Serialization.JsonSerializable(typeof(global::System.Collections.Generic.IList))] [global::System.Text.Json.Serialization.JsonSerializable(typeof(global::Zep.ApidataAddThreadMessagesResponse))] @@ -91,7 +96,6 @@ namespace Zep [global::System.Text.Json.Serialization.JsonSerializable(typeof(global::System.Collections.Generic.IList))] [global::System.Text.Json.Serialization.JsonSerializable(typeof(global::Zep.ApidataUpdateUserRequest))] [global::System.Text.Json.Serialization.JsonSerializable(typeof(global::Zep.GraphitiEntityNode))] - [global::System.Text.Json.Serialization.JsonSerializable(typeof(double))] [global::System.Text.Json.Serialization.JsonSerializable(typeof(global::Zep.ApidataUserNodeResponse))] [global::System.Text.Json.Serialization.JsonSerializable(typeof(global::Zep.ApidataUserInstruction))] [global::System.Text.Json.Serialization.JsonSerializable(typeof(global::Zep.ApidataListUserInstructionsResponse))] @@ -131,9 +135,7 @@ namespace Zep [global::System.Text.Json.Serialization.JsonSerializable(typeof(global::Zep.ApidataEntityTypeResponse))] [global::System.Text.Json.Serialization.JsonSerializable(typeof(global::System.Collections.Generic.IList))] [global::System.Text.Json.Serialization.JsonSerializable(typeof(global::System.Collections.Generic.IList))] - [global::System.Text.Json.Serialization.JsonSerializable(typeof(global::Zep.ModelsGraphDataType), TypeInfoPropertyName = "ModelsGraphDataType2")] [global::System.Text.Json.Serialization.JsonSerializable(typeof(global::Zep.ApidataAddDataRequest))] - [global::System.Text.Json.Serialization.JsonSerializable(typeof(global::Zep.ApidataGraphEpisode))] [global::System.Text.Json.Serialization.JsonSerializable(typeof(global::Zep.ApidataEpisodeData))] [global::System.Text.Json.Serialization.JsonSerializable(typeof(global::Zep.ApidataAddDataBatchRequest))] [global::System.Text.Json.Serialization.JsonSerializable(typeof(global::System.Collections.Generic.IList))] @@ -180,7 +182,6 @@ namespace Zep [global::System.Text.Json.Serialization.JsonSerializable(typeof(global::Zep.ApidataGraphSearchResponseMetadata))] [global::System.Text.Json.Serialization.JsonSerializable(typeof(global::Zep.GraphitiSagaNode))] [global::System.Text.Json.Serialization.JsonSerializable(typeof(global::Zep.ApidataGraphSearchResults))] - [global::System.Text.Json.Serialization.JsonSerializable(typeof(global::System.Collections.Generic.IList))] [global::System.Text.Json.Serialization.JsonSerializable(typeof(global::System.Collections.Generic.IList))] [global::System.Text.Json.Serialization.JsonSerializable(typeof(global::System.Collections.Generic.IList))] [global::System.Text.Json.Serialization.JsonSerializable(typeof(global::Zep.ApidataGraphSubgraphRequest))] @@ -188,7 +189,6 @@ namespace Zep [global::System.Text.Json.Serialization.JsonSerializable(typeof(global::Zep.ApidataUpdateGraphRequest))] [global::System.Text.Json.Serialization.JsonSerializable(typeof(global::Zep.ApidataGraphEdgesRequest))] [global::System.Text.Json.Serialization.JsonSerializable(typeof(global::Zep.ApidataUpdateEdgeRequest))] - [global::System.Text.Json.Serialization.JsonSerializable(typeof(global::Zep.ApidataGraphEpisodeResponse))] [global::System.Text.Json.Serialization.JsonSerializable(typeof(global::Zep.ApidataGraphEpisodeListRequest))] [global::System.Text.Json.Serialization.JsonSerializable(typeof(global::Zep.ApidataUpdateEpisodeRequest))] [global::System.Text.Json.Serialization.JsonSerializable(typeof(global::Zep.ApidataEpisodeMentions))] @@ -209,6 +209,8 @@ namespace Zep [global::System.Text.Json.Serialization.JsonSerializable(typeof(global::Zep.ApidataDeleteCustomInstructionsRequest))] [global::System.Text.Json.Serialization.JsonSerializable(typeof(global::Zep.ApidataGraphObservationsRequest))] [global::System.Text.Json.Serialization.JsonSerializable(typeof(global::Zep.ApidataGraphThreadSummariesRequest))] + [global::System.Text.Json.Serialization.JsonSerializable(typeof(global::Zep.ApidataGraphDocumentSummariesRequest))] + [global::System.Text.Json.Serialization.JsonSerializable(typeof(global::Zep.ApidataDocumentSummary))] [global::System.Text.Json.Serialization.JsonSerializable(typeof(global::Zep.ApidataProjectInfo))] [global::System.Text.Json.Serialization.JsonSerializable(typeof(global::Zep.ApidataProjectInfoResponse))] [global::System.Text.Json.Serialization.JsonSerializable(typeof(global::Zep.ApidataUpdateProjectInfoRequest))] @@ -236,10 +238,13 @@ namespace Zep [global::System.Text.Json.Serialization.JsonSerializable(typeof(global::Zep.ApidataBatchItemListResponse))] [global::System.Text.Json.Serialization.JsonSerializable(typeof(global::System.Collections.Generic.IList))] [global::System.Text.Json.Serialization.JsonSerializable(typeof(global::Zep.SetOntologyRequest))] + [global::System.Text.Json.Serialization.JsonSerializable(typeof(long))] [global::System.Text.Json.Serialization.JsonSerializable(typeof(global::System.Collections.Generic.IList))] [global::System.Text.Json.Serialization.JsonSerializable(typeof(global::System.Collections.Generic.IList))] + [global::System.Text.Json.Serialization.JsonSerializable(typeof(global::System.Collections.Generic.IList))] [global::System.Text.Json.Serialization.JsonSerializable(typeof(global::System.Collections.Generic.List))] [global::System.Text.Json.Serialization.JsonSerializable(typeof(global::System.Collections.Generic.List))] + [global::System.Text.Json.Serialization.JsonSerializable(typeof(global::System.Collections.Generic.List))] [global::System.Text.Json.Serialization.JsonSerializable(typeof(global::System.Collections.Generic.List))] [global::System.Text.Json.Serialization.JsonSerializable(typeof(global::System.Collections.Generic.List))] [global::System.Text.Json.Serialization.JsonSerializable(typeof(global::System.Collections.Generic.List))] @@ -261,7 +266,6 @@ namespace Zep [global::System.Text.Json.Serialization.JsonSerializable(typeof(global::System.Collections.Generic.List))] [global::System.Text.Json.Serialization.JsonSerializable(typeof(global::System.Collections.Generic.List))] [global::System.Text.Json.Serialization.JsonSerializable(typeof(global::System.Collections.Generic.List))] - [global::System.Text.Json.Serialization.JsonSerializable(typeof(global::System.Collections.Generic.List))] [global::System.Text.Json.Serialization.JsonSerializable(typeof(global::System.Collections.Generic.List))] [global::System.Text.Json.Serialization.JsonSerializable(typeof(global::System.Collections.Generic.List))] [global::System.Text.Json.Serialization.JsonSerializable(typeof(global::System.Collections.Generic.List))] @@ -274,6 +278,7 @@ namespace Zep [global::System.Text.Json.Serialization.JsonSerializable(typeof(global::System.Collections.Generic.List))] [global::System.Text.Json.Serialization.JsonSerializable(typeof(global::System.Collections.Generic.List))] [global::System.Text.Json.Serialization.JsonSerializable(typeof(global::System.Collections.Generic.List))] + [global::System.Text.Json.Serialization.JsonSerializable(typeof(global::System.Collections.Generic.List))] public sealed partial class SourceGenerationContext : global::System.Text.Json.Serialization.JsonSerializerContext { } diff --git a/src/libs/Zep/Generated/Zep.JsonSerializerContextTypes.g.cs b/src/libs/Zep/Generated/Zep.JsonSerializerContextTypes.g.cs index 92545ad..f70e632 100644 --- a/src/libs/Zep/Generated/Zep.JsonSerializerContextTypes.g.cs +++ b/src/libs/Zep/Generated/Zep.JsonSerializerContextTypes.g.cs @@ -88,443 +88,443 @@ public sealed partial class JsonSerializerContextTypes /// /// /// - public global::Zep.ApidataAddThreadMessagesRequest? Type15 { get; set; } + public global::Zep.ModelsGraphDataType? Type15 { get; set; } /// /// /// - public global::System.Collections.Generic.IList? Type16 { get; set; } + public global::Zep.ApidataGraphEpisode? Type16 { get; set; } /// /// /// - public global::Zep.ApidataAddThreadMessagesResponse? Type17 { get; set; } + public double? Type17 { get; set; } /// /// /// - public global::System.Collections.Generic.IList? Type18 { get; set; } + public global::Zep.ApidataGraphEpisodeResponse? Type18 { get; set; } /// /// /// - public global::Zep.ApidataThreadSummary? Type19 { get; set; } + public global::System.Collections.Generic.IList? Type19 { get; set; } /// /// /// - public global::Zep.ModelsThreadMessageUpdate? Type20 { get; set; } + public global::Zep.ApidataAddThreadMessagesRequest? Type20 { get; set; } /// /// /// - public global::Zep.ApidataCreateUserRequest? Type21 { get; set; } + public global::System.Collections.Generic.IList? Type21 { get; set; } /// /// /// - public global::Zep.ApidataUser? Type22 { get; set; } + public global::Zep.ApidataAddThreadMessagesResponse? Type22 { get; set; } /// /// /// - public global::Zep.ApidataUserListResponse? Type23 { get; set; } + public global::System.Collections.Generic.IList? Type23 { get; set; } /// /// /// - public global::System.Collections.Generic.IList? Type24 { get; set; } + public global::Zep.ApidataThreadSummary? Type24 { get; set; } /// /// /// - public global::Zep.ApidataUpdateUserRequest? Type25 { get; set; } + public global::Zep.ModelsThreadMessageUpdate? Type25 { get; set; } /// /// /// - public global::Zep.GraphitiEntityNode? Type26 { get; set; } + public global::Zep.ApidataCreateUserRequest? Type26 { get; set; } /// /// /// - public double? Type27 { get; set; } + public global::Zep.ApidataUser? Type27 { get; set; } /// /// /// - public global::Zep.ApidataUserNodeResponse? Type28 { get; set; } + public global::Zep.ApidataUserListResponse? Type28 { get; set; } /// /// /// - public global::Zep.ApidataUserInstruction? Type29 { get; set; } + public global::System.Collections.Generic.IList? Type29 { get; set; } /// /// /// - public global::Zep.ApidataListUserInstructionsResponse? Type30 { get; set; } + public global::Zep.ApidataUpdateUserRequest? Type30 { get; set; } /// /// /// - public global::System.Collections.Generic.IList? Type31 { get; set; } + public global::Zep.GraphitiEntityNode? Type31 { get; set; } /// /// /// - public global::Zep.ApidataAddUserInstructionsRequest? Type32 { get; set; } + public global::Zep.ApidataUserNodeResponse? Type32 { get; set; } /// /// /// - public global::Zep.ApidataDeleteUserInstructionsRequest? Type33 { get; set; } + public global::Zep.ApidataUserInstruction? Type33 { get; set; } /// /// /// - public global::Zep.ModelsUserGroupQuota? Type34 { get; set; } + public global::Zep.ApidataListUserInstructionsResponse? Type34 { get; set; } /// /// /// - public global::Zep.ModelsUserGroupKind? Type35 { get; set; } + public global::System.Collections.Generic.IList? Type35 { get; set; } /// /// /// - public global::Zep.ModelsUserGroup? Type36 { get; set; } + public global::Zep.ApidataAddUserInstructionsRequest? Type36 { get; set; } /// /// /// - public global::Zep.ApidataUserGroupListResponse? Type37 { get; set; } + public global::Zep.ApidataDeleteUserInstructionsRequest? Type37 { get; set; } /// /// /// - public global::System.Collections.Generic.IList? Type38 { get; set; } + public global::Zep.ModelsUserGroupQuota? Type38 { get; set; } /// /// /// - public global::Zep.ApidataCreateUserGroupRequest? Type39 { get; set; } + public global::Zep.ModelsUserGroupKind? Type39 { get; set; } /// /// /// - public global::Zep.ApidataUserGroupResponse? Type40 { get; set; } + public global::Zep.ModelsUserGroup? Type40 { get; set; } /// /// /// - public global::Zep.ApidataUserMembershipGroupsResponse? Type41 { get; set; } + public global::Zep.ApidataUserGroupListResponse? Type41 { get; set; } /// /// /// - public global::Zep.ApidataUpdateUserGroupRequest? Type42 { get; set; } + public global::System.Collections.Generic.IList? Type42 { get; set; } /// /// /// - public global::Zep.ApidataUserGroupMembersResponse? Type43 { get; set; } + public global::Zep.ApidataCreateUserGroupRequest? Type43 { get; set; } /// /// /// - public global::Zep.ApidataMutateUserGroupMembersRequest? Type44 { get; set; } + public global::Zep.ApidataUserGroupResponse? Type44 { get; set; } /// /// /// - public global::Zep.ApidataUserGroupMembershipResponse? Type45 { get; set; } + public global::Zep.ApidataUserMembershipGroupsResponse? Type45 { get; set; } /// /// /// - public global::Zep.ApidataPolicySetSummaryResponse? Type46 { get; set; } + public global::Zep.ApidataUpdateUserGroupRequest? Type46 { get; set; } /// /// /// - public global::Zep.ApidataAttachedPolicySetsResponse? Type47 { get; set; } + public global::Zep.ApidataUserGroupMembersResponse? Type47 { get; set; } /// /// /// - public global::System.Collections.Generic.IList? Type48 { get; set; } + public global::Zep.ApidataMutateUserGroupMembersRequest? Type48 { get; set; } /// /// /// - public global::Zep.ApidataAttachPolicySetRequest? Type49 { get; set; } + public global::Zep.ApidataUserGroupMembershipResponse? Type49 { get; set; } /// /// /// - public global::Zep.ApidataCreateContextTemplateRequest? Type50 { get; set; } + public global::Zep.ApidataPolicySetSummaryResponse? Type50 { get; set; } /// /// /// - public global::Zep.ApidataContextTemplateResponse? Type51 { get; set; } + public global::Zep.ApidataAttachedPolicySetsResponse? Type51 { get; set; } /// /// /// - public global::Zep.ApidataUpdateContextTemplateRequest? Type52 { get; set; } + public global::System.Collections.Generic.IList? Type52 { get; set; } /// /// /// - public global::Zep.ApidataListContextTemplatesResponse? Type53 { get; set; } + public global::Zep.ApidataAttachPolicySetRequest? Type53 { get; set; } /// /// /// - public global::System.Collections.Generic.IList? Type54 { get; set; } + public global::Zep.ApidataCreateContextTemplateRequest? Type54 { get; set; } /// /// /// - public global::Zep.GraphSetOntologyPutRequestBodyContentApplicationJsonSchemaEntities? Type55 { get; set; } + public global::Zep.ApidataContextTemplateResponse? Type55 { get; set; } /// /// /// - public global::Zep.GraphSetOntologyPutRequestBodyContentApplicationJsonSchemaEdges? Type56 { get; set; } + public global::Zep.ApidataUpdateContextTemplateRequest? Type56 { get; set; } /// /// /// - public global::Zep.ModelsEntityPropertyType? Type57 { get; set; } + public global::Zep.ApidataListContextTemplatesResponse? Type57 { get; set; } /// /// /// - public global::Zep.ApidataEntityProperty? Type58 { get; set; } + public global::System.Collections.Generic.IList? Type58 { get; set; } /// /// /// - public global::Zep.ApidataEntityEdgeSourceTarget? Type59 { get; set; } + public global::Zep.GraphSetOntologyPutRequestBodyContentApplicationJsonSchemaEntities? Type59 { get; set; } /// /// /// - public global::Zep.ApidataEdgeType? Type60 { get; set; } + public global::Zep.GraphSetOntologyPutRequestBodyContentApplicationJsonSchemaEdges? Type60 { get; set; } /// /// /// - public global::System.Collections.Generic.IList? Type61 { get; set; } + public global::Zep.ModelsEntityPropertyType? Type61 { get; set; } /// /// /// - public global::System.Collections.Generic.IList? Type62 { get; set; } + public global::Zep.ApidataEntityProperty? Type62 { get; set; } /// /// /// - public global::Zep.ApidataEntityType? Type63 { get; set; } + public global::Zep.ApidataEntityEdgeSourceTarget? Type63 { get; set; } /// /// /// - public global::Zep.ApidataEntityTypeResponse? Type64 { get; set; } + public global::Zep.ApidataEdgeType? Type64 { get; set; } /// /// /// - public global::System.Collections.Generic.IList? Type65 { get; set; } + public global::System.Collections.Generic.IList? Type65 { get; set; } /// /// /// - public global::System.Collections.Generic.IList? Type66 { get; set; } + public global::System.Collections.Generic.IList? Type66 { get; set; } /// /// /// - public global::Zep.ModelsGraphDataType? Type67 { get; set; } + public global::Zep.ApidataEntityType? Type67 { get; set; } /// /// /// - public global::Zep.ApidataAddDataRequest? Type68 { get; set; } + public global::Zep.ApidataEntityTypeResponse? Type68 { get; set; } /// /// /// - public global::Zep.ApidataGraphEpisode? Type69 { get; set; } + public global::System.Collections.Generic.IList? Type69 { get; set; } /// /// /// - public global::Zep.ApidataEpisodeData? Type70 { get; set; } + public global::System.Collections.Generic.IList? Type70 { get; set; } /// /// /// - public global::Zep.ApidataAddDataBatchRequest? Type71 { get; set; } + public global::Zep.ApidataAddDataRequest? Type71 { get; set; } /// /// /// - public global::System.Collections.Generic.IList? Type72 { get; set; } + public global::Zep.ApidataEpisodeData? Type72 { get; set; } /// /// /// - public global::Zep.GraphitiAddTripleRequest? Type73 { get; set; } + public global::Zep.ApidataAddDataBatchRequest? Type73 { get; set; } /// /// /// - public global::Zep.GraphitiEntityEdge? Type74 { get; set; } + public global::System.Collections.Generic.IList? Type74 { get; set; } /// /// /// - public global::Zep.GraphitiAddTripleResponse? Type75 { get; set; } + public global::Zep.GraphitiAddTripleRequest? Type75 { get; set; } /// /// /// - public global::Zep.ApidataCloneGraphRequest? Type76 { get; set; } + public global::Zep.GraphitiEntityEdge? Type76 { get; set; } /// /// /// - public global::Zep.ApidataCloneGraphResponse? Type77 { get; set; } + public global::Zep.GraphitiAddTripleResponse? Type77 { get; set; } /// /// /// - public global::Zep.ApidataCreateGraphRequest? Type78 { get; set; } + public global::Zep.ApidataCloneGraphRequest? Type78 { get; set; } /// /// /// - public global::Zep.ApidataGraph? Type79 { get; set; } + public global::Zep.ApidataCloneGraphResponse? Type79 { get; set; } /// /// /// - public global::Zep.ApidataGraphListResponse? Type80 { get; set; } + public global::Zep.ApidataCreateGraphRequest? Type80 { get; set; } /// /// /// - public global::System.Collections.Generic.IList? Type81 { get; set; } + public global::Zep.ApidataGraph? Type81 { get; set; } /// /// /// - public global::Zep.ApidataClusterDetectConfig? Type82 { get; set; } + public global::Zep.ApidataGraphListResponse? Type82 { get; set; } /// /// /// - public global::Zep.ApidataCoOccurrenceDetectConfig? Type83 { get; set; } + public global::System.Collections.Generic.IList? Type83 { get; set; } /// /// /// - public global::Zep.ApidataHubDetectConfig? Type84 { get; set; } + public global::Zep.ApidataClusterDetectConfig? Type84 { get; set; } /// /// /// - public global::Zep.ApidataPathDetectConfig? Type85 { get; set; } + public global::Zep.ApidataCoOccurrenceDetectConfig? Type85 { get; set; } /// /// /// - public global::Zep.ApidataRelationshipDetectConfig? Type86 { get; set; } + public global::Zep.ApidataHubDetectConfig? Type86 { get; set; } /// /// /// - public global::Zep.ApidataDetectConfig? Type87 { get; set; } + public global::Zep.ApidataPathDetectConfig? Type87 { get; set; } /// /// /// - public global::Zep.ApidataRecencyWeight? Type88 { get; set; } + public global::Zep.ApidataRelationshipDetectConfig? Type88 { get; set; } /// /// /// - public global::Zep.GraphitiComparisonOperator? Type89 { get; set; } + public global::Zep.ApidataDetectConfig? Type89 { get; set; } /// /// /// - public global::Zep.GraphitiDateFilter? Type90 { get; set; } + public global::Zep.ApidataRecencyWeight? Type90 { get; set; } /// /// /// - public global::Zep.GraphitiEpisodeMetadataFilter? Type91 { get; set; } + public global::Zep.GraphitiComparisonOperator? Type91 { get; set; } /// /// /// - public global::Zep.GraphitiMetadataFilterGroupType? Type92 { get; set; } + public global::Zep.GraphitiDateFilter? Type92 { get; set; } /// /// /// - public global::Zep.GraphitiMetadataFilterGroup? Type93 { get; set; } + public global::Zep.GraphitiEpisodeMetadataFilter? Type93 { get; set; } /// /// /// - public global::System.Collections.Generic.IList? Type94 { get; set; } + public global::Zep.GraphitiMetadataFilterGroupType? Type94 { get; set; } /// /// /// - public global::System.Collections.Generic.IList? Type95 { get; set; } + public global::Zep.GraphitiMetadataFilterGroup? Type95 { get; set; } /// /// /// - public global::Zep.GraphitiPropertyFilter? Type96 { get; set; } + public global::System.Collections.Generic.IList? Type96 { get; set; } /// /// /// - public global::Zep.GraphitiSearchFilters? Type97 { get; set; } + public global::System.Collections.Generic.IList? Type97 { get; set; } /// /// /// - public global::System.Collections.Generic.IList>? Type98 { get; set; } + public global::Zep.GraphitiPropertyFilter? Type98 { get; set; } /// /// /// - public global::System.Collections.Generic.IList? Type99 { get; set; } + public global::Zep.GraphitiSearchFilters? Type99 { get; set; } /// /// /// - public global::System.Collections.Generic.IList? Type100 { get; set; } + public global::System.Collections.Generic.IList>? Type100 { get; set; } /// /// /// - public global::Zep.ApidataPatternSeeds? Type101 { get; set; } + public global::System.Collections.Generic.IList? Type101 { get; set; } /// /// /// - public global::Zep.ApidataDetectPatternsRequest? Type102 { get; set; } + public global::System.Collections.Generic.IList? Type102 { get; set; } /// /// /// - public global::Zep.ApidataPatternMetadata? Type103 { get; set; } + public global::Zep.ApidataPatternSeeds? Type103 { get; set; } /// /// /// - public global::Zep.ApidataPatternResult? Type104 { get; set; } + public global::Zep.ApidataDetectPatternsRequest? Type104 { get; set; } /// /// /// - public global::System.Collections.Generic.IList? Type105 { get; set; } + public global::Zep.ApidataPatternMetadata? Type105 { get; set; } /// /// /// - public global::Zep.ApidataDetectPatternsResponse? Type106 { get; set; } + public global::Zep.ApidataPatternResult? Type106 { get; set; } /// /// /// - public global::System.Collections.Generic.IList? Type107 { get; set; } + public global::System.Collections.Generic.IList? Type107 { get; set; } /// /// /// - public global::System.Collections.Generic.IList? Type108 { get; set; } + public global::Zep.ApidataDetectPatternsResponse? Type108 { get; set; } /// /// /// - public global::Zep.GraphitiReranker? Type109 { get; set; } + public global::System.Collections.Generic.IList? Type109 { get; set; } /// /// /// - public global::Zep.GraphitiGraphSearchScope? Type110 { get; set; } + public global::System.Collections.Generic.IList? Type110 { get; set; } /// /// /// - public global::Zep.GraphitiGraphSearchQuery? Type111 { get; set; } + public global::Zep.GraphitiReranker? Type111 { get; set; } /// /// /// - public global::Zep.GraphitiDerivedNode? Type112 { get; set; } + public global::Zep.GraphitiGraphSearchScope? Type112 { get; set; } /// /// /// - public global::Zep.ApidataGraphSearchResponseMetadata? Type113 { get; set; } + public global::Zep.GraphitiGraphSearchQuery? Type113 { get; set; } /// /// /// - public global::Zep.GraphitiSagaNode? Type114 { get; set; } + public global::Zep.GraphitiDerivedNode? Type114 { get; set; } /// /// /// - public global::Zep.ApidataGraphSearchResults? Type115 { get; set; } + public global::Zep.ApidataGraphSearchResponseMetadata? Type115 { get; set; } /// /// /// - public global::System.Collections.Generic.IList? Type116 { get; set; } + public global::Zep.GraphitiSagaNode? Type116 { get; set; } /// /// /// - public global::System.Collections.Generic.IList? Type117 { get; set; } + public global::Zep.ApidataGraphSearchResults? Type117 { get; set; } /// /// /// - public global::System.Collections.Generic.IList? Type118 { get; set; } + public global::System.Collections.Generic.IList? Type118 { get; set; } /// /// /// - public global::Zep.ApidataGraphSubgraphRequest? Type119 { get; set; } + public global::System.Collections.Generic.IList? Type119 { get; set; } /// /// /// - public global::Zep.ApidataGraphSubgraphResponse? Type120 { get; set; } + public global::Zep.ApidataGraphSubgraphRequest? Type120 { get; set; } /// /// /// - public global::Zep.ApidataUpdateGraphRequest? Type121 { get; set; } + public global::Zep.ApidataGraphSubgraphResponse? Type121 { get; set; } /// /// /// - public global::Zep.ApidataGraphEdgesRequest? Type122 { get; set; } + public global::Zep.ApidataUpdateGraphRequest? Type122 { get; set; } /// /// /// - public global::Zep.ApidataUpdateEdgeRequest? Type123 { get; set; } + public global::Zep.ApidataGraphEdgesRequest? Type123 { get; set; } /// /// /// - public global::Zep.ApidataGraphEpisodeResponse? Type124 { get; set; } + public global::Zep.ApidataUpdateEdgeRequest? Type124 { get; set; } /// /// /// @@ -608,119 +608,135 @@ public sealed partial class JsonSerializerContextTypes /// /// /// - public global::Zep.ApidataProjectInfo? Type145 { get; set; } + public global::Zep.ApidataGraphDocumentSummariesRequest? Type145 { get; set; } /// /// /// - public global::Zep.ApidataProjectInfoResponse? Type146 { get; set; } + public global::Zep.ApidataDocumentSummary? Type146 { get; set; } /// /// /// - public global::Zep.ApidataUpdateProjectInfoRequest? Type147 { get; set; } + public global::Zep.ApidataProjectInfo? Type147 { get; set; } /// /// /// - public global::Zep.ApidataObservationType? Type148 { get; set; } + public global::Zep.ApidataProjectInfoResponse? Type148 { get; set; } /// /// /// - public global::Zep.ApidataObservationSteeringConfig? Type149 { get; set; } + public global::Zep.ApidataUpdateProjectInfoRequest? Type149 { get; set; } /// /// /// - public global::System.Collections.Generic.IList? Type150 { get; set; } + public global::Zep.ApidataObservationType? Type150 { get; set; } /// /// /// - public global::Zep.ApidataTaskErrorResponse? Type151 { get; set; } + public global::Zep.ApidataObservationSteeringConfig? Type151 { get; set; } /// /// /// - public global::Zep.ApidataTaskProgress? Type152 { get; set; } + public global::System.Collections.Generic.IList? Type152 { get; set; } /// /// /// - public global::Zep.ApidataGetTaskResponse? Type153 { get; set; } + public global::Zep.ApidataTaskErrorResponse? Type153 { get; set; } /// /// /// - public global::Zep.ApidataCreateBatchRequest? Type154 { get; set; } + public global::Zep.ApidataTaskProgress? Type154 { get; set; } /// /// /// - public global::Zep.ApidataBatchProgress? Type155 { get; set; } + public global::Zep.ApidataGetTaskResponse? Type155 { get; set; } /// /// /// - public global::Zep.ModelsBatchStatus? Type156 { get; set; } + public global::Zep.ApidataCreateBatchRequest? Type156 { get; set; } /// /// /// - public global::Zep.ApidataBatchSummary? Type157 { get; set; } + public global::Zep.ApidataBatchProgress? Type157 { get; set; } /// /// /// - public global::Zep.ModelsBatchItemKind? Type158 { get; set; } + public global::Zep.ModelsBatchStatus? Type158 { get; set; } /// /// /// - public global::Zep.ApidataBatchAddItem? Type159 { get; set; } + public global::Zep.ApidataBatchSummary? Type159 { get; set; } /// /// /// - public global::Zep.ApidataAddBatchItemsRequest? Type160 { get; set; } + public global::Zep.ModelsBatchItemKind? Type160 { get; set; } /// /// /// - public global::System.Collections.Generic.IList? Type161 { get; set; } + public global::Zep.ApidataBatchAddItem? Type161 { get; set; } /// /// /// - public global::Zep.ModelsBatchItemStatus? Type162 { get; set; } + public global::Zep.ApidataAddBatchItemsRequest? Type162 { get; set; } /// /// /// - public global::Zep.ApidataBatchItemDetail? Type163 { get; set; } + public global::System.Collections.Generic.IList? Type163 { get; set; } /// /// /// - public global::Zep.ApidataBatchInvalidItem? Type164 { get; set; } + public global::Zep.ModelsBatchItemStatus? Type164 { get; set; } /// /// /// - public global::Zep.ApidataBatchInvalidReferencesError? Type165 { get; set; } + public global::Zep.ApidataBatchItemDetail? Type165 { get; set; } /// /// /// - public global::System.Collections.Generic.IList? Type166 { get; set; } + public global::Zep.ApidataBatchInvalidItem? Type166 { get; set; } /// /// /// - public global::Zep.ApidataBatchListResponse? Type167 { get; set; } + public global::Zep.ApidataBatchInvalidReferencesError? Type167 { get; set; } /// /// /// - public global::System.Collections.Generic.IList? Type168 { get; set; } + public global::System.Collections.Generic.IList? Type168 { get; set; } /// /// /// - public global::Zep.ApidataBatchItemListResponse? Type169 { get; set; } + public global::Zep.ApidataBatchListResponse? Type169 { get; set; } /// /// /// - public global::System.Collections.Generic.IList? Type170 { get; set; } + public global::System.Collections.Generic.IList? Type170 { get; set; } /// /// /// - public global::Zep.SetOntologyRequest? Type171 { get; set; } + public global::Zep.ApidataBatchItemListResponse? Type171 { get; set; } /// /// /// - public global::System.Collections.Generic.IList? Type172 { get; set; } + public global::System.Collections.Generic.IList? Type172 { get; set; } /// /// /// - public global::System.Collections.Generic.IList? Type173 { get; set; } + public global::Zep.SetOntologyRequest? Type173 { get; set; } + /// + /// + /// + public long? Type174 { get; set; } + /// + /// + /// + public global::System.Collections.Generic.IList? Type175 { get; set; } + /// + /// + /// + public global::System.Collections.Generic.IList? Type176 { get; set; } + /// + /// + /// + public global::System.Collections.Generic.IList? Type177 { get; set; } /// /// @@ -733,91 +749,91 @@ public sealed partial class JsonSerializerContextTypes /// /// /// - public global::System.Collections.Generic.List? ListType2 { get; set; } + public global::System.Collections.Generic.List? ListType2 { get; set; } /// /// /// - public global::System.Collections.Generic.List? ListType3 { get; set; } + public global::System.Collections.Generic.List? ListType3 { get; set; } /// /// /// - public global::System.Collections.Generic.List? ListType4 { get; set; } + public global::System.Collections.Generic.List? ListType4 { get; set; } /// /// /// - public global::System.Collections.Generic.List? ListType5 { get; set; } + public global::System.Collections.Generic.List? ListType5 { get; set; } /// /// /// - public global::System.Collections.Generic.List? ListType6 { get; set; } + public global::System.Collections.Generic.List? ListType6 { get; set; } /// /// /// - public global::System.Collections.Generic.List? ListType7 { get; set; } + public global::System.Collections.Generic.List? ListType7 { get; set; } /// /// /// - public global::System.Collections.Generic.List? ListType8 { get; set; } + public global::System.Collections.Generic.List? ListType8 { get; set; } /// /// /// - public global::System.Collections.Generic.List? ListType9 { get; set; } + public global::System.Collections.Generic.List? ListType9 { get; set; } /// /// /// - public global::System.Collections.Generic.List? ListType10 { get; set; } + public global::System.Collections.Generic.List? ListType10 { get; set; } /// /// /// - public global::System.Collections.Generic.List? ListType11 { get; set; } + public global::System.Collections.Generic.List? ListType11 { get; set; } /// /// /// - public global::System.Collections.Generic.List? ListType12 { get; set; } + public global::System.Collections.Generic.List? ListType12 { get; set; } /// /// /// - public global::System.Collections.Generic.List? ListType13 { get; set; } + public global::System.Collections.Generic.List? ListType13 { get; set; } /// /// /// - public global::System.Collections.Generic.List? ListType14 { get; set; } + public global::System.Collections.Generic.List? ListType14 { get; set; } /// /// /// - public global::System.Collections.Generic.List? ListType15 { get; set; } + public global::System.Collections.Generic.List? ListType15 { get; set; } /// /// /// - public global::System.Collections.Generic.List? ListType16 { get; set; } + public global::System.Collections.Generic.List? ListType16 { get; set; } /// /// /// - public global::System.Collections.Generic.List>? ListType17 { get; set; } + public global::System.Collections.Generic.List? ListType17 { get; set; } /// /// /// - public global::System.Collections.Generic.List? ListType18 { get; set; } + public global::System.Collections.Generic.List>? ListType18 { get; set; } /// /// /// - public global::System.Collections.Generic.List? ListType19 { get; set; } + public global::System.Collections.Generic.List? ListType19 { get; set; } /// /// /// - public global::System.Collections.Generic.List? ListType20 { get; set; } + public global::System.Collections.Generic.List? ListType20 { get; set; } /// /// /// - public global::System.Collections.Generic.List? ListType21 { get; set; } + public global::System.Collections.Generic.List? ListType21 { get; set; } /// /// /// - public global::System.Collections.Generic.List? ListType22 { get; set; } + public global::System.Collections.Generic.List? ListType22 { get; set; } /// /// /// - public global::System.Collections.Generic.List? ListType23 { get; set; } + public global::System.Collections.Generic.List? ListType23 { get; set; } /// /// /// @@ -866,5 +882,9 @@ public sealed partial class JsonSerializerContextTypes /// /// public global::System.Collections.Generic.List? ListType35 { get; set; } + /// + /// + /// + public global::System.Collections.Generic.List? ListType36 { get; set; } } } \ No newline at end of file diff --git a/src/libs/Zep/Generated/Zep.Models.ApidataAddDataBatchRequest.g.cs b/src/libs/Zep/Generated/Zep.Models.ApidataAddDataBatchRequest.g.cs index b96f4a7..5aa1c22 100644 --- a/src/libs/Zep/Generated/Zep.Models.ApidataAddDataBatchRequest.g.cs +++ b/src/libs/Zep/Generated/Zep.Models.ApidataAddDataBatchRequest.g.cs @@ -8,6 +8,12 @@ namespace Zep /// public sealed partial class ApidataAddDataBatchRequest { + /// + /// Optional document ID applied to every episode in this batch request. + /// + [global::System.Text.Json.Serialization.JsonPropertyName("document_id")] + public string? DocumentId { get; set; } + /// /// /// @@ -43,6 +49,9 @@ public sealed partial class ApidataAddDataBatchRequest /// Initializes a new instance of the class. /// /// + /// + /// Optional document ID applied to every episode in this batch request. + /// /// /// graph_id is the ID of the graph to which the data will be added. If adding to the user graph, please use user_id field instead. /// @@ -57,10 +66,12 @@ public sealed partial class ApidataAddDataBatchRequest #endif public ApidataAddDataBatchRequest( global::System.Collections.Generic.IList episodes, + string? documentId, string? graphId, bool? strictOntology, string? userId) { + this.DocumentId = documentId; this.Episodes = episodes ?? throw new global::System.ArgumentNullException(nameof(episodes)); this.GraphId = graphId; this.StrictOntology = strictOntology; diff --git a/src/libs/Zep/Generated/Zep.Models.ApidataAddDataRequest.g.cs b/src/libs/Zep/Generated/Zep.Models.ApidataAddDataRequest.g.cs index 0a9ed47..d4538a9 100644 --- a/src/libs/Zep/Generated/Zep.Models.ApidataAddDataRequest.g.cs +++ b/src/libs/Zep/Generated/Zep.Models.ApidataAddDataRequest.g.cs @@ -21,6 +21,13 @@ public sealed partial class ApidataAddDataRequest [global::System.Text.Json.Serialization.JsonRequired] public required string Data { get; set; } + /// + /// Optional document ID that groups episodes as chunks of the same document
+ /// on a graph. Parallel to thread_id for message threads. + ///
+ [global::System.Text.Json.Serialization.JsonPropertyName("document_id")] + public string? DocumentId { get; set; } + /// /// graph_id is the ID of the graph to which the data will be added. If adding to the user graph, please use user_id field instead. /// @@ -71,6 +78,10 @@ public sealed partial class ApidataAddDataRequest /// /// /// + /// + /// Optional document ID that groups episodes as chunks of the same document
+ /// on a graph. Parallel to thread_id for message threads. + /// /// /// graph_id is the ID of the graph to which the data will be added. If adding to the user graph, please use user_id field instead. /// @@ -91,6 +102,7 @@ public ApidataAddDataRequest( string data, global::Zep.ModelsGraphDataType type, string? createdAt, + string? documentId, string? graphId, object? metadata, string? sourceDescription, @@ -99,6 +111,7 @@ public ApidataAddDataRequest( { this.CreatedAt = createdAt; this.Data = data ?? throw new global::System.ArgumentNullException(nameof(data)); + this.DocumentId = documentId; this.GraphId = graphId; this.Metadata = metadata; this.SourceDescription = sourceDescription; diff --git a/src/libs/Zep/Generated/Zep.Models.ApidataBatchAddItem.g.cs b/src/libs/Zep/Generated/Zep.Models.ApidataBatchAddItem.g.cs index d620654..fd9027a 100644 --- a/src/libs/Zep/Generated/Zep.Models.ApidataBatchAddItem.g.cs +++ b/src/libs/Zep/Generated/Zep.Models.ApidataBatchAddItem.g.cs @@ -33,6 +33,13 @@ public sealed partial class ApidataBatchAddItem [global::System.Text.Json.Serialization.JsonConverter(typeof(global::Zep.JsonConverters.ModelsGraphDataTypeJsonConverter))] public global::Zep.ModelsGraphDataType? DataType { get; set; } + /// + /// Optional document ID for graph_episode items. Groups episodes as document
+ /// chunks. Ignored for thread_message items. + ///
+ [global::System.Text.Json.Serialization.JsonPropertyName("document_id")] + public string? DocumentId { get; set; } + /// /// /// @@ -98,6 +105,10 @@ public sealed partial class ApidataBatchAddItem /// /// /// + /// + /// Optional document ID for graph_episode items. Groups episodes as document
+ /// chunks. Ignored for thread_message items. + /// /// /// /// @@ -114,6 +125,7 @@ public ApidataBatchAddItem( string? createdAt, string? data, global::Zep.ModelsGraphDataType? dataType, + string? documentId, string? graphId, object? metadata, string? name, @@ -126,6 +138,7 @@ public ApidataBatchAddItem( this.CreatedAt = createdAt; this.Data = data; this.DataType = dataType; + this.DocumentId = documentId; this.GraphId = graphId; this.Metadata = metadata; this.Name = name; diff --git a/src/libs/Zep/Generated/Zep.Models.ApidataBatchItemDetail.g.cs b/src/libs/Zep/Generated/Zep.Models.ApidataBatchItemDetail.g.cs index 7ecc441..4594355 100644 --- a/src/libs/Zep/Generated/Zep.Models.ApidataBatchItemDetail.g.cs +++ b/src/libs/Zep/Generated/Zep.Models.ApidataBatchItemDetail.g.cs @@ -14,6 +14,12 @@ public sealed partial class ApidataBatchItemDetail [global::System.Text.Json.Serialization.JsonPropertyName("created_at")] public string? CreatedAt { get; set; } + /// + /// + /// + [global::System.Text.Json.Serialization.JsonPropertyName("document_id")] + public string? DocumentId { get; set; } + /// /// EpisodeUUID is the UUID of the episode that will be (or has been) created
/// for this batch item. Populated for every item kind and always equal to
@@ -107,6 +113,7 @@ public sealed partial class ApidataBatchItemDetail /// Initializes a new instance of the class. ///
/// + /// /// /// EpisodeUUID is the UUID of the episode that will be (or has been) created
/// for this batch item. Populated for every item kind and always equal to
@@ -130,6 +137,7 @@ public sealed partial class ApidataBatchItemDetail #endif public ApidataBatchItemDetail( string? createdAt, + string? documentId, string? episodeUuid, object? error, string? graphId, @@ -145,6 +153,7 @@ public ApidataBatchItemDetail( string? userUuid) { this.CreatedAt = createdAt; + this.DocumentId = documentId; this.EpisodeUuid = episodeUuid; this.Error = error; this.GraphId = graphId; diff --git a/src/libs/Zep/Generated/Zep.Models.ApidataDocumentSummary.Json.g.cs b/src/libs/Zep/Generated/Zep.Models.ApidataDocumentSummary.Json.g.cs new file mode 100644 index 0000000..08f842c --- /dev/null +++ b/src/libs/Zep/Generated/Zep.Models.ApidataDocumentSummary.Json.g.cs @@ -0,0 +1,141 @@ +#nullable enable + +namespace Zep +{ + public sealed partial class ApidataDocumentSummary + { + /// + /// Serializes the current instance to a JSON string using the provided JsonSerializerContext. + /// + public string ToJson( + global::System.Text.Json.Serialization.JsonSerializerContext jsonSerializerContext) + { + return global::System.Text.Json.JsonSerializer.Serialize( + this, + this.GetType(), + jsonSerializerContext); + } + + /// + /// Serializes the current instance to a JSON string using the generated default JsonSerializerContext. + /// + public string ToJson() + { + return ToJson(global::Zep.SourceGenerationContext.Default); + } + + /// + /// Serializes the current instance to a JSON string using the provided JsonSerializerOptions. + /// +#if NET8_0_OR_GREATER + [global::System.Diagnostics.CodeAnalysis.RequiresUnreferencedCode("JSON serialization and deserialization might require types that cannot be statically analyzed. Use the overload that takes a JsonTypeInfo or JsonSerializerContext, or make sure all of the required types are preserved.")] + [global::System.Diagnostics.CodeAnalysis.RequiresDynamicCode("JSON serialization and deserialization might require types that cannot be statically analyzed and might need runtime code generation. Use System.Text.Json source generation for native AOT applications.")] +#endif + public string ToJson( + global::System.Text.Json.JsonSerializerOptions? jsonSerializerOptions = null) + { + if (jsonSerializerOptions is null) + { + return ToJson(global::Zep.SourceGenerationContext.Default); + } + + return global::System.Text.Json.JsonSerializer.Serialize( + this, + jsonSerializerOptions); + } + + /// + /// Deserializes a JSON string using the provided JsonSerializerContext. + /// + public static global::Zep.ApidataDocumentSummary? FromJson( + string json, + global::System.Text.Json.Serialization.JsonSerializerContext jsonSerializerContext) + { + return global::System.Text.Json.JsonSerializer.Deserialize( + json, + typeof(global::Zep.ApidataDocumentSummary), + jsonSerializerContext) as global::Zep.ApidataDocumentSummary; + } + + /// + /// Deserializes a JSON string using the generated default JsonSerializerContext. + /// + public static global::Zep.ApidataDocumentSummary? FromJson( + string json) + { + return FromJson( + json, + global::Zep.SourceGenerationContext.Default); + } + + /// + /// Deserializes a JSON string using the provided JsonSerializerOptions. + /// +#if NET8_0_OR_GREATER + [global::System.Diagnostics.CodeAnalysis.RequiresUnreferencedCode("JSON serialization and deserialization might require types that cannot be statically analyzed. Use the overload that takes a JsonTypeInfo or JsonSerializerContext, or make sure all of the required types are preserved.")] + [global::System.Diagnostics.CodeAnalysis.RequiresDynamicCode("JSON serialization and deserialization might require types that cannot be statically analyzed and might need runtime code generation. Use System.Text.Json source generation for native AOT applications.")] +#endif + public static global::Zep.ApidataDocumentSummary? FromJson( + string json, + global::System.Text.Json.JsonSerializerOptions? jsonSerializerOptions = null) + { + if (jsonSerializerOptions is null) + { + return FromJson( + json, + global::Zep.SourceGenerationContext.Default); + } + + return global::System.Text.Json.JsonSerializer.Deserialize( + json, + jsonSerializerOptions); + } + + /// + /// Deserializes a JSON stream using the provided JsonSerializerContext. + /// + public static async global::System.Threading.Tasks.ValueTask FromJsonStreamAsync( + global::System.IO.Stream jsonStream, + global::System.Text.Json.Serialization.JsonSerializerContext jsonSerializerContext) + { + return (await global::System.Text.Json.JsonSerializer.DeserializeAsync( + jsonStream, + typeof(global::Zep.ApidataDocumentSummary), + jsonSerializerContext).ConfigureAwait(false)) as global::Zep.ApidataDocumentSummary; + } + + /// + /// Deserializes a JSON stream using the generated default JsonSerializerContext. + /// + public static global::System.Threading.Tasks.ValueTask FromJsonStreamAsync( + global::System.IO.Stream jsonStream) + { + return FromJsonStreamAsync( + jsonStream, + global::Zep.SourceGenerationContext.Default); + } + + /// + /// Deserializes a JSON stream using the provided JsonSerializerOptions. + /// +#if NET8_0_OR_GREATER + [global::System.Diagnostics.CodeAnalysis.RequiresUnreferencedCode("JSON serialization and deserialization might require types that cannot be statically analyzed. Use the overload that takes a JsonTypeInfo or JsonSerializerContext, or make sure all of the required types are preserved.")] + [global::System.Diagnostics.CodeAnalysis.RequiresDynamicCode("JSON serialization and deserialization might require types that cannot be statically analyzed and might need runtime code generation. Use System.Text.Json source generation for native AOT applications.")] +#endif + public static global::System.Threading.Tasks.ValueTask FromJsonStreamAsync( + global::System.IO.Stream jsonStream, + global::System.Text.Json.JsonSerializerOptions? jsonSerializerOptions = null) + { + if (jsonSerializerOptions is null) + { + return FromJsonStreamAsync( + jsonStream, + global::Zep.SourceGenerationContext.Default); + } + + return global::System.Text.Json.JsonSerializer.DeserializeAsync( + jsonStream, + jsonSerializerOptions); + } + } +} diff --git a/src/libs/Zep/Generated/Zep.Models.ApidataDocumentSummary.g.cs b/src/libs/Zep/Generated/Zep.Models.ApidataDocumentSummary.g.cs new file mode 100644 index 0000000..aae1419 --- /dev/null +++ b/src/libs/Zep/Generated/Zep.Models.ApidataDocumentSummary.g.cs @@ -0,0 +1,105 @@ + +#nullable enable + +namespace Zep +{ + /// + /// + /// + public sealed partial class ApidataDocumentSummary + { + /// + /// CreatedAt is when the summary node was first created. + /// + [global::System.Text.Json.Serialization.JsonPropertyName("created_at")] + public string? CreatedAt { get; set; } + + /// + /// DocumentID is the customer-facing document identifier. + /// + [global::System.Text.Json.Serialization.JsonPropertyName("document_id")] + public string? DocumentId { get; set; } + + /// + /// LastSummarizedAt is the wall-clock timestamp of the most recent
+ /// summary update. + ///
+ [global::System.Text.Json.Serialization.JsonPropertyName("last_summarized_at")] + public string? LastSummarizedAt { get; set; } + + /// + /// LastSummarizedEpisodeValidAt is the maximum episode reference time
+ /// (valid_at) covered by the most recent summary. + ///
+ [global::System.Text.Json.Serialization.JsonPropertyName("last_summarized_episode_valid_at")] + public string? LastSummarizedEpisodeValidAt { get; set; } + + /// + /// Summary is the incremental summary content. + /// + [global::System.Text.Json.Serialization.JsonPropertyName("summary")] + public string? Summary { get; set; } + + /// + /// UUID of the document summary (derived) node. + /// + [global::System.Text.Json.Serialization.JsonPropertyName("uuid")] + public string? Uuid { get; set; } + + /// + /// Additional properties that are not explicitly defined in the schema + /// + [global::System.Text.Json.Serialization.JsonExtensionData] + public global::System.Collections.Generic.IDictionary AdditionalProperties { get; set; } = new global::System.Collections.Generic.Dictionary(); + + /// + /// Initializes a new instance of the class. + /// + /// + /// CreatedAt is when the summary node was first created. + /// + /// + /// DocumentID is the customer-facing document identifier. + /// + /// + /// LastSummarizedAt is the wall-clock timestamp of the most recent
+ /// summary update. + /// + /// + /// LastSummarizedEpisodeValidAt is the maximum episode reference time
+ /// (valid_at) covered by the most recent summary. + /// + /// + /// Summary is the incremental summary content. + /// + /// + /// UUID of the document summary (derived) node. + /// +#if NET7_0_OR_GREATER + [global::System.Diagnostics.CodeAnalysis.SetsRequiredMembers] +#endif + public ApidataDocumentSummary( + string? createdAt, + string? documentId, + string? lastSummarizedAt, + string? lastSummarizedEpisodeValidAt, + string? summary, + string? uuid) + { + this.CreatedAt = createdAt; + this.DocumentId = documentId; + this.LastSummarizedAt = lastSummarizedAt; + this.LastSummarizedEpisodeValidAt = lastSummarizedEpisodeValidAt; + this.Summary = summary; + this.Uuid = uuid; + } + + /// + /// Initializes a new instance of the class. + /// + public ApidataDocumentSummary() + { + } + + } +} \ No newline at end of file diff --git a/src/libs/Zep/Generated/Zep.Models.ApidataGraphDocumentSummariesRequest.Json.g.cs b/src/libs/Zep/Generated/Zep.Models.ApidataGraphDocumentSummariesRequest.Json.g.cs new file mode 100644 index 0000000..2bac981 --- /dev/null +++ b/src/libs/Zep/Generated/Zep.Models.ApidataGraphDocumentSummariesRequest.Json.g.cs @@ -0,0 +1,141 @@ +#nullable enable + +namespace Zep +{ + public sealed partial class ApidataGraphDocumentSummariesRequest + { + /// + /// Serializes the current instance to a JSON string using the provided JsonSerializerContext. + /// + public string ToJson( + global::System.Text.Json.Serialization.JsonSerializerContext jsonSerializerContext) + { + return global::System.Text.Json.JsonSerializer.Serialize( + this, + this.GetType(), + jsonSerializerContext); + } + + /// + /// Serializes the current instance to a JSON string using the generated default JsonSerializerContext. + /// + public string ToJson() + { + return ToJson(global::Zep.SourceGenerationContext.Default); + } + + /// + /// Serializes the current instance to a JSON string using the provided JsonSerializerOptions. + /// +#if NET8_0_OR_GREATER + [global::System.Diagnostics.CodeAnalysis.RequiresUnreferencedCode("JSON serialization and deserialization might require types that cannot be statically analyzed. Use the overload that takes a JsonTypeInfo or JsonSerializerContext, or make sure all of the required types are preserved.")] + [global::System.Diagnostics.CodeAnalysis.RequiresDynamicCode("JSON serialization and deserialization might require types that cannot be statically analyzed and might need runtime code generation. Use System.Text.Json source generation for native AOT applications.")] +#endif + public string ToJson( + global::System.Text.Json.JsonSerializerOptions? jsonSerializerOptions = null) + { + if (jsonSerializerOptions is null) + { + return ToJson(global::Zep.SourceGenerationContext.Default); + } + + return global::System.Text.Json.JsonSerializer.Serialize( + this, + jsonSerializerOptions); + } + + /// + /// Deserializes a JSON string using the provided JsonSerializerContext. + /// + public static global::Zep.ApidataGraphDocumentSummariesRequest? FromJson( + string json, + global::System.Text.Json.Serialization.JsonSerializerContext jsonSerializerContext) + { + return global::System.Text.Json.JsonSerializer.Deserialize( + json, + typeof(global::Zep.ApidataGraphDocumentSummariesRequest), + jsonSerializerContext) as global::Zep.ApidataGraphDocumentSummariesRequest; + } + + /// + /// Deserializes a JSON string using the generated default JsonSerializerContext. + /// + public static global::Zep.ApidataGraphDocumentSummariesRequest? FromJson( + string json) + { + return FromJson( + json, + global::Zep.SourceGenerationContext.Default); + } + + /// + /// Deserializes a JSON string using the provided JsonSerializerOptions. + /// +#if NET8_0_OR_GREATER + [global::System.Diagnostics.CodeAnalysis.RequiresUnreferencedCode("JSON serialization and deserialization might require types that cannot be statically analyzed. Use the overload that takes a JsonTypeInfo or JsonSerializerContext, or make sure all of the required types are preserved.")] + [global::System.Diagnostics.CodeAnalysis.RequiresDynamicCode("JSON serialization and deserialization might require types that cannot be statically analyzed and might need runtime code generation. Use System.Text.Json source generation for native AOT applications.")] +#endif + public static global::Zep.ApidataGraphDocumentSummariesRequest? FromJson( + string json, + global::System.Text.Json.JsonSerializerOptions? jsonSerializerOptions = null) + { + if (jsonSerializerOptions is null) + { + return FromJson( + json, + global::Zep.SourceGenerationContext.Default); + } + + return global::System.Text.Json.JsonSerializer.Deserialize( + json, + jsonSerializerOptions); + } + + /// + /// Deserializes a JSON stream using the provided JsonSerializerContext. + /// + public static async global::System.Threading.Tasks.ValueTask FromJsonStreamAsync( + global::System.IO.Stream jsonStream, + global::System.Text.Json.Serialization.JsonSerializerContext jsonSerializerContext) + { + return (await global::System.Text.Json.JsonSerializer.DeserializeAsync( + jsonStream, + typeof(global::Zep.ApidataGraphDocumentSummariesRequest), + jsonSerializerContext).ConfigureAwait(false)) as global::Zep.ApidataGraphDocumentSummariesRequest; + } + + /// + /// Deserializes a JSON stream using the generated default JsonSerializerContext. + /// + public static global::System.Threading.Tasks.ValueTask FromJsonStreamAsync( + global::System.IO.Stream jsonStream) + { + return FromJsonStreamAsync( + jsonStream, + global::Zep.SourceGenerationContext.Default); + } + + /// + /// Deserializes a JSON stream using the provided JsonSerializerOptions. + /// +#if NET8_0_OR_GREATER + [global::System.Diagnostics.CodeAnalysis.RequiresUnreferencedCode("JSON serialization and deserialization might require types that cannot be statically analyzed. Use the overload that takes a JsonTypeInfo or JsonSerializerContext, or make sure all of the required types are preserved.")] + [global::System.Diagnostics.CodeAnalysis.RequiresDynamicCode("JSON serialization and deserialization might require types that cannot be statically analyzed and might need runtime code generation. Use System.Text.Json source generation for native AOT applications.")] +#endif + public static global::System.Threading.Tasks.ValueTask FromJsonStreamAsync( + global::System.IO.Stream jsonStream, + global::System.Text.Json.JsonSerializerOptions? jsonSerializerOptions = null) + { + if (jsonSerializerOptions is null) + { + return FromJsonStreamAsync( + jsonStream, + global::Zep.SourceGenerationContext.Default); + } + + return global::System.Text.Json.JsonSerializer.DeserializeAsync( + jsonStream, + jsonSerializerOptions); + } + } +} diff --git a/src/libs/Zep/Generated/Zep.Models.ApidataGraphDocumentSummariesRequest.g.cs b/src/libs/Zep/Generated/Zep.Models.ApidataGraphDocumentSummariesRequest.g.cs new file mode 100644 index 0000000..2996007 --- /dev/null +++ b/src/libs/Zep/Generated/Zep.Models.ApidataGraphDocumentSummariesRequest.g.cs @@ -0,0 +1,105 @@ + +#nullable enable + +namespace Zep +{ + /// + /// + /// + public sealed partial class ApidataGraphDocumentSummariesRequest + { + /// + /// Opaque cursor for pagination, obtained from the Zep-Next-Cursor response header
+ /// of the previous page. Encodes the sort field, direction, and continuation position. + ///
+ [global::System.Text.Json.Serialization.JsonPropertyName("cursor")] + public string? Cursor { get; set; } + + /// + /// Sort direction. One of "asc" or "desc" (default "desc"). + /// + [global::System.Text.Json.Serialization.JsonPropertyName("direction")] + public string? Direction { get; set; } + + /// + /// Optional filters applied to the listed artifacts. Reuses the graph.search filter type. + /// + [global::System.Text.Json.Serialization.JsonPropertyName("filters")] + public global::Zep.GraphitiSearchFilters? Filters { get; set; } + + /// + /// Maximum number of items to return + /// + [global::System.Text.Json.Serialization.JsonPropertyName("limit")] + public int? Limit { get; set; } + + /// + /// Field to sort by. One of "created_at", "valid_at", or "uuid" (default "uuid"). + /// + [global::System.Text.Json.Serialization.JsonPropertyName("order_by")] + public string? OrderBy { get; set; } + + /// + /// UUID based cursor, used for pagination. Should be the UUID of the last item in the previous page.
+ /// Deprecated: prefer Cursor, the opaque cursor returned via the Zep-Next-Cursor response header. + ///
+ [global::System.Text.Json.Serialization.JsonPropertyName("uuid_cursor")] + public string? UuidCursor { get; set; } + + /// + /// Additional properties that are not explicitly defined in the schema + /// + [global::System.Text.Json.Serialization.JsonExtensionData] + public global::System.Collections.Generic.IDictionary AdditionalProperties { get; set; } = new global::System.Collections.Generic.Dictionary(); + + /// + /// Initializes a new instance of the class. + /// + /// + /// Opaque cursor for pagination, obtained from the Zep-Next-Cursor response header
+ /// of the previous page. Encodes the sort field, direction, and continuation position. + /// + /// + /// Sort direction. One of "asc" or "desc" (default "desc"). + /// + /// + /// Optional filters applied to the listed artifacts. Reuses the graph.search filter type. + /// + /// + /// Maximum number of items to return + /// + /// + /// Field to sort by. One of "created_at", "valid_at", or "uuid" (default "uuid"). + /// + /// + /// UUID based cursor, used for pagination. Should be the UUID of the last item in the previous page.
+ /// Deprecated: prefer Cursor, the opaque cursor returned via the Zep-Next-Cursor response header. + /// +#if NET7_0_OR_GREATER + [global::System.Diagnostics.CodeAnalysis.SetsRequiredMembers] +#endif + public ApidataGraphDocumentSummariesRequest( + string? cursor, + string? direction, + global::Zep.GraphitiSearchFilters? filters, + int? limit, + string? orderBy, + string? uuidCursor) + { + this.Cursor = cursor; + this.Direction = direction; + this.Filters = filters; + this.Limit = limit; + this.OrderBy = orderBy; + this.UuidCursor = uuidCursor; + } + + /// + /// Initializes a new instance of the class. + /// + public ApidataGraphDocumentSummariesRequest() + { + } + + } +} \ No newline at end of file diff --git a/src/libs/Zep/Generated/Zep.Models.ApidataGraphEpisode.g.cs b/src/libs/Zep/Generated/Zep.Models.ApidataGraphEpisode.g.cs index 4c94b80..dd7b223 100644 --- a/src/libs/Zep/Generated/Zep.Models.ApidataGraphEpisode.g.cs +++ b/src/libs/Zep/Generated/Zep.Models.ApidataGraphEpisode.g.cs @@ -22,6 +22,12 @@ public sealed partial class ApidataGraphEpisode [global::System.Text.Json.Serialization.JsonRequired] public required string CreatedAt { get; set; } + /// + /// Optional document ID, will be present if the episode is part of a document + /// + [global::System.Text.Json.Serialization.JsonPropertyName("document_id")] + public string? DocumentId { get; set; } + /// /// /// @@ -110,6 +116,9 @@ public sealed partial class ApidataGraphEpisode /// /// /// + /// + /// Optional document ID, will be present if the episode is part of a document + /// /// /// /// @@ -143,6 +152,7 @@ public ApidataGraphEpisode( string content, string createdAt, string uuid, + string? documentId, object? metadata, bool? processed, double? relevance, @@ -157,6 +167,7 @@ public ApidataGraphEpisode( { this.Content = content ?? throw new global::System.ArgumentNullException(nameof(content)); this.CreatedAt = createdAt ?? throw new global::System.ArgumentNullException(nameof(createdAt)); + this.DocumentId = documentId; this.Metadata = metadata; this.Processed = processed; this.Relevance = relevance; diff --git a/src/libs/Zep/Generated/Zep.Models.ApidataThreadSummary.g.cs b/src/libs/Zep/Generated/Zep.Models.ApidataThreadSummary.g.cs index 304b0a0..85b9cf2 100644 --- a/src/libs/Zep/Generated/Zep.Models.ApidataThreadSummary.g.cs +++ b/src/libs/Zep/Generated/Zep.Models.ApidataThreadSummary.g.cs @@ -47,7 +47,7 @@ public sealed partial class ApidataThreadSummary public string? ThreadId { get; set; } /// - /// UUID of the thread summary node. + /// UUID of the derived thread summary node. /// [global::System.Text.Json.Serialization.JsonPropertyName("uuid")] public string? Uuid { get; set; } @@ -85,7 +85,7 @@ public sealed partial class ApidataThreadSummary /// as an opaque identifier. /// /// - /// UUID of the thread summary node. + /// UUID of the derived thread summary node. /// #if NET7_0_OR_GREATER [global::System.Diagnostics.CodeAnalysis.SetsRequiredMembers] diff --git a/src/libs/Zep/Generated/Zep.ThreadClient.GetEpisodesForAThread.g.cs b/src/libs/Zep/Generated/Zep.ThreadClient.GetEpisodesForAThread.g.cs new file mode 100644 index 0000000..8fd8956 --- /dev/null +++ b/src/libs/Zep/Generated/Zep.ThreadClient.GetEpisodesForAThread.g.cs @@ -0,0 +1,537 @@ + +#nullable enable + +namespace Zep +{ + public partial class ThreadClient + { + + + private static readonly global::Zep.EndPointSecurityRequirement s_GetEpisodesForAThreadSecurityRequirement0 = + new global::Zep.EndPointSecurityRequirement + { + Authorizations = new global::Zep.EndPointAuthorizationRequirement[] + { new global::Zep.EndPointAuthorizationRequirement + { + Type = "Http", + SchemeId = "BearerAuth", + Location = "Header", + Name = "Bearer", + FriendlyName = "Bearer", + }, + }, + }; + private static readonly global::Zep.EndPointSecurityRequirement[] s_GetEpisodesForAThreadSecurityRequirements = + new global::Zep.EndPointSecurityRequirement[] + { s_GetEpisodesForAThreadSecurityRequirement0, + }; + partial void PrepareGetEpisodesForAThreadArguments( + global::System.Net.Http.HttpClient httpClient, + ref string threadId); + partial void PrepareGetEpisodesForAThreadRequest( + global::System.Net.Http.HttpClient httpClient, + global::System.Net.Http.HttpRequestMessage httpRequestMessage, + string threadId); + partial void ProcessGetEpisodesForAThreadResponse( + global::System.Net.Http.HttpClient httpClient, + global::System.Net.Http.HttpResponseMessage httpResponseMessage); + + partial void ProcessGetEpisodesForAThreadResponseContent( + global::System.Net.Http.HttpClient httpClient, + global::System.Net.Http.HttpResponseMessage httpResponseMessage, + ref string content); + + /// + /// Get Episodes for a thread
+ /// Returns graph episodes associated with a thread. Parallel to get_episodes_for_document for documents. + ///
+ /// + /// Per-request overrides such as headers, query parameters, timeout, retries, and response buffering. + /// The token to cancel the operation with + /// + public async global::System.Threading.Tasks.Task GetEpisodesForAThreadAsync( + string threadId, + global::Zep.AutoSDKRequestOptions? requestOptions = default, + global::System.Threading.CancellationToken cancellationToken = default) + { + var __response = await GetEpisodesForAThreadAsResponseAsync( + threadId: threadId, + requestOptions: requestOptions, + cancellationToken: cancellationToken + ).ConfigureAwait(false); + + return __response.Body; + } + /// + /// Get Episodes for a thread
+ /// Returns graph episodes associated with a thread. Parallel to get_episodes_for_document for documents. + ///
+ /// + /// Per-request overrides such as headers, query parameters, timeout, retries, and response buffering. + /// The token to cancel the operation with + /// + public async global::System.Threading.Tasks.Task> GetEpisodesForAThreadAsResponseAsync( + string threadId, + global::Zep.AutoSDKRequestOptions? requestOptions = default, + global::System.Threading.CancellationToken cancellationToken = default) + { + PrepareArguments( + client: HttpClient); + PrepareGetEpisodesForAThreadArguments( + httpClient: HttpClient, + threadId: ref threadId); + + + var __authorizations = global::Zep.EndPointSecurityResolver.ResolveAuthorizations( + availableAuthorizations: Authorizations, + securityRequirements: s_GetEpisodesForAThreadSecurityRequirements, + operationName: "GetEpisodesForAThreadAsync"); + + using var __timeoutCancellationTokenSource = global::Zep.AutoSDKRequestOptionsSupport.CreateTimeoutCancellationTokenSource( + clientOptions: Options, + requestOptions: requestOptions, + cancellationToken: cancellationToken); + var __effectiveCancellationToken = __timeoutCancellationTokenSource?.Token ?? cancellationToken; + var __effectiveReadResponseAsString = global::Zep.AutoSDKRequestOptionsSupport.GetReadResponseAsString( + clientOptions: Options, + requestOptions: requestOptions, + fallbackValue: ReadResponseAsString); + var __maxAttempts = global::Zep.AutoSDKRequestOptionsSupport.GetMaxAttempts( + clientOptions: Options, + requestOptions: requestOptions, + supportsRetry: true); + + global::System.Net.Http.HttpRequestMessage __CreateHttpRequest() + { + + var __pathBuilder = new global::Zep.PathBuilder( + path: $"/threads/{threadId}/episodes", + baseUri: HttpClient.BaseAddress); + var __path = __pathBuilder.ToString(); + __path = global::Zep.AutoSDKRequestOptionsSupport.AppendQueryParameters( + path: __path, + clientParameters: Options.QueryParameters, + requestParameters: requestOptions?.QueryParameters); + var __httpRequest = new global::System.Net.Http.HttpRequestMessage( + method: global::System.Net.Http.HttpMethod.Get, + requestUri: new global::System.Uri(__path, global::System.UriKind.RelativeOrAbsolute)); +#if NET6_0_OR_GREATER + __httpRequest.Version = global::System.Net.HttpVersion.Version11; + __httpRequest.VersionPolicy = global::System.Net.Http.HttpVersionPolicy.RequestVersionOrHigher; +#endif + + foreach (var __authorization in __authorizations) + { + if (__authorization.Type == "Http" || + __authorization.Type == "OAuth2" || + __authorization.Type == "OpenIdConnect") + { + __httpRequest.Headers.Authorization = new global::System.Net.Http.Headers.AuthenticationHeaderValue( + scheme: __authorization.Name, + parameter: __authorization.Value); + } + else if (__authorization.Type == "ApiKey" && + __authorization.Location == "Header") + { + __httpRequest.Headers.Add(__authorization.Name, __authorization.Value); + } + } + global::Zep.AutoSDKRequestOptionsSupport.ApplyHeaders( + request: __httpRequest, + clientHeaders: Options.Headers, + requestHeaders: requestOptions?.Headers); + + PrepareRequest( + client: HttpClient, + request: __httpRequest); + PrepareGetEpisodesForAThreadRequest( + httpClient: HttpClient, + httpRequestMessage: __httpRequest, + threadId: threadId!); + + return __httpRequest; + } + + global::System.Net.Http.HttpRequestMessage? __httpRequest = null; + global::System.Net.Http.HttpResponseMessage? __response = null; + var __attemptNumber = 0; + try + { + for (var __attempt = 1; __attempt <= __maxAttempts; __attempt++) + { + __attemptNumber = __attempt; + __httpRequest = __CreateHttpRequest(); + await global::Zep.AutoSDKRequestOptionsSupport.OnBeforeRequestAsync( + clientOptions: Options, + context: global::Zep.AutoSDKRequestOptionsSupport.CreateHookContext( + operationId: "GetEpisodesForAThread", + methodName: "GetEpisodesForAThreadAsync", + pathTemplate: "$\"/threads/{threadId}/episodes\"", + httpMethod: "GET", + baseUri: BaseUri, + request: __httpRequest!, + response: null, + exception: null, + clientOptions: Options, + requestOptions: requestOptions, + attempt: __attempt, + maxAttempts: __maxAttempts, + willRetry: false, + retryDelay: null, + retryReason: global::System.String.Empty, + cancellationToken: __effectiveCancellationToken)).ConfigureAwait(false); + try + { + __response = await HttpClient.SendAsync( + request: __httpRequest, + completionOption: global::System.Net.Http.HttpCompletionOption.ResponseContentRead, + cancellationToken: __effectiveCancellationToken).ConfigureAwait(false); + } + catch (global::System.Net.Http.HttpRequestException __exception) + { + var __retryDelay = global::Zep.AutoSDKRequestOptionsSupport.GetRetryDelay( + clientOptions: Options, + requestOptions: requestOptions, + response: null, + attempt: __attempt); + var __willRetry = __attempt < __maxAttempts && !__effectiveCancellationToken.IsCancellationRequested; + await global::Zep.AutoSDKRequestOptionsSupport.OnAfterErrorAsync( + clientOptions: Options, + context: global::Zep.AutoSDKRequestOptionsSupport.CreateHookContext( + operationId: "GetEpisodesForAThread", + methodName: "GetEpisodesForAThreadAsync", + pathTemplate: "$\"/threads/{threadId}/episodes\"", + httpMethod: "GET", + baseUri: BaseUri, + request: __httpRequest!, + response: null, + exception: __exception, + clientOptions: Options, + requestOptions: requestOptions, + attempt: __attempt, + maxAttempts: __maxAttempts, + willRetry: __willRetry, + retryDelay: __willRetry ? __retryDelay : (global::System.TimeSpan?)null, + retryReason: "exception", + cancellationToken: __effectiveCancellationToken)).ConfigureAwait(false); + if (!__willRetry) + { + throw; + } + + __httpRequest.Dispose(); + __httpRequest = null; + await global::Zep.AutoSDKRequestOptionsSupport.DelayBeforeRetryAsync( + retryDelay: __retryDelay, + cancellationToken: __effectiveCancellationToken).ConfigureAwait(false); + continue; + } + + if (__response != null && + __attempt < __maxAttempts && + global::Zep.AutoSDKRequestOptionsSupport.ShouldRetryStatusCode(__response.StatusCode)) + { + var __retryDelay = global::Zep.AutoSDKRequestOptionsSupport.GetRetryDelay( + clientOptions: Options, + requestOptions: requestOptions, + response: __response, + attempt: __attempt); + await global::Zep.AutoSDKRequestOptionsSupport.OnAfterErrorAsync( + clientOptions: Options, + context: global::Zep.AutoSDKRequestOptionsSupport.CreateHookContext( + operationId: "GetEpisodesForAThread", + methodName: "GetEpisodesForAThreadAsync", + pathTemplate: "$\"/threads/{threadId}/episodes\"", + httpMethod: "GET", + baseUri: BaseUri, + request: __httpRequest!, + response: __response, + exception: null, + clientOptions: Options, + requestOptions: requestOptions, + attempt: __attempt, + maxAttempts: __maxAttempts, + willRetry: true, + retryDelay: __retryDelay, + retryReason: "status:" + ((int)__response.StatusCode).ToString(global::System.Globalization.CultureInfo.InvariantCulture), + cancellationToken: __effectiveCancellationToken)).ConfigureAwait(false); + __response.Dispose(); + __response = null; + __httpRequest.Dispose(); + __httpRequest = null; + await global::Zep.AutoSDKRequestOptionsSupport.DelayBeforeRetryAsync( + retryDelay: __retryDelay, + cancellationToken: __effectiveCancellationToken).ConfigureAwait(false); + continue; + } + + break; + } + + if (__response == null) + { + throw new global::System.InvalidOperationException("No response received."); + } + + using (__response) + { + + ProcessResponse( + client: HttpClient, + response: __response); + ProcessGetEpisodesForAThreadResponse( + httpClient: HttpClient, + httpResponseMessage: __response); + if (__response.IsSuccessStatusCode) + { + await global::Zep.AutoSDKRequestOptionsSupport.OnAfterSuccessAsync( + clientOptions: Options, + context: global::Zep.AutoSDKRequestOptionsSupport.CreateHookContext( + operationId: "GetEpisodesForAThread", + methodName: "GetEpisodesForAThreadAsync", + pathTemplate: "$\"/threads/{threadId}/episodes\"", + httpMethod: "GET", + baseUri: BaseUri, + request: __httpRequest!, + response: __response, + exception: null, + clientOptions: Options, + requestOptions: requestOptions, + attempt: __attemptNumber, + maxAttempts: __maxAttempts, + willRetry: false, + retryDelay: null, + retryReason: global::System.String.Empty, + cancellationToken: __effectiveCancellationToken)).ConfigureAwait(false); + } + else + { + await global::Zep.AutoSDKRequestOptionsSupport.OnAfterErrorAsync( + clientOptions: Options, + context: global::Zep.AutoSDKRequestOptionsSupport.CreateHookContext( + operationId: "GetEpisodesForAThread", + methodName: "GetEpisodesForAThreadAsync", + pathTemplate: "$\"/threads/{threadId}/episodes\"", + httpMethod: "GET", + baseUri: BaseUri, + request: __httpRequest!, + response: __response, + exception: null, + clientOptions: Options, + requestOptions: requestOptions, + attempt: __attemptNumber, + maxAttempts: __maxAttempts, + willRetry: false, + retryDelay: null, + retryReason: global::System.String.Empty, + cancellationToken: __effectiveCancellationToken)).ConfigureAwait(false); + } + // Forbidden + if ((int)__response.StatusCode == 403) + { + string? __content_403 = null; + global::System.Exception? __exception_403 = null; + global::Zep.ApidataAPIError? __value_403 = null; + try + { + if (__effectiveReadResponseAsString) + { + __content_403 = await __response.Content.ReadAsStringAsync(__effectiveCancellationToken).ConfigureAwait(false); + __value_403 = global::Zep.ApidataAPIError.FromJson(__content_403, JsonSerializerContext); + } + else + { + __content_403 = await __response.Content.ReadAsStringAsync(__effectiveCancellationToken).ConfigureAwait(false); + + __value_403 = global::Zep.ApidataAPIError.FromJson(__content_403, JsonSerializerContext); + } + } + catch (global::System.Exception __ex) + { + __exception_403 = __ex; + } + + + throw global::Zep.ApiException.Create( + statusCode: __response.StatusCode, + message: __content_403 ?? __response.ReasonPhrase ?? string.Empty, + innerException: __exception_403, + responseBody: __content_403, + responseObject: __value_403, + responseHeaders: global::System.Linq.Enumerable.ToDictionary( + __response.Headers, + h => h.Key, + h => h.Value)); + } + // Not Found + if ((int)__response.StatusCode == 404) + { + string? __content_404 = null; + global::System.Exception? __exception_404 = null; + global::Zep.ApidataAPIError? __value_404 = null; + try + { + if (__effectiveReadResponseAsString) + { + __content_404 = await __response.Content.ReadAsStringAsync(__effectiveCancellationToken).ConfigureAwait(false); + __value_404 = global::Zep.ApidataAPIError.FromJson(__content_404, JsonSerializerContext); + } + else + { + __content_404 = await __response.Content.ReadAsStringAsync(__effectiveCancellationToken).ConfigureAwait(false); + + __value_404 = global::Zep.ApidataAPIError.FromJson(__content_404, JsonSerializerContext); + } + } + catch (global::System.Exception __ex) + { + __exception_404 = __ex; + } + + + throw global::Zep.ApiException.Create( + statusCode: __response.StatusCode, + message: __content_404 ?? __response.ReasonPhrase ?? string.Empty, + innerException: __exception_404, + responseBody: __content_404, + responseObject: __value_404, + responseHeaders: global::System.Linq.Enumerable.ToDictionary( + __response.Headers, + h => h.Key, + h => h.Value)); + } + // Internal Server Error + if ((int)__response.StatusCode == 500) + { + string? __content_500 = null; + global::System.Exception? __exception_500 = null; + global::Zep.ApidataAPIError? __value_500 = null; + try + { + if (__effectiveReadResponseAsString) + { + __content_500 = await __response.Content.ReadAsStringAsync(__effectiveCancellationToken).ConfigureAwait(false); + __value_500 = global::Zep.ApidataAPIError.FromJson(__content_500, JsonSerializerContext); + } + else + { + __content_500 = await __response.Content.ReadAsStringAsync(__effectiveCancellationToken).ConfigureAwait(false); + + __value_500 = global::Zep.ApidataAPIError.FromJson(__content_500, JsonSerializerContext); + } + } + catch (global::System.Exception __ex) + { + __exception_500 = __ex; + } + + + throw global::Zep.ApiException.Create( + statusCode: __response.StatusCode, + message: __content_500 ?? __response.ReasonPhrase ?? string.Empty, + innerException: __exception_500, + responseBody: __content_500, + responseObject: __value_500, + responseHeaders: global::System.Linq.Enumerable.ToDictionary( + __response.Headers, + h => h.Key, + h => h.Value)); + } + + if (__effectiveReadResponseAsString) + { + var __content = await __response.Content.ReadAsStringAsync( + #if NET5_0_OR_GREATER + __effectiveCancellationToken + #endif + ).ConfigureAwait(false); + + ProcessResponseContent( + client: HttpClient, + response: __response, + content: ref __content); + ProcessGetEpisodesForAThreadResponseContent( + httpClient: HttpClient, + httpResponseMessage: __response, + content: ref __content); + + try + { + __response.EnsureSuccessStatusCode(); + + var __value = global::Zep.ApidataGraphEpisodeResponse.FromJson(__content, JsonSerializerContext) ?? + throw new global::System.InvalidOperationException($"Response deserialization failed for \"{__content}\" "); + return new global::Zep.AutoSDKHttpResponse( + statusCode: __response.StatusCode, + headers: global::Zep.AutoSDKHttpResponse.CreateHeaders(__response), + requestUri: __response.RequestMessage?.RequestUri, + body: __value); + } + catch (global::System.Exception __ex) + { + throw global::Zep.ApiException.Create( + statusCode: __response.StatusCode, + message: __content ?? __response.ReasonPhrase ?? string.Empty, + innerException: __ex, + responseBody: __content, + responseHeaders: global::System.Linq.Enumerable.ToDictionary( + __response.Headers, + h => h.Key, + h => h.Value)); + } + } + else + { + try + { + __response.EnsureSuccessStatusCode(); + using var __content = await __response.Content.ReadAsStreamAsync( + #if NET5_0_OR_GREATER + __effectiveCancellationToken + #endif + ).ConfigureAwait(false); + + var __value = await global::Zep.ApidataGraphEpisodeResponse.FromJsonStreamAsync(__content, JsonSerializerContext).ConfigureAwait(false) ?? + throw new global::System.InvalidOperationException("Response deserialization failed."); + return new global::Zep.AutoSDKHttpResponse( + statusCode: __response.StatusCode, + headers: global::Zep.AutoSDKHttpResponse.CreateHeaders(__response), + requestUri: __response.RequestMessage?.RequestUri, + body: __value); + } + catch (global::System.Exception __ex) + { + string? __content = null; + try + { + __content = await __response.Content.ReadAsStringAsync( + #if NET5_0_OR_GREATER + __effectiveCancellationToken + #endif + ).ConfigureAwait(false); + } + catch (global::System.Exception) + { + } + + throw global::Zep.ApiException.Create( + statusCode: __response.StatusCode, + message: __content ?? __response.ReasonPhrase ?? string.Empty, + innerException: __ex, + responseBody: __content, + responseHeaders: global::System.Linq.Enumerable.ToDictionary( + __response.Headers, + h => h.Key, + h => h.Value)); + } + } + + } + } + finally + { + __httpRequest?.Dispose(); + } + } + } +} \ No newline at end of file diff --git a/src/libs/Zep/Generated/Zep.ThreadClient.GetMessagesOfAThread.g.cs b/src/libs/Zep/Generated/Zep.ThreadClient.GetMessagesOfAThread.g.cs index 93af454..80c145b 100644 --- a/src/libs/Zep/Generated/Zep.ThreadClient.GetMessagesOfAThread.g.cs +++ b/src/libs/Zep/Generated/Zep.ThreadClient.GetMessagesOfAThread.g.cs @@ -29,14 +29,14 @@ partial void PrepareGetMessagesOfAThreadArguments( global::System.Net.Http.HttpClient httpClient, ref string threadId, ref int? limit, - ref int? cursor, + ref long? cursor, ref int? lastn); partial void PrepareGetMessagesOfAThreadRequest( global::System.Net.Http.HttpClient httpClient, global::System.Net.Http.HttpRequestMessage httpRequestMessage, string threadId, int? limit, - int? cursor, + long? cursor, int? lastn); partial void ProcessGetMessagesOfAThreadResponse( global::System.Net.Http.HttpClient httpClient, @@ -61,7 +61,7 @@ partial void ProcessGetMessagesOfAThreadResponseContent( public async global::System.Threading.Tasks.Task GetMessagesOfAThreadAsync( string threadId, int? limit = default, - int? cursor = default, + long? cursor = default, int? lastn = default, global::Zep.AutoSDKRequestOptions? requestOptions = default, global::System.Threading.CancellationToken cancellationToken = default) @@ -91,7 +91,7 @@ partial void ProcessGetMessagesOfAThreadResponseContent( public async global::System.Threading.Tasks.Task> GetMessagesOfAThreadAsResponseAsync( string threadId, int? limit = default, - int? cursor = default, + long? cursor = default, int? lastn = default, global::Zep.AutoSDKRequestOptions? requestOptions = default, global::System.Threading.CancellationToken cancellationToken = default) diff --git a/src/libs/Zep/Generated/Zep.ZepClient.g.cs b/src/libs/Zep/Generated/Zep.ZepClient.g.cs index e980c2c..c497d5e 100644 --- a/src/libs/Zep/Generated/Zep.ZepClient.g.cs +++ b/src/libs/Zep/Generated/Zep.ZepClient.g.cs @@ -73,6 +73,24 @@ public sealed partial class ZepClient : global::Zep.IZepClient, global::System.I JsonSerializerContextProvider = JsonSerializerContextProvider, }; + /// + /// + /// + public DocumentClient Document => new DocumentClient(HttpClient, baseUri: null, authorizations: Authorizations, options: Options) + { + ReadResponseAsString = ReadResponseAsString, + JsonSerializerContextProvider = JsonSerializerContextProvider, + }; + + /// + /// + /// + public DocumentSummaryClient DocumentSummary => new DocumentSummaryClient(HttpClient, baseUri: null, authorizations: Authorizations, options: Options) + { + ReadResponseAsString = ReadResponseAsString, + JsonSerializerContextProvider = JsonSerializerContextProvider, + }; + /// /// /// diff --git a/src/libs/Zep/openapi.json b/src/libs/Zep/openapi.json index 9849b3c..5e901a6 100644 --- a/src/libs/Zep/openapi.json +++ b/src/libs/Zep/openapi.json @@ -283,7 +283,8 @@ "description": "Cursor for pagination", "required": false, "schema": { - "type": "integer" + "type": "integer", + "format": "int64" } }, { @@ -381,6 +382,69 @@ } } }, + "/threads/{threadId}/episodes": { + "get": { + "operationId": "get-episodes-for-a-thread", + "summary": "Get Episodes for a thread", + "description": "Returns graph episodes associated with a thread. Parallel to get_episodes_for_document for documents.", + "tags": [ + "thread" + ], + "parameters": [ + { + "name": "threadId", + "in": "path", + "description": "The ID of the thread", + "required": true, + "schema": { + "type": "string" + } + } + ], + "responses": { + "200": { + "description": "Episodes", + "content": { + "application/json": { + "schema": { + "$ref": "#/components/schemas/ApidataGraphEpisodeResponse" + } + } + } + }, + "403": { + "description": "Forbidden", + "content": { + "application/json": { + "schema": { + "$ref": "#/components/schemas/ApidataAPIError" + } + } + } + }, + "404": { + "description": "Not Found", + "content": { + "application/json": { + "schema": { + "$ref": "#/components/schemas/ApidataAPIError" + } + } + } + }, + "500": { + "description": "Internal Server Error", + "content": { + "application/json": { + "schema": { + "$ref": "#/components/schemas/ApidataAPIError" + } + } + } + } + } + } + }, "/threads/{threadId}/messages-batch": { "post": { "operationId": "add-messages-to-a-thread-in-batch", @@ -5387,6 +5451,154 @@ } } }, + "/graph/documents/{document_id}/episodes": { + "get": { + "operationId": "get-episodes-for-a-document", + "summary": "Get Episodes for a document", + "description": "Returns episodes associated with a document on a graph. Documents group episodes as chunks, parallel to how threads group messages.", + "tags": [ + "document" + ], + "parameters": [ + { + "name": "document_id", + "in": "path", + "description": "Document ID", + "required": true, + "schema": { + "type": "string" + } + }, + { + "name": "graph_id", + "in": "query", + "description": "Graph ID", + "required": true, + "schema": { + "type": "string" + } + } + ], + "responses": { + "200": { + "description": "Episodes", + "content": { + "application/json": { + "schema": { + "$ref": "#/components/schemas/ApidataGraphEpisodeResponse" + } + } + } + }, + "400": { + "description": "Bad Request", + "content": { + "application/json": { + "schema": { + "$ref": "#/components/schemas/ApidataAPIError" + } + } + } + }, + "404": { + "description": "Not Found", + "content": { + "application/json": { + "schema": { + "$ref": "#/components/schemas/ApidataAPIError" + } + } + } + }, + "500": { + "description": "Internal Server Error", + "content": { + "application/json": { + "schema": { + "$ref": "#/components/schemas/ApidataAPIError" + } + } + } + } + } + } + }, + "/graph/document-summary/graph/{graph_id}": { + "post": { + "operationId": "get-graph-document-summaries", + "summary": "Get Graph Document Summaries", + "description": "Returns incremental document summaries associated with the graph. Document summaries are derived similarly to thread summaries.", + "tags": [ + "document-summary" + ], + "parameters": [ + { + "name": "graph_id", + "in": "path", + "description": "Graph ID", + "required": true, + "schema": { + "type": "string" + } + } + ], + "responses": { + "200": { + "description": "Document summaries", + "content": { + "application/json": { + "schema": { + "type": "array", + "items": { + "$ref": "#/components/schemas/ApidataDocumentSummary" + } + } + } + } + }, + "400": { + "description": "Bad Request", + "content": { + "application/json": { + "schema": { + "$ref": "#/components/schemas/ApidataAPIError" + } + } + } + }, + "404": { + "description": "Not Found", + "content": { + "application/json": { + "schema": { + "$ref": "#/components/schemas/ApidataAPIError" + } + } + } + }, + "500": { + "description": "Internal Server Error", + "content": { + "application/json": { + "schema": { + "$ref": "#/components/schemas/ApidataAPIError" + } + } + } + } + }, + "requestBody": { + "description": "Pagination parameters", + "content": { + "application/json": { + "schema": { + "$ref": "#/components/schemas/ApidataGraphDocumentSummariesRequest" + } + } + } + } + } + }, "/projects/info": { "get": { "operationId": "retrieves-project-information", @@ -6439,6 +6651,97 @@ }, "title": "ApidataThreadMessageListResponse" }, + "ModelsGraphDataType": { + "type": "string", + "enum": [ + "text", + "json", + "message", + "fact_triple" + ], + "title": "ModelsGraphDataType" + }, + "ApidataGraphEpisode": { + "type": "object", + "properties": { + "content": { + "type": "string" + }, + "created_at": { + "type": "string" + }, + "document_id": { + "type": "string", + "description": "Optional document ID, will be present if the episode is part of a document" + }, + "metadata": { + "type": "object", + "additionalProperties": { + "description": "Any type" + } + }, + "processed": { + "type": "boolean" + }, + "relevance": { + "type": "number", + "format": "double", + "description": "Relevance is an experimental rank-aligned score in [0,1] derived from Score via logit transformation.\nOnly populated when using cross_encoder reranker; omitted for other reranker types (e.g., RRF)." + }, + "role": { + "type": "string", + "description": "Optional role, will only be present if the episode was created using memory.add API" + }, + "role_type": { + "$ref": "#/components/schemas/ApidataRoleType", + "description": "Optional role_type, will only be present if the episode was created using memory.add API" + }, + "score": { + "type": "number", + "format": "double", + "description": "Score is the reranker output: sigmoid-distributed logits [0,1] when using cross_encoder reranker, or RRF ordinal rank when using rrf reranker" + }, + "selection_rank": { + "type": "integer", + "description": "SelectionRank is the global cross-scope rank assigned by auto scope selection." + }, + "source": { + "$ref": "#/components/schemas/ModelsGraphDataType" + }, + "source_description": { + "type": "string" + }, + "task_id": { + "type": "string", + "description": "Optional task ID to poll episode processing status. Currently only available for batch ingestion." + }, + "thread_id": { + "type": "string", + "description": "Optional thread ID, will be present if the episode is part of a thread" + }, + "uuid": { + "type": "string" + } + }, + "required": [ + "content", + "created_at", + "uuid" + ], + "title": "ApidataGraphEpisode" + }, + "ApidataGraphEpisodeResponse": { + "type": "object", + "properties": { + "episodes": { + "type": "array", + "items": { + "$ref": "#/components/schemas/ApidataGraphEpisode" + } + } + }, + "title": "ApidataGraphEpisodeResponse" + }, "ApidataAddThreadMessagesRequest": { "type": "object", "properties": { @@ -6513,7 +6816,7 @@ }, "uuid": { "type": "string", - "description": "UUID of the thread summary node." + "description": "UUID of the derived thread summary node." } }, "title": "ApidataThreadSummary" @@ -7271,16 +7574,6 @@ }, "title": "ApidataEntityTypeResponse" }, - "ModelsGraphDataType": { - "type": "string", - "enum": [ - "text", - "json", - "message", - "fact_triple" - ], - "title": "ModelsGraphDataType" - }, "ApidataAddDataRequest": { "type": "object", "properties": { @@ -7290,6 +7583,10 @@ "data": { "type": "string" }, + "document_id": { + "type": "string", + "description": "Optional document ID that groups episodes as chunks of the same document\non a graph. Parallel to thread_id for message threads." + }, "graph_id": { "type": "string", "description": "graph_id is the ID of the graph to which the data will be added. If adding to the user graph, please use user_id field instead." @@ -7322,71 +7619,6 @@ ], "title": "ApidataAddDataRequest" }, - "ApidataGraphEpisode": { - "type": "object", - "properties": { - "content": { - "type": "string" - }, - "created_at": { - "type": "string" - }, - "metadata": { - "type": "object", - "additionalProperties": { - "description": "Any type" - } - }, - "processed": { - "type": "boolean" - }, - "relevance": { - "type": "number", - "format": "double", - "description": "Relevance is an experimental rank-aligned score in [0,1] derived from Score via logit transformation.\nOnly populated when using cross_encoder reranker; omitted for other reranker types (e.g., RRF)." - }, - "role": { - "type": "string", - "description": "Optional role, will only be present if the episode was created using memory.add API" - }, - "role_type": { - "$ref": "#/components/schemas/ApidataRoleType", - "description": "Optional role_type, will only be present if the episode was created using memory.add API" - }, - "score": { - "type": "number", - "format": "double", - "description": "Score is the reranker output: sigmoid-distributed logits [0,1] when using cross_encoder reranker, or RRF ordinal rank when using rrf reranker" - }, - "selection_rank": { - "type": "integer", - "description": "SelectionRank is the global cross-scope rank assigned by auto scope selection." - }, - "source": { - "$ref": "#/components/schemas/ModelsGraphDataType" - }, - "source_description": { - "type": "string" - }, - "task_id": { - "type": "string", - "description": "Optional task ID to poll episode processing status. Currently only available for batch ingestion." - }, - "thread_id": { - "type": "string", - "description": "Optional thread ID, will be present if the episode is part of a thread" - }, - "uuid": { - "type": "string" - } - }, - "required": [ - "content", - "created_at", - "uuid" - ], - "title": "ApidataGraphEpisode" - }, "ApidataEpisodeData": { "type": "object", "properties": { @@ -7419,6 +7651,10 @@ "ApidataAddDataBatchRequest": { "type": "object", "properties": { + "document_id": { + "type": "string", + "description": "Optional document ID applied to every episode in this batch request." + }, "episodes": { "type": "array", "items": { @@ -8696,18 +8932,6 @@ }, "title": "ApidataUpdateEdgeRequest" }, - "ApidataGraphEpisodeResponse": { - "type": "object", - "properties": { - "episodes": { - "type": "array", - "items": { - "$ref": "#/components/schemas/ApidataGraphEpisode" - } - } - }, - "title": "ApidataGraphEpisodeResponse" - }, "ApidataGraphEpisodeListRequest": { "type": "object", "properties": { @@ -9140,6 +9364,66 @@ }, "title": "ApidataGraphThreadSummariesRequest" }, + "ApidataGraphDocumentSummariesRequest": { + "type": "object", + "properties": { + "cursor": { + "type": "string", + "description": "Opaque cursor for pagination, obtained from the Zep-Next-Cursor response header\nof the previous page. Encodes the sort field, direction, and continuation position." + }, + "direction": { + "type": "string", + "description": "Sort direction. One of \"asc\" or \"desc\" (default \"desc\")." + }, + "filters": { + "$ref": "#/components/schemas/GraphitiSearchFilters", + "description": "Optional filters applied to the listed artifacts. Reuses the graph.search filter type." + }, + "limit": { + "type": "integer", + "description": "Maximum number of items to return" + }, + "order_by": { + "type": "string", + "description": "Field to sort by. One of \"created_at\", \"valid_at\", or \"uuid\" (default \"uuid\")." + }, + "uuid_cursor": { + "type": "string", + "description": "UUID based cursor, used for pagination. Should be the UUID of the last item in the previous page.\n\nDeprecated: prefer Cursor, the opaque cursor returned via the Zep-Next-Cursor response header." + } + }, + "title": "ApidataGraphDocumentSummariesRequest" + }, + "ApidataDocumentSummary": { + "type": "object", + "properties": { + "created_at": { + "type": "string", + "description": "CreatedAt is when the summary node was first created." + }, + "document_id": { + "type": "string", + "description": "DocumentID is the customer-facing document identifier." + }, + "last_summarized_at": { + "type": "string", + "description": "LastSummarizedAt is the wall-clock timestamp of the most recent\nsummary update." + }, + "last_summarized_episode_valid_at": { + "type": "string", + "description": "LastSummarizedEpisodeValidAt is the maximum episode reference time\n(valid_at) covered by the most recent summary." + }, + "summary": { + "type": "string", + "description": "Summary is the incremental summary content." + }, + "uuid": { + "type": "string", + "description": "UUID of the document summary (derived) node." + } + }, + "title": "ApidataDocumentSummary" + }, "ApidataProjectInfo": { "type": "object", "properties": { @@ -9418,6 +9702,10 @@ "data_type": { "$ref": "#/components/schemas/ModelsGraphDataType" }, + "document_id": { + "type": "string", + "description": "Optional document ID for graph_episode items. Groups episodes as document\nchunks. Ignored for thread_message items." + }, "graph_id": { "type": "string" }, @@ -9485,6 +9773,9 @@ "created_at": { "type": "string" }, + "document_id": { + "type": "string" + }, "episode_uuid": { "type": "string", "description": "EpisodeUUID is the UUID of the episode that will be (or has been) created\nfor this batch item. Populated for every item kind and always equal to\nSourceUUID \u2014 the underlying source row's UUID is reused as the episode\nUUID during processing."