validate live events credentials and stream name

Change-Id: I632d8d70da512f4e2580e40f3b0cf6347d30f4cf
Reviewed-on: https://gerrit.instructure.com/94090
Tested-by: Jenkins
Reviewed-by: Simon Williams <simon@instructure.com>
Product-Review: Cody Cutrer <cody@instructure.com>
QA-Review: Cody Cutrer <cody@instructure.com>

Author: ccutrer

gems/live_events/lib/live_events/client.rb

@@ -55,6 +55,13 @@ def self.aws_config(plugin_config)
       aws
     end
 
+    def valid?
+      @kinesis.describe_stream(stream_name: @stream_name, limit: 1)
+      true
+    rescue Aws::Kinesis::Errors::ServiceError
+      false
+    end
+
     def post_event(event_name, payload, time = Time.now, ctx = {}, partition_key = nil)
       statsd_prefix = "live_events.events.#{event_name}"
 

lib/canvas/plugins/validators/live_events_validator.rb

@@ -16,6 +16,8 @@
 # with this program. If not, see <http://www.gnu.org/licenses/>.
 #
 
+require 'aws-sdk'
+
 module Canvas::Plugins::Validators::LiveEventsValidator
   def self.validate(settings, plugin_setting)
     if settings.map(&:last).all?(&:blank?)
@@ -45,11 +47,17 @@ def self.validate(settings, plugin_setting)
         err = true
       end
 
-      if err
+      return false if err
+
+      settings = settings.slice(:kinesis_stream_name, :aws_access_key_id, :aws_secret_access_key, :aws_region, :aws_endpoint)
+      temp_settings = settings.dup
+      temp_settings[:aws_secret_access_key_dec] = temp_settings.delete(:aws_secret_access_key)
+      unless LiveEvents::Client.new(temp_settings).valid?
+        plugin_setting.errors.add(:base, I18n.t('Invalid AWS Configuration'))
         return false
-      else
-        return settings.slice(:kinesis_stream_name, :aws_access_key_id, :aws_secret_access_key, :aws_region, :aws_endpoint)
       end
+
+      settings
     end
   end
 end