Upstream vs rOpenSci

Gemfile.lock

@@ -3,6 +3,10 @@ GEM
   specs:
     addressable (2.8.7)
       public_suffix (>= 2.0.2, < 7.0)
+    airrecord (1.0.12)
+      faraday (>= 1.0, < 3.0)
+      faraday-net_http_persistent
+      net-http-persistent
     base64 (0.2.0)
     bibtex-ruby (6.1.0)
       latex-decode (~> 0.0)
@@ -26,6 +30,9 @@ GEM
       faraday (>= 2, < 3)
     faraday-net_http (3.3.0)
       net-http
+    faraday-net_http_persistent (2.1.0)
+      faraday (~> 2.5)
+      net-http-persistent (~> 4.0)
     faraday-retry (2.2.1)
       faraday (~> 2.0)
     github-linguist (8.0.1)
@@ -53,6 +60,8 @@ GEM
       ruby2_keywords (~> 0.0.1)
     net-http (0.4.1)
       uri
+    net-http-persistent (4.0.2)
+      connection_pool (~> 2.2)
     nio4r (2.7.3)
     nokogiri (1.16.7)
       mini_portile2 (~> 2.8.2)
@@ -132,6 +141,7 @@ PLATFORMS
   ruby
 
 DEPENDENCIES
+  airrecord
   bibtex-ruby
   chronic
   faraday
@@ -151,5 +161,8 @@ DEPENDENCIES
   sinatra-contrib (= 4.0.0)
   webmock
 
+RUBY VERSION
+   ruby 3.3.3p89
+
 BUNDLED WITH
    2.5.14

Gemfile_custom

@@ -1,3 +1,5 @@
 # This is a Gemfile to add extra dependencies
 # needed for custom responders or workers.
 # Override and add customized gems in this file.
+
+gem 'airrecord'

app/lib/workers.rb

@@ -1,4 +1,17 @@
 require 'sidekiq'
 
+Sidekiq.configure_server do |config|
+  config.redis = {
+    url: ENV["REDIS_URL"],
+    ssl_params: { verify_mode: OpenSSL::SSL::VERIFY_NONE }
+  }
+end
+Sidekiq.configure_client do |config|
+  config.redis = {
+      url: ENV["REDIS_URL"],
+      ssl_params: { verify_mode: OpenSSL::SSL::VERIFY_NONE }
+  }
+end
+
 require "#{File.expand_path '../..', __FILE__}/workers/buffy_worker.rb"
 Dir["#{File.expand_path '../..', __FILE__}/workers/**/*.rb"].sort.each { |f| require f }

app/responders/ropensci/approve_responder.rb

@@ -0,0 +1,60 @@
+require_relative '../../lib/responder'
+
+module Ropensci
+  class ApproveResponder < Responder
+
+    keyname :ropensci_approve
+
+    def define_listening
+      @event_action = "issue_comment.created"
+      @event_regex = /\A@#{bot_name} approve( [ \w-]+)?\.?\s*\z/i
+    end
+
+    def process_message(message)
+      return unless verify_package_name
+      return unless verify_submission_type
+
+      update_or_add_value("date-accepted", Time.now.strftime("%Y-%m-%d"), append: false, heading: "Date accepted")
+      respond_external_template(params[:template_file], locals) if params[:template_file]
+      Ropensci::AirtableWorker.perform_async("clear_assignments", serializable(params), serializable(locals), { "reviewers" => list_of_reviewers })
+      Ropensci::ApprovedPackageWorker.perform_async("new_team", serializable(params), serializable(locals), { "team_name" => @package_name })
+      process_labeling
+      close_issue
+    end
+
+    def verify_package_name
+      @package_name = match_data[1].to_s.strip
+      if @package_name.empty?
+        respond("Could not approve. Please, specify the name of the package.")
+        return false
+      end
+      true
+    end
+
+    def verify_submission_type
+      submission_type = read_value_from_body("submission-type").downcase
+      if submission_type == "stats"
+        statsgrade = read_value_from_body("statsgrade").downcase
+        if ["bronze", "silver", "gold"].include?(statsgrade)
+          Ropensci::StatsGradesWorker.perform_async("label", serializable(locals), { "stats_badge_url" => params[:stats_badge_url] })
+        else
+          respond("Please add a grade (#{Ropensci::MintResponder::VALID_METAL_VALUES.join("/")}) before approval.")
+          return false
+        end
+      end
+      true
+    end
+
+    def list_of_reviewers
+      @list_of_reviewers ||= read_value_from_body("reviewers-list").split(",").map(&:strip)
+    end
+
+    def default_description
+      "Approves a package. This command will close the issue."
+    end
+
+    def default_example_invocation
+      "@#{@bot_name} approve package-name"
+    end
+  end
+end

app/responders/ropensci/finalize_transfer_responder.rb

@@ -0,0 +1,39 @@
+module Ropensci
+  class FinalizeTransferResponder < Responder
+
+    keyname :ropensci_finalize_transfer
+
+    def define_listening
+      @event_action = "issue_comment.created"
+      @event_regex = /\A@#{bot_name} (finalize|finalise) transfer of ([\/\w-]+)?\.?\s*\z/i
+    end
+
+    def process_message(message)
+      return unless verify_package
+      Ropensci::ApprovedPackageWorker.perform_async("finalize_transfer", serializable(params), serializable(locals), serializable({ package_name: @package_name, package_author: @package_author }))
+    end
+
+    def verify_package
+      @package_name = match_data[2].to_s.strip
+      if @package_name.empty?
+        respond("Could not finalize transfer: Please, specify the name of the package (should match the name of the team at the rOpenSci org)")
+        return false
+      end
+
+      @package_author = context.issue_author.to_s.strip
+      if @package_author.empty?
+        respond("Could not finalize transfer: Could not identify package author")
+        return false
+      end
+      true
+    end
+
+    def default_description
+      "Adds package's repo to the rOpenSci team. This command should be issued after approval and transfer of the package."
+    end
+
+    def default_example_invocation
+      "@#{@bot_name} finalize transfer of package-name"
+    end
+  end
+end

app/responders/ropensci/invite_package_author_responder.rb

@@ -0,0 +1,39 @@
+module Ropensci
+  class InvitePackageAuthorResponder < Responder
+
+    keyname :ropensci_invite_author
+
+    def define_listening
+      @event_action = "issue_comment.created"
+      @event_regex = /\A@#{bot_name} invite me to ([\/\w-]+)?\.?\s*\z/i
+    end
+
+    def process_message(message)
+      return unless verify_package
+      Ropensci::ApprovedPackageWorker.perform_async("invite_author_to_transfered_repo", serializable(params), serializable(locals), serializable({ package_name: @package_name, package_author: @package_author }))
+    end
+
+    def verify_package
+      @package_name = match_data[1].to_s.strip
+      if @package_name.empty?
+        respond("Could not invite: Please, specify the name of the team (should match the name of the package at the rOpenSci org)")
+        return false
+      end
+
+      @package_author = context.issue_author.to_s.strip
+      if @package_author != context.sender.to_s.strip
+        respond("Could not invite, you are not the author of the package")
+        return false
+      end
+      true
+    end
+
+    def default_description
+      "Invite the author of a package to the corresponding rOpenSci team. This command should be issued by the author of the package."
+    end
+
+    def default_example_invocation
+      "@#{@bot_name} invite me to ropensci/package-name"
+    end
+  end
+end

app/responders/ropensci/mint_responder.rb

@@ -0,0 +1,46 @@
+require_relative '../../lib/responder'
+
+module Ropensci
+  class MintResponder < Responder
+
+    keyname :ropensci_mint
+
+    VALID_METAL_VALUES = %w(bronze silver gold)
+    VALID_SUBMISSION_TYPES = %w(stats)
+
+    def define_listening
+      @event_action = "issue_comment.created"
+      @event_regex = /\A@#{bot_name} mint( [ \w-]+)?\.?\s*\z/i
+    end
+
+    def process_message(message)
+      if valid_metal? && valid_submission_type?
+          update_or_add_value("statsgrade", @metal, append: false, heading: "Badge grade")
+          respond("Done, #{@metal} minted!")
+          process_labeling
+      else
+        respond(@error_reply)
+      end
+    end
+
+    def valid_metal?
+      @error_reply = "Couldn't mint. Please provide a valid value (#{VALID_METAL_VALUES.join('/')})."
+      @metal = @match_data[1].to_s.strip.downcase
+      VALID_METAL_VALUES.include?(@metal)
+    end
+
+    def valid_submission_type?
+      @error_reply = "Only submissions type: #{VALID_SUBMISSION_TYPES.join('/')} can be minted"
+      submission_type = read_value_from_body("submission-type").downcase
+      VALID_SUBMISSION_TYPES.include?(submission_type)
+    end
+
+    def default_description
+      "Mint package as [#{VALID_METAL_VALUES.join("/")}]"
+    end
+
+    def default_example_invocation
+      "@#{bot_name} mint silver"
+    end
+  end
+end

app/responders/ropensci/on_hold_responder.rb

@@ -0,0 +1,43 @@
+require_relative '../../lib/responder'
+
+module Ropensci
+  class OnHoldResponder < Responder
+
+    keyname :ropensci_on_hold
+
+    def define_listening
+      @event_action = "issue_comment.created"
+      @event_regex = /\A@#{bot_name} put on hold\.?\s*\z/i
+    end
+
+    def process_message(message)
+      label_issue([on_hold_label])
+      Ropensci::OnHoldReminderWorker.perform_at(reminder_at, serializable(locals), {"on_hold_label" => on_hold_label})
+      respond("Submission on hold!")
+    end
+
+    def on_hold_label
+      params[:on_hold_label] || "holding"
+    end
+
+    def on_hold_days
+      if params[:on_hold_days]
+        params[:on_hold_days].to_i
+      else
+        90
+      end
+    end
+
+    def reminder_at
+      Time.now + (on_hold_days * 86400)
+    end
+
+    def default_description
+      "Put the submission on hold for the next #{on_hold_days} days"
+    end
+
+    def default_example_invocation
+      "@#{bot_name} put on hold"
+    end
+  end
+end