fixes

Author: ford-at-aws

ruby/Gemfile

@@ -1,23 +1,23 @@
-source "https://rubygems.org"
-ruby "3.1.2"
+source 'https://rubygems.org'
+ruby '3.1.2'
 
-gem "aws-sdk"
-gem "cli-ui"
-gem "json"
-gem "mail"
-gem "mime"
-gem "multi_json"
-gem "openssl"
-gem "open-uri"
-gem "pp"
-gem "rack"
-gem "rack-test"
-gem "rake"
-gem "rspec"
-gem "rubocop"
-gem "rubocop-github"
-gem "rubocop-rake"
-gem "rubyzip"
-gem "sequel"
-gem "sinatra"
-gem "zip"
+gem 'aws-sdk'
+gem 'cli-ui'
+gem 'json'
+gem 'mail'
+gem 'mime'
+gem 'multi_json'
+gem 'openssl'
+gem 'open-uri'
+gem 'pp'
+gem 'rack'
+gem 'rack-test'
+gem 'rake'
+gem 'rspec'
+gem 'rubocop'
+gem 'rubocop-github'
+gem 'rubocop-rake'
+gem 'rubyzip'
+gem 'sequel'
+gem 'sinatra'
+gem 'zip'

ruby/Rakefile

@@ -1,27 +1,27 @@
 # frozen_string_literal: true
 
-require "rake/testtask"
-require "rspec/core/rake_task"
-require "rubocop"
-require "rubocop/rake_task"
-require "rubocop-rake"
+require 'rake/testtask'
+require 'rspec/core/rake_task'
+require 'rubocop'
+require 'rubocop/rake_task'
+require 'rubocop-rake'
 
 task default: [:spec]
 
 Rake::TestTask.new do |t|
-  t.pattern = "*/**/tests/test_*.rb"
+  t.pattern = '*/**/tests/test_*.rb'
   t.verbose = true
   t.warning = false
 end
 
-desc "Run specs."
+desc 'Run specs.'
 RSpec::Core::RakeTask.new do |t|
-  t.pattern = "*/**/*_spec.rb"
-  t.rspec_opts = ["--tag", "integ", "--tag", "~@quarantine"]
+  t.pattern = '*/**/*_spec.rb'
+  t.rspec_opts = ['--tag', 'integ', '--tag', '~@quarantine']
 end
 
-desc "Run rubocop"
+desc 'Run rubocop'
 RuboCop::RakeTask.new(:rubocop) do |t|
-  t.options = ["--config", "../.github/linters/.ruby-lint.yml"]
-  t.requires << "rubocop-rake"
+  t.options = ['--config', '../.github/linters/.ruby-lint.yml']
+  t.requires << 'rubocop-rake'
 end

ruby/cross_service_examples/feedback_sentiment_analyzer/comprehend_lambda_handler.rb

@@ -2,19 +2,19 @@
 # SPDX-License-Identifier: Apache-2.0
 # frozen_string_literal: true
 
-require "json"
-require "aws-sdk-comprehend"
-require "logger"
+require 'json'
+require 'aws-sdk-comprehend'
+require 'logger'
 
 def lambda_handler(event:, context:)
   logger = Logger.new($stdout)
 
   logger.info("event:\n #{event}\n")
   logger.info("context:\n #{context}\n")
 
-  rekognition_client = Aws::Comprehend::Client.new(region: event["region"])
+  rekognition_client = Aws::Comprehend::Client.new(region: event['region'])
 
-  source_text = event["source_text"]
+  source_text = event['source_text']
 
   logger.info("payload:\n #{source_text}")
 
@@ -32,5 +32,5 @@ def lambda_handler(event:, context:)
   logger.info("Sentiment: #{response.sentiment}")
   logger.info("Sentiment Score: #{response.sentiment_score}")
 
-  { "sentiment" => response.sentiment, "language_code" => language_code }
+  { 'sentiment' => response.sentiment, 'language_code' => language_code }
 end

ruby/cross_service_examples/feedback_sentiment_analyzer/polly_lambda_handler.rb

@@ -2,10 +2,10 @@
 # SPDX-License-Identifier: Apache-2.0
 # frozen_string_literal: true
 
-require "json"
-require "aws-sdk-polly"
-require "aws-sdk-s3"
-require "logger"
+require 'json'
+require 'aws-sdk-polly'
+require 'aws-sdk-s3'
+require 'logger'
 
 def lambda_handler(event, context)
   logger = Logger.new($stdout)
@@ -14,22 +14,22 @@ def lambda_handler(event, context)
   logger.info("context:\n #{context}")
 
   # Create an instance of the Polly client
-  polly_client = Aws::Polly::Client.new(region: event["region"])
+  polly_client = Aws::Polly::Client.new(region: event['region'])
 
   resp = polly_client.synthesize_speech({
-                                          engine: "neural",
-                                          output_format: "mp3",
-                                          text: event["translated_text"],
-                                          voice_id: "Ruth"
+                                          engine: 'neural',
+                                          output_format: 'mp3',
+                                          text: event['translated_text'],
+                                          voice_id: 'Ruth'
                                         })
 
   logger.info(resp.to_s)
 
   # Define the bucket name and file name for the MP3 file in S3
-  bucket_name = event["bucket"]
+  bucket_name = event['bucket']
   object_key = "#{event['object']}.mp3"
 
-  s3_client = Aws::S3::Client.new(region: event["region"])
+  s3_client = Aws::S3::Client.new(region: event['region'])
 
   # Put the MP3 file to S3
   s3_client.put_object(

ruby/cross_service_examples/feedback_sentiment_analyzer/textract_lambda_handler.rb

@@ -2,9 +2,9 @@
 # SPDX-License-Identifier: Apache-2.0
 # frozen_string_literal: true
 
-require "json"
-require "aws-sdk-textract"
-require "logger"
+require 'json'
+require 'aws-sdk-textract'
+require 'logger'
 
 def lambda_handler(event:, context:)
   logger = Logger.new($stdout)
@@ -13,13 +13,13 @@ def lambda_handler(event:, context:)
   logger.info("context:\n #{context}\n")
 
   # Create an instance of the Textract client
-  client = Aws::Textract::Client.new(region: event["region"])
+  client = Aws::Textract::Client.new(region: event['region'])
 
   params = {
     document: {
       s3_object: {
-        bucket: event["bucket"],
-        name: event["object"]
+        bucket: event['bucket'],
+        name: event['object']
       }
     }
   }
@@ -30,12 +30,12 @@ def lambda_handler(event:, context:)
   extracted_words = []
 
   response.blocks.each do |obj|
-    next unless obj.block_type.include?("LINE")
+    next unless obj.block_type.include?('LINE')
 
     extracted_words.append(obj.text) if obj.respond_to?(:text) && obj.text
   end
 
   logger.info("extracted words: #{extracted_words}")
 
-  extracted_words.join(" ")
+  extracted_words.join(' ')
 end

ruby/cross_service_examples/feedback_sentiment_analyzer/translate_lambda_handler.rb

@@ -2,9 +2,9 @@
 # SPDX-License-Identifier: Apache-2.0
 # frozen_string_literal: true
 
-require "json"
-require "aws-sdk-translate"
-require "logger"
+require 'json'
+require 'aws-sdk-translate'
+require 'logger'
 
 def lambda_handler(event:, context:)
   logger = Logger.new($stdout)
@@ -13,11 +13,11 @@ def lambda_handler(event:, context:)
   logger.info("context:\n #{context}")
 
   # Create an instance of the Translate client
-  client = Aws::Translate::Client.new(region: event["region"])
+  client = Aws::Translate::Client.new(region: event['region'])
 
   client.translate_text({
-                          text: event["extracted_text"], # required
-                          source_language_code: event["source_language_code"], # required
-                          target_language_code: "en"
+                          text: event['extracted_text'], # required
+                          source_language_code: event['source_language_code'], # required
+                          target_language_code: 'en'
                         })
 end

ruby/cross_service_examples/item_tracker/env/setup_scripts/create_table.rb

@@ -3,29 +3,28 @@
 
 # frozen_string_literal: true
 
-require "yaml"
-require "aws-sdk-rdsdataservice"
-require "aws-sdk-rds"
-require "aws-sdk-ses"
+require 'yaml'
+require 'aws-sdk-rdsdataservice'
+require 'aws-sdk-rds'
+require 'aws-sdk-ses'
 
 # A simple class for checking for databases and tables in an Amazon Aurora DB cluster.
 class SetupDatabase
-
   def initialize
-    @config = YAML.safe_load(File.open(File.join(File.dirname(__FILE__), "../", "config.yml")))
+    @config = YAML.safe_load(File.open(File.join(File.dirname(__FILE__), '../', 'config.yml')))
     @data_client = Aws::RDSDataService::Client.new
     @rds_client = Aws::RDS::Client.new
   end
 
   # Checks if database exists.
   # @return [Boolean] false if DBClusterNotFoundFault; else true.
   def database_exists?
-    identifier = Aws::ARNParser.parse(@config["resource_arn"])
+    identifier = Aws::ARNParser.parse(@config['resource_arn'])
     @rds_client.wait_until(:db_cluster_available, db_cluster_identifier: identifier.resource) do |w|
       w.max_attempts = 5
       w.delay = 5
     end
-  rescue Aws::RDS::Errors::DBClusterNotFoundFault => e
+  rescue Aws::RDS::Errors::DBClusterNotFoundFault
     false
   end
 
@@ -34,18 +33,16 @@ def database_exists?
   def table_exists?
     resp = @data_client.execute_statement(
       {
-        resource_arn: @config["resource_arn"],
-        secret_arn: @config["secret_arn"],
-        sql: "show tables;",
-        database: @config["database"]
+        resource_arn: @config['resource_arn'],
+        secret_arn: @config['secret_arn'],
+        sql: 'show tables;',
+        database: @config['database']
       }
     )
 
-    resp[0].each { |table|
-      if table[0].string_value == @config["table_name"]
-        return true
-      end
-    }
+    resp[0].each do |table|
+      return true if table[0].string_value == @config['table_name']
+    end
     false
   end
 
@@ -54,27 +51,24 @@ def table_exists?
   def create_table
     @data_client.execute_statement(
       {
-        resource_arn: @config["resource_arn"],
-        secret_arn: @config["secret_arn"],
-        sql: "CREATE TABLE work_items (work_item_id INT AUTO_INCREMENT PRIMARY KEY, description VARCHAR(400), guide VARCHAR(45), status VARCHAR(400), username VARCHAR(45), archived TINYINT(4));",
-        database: @config["database"],
+        resource_arn: @config['resource_arn'],
+        secret_arn: @config['secret_arn'],
+        sql: 'CREATE TABLE work_items (work_item_id INT AUTO_INCREMENT PRIMARY KEY, description VARCHAR(400), guide VARCHAR(45), status VARCHAR(400), username VARCHAR(45), archived TINYINT(4));',
+        database: @config['database']
       }
     )
   end
-
 end
 
-if __FILE__ == $0
-    # Checks for a database cluster & creates a table if none exists.
+if __FILE__ == $PROGRAM_NAME
+  # Checks for a database cluster & creates a table if none exists.
   begin
     setup = SetupDatabase.new
-    if setup.database_exists?
-      unless setup.table_exists?
-        setup.create_table
-      end
-    else
-      raise "No DB cluster exists! Please run CDK script found in resources/cdk/aurora_serverless_app."
+    unless setup.database_exists?
+      raise 'No DB cluster exists! Please run CDK script found in resources/cdk/aurora_serverless_app.'
     end
+
+    setup.create_table unless setup.table_exists?
   rescue StandardError => e
     raise "Failed while checking for or creating existing database/tables:\n#{e}"
   end

ruby/cross_service_examples/item_tracker/env/setup_scripts/populate_table.rb

@@ -3,25 +3,25 @@
 
 # frozen_string_literal: true
 
-require "yaml"
-require "aws-sdk-rdsdataservice"
-require_relative "../../src/aurora"
+require 'yaml'
+require 'aws-sdk-rdsdataservice'
+require_relative '../../src/aurora'
 
 # A simple class for creating items in the database.
 class PopulateTable
   def initialize
     client = Aws::RDSDataService::Client.new
-    config = YAML.safe_load(File.open(File.join(File.dirname(__FILE__), "./../", "config.yml")))
+    config = YAML.safe_load(File.open(File.join(File.dirname(__FILE__), './../', 'config.yml')))
     @wrapper = AuroraActions.new(config, client)
   end
 
   def add_records
     10.times do
-      username = ["ltolstoy", "jsteinbeck", "jkerouac", "wkhalifa"].sample
+      username = %w[ltolstoy jsteinbeck jkerouac wkhalifa].sample
       item_data = {
-        description: ["New feature", "Quick bugfix", "User research", "Tech debt"].sample,
-        guide: ["cpp", "python", "go", "ruby", "dotnet", "js", "php"].sample,
-        status: ["backlog", "icebox", "unrefined", "done", "in-progress"].sample,
+        description: ['New feature', 'Quick bugfix', 'User research', 'Tech debt'].sample,
+        guide: %w[cpp python go ruby dotnet js php].sample,
+        status: %w[backlog icebox unrefined done in-progress].sample,
         username: username,
         name: username,
         archived: [0, 1].sample
@@ -31,8 +31,8 @@ def add_records
   end
 end
 
-if __FILE__ == $0
-    # Checks for Aurora DB cluster & creates table if none exists.
+if __FILE__ == $PROGRAM_NAME
+  # Checks for Aurora DB cluster & creates table if none exists.
   begin
     setup = PopulateTable.new
     setup.add_records