From 06b00b819226b339bc06c02208d5e578ad08ebdd Mon Sep 17 00:00:00 2001
From: Stefan Erl <stefan.erl@dlr.de>
Date: Tue, 14 Aug 2018 14:41:21 +0200
Subject: [PATCH 1/2] enable time-based production rule messages

---
 agent/ingest.c | 7 +++++++
 1 file changed, 7 insertions(+)

diff --git a/agent/ingest.c b/agent/ingest.c
index c7ac15e..016afdf 100644
--- a/agent/ingest.c
+++ b/agent/ingest.c
@@ -283,6 +283,13 @@ void *rx_thread(int *running) {
                 	}
                 	break;
 
+			case MSG_TYPE_CTRL_PERIOD_PROD:
+			{
+				AMP_DEBUG_ALWAYS("NM Agent :","Received Periodic Production Ctrl Message.\n", NULL);
+				rx_handle_time_prod(&meta, cursor, size, &bytes);
+			}
+			break;
+
                 	default:
                 	{
                 		AMP_DEBUG_WARN("rx_thread","Received unknown type: %d.\n", hdr->type);

From d4012287647e2124166eab8fce0f176f47f093f2 Mon Sep 17 00:00:00 2001
From: Stefan Erl <stefan.erl@dlr.de>
Date: Tue, 14 Aug 2018 14:42:48 +0200
Subject: [PATCH 2/2] build time-based production rules

---
 mgr/nm_mgr_netui.c | 33 ++++++++++++++++++++-------------
 mgr/nm_mgr_netui.h |  4 ++--
 2 files changed, 22 insertions(+), 15 deletions(-)

diff --git a/mgr/nm_mgr_netui.c b/mgr/nm_mgr_netui.c
index 77c20fe..d58a179 100644
--- a/mgr/nm_mgr_netui.c
+++ b/mgr/nm_mgr_netui.c
@@ -201,6 +201,7 @@ void netui_construct_ctrl_by_idx(agent_t* agent,cmdFormat* curCmd)
 
 void netui_construct_time_rule_by_idx(agent_t* agent,cmdFormat* curCmd)
 {
+	mid_t* id = NULL;
 	time_t offset = 0;
 	uint32_t period = 0;
 	uint32_t evals = 0;
@@ -224,20 +225,30 @@ void netui_construct_time_rule_by_idx(agent_t* agent,cmdFormat* curCmd)
 	/* Step 1a: "tokenize" the string */
 
 	char** args=netui_parse_arguments(curCmd->arguments,&numArgs);
-	if(numArgs<4)
+	if(numArgs<5)
 	{
 		AMP_DEBUG_ERR("netui_construct_time_rule_by_idx","Not enough arguments %d",numArgs);
 		return;
 	}
 
-	offset=atoi(args[0]);
-	period=atoi(args[1]);
-	evals=atoi(args[2]);
+	oid_t oid_id = oid_construct(OID_TYPE_FULL, NULL, 0, args[0], strlen(args[0]));
+	printf("Parsed OID: %s\n", oid_pretty_print(oid_id));
 
-	/* Step 1b: Split the MID array */
-	unsigned int x = 3;
+	id = mid_construct(MID_TRL, NULL, NULL, oid_id);
+
+	if (id == NULL) {
+        AMP_DEBUG_ERR("netui_construct_time_rule_by_idx","Could not create MID",NULL);
+		return;
+	}
+
+	//printf("Parsed MID: %s\n", mid_pretty_print(id));
 
-	for(x=3;x<numArgs;x++)
+	offset=atoi(args[1]);
+	period=atoi(args[2]);
+	evals=atoi(args[3]);
+
+	/* Step 1b: Split the MID array */
+	for(unsigned int x = 4; x < numArgs; x++)
 	{
 		AMP_DEBUG_INFO("netui_construct_time_rule_by_idx","Found argument %s",args[x]);
 		//Fill into temp command
@@ -273,15 +284,10 @@ void netui_construct_time_rule_by_idx(agent_t* agent,cmdFormat* curCmd)
 		//Insert into lyst
 
 		netui_parse_single_mid_str(mids, mid_str,arguments,lyst_length(gAdmData)-1, MID_ATOMIC);
-
-
-		//mids = netui_parse_mid_str(curCmd,midIdxC, lyst_length(gAdmData))-1, MID_TYPE_DATA)
 	}
 
-/*	mids = netui_parse_mid_str(curCmd,midIdxC, lyst_length(gAdmData))-1, MID_TYPE_DATA);
-
 	/* Step 2: Construct the control primitive. */
-	trl_t *entry = trl_create(NULL, offset, evals, period, mids); // XXX: Place some MID ID here
+	trl_t *entry = trl_create(id, offset, evals, period, mids);
 
 	/* Step 3: Construct a PDU to hold the primitive. */
 	uint8_t *data = trl_serialize(entry, &size);
@@ -295,6 +301,7 @@ void netui_construct_time_rule_by_idx(agent_t* agent,cmdFormat* curCmd)
 	pdu_release_group(pdu_group);
 	trl_release(entry);
 	midcol_destroy(&mids);
+	mid_release(id);
 
 	SRELEASE(args);
 
diff --git a/mgr/nm_mgr_netui.h b/mgr/nm_mgr_netui.h
index 9c84231..44760c8 100644
--- a/mgr/nm_mgr_netui.h
+++ b/mgr/nm_mgr_netui.h
@@ -132,8 +132,8 @@ void ui_deregister_agent();
 
 void ui_event_loop(int *running);
 
-mid_t *ui_input_mid();
-int ui_input_mid_flag(uint8_t *flag);
+//mid_t *ui_input_mid();
+//int ui_input_mid_flag(uint8_t *flag);
 
 Lyst ui_parse_mid_str(char *mid_str, int max_idx, int type);