Merge pull request #1270 from interval/credentials-send-io-call-error

Support error messages for failed IO calls, use for credentials

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@interval/sdk",
-  "version": "1.3.0",
+  "version": "1.4.0-dev",
   "description": "The frontendless framework for high growth companies. Interval automatically generates apps by inlining the UI in your backend code. It's a faster and more maintainable way to build internal tools, rapid prototypes, and more.",
   "homepage": "https://interval.com",
   "repository": {

src/classes/IOClient.ts

@@ -311,7 +311,7 @@ export class IOClient {
             }
           })
           .catch(err => {
-            this.logger.warn('Failed resolving component immediately', err)
+            reject(err)
           })
 
         const response = {

src/classes/IOError.ts

@@ -3,6 +3,7 @@ export type IOErrorKind =
   | 'TRANSACTION_CLOSED'
   | 'BAD_RESPONSE'
   | 'RESPONSE_HANDLER_ERROR'
+  | 'RENDER_ERROR'
 
 export default class IOError extends Error {
   kind: IOErrorKind

src/classes/IntervalClient.ts

@@ -537,7 +537,10 @@ export default class IntervalClient {
             .then(response => {
               toResend.delete(transactionId)
 
-              if (!response) {
+              if (
+                !response ||
+                (typeof response === 'object' && response.type === 'ERROR')
+              ) {
                 // Unsuccessful response, don't try again
                 this.#pendingIOCalls.delete(transactionId)
               }
@@ -1058,7 +1061,7 @@ export default class IntervalClient {
                 }
               }
 
-              await intervalClient.#send(
+              const response = await intervalClient.#send(
                 'SEND_IO_CALL',
                 {
                   transactionId,
@@ -1068,6 +1071,21 @@ export default class IntervalClient {
                   attemptPeerSend,
                 }
               )
+
+              if (
+                !response ||
+                (typeof response === 'object' && response.type === 'ERROR')
+              ) {
+                let message = 'Error sending IO call.'
+                if (
+                  typeof response === 'object' &&
+                  response.type === 'ERROR' &&
+                  response.message
+                ) {
+                  message = response.message
+                }
+                throw new IOError('RENDER_ERROR', message)
+              }
             }
 
             intervalClient.#transactionLoadingStates.delete(transactionId)

src/internalRpcSchema.ts

@@ -314,7 +314,12 @@ export const wsServerSchema = {
       ioCall: z.string(),
       skipClientCall: z.boolean().optional(),
     }),
-    returns: z.boolean(),
+    returns: z.boolean().or(
+      z.object({
+        type: z.literal('ERROR'),
+        message: z.string().optional(),
+      })
+    ),
   },
   SEND_PAGE: {
     inputs: z.object({