jena-fuseki2/jena-fuseki-webapp/src/test/java/org/apache/jena/fuseki/TestHttpOp.java

/**
 * 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.fuseki;

import static org.apache.jena.fuseki.ServerCtl.serviceGSP;
import static org.apache.jena.fuseki.ServerCtl.serviceQuery;
import static org.apache.jena.fuseki.ServerCtl.serviceUpdate;
import static org.apache.jena.fuseki.ServerCtl.urlRoot;
import static org.apache.jena.fuseki.test.FusekiTest.execWithHttpException;
import static org.apache.jena.fuseki.test.FusekiTest.expect404;
import static org.apache.jena.riot.web.HttpOp.initialDefaultHttpClient;

import org.apache.http.client.HttpClient;
import org.apache.jena.atlas.lib.IRILib;
import org.apache.jena.atlas.web.TypedInputStream;
import org.apache.jena.riot.WebContent;
import org.apache.jena.riot.web.HttpOp;
import org.apache.jena.sparql.engine.http.Params;
import org.apache.jena.web.HttpSC;
import org.junit.Test;

// This a mixture of testing HttpOp and testing basic operation of the SPARQL server
// especially error cases and unusual usage that the higher level APIs don't use.
public class TestHttpOp extends AbstractFusekiTest {

    static String pingURL           = urlRoot()+"$/ping";
    static String gspServiceURL     = serviceGSP();
    static String defaultGraphURL   = serviceGSP()+"?default";
    static String namedGraphURL     = serviceGSP()+"?graph=http://example/g";
    static String queryURL          = serviceQuery();
    static String updateURL         = serviceUpdate();

    static String simpleQuery = queryURL+"?query="+IRILib.encodeUriComponent("ASK{}");

    @Test public void correctDefaultResetBehavior() {
        HttpClient defaultClient = HttpOp.getDefaultHttpClient();
        HttpOp.setDefaultHttpClient(null);
        assertSame("Failed to reset to initial client!", initialDefaultHttpClient, HttpOp.getDefaultHttpClient());
        HttpOp.setDefaultHttpClient(defaultClient);
    }

    // Basic operations

    @Test public void httpGet_01() {
        assertNotNull(HttpOp.execHttpGetString(pingURL));
    }

    @Test
    public void httpGet_02() {
        expect404(() -> HttpOp.execHttpGet(urlRoot() + "does-not-exist"));
    }

    @Test public void httpGet_03() {
        assertNotNull(HttpOp.execHttpGetString(pingURL));
    }

    @Test public void httpGet_04() {
        String x = HttpOp.execHttpGetString(urlRoot()+"does-not-exist");
        assertNull(x);
    }

    @Test public void httpGet_05() {
        assertNotNull(HttpOp.execHttpGetString(simpleQuery));
    }

    // SPARQL Query

    @Test public void queryGet_01() {
        assertNotNull(HttpOp.execHttpGetString(simpleQuery));
    }

    public void queryGet_02() {
        // No query.
        execWithHttpException(HttpSC.BAD_REQUEST_400, () -> HttpOp.execHttpGetString(queryURL + "?query="));
    }

    public void httpPost_01() {
        execWithHttpException(HttpSC.UNSUPPORTED_MEDIA_TYPE_415,
                () -> HttpOp.execHttpPost(queryURL, "ASK{}", "text/plain"));
    }

    public void httpPost_02() {
        execWithHttpException(HttpSC.UNSUPPORTED_MEDIA_TYPE_415,
                () -> HttpOp.execHttpPost(queryURL, "ASK{}", WebContent.contentTypeSPARQLQuery));
    }

    public void httpPost_03() {
        execWithHttpException(HttpSC.UNSUPPORTED_MEDIA_TYPE_415,
                () -> HttpOp.execHttpPost(queryURL, "ASK{}", WebContent.contentTypeOctets));
    }

    @Test public void httpPost_04() {
        Params params = new Params().addParam("query", "ASK{}");
        try ( TypedInputStream in = HttpOp.execHttpPostFormStream(queryURL, params, WebContent.contentTypeResultsJSON) ) {}
    }

    public void httpPost_05() {
        Params params = new Params().addParam("query", "ASK{}");
        // Query to Update
        execWithHttpException(HttpSC.BAD_REQUEST_400,
                () -> HttpOp.execHttpPostFormStream(updateURL, params, WebContent.contentTypeResultsJSON));
    }

    @Test public void httpPost_06() {
        Params params = new Params().addParam("request", "CLEAR ALL");
        HttpOp.execHttpPostForm(updateURL, params);
    }

    // GSP
    @Test public void gsp_01() {
        String x = HttpOp.execHttpGetString(defaultGraphURL, "application/rdf+xml");
        assertTrue(x.contains("</"));
        assertTrue(x.contains(":RDF"));
    }

    @Test public void gsp_02() {
        String x = HttpOp.execHttpGetString(defaultGraphURL, "application/n-triples");
        assertTrue(x.isEmpty());
    }

    static String graphString = "@prefix : <http://example/> . :s :p :o .";
    static String datasetString = "@prefix : <http://example/> . :s :p :o . :g { :sg :pg :og }";

    @Test public void gsp_03() {
        HttpOp.execHttpPut(defaultGraphURL, WebContent.contentTypeTurtle, graphString);
    }

    @Test public void gsp_04() {
        HttpOp.execHttpPut(defaultGraphURL, WebContent.contentTypeTurtle, graphString);
        String s1 = HttpOp.execHttpGetString(defaultGraphURL, WebContent.contentTypeNTriples);
        assertFalse(s1.isEmpty());
        HttpOp.execHttpDelete(defaultGraphURL);
        String s2 = HttpOp.execHttpGetString(defaultGraphURL, WebContent.contentTypeNTriples);
        assertTrue(s2.isEmpty());
    }

    @Test public void gsp_05() {
        HttpOp.execHttpDelete(defaultGraphURL);

        HttpOp.execHttpPost(defaultGraphURL, WebContent.contentTypeTurtle, graphString);
        String s1 = HttpOp.execHttpGetString(defaultGraphURL, WebContent.contentTypeNTriples);
        assertFalse(s1.isEmpty());
        HttpOp.execHttpDelete(defaultGraphURL);
        String s2 = HttpOp.execHttpGetString(defaultGraphURL, WebContent.contentTypeNTriples);
        assertTrue(s2.isEmpty());
    }

    @Test public void gsp_06() {
        HttpOp.execHttpPost(namedGraphURL, WebContent.contentTypeTurtle, graphString);
        String s1 = HttpOp.execHttpGetString(namedGraphURL, WebContent.contentTypeNTriples);
        assertFalse(s1.isEmpty());
        
        String s2 = HttpOp.execHttpGetString(defaultGraphURL, WebContent.contentTypeNTriples);
        assertTrue(s2.isEmpty());
        
        HttpOp.execHttpDelete(namedGraphURL);
        String s3 = HttpOp.execHttpGetString(defaultGraphURL, WebContent.contentTypeNTriples);
        assertTrue(s3.isEmpty());

        expect404(()->HttpOp.execHttpDelete(namedGraphURL));
    }

    @Test public void gsp_10() {
        HttpOp.execHttpDelete(defaultGraphURL);
    }

    // Extended GSP - no ?default, no ?graph acts on the datasets as a whole.
    @Test public void gsp_12() {
        execWithHttpException(HttpSC.METHOD_NOT_ALLOWED_405, () -> HttpOp.execHttpDelete(gspServiceURL));
    }

    @Test public void gsp_20() {
        String s1 = HttpOp.execHttpGetString(gspServiceURL, WebContent.contentTypeNQuads);
        assertNotNull("Got 404 (via null)", s1);
        assertTrue(s1.isEmpty());

        HttpOp.execHttpPost(gspServiceURL, WebContent.contentTypeTriG, datasetString);
        String s2 = HttpOp.execHttpGetString(gspServiceURL, WebContent.contentTypeNQuads);
        assertFalse(s2.isEmpty());

        String s4 = HttpOp.execHttpGetString(defaultGraphURL, WebContent.contentTypeNTriples);
        assertFalse(s4.isEmpty());
    }
}