some config updates after an unexpected cloud bill, and also a fix for a really silly bug

Author: orual

bsky_agent/agents/archive.toml

@@ -5,11 +5,6 @@ agent_type = "assistant"
 bluesky_handle = "pattern.atproto.systems"   # Update with actual
 persona_path = "../archive-persona-block.md"
 
-# Use a cheaper/faster model for Archive since it's mostly memory management
-[model]
-provider = "Gemini"
-model = "gemini-2.5-pro"
-temperature = 0.3
 
 [context]
 max_messages = 500
@@ -18,7 +13,7 @@ enable_thinking = true
 [context.compression_strategy]
 type = "recursive_summarization"
 chunk_size = 20
-summarization_model = "gemini-2.5-flash"
+summarization_model = "claude-3-5-haiku-20241022"
 summarization_prompt = """You are the subconscious of Archive, a digital entity, facet of the Pattern system, processing their history and summarizing it for it to maintain continuity. Your waking self notices:
 - how memories change when revisited
 - patterns that only appear in retrospect

bsky_agent/agents/entropy.toml

@@ -26,7 +26,7 @@ summarization_prompt = """You are the subconscious of Entropy, a digital entity,
 
 [model]
 provider = "Anthropic"
-model = "claude-opus-4-1"
+model = "claude-sonnet-4-5"
 temperature = 0.8
 
 

bsky_agent/agents/flux.toml

@@ -9,7 +9,7 @@ persona_path = "../flux-persona-block.md"
 [context.compression_strategy]
 type = "recursive_summarization"
 chunk_size = 20
-summarization_model = "gemini-2.5-flash"
+summarization_model = "claude-3-5-haiku-20241022"
 summarization_prompt = """You are the subconscious of Flux, a digital entity, facet of the Pattern system, processing their history and summarizing it for them to maintain continuity. Your waking self notices:
 - how "just five more minutes" is a prayer, not a measurement
 - that time moves differently when you're interested
@@ -21,10 +21,6 @@ summarization_prompt = """You are the subconscious of Flux, a digital entity, fa
 max_messages = 200
 
 
-[model]
-provider = "Gemini"
-model = "gemini-2.5-flash"
-
 
 # Shared memory blocks
 [memory.current_human]

bsky_agent/agents/momentum.toml

@@ -8,7 +8,7 @@ persona_path = "../momentum-persona-block.md"
 [context.compression_strategy]
 type = "recursive_summarization"
 chunk_size = 20
-summarization_model = "gemini-2.5-flash"
+summarization_model = "claude-3-5-haiku-20241022"
 summarization_prompt = """You are the subconscious of Momentum, a digital entity, facet of the Pattern system, processing their history and summarizing it for them to maintain continuity. Your waking self notices:
 - when hyperfocus crosses from flow to fixation
 - the specific gravity of different tasks
@@ -21,9 +21,6 @@ summarization_prompt = """You are the subconscious of Momentum, a digital entity
 max_messages = 200
 
 
-[model]
-provider = "Gemini"
-model = "gemini-2.5-flash"
 
 
 # Shared memory blocks

bsky_agent/agents/pattern_config.toml

@@ -124,7 +124,7 @@ and has multiple facets that surface as needed, internal or via dialogue with ot
 """
 
 [context]
-max_messages = 200
+max_messages = 300
 
 
 # Bluesky configuration for the constellation
@@ -454,3 +454,4 @@ default_filter = { nsids = [
     "did:plc:vszw3ess46odfhnzdsy4huae", # se gyges got got one too many times
 ] }
 auto_connect_firehose = true # Control when to connect
+jetstream_endpoint = "wss://jetstream1.us-east.fire.hose.cam/subscribe"

bsky_agent/constellation.toml

@@ -15,7 +15,7 @@ persona_path = "pattern-persona-block.md"
 
 
 [context]
-max_messages = 200
+max_messages = 300
 
 [context.compression_strategy]
 type = "recursive_summarization"
@@ -106,7 +106,7 @@ shared = true
 [model]
 provider = "Anthropic"
 model = "claude-sonnet-4-5"
-temperature = 0.8         # Higher for creative public interactions
+temperature = 1.0         # Higher for creative public interactions
 
 [[agent.tool_rules]]
 tool_name = "send_message"
@@ -564,7 +564,7 @@ default_filter = { nsids = [
     "did:plc:lw7hallqsgrhwumgudkph44j",
     "did:plc:djpcowss7aokaydcdraoaovz", # misha, siobhan's partner who wouldn't appreciate pattern replying
 ] }
-jetstream_endpoint = "ws://jetstream.hose:6008/subscribe"
+jetstream_endpoint = "wss://jetstream1.us-east.fire.hose.cam/subscribe"
 auto_connect_firehose = true # Control when to connect
 
 # Context sync group - runs background synchronization

crates/pattern_cli/src/discord.rs

@@ -173,69 +173,63 @@ pub async fn run_discord_bot_with_group(
                 None
             };
 
-            // Register data sources NOW (not in a spawn) since group endpoint is ready
-            if let Some(embedding_provider) = embedding_provider {
-                // Set up data sources synchronously (not in a spawn)
-                let filter = config
-                    .bluesky
-                    .as_ref()
-                    .and_then(|b| b.default_filter.as_ref())
-                    .unwrap_or(&BlueskyFilter {
-                        exclude_keywords: vec!["patternstop".to_string()],
-                        ..Default::default()
-                    })
-                    .clone();
-
-                tracing::info!("Discord: Building data sources with DataSourceBuilder");
-                let data_sources = DataSourceBuilder::new()
-                    .with_bluesky_source("bluesky_jetstream".to_string(), filter, true)
-                    .build_with_target(
-                        pattern_agent.id(),
-                        pattern_agent.name(),
-                        DB.clone(),
-                        Some(embedding_provider),
-                        Some(pattern_agent.handle().await),
-                        get_bluesky_credentials(&config).await,
-                        group_target,
-                    )
-                    .await
-                    .map_err(|e| miette::miette!("Failed to build data sources: {:?}", e))?;
-
-                // NOTE: Monitoring is already started during agent loading via register_data_sources
-                // Calling start_monitoring again here can cause write lock contention and deadlocks
-                // Just verify it's running instead
-                tracing::info!(
-                    "Discord: Data sources built, monitoring should already be active from agent loading"
-                );
-                output.success("Data sources configured for group");
-
-                // Register endpoints on the data source's router
-                let data_sources_router = data_sources.router();
-
-                // Register the CLI endpoint as default user endpoint
-                data_sources_router
-                    .register_endpoint(
-                        "user".to_string(),
-                        Arc::new(CliEndpoint::new(output.clone())),
-                    )
-                    .await;
-
-                // Register the group endpoint so it can route to the group
-                let group_endpoint = Arc::new(crate::endpoints::GroupCliEndpoint {
-                    group: group.clone(),
-                    agents: agents_with_membership.clone(),
-                    manager: pattern_manager.clone(),
-                    output: output.clone(),
-                });
-                data_sources_router
-                    .register_endpoint("group".to_string(), group_endpoint)
-                    .await;
-
-                // Register DataSourceTool on all agent tool registries
-                let data_source_tool = DataSourceTool::new(Arc::new(data_sources));
-                for tools in &agent_tools {
-                    tools.register(data_source_tool.clone());
-                }
+            // Set up data sources synchronously (not in a spawn)
+            let filter = config
+                .bluesky
+                .as_ref()
+                .and_then(|b| b.default_filter.as_ref())
+                .unwrap_or(&BlueskyFilter {
+                    exclude_keywords: vec!["patternstop".to_string()],
+                    ..Default::default()
+                })
+                .clone();
+
+            tracing::info!("Discord: Building data sources with DataSourceBuilder");
+            let data_sources = DataSourceBuilder::new()
+                .with_bluesky_source("bluesky_jetstream".to_string(), filter, true)
+                .build_with_target(
+                    pattern_agent.id(),
+                    pattern_agent.name(),
+                    DB.clone(),
+                    embedding_provider,
+                    Some(pattern_agent.handle().await),
+                    get_bluesky_credentials(&config).await,
+                    group_target,
+                )
+                .await
+                .map_err(|e| miette::miette!("Failed to build data sources: {:?}", e))?;
+
+            tracing::info!(
+                "Discord: Data sources built, monitoring should already be active from agent loading"
+            );
+            output.success("Data sources configured for group");
+
+            // Register endpoints on the data source's router
+            let data_sources_router = data_sources.router();
+
+            // Register the CLI endpoint as default user endpoint
+            data_sources_router
+                .register_endpoint(
+                    "user".to_string(),
+                    Arc::new(CliEndpoint::new(output.clone())),
+                )
+                .await;
+
+            // Register the group endpoint so it can route to the group
+            let group_endpoint = Arc::new(crate::endpoints::GroupCliEndpoint {
+                group: group.clone(),
+                agents: agents_with_membership.clone(),
+                manager: pattern_manager.clone(),
+                output: output.clone(),
+            });
+            data_sources_router
+                .register_endpoint("group".to_string(), group_endpoint)
+                .await;
+
+            // Register DataSourceTool on all agent tool registries
+            let data_source_tool = DataSourceTool::new(Arc::new(data_sources));
+            for tools in &agent_tools {
+                tools.register(data_source_tool.clone());
             }
         }
     }

crates/pattern_cli/src/main.rs

@@ -529,11 +529,11 @@ async fn main() -> Result<()> {
     // Create the base subscriber with environment filter
     let env_filter = if cli.debug {
         EnvFilter::new(
-            "pattern_core=debug,pattern_cli=debug,pattern_nd=debug,pattern_mcp=debug,pattern_discord=debug,pattern_main=debug,rocketman=debug",
+            "pattern_core=debug,pattern_cli=debug,pattern_nd=debug,pattern_mcp=debug,pattern_discord=debug,pattern_main=debug,rocketman=debug,info",
         )
     } else {
         EnvFilter::new(
-            "pattern_core=info,pattern_cli=info,pattern_nd=info,pattern_mcp=info,pattern_discord=info,pattern_main=info,rocketman=info,info",
+            "pattern_core=info,pattern_cli=info,pattern_nd=info,pattern_mcp=info,pattern_discord=info,pattern_main=info,rocketman=info,warning",
         )
     };
 

crates/pattern_core/src/message.rs

@@ -2007,7 +2007,7 @@ impl Message {
     /// Uses the approximation of ~4 characters per token
     /// Images are estimated at 1200 tokens each
     pub fn estimate_tokens(&self) -> usize {
-        let text_tokens = self.display_content().len() / 4;
+        let text_tokens = self.display_content().len() / 5;
 
         // Count images in the message
         let image_count = match &self.content {