CPrint.java

Go to the documentation of this file.

/*
 * @cond LICENSE
 * ######################################################################################
 * # LGPL License                                                                       #
 * #                                                                                    #
 * # This file is part of the LightJason AgentSpeak(L++)                                #
 * # Copyright (c) 2015-19, LightJason (info@lightjason.org)                            #
 * # This program is free software: you can redistribute it and/or modify               #
 * # it under the terms of the GNU Lesser 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 Lesser General Public License for more details.                                #
 * #                                                                                    #
 * # You should have received a copy of the GNU Lesser General Public License           #
 * # along with this program. If not, see http://www.gnu.org/licenses/                  #
 * ######################################################################################
 * @endcond
 */

package org.lightjason.agentspeak.action.builtin.generic;

import org.lightjason.agentspeak.action.builtin.IBuiltinAction;
import org.lightjason.agentspeak.action.builtin.math.blas.CFormat1D;
import org.lightjason.agentspeak.action.builtin.math.blas.CFormat2D;
import org.lightjason.agentspeak.language.ITerm;
import org.lightjason.agentspeak.language.execution.IContext;
import org.lightjason.agentspeak.language.fuzzy.CFuzzyValue;
import org.lightjason.agentspeak.language.fuzzy.IFuzzyValue;

import javax.annotation.Nonnull;
import javax.annotation.Nullable;
import java.io.ObjectInputStream;
import java.io.PrintStream;
import java.io.Serializable;
import java.text.MessageFormat;
import java.util.Arrays;
import java.util.Collection;
import java.util.Collections;
import java.util.HashSet;
import java.util.List;
import java.util.Objects;
import java.util.Set;
import java.util.stream.Collectors;


public final class CPrint extends IBuiltinAction
{
    private static final long serialVersionUID = -4271829260928469828L;
    private transient PrintStream m_stream;
    private final ISupplier<PrintStream> m_streamsupplier;
    private final String m_seperator;
    private final Set<IFormatter<?>> m_formatter;


    public CPrint() throws Exception
    {
        this( () -> System.out, "   ", new CFormat2D(), new CFormat1D() );
    }

    public CPrint( @Nonnull final ISupplier<PrintStream> p_streamsupplier ) throws Exception
    {
        this( p_streamsupplier, "   ", new CFormat2D(), new CFormat1D() );
    }

    public CPrint( @Nonnull final ISupplier<PrintStream> p_streamsupplier, @Nonnull final String p_seperator, @Nullable final IFormatter<?>... p_formatter )
        throws Exception
    {
        super( 2 );
        m_streamsupplier = p_streamsupplier;
        m_stream = m_streamsupplier.get();
        m_seperator = p_seperator;
        m_formatter = p_formatter != null ? new HashSet<>( Arrays.asList( p_formatter ) ) : Collections.emptySet();
    }

    private void readObject( final ObjectInputStream p_stream ) throws Exception
    {
        p_stream.defaultReadObject();
        m_stream = m_streamsupplier.get();
    }

    public final Set<IFormatter<?>> formatter()
    {
        return m_formatter;
    }

    @Nonnull
    @Override
    public final IFuzzyValue<Boolean> execute( final boolean p_parallel, @Nonnull final IContext p_context,
                                               @Nonnull final List<ITerm> p_argument, @Nonnull final List<ITerm> p_return
    )
    {
        m_stream.println( MessageFormat.format( "{0}", this.format( p_argument ) ) );
        return CFuzzyValue.from( true );
    }

    @Nonnull
    private String format( @Nonnull final Collection<ITerm> p_argument )
    {
        return p_argument.stream()
                         .map( ITerm::raw )
                         .map( i ->
                         {
                             if ( Objects.isNull( i ) )
                                 return "";

                             final IFormatter<?> l_formatter = m_formatter.parallelStream()
                                                                          .filter( j -> j.isAssignableTo( i.getClass() ) )
                                                                          .limit( 1 )
                                                                          .findFirst()
                                                                          .orElse( null );

                             return Objects.isNull( l_formatter ) ? i.toString() : l_formatter.toString( i );
                         } )
                         .collect( Collectors.joining( m_seperator ) );
    }

    @FunctionalInterface
    public interface ISupplier<T> extends Serializable
    {
        T get() throws Exception;
    }


    public abstract static class IFormatter<T> implements Serializable
    {
        private static final long serialVersionUID = -4997526550642055213L;

        public final boolean isAssignableTo( final Class<?> p_class )
        {
            return this.getType().isAssignableFrom( p_class );
        }

        @Override
        public final int hashCode()
        {
            return this.getType().hashCode();
        }

        @Override
        public final boolean equals( final Object p_object )
        {
            return ( p_object instanceof IFormatter<?> ) && ( this.hashCode() == p_object.hashCode() );
        }

        @SuppressWarnings( "unchecked" )
        public final String toString( final Object p_data )
        {
            return this.format( (T) p_data );
        }

        protected abstract Class<?> getType();

        protected abstract String format( final T p_data );
    }

}