// THIS CODE AND INFORMATION IS PROVIDED "AS IS" WITHOUT WARRANTY OF // ANY KIND, EITHER EXPRESSED OR IMPLIED, INCLUDING BUT NOT LIMITED TO // THE IMPLIED WARRANTIES OF MERCHANTABILITY AND/OR FITNESS FOR A // PARTICULAR PURPOSE. // // Copyright (c) Microsoft Corporation. All rights reserved #ifndef UNICODE #define UNICODE #endif #include "WebServices.h" #include "process.h" #include "stdio.h" #include "string.h" #include #include "PurchaseOrder.wsdl.h" // Print out rich error info void PrintError( _In_ HRESULT errorCode, _In_opt_ WS_ERROR* error) { wprintf(L"Failure: errorCode=0x%lx\n", errorCode); if (errorCode == E_INVALIDARG || errorCode == WS_E_INVALID_OPERATION) { // Correct use of the APIs should never generate these errors wprintf(L"The error was due to an invalid use of an API. This is likely due to a bug in the program.\n"); } HRESULT hr = S_OK; if (error != NULL) { ULONG errorCount; hr = WsGetErrorProperty(error, WS_ERROR_PROPERTY_STRING_COUNT, &errorCount, sizeof(errorCount)); if (FAILED(hr)) { goto Exit; } for (ULONG i = 0; i < errorCount; i++) { WS_STRING string; hr = WsGetErrorString(error, i, &string); if (FAILED(hr)) { goto Exit; } wprintf(L"%.*s\n", string.length, string.chars); } } Exit: if (FAILED(hr)) { wprintf(L"Could not get error string (errorCode=0x%lx)\n", hr); } } HANDLE closeServer = NULL; static const WCHAR ExpectedShipDate [] = L"1/1/2006"; static const WCHAR OrderStatusString [] = L"Pending"; static const WS_XML_STRING serviceName = WS_XML_STRING_VALUE("PurchaseOrderService"); static const WS_XML_STRING serviceNamespace = WS_XML_STRING_VALUE("http://example.org"); static const WS_XML_STRING portName = WS_XML_STRING_VALUE("IPurchaseOrder"); static const WS_XML_STRING bindingName = WS_XML_STRING_VALUE("PurchaseOrderBinding"); static const WS_XML_STRING bindingNs = WS_XML_STRING_VALUE("http://example.org"); // The WSDL document used by this example const static WS_XML_STRING wsdl = WS_XML_STRING_VALUE( "" " " " " " " " " " " " " " " " " " " " " " " " " " " " " " " " " " " " " " " " " " " " " " " " " " " " " " " " " " " " " " " " " " " " " " " " " " " " " " " " " " " " " " " " " " " " " " " " " "" ); static const WS_XML_STRING xsd = WS_XML_STRING_VALUE( "" "" "" "" "" "" "" "" "" "" "" "" "" "" "" "" "" "" "" "" "" "" "" "" "" "" "" "" "" "" "" "" "" ); static const WS_MESSAGE_DESCRIPTION emptyMessageDescription = { NULL, NULL }; static const WS_XML_STRING verbHeaderName = WS_XML_STRING_VALUE("Verb"); static const WS_XML_STRING contentTypeHeaderName = WS_XML_STRING_VALUE("Content-Type"); static const WS_XML_STRING statusCodeName = WS_XML_STRING_VALUE("StatusCode"); static const WS_XML_STRING statusTextName = WS_XML_STRING_VALUE("StatusText"); static const WS_STRING replyContentType = WS_STRING_VALUE(L"text/html"); static const BYTE replyBodyBytes[] = "" "" "Welcome To Web Services Sample" "" "" "

Welcome To Web Services Sample

" "

Introduction

" "

" "You are receiving this request from a service written using Windows Web Services" "

" "

Metadata

" "

" "Metadata for this service can be fetched using WS-MetadataExchange v1.1 by using the address, http://localhost/example" "

" "

" "Alternatively you can fetch the WSDL document directly using the address, http://localhost/metadata/wsdl" "

" "" "" ; static const WS_STRING wsdlDocumentName = WS_STRING_VALUE(L"wsdl"); static const WS_STRING xsdDocumentName = WS_STRING_VALUE(L"xsd"); static const WS_SERVICE_METADATA_DOCUMENT wsdlDocument = { (WS_XML_STRING*)&wsdl, (WS_STRING*)&wsdlDocumentName }; static const WS_SERVICE_METADATA_DOCUMENT xsdDocument = { (WS_XML_STRING*)&xsd, (WS_STRING*)&xsdDocumentName }; static const WS_SERVICE_METADATA_DOCUMENT* metadataDocuments[] = { &wsdlDocument, &xsdDocument }; static const WS_ELEMENT_DESCRIPTION bytesBodyDescription = { NULL, NULL, WS_BYTES_TYPE, NULL }; static const WS_MESSAGE_DESCRIPTION bytesMessageDescription = { NULL, const_cast(&bytesBodyDescription) }; HRESULT SetStatus( _In_ WS_MESSAGE* replyMessage, _In_ ULONG statusCode, _In_z_ WCHAR* statusText, _In_opt_ WS_ERROR* error) { HRESULT hr; // Add the status text to the message hr = WsAddMappedHeader( replyMessage, &statusTextName, WS_WSZ_TYPE, WS_WRITE_REQUIRED_POINTER, &statusText, sizeof(statusText), error); if (FAILED(hr)) { goto Exit; } // Add the status code to the message hr = WsAddMappedHeader( replyMessage, &statusCodeName, WS_UINT32_TYPE, WS_WRITE_REQUIRED_VALUE, &statusCode, sizeof(statusCode), error); if (FAILED(hr)) { goto Exit; } Exit: return hr; } HRESULT SendFailureMessage( _In_ WS_CHANNEL* channel, _In_ WS_MESSAGE* replyMessage, _In_ ULONG statusCode, _In_z_ WCHAR* statusText, _In_opt_ WS_ERROR* error) { HRESULT hr; // Add status code/text to the reply hr = SetStatus( replyMessage, statusCode, statusText, error); if (FAILED(hr)) { goto Exit; } // Send the reply hr = WsSendMessage( channel, replyMessage, &emptyMessageDescription, WS_WRITE_REQUIRED_VALUE, NULL, 0, NULL, error); if (FAILED(hr)) { goto Exit; } Exit: return hr; } HRESULT CALLBACK ProcessMessage( _In_ const WS_OPERATION_CONTEXT* context, _In_ const WS_ASYNC_CONTEXT* asyncContext, _In_ WS_ERROR* error) { UNREFERENCED_PARAMETER(asyncContext); WS_CHANNEL* channel = NULL; HRESULT hr = S_OK; WS_MESSAGE* requestMessage = NULL; WS_MESSAGE* replyMessage = NULL; WS_HEAP* heap; // Get the request mesasge hr = WsGetOperationContextProperty( context, WS_OPERATION_CONTEXT_PROPERTY_INPUT_MESSAGE, &requestMessage, sizeof(requestMessage), error); if (FAILED(hr)) { return hr; } // Get the channel hr = WsGetOperationContextProperty( context, WS_OPERATION_CONTEXT_PROPERTY_CHANNEL, &channel, sizeof(channel), error); if (FAILED(hr)) { return hr; } // Get the heap hr = WsGetOperationContextProperty( context, WS_OPERATION_CONTEXT_PROPERTY_HEAP, &heap, sizeof(heap), error); if (FAILED(hr)) { return hr; } // Create a reply message hr = WsCreateMessageForChannel( channel, NULL, 0, &replyMessage, error); if (FAILED(hr)) { goto Exit; } // Initialize reply message hr = WsInitializeMessage(replyMessage, WS_REPLY_MESSAGE, requestMessage, error); if (FAILED(hr)) { goto Exit; } // Get the HTTP Verb WS_STRING verb; hr = WsGetMappedHeader( requestMessage, &verbHeaderName, WS_SINGLETON_HEADER, 0, WS_STRING_TYPE, WS_READ_REQUIRED_VALUE, NULL, &verb, sizeof(verb), error); if (FAILED(hr)) { goto Exit; } wprintf(L"Verb: %.*s\n", verb.length, verb.chars); if (CompareString(LOCALE_INVARIANT, NORM_IGNORECASE, verb.chars, verb.length, L"GET", 3) != CSTR_EQUAL) { // Unrecognized verb hr = SendFailureMessage(channel, replyMessage, 405, L"Method Not Allowed", error); goto Exit; } // Read end of request message hr = WsReadMessageEnd(channel, requestMessage, NULL, error); if (FAILED(hr)) { goto Exit; } // Set content type header of reply hr = WsAddMappedHeader( replyMessage, &contentTypeHeaderName, WS_STRING_TYPE, WS_WRITE_REQUIRED_VALUE, &replyContentType, sizeof(replyContentType), error); if (FAILED(hr)) { goto Exit; } // Set status of reply hr = SetStatus(replyMessage, 200, L"OK", error); if (FAILED(hr)) { goto Exit; } // Set up the bytes to return in the HTTP body WS_BYTES body; body.bytes = const_cast(replyBodyBytes); body.length = sizeof(replyBodyBytes); // Send the reply message hr = WsSendMessage( channel, replyMessage, &bytesMessageDescription, WS_WRITE_REQUIRED_VALUE, &body, sizeof(body), NULL, error); if (FAILED(hr)) { goto Exit; } Exit: if (replyMessage != NULL) { WsFreeMessage(replyMessage); } return hr; } HRESULT CALLBACK PurchaseOrderImpl( _In_ const WS_OPERATION_CONTEXT* context, _In_ int quantity, _In_opt_z_ WCHAR* productName, _Out_ unsigned int* orderID, _Outptr_result_z_ WCHAR** expectedShipDate, _In_ const WS_ASYNC_CONTEXT* asyncContext, _In_ WS_ERROR* error) { UNREFERENCED_PARAMETER(asyncContext); WS_HEAP* heap = NULL; HRESULT hr = S_OK; wprintf(L"%ld, %s\n", quantity, productName); fflush(stdout); hr = WsGetOperationContextProperty(context, WS_OPERATION_CONTEXT_PROPERTY_HEAP, &heap, sizeof(heap), error); if (FAILED(hr)) { return hr; } hr = WsAlloc(heap, sizeof(ExpectedShipDate), (void**)expectedShipDate, error); if (FAILED(hr)) { return hr; } hr = StringCbCopyW(*expectedShipDate, sizeof(ExpectedShipDate), ExpectedShipDate); if (FAILED(hr)) { return hr; } *orderID = 123; return S_OK; } HRESULT CALLBACK GetOrderStatusImpl( _In_ const WS_OPERATION_CONTEXT* context, _Inout_ unsigned int* orderID, _Outptr_result_z_ WCHAR** status, _In_ const WS_ASYNC_CONTEXT* asyncContext, _In_ WS_ERROR* error) { UNREFERENCED_PARAMETER(asyncContext); WS_HEAP* heap = NULL; HRESULT hr = S_OK; *orderID = *orderID; hr = WsGetOperationContextProperty(context, WS_OPERATION_CONTEXT_PROPERTY_HEAP, &heap, sizeof(heap), error); if (FAILED(hr)) { return hr; } hr = WsAlloc(heap, sizeof(OrderStatusString), (void**)status, error); if (FAILED(hr)) { return hr; } hr = StringCbCopyW(*status, sizeof(OrderStatusString), OrderStatusString); if (FAILED(hr)) { return hr; } return S_OK; } ULONG numberOfSession = 0; HRESULT CALLBACK CloseChannelCallback( _In_ const WS_OPERATION_CONTEXT* context, _In_ const WS_ASYNC_CONTEXT* asyncContext) { UNREFERENCED_PARAMETER(context); UNREFERENCED_PARAMETER(asyncContext); if (InterlockedIncrement(&numberOfSession) == 6) { SetEvent(closeServer); } return S_OK; } static const PurchaseOrderBindingFunctionTable purchaseOrderFunctions = {PurchaseOrderImpl, GetOrderStatusImpl}; static const WS_SERVICE_CONTRACT messageContract = { NULL, ProcessMessage, NULL }; // Method contract for the service static const WS_SERVICE_CONTRACT purchaseOrderContract = { &PurchaseOrder_wsdl.contracts.PurchaseOrderBinding, // comes from the generated header. NULL, // for not specifying the default contract &purchaseOrderFunctions // specified by the user }; // Main entry point int __cdecl wmain() { HRESULT hr = S_OK; WS_SERVICE_HOST* host = NULL; WS_SERVICE_ENDPOINT typedHttpEndpoint = {}; WS_SERVICE_ENDPOINT unTypedHttpEndpoint = {}; const WS_SERVICE_ENDPOINT* serviceEndpoints[] = {&typedHttpEndpoint, &unTypedHttpEndpoint}; WS_ERROR* error = NULL; WS_SERVICE_PROPERTY serviceProperties[1]; WS_SERVICE_METADATA serviceMetadata = {}; WS_SERVICE_ENDPOINT_PROPERTY serviceEndpointPropertiesTypedContract[3]; WS_SERVICE_ENDPOINT_PROPERTY serviceEndpointPropertiesMetadata[2]; WS_SERVICE_PROPERTY_CLOSE_CALLBACK closeCallbackProperty = {CloseChannelCallback}; WS_SERVICE_ENDPOINT_METADATA endpointMetadata = {}; WS_METADATA_EXCHANGE_TYPE metadataExchangeTypeMex = WS_METADATA_EXCHANGE_TYPE_MEX; WS_METADATA_EXCHANGE_TYPE metadataExchangeTypeHttpGet = WS_METADATA_EXCHANGE_TYPE_HTTP_GET; // Configure Port on the endpoint for Mex endpointMetadata.portName = (WS_XML_STRING*)&portName; endpointMetadata.bindingName = (WS_XML_STRING*)&bindingName; endpointMetadata.bindingNs = (WS_XML_STRING*)&bindingNs; serviceEndpointPropertiesTypedContract[0].id = WS_SERVICE_ENDPOINT_PROPERTY_CLOSE_CHANNEL_CALLBACK; serviceEndpointPropertiesTypedContract[0].value = &closeCallbackProperty; serviceEndpointPropertiesTypedContract[0].valueSize = sizeof(closeCallbackProperty); // Specifying Port on the endpoint. serviceEndpointPropertiesTypedContract[1].id = WS_SERVICE_ENDPOINT_PROPERTY_METADATA; serviceEndpointPropertiesTypedContract[1].value = &endpointMetadata; serviceEndpointPropertiesTypedContract[1].valueSize = sizeof(endpointMetadata); // Marking the endpoint to service WS-MetadataExchnage Requests serviceEndpointPropertiesTypedContract[2].id = WS_SERVICE_ENDPOINT_PROPERTY_METADATA_EXCHANGE_TYPE; serviceEndpointPropertiesTypedContract[2].value = &metadataExchangeTypeMex; serviceEndpointPropertiesTypedContract[2].valueSize = sizeof(metadataExchangeTypeMex); typedHttpEndpoint.address.url.chars = L"http://+:80/example"; // address given as uri typedHttpEndpoint.address.url.length = (ULONG)wcslen(typedHttpEndpoint.address.url.chars); typedHttpEndpoint.channelBinding = WS_HTTP_CHANNEL_BINDING; // channel binding for the endpoint typedHttpEndpoint.channelType = WS_CHANNEL_TYPE_REPLY; // the channel type typedHttpEndpoint.contract = (WS_SERVICE_CONTRACT*)&purchaseOrderContract; // the contract typedHttpEndpoint.properties = serviceEndpointPropertiesTypedContract; typedHttpEndpoint.propertyCount = WsCountOf(serviceEndpointPropertiesTypedContract); serviceEndpointPropertiesMetadata[0].id = WS_SERVICE_ENDPOINT_PROPERTY_METADATA_EXCHANGE_TYPE; serviceEndpointPropertiesMetadata[0].value = &metadataExchangeTypeHttpGet; serviceEndpointPropertiesMetadata[0].valueSize = sizeof(metadataExchangeTypeHttpGet); serviceEndpointPropertiesMetadata[1].id = WS_SERVICE_ENDPOINT_PROPERTY_CLOSE_CHANNEL_CALLBACK; serviceEndpointPropertiesMetadata[1].value = &closeCallbackProperty; serviceEndpointPropertiesMetadata[1].valueSize = sizeof(closeCallbackProperty); unTypedHttpEndpoint.address.url.chars = L"http://+:80/metadata"; // address given as uri unTypedHttpEndpoint.address.url.length = (ULONG)wcslen(unTypedHttpEndpoint.address.url.chars); unTypedHttpEndpoint.channelBinding = WS_HTTP_CHANNEL_BINDING; // channel binding for the endpoint unTypedHttpEndpoint.channelType = WS_CHANNEL_TYPE_REPLY; // the channel type unTypedHttpEndpoint.contract = &messageContract; unTypedHttpEndpoint.properties = serviceEndpointPropertiesMetadata; unTypedHttpEndpoint.propertyCount = WsCountOf(serviceEndpointPropertiesMetadata); // Specifying WSDL document serviceMetadata.documentCount = WsCountOf(metadataDocuments); serviceMetadata.documents = (WS_SERVICE_METADATA_DOCUMENT**) metadataDocuments; // Initializing name of the service serviceMetadata.serviceName = (WS_XML_STRING*)&serviceName; // Note that this should concide be the target namespace of the wsdl document serviceMetadata.serviceNs = (WS_XML_STRING*)&serviceNamespace; // Specifying metadata document serviceProperties[0].id = WS_SERVICE_PROPERTY_METADATA; serviceProperties[0].value = &serviceMetadata; serviceProperties[0].valueSize = sizeof(serviceMetadata); // Create an error object for storing rich error information hr = WsCreateError( NULL, 0, &error); if (FAILED(hr)) { goto Exit; } // Create Event object for closing the server closeServer = CreateEvent( NULL, TRUE, FALSE, NULL); if (closeServer == NULL) { hr = HRESULT_FROM_WIN32(GetLastError()); goto Exit; } // Creating a service host hr = WsCreateServiceHost(serviceEndpoints, WsCountOf(serviceEndpoints), serviceProperties, WsCountOf(serviceProperties), &host, error); if (FAILED(hr)) { goto Exit; } // WsOpenServiceHost to start the listeners in the service host hr = WsOpenServiceHost(host, NULL, error); if (FAILED(hr)) { goto Exit; } WaitForSingleObject(closeServer, INFINITE); // Close the service host hr = WsCloseServiceHost(host, NULL, error); if (FAILED(hr)) { goto Exit; } Exit: if (FAILED(hr)) { // Print out the error PrintError(hr, error); } if (host != NULL) { WsFreeServiceHost(host); } if (error != NULL) { WsFreeError(error); } if (closeServer != NULL) { CloseHandle(closeServer); } fflush(stdout); return SUCCEEDED(hr) ? 0 : -1; }