Module: Brainiac::Plugins::Fizzy::Helpers
- Defined in:
- lib/brainiac/plugins/fizzy/helpers.rb
Overview
Fizzy-specific helper functions. These were previously in lib/brainiac/helpers.rb in core.
Class Method Summary collapse
- .append_fizzy_comment_footer(card_number, project_config:, agent_name: nil) ⇒ Object
- .default_fizzy_env ⇒ Object
-
.detect_planning_mode(text:, tags:, card_internal_id:, card_number:) ⇒ Object
Determines whether a card should run in planning mode.
- .ensure_fizzy_yaml!(chdir, project_config) ⇒ Object
- .fetch_card_comments(card_number, repo_path:, env:) ⇒ Object
- .fetch_card_details(card_number, repo_path:, env:) ⇒ Object
-
.fetch_intent_context(card_number, repo_path:, agent_name: nil) ⇒ Object
Lightweight recent comment context for intent classification.
- .fizzy_env_for(agent_name) ⇒ Object
- .fizzy_token_for(agent_name) ⇒ Object
-
.lookup_fizzy_card_info(card_internal_id) ⇒ Object
Look up a Fizzy card's work item info by its internal ID.
- .move_card_to_column(card_number, column_name, project_config:, agent_name: nil) ⇒ Object
- .prefetch_card_context(card_number, repo_path:, agent_name: nil) ⇒ Object
-
.resolve_card_number(internal_id, repo_path:) ⇒ Object
Resolve a card number from an internal ID by querying the Fizzy API.
- .scrub_invalid_attachments!(dir) ⇒ Object
-
.update_fizzy_work_item(card_internal_id, updates) ⇒ Object
Update or create a work item entry for a Fizzy card.
-
.verify_signature!(request, payload_body, board_key: nil) ⇒ Object
Returns true if signature is valid (or no secret configured).
Class Method Details
.append_fizzy_comment_footer(card_number, project_config:, agent_name: nil) ⇒ Object
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 |
# File 'lib/brainiac/plugins/fizzy/helpers.rb', line 105 def (card_number, project_config:, agent_name: nil) repo_path = project_config["repo_path"] env = fizzy_env_for(agent_name || AI_AGENT_NAME) output = run_cmd("fizzy", "comment", "list", "--card", card_number.to_s, chdir: repo_path, env: env) comments = JSON.parse(output)["data"] || [] agent_display = agent_display_name(agent_name || AI_AGENT_NAME) last_agent_comment = comments.reverse.find do |c| c["creator_name"]&.downcase == agent_display.downcase end return unless last_agent_comment # Check if footer already exists body = last_agent_comment.dig("body", "html") || "" return if body.include?("<em>Branch:") # Detect branch from comment content or card map branch = detect_branch_from_comment(body, card_number) return unless branch pr_url = detect_pr_url(branch, project_config) = "<p><em>Branch: <code>#{branch}</code>" += " | <a href=\"#{pr_url}\">PR</a>" if pr_url += "</em></p>" updated_body = body + run_cmd("fizzy", "comment", "update", last_agent_comment["id"], "--card", card_number.to_s, "--body", updated_body, chdir: repo_path, env: env) rescue StandardError => e LOG.warn "[Fizzy] Could not append footer to card ##{card_number}: #{e.}" if defined?(LOG) end |
.default_fizzy_env ⇒ Object
32 33 34 |
# File 'lib/brainiac/plugins/fizzy/helpers.rb', line 32 def default_fizzy_env fizzy_env_for(AI_AGENT_NAME) end |
.detect_planning_mode(text:, tags:, card_internal_id:, card_number:) ⇒ Object
Determines whether a card should run in planning mode.
Returns nil if planning is not active, or { card_id:
164 165 166 167 168 169 |
# File 'lib/brainiac/plugins/fizzy/helpers.rb', line 164 def detect_planning_mode(text:, tags:, card_internal_id:, card_number:) tag_names = ( || []).map { |t| t.is_a?(Hash) ? t["name"] : t.to_s }.map(&:downcase) return nil unless tag_names.include?("plan") || tag_names.include?("planning") { card_id: card_number || card_internal_id } end |
.ensure_fizzy_yaml!(chdir, project_config) ⇒ Object
138 139 140 141 142 143 144 145 146 147 |
# File 'lib/brainiac/plugins/fizzy/helpers.rb', line 138 def ensure_fizzy_yaml!(chdir, project_config) fizzy_yaml_dest = File.join(chdir, ".fizzy.yaml") return if File.exist?(fizzy_yaml_dest) fizzy_yaml_src = File.join(project_config["repo_path"], ".fizzy.yaml") return unless File.exist?(fizzy_yaml_src) FileUtils.cp(fizzy_yaml_src, fizzy_yaml_dest) LOG.info "[Fizzy] Copied .fizzy.yaml to #{chdir}" if defined?(LOG) end |
.fetch_card_comments(card_number, repo_path:, env:) ⇒ Object
61 62 63 64 65 66 67 68 69 70 71 72 73 74 |
# File 'lib/brainiac/plugins/fizzy/helpers.rb', line 61 def fetch_card_comments(card_number, repo_path:, env:) output = run_cmd("fizzy", "comment", "list", "--card", card_number.to_s, chdir: repo_path, env: env) comments = JSON.parse(output)["data"] || [] return "" if comments.empty? comments.last(15).map do |c| body = c.dig("body", "plain_text") || "" body = "#{body[0..500]}..." if body.length > 500 "**#{c["creator_name"]}** (#{c["id"]}):\n#{body}" end.join("\n\n---\n\n") rescue StandardError => e LOG.warn "[Fizzy] Could not fetch comments for card ##{card_number}: #{e.}" if defined?(LOG) "" end |
.fetch_card_details(card_number, repo_path:, env:) ⇒ Object
47 48 49 50 51 52 53 54 55 56 57 58 59 |
# File 'lib/brainiac/plugins/fizzy/helpers.rb', line 47 def fetch_card_details(card_number, repo_path:, env:) output = run_cmd("fizzy", "card", "show", card_number.to_s, chdir: repo_path, env: env) card = JSON.parse(output)["data"] return "" unless card parts = [] parts << "**Title:** #{card["title"]}" parts << "**Body:**\n#{card.dig("body", "plain_text")}" if card.dig("body", "plain_text") parts.join("\n") rescue StandardError => e LOG.warn "[Fizzy] Could not fetch card ##{card_number}: #{e.}" if defined?(LOG) "" end |
.fetch_intent_context(card_number, repo_path:, agent_name: nil) ⇒ Object
Lightweight recent comment context for intent classification. Returns a simple "author: message" format (last 5 comments).
78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 |
# File 'lib/brainiac/plugins/fizzy/helpers.rb', line 78 def fetch_intent_context(card_number, repo_path:, agent_name: nil) env = fizzy_env_for(agent_name || AI_AGENT_NAME) output = run_cmd("fizzy", "comment", "list", "--card", card_number.to_s, chdir: repo_path, env: env) comments = JSON.parse(output)["data"] || [] return nil if comments.empty? comments.last(5).map do |c| creator = c["creator_name"] || "unknown" body = (c.dig("body", "plain_text") || "").lines.first(3).join.strip body = "#{body[0..200]}..." if body.length > 200 "#{creator}: #{body}" end.join("\n") rescue StandardError => e LOG.warn "[Fizzy] Could not fetch intent context for card ##{card_number}: #{e.}" if defined?(LOG) nil end |
.fizzy_env_for(agent_name) ⇒ Object
27 28 29 30 |
# File 'lib/brainiac/plugins/fizzy/helpers.rb', line 27 def fizzy_env_for(agent_name) token = fizzy_token_for(agent_name) || fizzy_token_for(AI_AGENT_NAME) token ? { "FIZZY_TOKEN" => token } : {} end |
.fizzy_token_for(agent_name) ⇒ Object
23 24 25 |
# File 'lib/brainiac/plugins/fizzy/helpers.rb', line 23 def fizzy_token_for(agent_name) agent_env_var(agent_name, "FIZZY_TOKEN") end |
.lookup_fizzy_card_info(card_internal_id) ⇒ Object
Look up a Fizzy card's work item info by its internal ID. Returns a hash with top-level "number", "agent", "branch", "worktree", "project" keys for backward compatibility with handler code, or nil if not found.
174 175 176 177 178 179 180 181 182 183 184 |
# File 'lib/brainiac/plugins/fizzy/helpers.rb', line 174 def lookup_fizzy_card_info(card_internal_id) return nil unless card_internal_id result = find_work_item_by_card(card_internal_id) return nil unless result _work_item_id, info = result # Ensure "number" is at top level for fizzy handler compat info["number"] ||= info.dig("sources", "fizzy", "card_number") info end |
.move_card_to_column(card_number, column_name, project_config:, agent_name: nil) ⇒ Object
95 96 97 98 99 100 101 102 103 |
# File 'lib/brainiac/plugins/fizzy/helpers.rb', line 95 def move_card_to_column(card_number, column_name, project_config:, agent_name: nil) board_key = Config.board_key_for_project(project_config) column_id = Config.board_column_id(board_key, column_name) if board_key return unless column_id repo_path = project_config["repo_path"] env = fizzy_env_for(agent_name || AI_AGENT_NAME) run_cmd("fizzy", "card", "column", card_number.to_s, "--column", column_id, chdir: repo_path, env: env) end |
.prefetch_card_context(card_number, repo_path:, agent_name: nil) ⇒ Object
36 37 38 39 40 41 42 43 44 45 |
# File 'lib/brainiac/plugins/fizzy/helpers.rb', line 36 def prefetch_card_context(card_number, repo_path:, agent_name: nil) env = fizzy_env_for(agent_name || AI_AGENT_NAME) card_details = fetch_card_details(card_number, repo_path: repo_path, env: env) card_comments = fetch_card_comments(card_number, repo_path: repo_path, env: env) context = "" context += "## Card Details\n#{card_details}\n\n" unless card_details.empty? context += "## Recent Comments\n#{card_comments}\n" unless card_comments.empty? context end |
.resolve_card_number(internal_id, repo_path:) ⇒ Object
Resolve a card number from an internal ID by querying the Fizzy API. Searches card lists to find the matching card.
236 237 238 239 240 241 242 243 244 245 246 247 248 249 250 251 252 253 254 |
# File 'lib/brainiac/plugins/fizzy/helpers.rb', line 236 def resolve_card_number(internal_id, repo_path:) env = default_fizzy_env base_cmd = %w[fizzy card list] ["--all", "--all --indexed-by closed"].each do |flags| cmd = base_cmd + flags.split output = run_cmd(*cmd, chdir: repo_path, env: env) data = JSON.parse(output)["data"] || [] match = data.find { |c| c["id"] == internal_id } if match LOG.info "Resolved card number #{match["number"]} for internal_id #{internal_id}" if defined?(LOG) return match["number"] end rescue StandardError next end LOG.warn "Could not resolve card number for internal_id #{internal_id}" if defined?(LOG) nil end |
.scrub_invalid_attachments!(dir) ⇒ Object
149 150 151 152 153 154 155 156 157 158 159 |
# File 'lib/brainiac/plugins/fizzy/helpers.rb', line 149 def (dir) = File.join(dir, ".fizzy-attachments") return unless Dir.exist?() Dir.glob(File.join(, "*")).each do |file| next unless File.file?(file) next if File.size(file) > 100 # Keep files with real content File.delete(file) end end |
.update_fizzy_work_item(card_internal_id, updates) ⇒ Object
Update or create a work item entry for a Fizzy card. Accepts a hash of fields to merge into the existing entry. Handles both new-format (wi-xxx keyed) and creates new entries properly.
189 190 191 192 193 194 195 196 197 198 199 200 201 202 203 204 205 206 207 208 209 210 211 212 213 214 215 216 217 218 219 220 221 222 223 224 225 226 227 228 229 230 231 232 |
# File 'lib/brainiac/plugins/fizzy/helpers.rb', line 189 def update_fizzy_work_item(card_internal_id, updates) return unless card_internal_id map = load_work_item_map result = nil work_item_id = nil # Find existing entry by card internal ID map.each do |wid, info| next unless info.is_a?(Hash) fizzy_source = info.dig("sources", "fizzy") next unless fizzy_source && fizzy_source["card_internal_id"] == card_internal_id work_item_id = wid result = info break end card_number = updates.delete("number") if result result["sources"]["fizzy"]["card_number"] = card_number if card_number result.merge!(updates) map[work_item_id] = result else new_id = generate_work_item_id(branch: updates["branch"], card_number: card_number) map[new_id] = { "id" => new_id, "branch" => updates["branch"], "worktree" => updates["worktree"], "project" => updates["project"], "agent" => updates["agent"], "sources" => { "fizzy" => { "card_internal_id" => card_internal_id, "card_number" => card_number }.compact } }.compact.merge(updates.except("branch", "worktree", "project", "agent")) end save_work_item_map(map) end |
.verify_signature!(request, payload_body, board_key: nil) ⇒ Object
Returns true if signature is valid (or no secret configured). Returns false if signature verification fails.
12 13 14 15 16 17 18 19 20 21 |
# File 'lib/brainiac/plugins/fizzy/helpers.rb', line 12 def verify_signature!(request, payload_body, board_key: nil) signature = request.env["HTTP_X_WEBHOOK_SIGNATURE"] return false unless signature secret = board_key ? Config.board_webhook_secret(board_key) : ENV.fetch("FIZZY_WEBHOOK_SECRET", nil) return false unless secret computed = OpenSSL::HMAC.hexdigest("sha256", secret, payload_body) Rack::Utils.secure_compare(signature, computed) end |