shuguang/easynode
1
1
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

🐛 修复数据及时更新插入

Browse Source
This commit is contained in:
chaos-zhu 2024-08-15 01:59:00 +08:00
parent 2992563b68
commit fd847c1925
1 changed files with 5 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
server/app/utils/storage.js
View File

@ -49,6 +49,7 @@ const writeSSHRecord = async (record = []) => {
consola.error('清空SSHRecord出错:', err) consola.error('清空SSHRecord出错:', err)
reject(err) reject(err)
} else { } else {
sshRecordDB.compactDatafile()
sshRecordDB.insert(record, (err, newDocs) => { sshRecordDB.insert(record, (err, newDocs) => {
if (err) { if (err) {
consola.error('写入新的ssh记录出错:', err) consola.error('写入新的ssh记录出错:', err)
@ -85,6 +86,7 @@ const writeHostList = async (record = []) => {
consola.error('清空HostList出错:', err) consola.error('清空HostList出错:', err)
reject(err) reject(err)
} else { } else {
hostListDB.compactDatafile()
// 插入新的数据列表 // 插入新的数据列表
hostListDB.insert(record, (err, newDocs) => { hostListDB.insert(record, (err, newDocs) => {
if (err) { if (err) {
@ -184,6 +186,7 @@ const writeNotifyList = async (notifyList) => {
consola.error('清空notify list出错:', err) consola.error('清空notify list出错:', err)
reject(err) reject(err)
} else { } else {
notifyDB.compactDatafile()
notifyDB.insert(notifyList, (err, newDocs) => { notifyDB.insert(notifyList, (err, newDocs) => {
if (err) { if (err) {
consola.error('写入新的notify list出错:', err) consola.error('写入新的notify list出错:', err)
@ -220,6 +223,7 @@ const writeGroupList = async (list = []) => {
consola.error('清空group list出错:', err) consola.error('清空group list出错:', err)
reject(err) reject(err)
} else { } else {
groupDB.compactDatafile()
groupDB.insert(list, (err, newDocs) => { groupDB.insert(list, (err, newDocs) => {
if (err) { if (err) {
consola.error('写入新的group list出错:', err) consola.error('写入新的group list出错:', err)
@ -256,6 +260,7 @@ const writeScriptList = async (list = []) => {
consola.error('清空scripts list出错:', err) consola.error('清空scripts list出错:', err)
reject(err) reject(err)
} else { } else {
scriptsDB.compactDatafile()
scriptsDB.insert(list, (err, newDocs) => { scriptsDB.insert(list, (err, newDocs) => {
if (err) { if (err) {
consola.error('写入新的group list出错:', err) consola.error('写入新的group list出错:', err)