|
|
@@ -110,10 +110,10 @@ export class WebdavManager {
|
|
|
|
|
|
public notifyObservers(event: string): void {
|
|
|
Logger.info(TAG, '通知观察者:', event);
|
|
|
- Logger.debug(TAG, '观察者数量:', this.observers.length.toString());
|
|
|
+ Logger.info(TAG, '观察者数量:', this.observers.length.toString());
|
|
|
for (let i = 0; i < this.observers.length; i++) {
|
|
|
const observer = this.observers[i];
|
|
|
- Logger.debug(TAG, '调用观察者', i.toString(), ',事件:', event);
|
|
|
+ Logger.info(TAG, '调用观察者', i.toString(), ',事件:', event);
|
|
|
observer(event);
|
|
|
}
|
|
|
}
|
|
|
@@ -150,12 +150,12 @@ export class WebdavManager {
|
|
|
}
|
|
|
|
|
|
// 从数据库查询所有账户
|
|
|
- public async queryWebDavAccountsFromDB(notify: boolean = true): Promise<void> {
|
|
|
+ public async queryWebDavAccountsFromDB(): Promise<void> {
|
|
|
try {
|
|
|
const predicates = new relationalStore.RdbPredicates(this.webDavTable);
|
|
|
const columns = ['id', 'name', 'isActivate', 'host', 'localHost', 'isUseLocalHost',
|
|
|
- 'port', 'filepath', 'imageFilePath', 'lyricFilePath', 'uploadFilePath',
|
|
|
- 'account', 'password', 'enableHttps'];
|
|
|
+ 'port', 'filepath', 'imageFilePath', 'lyricFilePath', 'uploadFilePath',
|
|
|
+ 'account', 'password', 'enableHttps'];
|
|
|
|
|
|
const resultSet = await this.dataBaseUtil.queryData(this.webDavTable, columns, predicates);
|
|
|
|
|
|
@@ -182,15 +182,11 @@ export class WebdavManager {
|
|
|
resultSet.close();
|
|
|
|
|
|
Logger.info(TAG, '从数据库加载了', this.webDavAccounts.length.toString(), '个WebDAV账户');
|
|
|
- if (notify) {
|
|
|
- this.notifyObservers(WebdavManagerStates.QueryAccountsSucceed);
|
|
|
- }
|
|
|
+ this.notifyObservers(WebdavManagerStates.QueryAccountsSucceed);
|
|
|
} catch (err) {
|
|
|
const error = err as Error;
|
|
|
Logger.error(TAG, '查询WebDAV账户失败:', error.message);
|
|
|
- if (notify) {
|
|
|
- this.notifyObservers(WebdavManagerStates.QueryAccountsFailed);
|
|
|
- }
|
|
|
+ this.notifyObservers(WebdavManagerStates.QueryAccountsFailed);
|
|
|
throw error;
|
|
|
}
|
|
|
}
|
|
|
@@ -230,7 +226,7 @@ export class WebdavManager {
|
|
|
await this.dataBaseUtil.insertData(this.webDavTable, values);
|
|
|
Logger.info(TAG, '插入WebDAV账户成功:', name);
|
|
|
|
|
|
- await this.queryWebDavAccountsFromDB(false); // 不通知观察者,避免循环
|
|
|
+ await this.queryWebDavAccountsFromDB();
|
|
|
this.notifyObservers(WebdavManagerStates.InsertAccountSucceed);
|
|
|
} catch (err) {
|
|
|
const error = err as Error;
|
|
|
@@ -265,7 +261,7 @@ export class WebdavManager {
|
|
|
await this.dataBaseUtil.updateData(this.webDavTable, values, predicates);
|
|
|
Logger.info(TAG, '更新WebDAV账户成功:', account.name);
|
|
|
|
|
|
- await this.queryWebDavAccountsFromDB(false); // 不通知观察者,避免循环
|
|
|
+ await this.queryWebDavAccountsFromDB();
|
|
|
this.notifyObservers(WebdavManagerStates.EditAccountSucceed);
|
|
|
} catch (err) {
|
|
|
const error = err as Error;
|
|
|
@@ -284,7 +280,7 @@ export class WebdavManager {
|
|
|
await this.dataBaseUtil.deleteData(predicates);
|
|
|
Logger.info(TAG, '删除WebDAV账户成功:', account.name);
|
|
|
|
|
|
- await this.queryWebDavAccountsFromDB(false); // 不通知观察者,避免循环
|
|
|
+ await this.queryWebDavAccountsFromDB();
|
|
|
this.notifyObservers(WebdavManagerStates.RemoveAccountSucceed);
|
|
|
} catch (err) {
|
|
|
const error = err as Error;
|