| /* |
| * 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.polygene.library.rest.admin; |
| |
| import java.io.IOException; |
| import java.nio.charset.StandardCharsets; |
| import java.util.ArrayList; |
| import java.util.HashMap; |
| import java.util.List; |
| import java.util.Map; |
| import org.apache.http.NameValuePair; |
| import org.apache.http.client.entity.UrlEncodedFormEntity; |
| import org.apache.http.client.methods.CloseableHttpResponse; |
| import org.apache.http.client.methods.HttpDelete; |
| import org.apache.http.client.methods.HttpGet; |
| import org.apache.http.client.methods.HttpPost; |
| import org.apache.http.impl.client.CloseableHttpClient; |
| import org.apache.http.impl.client.HttpClients; |
| import org.apache.http.message.BasicNameValuePair; |
| import org.apache.http.util.EntityUtils; |
| import org.apache.polygene.api.association.Association; |
| import org.apache.polygene.api.common.Optional; |
| import org.apache.polygene.api.common.Visibility; |
| import org.apache.polygene.api.entity.EntityBuilder; |
| import org.apache.polygene.api.entity.EntityComposite; |
| import org.apache.polygene.api.identity.StringIdentity; |
| import org.apache.polygene.api.injection.scope.Service; |
| import org.apache.polygene.api.property.Property; |
| import org.apache.polygene.api.structure.ApplicationDescriptor; |
| import org.apache.polygene.api.unitofwork.NoSuchEntityException; |
| import org.apache.polygene.api.unitofwork.UnitOfWork; |
| import org.apache.polygene.bootstrap.ApplicationAssemblerAdapter; |
| import org.apache.polygene.bootstrap.Assembler; |
| import org.apache.polygene.bootstrap.AssemblyException; |
| import org.apache.polygene.bootstrap.ModuleAssembly; |
| import org.apache.polygene.index.rdf.assembly.RdfMemoryStoreAssembler; |
| import org.apache.polygene.test.AbstractPolygeneTest; |
| import org.apache.polygene.test.EntityTestAssembler; |
| import org.apache.polygene.test.util.FreePortFinder; |
| import org.junit.Before; |
| import org.junit.Test; |
| |
| import static org.hamcrest.CoreMatchers.anyOf; |
| import static org.hamcrest.CoreMatchers.equalTo; |
| import static org.junit.Assert.assertEquals; |
| import static org.junit.Assert.assertNull; |
| import static org.junit.Assert.assertThat; |
| |
| public class RestTest extends AbstractPolygeneTest |
| { |
| private static final int ADMIN_PORT = FreePortFinder.findFreePortOnLoopback(); |
| |
| @Override |
| protected ApplicationDescriptor newApplicationModel() |
| throws AssemblyException |
| { |
| return polygene.newApplicationModel( new ApplicationAssemblerAdapter( |
| new Assembler[][][] |
| { |
| { |
| { |
| RestTest.this, |
| new RestAssembler(), |
| new RdfMemoryStoreAssembler() |
| } |
| } |
| } ) |
| {} // subclassing ApplicationAssemblerAdapter |
| ); |
| } |
| |
| @Override |
| public void assemble( ModuleAssembly module ) |
| throws AssemblyException |
| { |
| ModuleAssembly config = module.layer().module( "config" ); |
| new EntityTestAssembler().assemble( config ); |
| config.configurations( RestServerConfiguration.class ).visibleIn( Visibility.layer ); |
| config.forMixin( RestServerConfiguration.class ).declareDefaults().port().set( ADMIN_PORT ); |
| |
| module.objects( RestTest.class, RestTester.class ); |
| module.entities( PersonEntity.class ); |
| module.services( RestServerComposite.class ).instantiateOnStartup(); |
| new EntityTestAssembler().assemble( module ); |
| } |
| |
| @Override |
| @Before |
| public void setUp() |
| throws Exception |
| { |
| super.setUp(); |
| UnitOfWork uow = unitOfWorkFactory.newUnitOfWork(); |
| try |
| { |
| EntityBuilder<PersonEntity> builder1 = uow.newEntityBuilder( PersonEntity.class, StringIdentity.identity( "P2" ) ); |
| PersonEntity maryDoe = builder1.instance(); |
| maryDoe.firstname().set( "Mary" ); |
| maryDoe.lastname().set( "Doe" ); |
| maryDoe = builder1.newInstance(); |
| |
| EntityBuilder<PersonEntity> builder2 = uow.newEntityBuilder( PersonEntity.class, StringIdentity.identity( "P1" ) ); |
| PersonEntity joeDoe = builder2.instance(); |
| joeDoe.firstname().set( "Joe" ); |
| joeDoe.lastname().set( "Doe" ); |
| joeDoe.mother().set( maryDoe ); |
| builder2.newInstance(); |
| |
| uow.complete(); |
| } |
| finally |
| { |
| uow.discard(); |
| } |
| } |
| |
| @Test |
| public void givenAnIdentityWhenExecutingGetCommandThenExpectTheCorrectRdf() |
| throws Exception |
| { |
| RestTester restTester = objectFactory.newObject( RestTester.class ); |
| String rdf = restTester.getEntity( "P1" ); |
| // System.out.println( rdf.replaceAll( "\n", "\\\\n" ).replaceAll( "\"", "\\\\\"" ) ); |
| assertThat( "Incorrect RDF produced", rdf, anyOf( |
| // Open JDK 8 & Valid |
| equalTo( "<?xml version=\"1.0\" encoding=\"UTF-8\"?>\n<rdf:RDF\n\txmlns:polygene=\"http://polygene.apache.org/rdf/model/1.0/\"\n\txmlns:rdf=\"http://www.w3.org/1999/02/22-rdf-syntax-ns#\"\n\txmlns:rdfs=\"http://www.w3.org/2000/01/rdf-schema#\">\n<org.apache.polygene.library.rest.admin.RestTest-PersonEntity xmlns=\"urn:polygene:type:\" rdf:about=\"urn:polygene:entity:P1\">\n\t<lastname xmlns=\"urn:polygene:type:org.apache.polygene.library.rest.admin.RestTest-Person#\">Doe</lastname>\n\t<firstname xmlns=\"urn:polygene:type:org.apache.polygene.library.rest.admin.RestTest-Person#\">Joe</firstname>\n\t<identity xmlns=\"urn:polygene:type:org.apache.polygene.api.identity.HasIdentity#\">P1</identity>\n\t<mother xmlns=\"urn:polygene:type:org.apache.polygene.library.rest.admin.RestTest-Person#\" rdf:resource=\"urn:polygene:entity:P2\"/>\n</org.apache.polygene.library.rest.admin.RestTest-PersonEntity>\n\n</rdf:RDF>" ), |
| equalTo( "<?xml version=\"1.0\" encoding=\"UTF-8\"?>\n<rdf:RDF\n\txmlns:polygene=\"http://polygene.apache.org/rdf/model/1.0/\"\n\txmlns:rdf=\"http://www.w3.org/1999/02/22-rdf-syntax-ns#\"\n\txmlns:rdfs=\"http://www.w3.org/2000/01/rdf-schema#\">\n<org.apache.polygene.library.rest.admin.RestTest-PersonEntity xmlns=\"urn:polygene:type:\" rdf:about=\"urn:polygene:entity:P1\">\n\t<identity xmlns=\"urn:polygene:type:org.apache.polygene.api.identity.HasIdentity#\">P1</identity>\n\t<firstname xmlns=\"urn:polygene:type:org.apache.polygene.library.rest.admin.RestTest-Person#\">Joe</firstname>\n\t<lastname xmlns=\"urn:polygene:type:org.apache.polygene.library.rest.admin.RestTest-Person#\">Doe</lastname>\n\t<mother xmlns=\"urn:polygene:type:org.apache.polygene.library.rest.admin.RestTest-Person#\" rdf:resource=\"urn:polygene:entity:P2\"/>\n</org.apache.polygene.library.rest.admin.RestTest-PersonEntity>\n\n</rdf:RDF>" ), |
| // Sun JDK 6 / Oracle JDK 7 & Valid |
| equalTo( "<?xml version=\"1.0\" encoding=\"UTF-8\"?>\n<rdf:RDF\n\txmlns:polygene=\"http://polygene.apache.org/rdf/model/1.0/\"\n\txmlns:rdf=\"http://www.w3.org/1999/02/22-rdf-syntax-ns#\"\n\txmlns:rdfs=\"http://www.w3.org/2000/01/rdf-schema#\">\n<org.apache.polygene.library.rest.admin.RestTest-PersonEntity xmlns=\"urn:polygene:type:\" rdf:about=\"urn:polygene:entity:P1\">\n\t<firstname xmlns=\"urn:polygene:type:org.apache.polygene.library.rest.admin.RestTest-Person#\">Joe</firstname>\n\t<lastname xmlns=\"urn:polygene:type:org.apache.polygene.library.rest.admin.RestTest-Person#\">Doe</lastname>\n\t<identity xmlns=\"urn:polygene:type:org.apache.polygene.api.identity.HasIdentity#\">P1</identity>\n\t<mother xmlns=\"urn:polygene:type:org.apache.polygene.library.rest.admin.RestTest-Person#\" rdf:resource=\"urn:polygene:entity:P2\"/>\n</org.apache.polygene.library.rest.admin.RestTest-PersonEntity>\n\n</rdf:RDF>" ), |
| // IBM JDK 6 & Valid |
| equalTo( "<?xml version=\"1.0\" encoding=\"UTF-8\"?>\n<rdf:RDF\n\txmlns:polygene=\"http://polygene.apache.org/rdf/model/1.0/\"\n\txmlns:rdf=\"http://www.w3.org/1999/02/22-rdf-syntax-ns#\"\n\txmlns:rdfs=\"http://www.w3.org/2000/01/rdf-schema#\">\n<org.apache.polygene.library.rest.admin.RestTest-PersonEntity xmlns=\"urn:polygene:type:\" rdf:about=\"urn:polygene:entity:P1\">\n\t<identity xmlns=\"urn:polygene:type:org.apache.polygene.api.identity.HasIdentity#\">P1</identity>\n\t<lastname xmlns=\"urn:polygene:type:org.apache.polygene.library.rest.admin.RestTest-Person#\">Doe</lastname>\n\t<firstname xmlns=\"urn:polygene:type:org.apache.polygene.library.rest.admin.RestTest-Person#\">Joe</firstname>\n\t<mother xmlns=\"urn:polygene:type:org.apache.polygene.library.rest.admin.RestTest-Person#\" rdf:resource=\"urn:polygene:entity:P2\"/>\n</org.apache.polygene.library.rest.admin.RestTest-PersonEntity>\n\n</rdf:RDF>" ) ) ); |
| } |
| |
| @Test |
| public void givenExistingIdentityWhenExecutingPutCommandThenNewValuesInEntity() |
| throws Throwable |
| { |
| RestTester restTester = objectFactory.newObject( RestTester.class ); |
| Map<String, String> properties = new HashMap<String, String>(); |
| properties.put( "reference", "P1" ); |
| properties.put( "firstname", "Jack" ); |
| properties.put( "lastname", "Doe" ); |
| restTester.putEntity( "P1", properties ); |
| UnitOfWork work = unitOfWorkFactory.newUnitOfWork(); |
| try |
| { |
| PersonEntity entity = work.get( PersonEntity.class, StringIdentity.identity( "P1" ) ); |
| assertEquals( "FirstName not changed.", "Jack", entity.firstname().get() ); |
| assertEquals( "LastName not changed.", "Doe", entity.lastname().get() ); |
| work.complete(); |
| } |
| finally |
| { |
| work.discard(); |
| } |
| } |
| |
| @Test |
| public void givenExistingIdentityWhenExecutingDeleteCommandThenEntityIsRemoved() |
| throws Throwable |
| { |
| RestTester restTester = objectFactory.newObject( RestTester.class ); |
| restTester.deleteEntity( "P1" ); |
| UnitOfWork work = unitOfWorkFactory.newUnitOfWork(); |
| try |
| { |
| PersonEntity entity = null; |
| try |
| { |
| entity = work.get( PersonEntity.class, StringIdentity.identity( "P1" ) ); |
| } |
| catch( NoSuchEntityException expected ) |
| { |
| // expected |
| } |
| assertNull( "Entity not removed.", entity ); |
| work.complete(); |
| } |
| finally |
| { |
| work.discard(); |
| } |
| } |
| |
| @Test |
| public void givenExistingEntitiesWhenExecutingGetCommandThenExpectTheCorrectRdf() |
| throws Exception |
| { |
| final RestTester restTester = objectFactory.newObject( RestTester.class ); |
| final String result = restTester.getEntities().replace( "\r", "" ); |
| assertThat( |
| "Returned RDF", result, |
| anyOf( |
| equalTo( "<?xml version=\"1.0\" encoding=\"UTF-8\"?>\n<rdf:RDF\n\txmlns=\"urn:polygene:\"\n\txmlns:polygene=\"http://polygene.apache.org/rdf/model/1.0/\"\n\txmlns:rdf=\"http://www.w3.org/1999/02/22-rdf-syntax-ns#\"\n\txmlns:rdfs=\"http://www.w3.org/2000/01/rdf-schema#\">\n<polygene:entity rdf:about=\"/entity/P2.rdf\"/>\n<polygene:entity rdf:about=\"/entity/P1.rdf\"/>\n</rdf:RDF>\n" ), |
| equalTo( "<?xml version=\"1.0\" encoding=\"UTF-8\" standalone=\\\"no\\\"?>\n<rdf:RDF\n\txmlns=\"urn:polygene:\"\n\txmlns:polygene=\"http://polygene.apache.org/rdf/model/1.0/\"\n\txmlns:rdf=\"http://www.w3.org/1999/02/22-rdf-syntax-ns#\"\n\txmlns:rdfs=\"http://www.w3.org/2000/01/rdf-schema#\">\n<polygene:entity rdf:about=\"/entity/P2.rdf\"/>\n<polygene:entity rdf:about=\"/entity/P1.rdf\"/>\n</rdf:RDF>\n" ), |
| equalTo( "<?xml version=\"1.0\" encoding=\"UTF-8\"?>\n<rdf:RDF\n\txmlns=\"urn:polygene:\"\n\txmlns:polygene=\"http://polygene.apache.org/rdf/model/1.0/\"\n\txmlns:rdf=\"http://www.w3.org/1999/02/22-rdf-syntax-ns#\"\n\txmlns:rdfs=\"http://www.w3.org/2000/01/rdf-schema#\">\n<polygene:entity rdf:about=\"/entity/P1.rdf\"/>\n<polygene:entity rdf:about=\"/entity/P2.rdf\"/>\n</rdf:RDF>\n" ), |
| equalTo( "<?xml version=\"1.0\" encoding=\"UTF-8\" standalone=\\\"no\\\"?>\n<rdf:RDF\n\txmlns=\"urn:polygene:\"\n\txmlns:polygene=\"http://polygene.apache.org/rdf/model/1.0/\"\n\txmlns:rdf=\"http://www.w3.org/1999/02/22-rdf-syntax-ns#\"\n\txmlns:rdfs=\"http://www.w3.org/2000/01/rdf-schema#\">\n<polygene:entity rdf:about=\"/entity/P1.rdf\"/>\n<polygene:entity rdf:about=\"/entity/P2.rdf\"/>\n</rdf:RDF>\n" ) ) ); |
| } |
| |
| public static class RestTester |
| { |
| |
| @Service |
| private RestServer server; |
| |
| public String getEntity( String identity ) |
| throws IOException |
| { |
| CloseableHttpClient client = HttpClients.createDefault(); |
| HttpGet method = new HttpGet( "http://localhost:" + ADMIN_PORT + "/entity/" + identity + ".rdf" ); |
| method.addHeader( "Accept", "application/rdf+xml" ); |
| try( CloseableHttpResponse response = client.execute( method ) ) |
| { |
| if( response.getStatusLine().getStatusCode() != 200 ) |
| { |
| throw new RuntimeException( "EntityResource returned status: " + response.getStatusLine() ); |
| } |
| return EntityUtils.toString( response.getEntity(), StandardCharsets.UTF_8 ); |
| } |
| } |
| |
| public void putEntity( String identity, Map<String, String> params ) |
| throws IOException |
| { |
| CloseableHttpClient client = HttpClients.createDefault(); |
| HttpPost method = new HttpPost( "http://localhost:" + ADMIN_PORT + "/entity/" + identity ); |
| List<NameValuePair> parameters = new ArrayList<>(); |
| for( Map.Entry<String, String> entry : params.entrySet() ) |
| { |
| parameters.add( new BasicNameValuePair( entry.getKey(), entry.getValue() ) ); |
| } |
| method.setEntity( new UrlEncodedFormEntity( parameters ) ); |
| try( CloseableHttpResponse response = client.execute( method ) ) |
| { |
| if( response.getStatusLine().getStatusCode() != 205 ) |
| { |
| throw new RuntimeException( "EntityResource returned status: " + response.getStatusLine() ); |
| } |
| } |
| } |
| |
| public void deleteEntity( String identity ) |
| throws IOException |
| { |
| CloseableHttpClient client = HttpClients.createDefault(); |
| HttpDelete method = new HttpDelete( "http://localhost:" + ADMIN_PORT + "/entity/" + identity ); |
| try( CloseableHttpResponse response = client.execute( method ) ) |
| { |
| if( response.getStatusLine().getStatusCode() != 204 ) |
| { |
| throw new RuntimeException( "EntityResource returned status: " + response.getStatusLine() ); |
| } |
| } |
| } |
| |
| public String getEntities() |
| throws IOException |
| { |
| CloseableHttpClient client = HttpClients.createDefault(); |
| HttpGet method = new HttpGet( "http://localhost:" + ADMIN_PORT + "/entity.rdf" ); |
| method.addHeader( "Accept", "application/rdf+xml" ); |
| try( CloseableHttpResponse response = client.execute( method ) ) |
| { |
| if( response.getStatusLine().getStatusCode() != 200 ) |
| { |
| throw new RuntimeException( "EntityResource returned status: " + response.getStatusLine() ); |
| } |
| return EntityUtils.toString( response.getEntity(), StandardCharsets.UTF_8 ); |
| } |
| } |
| } |
| |
| public interface PersonEntity |
| extends EntityComposite, Person |
| { |
| } |
| |
| public interface Person |
| { |
| |
| Property<String> firstname(); |
| |
| Property<String> lastname(); |
| |
| @Optional |
| Association<Person> mother(); |
| } |
| } |
