'first'

Author: Komatsu Yuji(小松 裕二)

Gemfile

@@ -0,0 +1 @@
+gem "httpclient"

README.rdoc

@@ -0,0 +1,3 @@
+= redmine_hangouts_chat_integration
+
+Description goes here

app/views/settings/_hangouts_chat_integration_settings.html.erb

@@ -0,0 +1,10 @@
+<table>
+  <tbody>
+    <tr>
+      <th>Webhook</th>
+      <td>
+        <input type="text" id="settings_hangouts_chat_webhook" value="<%= settings['hangouts_chat_webhook'] %>" name="settings[hangouts_chat_webhook]" size=120 >
+      </td>
+    </tr>
+  </tbody>
+</table>

config/locales/en.yml

@@ -0,0 +1,3 @@
+# English strings go here for Rails i18n
+en:
+  # my_label: "My label"

config/routes.rb

@@ -0,0 +1,2 @@
+# Plugin's routes
+# See: http://guides.rubyonrails.org/routing.html

db/migrate/20170419144536__populate_custom_fields.rb

@@ -0,0 +1,26 @@
+class PopulateCustomFields < ActiveRecord::Migration
+
+################################################################################
+## Create custom field
+################################################################################
+  def self.up
+    if ProjectCustomField.find_by_name('Hangouts Chat Webhook').nil?
+      ProjectCustomField.create(name: 'Hangouts Chat Webhook', field_format: 'string', visible: 0, default_value: '')
+    end
+    if UserCustomField.find_by_name('Hangouts Chat Disabled').nil?
+      UserCustomField.create(name: 'Hangouts Chat Disabled', field_format: 'bool', visible: 0, default_value: 0, is_required: 1)
+    end
+  end
+
+################################################################################
+## Delete custom field
+################################################################################
+  def self.down
+    unless ProjectCustomField.find_by_name('Hangouts Chat Webhook').nil?
+      ProjectCustomField.find_by_name('Hangouts Chat Webhook').delete
+    end
+    unless UserCustomField.find_by_name('Hangouts Chat Disabled').nil?
+      UserCustomField.find_by_name('Hangouts Chat Disabled').delete
+    end
+  end
+end

init.rb

@@ -0,0 +1,17 @@
+require_dependency 'redmine_hangouts_chat_integration/hooks'
+require_dependency 'redmine_hangouts_chat_integration/issue_relations_controller_patch'
+
+################################################################################
+## Register Plugin
+################################################################################
+Redmine::Plugin.register :redmine_hangouts_chat_integration do
+  name 'Redmine Hangouts Chat Integration plugin'
+  author 'Komatsu Yuji'
+  description 'This is a plugin for Redmine Google Hangouts Chat Integration'
+  version '0.0.4'
+  url 'https://www.future.co.jp/'
+  author_url 'https://www.future.co.jp/'
+
+  settings :default => {}, :partial => 'settings/hangouts_chat_integration_settings'
+
+end

lib/redmine_hangouts_chat_integration/hooks.rb

@@ -0,0 +1,242 @@
+require 'httpclient'
+
+module RedmineHangoutsChatIntegration
+  class Hooks < Redmine::Hook::ViewListener
+    include ApplicationHelper
+    include CustomFieldsHelper
+    include IssuesHelper
+
+################################################################################
+## Hook for issues_new_after_save
+################################################################################
+    def controller_issues_new_after_save(context={})
+      ## check user
+      return if is_disabled(User.current) 
+
+      ## Get issue
+      issue = context[:issue]
+
+      ## Is private issue
+      return if issue.is_private
+
+      ## Get issue URL
+      issue_url = get_object_url(issue)
+
+      ## Get Webhook URL
+      webhook_url = get_webhook_url(issue.project)
+      return if webhook_url.nil?
+
+      ## Make Webhook Thread URL
+      thread_key = Digest::MD5.hexdigest(issue_url)
+      thread_url = webhook_url + "&thread_key=" + thread_key
+      return unless thread_url =~ URI::regexp
+
+      ## webhook data
+      data = {}
+
+      ## Add issue updated_on
+      data['text'] = "*#{l(:field_updated_on)}:#{issue.updated_on}*"
+
+      ## Add issue subject
+      subject = issue.subject.gsub(/[　|\s|]+$/, "")
+      data['text'] = data['text'] + "\n*#{l(:field_subject)}:<#{issue_url}|[#{issue.project.name} - #{issue.tracker.name} ##{issue.id}] #{subject}>*"
+
+      ## Add issue URL
+      data['text'] = data['text'] + "\n*URL:* #{issue_url}"
+
+      ## Add issue author
+      data['text'] = data['text'] + "\n```" + l(:text_issue_added, :id => "##{issue.id}", :author => issue.author)
+
+      ## Add issue attributes
+      data['text'] = data['text'] + "\n#{''.ljust(37, '-')}\n" + render_email_issue_attributes(issue, User.current)
+      
+      ## Add issue descripption
+      unless issue.description.blank?
+        data['text'] = data['text'] + "\n#{''.ljust(37, '-')}\n#{issue.description}"
+      end
+
+      ## Add issue attachments
+      if issue.attachments.any?
+        data['text'] = data['text'] + "\n\n#{l(:label_attachment_plural).ljust(37, '-')}"
+        issue.attachments.each do |attachment|
+           data['text'] = data['text'] + "\n#{attachment.filename} #{number_to_human_size(attachment.filesize)}"
+        end
+      end
+
+      ## Add ```
+      data['text'] = data['text'] + "\n```"
+
+      ## Send webhook data
+      send_webhook_data(thread_url, data)
+    end
+
+################################################################################
+## Hook for controller_issues_edit_after_save
+################################################################################
+    def controller_issues_edit_after_save(context={})
+      ## check user
+      return if is_disabled(User.current) 
+
+      ## Get issue and journal
+      issue = context[:issue]
+      journal = context[:journal]
+
+      ## Is private issue
+      return if issue.is_private
+      return if journal.private_notes
+
+      ## Get issue URL
+      issue_url = get_object_url(issue)
+
+      ## Get Webhook URL
+      webhook_url = get_webhook_url(issue.project)
+      return if webhook_url.nil?
+
+      ## Make Webhook Thread URL
+      thread_key = Digest::MD5.hexdigest(issue_url)
+      thread_url = webhook_url + "&thread_key=" + thread_key
+      return unless thread_url =~ URI::regexp
+
+      ## webhook data
+      data = {}
+
+      ## Add issue updated_on
+      data['text'] = "*#{l(:field_updated_on)}:#{issue.updated_on}*"
+
+      ## Add issue subject
+      subject = issue.subject.gsub(/[　|\s|]+$/, "")
+      data['text'] = data['text'] + "\n*#{l(:field_subject)}:<#{issue_url}|[#{issue.project.name} - #{issue.tracker.name} ##{issue.id}] #{subject}>*"
+
+      ## Add issue URL
+      data['text'] = data['text'] + "\n*URL:* #{issue_url}"
+
+      ## Add issue author
+      data['text'] = data['text'] + "\n```" + l(:text_issue_updated, :id => "##{issue.id}", :author => journal.user)
+
+      ## Add issue details
+      details = details_to_strings(journal.visible_details, true).join("\n")
+      unless details.blank?
+        data['text'] = data['text'] + "\n#{''.ljust(37, '-')}\n#{details}"
+      end
+
+      ## Add issue notes
+      unless issue.notes.blank?
+        data['text'] = data['text'] + "\n#{''.ljust(37, '-')}\n#{issue.notes}"
+      end
+
+      ## Add ```
+      data['text'] = data['text'] + "\n```"
+
+      ## Don't send empty data
+      return if details.blank? && issue.notes.blank?
+
+      ## Send webhook data
+      send_webhook_data(thread_url, data)
+    end
+
+################################################################################
+## Hook for controller_issue_relations_new_after_save
+################################################################################
+    def controller_issue_relations_new_after_save(context={})
+      call_hook(:controller_issues_edit_after_save, context)
+    end
+
+################################################################################
+## Hook for controller_issue_relations_move_after_save
+################################################################################
+    def controller_issue_relations_move_after_save(context={})
+      call_hook(:controller_issues_edit_after_save, context)
+    end
+
+################################################################################
+## Private Method
+################################################################################
+private
+
+################################################################################
+## Get Redmine Object URL
+################################################################################
+    def get_object_url(obj)
+      routes = Rails.application.routes.url_helpers
+      if Setting.host_name.to_s =~ /\A(https?\:\/\/)?(.+?)(\:(\d+))?(\/.+)?\z/i
+        host, port, prefix = $2, $4, $5
+        routes.url_for(obj.event_url({
+          :host => host,
+          :protocol => Setting.protocol,
+          :port => port,
+          :script_name => prefix
+        }))
+      else
+        routes.url_for(obj.event_url({
+          :host => Setting.host_name,
+          :protocol => Setting.protocol
+        }))
+      end
+    end
+
+################################################################################
+## Is Hangouts Chat Disabled
+################################################################################
+    def is_disabled(user)
+      ## check user
+      return true if user.nil?
+      
+      ## check user custom field
+      user_cf = UserCustomField.find_by_name("Hangouts Chat Disabled")
+      return true if user_cf.nil?
+
+      ## check user custom value
+      user_cv = user.custom_value_for(user_cf)
+
+      ## user_cv is null
+      return false if user_cv.nil?
+
+      return false if user_cv.value == '0'
+
+      return true
+    end
+
+################################################################################
+## Get Hangouts Chat Webhook URL
+################################################################################
+    def get_webhook_url(proj)
+      ## used value from this plugin's setting
+      if proj.nil?
+        return Setting.plugin_redmine_hangouts_chat_integration['hangouts_chat_webhook']
+      end
+
+      ## used value from this project's custom field
+      proj_cf = ProjectCustomField.find_by_name("Hangouts Chat Webhook")
+      unless proj_cf.nil?
+        proj_cv = proj.custom_value_for(proj_cf)
+        unless proj_cv.nil?
+          url = proj_cv.value
+          return url if url =~ URI::regexp
+        end
+      end
+
+      ## used value from parent project's custom field
+      return get_webhook_url(proj.parent)
+    end
+
+################################################################################
+## Send data to Hangouts Chat
+################################################################################
+    def send_webhook_data(url, data)
+      Rails.logger.debug("Webhook URL: #{url}")
+      Rails.logger.debug("Webhook Data: #{data.to_json}")
+
+      ## Send data
+      begin
+        https_proxy = ENV['https_proxy'] || ENV['HTTPS_PROXY']
+        client = HTTPClient.new(https_proxy)
+        client.ssl_config.cert_store.set_default_paths
+        client.ssl_config.ssl_version = :auto
+        client.post_async url, {:body => data.to_json, :header => {'Content-Type' => 'application/json'}}
+      rescue Exception => e
+        Rails.logger.warn("cannot connect to #{url}")
+        Rails.logger.warn(e)
+      end
+    end
+  end
+end

lib/redmine_hangouts_chat_integration/issue_relations_controller_patch.rb

@@ -0,0 +1,62 @@
+module RedmineHangoutsChatIntegration
+
+################################################################################
+## Expand IssueRelationsController
+################################################################################
+  module IssueRelationsControllerPatch
+    def self.included(base)
+      base.send(:include, InstanceMethods)
+      ## Same as typing in the class
+      base.class_eval do
+        unloadable
+        after_filter :after_action_create, :only => :create
+        after_filter :after_action_destroy, :only => :destroy
+      end
+    end
+
+################################################################################
+## Expand InstanceMethods
+################################################################################
+    module InstanceMethods
+
+################################################################################
+## Call a action after issue_relation is created
+################################################################################
+      def after_action_create
+        return if @relation.nil?
+        return if @relation.id.nil?
+        return if @issue.nil?
+
+        call_hook(:controller_issue_relations_new_after_save, { :params => params, :issue => @issue, :journal => @issue.current_journal })
+      end
+
+################################################################################
+## Call a action after issue_relation is destroied
+################################################################################
+      def after_action_destroy
+        return if @relation.nil?
+        return if @relation.id.nil?
+
+        issue_relation = nil
+        begin
+          issue_relation = IssueRelation.find(@relation.id)
+        rescue ActiveRecord::RecordNotFound
+          issue_relation = nil
+        end
+        return unless issue_relation.nil?
+
+        issue_from = @relation.issue_from
+        issue_to = @relation.issue_to
+
+        call_hook(:controller_issue_relations_move_after_save, { :params => params, :issue => issue_from, :journal => issue_from.current_journal })
+        call_hook(:controller_issue_relations_move_after_save, { :params => params, :issue => issue_to, :journal => issue_to.current_journal })
+      end
+
+    end
+  end
+end
+
+################################################################################
+## Include IssueRelationsController
+################################################################################
+IssueRelationsController.send(:include, RedmineHangoutsChatIntegration::IssueRelationsControllerPatch)

test/test_helper.rb

@@ -0,0 +1,2 @@
+# Load the Redmine helper
+require File.expand_path(File.dirname(__FILE__) + '/../../../test/test_helper')