package io.ebeaninternal.server.text.json;

import com.fasterxml.jackson.core.JsonParser;
import io.ebean.PersistenceIOException;
import io.ebean.bean.PersistenceContext;
import io.ebean.text.json.JsonBeanReader;
import io.ebeaninternal.api.json.SpiJsonReader;
import io.ebeaninternal.server.deploy.BeanDescriptor;

import java.io.IOException;

A 'context' for reading entity beans from JSON.

This is used such that a load context and persistence context can be used to span multiple marshalling requests.

/**
 * A 'context' for reading entity beans from JSON.
 * <p>
 * This is used such that a load context and persistence context can be used to span multiple marshalling requests.
 * </p>
 */
public class DJsonBeanReader<T> implements JsonBeanReader<T> {

  private final BeanDescriptor<T> desc;

  private final SpiJsonReader readJson;

  public DJsonBeanReader(BeanDescriptor<T> desc, SpiJsonReader readJson) {
    this.desc = desc;
    this.readJson = readJson;
  }

  @Override
  public void persistenceContextPut(Object beanId, T currentBean) {
    readJson.persistenceContextPut(beanId, currentBean);
  }

  @Override
  public PersistenceContext getPersistenceContext() {
    return readJson.getPersistenceContext();
  }

  @Override
  public T read() {
    try {
      return desc.jsonRead(readJson, null);
    } catch (IOException e) {
      throw new PersistenceIOException(e);
    }
  }

  @Override
  public JsonBeanReader<T> forJson(JsonParser moreJson, boolean resetContext) {
    return new DJsonBeanReader<>(desc, readJson.forJson(moreJson, resetContext));
  }
}