mirror of
https://github.com/DeNNiiInc/dbgate.git
synced 2026-05-01 19:03:58 +00:00
azure auth works
This commit is contained in:
@@ -19,7 +19,6 @@ async function handleRefresh() {
|
|||||||
const databases = await driver.listDatabases(systemConnection);
|
const databases = await driver.listDatabases(systemConnection);
|
||||||
setStatusName('ok');
|
setStatusName('ok');
|
||||||
const databasesString = stableStringify(databases);
|
const databasesString = stableStringify(databases);
|
||||||
console.log('************* DATABASES *************', databases);
|
|
||||||
if (lastDatabases != databasesString) {
|
if (lastDatabases != databasesString) {
|
||||||
process.send({ msgtype: 'databases', databases });
|
process.send({ msgtype: 'databases', databases });
|
||||||
lastDatabases = databasesString;
|
lastDatabases = databasesString;
|
||||||
@@ -60,11 +59,8 @@ async function handleConnect(connection) {
|
|||||||
|
|
||||||
const driver = requireEngineDriver(storedConnection);
|
const driver = requireEngineDriver(storedConnection);
|
||||||
try {
|
try {
|
||||||
console.log('************* CONNECTING *************');
|
|
||||||
systemConnection = await connectUtility(driver, storedConnection, 'app');
|
systemConnection = await connectUtility(driver, storedConnection, 'app');
|
||||||
console.log('************* VERSION *************');
|
|
||||||
readVersion();
|
readVersion();
|
||||||
console.log('************* REFRESH *************');
|
|
||||||
handleRefresh();
|
handleRefresh();
|
||||||
if (extractBoolSettingsValue(globalSettings, 'connection.autoRefresh', false)) {
|
if (extractBoolSettingsValue(globalSettings, 'connection.autoRefresh', false)) {
|
||||||
setInterval(
|
setInterval(
|
||||||
|
|||||||
@@ -11,10 +11,6 @@
|
|||||||
export let passProps;
|
export let passProps;
|
||||||
|
|
||||||
$: databases = useDatabaseList({ conid: data._id });
|
$: databases = useDatabaseList({ conid: data._id });
|
||||||
$: console.log('USED DATABASE LIST', data._id);
|
|
||||||
|
|
||||||
// $: databases = useDatabaseList({ conid: $volatileConnectionMapStore[data._id] || data._id });
|
|
||||||
// $: console.log('USED DATABASE LIST', $volatileConnectionMapStore[data._id] || data._id);
|
|
||||||
</script>
|
</script>
|
||||||
|
|
||||||
<AppObjectList
|
<AppObjectList
|
||||||
|
|||||||
@@ -244,7 +244,6 @@ export function getVolatileConnections() {
|
|||||||
|
|
||||||
export function installNewVolatileConnectionListener() {
|
export function installNewVolatileConnectionListener() {
|
||||||
apiOn('got-volatile-token', async ({ savedConId, volatileConId }) => {
|
apiOn('got-volatile-token', async ({ savedConId, volatileConId }) => {
|
||||||
console.log('************************** GOT VOLASTILE TOKEN', savedConId, volatileConId);
|
|
||||||
setVolatileConnectionRemapping(savedConId, volatileConId);
|
setVolatileConnectionRemapping(savedConId, volatileConId);
|
||||||
await callServerPing();
|
await callServerPing();
|
||||||
dispatchCacheChange({ key: `server-status-changed` });
|
dispatchCacheChange({ key: `server-status-changed` });
|
||||||
|
|||||||
@@ -95,9 +95,7 @@ export async function subscribeCacheChange(reloadTrigger, cacheKey, reloadHandle
|
|||||||
if (!subscriptionsByReloadTrigger[itemString]) {
|
if (!subscriptionsByReloadTrigger[itemString]) {
|
||||||
subscriptionsByReloadTrigger[itemString] = [];
|
subscriptionsByReloadTrigger[itemString] = [];
|
||||||
}
|
}
|
||||||
console.log('+++++++++++++ SUBSCRIBE', itemString);
|
|
||||||
subscriptionsByReloadTrigger[itemString].push(reloadHandler);
|
subscriptionsByReloadTrigger[itemString].push(reloadHandler);
|
||||||
console.log('SUBSCRIBED', subscriptionsByReloadTrigger[itemString]);
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -110,7 +108,6 @@ export async function unsubscribeCacheChange(reloadTrigger, cacheKey, reloadHand
|
|||||||
);
|
);
|
||||||
}
|
}
|
||||||
if (subscriptionsByReloadTrigger[itemString].length == 0) {
|
if (subscriptionsByReloadTrigger[itemString].length == 0) {
|
||||||
console.log('------------- UNSUBSCRIBE', itemString);
|
|
||||||
delete subscriptionsByReloadTrigger[itemString];
|
delete subscriptionsByReloadTrigger[itemString];
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -121,7 +118,6 @@ export function dispatchCacheChange(reloadTrigger) {
|
|||||||
|
|
||||||
for (const item of getAsArray(reloadTrigger)) {
|
for (const item of getAsArray(reloadTrigger)) {
|
||||||
const itemString = stableStringify(transformApiArgsInv(item));
|
const itemString = stableStringify(transformApiArgsInv(item));
|
||||||
console.log('@@@@@@@@@@@@@@@@@@@@@@@@@ NOTIFYING ', itemString, subscriptionsByReloadTrigger[itemString]);
|
|
||||||
if (subscriptionsByReloadTrigger[itemString]) {
|
if (subscriptionsByReloadTrigger[itemString]) {
|
||||||
for (const handler of subscriptionsByReloadTrigger[itemString]) {
|
for (const handler of subscriptionsByReloadTrigger[itemString]) {
|
||||||
handler();
|
handler();
|
||||||
|
|||||||
Reference in New Issue
Block a user