diff --git a/.gitignore b/.gitignore index 7cc9f3f2..c4f45f5f 100644 --- a/.gitignore +++ b/.gitignore @@ -7,3 +7,5 @@ workbench.xmi target build +.DS_Store +bin/ diff --git a/islandora-http-client/build.gradle b/islandora-http-client/build.gradle new file mode 100644 index 00000000..35ec2d5a --- /dev/null +++ b/islandora-http-client/build.gradle @@ -0,0 +1,29 @@ +apply plugin: 'osgi' + +description = 'Islandora CLAW HTTP Client' + +dependencies { + compile group: 'org.apache.httpcomponents', name: 'httpclient', version: '4.5.3' + + testCompile group: 'junit', name: 'junit', version:'4.12' +} + +jar { + manifest { + description project.description + docURL project.docURL + vendor project.vendor + license project.license + + instruction 'Import-Package', 'org.apache.http.client,' + + defaultOsgiImports + instruction 'Export-Package', 'ca.islandora.indexing.http.client' + } +} + +artifacts { + archives (file('build/cfg/main/ca.islandora.alpaca.http.client.cfg')) { + classifier 'configuration' + type 'cfg' + } +} diff --git a/islandora-http-client/src/main/cfg/ca.islandora.alpaca.http.client.cfg b/islandora-http-client/src/main/cfg/ca.islandora.alpaca.http.client.cfg new file mode 100644 index 00000000..06cf1bb0 --- /dev/null +++ b/islandora-http-client/src/main/cfg/ca.islandora.alpaca.http.client.cfg @@ -0,0 +1,3 @@ +# The static token value to be used for authentication by the HttpClient available as an OSGi service for +# other services to use against the Fedora repository +token.value=islandora diff --git a/islandora-http-client/src/main/java/ca/islandora/alpaca/http/client/StaticTokenRequestInterceptor.java b/islandora-http-client/src/main/java/ca/islandora/alpaca/http/client/StaticTokenRequestInterceptor.java new file mode 100644 index 00000000..4cf3f6d8 --- /dev/null +++ b/islandora-http-client/src/main/java/ca/islandora/alpaca/http/client/StaticTokenRequestInterceptor.java @@ -0,0 +1,61 @@ +/* + * Licensed to Islandora Foundation under one or more contributor license + * agreements. See the NOTICE file distributed with this work for additional + * information regarding copyright ownership. + * + * The Islandora Foundation licenses this file to you under the MIT License. + * You may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * https://opensource.org/licenses/MIT + * + * 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 ca.islandora.alpaca.http.client; + +import static java.util.Objects.requireNonNull; + +import org.apache.http.Header; +import org.apache.http.HttpRequest; +import org.apache.http.HttpRequestInterceptor; +import org.apache.http.client.HttpClient; +import org.apache.http.impl.client.HttpClientBuilder; +import org.apache.http.message.BasicHeader; +import org.apache.http.protocol.HttpContext; + +public class StaticTokenRequestInterceptor implements HttpRequestInterceptor { + + public static final String AUTH_HEADER = "Authorization"; + + private Header header; + + public StaticTokenRequestInterceptor() { + } + + public StaticTokenRequestInterceptor(String token) { + this.header = makeHeader(token); + } + + public void setToken(String token) { + this.header = makeHeader(token); + } + + private Header makeHeader(String token) { + return new BasicHeader(AUTH_HEADER, "Bearer " + requireNonNull(token, "Token must not be null!")); + } + + @Override + public void process(HttpRequest request, HttpContext context) { + // we do not inject if auth headers present + if (request.getFirstHeader(AUTH_HEADER)== null) request.addHeader(header); + } + + public static HttpClient defaultClient(StaticTokenRequestInterceptor interceptor) { + return HttpClientBuilder.create().addInterceptorFirst(interceptor).build(); + } +} diff --git a/islandora-http-client/src/main/resources/OSGI-INF/blueprint/blueprint.xml b/islandora-http-client/src/main/resources/OSGI-INF/blueprint/blueprint.xml new file mode 100644 index 00000000..20946b78 --- /dev/null +++ b/islandora-http-client/src/main/resources/OSGI-INF/blueprint/blueprint.xml @@ -0,0 +1,26 @@ + + + + + + + + + + + + + + + + + + + + + diff --git a/islandora-http-client/src/test/java/ca/islandora/alpaca/http/client/StaticTokenRequestInterceptorTest.java b/islandora-http-client/src/test/java/ca/islandora/alpaca/http/client/StaticTokenRequestInterceptorTest.java new file mode 100644 index 00000000..c439b1ee --- /dev/null +++ b/islandora-http-client/src/test/java/ca/islandora/alpaca/http/client/StaticTokenRequestInterceptorTest.java @@ -0,0 +1,51 @@ +/* + * Licensed to Islandora Foundation under one or more contributor license + * agreements. See the NOTICE file distributed with this work for additional + * information regarding copyright ownership. + * + * The Islandora Foundation licenses this file to you under the MIT License. + * You may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * https://opensource.org/licenses/MIT + * + * 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 ca.islandora.alpaca.http.client; + +import static ca.islandora.alpaca.http.client.StaticTokenRequestInterceptor.AUTH_HEADER; + +import org.apache.http.Header; +import org.apache.http.HttpRequest; +import org.apache.http.client.methods.HttpGet; +import org.junit.Assert; +import org.junit.Test; + +public class StaticTokenRequestInterceptorTest extends Assert { + + @Test + public void shouldInjectHeaderWhenNoAuthHeadersPresent() { + StaticTokenRequestInterceptor testInterceptor = new StaticTokenRequestInterceptor("testToken"); + HttpRequest request = new HttpGet(); + testInterceptor.process(request, null); + Header[] authHeaders = request.getHeaders(AUTH_HEADER); + assertEquals("Should only be one auth header!", 1, authHeaders.length); + assertEquals("Wrong value for header!", "Bearer testToken", authHeaders[0].getValue()); + } + + @Test + public void shouldNotInjectHeaderWhenAuthHeadersPresent() { + StaticTokenRequestInterceptor testInterceptor = new StaticTokenRequestInterceptor("testToken"); + HttpRequest request = new HttpGet(); + request.addHeader(AUTH_HEADER, "fake header"); + testInterceptor.process(request, null); + Header[] authHeaders = request.getHeaders(AUTH_HEADER); + assertEquals("Should only be one auth header!", 1, authHeaders.length); + assertEquals("Wrong value for header!", "fake header", authHeaders[0].getValue()); + } +} diff --git a/settings.gradle b/settings.gradle index e05f19d0..abfbcf98 100644 --- a/settings.gradle +++ b/settings.gradle @@ -1,7 +1,9 @@ include ':islandora-karaf' include ':islandora-indexing-triplestore' include ':islandora-connector-broadcast' +include ':islandora-http-client' project(':islandora-karaf').projectDir = "$rootDir/karaf" as File project(':islandora-indexing-triplestore').projectDir = "$rootDir/islandora-indexing-triplestore" as File project(':islandora-connector-broadcast').projectDir = "$rootDir/islandora-connector-broadcast" as File +project(':islandora-http-client').projectDir = "$rootDir/islandora-http-client" as File