Method list

integrations/openai/src/threads.ts:571–610

(
    key: IntegrationTaskKey,
    threadId: string,
    params: Prettify<OpenAI.Beta.AssistantListParams> | OpenAIRequestOptions = {},
    options: OpenAIRequestOptions | undefined = undefined
  )

    options?: OpenAIRequestOptions
  ): Promise<OpenAI.Beta.Threads.ThreadMessage[]>;
  async list(
    key: IntegrationTaskKey,
    threadId: string,
    params: Prettify<OpenAI.Beta.AssistantListParams> | OpenAIRequestOptions = {},
    options: OpenAIRequestOptions | undefined = undefined
  ): Promise<OpenAI.Beta.Threads.ThreadMessage[]> {
    return this.runTask(
      key,
      async (client, task, io) => {
        if (isRequestOptions(params)) {
          const { data: page, response } = await client.beta.threads.messages
            .list(threadId, {
              idempotencyKey: task.idempotencyKey,
              ...params,
            })
            .withResponse();

          task.outputProperties = createTaskOutputProperties(undefined, response.headers);

          return page.data;
        }

        const { data: page, response } = await client.beta.threads.messages
          .list(threadId, params, {
            idempotencyKey: task.idempotencyKey,
            ...options,
          })
          .withResponse();

        task.outputProperties = createTaskOutputProperties(undefined, response.headers);

        return page.data;
      },
      {
        name: "List Messages",
        properties: [{ label: "threadId", text: threadId }],
      },
      handleOpenAIError
    );
  }

  /**
   * Returns all messages for a given thread.