Add support for Jira and update BZ actions

Author: ShimShtein

Gemfile

@@ -4,3 +4,5 @@ gem 'faraday'
 gem 'awesome_print'
 gem 'activesupport'
 gem 'pry'
+gem 'jira-ruby'
+gem 'jsonrpc-client'

bugzilla.rb

@@ -19,14 +19,19 @@ def url
     "https://bugzilla.redhat.com/show_bug.cgi?id=#{id}"
   end
 
-  def self.set_options(options)
+  def self.set_options(options, config)
     @options = options
+    @config = config
   end
 
   def self.options
     @options
   end
 
+  def self.config
+    @config
+  end
+
   def self.load(url)
     attrs = bz_query(id: url.gsub(/.*?(\d+)$/, '\1')).first
     self.new(attrs)
@@ -37,8 +42,8 @@ def self.search(filters = {})
   end
 
   def self.bz_query(filters = {})
-    filters = filters.merge('api_key' => options['api_key']) if options['api_key']
-    conn = Faraday.new(:url => 'https://bugzilla.redhat.com') do |faraday|
+    filters = filters.merge('api_key' => config.api_key) if config.api_key
+    conn = Faraday.new(:url => config.url) do |faraday|
       faraday.request :url_encoded
       faraday.response :logger
       faraday.adapter Faraday.default_adapter
@@ -48,4 +53,67 @@ def self.bz_query(filters = {})
     response = conn.get('/rest/bug', filters)
     JSON.parse(response.body)['bugs']
   end
+
+  def self.get_issue(id)
+    jsonrpc.invoke('Bug.get',[{api_key: config.api_key, ids: [id.to_i], include_fields: [:external_bugs, :summary, :comments],}])
+  end
+
+  # tracker url is the full url e.g. https://projects.engineering.redhat.com/browse/TFMRHCLOUD-165
+  # tracker id is the short id as it appears in BZ. e.g. TFMRHCLOUD-165
+  def self.put_tracker(id, tracker_url, tracker_id)
+    return unless get_issue(id)['bugs'].first['external_bugs'].select { |link| link['ext_bz_bug_id'] == tracker_id }.empty?
+
+    jsonrpc.invoke(
+      'ExternalBugs.add_external_bug',
+      [{
+          api_key: config.api_key,
+          bug_ids: [id.to_i],
+          external_bugs: [
+            {
+              ext_bz_bug_url: tracker_url,
+            },
+          ],
+        }]
+    )
+  end
+
+  # known fields:
+  #   cf_fixed_in: version,
+  #   status: 'POST'
+  def self.set_fields(id, fields)
+    all_fields = fields.merge(
+      api_key: config.api_key,
+    )
+    bz_api['bug']["#{id}"].put(all_fields)
+  end
+
+  def bugzilla_url(bz_id)
+    "#{config.url}/show_bug.cgi?id=#{bz_id}"
+  end
+
+  private
+
+  def self.bz_api
+    RestClient::Resource.new(config.url + '/rest', params: {api_key: config.api_key})
+  end
+
+  def self.jsonrpc
+    @jsonrpc ||= begin
+      conn = Faraday.new(url: config.url + '/jsonrpc.cgi') do |faraday|
+        faraday.response :logger, nil, { headers: true, bodies: true }
+      end
+
+      JsonRpcClient.new(config.url + '/jsonrpc.cgi', { connection: conn})
+    end
+  end
+
+  # Need to monkey-patch valid_response? because it has a strict JSONRPC version check
+  # https://github.com/fxposter/jsonrpc-client/blob/287f6d2418f9a67064ebff2417c281db2c3a17c8/lib/jsonrpc/client.rb#L194
+  class JsonRpcClient < JSONRPC::Client
+    private
+    def valid_response?(data)
+      return true
+    end
+  end
+
 end

jira.rb

@@ -0,0 +1,59 @@
+require 'jira-ruby'
+
+class Jira
+  def self.set_config(config)
+    @config = config
+  end
+
+  def self.issue(id)
+    api.Issue.find(id)
+  end
+
+  def self.issue_url(issue_id)
+    "#{config.site}/browse/#{issue_id}"
+  end
+
+  def self.update_summary(issue, summary)
+    issue.save({'fields' => { 'summary' => summary}})
+  end
+
+  def self.add_remote_link(issue, label, url)
+    return if issue.remotelink.all.find { |link| link.attrs.dig('object', 'title') }
+    link = issue.remotelink.build
+
+    link.save(
+      object: {
+        url: url,
+        title: label
+      }
+    )
+  end
+
+  def self.active_sprints
+    api.Agile.get_sprints(config.board, state: 'active')
+  end
+
+  def self.find_sprint(id)
+    api.Sprint.find(id)
+  end
+
+  private
+
+  def self.api
+    @client ||= JIRA::Client.new({
+      username: config.user,
+      password: config.password,
+      site: config.site,
+      context_path: '',
+      auth_type: :basic,
+    })
+  end
+
+  def self.config
+    @config
+  end
+
+  def self.project(id)
+    api.Project.find(id)
+  end
+end

kansync.rb

@@ -57,14 +57,19 @@ def self.prepare_kanboard_connection(connection_options)
     @kanboard_connection = RequestFactory.new(connection_options)
   end
 
-  def self.prepare_bz_connection(connection_options)
-    Bugzilla.set_options(connection_options)
+  def self.prepare_bz_connection(profile)
+    Bugzilla.set_options(profile.bugzilla_options, profile.bugzilla_config)
+  end
+
+  def self.prepare_jira_connection(profile)
+    Jira.set_config(profile.jira_config)
   end
 
   def self.setup(profile)
     prepare_logger(profile.logger_level)
     prepare_kanboard_connection(profile.kanboard_options)
-    prepare_bz_connection(profile.bugzilla_options)
+    prepare_bz_connection(profile)
+    prepare_jira_connection(profile)
   end
 end
 
@@ -108,5 +113,3 @@ def execute
 # TODO need a separate script to help with new iteration setup
 # TODO scripts may need custom configuration per profile, e.g. email mapping
 # TODO README with links to APIs, docker image, sql converting trick
-
-

profile.rb

@@ -1,7 +1,7 @@
 class Profile
   attr_accessor :project_id, :kanboard_options, :logger_level, :task_configuration,
                 :whitelist, :blacklist, :github_options, :bugzilla_options,
-                :backlog_swimlane_name
+                :backlog_swimlane_name, :bugzilla_config, :jira_config
 
   def initialize(profile_file)
     @profile_file = profile_file
@@ -25,6 +25,51 @@ def initialize_vars
     @blacklist = @data['blacklist']
     @github_options = @data['github']
     @bugzilla_options = @data['bugzilla']
+    @bugzilla_config = Bugzilla.new(@data['bugzilla'])
+    @jira_config = Jira.new(@data['jira'])
+  end
+
+  class Bugzilla
+    def initialize(yaml)
+      @yaml = yaml
+    end
+
+    def api_key
+      @yaml['api_key']
+    end
+
+    def username
+      @yaml['user']
+    end
+
+    def password
+      @yaml['password']
+    end
+
+    def url
+      @yaml['url'] || 'https://bugzilla.redhat.com'
+    end
   end
-end
 
+  class Jira
+    def initialize(yaml)
+      @yaml = yaml
+    end
+
+    def user
+      @yaml['user']
+    end
+
+    def password
+      @yaml['password']
+    end
+
+    def site
+      @yaml['site'] || 'https://projects.engineering.redhat.com'
+    end
+
+    def board
+      @yaml['board']
+    end
+  end
+end