Skip to content

feat(events producer): create initial dipper-producer crate. add initial events proto#648

Open
cmwhited wants to merge 2 commits into
mainfrom
chris.whited/feat-producer/initial-crate-with-proto
Open

feat(events producer): create initial dipper-producer crate. add initial events proto#648
cmwhited wants to merge 2 commits into
mainfrom
chris.whited/feat-producer/initial-crate-with-proto

Conversation

@cmwhited

Copy link
Copy Markdown

No description provided.

@cmwhited cmwhited requested a review from MoonBoi9001 June 24, 2026 19:24
@cmwhited cmwhited force-pushed the chris.whited/feat-producer/initial-crate-with-proto branch from cd0bd84 to f9c598b Compare June 24, 2026 19:51

@MoonBoi9001 MoonBoi9001 left a comment

Copy link
Copy Markdown
Member

Choose a reason for hiding this comment

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

Nice docs inline text documentation Chris, everything looks good to me. TYVM

// 3. subgraph.indexing.agreement.accepted - Emitted when an Indexer agrees to the indexing request for the Subgraph
// 4. subgraph.indexing.agreement.request.expired - Emitted when an indexer fails to accept within the time limit
// 5. subgraph.indexing.agreement.n_indexers_unavailable - Emitted when selection returns fewer candidates than requested
// 6. subgraph.indexing.agreement.terminated - Emitted if either the Subgraph developer, or Indexer cancel an indexing agreement on a Subgraph.

Copy link
Copy Markdown
Member

Choose a reason for hiding this comment

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

What if the dipper cancels the agreement on the sg? do we also expose that as an event here?

Copy link
Copy Markdown
Author

Choose a reason for hiding this comment

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

Yeah we probably should. Like subgraph.indexing.agreement.canceled? what data would it have? is it an onchain tx?

Copy link
Copy Markdown
Member

Choose a reason for hiding this comment

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

We can just use subgraph.indexing.agreement.terminated right? So instead of limiting this to only the Subgraph developer, or Indexer cancelling the agreement, then if the dipper cancels the agreement with an indexer (to pick another indexer instead) then we still expose that here.

Copy link
Copy Markdown
Author

Choose a reason for hiding this comment

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

Okay perfect. Don't have to change the protobuf then. Thanks 🙏

// Timestamp of when the Indexing Agreement was terminated
uint64 terminated_at = 2;

// 0x address of the entity (developer, indexer, etc) that terminated the agreement

Copy link
Copy Markdown
Member

Choose a reason for hiding this comment

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

I see, dipper can just throw his own address here

Base automatically changed from upgrade to main June 25, 2026 11:51
@MoonBoi9001 MoonBoi9001 added the agreement-events Kafka producer for agreement lifecycle events (Studio integration) label Jul 7, 2026
@cmwhited cmwhited force-pushed the chris.whited/feat-producer/initial-crate-with-proto branch from 98c254a to b45f5d8 Compare July 14, 2026 22:23
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

agreement-events Kafka producer for agreement lifecycle events (Studio integration)

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants