2 * Copyright 2006-2007 Jacek Caban for CodeWeavers
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.
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.
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
24 #define NONAMELESSUNION
25 #define NONAMELESSSTRUCT
33 #include "wine/debug.h"
34 #include "wine/unicode.h"
36 #include "mshtml_private.h"
38 WINE_DEFAULT_DEBUG_CHANNEL(mshtml
);
40 #define CONTENT_LENGTH "Content-Length"
41 #define UTF16_STR "utf-16"
43 #define NSINSTREAM(x) ((nsIInputStream*) &(x)->lpInputStreamVtbl)
45 #define NSINSTREAM_THIS(iface) DEFINE_THIS(nsProtocolStream, InputStream, iface)
47 static nsresult NSAPI
nsInputStream_QueryInterface(nsIInputStream
*iface
, nsIIDRef riid
,
50 nsProtocolStream
*This
= NSINSTREAM_THIS(iface
);
54 if(IsEqualGUID(&IID_nsISupports
, riid
)) {
55 TRACE("(%p)->(IID_nsISupports %p)\n", This
, result
);
56 *result
= NSINSTREAM(This
);
57 }else if(IsEqualGUID(&IID_nsIInputStream
, riid
)) {
58 TRACE("(%p)->(IID_nsIInputStream %p)\n", This
, result
);
59 *result
= NSINSTREAM(This
);
63 nsIInputStream_AddRef(NSINSTREAM(This
));
67 WARN("unsupported interface %s\n", debugstr_guid(riid
));
68 return NS_NOINTERFACE
;
71 static nsrefcnt NSAPI
nsInputStream_AddRef(nsIInputStream
*iface
)
73 nsProtocolStream
*This
= NSINSTREAM_THIS(iface
);
74 LONG ref
= InterlockedIncrement(&This
->ref
);
76 TRACE("(%p) ref=%d\n", This
, ref
);
82 static nsrefcnt NSAPI
nsInputStream_Release(nsIInputStream
*iface
)
84 nsProtocolStream
*This
= NSINSTREAM_THIS(iface
);
85 LONG ref
= InterlockedDecrement(&This
->ref
);
87 TRACE("(%p) ref=%d\n", This
, ref
);
95 static nsresult NSAPI
nsInputStream_Close(nsIInputStream
*iface
)
97 nsProtocolStream
*This
= NSINSTREAM_THIS(iface
);
98 FIXME("(%p)\n", This
);
99 return NS_ERROR_NOT_IMPLEMENTED
;
102 static nsresult NSAPI
nsInputStream_Available(nsIInputStream
*iface
, PRUint32
*_retval
)
104 nsProtocolStream
*This
= NSINSTREAM_THIS(iface
);
105 FIXME("(%p)->(%p)\n", This
, _retval
);
106 return NS_ERROR_NOT_IMPLEMENTED
;
109 static nsresult NSAPI
nsInputStream_Read(nsIInputStream
*iface
, char *aBuf
, PRUint32 aCount
,
112 nsProtocolStream
*This
= NSINSTREAM_THIS(iface
);
114 TRACE("(%p)->(%p %d %p)\n", This
, aBuf
, aCount
, _retval
);
116 /* Gecko always calls Read with big enough buffer */
117 if(aCount
< This
->buf_size
)
118 FIXME("aCount < This->buf_size\n");
120 *_retval
= This
->buf_size
;
122 memcpy(aBuf
, This
->buf
, This
->buf_size
);
128 static nsresult NSAPI
nsInputStream_ReadSegments(nsIInputStream
*iface
,
129 nsresult (WINAPI
*aWriter
)(nsIInputStream
*,void*,const char*,PRUint32
,PRUint32
,PRUint32
*),
130 void *aClousure
, PRUint32 aCount
, PRUint32
*_retval
)
132 nsProtocolStream
*This
= NSINSTREAM_THIS(iface
);
133 PRUint32 written
= 0;
136 TRACE("(%p)->(%p %p %d %p)\n", This
, aWriter
, aClousure
, aCount
, _retval
);
141 if(This
->buf_size
> aCount
)
142 FIXME("buf_size > aCount\n");
144 nsres
= aWriter(NSINSTREAM(This
), aClousure
, This
->buf
, 0, This
->buf_size
, &written
);
146 TRACE("aWritter failed: %08x\n", nsres
);
147 else if(written
!= This
->buf_size
)
148 FIXME("written %d != buf_size %d\n", written
, This
->buf_size
);
150 This
->buf_size
-= written
;
156 static nsresult NSAPI
nsInputStream_IsNonBlocking(nsIInputStream
*iface
, PRBool
*_retval
)
158 nsProtocolStream
*This
= NSINSTREAM_THIS(iface
);
159 FIXME("(%p)->(%p)\n", This
, _retval
);
160 return NS_ERROR_NOT_IMPLEMENTED
;
163 #undef NSINSTREAM_THIS
165 static const nsIInputStreamVtbl nsInputStreamVtbl
= {
166 nsInputStream_QueryInterface
,
167 nsInputStream_AddRef
,
168 nsInputStream_Release
,
170 nsInputStream_Available
,
172 nsInputStream_ReadSegments
,
173 nsInputStream_IsNonBlocking
176 static nsProtocolStream
*create_nsprotocol_stream(void)
178 nsProtocolStream
*ret
= mshtml_alloc(sizeof(nsProtocolStream
));
180 ret
->lpInputStreamVtbl
= &nsInputStreamVtbl
;
187 static HRESULT
read_stream_data(BSCallback
*This
, IStream
*stream
)
192 if(!This
->nslistener
) {
198 hres
= IStream_Read(stream
, buf
, sizeof(buf
), &read
);
199 }while(hres
== S_OK
&& read
);
205 This
->nsstream
= create_nsprotocol_stream();
208 hres
= IStream_Read(stream
, This
->nsstream
->buf
, sizeof(This
->nsstream
->buf
),
209 &This
->nsstream
->buf_size
);
210 if(!This
->nsstream
->buf_size
)
213 if(!This
->readed
&& This
->nsstream
->buf_size
>= 2 && *(WORD
*)This
->nsstream
->buf
== 0xfeff) {
214 This
->nschannel
->charset
= mshtml_alloc(sizeof(UTF16_STR
));
215 memcpy(This
->nschannel
->charset
, UTF16_STR
, sizeof(UTF16_STR
));
219 nsres
= nsIStreamListener_OnStartRequest(This
->nslistener
,
220 (nsIRequest
*)NSCHANNEL(This
->nschannel
), This
->nscontext
);
222 FIXME("OnStartRequest failed: %08x\n", nsres
);
225 This
->readed
+= This
->nsstream
->buf_size
;
227 nsres
= nsIStreamListener_OnDataAvailable(This
->nslistener
,
228 (nsIRequest
*)NSCHANNEL(This
->nschannel
), This
->nscontext
,
229 NSINSTREAM(This
->nsstream
), This
->readed
-This
->nsstream
->buf_size
,
230 This
->nsstream
->buf_size
);
232 ERR("OnDataAvailable failed: %08x\n", nsres
);
234 if(This
->nsstream
->buf_size
)
235 FIXME("buffer is not empty!\n");
236 }while(hres
== S_OK
);
241 static void add_nsrequest(BSCallback
*This
)
243 if(This
->nschannel
&& This
->nschannel
->load_group
) {
244 nsresult nsres
= nsILoadGroup_AddRequest(This
->nschannel
->load_group
,
245 (nsIRequest
*)NSCHANNEL(This
->nschannel
), This
->nscontext
);
248 ERR("AddRequest failed:%08x\n", nsres
);
252 static void on_stop_nsrequest(BSCallback
*This
) {
254 nsIStreamListener_OnStopRequest(This
->nslistener
, (nsIRequest
*)NSCHANNEL(This
->nschannel
),
255 This
->nscontext
, NS_OK
);
258 #define STATUSCLB_THIS(iface) DEFINE_THIS(BSCallback, BindStatusCallback, iface)
260 static HRESULT WINAPI
BindStatusCallback_QueryInterface(IBindStatusCallback
*iface
,
261 REFIID riid
, void **ppv
)
263 BSCallback
*This
= STATUSCLB_THIS(iface
);
266 if(IsEqualGUID(&IID_IUnknown
, riid
)) {
267 TRACE("(%p)->(IID_IUnknown, %p)\n", This
, ppv
);
268 *ppv
= STATUSCLB(This
);
269 }else if(IsEqualGUID(&IID_IBindStatusCallback
, riid
)) {
270 TRACE("(%p)->(IID_IBindStatusCallback, %p)\n", This
, ppv
);
271 *ppv
= STATUSCLB(This
);
272 }else if(IsEqualGUID(&IID_IServiceProvider
, riid
)) {
273 TRACE("(%p)->(IID_IServiceProvider %p)\n", This
, ppv
);
274 *ppv
= SERVPROV(This
);
275 }else if(IsEqualGUID(&IID_IHttpNegotiate
, riid
)) {
276 TRACE("(%p)->(IID_IHttpNegotiate %p)\n", This
, ppv
);
277 *ppv
= HTTPNEG(This
);
278 }else if(IsEqualGUID(&IID_IHttpNegotiate2
, riid
)) {
279 TRACE("(%p)->(IID_IHttpNegotiate2 %p)\n", This
, ppv
);
280 *ppv
= HTTPNEG(This
);
281 }else if(IsEqualGUID(&IID_IInternetBindInfo
, riid
)) {
282 TRACE("(%p)->(IID_IInternetBindInfo %p)\n", This
, ppv
);
283 *ppv
= BINDINFO(This
);
287 IBindStatusCallback_AddRef(STATUSCLB(This
));
291 TRACE("Unsupported riid = %s\n", debugstr_guid(riid
));
292 return E_NOINTERFACE
;
295 static ULONG WINAPI
BindStatusCallback_AddRef(IBindStatusCallback
*iface
)
297 BSCallback
*This
= STATUSCLB_THIS(iface
);
298 LONG ref
= InterlockedIncrement(&This
->ref
);
300 TRACE("(%p) ref = %d\n", This
, ref
);
305 static ULONG WINAPI
BindStatusCallback_Release(IBindStatusCallback
*iface
)
307 BSCallback
*This
= STATUSCLB_THIS(iface
);
308 LONG ref
= InterlockedDecrement(&This
->ref
);
310 TRACE("(%p) ref = %d\n", This
, ref
);
314 GlobalFree(This
->post_data
);
316 nsIChannel_Release(NSCHANNEL(This
->nschannel
));
318 nsIStreamListener_Release(This
->nslistener
);
320 nsISupports_Release(This
->nscontext
);
322 nsIInputStream_Release(NSINSTREAM(This
->nsstream
));
324 IMoniker_Release(This
->mon
);
326 IBinding_Release(This
->binding
);
327 mshtml_free(This
->headers
);
334 static HRESULT WINAPI
BindStatusCallback_OnStartBinding(IBindStatusCallback
*iface
,
335 DWORD dwReserved
, IBinding
*pbind
)
337 BSCallback
*This
= STATUSCLB_THIS(iface
);
339 TRACE("(%p)->(%d %p)\n", This
, dwReserved
, pbind
);
341 IBinding_AddRef(pbind
);
342 This
->binding
= pbind
;
349 static HRESULT WINAPI
BindStatusCallback_GetPriority(IBindStatusCallback
*iface
, LONG
*pnPriority
)
351 BSCallback
*This
= STATUSCLB_THIS(iface
);
352 FIXME("(%p)->(%p)\n", This
, pnPriority
);
356 static HRESULT WINAPI
BindStatusCallback_OnLowResource(IBindStatusCallback
*iface
, DWORD reserved
)
358 BSCallback
*This
= STATUSCLB_THIS(iface
);
359 FIXME("(%p)->(%d)\n", This
, reserved
);
363 static HRESULT WINAPI
BindStatusCallback_OnProgress(IBindStatusCallback
*iface
, ULONG ulProgress
,
364 ULONG ulProgressMax
, ULONG ulStatusCode
, LPCWSTR szStatusText
)
366 BSCallback
*This
= STATUSCLB_THIS(iface
);
368 TRACE("%p)->(%u %u %u %s)\n", This
, ulProgress
, ulProgressMax
, ulStatusCode
,
369 debugstr_w(szStatusText
));
371 switch(ulStatusCode
) {
372 case BINDSTATUS_MIMETYPEAVAILABLE
: {
377 mshtml_free(This
->nschannel
->content
);
379 len
= WideCharToMultiByte(CP_ACP
, 0, szStatusText
, -1, NULL
, 0, NULL
, NULL
);
380 This
->nschannel
->content
= mshtml_alloc(len
*sizeof(WCHAR
));
381 WideCharToMultiByte(CP_ACP
, 0, szStatusText
, -1, This
->nschannel
->content
, -1, NULL
, NULL
);
388 static HRESULT WINAPI
BindStatusCallback_OnStopBinding(IBindStatusCallback
*iface
,
389 HRESULT hresult
, LPCWSTR szError
)
391 BSCallback
*This
= STATUSCLB_THIS(iface
);
393 TRACE("(%p)->(%08x %s)\n", This
, hresult
, debugstr_w(szError
));
396 IBinding_Release(This
->binding
);
397 This
->binding
= NULL
;
400 on_stop_nsrequest(This
);
402 if(This
->nslistener
) {
403 if(This
->nschannel
->load_group
) {
406 nsres
= nsILoadGroup_RemoveRequest(This
->nschannel
->load_group
,
407 (nsIRequest
*)NSCHANNEL(This
->nschannel
), NULL
, NS_OK
);
409 ERR("RemoveRequest failed: %08x\n", nsres
);
413 if(This
->doc
&& !This
->doc
->nscontainer
) {
414 task_t
*task
= mshtml_alloc(sizeof(task_t
));
416 task
->doc
= This
->doc
;
417 task
->task_id
= TASK_PARSECOMPLETE
;
421 * This should be done in the worker thread that parses HTML,
422 * but we don't have such thread.
430 static HRESULT WINAPI
BindStatusCallback_GetBindInfo(IBindStatusCallback
*iface
,
431 DWORD
*grfBINDF
, BINDINFO
*pbindinfo
)
433 BSCallback
*This
= STATUSCLB_THIS(iface
);
436 TRACE("(%p)->(%p %p)\n", This
, grfBINDF
, pbindinfo
);
438 *grfBINDF
= BINDF_ASYNCHRONOUS
| BINDF_ASYNCSTORAGE
| BINDF_PULLDATA
;
440 size
= pbindinfo
->cbSize
;
441 memset(pbindinfo
, 0, size
);
442 pbindinfo
->cbSize
= size
;
444 pbindinfo
->cbstgmedData
= This
->post_data_len
;
445 pbindinfo
->dwCodePage
= CP_UTF8
;
446 pbindinfo
->dwOptions
= 0x80000;
448 if(This
->post_data
) {
449 pbindinfo
->dwBindVerb
= BINDVERB_POST
;
451 pbindinfo
->stgmedData
.tymed
= TYMED_HGLOBAL
;
452 pbindinfo
->stgmedData
.u
.hGlobal
= This
->post_data
;
453 pbindinfo
->stgmedData
.pUnkForRelease
= (IUnknown
*)STATUSCLB(This
);
454 IBindStatusCallback_AddRef(STATUSCLB(This
));
460 static HRESULT WINAPI
BindStatusCallback_OnDataAvailable(IBindStatusCallback
*iface
,
461 DWORD grfBSCF
, DWORD dwSize
, FORMATETC
*pformatetc
, STGMEDIUM
*pstgmed
)
463 BSCallback
*This
= STATUSCLB_THIS(iface
);
465 TRACE("(%p)->(%08x %d %p %p)\n", This
, grfBSCF
, dwSize
, pformatetc
, pstgmed
);
467 return read_stream_data(This
, pstgmed
->u
.pstm
);
470 static HRESULT WINAPI
BindStatusCallback_OnObjectAvailable(IBindStatusCallback
*iface
,
471 REFIID riid
, IUnknown
*punk
)
473 BSCallback
*This
= STATUSCLB_THIS(iface
);
474 FIXME("(%p)->(%s %p)\n", This
, debugstr_guid(riid
), punk
);
478 #undef STATUSCLB_THIS
480 static const IBindStatusCallbackVtbl BindStatusCallbackVtbl
= {
481 BindStatusCallback_QueryInterface
,
482 BindStatusCallback_AddRef
,
483 BindStatusCallback_Release
,
484 BindStatusCallback_OnStartBinding
,
485 BindStatusCallback_GetPriority
,
486 BindStatusCallback_OnLowResource
,
487 BindStatusCallback_OnProgress
,
488 BindStatusCallback_OnStopBinding
,
489 BindStatusCallback_GetBindInfo
,
490 BindStatusCallback_OnDataAvailable
,
491 BindStatusCallback_OnObjectAvailable
494 #define HTTPNEG_THIS(iface) DEFINE_THIS(BSCallback, HttpNegotiate2, iface)
496 static HRESULT WINAPI
HttpNegotiate_QueryInterface(IHttpNegotiate2
*iface
,
497 REFIID riid
, void **ppv
)
499 BSCallback
*This
= HTTPNEG_THIS(iface
);
500 return IBindStatusCallback_QueryInterface(STATUSCLB(This
), riid
, ppv
);
503 static ULONG WINAPI
HttpNegotiate_AddRef(IHttpNegotiate2
*iface
)
505 BSCallback
*This
= HTTPNEG_THIS(iface
);
506 return IBindStatusCallback_AddRef(STATUSCLB(This
));
509 static ULONG WINAPI
HttpNegotiate_Release(IHttpNegotiate2
*iface
)
511 BSCallback
*This
= HTTPNEG_THIS(iface
);
512 return IBindStatusCallback_Release(STATUSCLB(This
));
515 static HRESULT WINAPI
HttpNegotiate_BeginningTransaction(IHttpNegotiate2
*iface
,
516 LPCWSTR szURL
, LPCWSTR szHeaders
, DWORD dwReserved
, LPWSTR
*pszAdditionalHeaders
)
518 BSCallback
*This
= HTTPNEG_THIS(iface
);
521 TRACE("(%p)->(%s %s %d %p)\n", This
, debugstr_w(szURL
), debugstr_w(szHeaders
),
522 dwReserved
, pszAdditionalHeaders
);
525 *pszAdditionalHeaders
= NULL
;
529 size
= (strlenW(This
->headers
)+1)*sizeof(WCHAR
);
530 *pszAdditionalHeaders
= CoTaskMemAlloc(size
);
531 memcpy(*pszAdditionalHeaders
, This
->headers
, size
);
536 static HRESULT WINAPI
HttpNegotiate_OnResponse(IHttpNegotiate2
*iface
, DWORD dwResponseCode
,
537 LPCWSTR szResponseHeaders
, LPCWSTR szRequestHeaders
, LPWSTR
*pszAdditionalRequestHeaders
)
539 BSCallback
*This
= HTTPNEG_THIS(iface
);
540 FIXME("(%p)->(%d %s %s %p)\n", This
, dwResponseCode
, debugstr_w(szResponseHeaders
),
541 debugstr_w(szRequestHeaders
), pszAdditionalRequestHeaders
);
545 static HRESULT WINAPI
HttpNegotiate_GetRootSecurityId(IHttpNegotiate2
*iface
,
546 BYTE
*pbSecurityId
, DWORD
*pcbSecurityId
, DWORD_PTR dwReserved
)
548 BSCallback
*This
= HTTPNEG_THIS(iface
);
549 FIXME("(%p)->(%p %p %ld)\n", This
, pbSecurityId
, pcbSecurityId
, dwReserved
);
555 static const IHttpNegotiate2Vtbl HttpNegotiate2Vtbl
= {
556 HttpNegotiate_QueryInterface
,
557 HttpNegotiate_AddRef
,
558 HttpNegotiate_Release
,
559 HttpNegotiate_BeginningTransaction
,
560 HttpNegotiate_OnResponse
,
561 HttpNegotiate_GetRootSecurityId
564 #define BINDINFO_THIS(iface) DEFINE_THIS(BSCallback, InternetBindInfo, iface)
566 static HRESULT WINAPI
InternetBindInfo_QueryInterface(IInternetBindInfo
*iface
,
567 REFIID riid
, void **ppv
)
569 BSCallback
*This
= BINDINFO_THIS(iface
);
570 return IBindStatusCallback_QueryInterface(STATUSCLB(This
), riid
, ppv
);
573 static ULONG WINAPI
InternetBindInfo_AddRef(IInternetBindInfo
*iface
)
575 BSCallback
*This
= BINDINFO_THIS(iface
);
576 return IBindStatusCallback_AddRef(STATUSCLB(This
));
579 static ULONG WINAPI
InternetBindInfo_Release(IInternetBindInfo
*iface
)
581 BSCallback
*This
= BINDINFO_THIS(iface
);
582 return IBindStatusCallback_Release(STATUSCLB(This
));
585 static HRESULT WINAPI
InternetBindInfo_GetBindInfo(IInternetBindInfo
*iface
,
586 DWORD
*grfBINDF
, BINDINFO
*pbindinfo
)
588 BSCallback
*This
= BINDINFO_THIS(iface
);
589 FIXME("(%p)->(%p %p)\n", This
, grfBINDF
, pbindinfo
);
593 static HRESULT WINAPI
InternetBindInfo_GetBindString(IInternetBindInfo
*iface
,
594 ULONG ulStringType
, LPOLESTR
*ppwzStr
, ULONG cEl
, ULONG
*pcElFetched
)
596 BSCallback
*This
= BINDINFO_THIS(iface
);
597 FIXME("(%p)->(%u %p %u %p)\n", This
, ulStringType
, ppwzStr
, cEl
, pcElFetched
);
603 static const IInternetBindInfoVtbl InternetBindInfoVtbl
= {
604 InternetBindInfo_QueryInterface
,
605 InternetBindInfo_AddRef
,
606 InternetBindInfo_Release
,
607 InternetBindInfo_GetBindInfo
,
608 InternetBindInfo_GetBindString
611 #define SERVPROV_THIS(iface) DEFINE_THIS(BSCallback, ServiceProvider, iface)
613 static HRESULT WINAPI
BSCServiceProvider_QueryInterface(IServiceProvider
*iface
,
614 REFIID riid
, void **ppv
)
616 BSCallback
*This
= SERVPROV_THIS(iface
);
617 return IBindStatusCallback_QueryInterface(STATUSCLB(This
), riid
, ppv
);
620 static ULONG WINAPI
BSCServiceProvider_AddRef(IServiceProvider
*iface
)
622 BSCallback
*This
= SERVPROV_THIS(iface
);
623 return IBindStatusCallback_AddRef(STATUSCLB(This
));
626 static ULONG WINAPI
BSCServiceProvider_Release(IServiceProvider
*iface
)
628 BSCallback
*This
= SERVPROV_THIS(iface
);
629 return IBindStatusCallback_Release(STATUSCLB(This
));
632 static HRESULT WINAPI
BSCServiceProvider_QueryService(IServiceProvider
*iface
,
633 REFGUID guidService
, REFIID riid
, void **ppv
)
635 BSCallback
*This
= SERVPROV_THIS(iface
);
636 FIXME("(%p)->(%s %s %p)\n", This
, debugstr_guid(guidService
), debugstr_guid(riid
), ppv
);
642 static const IServiceProviderVtbl ServiceProviderVtbl
= {
643 BSCServiceProvider_QueryInterface
,
644 BSCServiceProvider_AddRef
,
645 BSCServiceProvider_Release
,
646 BSCServiceProvider_QueryService
649 BSCallback
*create_bscallback(IMoniker
*mon
)
651 BSCallback
*ret
= mshtml_alloc(sizeof(BSCallback
));
653 ret
->lpBindStatusCallbackVtbl
= &BindStatusCallbackVtbl
;
654 ret
->lpServiceProviderVtbl
= &ServiceProviderVtbl
;
655 ret
->lpHttpNegotiate2Vtbl
= &HttpNegotiate2Vtbl
;
656 ret
->lpInternetBindInfoVtbl
= &InternetBindInfoVtbl
;
658 ret
->post_data
= NULL
;
660 ret
->post_data_len
= 0;
662 ret
->nschannel
= NULL
;
663 ret
->nslistener
= NULL
;
664 ret
->nscontext
= NULL
;
665 ret
->nsstream
= NULL
;
670 IMoniker_AddRef(mon
);
676 static void parse_post_data(nsIInputStream
*post_data_stream
, LPWSTR
*headers_ret
,
677 HGLOBAL
*post_data_ret
, ULONG
*post_data_len_ret
)
679 PRUint32 post_data_len
= 0, available
= 0;
680 HGLOBAL post_data
= NULL
;
681 LPWSTR headers
= NULL
;
682 DWORD headers_len
= 0, len
;
683 const char *ptr
, *ptr2
, *post_data_end
;
685 nsIInputStream_Available(post_data_stream
, &available
);
686 post_data
= GlobalAlloc(0, available
+1);
687 nsIInputStream_Read(post_data_stream
, post_data
, available
, &post_data_len
);
689 TRACE("post_data = %s\n", debugstr_an(post_data
, post_data_len
));
691 ptr
= ptr2
= post_data
;
692 post_data_end
= (const char*)post_data
+post_data_len
;
694 while(ptr
< post_data_end
&& (*ptr
!= '\r' || ptr
[1] != '\n')) {
695 while(ptr
< post_data_end
&& (*ptr
!= '\r' || ptr
[1] != '\n'))
705 if(ptr
-ptr2
>= sizeof(CONTENT_LENGTH
)
706 && CompareStringA(LOCALE_SYSTEM_DEFAULT
, NORM_IGNORECASE
,
707 CONTENT_LENGTH
, sizeof(CONTENT_LENGTH
)-1,
708 ptr2
, sizeof(CONTENT_LENGTH
)-1) == CSTR_EQUAL
) {
713 len
= MultiByteToWideChar(CP_ACP
, 0, ptr2
, ptr
-ptr2
, NULL
, 0);
716 headers
= mshtml_realloc(headers
,(headers_len
+len
+1)*sizeof(WCHAR
));
718 headers
= mshtml_alloc((len
+1)*sizeof(WCHAR
));
720 len
= MultiByteToWideChar(CP_ACP
, 0, ptr2
, ptr
-ptr2
, headers
+headers_len
, -1);
726 headers
[headers_len
] = 0;
727 *headers_ret
= headers
;
729 if(ptr
>= post_data_end
-2) {
730 GlobalFree(post_data
);
737 post_data_len
-= ptr
-(const char*)post_data
;
738 memmove(post_data
, ptr
, post_data_len
);
739 post_data
= GlobalReAlloc(post_data
, post_data_len
+1, 0);
742 *post_data_ret
= post_data
;
743 *post_data_len_ret
= post_data_len
;
746 void hlink_frame_navigate(HTMLDocument
*doc
, IHlinkFrame
*hlink_frame
,
747 LPCWSTR uri
, nsIInputStream
*post_data_stream
, DWORD hlnf
)
749 BSCallback
*callback
;
755 callback
= create_bscallback(NULL
);
757 if(post_data_stream
) {
758 parse_post_data(post_data_stream
, &callback
->headers
, &callback
->post_data
,
759 &callback
->post_data_len
);
760 TRACE("headers = %s post_data = %s\n", debugstr_w(callback
->headers
),
761 debugstr_an(callback
->post_data
, callback
->post_data_len
));
764 hr
= CreateAsyncBindCtx(0, STATUSCLB(callback
), NULL
, &bindctx
);
766 IBindStatusCallback_Release(STATUSCLB(callback
));
770 hr
= CoCreateInstance(&CLSID_StdHlink
, NULL
, CLSCTX_INPROC_SERVER
, &IID_IHlink
, (LPVOID
*)&hlink
);
772 IBindCtx_Release(bindctx
);
773 IBindStatusCallback_Release(STATUSCLB(callback
));
777 hr
= CreateURLMoniker(NULL
, uri
, &mon
);
779 IHlink_SetMonikerReference(hlink
, 0, mon
, NULL
);
781 if(hlnf
& HLNF_OPENINNEWWINDOW
) {
782 static const WCHAR wszBlank
[] = {'_','b','l','a','n','k',0};
783 IHlink_SetTargetFrameName(hlink
, wszBlank
); /* FIXME */
786 IHlinkFrame_Navigate(hlink_frame
, hlnf
, bindctx
, STATUSCLB(callback
), hlink
);
788 IMoniker_Release(mon
);
791 IBindCtx_Release(bindctx
);
792 IBindStatusCallback_Release(STATUSCLB(callback
));
795 HRESULT
start_binding(BSCallback
*bscallback
)
801 hres
= CreateAsyncBindCtx(0, STATUSCLB(bscallback
), NULL
, &bctx
);
803 WARN("CreateAsyncBindCtx failed: %08x\n", hres
);
804 on_stop_nsrequest(bscallback
);
808 hres
= IMoniker_BindToStorage(bscallback
->mon
, bctx
, NULL
, &IID_IStream
, (void**)&str
);
809 IBindCtx_Release(bctx
);
811 WARN("BindToStorage failed: %08x\n", hres
);
812 on_stop_nsrequest(bscallback
);
817 IStream_Release(str
);
819 IMoniker_Release(bscallback
->mon
);
820 bscallback
->mon
= NULL
;
822 /* events are reset when a new document URI is loaded, so re-initialise them here */
823 if(bscallback
->doc
&& bscallback
->doc
->nscontainer
)
824 init_nsevents(bscallback
->doc
->nscontainer
);
829 void set_document_bscallback(HTMLDocument
*doc
, BSCallback
*callback
)
831 if(doc
->bscallback
) {
832 if(doc
->bscallback
->binding
)
833 IBinding_Abort(doc
->bscallback
->binding
);
834 doc
->bscallback
->doc
= NULL
;
835 IBindStatusCallback_Release(STATUSCLB(doc
->bscallback
));
838 doc
->bscallback
= callback
;
841 IBindStatusCallback_AddRef(STATUSCLB(callback
));
846 HRESULT
load_stream(BSCallback
*bscallback
, IStream
*stream
)
850 const char text_html
[] = "text/html";
852 add_nsrequest(bscallback
);
854 if(bscallback
->nschannel
) {
855 bscallback
->nschannel
->content
= mshtml_alloc(sizeof(text_html
));
856 memcpy(bscallback
->nschannel
->content
, text_html
, sizeof(text_html
));
859 hres
= read_stream_data(bscallback
, stream
);
860 IBindStatusCallback_OnStopBinding(STATUSCLB(bscallback
), hres
, ERROR_SUCCESS
);