RESTVoldReplicator.java

Go to the documentation of this file.

package de.zib.vold.replication;

import de.zib.vold.client.RESTClient;
import de.zib.vold.common.Key;

import java.util.List;
import java.util.Set;
import java.util.HashSet;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

public class RESTVoldReplicator implements Replicator
{
        protected final Logger log = LoggerFactory.getLogger( this.getClass() );

        RESTClient rest;

        public RESTVoldReplicator( )
        {
                this.rest = new RESTClient();
        }

        public void setBaseURL( String baseURL )
        {
                rest.setBaseURL( baseURL );
        }

        public void checkState( )
        {
                try
                {
                        rest.checkState();
                }
                catch( IllegalStateException e )
                {
                        throw new IllegalStateException( "Tried to operate on RESTReplicator while it had not been initialized yet. Set restClient before!", e );
                }
        }

        @Override
        public void insert( List< String > key, Set< String > value )
        {
                // guard
                {
                        if( 4 != key.size() )
                        {
                                throw new IllegalArgumentException( "key does not seem to come from Frontend." );
                        }

                        log.trace( "Insert: " + key.toString() + " |--> " + value.toString() );

                        checkState();
                }

                // build key
                Key k;
                {
                        k = Key.buildkey( key );
                }

                rest.insert( key.get( 3 ), k, value );
        }

        @Override
        public void refresh( List< String > key )
        {
                // guard
                {
                        if( 4 != key.size() )
                        {
                                throw new IllegalArgumentException( "key does not seem to come from Frontend." );
                        }

                        log.trace( "Refresh: " + key.toString() );

                        checkState();
                }

                // build key
                Key k;
                {
                        k = Key.buildkey( key );
                }

                Set< Key > keys = new HashSet< Key >();
                keys.add( k );

                rest.refresh( key.get( 3 ), keys );
        }

        @Override
        public void delete( List< String > key )
        {
                // no need to remove that key - that is part of the other VolD service
        }
}