CRUD requests processing

src/crud_tasks.c

@@ -0,0 +1,114 @@
+#include <stdio.h>
+#include <string.h>
+#include <stdlib.h>
+#include <cJSON.h>
+#include <wrp-c.h>
+#include "crud_tasks.h"
+#include "crud_internal.h"
+
+
+int processCrudRequest( wrp_msg_t *reqMsg, wrp_msg_t **responseMsg)
+{
+    wrp_msg_t *resp_msg = NULL;
+    char *str= NULL;
+    int ret = -1;
+    char *destVal = NULL;
+    char *destination = NULL;
+    
+    resp_msg = ( wrp_msg_t *)malloc( sizeof( wrp_msg_t ) );  
+    memset(resp_msg, 0, sizeof(wrp_msg_t));
+    
+    resp_msg->msg_type = reqMsg->msg_type;
+    resp_msg->u.crud.transaction_uuid = strdup(reqMsg->u.crud.transaction_uuid);
+    resp_msg->u.crud.source = strdup(reqMsg->u.crud.dest);
+    resp_msg->u.crud.dest = strdup(reqMsg->u.crud.source);
+
+    switch( reqMsg->msg_type ) 
+    {
+    
+	case WRP_MSG_TYPE__CREATE:
+	ParodusInfo( "CREATE request\n" );
+
+	ret = createObject( reqMsg, &resp_msg );
+
+	if(ret == 0)
+	{
+		cJSON *payloadObj = cJSON_Parse( (resp_msg)->u.crud.payload );
+		str = cJSON_PrintUnformatted(payloadObj);
+
+		resp_msg ->u.crud.payload = (void *)str;
+		if(str !=NULL)
+		{
+			ParodusInfo("Payload Response: %s\n", str);
+			resp_msg ->u.crud.payload_size = strlen(str);
+		}
+	}
+	else
+	{
+		ParodusError("Failed to create object in config JSON\n");
+
+		//WRP payload is NULL for failure cases
+		resp_msg ->u.crud.payload = NULL;
+		resp_msg ->u.crud.payload_size = 0;
+	}
+
+	*responseMsg = resp_msg;
+	break;
+	    
+	case WRP_MSG_TYPE__RETREIVE:
+	ParodusInfo( "RETREIVE request\n" );
+	
+	ret = retrieveObject( reqMsg, &resp_msg );
+	if(ret == 0)
+	{
+	    cJSON *payloadObj = cJSON_Parse( (resp_msg)->u.crud.payload );
+	    str = cJSON_PrintUnformatted(payloadObj);
+
+	    resp_msg ->u.crud.payload = (void *)str;
+	    if((resp_msg)->u.crud.payload !=NULL)
+	    {
+	    	ParodusInfo("Payload Response: %s\n", str);
+		resp_msg ->u.crud.payload_size = strlen((resp_msg)->u.crud.payload);
+	    }
+	}
+	else
+	{
+	    ParodusError("Failed to retrieve object \n");
+
+	    //WRP payload is NULL for failure cases
+	    resp_msg ->u.crud.payload = NULL;
+	    resp_msg ->u.crud.payload_size = 0;
+	}
+	
+	*responseMsg = resp_msg;
+	break;
+	    
+	case WRP_MSG_TYPE__UPDATE:
+	ParodusInfo( "UPDATE request\n" );
+
+	ret = updateObject( reqMsg, &resp_msg );
+
+	//WRP payload is NULL for update requests
+	resp_msg ->u.crud.payload = NULL;
+	resp_msg ->u.crud.payload_size = 0;
+	*responseMsg = resp_msg;
+	break;
+	    
+	case WRP_MSG_TYPE__DELETE:
+	ParodusInfo( "DELETE request\n" );
+	    
+	ret = deleteObject(reqMsg, &resp_msg );
+	//WRP payload is NULL for delete requests
+	resp_msg ->u.crud.payload = NULL;
+	resp_msg ->u.crud.payload_size = 0;
+	*responseMsg = resp_msg;
+	break;
+	    
+	default:
+	    ParodusInfo( "Unknown msgType for CRUD request\n" );
+	    break;
+     }
+        
+    return  0;
+}
+

src/crud_tasks.h

@@ -0,0 +1,31 @@
+/**
+ * Copyright 2016 Comcast Cable Communications Management, LLC
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
+ 
+ 
+#include <wrp-c.h>
+#include "ParodusInternal.h"
+
+/**
+ * @brief processCrudRequest function to process CRUD operations.
+ *
+ * @note processCrudRequest function allocates memory for response, 
+ * caller needs to free the response (resMsg) in both success and failure case.
+ * @param[in] decoded request in wrp_msg_t structure format
+ * @param[out] resulting wrp_msg_t structure as a response 
+ * @return  0 in success case and -1 in error case
+ */
+int processCrudRequest(wrp_msg_t * reqMsg, wrp_msg_t **resMsg);