zoriya/flood
1
0
Fork 0
mirror of https://github.com/zoriya/flood.git synced 2025-12-06 07:16:18 +00:00
Code Issues Packages Projects Releases Wiki Activity

client: migrate from Flux to MobX

Browse Source
This commit is contained in:
Jesse Chan
2020-10-23 13:20:10 +08:00
parent 4908617503
commit 0e57e36663
108 changed files with 2328 additions and 4971 deletions
Download Patch File Download Diff File Expand all files Collapse all files

35
server/services/historyService.ts
View File

@@ -6,15 +6,8 @@ import type {TransferHistory, TransferSummary} from '@shared/types/TransferData'
import BaseService from './BaseService';
import config from '../../config';
import HistoryEra from '../models/HistoryEra';
import historySnapshotTypes from '../../shared/constants/historySnapshotTypes';
type HistorySnapshotEvents = {
// TODO: Switch to string literal template type when TypeScript 4.1 is released.
// [snapshot in `${HistorySnapshot}_SNAPSHOT_FULL_UPDATE`]: (payload: {id: number, data: TransferHistory}) => void;
FIVE_MINUTE_SNAPSHOT_FULL_UPDATE: (payload: {id: number; data: TransferHistory}) => void;
};
interface HistoryServiceEvents extends HistorySnapshotEvents {
interface HistoryServiceEvents {
TRANSFER_SUMMARY_DIFF_CHANGE: (payload: {id: number; diff: Operation[]}) => void;
FETCH_TRANSFER_SUMMARY_SUCCESS: () => void;
FETCH_TRANSFER_SUMMARY_ERROR: () => void;
@@ -106,31 +99,6 @@ class HistoryService extends BaseService<HistoryServiceEvents> {
};
}
checkSnapshotDiffs() {
historySnapshotTypes.forEach((snapshotType: Readonly<HistorySnapshot>) => {
this.getHistory({snapshot: snapshotType}, (nextSnapshot, error) => {
if (error || nextSnapshot == null) {
return;
}
const lastSnapshot = this.lastSnapshots[snapshotType] || {timestamps: []};
const {timestamps} = lastSnapshot;
const nextLastTimestamp = timestamps[timestamps.length - 1];
const prevLastTimestamp = nextSnapshot.timestamps[nextSnapshot.timestamps.length - 1];
if (nextLastTimestamp !== prevLastTimestamp) {
this.emit(`${snapshotType}_SNAPSHOT_FULL_UPDATE` as `FIVE_MINUTE_SNAPSHOT_FULL_UPDATE`, {
id: nextLastTimestamp,
data: nextSnapshot,
});
}
this.lastSnapshots[snapshotType] = nextSnapshot;
});
});
}
deferFetchTransferSummary(interval = config.torrentClientPollInterval || 2000) {
this.pollTimeout = setTimeout(this.fetchCurrentTransferSummary, interval);
}
@@ -198,7 +166,6 @@ class HistoryService extends BaseService<HistoryServiceEvents> {
download: nextTransferSummary.downRate,
});
this.checkSnapshotDiffs();
this.deferFetchTransferSummary();
this.emit('FETCH_TRANSFER_SUMMARY_SUCCESS');