Use custom Slack client to avoid SSL issues with the previous one.

Author: dysk

app/controllers/games_controller.rb

@@ -1,3 +1,5 @@
+require 'custom_slack_client'
+
 class GamesController < ApplicationController
   skip_before_action :verify_authenticity_token, only: [:say]
   http_basic_authenticate_with name: "", password: Rails.application.secrets.say_password, except: :show
@@ -26,9 +28,12 @@ def say
     text = params[:text]
     game_id = params[:game_id]
     game = ReadModel::GameReadModel.find_by(id: game_id)
-    client = Slack::Web::Client.new(token: game.slack_token)
     begin
-      client.chat_postMessage(channel: game.slack_channel, text: text)
+      CustomSlackClient.post_message(
+        channel: game.slack_channel,
+        text: text,
+        token: game.slack_token
+      )
     rescue => e
       puts(e.inspect)
     end

lib/custom_slack_client.rb

@@ -0,0 +1,30 @@
+require 'faraday'
+require 'faraday/net_http_persistent'
+
+class CustomSlackClient
+  CONNECTION = Faraday.new(
+    url: 'https://slack.com',
+    headers: { 'Content-Type' => 'application/json' }
+  ) do |faraday|
+    faraday.adapter :net_http_persistent
+  end
+
+  def self.post_message(channel:, text:, token:)
+    response = CONNECTION.post('/api/chat.postMessage') do |req|
+      req.headers['Authorization'] = "Bearer #{token}"
+      req.headers['Accept'] = "application/json; charset=utf-8"
+      req.headers['Content-Type'] = "application/json"
+      req.body = {
+        channel: channel,
+        text: text
+      }.to_json
+    end
+
+    body = JSON.parse(response.body)
+    unless body['ok']
+      Rails.logger.error "Error posting to Slack: #{body['error']}"
+    end
+    
+    response
+  end
+end

notifications/lib/notifications/slack_notifier.rb

@@ -1,3 +1,5 @@
+require 'custom_slack_client'
+
 module Notifications
   class SlackNotifier
     def initialize(logger: nil, event_store:)
@@ -23,10 +25,10 @@ def call(event)
     def new_turn_notification(event)
       game = ReadModel::GameReadModel.find_by(id: event.data[:game_id])
       return unless game && game.slack_token
-      client = Slack::Web::Client.new(token: game.slack_token)
-      client.chat_postMessage(
+      CustomSlackClient.post_message(
         channel: game.slack_channel,
         text: game.build_slack_new_turn_message(event.data),
+        token: game.slack_token
       )
     end
 
@@ -37,13 +39,11 @@ def maybe_notify_remaining_players(event)
       if current_turn.unfinished_player_ids.size <= game.number_of_remaining_players_to_notify
         remaining_players_mentions =
           Player.where(id: current_turn.unfinished_player_ids).map { |player| "<@#{player.slack_id}>" }.join(" ")
-        client = Slack::Web::Client.new(token: game.slack_token)
-        response =
-          client.chat_postMessage(
-            channel: game.slack_channel,
-            text: "Turn " + remaining_players_mentions,
-          )
-        logger.warn("Slack response: #{response.pretty_inspect}") if logger
+        CustomSlackClient.post_message(
+          channel: game.slack_channel,
+          text: "Turn " + remaining_players_mentions,
+          token: game.slack_token
+        )
       end
     end
 

notifications/spec/notifications/slack_notifier_spec.rb

@@ -54,7 +54,7 @@ def given(*domain_events)
             "Authorization" => "Bearer xoxb-302139800755-nR1O848GLyVS5ZfNNMpBLm0b",
             "Accept" => "application/json; charset=utf-8",
             "Accept-Encoding" => "gzip;q=1.0,deflate;q=0.6,identity;q=0.3",
-            "Content-Type" => "application/x-www-form-urlencoded"
+            "Content-Type" => "application/json"
           }
         )
         .to_return(status: 200, body: {ok: true}.to_json, headers: {})
@@ -76,7 +76,7 @@ def given(*domain_events)
             "Authorization" => "Bearer xoxb-302139800755-nR1O848GLyVS5ZfNNMpBLm0b",
             "Accept" => "application/json; charset=utf-8",
             "Accept-Encoding" => "gzip;q=1.0,deflate;q=0.6,identity;q=0.3",
-            "Content-Type" => "application/x-www-form-urlencoded"
+            "Content-Type" => "application/json"
           }
         )
         .to_return(status: 200, body: {ok: true}.to_json, headers: {})
@@ -119,7 +119,7 @@ def given(*domain_events)
             "Authorization" => "Bearer xoxb-302139800755-nR1O848GLyVS5ZfNNMpBLm0b",
             "Accept" => "application/json; charset=utf-8",
             "Accept-Encoding" => "gzip;q=1.0,deflate;q=0.6,identity;q=0.3",
-            "Content-Type" => "application/x-www-form-urlencoded"
+            "Content-Type" => "application/json"
           }
         )
         .to_return(status: 200, body: {ok: true}.to_json, headers: {})
@@ -134,7 +134,7 @@ def given(*domain_events)
             "Authorization" => "Bearer xoxb-302139800755-nR1O848GLyVS5ZfNNMpBLm0b",
             "Accept" => "application/json; charset=utf-8",
             "Accept-Encoding" => "gzip;q=1.0,deflate;q=0.6,identity;q=0.3",
-            "Content-Type" => "application/x-www-form-urlencoded"
+            "Content-Type" => "application/json"
           }
         )
         .to_return(status: 200, body: {ok: true}.to_json, headers: {})