48:I[660678,["/_next/static/chunks/13vqyfldau57p.js","/_next/static/chunks/1gbl-dcot4vlq.js","/_next/static/chunks/3w7s_-pxil6pv.js","/_next/static/chunks/3zorfbfh_a_pd.js","/_next/static/chunks/0cnrn8dx8wpm6.js","/_next/static/chunks/2e4udl7tfg2xd.js","/_next/static/chunks/1mbdq0lktamc7.js","/_next/static/chunks/0nq310uz96h4-.js","/_next/static/chunks/2i4xo8xu-dpuk.js","/_next/static/chunks/40fmu66fmb8tm.js","/_next/static/chunks/3vehc-g2atkra.js","/_next/static/chunks/2a4jc680f5x-9.js","/_next/static/chunks/2wyk4b1ao4pa_.js","/_next/static/chunks/1gth09_ur0iam.js","/_next/static/chunks/0ugk39ckud30x.js","/_next/static/chunks/0pp6seif9t0rh.js","/_next/static/chunks/3bhq66ea_v7by.js","/_next/static/chunks/44c_5nh0vyeb5.js","/_next/static/chunks/1jiredr0b6jr_.js","/_next/static/chunks/0r86cplnpkdza.js","/_next/static/chunks/2ghxk472-g0i6.js","/_next/static/chunks/1ra7jqz5hyzln.js","/_next/static/chunks/42kj-we3o-c3u.js","/_next/static/chunks/2vvl77bxv5nze.js","/_next/static/chunks/2dk9hti1hh4ut.js","/_next/static/chunks/2l8l4_a9-xhts.js","/_next/static/chunks/1qsa_rj-5yj90.js","/_next/static/chunks/0ewjxq-e6quq-.js","/_next/static/chunks/34y7-26s89h2f.js","/_next/static/chunks/0ojgzwcpt7vsk.js","/_next/static/chunks/3enqpgm3pn7at.js","/_next/static/chunks/3-906s1ue5fj3.js","/_next/static/chunks/2t_5zfez2-77k.js","/_next/static/chunks/2641m2aqdum9a.js","/_next/static/chunks/1cvej8ocaz0a2.js","/_next/static/chunks/1j29bqcxcpyur.js"],"HydrationBoundary"] 47:Tbc4,{"@context":"https://schema.org","@graph":[{"@type":"WebSite","@id":"https://app.codemod.com/registry#website","url":"https://app.codemod.com/registry","name":"Codemod Registry"},{"@type":"Organization","@id":"https://app.codemod.com#org","name":"Alex Bit","url":"https://app.codemod.com","logo":"https://avatars.githubusercontent.com/u/78109534?v=4"},{"@type":"BreadcrumbList","@id":"https://app.codemod.com/registry/async-waterfall-mining#breadcrumb","itemListElement":[{"@type":"ListItem","position":1,"name":"Registry","item":"https://app.codemod.com/registry"},{"@type":"ListItem","position":2,"name":"async-waterfall-mining","item":"https://app.codemod.com/registry/async-waterfall-mining"}]},{"@type":"WebPage","@id":"https://app.codemod.com/registry/async-waterfall-mining#webpage","url":"https://app.codemod.com/registry/async-waterfall-mining","name":"async-waterfall-mining - Codemod Registry","description":"Mine TypeScript async serialization / parallelization opportunities via read-only JSSG metrics (await-in-loop, consecutive awaits, async reduce, sequential chunks, repeated await calls). Combines syntax detection with light data-flow filtering.","isPartOf":{"@id":"https://app.codemod.com/registry#website"},"author":{"@id":"https://app.codemod.com#org"},"breadcrumb":{"@id":"https://app.codemod.com/registry/async-waterfall-mining#breadcrumb"},"mainEntity":{"@id":"https://app.codemod.com/registry/async-waterfall-mining#sourcecode"}},{"@type":"SoftwareSourceCode","@id":"https://app.codemod.com/registry/async-waterfall-mining#sourcecode","name":"async-waterfall-mining","description":"Mine TypeScript async serialization / parallelization opportunities via read-only JSSG metrics (await-in-loop, consecutive awaits, async reduce, sequential chunks, repeated await calls). Combines syntax detection with light data-flow filtering.","url":"https://app.codemod.com/registry/async-waterfall-mining","publisher":{"@id":"https://app.codemod.com#org"},"image":"https://avatars.githubusercontent.com/u/78109534?v=4","isAccessibleForFree":true,"license":"MIT","version":"0.1.5","keywords":["mining","metrics","typescript","async","performance","parallelization","waterfall"],"datePublished":"2026-09-01 02:38:40.428502+00","dateModified":"2026-09-01 03:50:09.067704+00"},{"@type":"SoftwareApplication","@id":"https://app.codemod.com/registry/async-waterfall-mining#app","name":"async-waterfall-mining codemod","description":"Mine TypeScript async serialization / parallelization opportunities via read-only JSSG metrics (await-in-loop, consecutive awaits, async reduce, sequential chunks, repeated await calls). Combines syntax detection with light data-flow filtering.","url":"https://app.codemod.com/registry/async-waterfall-mining","publisher":{"@id":"https://app.codemod.com#org"},"softwareVersion":"0.1.5","applicationCategory":"DeveloperApplication","operatingSystem":"Cross-platform","offers":{"@type":"Offer","price":"0","priceCurrency":"USD","availability":"https://schema.org/InStock"}}]}49:T1148,# Async Waterfall Mining Read-only JSSG mining codemod that surfaces **async serialization / parallelization opportunities** in TypeScript codebases. Each workflow step emits a separate metric namespace; no source files are modified. Findings are **candidates for review**, not proof that code is safe to parallelize. Use metrics to narrow the search space in Codemod Insights; confirm with profiling and domain analysis before refactoring. ## Metrics | Metric atom | Pattern | |-------------|---------| | `async_waterfall_await_in_loop` | `await` inside `for` / `for...of` / `for await...of` / `while` / `do...while` | | `async_waterfall_consecutive_await` | Adjacent sibling `await` statements (with independence heuristic) | | `async_waterfall_async_reduce` | `.reduce()` with `async` callback or `await` in reducer | | `async_waterfall_sequential_chunk` | `await` inside loops over chunks, batches, or pages | | `async_waterfall_repeated_await_call` | Same awaited call shape repeated 2+ times in one function | Metrics do not include a `severity` or `impact` field. Tier findings in Insights using cardinality (for example `io_likelihood`, `independence`, `inside_loop`). ## Metric cardinality Every finding includes: - `file_path`, `function_name`, `line`, `snippet` Additional dimensions per metric: | Metric | Cardinality | |--------|-------------| | `async_waterfall_await_in_loop` | `loop_kind`, `nesting_depth`, `await_count`, `io_likelihood` | | `async_waterfall_consecutive_await` | `independence`, `first_callee`, `second_callee`, `first_io`, `second_io` | | `async_waterfall_async_reduce` | (location only) | | `async_waterfall_sequential_chunk` | `loop_var`, `iterable_hint`, `io_likelihood` | | `async_waterfall_repeated_await_call` | `callee`, `occurrence_count`, `inside_loop` | `io_likelihood` and `first_io` / `second_io` are heuristic (`high`, `medium`, `low`) based on callee names (for example `fetch`, `query`, `insert`, `checkpoint`). ## Emit conditions - **await-in-loop** — loop body has at least one non-suppressed `await`, and (`io_likelihood` is not `low` or `nesting_depth` is `2+`). Skips loop bodies that are only `await Promise.all(...)`. - **consecutive-await** — two adjacent statements in the same block each have a top-level `await`. Suppresses `likely_dependent` pairs unless `emit_dependent_consecutive` is enabled. - **async-reduce** — any `.reduce()` whose callback is `async` or contains `await` (no I/O gate). - **sequential-chunk** — loop variable or iterable matches chunk/batch/page naming (for example `chunk`, `batch`, `page`, `chunk(...)`, `paginate(...)`), with at least one non-suppressed `await` in the body. - **repeated-await-call** — identical awaited call shape appears 2+ times in one function, and (`inside_loop` is true or occurrences span 2+ lines). **Suppressed awaits** (not counted toward await-in-loop or sequential-chunk): `await` inside `Promise.all` / `allSettled` / `any` / `race` callbacks, or inside `p-limit`-style limiter callbacks. ## Consecutive-await independence For pairs of consecutive `await` statements, the miner checks whether identifiers bound by the first appear in the **call arguments** of the second. This is a shallow, same-block heuristic — not full data-flow or control-flow analysis. - `likely_independent` — no overlap (candidate for `Promise.all`) - `likely_dependent` — second uses first's binding (suppressed by default) - `unknown` — cannot determine from binding walk Enable dependent pairs for tuning: workflow param `emit_dependent_consecutive: true`. ## Semantic analysis Steps **2** (`consecutive-await`) and **5** (`repeated-await-call`) enable workspace semantic analysis (oxc) for richer callee resolution. Run from a TypeScript project root. Steps 1, 3, and 4 use file-scope AST only. ## Workflow params - `include_tests` (default `false`) — include `*.test.*` / `*.spec.*` - `emit_dependent_consecutive` (default `false`) — emit `likely_dependent` consecutive-await pairs ## Limits This tool **reports** suspicious patterns only. It does not: - Prove calls are safe to parallelize (transactions, ordering, rate limits) - Auto-apply `Promise.all` or `p-limit` refactors - Model full TypeScript control-flow or cross-function dependencies All findings require human review before refactoring. 19:[["$","script",null,{"type":"application/ld+json","dangerouslySetInnerHTML":{"__html":"$47"}}],["$","$L48",null,{"state":{"mutations":[],"queries":[{"state":{"data":{"json":{"id":"12d9f94e-5297-4d92-a9c4-4f5830075c08","name":"async-waterfall-mining","displayName":"async-waterfall-mining","description":"Mine TypeScript async serialization / parallelization opportunities via read-only JSSG metrics (await-in-loop, consecutive awaits, async reduce, sequential chunks, repeated await calls). Combines syntax detection with light data-flow filtering.","scope":null,"visibility":"public","downloadCount":14,"executionCount":3,"createdAt":"2026-09-01 02:38:40.428502+00","updatedAt":"2026-09-01 03:50:09.067704+00","latestVersion":"0.1.5","keywords":["mining","metrics","typescript","async","performance","parallelization","waterfall"],"starCount":0,"author":"Alex Bit ","homepage":null,"repository":null,"license":"MIT","access":"pro","documentation":null,"bugsUrl":null,"readme":"$49","organization":{"id":null,"name":null,"slug":null,"avatarUrl":null},"owner":{"id":"4519f7a8-2ebc-4eaf-8c0a-e01be4c05878","username":"alexbit-codemod","name":"Alex Bit","avatarUrl":"https://avatars.githubusercontent.com/u/78109534?v=4"},"isLegacy":false,"versions":[{"version":{"id":"6b125a58-2546-44f3-9003-b0ae5c268ee9","packageId":"12d9f94e-5297-4d92-a9c4-4f5830075c08","version":"0.1.5","description":"Mine TypeScript async serialization / parallelization opportunities via read-only JSSG metrics (await-in-loop, consecutive awaits, async reduce, sequential chunks, repeated await calls). Combines syntax detection with light data-flow filtering.","manifest":{"name":"async-waterfall-mining","author":"Alex Bit ","license":"MIT","targets":{"versions":{},"languages":["typescript","tsx"],"frameworks":[]},"version":"0.1.5","keywords":["mining","metrics","typescript","async","performance","parallelization","waterfall"],"registry":{"access":"pro","visibility":"public"},"workflows":[{"name":"main","path":"workflow.yaml","default":true}],"description":"Mine TypeScript async serialization / parallelization opportunities via read-only JSSG metrics (await-in-loop, consecutive awaits, async reduce, sequential chunks, repeated await calls). Combines syntax detection with light data-flow filtering.","dependencies":[],"schema_version":"1.0"},"checksum":"a9e3e38f16f8915e04a7ea9be8d96662a53f5876d283bf63d071ea809fe8c5a1","size":14135,"downloadUrl":"https://registry-cdn.codemod.com/prod/packages/private/async-waterfall-mining/0.1.5/private-a9e3_p04lexeiyec.tar.gz","aiGenerated":false,"sourceArchiveS3Key":null,"targets":{"languages":["typescript"],"frameworks":[]},"dependencies":[],"languages":["tsx"],"stepTypes":["js-ast-grep"],"workflowMetadata":{"nodes":[{"id":"async-waterfall-mining","name":"Async waterfall mining (read-only metrics)","steps":[{"name":"1. await-in-loop","type":"js-ast-grep","metrics":[{"name":"async_waterfall_await_in_loop","cardinalityKeys":["loop_kind","nesting_depth","await_count","io_likelihood"]}],"language":"tsx"},{"name":"2. consecutive-await","type":"js-ast-grep","metrics":[{"name":"async_waterfall_consecutive_await","cardinalityKeys":["independence","first_callee","second_callee","first_io","second_io"]}],"language":"tsx","semanticAnalysis":"workspace"},{"name":"3. async-reduce","type":"js-ast-grep","metrics":[{"name":"async_waterfall_async_reduce","cardinalityKeys":[]}],"language":"tsx"},{"name":"4. sequential-chunk","type":"js-ast-grep","metrics":[{"name":"async_waterfall_sequential_chunk","cardinalityKeys":["loop_var","iterable_hint","io_likelihood"]}],"language":"tsx"},{"name":"5. repeated-await-call","type":"js-ast-grep","metrics":[{"name":"async_waterfall_repeated_await_call","cardinalityKeys":["callee","occurrence_count","inside_loop"]}],"language":"tsx","semanticAnalysis":"workspace"}]}],"metricMetadataVersion":1},"validated":false,"validationErrors":null,"publishedBy":"4519f7a8-2ebc-4eaf-8c0a-e01be4c05878","deprecated":false,"deprecationMessage":null,"downloadCount":10,"cachedTestCases":{"input":"async function getUser(id: string) {\r\n return { id };\r\n}\r\nasync function getOrders(userId: string) {\r\n return [];\r\n}\r\n\r\nexport async function load(id: string) {\r\n const user = await getUser(id);\r\n await getOrders(user.id);\r\n}\r\n","output":"async function getUser(id: string) {\r\n return { id };\r\n}\r\nasync function getOrders(userId: string) {\r\n return [];\r\n}\r\n\r\nexport async function load(id: string) {\r\n const user = await getUser(id);\r\n await getOrders(user.id);\r\n}\r\n","isValid":true,"examples":[{"name":"negative","path":"tests/consecutive-await/negative","input":"async function getUser(id: string) {\r\n return { id };\r\n}\r\nasync function getOrders(userId: string) {\r\n return [];\r\n}\r\n\r\nexport async function load(id: string) {\r\n const user = await getUser(id);\r\n await getOrders(user.id);\r\n}\r\n","output":"async function getUser(id: string) {\r\n return { id };\r\n}\r\nasync function getOrders(userId: string) {\r\n return [];\r\n}\r\n\r\nexport async function load(id: string) {\r\n const user = await getUser(id);\r\n await getOrders(user.id);\r\n}\r\n","filename":"input.ts"},{"name":"positive","path":"tests/consecutive-await/positive","input":"async function readUsers() {\r\n return [];\r\n}\r\nasync function readGroups() {\r\n return [];\r\n}\r\n\r\nexport async function syncOrg() {\r\n await readUsers();\r\n await readGroups();\r\n}\r\n","output":"async function readUsers() {\r\n return [];\r\n}\r\nasync function readGroups() {\r\n return [];\r\n}\r\n\r\nexport async function syncOrg() {\r\n await readUsers();\r\n await readGroups();\r\n}\r\n","filename":"input.ts"},{"name":"positive","path":"tests/repeated-await-call/positive","input":"async function query() {\r\n return { items: [], pageInfo: { nextCursor: 'abc' } };\r\n}\r\nasync function getOwnServiceCredentials() {\r\n return {};\r\n}\r\n\r\nexport async function paginate() {\r\n let cursor: string | undefined = undefined;\r\n do {\r\n await query();\r\n await getOwnServiceCredentials();\r\n cursor = 'next';\r\n await getOwnServiceCredentials();\r\n } while (cursor);\r\n}\r\n","output":"async function query() {\r\n return { items: [], pageInfo: { nextCursor: 'abc' } };\r\n}\r\nasync function getOwnServiceCredentials() {\r\n return {};\r\n}\r\n\r\nexport async function paginate() {\r\n let cursor: string | undefined = undefined;\r\n do {\r\n await query();\r\n await getOwnServiceCredentials();\r\n cursor = 'next';\r\n await getOwnServiceCredentials();\r\n } while (cursor);\r\n}\r\n","filename":"input.ts"},{"name":"edge","path":"tests/sequential-chunk/edge","input":"function chunk(arr: T[], size: number): T[][] {\r\n const out: T[][] = [];\r\n for (let i = 0; i < arr.length; i += size) out.push(arr.slice(i, i + size));\r\n return out;\r\n}\r\n\r\nconst db = { insert: async (_rows: unknown) => {} };\r\n\r\nexport async function viaLodash(items: unknown[]) {\r\n for (const batch of chunk(items, 50)) {\r\n await db.insert(batch);\r\n }\r\n}\r\n","output":"function chunk(arr: T[], size: number): T[][] {\r\n const out: T[][] = [];\r\n for (let i = 0; i < arr.length; i += size) out.push(arr.slice(i, i + size));\r\n return out;\r\n}\r\n\r\nconst db = { insert: async (_rows: unknown) => {} };\r\n\r\nexport async function viaLodash(items: unknown[]) {\r\n for (const batch of chunk(items, 50)) {\r\n await db.insert(batch);\r\n }\r\n}\r\n","filename":"input.ts"}]},"defaultWorkflowName":"main","createdAt":"2026-09-01T03:50:09.067Z","updatedAt":"2026-09-05 15:08:28.717611+00"},"publishedBy":{"id":"4519f7a8-2ebc-4eaf-8c0a-e01be4c05878","username":"alexbit-codemod","name":"Alex Bit"},"insightsTemplate":{"packageVersionId":"6b125a58-2546-44f3-9003-b0ae5c268ee9","status":"ready","generatedAt":"2026-09-01T03:53:41.868Z"},"workflows":[{"name":"main","path":"workflow.yaml","description":null,"isDefault":true,"languages":["tsx"],"stepTypes":["js-ast-grep"],"workflowMetadata":{"nodes":[{"id":"async-waterfall-mining","name":"Async waterfall mining (read-only metrics)","steps":[{"name":"1. await-in-loop","type":"js-ast-grep","metrics":[{"name":"async_waterfall_await_in_loop","cardinalityKeys":["loop_kind","nesting_depth","await_count","io_likelihood"]}],"language":"tsx"},{"name":"2. consecutive-await","type":"js-ast-grep","metrics":[{"name":"async_waterfall_consecutive_await","cardinalityKeys":["independence","first_callee","second_callee","first_io","second_io"]}],"language":"tsx","semanticAnalysis":"workspace"},{"name":"3. async-reduce","type":"js-ast-grep","metrics":[{"name":"async_waterfall_async_reduce","cardinalityKeys":[]}],"language":"tsx"},{"name":"4. sequential-chunk","type":"js-ast-grep","metrics":[{"name":"async_waterfall_sequential_chunk","cardinalityKeys":["loop_var","iterable_hint","io_likelihood"]}],"language":"tsx"},{"name":"5. repeated-await-call","type":"js-ast-grep","metrics":[{"name":"async_waterfall_repeated_await_call","cardinalityKeys":["callee","occurrence_count","inside_loop"]}],"language":"tsx","semanticAnalysis":"workspace"}]}],"metricMetadataVersion":1}}],"packageBehavior":"workflow-only","isBundle":false,"bundleChildren":[],"parentBundles":[]},{"version":{"id":"fc8737ea-77fb-4e2b-917f-d8d6bb19b0f8","packageId":"12d9f94e-5297-4d92-a9c4-4f5830075c08","version":"0.1.4","description":"Mine TypeScript async serialization / parallelization opportunities via read-only JSSG metrics (await-in-loop, consecutive awaits, async reduce, sequential chunks, repeated await calls). Combines syntax detection with light data-flow filtering.","manifest":{"name":"async-waterfall-mining","author":"Alex Bit ","license":"MIT","targets":{"versions":{},"languages":["typescript","tsx"],"frameworks":[]},"version":"0.1.4","keywords":["mining","metrics","typescript","async","performance","parallelization","waterfall"],"registry":{"access":"pro","visibility":"public"},"workflows":[{"name":"main","path":"workflow.yaml","default":true}],"description":"Mine TypeScript async serialization / parallelization opportunities via read-only JSSG metrics (await-in-loop, consecutive awaits, async reduce, sequential chunks, repeated await calls). Combines syntax detection with light data-flow filtering.","dependencies":[],"schema_version":"1.0"},"checksum":"857a9c51d825fb093f5b5baf8898b49f6d2977d29a8139083d8436b5a33f21c8","size":13538,"downloadUrl":"https://registry-cdn.codemod.com/prod/packages/private/async-waterfall-mining/0.1.4/private-857a_ohupx0zml4r.tar.gz","aiGenerated":false,"sourceArchiveS3Key":null,"targets":{"languages":["typescript"],"frameworks":[]},"dependencies":[],"languages":["tsx"],"stepTypes":["js-ast-grep"],"workflowMetadata":{"nodes":[{"id":"async-waterfall-mining","name":"Async waterfall mining (read-only metrics)","steps":[{"name":"1. await-in-loop","type":"js-ast-grep","metrics":[{"name":"async_waterfall_await_in_loop","cardinalityKeys":["loop_kind","nesting_depth","await_count","io_likelihood"]}],"language":"tsx"},{"name":"2. consecutive-await","type":"js-ast-grep","metrics":[{"name":"async_waterfall_consecutive_await","cardinalityKeys":["independence","first_callee","second_callee","first_io","second_io"]}],"language":"tsx","semanticAnalysis":"workspace"},{"name":"3. async-reduce","type":"js-ast-grep","metrics":[{"name":"async_waterfall_async_reduce","cardinalityKeys":[]}],"language":"tsx"},{"name":"4. sequential-chunk","type":"js-ast-grep","metrics":[{"name":"async_waterfall_sequential_chunk","cardinalityKeys":["loop_var","iterable_hint","io_likelihood"]}],"language":"tsx"},{"name":"5. repeated-await-call","type":"js-ast-grep","metrics":[{"name":"async_waterfall_repeated_await_call","cardinalityKeys":["callee","occurrence_count","inside_loop"]}],"language":"tsx","semanticAnalysis":"workspace"}]}],"metricMetadataVersion":1},"validated":false,"validationErrors":null,"publishedBy":"4519f7a8-2ebc-4eaf-8c0a-e01be4c05878","deprecated":false,"deprecationMessage":null,"downloadCount":0,"cachedTestCases":{"input":"async function getUser(id: string) {\r\n return { id };\r\n}\r\nasync function getOrders(userId: string) {\r\n return [];\r\n}\r\n\r\nexport async function load(id: string) {\r\n const user = await getUser(id);\r\n await getOrders(user.id);\r\n}\r\n","output":"async function getUser(id: string) {\r\n return { id };\r\n}\r\nasync function getOrders(userId: string) {\r\n return [];\r\n}\r\n\r\nexport async function load(id: string) {\r\n const user = await getUser(id);\r\n await getOrders(user.id);\r\n}\r\n","isValid":true,"examples":[{"name":"negative","path":"tests/consecutive-await/negative","input":"async function getUser(id: string) {\r\n return { id };\r\n}\r\nasync function getOrders(userId: string) {\r\n return [];\r\n}\r\n\r\nexport async function load(id: string) {\r\n const user = await getUser(id);\r\n await getOrders(user.id);\r\n}\r\n","output":"async function getUser(id: string) {\r\n return { id };\r\n}\r\nasync function getOrders(userId: string) {\r\n return [];\r\n}\r\n\r\nexport async function load(id: string) {\r\n const user = await getUser(id);\r\n await getOrders(user.id);\r\n}\r\n","filename":"input.ts"},{"name":"positive","path":"tests/consecutive-await/positive","input":"async function readUsers() {\r\n return [];\r\n}\r\nasync function readGroups() {\r\n return [];\r\n}\r\n\r\nexport async function syncOrg() {\r\n await readUsers();\r\n await readGroups();\r\n}\r\n","output":"async function readUsers() {\r\n return [];\r\n}\r\nasync function readGroups() {\r\n return [];\r\n}\r\n\r\nexport async function syncOrg() {\r\n await readUsers();\r\n await readGroups();\r\n}\r\n","filename":"input.ts"},{"name":"positive","path":"tests/repeated-await-call/positive","input":"async function query() {\r\n return { items: [], pageInfo: { nextCursor: 'abc' } };\r\n}\r\nasync function getOwnServiceCredentials() {\r\n return {};\r\n}\r\n\r\nexport async function paginate() {\r\n let cursor: string | undefined = undefined;\r\n do {\r\n await query();\r\n await getOwnServiceCredentials();\r\n cursor = 'next';\r\n await getOwnServiceCredentials();\r\n } while (cursor);\r\n}\r\n","output":"async function query() {\r\n return { items: [], pageInfo: { nextCursor: 'abc' } };\r\n}\r\nasync function getOwnServiceCredentials() {\r\n return {};\r\n}\r\n\r\nexport async function paginate() {\r\n let cursor: string | undefined = undefined;\r\n do {\r\n await query();\r\n await getOwnServiceCredentials();\r\n cursor = 'next';\r\n await getOwnServiceCredentials();\r\n } while (cursor);\r\n}\r\n","filename":"input.ts"},{"name":"edge","path":"tests/sequential-chunk/edge","input":"function chunk(arr: T[], size: number): T[][] {\r\n const out: T[][] = [];\r\n for (let i = 0; i < arr.length; i += size) out.push(arr.slice(i, i + size));\r\n return out;\r\n}\r\n\r\nconst db = { insert: async (_rows: unknown) => {} };\r\n\r\nexport async function viaLodash(items: unknown[]) {\r\n for (const batch of chunk(items, 50)) {\r\n await db.insert(batch);\r\n }\r\n}\r\n","output":"function chunk(arr: T[], size: number): T[][] {\r\n const out: T[][] = [];\r\n for (let i = 0; i < arr.length; i += size) out.push(arr.slice(i, i + size));\r\n return out;\r\n}\r\n\r\nconst db = { insert: async (_rows: unknown) => {} };\r\n\r\nexport async function viaLodash(items: unknown[]) {\r\n for (const batch of chunk(items, 50)) {\r\n await db.insert(batch);\r\n }\r\n}\r\n","filename":"input.ts"}]},"defaultWorkflowName":"main","createdAt":"2026-09-01T03:16:52.681Z","updatedAt":"2026-09-01 03:16:53.305024+00"},"publishedBy":{"id":"4519f7a8-2ebc-4eaf-8c0a-e01be4c05878","username":"alexbit-codemod","name":"Alex Bit"},"insightsTemplate":{"packageVersionId":"fc8737ea-77fb-4e2b-917f-d8d6bb19b0f8","status":"ready","generatedAt":"2026-09-01T03:31:15.055Z"},"workflows":[{"name":"main","path":"workflow.yaml","description":null,"isDefault":true,"languages":["tsx"],"stepTypes":["js-ast-grep"],"workflowMetadata":{"nodes":[{"id":"async-waterfall-mining","name":"Async waterfall mining (read-only metrics)","steps":[{"name":"1. await-in-loop","type":"js-ast-grep","metrics":[{"name":"async_waterfall_await_in_loop","cardinalityKeys":["loop_kind","nesting_depth","await_count","io_likelihood"]}],"language":"tsx"},{"name":"2. consecutive-await","type":"js-ast-grep","metrics":[{"name":"async_waterfall_consecutive_await","cardinalityKeys":["independence","first_callee","second_callee","first_io","second_io"]}],"language":"tsx","semanticAnalysis":"workspace"},{"name":"3. async-reduce","type":"js-ast-grep","metrics":[{"name":"async_waterfall_async_reduce","cardinalityKeys":[]}],"language":"tsx"},{"name":"4. sequential-chunk","type":"js-ast-grep","metrics":[{"name":"async_waterfall_sequential_chunk","cardinalityKeys":["loop_var","iterable_hint","io_likelihood"]}],"language":"tsx"},{"name":"5. repeated-await-call","type":"js-ast-grep","metrics":[{"name":"async_waterfall_repeated_await_call","cardinalityKeys":["callee","occurrence_count","inside_loop"]}],"language":"tsx","semanticAnalysis":"workspace"}]}],"metricMetadataVersion":1}}],"packageBehavior":"workflow-only","isBundle":false,"bundleChildren":[],"parentBundles":[]},{"version":{"id":"df61274e-4a0f-480a-aca3-b8938eb8870d","packageId":"12d9f94e-5297-4d92-a9c4-4f5830075c08","version":"0.1.3","description":"Mine TypeScript async serialization / parallelization opportunities via read-only JSSG metrics (await-in-loop, consecutive awaits, async reduce, sequential chunks, repeated await calls). Combines syntax detection with light data-flow filtering.","manifest":{"name":"async-waterfall-mining","author":"Alex Bit ","license":"MIT","targets":{"versions":{},"languages":["typescript","tsx"],"frameworks":[]},"version":"0.1.3","keywords":["mining","metrics","typescript","async","performance","parallelization","waterfall"],"registry":{"access":"pro","visibility":"public"},"workflows":[{"name":"main","path":"workflow.yaml","default":true}],"description":"Mine TypeScript async serialization / parallelization opportunities via read-only JSSG metrics (await-in-loop, consecutive awaits, async reduce, sequential chunks, repeated await calls). Combines syntax detection with light data-flow filtering.","dependencies":[],"schema_version":"1.0"},"checksum":"e8e886db2e60d86a6f764541b4692a06ef194349ff2d39feb4007d290ff95f45","size":13571,"downloadUrl":"https://registry-cdn.codemod.com/prod/packages/private/async-waterfall-mining/0.1.3/private-e8e8_9n3vr0lo0jq.tar.gz","aiGenerated":false,"sourceArchiveS3Key":null,"targets":{"languages":["typescript"],"frameworks":[]},"dependencies":[],"languages":["tsx"],"stepTypes":["js-ast-grep"],"workflowMetadata":{"nodes":[{"id":"async-waterfall-mining","name":"Async waterfall mining (read-only metrics)","steps":[{"name":"1. await-in-loop","type":"js-ast-grep","metrics":[],"language":"tsx"},{"name":"2. consecutive-await","type":"js-ast-grep","metrics":[],"language":"tsx","semanticAnalysis":"workspace"},{"name":"3. async-reduce","type":"js-ast-grep","metrics":[],"language":"tsx"},{"name":"4. sequential-chunk","type":"js-ast-grep","metrics":[],"language":"tsx"},{"name":"5. repeated-await-call","type":"js-ast-grep","metrics":[],"language":"tsx","semanticAnalysis":"workspace"}]}],"metricMetadataVersion":1},"validated":false,"validationErrors":null,"publishedBy":"4519f7a8-2ebc-4eaf-8c0a-e01be4c05878","deprecated":false,"deprecationMessage":null,"downloadCount":0,"cachedTestCases":{"input":"async function getUser(id: string) {\r\n return { id };\r\n}\r\nasync function getOrders(userId: string) {\r\n return [];\r\n}\r\n\r\nexport async function load(id: string) {\r\n const user = await getUser(id);\r\n await getOrders(user.id);\r\n}\r\n","output":"async function getUser(id: string) {\r\n return { id };\r\n}\r\nasync function getOrders(userId: string) {\r\n return [];\r\n}\r\n\r\nexport async function load(id: string) {\r\n const user = await getUser(id);\r\n await getOrders(user.id);\r\n}\r\n","isValid":true,"examples":[{"name":"negative","path":"tests/consecutive-await/negative","input":"async function getUser(id: string) {\r\n return { id };\r\n}\r\nasync function getOrders(userId: string) {\r\n return [];\r\n}\r\n\r\nexport async function load(id: string) {\r\n const user = await getUser(id);\r\n await getOrders(user.id);\r\n}\r\n","output":"async function getUser(id: string) {\r\n return { id };\r\n}\r\nasync function getOrders(userId: string) {\r\n return [];\r\n}\r\n\r\nexport async function load(id: string) {\r\n const user = await getUser(id);\r\n await getOrders(user.id);\r\n}\r\n","filename":"input.ts"},{"name":"positive","path":"tests/consecutive-await/positive","input":"async function readUsers() {\r\n return [];\r\n}\r\nasync function readGroups() {\r\n return [];\r\n}\r\n\r\nexport async function syncOrg() {\r\n await readUsers();\r\n await readGroups();\r\n}\r\n","output":"async function readUsers() {\r\n return [];\r\n}\r\nasync function readGroups() {\r\n return [];\r\n}\r\n\r\nexport async function syncOrg() {\r\n await readUsers();\r\n await readGroups();\r\n}\r\n","filename":"input.ts"},{"name":"positive","path":"tests/repeated-await-call/positive","input":"async function query() {\r\n return { items: [], pageInfo: { nextCursor: 'abc' } };\r\n}\r\nasync function getOwnServiceCredentials() {\r\n return {};\r\n}\r\n\r\nexport async function paginate() {\r\n let cursor: string | undefined = undefined;\r\n do {\r\n await query();\r\n await getOwnServiceCredentials();\r\n cursor = 'next';\r\n await getOwnServiceCredentials();\r\n } while (cursor);\r\n}\r\n","output":"async function query() {\r\n return { items: [], pageInfo: { nextCursor: 'abc' } };\r\n}\r\nasync function getOwnServiceCredentials() {\r\n return {};\r\n}\r\n\r\nexport async function paginate() {\r\n let cursor: string | undefined = undefined;\r\n do {\r\n await query();\r\n await getOwnServiceCredentials();\r\n cursor = 'next';\r\n await getOwnServiceCredentials();\r\n } while (cursor);\r\n}\r\n","filename":"input.ts"},{"name":"edge","path":"tests/sequential-chunk/edge","input":"function chunk(arr: T[], size: number): T[][] {\r\n const out: T[][] = [];\r\n for (let i = 0; i < arr.length; i += size) out.push(arr.slice(i, i + size));\r\n return out;\r\n}\r\n\r\nconst db = { insert: async (_rows: unknown) => {} };\r\n\r\nexport async function viaLodash(items: unknown[]) {\r\n for (const batch of chunk(items, 50)) {\r\n await db.insert(batch);\r\n }\r\n}\r\n","output":"function chunk(arr: T[], size: number): T[][] {\r\n const out: T[][] = [];\r\n for (let i = 0; i < arr.length; i += size) out.push(arr.slice(i, i + size));\r\n return out;\r\n}\r\n\r\nconst db = { insert: async (_rows: unknown) => {} };\r\n\r\nexport async function viaLodash(items: unknown[]) {\r\n for (const batch of chunk(items, 50)) {\r\n await db.insert(batch);\r\n }\r\n}\r\n","filename":"input.ts"}]},"defaultWorkflowName":"main","createdAt":"2026-09-01T03:12:11.708Z","updatedAt":"2026-09-01 03:12:12.450147+00"},"publishedBy":{"id":"4519f7a8-2ebc-4eaf-8c0a-e01be4c05878","username":"alexbit-codemod","name":"Alex Bit"},"insightsTemplate":{"packageVersionId":"df61274e-4a0f-480a-aca3-b8938eb8870d","status":"ready","generatedAt":"2026-09-01T03:12:29.478Z"},"workflows":[{"name":"main","path":"workflow.yaml","description":null,"isDefault":true,"languages":["tsx"],"stepTypes":["js-ast-grep"],"workflowMetadata":{"nodes":[{"id":"async-waterfall-mining","name":"Async waterfall mining (read-only metrics)","steps":[{"name":"1. await-in-loop","type":"js-ast-grep","metrics":[],"language":"tsx"},{"name":"2. consecutive-await","type":"js-ast-grep","metrics":[],"language":"tsx","semanticAnalysis":"workspace"},{"name":"3. async-reduce","type":"js-ast-grep","metrics":[],"language":"tsx"},{"name":"4. sequential-chunk","type":"js-ast-grep","metrics":[],"language":"tsx"},{"name":"5. repeated-await-call","type":"js-ast-grep","metrics":[],"language":"tsx","semanticAnalysis":"workspace"}]}],"metricMetadataVersion":1}}],"packageBehavior":"workflow-only","isBundle":false,"bundleChildren":[],"parentBundles":[]},{"version":{"id":"b0465b0a-27fe-4f49-af22-cd600944b4d7","packageId":"12d9f94e-5297-4d92-a9c4-4f5830075c08","version":"0.1.2","description":"Mine TypeScript async serialization / parallelization opportunities via read-only JSSG metrics (await-in-loop, consecutive awaits, async reduce, sequential chunks, repeated await calls). Combines syntax detection with light data-flow filtering.","manifest":{"name":"async-waterfall-mining","author":"Alex Bit ","license":"MIT","targets":{"versions":{},"languages":["typescript","tsx"],"frameworks":[]},"version":"0.1.2","keywords":["mining","metrics","typescript","async","performance","parallelization","waterfall"],"registry":{"access":"pro","visibility":"public"},"workflows":[{"name":"main","path":"workflow.yaml","default":true}],"description":"Mine TypeScript async serialization / parallelization opportunities via read-only JSSG metrics (await-in-loop, consecutive awaits, async reduce, sequential chunks, repeated await calls). Combines syntax detection with light data-flow filtering.","dependencies":[],"schema_version":"1.0"},"checksum":"f8c600524342865df38adce5617710bb4573b25b6cd8e54f9480b2e42a28d238","size":13535,"downloadUrl":"https://registry-cdn.codemod.com/prod/packages/private/async-waterfall-mining/0.1.2/private-f8c6_7fxvdyblv3f.tar.gz","aiGenerated":false,"sourceArchiveS3Key":null,"targets":{"languages":["typescript"],"frameworks":[]},"dependencies":[],"languages":["tsx"],"stepTypes":["js-ast-grep"],"workflowMetadata":{"nodes":[{"id":"async-waterfall-mining","name":"Async waterfall mining (read-only metrics)","steps":[{"name":"1. await-in-loop","type":"js-ast-grep","metrics":[],"language":"tsx"},{"name":"2. consecutive-await","type":"js-ast-grep","metrics":[],"language":"tsx","semanticAnalysis":"workspace"},{"name":"3. async-reduce","type":"js-ast-grep","metrics":[],"language":"tsx"},{"name":"4. sequential-chunk","type":"js-ast-grep","metrics":[],"language":"tsx"},{"name":"5. repeated-await-call","type":"js-ast-grep","metrics":[],"language":"tsx","semanticAnalysis":"workspace"}]}],"metricMetadataVersion":1},"validated":false,"validationErrors":null,"publishedBy":"4519f7a8-2ebc-4eaf-8c0a-e01be4c05878","deprecated":false,"deprecationMessage":null,"downloadCount":2,"cachedTestCases":{"input":"async function getUser(id: string) {\r\n return { id };\r\n}\r\nasync function getOrders(userId: string) {\r\n return [];\r\n}\r\n\r\nexport async function load(id: string) {\r\n const user = await getUser(id);\r\n await getOrders(user.id);\r\n}\r\n","output":"async function getUser(id: string) {\r\n return { id };\r\n}\r\nasync function getOrders(userId: string) {\r\n return [];\r\n}\r\n\r\nexport async function load(id: string) {\r\n const user = await getUser(id);\r\n await getOrders(user.id);\r\n}\r\n","isValid":true,"examples":[{"name":"negative","path":"tests/consecutive-await/negative","input":"async function getUser(id: string) {\r\n return { id };\r\n}\r\nasync function getOrders(userId: string) {\r\n return [];\r\n}\r\n\r\nexport async function load(id: string) {\r\n const user = await getUser(id);\r\n await getOrders(user.id);\r\n}\r\n","output":"async function getUser(id: string) {\r\n return { id };\r\n}\r\nasync function getOrders(userId: string) {\r\n return [];\r\n}\r\n\r\nexport async function load(id: string) {\r\n const user = await getUser(id);\r\n await getOrders(user.id);\r\n}\r\n","filename":"input.ts"},{"name":"positive","path":"tests/consecutive-await/positive","input":"async function readUsers() {\r\n return [];\r\n}\r\nasync function readGroups() {\r\n return [];\r\n}\r\n\r\nexport async function syncOrg() {\r\n await readUsers();\r\n await readGroups();\r\n}\r\n","output":"async function readUsers() {\r\n return [];\r\n}\r\nasync function readGroups() {\r\n return [];\r\n}\r\n\r\nexport async function syncOrg() {\r\n await readUsers();\r\n await readGroups();\r\n}\r\n","filename":"input.ts"},{"name":"positive","path":"tests/repeated-await-call/positive","input":"async function query() {\r\n return { items: [], pageInfo: { nextCursor: 'abc' } };\r\n}\r\nasync function getOwnServiceCredentials() {\r\n return {};\r\n}\r\n\r\nexport async function paginate() {\r\n let cursor: string | undefined = undefined;\r\n do {\r\n await query();\r\n await getOwnServiceCredentials();\r\n cursor = 'next';\r\n await getOwnServiceCredentials();\r\n } while (cursor);\r\n}\r\n","output":"async function query() {\r\n return { items: [], pageInfo: { nextCursor: 'abc' } };\r\n}\r\nasync function getOwnServiceCredentials() {\r\n return {};\r\n}\r\n\r\nexport async function paginate() {\r\n let cursor: string | undefined = undefined;\r\n do {\r\n await query();\r\n await getOwnServiceCredentials();\r\n cursor = 'next';\r\n await getOwnServiceCredentials();\r\n } while (cursor);\r\n}\r\n","filename":"input.ts"},{"name":"edge","path":"tests/sequential-chunk/edge","input":"function chunk(arr: T[], size: number): T[][] {\r\n const out: T[][] = [];\r\n for (let i = 0; i < arr.length; i += size) out.push(arr.slice(i, i + size));\r\n return out;\r\n}\r\n\r\nconst db = { insert: async (_rows: unknown) => {} };\r\n\r\nexport async function viaLodash(items: unknown[]) {\r\n for (const batch of chunk(items, 50)) {\r\n await db.insert(batch);\r\n }\r\n}\r\n","output":"function chunk(arr: T[], size: number): T[][] {\r\n const out: T[][] = [];\r\n for (let i = 0; i < arr.length; i += size) out.push(arr.slice(i, i + size));\r\n return out;\r\n}\r\n\r\nconst db = { insert: async (_rows: unknown) => {} };\r\n\r\nexport async function viaLodash(items: unknown[]) {\r\n for (const batch of chunk(items, 50)) {\r\n await db.insert(batch);\r\n }\r\n}\r\n","filename":"input.ts"}]},"defaultWorkflowName":"main","createdAt":"2026-09-01T03:00:32.900Z","updatedAt":"2026-09-01 03:02:24.666237+00"},"publishedBy":{"id":"4519f7a8-2ebc-4eaf-8c0a-e01be4c05878","username":"alexbit-codemod","name":"Alex Bit"},"insightsTemplate":{"packageVersionId":"b0465b0a-27fe-4f49-af22-cd600944b4d7","status":"ready","generatedAt":"2026-09-01T03:00:51.493Z"},"workflows":[{"name":"main","path":"workflow.yaml","description":null,"isDefault":true,"languages":["tsx"],"stepTypes":["js-ast-grep"],"workflowMetadata":{"nodes":[{"id":"async-waterfall-mining","name":"Async waterfall mining (read-only metrics)","steps":[{"name":"1. await-in-loop","type":"js-ast-grep","metrics":[],"language":"tsx"},{"name":"2. consecutive-await","type":"js-ast-grep","metrics":[],"language":"tsx","semanticAnalysis":"workspace"},{"name":"3. async-reduce","type":"js-ast-grep","metrics":[],"language":"tsx"},{"name":"4. sequential-chunk","type":"js-ast-grep","metrics":[],"language":"tsx"},{"name":"5. repeated-await-call","type":"js-ast-grep","metrics":[],"language":"tsx","semanticAnalysis":"workspace"}]}],"metricMetadataVersion":1}}],"packageBehavior":"workflow-only","isBundle":false,"bundleChildren":[],"parentBundles":[]},{"version":{"id":"9289e1b2-7a44-4dad-beaa-31d4e56ae28e","packageId":"12d9f94e-5297-4d92-a9c4-4f5830075c08","version":"0.1.1","description":"Mine TypeScript async serialization / parallelization opportunities via read-only JSSG metrics (await-in-loop, consecutive awaits, async reduce, sequential chunks, repeated await calls). Combines syntax detection with light data-flow filtering.","manifest":{"name":"async-waterfall-mining","author":"Alex Bit ","license":"MIT","targets":{"versions":{},"languages":["typescript","tsx"],"frameworks":[]},"version":"0.1.1","keywords":["mining","metrics","typescript","async","performance","parallelization","waterfall"],"registry":{"access":"pro","visibility":"public"},"workflows":[{"name":"main","path":"workflow.yaml","default":true}],"description":"Mine TypeScript async serialization / parallelization opportunities via read-only JSSG metrics (await-in-loop, consecutive awaits, async reduce, sequential chunks, repeated await calls). Combines syntax detection with light data-flow filtering.","dependencies":[],"schema_version":"1.0"},"checksum":"4b9a0a79335075ee74f7843ef309ca4d734120884cd886d5586d52c53bffa1ce","size":13311,"downloadUrl":"https://registry-cdn.codemod.com/prod/packages/private/async-waterfall-mining/0.1.1/private-4b9a_ifxojmt6wd.tar.gz","aiGenerated":false,"sourceArchiveS3Key":null,"targets":{"languages":["typescript"],"frameworks":[]},"dependencies":[],"languages":["tsx"],"stepTypes":["js-ast-grep"],"workflowMetadata":{"nodes":[{"id":"async-waterfall-mining","name":"Async waterfall mining (read-only metrics)","steps":[{"name":"1. await-in-loop","type":"js-ast-grep","metrics":[],"language":"tsx"},{"name":"2. consecutive-await","type":"js-ast-grep","metrics":[],"language":"tsx","semanticAnalysis":"workspace"},{"name":"3. async-reduce","type":"js-ast-grep","metrics":[],"language":"tsx"},{"name":"4. sequential-chunk","type":"js-ast-grep","metrics":[],"language":"tsx"},{"name":"5. repeated-await-call","type":"js-ast-grep","metrics":[],"language":"tsx","semanticAnalysis":"workspace"}]}],"metricMetadataVersion":1},"validated":false,"validationErrors":null,"publishedBy":"4519f7a8-2ebc-4eaf-8c0a-e01be4c05878","deprecated":false,"deprecationMessage":null,"downloadCount":2,"cachedTestCases":{"input":"async function getUser(id: string) {\r\n return { id };\r\n}\r\nasync function getOrders(userId: string) {\r\n return [];\r\n}\r\n\r\nexport async function load(id: string) {\r\n const user = await getUser(id);\r\n await getOrders(user.id);\r\n}\r\n","output":"async function getUser(id: string) {\r\n return { id };\r\n}\r\nasync function getOrders(userId: string) {\r\n return [];\r\n}\r\n\r\nexport async function load(id: string) {\r\n const user = await getUser(id);\r\n await getOrders(user.id);\r\n}\r\n","isValid":true,"examples":[{"name":"negative","path":"tests/consecutive-await/negative","input":"async function getUser(id: string) {\r\n return { id };\r\n}\r\nasync function getOrders(userId: string) {\r\n return [];\r\n}\r\n\r\nexport async function load(id: string) {\r\n const user = await getUser(id);\r\n await getOrders(user.id);\r\n}\r\n","output":"async function getUser(id: string) {\r\n return { id };\r\n}\r\nasync function getOrders(userId: string) {\r\n return [];\r\n}\r\n\r\nexport async function load(id: string) {\r\n const user = await getUser(id);\r\n await getOrders(user.id);\r\n}\r\n","filename":"input.ts"},{"name":"positive","path":"tests/consecutive-await/positive","input":"async function readUsers() {\r\n return [];\r\n}\r\nasync function readGroups() {\r\n return [];\r\n}\r\n\r\nexport async function syncOrg() {\r\n await readUsers();\r\n await readGroups();\r\n}\r\n","output":"async function readUsers() {\r\n return [];\r\n}\r\nasync function readGroups() {\r\n return [];\r\n}\r\n\r\nexport async function syncOrg() {\r\n await readUsers();\r\n await readGroups();\r\n}\r\n","filename":"input.ts"},{"name":"positive","path":"tests/repeated-await-call/positive","input":"async function query() {\r\n return { items: [], pageInfo: { nextCursor: 'abc' } };\r\n}\r\nasync function getOwnServiceCredentials() {\r\n return {};\r\n}\r\n\r\nexport async function paginate() {\r\n let cursor: string | undefined = undefined;\r\n do {\r\n await query();\r\n await getOwnServiceCredentials();\r\n cursor = 'next';\r\n await getOwnServiceCredentials();\r\n } while (cursor);\r\n}\r\n","output":"async function query() {\r\n return { items: [], pageInfo: { nextCursor: 'abc' } };\r\n}\r\nasync function getOwnServiceCredentials() {\r\n return {};\r\n}\r\n\r\nexport async function paginate() {\r\n let cursor: string | undefined = undefined;\r\n do {\r\n await query();\r\n await getOwnServiceCredentials();\r\n cursor = 'next';\r\n await getOwnServiceCredentials();\r\n } while (cursor);\r\n}\r\n","filename":"input.ts"},{"name":"edge","path":"tests/sequential-chunk/edge","input":"function chunk(arr: T[], size: number): T[][] {\r\n const out: T[][] = [];\r\n for (let i = 0; i < arr.length; i += size) out.push(arr.slice(i, i + size));\r\n return out;\r\n}\r\n\r\nconst db = { insert: async (_rows: unknown) => {} };\r\n\r\nexport async function viaLodash(items: unknown[]) {\r\n for (const batch of chunk(items, 50)) {\r\n await db.insert(batch);\r\n }\r\n}\r\n","output":"function chunk(arr: T[], size: number): T[][] {\r\n const out: T[][] = [];\r\n for (let i = 0; i < arr.length; i += size) out.push(arr.slice(i, i + size));\r\n return out;\r\n}\r\n\r\nconst db = { insert: async (_rows: unknown) => {} };\r\n\r\nexport async function viaLodash(items: unknown[]) {\r\n for (const batch of chunk(items, 50)) {\r\n await db.insert(batch);\r\n }\r\n}\r\n","filename":"input.ts"}]},"defaultWorkflowName":"main","createdAt":"2026-09-01T02:40:34.641Z","updatedAt":"2026-09-01 02:43:57.366187+00"},"publishedBy":{"id":"4519f7a8-2ebc-4eaf-8c0a-e01be4c05878","username":"alexbit-codemod","name":"Alex Bit"},"insightsTemplate":{"packageVersionId":"9289e1b2-7a44-4dad-beaa-31d4e56ae28e","status":"ready","generatedAt":"2026-09-01T02:40:55.266Z"},"workflows":[{"name":"main","path":"workflow.yaml","description":null,"isDefault":true,"languages":["tsx"],"stepTypes":["js-ast-grep"],"workflowMetadata":{"nodes":[{"id":"async-waterfall-mining","name":"Async waterfall mining (read-only metrics)","steps":[{"name":"1. await-in-loop","type":"js-ast-grep","metrics":[],"language":"tsx"},{"name":"2. consecutive-await","type":"js-ast-grep","metrics":[],"language":"tsx","semanticAnalysis":"workspace"},{"name":"3. async-reduce","type":"js-ast-grep","metrics":[],"language":"tsx"},{"name":"4. sequential-chunk","type":"js-ast-grep","metrics":[],"language":"tsx"},{"name":"5. repeated-await-call","type":"js-ast-grep","metrics":[],"language":"tsx","semanticAnalysis":"workspace"}]}],"metricMetadataVersion":1}}],"packageBehavior":"workflow-only","isBundle":false,"bundleChildren":[],"parentBundles":[]},{"version":{"id":"70ca6c31-acca-4e68-9d76-7b419c208a41","packageId":"12d9f94e-5297-4d92-a9c4-4f5830075c08","version":"0.1.0","description":"Mine TypeScript async serialization / parallelization opportunities via read-only JSSG metrics (await-in-loop, consecutive awaits, async reduce, sequential chunks, repeated await calls). Combines syntax detection with light data-flow filtering.","manifest":{"name":"async-waterfall-mining","author":"Alex Bit ","license":"MIT","targets":{"versions":{},"languages":["typescript","tsx"],"frameworks":[]},"version":"0.1.0","keywords":["mining","metrics","typescript","async","performance","parallelization","waterfall"],"registry":{"access":"public","visibility":"public"},"workflows":[{"name":"main","path":"workflow.yaml","default":true}],"description":"Mine TypeScript async serialization / parallelization opportunities via read-only JSSG metrics (await-in-loop, consecutive awaits, async reduce, sequential chunks, repeated await calls). Combines syntax detection with light data-flow filtering.","dependencies":[],"schema_version":"1.0"},"checksum":"d64fd1af739145ba9a8a173408dccf43828692ae3de0d893e7ad996faedd89e7","size":13308,"downloadUrl":"https://registry-cdn.codemod.com/prod/packages/async-waterfall-mining/0.1.0/public.tar.gz","aiGenerated":false,"sourceArchiveS3Key":null,"targets":{"languages":["typescript"],"frameworks":[]},"dependencies":[],"languages":["tsx"],"stepTypes":["js-ast-grep"],"workflowMetadata":{"nodes":[{"id":"async-waterfall-mining","name":"Async waterfall mining (read-only metrics)","steps":[{"name":"1. await-in-loop","type":"js-ast-grep","metrics":[],"language":"tsx"},{"name":"2. consecutive-await","type":"js-ast-grep","metrics":[],"language":"tsx","semanticAnalysis":"workspace"},{"name":"3. async-reduce","type":"js-ast-grep","metrics":[],"language":"tsx"},{"name":"4. sequential-chunk","type":"js-ast-grep","metrics":[],"language":"tsx"},{"name":"5. repeated-await-call","type":"js-ast-grep","metrics":[],"language":"tsx","semanticAnalysis":"workspace"}]}],"metricMetadataVersion":1},"validated":false,"validationErrors":null,"publishedBy":"4519f7a8-2ebc-4eaf-8c0a-e01be4c05878","deprecated":false,"deprecationMessage":null,"downloadCount":0,"cachedTestCases":{"input":"async function getUser(id: string) {\r\n return { id };\r\n}\r\nasync function getOrders(userId: string) {\r\n return [];\r\n}\r\n\r\nexport async function load(id: string) {\r\n const user = await getUser(id);\r\n await getOrders(user.id);\r\n}\r\n","output":"async function getUser(id: string) {\r\n return { id };\r\n}\r\nasync function getOrders(userId: string) {\r\n return [];\r\n}\r\n\r\nexport async function load(id: string) {\r\n const user = await getUser(id);\r\n await getOrders(user.id);\r\n}\r\n","isValid":true,"examples":[{"name":"negative","path":"tests/consecutive-await/negative","input":"async function getUser(id: string) {\r\n return { id };\r\n}\r\nasync function getOrders(userId: string) {\r\n return [];\r\n}\r\n\r\nexport async function load(id: string) {\r\n const user = await getUser(id);\r\n await getOrders(user.id);\r\n}\r\n","output":"async function getUser(id: string) {\r\n return { id };\r\n}\r\nasync function getOrders(userId: string) {\r\n return [];\r\n}\r\n\r\nexport async function load(id: string) {\r\n const user = await getUser(id);\r\n await getOrders(user.id);\r\n}\r\n","filename":"input.ts"},{"name":"positive","path":"tests/consecutive-await/positive","input":"async function readUsers() {\r\n return [];\r\n}\r\nasync function readGroups() {\r\n return [];\r\n}\r\n\r\nexport async function syncOrg() {\r\n await readUsers();\r\n await readGroups();\r\n}\r\n","output":"async function readUsers() {\r\n return [];\r\n}\r\nasync function readGroups() {\r\n return [];\r\n}\r\n\r\nexport async function syncOrg() {\r\n await readUsers();\r\n await readGroups();\r\n}\r\n","filename":"input.ts"},{"name":"positive","path":"tests/repeated-await-call/positive","input":"async function query() {\r\n return { items: [], pageInfo: { nextCursor: 'abc' } };\r\n}\r\nasync function getOwnServiceCredentials() {\r\n return {};\r\n}\r\n\r\nexport async function paginate() {\r\n let cursor: string | undefined = undefined;\r\n do {\r\n await query();\r\n await getOwnServiceCredentials();\r\n cursor = 'next';\r\n await getOwnServiceCredentials();\r\n } while (cursor);\r\n}\r\n","output":"async function query() {\r\n return { items: [], pageInfo: { nextCursor: 'abc' } };\r\n}\r\nasync function getOwnServiceCredentials() {\r\n return {};\r\n}\r\n\r\nexport async function paginate() {\r\n let cursor: string | undefined = undefined;\r\n do {\r\n await query();\r\n await getOwnServiceCredentials();\r\n cursor = 'next';\r\n await getOwnServiceCredentials();\r\n } while (cursor);\r\n}\r\n","filename":"input.ts"},{"name":"edge","path":"tests/sequential-chunk/edge","input":"function chunk(arr: T[], size: number): T[][] {\r\n const out: T[][] = [];\r\n for (let i = 0; i < arr.length; i += size) out.push(arr.slice(i, i + size));\r\n return out;\r\n}\r\n\r\nconst db = { insert: async (_rows: unknown) => {} };\r\n\r\nexport async function viaLodash(items: unknown[]) {\r\n for (const batch of chunk(items, 50)) {\r\n await db.insert(batch);\r\n }\r\n}\r\n","output":"function chunk(arr: T[], size: number): T[][] {\r\n const out: T[][] = [];\r\n for (let i = 0; i < arr.length; i += size) out.push(arr.slice(i, i + size));\r\n return out;\r\n}\r\n\r\nconst db = { insert: async (_rows: unknown) => {} };\r\n\r\nexport async function viaLodash(items: unknown[]) {\r\n for (const batch of chunk(items, 50)) {\r\n await db.insert(batch);\r\n }\r\n}\r\n","filename":"input.ts"}]},"defaultWorkflowName":"main","createdAt":"2026-09-01T02:38:40.428Z","updatedAt":"2026-09-01 02:38:41.220025+00"},"publishedBy":{"id":"4519f7a8-2ebc-4eaf-8c0a-e01be4c05878","username":"alexbit-codemod","name":"Alex Bit"},"insightsTemplate":{"packageVersionId":"70ca6c31-acca-4e68-9d76-7b419c208a41","status":"ready","generatedAt":"2026-09-01T02:38:59.178Z"},"workflows":[{"name":"main","path":"workflow.yaml","description":null,"isDefault":true,"languages":["tsx"],"stepTypes":["js-ast-grep"],"workflowMetadata":{"nodes":[{"id":"async-waterfall-mining","name":"Async waterfall mining (read-only metrics)","steps":[{"name":"1. await-in-loop","type":"js-ast-grep","metrics":[],"language":"tsx"},{"name":"2. consecutive-await","type":"js-ast-grep","metrics":[],"language":"tsx","semanticAnalysis":"workspace"},{"name":"3. async-reduce","type":"js-ast-grep","metrics":[],"language":"tsx"},{"name":"4. sequential-chunk","type":"js-ast-grep","metrics":[],"language":"tsx"},{"name":"5. repeated-await-call","type":"js-ast-grep","metrics":[],"language":"tsx","semanticAnalysis":"workspace"}]}],"metricMetadataVersion":1}}],"packageBehavior":"workflow-only","isBundle":false,"bundleChildren":[],"parentBundles":[]}],"distTags":{"latest":"0.1.5"},"latestPackageBehavior":"workflow-only","cachedTestCases":"$19:1:props:state:queries:0:state:data:json:versions:0:version:cachedTestCases"},"meta":{"values":{"versions.0.version.createdAt":["Date"],"versions.0.insightsTemplate.generatedAt":["Date"],"versions.1.version.createdAt":["Date"],"versions.1.insightsTemplate.generatedAt":["Date"],"versions.2.version.createdAt":["Date"],"versions.2.insightsTemplate.generatedAt":["Date"],"versions.3.version.createdAt":["Date"],"versions.3.insightsTemplate.generatedAt":["Date"],"versions.4.version.createdAt":["Date"],"versions.4.insightsTemplate.generatedAt":["Date"],"versions.5.version.createdAt":["Date"],"versions.5.insightsTemplate.generatedAt":["Date"]},"referentialEqualities":{"cachedTestCases":["versions.0.version.cachedTestCases"]}}},"dataUpdateCount":1,"dataUpdatedAt":1789593213402,"error":null,"errorUpdateCount":0,"errorUpdatedAt":0,"fetchFailureCount":0,"fetchFailureReason":null,"fetchMeta":null,"isInvalidated":false,"status":"success","fetchStatus":"idle"},"queryKey":[["registry","getPackage"],{"input":{"name":"async-waterfall-mining","scope":"$undefined"},"type":"query"}],"queryHash":"[[\"registry\",\"getPackage\"],{\"input\":{\"name\":\"async-waterfall-mining\"},\"type\":\"query\"}]"}]},"children":"$L4a"}]] 1c:null 20:[["$","title","0",{"children":"async-waterfall-mining - Codemod Registry"}],["$","meta","1",{"name":"description","content":"Mine TypeScript async serialization / parallelization opportunities via read-only JSSG metrics (await-in-loop, consecutive awaits, async reduce, sequential chunks, repeated await calls). Combines syntax detection with light data-flow filtering."}],["$","meta","2",{"name":"author","content":"Alex Bit"}],["$","meta","3",{"name":"keywords","content":"async-waterfall-mining, codemod, code transformation, automated refactoring, package, registry, mining, metrics, typescript, async, performance, parallelization, waterfall"}],["$","meta","4",{"name":"creator","content":"Alex Bit"}],["$","meta","5",{"name":"publisher","content":"Codemod"}],["$","meta","6",{"name":"robots","content":"index, follow"}],["$","meta","7",{"name":"googlebot","content":"index, follow, max-video-preview:-1, max-image-preview:large, max-snippet:-1"}],["$","meta","8",{"name":"application-name","content":"Codemod Registry"}],["$","meta","9",{"name":"apple-mobile-web-app-title","content":"Codemod"}],["$","meta","10",{"name":"apple-mobile-web-app-capable","content":"yes"}],["$","meta","11",{"name":"apple-mobile-web-app-status-bar-style","content":"default"}],["$","meta","12",{"name":"format-detection","content":"telephone=no"}],["$","meta","13",{"name":"mobile-web-app-capable","content":"yes"}],["$","meta","14",{"name":"msapplication-config","content":"/browserconfig.xml"}],["$","meta","15",{"name":"msapplication-TileColor","content":"#000000"}],["$","meta","16",{"name":"msapplication-tap-highlight","content":"no"}],["$","meta","17",{"name":"theme-color","content":"#000000"}],["$","meta","18",{"name":"viewport","content":"width=device-width, initial-scale=1, maximum-scale=1, user-scalable=no"}],["$","link","19",{"rel":"canonical","href":"https://app.codemod.com/registry/async-waterfall-mining"}],["$","meta","20",{"property":"og:title","content":"async-waterfall-mining - Codemod Registry"}],["$","meta","21",{"property":"og:description","content":"Mine TypeScript async serialization / parallelization opportunities via read-only JSSG metrics (await-in-loop, consecutive awaits, async reduce, sequential chunks, repeated await calls). Combines syntax detection with light data-flow filtering."}],["$","meta","22",{"property":"og:url","content":"https://app.codemod.com/registry/async-waterfall-mining"}],["$","meta","23",{"property":"og:site_name","content":"Codemod Registry"}],["$","meta","24",{"property":"og:locale","content":"en_US"}],["$","meta","25",{"property":"og:image","content":"https://app.codemod.com/api/og/registry/async-waterfall-mining"}],["$","meta","26",{"property":"og:image:width","content":"1200"}],["$","meta","27",{"property":"og:image:height","content":"630"}],["$","meta","28",{"property":"og:image:alt","content":"async-waterfall-mining package"}],["$","meta","29",{"property":"og:type","content":"website"}],["$","meta","30",{"name":"twitter:card","content":"summary_large_image"}],["$","meta","31",{"name":"twitter:site","content":"@codemod"}],["$","meta","32",{"name":"twitter:creator","content":"@codemod"}],["$","meta","33",{"name":"twitter:title","content":"async-waterfall-mining - Codemod Registry"}],["$","meta","34",{"name":"twitter:description","content":"Mine TypeScript async serialization / parallelization opportunities via read-only JSSG metrics (await-in-loop, consecutive awaits, async reduce, sequential chunks, repeated await calls). Combines syntax detection with light data-flow filtering."}],["$","meta","35",{"name":"twitter:image","content":"https://app.codemod.com/api/og/registry/async-waterfall-mining"}]]