[ZEE-6082] Add specification to DataProduct

src/main/java/zeenea/connector/dataproduct/DataProduct.java

@@ -2,6 +2,7 @@
 
 import java.util.*;
 import org.jetbrains.annotations.NotNull;
+import org.jetbrains.annotations.Nullable;
 import zeenea.connector.Item;
 import zeenea.connector.dataset.Dataset;
 import zeenea.connector.exception.ExceptionUtils;
@@ -19,6 +20,9 @@ public final class DataProduct extends Item {
   /** The list of internal components for the data product. */
   @NotNull private final List<Item> internalComponents;
 
+  /** The specification of the data product. */
+  @Nullable private final String specification;
+
   /**
    * Constructs a DataProduct instance using the provided builder.
    *
@@ -32,6 +36,7 @@ private DataProduct(Builder builder) {
     inputPorts = List.copyOf(builder.inputPorts);
     outputPorts = List.copyOf(builder.outputPorts);
     internalComponents = List.copyOf(builder.internalComponents);
+    specification = builder.specification;
   }
 
   /**
@@ -61,6 +66,15 @@ private DataProduct(Builder builder) {
     return internalComponents;
   }
 
+  /**
+   * Gets the specification of the data product.
+   *
+   * @return the specification of the data product
+   */
+  public @NotNull Optional<String> getSpecification() {
+    return Optional.ofNullable(specification);
+  }
+
   /**
    * Checks if this DataProduct is equal to another object.
    *
@@ -72,9 +86,15 @@ public boolean equals(Object o) {
     if (this == o) return true;
     if (o == null || getClass() != o.getClass()) return false;
     DataProduct that = (DataProduct) o;
-    return Objects.equals(inputPorts, that.inputPorts)
+    return Objects.equals(getId(), that.getId())
+        && Objects.equals(getName(), that.getName())
+        && Objects.equals(getDescription(), that.getDescription())
+        && Objects.equals(getContacts(), that.getContacts())
+        && Objects.equals(getProperties(), that.getProperties())
+        && Objects.equals(inputPorts, that.inputPorts)
         && Objects.equals(outputPorts, that.outputPorts)
-        && Objects.equals(internalComponents, that.internalComponents);
+        && Objects.equals(internalComponents, that.internalComponents)
+        && Objects.equals(specification, that.specification);
   }
 
   /**
@@ -84,7 +104,16 @@ public boolean equals(Object o) {
    */
   @Override
   public int hashCode() {
-    return Objects.hash(inputPorts, outputPorts, internalComponents);
+    return Objects.hash(
+        getId(),
+        getName(),
+        getDescription(),
+        getContacts(),
+        getProperties(),
+        inputPorts,
+        outputPorts,
+        internalComponents,
+        specification);
   }
 
   /**
@@ -111,6 +140,8 @@ public String toString() {
         + internalComponents
         + ", outputPorts="
         + outputPorts
+        + ", specification="
+        + specification
         + "}";
   }
 
@@ -151,6 +182,8 @@ public static class Builder extends Item.Builder<DataProduct, Builder> {
 
     private List<Item> internalComponents = Collections.emptyList();
 
+    private String specification;
+
     /**
      * Set a collection of input ports to the data product.
      *
@@ -217,6 +250,17 @@ public Builder internalComponents(Item... items) {
       return this;
     }
 
+    /**
+     * Sets the specification of the data product.
+     *
+     * @param specification the specification of the data product
+     * @return the builder instance
+     */
+    public Builder specification(@Nullable String specification) {
+      this.specification = specification;
+      return this;
+    }
+
     /**
      * Builds and returns a DataProduct instance.
      *

version.txt

@@ -1 +1 @@
-2.1.0
+2.2.0