Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion api.md
Original file line number Diff line number Diff line change
Expand Up @@ -2569,7 +2569,7 @@ Methods:

- <code title="post /accounts/{account_id}/queues">client.queues.<a href="./src/resources/queues/queues.ts">create</a>({ ...params }) -> QueueCreateResponse | null</code>
- <code title="put /accounts/{account_id}/queues/{queue_id}">client.queues.<a href="./src/resources/queues/queues.ts">update</a>(queueId, { ...params }) -> QueueUpdateResponse | null</code>
- <code title="get /accounts/{account_id}/queues">client.queues.<a href="./src/resources/queues/queues.ts">list</a>({ ...params }) -> QueueListResponsesSinglePage</code>
- <code title="get /accounts/{account_id}/queues">client.queues.<a href="./src/resources/queues/queues.ts">list</a>({ ...params }) -> QueueListResponse | null</code>
- <code title="delete /accounts/{account_id}/queues/{queue_id}">client.queues.<a href="./src/resources/queues/queues.ts">delete</a>(queueId, { ...params }) -> QueueDeleteResponse | null</code>
- <code title="get /accounts/{account_id}/queues/{queue_id}">client.queues.<a href="./src/resources/queues/queues.ts">get</a>(queueId, { ...params }) -> QueueGetResponse | null</code>

Expand Down
1 change: 0 additions & 1 deletion src/index.ts
Original file line number Diff line number Diff line change
Expand Up @@ -646,7 +646,6 @@ export namespace Cloudflare {
export import QueueListResponse = API.QueueListResponse;
export import QueueDeleteResponse = API.QueueDeleteResponse;
export import QueueGetResponse = API.QueueGetResponse;
export import QueueListResponsesSinglePage = API.QueueListResponsesSinglePage;
export import QueueCreateParams = API.QueueCreateParams;
export import QueueUpdateParams = API.QueueUpdateParams;
export import QueueListParams = API.QueueListParams;
Expand Down
1 change: 0 additions & 1 deletion src/resources/index.ts
Original file line number Diff line number Diff line change
Expand Up @@ -278,7 +278,6 @@ export {
QueueListParams,
QueueDeleteParams,
QueueGetParams,
QueueListResponsesSinglePage,
Queues,
} from './queues/queues';
export { R2 } from './r2/r2';
Expand Down
1 change: 0 additions & 1 deletion src/resources/queues/index.ts
Original file line number Diff line number Diff line change
Expand Up @@ -25,7 +25,6 @@ export {
QueueListParams,
QueueDeleteParams,
QueueGetParams,
QueueListResponsesSinglePage,
Queues,
} from './queues';
export {
Expand Down
37 changes: 19 additions & 18 deletions src/resources/queues/queues.ts
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,6 @@ import { APIResource } from 'cloudflare/resource';
import * as QueuesAPI from 'cloudflare/resources/queues/queues';
import * as ConsumersAPI from 'cloudflare/resources/queues/consumers';
import * as MessagesAPI from 'cloudflare/resources/queues/messages';
import { SinglePage } from 'cloudflare/pagination';

export class Queues extends APIResource {
consumers: ConsumersAPI.Consumers = new ConsumersAPI.Consumers(this._client);
Expand Down Expand Up @@ -46,12 +45,13 @@ export class Queues extends APIResource {
/**
* Returns the queues owned by an account.
*/
list(
params: QueueListParams,
options?: Core.RequestOptions,
): Core.PagePromise<QueueListResponsesSinglePage, QueueListResponse> {
list(params: QueueListParams, options?: Core.RequestOptions): Core.APIPromise<QueueListResponse | null> {
const { account_id } = params;
return this._client.getAPIList(`/accounts/${account_id}/queues`, QueueListResponsesSinglePage, options);
return (
this._client.get(`/accounts/${account_id}/queues`, options) as Core.APIPromise<{
result: QueueListResponse | null;
}>
)._thenUnwrap((obj) => obj.result);
}

/**
Expand Down Expand Up @@ -87,8 +87,6 @@ export class Queues extends APIResource {
}
}

export class QueueListResponsesSinglePage extends SinglePage<QueueListResponse> {}

export interface Queue {
consumers?: unknown;

Expand Down Expand Up @@ -147,22 +145,26 @@ export interface QueueUpdateResponse {
queue_name?: string;
}

export interface QueueListResponse {
consumers?: unknown;
export type QueueListResponse = Array<QueueListResponse.QueueListResponseItem>;

consumers_total_count?: unknown;
export namespace QueueListResponse {
export interface QueueListResponseItem {
consumers?: unknown;

created_on?: unknown;
consumers_total_count?: unknown;

modified_on?: unknown;
created_on?: unknown;

producers?: unknown;
modified_on?: unknown;

producers_total_count?: unknown;
producers?: unknown;

queue_id?: string;
producers_total_count?: unknown;

queue_name?: string;
queue_id?: string;

queue_name?: string;
}
}

export type QueueDeleteResponse = unknown | Array<unknown> | string;
Expand Down Expand Up @@ -239,7 +241,6 @@ export namespace Queues {
export import QueueListResponse = QueuesAPI.QueueListResponse;
export import QueueDeleteResponse = QueuesAPI.QueueDeleteResponse;
export import QueueGetResponse = QueuesAPI.QueueGetResponse;
export import QueueListResponsesSinglePage = QueuesAPI.QueueListResponsesSinglePage;
export import QueueCreateParams = QueuesAPI.QueueCreateParams;
export import QueueUpdateParams = QueuesAPI.QueueUpdateParams;
export import QueueListParams = QueuesAPI.QueueListParams;
Expand Down