1.1 --- /dev/null Thu Jan 01 00:00:00 1970 +0000 1.2 +++ b/rdf/base/src/nsRDFXMLParser.cpp Wed Dec 31 06:09:35 2014 +0100 1.3 @@ -0,0 +1,127 @@ 1.4 +/* -*- Mode: C++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*- 1.5 + * 1.6 + * This Source Code Form is subject to the terms of the Mozilla Public 1.7 + * License, v. 2.0. If a copy of the MPL was not distributed with this 1.8 + * file, You can obtain one at http://mozilla.org/MPL/2.0/. */ 1.9 + 1.10 +#include "nsRDFXMLParser.h" 1.11 + 1.12 +#include "nsIComponentManager.h" 1.13 +#include "nsIParser.h" 1.14 +#include "nsCharsetSource.h" 1.15 +#include "nsIRDFContentSink.h" 1.16 +#include "nsParserCIID.h" 1.17 +#include "nsStringStream.h" 1.18 +#include "nsNetUtil.h" 1.19 + 1.20 +static NS_DEFINE_CID(kParserCID, NS_PARSER_CID); 1.21 + 1.22 +NS_IMPL_ISUPPORTS(nsRDFXMLParser, nsIRDFXMLParser) 1.23 + 1.24 +nsresult 1.25 +nsRDFXMLParser::Create(nsISupports* aOuter, REFNSIID aIID, void** aResult) 1.26 +{ 1.27 + if (aOuter) 1.28 + return NS_ERROR_NO_AGGREGATION; 1.29 + 1.30 + nsRDFXMLParser* result = new nsRDFXMLParser(); 1.31 + if (! result) 1.32 + return NS_ERROR_OUT_OF_MEMORY; 1.33 + 1.34 + nsresult rv; 1.35 + NS_ADDREF(result); 1.36 + rv = result->QueryInterface(aIID, aResult); 1.37 + NS_RELEASE(result); 1.38 + return rv; 1.39 +} 1.40 + 1.41 +nsRDFXMLParser::nsRDFXMLParser() 1.42 +{ 1.43 + MOZ_COUNT_CTOR(nsRDFXMLParser); 1.44 +} 1.45 + 1.46 +nsRDFXMLParser::~nsRDFXMLParser() 1.47 +{ 1.48 + MOZ_COUNT_DTOR(nsRDFXMLParser); 1.49 +} 1.50 + 1.51 +NS_IMETHODIMP 1.52 +nsRDFXMLParser::ParseAsync(nsIRDFDataSource* aSink, nsIURI* aBaseURI, nsIStreamListener** aResult) 1.53 +{ 1.54 + nsresult rv; 1.55 + 1.56 + nsCOMPtr<nsIRDFContentSink> sink = 1.57 + do_CreateInstance("@mozilla.org/rdf/content-sink;1", &rv); 1.58 + 1.59 + if (NS_FAILED(rv)) return rv; 1.60 + 1.61 + rv = sink->Init(aBaseURI); 1.62 + if (NS_FAILED(rv)) return rv; 1.63 + 1.64 + // We set the content sink's data source directly to our in-memory 1.65 + // store. This allows the initial content to be generated "directly". 1.66 + rv = sink->SetDataSource(aSink); 1.67 + if (NS_FAILED(rv)) return rv; 1.68 + 1.69 + nsCOMPtr<nsIParser> parser = do_CreateInstance(kParserCID, &rv); 1.70 + if (NS_FAILED(rv)) return rv; 1.71 + 1.72 + parser->SetDocumentCharset(NS_LITERAL_CSTRING("UTF-8"), 1.73 + kCharsetFromDocTypeDefault); 1.74 + parser->SetContentSink(sink); 1.75 + 1.76 + rv = parser->Parse(aBaseURI); 1.77 + if (NS_FAILED(rv)) return rv; 1.78 + 1.79 + return CallQueryInterface(parser, aResult); 1.80 +} 1.81 + 1.82 +NS_IMETHODIMP 1.83 +nsRDFXMLParser::ParseString(nsIRDFDataSource* aSink, nsIURI* aBaseURI, const nsACString& aString) 1.84 +{ 1.85 + nsresult rv; 1.86 + 1.87 + nsCOMPtr<nsIRDFContentSink> sink = 1.88 + do_CreateInstance("@mozilla.org/rdf/content-sink;1", &rv); 1.89 + 1.90 + if (NS_FAILED(rv)) return rv; 1.91 + 1.92 + rv = sink->Init(aBaseURI); 1.93 + if (NS_FAILED(rv)) return rv; 1.94 + 1.95 + // We set the content sink's data source directly to our in-memory 1.96 + // store. This allows the initial content to be generated "directly". 1.97 + rv = sink->SetDataSource(aSink); 1.98 + if (NS_FAILED(rv)) return rv; 1.99 + 1.100 + nsCOMPtr<nsIParser> parser = do_CreateInstance(kParserCID, &rv); 1.101 + if (NS_FAILED(rv)) return rv; 1.102 + 1.103 + parser->SetDocumentCharset(NS_LITERAL_CSTRING("UTF-8"), 1.104 + kCharsetFromOtherComponent); 1.105 + parser->SetContentSink(sink); 1.106 + 1.107 + rv = parser->Parse(aBaseURI); 1.108 + if (NS_FAILED(rv)) return rv; 1.109 + 1.110 + nsCOMPtr<nsIStreamListener> listener = 1.111 + do_QueryInterface(parser); 1.112 + 1.113 + if (! listener) 1.114 + return NS_ERROR_FAILURE; 1.115 + 1.116 + nsCOMPtr<nsIInputStream> stream; 1.117 + rv = NS_NewCStringInputStream(getter_AddRefs(stream), aString); 1.118 + if (NS_FAILED(rv)) return rv; 1.119 + 1.120 + nsCOMPtr<nsIChannel> channel; 1.121 + rv = NS_NewInputStreamChannel(getter_AddRefs(channel), aBaseURI, stream, 1.122 + NS_LITERAL_CSTRING("text/xml")); 1.123 + if (NS_FAILED(rv)) return rv; 1.124 + 1.125 + listener->OnStartRequest(channel, nullptr); 1.126 + listener->OnDataAvailable(channel, nullptr, stream, 0, aString.Length()); 1.127 + listener->OnStopRequest(channel, nullptr, NS_OK); 1.128 + 1.129 + return NS_OK; 1.130 +}