From 81b9a7a395c918a78cc2d021d843eed084a6d188 Mon Sep 17 00:00:00 2001 From: "github-actions[bot]" Date: Fri, 21 Aug 2026 21:21:42 +0000 Subject: [PATCH] feat: Updated OpenAPI spec --- .../Zep.BatchClient.CreateBatch.g.cs | 5 + .../Zep.DataClient.AddDataInBatchMode.g.cs | 557 ------------------ ...p.EntityClient.GetEntityEdgesForANode.g.cs | 500 ---------------- .../Zep.EntityClient.GetEpisodesForANode.g.cs | 500 ---------------- ...nAnyNodesAndEdgesMentionedInAnEpisode.g.cs | 500 ---------------- .../Zep.IBatchClient.CreateBatch.g.cs | 4 + .../Zep.IDataClient.AddDataInBatchMode.g.cs | 65 -- ....IEntityClient.GetEntityEdgesForANode.g.cs | 32 - ...Zep.IEntityClient.GetEpisodesForANode.g.cs | 32 - ...nAnyNodesAndEdgesMentionedInAnEpisode.g.cs | 32 - ...eadClient.AddMessagesToAThreadInBatch.g.cs | 71 --- .../Zep.Models.ApidataBatchSummary.g.cs | 9 + .../Zep.Models.ApidataCreateBatchRequest.g.cs | 13 +- ...eadClient.AddMessagesToAThreadInBatch.g.cs | 531 ----------------- src/libs/Zep/openapi.json | 153 ++++- 15 files changed, 154 insertions(+), 2850 deletions(-) delete mode 100644 src/libs/Zep/Generated/Zep.DataClient.AddDataInBatchMode.g.cs delete mode 100644 src/libs/Zep/Generated/Zep.EntityClient.GetEntityEdgesForANode.g.cs delete mode 100644 src/libs/Zep/Generated/Zep.EntityClient.GetEpisodesForANode.g.cs delete mode 100644 src/libs/Zep/Generated/Zep.EpisodesClient.ReturnAnyNodesAndEdgesMentionedInAnEpisode.g.cs delete mode 100644 src/libs/Zep/Generated/Zep.IDataClient.AddDataInBatchMode.g.cs delete mode 100644 src/libs/Zep/Generated/Zep.IEntityClient.GetEntityEdgesForANode.g.cs delete mode 100644 src/libs/Zep/Generated/Zep.IEntityClient.GetEpisodesForANode.g.cs delete mode 100644 src/libs/Zep/Generated/Zep.IEpisodesClient.ReturnAnyNodesAndEdgesMentionedInAnEpisode.g.cs delete mode 100644 src/libs/Zep/Generated/Zep.IThreadClient.AddMessagesToAThreadInBatch.g.cs delete mode 100644 src/libs/Zep/Generated/Zep.ThreadClient.AddMessagesToAThreadInBatch.g.cs diff --git a/src/libs/Zep/Generated/Zep.BatchClient.CreateBatch.g.cs b/src/libs/Zep/Generated/Zep.BatchClient.CreateBatch.g.cs index 59598e8..2e5672f 100644 --- a/src/libs/Zep/Generated/Zep.BatchClient.CreateBatch.g.cs +++ b/src/libs/Zep/Generated/Zep.BatchClient.CreateBatch.g.cs @@ -555,12 +555,16 @@ partial void ProcessCreateBatchResponseContent( /// Has no effect on graph_episode items. /// /// + /// + /// When true, prevents extraction of generic Entity nodes that do not match the configured ontology. + /// /// 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 CreateBatchAsync( global::System.Collections.Generic.IList? ignoreRoles = default, object? metadata = default, + bool? strictOntology = default, global::Zep.AutoSDKRequestOptions? requestOptions = default, global::System.Threading.CancellationToken cancellationToken = default) { @@ -568,6 +572,7 @@ partial void ProcessCreateBatchResponseContent( { IgnoreRoles = ignoreRoles, Metadata = metadata, + StrictOntology = strictOntology, }; return await CreateBatchAsync( diff --git a/src/libs/Zep/Generated/Zep.DataClient.AddDataInBatchMode.g.cs b/src/libs/Zep/Generated/Zep.DataClient.AddDataInBatchMode.g.cs deleted file mode 100644 index c379e59..0000000 --- a/src/libs/Zep/Generated/Zep.DataClient.AddDataInBatchMode.g.cs +++ /dev/null @@ -1,557 +0,0 @@ - -#nullable enable - -namespace Zep -{ - public partial class DataClient - { - - - private static readonly global::Zep.EndPointSecurityRequirement s_AddDataInBatchModeSecurityRequirement0 = - 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_AddDataInBatchModeSecurityRequirements = - new global::Zep.EndPointSecurityRequirement[] - { s_AddDataInBatchModeSecurityRequirement0, - }; - partial void PrepareAddDataInBatchModeArguments( - global::System.Net.Http.HttpClient httpClient, - global::Zep.ApidataAddDataBatchRequest request); - partial void PrepareAddDataInBatchModeRequest( - global::System.Net.Http.HttpClient httpClient, - global::System.Net.Http.HttpRequestMessage httpRequestMessage, - global::Zep.ApidataAddDataBatchRequest request); - partial void ProcessAddDataInBatchModeResponse( - global::System.Net.Http.HttpClient httpClient, - global::System.Net.Http.HttpResponseMessage httpResponseMessage); - - partial void ProcessAddDataInBatchModeResponseContent( - global::System.Net.Http.HttpClient httpClient, - global::System.Net.Http.HttpResponseMessage httpResponseMessage, - ref string content); - - /// - /// Add Data in batch mode
- /// Deprecated. Use the [Batch API](/adding-batch-data) (`client.batch.*`) instead.
- /// Adds data to the graph in batch mode, processing episodes concurrently. - /// - /// - /// 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> AddDataInBatchModeAsync( - - global::Zep.ApidataAddDataBatchRequest request, - global::Zep.AutoSDKRequestOptions? requestOptions = default, - global::System.Threading.CancellationToken cancellationToken = default) - { - var __response = await AddDataInBatchModeAsResponseAsync( - - request: request, - requestOptions: requestOptions, - cancellationToken: cancellationToken - ).ConfigureAwait(false); - - return __response.Body; - } - /// - /// Add Data in batch mode
- /// Deprecated. Use the [Batch API](/adding-batch-data) (`client.batch.*`) instead.
- /// Adds data to the graph in batch mode, processing episodes concurrently. - /// - /// - /// 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>> AddDataInBatchModeAsResponseAsync( - - global::Zep.ApidataAddDataBatchRequest request, - global::Zep.AutoSDKRequestOptions? requestOptions = default, - global::System.Threading.CancellationToken cancellationToken = default) - { - request = request ?? throw new global::System.ArgumentNullException(nameof(request)); - - PrepareArguments( - client: HttpClient); - PrepareAddDataInBatchModeArguments( - httpClient: HttpClient, - request: request); - - - var __authorizations = global::Zep.EndPointSecurityResolver.ResolveAuthorizations( - availableAuthorizations: Authorizations, - securityRequirements: s_AddDataInBatchModeSecurityRequirements, - operationName: "AddDataInBatchModeAsync"); - - 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-batch", - 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); - PrepareAddDataInBatchModeRequest( - httpClient: HttpClient, - httpRequestMessage: __httpRequest, - 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: "AddDataInBatchMode", - methodName: "AddDataInBatchModeAsync", - pathTemplate: "\"/graph-batch\"", - 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: "AddDataInBatchMode", - methodName: "AddDataInBatchModeAsync", - pathTemplate: "\"/graph-batch\"", - 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: "AddDataInBatchMode", - methodName: "AddDataInBatchModeAsync", - pathTemplate: "\"/graph-batch\"", - 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); - ProcessAddDataInBatchModeResponse( - httpClient: HttpClient, - httpResponseMessage: __response); - if (__response.IsSuccessStatusCode) - { - await global::Zep.AutoSDKRequestOptionsSupport.OnAfterSuccessAsync( - clientOptions: Options, - context: global::Zep.AutoSDKRequestOptionsSupport.CreateHookContext( - operationId: "AddDataInBatchMode", - methodName: "AddDataInBatchModeAsync", - pathTemplate: "\"/graph-batch\"", - 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: "AddDataInBatchMode", - methodName: "AddDataInBatchModeAsync", - pathTemplate: "\"/graph-batch\"", - 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)); - } - // 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); - ProcessAddDataInBatchModeResponseContent( - 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(); - } - } - /// - /// Add Data in batch mode
- /// 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. - /// - /// - /// When true, prevents extraction of generic Entity nodes that do not match the configured ontology. - /// - /// - /// User ID is the ID of the user to which the data will be added. If not adding to a user graph, please use graph_id field instead. - /// - /// 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> AddDataInBatchModeAsync( - global::System.Collections.Generic.IList episodes, - string? documentId = default, - string? graphId = default, - bool? strictOntology = default, - string? userId = default, - global::Zep.AutoSDKRequestOptions? requestOptions = default, - global::System.Threading.CancellationToken cancellationToken = default) - { - var __request = new global::Zep.ApidataAddDataBatchRequest - { - DocumentId = documentId, - Episodes = episodes, - GraphId = graphId, - StrictOntology = strictOntology, - UserId = userId, - }; - - return await AddDataInBatchModeAsync( - request: __request, - requestOptions: requestOptions, - cancellationToken: cancellationToken).ConfigureAwait(false); - } - } -} \ No newline at end of file diff --git a/src/libs/Zep/Generated/Zep.EntityClient.GetEntityEdgesForANode.g.cs b/src/libs/Zep/Generated/Zep.EntityClient.GetEntityEdgesForANode.g.cs deleted file mode 100644 index 28fa943..0000000 --- a/src/libs/Zep/Generated/Zep.EntityClient.GetEntityEdgesForANode.g.cs +++ /dev/null @@ -1,500 +0,0 @@ - -#nullable enable - -namespace Zep -{ - public partial class EntityClient - { - - - private static readonly global::Zep.EndPointSecurityRequirement s_GetEntityEdgesForANodeSecurityRequirement0 = - 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_GetEntityEdgesForANodeSecurityRequirements = - new global::Zep.EndPointSecurityRequirement[] - { s_GetEntityEdgesForANodeSecurityRequirement0, - }; - partial void PrepareGetEntityEdgesForANodeArguments( - global::System.Net.Http.HttpClient httpClient, - ref string nodeUuid); - partial void PrepareGetEntityEdgesForANodeRequest( - global::System.Net.Http.HttpClient httpClient, - global::System.Net.Http.HttpRequestMessage httpRequestMessage, - string nodeUuid); - partial void ProcessGetEntityEdgesForANodeResponse( - global::System.Net.Http.HttpClient httpClient, - global::System.Net.Http.HttpResponseMessage httpResponseMessage); - - partial void ProcessGetEntityEdgesForANodeResponseContent( - global::System.Net.Http.HttpClient httpClient, - global::System.Net.Http.HttpResponseMessage httpResponseMessage, - ref string content); - - /// - /// Get Entity Edges for a node
- /// Deprecated. Use edge listing with `filters.connected_node_uuids`, or the neighbors endpoint (`POST /graph/node/{node_uuid}/neighbors`), instead. Returns all edges for a node, subject to an internal cap; responses reduced by that cap set the Zep-Truncated 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> GetEntityEdgesForANodeAsync( - string nodeUuid, - global::Zep.AutoSDKRequestOptions? requestOptions = default, - global::System.Threading.CancellationToken cancellationToken = default) - { - var __response = await GetEntityEdgesForANodeAsResponseAsync( - nodeUuid: nodeUuid, - requestOptions: requestOptions, - cancellationToken: cancellationToken - ).ConfigureAwait(false); - - return __response.Body; - } - /// - /// Get Entity Edges for a node
- /// Deprecated. Use edge listing with `filters.connected_node_uuids`, or the neighbors endpoint (`POST /graph/node/{node_uuid}/neighbors`), instead. Returns all edges for a node, subject to an internal cap; responses reduced by that cap set the Zep-Truncated 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>> GetEntityEdgesForANodeAsResponseAsync( - string nodeUuid, - global::Zep.AutoSDKRequestOptions? requestOptions = default, - global::System.Threading.CancellationToken cancellationToken = default) - { - PrepareArguments( - client: HttpClient); - PrepareGetEntityEdgesForANodeArguments( - httpClient: HttpClient, - nodeUuid: ref nodeUuid); - - - var __authorizations = global::Zep.EndPointSecurityResolver.ResolveAuthorizations( - availableAuthorizations: Authorizations, - securityRequirements: s_GetEntityEdgesForANodeSecurityRequirements, - operationName: "GetEntityEdgesForANodeAsync"); - - 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/node/{nodeUuid}/entity-edges", - 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); - PrepareGetEntityEdgesForANodeRequest( - httpClient: HttpClient, - httpRequestMessage: __httpRequest, - nodeUuid: nodeUuid!); - - 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: "GetEntityEdgesForANode", - methodName: "GetEntityEdgesForANodeAsync", - pathTemplate: "$\"/graph/node/{nodeUuid}/entity-edges\"", - 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: "GetEntityEdgesForANode", - methodName: "GetEntityEdgesForANodeAsync", - pathTemplate: "$\"/graph/node/{nodeUuid}/entity-edges\"", - 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: "GetEntityEdgesForANode", - methodName: "GetEntityEdgesForANodeAsync", - pathTemplate: "$\"/graph/node/{nodeUuid}/entity-edges\"", - 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); - ProcessGetEntityEdgesForANodeResponse( - httpClient: HttpClient, - httpResponseMessage: __response); - if (__response.IsSuccessStatusCode) - { - await global::Zep.AutoSDKRequestOptionsSupport.OnAfterSuccessAsync( - clientOptions: Options, - context: global::Zep.AutoSDKRequestOptionsSupport.CreateHookContext( - operationId: "GetEntityEdgesForANode", - methodName: "GetEntityEdgesForANodeAsync", - pathTemplate: "$\"/graph/node/{nodeUuid}/entity-edges\"", - 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: "GetEntityEdgesForANode", - methodName: "GetEntityEdgesForANodeAsync", - pathTemplate: "$\"/graph/node/{nodeUuid}/entity-edges\"", - 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)); - } - // 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); - ProcessGetEntityEdgesForANodeResponseContent( - 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(); - } - } - } -} \ No newline at end of file diff --git a/src/libs/Zep/Generated/Zep.EntityClient.GetEpisodesForANode.g.cs b/src/libs/Zep/Generated/Zep.EntityClient.GetEpisodesForANode.g.cs deleted file mode 100644 index 591d7b9..0000000 --- a/src/libs/Zep/Generated/Zep.EntityClient.GetEpisodesForANode.g.cs +++ /dev/null @@ -1,500 +0,0 @@ - -#nullable enable - -namespace Zep -{ - public partial class EntityClient - { - - - private static readonly global::Zep.EndPointSecurityRequirement s_GetEpisodesForANodeSecurityRequirement0 = - 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_GetEpisodesForANodeSecurityRequirements = - new global::Zep.EndPointSecurityRequirement[] - { s_GetEpisodesForANodeSecurityRequirement0, - }; - partial void PrepareGetEpisodesForANodeArguments( - global::System.Net.Http.HttpClient httpClient, - ref string nodeUuid); - partial void PrepareGetEpisodesForANodeRequest( - global::System.Net.Http.HttpClient httpClient, - global::System.Net.Http.HttpRequestMessage httpRequestMessage, - string nodeUuid); - partial void ProcessGetEpisodesForANodeResponse( - global::System.Net.Http.HttpClient httpClient, - global::System.Net.Http.HttpResponseMessage httpResponseMessage); - - partial void ProcessGetEpisodesForANodeResponseContent( - global::System.Net.Http.HttpClient httpClient, - global::System.Net.Http.HttpResponseMessage httpResponseMessage, - ref string content); - - /// - /// Get Episodes for a node
- /// Deprecated. Use episode listing with `mentioned_node_uuids` (`POST /graph/episodes/graph/{graph_id}` or `POST /graph/episodes/user/{user_id}`) instead. Returns episodes that mentioned a given node, subject to an internal cap; responses reduced by that cap set the Zep-Truncated 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 GetEpisodesForANodeAsync( - string nodeUuid, - global::Zep.AutoSDKRequestOptions? requestOptions = default, - global::System.Threading.CancellationToken cancellationToken = default) - { - var __response = await GetEpisodesForANodeAsResponseAsync( - nodeUuid: nodeUuid, - requestOptions: requestOptions, - cancellationToken: cancellationToken - ).ConfigureAwait(false); - - return __response.Body; - } - /// - /// Get Episodes for a node
- /// Deprecated. Use episode listing with `mentioned_node_uuids` (`POST /graph/episodes/graph/{graph_id}` or `POST /graph/episodes/user/{user_id}`) instead. Returns episodes that mentioned a given node, subject to an internal cap; responses reduced by that cap set the Zep-Truncated 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> GetEpisodesForANodeAsResponseAsync( - string nodeUuid, - global::Zep.AutoSDKRequestOptions? requestOptions = default, - global::System.Threading.CancellationToken cancellationToken = default) - { - PrepareArguments( - client: HttpClient); - PrepareGetEpisodesForANodeArguments( - httpClient: HttpClient, - nodeUuid: ref nodeUuid); - - - var __authorizations = global::Zep.EndPointSecurityResolver.ResolveAuthorizations( - availableAuthorizations: Authorizations, - securityRequirements: s_GetEpisodesForANodeSecurityRequirements, - operationName: "GetEpisodesForANodeAsync"); - - 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/node/{nodeUuid}/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); - PrepareGetEpisodesForANodeRequest( - httpClient: HttpClient, - httpRequestMessage: __httpRequest, - nodeUuid: nodeUuid!); - - 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: "GetEpisodesForANode", - methodName: "GetEpisodesForANodeAsync", - pathTemplate: "$\"/graph/node/{nodeUuid}/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: "GetEpisodesForANode", - methodName: "GetEpisodesForANodeAsync", - pathTemplate: "$\"/graph/node/{nodeUuid}/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: "GetEpisodesForANode", - methodName: "GetEpisodesForANodeAsync", - pathTemplate: "$\"/graph/node/{nodeUuid}/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); - ProcessGetEpisodesForANodeResponse( - httpClient: HttpClient, - httpResponseMessage: __response); - if (__response.IsSuccessStatusCode) - { - await global::Zep.AutoSDKRequestOptionsSupport.OnAfterSuccessAsync( - clientOptions: Options, - context: global::Zep.AutoSDKRequestOptionsSupport.CreateHookContext( - operationId: "GetEpisodesForANode", - methodName: "GetEpisodesForANodeAsync", - pathTemplate: "$\"/graph/node/{nodeUuid}/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: "GetEpisodesForANode", - methodName: "GetEpisodesForANodeAsync", - pathTemplate: "$\"/graph/node/{nodeUuid}/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)); - } - // 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); - ProcessGetEpisodesForANodeResponseContent( - 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.EpisodesClient.ReturnAnyNodesAndEdgesMentionedInAnEpisode.g.cs b/src/libs/Zep/Generated/Zep.EpisodesClient.ReturnAnyNodesAndEdgesMentionedInAnEpisode.g.cs deleted file mode 100644 index d667f18..0000000 --- a/src/libs/Zep/Generated/Zep.EpisodesClient.ReturnAnyNodesAndEdgesMentionedInAnEpisode.g.cs +++ /dev/null @@ -1,500 +0,0 @@ - -#nullable enable - -namespace Zep -{ - public partial class EpisodesClient - { - - - private static readonly global::Zep.EndPointSecurityRequirement s_ReturnAnyNodesAndEdgesMentionedInAnEpisodeSecurityRequirement0 = - 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_ReturnAnyNodesAndEdgesMentionedInAnEpisodeSecurityRequirements = - new global::Zep.EndPointSecurityRequirement[] - { s_ReturnAnyNodesAndEdgesMentionedInAnEpisodeSecurityRequirement0, - }; - partial void PrepareReturnAnyNodesAndEdgesMentionedInAnEpisodeArguments( - global::System.Net.Http.HttpClient httpClient, - ref string uuid); - partial void PrepareReturnAnyNodesAndEdgesMentionedInAnEpisodeRequest( - global::System.Net.Http.HttpClient httpClient, - global::System.Net.Http.HttpRequestMessage httpRequestMessage, - string uuid); - partial void ProcessReturnAnyNodesAndEdgesMentionedInAnEpisodeResponse( - global::System.Net.Http.HttpClient httpClient, - global::System.Net.Http.HttpResponseMessage httpResponseMessage); - - partial void ProcessReturnAnyNodesAndEdgesMentionedInAnEpisodeResponseContent( - global::System.Net.Http.HttpClient httpClient, - global::System.Net.Http.HttpResponseMessage httpResponseMessage, - ref string content); - - /// - /// Return any nodes and edges mentioned in an episode
- /// Deprecated. Use edge and node listing with `filters.episode_uuids` instead. Returns nodes and edges mentioned in an episode, subject to an internal cap; responses reduced by that cap set the Zep-Truncated 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 ReturnAnyNodesAndEdgesMentionedInAnEpisodeAsync( - string uuid, - global::Zep.AutoSDKRequestOptions? requestOptions = default, - global::System.Threading.CancellationToken cancellationToken = default) - { - var __response = await ReturnAnyNodesAndEdgesMentionedInAnEpisodeAsResponseAsync( - uuid: uuid, - requestOptions: requestOptions, - cancellationToken: cancellationToken - ).ConfigureAwait(false); - - return __response.Body; - } - /// - /// Return any nodes and edges mentioned in an episode
- /// Deprecated. Use edge and node listing with `filters.episode_uuids` instead. Returns nodes and edges mentioned in an episode, subject to an internal cap; responses reduced by that cap set the Zep-Truncated 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> ReturnAnyNodesAndEdgesMentionedInAnEpisodeAsResponseAsync( - string uuid, - global::Zep.AutoSDKRequestOptions? requestOptions = default, - global::System.Threading.CancellationToken cancellationToken = default) - { - PrepareArguments( - client: HttpClient); - PrepareReturnAnyNodesAndEdgesMentionedInAnEpisodeArguments( - httpClient: HttpClient, - uuid: ref uuid); - - - var __authorizations = global::Zep.EndPointSecurityResolver.ResolveAuthorizations( - availableAuthorizations: Authorizations, - securityRequirements: s_ReturnAnyNodesAndEdgesMentionedInAnEpisodeSecurityRequirements, - operationName: "ReturnAnyNodesAndEdgesMentionedInAnEpisodeAsync"); - - 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/episodes/{uuid}/mentions", - 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); - PrepareReturnAnyNodesAndEdgesMentionedInAnEpisodeRequest( - httpClient: HttpClient, - httpRequestMessage: __httpRequest, - uuid: uuid!); - - 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: "ReturnAnyNodesAndEdgesMentionedInAnEpisode", - methodName: "ReturnAnyNodesAndEdgesMentionedInAnEpisodeAsync", - pathTemplate: "$\"/graph/episodes/{uuid}/mentions\"", - 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: "ReturnAnyNodesAndEdgesMentionedInAnEpisode", - methodName: "ReturnAnyNodesAndEdgesMentionedInAnEpisodeAsync", - pathTemplate: "$\"/graph/episodes/{uuid}/mentions\"", - 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: "ReturnAnyNodesAndEdgesMentionedInAnEpisode", - methodName: "ReturnAnyNodesAndEdgesMentionedInAnEpisodeAsync", - pathTemplate: "$\"/graph/episodes/{uuid}/mentions\"", - 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); - ProcessReturnAnyNodesAndEdgesMentionedInAnEpisodeResponse( - httpClient: HttpClient, - httpResponseMessage: __response); - if (__response.IsSuccessStatusCode) - { - await global::Zep.AutoSDKRequestOptionsSupport.OnAfterSuccessAsync( - clientOptions: Options, - context: global::Zep.AutoSDKRequestOptionsSupport.CreateHookContext( - operationId: "ReturnAnyNodesAndEdgesMentionedInAnEpisode", - methodName: "ReturnAnyNodesAndEdgesMentionedInAnEpisodeAsync", - pathTemplate: "$\"/graph/episodes/{uuid}/mentions\"", - 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: "ReturnAnyNodesAndEdgesMentionedInAnEpisode", - methodName: "ReturnAnyNodesAndEdgesMentionedInAnEpisodeAsync", - pathTemplate: "$\"/graph/episodes/{uuid}/mentions\"", - 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)); - } - // 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); - ProcessReturnAnyNodesAndEdgesMentionedInAnEpisodeResponseContent( - httpClient: HttpClient, - httpResponseMessage: __response, - content: ref __content); - - try - { - __response.EnsureSuccessStatusCode(); - - var __value = global::Zep.ApidataEpisodeMentions.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.ApidataEpisodeMentions.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.IBatchClient.CreateBatch.g.cs b/src/libs/Zep/Generated/Zep.IBatchClient.CreateBatch.g.cs index 50c5af9..c8057a7 100644 --- a/src/libs/Zep/Generated/Zep.IBatchClient.CreateBatch.g.cs +++ b/src/libs/Zep/Generated/Zep.IBatchClient.CreateBatch.g.cs @@ -41,12 +41,16 @@ public partial interface IBatchClient /// Has no effect on graph_episode items. /// /// + /// + /// When true, prevents extraction of generic Entity nodes that do not match the configured ontology. + /// /// 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 CreateBatchAsync( global::System.Collections.Generic.IList? ignoreRoles = default, object? metadata = default, + bool? strictOntology = default, global::Zep.AutoSDKRequestOptions? requestOptions = default, global::System.Threading.CancellationToken cancellationToken = default); } diff --git a/src/libs/Zep/Generated/Zep.IDataClient.AddDataInBatchMode.g.cs b/src/libs/Zep/Generated/Zep.IDataClient.AddDataInBatchMode.g.cs deleted file mode 100644 index 1a5c804..0000000 --- a/src/libs/Zep/Generated/Zep.IDataClient.AddDataInBatchMode.g.cs +++ /dev/null @@ -1,65 +0,0 @@ -#nullable enable - -namespace Zep -{ - public partial interface IDataClient - { - /// - /// Add Data in batch mode
- /// Deprecated. Use the [Batch API](/adding-batch-data) (`client.batch.*`) instead.
- /// Adds data to the graph in batch mode, processing episodes concurrently. - /// - /// - /// 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> AddDataInBatchModeAsync( - - global::Zep.ApidataAddDataBatchRequest request, - global::Zep.AutoSDKRequestOptions? requestOptions = default, - global::System.Threading.CancellationToken cancellationToken = default); - /// - /// Add Data in batch mode
- /// Deprecated. Use the [Batch API](/adding-batch-data) (`client.batch.*`) instead.
- /// Adds data to the graph in batch mode, processing episodes concurrently. - /// - /// - /// 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>> AddDataInBatchModeAsResponseAsync( - - global::Zep.ApidataAddDataBatchRequest request, - global::Zep.AutoSDKRequestOptions? requestOptions = default, - global::System.Threading.CancellationToken cancellationToken = default); - /// - /// Add Data in batch mode
- /// 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. - /// - /// - /// When true, prevents extraction of generic Entity nodes that do not match the configured ontology. - /// - /// - /// User ID is the ID of the user to which the data will be added. If not adding to a user graph, please use graph_id field instead. - /// - /// 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> AddDataInBatchModeAsync( - global::System.Collections.Generic.IList episodes, - string? documentId = default, - string? graphId = default, - bool? strictOntology = default, - string? userId = 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.IEntityClient.GetEntityEdgesForANode.g.cs b/src/libs/Zep/Generated/Zep.IEntityClient.GetEntityEdgesForANode.g.cs deleted file mode 100644 index 09e9b2d..0000000 --- a/src/libs/Zep/Generated/Zep.IEntityClient.GetEntityEdgesForANode.g.cs +++ /dev/null @@ -1,32 +0,0 @@ -#nullable enable - -namespace Zep -{ - public partial interface IEntityClient - { - /// - /// Get Entity Edges for a node
- /// Deprecated. Use edge listing with `filters.connected_node_uuids`, or the neighbors endpoint (`POST /graph/node/{node_uuid}/neighbors`), instead. Returns all edges for a node, subject to an internal cap; responses reduced by that cap set the Zep-Truncated 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> GetEntityEdgesForANodeAsync( - string nodeUuid, - global::Zep.AutoSDKRequestOptions? requestOptions = default, - global::System.Threading.CancellationToken cancellationToken = default); - /// - /// Get Entity Edges for a node
- /// Deprecated. Use edge listing with `filters.connected_node_uuids`, or the neighbors endpoint (`POST /graph/node/{node_uuid}/neighbors`), instead. Returns all edges for a node, subject to an internal cap; responses reduced by that cap set the Zep-Truncated 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>> GetEntityEdgesForANodeAsResponseAsync( - string nodeUuid, - 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.IEntityClient.GetEpisodesForANode.g.cs b/src/libs/Zep/Generated/Zep.IEntityClient.GetEpisodesForANode.g.cs deleted file mode 100644 index 5e7826b..0000000 --- a/src/libs/Zep/Generated/Zep.IEntityClient.GetEpisodesForANode.g.cs +++ /dev/null @@ -1,32 +0,0 @@ -#nullable enable - -namespace Zep -{ - public partial interface IEntityClient - { - /// - /// Get Episodes for a node
- /// Deprecated. Use episode listing with `mentioned_node_uuids` (`POST /graph/episodes/graph/{graph_id}` or `POST /graph/episodes/user/{user_id}`) instead. Returns episodes that mentioned a given node, subject to an internal cap; responses reduced by that cap set the Zep-Truncated 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 GetEpisodesForANodeAsync( - string nodeUuid, - global::Zep.AutoSDKRequestOptions? requestOptions = default, - global::System.Threading.CancellationToken cancellationToken = default); - /// - /// Get Episodes for a node
- /// Deprecated. Use episode listing with `mentioned_node_uuids` (`POST /graph/episodes/graph/{graph_id}` or `POST /graph/episodes/user/{user_id}`) instead. Returns episodes that mentioned a given node, subject to an internal cap; responses reduced by that cap set the Zep-Truncated 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> GetEpisodesForANodeAsResponseAsync( - string nodeUuid, - 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.IEpisodesClient.ReturnAnyNodesAndEdgesMentionedInAnEpisode.g.cs b/src/libs/Zep/Generated/Zep.IEpisodesClient.ReturnAnyNodesAndEdgesMentionedInAnEpisode.g.cs deleted file mode 100644 index 2b5ee3f..0000000 --- a/src/libs/Zep/Generated/Zep.IEpisodesClient.ReturnAnyNodesAndEdgesMentionedInAnEpisode.g.cs +++ /dev/null @@ -1,32 +0,0 @@ -#nullable enable - -namespace Zep -{ - public partial interface IEpisodesClient - { - /// - /// Return any nodes and edges mentioned in an episode
- /// Deprecated. Use edge and node listing with `filters.episode_uuids` instead. Returns nodes and edges mentioned in an episode, subject to an internal cap; responses reduced by that cap set the Zep-Truncated 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 ReturnAnyNodesAndEdgesMentionedInAnEpisodeAsync( - string uuid, - global::Zep.AutoSDKRequestOptions? requestOptions = default, - global::System.Threading.CancellationToken cancellationToken = default); - /// - /// Return any nodes and edges mentioned in an episode
- /// Deprecated. Use edge and node listing with `filters.episode_uuids` instead. Returns nodes and edges mentioned in an episode, subject to an internal cap; responses reduced by that cap set the Zep-Truncated 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> ReturnAnyNodesAndEdgesMentionedInAnEpisodeAsResponseAsync( - string uuid, - 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.AddMessagesToAThreadInBatch.g.cs b/src/libs/Zep/Generated/Zep.IThreadClient.AddMessagesToAThreadInBatch.g.cs deleted file mode 100644 index f5c99d8..0000000 --- a/src/libs/Zep/Generated/Zep.IThreadClient.AddMessagesToAThreadInBatch.g.cs +++ /dev/null @@ -1,71 +0,0 @@ -#nullable enable - -namespace Zep -{ - public partial interface IThreadClient - { - /// - /// Add messages to a thread in batch
- /// Deprecated. Use the [Batch API](/adding-batch-data) (`client.batch.*` with `type: "thread_message"`) instead.
- /// Adds messages to a thread in batch mode, processing messages concurrently. - /// - /// - /// - /// 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 AddMessagesToAThreadInBatchAsync( - string threadId, - - global::Zep.ApidataAddThreadMessagesRequest request, - global::Zep.AutoSDKRequestOptions? requestOptions = default, - global::System.Threading.CancellationToken cancellationToken = default); - /// - /// Add messages to a thread in batch
- /// Deprecated. Use the [Batch API](/adding-batch-data) (`client.batch.*` with `type: "thread_message"`) instead.
- /// Adds messages to a thread in batch mode, processing messages concurrently. - /// - /// - /// - /// 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> AddMessagesToAThreadInBatchAsResponseAsync( - string threadId, - - global::Zep.ApidataAddThreadMessagesRequest request, - global::Zep.AutoSDKRequestOptions? requestOptions = default, - global::System.Threading.CancellationToken cancellationToken = default); - /// - /// Add messages to a thread in batch
- /// Deprecated. Use the [Batch API](/adding-batch-data) (`client.batch.*` with `type: "thread_message"`) instead.
- /// Adds messages to a thread in batch mode, processing messages concurrently. - /// - /// - /// - /// Optional list of role types to ignore when adding messages to graph memory.
- /// The message itself will still be added, retained and used as context for messages
- /// that are added to a user's graph. - /// - /// - /// A list of message objects, where each message contains a role and content. - /// - /// - /// Optionally return context block relevant to the most recent messages. - /// - /// - /// When true, prevents extraction of generic Entity nodes that do not match the configured ontology. - /// - /// 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 AddMessagesToAThreadInBatchAsync( - string threadId, - global::System.Collections.Generic.IList messages, - global::System.Collections.Generic.IList? ignoreRoles = default, - bool? returnContext = default, - bool? strictOntology = 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.Models.ApidataBatchSummary.g.cs b/src/libs/Zep/Generated/Zep.Models.ApidataBatchSummary.g.cs index c3d9e2a..bf65332 100644 --- a/src/libs/Zep/Generated/Zep.Models.ApidataBatchSummary.g.cs +++ b/src/libs/Zep/Generated/Zep.Models.ApidataBatchSummary.g.cs @@ -63,6 +63,12 @@ public sealed partial class ApidataBatchSummary [global::System.Text.Json.Serialization.JsonConverter(typeof(global::Zep.JsonConverters.ModelsBatchStatusJsonConverter))] public global::Zep.ModelsBatchStatus? Status { get; set; } + /// + /// + /// + [global::System.Text.Json.Serialization.JsonPropertyName("strict_ontology")] + public bool? StrictOntology { get; set; } + /// /// /// @@ -87,6 +93,7 @@ public sealed partial class ApidataBatchSummary /// /// /// + /// /// #if NET7_0_OR_GREATER [global::System.Diagnostics.CodeAnalysis.SetsRequiredMembers] @@ -101,6 +108,7 @@ public ApidataBatchSummary( string? processedAt, global::Zep.ApidataBatchProgress? progress, global::Zep.ModelsBatchStatus? status, + bool? strictOntology, string? updatedAt) { this.BatchId = batchId; @@ -112,6 +120,7 @@ public ApidataBatchSummary( this.ProcessedAt = processedAt; this.Progress = progress; this.Status = status; + this.StrictOntology = strictOntology; this.UpdatedAt = updatedAt; } diff --git a/src/libs/Zep/Generated/Zep.Models.ApidataCreateBatchRequest.g.cs b/src/libs/Zep/Generated/Zep.Models.ApidataCreateBatchRequest.g.cs index e475b03..d35c140 100644 --- a/src/libs/Zep/Generated/Zep.Models.ApidataCreateBatchRequest.g.cs +++ b/src/libs/Zep/Generated/Zep.Models.ApidataCreateBatchRequest.g.cs @@ -23,6 +23,12 @@ public sealed partial class ApidataCreateBatchRequest [global::System.Text.Json.Serialization.JsonPropertyName("metadata")] public object? Metadata { get; set; } + /// + /// When true, prevents extraction of generic Entity nodes that do not match the configured ontology. + /// + [global::System.Text.Json.Serialization.JsonPropertyName("strict_ontology")] + public bool? StrictOntology { get; set; } + /// /// Additional properties that are not explicitly defined in the schema /// @@ -39,15 +45,20 @@ public sealed partial class ApidataCreateBatchRequest /// Has no effect on graph_episode items. /// /// + /// + /// When true, prevents extraction of generic Entity nodes that do not match the configured ontology. + /// #if NET7_0_OR_GREATER [global::System.Diagnostics.CodeAnalysis.SetsRequiredMembers] #endif public ApidataCreateBatchRequest( global::System.Collections.Generic.IList? ignoreRoles, - object? metadata) + object? metadata, + bool? strictOntology) { this.IgnoreRoles = ignoreRoles; this.Metadata = metadata; + this.StrictOntology = strictOntology; } /// diff --git a/src/libs/Zep/Generated/Zep.ThreadClient.AddMessagesToAThreadInBatch.g.cs b/src/libs/Zep/Generated/Zep.ThreadClient.AddMessagesToAThreadInBatch.g.cs deleted file mode 100644 index da873a9..0000000 --- a/src/libs/Zep/Generated/Zep.ThreadClient.AddMessagesToAThreadInBatch.g.cs +++ /dev/null @@ -1,531 +0,0 @@ - -#nullable enable - -namespace Zep -{ - public partial class ThreadClient - { - - - private static readonly global::Zep.EndPointSecurityRequirement s_AddMessagesToAThreadInBatchSecurityRequirement0 = - 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_AddMessagesToAThreadInBatchSecurityRequirements = - new global::Zep.EndPointSecurityRequirement[] - { s_AddMessagesToAThreadInBatchSecurityRequirement0, - }; - partial void PrepareAddMessagesToAThreadInBatchArguments( - global::System.Net.Http.HttpClient httpClient, - ref string threadId, - global::Zep.ApidataAddThreadMessagesRequest request); - partial void PrepareAddMessagesToAThreadInBatchRequest( - global::System.Net.Http.HttpClient httpClient, - global::System.Net.Http.HttpRequestMessage httpRequestMessage, - string threadId, - global::Zep.ApidataAddThreadMessagesRequest request); - partial void ProcessAddMessagesToAThreadInBatchResponse( - global::System.Net.Http.HttpClient httpClient, - global::System.Net.Http.HttpResponseMessage httpResponseMessage); - - partial void ProcessAddMessagesToAThreadInBatchResponseContent( - global::System.Net.Http.HttpClient httpClient, - global::System.Net.Http.HttpResponseMessage httpResponseMessage, - ref string content); - - /// - /// Add messages to a thread in batch
- /// Deprecated. Use the [Batch API](/adding-batch-data) (`client.batch.*` with `type: "thread_message"`) instead.
- /// Adds messages to a thread in batch mode, processing messages concurrently. - /// - /// - /// - /// 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 AddMessagesToAThreadInBatchAsync( - string threadId, - - global::Zep.ApidataAddThreadMessagesRequest request, - global::Zep.AutoSDKRequestOptions? requestOptions = default, - global::System.Threading.CancellationToken cancellationToken = default) - { - var __response = await AddMessagesToAThreadInBatchAsResponseAsync( - threadId: threadId, - - request: request, - requestOptions: requestOptions, - cancellationToken: cancellationToken - ).ConfigureAwait(false); - - return __response.Body; - } - /// - /// Add messages to a thread in batch
- /// Deprecated. Use the [Batch API](/adding-batch-data) (`client.batch.*` with `type: "thread_message"`) instead.
- /// Adds messages to a thread in batch mode, processing messages concurrently. - /// - /// - /// - /// 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> AddMessagesToAThreadInBatchAsResponseAsync( - string threadId, - - global::Zep.ApidataAddThreadMessagesRequest request, - global::Zep.AutoSDKRequestOptions? requestOptions = default, - global::System.Threading.CancellationToken cancellationToken = default) - { - request = request ?? throw new global::System.ArgumentNullException(nameof(request)); - - PrepareArguments( - client: HttpClient); - PrepareAddMessagesToAThreadInBatchArguments( - httpClient: HttpClient, - threadId: ref threadId, - request: request); - - - var __authorizations = global::Zep.EndPointSecurityResolver.ResolveAuthorizations( - availableAuthorizations: Authorizations, - securityRequirements: s_AddMessagesToAThreadInBatchSecurityRequirements, - operationName: "AddMessagesToAThreadInBatchAsync"); - - 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}/messages-batch", - 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); - PrepareAddMessagesToAThreadInBatchRequest( - httpClient: HttpClient, - httpRequestMessage: __httpRequest, - threadId: threadId!, - 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: "AddMessagesToAThreadInBatch", - methodName: "AddMessagesToAThreadInBatchAsync", - pathTemplate: "$\"/threads/{threadId}/messages-batch\"", - 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: "AddMessagesToAThreadInBatch", - methodName: "AddMessagesToAThreadInBatchAsync", - pathTemplate: "$\"/threads/{threadId}/messages-batch\"", - 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: "AddMessagesToAThreadInBatch", - methodName: "AddMessagesToAThreadInBatchAsync", - pathTemplate: "$\"/threads/{threadId}/messages-batch\"", - 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); - ProcessAddMessagesToAThreadInBatchResponse( - httpClient: HttpClient, - httpResponseMessage: __response); - if (__response.IsSuccessStatusCode) - { - await global::Zep.AutoSDKRequestOptionsSupport.OnAfterSuccessAsync( - clientOptions: Options, - context: global::Zep.AutoSDKRequestOptionsSupport.CreateHookContext( - operationId: "AddMessagesToAThreadInBatch", - methodName: "AddMessagesToAThreadInBatchAsync", - pathTemplate: "$\"/threads/{threadId}/messages-batch\"", - 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: "AddMessagesToAThreadInBatch", - methodName: "AddMessagesToAThreadInBatchAsync", - pathTemplate: "$\"/threads/{threadId}/messages-batch\"", - 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); - } - // 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); - ProcessAddMessagesToAThreadInBatchResponseContent( - httpClient: HttpClient, - httpResponseMessage: __response, - content: ref __content); - - try - { - __response.EnsureSuccessStatusCode(); - - var __value = global::Zep.ApidataAddThreadMessagesResponse.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.ApidataAddThreadMessagesResponse.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(); - } - } - /// - /// Add messages to a thread in batch
- /// Deprecated. Use the [Batch API](/adding-batch-data) (`client.batch.*` with `type: "thread_message"`) instead.
- /// Adds messages to a thread in batch mode, processing messages concurrently. - /// - /// - /// - /// Optional list of role types to ignore when adding messages to graph memory.
- /// The message itself will still be added, retained and used as context for messages
- /// that are added to a user's graph. - /// - /// - /// A list of message objects, where each message contains a role and content. - /// - /// - /// Optionally return context block relevant to the most recent messages. - /// - /// - /// When true, prevents extraction of generic Entity nodes that do not match the configured ontology. - /// - /// 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 AddMessagesToAThreadInBatchAsync( - string threadId, - global::System.Collections.Generic.IList messages, - global::System.Collections.Generic.IList? ignoreRoles = default, - bool? returnContext = default, - bool? strictOntology = default, - global::Zep.AutoSDKRequestOptions? requestOptions = default, - global::System.Threading.CancellationToken cancellationToken = default) - { - var __request = new global::Zep.ApidataAddThreadMessagesRequest - { - IgnoreRoles = ignoreRoles, - Messages = messages, - ReturnContext = returnContext, - StrictOntology = strictOntology, - }; - - return await AddMessagesToAThreadInBatchAsync( - threadId: threadId, - request: __request, - requestOptions: requestOptions, - cancellationToken: cancellationToken).ConfigureAwait(false); - } - } -} \ No newline at end of file diff --git a/src/libs/Zep/openapi.json b/src/libs/Zep/openapi.json index 0e2ba34..229c6c6 100644 --- a/src/libs/Zep/openapi.json +++ b/src/libs/Zep/openapi.json @@ -486,6 +486,7 @@ } } }, + "deprecated": true, "requestBody": { "description": "An object representing the thread messages to be added.", "content": { @@ -566,9 +567,6 @@ "operationId": "updates-a-message", "summary": "Updates a message.", "description": "Updates a message.", - "tags": [ - "" - ], "parameters": [ { "name": "messageUUID", @@ -2810,6 +2808,7 @@ } } }, + "deprecated": true, "requestBody": { "description": "Add data request", "content": { @@ -3002,7 +3001,9 @@ "description": "Number of graphs to retrieve per page (default 50, range 1-100; explicit 0 is invalid).", "required": false, "schema": { - "type": "integer" + "type": "integer", + "minimum": 1, + "maximum": 100 } }, { @@ -4325,7 +4326,8 @@ } } } - } + }, + "deprecated": true } }, "/graph/nodes": { @@ -4565,7 +4567,8 @@ } } } - } + }, + "deprecated": true } }, "/graph/node/{node_uuid}/episodes": { @@ -4618,7 +4621,8 @@ } } } - } + }, + "deprecated": true } }, "/graph/node/{node_uuid}/neighbors": { @@ -6533,6 +6537,7 @@ "properties": { "thread_id": { "type": "string", + "maxLength": 500, "description": "The unique identifier of the thread." }, "user_id": { @@ -6871,6 +6876,7 @@ }, "user_id": { "type": "string", + "maxLength": 500, "description": "The unique identifier of the user." } }, @@ -7059,10 +7065,13 @@ "type": "object", "properties": { "name": { - "type": "string" + "type": "string", + "maxLength": 100 }, "text": { - "type": "string" + "type": "string", + "minLength": 1, + "maxLength": 100 } }, "required": [ @@ -7216,10 +7225,13 @@ "type": "object", "properties": { "description": { - "type": "string" + "type": "string", + "maxLength": 4096 }, "name": { - "type": "string" + "type": "string", + "minLength": 1, + "maxLength": 128 } }, "required": [ @@ -7279,13 +7291,17 @@ "type": "object", "properties": { "description": { - "type": "string" + "type": "string", + "maxLength": 4096 }, "expected_version": { - "type": "integer" + "type": "integer", + "minimum": 1 }, "name": { - "type": "string" + "type": "string", + "minLength": 1, + "maxLength": 128 } }, "required": [ @@ -7388,10 +7404,13 @@ "properties": { "template": { "type": "string", + "minLength": 1, + "maxLength": 1200, "description": "The template content (max 1200 characters)." }, "template_id": { "type": "string", + "maxLength": 100, "description": "Unique identifier for the template (max 100 characters)." } }, @@ -7424,6 +7443,8 @@ "properties": { "template": { "type": "string", + "minLength": 1, + "maxLength": 1200, "description": "The template content (max 1200 characters)." } }, @@ -7470,7 +7491,8 @@ "type": "object", "properties": { "description": { - "type": "string" + "type": "string", + "maxLength": 500 }, "name": { "type": "string" @@ -7504,7 +7526,8 @@ "type": "object", "properties": { "description": { - "type": "string" + "type": "string", + "maxLength": 500 }, "name": { "type": "string" @@ -7532,7 +7555,8 @@ "type": "object", "properties": { "description": { - "type": "string" + "type": "string", + "maxLength": 500 }, "identity_properties": { "type": "array", @@ -7585,6 +7609,8 @@ }, "document_id": { "type": "string", + "minLength": 1, + "maxLength": 100, "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": { @@ -7599,7 +7625,8 @@ "description": "Optional metadata key-value pairs. Max 10 keys. Values must be strings, numbers, booleans, or arrays of scalars." }, "source_description": { - "type": "string" + "type": "string", + "maxLength": 500 }, "strict_ontology": { "type": "boolean", @@ -7636,7 +7663,8 @@ "description": "Optional metadata key-value pairs. Max 10 keys. Values must be strings, numbers, booleans, or arrays of scalars." }, "source_description": { - "type": "string" + "type": "string", + "maxLength": 500 }, "type": { "$ref": "#/components/schemas/ModelsGraphDataType" @@ -7653,6 +7681,8 @@ "properties": { "document_id": { "type": "string", + "minLength": 1, + "maxLength": 100, "description": "Optional document ID applied to every episode in this batch request." }, "episodes": { @@ -7699,10 +7729,13 @@ }, "fact": { "type": "string", + "maxLength": 250, "description": "The fact relating the two nodes that this edge represents" }, "fact_name": { "type": "string", + "minLength": 1, + "maxLength": 50, "description": "The name of the edge to add. Should be all caps using snake case (eg RELATES_TO)" }, "graph_id": { @@ -7735,10 +7768,12 @@ }, "source_node_name": { "type": "string", + "maxLength": 50, "description": "The name of the source node to add" }, "source_node_summary": { "type": "string", + "maxLength": 500, "description": "The summary of the source node to add" }, "source_node_uuid": { @@ -7761,10 +7796,12 @@ }, "target_node_name": { "type": "string", + "maxLength": 50, "description": "The name of the target node to add" }, "target_node_summary": { "type": "string", + "maxLength": 500, "description": "The summary of the target node to add" }, "target_node_uuid": { @@ -7951,13 +7988,15 @@ "type": "object", "properties": { "description": { - "type": "string" + "type": "string", + "maxLength": 2000 }, "graph_id": { "type": "string" }, "name": { - "type": "string" + "type": "string", + "maxLength": 255 }, "time_zone": { "type": [ @@ -8042,6 +8081,8 @@ "properties": { "max_hops": { "type": "integer", + "minimum": 1, + "maximum": 5, "description": "Max hops within which to detect co-occurring node types. Default: 3, Max: 5" } }, @@ -8052,6 +8093,7 @@ "properties": { "min_degree": { "type": "integer", + "minimum": 2, "description": "Minimum number of connections for a node to be considered a hub. Default: 3, Min: 2" } }, @@ -8062,6 +8104,8 @@ "properties": { "max_hops": { "type": "integer", + "minimum": 1, + "maximum": 5, "description": "Max hops from seed nodes for path detection. Default: 3, Max: 5" } }, @@ -8375,6 +8419,8 @@ }, "edge_limit": { "type": "integer", + "minimum": 1, + "maximum": 100, "description": "Max resolved edges per pattern. Default: 10, Max: 100. Only used with query." }, "graph_id": { @@ -8383,18 +8429,25 @@ }, "limit": { "type": "integer", + "minimum": 1, + "maximum": 200, "description": "Max patterns to return. Default: 50, Max: 200" }, "min_occurrences": { "type": "integer", + "minimum": 1, "description": "Minimum occurrence count to report a pattern. Default: 2" }, "query": { "type": "string", + "minLength": 1, + "maxLength": 400, "description": "Search query for discovering seed nodes via hybrid search.\nWhen set, forces triple-frequency detection only and enables edge resolution\nwith cross-encoder reranking. Mutually exclusive with seeds." }, "query_limit": { "type": "integer", + "minimum": 1, + "maximum": 50, "description": "Max seed nodes from search. Default: 10, Max: 50. Only used with query." }, "recency_weight": { @@ -8549,10 +8602,13 @@ }, "limit": { "type": "integer", + "maximum": 50, "description": "The maximum number of facts to retrieve for non-auto scopes. Defaults to 10. Limited to 50. Ignored when scope=auto." }, "max_characters": { "type": "integer", + "minimum": 1, + "maximum": 50000, "description": "Maximum total characters across all selected results when scope=auto. Defaults to 2500. Limited to 50000." }, "mmr_lambda": { @@ -8562,6 +8618,7 @@ }, "query": { "type": "string", + "maxLength": 400, "description": "The string to search for (required)" }, "reranker": { @@ -8777,6 +8834,8 @@ "properties": { "depth": { "type": "integer", + "minimum": 1, + "maximum": 3, "description": "Maximum traversal depth from the seeds. 1-3. Defaults to 1." }, "direction": { @@ -8789,10 +8848,14 @@ }, "max_edges": { "type": "integer", + "minimum": 1, + "maximum": 1000, "description": "Maximum number of edges in the response. 1-1000. Defaults to 200." }, "max_nodes": { "type": "integer", + "minimum": 1, + "maximum": 500, "description": "Maximum number of nodes in the response, including admitted seeds.\n1-500. Defaults to 100." }, "search_filters": { @@ -8851,13 +8914,15 @@ "type": [ "string", "null" - ] + ], + "maxLength": 2000 }, "name": { "type": [ "string", "null" - ] + ], + "maxLength": 255 }, "time_zone": { "type": [ @@ -8915,6 +8980,7 @@ }, "fact": { "type": "string", + "maxLength": 250, "description": "Updated fact for the edge" }, "invalid_at": { @@ -8923,6 +8989,8 @@ }, "name": { "type": "string", + "minLength": 1, + "maxLength": 50, "description": "Updated name (relationship type) for the edge" }, "valid_at": { @@ -9011,6 +9079,7 @@ }, "label": { "type": "string", + "maxLength": 100, "description": "The node's entity type. At most one; the base \"Entity\" label is added\nimplicitly by the graph layer on save and does not need to be supplied." }, "metadata": { @@ -9022,10 +9091,13 @@ }, "name": { "type": "string", + "minLength": 1, + "maxLength": 50, "description": "The name of the node. Used to derive the node's search embedding." }, "summary": { "type": "string", + "maxLength": 500, "description": "A regional summary of the node." } }, @@ -9072,6 +9144,7 @@ }, "label": { "type": "string", + "maxLength": 100, "description": "The node's entity type." }, "metadata": { @@ -9083,10 +9156,13 @@ }, "name": { "type": "string", + "minLength": 1, + "maxLength": 50, "description": "The name of the node." }, "summary": { "type": "string", + "maxLength": 500, "description": "A regional summary of the node." }, "uuid": { @@ -9210,10 +9286,13 @@ }, "name": { "type": "string", + "minLength": 1, + "maxLength": 50, "description": "Updated name for the node" }, "summary": { "type": "string", + "maxLength": 500, "description": "Updated summary for the node" } }, @@ -9223,10 +9302,13 @@ "type": "object", "properties": { "name": { - "type": "string" + "type": "string", + "maxLength": 100 }, "text": { - "type": "string" + "type": "string", + "minLength": 1, + "maxLength": 5000 } }, "required": [ @@ -9474,10 +9556,12 @@ "type": "object", "properties": { "description": { - "type": "string" + "type": "string", + "maxLength": 500 }, "name": { - "type": "string" + "type": "string", + "maxLength": 50 } }, "required": [ @@ -9493,7 +9577,8 @@ "type": [ "string", "null" - ] + ], + "maxLength": 2000 }, "types": { "type": "array", @@ -9588,6 +9673,10 @@ "additionalProperties": { "description": "Any type" } + }, + "strict_ontology": { + "type": "boolean", + "description": "When true, prevents extraction of generic Entity nodes that do not match the configured ontology." } }, "title": "ApidataCreateBatchRequest" @@ -9673,6 +9762,9 @@ "status": { "$ref": "#/components/schemas/ModelsBatchStatus" }, + "strict_ontology": { + "type": "boolean" + }, "updated_at": { "type": "string" } @@ -9704,6 +9796,8 @@ }, "document_id": { "type": "string", + "minLength": 1, + "maxLength": 100, "description": "Optional document ID for graph_episode items. Groups episodes as document\nchunks. Ignored for thread_message items." }, "graph_id": { @@ -9722,7 +9816,8 @@ "$ref": "#/components/schemas/ApidataRoleType" }, "source_description": { - "type": "string" + "type": "string", + "maxLength": 500 }, "thread_id": { "type": "string"