Skip to content

Commit

Permalink
Add event for scheduled block updates (#2571)
Browse files Browse the repository at this point in the history
  • Loading branch information
aromaa authored Nov 6, 2024
1 parent 5b10dcc commit 0fcd92c
Show file tree
Hide file tree
Showing 2 changed files with 170 additions and 0 deletions.
Original file line number Diff line number Diff line change
@@ -0,0 +1,88 @@
/*
* This file is part of SpongeAPI, licensed under the MIT License (MIT).
*
* Copyright (c) SpongePowered <https://www.spongepowered.org>
* Copyright (c) contributors
*
* Permission is hereby granted, free of charge, to any person obtaining a copy
* of this software and associated documentation files (the "Software"), to deal
* in the Software without restriction, including without limitation the rights
* to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
* copies of the Software, and to permit persons to whom the Software is
* furnished to do so, subject to the following conditions:
*
* The above copyright notice and this permission notice shall be included in
* all copies or substantial portions of the Software.
*
* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
* IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
* FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
* AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
* LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
* OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
* THE SOFTWARE.
*/
package org.spongepowered.api.block.transaction;

import org.spongepowered.api.scheduler.ScheduledUpdate;
import org.spongepowered.api.scheduler.TaskPriority;
import org.spongepowered.api.world.LocatableBlock;

import java.time.Duration;

/**
* Represents a {@link ScheduledUpdate scheduled block update} that
* is being proposed to the engine.
*/
public interface ScheduleUpdateTicket<T> {

/**
* Gets the target block of this scheduled update.
*
* @return The target block
*/
LocatableBlock block();

/**
* Gets the target of this scheduled update.
*
* @return The target
*/
T target();

/**
* Gets the {@link Duration delay} until this update
* should cause the block to update.
*
* @return The delay until this SBU should cause the block to update
*/
Duration delay();

/**
* Gets the priority of this scheduled block update.
*
* @return The priority of this scheduled block update
*/
TaskPriority priority();

/**
* Gets whether this ticket is marked as valid.
*
* @return The valid state of this ticket
*/
boolean valid();

/**
* Sets whether this ticket is valid or not.
*
* @param valid The valid state of this ticket
*/
void setValid(boolean valid);

/**
* Invalidates this ticket.
*/
default void invalidate() {
this.setValid(false);
}
}
Original file line number Diff line number Diff line change
@@ -0,0 +1,82 @@
/*
* This file is part of SpongeAPI, licensed under the MIT License (MIT).
*
* Copyright (c) SpongePowered <https://www.spongepowered.org>
* Copyright (c) contributors
*
* Permission is hereby granted, free of charge, to any person obtaining a copy
* of this software and associated documentation files (the "Software"), to deal
* in the Software without restriction, including without limitation the rights
* to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
* copies of the Software, and to permit persons to whom the Software is
* furnished to do so, subject to the following conditions:
*
* The above copyright notice and this permission notice shall be included in
* all copies or substantial portions of the Software.
*
* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
* IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
* FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
* AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
* LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
* OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
* THE SOFTWARE.
*/
package org.spongepowered.api.event.block;

import org.spongepowered.api.block.transaction.ScheduleUpdateTicket;
import org.spongepowered.api.event.Cancellable;
import org.spongepowered.api.event.GenericEvent;
import org.spongepowered.api.scheduler.ScheduledUpdate;
import org.spongepowered.api.world.server.ServerLocation;

import java.util.List;
import java.util.function.Predicate;

/**
* Fired when a {@link ScheduledUpdate scheduled block update}
* is being proposed to the engine.
*/
public interface ScheduleBlockUpdateEvent<T extends Object> extends GenericEvent<T>, Cancellable {

/**
* Gets a list of the {@link ScheduleUpdateTicket}s for this event.
* If a ticket is requested to be marked as "invalid",
* {@link ScheduleUpdateTicket#setValid(boolean)} can be used.
*
* @return The unmodifiable list of tickets
*/
List<ScheduleUpdateTicket<T>> tickets();

/**
* Applies the provided {@link Predicate} to the {@link List} of
* {@link ScheduleUpdateTicket}s from {@link #tickets()} such that
* any time that {@link Predicate#test(Object)} returns {@code false}
* on the location of the {@link ScheduleUpdateTicket}, the
* {@link ScheduleUpdateTicket} is marked as "invalid".
*
* <p>{@link ScheduleUpdateTicket#block()} is used to get the {@link ServerLocation}</p>
*
* @param predicate The predicate to use for filtering
*/
default void filterTargetPositions(final Predicate<ServerLocation> predicate) {
this.filterTickets(t -> predicate.test(t.block().serverLocation()));
}

/**
* Applies the provided {@link Predicate} to the {@link List} of
* {@link ScheduleUpdateTicket}s from {@link #tickets()} such that
* any time that {@link Predicate#test(Object)} returns {@code false}
* on the location of the {@link ScheduleUpdateTicket}, the
* {@link ScheduleUpdateTicket} is marked as "invalid".
*
* @param predicate The predicate to use for filtering
*/
default void filterTickets(final Predicate<ScheduleUpdateTicket<T>> predicate) {
this.tickets().forEach(ticket -> {
if (!predicate.test(ticket)) {
ticket.setValid(false);
}
});
}
}

0 comments on commit 0fcd92c

Please sign in to comment.