CommandJdo_replayNext.java

package org.isisaddons.module.command.replay.impl.mixins;

import java.util.List;

import javax.inject.Inject;

import org.apache.isis.applib.annotation.Action;
import org.apache.isis.applib.annotation.ActionLayout;
import org.apache.isis.applib.annotation.CommandReification;
import org.apache.isis.applib.annotation.Contributed;
import org.apache.isis.applib.annotation.MemberOrder;
import org.apache.isis.applib.annotation.Mixin;
import org.apache.isis.applib.annotation.SemanticsOf;
import org.apache.isis.applib.services.message.MessageService;
import org.apache.isis.core.metamodel.services.configinternal.ConfigurationServiceInternal;
import org.apache.isis.core.runtime.services.background.CommandExecutorService;
import org.apache.isis.schema.cmd.v1.CommandDto;

import org.isisaddons.module.command.CommandModule;
import org.isisaddons.module.command.dom.CommandJdo;
import org.isisaddons.module.command.dom.CommandServiceJdoRepository;
import org.isisaddons.module.command.replay.impl.CommandFetcher;
import org.isisaddons.module.command.replay.impl.CommandReplayAnalyser;
import org.isisaddons.module.command.replay.impl.SlaveConfiguration;
import org.isisaddons.module.command.replay.impl.StatusException;

@Mixin(method = "act")

public class CommandJdo_replayNext {

    private final CommandJdo commandJdo;

    //region > constructor
    public CommandJdo_replayNext(CommandJdo commandJdo) {
        this.commandJdo = commandJdo;
    }
    //endregion


    public static class ActionDomainEvent extends CommandModule.ActionDomainEvent<CommandJdo_replayNext> { }
    @Action(
            semantics = SemanticsOf.NON_IDEMPOTENT,
            domainEvent = ActionDomainEvent.class,
            command = CommandReification.DISABLED
    )
    @ActionLayout(
            contributed = Contributed.AS_ACTION
    )
    @MemberOrder(name = "executeIn", sequence = "3")
    public CommandJdo act() throws StatusException {

        // double check this is still the HWM
        final CommandJdo replayHwm = commandServiceJdoRepository.findReplayHwm();
        if(commandJdo != replayHwm) {
            messageService.informUser("HWM has changed");
            return replayHwm;
        }

        final CommandJdo nextHwm = fetchNext();
        if(nextHwm == null) {
            messageService.informUser("No more commands on master");
            return commandJdo;
        }

        execute(nextHwm);

        commandReplayAnalyser.analyze(nextHwm);

        return nextHwm;
    }


    private CommandJdo fetchNext() throws StatusException {
        SlaveConfiguration slaveConfig = getSlaveConfig();

        final CommandDto commandDto = commandFetcher.fetchCommand(this.commandJdo, slaveConfig);
        return commandDto == null
                ? null
                : commandServiceJdoRepository.saveForReplay(commandDto);
    }

    private void execute(final CommandJdo hwmCommand) {
        // execute the hwm command
        commandExecutorService.executeCommand(CommandExecutorService.SudoPolicy.SWITCH, hwmCommand);

        // find background commands, and run them
        final List<CommandJdo> backgroundCommands = commandServiceJdoRepository.findBackgroundCommandsByParent(hwmCommand);
        for (final CommandJdo backgroundCommand : backgroundCommands) {
            commandExecutorService.executeCommand(CommandExecutorService.SudoPolicy.SWITCH, backgroundCommand);
        }
    }

    public String disableAct() {
        final CommandJdo replayHwm = commandServiceJdoRepository.findReplayHwm();

        if(commandJdo != replayHwm) {
            return "This action can only be performed against the 'HWM' command on the slave";
        }
        if(commandJdo.getExecuteIn().isReplayable() && commandJdo.getReplayState() != null && commandJdo.getReplayState().representsError()) {
            return "Replayable command is in error.  Exclude the command to continue.";
        }
        if(!commandJdo.isComplete()) {
            return "Replayable command is not complete";
        }

        if(commandJdo.getExecuteIn().isBackground()) {
            // this shouldn't happen; findReplayHwm should never return a background command
            return "Background commands cannot be replayed";
        }

        return null;
    }

    // //////////////////////////////////////

    /**
     * lazily loaded
     */
    SlaveConfiguration slaveConfig;
    private SlaveConfiguration getSlaveConfig() {
        if (slaveConfig == null){
            slaveConfig = new SlaveConfiguration(configurationServiceInternal.asMap());
        }
        return slaveConfig;
    }

    // //////////////////////////////////////

    @javax.inject.Inject
    CommandServiceJdoRepository commandServiceJdoRepository;

    @javax.inject.Inject
    CommandFetcher commandFetcher;

    @javax.inject.Inject
    CommandExecutorService commandExecutorService;

    @javax.inject.Inject
    ConfigurationServiceInternal configurationServiceInternal;

    @javax.inject.Inject
    MessageService messageService;

    @Inject
    CommandReplayAnalyser commandReplayAnalyser;
}