Compare commits
No commits in common. "1a49db245067382853c2b22ff5308a5ee0c6db45" and "bb1d9f316b916cbbde19a3c083a73c7d9f87bb55" have entirely different histories.
1a49db2450
...
bb1d9f316b
|
@ -302,6 +302,10 @@ func (c *connectionService) OpenConnection(name string) (resp types.JSResp) {
|
|||
}
|
||||
}
|
||||
switch selConn.DBFilterType {
|
||||
case "none":
|
||||
for idx := 0; idx < totaldb; idx++ {
|
||||
dbs = append(dbs, queryDB(idx))
|
||||
}
|
||||
case "show":
|
||||
for _, idx := range selConn.DBFilterList {
|
||||
dbs = append(dbs, queryDB(idx))
|
||||
|
@ -312,10 +316,6 @@ func (c *connectionService) OpenConnection(name string) (resp types.JSResp) {
|
|||
dbs = append(dbs, queryDB(idx))
|
||||
}
|
||||
}
|
||||
default:
|
||||
for idx := 0; idx < totaldb; idx++ {
|
||||
dbs = append(dbs, queryDB(idx))
|
||||
}
|
||||
}
|
||||
|
||||
resp.Success = true
|
||||
|
|
|
@ -1,109 +1,55 @@
|
|||
<script setup>
|
||||
import { computed, onMounted, onUnmounted, reactive, watch } from 'vue'
|
||||
import { computed, onMounted, onUnmounted, ref, watch } from 'vue'
|
||||
import { types } from '@/consts/support_redis_type.js'
|
||||
import ContentValueHash from '@/components/content_value/ContentValueHash.vue'
|
||||
import ContentValueList from '@/components/content_value/ContentValueList.vue'
|
||||
import ContentValueString from '@/components/content_value/ContentValueString.vue'
|
||||
import ContentValueSet from '@/components/content_value/ContentValueSet.vue'
|
||||
import ContentValueZset from '@/components/content_value/ContentValueZSet.vue'
|
||||
import { get, isEmpty, keyBy, map, size, toUpper } from 'lodash'
|
||||
import { isEmpty, map, toUpper } from 'lodash'
|
||||
import useTabStore from 'stores/tab.js'
|
||||
import useConnectionStore from 'stores/connections.js'
|
||||
import ContentServerStatus from '@/components/content_value/ContentServerStatus.vue'
|
||||
import ContentValueStream from '@/components/content_value/ContentValueStream.vue'
|
||||
|
||||
/**
|
||||
* @typedef {Object} ServerStatusItem
|
||||
* @property {string} name
|
||||
* @property {Object} info
|
||||
* @property {boolean} autoRefresh
|
||||
* @property {boolean} loading loading status for refresh
|
||||
* @property {boolean} autoLoading loading status for auto refresh
|
||||
*/
|
||||
|
||||
/**
|
||||
*
|
||||
* @type {UnwrapNestedRefs<Object.<string, ServerStatusItem>>}
|
||||
*/
|
||||
const serverStatusTab = reactive({})
|
||||
|
||||
/**
|
||||
*
|
||||
* @param {string} serverName
|
||||
* @return {UnwrapRef<ServerStatusItem>}
|
||||
*/
|
||||
const getServerInfo = (serverName) => {
|
||||
if (isEmpty(serverName)) {
|
||||
return {
|
||||
name: serverName,
|
||||
info: {},
|
||||
autoRefresh: false,
|
||||
autoLoading: false,
|
||||
loading: false,
|
||||
}
|
||||
}
|
||||
if (!serverStatusTab.hasOwnProperty(serverName)) {
|
||||
serverStatusTab[serverName] = {
|
||||
name: serverName,
|
||||
info: {},
|
||||
autoRefresh: false,
|
||||
autoLoading: false,
|
||||
loading: false,
|
||||
}
|
||||
}
|
||||
return serverStatusTab[serverName]
|
||||
}
|
||||
const serverInfo = ref({})
|
||||
const autoRefresh = ref(false)
|
||||
const serverName = computed(() => {
|
||||
if (tabContent.value != null) {
|
||||
return tabContent.value.name
|
||||
}
|
||||
return ''
|
||||
})
|
||||
/**
|
||||
*
|
||||
* @type {ComputedRef<ServerStatusItem>}
|
||||
*/
|
||||
const currentServer = computed(() => {
|
||||
return getServerInfo(serverName.value)
|
||||
})
|
||||
const loadingServerInfo = ref(false)
|
||||
const autoLoadingServerInfo = ref(false)
|
||||
|
||||
/**
|
||||
* refresh server status info
|
||||
* @param {string} serverName
|
||||
* @param {boolean} [force] force refresh will show loading indicator
|
||||
* @returns {Promise<void>}
|
||||
*/
|
||||
const refreshInfo = async (serverName, force) => {
|
||||
const info = getServerInfo(serverName)
|
||||
const refreshInfo = async (force) => {
|
||||
if (force) {
|
||||
info.loading = true
|
||||
loadingServerInfo.value = true
|
||||
} else {
|
||||
info.autoLoading = true
|
||||
autoLoadingServerInfo.value = true
|
||||
}
|
||||
if (!isEmpty(serverName) && connectionStore.isConnected(serverName)) {
|
||||
if (!isEmpty(serverName.value) && connectionStore.isConnected(serverName.value)) {
|
||||
try {
|
||||
info.info = await connectionStore.getServerInfo(serverName)
|
||||
serverInfo.value = await connectionStore.getServerInfo(serverName.value)
|
||||
} finally {
|
||||
info.loading = false
|
||||
info.autoLoading = false
|
||||
loadingServerInfo.value = false
|
||||
autoLoadingServerInfo.value = false
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
const refreshAllInfo = async (force) => {
|
||||
for (const serverName in serverStatusTab) {
|
||||
await refreshInfo(serverName, force)
|
||||
}
|
||||
}
|
||||
|
||||
let intervalId
|
||||
onMounted(() => {
|
||||
refreshAllInfo(true)
|
||||
refreshInfo(true)
|
||||
intervalId = setInterval(() => {
|
||||
for (const serverName in serverStatusTab) {
|
||||
if (get(serverStatusTab, [serverName, 'autoRefresh'])) {
|
||||
refreshInfo(serverName)
|
||||
}
|
||||
if (autoRefresh.value) {
|
||||
refreshInfo()
|
||||
}
|
||||
}, 5000)
|
||||
})
|
||||
|
@ -134,27 +80,11 @@ watch(
|
|||
() => tabStore.nav,
|
||||
(nav) => {
|
||||
if (nav === 'browser') {
|
||||
refreshInfo(serverName.value)
|
||||
refreshInfo()
|
||||
}
|
||||
},
|
||||
)
|
||||
|
||||
watch(
|
||||
() => tabStore.tabList,
|
||||
(tabs) => {
|
||||
if (size(tabs) < size(serverStatusTab)) {
|
||||
const tabMap = keyBy(tabs, 'name')
|
||||
// remove unused server status tab
|
||||
for (const t in serverStatusTab) {
|
||||
if (!tabMap.hasOwnProperty(t)) {
|
||||
delete serverStatusTab[t]
|
||||
}
|
||||
}
|
||||
}
|
||||
},
|
||||
{ deep: true },
|
||||
)
|
||||
|
||||
const tabContent = computed(() => {
|
||||
const tab = tabStore.currentTab
|
||||
if (tab == null) {
|
||||
|
@ -180,6 +110,10 @@ const showNonexists = computed(() => {
|
|||
return tabContent.value.value == null
|
||||
})
|
||||
|
||||
const onUpdateValue = (tabIndex) => {
|
||||
tabStore.switchTab(tabIndex)
|
||||
}
|
||||
|
||||
/**
|
||||
* reload current selection key
|
||||
* @returns {Promise<null>}
|
||||
|
@ -198,12 +132,12 @@ const onReloadKey = async () => {
|
|||
<div v-if="showServerStatus" class="content-container flex-item-expand flex-box-v">
|
||||
<!-- select nothing or select server node, display server status -->
|
||||
<content-server-status
|
||||
v-model:auto-refresh="currentServer.autoRefresh"
|
||||
:info="currentServer.info"
|
||||
:loading="currentServer.loading"
|
||||
:auto-loading="currentServer.autoLoading"
|
||||
:server="currentServer.name"
|
||||
@refresh="refreshInfo(currentServer.name, true)" />
|
||||
v-model:auto-refresh="autoRefresh"
|
||||
:info="serverInfo"
|
||||
:loading="loadingServerInfo"
|
||||
:auto-loading="autoLoadingServerInfo"
|
||||
:server="serverName"
|
||||
@refresh="refreshInfo(true)" />
|
||||
</div>
|
||||
<div v-else-if="showNonexists" class="content-container flex-item-expand flex-box-v">
|
||||
<n-empty :description="$t('interface.nonexist_tab_content')" class="empty-content">
|
||||
|
|
|
@ -261,7 +261,7 @@ const onClose = () => {
|
|||
path="keySeparator">
|
||||
<n-input
|
||||
v-model:value="generalForm.keySeparator"
|
||||
:placeholder="$t('dialogue.connection.advn.separator_tip')" />
|
||||
:placeholder="$t('dialogue.connection.advn_separator_tip')" />
|
||||
</n-form-item-gi>
|
||||
<n-form-item-gi
|
||||
:span="12"
|
||||
|
|
|
@ -21,7 +21,7 @@ import usePreferencesStore from 'stores/preferences.js'
|
|||
|
||||
const themeVars = useThemeVars()
|
||||
const i18n = useI18n()
|
||||
const connectingServer = ref('')
|
||||
const openingConnection = ref(false)
|
||||
const connectionStore = useConnectionStore()
|
||||
const tabStore = useTabStore()
|
||||
const prefStore = usePreferencesStore()
|
||||
|
@ -287,21 +287,18 @@ const onUpdateSelectedKeys = (keys, option) => {
|
|||
*/
|
||||
const openConnection = async (name) => {
|
||||
try {
|
||||
connectingServer.value = name
|
||||
if (!connectionStore.isConnected(name)) {
|
||||
openingConnection.value = true
|
||||
await connectionStore.openConnection(name)
|
||||
}
|
||||
// check if connection already canceled before finish open
|
||||
if (!isEmpty(connectingServer.value)) {
|
||||
tabStore.upsertTab({
|
||||
server: name,
|
||||
})
|
||||
}
|
||||
tabStore.upsertTab({
|
||||
server: name,
|
||||
})
|
||||
} catch (e) {
|
||||
$message.error(e.message)
|
||||
// node.isLeaf = undefined
|
||||
} finally {
|
||||
connectingServer.value = ''
|
||||
openingConnection.value = false
|
||||
}
|
||||
}
|
||||
|
||||
|
@ -470,13 +467,6 @@ const handleDrop = ({ node, dragNode, dropPosition }) => {
|
|||
connectionStore.connections = Array.from(connectionStore.connections)
|
||||
saveSort()
|
||||
}
|
||||
|
||||
const onCancelOpen = () => {
|
||||
if (!isEmpty(connectingServer.value)) {
|
||||
connectionStore.closeConnection(connectingServer.value)
|
||||
connectingServer.value = ''
|
||||
}
|
||||
}
|
||||
</script>
|
||||
|
||||
<template>
|
||||
|
@ -506,7 +496,7 @@ const onCancelOpen = () => {
|
|||
@update:expanded-keys="onUpdateExpandedKeys" />
|
||||
|
||||
<!-- status display modal -->
|
||||
<n-modal :show="connectingServer !== ''" transform-origin="center">
|
||||
<n-modal :show="openingConnection" transform-origin="center">
|
||||
<n-card
|
||||
:bordered="false"
|
||||
:content-style="{ textAlign: 'center' }"
|
||||
|
@ -515,12 +505,7 @@ const onCancelOpen = () => {
|
|||
style="width: 400px">
|
||||
<n-spin>
|
||||
<template #description>
|
||||
<n-space vertical>
|
||||
<n-text strong>{{ $t('dialogue.opening_connection') }}</n-text>
|
||||
<n-button secondary size="small" :focusable="false" @click="onCancelOpen">
|
||||
{{ $t('dialogue.interrupt_connection') }}
|
||||
</n-button>
|
||||
</n-space>
|
||||
{{ $t('dialogue.opening_connection') }}
|
||||
</template>
|
||||
</n-spin>
|
||||
</n-card>
|
||||
|
|
|
@ -99,7 +99,6 @@
|
|||
"close_confirm": "Confirm close this tab and connection",
|
||||
"edit_close_confirm": "Please close the relevant connections before editing. Do you want to continue?",
|
||||
"opening_connection": "Opening Connection...",
|
||||
"interrupt_connection": "Cancel",
|
||||
"remove_tip": "{type} \"{name}\" will be deleted",
|
||||
"remove_group_tip": "Group \"{name}\" and all connections in it will be deleted",
|
||||
"delete_key_succ": "\"{key}\" has been deleted",
|
||||
|
|
|
@ -99,7 +99,6 @@
|
|||
"close_confirm": "是否关闭当前连接",
|
||||
"edit_close_confirm": "编辑前需要关闭相关连接,是否继续",
|
||||
"opening_connection": "正在打开连接...",
|
||||
"interrupt_connection": "中断连接",
|
||||
"remove_tip": "{type} \"{name}\" 将会被删除",
|
||||
"remove_group_tip": "分组 \"{name}\"及其所有连接将会被删除",
|
||||
"delete_key_succ": "{key} 已被删除",
|
||||
|
|
|
@ -105,7 +105,6 @@ export async function setupDiscreteApi() {
|
|||
configProviderProps,
|
||||
messageProviderProps: {
|
||||
placement: 'bottom-right',
|
||||
keepAliveOnHover: true,
|
||||
},
|
||||
notificationProviderProps: {
|
||||
max: 5,
|
||||
|
|
Loading…
Reference in New Issue