Skip to content

Commit 14c1be7

Browse files
sergeytimoshinsergeytimoshin
committed
refactor: replace grpc queue info with polling
1 parent 3274f97 commit 14c1be7

42 files changed

Lines changed: 769 additions & 1030 deletions

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

‎Cargo.lock‎

Lines changed: 35 additions & 242 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

‎cli/src/commands/test-validator/index.ts‎

Lines changed: 0 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -69,12 +69,6 @@ class SetupCommand extends Command {
6969
default: 8784,
7070
exclusive: ["skip-indexer"],
7171
}),
72-
"grpc-port": Flags.integer({
73-
description: "Enable Photon indexer gRPC on this port.",
74-
required: false,
75-
default: 50051,
76-
exclusive: ["skip-indexer"],
77-
}),
7872
"prover-port": Flags.integer({
7973
description: "Enable Light Prover server on this port.",
8074
required: false,
@@ -200,7 +194,6 @@ class SetupCommand extends Command {
200194
rpcPort: flags["rpc-port"],
201195
gossipHost: flags["gossip-host"],
202196
indexerPort: flags["indexer-port"],
203-
grpcPort: flags["grpc-port"],
204197
proverPort: flags["prover-port"],
205198
prover: !flags["skip-prover"],
206199
skipSystemAccounts: flags["skip-system-accounts"],

‎cli/src/utils/initTestEnv.ts‎

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -86,7 +86,6 @@ export async function initTestEnv({
8686
prover = true,
8787
rpcPort = 8899,
8888
indexerPort = 8784,
89-
grpcPort = 50051,
9089
proverPort = 3001,
9190
gossipHost = "127.0.0.1",
9291
checkPhotonVersion = true,
@@ -101,7 +100,6 @@ export async function initTestEnv({
101100
prover: boolean;
102101
rpcPort?: number;
103102
indexerPort?: number;
104-
grpcPort?: number;
105103
proverPort?: number;
106104
gossipHost?: string;
107105
checkPhotonVersion?: boolean;
@@ -130,7 +128,6 @@ export async function initTestEnv({
130128
await startIndexer(
131129
`http://127.0.0.1:${rpcPort}`,
132130
indexerPort,
133-
grpcPort,
134131
checkPhotonVersion,
135132
photonDatabaseUrl,
136133
);

‎cli/src/utils/processPhotonIndexer.ts‎

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -39,7 +39,6 @@ function getPhotonInstallMessage(): string {
3939
export async function startIndexer(
4040
rpcUrl: string,
4141
indexerPort: number,
42-
grpcPort: number = 50051,
4342
checkPhotonVersion: boolean = true,
4443
photonDatabaseUrl?: string,
4544
) {
@@ -58,8 +57,6 @@ export async function startIndexer(
5857
indexerPort.toString(),
5958
"--rpc-url",
6059
rpcUrl,
61-
"--grpc-port",
62-
grpcPort.toString(),
6360
];
6461
if (photonDatabaseUrl) {
6562
args.push("--db-url", photonDatabaseUrl);

‎forester/Cargo.toml‎

Lines changed: 1 addition & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -59,17 +59,9 @@ dashmap = "6.1.0"
5959
scopeguard = "1.2.0"
6060
itertools = "0.14.0"
6161
num-bigint = { workspace = true }
62-
63-
tonic = "0.14.2"
64-
prost = "0.14.1"
65-
prost-types = "0.14.1"
66-
tonic-prost = "0.14.2"
67-
tokio-stream = { version = "0.1", features = ["sync"] }
62+
kameo = "0.19"
6863
once_cell = "1.21.3"
6964

70-
[build-dependencies]
71-
tonic-prost-build = "0.14.2"
72-
7365
[dev-dependencies]
7466
serial_test = { workspace = true }
7567
light-prover-client = { workspace = true, features = ["devenv"] }

‎forester/build.rs‎

Lines changed: 0 additions & 6 deletions
This file was deleted.

‎forester/proto/photon.proto‎

Lines changed: 0 additions & 70 deletions
This file was deleted.

0 commit comments

Comments
 (0)