Implement timeseries index model to command-manager plugin

plugins/command-manager/src/main/java/com/wazuh/commandmanager/model/Command.java

@@ -61,6 +61,15 @@ public Command(
         this.status = Status.PENDING;
     }
 
+    /**
+     * Retrieves the timeout value for this command.
+     *
+     * @return the timeout value in milliseconds.
+     */
+    public Integer getTimeout() {
+        return this.timeout;
+    }
+
     /**
      * Parses the request's payload into the Command model.
      *

plugins/command-manager/src/main/java/com/wazuh/commandmanager/model/Document.java

@@ -18,9 +18,13 @@
 
 /** Command's target fields. */
 public class Document implements ToXContentObject {
+    public static final String TIMESTAMP = "@timestamp";
+    public static final String DELIVERY_TIMESTAMP = "delivery_timestamp";
     private final Agent agent;
     private final Command command;
     private final String id;
+    private final long timestamp;
+    private final long deliveryTimestamp;
 
     /**
      * Default constructor
@@ -32,6 +36,20 @@ public Document(Agent agent, Command command) {
         this.agent = agent;
         this.command = command;
         this.id = UUIDs.base64UUID();
+        this.timestamp = System.currentTimeMillis();
+        this.deliveryTimestamp = calculateDeliveryTimestamp(this.timestamp, command.getTimeout());
+    }
+
+    /**
+     * Calculates the delivery timestamp by adding a specified timeout to the given timestamp.
+     *
+     * @param timestamp the initial timestamp in milliseconds.
+     * @param timeout the time in seconds to be added to the timestamp.
+     * @return a new timestamp representing the delivery time.
+     */
+    private long calculateDeliveryTimestamp(long timestamp, int timeout) {
+        long timeoutInMillis = timeout * 1000L;
+        return timestamp + timeoutInMillis;
     }
 
     /**
@@ -68,11 +86,22 @@ public XContentBuilder toXContent(XContentBuilder builder, Params params) throws
         builder.startObject();
         this.agent.toXContent(builder, ToXContentObject.EMPTY_PARAMS);
         this.command.toXContent(builder, ToXContentObject.EMPTY_PARAMS);
+        builder.field(TIMESTAMP, this.timestamp);
+        builder.field(DELIVERY_TIMESTAMP, this.deliveryTimestamp);
         return builder.endObject();
     }
 
     @Override
     public String toString() {
-        return "Document{" + "agent=" + agent + ", command=" + command + '}';
+        return "Document{"
+                + "@timestamp="
+                + timestamp
+                + ", delivery_timestamp="
+                + deliveryTimestamp
+                + ", agent="
+                + agent
+                + ", command="
+                + command
+                + '}';
     }
 }

plugins/command-manager/src/main/resources/index-template-commands.json

@@ -6,6 +6,9 @@
     "date_detection": false,
     "dynamic": "strict",
     "properties": {
+      "@timestamp": {
+        "type": "date"
+      },
       "agent": {
         "properties": {
           "groups": {
@@ -83,6 +86,9 @@
             "type": "keyword"
           }
         }
+      },
+      "delivery_timestamp": {
+        "type": "date"
       }
     }
   },

plugins/setup/src/main/resources/index-template-commands.json

@@ -6,6 +6,9 @@
     "date_detection": false,
     "dynamic": "strict",
     "properties": {
+      "@timestamp": {
+        "type": "date"
+      },
       "agent": {
         "properties": {
           "groups": {
@@ -83,6 +86,9 @@
             "type": "keyword"
           }
         }
+      },
+      "delivery_timestamp": {
+        "type": "date"
       }
     }
   },