feat(sync): add Composio Todoist memory-sync pipeline

[YellowSnnowmann]

Summary

Adds TodoistSyncPipeline for the Composio todoist toolkit, document-shaped. Previously advertised but unsyncable (#106).

• Single action TODOIST_GET_ALL_TASKS (verified against catalogs_productivity.rs). Todoist's active-tasks endpoint returns a plain array and is unpaginated, so this is an honest single-fetch — no invented page-token params; extract_page handles both the data.tasks wrapper and a bare data array. Task text comes from content; stable upsert key todoist:<id>, taint = external_sync, content-free logging.
• Registered through the three mod files.

Branch name mentions Dropbox, but Dropbox is deferred: the curated catalog exposes no clean list_folder-style enumeration action, so shipping it would require guessing an action schema. Only Todoist is included here — no Dropbox stub was committed.

Pipeline body only (step 1 of 2); openhuman wiring closes the issue end to end.

API Or Behavior Changes

One new public SyncPipeline type exported from memory::sync. Additive.

Tests

• cargo fmt --check
• cargo clippy --all-targets -- -D warnings
• cargo build --all-targets
• cargo test (all-features green; new mock test asserts task ingestion from content, stable document_id, and idempotent re-sync via global dedup)

Documentation

Module/item docs, including a note that page_size is unused (Todoist active-tasks is unpaginated). No external docs needed.

Part of #95 · tracker #106

Summary by CodeRabbit

• New Features

  • Added Todoist synchronization for importing active tasks.
  • Supports task titles, descriptions, and alternate response formats.
  • Preserves updates, avoids duplicates, and supports configurable synchronization limits.
  • Exposes Todoist integration metadata.

• Bug Fixes

  • Updated tasks are re-imported even when timestamps remain unchanged.

• Tests

  • Added coverage for ingestion, deduplication, external-sync tagging, alternate responses, and content updates.

[coderabbitai]

No actionable comments were generated in the recent review. 🎉

ℹ️ Recent review info

⚙️ Run configuration

Configuration used: Organization UI

Review profile: CHILL

Plan: Pro

Run ID: 1c931ec7-33c1-44e9-a9c1-d3293918baf9

📥 Commits

Reviewing files that changed from the base of the PR and between d8b9f96 and 18b5b74.

📒 Files selected for processing (5)

• src/memory/sync/composio/mod.rs
• src/memory/sync/composio/providers/mod.rs
• src/memory/sync/composio/providers/todoist.rs
• src/memory/sync/mod.rs
• tests/composio_sync_mock.rs

🚧 Files skipped from review as they are similar to previous changes (4)

• src/memory/sync/mod.rs
• src/memory/sync/composio/mod.rs
• src/memory/sync/composio/providers/mod.rs
• tests/composio_sync_mock.rs

---

📝 Walkthrough

Walkthrough

Adds an incremental TodoistSyncPipeline for active Composio tasks. The pipeline supports two response shapes, deduplicates by task ID and payload fingerprint, converts tasks to SkillDocument records, exposes public exports, and adds mock integration tests.

Changes

Todoist synchronization

Layer / File(s)	Summary
Todoist pipeline implementation src/memory/sync/composio/providers/todoist.rs	Adds configuration, Composio metadata, task fetching, response extraction, canonical payload fingerprinting, deduplication, and SkillDocument conversion.
Public pipeline registration src/memory/sync/composio/providers/mod.rs, src/memory/sync/composio/mod.rs, src/memory/sync/mod.rs	Declares the Todoist provider and re-exports TodoistSyncPipeline through the sync module hierarchy.
Sync integration tests tests/composio_sync_mock.rs	Tests task ingestion, alternate response shapes, unchanged-task idempotency, external-sync tainting, and re-ingestion after content changes without timestamp changes.

Estimated code review effort: 3 (Moderate) | ~20 minutes

Sequence Diagram(s)

sequenceDiagram
participant SyncFramework
participant TodoistSyncPipeline
participant ComposioClient
SyncFramework->>TodoistSyncPipeline: tick()
TodoistSyncPipeline->>ComposioClient: Execute TODOIST_GET_ALL_TASKS
ComposioClient-->>TodoistSyncPipeline: Return active tasks
TodoistSyncPipeline->>TodoistSyncPipeline: Deduplicate by ID and payload fingerprint
TodoistSyncPipeline-->>SyncFramework: Return SkillDocument records

Loading

Possibly related issues

• tinyhumansai/openhuman#4972 — Adds and registers a Todoist Composio sync pipeline.
• Composio memory sync: add Todoist (todoist) sync pipeline #95 — Requests the TodoistSyncPipeline, exports, and regression tests.

Possibly related PRs

• tinyhumansai/tinycortex#107 — Adds a comparable Composio provider pipeline through the same export hierarchy.
• tinyhumansai/tinycortex#109 — Adds another incremental provider pipeline with document conversion and tests.
• tinyhumansai/tinycortex#136 — Adds and exports a provider pipeline with mock synchronization tests.

Poem

A rabbit checks each Todoist task,
Hashes changes without being asked.
Exports open the pipeline door,
Stable tasks return no more.
Revised notes hop safely ashore.

🚥 Pre-merge checks | ✅ 5

✅ Passed checks (5 passed)

Check name	Status	Explanation
Description Check	✅ Passed	Check skipped - CodeRabbit’s high-level summary is enabled.
Title check	✅ Passed	The title 'feat(sync): add Composio Todoist memory-sync pipeline' directly and clearly summarizes the main change: adding a new Todoist synchronization pipeline to the Composio sync module.
Docstring Coverage	✅ Passed	No functions found in the changed files to evaluate docstring coverage. Skipping docstring coverage check.
Linked Issues check	✅ Passed	Check skipped because no linked issues were found for this pull request.
Out of Scope Changes check	✅ Passed	Check skipped because no linked issues were found for this pull request.

---

_{Comment @coderabbitai help to get the list of available commands.}

[greptile-apps]

Greptile Summary

Adds TodoistSyncPipeline, a document-shaped Composio provider that imports active Todoist tasks into the memory store. It follows the existing IncrementalSource pattern, using a payload fingerprint (FNV-1a over a canonically serialized task) as the dedup key in place of the missing Todoist modification timestamp, so edited tasks re-ingest while truly unchanged tasks are skipped.

• Pipeline body (todoist.rs): extract_page handles both the bare-array and {tasks:[...]} wrapped response shapes; sort_cursor intentionally returns None to avoid the orchestrator's cursor-boundary short-circuit halting re-ingestion of edited tasks; with_limits accepts _page_size as an inert argument for API-surface parity.
• payload_fingerprint/write_canonical: Stable FNV-1a hash over recursively key-sorted JSON — not DefaultHasher — so persisted dedup keys survive toolchain bumps.
• Tests: Three mock-server tests cover normal ingestion + idempotency, bare-array response shape, and the fingerprint-driven edit re-ingest path that was the subject of the previous review thread.

Confidence Score: 5/5

Safe to merge — additive pipeline with no impact on existing providers, well-tested, and both issues flagged in the previous review thread are correctly resolved in this revision.

The implementation is a self-contained new pipeline that registers through three mod files. The payload fingerprint is stable (FNV-1a over canonical JSON, not DefaultHasher), the dedup/cursor logic is consistent with how the orchestrator works, the response-shape ambiguity is correctly handled, and all three new mock tests exercise the scenarios that matter (happy path, bare-array variant, and the fingerprint-change re-ingest). No regressions to existing pipelines.

Files Needing Attention: No files require special attention.

Important Files Changed

Filename	Overview
src/memory/sync/composio/providers/todoist.rs	New TodoistSyncPipeline implementing IncrementalSource; payload-fingerprint dedup is sound, sort_cursor deliberately returns None, extract_page correctly handles both bare-array and object-wrapped responses after the client strips the outer data envelope.
tests/composio_sync_mock.rs	Three new integration tests cover task ingestion, bare-array response handling, idempotency (second tick is a no-op), and edit re-ingestion via fingerprint change — all exercising the key behaviors of the pipeline.
src/memory/sync/composio/mod.rs	Re-exports TodoistSyncPipeline; additive, no side effects.
src/memory/sync/composio/providers/mod.rs	Registers the todoist sub-module and re-exports TodoistSyncPipeline alongside other providers; change is mechanical and consistent with existing entries.
src/memory/sync/mod.rs	Adds TodoistSyncPipeline to the crate-level public re-export list; one-line additive change.

Sequence Diagram

sequenceDiagram
participant Caller
participant TodoistSyncPipeline
participant Orchestrator as run_incremental_sync
participant Composio as Composio API
participant State as SyncState (persisted)
Caller->>TodoistSyncPipeline: tick(config, context)
TodoistSyncPipeline->>Orchestrator: run_incremental_sync(self, client, ...)
Orchestrator->>State: load synced_ids + cursor
Orchestrator->>Composio: TODOIST_GET_ALL_TASKS (no args)
Composio-->>Orchestrator: "{ successful:true, data: {tasks:[...]} }"
Orchestrator->>TodoistSyncPipeline: extract_page(data)
TodoistSyncPipeline-->>Orchestrator: "PageFetch { items:[...], next:None }"
loop each task
Orchestrator->>TodoistSyncPipeline: "dedup_key(item) → id@FNV(canonical)"
alt key already in synced_ids
Orchestrator-->>Orchestrator: skip
else new or edited task
Orchestrator->>TodoistSyncPipeline: document(item) → SkillDocument
Orchestrator->>State: mark_synced(key)
Orchestrator->>Caller: store document
end
end
Note over Orchestrator: sort_cursor=None → no cursor boundary check
Note over Orchestrator: stop_on_empty_pending=true → stop if all skipped
Orchestrator->>State: save synced_ids (no cursor advance)

Loading

_{Reviews (4): Last reviewed commit: "Merge main into feat/composio-todoist-dr..." | Re-trigger Greptile}

[coderabbitai]

Actionable comments posted: 3

🧹 Nitpick comments (1)

src/memory/sync/composio/providers/todoist.rs (1)

35-49: 📐 Maintainability & Code Quality | 🔵 Trivial | ⚡ Quick win

Document the public constructors.

Add Rustdoc for TodoistSyncPipeline::new and TodoistSyncPipeline::with_limits. Document that Todoist is unpaginated and that _page_size has no effect.

As per coding guidelines, “Document public APIs, module contracts, and non-obvious behavior thoroughly.”

🤖 Prompt for AI Agents

Verify each finding against current code. Fix only still-valid issues, skip the
rest with a brief reason, keep changes minimal, and validate.
In `@src/memory/sync/composio/providers/todoist.rs` around lines 35 - 49, Add
Rustdoc comments to the public constructors TodoistSyncPipeline::new and
TodoistSyncPipeline::with_limits. Describe their initialization/configuration
behavior, explicitly note that Todoist active tasks are unpaginated, and
document that the _page_size parameter is accepted for signature parity but has
no effect.

Source: Coding guidelines

🤖 Prompt for all review comments with AI agents

Verify each finding against current code. Fix only still-valid issues, skip the
rest with a brief reason, keep changes minimal, and validate.
Inline comments:
In `@src/memory/sync/composio/providers/todoist.rs`:
- Around line 150-157: Update the document construction in the Todoist item
conversion flow to populate SkillDocument.content with the task’s text content
rather than the pretty-serialized item.raw JSON. Keep the existing document
metadata and raw payload unchanged, and remove the now-unneeded serialization
used solely for content.
- Around line 162-170: Replace DefaultHasher in payload_fingerprint with a
specified stable digest computed from canonical JSON bytes. Recursively
canonicalize serde_json::Value objects by sorting their keys before
serialization, then hash the resulting bytes with the chosen stable digest so
persisted dedup_key values remain consistent across toolchain and
feature-resolution changes.
In `@tests/composio_sync_mock.rs`:
- Around line 405-415: Extend the sync test around the captured documents to
assert that the first document’s content is exactly “Write report”, not
JSON-formatted task data. Add a separate mock response case where Composio’s
data value is the task array itself rather than an object under data.tasks, and
verify the pipeline handles that bare-array response contract.
---
Nitpick comments:
In `@src/memory/sync/composio/providers/todoist.rs`:
- Around line 35-49: Add Rustdoc comments to the public constructors
TodoistSyncPipeline::new and TodoistSyncPipeline::with_limits. Describe their
initialization/configuration behavior, explicitly note that Todoist active tasks
are unpaginated, and document that the _page_size parameter is accepted for
signature parity but has no effect.

🪄 Autofix

Fix all unresolved CodeRabbit comments on this PR:

• Push a commit to this branch (recommended)
• Create a new PR with the fixes

---

ℹ️ Review info

⚙️ Run configuration

Configuration used: Organization UI

Review profile: CHILL

Plan: Pro

Run ID: 8ef1fc1f-0e08-491b-9fd5-d5d305f09fc7

📥 Commits

Reviewing files that changed from the base of the PR and between 115e4bb and d8b9f96.

📒 Files selected for processing (5)

• src/memory/sync/composio/mod.rs
• src/memory/sync/composio/providers/mod.rs
• src/memory/sync/composio/providers/todoist.rs
• src/memory/sync/mod.rs
• tests/composio_sync_mock.rs