package org.csc.phynixx.connection.loggersystem;
   
   /*
    * #%L
    * phynixx-common
    * %%
    * Copyright (C) 2014 csc
    * %%
    * Licensed under the Apache License, Version 2.0 (the "License");
   * you may not use this file except in compliance with the License.
   * You may obtain a copy of the License at
   * 
   *      http://www.apache.org/licenses/LICENSE-2.0
   * 
   * Unless required by applicable law or agreed to in writing, software
   * distributed under the License is distributed on an "AS IS" BASIS,
   * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
   * See the License for the specific language governing permissions and
   * limitations under the License.
   * #L%
   */
  
  
  import org.csc.phynixx.common.logger.IPhynixxLogger;
  import org.csc.phynixx.common.logger.PhynixxLogManager;
  import org.csc.phynixx.connection.*;
  import org.csc.phynixx.loggersystem.logrecord.IDataRecord;
  import org.csc.phynixx.loggersystem.logrecord.IDataRecordReplay;
  import org.csc.phynixx.loggersystem.logrecord.IXADataRecorder;
  import org.csc.phynixx.loggersystem.logrecord.XALogRecordType;
  
  import java.util.ArrayList;
  import java.util.Collections;
  import java.util.List;
  
  /**
   * written data are fired an forgotten. Their are not stored as if wriiten to dev0.
   */
  
  public class Dev0Strategy<C extends IPhynixxConnection> extends PhynixxManagedConnectionListenerAdapter<C> implements IPhynixxLoggerSystemStrategy<C> {
  
      private static final IPhynixxLogger LOG = PhynixxLogManager.getLogger(Dev0Strategy.class);
  
  
      public static final Dev0Logger THE_DEV0_LOGGER = new Dev0Logger();
  
      private static class Dev0Logger implements IXADataRecorder {
  
          @Override
          public void writeRollforwardData(byte[][] data) {
          }
  
          @Override
          public void writeRollforwardData(byte[] data) {
          }
  
          public boolean isCommitting() {
              return false;
          }
  
          public boolean isCompleted() {
              return false;
          }
  
          @Override
          public boolean isEmpty() {
              return false;
          }
  
          public boolean isPrepared() {
              return false;
          }
  
          @Override
          public void replayRecords(IDataRecordReplay replay) {
          }
  
          @Override
          public boolean isClosed() {
              return false;
          }
  
          @Override
          public IDataRecord createDataRecord(XALogRecordType logRecordType, byte[][] recordData) {
              return null;
          }
  
          @Override
          public IDataRecord createDataRecord(XALogRecordType logRecordType, byte[] recordData) {
              return null;
          }
  
          @Override
          public void writeRollbackData(byte[] data) {
          }
  
          @Override
          public void writeRollbackData(byte[][] data) {
          }
 
         @Override
         public void close() {
         }
 
         @Override
         public void reset() {
 
         }
 
         @Override
         public void destroy() {
         }
 
         @Override
         public List<IDataRecord> getDataRecords() {
             return Collections.emptyList();
         }
 
         @Override
         public long getXADataRecorderId() {
             return -1;
         }
 
         @Override
         public void recover() {
 
         }
     }
 
     @Override
     public void close() {
     }
 
     @Override
     public IPhynixxManagedConnection<C> decorate(IPhynixxManagedConnection<C> managedConnection) {
         managedConnection.addConnectionListener(this);
         return managedConnection;
     }
 
 
     @Override
     public void connectionRequiresTransaction(IManagedConnectionEvent<C> event) {
         IPhynixxConnection con = event.getManagedConnection().getCoreConnection();
         if (con == null || !(con instanceof IXADataRecorderAware)) {
             return;
         }
         IXADataRecorderAware messageAwareConnection = (IXADataRecorderAware) con;
         // Transaction is close and the LOG is destroyed ...
         IXADataRecorder logger = messageAwareConnection.getXADataRecorder();
         if (logger == null) {
             messageAwareConnection.setXADataRecorder(THE_DEV0_LOGGER);
         }
         event.getManagedConnection().addConnectionListener(this);
     }
 
 
     @Override
     public List<IXADataRecorder> readIncompleteTransactions() {
         return new ArrayList(0);
     }
 
 
 }