[WIP] Getting to a demoable "full" circuit

[juanmardefago]

No description provided.

[maoueh]

I think sadly you might have gone too fast here. I needed to do a full refactoring and many many changes, hopefully Codex will be able to go back on its feet.

I decided to create a sds sink run ..., this is a Data Service aware substreams run equivalent. I realized this could be a good "easy" way to bring some "default" sink (like the sql one for example plan to have under substreams sink sql at some point.

Anyway, my branch is now merged, happy to discuss further on Slack or over a call as needed.

[maoueh]

For example, locally you should be able:

# Terminal 1
reflex -c .reflex

# Terminal 2
./devel/sds_sink run common@v0.1.0 map_clocks -s -1

Feel free to refactor how sds sink run is hooked exactly, I haven't fully looked at the architecture on that front.

[juanmardefago]

I think sadly you might have gone too fast here. I needed to do a full refactoring and many many changes, hopefully Codex will be able to go back on its feet.

I decided to create a sds sink run ..., this is a Data Service aware substreams run equivalent. I realized this could be a good "easy" way to bring some "default" sink (like the sql one for example plan to have under substreams sink sql at some point.

Anyway, my branch is now merged, happy to discuss further on Slack or over a call as needed.

No worries! I was expecting some more changes in the plugins but didn't want to block you so I started planning/implementing the remaining steps to get to a workable demo (while taking as an assumption that the plugin would work eventually).

I'll probably see if I can simply reuse the current work, or worst case scenario just re-use the planning steps if possible and rebuild it from scratch.

I'll take a look at the refactored code tomorrow and continue from there! Thanks for the headsup!

[maoueh]

FYI, I'm not planning on changing anything else this week, at least nothing that should have global impact.

My next steps is to replace the GlobalRepository in memory implementation by a persistent version so data will be available across restart and then create some tools to redeem RAVs and check state on chain to ensure operation are working as expected.