feat(torii): sync from master torii

bin/torii/src/main.rs

@@ -39,6 +39,7 @@ use torii_core::simple_broker::SimpleBroker;
 use torii_core::sql::cache::ModelCache;
 use torii_core::sql::Sql;
 use torii_core::types::{Contract, ContractType, Model};
+use torii_grpc::client::WorldClient;
 use torii_server::proxy::Proxy;
 use tracing::{error, info};
 use tracing_subscriber::{fmt, EnvFilter};

crates/torii/cli/src/options.rs

@@ -2,10 +2,12 @@
 use std::str::FromStr;
 
 use anyhow::Context;
+use dojo_utils::parse::parse_url;
 use serde::ser::SerializeSeq;
 use serde::{Deserialize, Serialize};
 use starknet::core::types::Felt;
 use torii_core::types::{Contract, ContractType};
+use url::Url;
 
 pub const DEFAULT_HTTP_ADDR: IpAddr = IpAddr::V4(Ipv4Addr::LOCALHOST);
 pub const DEFAULT_HTTP_PORT: u16 = 8080;
@@ -20,6 +22,9 @@
 pub const DEFAULT_RELAY_WEBRTC_PORT: u16 = 9091;
 pub const DEFAULT_RELAY_WEBSOCKET_PORT: u16 = 9092;
 
+pub const DEFAULT_REPLICA_ENTITIES: bool = true;
+pub const DEFAULT_REPLICA_EVENT_MESSAGES: bool = true;
+
 #[derive(Debug, clap::Args, Clone, Serialize, Deserialize, PartialEq)]
 #[command(next_help_heading = "Relay options")]
 pub struct RelayOptions {
@@ -317,6 +322,32 @@
     }
 }
 
+#[derive(Debug, clap::Args, Clone, Serialize, Deserialize, PartialEq)]
+#[command(next_help_heading = "Replica options")]
+pub struct ReplicaOptions {
+    /// The master torii URL to connect to
+    #[arg(long, value_name = "URL", value_parser = parse_url)]
+    pub master_torii: Option<Url>,
+
+    /// If this replica should sync entity updates
+    #[arg(long, default_value_t = DEFAULT_REPLICA_ENTITIES)]
+    pub entities: bool,
+
+    /// If this replica should sync event messages
+    #[arg(long, default_value_t = DEFAULT_REPLICA_EVENT_MESSAGES)]
+    pub event_messages: bool,
+}
+
+impl Default for ReplicaOptions {
+    fn default() -> Self {
+        Self {
+            master_torii: None,
+            entities: DEFAULT_REPLICA_ENTITIES,
+            event_messages: DEFAULT_REPLICA_EVENT_MESSAGES,
+        }
+    }
+}
+
 // Parses clap cli argument which is expected to be in the format:
 // - erc_type:address:start_block
 // - address:start_block (erc_type defaults to ERC20)