@forge/sql

4.0.5-next.1-experimental-e9e08bb4.0.5-next.1-experimental-d477002
out/sql.js
~out/sql.jsModified
+3−37
Index: package/out/sql.js
===================================================================
--- package/out/sql.js
+++ package/out/sql.js
@@ -10,20 +10,17 @@
     EXECUTE_DDL: '/api/v1/execute/ddl'
 };
 class SqlClient {
     async sendRequest(path, options) {
-        const requestOptions = {
+        const response = await (0, api_1.__fetchProduct)({ provider: 'app', remote: 'sql', type: 'sql' })(path, {
             ...options,
             redirect: 'follow',
             headers: {
                 ...options?.headers,
                 'Content-Type': 'application/json'
             }
-        };
-        const localClient = getLocalSqlFetchClient();
-        if (localClient)
-            return localClient(path, requestOptions);
-        return (0, api_1.__fetchProduct)({ provider: 'app', remote: 'sql', type: 'sql' })(path, requestOptions);
+        });
+        return response;
     }
     async storageApi(query, params = [], method = 'all', endpoint = exports.SQL_API_ENDPOINTS.EXECUTE) {
         const response = await this.sendRequest(endpoint, {
             method: 'POST',
@@ -57,35 +54,4 @@
     }
 }
 exports.SqlClient = SqlClient;
 exports.sql = new SqlClient();
-function getLocalSqlFetchClient() {
-    if (process.env.FORGE_LOCAL_STORAGE !== '1')
-        return undefined;
-    const baseUrl = process.env.FORGE_LOCAL_SQL_URL;
-    const appId = process.env.FORGE_LOCAL_STORAGE_APP_ID;
-    const environmentId = process.env.FORGE_LOCAL_STORAGE_ENVIRONMENT_ID;
-    const installationId = process.env.FORGE_LOCAL_STORAGE_INSTALLATION_ID;
-    if (!baseUrl || !appId || !environmentId || !installationId) {
-        throw new Error('Forge local SQL routing is enabled but its local namespace is incomplete.');
-    }
-    if (baseUrl !== 'http://127.0.0.1:18091') {
-        throw new Error('Forge local SQL endpoint must be http://127.0.0.1:18091.');
-    }
-    const fetchImplementation = globalThis.__forge_local_fetch__;
-    if (typeof fetchImplementation !== 'function') {
-        throw new Error('Forge local SQL routing requires the tunnel local-fetch bridge.');
-    }
-    const endpoint = new URL(baseUrl);
-    return async (requestPath, options) => (await fetchImplementation(new URL(requestPath, endpoint), {
-        ...options,
-        headers: {
-            ...options?.headers,
-            'x-forge-app-id': appId,
-            'x-forge-environment-id': environmentId,
-            'x-forge-installation-id': installationId,
-            'x-atlassian-forgeapp-app-id': appId,
-            'x-atlassian-forgeapp-environment-id': environmentId,
-            'x-atlassian-forgeapp-installation-id': installationId
-        }
-    }));
-}