118 lines
4.4 KiB
Java
118 lines
4.4 KiB
Java
/*
|
|
* PlotSquared, a land and world management plugin for Minecraft.
|
|
* Copyright (C) IntellectualSites <https://intellectualsites.com>
|
|
* Copyright (C) IntellectualSites team and contributors
|
|
*
|
|
* 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 <https://www.gnu.org/licenses/>.
|
|
*/
|
|
package com.plotsquared.core.services.plots;
|
|
|
|
import com.google.common.cache.Cache;
|
|
import com.google.common.cache.CacheBuilder;
|
|
import com.plotsquared.core.plot.Plot;
|
|
import com.plotsquared.core.plot.PlotAreaType;
|
|
import com.plotsquared.core.plot.PlotId;
|
|
import org.checkerframework.checker.nullness.qual.NonNull;
|
|
import org.checkerframework.checker.nullness.qual.Nullable;
|
|
import org.incendo.cloud.services.type.Service;
|
|
|
|
import java.util.Collections;
|
|
import java.util.List;
|
|
import java.util.concurrent.TimeUnit;
|
|
import java.util.function.Predicate;
|
|
|
|
public interface AutoService extends Service<AutoQuery, List<Plot>> {
|
|
|
|
Cache<PlotId, Plot> plotCandidateCache = CacheBuilder.newBuilder()
|
|
.expireAfterWrite(20, TimeUnit.SECONDS).build();
|
|
Object plotLock = new Object();
|
|
|
|
final class DefaultAutoService implements AutoService {
|
|
|
|
@Override
|
|
public List<Plot> handle(final @NonNull AutoQuery autoQuery) {
|
|
return Collections.emptyList();
|
|
}
|
|
|
|
}
|
|
|
|
final class SinglePlotService implements AutoService, Predicate<AutoQuery> {
|
|
|
|
@Nullable
|
|
@Override
|
|
public List<Plot> handle(@NonNull AutoQuery autoQuery) {
|
|
Plot plot;
|
|
PlotId nextId = autoQuery.startId();
|
|
do {
|
|
synchronized (plotLock) {
|
|
plot = autoQuery.plotArea().getNextFreePlot(autoQuery.player(), nextId);
|
|
if (plot != null && plotCandidateCache.getIfPresent(plot.getId()) == null) {
|
|
plotCandidateCache.put(plot.getId(), plot);
|
|
return Collections.singletonList(plot);
|
|
}
|
|
// if the plot is already in the cache, we want to make sure we skip it the next time
|
|
if (plot != null) {
|
|
nextId = plot.getId();
|
|
}
|
|
}
|
|
} while (plot != null);
|
|
return null;
|
|
}
|
|
|
|
@Override
|
|
public boolean test(final @NonNull AutoQuery autoQuery) {
|
|
return autoQuery.sizeX() == 1 && autoQuery.sizeZ() == 1;
|
|
}
|
|
|
|
}
|
|
|
|
final class MultiPlotService implements AutoService, Predicate<AutoQuery> {
|
|
|
|
@Override
|
|
public List<Plot> handle(final @NonNull AutoQuery autoQuery) {
|
|
/* TODO: Add timeout? */
|
|
outer:
|
|
while (true) {
|
|
synchronized (plotLock) {
|
|
final PlotId start =
|
|
autoQuery.plotArea().getMeta("lastPlot", PlotId.of(0, 0)).getNextId();
|
|
final PlotId end = PlotId.of(
|
|
start.getX() + autoQuery.sizeX() - 1,
|
|
start.getY() + autoQuery.sizeZ() - 1
|
|
);
|
|
final List<Plot> plots =
|
|
autoQuery.plotArea().canClaim(autoQuery.player(), start, end);
|
|
autoQuery.plotArea().setMeta("lastPlot", start); // set entry point for next try
|
|
if (plots != null && !plots.isEmpty()) {
|
|
for (final Plot plot : plots) {
|
|
if (plotCandidateCache.getIfPresent(plot.getId()) != null) {
|
|
continue outer;
|
|
}
|
|
plotCandidateCache.put(plot.getId(), plot);
|
|
}
|
|
return plots;
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
@Override
|
|
public boolean test(final @NonNull AutoQuery autoQuery) {
|
|
return autoQuery.plotArea().getType() != PlotAreaType.PARTIAL;
|
|
}
|
|
|
|
}
|
|
|
|
}
|