fix(providers): limit transport retries to network socket codes

Author: waleedlatif1

apps/sim/lib/core/errors/retryable-infrastructure.ts

@@ -97,6 +97,19 @@ export function isRetryableInfrastructureError(error: unknown): boolean {
   return Boolean(describeRetryableInfrastructureError(error))
 }
 
+/**
+ * A network-level failure only — a dropped, refused, or timed-out socket anywhere in the
+ * cause chain. Narrower than {@link isRetryableInfrastructureError}: database and application
+ * codes are excluded, so a caller replaying a billed request never mistakes one for a socket.
+ */
+export function isRetryableNetworkError(error: unknown): boolean {
+  return getErrorChain(error).some(
+    (candidate) =>
+      (typeof candidate.code === 'string' && RETRYABLE_NETWORK_ERROR_CODES.has(candidate.code)) ||
+      (typeof candidate.errno === 'string' && RETRYABLE_NETWORK_ERROR_CODES.has(candidate.errno))
+  )
+}
+
 /**
  * A retryable infrastructure failure raised strictly BEFORE the guarded
  * operation performed any effect (no workflow block ran, no mutation

apps/sim/providers/retry.test.ts

@@ -227,6 +227,11 @@ describe('fetchWithProviderRetry', () => {
   it.each([
     ['an unrecognised failure', new Error('body serialization failed')],
     ['a TypeError from building the request', new TypeError('Invalid URL')],
+    [
+      'an application error code',
+      Object.assign(new Error('overloaded'), { code: 'RESOURCE_EXHAUSTED' }),
+    ],
+    ['a database error code', Object.assign(new Error('admin shutdown'), { code: '57P01' })],
   ])('does not retry %s', async (_, failure) => {
     const send = vi.fn().mockRejectedValue(failure)
 

apps/sim/providers/retry.ts

@@ -22,7 +22,7 @@ import { isRecordLike } from '@sim/utils/object'
 import { backoffWithJitter, parseRetryAfter } from '@sim/utils/retry'
 import { truncate } from '@sim/utils/string'
 import { isQuotaExhaustionBody } from '@/lib/core/errors/provider-quota'
-import { isRetryableInfrastructureError } from '@/lib/core/errors/retryable-infrastructure'
+import { isRetryableNetworkError } from '@/lib/core/errors/retryable-infrastructure'
 import {
   DEFAULT_MAX_ERROR_BODY_BYTES,
   readResponseTextWithLimit,
@@ -80,7 +80,7 @@ export function isWithinRetryWindow(retryAfterMs: number | null): boolean {
 function isRetryableTransportFailure(error: unknown): boolean {
   const code = isRecordLike(error) ? error.code : undefined
   if (typeof code === 'string' && BUN_CONNECTION_ERROR_CODES.has(code)) return true
-  return isRetryableInfrastructureError(error)
+  return isRetryableNetworkError(error)
 }
 
 /**