Skip to content

Improve tasks and batches types, refactor related tests #1943

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Closed
wants to merge 79 commits into from
Closed
Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
79 commits
Select commit Hold shift + click to select a range
797d9ee
Remove unnecessary classes
flevi29 Jan 8, 2025
23218d2
Save progress
flevi29 Jan 10, 2025
e5f1840
Progress
flevi29 Jan 13, 2025
4dceb10
Progress
flevi29 Jan 13, 2025
a18fad3
Merge branch 'main' into improve-task-batch
flevi29 Jan 13, 2025
9553b75
Fix formatting
flevi29 Jan 13, 2025
baf08c5
Fix test
flevi29 Jan 13, 2025
b5bfb5d
Fix test
flevi29 Jan 13, 2025
b8c7afc
Fix rest of the tests, adjust readme
flevi29 Jan 13, 2025
207da36
Add documentation, adjust types, functions, misc
flevi29 Jan 14, 2025
5651f6c
Merge branch 'main' into improve-task-batch
flevi29 Jan 14, 2025
a10699a
Fix formatting
flevi29 Jan 14, 2025
1ea7670
Revert some changes, misc
flevi29 Jan 15, 2025
8062d9b
Adjust types
flevi29 Jan 15, 2025
b77291b
Fix test
flevi29 Jan 15, 2025
b525e8d
Misc
flevi29 Jan 15, 2025
ccd5c20
Adjust docs
flevi29 Jan 16, 2025
bcbac12
Adjust doc
flevi29 Jan 18, 2025
03be679
Merge branch 'main' into improve-task-batch
flevi29 Jan 28, 2025
49dedd0
Merge with main
flevi29 Jan 30, 2025
890102a
Merge branch 'improve-task-batch' of github.com:flevi29/meilisearch-j…
flevi29 Jan 30, 2025
6e00229
Revert settings types change
flevi29 Jan 30, 2025
1dc418a
Fix formatting
flevi29 Jan 30, 2025
d141b1b
Add task wait applier to tasks as well
flevi29 Jan 30, 2025
6ff3d52
Revert bad test
flevi29 Jan 30, 2025
72c1456
Remove focus from test, experiment with old interval
flevi29 Jan 30, 2025
048a479
Fix not clearing timers when task is successfully awaited
flevi29 Jan 30, 2025
53a9049
Try and fix waitTask being slow
flevi29 Jan 30, 2025
adc946b
Fix unhandled rejections
flevi29 Jan 30, 2025
d2b3234
Refactor waitTask
flevi29 Jan 30, 2025
b509d60
Try fix slow waitTask
flevi29 Jan 31, 2025
9f4aacc
Try fix slow waitTask
flevi29 Jan 31, 2025
4db49a6
Add ability to specify default wait options for tasks through exporte…
flevi29 Jan 31, 2025
bc08957
Shorten code
flevi29 Jan 31, 2025
b5a6a7d
Rename variables
flevi29 Jan 31, 2025
a906055
Remove hint about bad Meilisearch version
flevi29 Jan 31, 2025
8c500a3
Add test for failing waitTask
flevi29 Jan 31, 2025
b2acf84
Fix formatting, don't add timeout if interval is invalid
flevi29 Jan 31, 2025
88f210e
Rename functions, adjust description
flevi29 Jan 31, 2025
15984a2
Do not export TaskClient in index
flevi29 Jan 31, 2025
1c74be0
Merge branch 'main' into improve-task-batch
flevi29 Feb 1, 2025
3156692
Revert deprecations
flevi29 Feb 5, 2025
9be9626
Merge branch 'main' into improve-task-batch
flevi29 Feb 6, 2025
a278fe6
Merge with main
flevi29 Feb 17, 2025
824f284
Merge branch 'improve-task-batch' of github.com:flevi29/meilisearch-j…
flevi29 Feb 17, 2025
61cf291
Fix formatting
flevi29 Feb 17, 2025
f9d412a
Merge branch 'main' into improve-task-batch
flevi29 Mar 2, 2025
7db2295
Merge with main
flevi29 Mar 12, 2025
cb7ff86
Added missing batchUids prop, misc
flevi29 Mar 13, 2025
d1e7b60
Make waitTask abort last getTask on timeout
flevi29 Mar 13, 2025
0b65095
Improve timeout errors, fix tests
flevi29 Mar 13, 2025
97c3019
Misc
flevi29 Mar 15, 2025
cdbd556
Fix error
flevi29 Mar 15, 2025
12fe057
Fix formatting
flevi29 Mar 15, 2025
fc4e9f4
Remove unnecessary tests
flevi29 Mar 15, 2025
324ae8c
Fix waitTask, try Symbol for timeout ID
flevi29 Mar 15, 2025
43f79b2
Fix http requests not catching abort error on response.text()
flevi29 Mar 15, 2025
6248a59
Fix Node.js 18 compat
flevi29 Mar 15, 2025
4f2b292
Add documentation to changed errors
flevi29 Mar 15, 2025
13cec4b
Merge with main
flevi29 Mar 21, 2025
517e119
Merge with main
flevi29 Mar 26, 2025
1cd5aae
Merge branch 'main' into improve-task-batch
Strift Apr 1, 2025
68c4afd
Update type definitions header
flevi29 Apr 1, 2025
51cb947
Improve tasks and batches, refactor tests
flevi29 May 8, 2025
1a32547
Merge with main
flevi29 May 8, 2025
50a7ee1
Improvements
flevi29 May 8, 2025
dfa1e61
Fix bad merge
flevi29 May 8, 2025
b7c975e
Try fix renamed file
flevi29 May 8, 2025
878388a
Refactor code, minor changes
flevi29 May 9, 2025
df365fb
Revert file rename, cannot fix git not detecting it properly
flevi29 May 9, 2025
29d1c1b
Add test for wait options
flevi29 May 11, 2025
2bf02e5
Fix documentation
flevi29 May 11, 2025
05d87ec
Merge branch 'main' into improve-task-batch
flevi29 May 19, 2025
fddd1e3
Use randomUUID instead of fixed UUID
flevi29 May 19, 2025
80095a0
Revert renaming of types and certain symbols
flevi29 May 28, 2025
9d1287c
Add missing renames
flevi29 May 28, 2025
d7dd3fe
Misc
flevi29 May 28, 2025
dd8946a
Fix test
flevi29 May 28, 2025
ff1e7e1
Update src/types/task_and_batch.ts
flevi29 May 28, 2025
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
32 changes: 16 additions & 16 deletions .code-samples.meilisearch.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -99,35 +99,35 @@ multi_search_1: |-
},
]})
get_all_tasks_1: |-
client.getTasks()
client.tasks.getTasks()
get_task_1: |-
client.getTask(1)
client.tasks.getTask(1)
async_guide_filter_by_date_1: |-
client.getTasks({ afterEnqueuedAt: '2020-10-11T11:49:53.000Z' })
client.tasks.getTasks({ afterEnqueuedAt: '2020-10-11T11:49:53.000Z' })
async_guide_multiple_filters_1: |-
client.getTasks({
client.tasks.getTasks({
indexUids: ['movies'],
types: ['documentAdditionOrUpdate','documentDeletion'],
statuses: ['processing']
})
async_guide_filter_by_ids_1: |-
client.getTasks({ uids: [5, 10, 13] })
client.tasks.getTasks({ uids: [5, 10, 13] })
async_guide_filter_by_statuses_1: |-
client.getTasks({ statuses: ['failed', 'canceled'] })
client.tasks.getTasks({ statuses: ['failed', 'canceled'] })
async_guide_filter_by_types_1: |-
client.getTasks({ types: ['dumpCreation', 'indexSwap'] })
client.tasks.getTasks({ types: ['dumpCreation', 'indexSwap'] })
async_guide_filter_by_index_uids_1: |-
client.getTasks({ indexUids: ['movies'] })
client.tasks.getTasks({ indexUids: ['movies'] })
get_all_tasks_paginating_1: |-
client.getTasks({ limit: 2, from: 10 })
client.tasks.getTasks({ limit: 2, from: 10 })
get_all_tasks_paginating_2: |-
client.getTasks({ limit: 2, from: 8 })
client.tasks.getTasks({ limit: 2, from: 8 })
async_guide_canceled_by_1: |-
client.getTasks({ canceledBy: [9, 15] })
client.tasks.getTasks({ canceledBy: [9, 15] })
delete_tasks_1: |-
client.deleteTasks({ uids: [1, 2] })
client.tasks.deleteTasks({ uids: [1, 2] })
cancel_tasks_1: |-
client.cancelTasks({ uids: [1, 2] })
client.tasks.cancelTasks({ uids: [1, 2] })
get_one_key_1: |-
client.getKey('6062abda-a5aa-4414-ac91-ecd7944c0f8d')
get_all_keys_1: |-
Expand Down Expand Up @@ -458,7 +458,7 @@ getting_started_update_searchable_attributes: |-
getting_started_update_stop_words: |-
client.index('movies').updateStopWords(['the'])
getting_started_check_task_status: |-
client.getTask(0)
client.tasks.getTask(0)
getting_started_synonyms: |-
client.index('movies').updateSynonyms({
winnie: ['piglet'],
Expand Down Expand Up @@ -806,9 +806,9 @@ update_prefix_search_settings_1: |-
reset_prefix_search_settings_1: |-
client.index('INDEX_NAME').resetPrefixSearch();
get_all_batches_1: |-
client.getBatches();
client.batches.getBatches();
get_batch_1: |-
client.getBatch(BATCH_UID);
client.batches.getBatch(BATCH_UID);
# Vector search
update_embedders_1: |-
client.index('INDEX_NAME').updateEmbedders({
Expand Down
16 changes: 8 additions & 8 deletions README.md
Original file line number Diff line number Diff line change
Expand Up @@ -531,37 +531,37 @@ client.index('myIndex').deleteAllDocuments(): Promise<Types.EnqueuedTask>
#### [Get all tasks](https://www.meilisearch.com/docs/reference/api/tasks#get-all-tasks)

```ts
client.getTasks(parameters: TasksQuery): Promise<TasksResults>
client.tasks.getTasks(parameters: TasksQuery): Promise<TasksResults>
```

#### [Get one task](https://www.meilisearch.com/docs/reference/api/tasks)

```ts
client.getTask(uid: number): Promise<Task>
client.tasks.getTask(uid: number): Promise<Task>
```

#### [Delete tasks](https://www.meilisearch.com/docs/reference/api/tasks#delete-tasks)

```ts
client.deleteTasks(parameters: DeleteTasksQuery = {}): Promise<EnqueuedTask>
client.tasks.deleteTasks(parameters: DeleteTasksQuery = {}): Promise<EnqueuedTask>
Copy link
Preview

Copilot AI May 15, 2025

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

The API implementation now returns a SummarizedTaskPromise (and SummarizedTaskView) instead of EnqueuedTask. Please update the README examples to reflect the new type names for consistency.

Copilot uses AI. Check for mistakes.

```

#### [Cancel tasks](https://www.meilisearch.com/docs/reference/api/tasks#cancel-tasks)

```ts
client.cancelTasks(parameters: CancelTasksQuery = {}): Promise<EnqueuedTask>
client.tasks.cancelTasks(parameters: CancelTasksQuery = {}): Promise<EnqueuedTask>
```

#### [Get all tasks of an index](https://www.meilisearch.com/docs/reference/api/tasks#get-all-tasks-by-index)

```ts
client.index('myIndex').getTasks(parameters: TasksQuery): Promise<TasksResults>
client.index('myIndex').tasks.getTasks(parameters: TasksQuery): Promise<TasksResults>
```

#### [Get one task of an index](https://www.meilisearch.com/docs/reference/api/tasks)

```ts
client.index('myIndex').getTask(uid: number): Promise<Task>
client.index('myIndex').tasks.getTask(uid: number): Promise<Task>
```

#### Wait for one task
Expand All @@ -581,13 +581,13 @@ client.tasks.waitForTasks(uids: number[], { timeout?: number, interval?: number
#### [Get one batch](https://www.meilisearch.com/docs/reference/api/batches#get-one-batch)

```ts
client.getBatch(uid: number): Promise<Batch>
client.batches.getBatch(uid: number): Promise<Batch>
```

#### [Get all batches](https://www.meilisearch.com/docs/reference/api/batchess#get-batches)

```ts
client.getBatches(parameters: BatchesQuery = {}): Promise<BatchesResults>
client.batches.getBatches(parameters: BatchesQuery = {}): Promise<BatchesResults>
```

### Indexes <!-- omit in toc -->
Expand Down
15 changes: 3 additions & 12 deletions src/batch.ts
Original file line number Diff line number Diff line change
Expand Up @@ -19,20 +19,11 @@ export class BatchClient {

/** {@link https://www.meilisearch.com/docs/reference/api/batches#get-one-batch} */
async getBatch(uid: number): Promise<Batch> {
const batch = await this.#httpRequest.get<Batch>({
path: `batches/${uid}`,
});
return batch;
return await this.#httpRequest.get({ path: `batches/${uid}` });
}

/** {@link https://www.meilisearch.com/docs/reference/api/batches#get-batches} */
async getBatches(
batchesQuery?: TasksOrBatchesQuery,
): Promise<BatchesResults> {
const batches = await this.#httpRequest.get<BatchesResults>({
path: "batches",
params: batchesQuery,
});
return batches;
async getBatches(params?: TasksOrBatchesQuery): Promise<BatchesResults> {
return await this.#httpRequest.get({ path: "batches", params });
}
}
22 changes: 6 additions & 16 deletions src/task.ts
Original file line number Diff line number Diff line change
Expand Up @@ -74,24 +74,20 @@ export class TaskClient {
// TODO: Need to do this for all other methods: https://github.com/meilisearch/meilisearch-js/issues/1476
extraRequestInit?: ExtraRequestInit,
): Promise<Task> {
const task = await this.#httpRequest.get<Task>({
return await this.#httpRequest.get({
path: `tasks/${uid}`,
extraRequestInit,
});
return task;
}

/** {@link https://www.meilisearch.com/docs/reference/api/tasks#get-tasks} */
async getTasks(params?: TasksOrBatchesQuery): Promise<TasksResults> {
const tasks = await this.#httpRequest.get<TasksResults>({
path: "tasks",
params,
});
return tasks;
return await this.#httpRequest.get({ path: "tasks", params });
}

/**
* Wait for an enqueued task to be processed.
* Wait for an enqueued task to be processed. This is done through polling
* with {@link TaskClient.getTask}.
*
* @remarks
* If an {@link EnqueuedTask} needs to be awaited instantly, it is recommended
Expand Down Expand Up @@ -167,20 +163,14 @@ export class TaskClient {
/** {@link https://www.meilisearch.com/docs/reference/api/tasks#cancel-tasks} */
cancelTasks(params: DeleteOrCancelTasksQuery): EnqueuedTaskPromise {
return this.#applyWaitTask(
this.#httpRequest.post({
path: "tasks/cancel",
params,
}),
this.#httpRequest.post({ path: "tasks/cancel", params }),
);
}

/** {@link https://www.meilisearch.com/docs/reference/api/tasks#delete-tasks} */
deleteTasks(params: DeleteOrCancelTasksQuery): EnqueuedTaskPromise {
return this.#applyWaitTask(
this.#httpRequest.delete({
path: "tasks",
params,
}),
this.#httpRequest.delete({ path: "tasks", params }),
);
}
}
Expand Down
9 changes: 9 additions & 0 deletions src/types/shared.ts
Original file line number Diff line number Diff line change
Expand Up @@ -16,3 +16,12 @@ export type NonNullableDeepRecordValues<T> = {
? NonNullableDeepRecordValues<T[P]>
: NonNullable<T[P]>;
};

// taken from https://stackoverflow.com/a/65642944
export type PascalToCamelCase<S extends string> = Uncapitalize<S>;

export type SafeOmit<T, K extends keyof T> = Omit<T, K>;

export type OptionStarOr<T> = "*" | T | null;
// eslint-disable-next-line @typescript-eslint/no-explicit-any
export type OptionStarOrList<T extends any[]> = ["*"] | T | null;
Loading