Skip to content

Feature/manager upgrades #95

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
jeisses wants to merge 2 commits into
base: main
Choose a base branch
from
Open

Feature/manager upgrades #95

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
2365c3f
feat: state syncing & FSM improvements
Jeffrieh Feb 18, 2026
80b8fea
fix: build
Jeffrieh Mar 20, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 2 additions & 0 deletions Anchor.toml
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
[toolchain]
package_manager = "pnpm"
anchor_version = "0.31.1"

[features]
resolution = true
Expand All @@ -17,3 +18,4 @@ members = ["modules/payment/program", "modules/migration/program", "modules/stak

[scripts]
test = "pnpm vitest"

42 changes: 42 additions & 0 deletions core/protobufs/src/effect.proto
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -43,6 +43,46 @@ message RequestToWorkResponse {
string peer = 3;
}

message WorkerSyncRequest {
uint32 timestamp = 1;
string worker_id = 2;
optional uint64 cursor = 3;
repeated string scopes = 4;
optional uint32 limit = 5;
}

message WorkerSyncStatus {
string state = 1;
uint32 last_activity = 2;
}

message WorkerSyncTask {
string task_id = 1;
string status = 2;
uint32 last_event_at = 3;
Task task = 4;
}

message WorkerSyncPayment {
string payment_id = 1;
string status = 2;
string amount = 3;
optional string task_id = 4;
uint32 created_at = 5;
Payment payment = 6;
}

message WorkerSyncResponse {
uint32 server_time = 1;
string worker_id = 2;
uint64 cursor = 3;
string manager_peer_id = 4;
optional WorkerSyncStatus status = 5;
repeated string capabilities = 6;
repeated WorkerSyncTask tasks = 7;
repeated WorkerSyncPayment payments = 8;
}

message EffectProtocolMessage {
oneof message {
Task task = 1;
Expand All @@ -62,5 +102,7 @@ message EffectProtocolMessage {
EffectIdentifyRequest identify_request = 15;
EffectIdentifyResponse identify_response = 16;
BulkProofRequest bulk_proof_request = 17;
WorkerSyncRequest worker_sync_request = 18;
WorkerSyncResponse worker_sync_response = 19;
}
}
Loading