Compare commits

..

No commits in common. "1a49db245067382853c2b22ff5308a5ee0c6db45" and "bb1d9f316b916cbbde19a3c083a73c7d9f87bb55" have entirely different histories.

7 changed files with 40 additions and 124 deletions

View File

@ -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

View File

@ -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">

View File

@ -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"

View File

@ -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>

View File

@ -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",

View File

@ -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} 已被删除",

View File

@ -105,7 +105,6 @@ export async function setupDiscreteApi() {
configProviderProps,
messageProviderProps: {
placement: 'bottom-right',
keepAliveOnHover: true,
},
notificationProviderProps: {
max: 5,