CSend.java

Go to the documentation of this file.

package org.lightvoting.simulation.action.message;

import org.lightjason.agentspeak.action.IBaseAction;
import org.lightjason.agentspeak.agent.IAgent;
import org.lightjason.agentspeak.common.CPath;
import org.lightjason.agentspeak.common.IPath;
import org.lightjason.agentspeak.language.CLiteral;
import org.lightjason.agentspeak.language.CRawTerm;
import org.lightjason.agentspeak.language.ITerm;
import org.lightjason.agentspeak.language.execution.IContext;
import org.lightjason.agentspeak.language.execution.fuzzy.CFuzzyValue;
import org.lightjason.agentspeak.language.execution.fuzzy.IFuzzyValue;
import org.lightjason.agentspeak.language.instantiable.plan.trigger.CTrigger;
import org.lightjason.agentspeak.language.instantiable.plan.trigger.ITrigger;
import org.lightvoting.simulation.agent.CVotingAgent;

import java.util.List;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;


public final class CSend extends IBaseAction
{
    private final Map<String, CVotingAgent> m_agents = new ConcurrentHashMap<>();

    public final CVotingAgent register( final CVotingAgent p_agent )
    {
        m_agents.put( p_agent.name(), p_agent );
        return p_agent;
    }

    public final CVotingAgent unregister( final CVotingAgent p_agent )
    {
        m_agents.remove( p_agent.name() );
        return p_agent;
    }

    @Override
    public final IPath name()
    {
        return CPath.from( "message/send" );
    }

    @Override
    public final int minimalArgumentNumber()
    {
        return 2;
    }

    @Override
    public final IFuzzyValue<Boolean> execute( final IContext p_context, final boolean p_parallel, final List<ITerm> p_argument,
                                               final List<ITerm> p_return )
    {
        final IAgent<?> l_receiver = m_agents.get( p_argument.get( 0 ).<String>raw() );

        // if the agent is it not found, action fails
        if ( l_receiver == null )
            return CFuzzyValue.from( false );

        // create the receiving goal-trigger of the message
        l_receiver.trigger(
                CTrigger.from(
                        ITrigger.EType.ADDGOAL,

                        // create the goal literal "message/receive(M,S)" with M is the message literal
                        // and S the sending agent name
                        CLiteral.from(
                                "message/receive",

                                // message literal
                                CLiteral.from(
                                        "message",

                                        // first argument is the agent name so copy all other arguments to the message literal
                                        p_argument.subList( 1, p_argument.size() ).stream().map( i -> CRawTerm.from( i.raw() ) )
                                ),

                                // name of the sending agent in this the agent which calls the send action is read from
                                // context and translate in the communication agent, the communication agent has got the
                                // method name() to read the agent name
                                CLiteral.from( "from", CRawTerm.from( p_context.agent().<CVotingAgent>raw().name() ) )
                        )

                )
        );

        return CFuzzyValue.from( true );
    }
}