Class: Ask::CodingProviders::Claude::Adapter

Inherits:
Adapter
  • Object
show all
Defined in:
lib/ask/coding_providers/claude/adapter.rb

Overview

Adapter for Claude Code CLI.

Uses claude -p --output-format=stream-json for non-interactive prompts. Streams JSON events via stdout for real-time response display.

Examples:

adapter = Ask::CodingProviders::Claude::Adapter.new(cli_path: "claude")
adapter.start
sid = adapter.create_session("/tmp")
adapter.send_and_stream(sid, "Hello") { |ev| puts ev }

Class Method Summary collapse

Instance Method Summary collapse

Methods inherited from Adapter

#find_recent_session, #find_recent_tui_session, #find_sessions, #handle_session_error, #list_projects, #list_sessions, #recent_sessions, #session_directory, #session_history

Constructor Details

#initialize(cli_path: "claude", cwd: ".", request_timeout: 120.0) ⇒ Adapter

Returns a new instance of Adapter.



20
21
22
23
24
25
26
 
# File 'lib/ask/coding_providers/claude/adapter.rb', line 20

def initialize(cli_path: "claude", cwd: ".", request_timeout: 120.0)
  @cli_path = cli_path
  @cwd = cwd
  @request_timeout = request_timeout
  @started = false
  @sessions = {}
end

Class Method Details

.from_config(workspace_path: Dir.pwd, cli_path: nil, request_timeout: 120) ⇒ Object 



151
152
153
 
# File 'lib/ask/coding_providers/claude/adapter.rb', line 151

def self.from_config(workspace_path: Dir.pwd, cli_path: nil, request_timeout: 120, **)
  new(cli_path: cli_path || "claude", cwd: workspace_path, request_timeout: request_timeout)
end

Instance Method Details

#create_session(workspace_path, mode: nil, system_prompt: nil) ⇒ Object 



41
42
43
44
45
46
 
# File 'lib/ask/coding_providers/claude/adapter.rb', line 41

def create_session(workspace_path, mode: nil, system_prompt: nil, **)
  ensure_started
  sid = "sess_#{SecureRandom.uuid}"
  @sessions[sid] = { workspace: workspace_path, mode: mode, created_at: Time.now }
  sid
end

#get_events(session_id, after_seq:, limit: nil) ⇒ Object 



140
141
142
 
# File 'lib/ask/coding_providers/claude/adapter.rb', line 140

def get_events(session_id, after_seq:, limit: nil)
  {}
end

#get_workspace_state(workspace_path) ⇒ Object 



147
148
149
 
# File 'lib/ask/coding_providers/claude/adapter.rb', line 147

def get_workspace_state(workspace_path)
  {}
end

#respond(request_id, result) ⇒ Object 



144
145
 
# File 'lib/ask/coding_providers/claude/adapter.rb', line 144

def respond(request_id, result)
end

#resume_session(session_id) ⇒ Object 



48
49
50
 
# File 'lib/ask/coding_providers/claude/adapter.rb', line 48

def resume_session(session_id)
  @sessions&.dig(session_id) || {}
end

#running? ⇒ Boolean

Returns:

  • (Boolean) 


37
38
39
 
# File 'lib/ask/coding_providers/claude/adapter.rb', line 37

def running?
  @started
end

#send_and_stream(session_id, content, turn_timeout: 600.0, &block) ⇒ Object 



61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
 
# File 'lib/ask/coding_providers/claude/adapter.rb', line 61

def send_and_stream(session_id, content, turn_timeout: 600.0, &block)
  return enum_for(:send_and_stream, session_id, content, turn_timeout: turn_timeout) unless block
  ensure_started

  block.call({ type: "turn.started", seq: 1, payload: { "sessionId" => session_id } })

  deadline = Time.now + (turn_timeout || @request_timeout)
  accumulated = ""

  begin
    stdin, stdout, stderr, wait_thr = Open3.popen3(
      @cli_path, "-p", content.to_s,
      "--verbose", "--output-format=stream-json",
      chdir: @cwd
    )
    stdin.close

    # Read JSON events from stdout
    stdout.each_line do |line|
      break if Time.now > deadline
      line = line.strip
      next if line.empty?

      begin
        event = JSON.parse(line)
      rescue JSON::ParserError
        next
      end

      case event["type"]
      when "assistant"
        msg = event["message"] || {}
        (msg["content"] || []).each do |content_block|
          if content_block["type"] == "text" && content_block["text"]
            delta = content_block["text"]
            accumulated += delta
            # NB: the inner loop variable must not shadow the
            # method's &block — block.call streams to the caller.
            block.call({
              type: "model.streaming", seq: 2,
              payload: { "delta" => delta, "sessionId" => session_id }
            })
          end
        end
      when "result"
        is_error = event["is_error"]
        if is_error
          err = event["result"] || "Claude error"
          block.call({
            type: "turn.failed", seq: 3,
            payload: { "error" => { "message" => err }, "sessionId" => session_id }
          })
        else
          block.call({
            type: "turn.completed", seq: 3,
            payload: { "response" => accumulated, "sessionId" => session_id }
          })
        end
      when "error"
        err_msg = event["message"] || event["error"] || "Claude error"
        block.call({
          type: "turn.failed", seq: 3,
          payload: { "error" => { "message" => err_msg }, "sessionId" => session_id }
        })
      end
    end

    stdout.close rescue nil
    stderr.close rescue nil
    wait_thr&.join(5)

  rescue => e
    block.call({
      type: "turn.failed", seq: 3,
      payload: { "error" => { "message" => e.message }, "sessionId" => session_id }
    })
  end
end

#send_message(session_id, content) ⇒ Object 



56
57
58
59
 
# File 'lib/ask/coding_providers/claude/adapter.rb', line 56

def send_message(session_id, content)
  ensure_started
  run_claude(content)
end

#start ⇒ Object 



28
29
30
 
# File 'lib/ask/coding_providers/claude/adapter.rb', line 28

def start
  @started = true
end

#stop ⇒ Object 



32
33
34
35
 
# File 'lib/ask/coding_providers/claude/adapter.rb', line 32

def stop
  @started = false
  @sessions = {}
end

#subscribe(session_id, after_seq: 0) ⇒ Object 



52
53
54
 
# File 'lib/ask/coding_providers/claude/adapter.rb', line 52

def subscribe(session_id, after_seq: 0)
  { "eventSeq" => 0 }
end