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();