dennii/dbgate
1
0
Fork 0
mirror of https://github.com/DeNNiiInc/dbgate.git synced 2026-04-24 19:56:00 +00:00
Code Issues Packages Projects Releases Wiki Activity

fixed unwanted closing connections

Browse Source
This commit is contained in:
Jan Prochazka
2021-01-23 08:44:41 +01:00
parent fa29bc65dc
commit 19a39d4a83
3 changed files with 16 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
packages/api/src/proc/databaseConnectionProcess.js
View File

@@ -120,7 +120,7 @@ function start() {
setInterval(() => { setInterval(() => {
const time = new Date().getTime(); const time = new Date().getTime();
if (time - lastPing > 60 * 1000) { if (time - lastPing > 120 * 1000) {
console.log('Database connection not alive, exiting'); console.log('Database connection not alive, exiting');
process.exit(0); process.exit(0);
} }

3
packages/api/src/proc/serverConnectionProcess.js
View File

@@ -89,7 +89,8 @@ function start() {
setInterval(() => { setInterval(() => {
const time = new Date().getTime(); const time = new Date().getTime();
if (time - lastPing > 60 * 1000) { if (time - lastPing > 120 * 1000) {
console.log('Server connection not alive, exiting');
process.exit(0); process.exit(0);
} }
}, 60 * 1000); }, 60 * 1000);

22
packages/web/src/utility/ConnectionsPinger.js
View File

@@ -6,16 +6,20 @@ import axios from './axios';
export default function ConnectionsPinger({ children }) { export default function ConnectionsPinger({ children }) {
const openedConnections = useOpenedConnections(); const openedConnections = useOpenedConnections();
const currentDatabase = useCurrentDatabase(); const currentDatabase = useCurrentDatabase();
React.useEffect(() => {
const handle = window.setInterval(() => {
axios.post('server-connections/ping', { connections: openedConnections });
const database = _.get(currentDatabase, 'name'); const doPing = () => {
const conid = _.get(currentDatabase, 'connection._id'); axios.post('server-connections/ping', { connections: openedConnections });
if (conid && database) {
axios.post('database-connections/ping', { conid, database }); const database = _.get(currentDatabase, 'name');
} const conid = _.get(currentDatabase, 'connection._id');
}, 30 * 1000); if (conid && database) {
axios.post('database-connections/ping', { conid, database });
}
};
React.useEffect(() => {
doPing();
const handle = window.setInterval(doPing, 30 * 1000);
return () => window.clearInterval(handle); return () => window.clearInterval(handle);
}, [openedConnections, currentDatabase]); }, [openedConnections, currentDatabase]);
return children; return children;