rpc: introduce gRPC service

Cargo.toml

@@ -148,8 +148,8 @@ members = [
     "crates/sui-protocol-config-macros",
     "crates/sui-proxy",
     "crates/sui-replay",
-    "crates/sui-rest-api",
     "crates/sui-rosetta",
+    "crates/sui-rpc-api",
     "crates/sui-rpc-loadgen",
     "crates/sui-sdk",
     "crates/sui-security-watchdog",
@@ -605,7 +605,7 @@ anemo-tower = { git = "https://github.com/mystenlabs/anemo.git", rev = "e609f769
 
 # core-types with json format for REST api
 # sui-sdk-types = { version = "0.0.1", features = ["hash", "serde", "schemars"] }
-sui-sdk-types = { git = "https://github.com/MystenLabs/sui-rust-sdk.git", rev = "31bd9da32a8057edc45da8f5e6a8f25b83919b93", features = ["hash", "serde", "schemars"] }
+sui-sdk-types = { git = "https://github.com/MystenLabs/sui-rust-sdk.git", rev = "24c34933c421319e9aa1c48b3b7108c756e1422f", features = ["hash", "serde", "schemars"] }
 
 ### Workspace Members ###
 anemo-benchmark = { path = "crates/anemo-benchmark" }
@@ -691,7 +691,7 @@ sui-telemetry = { path = "crates/sui-telemetry" }
 sui-test-transaction-builder = { path = "crates/sui-test-transaction-builder" }
 sui-test-validator = { path = "crates/sui-test-validator" }
 sui-tls = { path = "crates/sui-tls" }
-sui-rest-api = { path = "crates/sui-rest-api" }
+sui-rpc-api = { path = "crates/sui-rpc-api" }
 sui-tool = { path = "crates/sui-tool" }
 sui-transaction-builder = { path = "crates/sui-transaction-builder" }
 sui-transaction-checks = { path = "crates/sui-transaction-checks" }

crates/simulacrum/src/lib.rs

@@ -16,7 +16,6 @@ use std::sync::Arc;
 
 use anyhow::{anyhow, Result};
 use fastcrypto::traits::Signer;
-use move_core_types::language_storage::StructTag;
 use rand::rngs::OsRng;
 use sui_config::verifier_signing_config::VerifierSigningConfig;
 use sui_config::{genesis, transaction_deny_config::TransactionDenyConfig};
@@ -29,7 +28,7 @@ use sui_types::base_types::{AuthorityName, ObjectID, VersionNumber};
 use sui_types::crypto::AuthoritySignature;
 use sui_types::digests::ConsensusCommitDigest;
 use sui_types::object::Object;
-use sui_types::storage::{ObjectStore, ReadStore, RestStateReader};
+use sui_types::storage::{ObjectStore, ReadStore, RpcStateReader};
 use sui_types::sui_system_state::epoch_start_sui_system_state::EpochStartSystemState;
 use sui_types::transaction::EndOfEpochTransactionKind;
 use sui_types::{
@@ -549,16 +548,7 @@ impl<T, V: store::SimulatorStore> ReadStore for Simulacrum<T, V> {
     }
 }
 
-impl<T: Send + Sync, V: store::SimulatorStore + Send + Sync> RestStateReader for Simulacrum<T, V> {
-    fn get_transaction_checkpoint(
-        &self,
-        _digest: &sui_types::digests::TransactionDigest,
-    ) -> sui_types::storage::error::Result<
-        Option<sui_types::messages_checkpoint::CheckpointSequenceNumber>,
-    > {
-        todo!()
-    }
-
+impl<T: Send + Sync, V: store::SimulatorStore + Send + Sync> RpcStateReader for Simulacrum<T, V> {
     fn get_lowest_available_checkpoint_objects(
         &self,
     ) -> sui_types::storage::error::Result<CheckpointSequenceNumber> {
@@ -577,38 +567,8 @@ impl<T: Send + Sync, V: store::SimulatorStore + Send + Sync> RestStateReader for
             .into())
     }
 
-    fn account_owned_objects_info_iter(
-        &self,
-        _owner: SuiAddress,
-        _cursor: Option<ObjectID>,
-    ) -> sui_types::storage::error::Result<
-        Box<dyn Iterator<Item = sui_types::storage::AccountOwnedObjectInfo> + '_>,
-    > {
-        todo!()
-    }
-
-    fn dynamic_field_iter(
-        &self,
-        _parent: ObjectID,
-        _cursor: Option<ObjectID>,
-    ) -> sui_types::storage::error::Result<
-        Box<
-            dyn Iterator<
-                    Item = (
-                        sui_types::storage::DynamicFieldKey,
-                        sui_types::storage::DynamicFieldIndexInfo,
-                    ),
-                > + '_,
-        >,
-    > {
-        todo!()
-    }
-
-    fn get_coin_info(
-        &self,
-        _coin_type: &StructTag,
-    ) -> sui_types::storage::error::Result<Option<sui_types::storage::CoinInfo>> {
-        todo!()
+    fn indexes(&self) -> Option<&dyn sui_types::storage::RpcIndexes> {
+        None
     }
 }
 

crates/sui-analytics-indexer/Cargo.toml

@@ -41,7 +41,7 @@ eyre.workspace = true
 tempfile.workspace = true
 sui-types.workspace = true
 telemetry-subscribers.workspace = true
-sui-rest-api.workspace = true
+sui-rpc-api.workspace = true
 sui-storage.workspace = true
 sui-config.workspace = true
 typed-store.workspace = true

crates/sui-analytics-indexer/src/analytics_processor.rs

@@ -17,7 +17,7 @@ use tracing::{error, info};
 
 use sui_config::object_storage_config::{ObjectStoreConfig, ObjectStoreType};
 use sui_data_ingestion_core::Worker;
-use sui_rest_api::CheckpointData;
+use sui_rpc_api::CheckpointData;
 use sui_storage::object_store::util::{copy_file, path_to_filesystem};
 use sui_types::messages_checkpoint::CheckpointSequenceNumber;
 

crates/sui-analytics-indexer/src/handlers/checkpoint_handler.rs

@@ -6,7 +6,7 @@ use fastcrypto::traits::EncodeDecodeBase64;
 use tokio::sync::Mutex;
 
 use sui_data_ingestion_core::Worker;
-use sui_rest_api::{CheckpointData, CheckpointTransaction};
+use sui_rpc_api::{CheckpointData, CheckpointTransaction};
 use sui_types::effects::TransactionEffectsAPI;
 use sui_types::messages_checkpoint::{CertifiedCheckpointSummary, CheckpointSummary};
 use sui_types::transaction::TransactionDataAPI;

crates/sui-analytics-indexer/src/handlers/df_handler.rs

@@ -16,7 +16,7 @@ use tracing::warn;
 use sui_indexer::types::owner_to_owner_info;
 use sui_json_rpc_types::SuiMoveValue;
 use sui_package_resolver::Resolver;
-use sui_rest_api::{CheckpointData, CheckpointTransaction};
+use sui_rpc_api::{CheckpointData, CheckpointTransaction};
 use sui_types::base_types::ObjectID;
 use sui_types::dynamic_field::visitor as DFV;
 use sui_types::dynamic_field::{DynamicFieldName, DynamicFieldType};

crates/sui-analytics-indexer/src/handlers/event_handler.rs

@@ -16,7 +16,7 @@ use crate::tables::EventEntry;
 use crate::FileType;
 use sui_json_rpc_types::type_and_fields_from_move_event_data;
 use sui_package_resolver::Resolver;
-use sui_rest_api::CheckpointData;
+use sui_rpc_api::CheckpointData;
 use sui_types::digests::TransactionDigest;
 use sui_types::effects::TransactionEvents;
 use sui_types::event::Event;

crates/sui-analytics-indexer/src/handlers/move_call_handler.rs

@@ -5,7 +5,7 @@ use anyhow::Result;
 use sui_data_ingestion_core::Worker;
 use tokio::sync::Mutex;
 
-use sui_rest_api::CheckpointData;
+use sui_rpc_api::CheckpointData;
 use sui_types::base_types::ObjectID;
 use sui_types::transaction::TransactionDataAPI;
 

crates/sui-analytics-indexer/src/handlers/object_handler.rs

@@ -10,7 +10,7 @@ use tokio::sync::Mutex;
 
 use sui_json_rpc_types::SuiMoveStruct;
 use sui_package_resolver::Resolver;
-use sui_rest_api::{CheckpointData, CheckpointTransaction};
+use sui_rpc_api::{CheckpointData, CheckpointTransaction};
 use sui_types::base_types::ObjectID;
 use sui_types::effects::TransactionEffects;
 use sui_types::object::Object;

crates/sui-analytics-indexer/src/handlers/package_handler.rs

@@ -4,7 +4,7 @@
 use anyhow::Result;
 use fastcrypto::encoding::{Base64, Encoding};
 use sui_data_ingestion_core::Worker;
-use sui_rest_api::CheckpointData;
+use sui_rpc_api::CheckpointData;
 use sui_types::full_checkpoint_content::CheckpointTransaction;
 use sui_types::object::Object;
 use tokio::sync::Mutex;

crates/sui-analytics-indexer/src/handlers/transaction_handler.rs

@@ -9,7 +9,7 @@ use sui_data_ingestion_core::Worker;
 use tokio::sync::Mutex;
 use tracing::error;
 
-use sui_rest_api::{CheckpointData, CheckpointTransaction};
+use sui_rpc_api::{CheckpointData, CheckpointTransaction};
 use sui_types::effects::TransactionEffects;
 use sui_types::effects::TransactionEffectsAPI;
 use sui_types::transaction::{Command, TransactionDataAPI, TransactionKind};

crates/sui-analytics-indexer/src/handlers/transaction_objects_handler.rs

@@ -5,7 +5,7 @@ use anyhow::Result;
 use sui_data_ingestion_core::Worker;
 use tokio::sync::Mutex;
 
-use sui_rest_api::{CheckpointData, CheckpointTransaction};
+use sui_rpc_api::{CheckpointData, CheckpointTransaction};
 use sui_types::base_types::ObjectID;
 use sui_types::effects::TransactionEffects;
 use sui_types::transaction::TransactionDataAPI;

crates/sui-analytics-indexer/src/handlers/wrapped_object_handler.rs

@@ -9,7 +9,7 @@ use sui_types::SYSTEM_PACKAGE_ADDRESSES;
 use tokio::sync::Mutex;
 
 use sui_package_resolver::Resolver;
-use sui_rest_api::{CheckpointData, CheckpointTransaction};
+use sui_rpc_api::{CheckpointData, CheckpointTransaction};
 use sui_types::object::Object;
 
 use crate::handlers::{get_move_struct, parse_struct, AnalyticsHandler};

crates/sui-analytics-indexer/src/lib.rs

@@ -19,7 +19,7 @@ use tracing::info;
 
 use sui_config::object_storage_config::ObjectStoreConfig;
 use sui_data_ingestion_core::Worker;
-use sui_rest_api::CheckpointData;
+use sui_rpc_api::CheckpointData;
 use sui_storage::object_store::util::{
     find_all_dirs_with_epoch_prefix, find_all_files_with_epoch_prefix,
 };

crates/sui-analytics-indexer/src/package_store.rs

@@ -9,7 +9,7 @@ use move_core_types::account_address::AccountAddress;
 use sui_package_resolver::{
     error::Error as PackageResolverError, Package, PackageStore, PackageStoreWithLruCache, Result,
 };
-use sui_rest_api::Client;
+use sui_rpc_api::Client;
 use sui_types::base_types::ObjectID;
 use sui_types::object::Object;
 use thiserror::Error;
@@ -76,7 +76,7 @@ impl LocalDBPackageStore {
     pub fn new(path: &Path, rest_url: &str) -> Self {
         Self {
             package_store_tables: PackageStoreTables::new(path),
-            fallback_client: Client::new(rest_url),
+            fallback_client: Client::new(rest_url).unwrap(),
         }
     }
 

crates/sui-config/Cargo.toml

@@ -33,7 +33,7 @@ sui-keys.workspace = true
 sui-protocol-config.workspace = true
 sui-types.workspace = true
 move-vm-config.workspace = true
-sui-rest-api.workspace = true
+sui-rpc-api.workspace = true
 mysten-common.workspace = true
 
 [dev-dependencies]

crates/sui-config/src/node.rs

@@ -67,7 +67,7 @@ pub struct NodeConfig {
     #[serde(default)]
     pub enable_experimental_rest_api: bool,
     #[serde(skip_serializing_if = "Option::is_none")]
-    pub rest: Option<sui_rest_api::Config>,
+    pub rpc: Option<sui_rpc_api::Config>,
 
     #[serde(default = "default_metrics_address")]
     pub metrics_address: SocketAddr,

crates/sui-core/src/authority.rs

@@ -6,7 +6,7 @@ use crate::consensus_adapter::ConsensusOverloadChecker;
 use crate::execution_cache::ExecutionCacheTraitPointers;
 use crate::execution_cache::TransactionCacheRead;
 use crate::jsonrpc_index::CoinIndexKey2;
-use crate::rest_index::RestIndexStore;
+use crate::rpc_index::RpcIndexStore;
 use crate::transaction_outputs::TransactionOutputs;
 use crate::verify_indexes::verify_indexes;
 use anyhow::anyhow;
@@ -792,7 +792,7 @@ pub struct AuthorityState {
     execution_lock: RwLock<EpochId>,
 
     pub indexes: Option<Arc<IndexStore>>,
-    pub rest_index: Option<Arc<RestIndexStore>>,
+    pub rpc_index: Option<Arc<RpcIndexStore>>,
 
     pub subscription_handler: Arc<SubscriptionHandler>,
     checkpoint_store: Arc<CheckpointStore>,
@@ -2834,7 +2834,7 @@ impl AuthorityState {
         epoch_store: Arc<AuthorityPerEpochStore>,
         committee_store: Arc<CommitteeStore>,
         indexes: Option<Arc<IndexStore>>,
-        rest_index: Option<Arc<RestIndexStore>>,
+        rpc_index: Option<Arc<RpcIndexStore>>,
         checkpoint_store: Arc<CheckpointStore>,
         prometheus_registry: &Registry,
         genesis_objects: &[Object],
@@ -2866,7 +2866,7 @@ impl AuthorityState {
         let _pruner = AuthorityStorePruner::new(
             store.perpetual_tables.clone(),
             checkpoint_store.clone(),
-            rest_index.clone(),
+            rpc_index.clone(),
             store.objects_lock_table.clone(),
             config.authority_store_pruning_config.clone(),
             epoch_store.committee().authority_exists(&name),
@@ -2886,7 +2886,7 @@ impl AuthorityState {
             input_loader,
             execution_cache_trait_pointers,
             indexes,
-            rest_index,
+            rpc_index,
             subscription_handler: Arc::new(SubscriptionHandler::new(prometheus_registry)),
             checkpoint_store,
             committee_store,
@@ -2978,7 +2978,7 @@ impl AuthorityState {
         AuthorityStorePruner::prune_checkpoints_for_eligible_epochs(
             &self.database_for_testing().perpetual_tables,
             &self.checkpoint_store,
-            self.rest_index.as_deref(),
+            self.rpc_index.as_deref(),
             &self.database_for_testing().objects_lock_table,
             config.authority_store_pruning_config,
             metrics,

crates/sui-core/src/authority/authority_store.rs

@@ -13,7 +13,7 @@ use crate::authority::authority_store_types::{
     get_store_object_pair, ObjectContentDigest, StoreObject, StoreObjectPair, StoreObjectWrapper,
 };
 use crate::authority::epoch_start_configuration::{EpochFlag, EpochStartConfiguration};
-use crate::rest_index::RestIndexStore;
+use crate::rpc_index::RpcIndexStore;
 use crate::state_accumulator::AccumulatorStore;
 use crate::transaction_outputs::TransactionOutputs;
 use either::Either;
@@ -1791,7 +1791,7 @@ impl AuthorityStore {
     pub async fn prune_objects_and_compact_for_testing(
         &self,
         checkpoint_store: &Arc<CheckpointStore>,
-        rest_index: Option<&RestIndexStore>,
+        rpc_index: Option<&RpcIndexStore>,
     ) {
         let pruning_config = AuthorityStorePruningConfig {
             num_epochs_to_retain: 0,
@@ -1800,7 +1800,7 @@ impl AuthorityStore {
         let _ = AuthorityStorePruner::prune_objects_for_eligible_epochs(
             &self.perpetual_tables,
             checkpoint_store,
-            rest_index,
+            rpc_index,
             &self.objects_lock_table,
             pruning_config,
             AuthorityStorePruningMetrics::new_for_test(),