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 #include <stdlib.h>
  21
  22 #include "windef.h"
  23 #include "winbase.h"
  24 #include "winuser.h"
  25 #include "webservices.h"
  26
  27 #include "wine/debug.h"
  28 #include "wine/list.h"
  29 #include "webservices_private.h"
  30
  31 WINE_DEFAULT_DEBUG_CHANNEL(webservices);
  32
  33 static const struct prop_desc proxy_props[] =
  34 {
  35     { sizeof(ULONG), FALSE, TRUE },             /* WS_PROXY_PROPERTY_CALL_TIMEOUT */
  36     { sizeof(WS_MESSAGE_PROPERTIES), FALSE },   /* WS_PROXY_PROPERTY_MESSAGE_PROPERTIES */
  37     { sizeof(USHORT), FALSE, TRUE },            /* WS_PROXY_PROPERTY_MAX_CALL_POOL_SIZE */
  38     { sizeof(WS_SERVICE_PROXY_STATE), TRUE },   /* WS_PROXY_PROPERTY_STATE */
  39     { sizeof(ULONG), FALSE, TRUE },             /* WS_PROXY_PROPERTY_MAX_PENDING_CALLS */
  40     { sizeof(ULONG), FALSE, TRUE },             /* WS_PROXY_PROPERTY_MAX_CLOSE_TIMEOUT */
  41     { sizeof(LANGID), FALSE, TRUE },            /* WS_PROXY_FAULT_LANG_ID */
  42 };
  43
  44 struct proxy
  45 {
  46     ULONG                   magic;
  47     CRITICAL_SECTION        cs;
  48     WS_SERVICE_PROXY_STATE  state;
  49     WS_CHANNEL             *channel;
  50     ULONG                   prop_count;
  51     struct prop             prop[ARRAY_SIZE( proxy_props )];
  52 };
  53
  54 #define PROXY_MAGIC (('P' << 24) | ('R' << 16) | ('O' << 8) | 'X')
  55
  56 static struct proxy *alloc_proxy(void)
  57 {
  58     static const ULONG count = ARRAY_SIZE( proxy_props );
  59     struct proxy *ret;
  60     ULONG size = sizeof(*ret) + prop_size( proxy_props, count );
  61
  62     if (!(ret = calloc( 1, size ))) return NULL;
  63
  64     ret->magic      = PROXY_MAGIC;
  65     InitializeCriticalSection( &ret->cs );
  66     ret->cs.DebugInfo->Spare[0] = (DWORD_PTR)(__FILE__ ": proxy.cs");
  67
  68     prop_init( proxy_props, count, ret->prop, &ret[1] );
  69     ret->prop_count = count;
  70     return ret;
  71 }
  72
  73 static void reset_proxy( struct proxy *proxy )
  74 {
  75     WsResetChannel( proxy->channel, NULL );
  76     proxy->state = WS_SERVICE_PROXY_STATE_CREATED;
  77 }
  78
  79 static void free_proxy( struct proxy *proxy )
  80 {
  81     reset_proxy( proxy );
  82     WsFreeChannel( proxy->channel );
  83
  84     proxy->cs.DebugInfo->Spare[0] = 0;
  85     DeleteCriticalSection( &proxy->cs );
  86     free( proxy );
  87 }
  88
  89 static HRESULT create_proxy( WS_CHANNEL *channel, const WS_PROXY_PROPERTY *properties, ULONG count,
  90                              WS_SERVICE_PROXY **handle )
  91 {
  92     struct proxy *proxy;
  93     HRESULT hr;
  94     ULONG i;
  95
  96     if (!(proxy = alloc_proxy())) return E_OUTOFMEMORY;
  97
  98     for (i = 0; i < count; i++)
  99     {
 100         hr = prop_set( proxy->prop, proxy->prop_count, properties[i].id, properties[i].value,
 101                        properties[i].valueSize );
 102         if (hr != S_OK)
 103         {
 104             free_proxy( proxy );
 105             return hr;
 106         }
 107     }
 108
 109     proxy->channel = channel;
 110
 111     *handle = (WS_SERVICE_PROXY *)proxy;
 112     return S_OK;
 113 }
 114
 115 /**************************************************************************
 116  *          WsCreateServiceProxy                [webservices.@]
 117  */
 118 HRESULT WINAPI WsCreateServiceProxy( const WS_CHANNEL_TYPE type, const WS_CHANNEL_BINDING binding,
 119                                      const WS_SECURITY_DESCRIPTION *desc,
 120                                      const WS_PROXY_PROPERTY *proxy_props, ULONG proxy_props_count,
 121                                      const WS_CHANNEL_PROPERTY *channel_props,
 122                                      const ULONG channel_props_count, WS_SERVICE_PROXY **handle,
 123                                      WS_ERROR *error )
 124 {
 125     WS_CHANNEL *channel;
 126     HRESULT hr;
 127
 128     TRACE( "%u %u %p %p %lu %p %lu %p %p\n", type, binding, desc, proxy_props, proxy_props_count,
 129            channel_props, channel_props_count, handle, error );
 130     if (error) FIXME( "ignoring error parameter\n" );
 131     if (desc) FIXME( "ignoring security description\n" );
 132
 133     if (!handle) return E_INVALIDARG;
 134
 135     if ((hr = WsCreateChannel( type, binding, channel_props, channel_props_count, NULL, &channel,
 136                                NULL )) != S_OK) return hr;
 137
 138     if ((hr = create_proxy( channel, proxy_props, proxy_props_count, handle )) != S_OK)
 139     {
 140         WsFreeChannel( channel );
 141         return hr;
 142     }
 143
 144     TRACE( "created %p\n", *handle );
 145     return S_OK;
 146 }
 147
 148 /**************************************************************************
 149  *          WsCreateServiceProxyFromTemplate            [webservices.@]
 150  */
 151 HRESULT WINAPI WsCreateServiceProxyFromTemplate( WS_CHANNEL_TYPE channel_type,
 152                                                  const WS_PROXY_PROPERTY *properties, const ULONG count,
 153                                                  WS_BINDING_TEMPLATE_TYPE type, void *value, ULONG size,
 154                                                  const void *desc, ULONG desc_size, WS_SERVICE_PROXY **handle,
 155                                                  WS_ERROR *error )
 156 {
 157     const WS_CHANNEL_PROPERTY *channel_props = NULL;
 158     ULONG channel_props_count = 0;
 159     WS_CHANNEL_BINDING binding;
 160     WS_CHANNEL *channel;
 161     HRESULT hr;
 162
 163     TRACE( "%u %p %lu %u %p %lu %p %lu %p %p\n", channel_type, properties, count, type, value, size, desc,
 164            desc_size, handle, error );
 165     if (error) FIXME( "ignoring error parameter\n" );
 166
 167     if (!desc || !handle) return E_INVALIDARG;
 168     FIXME( "ignoring description\n" );
 169
 170     switch (type)
 171     {
 172     case WS_HTTP_BINDING_TEMPLATE_TYPE:
 173     {
 174         WS_HTTP_BINDING_TEMPLATE *http = value;
 175         if (http)
 176         {
 177             channel_props = http->channelProperties.properties;
 178             channel_props_count = http->channelProperties.propertyCount;
 179         }
 180         binding = WS_HTTP_CHANNEL_BINDING;
 181         break;
 182     }
 183     case WS_HTTP_SSL_BINDING_TEMPLATE_TYPE:
 184     {
 185         WS_HTTP_SSL_BINDING_TEMPLATE *https = value;
 186         if (https)
 187         {
 188             channel_props = https->channelProperties.properties;
 189             channel_props_count = https->channelProperties.propertyCount;
 190         }
 191         binding = WS_HTTP_CHANNEL_BINDING;
 192         break;
 193     }
 194     default:
 195         FIXME( "template type %u not implemented\n", type );
 196         return E_NOTIMPL;
 197     }
 198
 199     if ((hr = WsCreateChannel( channel_type, binding, channel_props, channel_props_count, NULL,
 200                                &channel, NULL )) != S_OK) return hr;
 201
 202     if ((hr = create_proxy( channel, properties, count, handle )) != S_OK)
 203     {
 204         WsFreeChannel( channel );
 205         return hr;
 206     }
 207
 208     TRACE( "created %p\n", *handle );
 209     return S_OK;
 210 }
 211
 212 /**************************************************************************
 213  *          WsResetServiceProxy         [webservices.@]
 214  */
 215 HRESULT WINAPI WsResetServiceProxy( WS_SERVICE_PROXY *handle, WS_ERROR *error )
 216 {
 217     struct proxy *proxy = (struct proxy *)handle;
 218     HRESULT hr = S_OK;
 219
 220     TRACE( "%p %p\n", handle, error );
 221     if (error) FIXME( "ignoring error parameter\n" );
 222
 223     if (!proxy) return E_INVALIDARG;
 224
 225     EnterCriticalSection( &proxy->cs );
 226
 227     if (proxy->magic != PROXY_MAGIC)
 228     {
 229         LeaveCriticalSection( &proxy->cs );
 230         return E_INVALIDARG;
 231     }
 232
 233     if (proxy->state != WS_SERVICE_PROXY_STATE_CREATED && proxy->state != WS_SERVICE_PROXY_STATE_CLOSED)
 234         hr = WS_E_INVALID_OPERATION;
 235     else
 236         reset_proxy( proxy );
 237
 238     LeaveCriticalSection( &proxy->cs );
 239     TRACE( "returning %#lx\n", hr );
 240     return hr;
 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 %lu %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     TRACE( "returning %#lx\n", hr );
 303     return hr;
 304 }
 305
 306 /**************************************************************************
 307  *          WsOpenServiceProxy          [webservices.@]
 308  */
 309 HRESULT WINAPI WsOpenServiceProxy( WS_SERVICE_PROXY *handle, const WS_ENDPOINT_ADDRESS *endpoint,
 310                                    const WS_ASYNC_CONTEXT *ctx, WS_ERROR *error )
 311 {
 312     struct proxy *proxy = (struct proxy *)handle;
 313     HRESULT hr;
 314
 315     TRACE( "%p %p %p %p\n", handle, endpoint, ctx, error );
 316     if (error) FIXME( "ignoring error parameter\n" );
 317     if (ctx) FIXME( "ignoring ctx parameter\n" );
 318
 319     if (!proxy || !endpoint) return E_INVALIDARG;
 320
 321     EnterCriticalSection( &proxy->cs );
 322
 323     if (proxy->magic != PROXY_MAGIC)
 324     {
 325         LeaveCriticalSection( &proxy->cs );
 326         return E_INVALIDARG;
 327     }
 328
 329     if ((hr = WsOpenChannel( proxy->channel, endpoint, NULL, NULL )) == S_OK)
 330         proxy->state = WS_SERVICE_PROXY_STATE_OPEN;
 331
 332     LeaveCriticalSection( &proxy->cs );
 333     TRACE( "returning %#lx\n", hr );
 334     return hr;
 335 }
 336
 337 /**************************************************************************
 338  *          WsCloseServiceProxy         [webservices.@]
 339  */
 340 HRESULT WINAPI WsCloseServiceProxy( WS_SERVICE_PROXY *handle, const WS_ASYNC_CONTEXT *ctx, WS_ERROR *error )
 341 {
 342     struct proxy *proxy = (struct proxy *)handle;
 343     HRESULT hr;
 344
 345     TRACE( "%p %p %p\n", handle, ctx, error );
 346     if (error) FIXME( "ignoring error parameter\n" );
 347     if (ctx) FIXME( "ignoring ctx parameter\n" );
 348
 349     if (!proxy) return E_INVALIDARG;
 350
 351     EnterCriticalSection( &proxy->cs );
 352
 353     if (proxy->magic != PROXY_MAGIC)
 354     {
 355         LeaveCriticalSection( &proxy->cs );
 356         return E_INVALIDARG;
 357     }
 358
 359     if ((hr = WsCloseChannel( proxy->channel, NULL, NULL )) == S_OK)
 360         proxy->state = WS_SERVICE_PROXY_STATE_CLOSED;
 361
 362     LeaveCriticalSection( &proxy->cs );
 363     TRACE( "returning %#lx\n", hr );
 364     return hr;
 365 }
 366
 367 /**************************************************************************
 368  *          WsAbortServiceProxy         [webservices.@]
 369  */
 370 HRESULT WINAPI WsAbortServiceProxy( WS_SERVICE_PROXY *handle, WS_ERROR *error )
 371 {
 372     FIXME( "%p %p\n", handle, error );
 373     return E_NOTIMPL;
 374 }
 375
 376 static HRESULT set_send_context( WS_MESSAGE *msg, const WS_CALL_PROPERTY *props, ULONG count )
 377 {
 378     ULONG i;
 379     for (i = 0; i < count; i++)
 380     {
 381         if (props[i].id == WS_CALL_PROPERTY_SEND_MESSAGE_CONTEXT)
 382         {
 383             if (props[i].valueSize != sizeof(WS_PROXY_MESSAGE_CALLBACK_CONTEXT)) return E_INVALIDARG;
 384             message_set_send_context( msg, props[i].value );
 385             break;
 386         }
 387     }
 388     return S_OK;
 389 }
 390
 391 static HRESULT set_receive_context( WS_MESSAGE *msg, const WS_CALL_PROPERTY *props, ULONG count )
 392 {
 393     ULONG i;
 394     for (i = 0; i < count; i++)
 395     {
 396         if (props[i].id == WS_CALL_PROPERTY_RECEIVE_MESSAGE_CONTEXT)
 397         {
 398             if (props[i].valueSize != sizeof(WS_PROXY_MESSAGE_CALLBACK_CONTEXT)) return E_INVALIDARG;
 399             message_set_receive_context( msg, props[i].value );
 400             break;
 401         }
 402     }
 403     return S_OK;
 404 }
 405
 406 static HRESULT write_message( WS_MESSAGE *msg, WS_XML_WRITER *writer, const WS_ELEMENT_DESCRIPTION *desc,
 407                               const WS_PARAMETER_DESCRIPTION *params, ULONG count, const void **args )
 408 {
 409     HRESULT hr;
 410     message_do_send_callback( msg );
 411     if ((hr = WsWriteEnvelopeStart( msg, writer, NULL, NULL, NULL )) != S_OK) return hr;
 412     if ((hr = write_input_params( writer, desc, params, count, args )) != S_OK) return hr;
 413     return WsWriteEnvelopeEnd( msg, NULL );
 414 }
 415
 416 static HRESULT set_output( WS_XML_WRITER *writer )
 417 {
 418     WS_XML_WRITER_TEXT_ENCODING text = { {WS_XML_WRITER_ENCODING_TYPE_TEXT}, WS_CHARSET_UTF8 };
 419     WS_XML_WRITER_BUFFER_OUTPUT buf = { {WS_XML_WRITER_OUTPUT_TYPE_BUFFER} };
 420     return WsSetOutput( writer, &text.encoding, &buf.output, NULL, 0, NULL );
 421 }
 422
 423 static HRESULT send_message( WS_CHANNEL *channel, WS_MESSAGE *msg, WS_MESSAGE_DESCRIPTION *desc,
 424                              WS_PARAMETER_DESCRIPTION *params, ULONG count, const void **args )
 425 {
 426     WS_XML_WRITER *writer;
 427     HRESULT hr;
 428
 429     if ((hr = channel_address_message( channel, msg )) != S_OK) return hr;
 430     if ((hr = message_set_action( msg, desc->action )) != S_OK) return hr;
 431     if ((hr = WsCreateWriter( NULL, 0, &writer, NULL )) != S_OK) return hr;
 432     if ((hr = set_output( writer )) != S_OK) goto done;
 433     if ((hr = write_message( msg, writer, desc->bodyElementDescription, params, count, args )) != S_OK) goto done;
 434     hr = channel_send_message( channel, msg );
 435
 436 done:
 437     WsFreeWriter( writer );
 438     return hr;
 439 }
 440
 441 static HRESULT read_message( WS_MESSAGE *msg, WS_XML_READER *reader, WS_HEAP *heap,
 442                              const WS_ELEMENT_DESCRIPTION *desc, const WS_PARAMETER_DESCRIPTION *params,
 443                              ULONG count, const void **args, WS_ERROR *error )
 444 {
 445     HRESULT hr;
 446     if ((hr = WsReadEnvelopeStart( msg, reader, NULL, NULL, NULL )) != S_OK) return hr;
 447     message_do_receive_callback( msg );
 448     if ((hr = message_read_fault( msg, heap, error )) != S_OK) return hr;
 449     if ((hr = read_output_params( reader, heap, desc, params, count, args )) != S_OK) return hr;
 450     return WsReadEnvelopeEnd( msg, NULL );
 451 }
 452
 453 static HRESULT receive_message( WS_CHANNEL *channel, WS_MESSAGE *msg, WS_MESSAGE_DESCRIPTION *desc,
 454                                 WS_PARAMETER_DESCRIPTION *params, ULONG count,
 455                                 WS_HEAP *heap, const void **args, WS_ERROR *error )
 456 {
 457     WS_XML_READER *reader;
 458     HRESULT hr;
 459
 460     if ((hr = message_set_action( msg, desc->action )) != S_OK) return hr;
 461     if ((hr = channel_receive_message( channel, msg )) != S_OK) return hr;
 462     if ((hr = channel_get_reader( channel, &reader )) != S_OK) return hr;
 463     return read_message( msg, reader, heap, desc->bodyElementDescription, params, count, args, error );
 464 }
 465
 466 static HRESULT create_input_message( WS_CHANNEL *channel, const WS_CALL_PROPERTY *properties,
 467                                      ULONG count, WS_MESSAGE **ret )
 468 {
 469     WS_MESSAGE *msg;
 470     HRESULT hr;
 471
 472     if ((hr = WsCreateMessageForChannel( channel, NULL, 0, &msg, NULL )) != S_OK) return hr;
 473     if ((hr = WsInitializeMessage( msg, WS_REQUEST_MESSAGE, NULL, NULL )) != S_OK ||
 474         (hr = set_send_context( msg, properties, count )) != S_OK)
 475     {
 476         WsFreeMessage( msg );
 477         return hr;
 478     }
 479     *ret = msg;
 480     return S_OK;
 481 }
 482
 483 static HRESULT create_output_message( WS_CHANNEL *channel, const WS_CALL_PROPERTY *properties,
 484                                       ULONG count, WS_MESSAGE **ret )
 485 {
 486     WS_MESSAGE *msg;
 487     HRESULT hr;
 488
 489     if ((hr = WsCreateMessageForChannel( channel, NULL, 0, &msg, NULL )) != S_OK) return hr;
 490     if ((hr = set_receive_context( msg, properties, count )) != S_OK)
 491     {
 492         WsFreeMessage( msg );
 493         return hr;
 494     }
 495     *ret = msg;
 496     return S_OK;
 497 }
 498
 499 /**************************************************************************
 500  *          WsCall              [webservices.@]
 501  */
 502 HRESULT WINAPI WsCall( WS_SERVICE_PROXY *handle, const WS_OPERATION_DESCRIPTION *desc, const void **args,
 503                        WS_HEAP *heap, const WS_CALL_PROPERTY *properties, const ULONG count,
 504                        const WS_ASYNC_CONTEXT *ctx, WS_ERROR *error )
 505 {
 506     struct proxy *proxy = (struct proxy *)handle;
 507     WS_MESSAGE *msg = NULL;
 508     HRESULT hr;
 509     ULONG i;
 510
 511     TRACE( "%p %p %p %p %p %lu %p %p\n", handle, desc, args, heap, properties, count, ctx, error );
 512     if (ctx) FIXME( "ignoring ctx parameter\n" );
 513     for (i = 0; i < count; i++)
 514     {
 515         if (properties[i].id != WS_CALL_PROPERTY_SEND_MESSAGE_CONTEXT &&
 516             properties[i].id != WS_CALL_PROPERTY_RECEIVE_MESSAGE_CONTEXT)
 517         {
 518             FIXME( "unimplemented call property %u\n", properties[i].id );
 519             return E_NOTIMPL;
 520         }
 521     }
 522
 523     if (!proxy || !desc || (desc->parameterCount && !args)) return E_INVALIDARG;
 524
 525     EnterCriticalSection( &proxy->cs );
 526
 527     if (proxy->magic != PROXY_MAGIC)
 528     {
 529         LeaveCriticalSection( &proxy->cs );
 530         return E_INVALIDARG;
 531     }
 532
 533     if ((hr = create_input_message( proxy->channel, properties, count, &msg )) != S_OK) goto done;
 534     if ((hr = send_message( proxy->channel, msg, desc->inputMessageDescription, desc->parameterDescription,
 535                             desc->parameterCount, args )) != S_OK) goto done;
 536     WsFreeMessage( msg );
 537     msg = NULL;
 538
 539     if ((hr = create_output_message( proxy->channel, properties, count, &msg )) != S_OK) goto done;
 540     hr = receive_message( proxy->channel, msg, desc->outputMessageDescription, desc->parameterDescription,
 541                           desc->parameterCount, heap, args, error );
 542
 543 done:
 544     WsFreeMessage( msg );
 545     LeaveCriticalSection( &proxy->cs );
 546     TRACE( "returning %#lx\n", hr );
 547     return hr;
 548 }