src/plugins/redirect/redirect_stubs.c - third_party/openwsman - Git at Google

 /*
  *  Copyright (c) 2006 Dell, Inc.
  *  by Praveen K Paladugu <praveen_paladugu@dell.com>
  *  Licensed under the GNU General Public license, version 2.
  */


 #include "wsman_config.h"

 #include "stdlib.h"
 #include "stdio.h"
 #include "string.h"
 #include "ctype.h"


 #include "u/libu.h"

 #include "wsman-xml-api.h"
 #include "wsman-soap.h"
 #include "wsman-xml.h"
 #include "wsman-client-api.h"
 #include "wsman-xml-serializer.h"

 #include <wsman-client-transport.h>
 #include <wsman-debug.h>

 #include "wsman-soap-envelope.h"
 #include "wsman-soap-message.h"
 #include "wsman-dispatcher.h"

 #include "redirect.h"


 WsXmlDocH redirect_generate_fault( WsXmlDocH in_doc, WsManClient *cl);
 char* redirect_fault_msg (char * last_error_string);

 //DEBUG
 static void xml_print( WsXmlDocH doc);

 int Redirect_transfer_action ( SoapOpH op,
                 void* appData,
                 void *opaqueData)
 {
     //Same function to be called for Get, Put, Create, Delete Actions
     WsmanMessage *msg = wsman_get_msg_from_op(op);
     SoapH soap = soap_get_op_soap(op);
     WsXmlDocH in_doc = soap_get_op_doc(op, 1);
     WsContextH cntx = ws_create_ep_context(soap, in_doc);
     WsManClient *cl=NULL;
     WsXmlDocH response=NULL;


     debug ("Test Get Endpoint Called");
     cl = setup_redirect_client(cntx, msg->auth_data.username, msg->auth_data.password );

     wsman_send_request(cl,cntx->indoc);


     if (wsmc_get_last_error(cl) != WS_LASTERR_OK ){
 	//CURL/ HTTP errors
 	soap_set_op_doc(op,
 	    redirect_generate_fault( cntx->indoc , cl),
 	    0);

 	    return 1;
     }


     response = wsmc_build_envelope_from_response(cl);

     soap_set_op_doc(op,
 		ws_xml_duplicate_doc(response), 0);

     wsmc_release(cl);

     return 0;
 }


 int Redirect_Get_EP( SoapOpH op,
                 void* appData,
                 void *opaqueData)

 {
 	return Redirect_transfer_action(op,appData, opaqueData);

 }

 int Redirect_Create_EP( SoapOpH op,
                 void* appData,
                 void *opaqueData)

 {
 	return Redirect_transfer_action(op,appData, opaqueData);

 }

 int Redirect_Delete_EP( SoapOpH op,
                 void* appData,
                 void *opaqueData)

 {
 	return Redirect_transfer_action(op,appData, opaqueData);

 }


 int Redirect_Put_EP( SoapOpH op,
                 void* appData,
                 void *opaqueData)
 {
 	return Redirect_transfer_action(op,appData, opaqueData);
 }


 int Redirect_Enumerate_EP(WsContextH cntx,
 			WsEnumerateInfo* enumInfo,
 			WsmanStatus *status, void *opaqueData)
 {

     WsXmlNodeH r_header=NULL, r_node=NULL, r_body=NULL, r_opt=NULL;
     WsXmlDocH r_response=NULL;
     char *resource_uri, *remote_enumContext=NULL;
     int op;
     WsManClient *cl=NULL;


     //The redirected Enumeration request must have RequestTotalItemsCountEstimate enabled

     r_header = ws_xml_get_soap_header(cntx->indoc);
     if ( (r_node = ws_xml_get_child(r_header,0,XML_NS_WS_MAN, WSM_REQUEST_TOTAL )) == NULL )
 	    ws_xml_add_child(r_header, XML_NS_WS_MAN, WSM_REQUEST_TOTAL, NULL);


     cl = setup_redirect_client(cntx,  enumInfo->auth_data.username, enumInfo->auth_data.password);


     //Set the enumInfo flags based on the indoc. This is required while handling the response in wsenum_eunmerate_stub
     r_body=ws_xml_get_soap_body(cntx->indoc);
     if ( ( r_node = ws_xml_get_child(r_body ,0, XML_NS_ENUMERATION, WSENUM_ENUMERATE )) != NULL )
     {
 	    if ( (r_opt = ws_xml_get_child(r_node,0,XML_NS_WS_MAN,WSM_OPTIMIZE_ENUM )) != NULL )
 		    enumInfo->flags |= WSMAN_ENUMINFO_OPT ;

     }


     wsman_send_request(cl,cntx->indoc);

     if (wsmc_get_last_error(cl) != WS_LASTERR_OK ){
 	//CURL or HTTP errors
 	enumInfo->pullResultPtr = NULL;
 	status->fault_code = WSMAN_INTERNAL_ERROR;
 	status->fault_detail_code = 0;
 	status->fault_msg = redirect_fault_msg( wsman_transport_get_last_error_string(  wsmc_get_last_error(cl) )  );
             return 1;
     }


     r_response = wsmc_build_envelope_from_response(cl);


     if (  wsman_is_fault_envelope(r_response)){
         enumInfo->pullResultPtr = NULL;
         wsman_get_fault_status_from_doc(r_response, status);
 	return 1;
     }


     //Get the Estimated Total No.of Items from the response.
     r_header=ws_xml_get_soap_header(r_response);
     r_node=ws_xml_get_child(r_header,0,XML_NS_WS_MAN, WSM_TOTAL_ESTIMATE );
     enumInfo->totalItems=(!r_node) ? 0: atoi(ws_xml_get_node_text(r_node));


     //Get the remote context
     remote_enumContext = wsmc_get_enum_context(r_response);


     //Set the pullResultPtr only if some Enum Items are returned, in optimized mode.
     r_body= ws_xml_get_soap_body(r_response);

     if (  (r_node = ws_xml_get_child(r_body,0,XML_NS_ENUMERATION, WSENUM_ENUMERATE_RESP )) != NULL &&
 			( ws_xml_get_child(r_node,0,XML_NS_WS_MAN,WSENUM_ITEMS) != NULL)  )

     {

 	enumInfo->pullResultPtr = r_response;

 	if( strlen(remote_enumContext) != 0 )
 	    strncpy(enumInfo->enumId, remote_enumContext, strlen(remote_enumContext)+1);

 	else  // If all the instances are returned, the context will be NULL
 	    enumInfo->enumId[0]='\0';

     }

     else{
 	    //If not items are returned, set the context and return.
 	    strncpy(enumInfo->enumId, remote_enumContext, strlen(remote_enumContext)+1);
 	    ws_xml_destroy_doc(r_response);

     }

     wsmc_release(cl);
     if (remote_enumContext != NULL)
 	free(remote_enumContext);

     return 0;

 }


 int Redirect_Release_EP(WsContextH cntx,
                         WsEnumerateInfo* enumInfo,
                         WsmanStatus *status, void *opaqueData)
 {


     WsManClient *cl=NULL;
     WsXmlDocH response=NULL;


     cl = setup_redirect_client(cntx,  enumInfo->auth_data.username, enumInfo->auth_data.password);

     wsman_send_request(cl,cntx->indoc);
     if (wsmc_get_last_error(cl) != WS_LASTERR_OK ){
 	//just return for now, as the release_stub is not handling the status codes.
 	return 1;
     }

     response=wsmc_build_envelope_from_response(cl);

     //The status value is not used in the release stub. So, just return, if fault or not.
     return wsman_is_fault_envelope(response);
 }

 int Redirect_Pull_EP(WsContextH cntx, WsEnumerateInfo* enumInfo,
 			WsmanStatus *status, void *opaqueData)
 {
     WsXmlDocH doc=NULL,response=NULL;
     WsManClient *cl=NULL;
     int retVal=0;


     cl = setup_redirect_client( cntx, enumInfo->auth_data.username, enumInfo->auth_data.password);


     wsman_send_request(cl,cntx->indoc);

     if (wsmc_get_last_error(cl) != WS_LASTERR_OK ){
         //CURL or HTTP errors
         enumInfo->pullResultPtr = NULL;
         status->fault_code = WSMAN_INTERNAL_ERROR;
         status->fault_detail_code = 0;
         status->fault_msg = redirect_fault_msg( wsman_transport_get_last_error_string(  wsmc_get_last_error(cl) )  );
             return 1;
     }


     response = wsmc_build_envelope_from_response(cl);


     if ( ! wsman_is_fault_envelope(response) )
 	    enumInfo->pullResultPtr = response;

     else{
 	    //If there a fault, return the status code.
 	    enumInfo->pullResultPtr = NULL;
 	    wsman_get_fault_status_from_doc (response, status);
 	    retVal=1;
     }

     wsmc_release(cl);

     return retVal;
 }


 int Redirect_Custom_EP( SoapOpH op,
 		void* appData,
 		void *opaqueData )
 {

     //By passing the stubs. Called from process_inbound_operation

     //Fix the wsa:To element in the forwarded request?? Nothing is verifying the URL in this element anyway.
 	return Redirect_transfer_action(op,appData, opaqueData);


 }


 static void xml_print( WsXmlDocH doc)
 {

         ws_xml_dump_node_tree(stdout, ws_xml_get_doc_root(doc));
         return;

 }

 WsXmlDocH redirect_generate_fault( WsXmlDocH in_doc, WsManClient *cl)
 {

     WS_LASTERR_Code last_error =wsmc_get_last_error(cl);
     char *last_error_string = wsman_transport_get_last_error_string(last_error);


     return wsman_generate_fault(in_doc, WSMAN_INTERNAL_ERROR, 0,
 	redirect_fault_msg(last_error_string) );


 }

 char* redirect_fault_msg (char * last_error_string)
 {
     char *prepend_string = "Redirect Plugin: ";
     char* fault_msg =calloc(1,strlen(prepend_string)+strlen(last_error_string)+2);

     strncpy(fault_msg, prepend_string, strlen(prepend_string));
     strncat(fault_msg, last_error_string, strlen(last_error_string));

     return fault_msg;

 }
	/*
	* Copyright (c) 2006 Dell, Inc.
	* by Praveen K Paladugu <praveen_paladugu@dell.com>
	* Licensed under the GNU General Public license, version 2.
	*/


	#include "wsman_config.h"

	#include "stdlib.h"
	#include "stdio.h"
	#include "string.h"
	#include "ctype.h"


	#include "u/libu.h"

	#include "wsman-xml-api.h"
	#include "wsman-soap.h"
	#include "wsman-xml.h"
	#include "wsman-client-api.h"
	#include "wsman-xml-serializer.h"

	#include <wsman-client-transport.h>
	#include <wsman-debug.h>

	#include "wsman-soap-envelope.h"
	#include "wsman-soap-message.h"
	#include "wsman-dispatcher.h"

	#include "redirect.h"


	WsXmlDocH redirect_generate_fault( WsXmlDocH in_doc, WsManClient *cl);
	char* redirect_fault_msg (char * last_error_string);

	//DEBUG
	static void xml_print( WsXmlDocH doc);

	int Redirect_transfer_action ( SoapOpH op,
	void* appData,
	void *opaqueData)
	{
	//Same function to be called for Get, Put, Create, Delete Actions
	WsmanMessage *msg = wsman_get_msg_from_op(op);
	SoapH soap = soap_get_op_soap(op);
	WsXmlDocH in_doc = soap_get_op_doc(op, 1);
	WsContextH cntx = ws_create_ep_context(soap, in_doc);
	WsManClient *cl=NULL;
	WsXmlDocH response=NULL;



	debug ("Test Get Endpoint Called");
	cl = setup_redirect_client(cntx, msg->auth_data.username, msg->auth_data.password );

	wsman_send_request(cl,cntx->indoc);


	if (wsmc_get_last_error(cl) != WS_LASTERR_OK ){
	//CURL/ HTTP errors
	soap_set_op_doc(op,
	redirect_generate_fault( cntx->indoc , cl),
	0);

	return 1;
	}


	response = wsmc_build_envelope_from_response(cl);

	soap_set_op_doc(op,
	ws_xml_duplicate_doc(response), 0);

	wsmc_release(cl);

	return 0;
	}


	int Redirect_Get_EP( SoapOpH op,
	void* appData,
	void *opaqueData)

	{
	return Redirect_transfer_action(op,appData, opaqueData);

	}

	int Redirect_Create_EP( SoapOpH op,
	void* appData,
	void *opaqueData)

	{
	return Redirect_transfer_action(op,appData, opaqueData);

	}

	int Redirect_Delete_EP( SoapOpH op,
	void* appData,
	void *opaqueData)

	{
	return Redirect_transfer_action(op,appData, opaqueData);

	}



	int Redirect_Put_EP( SoapOpH op,
	void* appData,
	void *opaqueData)
	{
	return Redirect_transfer_action(op,appData, opaqueData);
	}


	int Redirect_Enumerate_EP(WsContextH cntx,
	WsEnumerateInfo* enumInfo,
	WsmanStatus status, void opaqueData)
	{

	WsXmlNodeH r_header=NULL, r_node=NULL, r_body=NULL, r_opt=NULL;
	WsXmlDocH r_response=NULL;
	char resource_uri, remote_enumContext=NULL;
	int op;
	WsManClient *cl=NULL;


	//The redirected Enumeration request must have RequestTotalItemsCountEstimate enabled

	r_header = ws_xml_get_soap_header(cntx->indoc);
	if ( (r_node = ws_xml_get_child(r_header,0,XML_NS_WS_MAN, WSM_REQUEST_TOTAL )) == NULL )
	ws_xml_add_child(r_header, XML_NS_WS_MAN, WSM_REQUEST_TOTAL, NULL);


	cl = setup_redirect_client(cntx, enumInfo->auth_data.username, enumInfo->auth_data.password);


	//Set the enumInfo flags based on the indoc. This is required while handling the response in wsenum_eunmerate_stub
	r_body=ws_xml_get_soap_body(cntx->indoc);
	if ( ( r_node = ws_xml_get_child(r_body ,0, XML_NS_ENUMERATION, WSENUM_ENUMERATE )) != NULL )
	{
	if ( (r_opt = ws_xml_get_child(r_node,0,XML_NS_WS_MAN,WSM_OPTIMIZE_ENUM )) != NULL )
	enumInfo->flags \|= WSMAN_ENUMINFO_OPT ;

	}


	wsman_send_request(cl,cntx->indoc);

	if (wsmc_get_last_error(cl) != WS_LASTERR_OK ){
	//CURL or HTTP errors
	enumInfo->pullResultPtr = NULL;
	status->fault_code = WSMAN_INTERNAL_ERROR;
	status->fault_detail_code = 0;
	status->fault_msg = redirect_fault_msg( wsman_transport_get_last_error_string( wsmc_get_last_error(cl) ) );
	return 1;
	}




	r_response = wsmc_build_envelope_from_response(cl);


	if ( wsman_is_fault_envelope(r_response)){
	enumInfo->pullResultPtr = NULL;
	wsman_get_fault_status_from_doc(r_response, status);
	return 1;
	}



	//Get the Estimated Total No.of Items from the response.
	r_header=ws_xml_get_soap_header(r_response);
	r_node=ws_xml_get_child(r_header,0,XML_NS_WS_MAN, WSM_TOTAL_ESTIMATE );
	enumInfo->totalItems=(!r_node) ? 0: atoi(ws_xml_get_node_text(r_node));


	//Get the remote context
	remote_enumContext = wsmc_get_enum_context(r_response);



	//Set the pullResultPtr only if some Enum Items are returned, in optimized mode.
	r_body= ws_xml_get_soap_body(r_response);

	if ( (r_node = ws_xml_get_child(r_body,0,XML_NS_ENUMERATION, WSENUM_ENUMERATE_RESP )) != NULL &&
	( ws_xml_get_child(r_node,0,XML_NS_WS_MAN,WSENUM_ITEMS) != NULL) )

	{

	enumInfo->pullResultPtr = r_response;

	if( strlen(remote_enumContext) != 0 )
	strncpy(enumInfo->enumId, remote_enumContext, strlen(remote_enumContext)+1);

	else // If all the instances are returned, the context will be NULL
	enumInfo->enumId[0]='\0';

	}

	else{
	//If not items are returned, set the context and return.
	strncpy(enumInfo->enumId, remote_enumContext, strlen(remote_enumContext)+1);
	ws_xml_destroy_doc(r_response);

	}

	wsmc_release(cl);
	if (remote_enumContext != NULL)
	free(remote_enumContext);

	return 0;

	}


	int Redirect_Release_EP(WsContextH cntx,
	WsEnumerateInfo* enumInfo,
	WsmanStatus status, void opaqueData)
	{


	WsManClient *cl=NULL;
	WsXmlDocH response=NULL;


	cl = setup_redirect_client(cntx, enumInfo->auth_data.username, enumInfo->auth_data.password);

	wsman_send_request(cl,cntx->indoc);
	if (wsmc_get_last_error(cl) != WS_LASTERR_OK ){
	//just return for now, as the release_stub is not handling the status codes.
	return 1;
	}

	response=wsmc_build_envelope_from_response(cl);

	//The status value is not used in the release stub. So, just return, if fault or not.
	return wsman_is_fault_envelope(response);
	}

	int Redirect_Pull_EP(WsContextH cntx, WsEnumerateInfo* enumInfo,
	WsmanStatus status, void opaqueData)
	{
	WsXmlDocH doc=NULL,response=NULL;
	WsManClient *cl=NULL;
	int retVal=0;




	cl = setup_redirect_client( cntx, enumInfo->auth_data.username, enumInfo->auth_data.password);


	wsman_send_request(cl,cntx->indoc);

	if (wsmc_get_last_error(cl) != WS_LASTERR_OK ){
	//CURL or HTTP errors
	enumInfo->pullResultPtr = NULL;
	status->fault_code = WSMAN_INTERNAL_ERROR;
	status->fault_detail_code = 0;
	status->fault_msg = redirect_fault_msg( wsman_transport_get_last_error_string( wsmc_get_last_error(cl) ) );
	return 1;
	}


	response = wsmc_build_envelope_from_response(cl);


	if ( ! wsman_is_fault_envelope(response) )
	enumInfo->pullResultPtr = response;

	else{
	//If there a fault, return the status code.
	enumInfo->pullResultPtr = NULL;
	wsman_get_fault_status_from_doc (response, status);
	retVal=1;
	}

	wsmc_release(cl);

	return retVal;
	}



	int Redirect_Custom_EP( SoapOpH op,
	void* appData,
	void *opaqueData )
	{

	//By passing the stubs. Called from process_inbound_operation

	//Fix the wsa:To element in the forwarded request?? Nothing is verifying the URL in this element anyway.
	return Redirect_transfer_action(op,appData, opaqueData);



	}


	static void xml_print( WsXmlDocH doc)
	{

	ws_xml_dump_node_tree(stdout, ws_xml_get_doc_root(doc));
	return;

	}

	WsXmlDocH redirect_generate_fault( WsXmlDocH in_doc, WsManClient *cl)
	{

	WS_LASTERR_Code last_error =wsmc_get_last_error(cl);
	char *last_error_string = wsman_transport_get_last_error_string(last_error);


	return wsman_generate_fault(in_doc, WSMAN_INTERNAL_ERROR, 0,
	redirect_fault_msg(last_error_string) );


	}

	char* redirect_fault_msg (char * last_error_string)
	{
	char *prepend_string = "Redirect Plugin: ";
	char* fault_msg =calloc(1,strlen(prepend_string)+strlen(last_error_string)+2);

	strncpy(fault_msg, prepend_string, strlen(prepend_string));
	strncat(fault_msg, last_error_string, strlen(last_error_string));

	return fault_msg;

	}