Ajay Krishnan
9b0c4cd3cd
opencode-rails — production-grade Rails integration for OpenCode. Rails companion to opencode-ruby. ActiveRecord-aware session lifecycle (idempotent ensure!/recreate!/abort! with row-level locks), a Turn orchestrator driving the Reply state machine and recovering from session-not-found, an artifact pipeline backed by ActiveStorage, sandbox seeding, and tool-display value objects for Turbo Stream broadcasts. Drop into any Rails 7.1+ app that wants production-grade OpenCode streaming without rolling boilerplate. What this version ships: - Opencode::Session (AR-coupled lifecycle, row-level locks) - Opencode::Turn (Reply state machine, session-not-found recovery) - Opencode::Exchange (one turn = one request/response unit) - Opencode::Impostor (deterministic mock for tests) - Opencode::Sandbox / SandboxFile (per-session FS scratch space) - Opencode::Transform (host-rendered artifact pipeline) - Opencode::Artifact / MessageArtifacts (ActiveStorage-backed) - Opencode::UploadedFilesPrompt (system-prompt builder) - Opencode::ToolDisplay (Turbo Stream value objects) - Opencode::ErrorReporter (pluggable adapter — Honeybadger/Sentry/etc.) - examples/rails_integration.rb — canonical wiring blueprint 53 smoke tests. CI on Ruby 3.2/3.3/3.4. Ruby >= 3.2. Runtime deps: opencode-ruby = 0.0.1.alpha2, activerecord/activestorage/activesupport >= 7.1, < 9.0. See CHANGELOG.md for the alpha1 -> alpha2 delta.
63 lines
2.3 KiB
Ruby
63 lines
2.3 KiB
Ruby
# frozen_string_literal: true
|
|
|
|
require "test_helper"
|
|
|
|
# Contract smoke for Opencode::Turn (the orchestrator) and its inner
|
|
# Result value object. Behavioral coverage (the full send -> stream ->
|
|
# recover -> finalize loop) lives in the host application — Turn needs
|
|
# an Opencode::Client, an AR Message, a subject record, etc., which are
|
|
# all integration-level concerns.
|
|
class Opencode::TurnTest < Minitest::Test
|
|
REQUIRED_INIT_KEYS = %i[
|
|
message subject query_text client session_for observer_factory
|
|
system_context agent_name tracer
|
|
].freeze
|
|
|
|
OPTIONAL_INIT_KEYS = %i[
|
|
on_finalized on_turn_finished on_activity_tick
|
|
empty_stream_retry_delay final_exchange_timeout
|
|
final_exchange_retry_delay error_fallback_content error_feature
|
|
].freeze
|
|
|
|
def test_required_keyword_arguments
|
|
params = Opencode::Turn.instance_method(:initialize).parameters
|
|
required = params.select { |kind, _| kind == :keyreq }.map(&:last).sort
|
|
|
|
assert_equal REQUIRED_INIT_KEYS.sort, required,
|
|
"Turn's required keyword args drifted. Expected: #{REQUIRED_INIT_KEYS.sort}, got: #{required}"
|
|
end
|
|
|
|
def test_optional_keyword_arguments_match_documented_surface
|
|
params = Opencode::Turn.instance_method(:initialize).parameters
|
|
optional = params.select { |kind, _| kind == :key }.map(&:last).sort
|
|
|
|
assert_equal OPTIONAL_INIT_KEYS.sort, optional,
|
|
"Turn's optional keyword args drifted. Expected: #{OPTIONAL_INIT_KEYS.sort}, got: #{optional}"
|
|
end
|
|
|
|
def test_public_surface_is_call_only
|
|
# Turn is an orchestrator; the only public verb is #call. Everything
|
|
# else is internal. Locking this prevents helpers from accidentally
|
|
# bleeding into the public API.
|
|
assert_equal [ :call ], Opencode::Turn.instance_methods(false)
|
|
end
|
|
|
|
def test_result_is_a_value_object_with_status_predicates
|
|
fake_message = Struct.new(:cost, :input_tokens, :output_tokens, keyword_init: true).new(
|
|
cost: 0.012, input_tokens: 100, output_tokens: 50
|
|
)
|
|
result = Opencode::Turn::Result.new(
|
|
status: :completed, message: fake_message, duration_ms: 1234
|
|
)
|
|
|
|
assert result.completed?
|
|
refute result.cancelled?
|
|
refute result.errored?
|
|
refute result.failed?
|
|
assert_equal 1234, result.duration_ms
|
|
assert_equal 0.012, result.cost
|
|
assert_equal 100, result.input_tokens
|
|
assert_equal 50, result.output_tokens
|
|
end
|
|
end
|