Remove handling of GW timeout errors

somleng · Sep 24, 2024 · 19ccfdc · 19ccfdc
1 parent 4e624c9
commit 19ccfdc
Show file tree

Hide file tree

Showing 15 changed files with 2 additions and 443 deletions.
diff --git a/components/services/app.rb b/components/services/app.rb
@@ -30,8 +30,6 @@ def process
         HandleSQSMessageEvent.call(event:)
       when :service_action
         event.service_action.call(**event.parameters)
-      when :cloudwatch_log_event
-        HandleLogEvents.call(event:)
       end
     end
 

diff --git a/components/services/app/parsers/cloudwatch_log_event_parser.rb b/components/services/app/parsers/cloudwatch_log_event_parser.rb
diff --git a/components/services/app/parsers/event_parser.rb b/components/services/app/parsers/event_parser.rb
@@ -12,8 +12,6 @@ def parse_event
                SQSMessageEventParser
     elsif service_action?
                ServiceActionParser
-    elsif cloudwatch_log_event?
-               CloudWatchLogEventParser
     end
 
     parser.new(event).parse_event
@@ -32,8 +30,4 @@ def ecs_event?
   def service_action?
     event.key?("serviceAction")
   end
-
-  def cloudwatch_log_event?
-    event.keys.size == 1 && event.key?("awslogs")
-  end
 end
diff --git a/components/services/app/parsers/opensips_log_event_parser.rb b/components/services/app/parsers/opensips_log_event_parser.rb
diff --git a/components/services/app/workflows/find_ecs_task.rb b/components/services/app/workflows/find_ecs_task.rb
diff --git a/components/services/app/workflows/handle_log_events.rb b/components/services/app/workflows/handle_log_events.rb
diff --git a/components/services/app/workflows/handle_opensips_log_event.rb b/components/services/app/workflows/handle_opensips_log_event.rb
diff --git a/components/services/config/initializers/sentry.rb b/components/services/config/initializers/sentry.rb
@@ -3,6 +3,5 @@
 Sentry.init do |config|
   config.dsn = AppSettings[:sentry_dsn]
   config.environment = AppSettings.env
-  config.debug = true
   config.background_worker_threads = 0
 end
diff --git a/components/services/lib/somleng_region/region.rb b/components/services/lib/somleng_region/region.rb
@@ -10,16 +10,14 @@ class RegionNotFound < StandardError; end
         alias: "hydrogen",
         group_id: 1,
         human_name: "South East Asia (Singapore)",
-        nat_ip: "13.250.230.15",
-        vpc_cidr: "10.10.0.0/22"
+        nat_ip: "13.250.230.15"
       ),
       new(
         identifier: "us-east-1",
         alias: "helium",
         group_id: 2,
         human_name: "North America (N. Virginia, USA)",
-        nat_ip: "52.4.242.134",
-        vpc_cidr: "10.20.0.0/20"
+        nat_ip: "52.4.242.134"
       )
     ]
 

diff --git a/components/services/spec/fixtures/files/cloudwatch_log_event.json b/components/services/spec/fixtures/files/cloudwatch_log_event.json
diff --git a/components/services/spec/requests/cloudwatch_log_events_spec.rb b/components/services/spec/requests/cloudwatch_log_events_spec.rb
diff --git a/components/services/spec/spec_helper.rb b/components/services/spec/spec_helper.rb
@@ -24,8 +24,6 @@
   SimpleCov.formatter = SimpleCov::Formatter::CoberturaFormatter
 end
 
-ENV["PUBLIC_GATEWAY_LOG_GROUP"] = "public-gateway"
-ENV["CLIENT_GATEWAY_LOG_GROUP"] = "client-gateway"
 ENV["SWITCH_GROUP"] = "service:somleng-switch"
 ENV["MEDIA_PROXY_GROUP"] = "service:media-proxy"
 ENV["CLIENT_GATEWAY_GROUP"] = "service:client-gateway"

diff --git a/components/services/spec/support/aws_stubs.rb b/components/services/spec/support/aws_stubs.rb
@@ -1,6 +1,3 @@
-AWSRequests = Array.new
-AWSRequest = Struct.new(:context, :operation_name, keyword_init: true)
-
 Aws.config[:ecs] = {
   stub_responses: {
     describe_container_instances: lambda { |_context|
@@ -9,40 +6,6 @@
           ec2_instance_id: "ec2-instance-id"
         ]
       }
-    },
-    list_clusters: ->(context) {
-      {
-        cluster_arns: [ "arn:aws:ecs:#{context.client.config.region}:123456789012:cluster/cluster-1" ]
-      }
-    },
-    list_tasks: ->(context) {
-      {
-        task_arns: [ "arn:aws:ecs:#{context.client.config.region}:123456789012:task/cluster-1/#{SecureRandom.uuid.gsub('-', '')}" ]
-      }
-    },
-    describe_tasks: ->(context) {
-      {
-        tasks: [
-          {
-            attachments: [
-              {
-                type: "ElasticNetworkInterface",
-                details: [
-                  {
-                    name: "privateIPv4Address",
-                    value: "10.10.1.180"
-                  }
-                ]
-              }
-            ],
-            task_arn: "arn:aws:ecs:#{context.client.config.region}:123456789012:task/cluster-1/#{SecureRandom.uuid.gsub('-', '')}",
-            cluster_arn: "arn:aws:ecs:#{context.client.config.region}:123456789012:cluster/cluster-1"
-          }
-        ]
-      }
-    },
-    stop_task: ->(context) {
-      AWSRequests << AWSRequest.new(context:, operation_name: :stop_task)
     }
   }
 }