SzCoreProduct.java

package com.senzing.g2.engine;

import static com.senzing.g2.engine.SzException.*;

/**
 * The package-protected implementation of {@link SzProduct} that works with the {@link
 * SzCoreEnvironment} class.
 */
public class SzCoreProduct implements SzProduct {
  /** Gets the class prefix to use for {@link SzException} construction. */
  private static final String CLASS_PREFIX = SzCoreProduct.class.getSimpleName();

  /** The {@link SzCoreEnvironment} that constructed this instance. */
  private SzCoreEnvironment env = null;

  /** The underlying {@link G2ProductJNI} instance. */
  G2ProductJNI nativeApi = null;

  /**
   * Default constructor.
   *
   * @throws IllegalStateException If the underlying {@link SzCoreEnvironment} instance has already
   *     been destroyed.
   * @throws SzException If a Senzing failure occurs during initialization.
   */
  SzCoreProduct(SzCoreEnvironment environment) throws IllegalStateException, SzException {
    this.env = environment;
    this.env.execute(
        () -> {
          this.nativeApi = new G2ProductJNI();

          int returnCode =
              this.nativeApi.init(
                  this.env.getInstanceName(), this.env.getSettings(), this.env.isVerboseLogging());

          if (returnCode != 0) {
            this.env.handleReturnCode(
                returnCode,
                this.nativeApi,
                CLASS_PREFIX + "()",
                paramsOf(
                    "instanceName",
                    this.env.getInstanceName(),
                    "settings",
                    redact(this.env.getSettings()),
                    "verboseLogging",
                    this.env.isVerboseLogging()));
          }

          return null;
        });
  }

  /** The package-protected function to destroy the Senzing Product SDK. */
  void destroy() {
    synchronized (this) {
      if (this.nativeApi == null) return;
      this.nativeApi.destroy();
      this.nativeApi = null;
    }
  }

  /**
   * Checks if this instance has been destroyed by the associated {@link SzEnvironment}.
   *
   * @return <code>true</code> if this instance has been destroyed, otherwise <code>false</code>.
   */
  protected boolean isDestroyed() {
    synchronized (this) {
      return (this.nativeApi == null);
    }
  }

  @Override
  public String getLicense() throws SzException {
    return this.env.execute(
        () -> {
          return this.nativeApi.license();
        });
  }

  @Override
  public String getVersion() throws SzException {
    return this.env.execute(
        () -> {
          return this.nativeApi.version();
        });
  }
}