From cf1a089e41093ce0dfb7a13638fd0fcc2e2d8f1f Mon Sep 17 00:00:00 2001 From: "github-actions[bot]" Date: Thu, 2 Apr 2026 18:49:43 +0000 Subject: [PATCH] feat: Updated OpenAPI spec --- ...nt.ActorTaskRunSyncGetDatasetItemsGet.g.cs | 161 ++++++++++- ...t.ActorTaskRunSyncGetDatasetItemsPost.g.cs | 184 ++++++++++++- ...fy.ActorTasksClient.ActorTaskRunsPost.g.cs | 95 ++++++- ...Apify.ActorTasksClient.ActorTasksPost.g.cs | 41 ++- ...ActorsActorBuildsClient.ActBuildsPost.g.cs | 61 +++- ...nsClient.ActRunSyncGetDatasetItemsGet.g.cs | 175 +++++++++++- ...sClient.ActRunSyncGetDatasetItemsPost.g.cs | 185 ++++++++++++- ...ify.ActorsActorRunsClient.ActRunsPost.g.cs | 99 ++++++- ...rVersionsClient.ActVersionEnvVarsPost.g.cs | 58 +++- ...rsActorVersionsClient.ActVersionsPost.g.cs | 62 ++++- .../Apify.ActorsClient.ActsPost.g.cs | 46 +++- .../Generated/Apify.AutoSDKHttpResponse.g.cs | 86 ++++++ ...nt.ActorTaskRunSyncGetDatasetItemsGet.g.cs | 119 ++++++++ ...t.ActorTaskRunSyncGetDatasetItemsPost.g.cs | 138 ++++++++++ ...y.IActorTasksClient.ActorTaskRunsPost.g.cs | 63 +++++ ...pify.IActorTasksClient.ActorTasksPost.g.cs | 18 ++ ...ActorsActorBuildsClient.ActBuildsPost.g.cs | 34 +++ ...nsClient.ActRunSyncGetDatasetItemsGet.g.cs | 127 +++++++++ ...sClient.ActRunSyncGetDatasetItemsPost.g.cs | 135 +++++++++ ...fy.IActorsActorRunsClient.ActRunsPost.g.cs | 66 +++++ ...rVersionsClient.ActVersionEnvVarsPost.g.cs | 33 +++ ...rsActorVersionsClient.ActVersionsPost.g.cs | 38 +++ .../Apify.IActorsClient.ActsPost.g.cs | 23 ++ .../Apify.ISchedulesClient.SchedulesPost.g.cs | 16 ++ ...StorageDatasetsClient.DatasetItemsGet.g.cs | 217 +++++++++++++++ ...torageDatasetsClient.DatasetItemsPost.g.cs | 19 ++ ...y.IStorageDatasetsClient.DatasetsPost.g.cs | 15 + ...eStoresClient.KeyValueStoreRecordPost.g.cs | 22 ++ ...ueStoresClient.KeyValueStoreRecordPut.g.cs | 32 +++ ...yValueStoresClient.KeyValueStoresPost.g.cs | 19 ++ ...RequestQueuesClient.RequestQueuesPost.g.cs | 17 ++ ....IWebhooksWebhooksClient.WebhooksPost.g.cs | 55 ++++ .../Apify.SchedulesClient.SchedulesPost.g.cs | 39 ++- ...StorageDatasetsClient.DatasetItemsGet.g.cs | 260 +++++++++++++++++- ...torageDatasetsClient.DatasetItemsPost.g.cs | 39 ++- ...fy.StorageDatasetsClient.DatasetsPost.g.cs | 37 ++- ...eStoresClient.KeyValueStoreRecordPost.g.cs | 44 ++- ...ueStoresClient.KeyValueStoreRecordPut.g.cs | 54 +++- ...yValueStoresClient.KeyValueStoresPost.g.cs | 41 ++- ...RequestQueuesClient.RequestQueuesPost.g.cs | 39 ++- ...y.WebhooksWebhooksClient.WebhooksPost.g.cs | 78 +++++- 41 files changed, 3020 insertions(+), 70 deletions(-) create mode 100644 src/libs/Apify/Generated/Apify.AutoSDKHttpResponse.g.cs diff --git a/src/libs/Apify/Generated/Apify.ActorTasksClient.ActorTaskRunSyncGetDatasetItemsGet.g.cs b/src/libs/Apify/Generated/Apify.ActorTasksClient.ActorTaskRunSyncGetDatasetItemsGet.g.cs index da6b76b..a87e498 100644 --- a/src/libs/Apify/Generated/Apify.ActorTasksClient.ActorTaskRunSyncGetDatasetItemsGet.g.cs +++ b/src/libs/Apify/Generated/Apify.ActorTasksClient.ActorTaskRunSyncGetDatasetItemsGet.g.cs @@ -188,6 +188,157 @@ partial void ProcessActorTaskRunSyncGetDatasetItemsGetResponseContent( bool? simplified = default, bool? skipFailedPages = default, global::System.Threading.CancellationToken cancellationToken = default) + { + var __response = await ActorTaskRunSyncGetDatasetItemsGetAsResponseAsync( + actorTaskId: actorTaskId, + timeout: timeout, + memory: memory, + maxItems: maxItems, + build: build, + webhooks: webhooks, + format: format, + clean: clean, + offset: offset, + limit: limit, + fields: fields, + omit: omit, + unwind: unwind, + flatten: flatten, + desc: desc, + attachment: attachment, + delimiter: delimiter, + bom: bom, + xmlRoot: xmlRoot, + xmlRow: xmlRow, + skipHeaderRow: skipHeaderRow, + skipHidden: skipHidden, + skipEmpty: skipEmpty, + simplified: simplified, + skipFailedPages: skipFailedPages, + cancellationToken: cancellationToken + ).ConfigureAwait(false); + + return __response.Body; + } + /// + /// Run task synchronously and get dataset items
+ /// Run a specific task and return its dataset items.
+ /// The run must finish in 300<!-- MAX_ACTOR_JOB_SYNC_WAIT_SECS --> seconds
+ /// otherwise the HTTP request fails with a timeout error (this won't abort
+ /// the run itself).
+ /// You can send all the same options in parameters as the [Get Dataset
+ /// Items](#/reference/datasets/item-collection/get-items) API endpoint.
+ /// Beware that it might be impossible to maintain an idle HTTP connection for
+ /// an extended period, due to client timeout or network conditions. Make sure your HTTP client is
+ /// configured to have a long enough connection timeout.
+ /// If the connection breaks, you will not receive any information about the run
+ /// and its status.
+ /// To run the Task asynchronously, use the [Run task
+ /// asynchronously](#/reference/actor-tasks/run-collection/run-task) endpoint
+ /// instead. + ///
+ /// + /// Example: janedoe~my-task + /// + /// + /// Example: 60 + /// + /// + /// Example: 256 + /// + /// + /// Example: 1000 + /// + /// + /// Example: 0.1.234 + /// + /// + /// Example: dGhpcyBpcyBqdXN0IGV4YW1wbGUK... + /// + /// + /// Example: json + /// + /// + /// Example: false + /// + /// + /// Example: 0 + /// + /// + /// + /// Example: myValue,myOtherValue + /// + /// + /// Example: myValue,myOtherValue + /// + /// + /// Example: myValue,myOtherValue + /// + /// + /// Example: myValue + /// + /// + /// Example: true + /// + /// + /// Example: true + /// + /// + /// Example: ; + /// + /// + /// Example: false + /// + /// + /// Example: items + /// + /// + /// Example: item + /// + /// + /// Example: true + /// + /// + /// Example: false + /// + /// + /// Example: false + /// + /// + /// Example: false + /// + /// + /// Example: false + /// + /// The token to cancel the operation with + /// + public async global::System.Threading.Tasks.Task> ActorTaskRunSyncGetDatasetItemsGetAsResponseAsync( + string actorTaskId, + double? timeout = default, + double? memory = default, + double? maxItems = default, + string? build = default, + string? webhooks = default, + string? format = default, + bool? clean = default, + double? offset = default, + double? limit = default, + string? fields = default, + string? omit = default, + string? unwind = default, + string? flatten = default, + bool? desc = default, + bool? attachment = default, + string? delimiter = default, + bool? bom = default, + string? xmlRoot = default, + string? xmlRow = default, + bool? skipHeaderRow = default, + bool? skipHidden = default, + bool? skipEmpty = default, + bool? simplified = default, + bool? skipFailedPages = default, + global::System.Threading.CancellationToken cancellationToken = default) { PrepareArguments( client: HttpClient); @@ -604,7 +755,10 @@ partial void ProcessActorTaskRunSyncGetDatasetItemsGetResponseContent( { __response.EnsureSuccessStatusCode(); - return __content; + return new global::Apify.AutoSDKHttpResponse( + statusCode: __response.StatusCode, + headers: global::Apify.AutoSDKHttpResponse.CreateHeaders(__response), + body: __content); } catch (global::System.Exception __ex) { @@ -633,7 +787,10 @@ partial void ProcessActorTaskRunSyncGetDatasetItemsGetResponseContent( #endif ).ConfigureAwait(false); - return __content; + return new global::Apify.AutoSDKHttpResponse( + statusCode: __response.StatusCode, + headers: global::Apify.AutoSDKHttpResponse.CreateHeaders(__response), + body: __content); } catch (global::System.Exception __ex) { diff --git a/src/libs/Apify/Generated/Apify.ActorTasksClient.ActorTaskRunSyncGetDatasetItemsPost.g.cs b/src/libs/Apify/Generated/Apify.ActorTasksClient.ActorTaskRunSyncGetDatasetItemsPost.g.cs index ca9f874..61588de 100644 --- a/src/libs/Apify/Generated/Apify.ActorTasksClient.ActorTaskRunSyncGetDatasetItemsPost.g.cs +++ b/src/libs/Apify/Generated/Apify.ActorTasksClient.ActorTaskRunSyncGetDatasetItemsPost.g.cs @@ -185,6 +185,180 @@ partial void ProcessActorTaskRunSyncGetDatasetItemsPostResponseContent( public async global::System.Threading.Tasks.Task ActorTaskRunSyncGetDatasetItemsPostAsync( string actorTaskId, + object request, + double? timeout = default, + double? memory = default, + double? maxItems = default, + double? maxTotalChargeUsd = default, + bool? restartOnError = default, + string? build = default, + string? webhooks = default, + string? format = default, + bool? clean = default, + double? offset = default, + double? limit = default, + string? fields = default, + string? omit = default, + string? unwind = default, + string? flatten = default, + bool? desc = default, + bool? attachment = default, + string? delimiter = default, + bool? bom = default, + string? xmlRoot = default, + string? xmlRow = default, + bool? skipHeaderRow = default, + bool? skipHidden = default, + bool? skipEmpty = default, + bool? simplified = default, + bool? skipFailedPages = default, + global::System.Threading.CancellationToken cancellationToken = default) + { + var __response = await ActorTaskRunSyncGetDatasetItemsPostAsResponseAsync( + actorTaskId: actorTaskId, + + request: request, + timeout: timeout, + memory: memory, + maxItems: maxItems, + maxTotalChargeUsd: maxTotalChargeUsd, + restartOnError: restartOnError, + build: build, + webhooks: webhooks, + format: format, + clean: clean, + offset: offset, + limit: limit, + fields: fields, + omit: omit, + unwind: unwind, + flatten: flatten, + desc: desc, + attachment: attachment, + delimiter: delimiter, + bom: bom, + xmlRoot: xmlRoot, + xmlRow: xmlRow, + skipHeaderRow: skipHeaderRow, + skipHidden: skipHidden, + skipEmpty: skipEmpty, + simplified: simplified, + skipFailedPages: skipFailedPages, + cancellationToken: cancellationToken + ).ConfigureAwait(false); + + return __response.Body; + } + /// + /// Run task synchronously and get dataset items
+ /// Runs an Actor task and synchronously returns its dataset items.
+ /// The run must finish in 300<!-- MAX_ACTOR_JOB_SYNC_WAIT_SECS --> seconds
+ /// otherwise the HTTP request fails with a timeout error (this won't abort
+ /// the run itself).
+ /// Optionally, you can override the Actor input configuration by passing a JSON
+ /// object as the POST payload and setting the `Content-Type: application/json` HTTP header.
+ /// Note that if the object in the POST payload does not define a particular
+ /// input property, the Actor run uses the default value defined by the task (or the Actor's
+ /// input schema if not defined by the task).
+ /// You can send all the same options in parameters as the [Get Dataset
+ /// Items](#/reference/datasets/item-collection/get-items) API endpoint.
+ /// Beware that it might be impossible to maintain an idle HTTP connection for
+ /// an extended period, due to client timeout or network conditions. Make sure your HTTP client is
+ /// configured to have a long enough connection timeout.
+ /// If the connection breaks, you will not receive any information about the run
+ /// and its status.
+ /// Input fields from Actor task configuration can be overloaded with values
+ /// passed as the POST payload.
+ /// Just make sure to specify the `Content-Type` header as `application/json`
+ /// and that the input is an object.
+ /// To run the task asynchronously, use the [Run
+ /// task](#/reference/actor-tasks/run-collection/run-task) API endpoint instead. + ///
+ /// + /// Example: janedoe~my-task + /// + /// + /// Example: 60 + /// + /// + /// Example: 256 + /// + /// + /// Example: 1000 + /// + /// + /// Example: 5 + /// + /// + /// Example: false + /// + /// + /// Example: 0.1.234 + /// + /// + /// Example: dGhpcyBpcyBqdXN0IGV4YW1wbGUK... + /// + /// + /// Example: json + /// + /// + /// Example: false + /// + /// + /// Example: 0 + /// + /// + /// + /// Example: myValue,myOtherValue + /// + /// + /// Example: myValue,myOtherValue + /// + /// + /// Example: myValue,myOtherValue + /// + /// + /// Example: myValue + /// + /// + /// Example: true + /// + /// + /// Example: true + /// + /// + /// Example: ; + /// + /// + /// Example: false + /// + /// + /// Example: items + /// + /// + /// Example: item + /// + /// + /// Example: true + /// + /// + /// Example: false + /// + /// + /// Example: false + /// + /// + /// Example: false + /// + /// + /// Example: false + /// + /// + /// The token to cancel the operation with + /// + public async global::System.Threading.Tasks.Task> ActorTaskRunSyncGetDatasetItemsPostAsResponseAsync( + string actorTaskId, + object request, double? timeout = default, double? memory = default, @@ -683,7 +857,10 @@ partial void ProcessActorTaskRunSyncGetDatasetItemsPostResponseContent( { __response.EnsureSuccessStatusCode(); - return __content; + return new global::Apify.AutoSDKHttpResponse( + statusCode: __response.StatusCode, + headers: global::Apify.AutoSDKHttpResponse.CreateHeaders(__response), + body: __content); } catch (global::System.Exception __ex) { @@ -712,7 +889,10 @@ partial void ProcessActorTaskRunSyncGetDatasetItemsPostResponseContent( #endif ).ConfigureAwait(false); - return __content; + return new global::Apify.AutoSDKHttpResponse( + statusCode: __response.StatusCode, + headers: global::Apify.AutoSDKHttpResponse.CreateHeaders(__response), + body: __content); } catch (global::System.Exception __ex) { diff --git a/src/libs/Apify/Generated/Apify.ActorTasksClient.ActorTaskRunsPost.g.cs b/src/libs/Apify/Generated/Apify.ActorTasksClient.ActorTaskRunsPost.g.cs index 8573255..086580b 100644 --- a/src/libs/Apify/Generated/Apify.ActorTasksClient.ActorTaskRunsPost.g.cs +++ b/src/libs/Apify/Generated/Apify.ActorTasksClient.ActorTaskRunsPost.g.cs @@ -92,6 +92,87 @@ partial void ProcessActorTaskRunsPostResponseContent( public async global::System.Threading.Tasks.Task ActorTaskRunsPostAsync( string actorTaskId, + object request, + double? timeout = default, + double? memory = default, + double? maxItems = default, + double? maxTotalChargeUsd = default, + bool? restartOnError = default, + string? build = default, + double? waitForFinish = default, + string? webhooks = default, + global::System.Threading.CancellationToken cancellationToken = default) + { + var __response = await ActorTaskRunsPostAsResponseAsync( + actorTaskId: actorTaskId, + + request: request, + timeout: timeout, + memory: memory, + maxItems: maxItems, + maxTotalChargeUsd: maxTotalChargeUsd, + restartOnError: restartOnError, + build: build, + waitForFinish: waitForFinish, + webhooks: webhooks, + cancellationToken: cancellationToken + ).ConfigureAwait(false); + + return __response.Body; + } + /// + /// Run task
+ /// Runs an Actor task and immediately returns without waiting for the run to
+ /// finish.
+ /// Optionally, you can override the Actor input configuration by passing a JSON
+ /// object as the POST payload and setting the `Content-Type: application/json` HTTP header.
+ /// Note that if the object in the POST payload does not define a particular
+ /// input property, the Actor run uses the default value defined by the task (or Actor's input
+ /// schema if not defined by the task).
+ /// The response is the Actor Run object as returned by the [Get
+ /// run](#/reference/actor-runs/run-object-and-its-storages/get-run) endpoint.
+ /// If you want to wait for the run to finish and receive the actual output of
+ /// the Actor run as the response, use one of the [Run task
+ /// synchronously](#/reference/actor-tasks/run-task-synchronously) API endpoints
+ /// instead.
+ /// To fetch the Actor run results that are typically stored in the default
+ /// dataset, you'll need to pass the ID received in the `defaultDatasetId` field
+ /// received in the response JSON to the
+ /// [Get dataset items](#/reference/datasets/item-collection/get-items) API endpoint. + ///
+ /// + /// Example: janedoe~my-task + /// + /// + /// Example: 60 + /// + /// + /// Example: 256 + /// + /// + /// Example: 1000 + /// + /// + /// Example: 5 + /// + /// + /// Example: false + /// + /// + /// Example: 0.1.234 + /// + /// + /// Example: 60 + /// + /// + /// Example: dGhpcyBpcyBqdXN0IGV4YW1wbGUK... + /// + /// + /// The token to cancel the operation with + /// + public async global::System.Threading.Tasks.Task> ActorTaskRunsPostAsResponseAsync( + string actorTaskId, + object request, double? timeout = default, double? memory = default, @@ -518,9 +599,12 @@ partial void ProcessActorTaskRunsPostResponseContent( { __response.EnsureSuccessStatusCode(); - return - global::Apify.ActorTaskRunsPostResponse.FromJson(__content, JsonSerializerContext) ?? + var __value = global::Apify.ActorTaskRunsPostResponse.FromJson(__content, JsonSerializerContext) ?? throw new global::System.InvalidOperationException($"Response deserialization failed for \"{__content}\" "); + return new global::Apify.AutoSDKHttpResponse( + statusCode: __response.StatusCode, + headers: global::Apify.AutoSDKHttpResponse.CreateHeaders(__response), + body: __value); } catch (global::System.Exception __ex) { @@ -549,9 +633,12 @@ partial void ProcessActorTaskRunsPostResponseContent( #endif ).ConfigureAwait(false); - return - await global::Apify.ActorTaskRunsPostResponse.FromJsonStreamAsync(__content, JsonSerializerContext).ConfigureAwait(false) ?? + var __value = await global::Apify.ActorTaskRunsPostResponse.FromJsonStreamAsync(__content, JsonSerializerContext).ConfigureAwait(false) ?? throw new global::System.InvalidOperationException("Response deserialization failed."); + return new global::Apify.AutoSDKHttpResponse( + statusCode: __response.StatusCode, + headers: global::Apify.AutoSDKHttpResponse.CreateHeaders(__response), + body: __value); } catch (global::System.Exception __ex) { diff --git a/src/libs/Apify/Generated/Apify.ActorTasksClient.ActorTasksPost.g.cs b/src/libs/Apify/Generated/Apify.ActorTasksClient.ActorTasksPost.g.cs index 5ca2e3d..7c12bb5 100644 --- a/src/libs/Apify/Generated/Apify.ActorTasksClient.ActorTasksPost.g.cs +++ b/src/libs/Apify/Generated/Apify.ActorTasksClient.ActorTasksPost.g.cs @@ -37,6 +37,33 @@ partial void ProcessActorTasksPostResponseContent( /// public async global::System.Threading.Tasks.Task ActorTasksPostAsync( + global::Apify.AllOf request, + global::System.Threading.CancellationToken cancellationToken = default) + { + var __response = await ActorTasksPostAsResponseAsync( + + request: request, + cancellationToken: cancellationToken + ).ConfigureAwait(false); + + return __response.Body; + } + /// + /// Create task
+ /// Create a new task with settings specified by the object passed as JSON in
+ /// the POST payload.
+ /// The response is the full task object as returned by the
+ /// [Get task](#/reference/tasks/task-object/get-task) endpoint.
+ /// The request needs to specify the `Content-Type: application/json` HTTP header!
+ /// When providing your API authentication token, we recommend using the
+ /// request's `Authorization` header, rather than the URL. ([More
+ /// info](#/introduction/authentication)). + ///
+ /// + /// The token to cancel the operation with + /// + public async global::System.Threading.Tasks.Task> ActorTasksPostAsResponseAsync( + global::Apify.AllOf request, global::System.Threading.CancellationToken cancellationToken = default) { @@ -387,9 +414,12 @@ partial void ProcessActorTasksPostResponseContent( { __response.EnsureSuccessStatusCode(); - return - global::Apify.TaskResponse.FromJson(__content, JsonSerializerContext) ?? + var __value = global::Apify.TaskResponse.FromJson(__content, JsonSerializerContext) ?? throw new global::System.InvalidOperationException($"Response deserialization failed for \"{__content}\" "); + return new global::Apify.AutoSDKHttpResponse( + statusCode: __response.StatusCode, + headers: global::Apify.AutoSDKHttpResponse.CreateHeaders(__response), + body: __value); } catch (global::System.Exception __ex) { @@ -418,9 +448,12 @@ partial void ProcessActorTasksPostResponseContent( #endif ).ConfigureAwait(false); - return - await global::Apify.TaskResponse.FromJsonStreamAsync(__content, JsonSerializerContext).ConfigureAwait(false) ?? + var __value = await global::Apify.TaskResponse.FromJsonStreamAsync(__content, JsonSerializerContext).ConfigureAwait(false) ?? throw new global::System.InvalidOperationException("Response deserialization failed."); + return new global::Apify.AutoSDKHttpResponse( + statusCode: __response.StatusCode, + headers: global::Apify.AutoSDKHttpResponse.CreateHeaders(__response), + body: __value); } catch (global::System.Exception __ex) { diff --git a/src/libs/Apify/Generated/Apify.ActorsActorBuildsClient.ActBuildsPost.g.cs b/src/libs/Apify/Generated/Apify.ActorsActorBuildsClient.ActBuildsPost.g.cs index 369d426..aef7839 100644 --- a/src/libs/Apify/Generated/Apify.ActorsActorBuildsClient.ActBuildsPost.g.cs +++ b/src/libs/Apify/Generated/Apify.ActorsActorBuildsClient.ActBuildsPost.g.cs @@ -65,6 +65,53 @@ partial void ProcessActBuildsPostResponseContent( string? tag = default, double? waitForFinish = default, global::System.Threading.CancellationToken cancellationToken = default) + { + var __response = await ActBuildsPostAsResponseAsync( + actorId: actorId, + version: version, + useCache: useCache, + betaPackages: betaPackages, + tag: tag, + waitForFinish: waitForFinish, + cancellationToken: cancellationToken + ).ConfigureAwait(false); + + return __response.Body; + } + /// + /// Build Actor
+ /// Builds an Actor.
+ /// The response is the build object as returned by the
+ /// [Get build](#/reference/actors/build-object/get-build) endpoint. + ///
+ /// + /// Example: janedoe~my-actor + /// + /// + /// Example: 0.0 + /// + /// + /// Example: true + /// + /// + /// Example: true + /// + /// + /// Example: latest + /// + /// + /// Example: 60 + /// + /// The token to cancel the operation with + /// + public async global::System.Threading.Tasks.Task> ActBuildsPostAsResponseAsync( + string actorId, + string version, + bool? useCache = default, + bool? betaPackages = default, + string? tag = default, + double? waitForFinish = default, + global::System.Threading.CancellationToken cancellationToken = default) { PrepareArguments( client: HttpClient); @@ -386,9 +433,12 @@ partial void ProcessActBuildsPostResponseContent( { __response.EnsureSuccessStatusCode(); - return - global::Apify.BuildResponse.FromJson(__content, JsonSerializerContext) ?? + var __value = global::Apify.BuildResponse.FromJson(__content, JsonSerializerContext) ?? throw new global::System.InvalidOperationException($"Response deserialization failed for \"{__content}\" "); + return new global::Apify.AutoSDKHttpResponse( + statusCode: __response.StatusCode, + headers: global::Apify.AutoSDKHttpResponse.CreateHeaders(__response), + body: __value); } catch (global::System.Exception __ex) { @@ -417,9 +467,12 @@ partial void ProcessActBuildsPostResponseContent( #endif ).ConfigureAwait(false); - return - await global::Apify.BuildResponse.FromJsonStreamAsync(__content, JsonSerializerContext).ConfigureAwait(false) ?? + var __value = await global::Apify.BuildResponse.FromJsonStreamAsync(__content, JsonSerializerContext).ConfigureAwait(false) ?? throw new global::System.InvalidOperationException("Response deserialization failed."); + return new global::Apify.AutoSDKHttpResponse( + statusCode: __response.StatusCode, + headers: global::Apify.AutoSDKHttpResponse.CreateHeaders(__response), + body: __value); } catch (global::System.Exception __ex) { diff --git a/src/libs/Apify/Generated/Apify.ActorsActorRunsClient.ActRunSyncGetDatasetItemsGet.g.cs b/src/libs/Apify/Generated/Apify.ActorsActorRunsClient.ActRunSyncGetDatasetItemsGet.g.cs index 58b0a0e..a4bbcba 100644 --- a/src/libs/Apify/Generated/Apify.ActorsActorRunsClient.ActRunSyncGetDatasetItemsGet.g.cs +++ b/src/libs/Apify/Generated/Apify.ActorsActorRunsClient.ActRunSyncGetDatasetItemsGet.g.cs @@ -200,6 +200,167 @@ partial void ProcessActRunSyncGetDatasetItemsGetResponseContent( bool? simplified = default, bool? skipFailedPages = default, global::System.Threading.CancellationToken cancellationToken = default) + { + var __response = await ActRunSyncGetDatasetItemsGetAsResponseAsync( + actorId: actorId, + timeout: timeout, + memory: memory, + maxItems: maxItems, + maxTotalChargeUsd: maxTotalChargeUsd, + restartOnError: restartOnError, + build: build, + webhooks: webhooks, + format: format, + clean: clean, + offset: offset, + limit: limit, + fields: fields, + omit: omit, + unwind: unwind, + flatten: flatten, + desc: desc, + attachment: attachment, + delimiter: delimiter, + bom: bom, + xmlRoot: xmlRoot, + xmlRow: xmlRow, + skipHeaderRow: skipHeaderRow, + skipHidden: skipHidden, + skipEmpty: skipEmpty, + simplified: simplified, + skipFailedPages: skipFailedPages, + cancellationToken: cancellationToken + ).ConfigureAwait(false); + + return __response.Body; + } + /// + /// Run Actor synchronously without input and get dataset items
+ /// Runs a specific Actor and returns its dataset items.
+ /// The run must finish in 300<!-- MAX_ACTOR_JOB_SYNC_WAIT_SECS --> seconds
+ /// otherwise the API endpoint returns a timeout error.
+ /// The Actor is not passed any input.
+ /// It allows to send all possible options in parameters from [Get Dataset
+ /// Items](#/reference/datasets/item-collection/get-items) API endpoint.
+ /// Beware that it might be impossible to maintain an idle HTTP connection for a
+ /// long period of time,
+ /// due to client timeout or network conditions. Make sure your HTTP client is
+ /// configured to have a long enough connection timeout.
+ /// If the connection breaks, you will not receive any information about the run
+ /// and its status.
+ /// To run the Actor asynchronously, use the [Run
+ /// Actor](#/reference/actors/run-collection/run-actor) API endpoint instead. + ///
+ /// + /// Example: janedoe~my-actor + /// + /// + /// Example: 60 + /// + /// + /// Example: 256 + /// + /// + /// Example: 1000 + /// + /// + /// Example: 5 + /// + /// + /// Example: false + /// + /// + /// Example: 0.1.234 + /// + /// + /// Example: dGhpcyBpcyBqdXN0IGV4YW1wbGUK... + /// + /// + /// Example: json + /// + /// + /// Example: false + /// + /// + /// Example: 0 + /// + /// + /// + /// Example: myValue,myOtherValue + /// + /// + /// Example: myValue,myOtherValue + /// + /// + /// Example: myValue,myOtherValue + /// + /// + /// Example: myValue + /// + /// + /// Example: true + /// + /// + /// Example: true + /// + /// + /// Example: ; + /// + /// + /// Example: false + /// + /// + /// Example: items + /// + /// + /// Example: item + /// + /// + /// Example: true + /// + /// + /// Example: false + /// + /// + /// Example: false + /// + /// + /// Example: false + /// + /// + /// Example: false + /// + /// The token to cancel the operation with + /// + public async global::System.Threading.Tasks.Task>> ActRunSyncGetDatasetItemsGetAsResponseAsync( + string actorId, + double? timeout = default, + double? memory = default, + double? maxItems = default, + double? maxTotalChargeUsd = default, + bool? restartOnError = default, + string? build = default, + string? webhooks = default, + string? format = default, + bool? clean = default, + double? offset = default, + double? limit = default, + string? fields = default, + string? omit = default, + string? unwind = default, + string? flatten = default, + bool? desc = default, + bool? attachment = default, + string? delimiter = default, + bool? bom = default, + string? xmlRoot = default, + string? xmlRow = default, + bool? skipHeaderRow = default, + bool? skipHidden = default, + bool? skipEmpty = default, + bool? simplified = default, + bool? skipFailedPages = default, + global::System.Threading.CancellationToken cancellationToken = default) { PrepareArguments( client: HttpClient); @@ -508,9 +669,12 @@ partial void ProcessActRunSyncGetDatasetItemsGetResponseContent( { __response.EnsureSuccessStatusCode(); - return - (global::System.Collections.Generic.IList?)global::System.Text.Json.JsonSerializer.Deserialize(__content, typeof(global::System.Collections.Generic.IList), JsonSerializerContext) ?? + 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::Apify.AutoSDKHttpResponse>( + statusCode: __response.StatusCode, + headers: global::Apify.AutoSDKHttpResponse.CreateHeaders(__response), + body: __value); } catch (global::System.Exception __ex) { @@ -539,9 +703,12 @@ partial void ProcessActRunSyncGetDatasetItemsGetResponseContent( #endif ).ConfigureAwait(false); - return - (global::System.Collections.Generic.IList?)await global::System.Text.Json.JsonSerializer.DeserializeAsync(__content, typeof(global::System.Collections.Generic.IList), JsonSerializerContext).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::Apify.AutoSDKHttpResponse>( + statusCode: __response.StatusCode, + headers: global::Apify.AutoSDKHttpResponse.CreateHeaders(__response), + body: __value); } catch (global::System.Exception __ex) { diff --git a/src/libs/Apify/Generated/Apify.ActorsActorRunsClient.ActRunSyncGetDatasetItemsPost.g.cs b/src/libs/Apify/Generated/Apify.ActorsActorRunsClient.ActRunSyncGetDatasetItemsPost.g.cs index 1cffbbd..1fd7248 100644 --- a/src/libs/Apify/Generated/Apify.ActorsActorRunsClient.ActRunSyncGetDatasetItemsPost.g.cs +++ b/src/libs/Apify/Generated/Apify.ActorsActorRunsClient.ActRunSyncGetDatasetItemsPost.g.cs @@ -182,6 +182,177 @@ partial void ProcessActRunSyncGetDatasetItemsPostResponseContent( public async global::System.Threading.Tasks.Task> ActRunSyncGetDatasetItemsPostAsync( string actorId, + object request, + double? timeout = default, + double? memory = default, + double? maxItems = default, + double? maxTotalChargeUsd = default, + bool? restartOnError = default, + string? build = default, + string? webhooks = default, + string? format = default, + bool? clean = default, + double? offset = default, + double? limit = default, + string? fields = default, + string? omit = default, + string? unwind = default, + string? flatten = default, + bool? desc = default, + bool? attachment = default, + string? delimiter = default, + bool? bom = default, + string? xmlRoot = default, + string? xmlRow = default, + bool? skipHeaderRow = default, + bool? skipHidden = default, + bool? skipEmpty = default, + bool? simplified = default, + bool? skipFailedPages = default, + global::System.Threading.CancellationToken cancellationToken = default) + { + var __response = await ActRunSyncGetDatasetItemsPostAsResponseAsync( + actorId: actorId, + + request: request, + timeout: timeout, + memory: memory, + maxItems: maxItems, + maxTotalChargeUsd: maxTotalChargeUsd, + restartOnError: restartOnError, + build: build, + webhooks: webhooks, + format: format, + clean: clean, + offset: offset, + limit: limit, + fields: fields, + omit: omit, + unwind: unwind, + flatten: flatten, + desc: desc, + attachment: attachment, + delimiter: delimiter, + bom: bom, + xmlRoot: xmlRoot, + xmlRow: xmlRow, + skipHeaderRow: skipHeaderRow, + skipHidden: skipHidden, + skipEmpty: skipEmpty, + simplified: simplified, + skipFailedPages: skipFailedPages, + cancellationToken: cancellationToken + ).ConfigureAwait(false); + + return __response.Body; + } + /// + /// Run Actor synchronously with input and get dataset items
+ /// Runs a specific Actor and returns its dataset items.
+ /// The POST payload including its `Content-Type` header is passed as `INPUT` to
+ /// the Actor (usually `application/json`).
+ /// The HTTP response contains the Actors dataset items, while the format of
+ /// items depends on specifying dataset items' `format` parameter.
+ /// You can send all the same options in parameters as the [Get Dataset
+ /// Items](#/reference/datasets/item-collection/get-items) API endpoint.
+ /// The Actor is started with the default options; you can override them using
+ /// URL query parameters.
+ /// If the Actor run exceeds 300<!-- MAX_ACTOR_JOB_SYNC_WAIT_SECS --> seconds,
+ /// the HTTP response will return the 408 status code (Request Timeout).
+ /// Beware that it might be impossible to maintain an idle HTTP connection for a
+ /// long period of time,
+ /// due to client timeout or network conditions. Make sure your HTTP client is
+ /// configured to have a long enough connection timeout.
+ /// If the connection breaks, you will not receive any information about the run
+ /// and its status.
+ /// To run the Actor asynchronously, use the [Run
+ /// Actor](#/reference/actors/run-collection/run-actor) API endpoint instead. + ///
+ /// + /// Example: janedoe~my-actor + /// + /// + /// Example: 60 + /// + /// + /// Example: 256 + /// + /// + /// Example: 1000 + /// + /// + /// Example: 5 + /// + /// + /// Example: false + /// + /// + /// Example: 0.1.234 + /// + /// + /// Example: dGhpcyBpcyBqdXN0IGV4YW1wbGUK... + /// + /// + /// Example: json + /// + /// + /// Example: false + /// + /// + /// Example: 0 + /// + /// + /// + /// Example: myValue,myOtherValue + /// + /// + /// Example: myValue,myOtherValue + /// + /// + /// Example: myValue,myOtherValue + /// + /// + /// Example: myValue + /// + /// + /// Example: true + /// + /// + /// Example: true + /// + /// + /// Example: ; + /// + /// + /// Example: false + /// + /// + /// Example: items + /// + /// + /// Example: item + /// + /// + /// Example: true + /// + /// + /// Example: false + /// + /// + /// Example: false + /// + /// + /// Example: false + /// + /// + /// Example: false + /// + /// + /// The token to cancel the operation with + /// + public async global::System.Threading.Tasks.Task>> ActRunSyncGetDatasetItemsPostAsResponseAsync( + string actorId, + object request, double? timeout = default, double? memory = default, @@ -528,9 +699,12 @@ partial void ProcessActRunSyncGetDatasetItemsPostResponseContent( { __response.EnsureSuccessStatusCode(); - return - (global::System.Collections.Generic.IList?)global::System.Text.Json.JsonSerializer.Deserialize(__content, typeof(global::System.Collections.Generic.IList), JsonSerializerContext) ?? + 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::Apify.AutoSDKHttpResponse>( + statusCode: __response.StatusCode, + headers: global::Apify.AutoSDKHttpResponse.CreateHeaders(__response), + body: __value); } catch (global::System.Exception __ex) { @@ -559,9 +733,12 @@ partial void ProcessActRunSyncGetDatasetItemsPostResponseContent( #endif ).ConfigureAwait(false); - return - (global::System.Collections.Generic.IList?)await global::System.Text.Json.JsonSerializer.DeserializeAsync(__content, typeof(global::System.Collections.Generic.IList), JsonSerializerContext).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::Apify.AutoSDKHttpResponse>( + statusCode: __response.StatusCode, + headers: global::Apify.AutoSDKHttpResponse.CreateHeaders(__response), + body: __value); } catch (global::System.Exception __ex) { diff --git a/src/libs/Apify/Generated/Apify.ActorsActorRunsClient.ActRunsPost.g.cs b/src/libs/Apify/Generated/Apify.ActorsActorRunsClient.ActRunsPost.g.cs index aca5313..f4846f9 100644 --- a/src/libs/Apify/Generated/Apify.ActorsActorRunsClient.ActRunsPost.g.cs +++ b/src/libs/Apify/Generated/Apify.ActorsActorRunsClient.ActRunsPost.g.cs @@ -96,6 +96,91 @@ partial void ProcessActRunsPostResponseContent( public async global::System.Threading.Tasks.Task ActRunsPostAsync( string actorId, + object request, + double? timeout = default, + double? memory = default, + double? maxItems = default, + double? maxTotalChargeUsd = default, + bool? restartOnError = default, + string? build = default, + double? waitForFinish = default, + string? webhooks = default, + global::Apify.ActRunsPostForcePermissionLevel? forcePermissionLevel = default, + global::System.Threading.CancellationToken cancellationToken = default) + { + var __response = await ActRunsPostAsResponseAsync( + actorId: actorId, + + request: request, + timeout: timeout, + memory: memory, + maxItems: maxItems, + maxTotalChargeUsd: maxTotalChargeUsd, + restartOnError: restartOnError, + build: build, + waitForFinish: waitForFinish, + webhooks: webhooks, + forcePermissionLevel: forcePermissionLevel, + cancellationToken: cancellationToken + ).ConfigureAwait(false); + + return __response.Body; + } + /// + /// Run Actor
+ /// Runs an Actor and immediately returns without waiting for the run to finish.
+ /// The POST payload including its `Content-Type` header is passed as `INPUT` to
+ /// the Actor (usually `application/json`).
+ /// The Actor is started with the default options; you can override them using
+ /// various URL query parameters.
+ /// The response is the Run object as returned by the [Get
+ /// run](#/reference/actor-runs/run-object-and-its-storages/get-run) API
+ /// endpoint.
+ /// If you want to wait for the run to finish and receive the actual output of
+ /// the Actor as the response, please use one of the [Run Actor
+ /// synchronously](#/reference/actors/run-actor-synchronously) API endpoints
+ /// instead.
+ /// To fetch the Actor run results that are typically stored in the default
+ /// dataset, you'll need to pass the ID received in the `defaultDatasetId` field
+ /// received in the response JSON to the [Get dataset items](#/reference/datasets/item-collection/get-items)
+ /// API endpoint. + ///
+ /// + /// Example: janedoe~my-actor + /// + /// + /// Example: 60 + /// + /// + /// Example: 256 + /// + /// + /// Example: 1000 + /// + /// + /// Example: 5 + /// + /// + /// Example: false + /// + /// + /// Example: 0.1.234 + /// + /// + /// Example: 60 + /// + /// + /// Example: dGhpcyBpcyBqdXN0IGV4YW1wbGUK... + /// + /// + /// Example: LIMITED_PERMISSIONS + /// + /// + /// The token to cancel the operation with + /// + public async global::System.Threading.Tasks.Task> ActRunsPostAsResponseAsync( + string actorId, + object request, double? timeout = default, double? memory = default, @@ -526,9 +611,12 @@ partial void ProcessActRunsPostResponseContent( { __response.EnsureSuccessStatusCode(); - return - global::Apify.RunResponse.FromJson(__content, JsonSerializerContext) ?? + var __value = global::Apify.RunResponse.FromJson(__content, JsonSerializerContext) ?? throw new global::System.InvalidOperationException($"Response deserialization failed for \"{__content}\" "); + return new global::Apify.AutoSDKHttpResponse( + statusCode: __response.StatusCode, + headers: global::Apify.AutoSDKHttpResponse.CreateHeaders(__response), + body: __value); } catch (global::System.Exception __ex) { @@ -557,9 +645,12 @@ partial void ProcessActRunsPostResponseContent( #endif ).ConfigureAwait(false); - return - await global::Apify.RunResponse.FromJsonStreamAsync(__content, JsonSerializerContext).ConfigureAwait(false) ?? + var __value = await global::Apify.RunResponse.FromJsonStreamAsync(__content, JsonSerializerContext).ConfigureAwait(false) ?? throw new global::System.InvalidOperationException("Response deserialization failed."); + return new global::Apify.AutoSDKHttpResponse( + statusCode: __response.StatusCode, + headers: global::Apify.AutoSDKHttpResponse.CreateHeaders(__response), + body: __value); } catch (global::System.Exception __ex) { diff --git a/src/libs/Apify/Generated/Apify.ActorsActorVersionsClient.ActVersionEnvVarsPost.g.cs b/src/libs/Apify/Generated/Apify.ActorsActorVersionsClient.ActVersionEnvVarsPost.g.cs index 5451024..8d38ad2 100644 --- a/src/libs/Apify/Generated/Apify.ActorsActorVersionsClient.ActVersionEnvVarsPost.g.cs +++ b/src/libs/Apify/Generated/Apify.ActorsActorVersionsClient.ActVersionEnvVarsPost.g.cs @@ -56,6 +56,50 @@ partial void ProcessActVersionEnvVarsPostResponseContent( string actorId, string versionNumber, + global::Apify.EnvVar request, + global::System.Threading.CancellationToken cancellationToken = default) + { + var __response = await ActVersionEnvVarsPostAsResponseAsync( + actorId: actorId, + versionNumber: versionNumber, + + request: request, + cancellationToken: cancellationToken + ).ConfigureAwait(false); + + return __response.Body; + } + /// + /// Create environment variable
+ /// Creates an environment variable of an Actor using values specified in a
+ /// [EnvVar object](#/reference/actors/environment-variable-object) passed as
+ /// JSON in the POST payload.
+ /// The request must specify `name` and `value` parameters (as strings) in the
+ /// JSON payload and a `Content-Type: application/json` HTTP header.
+ /// ```
+ /// {
+ /// "name": "ENV_VAR_NAME",
+ /// "value": "my-env-var"
+ /// }
+ /// ```
+ /// The response is the [EnvVar
+ /// object](#/reference/actors/environment-variable-object) as returned by the [Get environment
+ /// variable](#/reference/actors/environment-variable-object/get-environment-variable)
+ /// endpoint. + ///
+ /// + /// Example: janedoe~my-actor + /// + /// + /// Example: 0.1 + /// + /// + /// The token to cancel the operation with + /// + public async global::System.Threading.Tasks.Task> ActVersionEnvVarsPostAsResponseAsync( + string actorId, + string versionNumber, + global::Apify.EnvVar request, global::System.Threading.CancellationToken cancellationToken = default) { @@ -450,9 +494,12 @@ partial void ProcessActVersionEnvVarsPostResponseContent( { __response.EnsureSuccessStatusCode(); - return - global::Apify.EnvVarResponse.FromJson(__content, JsonSerializerContext) ?? + var __value = global::Apify.EnvVarResponse.FromJson(__content, JsonSerializerContext) ?? throw new global::System.InvalidOperationException($"Response deserialization failed for \"{__content}\" "); + return new global::Apify.AutoSDKHttpResponse( + statusCode: __response.StatusCode, + headers: global::Apify.AutoSDKHttpResponse.CreateHeaders(__response), + body: __value); } catch (global::System.Exception __ex) { @@ -481,9 +528,12 @@ partial void ProcessActVersionEnvVarsPostResponseContent( #endif ).ConfigureAwait(false); - return - await global::Apify.EnvVarResponse.FromJsonStreamAsync(__content, JsonSerializerContext).ConfigureAwait(false) ?? + var __value = await global::Apify.EnvVarResponse.FromJsonStreamAsync(__content, JsonSerializerContext).ConfigureAwait(false) ?? throw new global::System.InvalidOperationException("Response deserialization failed."); + return new global::Apify.AutoSDKHttpResponse( + statusCode: __response.StatusCode, + headers: global::Apify.AutoSDKHttpResponse.CreateHeaders(__response), + body: __value); } catch (global::System.Exception __ex) { diff --git a/src/libs/Apify/Generated/Apify.ActorsActorVersionsClient.ActVersionsPost.g.cs b/src/libs/Apify/Generated/Apify.ActorsActorVersionsClient.ActVersionsPost.g.cs index 4b3d036..9a82afd 100644 --- a/src/libs/Apify/Generated/Apify.ActorsActorVersionsClient.ActVersionsPost.g.cs +++ b/src/libs/Apify/Generated/Apify.ActorsActorVersionsClient.ActVersionsPost.g.cs @@ -59,6 +59,54 @@ partial void ProcessActVersionsPostResponseContent( public async global::System.Threading.Tasks.Task ActVersionsPostAsync( string actorId, + global::Apify.CreateOrUpdateVersionRequest request, + global::System.Threading.CancellationToken cancellationToken = default) + { + var __response = await ActVersionsPostAsResponseAsync( + actorId: actorId, + + request: request, + cancellationToken: cancellationToken + ).ConfigureAwait(false); + + return __response.Body; + } + /// + /// Create version
+ /// Creates a version of an Actor using values specified in a [Version
+ /// object](#/reference/actors/version-object) passed as JSON in the POST
+ /// payload.
+ /// The request must specify `versionNumber` and `sourceType` parameters (as
+ /// strings) in the JSON payload and a `Content-Type: application/json` HTTP
+ /// header.
+ /// Each `sourceType` requires its own additional properties to be passed to the
+ /// JSON payload object. These are outlined in the [Version
+ /// object](#/reference/actors/version-object) table below and in more detail in
+ /// the [Apify
+ /// documentation](https://docs.apify.com/platform/actors/development/deployment/source-types).
+ /// For example, if an Actor's source code is stored in a [GitHub
+ /// repository](https://docs.apify.com/platform/actors/development/deployment/source-types#git-repository),
+ /// you will set the `sourceType` to `GIT_REPO` and pass the repository's URL in
+ /// the `gitRepoUrl` property.
+ /// ```
+ /// {
+ /// "versionNumber": "0.1",
+ /// "sourceType": "GIT_REPO",
+ /// "gitRepoUrl": "https://github.com/my-github-account/actor-repo"
+ /// }
+ /// ```
+ /// The response is the [Version object](#/reference/actors/version-object) as
+ /// returned by the [Get version](#/reference/actors/version-object/get-version) endpoint. + ///
+ /// + /// Example: janedoe~my-actor + /// + /// + /// The token to cancel the operation with + /// + public async global::System.Threading.Tasks.Task> ActVersionsPostAsResponseAsync( + string actorId, + global::Apify.CreateOrUpdateVersionRequest request, global::System.Threading.CancellationToken cancellationToken = default) { @@ -451,9 +499,12 @@ partial void ProcessActVersionsPostResponseContent( { __response.EnsureSuccessStatusCode(); - return - global::Apify.VersionResponse.FromJson(__content, JsonSerializerContext) ?? + var __value = global::Apify.VersionResponse.FromJson(__content, JsonSerializerContext) ?? throw new global::System.InvalidOperationException($"Response deserialization failed for \"{__content}\" "); + return new global::Apify.AutoSDKHttpResponse( + statusCode: __response.StatusCode, + headers: global::Apify.AutoSDKHttpResponse.CreateHeaders(__response), + body: __value); } catch (global::System.Exception __ex) { @@ -482,9 +533,12 @@ partial void ProcessActVersionsPostResponseContent( #endif ).ConfigureAwait(false); - return - await global::Apify.VersionResponse.FromJsonStreamAsync(__content, JsonSerializerContext).ConfigureAwait(false) ?? + var __value = await global::Apify.VersionResponse.FromJsonStreamAsync(__content, JsonSerializerContext).ConfigureAwait(false) ?? throw new global::System.InvalidOperationException("Response deserialization failed."); + return new global::Apify.AutoSDKHttpResponse( + statusCode: __response.StatusCode, + headers: global::Apify.AutoSDKHttpResponse.CreateHeaders(__response), + body: __value); } catch (global::System.Exception __ex) { diff --git a/src/libs/Apify/Generated/Apify.ActorsClient.ActsPost.g.cs b/src/libs/Apify/Generated/Apify.ActorsClient.ActsPost.g.cs index 4383ee1..9668c6a 100644 --- a/src/libs/Apify/Generated/Apify.ActorsClient.ActsPost.g.cs +++ b/src/libs/Apify/Generated/Apify.ActorsClient.ActsPost.g.cs @@ -44,6 +44,38 @@ partial void ProcessActsPostResponseContent( /// public async global::System.Threading.Tasks.Task ActsPostAsync( + global::Apify.CreateActorRequest request, + global::System.Threading.CancellationToken cancellationToken = default) + { + var __response = await ActsPostAsResponseAsync( + + request: request, + cancellationToken: cancellationToken + ).ConfigureAwait(false); + + return __response.Body; + } + /// + /// Create Actor
+ /// Creates a new Actor with settings specified in an Actor object passed as
+ /// JSON in the POST payload.
+ /// The response is the full Actor object as returned by the
+ /// [Get Actor](#/reference/actors/actor-object/get-actor) endpoint.
+ /// The HTTP request must have the `Content-Type: application/json` HTTP header!
+ /// The Actor needs to define at least one version of the source code.
+ /// For more information, see [Version object](#/reference/actors/version-object).
+ /// If you want to make your Actor
+ /// [public](https://docs.apify.com/platform/actors/publishing) using `isPublic:
+ /// true`, you will need to provide the Actor's `title` and the `categories`
+ /// under which that Actor will be classified in Apify Store. For this, it's
+ /// best to use the [constants from our `apify-shared-js`
+ /// package](https://github.com/apify/apify-shared-js/blob/2d43ebc41ece9ad31cd6525bd523fb86939bf860/packages/consts/src/consts.ts#L452-L471). + ///
+ /// + /// The token to cancel the operation with + /// + public async global::System.Threading.Tasks.Task> ActsPostAsResponseAsync( + global::Apify.CreateActorRequest request, global::System.Threading.CancellationToken cancellationToken = default) { @@ -396,9 +428,12 @@ partial void ProcessActsPostResponseContent( { __response.EnsureSuccessStatusCode(); - return - global::Apify.ActorResponse.FromJson(__content, JsonSerializerContext) ?? + var __value = global::Apify.ActorResponse.FromJson(__content, JsonSerializerContext) ?? throw new global::System.InvalidOperationException($"Response deserialization failed for \"{__content}\" "); + return new global::Apify.AutoSDKHttpResponse( + statusCode: __response.StatusCode, + headers: global::Apify.AutoSDKHttpResponse.CreateHeaders(__response), + body: __value); } catch (global::System.Exception __ex) { @@ -427,9 +462,12 @@ partial void ProcessActsPostResponseContent( #endif ).ConfigureAwait(false); - return - await global::Apify.ActorResponse.FromJsonStreamAsync(__content, JsonSerializerContext).ConfigureAwait(false) ?? + var __value = await global::Apify.ActorResponse.FromJsonStreamAsync(__content, JsonSerializerContext).ConfigureAwait(false) ?? throw new global::System.InvalidOperationException("Response deserialization failed."); + return new global::Apify.AutoSDKHttpResponse( + statusCode: __response.StatusCode, + headers: global::Apify.AutoSDKHttpResponse.CreateHeaders(__response), + body: __value); } catch (global::System.Exception __ex) { diff --git a/src/libs/Apify/Generated/Apify.AutoSDKHttpResponse.g.cs b/src/libs/Apify/Generated/Apify.AutoSDKHttpResponse.g.cs new file mode 100644 index 0000000..f0a51b5 --- /dev/null +++ b/src/libs/Apify/Generated/Apify.AutoSDKHttpResponse.g.cs @@ -0,0 +1,86 @@ + +#nullable enable + +namespace Apify +{ + /// + /// Represents a successful HTTP response with status code and headers. + /// + public partial class AutoSDKHttpResponse + { + /// + /// Initializes a new instance of the class. + /// + public AutoSDKHttpResponse( + global::System.Net.HttpStatusCode statusCode, + global::System.Collections.Generic.Dictionary> headers) + { + StatusCode = statusCode; + Headers = headers ?? throw new global::System.ArgumentNullException(nameof(headers)); + } + + /// + /// Gets the HTTP status code. + /// + public global::System.Net.HttpStatusCode StatusCode { get; } + /// + /// Gets the response headers. + /// + public global::System.Collections.Generic.Dictionary> Headers { get; } + + internal static global::System.Collections.Generic.Dictionary> CreateHeaders( + global::System.Net.Http.HttpResponseMessage response) + { + response = response ?? throw new global::System.ArgumentNullException(nameof(response)); + + var headers = global::System.Linq.Enumerable.ToDictionary( + response.Headers, + static header => header.Key, + static header => (global::System.Collections.Generic.IEnumerable)global::System.Linq.Enumerable.ToArray(header.Value), + global::System.StringComparer.OrdinalIgnoreCase); + + if (response.Content?.Headers == null) + { + return headers; + } + + foreach (var header in response.Content.Headers) + { + if (headers.TryGetValue(header.Key, out var existingValues)) + { + headers[header.Key] = global::System.Linq.Enumerable.ToArray( + global::System.Linq.Enumerable.Concat(existingValues, header.Value)); + } + else + { + headers[header.Key] = global::System.Linq.Enumerable.ToArray(header.Value); + } + } + + return headers; + } + } + + /// + /// Represents a successful HTTP response with status code, headers, and body. + /// + public partial class AutoSDKHttpResponse : AutoSDKHttpResponse + { + /// + /// Initializes a new instance of the class. + /// + public AutoSDKHttpResponse( + global::System.Net.HttpStatusCode statusCode, + global::System.Collections.Generic.Dictionary> headers, + T body) + : base(statusCode, headers) + { + Body = body; + } + + /// + /// Gets the response body. + /// + public T Body { get; } + } +} \ No newline at end of file diff --git a/src/libs/Apify/Generated/Apify.IActorTasksClient.ActorTaskRunSyncGetDatasetItemsGet.g.cs b/src/libs/Apify/Generated/Apify.IActorTasksClient.ActorTaskRunSyncGetDatasetItemsGet.g.cs index 21f4e8b..c56e8f2 100644 --- a/src/libs/Apify/Generated/Apify.IActorTasksClient.ActorTaskRunSyncGetDatasetItemsGet.g.cs +++ b/src/libs/Apify/Generated/Apify.IActorTasksClient.ActorTaskRunSyncGetDatasetItemsGet.g.cs @@ -123,5 +123,124 @@ public partial interface IActorTasksClient bool? simplified = default, bool? skipFailedPages = default, global::System.Threading.CancellationToken cancellationToken = default); + /// + /// Run task synchronously and get dataset items
+ /// Run a specific task and return its dataset items.
+ /// The run must finish in 300<!-- MAX_ACTOR_JOB_SYNC_WAIT_SECS --> seconds
+ /// otherwise the HTTP request fails with a timeout error (this won't abort
+ /// the run itself).
+ /// You can send all the same options in parameters as the [Get Dataset
+ /// Items](#/reference/datasets/item-collection/get-items) API endpoint.
+ /// Beware that it might be impossible to maintain an idle HTTP connection for
+ /// an extended period, due to client timeout or network conditions. Make sure your HTTP client is
+ /// configured to have a long enough connection timeout.
+ /// If the connection breaks, you will not receive any information about the run
+ /// and its status.
+ /// To run the Task asynchronously, use the [Run task
+ /// asynchronously](#/reference/actor-tasks/run-collection/run-task) endpoint
+ /// instead. + ///
+ /// + /// Example: janedoe~my-task + /// + /// + /// Example: 60 + /// + /// + /// Example: 256 + /// + /// + /// Example: 1000 + /// + /// + /// Example: 0.1.234 + /// + /// + /// Example: dGhpcyBpcyBqdXN0IGV4YW1wbGUK... + /// + /// + /// Example: json + /// + /// + /// Example: false + /// + /// + /// Example: 0 + /// + /// + /// + /// Example: myValue,myOtherValue + /// + /// + /// Example: myValue,myOtherValue + /// + /// + /// Example: myValue,myOtherValue + /// + /// + /// Example: myValue + /// + /// + /// Example: true + /// + /// + /// Example: true + /// + /// + /// Example: ; + /// + /// + /// Example: false + /// + /// + /// Example: items + /// + /// + /// Example: item + /// + /// + /// Example: true + /// + /// + /// Example: false + /// + /// + /// Example: false + /// + /// + /// Example: false + /// + /// + /// Example: false + /// + /// The token to cancel the operation with + /// + global::System.Threading.Tasks.Task> ActorTaskRunSyncGetDatasetItemsGetAsResponseAsync( + string actorTaskId, + double? timeout = default, + double? memory = default, + double? maxItems = default, + string? build = default, + string? webhooks = default, + string? format = default, + bool? clean = default, + double? offset = default, + double? limit = default, + string? fields = default, + string? omit = default, + string? unwind = default, + string? flatten = default, + bool? desc = default, + bool? attachment = default, + string? delimiter = default, + bool? bom = default, + string? xmlRoot = default, + string? xmlRow = default, + bool? skipHeaderRow = default, + bool? skipHidden = default, + bool? skipEmpty = default, + bool? simplified = default, + bool? skipFailedPages = default, + global::System.Threading.CancellationToken cancellationToken = default); } } \ No newline at end of file diff --git a/src/libs/Apify/Generated/Apify.IActorTasksClient.ActorTaskRunSyncGetDatasetItemsPost.g.cs b/src/libs/Apify/Generated/Apify.IActorTasksClient.ActorTaskRunSyncGetDatasetItemsPost.g.cs index e7c0c36..573cff8 100644 --- a/src/libs/Apify/Generated/Apify.IActorTasksClient.ActorTaskRunSyncGetDatasetItemsPost.g.cs +++ b/src/libs/Apify/Generated/Apify.IActorTasksClient.ActorTaskRunSyncGetDatasetItemsPost.g.cs @@ -246,6 +246,144 @@ public partial interface IActorTasksClient /// /// Example: false /// + /// + /// The token to cancel the operation with + /// + global::System.Threading.Tasks.Task> ActorTaskRunSyncGetDatasetItemsPostAsResponseAsync( + string actorTaskId, + + object request, + double? timeout = default, + double? memory = default, + double? maxItems = default, + double? maxTotalChargeUsd = default, + bool? restartOnError = default, + string? build = default, + string? webhooks = default, + string? format = default, + bool? clean = default, + double? offset = default, + double? limit = default, + string? fields = default, + string? omit = default, + string? unwind = default, + string? flatten = default, + bool? desc = default, + bool? attachment = default, + string? delimiter = default, + bool? bom = default, + string? xmlRoot = default, + string? xmlRow = default, + bool? skipHeaderRow = default, + bool? skipHidden = default, + bool? skipEmpty = default, + bool? simplified = default, + bool? skipFailedPages = default, + global::System.Threading.CancellationToken cancellationToken = default); + /// + /// Run task synchronously and get dataset items
+ /// Runs an Actor task and synchronously returns its dataset items.
+ /// The run must finish in 300<!-- MAX_ACTOR_JOB_SYNC_WAIT_SECS --> seconds
+ /// otherwise the HTTP request fails with a timeout error (this won't abort
+ /// the run itself).
+ /// Optionally, you can override the Actor input configuration by passing a JSON
+ /// object as the POST payload and setting the `Content-Type: application/json` HTTP header.
+ /// Note that if the object in the POST payload does not define a particular
+ /// input property, the Actor run uses the default value defined by the task (or the Actor's
+ /// input schema if not defined by the task).
+ /// You can send all the same options in parameters as the [Get Dataset
+ /// Items](#/reference/datasets/item-collection/get-items) API endpoint.
+ /// Beware that it might be impossible to maintain an idle HTTP connection for
+ /// an extended period, due to client timeout or network conditions. Make sure your HTTP client is
+ /// configured to have a long enough connection timeout.
+ /// If the connection breaks, you will not receive any information about the run
+ /// and its status.
+ /// Input fields from Actor task configuration can be overloaded with values
+ /// passed as the POST payload.
+ /// Just make sure to specify the `Content-Type` header as `application/json`
+ /// and that the input is an object.
+ /// To run the task asynchronously, use the [Run
+ /// task](#/reference/actor-tasks/run-collection/run-task) API endpoint instead. + ///
+ /// + /// Example: janedoe~my-task + /// + /// + /// Example: 60 + /// + /// + /// Example: 256 + /// + /// + /// Example: 1000 + /// + /// + /// Example: 5 + /// + /// + /// Example: false + /// + /// + /// Example: 0.1.234 + /// + /// + /// Example: dGhpcyBpcyBqdXN0IGV4YW1wbGUK... + /// + /// + /// Example: json + /// + /// + /// Example: false + /// + /// + /// Example: 0 + /// + /// + /// + /// Example: myValue,myOtherValue + /// + /// + /// Example: myValue,myOtherValue + /// + /// + /// Example: myValue,myOtherValue + /// + /// + /// Example: myValue + /// + /// + /// Example: true + /// + /// + /// Example: true + /// + /// + /// Example: ; + /// + /// + /// Example: false + /// + /// + /// Example: items + /// + /// + /// Example: item + /// + /// + /// Example: true + /// + /// + /// Example: false + /// + /// + /// Example: false + /// + /// + /// Example: false + /// + /// + /// Example: false + /// /// The token to cancel the operation with /// global::System.Threading.Tasks.Task ActorTaskRunSyncGetDatasetItemsPostAsync( diff --git a/src/libs/Apify/Generated/Apify.IActorTasksClient.ActorTaskRunsPost.g.cs b/src/libs/Apify/Generated/Apify.IActorTasksClient.ActorTaskRunsPost.g.cs index b353f59..5641fcb 100644 --- a/src/libs/Apify/Generated/Apify.IActorTasksClient.ActorTaskRunsPost.g.cs +++ b/src/libs/Apify/Generated/Apify.IActorTasksClient.ActorTaskRunsPost.g.cs @@ -114,6 +114,69 @@ public partial interface IActorTasksClient /// /// Example: dGhpcyBpcyBqdXN0IGV4YW1wbGUK... /// + /// + /// The token to cancel the operation with + /// + global::System.Threading.Tasks.Task> ActorTaskRunsPostAsResponseAsync( + string actorTaskId, + + object request, + double? timeout = default, + double? memory = default, + double? maxItems = default, + double? maxTotalChargeUsd = default, + bool? restartOnError = default, + string? build = default, + double? waitForFinish = default, + string? webhooks = default, + global::System.Threading.CancellationToken cancellationToken = default); + /// + /// Run task
+ /// Runs an Actor task and immediately returns without waiting for the run to
+ /// finish.
+ /// Optionally, you can override the Actor input configuration by passing a JSON
+ /// object as the POST payload and setting the `Content-Type: application/json` HTTP header.
+ /// Note that if the object in the POST payload does not define a particular
+ /// input property, the Actor run uses the default value defined by the task (or Actor's input
+ /// schema if not defined by the task).
+ /// The response is the Actor Run object as returned by the [Get
+ /// run](#/reference/actor-runs/run-object-and-its-storages/get-run) endpoint.
+ /// If you want to wait for the run to finish and receive the actual output of
+ /// the Actor run as the response, use one of the [Run task
+ /// synchronously](#/reference/actor-tasks/run-task-synchronously) API endpoints
+ /// instead.
+ /// To fetch the Actor run results that are typically stored in the default
+ /// dataset, you'll need to pass the ID received in the `defaultDatasetId` field
+ /// received in the response JSON to the
+ /// [Get dataset items](#/reference/datasets/item-collection/get-items) API endpoint. + ///
+ /// + /// Example: janedoe~my-task + /// + /// + /// Example: 60 + /// + /// + /// Example: 256 + /// + /// + /// Example: 1000 + /// + /// + /// Example: 5 + /// + /// + /// Example: false + /// + /// + /// Example: 0.1.234 + /// + /// + /// Example: 60 + /// + /// + /// Example: dGhpcyBpcyBqdXN0IGV4YW1wbGUK... + /// /// The token to cancel the operation with /// global::System.Threading.Tasks.Task ActorTaskRunsPostAsync( diff --git a/src/libs/Apify/Generated/Apify.IActorTasksClient.ActorTasksPost.g.cs b/src/libs/Apify/Generated/Apify.IActorTasksClient.ActorTasksPost.g.cs index 6ec49d9..9b3d5a4 100644 --- a/src/libs/Apify/Generated/Apify.IActorTasksClient.ActorTasksPost.g.cs +++ b/src/libs/Apify/Generated/Apify.IActorTasksClient.ActorTasksPost.g.cs @@ -33,6 +33,24 @@ public partial interface IActorTasksClient /// request's `Authorization` header, rather than the URL. ([More
/// info](#/introduction/authentication)). /// + /// + /// The token to cancel the operation with + /// + global::System.Threading.Tasks.Task> ActorTasksPostAsResponseAsync( + + global::Apify.AllOf request, + global::System.Threading.CancellationToken cancellationToken = default); + /// + /// Create task
+ /// Create a new task with settings specified by the object passed as JSON in
+ /// the POST payload.
+ /// The response is the full task object as returned by the
+ /// [Get task](#/reference/tasks/task-object/get-task) endpoint.
+ /// The request needs to specify the `Content-Type: application/json` HTTP header!
+ /// When providing your API authentication token, we recommend using the
+ /// request's `Authorization` header, rather than the URL. ([More
+ /// info](#/introduction/authentication)). + ///
/// The token to cancel the operation with /// global::System.Threading.Tasks.Task ActorTasksPostAsync( diff --git a/src/libs/Apify/Generated/Apify.IActorsActorBuildsClient.ActBuildsPost.g.cs b/src/libs/Apify/Generated/Apify.IActorsActorBuildsClient.ActBuildsPost.g.cs index 7079003..906672d 100644 --- a/src/libs/Apify/Generated/Apify.IActorsActorBuildsClient.ActBuildsPost.g.cs +++ b/src/libs/Apify/Generated/Apify.IActorsActorBuildsClient.ActBuildsPost.g.cs @@ -38,5 +38,39 @@ public partial interface IActorsActorBuildsClient string? tag = default, double? waitForFinish = default, global::System.Threading.CancellationToken cancellationToken = default); + /// + /// Build Actor
+ /// Builds an Actor.
+ /// The response is the build object as returned by the
+ /// [Get build](#/reference/actors/build-object/get-build) endpoint. + ///
+ /// + /// Example: janedoe~my-actor + /// + /// + /// Example: 0.0 + /// + /// + /// Example: true + /// + /// + /// Example: true + /// + /// + /// Example: latest + /// + /// + /// Example: 60 + /// + /// The token to cancel the operation with + /// + global::System.Threading.Tasks.Task> ActBuildsPostAsResponseAsync( + string actorId, + string version, + bool? useCache = default, + bool? betaPackages = default, + string? tag = default, + double? waitForFinish = default, + global::System.Threading.CancellationToken cancellationToken = default); } } \ No newline at end of file diff --git a/src/libs/Apify/Generated/Apify.IActorsActorRunsClient.ActRunSyncGetDatasetItemsGet.g.cs b/src/libs/Apify/Generated/Apify.IActorsActorRunsClient.ActRunSyncGetDatasetItemsGet.g.cs index eef6506..20c24f7 100644 --- a/src/libs/Apify/Generated/Apify.IActorsActorRunsClient.ActRunSyncGetDatasetItemsGet.g.cs +++ b/src/libs/Apify/Generated/Apify.IActorsActorRunsClient.ActRunSyncGetDatasetItemsGet.g.cs @@ -131,5 +131,132 @@ public partial interface IActorsActorRunsClient bool? simplified = default, bool? skipFailedPages = default, global::System.Threading.CancellationToken cancellationToken = default); + /// + /// Run Actor synchronously without input and get dataset items
+ /// Runs a specific Actor and returns its dataset items.
+ /// The run must finish in 300<!-- MAX_ACTOR_JOB_SYNC_WAIT_SECS --> seconds
+ /// otherwise the API endpoint returns a timeout error.
+ /// The Actor is not passed any input.
+ /// It allows to send all possible options in parameters from [Get Dataset
+ /// Items](#/reference/datasets/item-collection/get-items) API endpoint.
+ /// Beware that it might be impossible to maintain an idle HTTP connection for a
+ /// long period of time,
+ /// due to client timeout or network conditions. Make sure your HTTP client is
+ /// configured to have a long enough connection timeout.
+ /// If the connection breaks, you will not receive any information about the run
+ /// and its status.
+ /// To run the Actor asynchronously, use the [Run
+ /// Actor](#/reference/actors/run-collection/run-actor) API endpoint instead. + ///
+ /// + /// Example: janedoe~my-actor + /// + /// + /// Example: 60 + /// + /// + /// Example: 256 + /// + /// + /// Example: 1000 + /// + /// + /// Example: 5 + /// + /// + /// Example: false + /// + /// + /// Example: 0.1.234 + /// + /// + /// Example: dGhpcyBpcyBqdXN0IGV4YW1wbGUK... + /// + /// + /// Example: json + /// + /// + /// Example: false + /// + /// + /// Example: 0 + /// + /// + /// + /// Example: myValue,myOtherValue + /// + /// + /// Example: myValue,myOtherValue + /// + /// + /// Example: myValue,myOtherValue + /// + /// + /// Example: myValue + /// + /// + /// Example: true + /// + /// + /// Example: true + /// + /// + /// Example: ; + /// + /// + /// Example: false + /// + /// + /// Example: items + /// + /// + /// Example: item + /// + /// + /// Example: true + /// + /// + /// Example: false + /// + /// + /// Example: false + /// + /// + /// Example: false + /// + /// + /// Example: false + /// + /// The token to cancel the operation with + /// + global::System.Threading.Tasks.Task>> ActRunSyncGetDatasetItemsGetAsResponseAsync( + string actorId, + double? timeout = default, + double? memory = default, + double? maxItems = default, + double? maxTotalChargeUsd = default, + bool? restartOnError = default, + string? build = default, + string? webhooks = default, + string? format = default, + bool? clean = default, + double? offset = default, + double? limit = default, + string? fields = default, + string? omit = default, + string? unwind = default, + string? flatten = default, + bool? desc = default, + bool? attachment = default, + string? delimiter = default, + bool? bom = default, + string? xmlRoot = default, + string? xmlRow = default, + bool? skipHeaderRow = default, + bool? skipHidden = default, + bool? skipEmpty = default, + bool? simplified = default, + bool? skipFailedPages = default, + global::System.Threading.CancellationToken cancellationToken = default); } } \ No newline at end of file diff --git a/src/libs/Apify/Generated/Apify.IActorsActorRunsClient.ActRunSyncGetDatasetItemsPost.g.cs b/src/libs/Apify/Generated/Apify.IActorsActorRunsClient.ActRunSyncGetDatasetItemsPost.g.cs index 810d3ea..9279e84 100644 --- a/src/libs/Apify/Generated/Apify.IActorsActorRunsClient.ActRunSyncGetDatasetItemsPost.g.cs +++ b/src/libs/Apify/Generated/Apify.IActorsActorRunsClient.ActRunSyncGetDatasetItemsPost.g.cs @@ -240,6 +240,141 @@ public partial interface IActorsActorRunsClient /// /// Example: false /// + /// + /// The token to cancel the operation with + /// + global::System.Threading.Tasks.Task>> ActRunSyncGetDatasetItemsPostAsResponseAsync( + string actorId, + + object request, + double? timeout = default, + double? memory = default, + double? maxItems = default, + double? maxTotalChargeUsd = default, + bool? restartOnError = default, + string? build = default, + string? webhooks = default, + string? format = default, + bool? clean = default, + double? offset = default, + double? limit = default, + string? fields = default, + string? omit = default, + string? unwind = default, + string? flatten = default, + bool? desc = default, + bool? attachment = default, + string? delimiter = default, + bool? bom = default, + string? xmlRoot = default, + string? xmlRow = default, + bool? skipHeaderRow = default, + bool? skipHidden = default, + bool? skipEmpty = default, + bool? simplified = default, + bool? skipFailedPages = default, + global::System.Threading.CancellationToken cancellationToken = default); + /// + /// Run Actor synchronously with input and get dataset items
+ /// Runs a specific Actor and returns its dataset items.
+ /// The POST payload including its `Content-Type` header is passed as `INPUT` to
+ /// the Actor (usually `application/json`).
+ /// The HTTP response contains the Actors dataset items, while the format of
+ /// items depends on specifying dataset items' `format` parameter.
+ /// You can send all the same options in parameters as the [Get Dataset
+ /// Items](#/reference/datasets/item-collection/get-items) API endpoint.
+ /// The Actor is started with the default options; you can override them using
+ /// URL query parameters.
+ /// If the Actor run exceeds 300<!-- MAX_ACTOR_JOB_SYNC_WAIT_SECS --> seconds,
+ /// the HTTP response will return the 408 status code (Request Timeout).
+ /// Beware that it might be impossible to maintain an idle HTTP connection for a
+ /// long period of time,
+ /// due to client timeout or network conditions. Make sure your HTTP client is
+ /// configured to have a long enough connection timeout.
+ /// If the connection breaks, you will not receive any information about the run
+ /// and its status.
+ /// To run the Actor asynchronously, use the [Run
+ /// Actor](#/reference/actors/run-collection/run-actor) API endpoint instead. + ///
+ /// + /// Example: janedoe~my-actor + /// + /// + /// Example: 60 + /// + /// + /// Example: 256 + /// + /// + /// Example: 1000 + /// + /// + /// Example: 5 + /// + /// + /// Example: false + /// + /// + /// Example: 0.1.234 + /// + /// + /// Example: dGhpcyBpcyBqdXN0IGV4YW1wbGUK... + /// + /// + /// Example: json + /// + /// + /// Example: false + /// + /// + /// Example: 0 + /// + /// + /// + /// Example: myValue,myOtherValue + /// + /// + /// Example: myValue,myOtherValue + /// + /// + /// Example: myValue,myOtherValue + /// + /// + /// Example: myValue + /// + /// + /// Example: true + /// + /// + /// Example: true + /// + /// + /// Example: ; + /// + /// + /// Example: false + /// + /// + /// Example: items + /// + /// + /// Example: item + /// + /// + /// Example: true + /// + /// + /// Example: false + /// + /// + /// Example: false + /// + /// + /// Example: false + /// + /// + /// Example: false + /// /// The token to cancel the operation with /// global::System.Threading.Tasks.Task> ActRunSyncGetDatasetItemsPostAsync( diff --git a/src/libs/Apify/Generated/Apify.IActorsActorRunsClient.ActRunsPost.g.cs b/src/libs/Apify/Generated/Apify.IActorsActorRunsClient.ActRunsPost.g.cs index e9b4b9b..7615ebc 100644 --- a/src/libs/Apify/Generated/Apify.IActorsActorRunsClient.ActRunsPost.g.cs +++ b/src/libs/Apify/Generated/Apify.IActorsActorRunsClient.ActRunsPost.g.cs @@ -119,6 +119,72 @@ public partial interface IActorsActorRunsClient /// /// Example: LIMITED_PERMISSIONS /// + /// + /// The token to cancel the operation with + /// + global::System.Threading.Tasks.Task> ActRunsPostAsResponseAsync( + string actorId, + + object request, + double? timeout = default, + double? memory = default, + double? maxItems = default, + double? maxTotalChargeUsd = default, + bool? restartOnError = default, + string? build = default, + double? waitForFinish = default, + string? webhooks = default, + global::Apify.ActRunsPostForcePermissionLevel? forcePermissionLevel = default, + global::System.Threading.CancellationToken cancellationToken = default); + /// + /// Run Actor
+ /// Runs an Actor and immediately returns without waiting for the run to finish.
+ /// The POST payload including its `Content-Type` header is passed as `INPUT` to
+ /// the Actor (usually `application/json`).
+ /// The Actor is started with the default options; you can override them using
+ /// various URL query parameters.
+ /// The response is the Run object as returned by the [Get
+ /// run](#/reference/actor-runs/run-object-and-its-storages/get-run) API
+ /// endpoint.
+ /// If you want to wait for the run to finish and receive the actual output of
+ /// the Actor as the response, please use one of the [Run Actor
+ /// synchronously](#/reference/actors/run-actor-synchronously) API endpoints
+ /// instead.
+ /// To fetch the Actor run results that are typically stored in the default
+ /// dataset, you'll need to pass the ID received in the `defaultDatasetId` field
+ /// received in the response JSON to the [Get dataset items](#/reference/datasets/item-collection/get-items)
+ /// API endpoint. + ///
+ /// + /// Example: janedoe~my-actor + /// + /// + /// Example: 60 + /// + /// + /// Example: 256 + /// + /// + /// Example: 1000 + /// + /// + /// Example: 5 + /// + /// + /// Example: false + /// + /// + /// Example: 0.1.234 + /// + /// + /// Example: 60 + /// + /// + /// Example: dGhpcyBpcyBqdXN0IGV4YW1wbGUK... + /// + /// + /// Example: LIMITED_PERMISSIONS + /// /// The token to cancel the operation with /// global::System.Threading.Tasks.Task ActRunsPostAsync( diff --git a/src/libs/Apify/Generated/Apify.IActorsActorVersionsClient.ActVersionEnvVarsPost.g.cs b/src/libs/Apify/Generated/Apify.IActorsActorVersionsClient.ActVersionEnvVarsPost.g.cs index 838d129..9340c09 100644 --- a/src/libs/Apify/Generated/Apify.IActorsActorVersionsClient.ActVersionEnvVarsPost.g.cs +++ b/src/libs/Apify/Generated/Apify.IActorsActorVersionsClient.ActVersionEnvVarsPost.g.cs @@ -61,6 +61,39 @@ public partial interface IActorsActorVersionsClient /// /// Example: 0.1 /// + /// + /// The token to cancel the operation with + /// + global::System.Threading.Tasks.Task> ActVersionEnvVarsPostAsResponseAsync( + string actorId, + string versionNumber, + + global::Apify.EnvVar request, + global::System.Threading.CancellationToken cancellationToken = default); + /// + /// Create environment variable
+ /// Creates an environment variable of an Actor using values specified in a
+ /// [EnvVar object](#/reference/actors/environment-variable-object) passed as
+ /// JSON in the POST payload.
+ /// The request must specify `name` and `value` parameters (as strings) in the
+ /// JSON payload and a `Content-Type: application/json` HTTP header.
+ /// ```
+ /// {
+ /// "name": "ENV_VAR_NAME",
+ /// "value": "my-env-var"
+ /// }
+ /// ```
+ /// The response is the [EnvVar
+ /// object](#/reference/actors/environment-variable-object) as returned by the [Get environment
+ /// variable](#/reference/actors/environment-variable-object/get-environment-variable)
+ /// endpoint. + ///
+ /// + /// Example: janedoe~my-actor + /// + /// + /// Example: 0.1 + /// /// /// /// diff --git a/src/libs/Apify/Generated/Apify.IActorsActorVersionsClient.ActVersionsPost.g.cs b/src/libs/Apify/Generated/Apify.IActorsActorVersionsClient.ActVersionsPost.g.cs index 260cbb6..a11a155 100644 --- a/src/libs/Apify/Generated/Apify.IActorsActorVersionsClient.ActVersionsPost.g.cs +++ b/src/libs/Apify/Generated/Apify.IActorsActorVersionsClient.ActVersionsPost.g.cs @@ -72,6 +72,44 @@ public partial interface IActorsActorVersionsClient /// /// Example: janedoe~my-actor /// + /// + /// The token to cancel the operation with + /// + global::System.Threading.Tasks.Task> ActVersionsPostAsResponseAsync( + string actorId, + + global::Apify.CreateOrUpdateVersionRequest request, + global::System.Threading.CancellationToken cancellationToken = default); + /// + /// Create version
+ /// Creates a version of an Actor using values specified in a [Version
+ /// object](#/reference/actors/version-object) passed as JSON in the POST
+ /// payload.
+ /// The request must specify `versionNumber` and `sourceType` parameters (as
+ /// strings) in the JSON payload and a `Content-Type: application/json` HTTP
+ /// header.
+ /// Each `sourceType` requires its own additional properties to be passed to the
+ /// JSON payload object. These are outlined in the [Version
+ /// object](#/reference/actors/version-object) table below and in more detail in
+ /// the [Apify
+ /// documentation](https://docs.apify.com/platform/actors/development/deployment/source-types).
+ /// For example, if an Actor's source code is stored in a [GitHub
+ /// repository](https://docs.apify.com/platform/actors/development/deployment/source-types#git-repository),
+ /// you will set the `sourceType` to `GIT_REPO` and pass the repository's URL in
+ /// the `gitRepoUrl` property.
+ /// ```
+ /// {
+ /// "versionNumber": "0.1",
+ /// "sourceType": "GIT_REPO",
+ /// "gitRepoUrl": "https://github.com/my-github-account/actor-repo"
+ /// }
+ /// ```
+ /// The response is the [Version object](#/reference/actors/version-object) as
+ /// returned by the [Get version](#/reference/actors/version-object/get-version) endpoint. + ///
+ /// + /// Example: janedoe~my-actor + /// /// /// /// diff --git a/src/libs/Apify/Generated/Apify.IActorsClient.ActsPost.g.cs b/src/libs/Apify/Generated/Apify.IActorsClient.ActsPost.g.cs index 67d8c3f..99ed3b3 100644 --- a/src/libs/Apify/Generated/Apify.IActorsClient.ActsPost.g.cs +++ b/src/libs/Apify/Generated/Apify.IActorsClient.ActsPost.g.cs @@ -45,6 +45,29 @@ public partial interface IActorsClient /// best to use the [constants from our `apify-shared-js`
/// package](https://github.com/apify/apify-shared-js/blob/2d43ebc41ece9ad31cd6525bd523fb86939bf860/packages/consts/src/consts.ts#L452-L471). /// + /// + /// The token to cancel the operation with + /// + global::System.Threading.Tasks.Task> ActsPostAsResponseAsync( + + global::Apify.CreateActorRequest request, + global::System.Threading.CancellationToken cancellationToken = default); + /// + /// Create Actor
+ /// Creates a new Actor with settings specified in an Actor object passed as
+ /// JSON in the POST payload.
+ /// The response is the full Actor object as returned by the
+ /// [Get Actor](#/reference/actors/actor-object/get-actor) endpoint.
+ /// The HTTP request must have the `Content-Type: application/json` HTTP header!
+ /// The Actor needs to define at least one version of the source code.
+ /// For more information, see [Version object](#/reference/actors/version-object).
+ /// If you want to make your Actor
+ /// [public](https://docs.apify.com/platform/actors/publishing) using `isPublic:
+ /// true`, you will need to provide the Actor's `title` and the `categories`
+ /// under which that Actor will be classified in Apify Store. For this, it's
+ /// best to use the [constants from our `apify-shared-js`
+ /// package](https://github.com/apify/apify-shared-js/blob/2d43ebc41ece9ad31cd6525bd523fb86939bf860/packages/consts/src/consts.ts#L452-L471). + ///
/// /// /// diff --git a/src/libs/Apify/Generated/Apify.ISchedulesClient.SchedulesPost.g.cs b/src/libs/Apify/Generated/Apify.ISchedulesClient.SchedulesPost.g.cs index d362788..cbd184d 100644 --- a/src/libs/Apify/Generated/Apify.ISchedulesClient.SchedulesPost.g.cs +++ b/src/libs/Apify/Generated/Apify.ISchedulesClient.SchedulesPost.g.cs @@ -29,6 +29,22 @@ public partial interface ISchedulesClient /// request's `Authorization` header, rather than the URL. ([More
/// info](#/introduction/authentication)). /// + /// + /// The token to cancel the operation with + /// + global::System.Threading.Tasks.Task> SchedulesPostAsResponseAsync( + + global::Apify.ScheduleCreate request, + global::System.Threading.CancellationToken cancellationToken = default); + /// + /// Create schedule
+ /// Creates a new schedule with settings provided by the schedule object passed
+ /// as JSON in the payload. The response is the created schedule object.
+ /// The request needs to specify the `Content-Type: application/json` HTTP header!
+ /// When providing your API authentication token, we recommend using the
+ /// request's `Authorization` header, rather than the URL. ([More
+ /// info](#/introduction/authentication)). + ///
/// /// /// diff --git a/src/libs/Apify/Generated/Apify.IStorageDatasetsClient.DatasetItemsGet.g.cs b/src/libs/Apify/Generated/Apify.IStorageDatasetsClient.DatasetItemsGet.g.cs index 27b447d..11c936a 100644 --- a/src/libs/Apify/Generated/Apify.IStorageDatasetsClient.DatasetItemsGet.g.cs +++ b/src/libs/Apify/Generated/Apify.IStorageDatasetsClient.DatasetItemsGet.g.cs @@ -221,5 +221,222 @@ public partial interface IStorageDatasetsClient bool? skipFailedPages = default, string? signature = default, global::System.Threading.CancellationToken cancellationToken = default); + /// + /// Get dataset items
+ /// Returns data stored in the dataset in a desired format.
+ /// ### Response format
+ /// The format of the response depends on <code>format</code> query parameter.
+ /// The <code>format</code> parameter can have one of the following values:
+ /// <code>json</code>, <code>jsonl</code>, <code>xml</code>, <code>html</code>,
+ /// <code>csv</code>, <code>xlsx</code> and <code>rss</code>.
+ /// The following table describes how each format is treated.
+ /// <table>
+ /// <tr>
+ /// <th>Format</th>
+ /// <th>Items</th>
+ /// </tr>
+ /// <tr>
+ /// <td><code>json</code></td>
+ /// <td rowspan="3">The response is a JSON, JSONL or XML array of raw item objects.</td>
+ /// </tr>
+ /// <tr>
+ /// <td><code>jsonl</code></td>
+ /// </tr>
+ /// <tr>
+ /// <td><code>xml</code></td>
+ /// </tr>
+ /// <tr>
+ /// <td><code>html</code></td>
+ /// <td rowspan="3">The response is a HTML, CSV or XLSX table, where columns correspond to the
+ /// properties of the item and rows correspond to each dataset item.</td>
+ /// </tr>
+ /// <tr>
+ /// <td><code>csv</code></td>
+ /// </tr>
+ /// <tr>
+ /// <td><code>xlsx</code></td>
+ /// </tr>
+ /// <tr>
+ /// <td><code>rss</code></td>
+ /// <td colspan="2">The response is a RSS file. Each item is displayed as child elements of one
+ /// <code>&lt;item&gt;</code>.</td>
+ /// </tr>
+ /// </table>
+ /// Note that CSV, XLSX and HTML tables are limited to 2000 columns and the column names cannot be longer than 200 characters.
+ /// JSON, XML and RSS formats do not have such restrictions.
+ /// ### Hidden fields
+ /// The top-level fields starting with the `#` character are considered hidden.
+ /// These are useful to store debugging information and can be omitted from the output by providing the `skipHidden=1` or `clean=1` query parameters.
+ /// For example, if you store the following object to the dataset:
+ /// ```
+ /// {
+ /// productName: "iPhone Xs",
+ /// description: "Welcome to the big screens."
+ /// #debug: {
+ /// url: "https://www.apple.com/lae/iphone-xs/",
+ /// crawledAt: "2019-01-21T16:06:03.683Z"
+ /// }
+ /// }
+ /// ```
+ /// The `#debug` field will be considered as hidden and can be omitted from the
+ /// results. This is useful to
+ /// provide nice cleaned data to end users, while keeping debugging info
+ /// available if needed. The Dataset object
+ /// returned by the API contains the number of such clean items in the`dataset.cleanItemCount` property.
+ /// ### XML format extension
+ /// When exporting results to XML or RSS formats, the names of object properties become XML tags and the corresponding values become tag's children. For example, the following JavaScript object:
+ /// ```
+ /// {
+ /// name: "Paul Newman",
+ /// address: [
+ /// { type: "home", street: "21st", city: "Chicago" },
+ /// { type: "office", street: null, city: null }
+ /// ]
+ /// }
+ /// ```
+ /// will be transformed to the following XML snippet:
+ /// ```
+ /// <name>Paul Newman</name>
+ /// <address>
+ /// <type>home</type>
+ /// <street>21st</street>
+ /// <city>Chicago</city>
+ /// </address>
+ /// <address>
+ /// <type>office</type>
+ /// <street/>
+ /// <city/>
+ /// </address>
+ /// ```
+ /// If the JavaScript object contains a property named `@` then its sub-properties are exported as attributes of the parent XML
+ /// element.
+ /// If the parent XML element does not have any child elements then its value is taken from a JavaScript object property named `#`.
+ /// For example, the following JavaScript object:
+ /// ```
+ /// {
+ /// "address": [{
+ /// "@": {
+ /// "type": "home"
+ /// },
+ /// "street": "21st",
+ /// "city": "Chicago"
+ /// },
+ /// {
+ /// "@": {
+ /// "type": "office"
+ /// },
+ /// "#": 'unknown'
+ /// }]
+ /// }
+ /// ```
+ /// will be transformed to the following XML snippet:
+ /// ```
+ /// <address type="home">
+ /// <street>21st</street>
+ /// <city>Chicago</city>
+ /// </address>
+ /// <address type="office">unknown</address>
+ /// ```
+ /// This feature is also useful to customize your RSS feeds generated for various websites.
+ /// By default the whole result is wrapped in a `<items>` element and each page object is wrapped in a `<item>` element.
+ /// You can change this using <code>xmlRoot</code> and <code>xmlRow</code> url parameters.
+ /// ### Pagination
+ /// The generated response supports [pagination](#/introduction/pagination).
+ /// The pagination is always performed with the granularity of a single item, regardless whether <code>unwind</code> parameter was provided.
+ /// By default, the **Items** in the response are sorted by the time they were stored to the database, therefore you can use pagination to incrementally fetch the items as they are being added.
+ /// No limit exists to how many items can be returned in one response.
+ /// If you specify `desc=1` query parameter, the results are returned in the reverse order than they were stored (i.e. from newest to oldest items).
+ /// Note that only the order of **Items** is reversed, but not the order of the `unwind` array elements. + ///
+ /// + /// Example: WkzbQMuFYuamGv3YF + /// + /// + /// Example: json + /// + /// + /// Example: false + /// + /// + /// Example: 0 + /// + /// + /// + /// Example: myValue,myOtherValue + /// + /// + /// Example: myValue,myOtherValue + /// + /// + /// Example: myValue,myOtherValue + /// + /// + /// Example: myValue + /// + /// + /// Example: true + /// + /// + /// Example: true + /// + /// + /// Example: ; + /// + /// + /// Example: false + /// + /// + /// Example: items + /// + /// + /// Example: item + /// + /// + /// Example: true + /// + /// + /// Example: false + /// + /// + /// Example: false + /// + /// + /// Example: false + /// + /// + /// Example: overview + /// + /// + /// Example: false + /// + /// + /// Example: 2wTI46Bg8qWQrV7tavlPI + /// + /// The token to cancel the operation with + /// + global::System.Threading.Tasks.Task>> DatasetItemsGetAsResponseAsync( + string datasetId, + string? format = default, + bool? clean = default, + double? offset = default, + double? limit = default, + string? fields = default, + string? omit = default, + string? unwind = default, + string? flatten = default, + bool? desc = default, + bool? attachment = default, + string? delimiter = default, + bool? bom = default, + string? xmlRoot = default, + string? xmlRow = default, + bool? skipHeaderRow = default, + bool? skipHidden = default, + bool? skipEmpty = default, + bool? simplified = default, + string? view = default, + bool? skipFailedPages = default, + string? signature = default, + global::System.Threading.CancellationToken cancellationToken = default); } } \ No newline at end of file diff --git a/src/libs/Apify/Generated/Apify.IStorageDatasetsClient.DatasetItemsPost.g.cs b/src/libs/Apify/Generated/Apify.IStorageDatasetsClient.DatasetItemsPost.g.cs index 266b507..3ed9ec5 100644 --- a/src/libs/Apify/Generated/Apify.IStorageDatasetsClient.DatasetItemsPost.g.cs +++ b/src/libs/Apify/Generated/Apify.IStorageDatasetsClient.DatasetItemsPost.g.cs @@ -34,6 +34,25 @@ public partial interface IStorageDatasetsClient /// /// Example: WkzbQMuFYuamGv3YF /// + /// + /// The token to cancel the operation with + /// + global::System.Threading.Tasks.Task> DatasetItemsPostAsResponseAsync( + string datasetId, + + global::Apify.OneOf> request, + global::System.Threading.CancellationToken cancellationToken = default); + /// + /// Store items
+ /// Appends an item or an array of items to the end of the dataset.
+ /// The POST payload is a JSON object or a JSON array of objects to save into the dataset.
+ /// If the data you attempt to store in the dataset is invalid (meaning any of the items received by the API fails the validation), the whole request is discarded and the API will return a response with status code 400.
+ /// For more information about dataset schema validation, see [Dataset schema](https://docs.apify.com/platform/actors/development/actor-definition/dataset-schema/validation).
+ /// **IMPORTANT:** The limit of request payload size for the dataset is 5 MB. If the array exceeds the size, you'll need to split it into a number of smaller arrays. + ///
+ /// + /// Example: WkzbQMuFYuamGv3YF + /// /// The token to cancel the operation with /// global::System.Threading.Tasks.Task DatasetItemsPostAsync( diff --git a/src/libs/Apify/Generated/Apify.IStorageDatasetsClient.DatasetsPost.g.cs b/src/libs/Apify/Generated/Apify.IStorageDatasetsClient.DatasetsPost.g.cs index c9ea274..827cdf8 100644 --- a/src/libs/Apify/Generated/Apify.IStorageDatasetsClient.DatasetsPost.g.cs +++ b/src/libs/Apify/Generated/Apify.IStorageDatasetsClient.DatasetsPost.g.cs @@ -19,5 +19,20 @@ public partial interface IStorageDatasetsClient global::System.Threading.Tasks.Task DatasetsPostAsync( string? name = default, global::System.Threading.CancellationToken cancellationToken = default); + /// + /// Create dataset
+ /// Creates a dataset and returns its object.
+ /// Keep in mind that data stored under unnamed dataset follows [data retention period](https://docs.apify.com/platform/storage#data-retention).
+ /// It creates a dataset with the given name if the parameter name is used.
+ /// If a dataset with the given name already exists then returns its object. + ///
+ /// + /// Example: eshop-items + /// + /// The token to cancel the operation with + /// + global::System.Threading.Tasks.Task> DatasetsPostAsResponseAsync( + string? name = default, + global::System.Threading.CancellationToken cancellationToken = default); } } \ No newline at end of file diff --git a/src/libs/Apify/Generated/Apify.IStorageKeyValueStoresClient.KeyValueStoreRecordPost.g.cs b/src/libs/Apify/Generated/Apify.IStorageKeyValueStoresClient.KeyValueStoreRecordPost.g.cs index d5ea3c6..d8258bc 100644 --- a/src/libs/Apify/Generated/Apify.IStorageKeyValueStoresClient.KeyValueStoreRecordPost.g.cs +++ b/src/libs/Apify/Generated/Apify.IStorageKeyValueStoresClient.KeyValueStoreRecordPost.g.cs @@ -38,6 +38,28 @@ public partial interface IStorageKeyValueStoresClient /// Example: someKey /// /// + /// + /// The token to cancel the operation with + /// + global::System.Threading.Tasks.Task> KeyValueStoreRecordPostAsResponseAsync( + string storeId, + string recordKey, + + global::Apify.PutRecordRequest request, + global::Apify.KeyValueStoreRecordPostContentEncoding? contentEncoding = default, + global::System.Threading.CancellationToken cancellationToken = default); + /// + /// Store record (POST)
+ /// Stores a value under a specific key to the key-value store.
+ /// This endpoint is an alias for the [`PUT` record](#tag/Key-value-storesRecord/operation/keyValueStore_record_put) method and behaves identically. + ///
+ /// + /// Example: WkzbQMuFYuamGv3YF + /// + /// + /// Example: someKey + /// + /// /// The token to cancel the operation with /// global::System.Threading.Tasks.Task KeyValueStoreRecordPostAsync( diff --git a/src/libs/Apify/Generated/Apify.IStorageKeyValueStoresClient.KeyValueStoreRecordPut.g.cs b/src/libs/Apify/Generated/Apify.IStorageKeyValueStoresClient.KeyValueStoreRecordPut.g.cs index 209170f..6a86bd1 100644 --- a/src/libs/Apify/Generated/Apify.IStorageKeyValueStoresClient.KeyValueStoreRecordPut.g.cs +++ b/src/libs/Apify/Generated/Apify.IStorageKeyValueStoresClient.KeyValueStoreRecordPut.g.cs @@ -58,6 +58,38 @@ public partial interface IStorageKeyValueStoresClient /// Example: someKey /// /// + /// + /// The token to cancel the operation with + /// + global::System.Threading.Tasks.Task> KeyValueStoreRecordPutAsResponseAsync( + string storeId, + string recordKey, + + global::Apify.PutRecordRequest request, + global::Apify.KeyValueStoreRecordPutContentEncoding? contentEncoding = default, + global::System.Threading.CancellationToken cancellationToken = default); + /// + /// Store record
+ /// Stores a value under a specific key to the key-value store.
+ /// The value is passed as the PUT payload and it is stored with a MIME content
+ /// type defined by the `Content-Type` header and with encoding defined by the
+ /// `Content-Encoding` header.
+ /// To save bandwidth, storage, and speed up your upload, send the request
+ /// payload compressed with Gzip compression and add the `Content-Encoding: gzip`
+ /// header. It is possible to set up another compression type with `Content-Encoding`
+ /// request header.
+ /// Below is a list of supported `Content-Encoding` types.
+ /// * Gzip compression: `Content-Encoding: gzip`
+ /// * Deflate compression: `Content-Encoding: deflate`
+ /// * Brotli compression: `Content-Encoding: br` + ///
+ /// + /// Example: WkzbQMuFYuamGv3YF + /// + /// + /// Example: someKey + /// + /// /// The token to cancel the operation with /// global::System.Threading.Tasks.Task KeyValueStoreRecordPutAsync( diff --git a/src/libs/Apify/Generated/Apify.IStorageKeyValueStoresClient.KeyValueStoresPost.g.cs b/src/libs/Apify/Generated/Apify.IStorageKeyValueStoresClient.KeyValueStoresPost.g.cs index 6ec6017..7d6090f 100644 --- a/src/libs/Apify/Generated/Apify.IStorageKeyValueStoresClient.KeyValueStoresPost.g.cs +++ b/src/libs/Apify/Generated/Apify.IStorageKeyValueStoresClient.KeyValueStoresPost.g.cs @@ -23,5 +23,24 @@ public partial interface IStorageKeyValueStoresClient global::System.Threading.Tasks.Task KeyValueStoresPostAsync( string? name = default, global::System.Threading.CancellationToken cancellationToken = default); + /// + /// Create key-value store
+ /// Creates a key-value store and returns its object. The response is the same
+ /// object as returned by the [Get store](#/reference/key-value-stores/store-object/get-store)
+ /// endpoint.
+ /// Keep in mind that data stored under unnamed store follows [data retention
+ /// period](https://docs.apify.com/platform/storage#data-retention).
+ /// It creates a store with the given name if the parameter name is used.
+ /// If there is another store with the same name, the endpoint does not create a
+ /// new one and returns the existing object instead. + ///
+ /// + /// Example: eshop-values + /// + /// The token to cancel the operation with + /// + global::System.Threading.Tasks.Task> KeyValueStoresPostAsResponseAsync( + string? name = default, + global::System.Threading.CancellationToken cancellationToken = default); } } \ No newline at end of file diff --git a/src/libs/Apify/Generated/Apify.IStorageRequestQueuesClient.RequestQueuesPost.g.cs b/src/libs/Apify/Generated/Apify.IStorageRequestQueuesClient.RequestQueuesPost.g.cs index 7be326d..110f8c4 100644 --- a/src/libs/Apify/Generated/Apify.IStorageRequestQueuesClient.RequestQueuesPost.g.cs +++ b/src/libs/Apify/Generated/Apify.IStorageRequestQueuesClient.RequestQueuesPost.g.cs @@ -21,5 +21,22 @@ public partial interface IStorageRequestQueuesClient global::System.Threading.Tasks.Task RequestQueuesPostAsync( string? name = default, global::System.Threading.CancellationToken cancellationToken = default); + /// + /// Create request queue
+ /// Creates a request queue and returns its object.
+ /// Keep in mind that requests stored under unnamed queue follows [data
+ /// retention period](https://docs.apify.com/platform/storage#data-retention).
+ /// It creates a queue of given name if the parameter name is used. If a queue
+ /// with the given name already exists then the endpoint returns
+ /// its object. + ///
+ /// + /// Example: example-com + /// + /// The token to cancel the operation with + /// + global::System.Threading.Tasks.Task> RequestQueuesPostAsResponseAsync( + string? name = default, + global::System.Threading.CancellationToken cancellationToken = default); } } \ No newline at end of file diff --git a/src/libs/Apify/Generated/Apify.IWebhooksWebhooksClient.WebhooksPost.g.cs b/src/libs/Apify/Generated/Apify.IWebhooksWebhooksClient.WebhooksPost.g.cs index a0bbf30..6c47531 100644 --- a/src/libs/Apify/Generated/Apify.IWebhooksWebhooksClient.WebhooksPost.g.cs +++ b/src/libs/Apify/Generated/Apify.IWebhooksWebhooksClient.WebhooksPost.g.cs @@ -107,6 +107,61 @@ public partial interface IWebhooksWebhooksClient /// **Important**: The request must specify the `Content-Type: application/json`
/// HTTP header. /// + /// + /// The token to cancel the operation with + /// + global::System.Threading.Tasks.Task> WebhooksPostAsResponseAsync( + + global::Apify.WebhookCreate request, + global::System.Threading.CancellationToken cancellationToken = default); + /// + /// Create webhook
+ /// Creates a new webhook with settings provided by the webhook object passed as
+ /// JSON in the payload.
+ /// The response is the created webhook object.
+ /// To avoid duplicating a webhook, use the `idempotencyKey` parameter in the
+ /// request body.
+ /// Multiple calls to create a webhook with the same `idempotencyKey` will only
+ /// create the webhook with the first call and return the existing webhook on
+ /// subsequent calls.
+ /// Idempotency keys must be unique, so use a UUID or another random string with
+ /// enough entropy.
+ /// To assign the new webhook to an Actor or task, the request body must contain
+ /// `requestUrl`, `eventTypes`, and `condition` properties.
+ /// * `requestUrl` is the webhook's target URL, to which data is sent as a POST
+ /// request with a JSON payload.
+ /// * `eventTypes` is a list of events that will trigger the webhook, e.g. when
+ /// the Actor run succeeds.
+ /// * `condition` should be an object containing the ID of the Actor or task to
+ /// which the webhook will be assigned.
+ /// * `payloadTemplate` is a JSON-like string, whose syntax is extended with the
+ /// use of variables.
+ /// * `headersTemplate` is a JSON-like string, whose syntax is extended with the
+ /// use of variables. Following values will be re-written to defaults: "host",
+ /// "Content-Type", "X-Apify-Webhook", "X-Apify-Webhook-Dispatch-Id",
+ /// "X-Apify-Request-Origin"
+ /// * `description` is an optional string.
+ /// * `shouldInterpolateStrings` is a boolean indicating whether to interpolate
+ /// variables contained inside strings in the `payloadTemplate`
+ /// ```
+ /// "isAdHoc" : false,
+ /// "requestUrl" : "https://example.com",
+ /// "eventTypes" : [
+ /// "ACTOR.RUN.SUCCEEDED",
+ /// "ACTOR.RUN.ABORTED"
+ /// ],
+ /// "condition" : {
+ /// "actorId": "5sTMwDQywwsLzKRRh",
+ /// "actorTaskId" : "W9bs9JE9v7wprjAnJ"
+ /// },
+ /// "payloadTemplate": "",
+ /// "headersTemplate": "",
+ /// "description": "my awesome webhook",
+ /// "shouldInterpolateStrings": false,
+ /// ```
+ /// **Important**: The request must specify the `Content-Type: application/json`
+ /// HTTP header. + ///
/// /// /// diff --git a/src/libs/Apify/Generated/Apify.SchedulesClient.SchedulesPost.g.cs b/src/libs/Apify/Generated/Apify.SchedulesClient.SchedulesPost.g.cs index 20a1c4e..b5ac4f1 100644 --- a/src/libs/Apify/Generated/Apify.SchedulesClient.SchedulesPost.g.cs +++ b/src/libs/Apify/Generated/Apify.SchedulesClient.SchedulesPost.g.cs @@ -35,6 +35,31 @@ partial void ProcessSchedulesPostResponseContent( /// public async global::System.Threading.Tasks.Task SchedulesPostAsync( + global::Apify.ScheduleCreate request, + global::System.Threading.CancellationToken cancellationToken = default) + { + var __response = await SchedulesPostAsResponseAsync( + + request: request, + cancellationToken: cancellationToken + ).ConfigureAwait(false); + + return __response.Body; + } + /// + /// Create schedule
+ /// Creates a new schedule with settings provided by the schedule object passed
+ /// as JSON in the payload. The response is the created schedule object.
+ /// The request needs to specify the `Content-Type: application/json` HTTP header!
+ /// When providing your API authentication token, we recommend using the
+ /// request's `Authorization` header, rather than the URL. ([More
+ /// info](#/introduction/authentication)). + ///
+ /// + /// The token to cancel the operation with + /// + public async global::System.Threading.Tasks.Task> SchedulesPostAsResponseAsync( + global::Apify.ScheduleCreate request, global::System.Threading.CancellationToken cancellationToken = default) { @@ -463,9 +488,12 @@ partial void ProcessSchedulesPostResponseContent( { __response.EnsureSuccessStatusCode(); - return - global::Apify.ScheduleResponse.FromJson(__content, JsonSerializerContext) ?? + var __value = global::Apify.ScheduleResponse.FromJson(__content, JsonSerializerContext) ?? throw new global::System.InvalidOperationException($"Response deserialization failed for \"{__content}\" "); + return new global::Apify.AutoSDKHttpResponse( + statusCode: __response.StatusCode, + headers: global::Apify.AutoSDKHttpResponse.CreateHeaders(__response), + body: __value); } catch (global::System.Exception __ex) { @@ -494,9 +522,12 @@ partial void ProcessSchedulesPostResponseContent( #endif ).ConfigureAwait(false); - return - await global::Apify.ScheduleResponse.FromJsonStreamAsync(__content, JsonSerializerContext).ConfigureAwait(false) ?? + var __value = await global::Apify.ScheduleResponse.FromJsonStreamAsync(__content, JsonSerializerContext).ConfigureAwait(false) ?? throw new global::System.InvalidOperationException("Response deserialization failed."); + return new global::Apify.AutoSDKHttpResponse( + statusCode: __response.StatusCode, + headers: global::Apify.AutoSDKHttpResponse.CreateHeaders(__response), + body: __value); } catch (global::System.Exception __ex) { diff --git a/src/libs/Apify/Generated/Apify.StorageDatasetsClient.DatasetItemsGet.g.cs b/src/libs/Apify/Generated/Apify.StorageDatasetsClient.DatasetItemsGet.g.cs index 35c988b..fac094b 100644 --- a/src/libs/Apify/Generated/Apify.StorageDatasetsClient.DatasetItemsGet.g.cs +++ b/src/libs/Apify/Generated/Apify.StorageDatasetsClient.DatasetItemsGet.g.cs @@ -280,6 +280,252 @@ partial void ProcessDatasetItemsGetResponseContent( bool? skipFailedPages = default, string? signature = default, global::System.Threading.CancellationToken cancellationToken = default) + { + var __response = await DatasetItemsGetAsResponseAsync( + datasetId: datasetId, + format: format, + clean: clean, + offset: offset, + limit: limit, + fields: fields, + omit: omit, + unwind: unwind, + flatten: flatten, + desc: desc, + attachment: attachment, + delimiter: delimiter, + bom: bom, + xmlRoot: xmlRoot, + xmlRow: xmlRow, + skipHeaderRow: skipHeaderRow, + skipHidden: skipHidden, + skipEmpty: skipEmpty, + simplified: simplified, + view: view, + skipFailedPages: skipFailedPages, + signature: signature, + cancellationToken: cancellationToken + ).ConfigureAwait(false); + + return __response.Body; + } + /// + /// Get dataset items
+ /// Returns data stored in the dataset in a desired format.
+ /// ### Response format
+ /// The format of the response depends on <code>format</code> query parameter.
+ /// The <code>format</code> parameter can have one of the following values:
+ /// <code>json</code>, <code>jsonl</code>, <code>xml</code>, <code>html</code>,
+ /// <code>csv</code>, <code>xlsx</code> and <code>rss</code>.
+ /// The following table describes how each format is treated.
+ /// <table>
+ /// <tr>
+ /// <th>Format</th>
+ /// <th>Items</th>
+ /// </tr>
+ /// <tr>
+ /// <td><code>json</code></td>
+ /// <td rowspan="3">The response is a JSON, JSONL or XML array of raw item objects.</td>
+ /// </tr>
+ /// <tr>
+ /// <td><code>jsonl</code></td>
+ /// </tr>
+ /// <tr>
+ /// <td><code>xml</code></td>
+ /// </tr>
+ /// <tr>
+ /// <td><code>html</code></td>
+ /// <td rowspan="3">The response is a HTML, CSV or XLSX table, where columns correspond to the
+ /// properties of the item and rows correspond to each dataset item.</td>
+ /// </tr>
+ /// <tr>
+ /// <td><code>csv</code></td>
+ /// </tr>
+ /// <tr>
+ /// <td><code>xlsx</code></td>
+ /// </tr>
+ /// <tr>
+ /// <td><code>rss</code></td>
+ /// <td colspan="2">The response is a RSS file. Each item is displayed as child elements of one
+ /// <code>&lt;item&gt;</code>.</td>
+ /// </tr>
+ /// </table>
+ /// Note that CSV, XLSX and HTML tables are limited to 2000 columns and the column names cannot be longer than 200 characters.
+ /// JSON, XML and RSS formats do not have such restrictions.
+ /// ### Hidden fields
+ /// The top-level fields starting with the `#` character are considered hidden.
+ /// These are useful to store debugging information and can be omitted from the output by providing the `skipHidden=1` or `clean=1` query parameters.
+ /// For example, if you store the following object to the dataset:
+ /// ```
+ /// {
+ /// productName: "iPhone Xs",
+ /// description: "Welcome to the big screens."
+ /// #debug: {
+ /// url: "https://www.apple.com/lae/iphone-xs/",
+ /// crawledAt: "2019-01-21T16:06:03.683Z"
+ /// }
+ /// }
+ /// ```
+ /// The `#debug` field will be considered as hidden and can be omitted from the
+ /// results. This is useful to
+ /// provide nice cleaned data to end users, while keeping debugging info
+ /// available if needed. The Dataset object
+ /// returned by the API contains the number of such clean items in the`dataset.cleanItemCount` property.
+ /// ### XML format extension
+ /// When exporting results to XML or RSS formats, the names of object properties become XML tags and the corresponding values become tag's children. For example, the following JavaScript object:
+ /// ```
+ /// {
+ /// name: "Paul Newman",
+ /// address: [
+ /// { type: "home", street: "21st", city: "Chicago" },
+ /// { type: "office", street: null, city: null }
+ /// ]
+ /// }
+ /// ```
+ /// will be transformed to the following XML snippet:
+ /// ```
+ /// <name>Paul Newman</name>
+ /// <address>
+ /// <type>home</type>
+ /// <street>21st</street>
+ /// <city>Chicago</city>
+ /// </address>
+ /// <address>
+ /// <type>office</type>
+ /// <street/>
+ /// <city/>
+ /// </address>
+ /// ```
+ /// If the JavaScript object contains a property named `@` then its sub-properties are exported as attributes of the parent XML
+ /// element.
+ /// If the parent XML element does not have any child elements then its value is taken from a JavaScript object property named `#`.
+ /// For example, the following JavaScript object:
+ /// ```
+ /// {
+ /// "address": [{
+ /// "@": {
+ /// "type": "home"
+ /// },
+ /// "street": "21st",
+ /// "city": "Chicago"
+ /// },
+ /// {
+ /// "@": {
+ /// "type": "office"
+ /// },
+ /// "#": 'unknown'
+ /// }]
+ /// }
+ /// ```
+ /// will be transformed to the following XML snippet:
+ /// ```
+ /// <address type="home">
+ /// <street>21st</street>
+ /// <city>Chicago</city>
+ /// </address>
+ /// <address type="office">unknown</address>
+ /// ```
+ /// This feature is also useful to customize your RSS feeds generated for various websites.
+ /// By default the whole result is wrapped in a `<items>` element and each page object is wrapped in a `<item>` element.
+ /// You can change this using <code>xmlRoot</code> and <code>xmlRow</code> url parameters.
+ /// ### Pagination
+ /// The generated response supports [pagination](#/introduction/pagination).
+ /// The pagination is always performed with the granularity of a single item, regardless whether <code>unwind</code> parameter was provided.
+ /// By default, the **Items** in the response are sorted by the time they were stored to the database, therefore you can use pagination to incrementally fetch the items as they are being added.
+ /// No limit exists to how many items can be returned in one response.
+ /// If you specify `desc=1` query parameter, the results are returned in the reverse order than they were stored (i.e. from newest to oldest items).
+ /// Note that only the order of **Items** is reversed, but not the order of the `unwind` array elements. + ///
+ /// + /// Example: WkzbQMuFYuamGv3YF + /// + /// + /// Example: json + /// + /// + /// Example: false + /// + /// + /// Example: 0 + /// + /// + /// + /// Example: myValue,myOtherValue + /// + /// + /// Example: myValue,myOtherValue + /// + /// + /// Example: myValue,myOtherValue + /// + /// + /// Example: myValue + /// + /// + /// Example: true + /// + /// + /// Example: true + /// + /// + /// Example: ; + /// + /// + /// Example: false + /// + /// + /// Example: items + /// + /// + /// Example: item + /// + /// + /// Example: true + /// + /// + /// Example: false + /// + /// + /// Example: false + /// + /// + /// Example: false + /// + /// + /// Example: overview + /// + /// + /// Example: false + /// + /// + /// Example: 2wTI46Bg8qWQrV7tavlPI + /// + /// The token to cancel the operation with + /// + public async global::System.Threading.Tasks.Task>> DatasetItemsGetAsResponseAsync( + string datasetId, + string? format = default, + bool? clean = default, + double? offset = default, + double? limit = default, + string? fields = default, + string? omit = default, + string? unwind = default, + string? flatten = default, + bool? desc = default, + bool? attachment = default, + string? delimiter = default, + bool? bom = default, + string? xmlRoot = default, + string? xmlRow = default, + bool? skipHeaderRow = default, + bool? skipHidden = default, + bool? skipEmpty = default, + bool? simplified = default, + string? view = default, + bool? skipFailedPages = default, + string? signature = default, + global::System.Threading.CancellationToken cancellationToken = default) { PrepareArguments( client: HttpClient); @@ -649,9 +895,12 @@ partial void ProcessDatasetItemsGetResponseContent( { __response.EnsureSuccessStatusCode(); - return - (global::System.Collections.Generic.IList?)global::System.Text.Json.JsonSerializer.Deserialize(__content, typeof(global::System.Collections.Generic.IList), JsonSerializerContext) ?? + 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::Apify.AutoSDKHttpResponse>( + statusCode: __response.StatusCode, + headers: global::Apify.AutoSDKHttpResponse.CreateHeaders(__response), + body: __value); } catch (global::System.Exception __ex) { @@ -680,9 +929,12 @@ partial void ProcessDatasetItemsGetResponseContent( #endif ).ConfigureAwait(false); - return - (global::System.Collections.Generic.IList?)await global::System.Text.Json.JsonSerializer.DeserializeAsync(__content, typeof(global::System.Collections.Generic.IList), JsonSerializerContext).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::Apify.AutoSDKHttpResponse>( + statusCode: __response.StatusCode, + headers: global::Apify.AutoSDKHttpResponse.CreateHeaders(__response), + body: __value); } catch (global::System.Exception __ex) { diff --git a/src/libs/Apify/Generated/Apify.StorageDatasetsClient.DatasetItemsPost.g.cs b/src/libs/Apify/Generated/Apify.StorageDatasetsClient.DatasetItemsPost.g.cs index 1df0f52..94fe0c6 100644 --- a/src/libs/Apify/Generated/Apify.StorageDatasetsClient.DatasetItemsPost.g.cs +++ b/src/libs/Apify/Generated/Apify.StorageDatasetsClient.DatasetItemsPost.g.cs @@ -40,6 +40,35 @@ partial void ProcessDatasetItemsPostResponseContent( public async global::System.Threading.Tasks.Task DatasetItemsPostAsync( string datasetId, + global::Apify.OneOf> request, + global::System.Threading.CancellationToken cancellationToken = default) + { + var __response = await DatasetItemsPostAsResponseAsync( + datasetId: datasetId, + + request: request, + cancellationToken: cancellationToken + ).ConfigureAwait(false); + + return __response.Body; + } + /// + /// Store items
+ /// Appends an item or an array of items to the end of the dataset.
+ /// The POST payload is a JSON object or a JSON array of objects to save into the dataset.
+ /// If the data you attempt to store in the dataset is invalid (meaning any of the items received by the API fails the validation), the whole request is discarded and the API will return a response with status code 400.
+ /// For more information about dataset schema validation, see [Dataset schema](https://docs.apify.com/platform/actors/development/actor-definition/dataset-schema/validation).
+ /// **IMPORTANT:** The limit of request payload size for the dataset is 5 MB. If the array exceeds the size, you'll need to split it into a number of smaller arrays. + ///
+ /// + /// Example: WkzbQMuFYuamGv3YF + /// + /// + /// The token to cancel the operation with + /// + public async global::System.Threading.Tasks.Task> DatasetItemsPostAsResponseAsync( + string datasetId, + global::Apify.OneOf> request, global::System.Threading.CancellationToken cancellationToken = default) { @@ -240,7 +269,10 @@ partial void ProcessDatasetItemsPostResponseContent( { __response.EnsureSuccessStatusCode(); - return __content; + return new global::Apify.AutoSDKHttpResponse( + statusCode: __response.StatusCode, + headers: global::Apify.AutoSDKHttpResponse.CreateHeaders(__response), + body: __content); } catch (global::System.Exception __ex) { @@ -269,7 +301,10 @@ partial void ProcessDatasetItemsPostResponseContent( #endif ).ConfigureAwait(false); - return __content; + return new global::Apify.AutoSDKHttpResponse( + statusCode: __response.StatusCode, + headers: global::Apify.AutoSDKHttpResponse.CreateHeaders(__response), + body: __content); } catch (global::System.Exception __ex) { diff --git a/src/libs/Apify/Generated/Apify.StorageDatasetsClient.DatasetsPost.g.cs b/src/libs/Apify/Generated/Apify.StorageDatasetsClient.DatasetsPost.g.cs index 068933c..eaa41c5 100644 --- a/src/libs/Apify/Generated/Apify.StorageDatasetsClient.DatasetsPost.g.cs +++ b/src/libs/Apify/Generated/Apify.StorageDatasetsClient.DatasetsPost.g.cs @@ -36,6 +36,29 @@ partial void ProcessDatasetsPostResponseContent( public async global::System.Threading.Tasks.Task DatasetsPostAsync( string? name = default, global::System.Threading.CancellationToken cancellationToken = default) + { + var __response = await DatasetsPostAsResponseAsync( + name: name, + cancellationToken: cancellationToken + ).ConfigureAwait(false); + + return __response.Body; + } + /// + /// Create dataset
+ /// Creates a dataset and returns its object.
+ /// Keep in mind that data stored under unnamed dataset follows [data retention period](https://docs.apify.com/platform/storage#data-retention).
+ /// It creates a dataset with the given name if the parameter name is used.
+ /// If a dataset with the given name already exists then returns its object. + ///
+ /// + /// Example: eshop-items + /// + /// The token to cancel the operation with + /// + public async global::System.Threading.Tasks.Task> DatasetsPostAsResponseAsync( + string? name = default, + global::System.Threading.CancellationToken cancellationToken = default) { PrepareArguments( client: HttpClient); @@ -305,9 +328,12 @@ partial void ProcessDatasetsPostResponseContent( { __response.EnsureSuccessStatusCode(); - return - global::Apify.DatasetResponse.FromJson(__content, JsonSerializerContext) ?? + var __value = global::Apify.DatasetResponse.FromJson(__content, JsonSerializerContext) ?? throw new global::System.InvalidOperationException($"Response deserialization failed for \"{__content}\" "); + return new global::Apify.AutoSDKHttpResponse( + statusCode: __response.StatusCode, + headers: global::Apify.AutoSDKHttpResponse.CreateHeaders(__response), + body: __value); } catch (global::System.Exception __ex) { @@ -336,9 +362,12 @@ partial void ProcessDatasetsPostResponseContent( #endif ).ConfigureAwait(false); - return - await global::Apify.DatasetResponse.FromJsonStreamAsync(__content, JsonSerializerContext).ConfigureAwait(false) ?? + var __value = await global::Apify.DatasetResponse.FromJsonStreamAsync(__content, JsonSerializerContext).ConfigureAwait(false) ?? throw new global::System.InvalidOperationException("Response deserialization failed."); + return new global::Apify.AutoSDKHttpResponse( + statusCode: __response.StatusCode, + headers: global::Apify.AutoSDKHttpResponse.CreateHeaders(__response), + body: __value); } catch (global::System.Exception __ex) { diff --git a/src/libs/Apify/Generated/Apify.StorageKeyValueStoresClient.KeyValueStoreRecordPost.g.cs b/src/libs/Apify/Generated/Apify.StorageKeyValueStoresClient.KeyValueStoreRecordPost.g.cs index 19a7692..97c921c 100644 --- a/src/libs/Apify/Generated/Apify.StorageKeyValueStoresClient.KeyValueStoreRecordPost.g.cs +++ b/src/libs/Apify/Generated/Apify.StorageKeyValueStoresClient.KeyValueStoreRecordPost.g.cs @@ -46,6 +46,40 @@ partial void ProcessKeyValueStoreRecordPostResponseContent( string storeId, string recordKey, + global::Apify.PutRecordRequest request, + global::Apify.KeyValueStoreRecordPostContentEncoding? contentEncoding = default, + global::System.Threading.CancellationToken cancellationToken = default) + { + var __response = await KeyValueStoreRecordPostAsResponseAsync( + storeId: storeId, + recordKey: recordKey, + + request: request, + contentEncoding: contentEncoding, + cancellationToken: cancellationToken + ).ConfigureAwait(false); + + return __response.Body; + } + /// + /// Store record (POST)
+ /// Stores a value under a specific key to the key-value store.
+ /// This endpoint is an alias for the [`PUT` record](#tag/Key-value-storesRecord/operation/keyValueStore_record_put) method and behaves identically. + ///
+ /// + /// Example: WkzbQMuFYuamGv3YF + /// + /// + /// Example: someKey + /// + /// + /// + /// The token to cancel the operation with + /// + public async global::System.Threading.Tasks.Task> KeyValueStoreRecordPostAsResponseAsync( + string storeId, + string recordKey, + global::Apify.PutRecordRequest request, global::Apify.KeyValueStoreRecordPostContentEncoding? contentEncoding = default, global::System.Threading.CancellationToken cancellationToken = default) @@ -411,7 +445,10 @@ partial void ProcessKeyValueStoreRecordPostResponseContent( { __response.EnsureSuccessStatusCode(); - return __content; + return new global::Apify.AutoSDKHttpResponse( + statusCode: __response.StatusCode, + headers: global::Apify.AutoSDKHttpResponse.CreateHeaders(__response), + body: __content); } catch (global::System.Exception __ex) { @@ -440,7 +477,10 @@ partial void ProcessKeyValueStoreRecordPostResponseContent( #endif ).ConfigureAwait(false); - return __content; + return new global::Apify.AutoSDKHttpResponse( + statusCode: __response.StatusCode, + headers: global::Apify.AutoSDKHttpResponse.CreateHeaders(__response), + body: __content); } catch (global::System.Exception __ex) { diff --git a/src/libs/Apify/Generated/Apify.StorageKeyValueStoresClient.KeyValueStoreRecordPut.g.cs b/src/libs/Apify/Generated/Apify.StorageKeyValueStoresClient.KeyValueStoreRecordPut.g.cs index 8ff34f9..4014595 100644 --- a/src/libs/Apify/Generated/Apify.StorageKeyValueStoresClient.KeyValueStoreRecordPut.g.cs +++ b/src/libs/Apify/Generated/Apify.StorageKeyValueStoresClient.KeyValueStoreRecordPut.g.cs @@ -56,6 +56,50 @@ partial void ProcessKeyValueStoreRecordPutResponseContent( string storeId, string recordKey, + global::Apify.PutRecordRequest request, + global::Apify.KeyValueStoreRecordPutContentEncoding? contentEncoding = default, + global::System.Threading.CancellationToken cancellationToken = default) + { + var __response = await KeyValueStoreRecordPutAsResponseAsync( + storeId: storeId, + recordKey: recordKey, + + request: request, + contentEncoding: contentEncoding, + cancellationToken: cancellationToken + ).ConfigureAwait(false); + + return __response.Body; + } + /// + /// Store record
+ /// Stores a value under a specific key to the key-value store.
+ /// The value is passed as the PUT payload and it is stored with a MIME content
+ /// type defined by the `Content-Type` header and with encoding defined by the
+ /// `Content-Encoding` header.
+ /// To save bandwidth, storage, and speed up your upload, send the request
+ /// payload compressed with Gzip compression and add the `Content-Encoding: gzip`
+ /// header. It is possible to set up another compression type with `Content-Encoding`
+ /// request header.
+ /// Below is a list of supported `Content-Encoding` types.
+ /// * Gzip compression: `Content-Encoding: gzip`
+ /// * Deflate compression: `Content-Encoding: deflate`
+ /// * Brotli compression: `Content-Encoding: br` + ///
+ /// + /// Example: WkzbQMuFYuamGv3YF + /// + /// + /// Example: someKey + /// + /// + /// + /// The token to cancel the operation with + /// + public async global::System.Threading.Tasks.Task> KeyValueStoreRecordPutAsResponseAsync( + string storeId, + string recordKey, + global::Apify.PutRecordRequest request, global::Apify.KeyValueStoreRecordPutContentEncoding? contentEncoding = default, global::System.Threading.CancellationToken cancellationToken = default) @@ -421,7 +465,10 @@ partial void ProcessKeyValueStoreRecordPutResponseContent( { __response.EnsureSuccessStatusCode(); - return __content; + return new global::Apify.AutoSDKHttpResponse( + statusCode: __response.StatusCode, + headers: global::Apify.AutoSDKHttpResponse.CreateHeaders(__response), + body: __content); } catch (global::System.Exception __ex) { @@ -450,7 +497,10 @@ partial void ProcessKeyValueStoreRecordPutResponseContent( #endif ).ConfigureAwait(false); - return __content; + return new global::Apify.AutoSDKHttpResponse( + statusCode: __response.StatusCode, + headers: global::Apify.AutoSDKHttpResponse.CreateHeaders(__response), + body: __content); } catch (global::System.Exception __ex) { diff --git a/src/libs/Apify/Generated/Apify.StorageKeyValueStoresClient.KeyValueStoresPost.g.cs b/src/libs/Apify/Generated/Apify.StorageKeyValueStoresClient.KeyValueStoresPost.g.cs index 732ce71..65c1145 100644 --- a/src/libs/Apify/Generated/Apify.StorageKeyValueStoresClient.KeyValueStoresPost.g.cs +++ b/src/libs/Apify/Generated/Apify.StorageKeyValueStoresClient.KeyValueStoresPost.g.cs @@ -40,6 +40,33 @@ partial void ProcessKeyValueStoresPostResponseContent( public async global::System.Threading.Tasks.Task KeyValueStoresPostAsync( string? name = default, global::System.Threading.CancellationToken cancellationToken = default) + { + var __response = await KeyValueStoresPostAsResponseAsync( + name: name, + cancellationToken: cancellationToken + ).ConfigureAwait(false); + + return __response.Body; + } + /// + /// Create key-value store
+ /// Creates a key-value store and returns its object. The response is the same
+ /// object as returned by the [Get store](#/reference/key-value-stores/store-object/get-store)
+ /// endpoint.
+ /// Keep in mind that data stored under unnamed store follows [data retention
+ /// period](https://docs.apify.com/platform/storage#data-retention).
+ /// It creates a store with the given name if the parameter name is used.
+ /// If there is another store with the same name, the endpoint does not create a
+ /// new one and returns the existing object instead. + ///
+ /// + /// Example: eshop-values + /// + /// The token to cancel the operation with + /// + public async global::System.Threading.Tasks.Task> KeyValueStoresPostAsResponseAsync( + string? name = default, + global::System.Threading.CancellationToken cancellationToken = default) { PrepareArguments( client: HttpClient); @@ -309,9 +336,12 @@ partial void ProcessKeyValueStoresPostResponseContent( { __response.EnsureSuccessStatusCode(); - return - global::Apify.KeyValueStoreResponse.FromJson(__content, JsonSerializerContext) ?? + var __value = global::Apify.KeyValueStoreResponse.FromJson(__content, JsonSerializerContext) ?? throw new global::System.InvalidOperationException($"Response deserialization failed for \"{__content}\" "); + return new global::Apify.AutoSDKHttpResponse( + statusCode: __response.StatusCode, + headers: global::Apify.AutoSDKHttpResponse.CreateHeaders(__response), + body: __value); } catch (global::System.Exception __ex) { @@ -340,9 +370,12 @@ partial void ProcessKeyValueStoresPostResponseContent( #endif ).ConfigureAwait(false); - return - await global::Apify.KeyValueStoreResponse.FromJsonStreamAsync(__content, JsonSerializerContext).ConfigureAwait(false) ?? + var __value = await global::Apify.KeyValueStoreResponse.FromJsonStreamAsync(__content, JsonSerializerContext).ConfigureAwait(false) ?? throw new global::System.InvalidOperationException("Response deserialization failed."); + return new global::Apify.AutoSDKHttpResponse( + statusCode: __response.StatusCode, + headers: global::Apify.AutoSDKHttpResponse.CreateHeaders(__response), + body: __value); } catch (global::System.Exception __ex) { diff --git a/src/libs/Apify/Generated/Apify.StorageRequestQueuesClient.RequestQueuesPost.g.cs b/src/libs/Apify/Generated/Apify.StorageRequestQueuesClient.RequestQueuesPost.g.cs index 4b1f650..cd0dddd 100644 --- a/src/libs/Apify/Generated/Apify.StorageRequestQueuesClient.RequestQueuesPost.g.cs +++ b/src/libs/Apify/Generated/Apify.StorageRequestQueuesClient.RequestQueuesPost.g.cs @@ -38,6 +38,31 @@ partial void ProcessRequestQueuesPostResponseContent( public async global::System.Threading.Tasks.Task RequestQueuesPostAsync( string? name = default, global::System.Threading.CancellationToken cancellationToken = default) + { + var __response = await RequestQueuesPostAsResponseAsync( + name: name, + cancellationToken: cancellationToken + ).ConfigureAwait(false); + + return __response.Body; + } + /// + /// Create request queue
+ /// Creates a request queue and returns its object.
+ /// Keep in mind that requests stored under unnamed queue follows [data
+ /// retention period](https://docs.apify.com/platform/storage#data-retention).
+ /// It creates a queue of given name if the parameter name is used. If a queue
+ /// with the given name already exists then the endpoint returns
+ /// its object. + ///
+ /// + /// Example: example-com + /// + /// The token to cancel the operation with + /// + public async global::System.Threading.Tasks.Task> RequestQueuesPostAsResponseAsync( + string? name = default, + global::System.Threading.CancellationToken cancellationToken = default) { PrepareArguments( client: HttpClient); @@ -307,9 +332,12 @@ partial void ProcessRequestQueuesPostResponseContent( { __response.EnsureSuccessStatusCode(); - return - global::Apify.RequestQueueResponse.FromJson(__content, JsonSerializerContext) ?? + var __value = global::Apify.RequestQueueResponse.FromJson(__content, JsonSerializerContext) ?? throw new global::System.InvalidOperationException($"Response deserialization failed for \"{__content}\" "); + return new global::Apify.AutoSDKHttpResponse( + statusCode: __response.StatusCode, + headers: global::Apify.AutoSDKHttpResponse.CreateHeaders(__response), + body: __value); } catch (global::System.Exception __ex) { @@ -338,9 +366,12 @@ partial void ProcessRequestQueuesPostResponseContent( #endif ).ConfigureAwait(false); - return - await global::Apify.RequestQueueResponse.FromJsonStreamAsync(__content, JsonSerializerContext).ConfigureAwait(false) ?? + var __value = await global::Apify.RequestQueueResponse.FromJsonStreamAsync(__content, JsonSerializerContext).ConfigureAwait(false) ?? throw new global::System.InvalidOperationException("Response deserialization failed."); + return new global::Apify.AutoSDKHttpResponse( + statusCode: __response.StatusCode, + headers: global::Apify.AutoSDKHttpResponse.CreateHeaders(__response), + body: __value); } catch (global::System.Exception __ex) { diff --git a/src/libs/Apify/Generated/Apify.WebhooksWebhooksClient.WebhooksPost.g.cs b/src/libs/Apify/Generated/Apify.WebhooksWebhooksClient.WebhooksPost.g.cs index d70e477..f1a8452 100644 --- a/src/libs/Apify/Generated/Apify.WebhooksWebhooksClient.WebhooksPost.g.cs +++ b/src/libs/Apify/Generated/Apify.WebhooksWebhooksClient.WebhooksPost.g.cs @@ -74,6 +74,70 @@ partial void ProcessWebhooksPostResponseContent( /// public async global::System.Threading.Tasks.Task WebhooksPostAsync( + global::Apify.WebhookCreate request, + global::System.Threading.CancellationToken cancellationToken = default) + { + var __response = await WebhooksPostAsResponseAsync( + + request: request, + cancellationToken: cancellationToken + ).ConfigureAwait(false); + + return __response.Body; + } + /// + /// Create webhook
+ /// Creates a new webhook with settings provided by the webhook object passed as
+ /// JSON in the payload.
+ /// The response is the created webhook object.
+ /// To avoid duplicating a webhook, use the `idempotencyKey` parameter in the
+ /// request body.
+ /// Multiple calls to create a webhook with the same `idempotencyKey` will only
+ /// create the webhook with the first call and return the existing webhook on
+ /// subsequent calls.
+ /// Idempotency keys must be unique, so use a UUID or another random string with
+ /// enough entropy.
+ /// To assign the new webhook to an Actor or task, the request body must contain
+ /// `requestUrl`, `eventTypes`, and `condition` properties.
+ /// * `requestUrl` is the webhook's target URL, to which data is sent as a POST
+ /// request with a JSON payload.
+ /// * `eventTypes` is a list of events that will trigger the webhook, e.g. when
+ /// the Actor run succeeds.
+ /// * `condition` should be an object containing the ID of the Actor or task to
+ /// which the webhook will be assigned.
+ /// * `payloadTemplate` is a JSON-like string, whose syntax is extended with the
+ /// use of variables.
+ /// * `headersTemplate` is a JSON-like string, whose syntax is extended with the
+ /// use of variables. Following values will be re-written to defaults: "host",
+ /// "Content-Type", "X-Apify-Webhook", "X-Apify-Webhook-Dispatch-Id",
+ /// "X-Apify-Request-Origin"
+ /// * `description` is an optional string.
+ /// * `shouldInterpolateStrings` is a boolean indicating whether to interpolate
+ /// variables contained inside strings in the `payloadTemplate`
+ /// ```
+ /// "isAdHoc" : false,
+ /// "requestUrl" : "https://example.com",
+ /// "eventTypes" : [
+ /// "ACTOR.RUN.SUCCEEDED",
+ /// "ACTOR.RUN.ABORTED"
+ /// ],
+ /// "condition" : {
+ /// "actorId": "5sTMwDQywwsLzKRRh",
+ /// "actorTaskId" : "W9bs9JE9v7wprjAnJ"
+ /// },
+ /// "payloadTemplate": "",
+ /// "headersTemplate": "",
+ /// "description": "my awesome webhook",
+ /// "shouldInterpolateStrings": false,
+ /// ```
+ /// **Important**: The request must specify the `Content-Type: application/json`
+ /// HTTP header. + ///
+ /// + /// The token to cancel the operation with + /// + public async global::System.Threading.Tasks.Task> WebhooksPostAsResponseAsync( + global::Apify.WebhookCreate request, global::System.Threading.CancellationToken cancellationToken = default) { @@ -426,9 +490,12 @@ partial void ProcessWebhooksPostResponseContent( { __response.EnsureSuccessStatusCode(); - return - global::Apify.WebhookResponse.FromJson(__content, JsonSerializerContext) ?? + var __value = global::Apify.WebhookResponse.FromJson(__content, JsonSerializerContext) ?? throw new global::System.InvalidOperationException($"Response deserialization failed for \"{__content}\" "); + return new global::Apify.AutoSDKHttpResponse( + statusCode: __response.StatusCode, + headers: global::Apify.AutoSDKHttpResponse.CreateHeaders(__response), + body: __value); } catch (global::System.Exception __ex) { @@ -457,9 +524,12 @@ partial void ProcessWebhooksPostResponseContent( #endif ).ConfigureAwait(false); - return - await global::Apify.WebhookResponse.FromJsonStreamAsync(__content, JsonSerializerContext).ConfigureAwait(false) ?? + var __value = await global::Apify.WebhookResponse.FromJsonStreamAsync(__content, JsonSerializerContext).ConfigureAwait(false) ?? throw new global::System.InvalidOperationException("Response deserialization failed."); + return new global::Apify.AutoSDKHttpResponse( + statusCode: __response.StatusCode, + headers: global::Apify.AutoSDKHttpResponse.CreateHeaders(__response), + body: __value); } catch (global::System.Exception __ex) {