Uses of Class
com.ultikits.ultitools.websocket.CloudRequest
Packages that use CloudRequest
Package
Description
UltiPanel WebSocket client internals, and the three stable extension points modules use.
-
Uses of CloudRequest in com.ultikits.ultitools.manager
Methods in com.ultikits.ultitools.manager with parameters of type CloudRequestModifier and TypeMethodDescriptionprivate voidRemoteFileOperations.delete(CloudRequest request, CloudChannel channel) Answersfiles.delete: removes one file, or one symbolic link as the link itself.private voidRemotePropertiesHandler.get(CloudRequest request, CloudChannel channel) Answersproperties.get.voidAgentTelemetry.handle(CloudRequest request, CloudChannel channel) Handlessnapshot.request: pushes the requested snapshots in request order and then answerssnapshot.request.resultwith what was sent (SEMANTICS item 4, checker B-W3).voidRemoteFileOperations.handle(CloudRequest request, CloudChannel channel) voidRemotePropertiesHandler.handle(CloudRequest request, CloudChannel channel) private voidRemoteFileOperations.list(CloudRequest request, CloudChannel channel) Answersfiles.list: one directory's entries, with the size and modification time of files (nullfor directories), or — for the empty path — the configured editable roots, which is what the contract means by the server root: the panel may browse no further up than the operator's grant.private voidRemoteFileOperations.read(CloudRequest request, CloudChannel channel) Answersfiles.read: the file's content decoded as strict UTF-8, its size in bytes and the SHA-256 of exactly those bytes — the version a laterfiles.writemust send back as itsbaseVersion.AgentTelemetry.requestedTargets(CloudRequest request) private voidRemotePropertiesHandler.update(CloudRequest request, CloudChannel channel) Answersproperties.update.private voidRemoteFileOperations.write(CloudRequest request, CloudChannel channel) Answersfiles.write: replaces an existing file's content when, and only when, the panel'sbaseVersionstill equals the SHA-256 of the bytes on disk. -
Uses of CloudRequest in com.ultikits.ultitools.utils
Fields in com.ultikits.ultitools.utils with type parameters of type CloudRequestModifier and TypeFieldDescriptionprivate final List<Consumer<CloudRequest>> AgentProtocol.replyListenersMethods in com.ultikits.ultitools.utils that return CloudRequestMethods in com.ultikits.ultitools.utils with parameters of type CloudRequestModifier and TypeMethodDescriptionprivate voidPlayerActionHandler.completeTeleport(CloudChannel channel, CloudRequest request, PlayerActionHandler.Action action, Boolean completed, Throwable error) Answers the teleport once its future completes.private CloudPlayerLinks.LinkCompletionPlayerLinkChannel.completionOf(CloudRequest request) private voidPlayerActionHandler.deny(CloudChannel channel, CloudRequest request, PlayerActionHandler.Action action, String code, String message) private org.bukkit.LocationPlayerActionHandler.destination(CloudChannel channel, CloudRequest request, PlayerActionHandler.Action action, org.bukkit.entity.Player subject) Resolves the destination, answeringplayer_not_onlineorworld_not_foundand returning null when the target cannot be resolved.private voidPowerActionHandler.execute(CloudRequest request, CloudChannel channel, String action) Runs once per newly recorded id: the operator switch, then (for a restart) the restart pre-check, then the result, the pre-shutdown hook and the scheduled power action in that order.private voidPlayerActionHandler.fail(CloudChannel channel, CloudRequest request, PlayerActionHandler.Action action, Throwable error) Maps a throwing call to the contract'sinternal_errorwith one fixed message: the exception class and stack stay in the local log and never reach the wire, as in the agent router (22-08).(package private) static voidAckFirstGate.handle(CloudRequest request, CloudChannel channel, DedupeLedger ledger, Runnable execute) Records and persists a new id under the shared ledger monitor, then releases the monitor before acknowledging and executing.voidCredentialRotationHandler.handle(CloudRequest request, CloudChannel channel) voidModuleRequestHandler.handle(CloudRequest request, CloudChannel channel) Validates onemodule.requestand hands it to its owning module's responder.voidPlayerActionHandler.handle(CloudRequest request, CloudChannel channel) Validates the payload on the dispatching thread, then performs the action on the main thread.voidPowerActionHandler.handle(CloudRequest request, CloudChannel channel) Validates the action, then runs persist-acknowledge-execute.voidRemoteCommandHandler.handle(CloudRequest request, CloudChannel channel) private static voidSerialRequestWorker.handle(CloudRequestHandler handler, CloudRequest request, CloudChannel channel) private voidRemoteConfigHandler.handleEntries(CloudRequest request, CloudChannel channel) Answers one file's typed entries and the SHA-256 of its current bytes.private voidRemoteConfigHandler.handleTree(CloudRequest request, CloudChannel channel) Answers the configuration file tree: each loaded module with the files it registered.private voidSerialRequestWorker.handleUnlessShuttingDown(CloudRequestHandler handler, CloudRequest request, CloudChannel channel) private voidRemoteConfigHandler.handleUpdate(CloudRequest request, CloudChannel channel) Writes exactly the keys a panel edit names, and only while the file still holds the bytes it read.private static voidRemoteCommandHandler.internalError(CloudRequest request, CloudChannel channel, RuntimeException failure) private voidPlayerLinkChannel.onCompleted(CloudRequest request, CloudChannel connection) private voidPlayerLinkChannel.onCreated(CloudRequest request, CloudChannel connection) (package private) voidPlayerLinkChannel.onErrorReply(CloudRequest request) Answers a correlatederrorreply for a create this run issued.private voidPlayerLinkChannel.onExpired(CloudRequest request, CloudChannel connection) private static PlayerActionHandler.ActionPlayerActionHandler.parse(CloudRequest request) Reads one branch of the discriminated union, validating exactly the keys that branch allows.private voidPlayerActionHandler.perform(CloudRequest request, CloudChannel channel, PlayerActionHandler.Action action) Runs once per accepted request, on the main thread: resolve the subject, then act.private static voidModuleRequestHandler.publishPanelMessageEvent(CloudRequest request, String messageType, com.google.gson.JsonObject data) Republishes the request for modules that subscribe toPanelMessageEvent, exactly as the v1 inbound path does: built here on the dispatching thread, delivered on the main thread, carrying the type the responder is registered under, the responder's input (the request's params plus the gateway-asserted actor) and the v2 envelope as received.private voidCloudFeatures.recordSwitchRefusal(CloudRequest request, String capability, String message) Records a request the capability gate refused as exactly one DENIED entry (FEATURES.mdultitools.remote.file-refusal-audit, as 6.3.0 did): the switch that decides the capability, the request type as action, itscommandorpathas target when it carries one (the type otherwise), the panel as actor and the refusal sentence naming the configuration key as reason.private static StringCloudFeatures.refusalTarget(CloudRequest request) (package private) voidShutdownGate.refuse(CloudRequest request, CloudChannel channel) Answers a covered request that was not let in.voidAgentMessageRouter.SwitchRefusalListener.refused(CloudRequest request, String capability, String message) private voidPlayerActionHandler.runGameMode(CloudChannel channel, CloudRequest request, PlayerActionHandler.Action action, org.bukkit.entity.Player subject) Applies the requested game mode and reports it as done only when the player's mode now equals the requested one: another plugin may cancel thePlayerGameModeChangeEvent, and the platform discards that answer.private voidPlayerActionHandler.runKick(CloudChannel channel, CloudRequest request, PlayerActionHandler.Action action, org.bukkit.entity.Player subject) Kicks with the reason as one plain-text component, or with the server's own default message when the panel sent no reason.private voidPlayerActionHandler.runTeleport(CloudChannel channel, CloudRequest request, PlayerActionHandler.Action action, org.bukkit.entity.Player subject) Starts the asynchronous teleport and answers when its future completes.private voidRemoteCommandHandler.runUnlessDisabling(Runnable action, CloudRequest request, CloudChannel channel) Runs one step of the acknowledged request unless the plugin is disabling.private voidSerialRequestWorker.submit(CloudRequestHandler handler, CloudRequest request, CloudChannel channel) private voidPlayerActionHandler.succeed(CloudChannel channel, CloudRequest request, PlayerActionHandler.Action action) Method parameters in com.ultikits.ultitools.utils with type arguments of type CloudRequestModifier and TypeMethodDescription(package private) voidAgentProtocol.addReplyListener(Consumer<CloudRequest> listener) -
Uses of CloudRequest in com.ultikits.ultitools.websocket
Methods in com.ultikits.ultitools.websocket with parameters of type CloudRequestModifier and TypeMethodDescriptionvoidCloudRequestHandler.handle(CloudRequest request, CloudChannel channel) Validates the payload and handles it on the dispatching thread.