Merge pull request #16 from stardothosting/issue-15

Issue 15

Author: stardothosting

app/Console/Commands/TestTimeoutAlerts.php

@@ -0,0 +1,47 @@
+<?php
+
+namespace App\Console\Commands;
+
+use App\Services\AlertService;
+use Illuminate\Console\Command;
+
+class TestTimeoutAlerts extends Command
+{
+    protected $signature = 'test:timeout-alerts';
+    protected $description = 'Test timeout and connectivity alerts';
+
+    public function handle(AlertService $alertService): int
+    {
+        $this->info('Testing timeout alerts...');
+
+        // Test API timeout alert
+        $this->info('Sending API timeout alert...');
+        $alertService->apiTimeout(
+            'Unwrangle API',
+            'B0D8L7K9QR',
+            120,
+            [
+                'attempt' => 3,
+                'max_pages' => 10,
+                'error_details' => 'cURL error 28: Operation timed out after 120 seconds'
+            ]
+        );
+
+        // Test connectivity issue alert
+        $this->info('Sending connectivity issue alert...');
+        $alertService->connectivityIssue(
+            'Unwrangle API',
+            'CONNECTION_TIMEOUT_NO_DATA',
+            'cURL error 28: Operation timed out with 0 bytes received',
+            [
+                'asin' => 'B0D8L7K9QR',
+                'attempt' => 2
+            ]
+        );
+
+        $this->info('✅ Timeout alerts sent successfully!');
+        $this->info('Check your Pushover app and logs for the alerts.');
+
+        return self::SUCCESS;
+    }
+} 

app/Enums/AlertType.php

@@ -8,6 +8,8 @@ enum AlertType: string
     case OPENAI_QUOTA_EXCEEDED = 'openai_quota_exceeded';
     case OPENAI_API_ERROR = 'openai_api_error';
     case AMAZON_API_ERROR = 'amazon_api_error';
+    case API_TIMEOUT = 'api_timeout';
+    case CONNECTIVITY_ISSUE = 'connectivity_issue';
     case SYSTEM_ERROR = 'system_error';
     case RATE_LIMIT_EXCEEDED = 'rate_limit_exceeded';
     case DATABASE_ERROR = 'database_error';
@@ -25,6 +27,8 @@ public function getDisplayName(): string
             self::OPENAI_QUOTA_EXCEEDED => 'OpenAI Quota Exceeded',
             self::OPENAI_API_ERROR => 'OpenAI API Error',
             self::AMAZON_API_ERROR => 'Amazon API Error',
+            self::API_TIMEOUT => 'API Timeout',
+            self::CONNECTIVITY_ISSUE => 'Connectivity Issue',
             self::SYSTEM_ERROR => 'System Error',
             self::RATE_LIMIT_EXCEEDED => 'Rate Limit Exceeded',
             self::DATABASE_ERROR => 'Database Error',
@@ -45,6 +49,8 @@ public function getDefaultPriority(): int
             self::SECURITY_ALERT => 2, // Emergency priority
             self::DATABASE_ERROR => 2, // Emergency priority
             self::SYSTEM_ERROR => 1, // High priority
+            self::API_TIMEOUT => 0, // Normal priority
+            self::CONNECTIVITY_ISSUE => 1, // High priority - might indicate broader issues
             self::OPENAI_API_ERROR => 0, // Normal priority
             self::AMAZON_API_ERROR => 0, // Normal priority
             self::RATE_LIMIT_EXCEEDED => 0, // Normal priority
@@ -77,6 +83,8 @@ public function shouldThrottle(): bool
             self::OPENAI_QUOTA_EXCEEDED => true,
             self::RATE_LIMIT_EXCEEDED => true,
             self::PERFORMANCE_ALERT => true,
+            self::API_TIMEOUT => true,
+            self::CONNECTIVITY_ISSUE => true,
             default => false,
         };
     }
@@ -91,6 +99,8 @@ public function getThrottleDuration(): int
             self::OPENAI_QUOTA_EXCEEDED => 60, // 1 hour
             self::RATE_LIMIT_EXCEEDED => 30, // 30 minutes
             self::PERFORMANCE_ALERT => 15, // 15 minutes
+            self::API_TIMEOUT => 15, // 15 minutes
+            self::CONNECTIVITY_ISSUE => 30, // 30 minutes - more serious
             default => 0,
         };
     }

app/Services/AlertService.php

@@ -141,6 +141,40 @@ public function securityAlert(string $message, array $context = []): void
         );
     }
 
+    /**
+     * Send API timeout alert
+     */
+    public function apiTimeout(string $service, string $asin, int $timeoutDuration, array $context = []): void
+    {
+        $this->alert(
+            AlertType::API_TIMEOUT,
+            "API timeout for {$service} after {$timeoutDuration}s (ASIN: {$asin})",
+            array_merge($context, [
+                'service' => $service,
+                'asin' => $asin,
+                'timeout_duration' => $timeoutDuration,
+                'error_type' => 'timeout'
+            ])
+        );
+    }
+
+    /**
+     * Send connectivity issue alert
+     */
+    public function connectivityIssue(string $service, string $errorType, string $errorMessage, array $context = []): void
+    {
+        $this->alert(
+            AlertType::CONNECTIVITY_ISSUE,
+            "Connectivity issue with {$service}: {$errorType} - {$errorMessage}",
+            array_merge($context, [
+                'service' => $service,
+                'error_type' => $errorType,
+                'error_message' => $errorMessage
+            ]),
+            1 // High priority
+        );
+    }
+
     /**
      * Check if an alert type is currently throttled
      */