-
-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
Showing
2 changed files
with
136 additions
and
136 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
268 changes: 134 additions & 134 deletions
268
src/main/java/me/ryanhamshire/GriefPrevention/DeliverClaimBlocksTask.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -1,134 +1,134 @@ | ||
| /* | ||
| GriefPrevention Server Plugin for Minecraft | ||
| Copyright (C) 2012 Ryan Hamshire | ||
| This program is free software: you can redistribute it and/or modify | ||
| it under the terms of the GNU 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 General Public License for more details. | ||
| You should have received a copy of the GNU General Public License | ||
| along with this program. If not, see <http://www.gnu.org/licenses/>. | ||
| */ | ||
|
|
||
| package me.ryanhamshire.GriefPrevention; | ||
|
|
||
| import me.ryanhamshire.GriefPrevention.events.AccrueClaimBlocksEvent; | ||
| import org.bukkit.Location; | ||
| import org.bukkit.entity.Player; | ||
|
|
||
| import java.util.Collection; | ||
| import java.util.concurrent.TimeUnit; | ||
|
|
||
| //FEATURE: give players claim blocks for playing, as long as they're not away from their computer | ||
|
|
||
| //runs every 5 minutes in the main thread, grants blocks per hour / 12 to each online player who appears to be actively playing | ||
| class DeliverClaimBlocksTask implements Runnable | ||
| { | ||
| private final Player player; | ||
| private final GriefPrevention instance; | ||
| private final int idleThresholdSquared; | ||
|
|
||
| public DeliverClaimBlocksTask(Player player, GriefPrevention instance) | ||
| { | ||
| this.player = player; | ||
| this.instance = instance; | ||
| this.idleThresholdSquared = instance.config_claims_accruedIdleThreshold * instance.config_claims_accruedIdleThreshold; | ||
| } | ||
|
|
||
| @Override | ||
| public void run() | ||
| { | ||
| //if no player specified, this task will create a player-specific task for each online player, scheduled one tick apart | ||
| if (this.player == null) | ||
| { | ||
| @SuppressWarnings("unchecked") | ||
| Collection<Player> players = (Collection<Player>) GriefPrevention.instance.getServer().getOnlinePlayers(); | ||
|
|
||
| long i = 1; | ||
| for (Player onlinePlayer : players) | ||
| { | ||
| DeliverClaimBlocksTask newTask = new DeliverClaimBlocksTask(onlinePlayer, instance); | ||
| GriefPrevention.scheduler.getImpl().runAtEntityLater(onlinePlayer, newTask, 50L * i++, TimeUnit.MILLISECONDS); | ||
| } | ||
|
|
||
| return; //tasks started for each player | ||
| } | ||
|
|
||
| //deliver claim blocks to the specified player | ||
| if (!this.player.isOnline()) | ||
| { | ||
| return; //player is not online to receive claim blocks | ||
| } | ||
|
|
||
| DataStore dataStore = instance.dataStore; | ||
| PlayerData playerData = dataStore.getPlayerData(player.getUniqueId()); | ||
|
|
||
| // check if player is idle. considered idle if | ||
| // in vehicle or is in water (pushed by water) | ||
| // or has not moved at least defined blocks since last check | ||
| boolean isIdle = false; | ||
| try | ||
| { | ||
| Location loc = player.getLocation(); | ||
| boolean inLoadedChunk = player.getWorld().isChunkLoaded(player.getLocation().getBlockX() >> 4, | ||
| player.getLocation().getBlockZ() >> 4); | ||
|
|
||
| isIdle = player.isInsideVehicle() || (inLoadedChunk && loc.getBlock().isLiquid()) || | ||
| !(playerData.lastAfkCheckLocation == null || playerData.lastAfkCheckLocation.distanceSquared(loc) > idleThresholdSquared); | ||
| } | ||
| catch (IllegalArgumentException ignore) //can't measure distance when to/from are different worlds | ||
| { | ||
| } | ||
|
|
||
| //remember current location for next time | ||
| playerData.lastAfkCheckLocation = player.getLocation(); | ||
|
|
||
| try | ||
| { | ||
| //determine how fast blocks accrue for this player //RoboMWM: addons determine this instead | ||
| int accrualRate = instance.getBlocksAccruedPerHour(player); | ||
|
|
||
| //determine idle accrual rate when idle | ||
| if (isIdle) | ||
| { | ||
| if (instance.config_claims_accruedIdlePercent <= 0) | ||
| { | ||
| GriefPrevention.AddLogEntry(player.getName() + " wasn't active enough to accrue claim blocks this round.", CustomLogEntryTypes.Debug, false); | ||
| return; //idle accrual percentage is disabled | ||
| } | ||
|
|
||
| accrualRate = (int) (accrualRate * (instance.config_claims_accruedIdlePercent / 100.0D)); | ||
| } | ||
|
|
||
| //fire event for addons | ||
| AccrueClaimBlocksEvent event = new AccrueClaimBlocksEvent(player, accrualRate, isIdle); | ||
| instance.getServer().getPluginManager().callEvent(event); | ||
| if (event.isCancelled()) | ||
| { | ||
| GriefPrevention.AddLogEntry(player.getName() + " claim block delivery was canceled by another plugin.", CustomLogEntryTypes.Debug, false); | ||
| return; //event was cancelled | ||
| } | ||
|
|
||
| //set actual accrual | ||
| accrualRate = event.getBlocksToAccrue(); | ||
| if (accrualRate < 0) accrualRate = 0; | ||
| playerData.accrueBlocks(accrualRate); | ||
| GriefPrevention.AddLogEntry("Delivering " + event.getBlocksToAccrue() + " blocks to " + player.getName(), CustomLogEntryTypes.Debug, false); | ||
|
|
||
| //intentionally NOT saving data here to reduce overall secondary storage access frequency | ||
| //many other operations will cause this player's data to save, including his eventual logout | ||
| //dataStore.savePlayerData(player.getUniqueIdentifier(), playerData); | ||
| } | ||
| catch (Exception e) | ||
| { | ||
| GriefPrevention.AddLogEntry("Problem delivering claim blocks to player " + player.getName() + ":"); | ||
| e.printStackTrace(); | ||
| } | ||
| } | ||
| } | ||
| /* | ||
| GriefPrevention Server Plugin for Minecraft | ||
| Copyright (C) 2012 Ryan Hamshire | ||
| This program is free software: you can redistribute it and/or modify | ||
| it under the terms of the GNU 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 General Public License for more details. | ||
| You should have received a copy of the GNU General Public License | ||
| along with this program. If not, see <http://www.gnu.org/licenses/>. | ||
| */ | ||
|
|
||
| package me.ryanhamshire.GriefPrevention; | ||
|
|
||
| import me.ryanhamshire.GriefPrevention.events.AccrueClaimBlocksEvent; | ||
| import org.bukkit.Location; | ||
| import org.bukkit.entity.Player; | ||
|
|
||
| import java.util.Collection; | ||
| import java.util.concurrent.TimeUnit; | ||
|
|
||
| //FEATURE: give players claim blocks for playing, as long as they're not away from their computer | ||
|
|
||
| //runs every 5 minutes in the main thread, grants blocks per hour / 12 to each online player who appears to be actively playing | ||
| class DeliverClaimBlocksTask implements Runnable | ||
| { | ||
| private final Player player; | ||
| private final GriefPrevention instance; | ||
| private final int idleThresholdSquared; | ||
|
|
||
| public DeliverClaimBlocksTask(Player player, GriefPrevention instance) | ||
| { | ||
| this.player = player; | ||
| this.instance = instance; | ||
| this.idleThresholdSquared = instance.config_claims_accruedIdleThreshold * instance.config_claims_accruedIdleThreshold; | ||
| } | ||
|
|
||
| @Override | ||
| public void run() | ||
| { | ||
| //if no player specified, this task will create a player-specific task for each online player, scheduled one tick apart | ||
| if (this.player == null) | ||
| { | ||
| @SuppressWarnings("unchecked") | ||
| Collection<Player> players = (Collection<Player>) GriefPrevention.instance.getServer().getOnlinePlayers(); | ||
|
|
||
| long i = 1; | ||
| for (Player onlinePlayer : players) | ||
| { | ||
| DeliverClaimBlocksTask newTask = new DeliverClaimBlocksTask(onlinePlayer, instance); | ||
| GriefPrevention.scheduler.getImpl().runAtEntityLater(onlinePlayer, newTask, 50L * i++, TimeUnit.MILLISECONDS); | ||
| } | ||
|
|
||
| return; //tasks started for each player | ||
| } | ||
|
|
||
| //deliver claim blocks to the specified player | ||
| if (!this.player.isOnline()) | ||
| { | ||
| return; //player is not online to receive claim blocks | ||
| } | ||
|
|
||
| DataStore dataStore = instance.dataStore; | ||
| PlayerData playerData = dataStore.getPlayerData(player.getUniqueId()); | ||
|
|
||
| // check if player is idle. considered idle if | ||
| // in vehicle or is in water (pushed by water) | ||
| // or has not moved at least defined blocks since last check | ||
| boolean isIdle = false; | ||
| try | ||
| { | ||
| Location loc = player.getLocation(); | ||
| boolean inLoadedChunk = player.getWorld().isChunkLoaded(player.getLocation().getBlockX() >> 4, | ||
| player.getLocation().getBlockZ() >> 4); | ||
|
|
||
| isIdle = player.isInsideVehicle() || (inLoadedChunk && loc.getBlock().isLiquid()) || | ||
| !(playerData.lastAfkCheckLocation == null || playerData.lastAfkCheckLocation.distanceSquared(loc) > idleThresholdSquared); | ||
| } | ||
| catch (IllegalArgumentException ignore) //can't measure distance when to/from are different worlds | ||
| { | ||
| } | ||
|
|
||
| //remember current location for next time | ||
| playerData.lastAfkCheckLocation = player.getLocation(); | ||
|
|
||
| try | ||
| { | ||
| //determine how fast blocks accrue for this player //RoboMWM: addons determine this instead | ||
| int accrualRate = instance.getBlocksAccruedPerHour(player); | ||
|
|
||
| //determine idle accrual rate when idle | ||
| if (isIdle) | ||
| { | ||
| if (instance.config_claims_accruedIdlePercent <= 0) | ||
| { | ||
| GriefPrevention.AddLogEntry(player.getName() + " wasn't active enough to accrue claim blocks this round.", CustomLogEntryTypes.Debug, false); | ||
| return; //idle accrual percentage is disabled | ||
| } | ||
|
|
||
| accrualRate = (int) (accrualRate * (instance.config_claims_accruedIdlePercent / 100.0D)); | ||
| } | ||
|
|
||
| //fire event for addons | ||
| AccrueClaimBlocksEvent event = new AccrueClaimBlocksEvent(player, accrualRate, isIdle); | ||
| instance.getServer().getPluginManager().callEvent(event); | ||
| if (event.isCancelled()) | ||
| { | ||
| GriefPrevention.AddLogEntry(player.getName() + " claim block delivery was canceled by another plugin.", CustomLogEntryTypes.Debug, false); | ||
| return; //event was cancelled | ||
| } | ||
|
|
||
| //set actual accrual | ||
| accrualRate = event.getBlocksToAccrue(); | ||
| if (accrualRate < 0) accrualRate = 0; | ||
| playerData.accrueBlocks(accrualRate); | ||
| GriefPrevention.AddLogEntry("Delivering " + event.getBlocksToAccrue() + " blocks to " + player.getName(), CustomLogEntryTypes.Debug, false); | ||
|
|
||
| //intentionally NOT saving data here to reduce overall secondary storage access frequency | ||
| //many other operations will cause this player's data to save, including his eventual logout | ||
| //dataStore.savePlayerData(player.getUniqueIdentifier(), playerData); | ||
| } | ||
| catch (Exception e) | ||
| { | ||
| GriefPrevention.AddLogEntry("Problem delivering claim blocks to player " + player.getName() + ":"); | ||
| e.printStackTrace(); | ||
| } | ||
| } | ||
| } |