dlls/webservices/proxy.c

   1 /*
   2  * Copyright 2016 Hans Leidekker for CodeWeavers
   3  *
   4  * This library is free software; you can redistribute it and/or
   5  * modify it under the terms of the GNU Lesser General Public
   6  * License as published by the Free Software Foundation; either
   7  * version 2.1 of the License, or (at your option) any later version.
   8  *
   9  * This library is distributed in the hope that it will be useful,
  10  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  11  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
  12  * Lesser General Public License for more details.
  13  *
  14  * You should have received a copy of the GNU Lesser General Public
  15  * License along with this library; if not, write to the Free Software
  16  * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301, USA
  17  */
  18
  19 #include <stdarg.h>
  20
  21 #include "windef.h"
  22 #include "winbase.h"
  23 #include "winuser.h"
  24 #include "webservices.h"
  25
  26 #include "wine/debug.h"
  27 #include "wine/list.h"
  28 #include "webservices_private.h"
  29
  30 WINE_DEFAULT_DEBUG_CHANNEL(webservices);
  31
  32 static const struct prop_desc proxy_props[] =
  33 {
  34     { sizeof(ULONG), FALSE, TRUE },             /* WS_PROXY_PROPERTY_CALL_TIMEOUT */
  35     { sizeof(WS_MESSAGE_PROPERTIES), FALSE },   /* WS_PROXY_PROPERTY_MESSAGE_PROPERTIES */
  36     { sizeof(USHORT), FALSE, TRUE },            /* WS_PROXY_PROPERTY_MAX_CALL_POOL_SIZE */
  37     { sizeof(WS_SERVICE_PROXY_STATE), TRUE },   /* WS_PROXY_PROPERTY_STATE */
  38     { sizeof(ULONG), FALSE, TRUE },             /* WS_PROXY_PROPERTY_MAX_PENDING_CALLS */
  39     { sizeof(ULONG), FALSE, TRUE },             /* WS_PROXY_PROPERTY_MAX_CLOSE_TIMEOUT */
  40     { sizeof(LANGID), FALSE, TRUE },            /* WS_PROXY_FAULT_LANG_ID */
  41 };
  42
  43 struct proxy
  44 {
  45     ULONG                   magic;
  46     CRITICAL_SECTION        cs;
  47     WS_SERVICE_PROXY_STATE  state;
  48     WS_CHANNEL             *channel;
  49     ULONG                   prop_count;
  50     struct prop             prop[sizeof(proxy_props)/sizeof(proxy_props[0])];
  51 };
  52
  53 #define PROXY_MAGIC (('P' << 24) | ('R' << 16) | ('O' << 8) | 'X')
  54
  55 static struct proxy *alloc_proxy(void)
  56 {
  57     static const ULONG count = sizeof(proxy_props)/sizeof(proxy_props[0]);
  58     struct proxy *ret;
  59     ULONG size = sizeof(*ret) + prop_size( proxy_props, count );
  60
  61     if (!(ret = heap_alloc_zero( size ))) return NULL;
  62
  63     ret->magic      = PROXY_MAGIC;
  64     InitializeCriticalSection( &ret->cs );
  65     ret->cs.DebugInfo->Spare[0] = (DWORD_PTR)(__FILE__ ": proxy.cs");
  66
  67     prop_init( proxy_props, count, ret->prop, &ret[1] );
  68     ret->prop_count = count;
  69     return ret;
  70 }
  71
  72 static void reset_proxy( struct proxy *proxy )
  73 {
  74     WsResetChannel( proxy->channel, NULL );
  75     proxy->state = WS_SERVICE_PROXY_STATE_CREATED;
  76 }
  77
  78 static void free_proxy( struct proxy *proxy )
  79 {
  80     reset_proxy( proxy );
  81     WsFreeChannel( proxy->channel );
  82
  83     proxy->cs.DebugInfo->Spare[0] = 0;
  84     DeleteCriticalSection( &proxy->cs );
  85     heap_free( proxy );
  86 }
  87
  88 static HRESULT create_proxy( WS_CHANNEL *channel, const WS_PROXY_PROPERTY *properties, ULONG count,
  89                              WS_SERVICE_PROXY **handle )
  90 {
  91     struct proxy *proxy;
  92     HRESULT hr;
  93     ULONG i;
  94
  95     if (!(proxy = alloc_proxy())) return E_OUTOFMEMORY;
  96
  97     for (i = 0; i < count; i++)
  98     {
  99         hr = prop_set( proxy->prop, proxy->prop_count, properties[i].id, properties[i].value,
 100                        properties[i].valueSize );
 101         if (hr != S_OK)
 102         {
 103             free_proxy( proxy );
 104             return hr;
 105         }
 106     }
 107
 108     proxy->channel = channel;
 109
 110     *handle = (WS_SERVICE_PROXY *)proxy;
 111     return S_OK;
 112 }
 113
 114 /**************************************************************************
 115  *          WsCreateServiceProxy                [webservices.@]
 116  */
 117 HRESULT WINAPI WsCreateServiceProxy( const WS_CHANNEL_TYPE type, const WS_CHANNEL_BINDING binding,
 118                                      const WS_SECURITY_DESCRIPTION *desc,
 119                                      const WS_PROXY_PROPERTY *proxy_props, ULONG proxy_props_count,
 120                                      const WS_CHANNEL_PROPERTY *channel_props,
 121                                      const ULONG channel_props_count, WS_SERVICE_PROXY **handle,
 122                                      WS_ERROR *error )
 123 {
 124     WS_CHANNEL *channel;
 125     HRESULT hr;
 126
 127     TRACE( "%u %u %p %p %u %p %u %p %p\n", type, binding, desc, proxy_props, proxy_props_count,
 128            channel_props, channel_props_count, handle, error );
 129     if (error) FIXME( "ignoring error parameter\n" );
 130     if (desc) FIXME( "ignoring security description\n" );
 131
 132     if (!handle) return E_INVALIDARG;
 133
 134     if ((hr = WsCreateChannel( type, binding, channel_props, channel_props_count, NULL, &channel,
 135                                NULL )) != S_OK) return hr;
 136
 137     if ((hr = create_proxy( channel, proxy_props, proxy_props_count, handle )) != S_OK)
 138     {
 139         WsFreeChannel( channel );
 140         return hr;
 141     }
 142
 143     TRACE( "created %p\n", *handle );
 144     return S_OK;
 145 }
 146
 147 /**************************************************************************
 148  *          WsCreateServiceProxyFromTemplate            [webservices.@]
 149  */
 150 HRESULT WINAPI WsCreateServiceProxyFromTemplate( WS_CHANNEL_TYPE channel_type,
 151                                                  const WS_PROXY_PROPERTY *properties, const ULONG count,
 152                                                  WS_BINDING_TEMPLATE_TYPE type, void *value, ULONG size,
 153                                                  const void *desc, ULONG desc_size, WS_SERVICE_PROXY **handle,
 154                                                  WS_ERROR *error )
 155 {
 156     const WS_CHANNEL_PROPERTY *channel_props = NULL;
 157     ULONG channel_props_count = 0;
 158     WS_CHANNEL_BINDING binding;
 159     WS_CHANNEL *channel;
 160     HRESULT hr;
 161
 162     TRACE( "%u %p %u %u %p %u %p %u %p %p\n", channel_type, properties, count, type, value, size, desc,
 163            desc_size, handle, error );
 164     if (error) FIXME( "ignoring error parameter\n" );
 165
 166     if (!desc || !handle) return E_INVALIDARG;
 167     FIXME( "ignoring description\n" );
 168
 169     switch (type)
 170     {
 171     case WS_HTTP_BINDING_TEMPLATE_TYPE:
 172     {
 173         WS_HTTP_BINDING_TEMPLATE *http = value;
 174         if (http)
 175         {
 176             channel_props = http->channelProperties.properties;
 177             channel_props_count = http->channelProperties.propertyCount;
 178         }
 179         binding = WS_HTTP_CHANNEL_BINDING;
 180         break;
 181     }
 182     case WS_HTTP_SSL_BINDING_TEMPLATE_TYPE:
 183     {
 184         WS_HTTP_SSL_BINDING_TEMPLATE *https = value;
 185         if (https)
 186         {
 187             channel_props = https->channelProperties.properties;
 188             channel_props_count = https->channelProperties.propertyCount;
 189         }
 190         binding = WS_HTTP_CHANNEL_BINDING;
 191         break;
 192     }
 193     default:
 194         FIXME( "template type %u not implemented\n", type );
 195         return E_NOTIMPL;
 196     }
 197
 198     if ((hr = WsCreateChannel( channel_type, binding, channel_props, channel_props_count, NULL,
 199                                &channel, NULL )) != S_OK) return hr;
 200
 201     if ((hr = create_proxy( channel, properties, count, handle )) != S_OK)
 202     {
 203         WsFreeChannel( channel );
 204         return hr;
 205     }
 206
 207     TRACE( "created %p\n", *handle );
 208     return S_OK;
 209 }
 210
 211 /**************************************************************************
 212  *          WsResetServiceProxy         [webservices.@]
 213  */
 214 HRESULT WINAPI WsResetServiceProxy( WS_SERVICE_PROXY *handle, WS_ERROR *error )
 215 {
 216     struct proxy *proxy = (struct proxy *)handle;
 217
 218     TRACE( "%p %p\n", handle, error );
 219     if (error) FIXME( "ignoring error parameter\n" );
 220
 221     if (!proxy) return E_INVALIDARG;
 222
 223     EnterCriticalSection( &proxy->cs );
 224
 225     if (proxy->magic != PROXY_MAGIC)
 226     {
 227         LeaveCriticalSection( &proxy->cs );
 228         return E_INVALIDARG;
 229     }
 230
 231     if (proxy->state != WS_SERVICE_PROXY_STATE_CREATED && proxy->state != WS_SERVICE_PROXY_STATE_CLOSED)
 232     {
 233         LeaveCriticalSection( &proxy->cs );
 234         return WS_E_INVALID_OPERATION;
 235     }
 236
 237     reset_proxy( proxy );
 238
 239     LeaveCriticalSection( &proxy->cs );
 240     return S_OK;
 241 }
 242
 243 /**************************************************************************
 244  *          WsFreeServiceProxy          [webservices.@]
 245  */
 246 void WINAPI WsFreeServiceProxy( WS_SERVICE_PROXY *handle )
 247 {
 248     struct proxy *proxy = (struct proxy *)handle;
 249
 250     TRACE( "%p\n", handle );
 251
 252     if (!proxy) return;
 253
 254     EnterCriticalSection( &proxy->cs );
 255
 256     if (proxy->magic != PROXY_MAGIC)
 257     {
 258         LeaveCriticalSection( &proxy->cs );
 259         return;
 260     }
 261
 262     proxy->magic = 0;
 263
 264     LeaveCriticalSection( &proxy->cs );
 265     free_proxy( proxy );
 266 }
 267
 268 /**************************************************************************
 269  *          WsGetServiceProxyProperty           [webservices.@]
 270  */
 271 HRESULT WINAPI WsGetServiceProxyProperty( WS_SERVICE_PROXY *handle, WS_PROXY_PROPERTY_ID id,
 272                                           void *buf, ULONG size, WS_ERROR *error )
 273 {
 274     struct proxy *proxy = (struct proxy *)handle;
 275     HRESULT hr = S_OK;
 276
 277     TRACE( "%p %u %p %u %p\n", handle, id, buf, size, error );
 278     if (error) FIXME( "ignoring error parameter\n" );
 279
 280     if (!proxy) return E_INVALIDARG;
 281
 282     EnterCriticalSection( &proxy->cs );
 283
 284     if (proxy->magic != PROXY_MAGIC)
 285     {
 286         LeaveCriticalSection( &proxy->cs );
 287         return E_INVALIDARG;
 288     }
 289
 290     switch (id)
 291     {
 292     case WS_PROXY_PROPERTY_STATE:
 293         if (!buf || size != sizeof(proxy->state)) hr = E_INVALIDARG;
 294         else *(WS_SERVICE_PROXY_STATE *)buf = proxy->state;
 295         break;
 296
 297     default:
 298         hr = prop_get( proxy->prop, proxy->prop_count, id, buf, size );
 299     }
 300
 301     LeaveCriticalSection( &proxy->cs );
 302     return hr;
 303 }
 304
 305 /**************************************************************************
 306  *          WsOpenServiceProxy          [webservices.@]
 307  */
 308 HRESULT WINAPI WsOpenServiceProxy( WS_SERVICE_PROXY *handle, const WS_ENDPOINT_ADDRESS *endpoint,
 309                                    const WS_ASYNC_CONTEXT *ctx, WS_ERROR *error )
 310 {
 311     struct proxy *proxy = (struct proxy *)handle;
 312     HRESULT hr;
 313
 314     TRACE( "%p %p %p %p\n", handle, endpoint, ctx, error );
 315     if (error) FIXME( "ignoring error parameter\n" );
 316     if (ctx) FIXME( "ignoring ctx parameter\n" );
 317
 318     if (!proxy || !endpoint) return E_INVALIDARG;
 319
 320     EnterCriticalSection( &proxy->cs );
 321
 322     if (proxy->magic != PROXY_MAGIC)
 323     {
 324         LeaveCriticalSection( &proxy->cs );
 325         return E_INVALIDARG;
 326     }
 327
 328     if ((hr = WsOpenChannel( proxy->channel, endpoint, NULL, NULL )) == S_OK)
 329         proxy->state = WS_SERVICE_PROXY_STATE_OPEN;
 330
 331     LeaveCriticalSection( &proxy->cs );
 332     return hr;
 333 }
 334
 335 /**************************************************************************
 336  *          WsCloseServiceProxy         [webservices.@]
 337  */
 338 HRESULT WINAPI WsCloseServiceProxy( WS_SERVICE_PROXY *handle, const WS_ASYNC_CONTEXT *ctx, WS_ERROR *error )
 339 {
 340     struct proxy *proxy = (struct proxy *)handle;
 341     HRESULT hr;
 342
 343     TRACE( "%p %p %p\n", handle, ctx, error );
 344     if (error) FIXME( "ignoring error parameter\n" );
 345     if (ctx) FIXME( "ignoring ctx parameter\n" );
 346
 347     if (!proxy) return E_INVALIDARG;
 348
 349     EnterCriticalSection( &proxy->cs );
 350
 351     if (proxy->magic != PROXY_MAGIC)
 352     {
 353         LeaveCriticalSection( &proxy->cs );
 354         return E_INVALIDARG;
 355     }
 356
 357     if ((hr = WsCloseChannel( proxy->channel, NULL, NULL )) == S_OK)
 358         proxy->state = WS_SERVICE_PROXY_STATE_CLOSED;
 359
 360     LeaveCriticalSection( &proxy->cs );
 361     return hr;
 362 }
 363
 364 /**************************************************************************
 365  *          WsAbortServiceProxy         [webservices.@]
 366  */
 367 HRESULT WINAPI WsAbortServiceProxy( WS_SERVICE_PROXY *handle, WS_ERROR *error )
 368 {
 369     FIXME( "%p %p\n", handle, error );
 370     return E_NOTIMPL;
 371 }
 372
 373 static HRESULT set_send_context( WS_MESSAGE *msg, const WS_CALL_PROPERTY *props, ULONG count )
 374 {
 375     ULONG i;
 376     for (i = 0; i < count; i++)
 377     {
 378         if (props[i].id == WS_CALL_PROPERTY_SEND_MESSAGE_CONTEXT)
 379         {
 380             if (props[i].valueSize != sizeof(WS_PROXY_MESSAGE_CALLBACK_CONTEXT)) return E_INVALIDARG;
 381             message_set_send_context( msg, props[i].value );
 382             break;
 383         }
 384     }
 385     return S_OK;
 386 }
 387
 388 static HRESULT set_receive_context( WS_MESSAGE *msg, const WS_CALL_PROPERTY *props, ULONG count )
 389 {
 390     ULONG i;
 391     for (i = 0; i < count; i++)
 392     {
 393         if (props[i].id == WS_CALL_PROPERTY_RECEIVE_MESSAGE_CONTEXT)
 394         {
 395             if (props[i].valueSize != sizeof(WS_PROXY_MESSAGE_CALLBACK_CONTEXT)) return E_INVALIDARG;
 396             message_set_receive_context( msg, props[i].value );
 397             break;
 398         }
 399     }
 400     return S_OK;
 401 }
 402
 403 static HRESULT write_message( WS_MESSAGE *msg, WS_XML_WRITER *writer, const WS_ELEMENT_DESCRIPTION *desc,
 404                               const WS_PARAMETER_DESCRIPTION *params, ULONG count, const void **args )
 405 {
 406     HRESULT hr;
 407     message_do_send_callback( msg );
 408     if ((hr = WsWriteEnvelopeStart( msg, writer, NULL, NULL, NULL )) != S_OK) return hr;
 409     if ((hr = write_input_params( writer, desc, params, count, args )) != S_OK) return hr;
 410     return WsWriteEnvelopeEnd( msg, NULL );
 411 }
 412
 413 static HRESULT set_output( WS_XML_WRITER *writer )
 414 {
 415     WS_XML_WRITER_TEXT_ENCODING text = { {WS_XML_WRITER_ENCODING_TYPE_TEXT}, WS_CHARSET_UTF8 };
 416     WS_XML_WRITER_BUFFER_OUTPUT buf = { {WS_XML_WRITER_OUTPUT_TYPE_BUFFER} };
 417     return WsSetOutput( writer, &text.encoding, &buf.output, NULL, 0, NULL );
 418 }
 419
 420 static HRESULT send_message( WS_CHANNEL *channel, WS_MESSAGE *msg, WS_MESSAGE_DESCRIPTION *desc,
 421                              WS_PARAMETER_DESCRIPTION *params, ULONG count, const void **args )
 422 {
 423     WS_XML_WRITER *writer;
 424     HRESULT hr;
 425
 426     if ((hr = message_set_action( msg, desc->action )) != S_OK) return hr;
 427     if ((hr = WsCreateWriter( NULL, 0, &writer, NULL )) != S_OK) return hr;
 428     if ((hr = set_output( writer )) != S_OK) goto done;
 429     if ((hr = write_message( msg, writer, desc->bodyElementDescription, params, count, args )) != S_OK) goto done;
 430     hr = channel_send_message( channel, msg );
 431
 432 done:
 433     WsFreeWriter( writer );
 434     return hr;
 435 }
 436
 437 static HRESULT read_message( WS_MESSAGE *msg, WS_XML_READER *reader, WS_HEAP *heap,
 438                              const WS_ELEMENT_DESCRIPTION *desc, const WS_PARAMETER_DESCRIPTION *params,
 439                              ULONG count, const void **args )
 440 {
 441     HRESULT hr;
 442     if ((hr = WsReadEnvelopeStart( msg, reader, NULL, NULL, NULL )) != S_OK) return hr;
 443     message_do_receive_callback( msg );
 444     if ((hr = read_output_params( reader, heap, desc, params, count, args )) != S_OK) return hr;
 445     return WsReadEnvelopeEnd( msg, NULL );
 446 }
 447
 448 static HRESULT receive_message( WS_CHANNEL *channel, WS_MESSAGE *msg, WS_MESSAGE_DESCRIPTION *desc,
 449                                 WS_PARAMETER_DESCRIPTION *params, ULONG count, WS_HEAP *heap, const void **args )
 450 {
 451     WS_XML_READER *reader;
 452     HRESULT hr;
 453
 454     if ((hr = message_set_action( msg, desc->action )) != S_OK) return hr;
 455     if ((hr = channel_receive_message( channel )) != S_OK) return hr;
 456     if ((hr = channel_get_reader( channel, &reader )) != S_OK) return hr;
 457     return read_message( msg, reader, heap, desc->bodyElementDescription, params, count, args );
 458 }
 459
 460 static HRESULT create_input_message( WS_CHANNEL *channel, const WS_CALL_PROPERTY *properties,
 461                                      ULONG count, WS_MESSAGE **ret )
 462 {
 463     WS_MESSAGE *msg;
 464     HRESULT hr;
 465
 466     if ((hr = WsCreateMessageForChannel( channel, NULL, 0, &msg, NULL )) != S_OK) return hr;
 467     if ((hr = WsInitializeMessage( msg, WS_REQUEST_MESSAGE, NULL, NULL )) != S_OK ||
 468         (hr = set_send_context( msg, properties, count )) != S_OK)
 469     {
 470         WsFreeMessage( msg );
 471         return hr;
 472     }
 473     *ret = msg;
 474     return S_OK;
 475 }
 476
 477 static HRESULT create_output_message( WS_CHANNEL *channel, const WS_CALL_PROPERTY *properties,
 478                                       ULONG count, WS_MESSAGE **ret )
 479 {
 480     WS_MESSAGE *msg;
 481     HRESULT hr;
 482
 483     if ((hr = WsCreateMessageForChannel( channel, NULL, 0, &msg, NULL )) != S_OK) return hr;
 484     if ((hr = set_receive_context( msg, properties, count )) != S_OK)
 485     {
 486         WsFreeMessage( msg );
 487         return hr;
 488     }
 489     *ret = msg;
 490     return S_OK;
 491 }
 492
 493 /**************************************************************************
 494  *          WsCall              [webservices.@]
 495  */
 496 HRESULT WINAPI WsCall( WS_SERVICE_PROXY *handle, const WS_OPERATION_DESCRIPTION *desc, const void **args,
 497                        WS_HEAP *heap, const WS_CALL_PROPERTY *properties, const ULONG count,
 498                        const WS_ASYNC_CONTEXT *ctx, WS_ERROR *error )
 499 {
 500     struct proxy *proxy = (struct proxy *)handle;
 501     WS_MESSAGE *msg = NULL;
 502     HRESULT hr;
 503     ULONG i;
 504
 505     TRACE( "%p %p %p %p %p %u %p %p\n", handle, desc, args, heap, properties, count, ctx, error );
 506     if (error) FIXME( "ignoring error parameter\n" );
 507     if (ctx) FIXME( "ignoring ctx parameter\n" );
 508     for (i = 0; i < count; i++)
 509     {
 510         if (properties[i].id != WS_CALL_PROPERTY_SEND_MESSAGE_CONTEXT &&
 511             properties[i].id != WS_CALL_PROPERTY_RECEIVE_MESSAGE_CONTEXT)
 512         {
 513             FIXME( "unimplemented call property %u\n", properties[i].id );
 514             return E_NOTIMPL;
 515         }
 516     }
 517
 518     if (!proxy || !desc || (desc->parameterCount && !args)) return E_INVALIDARG;
 519
 520     EnterCriticalSection( &proxy->cs );
 521
 522     if (proxy->magic != PROXY_MAGIC)
 523     {
 524         LeaveCriticalSection( &proxy->cs );
 525         return E_INVALIDARG;
 526     }
 527
 528     if ((hr = create_input_message( proxy->channel, properties, count, &msg )) != S_OK) goto done;
 529     if ((hr = send_message( proxy->channel, msg, desc->inputMessageDescription, desc->parameterDescription,
 530                             desc->parameterCount, args )) != S_OK) goto done;
 531
 532     WsFreeMessage( msg );
 533     msg = NULL;
 534
 535     if ((hr = create_output_message( proxy->channel, properties, count, &msg )) != S_OK) goto done;
 536     hr = receive_message( proxy->channel, msg, desc->outputMessageDescription, desc->parameterDescription,
 537                           desc->parameterCount, heap, args );
 538
 539 done:
 540     WsFreeMessage( msg );
 541     LeaveCriticalSection( &proxy->cs );
 542     return hr;
 543 }