dennii/dbgate
1
0
Fork 0
mirror of https://github.com/DeNNiiInc/dbgate.git synced 2026-05-02 09:03:58 +00:00
Code Issues Packages Projects Releases Wiki Activity

azure aith wip

Browse Source
This commit is contained in:
Jan Prochazka
2024-08-02 15:12:38 +02:00
parent fc448ed578
commit 112513a569
6 changed files with 13 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
packages/api/src/controllers/connections.js
View File

@@ -389,7 +389,7 @@ module.exports = {
const { conid } = req.query; const { conid } = req.query;
const connection = await this.getCore({ conid }); const connection = await this.getCore({ conid });
const driver = requireEngineDriver(connection); const driver = requireEngineDriver(connection);
const authUrl = driver.getRedirectAuthUrl(connection); const authUrl = await driver.getRedirectAuthUrl(connection);
res.redirect(authUrl); res.redirect(authUrl);
}, },
}; };

3
packages/api/src/controllers/serverConnections.js
View File

@@ -55,6 +55,9 @@ module.exports = {
} }
if (connection.passwordMode == 'askPassword' || connection.passwordMode == 'askUser') { if (connection.passwordMode == 'askPassword' || connection.passwordMode == 'askUser') {
throw new MissingCredentialsError({ conid, passwordMode: connection.passwordMode }); throw new MissingCredentialsError({ conid, passwordMode: connection.passwordMode });
}
if (connection.useRedirectDbLogin) {
throw new MissingCredentialsError({ conid, redirectToDbLogin: true });
} }
const subprocess = fork( const subprocess = fork(
global['API_PACKAGE'] || process.argv[1], global['API_PACKAGE'] || process.argv[1],

2
packages/api/src/utility/useController.js
View File

@@ -67,7 +67,7 @@ module.exports = function useController(app, electron, route, controller) {
} }
if (raw) { if (raw) {
router[method](routeAction, controller[key]); router[method](routeAction, (req, res) => controller[key](req, res));
} else { } else {
router[method](routeAction, async (req, res) => { router[method](routeAction, async (req, res) => {
// if (controller._init && !controller._init_called) { // if (controller._init && !controller._init_called) {

5
packages/web/src/tabs/ConnectionTab.svelte
View File

@@ -181,6 +181,11 @@
} }
}); });
export function changeConnectionBeforeSave(connection) {
if (driver?.beforeConnectionSave) return driver.beforeConnectionSave(connection);
return connection;
}
$: isConnected = $openedConnections.includes($values._id) || $openedSingleDatabaseConnections.includes($values._id); $: isConnected = $openedConnections.includes($values._id) || $openedSingleDatabaseConnections.includes($values._id);
// $: console.log('CONN VALUES', $values); // $: console.log('CONN VALUES', $values);

2
packages/web/src/utility/api.ts
View File

@@ -65,7 +65,7 @@ function processApiResponse(route, args, resp) {
if (resp?.missingCredentials) { if (resp?.missingCredentials) {
if (resp.detail.redirectToDbLogin) { if (resp.detail.redirectToDbLogin) {
openWebLink('connections/dblogin'); openWebLink(`connections/dblogin?conid=${resp.detail.conid}`);
} else if (!isDatabaseLoginVisible()) { } else if (!isDatabaseLoginVisible()) {
showModal(DatabaseLoginModal, resp.detail); showModal(DatabaseLoginModal, resp.detail);
} }

2
plugins/dbgate-plugin-mssql/src/backend/driver.js
View File

@@ -8,7 +8,7 @@ const AsyncLock = require('async-lock');
const nativeDriver = require('./nativeDriver'); const nativeDriver = require('./nativeDriver');
const lock = new AsyncLock(); const lock = new AsyncLock();
const { tediousConnect, tediousQueryCore, tediousReadQuery, tediousStream } = require('./tediousDriver'); const { tediousConnect, tediousQueryCore, tediousReadQuery, tediousStream } = require('./tediousDriver');
const { getAzureAuthTypes } = require('./azureAuth'); const { getAzureAuthTypes, azureGetRedirectAuthUrl } = require('./azureAuth');
const { nativeConnect, nativeQueryCore, nativeReadQuery, nativeStream } = nativeDriver; const { nativeConnect, nativeQueryCore, nativeReadQuery, nativeStream } = nativeDriver;
let requireMsnodesqlv8; let requireMsnodesqlv8;