Extract plan data insertion (#198)

#### Problem
The plan data insertion flow is embedded directly in `sync`, making that
function harder to scan.

#### Solution
Move the insert sequence into `insert_plan_data`. Keep the existing
insertion behavior and progress handling unchanged.

Author: mxr

sqlite_export_for_ynab/_main.py

@@ -207,51 +207,17 @@ async def sync(
             _print("No new data fetched", quiet=quiet)
         else:
             _print("Inserting plan data...", quiet=quiet)
-            await insert_plans(context, plans, new_lkos)
-            await asyncio.gather(
-                *(
-                    insert_accounts(context, plan_id, account_data["accounts"], quiet)
-                    for plan_id, account_data in zip(
-                        plan_ids, all_account_data, strict=True
-                    )
-                ),
-                *(
-                    insert_category_groups(
-                        context,
-                        plan_id,
-                        cat_data["category_groups"],
-                        quiet,
-                    )
-                    for plan_id, cat_data in zip(plan_ids, all_cat_data, strict=True)
-                ),
-                *(
-                    insert_payees(context, plan_id, payee_data["payees"], quiet)
-                    for plan_id, payee_data in zip(
-                        plan_ids, all_payee_data, strict=True
-                    )
-                ),
-            )
-            await asyncio.gather(
-                *(
-                    insert_transactions(
-                        context,
-                        plan_id,
-                        txn_data["transactions"],
-                        quiet,
-                    )
-                    for plan_id, txn_data in zip(plan_ids, all_txn_data, strict=True)
-                ),
-                *(
-                    insert_scheduled_transactions(
-                        context,
-                        plan_id,
-                        sched_txn_data["scheduled_transactions"],
-                        quiet,
-                    )
-                    for plan_id, sched_txn_data in zip(
-                        plan_ids, all_sched_txn_data, strict=True
-                    )
-                ),
+            await insert_plan_data(
+                context,
+                plans,
+                plan_ids,
+                all_account_data,
+                all_cat_data,
+                all_payee_data,
+                all_txn_data,
+                all_sched_txn_data,
+                new_lkos,
+                quiet,
             )
             await context.con.commit()
             _print("Done", quiet=quiet)
@@ -275,6 +241,67 @@ async def get_last_knowledge_of_server(cur: aiosqlite.Cursor) -> dict[str, int]:
     return {r["id"]: r["last_knowledge_of_server"] for r in await cur.fetchall()}
 
 
+async def insert_plan_data(
+    context: _Context,
+    plans: list[dict[str, Any]],
+    plan_ids: list[str],
+    all_account_data: list[dict[str, Any]],
+    all_cat_data: list[dict[str, Any]],
+    all_payee_data: list[dict[str, Any]],
+    all_txn_data: list[dict[str, Any]],
+    all_sched_txn_data: list[dict[str, Any]],
+    new_lkos: dict[str, int],
+    quiet: bool,
+) -> None:
+    await insert_plans(context, plans, new_lkos)
+    await asyncio.gather(
+        *(
+            insert_accounts(
+                context,
+                plan_id,
+                account_data["accounts"],
+                quiet,
+            )
+            for plan_id, account_data in zip(plan_ids, all_account_data, strict=True)
+        ),
+        *(
+            insert_category_groups(
+                context,
+                plan_id,
+                cat_data["category_groups"],
+                quiet,
+            )
+            for plan_id, cat_data in zip(plan_ids, all_cat_data, strict=True)
+        ),
+        *(
+            insert_payees(context, plan_id, payee_data["payees"], quiet)
+            for plan_id, payee_data in zip(plan_ids, all_payee_data, strict=True)
+        ),
+    )
+    await asyncio.gather(
+        *(
+            insert_transactions(
+                context,
+                plan_id,
+                txn_data["transactions"],
+                quiet,
+            )
+            for plan_id, txn_data in zip(plan_ids, all_txn_data, strict=True)
+        ),
+        *(
+            insert_scheduled_transactions(
+                context,
+                plan_id,
+                sched_txn_data["scheduled_transactions"],
+                quiet,
+            )
+            for plan_id, sched_txn_data in zip(
+                plan_ids, all_sched_txn_data, strict=True
+            )
+        ),
+    )
+
+
 async def insert_plans(
     context: _Context, plans: list[dict[str, Any]], lkos: dict[str, int]
 ) -> None: