Jaki/SteamWar
1
0
Fork 0
forked from SteamWar/SteamWar
Code Pull Requests Activity

Update Region System of BauSystem

Browse Source
This commit is contained in:
YoyoNow
2024-12-21 19:30:31 +01:00
parent 8427ae36f2
commit 6822dc796f
73 changed files with 927 additions and 1796 deletions
Download Patch File Download Diff File Expand all files Collapse all files
BauSystem/BauSystem_Main/src/de/steamwar/bausystem/region/BackupScheduler.java
+13 -29
View File
@@ -1,33 +1,14 @@
/*
* This file is a part of the SteamWar software.
*
* Copyright (C) 2021 SteamWar.de-Serverteam
*
* This program is free software: you can redistribute it and/or modify
* it under the terms of the GNU Affero General Public License as published by
* the Free Software Foundation, either version 3 of the License, or
* (at your option) any later version.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU Affero General Public License for more details.
*
* You should have received a copy of the GNU Affero General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package de.steamwar.bausystem.region;
import de.steamwar.bausystem.BauSystem;
import de.steamwar.bausystem.region.tags.Tag;
import de.steamwar.bausystem.region.flags.ChangedMode;
import de.steamwar.bausystem.region.flags.Flag;
import de.steamwar.linkage.Linked;
import de.steamwar.linkage.api.Enable;
import org.bukkit.scheduler.BukkitRunnable;
import java.util.Iterator;
@Linked
public class BackupScheduler implements Enable {
@@ -39,26 +20,29 @@ public class BackupScheduler implements Enable {
new BukkitRunnable() {
@Override
public void run() {
final Iterator<Region> regions = Region.getREGION_MAP().values().stream().filter(region -> region.get(Tag.CHANGED)).iterator();
BackupScheduler.this.doBackup(regions);
Iterator<Region> regionsToBackup = RegionSystem.INSTANCE.getRegions()
.filter(region -> region.isFlag(Flag.CHANGED, ChangedMode.HAS_CHANGE))
.iterator();
if (!regionsToBackup.hasNext()) return;
doBackup(regionsToBackup);
}
}.runTaskTimer(BauSystem.getInstance(), INITIAL, PERIOD);
}
public void doBackup(final Iterator<Region> regionIterator) {
private void doBackup(Iterator<Region> regionsToBackup) {
new BukkitRunnable() {
@Override
public void run() {
if (!regionIterator.hasNext()) {
if (!regionsToBackup.hasNext()) {
this.cancel();
return;
}
final Region region = regionIterator.next();
if (region.backup()) {
region.remove(Tag.CHANGED);
Region region = regionsToBackup.next();
if (region.backup(true)) {
region.setFlag(Flag.CHANGED, ChangedMode.NO_CHANGE);
}
}
}.runTaskTimer(BauSystem.getInstance(), 0, 20 * 60);
}
}
}