/*
 * Licensed to the Apache Software Foundation (ASF) under one
 * or more contributor license agreements.  See the NOTICE file
 * distributed with this work for additional information
 * regarding copyright ownership.  The ASF licenses this file
 * to you under the Apache License, Version 2.0 (the
 * "License"); you may not use this file except in compliance
 * with the License.  You may obtain a copy of the License at
 *
 *     http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

package org.apache.jena.rdfxml.xmlinput;

import java.io.* ;

import junit.framework.Test ;
import junit.framework.TestCase ;
import junit.framework.TestSuite ;
import org.apache.jena.ontology.OntDocumentManager ;
import org.apache.jena.rdf.model.Model ;
import org.apache.jena.rdf.model.ModelFactory ;
import org.apache.jena.rdf.model.RDFErrorHandler ;
import org.apache.jena.rdf.model.RDFReaderI ;
import org.apache.jena.vocabulary.RDF ;
import org.junit.Assert ;
import org.slf4j.Logger ;
import org.slf4j.LoggerFactory ;
import org.xml.sax.SAXException ;

/** Additional ARP tests */
@SuppressWarnings("deprecation")
public class TestsARP extends TestCase implements RDFErrorHandler, ARPErrorNumbers {

	static private Logger logger = LoggerFactory.getLogger(TestsARP.class);
	static public Test suite() {
		TestSuite suite = new TestSuite(TestsARP.class);

		suite.addTest(TestErrorMsg.suite());

        suite.addTest(TestPropEltErrorMsg.suite());
		suite.addTest(TestScope.suite());
		suite.addTest(TestSuiteException.suite());

        suite.addTest(new TestsMoreDOM2RDF("testDOMwithARP"));

        suite.addTestSuite(TestsARP.class) ;
//		suite.addTest(new ARPTests2("testIcu"));
//		suite.addTest(new ARPTests2("testLatin1"));
//		suite.addTest(new ARPTests2("testIcu2"));
//		suite.addTest(new ARPTests2("testEncodingMismatch1"));
//		suite.addTest(new ARPTests2("testEncodingMismatch2"));
//		suite.addTest(new ARPTests2("testEncodingMismatch3"));
//		suite.addTest(new ARPTests2("testNullBaseParamOK"));
//		suite.addTest(new ARPTests2("testNullBaseParamError"));
//		suite.addTest(new ARPTests2("testEmptyBaseParamOK"));
//		suite.addTest(new ARPTests2("testEmptyBaseParamError"));
//      suite.addTest(new ARPTests2("testBadBaseParamOK"));
//      suite.addTest(new ARPTests2("testBadBaseParamError"));
//      suite.addTest(new ARPTests2("testRelativeBaseParamOK"));
//      suite.addTest(new ARPTests2("testRelativeBaseParamError"));
//      suite.addTest(new ARPTests2("testBaseTruncation"));
//		suite.addTest(new ARPTests2("testWineDefaultNS"));
//		suite.addTest(new ARPTests2("testInterrupt"));
//      suite.addTest(new ARPTests2("testDanBriXMLBase"));
//		suite.addTest(new ARPTests2("testToString"));

//for (int i=0; i< 20; i++ ) {
		//suite.addTest(new ARPTests2("testTokenGarbage1"));
		//suite.addTest(new ARPTests2("testTokenGarbage2"));
//		suite.addTest(new ARPTests2("testTokenGarbage1"));
//		suite.addTest(new ARPTests2("testTokenGarbage2"));
//		suite.addTest(new ARPTests2("testTokenGarbage1"));
//		suite.addTest(new ARPTests2("testTokenGarbage2"));
//}
		return suite;
	}

	public TestsARP(String s) {
		super(s);
	}

	protected Model createMemModel() {
		return ModelFactory.createDefaultModel();
	}

	@Override
    public void setUp() {
		// ensure the ont doc manager is in a consistent state
		OntDocumentManager.getInstance().reset(true);
	}

   public void testXMLProperty() throws IOException {
        Model m = createMemModel();
        InputStream in = new FileInputStream("testing/arp/xml-prop.rdf");
        m.read(in, "");
        assertEquals(1, m.size());
    }


	public void testWineDefaultNS() throws IOException {
		testWineNS(createMemModel());
		testWineNS(ModelFactory.createOntologyModel());
	}

    private void testWineNS(Model m) throws FileNotFoundException, IOException {
        try (InputStream in = new FileInputStream("testing/arp/xmlns/wine.rdf")) {
            m.read(in, "") ;
            assertEquals("http://www.w3.org/TR/2003/CR-owl-guide-20030818/wine#", m.getNsPrefixURI("")) ;
        }
    }

    // JENA-1537
    // Character encoding checks removed due to lack of support in JDK XML parser APIs.
//	public void testLatin1() throws IOException {
//		Model m = createMemModel();
//		RDFReader rdr = m.getReader();
//		InputStream r = new FileInputStream(
//				"testing/arp/i18n/latin1.rdf");
//
//		rdr.setErrorHandler(this);
//		expected = new int[] { WARN_NONCANONICAL_IANA_NAME };
//		rdr.read(m, r, "http://example.org/");
//		checkExpected();
//	}

	// JENA-1537
    // Character encoding checks removed due to lack of support in JDK XML parser APIs.

//	public void testARPMacRoman() throws IOException {
//		Model m = createMemModel();
//		RDFReader rdr = m.getReader();
//		InputStream r = new FileInputStream(
//				"testing/arp/i18n/macroman.rdf");
//
//		rdr.setErrorHandler(this);
//		expected = new int[] { WARN_UNSUPPORTED_ENCODING, WARN_NON_IANA_ENCODING };
//		expected[Charset.isSupported("MacRoman")?0:1]=0;
////		 Only one of the warnings is expected, which depends on Java version
//
//		rdr.read(m, r, "http://example.org/");
//		checkExpected();
//	}
//	public void testARPMacArabic() throws IOException {
//		Model m = createMemModel();
//		RDFReader rdr = m.getReader();
//		InputStream r = new FileInputStream(
//				"testing/arp/i18n/arabic-macarabic.rdf");
//
//		rdr.setErrorHandler(this);
//		expected = new int[] { WARN_UNSUPPORTED_ENCODING, WARN_NON_IANA_ENCODING };
//		expected[Charset.isSupported("MacArabic")?0:1]=0;
////		 Only one of the warnings is expected, which depends on Java version
//		rdr.read(m, r, "http://example.org/");
//		checkExpected();
//	}
//
//
//	public void testEncodingMismatch1() throws IOException {
//		Model m = createMemModel();
//		RDFReader rdr = m.getReader();
//		try ( FileReader r = new FileReader("testing/wg/rdfms-syntax-incomplete/test001.rdf") ) {
//		    if (r.getEncoding().startsWith("UTF")) {
//		        //logger.warn("Encoding mismatch tests not executed on platform with default UTF encoding.");
//		        r.close() ;
//		        return;
//		    }
//		    rdr.setErrorHandler(this);
//		    expected = new int[] { WARN_ENCODING_MISMATCH };
//		    rdr.read(m, r, "http://example.org/");
//		    //System.err.println(m.size() + " triples read.");
//		    checkExpected();
//		}
//	}

	public void testIcu() throws IOException {
//	  "\u0b87\u0ba8\u0bcd\u0ba4\u0bbf\u0baf\u0bbe"
//	    Normalizer.  isNormalized(
//	            "\u0bcd\u0ba4\u0bbf\u0baf\u0bbe"
//	            ,Normalizer.NFC,0);

	    Model m = createMemModel();
	    RDFReaderI rdr = new RDFXMLReader();
	    try(FileInputStream r = new FileInputStream("testing/arp/i18n/icubug.rdf")){
	        rdr.setErrorHandler(this);
	        expected = new int[] { WARN_STRING_COMPOSING_CHAR  };
	        rdr.read(m, r, "http://example.org/");
	    }
	    checkExpected();
	}
	public void testIcu2() throws IOException {
//		  "\u0b87\u0ba8\u0bcd\u0ba4\u0bbf\u0baf\u0bbe"
//		    Normalizer.  isNormalized(
//		            "\u0bcd\u0ba4\u0bbf\u0baf\u0bbe"
//		            ,Normalizer.NFC,0);

	    Model m = createMemModel();
	    RDFReaderI rdr = new RDFXMLReader();
	    try(FileInputStream r = new FileInputStream("testing/arp/i18n/icubugtwo.rdf")) {
	        rdr.setErrorHandler(this);
	        expected = new int[] { WARN_STRING_NOT_NORMAL_FORM_C };
	        rdr.read(m, r, "http://example.org/");
	    }
	    checkExpected();
	}

	static class ToStringStatementHandler implements StatementHandler {
		String obj;

		String subj;

		@Override
        public void statement(AResource sub, AResource pred, ALiteral lit) {
			// System.out.println("(" + sub + ", " + pred + ", " + lit + ")");
			subj = sub.toString();
		}

		@Override
        public void statement(AResource sub, AResource pred, AResource ob) {
			//  System.out.println("(" + sub + ", " + pred + ", " + ob + ")");
			obj = ob.toString();
		}

	}

	public void testToString() throws IOException, SAXException {

		String testcase = "<rdf:RDF xmlns:music=\"http://www.kanzaki.com/ns/music#\" "
				+ "  xmlns:rdf=\"http://www.w3.org/1999/02/22-rdf-syntax-ns#\"> "
				+ "<rdf:Description> "
				+ "  <music:performs rdf:nodeID=\"p1\"/> "
				+ "</rdf:Description> "
				+ "<rdf:Description rdf:nodeID=\"p1\"> "
				+ "  <music:opus>op.26</music:opus> "
				+ "</rdf:Description> "
				+ "</rdf:RDF>";

		ARP parser = new ARP();
		ToStringStatementHandler tssh = new ToStringStatementHandler();
		parser.getHandlers().setStatementHandler(tssh);
		parser.load(new StringReader(testcase), "http://www.example.com");
		assertEquals(tssh.subj, tssh.obj);
	}

    // JENA-1537
    // Character encoding checks removed due to lack of support in JDK XML parser APIs.

//	public void testEncodingMismatch2() throws IOException {
//		FileReader r = new FileReader(
//				"testing/wg/rdf-charmod-literals/test001.rdf");
//
//		subTestEncodingMismatch2(r);
//	}
//
//	public void testEncodingMismatch3() throws IOException {
//	    try ( FileInputStream fin = new FileInputStream("testing/wg/rdf-charmod-literals/test001.rdf") ;
//	          InputStreamReader r = new InputStreamReader(fin,"MS950")) {
//	        subTestEncodingMismatch2(r);
//	    }catch (java.io.UnsupportedEncodingException e) {
//	        System.err
//	        .println("WARNING: Encoding mismatch3 test not executed on platform without MS950 encoding.");
//	        return;
//	    }
//	}
//
//	private void subTestEncodingMismatch2(InputStreamReader r) {
//		if (r.getEncoding().startsWith("UTF")) {
//			// see above for warning message.
//			return;
//		}
//		Model m = createMemModel();
//		RDFReader rdr = m.getReader();
//
//		rdr.setErrorHandler(this);
//		expected = new int[] { WARN_ENCODING_MISMATCH, ERR_ENCODING_MISMATCH };
//		rdr.read(m, r, "http://example.org/");
//
//		checkExpected();
//	}

	public void testNullBaseParamOK() throws IOException {
		Model m = createMemModel();
		Model m1 = createMemModel();
		RDFReaderI rdr = new RDFXMLReader();
		try (FileInputStream fin = new FileInputStream("testing/wg/rdfms-identity-anon-resources/test001.rdf") ) {
		    rdr.setErrorHandler(this);
		    expected = new int[] {};
		    rdr.read(m, fin, "http://example.org/");
		}
		try (FileInputStream fin = new FileInputStream("testing/wg/rdfms-identity-anon-resources/test001.rdf")) {
		    rdr.read(m1, fin, null);
		}
		assertTrue("Base URI should have no effect.", m.isIsomorphicWith(m1));
		checkExpected();
	}
    public void testDanBriXMLBase() throws IOException {
        Model m = createMemModel();
        Model m1 = createMemModel();
        try (FileInputStream fin = new FileInputStream("testing/arp/xmlbase/danbri.rdf")) {
            m.read(fin,"http://wrong.example.org/");
        }
        try (FileInputStream fin = new FileInputStream("testing/arp/xmlbase/danbri.nt")) {
            m1.read(fin,"http://wrong.example.org/","N-TRIPLE");
        }
        assertTrue("Dan Bri nested XML Base.", m.isIsomorphicWith(m1));
    }

	public void testNullBaseParamError() throws IOException {
		Model m = createMemModel();
		RDFReaderI rdr = new RDFXMLReader();
		try (FileInputStream fin = new FileInputStream("testing/wg/rdfms-difference-between-ID-and-about/test1.rdf")) {
			rdr.setErrorHandler(this);
			expected = new int[] { ERR_RESOLVING_URI_AGAINST_NULL_BASE, WARN_RELATIVE_URI};
			rdr.read(m, fin, null);
		}
		checkExpected();
	}

	public void testEmptyBaseParamOK() throws IOException {
	    Model m = createMemModel();
	    Model m1 = createMemModel();
	    RDFReaderI rdr = new RDFXMLReader();
	    try (FileInputStream fin = new FileInputStream("testing/wg/rdfms-identity-anon-resources/test001.rdf")){
	        rdr.setErrorHandler(this);
	        expected = new int[] {};
	        rdr.read(m, fin, "http://example.org/");
	    }
	    try (FileInputStream fin = new FileInputStream("testing/wg/rdfms-identity-anon-resources/test001.rdf")) {
	        rdr.read(m1, fin, "");
	    }
	    assertTrue("Empty base URI should have no effect.[" + m1.toString()
	               + "]", m.isIsomorphicWith(m1));
	    checkExpected();
	}

	/** Create an {@link RDFXMLReader} that does not reolve the initial XML base. */
	private static RDFXMLReader baseTestReader() {
	    return new RDFXMLReader(false);
	}

	public void testEmptyBaseParamError() throws IOException {
		Model m = createMemModel();
		RDFReaderI rdr = baseTestReader();
		try (FileInputStream fin = new FileInputStream("testing/wg/rdfms-difference-between-ID-and-about/test1.rdf")) {
		    rdr.setErrorHandler(this);
		    expected = new int[] { WARN_RESOLVING_URI_AGAINST_EMPTY_BASE};
		    rdr.read(m, fin, "");
		}
		Model m1 = createMemModel();
		m1.createResource("#foo").addProperty(RDF.value, "abc");
		assertTrue("Empty base URI should produce relative URI.["
				+ m.toString() + "]", m.isIsomorphicWith(m1));
		checkExpected();
	}

    // Becomes an IRI error.
//    public void testBadBaseParamError() throws IOException {
//        Model m = createMemModel();
//        RDFReaderI rdr = baseTestReader();
//        try (FileInputStream fin = new FileInputStream("testing/wg/rdfms-difference-between-ID-and-about/test1.rdf")) {
//            rdr.setErrorHandler(this);
//            expected = new int[] { WARN_MALFORMED_URI,
//                WARN_MALFORMED_URI,
//                //        WARN_RELATIVE_URI, ERR_RESOLVING_AGAINST_MALFORMED_BASE};
//                ERR_RESOLVING_AGAINST_MALFORMED_BASE};
//            rdr.read(m, fin, "http://jjc^3.org/demo.mp3");
//        }
//        Model m1 = createMemModel();
//        assertTrue("Bad base URI should produce no URIs in model.["
//                + m.toString() + "]", m.isIsomorphicWith(m1));
//        checkExpected();
//    }
//
//    public void testBadBaseParamOK() throws IOException {
//        Model m = createMemModel();
//        Model m1 = createMemModel();
//        RDFReaderI rdr = baseTestReader();
//        try (FileInputStream fin = new FileInputStream("testing/wg/rdfms-identity-anon-resources/test001.rdf")) {
//
//            rdr.setErrorHandler(this);
//            expected = new int[] { WARN_MALFORMED_URI };
//            rdr.read(m, fin, "http://jjc^3.org/demo.mp3");
//        }
//        try(FileInputStream fin = new FileInputStream("testing/wg/rdfms-identity-anon-resources/test001.rdf")) {
//            rdr.read(m1, fin, "");
//        }
//        assertTrue("Bad base URI should have no effect on model.[" + m1.toString()
//                   + "]", m.isIsomorphicWith(m1));
//        checkExpected();
//    }

    public void testRelativeBaseParamError() throws IOException {
        Model m = createMemModel();
        RDFReaderI rdr = baseTestReader();
        try (FileInputStream fin = new FileInputStream("testing/wg/rdfms-difference-between-ID-and-about/test1.rdf")) {
            rdr.setErrorHandler(this);
            expected = new int[] { WARN_RELATIVE_URI, WARN_RELATIVE_URI,  ERR_RESOLVING_AGAINST_RELATIVE_BASE, };
            rdr.setProperty("ERR_RESOLVING_AGAINST_RELATIVE_BASE","EM_WARNING");
            rdr.read(m, fin, "foo/");
        }
        Model m1 = createMemModel();
        m1.createResource("foo/#foo").addProperty(RDF.value, "abc");
        assertTrue("Relative base URI should produce relative URIs in model (when error suppressed).["
                + m.toString() + "]", m.isIsomorphicWith(m1));
        checkExpected();
    }

    public void testRelativeBaseParamOK() throws IOException {
        Model m = createMemModel();
        Model m1 = createMemModel();
        RDFReaderI rdr = baseTestReader();
        try (FileInputStream fin = new FileInputStream("testing/wg/rdfms-identity-anon-resources/test001.rdf")) {
            rdr.setErrorHandler(this);
            expected = new int[] { WARN_RELATIVE_URI };
            rdr.read(m, fin, "foo/");
        }

        try (FileInputStream fin = new FileInputStream("testing/wg/rdfms-identity-anon-resources/test001.rdf")) {
            rdr.read(m1, fin, "");
        }
        assertTrue("Bad base URI should have no effect on model.[" + m1.toString()
                   + "]", m.isIsomorphicWith(m1));
        checkExpected();
    }

	static String RDF_TEXT = "<?xml version=\"1.0\" ?>\n" +
    "<rdf:RDF xmlns:rdf=\"http://www.w3.org/1999/02/22-rdf-syntax-ns#\">\n" +
    " <rdf:Description>\n" +
    "  <rdf:value rdf:resource=\"http://example/some_random_text\"/>\n" +
    "  <rdf:value rdf:resource=\"relative_random_text\"/>\n" +
    " </rdf:Description>\n" +
    "</rdf:RDF>\n";

	public void testIRIRules_1()
	{
        Model model = ModelFactory.createDefaultModel() ;
        model.read(new StringReader(RDF_TEXT), "http://example/") ;
	}

	// No longer applies. The testing used to have spaces in the rdf:resource but that is handled differently now.
//	public void testIRIRules_2()
//	{
//        Model model = ModelFactory.createDefaultModel() ;
//	    IRIFactory f = ARPOptions.getIRIFactoryGlobal() ;
//	    try {
//	        ARPOptions.setIRIFactoryGlobal(IRIFactory.iriImplementation()) ;
//	        RDFReaderI r = new RDFXMLReader();
//            expected = new int[] { WARN_MALFORMED_URI , WARN_MALFORMED_URI };
//	        r.setErrorHandler(this);
//	        r.read(model, new StringReader(RDF_TEXT), "http://example/") ;
//	    } finally { ARPOptions.setIRIFactoryGlobal(f) ; }
//        checkExpected() ;
//	}

    public void testIRIRules_2a()
    {
        Model model = ModelFactory.createDefaultModel() ;
        RDFReaderI r = new RDFXMLReader();
        r.setErrorHandler(this);
        expected = new int[] { };
        model.read(new StringReader(RDF_TEXT), "http://example/") ;
        checkExpected() ;
    }

    // No longer applies.
//    public void testIRIRules_3()
//    {
//        Model model = ModelFactory.createDefaultModel() ;
//        RDFReaderI r = new RDFXMLReader();
//        r.setErrorHandler(this);
//        expected = new int[] { WARN_MALFORMED_URI , WARN_MALFORMED_URI };
//        r.setProperty("iri-rules", "strict") ;
//        r.read(model, new StringReader(RDF_TEXT), "http://example/") ;
//        checkExpected() ;
//    }

    // No longer applies.
//    public void testIRIRules_4()
//    {
//        Model model = ModelFactory.createDefaultModel() ;
//        RDFReaderI r = new RDFXMLReader();
//        r.setProperty("iri-rules", "strict") ;
//        r.setProperty( "WARN_MALFORMED_URI", ARPErrorNumbers.EM_ERROR) ;
//        r.setErrorHandler(this);
//        expected = new int[] { WARN_MALFORMED_URI , WARN_MALFORMED_URI };   // Errors actually continue.
//        r.read(model, new StringReader(RDF_TEXT), "http://example/") ;
//        checkExpected() ;
//    }

    public void testNTripleEscaping() {
    	String data[][] = {
    			{ "foo", "foo" },
    			{ "fooZX", "fooZ5aX" },
    			{ "Andr\u00E9", "AndrZc3Za9" },
    			{ "a.b", "aZ2eb" },
    			{ "a:b", "aZ3ab" },
    	};
    	for (String p[] : data ) {
//    		System.err.println(NTriple.escapeNTriple(p[0]));
    		Assert.assertEquals("NTriple escaping", p[1],NTriple.escapeNTriple(p[0]) );
    	}


    }

	private void checkExpected() {
        for ( int anExpected : expected )
        {
            if ( anExpected != 0 )
            {
                fail( "Expected error: " + ParseException.errorCodeName( anExpected ) + " but it did not occur." );
            }
        }
	}

	@Override
    public void warning(Exception e) {
		error(0, e);
	}

	@Override
    public void error(Exception e) {
		error(1, e);
	}

	@Override
    public void fatalError(Exception e) {
		error(2, e);
	}

	private void error(int level, Exception e) {
		//System.err.println(e.getMessage());
		if (e instanceof ParseException) {
			int eCode = ((ParseException) e).getErrorNumber();
			onError(level, eCode);
		} else {
			fail("Not expecting an Exception: " + e.getMessage());
		}
	}

	private int expected[];

	private void println(String m) {
		logger.error(m);
	}

	void onError(int level, int num) {
		for (int i = 0; i < expected.length; i++)
			if (expected[i] == num) {
				expected[i] = 0;
				return;
			}
		String msg = "Parser reports unexpected "
				+ WGTestSuite.errorLevelName[level] + ": "
				+ ParseException.errorCodeName(num);
		println(msg);
		fail(msg);
	}

//	private void tokenGarbage(String file) {
//		try {
//			Token.COUNT = true;
//			Token.COUNTTEST = true;
//			Token.reinitHighTide();
//			NTriple.main(new String[] { "-t", file });
//			//System.err.println("["+Token.highTide+"]");
//			assertTrue("Too many tokens used: "+ Token.highTide,
//					Token.highTide<2000);
//		} finally {
//			Token.COUNT = false;
//			Token.COUNTTEST = false;
//		}
//	}
//
//	public void testTokenGarbage1() {
//		tokenGarbage("testing/ontology/owl/Wine/wine.owl");
//	}
//
//	public void testTokenGarbage2() {
//
//		tokenGarbage("testing/arp/gc/someWordNet.rdf");
//	}
}
