npm package diff

Package: @forge/sql

Versions: 2.2.0-next.2 - 2.2.0-next.3

File: package/out/sql.js

Index: package/out/sql.js
===================================================================
--- package/out/sql.js
+++ package/out/sql.js
@@ -1,10 +1,11 @@
 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
 exports.sql = exports.SqlClient = void 0;
 const api_1 = require("@forge/api");
-const response_handler_1 = require("./utils/response-handler");
 const sql_statement_1 = require("./sql-statement");
+const error_handling_1 = require("./utils/error-handling");
+const errors_1 = require("./errors");
 class SqlClient {
     async sendRequest(path, options) {
         const response = await (0, api_1.__fetchProduct)({ provider: 'app', remote: 'sql' })(path, {
             ...options,
@@ -20,9 +21,16 @@
         const response = await this.sendRequest('api/v1/execute', {
             method: 'POST',
             body: JSON.stringify({ query, params, method })
         });
-        return await (0, response_handler_1.getResponseBody)(response);
+        await (0, error_handling_1.checkResponseError)(response);
+        const responseText = await response.text();
+        try {
+            return JSON.parse(responseText);
+        }
+        catch (error) {
+            throw new errors_1.ForgeSQLError(`Unexpected error. Response was not valid JSON: ${responseText}`);
+        }
     }
     prepare(query) {
         return new sql_statement_1.SqlStatement(query, this.storageApi.bind(this));
     }
@@ -32,9 +40,9 @@
     async _provision() {
         const response = await this.sendRequest('/api/v1/provision', {
             method: 'POST'
         });
-        await (0, response_handler_1.getResponseBody)(response);
+        await (0, error_handling_1.checkResponseError)(response, 'Unexpected error in provision request');
     }
 }
 exports.SqlClient = SqlClient;
 exports.sql = new SqlClient();