WIP Initial module

Gemfile

@@ -2,6 +2,7 @@ source "https://rubygems.org"
 
 gemspec
 
+gem "dotenv", "~> 2.7"
 gem "minitest", "~> 5.0"
 gem "minitest-reporters", "~> 1.6"
 gem "rake", "~> 13.0"

README.md

@@ -208,6 +208,10 @@ rake ci:test      # Run test suite
 rake ci:lint      # Run RuboCop linter
 rake ci:lint:fix  # Auto-fix linting issues
 rake ci:scan      # Run security audit
+
+# To run manual examples build locally:
+rake build
+rake install
 ```
 
 5. Commit your changes: `git commit -am 'Add some feature'`

examples/example1.rb

@@ -0,0 +1,105 @@
+require "dotenv/load"
+require "reline"
+
+# Register the mcp server
+# claude mcp add --transport http headless-browser http://localhost:4567/mcp
+# claude --dangerously-skip-permissions
+
+# Install the headless_browser_tool gem
+# gem install headless_browser_tool --source https://github.com/krschacht/headless-browser-tool.git
+
+# Before running start the hbt server in a separate terminal:
+#   bundle exec hbt start --no-headless --be-human --single-session --session-id=amazon
+
+# Load local development version instead of installed gem
+$LOAD_PATH.unshift File.expand_path("../lib", __dir__)
+require "ruby_agent"
+
+class MyAgent < RubyAgent::Agent
+  # 1. General event handler - fires for ALL events
+  on_event :my_handler
+
+  def my_handler(event)
+    puts "Event triggered"
+    puts "Received event type: #{event['type']}"
+    puts "Received event: #{event.dig('message', 'id')}"
+  end
+
+  # 2. Event-specific handler - fires only for assistant messages
+  on_event_assistant do |_event|
+    puts "Assistant message received"
+  end
+
+  # 3. Another event-specific handler - fires only for content_block_delta events
+  on_event_content_block_delta :streaming_handler
+
+  def streaming_handler(event)
+    # Handle streaming text output for content_block_delta events only
+    return unless event.dig("delta", "text")
+
+    print event["delta"]["text"]
+  end
+
+  # TODO: Add this
+  # def on_event_result(event)
+  #  puts "\nConversation complete!"
+  # end
+end
+
+DONE = %w[done end eof exit].freeze
+
+def prompt_for_message
+  puts "\n(multiline input; type 'end' on its own line when done. or 'exit' to exit)\n\n"
+
+  user_message = Reline.readmultiline("User message: ", true) do |multiline_input|
+    last = multiline_input.split.last
+    DONE.include?(last)
+  end
+
+  return :noop unless user_message
+
+  lines = user_message.split("\n")
+
+  if lines.size > 1 && DONE.include?(lines.last)
+    # remove the "done" from the message
+    user_message = lines[0..-2].join("\n")
+  end
+
+  return :exit if DONE.include?(user_message.downcase)
+
+  user_message
+end
+
+begin
+  RubyAgent.configure do |config|
+    config.anthropic_api_key = ENV.fetch("ANTHROPIC_API_KEY", nil) # Not strictly necessary with claude installed
+    config.system_prompt = "You are a helpful AI news  assistant."
+    config.model = "claude-sonnet-4-5-20250929"
+    config.sandbox_dir = "./news_sandbox"
+  end
+
+  agent = MyAgent.new(name: "News-Agent").connect(mcp_servers: { headless_browser: { type: :http,
+                                                                                     url: "http://0.0.0.0:4567/mcp" } })
+
+  puts "Welcome to your Claude assistant!"
+
+  loop do
+    user_message = prompt_for_message
+
+    case user_message
+    when :noop
+      next
+    when :exit
+      break
+    end
+
+    puts "Asking Claude..."
+    response = agent.ask(user_message)
+    puts "\n\nFinal response:\n\n"
+    puts response.final_text
+  end
+rescue Interrupt
+  puts "\nExiting..."
+ensure
+  agent&.close
+end