package delays.java.stream;

import org.infinispan.manager.EmbeddedCacheManager;
import org.infinispan.query.remote.ProtobufMetadataManager;
import org.infinispan.tasks.ServerTask;
import org.infinispan.tasks.TaskContext;
import org.infinispan.tasks.TaskExecutionMode;

import delays.java.stream.pojos.Station;
import delays.java.stream.pojos.Stop;
import delays.java.stream.pojos.Train;

public class AddProtobufTask implements ServerTask {

   private TaskContext ctx;

   @Override
   public void setTaskContext(TaskContext ctx) {
      this.ctx = ctx;
   }

   @Override
   public String getName() {
      return "add-protobuf";
   }

   @Override
   public Object call() throws Exception {
      EmbeddedCacheManager cm = ctx.getCache().get().getCacheManager();
      ProtobufMetadataManager protobufMetadataManager = cm.getGlobalComponentRegistry().getComponent(ProtobufMetadataManager.class);
      protobufMetadataManager.registerMarshaller(new Stop.Marshaller());
      protobufMetadataManager.registerMarshaller(new Station.Marshaller());
      protobufMetadataManager.registerMarshaller(new Train.Marshaller());
      return null;
   }

   @Override
   public TaskExecutionMode getExecutionMode() {
      // Registering marshallers should be done in all nodes
      return TaskExecutionMode.ALL_NODES;
   }

}