Java Code Examples for org.xml.sax.SAXException

public void write(String htmlText) throws SAXException {
  try {
    writer.write(htmlText);
  }
 catch (  IOException e) {
    throw new SAXException("I/O error",e);
  }
}
 

/** 
 * Instantiates a new xml dom.
 * @param is Raw XML.
 * @throws SAXException the SAX exception
 */
public XmlDom(InputStream is) throws SAXException {
  DocumentBuilderFactory factory=DocumentBuilderFactory.newInstance();
  DocumentBuilder builder;
  try {
    builder=factory.newDocumentBuilder();
    Document doc=builder.parse(is);
    this.root=(Element)doc.getDocumentElement();
  }
 catch (  ParserConfigurationException e) {
  }
catch (  IOException e) {
    throw new SAXException(e);
  }
}
 

/** 
 * Write a newline at the end of the document. Pass the event on down the filter chain for further processing.
 * @exception org.xml.sax.SAXException If there is an errorwriting the newline, or if a handler further down the filter chain raises an exception.
 * @see org.xml.sax.ContentHandler#endDocument
 */
public void endDocument() throws SAXException {
  write('\n');
  super.endDocument();
  try {
    flush();
  }
 catch (  IOException e) {
    throw new SAXException(e);
  }
}
 

private static String getRequiredString(Attributes attributes,String localName) throws SAXException {
  String result=attributes.getValue("",localName);
  if (result == null) {
    throw new SAXException("Expected attribute " + localName);
  }
  return result;
}
 

/** 
 * Process notification of the end of a document and write generated bytecode into output stream.
 * @exception SAXException if parsing or writing error is to be reported.
 */
public final void endDocument() throws SAXException {
  try {
    os.write(toByteArray());
  }
 catch (  IOException ex) {
    throw new SAXException(ex.toString(),ex);
  }
}
 

/** 
 * Bind a given resource, probably resuming an old session.
 * @param resource String The preferred resource string.
 * @return String The actual resource string.
 * @throws XmppException On Error.
 */
public String bind(String resource) throws XmppException {
  Log.d("BC/XMPP/Negotiation","bind " + resource);
  try {
    if (!TextUtils.isEmpty(resource)) {
      xmppOutput.sendUnchecked("<iq type=\"set\" id=\"bind_1\">" + "<bind xmlns=\"urn:ietf:params:xml:ns:xmpp-bind\">" + "<resource>" + resource + "</resource>"+ "</bind>"+ "</iq>");
    }
 else {
      xmppOutput.sendUnchecked("<iq type=\"set\" id=\"bind_1\">" + "<bind xmlns=\"urn:ietf:params:xml:ns:xmpp-bind\">" + "</bind>"+ "</iq>");
    }
    Stanza stanza=xmppInput.nextStanza();
    Node node=XMLUtils.getDocumentNode(stanza.getXml());
    Node bind=XMLUtils.getFirstChild(node,"urn:ietf:params:xml:ns:xmpp-bind","bind");
    Node jid=XMLUtils.getFirstChild(bind,null,"jid");
    if (sessionsSupported) {
      startSession();
    }
    return jid.getTextContent();
  }
 catch (  IllegalArgumentException e) {
    throw new XmppMalformedException("bind malformed",e);
  }
catch (  IllegalStateException e) {
    throw new XmppMalformedException("bind malformed",e);
  }
catch (  SAXException e) {
    throw new XmppMalformedException("bind malformed",e);
  }
}
 

public void startElement(String uri,String localName,String qName,Attributes attrs) throws SAXException {
switch (mState) {
case STATE_DOCUMENT:
    if (uri.equals(ATOM_NAMESPACE) && localName.equals(FEED_ELEMENT)) {
      mState=STATE_FEED;
    }
 else {
      throw new SAXException();
    }
  break;
case STATE_FEED:
if (uri.equals(ATOM_NAMESPACE) && localName.equals(ENTRY_ELEMENT)) {
  mState=STATE_ENTRY;
  mEntry.clear();
}
 else {
  startProperty(uri,localName,attrs);
}
break;
case STATE_ENTRY:
startProperty(uri,localName,attrs);
break;
}
}
 

/** 
 * Get the XML document for the RSS feed
 * @return the XML Document for the feed on success, on error returns null
 */
private static Document getDocument(){
  Document doc=null;
  try {
    DocumentBuilder builder=DocumentBuilderFactory.newInstance().newDocumentBuilder();
    DefaultHttpClient client=new DefaultHttpClient();
    HttpGet request=new HttpGet(URI);
    HttpResponse response=client.execute(request);
    doc=builder.parse(response.getEntity().getContent());
  }
 catch (  java.io.IOException e) {
    return null;
  }
catch (  SAXException e) {
    Log.e("AARSS","Parse Exception in RSS feed",e);
    return null;
  }
catch (  Exception e) {
    return null;
  }
  return doc;
}
 

@Override public void startElement(String uri,String localName,String qName,Attributes attributes) throws SAXException {
  if (!underlyingCommodoityPriceFieldToCollect.isEmpty() && qName.equalsIgnoreCase("STRONG")) {
    collectUnderlyingCommodityPrice=true;
    return;
  }
  if (null == optionType) {
    return;
  }
  if (qName.equalsIgnoreCase("TR") && null != attributes.getValue("title")) {
    String title=attributes.getValue("title");
    optionBuilder=new String[6];
    optionBuilder[0]=title;
    optionRowProcessing=true;
    optionColumnIndex=-1;
    return;
  }
  if (optionRowProcessing && qName.equalsIgnoreCase("TD")) {
    optionColumnIndex++;
    optionColumnProcessing=true;
    return;
  }
}
 

static public <T>T decode(Class<T> clazz,InputStream is,Properties props,ValidationEventHandler validationHandler) throws IOException, XMLStreamException, JAXBException, SAXException {
  ClassLoader original=Thread.currentThread().getContextClassLoader();
  try {
    Thread.currentThread().setContextClassLoader(ClassFinder.class_loader());
    if (is == null) {
      throw new IllegalArgumentException("input stream was null");
    }
    try {
      XMLStreamReader reader=factory.createXMLStreamReader(is);
      if (props != null) {
        reader=new PropertiesFilter(reader,props);
      }
      Unmarshaller unmarshaller=context().createUnmarshaller();
      if (validationHandler != null) {
        try {
          SchemaFactory sf=SchemaFactory.newInstance(XMLConstants.W3C_XML_SCHEMA_NS_URI);
          sf.setFeature("http://apache.org/xml/features/validation/schema-full-checking",false);
          Schema schema=sf.newSchema(XmlCodec.class.getResource("apollo.xsd"));
          unmarshaller.setSchema(schema);
          unmarshaller.setEventHandler(validationHandler);
        }
 catch (        Exception e) {
          System.err.println("Could not load schema: " + e.getMessage());
        }
      }
      return clazz.cast(unmarshaller.unmarshal(reader));
    }
  finally {
      is.close();
    }
  }
  finally {
    Thread.currentThread().setContextClassLoader(original);
  }
}
 

public static Document parse(InputStream is) throws IOException {
  DocumentBuilderFactory domFactory=DocumentBuilderFactory.newInstance();
  domFactory.setValidating(false);
  domFactory.setNamespaceAware(false);
  domFactory.setIgnoringElementContentWhitespace(true);
  DocumentBuilder builder=null;
  try {
    builder=domFactory.newDocumentBuilder();
  }
 catch (  ParserConfigurationException e) {
    throw new RuntimeException(e);
  }
  Document ret;
  try {
    ret=builder.parse(is);
  }
 catch (  SAXException e) {
    throw new ParseException("Error parsing PubMed response",e);
  }
  return ret;
}
 

@Override public void endElement(final String uri,final String localName,final String name) throws SAXException {
  super.endElement(uri,localName,name);
  try {
    if (this.currentFeedItem != null) {
      if (localName.equalsIgnoreCase(TITLE)) {
        currentFeedItem.title=builder.toString();
      }
 else       if (localName.equalsIgnoreCase(LINK)) {
        currentFeedItem.link=builder.toString();
      }
 else       if (localName.equalsIgnoreCase(DESCRIPTION)) {
        currentFeedItem.description=builder.toString();
      }
 else       if (localName.equalsIgnoreCase(PUB_DATE)) {
        currentFeedItem.date=DateUtils.Parser.GMT_DATE_PARSER.parse(builder.toString());
      }
 else       if (localName.equalsIgnoreCase(ITEM)) {
        messages.add(currentFeedItem);
      }
      builder.setLength(0);
    }
  }
 catch (  final Exception e) {
    Ln.e(e);
  }
}
 

private void parseXml(byte[] s) throws MojoFailureException {
  DocumentBuilderFactory dbf=DocumentBuilderFactory.newInstance();
  try {
    DocumentBuilder db=dbf.newDocumentBuilder();
    Document dom=db.parse(new InputSource(new ByteArrayInputStream(s)));
    NodeList nl=dom.getDocumentElement().getChildNodes();
    for (int i=0; i < nl.getLength(); i++) {
      Object uel=nl.item(i);
      if (uel instanceof Element) {
        Element el=(Element)uel;
        String nodeName=el.getNodeName();
        if (nodeName.equals("id"))         id=el.getTextContent();
      }
    }
  }
 catch (  ParserConfigurationException e) {
    throwParseFail(file,e);
  }
catch (  SAXException e) {
    throwParseFail(file,e);
  }
catch (  IOException e) {
    throwParseFail(file,e);
  }
}
 

public void readTerritoriesXML() throws ParserConfigurationException, SAXException, IOException {
  DocumentBuilderFactory dbFactory=DocumentBuilderFactory.newInstance();
  DocumentBuilder dBuilder=dbFactory.newDocumentBuilder();
  Document doc;
  doc=dBuilder.parse(getClass().getResourceAsStream("/got/resource/xml/territory.xml"));
  doc.getDocumentElement().normalize();
  NodeList nList=doc.getElementsByTagName("Territory");
  for (int temp=0; temp < nList.getLength(); temp++) {
    TerritoryInfo ti=new TerritoryInfo();
    Node nNode=nList.item(temp);
    String name=nNode.getAttributes().getNamedItem("Name").getNodeValue();
    String mustering=nNode.getAttributes().getNamedItem("Mustering").getNodeValue();
    String supply=nNode.getAttributes().getNamedItem("Supply").getNodeValue();
    String power=nNode.getAttributes().getNamedItem("Power").getNodeValue();
    String port=nNode.getAttributes().getNamedItem("Port").getNodeValue();
    String type=nNode.getAttributes().getNamedItem("Type").getNodeValue();
    ti.setName(name);
    ti.setMustering(Integer.valueOf(mustering));
    ti.setSupply(Integer.valueOf(supply));
    ti.setPower(Integer.valueOf(power));
    ti.setType(TerritoryType.values()[Integer.valueOf(type)]);
    ti.setAction(Action.NONE);
    for (    Arm arm : Arm.values()) {
      ti.getConquerArms().put(arm,0);
    }
    getTerrMap().put(ti.getName(),ti);
    getConnTerritories().put(ti.getName(),new ArrayList<String>());
  }
}
 

/** 
 * Method that loads IPConfig
 */
static void load(){
  try {
    SAXParser parser=SAXParserFactory.newInstance().newSAXParser();
    parser.parse(new File(CONFIG_FILE),new DefaultHandler(){
      @Override public void startElement(      String uri,      String localName,      String qName,      Attributes attributes) throws SAXException {
        if (qName.equals("ipconfig")) {
          defaultAddress=IPRange.toByteArray(attributes.getValue("default"));
        }
 else         if (qName.equals("iprange")) {
          String min=attributes.getValue("min");
          String max=attributes.getValue("max");
          String address=attributes.getValue("address");
          IPRange ipRange=new IPRange(min,max,address);
          ranges.add(ipRange);
        }
      }
    }
);
  }
 catch (  Exception e) {
    log.fatal("Critical error while parsing ipConfig",e);
    throw new Error("Can't load ipConfig",e);
  }
}
 

@Override public void startElement(String uri,String localName,String qName,Attributes attributes) throws SAXException {
  String attr;
  if (qName.equalsIgnoreCase("AIRSIGMET")) {
    entry=new AirSigmetEntry();
  }
 else   if (qName.equalsIgnoreCase("altitude")) {
    attr=attributes.getValue("min_ft_msl");
    if (attr != null) {
      entry.minAltitudeFeet=Integer.valueOf(attr);
    }
    attr=attributes.getValue("max_ft_msl");
    if (attr != null) {
      entry.maxAltitudeFeet=Integer.valueOf(attr);
    }
  }
 else   if (qName.equalsIgnoreCase("hazard")) {
    entry.hazardType=attributes.getValue("type");
    entry.hazardSeverity=attributes.getValue("severity");
  }
 else   if (qName.equalsIgnoreCase("area")) {
    entry.points=new ArrayList<AirSigmetPoint>();
  }
 else   if (qName.equalsIgnoreCase("point")) {
    point=new AirSigmetPoint();
  }
 else {
    text.setLength(0);
  }
}
 

public AbstractXmlParser(InputStream inputStream){
  DocumentBuilder newDocumentBuilder=createDocumentBuilder();
  try {
    this.xmlDocument=newDocumentBuilder.parse(inputStream);
  }
 catch (  SAXException e) {
    throw new ApplicationGeneralException(e);
  }
catch (  IOException e) {
    throw new ApplicationGeneralException(e);
  }
}
 

@Override public void endElement(String uri,String localName,String qName) throws SAXException {
  Log.i(PKG,TAG + ": endElement()");
  if (localName.contentEquals("finance")) {
    inQuote=false;
    quotes.add(currentQuote);
  }
}
 

public ArrayList<Flavor> createList(boolean detail,Context context){
  CustomHttpClient httpclient=new CustomHttpClient(context);
  HttpGet get=new HttpGet(Account.getAccount().getServerUrl() + "/flavors/detail.xml?now=cache_time2");
  ArrayList<Flavor> flavors=new ArrayList<Flavor>();
  get.addHeader("X-Auth-Token",Account.getAccount().getAuthToken());
  try {
    HttpResponse resp=httpclient.execute(get);
    BasicResponseHandler responseHandler=new BasicResponseHandler();
    String body=responseHandler.handleResponse(resp);
    if (resp.getStatusLine().getStatusCode() == 200 || resp.getStatusLine().getStatusCode() == 203) {
      FlavorsXMLParser flavorsXMLParser=new FlavorsXMLParser();
      SAXParser saxParser=SAXParserFactory.newInstance().newSAXParser();
      XMLReader xmlReader=saxParser.getXMLReader();
      xmlReader.setContentHandler(flavorsXMLParser);
      xmlReader.parse(new InputSource(new StringReader(body)));
      flavors=flavorsXMLParser.getFlavors();
    }
  }
 catch (  ClientProtocolException cpe) {
  }
catch (  IOException e) {
  }
catch (  ParserConfigurationException e) {
  }
catch (  SAXException e) {
  }
catch (  FactoryConfigurationError e) {
  }
  return flavors;
}
 

/** 
 * Parses input stream as RSS feed. It is the responsibility of the caller to close the RSS feed input stream.
 * @param feed RSS 2.0 feed input stream
 * @return in-memory representation of RSS feed
 * @throws RSSFault if an unrecoverable parse error occurs
 */
@Override public RSSFeed parse(InputStream feed){
  try {
    final SAXParserFactory factory=SAXParserFactory.newInstance();
    factory.setFeature("http://xml.org/sax/features/namespaces",false);
    factory.setFeature("http://xml.org/sax/features/namespace-prefixes",true);
    final SAXParser parser=factory.newSAXParser();
    return parse(parser,feed);
  }
 catch (  ParserConfigurationException e) {
    throw new RSSFault(e);
  }
catch (  SAXException e) {
    throw new RSSFault(e);
  }
catch (  IOException e) {
    throw new RSSFault(e);
  }
}
 

void parseRSS(InputStream feed){
  XMLReader parser=null;
  try {
    parser=XMLReaderFactory.createXMLReader();
    parser.setContentHandler(getRSSContentHandler());
    parser.parse(new InputSource(feed));
  }
 catch (  IOException e) {
    e.printStackTrace();
  }
catch (  SAXException e) {
    e.printStackTrace();
  }
}
 

/** 
 * Invoke the right input method according to args.
 * @param args the parsed command line arguments.
 * @return the read dictionary.
 */
private static FusionDictionary readInputFromParsedArgs(final Arguments args) throws IOException, UnsupportedFormatException, ParserConfigurationException, SAXException, FileNotFoundException {
  if (null != args.mInputBinary) {
    return readBinaryFile(args.mInputBinary);
  }
 else   if (null != args.mInputUnigramXml) {
    return readXmlFile(args.mInputUnigramXml,args.mInputBigramXml);
  }
 else {
    throw new RuntimeException("No input file specified");
  }
}
 

public List load(InputStream ins) throws ParserConfigurationException, SAXException, IOException {
  DocumentBuilderFactory dbf=DocumentBuilderFactory.newInstance();
  DocumentBuilder db=dbf.newDocumentBuilder();
  Document doc=db.parse(ins);
  return loadConnectors(doc);
}
 

/** 
 * Invoke the right input method according to args.
 * @param args the parsed command line arguments.
 * @return the read dictionary.
 */
private static FusionDictionary readInputFromParsedArgs(final Arguments args) throws IOException, UnsupportedFormatException, ParserConfigurationException, SAXException, FileNotFoundException {
  if (null != args.mInputBinary) {
    return readBinaryFile(args.mInputBinary);
  }
 else   if (null != args.mInputUnigramXml) {
    return readXmlFile(args.mInputUnigramXml,args.mInputBigramXml);
  }
 else {
    throw new RuntimeException("No input file specified");
  }
}
 

@Override public void startElement(String uri,String localName,String qName,Attributes attrs) throws SAXException {
  if (skip) {
    return;
  }
  if (!uri.equals(XML_NAMESPACE)) {
    return;
  }
  if (recordNext) {
    if (!localName.equals(INTENT_TAG)) {
      return;
    }
    action=attrs.getValue("action");
    data=attrs.getValue("data");
    type=attrs.getValue("type");
    extras=toMap(attrs.getValue("extras"));
    recordMatch(true);
  }
 else {
    if (!localName.equals(VERSION_TAG)) {
      return;
    }
    VeecheckVersion version=new VeecheckVersion(attrs);
    recordNext=this.version.matches(version);
  }
}
 

public Service parse(InputStream in){
  try {
    Xml.parse(in,Xml.Encoding.UTF_8,this);
  }
 catch (  IOException e) {
    Log.e(TAG,"IOException " + e.getMessage());
    return null;
  }
catch (  SAXException e) {
    Log.e(TAG,"SAXException " + e.getMessage());
    return null;
  }
  return service;
}
 

/** 
 * {@inheritDoc}
 */
@Override protected void doValidate(){
  if (this._id == null || "".equals(this._id)) {
    throw new Ant4EclipseException(PdeExceptionCode.ANT_ATTRIBUTE_NOT_SET,"id");
  }
  if (this._targetFile != null) {
    if (!this._targetFile.exists()) {
      throw new Ant4EclipseException(PdeExceptionCode.TARGET_FILE_NOT_FOUND,this._targetFile.toString());
    }
    try {
      XMLReader reader=XMLReaderFactory.createXMLReader();
      reader.setContentHandler(new TargetPlattformContentHandler(this._targetFile,this));
      FileInputStream in=new FileInputStream(this._targetFile);
      try {
        reader.parse(new InputSource(new InputStreamReader(in,"UTF-8")));
      }
  finally {
        in.close();
      }
    }
 catch (    SAXException e) {
      Ant4EclipseException exeption=new Ant4EclipseException(PdeExceptionCode.TARGET_PARSING_FAILED,this._targetFile.toString(),e.toString());
      exeption.initCause(e);
      throw exeption;
    }
catch (    IOException e) {
      Ant4EclipseException exeption=new Ant4EclipseException(PdeExceptionCode.TARGET_PARSING_FAILED,this._targetFile.toString(),e.toString());
      exeption.initCause(e);
      throw exeption;
    }
  }
  if (this._targetPlatformDefinition.getLocations().length == 0) {
    A4ELogging.warn("Target definition with id %s does not contain any locations!",this._id);
  }
  TargetPlatformRegistry targetPlatformRegistry=ServiceRegistryAccess.instance().getService(TargetPlatformRegistry.class);
  targetPlatformRegistry.addTargetPlatformDefinition(this._id,this._targetPlatformDefinition);
}
 

/** 
 * Returns the DOM of the given document URI. 
 * @return the <i>HTML</i> DOM.
 * @throws IOException
 */
public Document getDOM() throws IOException {
  if (result == null) {
    long startTime=System.currentTimeMillis();
    try {
      result=parse();
    }
 catch (    SAXException ex) {
      throw new RuntimeException("Shouldn not happen, it's a tag soup parser",ex);
    }
catch (    TransformerException ex) {
      throw new RuntimeException("Shouldn not happen, it's a tag soup parser",ex);
    }
catch (    NullPointerException ex) {
      if (ex.getStackTrace()[0].getClassName().equals("java.io.Reader")) {
        throw new RuntimeException("Bug in NekoHTML, try upgrading to newer release!",ex);
      }
 else {
        throw ex;
      }
    }
 finally {
      long elapsed=System.currentTimeMillis() - startTime;
      logger.debug("Parsed " + documentURI + " with NekoHTML, "+ elapsed+ "ms");
    }
  }
  result.setDocumentURI(documentURI);
  return result;
}
 

private Document readIdeaFile(@NotNull File ideaFile,final String defaultTemplate){
  Document result=null;
  try {
    DocumentBuilder reader=DocumentBuilderFactory.newInstance().newDocumentBuilder();
    InputStream is;
    if (!env.forceBuild() && ideaFile.exists()) {
      is=new FileInputStream(ideaFile);
    }
 else     if (template != null && template.exists()) {
      is=new FileInputStream(template);
    }
 else {
      is=getClass().getResourceAsStream(defaultTemplate);
    }
    result=reader.parse(is);
  }
 catch (  ParserConfigurationException e) {
    env.handle(e);
  }
catch (  IOException e) {
    env.handle(e);
  }
catch (  SAXException e) {
    env.handle(e);
  }
  return result;
}
 

@Override public InputSource resolveEntity(String publicId,String systemId) throws SAXException, IOException {
  if (defaultResolver != null) {
    try {
      return defaultResolver.resolveEntity(publicId,systemId);
    }
 catch (    IOException ioex) {
      return resolveInClasspath(publicId,systemId);
    }
  }
  return resolveInClasspath(publicId,systemId);
}
 

private Document parseXmlFile(File file){
  Document dom=null;
  DocumentBuilderFactory dbf=DocumentBuilderFactory.newInstance();
  try {
    DocumentBuilder db=dbf.newDocumentBuilder();
    dom=db.parse(file);
  }
 catch (  ParserConfigurationException pce) {
    pce.printStackTrace();
  }
catch (  SAXException se) {
    se.printStackTrace();
  }
catch (  IOException ioe) {
    ioe.printStackTrace();
  }
  return dom;
}
 

/** 
 * @param xmlInputStream The file to be parsed
 * @return The document
 */
private Document getDocument(InputStream xmlInputStream){
  DocumentBuilderFactory docBuilderFactory=DocumentBuilderFactory.newInstance();
  docBuilderFactory.setNamespaceAware(true);
  DocumentBuilder docBuilder=null;
  try {
    docBuilder=docBuilderFactory.newDocumentBuilder();
  }
 catch (  ParserConfigurationException e) {
    e.printStackTrace();
  }
  Document doc=null;
  try {
    doc=docBuilder.parse(xmlInputStream);
    doc.normalize();
  }
 catch (  SAXException e) {
  }
catch (  IOException e) {
  }
  return doc;
}
 

private void validateXML(String xml) throws Exception {
  DocumentBuilderFactory dbf=DocumentBuilderFactory.newInstance();
  dbf.setValidating(true);
  dbf.setNamespaceAware(true);
  dbf.setAttribute("http://java.sun.com/xml/jaxp/properties/schemaLanguage","http://www.w3.org/2001/XMLSchema");
  DocumentBuilder db=dbf.newDocumentBuilder();
  db.setErrorHandler(new ErrorHandler(){
    @Override public void warning(    SAXParseException exception) throws SAXException {
      throw exception;
    }
    @Override public void fatalError(    SAXParseException exception) throws SAXException {
      throw exception;
    }
    @Override public void error(    SAXParseException exception) throws SAXException {
      throw exception;
    }
  }
);
  db.setEntityResolver(new EntityResolver(){
    @Override public InputSource resolveEntity(    String publicId,    String systemId) throws SAXException, IOException {
      if ("http://jboss.org/schema/arquillian/arquillian_1_0.xsd".equals(systemId)) {
        return new InputSource(this.getClass().getClassLoader().getResourceAsStream("arquillian_1_0.xsd"));
      }
      return null;
    }
  }
);
  db.parse(new ByteArrayInputStream(xml.getBytes()));
}
 

public String obtainDataSourceName(final String descriptor){
  try {
    final Document document=factory.newDocumentBuilder().parse(new ByteArrayInputStream(descriptor.getBytes()));
    final NodeList persistenceUnits=document.getElementsByTagName("persistence-unit");
    if (persistenceUnits.getLength() > 1) {
      throw new MultiplePersistenceUnitsException("Multiple persistence units defined. Please specify default data source either in 'arquillian.xml' or by using @DataSource annotation");
    }
    final Node persistenceUnit=persistenceUnits.item(0);
    Node dataSource=getJtaDataSource(persistenceUnit);
    if (dataSource == null) {
      dataSource=getNonJtaDataSource(persistenceUnit);
    }
    return dataSource.getTextContent();
  }
 catch (  SAXException e) {
    throw new PersistenceDescriptorParsingException("Unable to parse descriptor " + descriptor,e);
  }
catch (  IOException e) {
    throw new PersistenceDescriptorParsingException("Unable to parse descriptor " + descriptor,e);
  }
catch (  ParserConfigurationException e) {
    throw new PersistenceDescriptorParsingException("Unable to parse descriptor " + descriptor,e);
  }
}
 

@BeforeMethod public void prepareEnvironment() throws IOException, SAXException {
  stub=new VisualSuiteStub();
  PipedInputStream in=new PipedInputStream();
  PipedOutputStream writerOut=new PipedOutputStream(in);
  documentOutputStream=new ByteArrayOutputStream();
  TeeOutputStream out=new TeeOutputStream(writerOut,documentOutputStream);
  OutputFormat format=new OutputFormat("\t",true);
  writer=new XMLWriter(out,format);
  inputStream=in;
  parser=new Parser();
  handler=parser.getHandler();
}
 

public SWCResourceRoot(File path) throws IOException {
  this.path=path;
  ZipFile zip=new ZipFile(path.getAbsolutePath());
  try {
    ZipEntry entry=zip.getEntry(CATALOG_FILENAME);
    if (entry == null) {
      throw new IllegalArgumentException("No " + CATALOG_FILENAME + " in swc: "+ path.getAbsolutePath());
    }
    qnames=readCatalog(zip.getInputStream(entry));
  }
 catch (  ParserConfigurationException e) {
    throw new IOException(e.toString());
  }
catch (  SAXException e) {
    throw new IOException(e.toString());
  }
catch (  XPathExpressionException e) {
    throw new IOException(e.toString());
  }
 finally {
    zip.close();
  }
}
 

/** 
 * Bind a given resource, probably resuming an old session.
 * @param resource String The preferred resource string.
 * @return String The actual resource string.
 * @throws XmppException On Error.
 */
public String bind(String resource) throws XmppException {
  try {
    if (!TextUtils.isEmpty(resource)) {
      xmppOutput.sendUnchecked("<iq type=\"set\" id=\"bind_1\">" + "<bind xmlns=\"urn:ietf:params:xml:ns:xmpp-bind\">" + "<resource>" + resource + "</resource>"+ "</bind>"+ "</iq>");
    }
 else {
      xmppOutput.sendUnchecked("<iq type=\"set\" id=\"bind_1\">" + "<bind xmlns=\"urn:ietf:params:xml:ns:xmpp-bind\">" + "</bind>"+ "</iq>");
    }
    Stanza stanza=xmppInput.nextStanza();
    Node node=XMLUtils.getDocumentNode(stanza.getXml());
    Node bind=XMLUtils.getFirstChild(node,"urn:ietf:params:xml:ns:xmpp-bind","bind");
    Node jid=XMLUtils.getFirstChild(bind,null,"jid");
    if (sessionsSupported) {
      startSession();
    }
    return jid.getTextContent();
  }
 catch (  IllegalArgumentException e) {
    throw new XmppMalformedException("bind malformed",e);
  }
catch (  IllegalStateException e) {
    throw new XmppMalformedException("bind malformed",e);
  }
catch (  SAXException e) {
    throw new XmppMalformedException("bind malformed",e);
  }
}
 

String getPackageNameFromManifest(File root) throws IOException {
  File manifest=new File(root.getAbsolutePath() + "/AndroidManifest.xml");
  String result=null;
  if (manifest.exists()) {
    DocumentBuilderFactory dbf=DocumentBuilderFactory.newInstance();
    try {
      DocumentBuilder db=dbf.newDocumentBuilder();
      Document dom=db.parse(manifest);
      result=dom.getElementsByTagName("manifest").item(0).getAttributes().getNamedItem("package").getNodeValue();
    }
 catch (    ParserConfigurationException pce) {
      pce.printStackTrace();
    }
catch (    SAXException se) {
      se.printStackTrace();
    }
catch (    IOException ioe) {
      ioe.printStackTrace();
    }
  }
 else {
    throw (new IOException("Could not find an Android Manifest file: " + manifest.getAbsolutePath()));
  }
  return result;
}
 

@Override public void parseAsXml(InputStream inputStream,IEntity destEntity) throws ServiceException {
  try {
    SAXParserFactory spf=SAXParserFactory.newInstance();
    SAXParser sp=spf.newSAXParser();
    XMLReader xr=sp.getXMLReader();
    xr.setContentHandler(new XmlParser(destEntity));
    xr.parse(new InputSource(inputStream));
  }
 catch (  ParserConfigurationException e) {
    log.error("An error occurred while instantiating XML Parser",e);
    throw new ServiceException(ServiceException.GENERIC_ERROR,e.getMessage());
  }
catch (  SAXException e) {
    log.error("An error occurred while instantiating XML Parser",e);
    throw new ServiceException(ServiceException.GENERIC_ERROR,e.getMessage());
  }
catch (  IllegalStateException e) {
    log.error("An error occurred while parsing response",e);
    throw new ServiceException(ServiceException.GENERIC_ERROR,e.getMessage());
  }
catch (  IOException e) {
    log.error("An error occurred while parsing response",e);
    throw new ServiceException(ServiceException.GENERIC_ERROR,e.getMessage());
  }
}
 

/** 
 * Utility to validate XML files against pre-defined schema files. The schema files are extracted automatically when this function is called, the XML being validated is not. Be sure the XML file is already extracted otherwise it will return false.
 * @param xmlfile The XML file to validate, in DOMSource format
 * @param type The file name of the schema to validate against, must exist as a resource in the same package as where this function is being called.For example usages, please see KeywordSearchListsXML, HashDbXML, or IngestModuleLoader.
 */
public static boolean xmlIsValid(DOMSource xmlfile,Class clazz,String schemaFile){
  try {
    PlatformUtil.extractResourceToUserConfigDir(clazz,schemaFile);
    File schemaLoc=new File(PlatformUtil.getUserConfigDirectory() + File.separator + schemaFile);
    SchemaFactory schm=SchemaFactory.newInstance(XMLConstants.W3C_XML_SCHEMA_NS_URI);
    try {
      Schema schema=schm.newSchema(schemaLoc);
      Validator validator=schema.newValidator();
      DOMResult result=new DOMResult();
      validator.validate(xmlfile,result);
      return true;
    }
 catch (    SAXException e) {
      Logger.getLogger(clazz.getName()).log(Level.WARNING,"Unable to validate XML file.",e);
      return false;
    }
  }
 catch (  IOException e) {
    Logger.getLogger(clazz.getName()).log(Level.WARNING,"Unable to load XML file [" + xmlfile.toString() + "] of type ["+ schemaFile+ "]",e);
    return false;
  }
}
 

private static SignableSAMLObject getSamlTokenFromSamlResponse(String samlResponse) throws ParserConfigurationException, SAXException, IOException, UnmarshallingException {
  Document document=getDocument(samlResponse);
  Unmarshaller unmarshaller=Configuration.getUnmarshallerFactory().getUnmarshaller(document.getDocumentElement());
  org.opensaml.saml2.core.Response response=(org.opensaml.saml2.core.Response)unmarshaller.unmarshall(document.getDocumentElement());
  SignableSAMLObject samlToken=(SignableSAMLObject)response.getAssertions().get(0);
  return samlToken;
}
 

public void parse(String str) throws UnsupportedEncodingException, SAXException, IOException, ParserConfigurationException {
  DocumentBuilderFactory dbf=DocumentBuilderFactory.newInstance();
  DocumentBuilder db=dbf.newDocumentBuilder();
  Document doc=db.parse(new ByteArrayInputStream(str.getBytes("UTF-8")));
  doc.getDocumentElement().normalize();
  Element nodeResponse=(Element)doc.getElementsByTagName("response").item(0);
  returncode=ParserUtils.getNodeValue(nodeResponse,"returncode");
  if (returncode.equals("SUCCESS")) {
    fullname=ParserUtils.getNodeValue(nodeResponse,"fullname");
    confname=ParserUtils.getNodeValue(nodeResponse,"confname");
    meetingID=ParserUtils.getNodeValue(nodeResponse,"meetingID");
    externUserID=ParserUtils.getNodeValue(nodeResponse,"externUserID");
    role=ParserUtils.getNodeValue(nodeResponse,"role");
    conference=ParserUtils.getNodeValue(nodeResponse,"conference");
    room=ParserUtils.getNodeValue(nodeResponse,"room");
    voicebridge=ParserUtils.getNodeValue(nodeResponse,"voicebridge");
    webvoiceconf=ParserUtils.getNodeValue(nodeResponse,"webvoiceconf");
    mode=ParserUtils.getNodeValue(nodeResponse,"mode");
    record=ParserUtils.getNodeValue(nodeResponse,"record");
    welcome=ParserUtils.getNodeValue(nodeResponse,"welcome");
    server=ParserUtils.getNodeValue(nodeResponse,"server");
  }
 else {
    message=ParserUtils.getNodeValue(nodeResponse,"message");
  }
}
 

/** 
 * Parses input stream as RSS feed. It is the responsibility of the caller to close the RSS feed input stream.
 * @param feed RSS 2.0 feed input stream
 * @return in-memory representation of RSS feed
 * @throws RSSFault if an unrecoverable parse error occurs
 */
public RSSFeed parse(InputStream feed){
  try {
    final SAXParserFactory factory=SAXParserFactory.newInstance();
    factory.setFeature("http://xml.org/sax/features/namespaces",false);
    factory.setFeature("http://xml.org/sax/features/namespace-prefixes",true);
    final SAXParser parser=factory.newSAXParser();
    return parse(parser,feed);
  }
 catch (  ParserConfigurationException e) {
    throw new RSSFault(e);
  }
catch (  SAXException e) {
    throw new RSSFault(e);
  }
catch (  IOException e) {
    throw new RSSFault(e);
  }
}
 

/** 
 * Constructor (for reading)
 * @param fn file name of Xml file to read
 * @throws CoreException
 */
public SupXml(String fn) throws CoreException {
  this.pathName=FilenameUtils.addSeparator(FilenameUtils.getParent(fn));
  this.title=FilenameUtils.removeExtension(FilenameUtils.getName(fn));
  SAXParserFactory factory=SAXParserFactory.newInstance();
  SAXParser saxParser;
  try {
    saxParser=factory.newSAXParser();
    DefaultHandler handler=new XmlHandler();
    saxParser.parse(new File(fn),handler);
  }
 catch (  ParserConfigurationException e) {
    throw new CoreException(e.getMessage());
  }
catch (  SAXException e) {
    throw new CoreException(e.getMessage());
  }
catch (  IOException e) {
    throw new CoreException(e.getMessage());
  }
  logger.trace("\nDetected " + numForcedFrames + " forced captions.\n");
}