feat: implement PaymentTimeoutService to handle transaction tracking, automated retries, and gas price bumping for chain payments.

Author: sweetesty

backend/services/accessControl.ts

@@ -5,9 +5,9 @@
  */
 
 import { randomUUID } from 'crypto';
-import { AuditService } from './auditService';
-import { AlertingService } from './alerting';
-import type { Alert } from './types';
+import { AuditService } from './shared/auditService';
+import { AlertingService } from './notification/alerting';
+import type { Alert } from './shared/types';
 
 // ─── Resource & Action Types ──────────────────────────────────────────────────
 

backend/services/affiliate/AffiliateService.ts

@@ -1,5 +1,5 @@
-import { AuditService } from '../auditService';
-import type { AuditAction } from '../auditTypes';
+import { AuditService } from '../shared/auditService';
+import type { AuditAction } from '../shared/auditTypes';
 import {
   Affiliate,
   AffiliateProgram,

backend/services/paymentTimeoutService.ts

@@ -9,8 +9,8 @@
  *  - Stuck transaction alerting
  */
 
-import type { AlertingService } from './alerting';
-import type { Alert } from './types';
+import type { AlertingService } from './notification/alerting';
+import type { Alert } from './shared/types';
 
 // ── Chain timeout configuration ───────────────────────────────────────────────
 

backend/services/shared/__tests__/accessControl.test.ts

@@ -1,6 +1,6 @@
-import { AccessControlService, ROLE_HIERARCHY, ROLE_PERMISSIONS } from '../accessControl';
+import { AccessControlService, ROLE_HIERARCHY, ROLE_PERMISSIONS } from '../../accessControl';
 import { AuditService } from '../auditService';
-import { AlertingService } from '../alerting';
+import { AlertingService } from '../../notification/alerting';
 
 describe('AccessControlService', () => {
   let svc: AccessControlService;

backend/services/shared/__tests__/auditService.test.ts

@@ -1,4 +1,4 @@
-import { AlertingService } from '../alerting';
+import { AlertingService } from '../../notification/alerting';
 import { AuditService } from '../auditService';
 
 const SECRET = 'test-secret-key';

backend/services/shared/auditService.ts

@@ -1,6 +1,6 @@
 import { createHmac, randomUUID } from 'crypto';
 import AsyncStorage from '@react-native-async-storage/async-storage';
-import type { AlertingService, AlertDispatcher } from './alerting';
+import type { AlertingService, AlertDispatcher } from '../notification/alerting';
 import type {
   AuditAction,
   AuditArchiveEntry,

contracts/api/src/auth.rs

@@ -60,7 +60,7 @@ pub fn create_api_key(
         .get(&DataKey::OwnerKeys(owner.clone()))
         .unwrap_or(Vec::new(env));
     assert!(
-        (owner_keys.len() as u32) < MAX_KEYS_PER_OWNER,
+        owner_keys.len() < MAX_KEYS_PER_OWNER,
         "Max keys per owner reached"
     );
     let mut new_owner_keys = owner_keys;

contracts/api/src/ratelimit.rs

@@ -52,15 +52,9 @@ pub fn check_rate_limit(env: &Env, key: &ApiKey, now: u64) -> RateLimitStatus {
         SECS_PER_DAY,
     );
 
-    let exceeded = if min_count > cfg.requests_per_minute {
-        true
-    } else if hour_count > cfg.requests_per_hour {
-        true
-    } else if day_count > cfg.requests_per_day {
-        true
-    } else {
-        false
-    };
+    let exceeded = min_count > cfg.requests_per_minute
+        || hour_count > cfg.requests_per_hour
+        || day_count > cfg.requests_per_day;
 
     if exceeded {
         let reset_at = core::cmp::min(core::cmp::min(min_reset, hour_reset), day_reset);

contracts/api/src/test.rs

@@ -1,4 +1,3 @@
-
 use soroban_sdk::{testutils::Address as _, testutils::Ledger as _, Address, Bytes, BytesN, Env};
 use subtrackr_types::{ApiKeyConfig, ApiKeyStatus, RateLimitConfig, TimeRange, UsageTier};
 
@@ -48,7 +47,7 @@ fn test_create_api_key() {
 
     let (key_id, raw_key) = client.create_api_key(&owner, &default_config(&env));
     assert!(key_id >= 1, "Key id should be >= 1");
-    assert!(raw_key.len() > 0, "Raw key bytes should not be empty");
+    assert!(!raw_key.is_empty(), "Raw key bytes should not be empty");
 
     let stored = client.get_api_key(&key_id).unwrap();
     assert_eq!(stored.id, key_id);

contracts/fraud/src/lib.rs

@@ -239,10 +239,6 @@ fn build_evidence(
             .device_fingerprint
             .clone()
             .unwrap_or_else(|| String::from_str(env, "unknown"));
-        let trusted = profile
-            .trusted_device_fingerprint
-            .clone()
-            .unwrap_or_else(|| String::from_str(env, "unknown"));
         evidence.push_back(subtrackr_types::FraudEvidence {
             label: String::from_str(env, "device mismatch"),
             value: current,
@@ -661,7 +657,7 @@ impl SubTrackrFraud {
                 }
 
                 if let Some(case) = review_case_for_subscription(&env, score.subscription_id) {
-                    if case.evidence.len() == 0 {
+                    if case.evidence.is_empty() {
                         pending_evidence += 1;
                     }
                     if case.status == FraudReviewStatus::Dismissed {
@@ -670,7 +666,7 @@ impl SubTrackrFraud {
                     recent_cases.push_back(case);
                 } else if score.total_score >= REVIEW_THRESHOLD {
                     let case = persist_case(&env, &score, FraudReviewStatus::Pending);
-                    if case.evidence.len() == 0 {
+                    if case.evidence.is_empty() {
                         pending_evidence += 1;
                     }
                     recent_cases.push_back(case);