package com.linkedin.common.urn;

import com.linkedin.common.FabricType;
import com.linkedin.data.template.Custom;
import com.linkedin.data.template.DirectCoercer;
import com.linkedin.data.template.TemplateOutputCastException;
import java.net.URISyntaxException;
import java.util.regex.Matcher;
import java.util.regex.Pattern;


/**
 * Standardized dataset field information identifier
 */
public class DatasetFieldUrn extends Urn {

  // uniquely identifies urn's key type
  public static final String ENTITY_TYPE = "datasetField";

  /**
   * Dataset urn of the datasetFieldUrn
   */
  private final DatasetUrn _dataset;

  /**
   * Field of datasetFieldUrn
   */
  private final String _fieldPath;

  static {
    Custom.initializeCustomClass(DatasetUrn.class);
    Custom.registerCoercer(new DirectCoercer<DatasetFieldUrn>() {

      @Override
      public String coerceInput(DatasetFieldUrn object) throws ClassCastException {
        return object.toString();
      }

      @Override
      public DatasetFieldUrn coerceOutput(Object object) throws TemplateOutputCastException {
        if (object instanceof String) {
          try {
            return DatasetFieldUrn.createFromString((String) object);
          } catch (URISyntaxException e) {
            throw new TemplateOutputCastException("Invalid URN syntax: " + e.getMessage(), e);
          }
        }
        throw new TemplateOutputCastException((("Output '" + object) + ("' is not a String, and cannot be coerced to "
            + DatasetFieldUrn.class.getName())));
      }
    }, DatasetFieldUrn.class);
  }

  public DatasetFieldUrn(String dataPlatform, String datasetName, FabricType fabricType, String fieldPath) {
    this(new DatasetUrn(new DataPlatformUrn(dataPlatform), datasetName, fabricType), fieldPath);
  }

  /**
   * Creates a new instance of a {@link DatasetFieldUrn}.
   *
   * @param dataset dataset that this dataset field belongs to
   * @param fieldPath dataset field path or column name
   */
  public DatasetFieldUrn(DatasetUrn dataset, String fieldPath) {
    super(ENTITY_TYPE, TupleKey.create(dataset, fieldPath));
    this._dataset = dataset;
    this._fieldPath = fieldPath;
  }

  public static DatasetFieldUrn createFromString(String rawUrn) throws URISyntaxException {
    return createFromUrn(Urn.createFromString(rawUrn));
  }

  public static DatasetFieldUrn deserialize(String rawUrn) throws URISyntaxException {
    return createFromString(rawUrn);
  }

  public static DatasetFieldUrn createFromUrn(Urn urn) throws URISyntaxException {
    if (!"li".equals(urn.getNamespace())) {
      throw new URISyntaxException(urn.toString(), "Urn namespace type should be 'li'.");
    } else if (!ENTITY_TYPE.equals(urn.getEntityType())) {
      throw new URISyntaxException(urn.toString(), "Urn entity type should be 'datasetField'.");
    } else {
      TupleKey key = urn.getEntityKey();
      if (key.size() != 2) {
        throw new URISyntaxException(urn.toString(), "Invalid number of keys.");
      } else {
        try {
          return new DatasetFieldUrn((DatasetUrn) key.getAs(0, DatasetUrn.class), (String) key.getAs(1, String.class));
        } catch (Exception var3) {
          throw new URISyntaxException(urn.toString(), "Invalid URN Parameter: '" + var3.getMessage());
        }
      }
    }
  }

  public DatasetUrn getDatasetEntity() {
    return _dataset;
  }

  public String getFieldPathEntity() {
    return _fieldPath;
  }
}
