package io.ebeaninternal.server.changelog;

import io.ebean.event.changelog.BeanChange;
import io.ebean.event.changelog.ChangeLogListener;
import io.ebean.event.changelog.ChangeSet;
import io.ebean.event.changelog.ChangeType;
import io.ebean.plugin.Plugin;
import io.ebean.plugin.SpiServer;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import java.io.StringWriter;
import java.util.Properties;

Simply logs the change sets in JSON form to logger named io.ebean.ChangeLog.
/**
 * Simply logs the change sets in JSON form to logger named <code>io.ebean.ChangeLog</code>.
 */
public class DefaultChangeLogListener implements ChangeLogListener, Plugin {

  
The usual application specific logger.
/**
   * The usual application specific logger.
   */
  protected static final Logger logger = LoggerFactory.getLogger(DefaultChangeLogListener.class);

  
The named logger we send the change set payload to. Can be externally configured as desired.
/**
   * The named logger we send the change set payload to. Can be externally configured as desired.
   */
  private static final Logger changeLog = LoggerFactory.getLogger("io.ebean.ChangeLog");

  
Used to build the JSON.
/**
   * Used to build the JSON.
   */
  private ChangeJsonBuilder jsonBuilder;

  
A bigger default buffer for bean inserts and updates (that have value pairs).
/**
   * A bigger default buffer for bean inserts and updates (that have value pairs).
   */
  private int defaultBufferSize = 400;

  public DefaultChangeLogListener() {
  }

  
Configure the underlying JSON handler.
/**
   * Configure the underlying JSON handler.
   */
  @Override
  public void configure(SpiServer server) {
    jsonBuilder = new ChangeJsonBuilder(server.json());

    Properties properties = server.getServerConfig().getProperties();
    if (properties != null) {
      String bufferSize = properties.getProperty("ebean.changeLog.bufferSize");
      if (bufferSize != null) {
        defaultBufferSize = Integer.parseInt(bufferSize);
      }
    }
  }

  @Override
  public void online(boolean online) {
    // nothing to do
  }

  @Override
  public void shutdown() {
    // nothing to do
  }

  @Override
  public void log(ChangeSet changeSet) {

    for (BeanChange beanChange : changeSet.getChanges()) {
      // log each bean change as a separate log entry
      try {
        StringWriter writer = new StringWriter(getBufferSize(beanChange));
        jsonBuilder.writeBeanJson(writer, beanChange, changeSet);
        changeLog.info(writer.toString());
      } catch (Exception e) {
        logger.error("Exception logging beanChange " + beanChange.toString(), e);
      }
    }
  }

  
Return a decent buffer size based on the bean change.
/**
   * Return a decent buffer size based on the bean change.
   */
  private int getBufferSize(BeanChange beanChange) {

    return ChangeType.DELETE == beanChange.getEvent() ? 250 : defaultBufferSize;
  }

}