( loadPage: (after?: string) => Promise<unknown>, )
| 344 | }; |
| 345 | |
| 346 | export const collectRawWorkOSList = async ( |
| 347 | loadPage: (after?: string) => Promise<unknown>, |
| 348 | ): Promise<WorkOSCollectedList<unknown>> => { |
| 349 | const first = Option.getOrNull(decodeRawWorkOSListResponse(await loadPage())); |
| 350 | if (!first) { |
| 351 | return { |
| 352 | object: "list", |
| 353 | data: [], |
| 354 | listMetadata: completedListMetadata, |
| 355 | }; |
| 356 | } |
| 357 | |
| 358 | const data = [...first.data]; |
| 359 | let after = nextCursorFromRawList(first); |
| 360 | |
| 361 | while (after) { |
| 362 | const next = Option.getOrNull(decodeRawWorkOSListResponse(await loadPage(after))); |
| 363 | if (!next) break; |
| 364 | data.push(...next.data); |
| 365 | after = nextCursorFromRawList(next); |
| 366 | } |
| 367 | |
| 368 | return { |
| 369 | object: "list", |
| 370 | data, |
| 371 | listMetadata: completedListMetadata, |
| 372 | }; |
| 373 | }; |
| 374 | |
| 375 | class WorkOSConfigurationError extends Data.TaggedError("WorkOSConfigurationError")<{ |
| 376 | readonly message: string; |
no test coverage detected