[WIP] REST Based Catalog

api/src/main/java/org/apache/iceberg/exceptions/NotAuthorizedException.java

@@ -0,0 +1,37 @@
+/*
+ * 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.iceberg.exceptions;
+
+/**
+ * Exception raised when an attempt to perform an operation fails due to invalid permissions.
+ */
+public class NotAuthorizedException extends RuntimeException {
+  public NotAuthorizedException(String message) {
+    super(message);
+  }
+
+  public NotAuthorizedException(String message, Object... args) {
+    super(String.format(message, args));
+  }
+
+  public NotAuthorizedException(String message, Throwable cause) {
+    super(message, cause);
+  }
+}

api/src/main/java/org/apache/iceberg/rest/CreateNamespaceRequest.java

@@ -0,0 +1,101 @@
+/*
+ * 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.iceberg.rest;
+
+import java.util.Map;
+import org.apache.iceberg.catalog.Namespace;
+import org.apache.iceberg.relocated.com.google.common.base.Preconditions;
+import org.apache.iceberg.relocated.com.google.common.collect.ImmutableList;
+import org.apache.iceberg.relocated.com.google.common.collect.ImmutableMap;
+
+/**
+ * Represents a REST request to create a namespace / database.
+ *
+ * Possible example POST body (outer format object possibly only used on Response):
+ *   { "data": { "namespace": ["prod", "accounting"], properties: {} }}
+ */
+public class CreateNamespaceRequest {
+
+  private Namespace namespace;
+  private Map<String, String> properties;
+
+  private CreateNamespaceRequest() {
+  }
+
+  private CreateNamespaceRequest(String[] namespaceLevels, Map<String, String> properties) {
+    this.namespace = Namespace.of(namespaceLevels);
+    this.properties = properties;
+  }
+
+  public Namespace getNamespace() {
+    return namespace;
+  }
+
+  public void setNamespace(Namespace namespace) {
+    this.namespace = namespace;
+  }
+
+  public Map<String, String> getProperties() {
+    return properties;
+  }
+
+  public void setProperties(Map<String, String> properties) {
+    this.properties = properties;
+  }
+
+  public static Builder builder() {
+    return new Builder();
+  }
+
+  public static class Builder {
+    private ImmutableList.Builder<String> namespaceBuilder;
+    private final ImmutableMap.Builder<String, String> propertiesBuilder;
+
+    public Builder() {
+      this.namespaceBuilder = ImmutableList.builder();
+      this.propertiesBuilder = ImmutableMap.builder();
+    }
+
+    public Builder withNamespace(Namespace namespace) {
+      this.namespaceBuilder.add(namespace.levels());
+      return this;
+    }
+
+    public Builder withProperties(Map<String, String> properties) {
+      if (properties != null) {
+        propertiesBuilder.putAll(properties);
+      }
+      return this;
+    }
+
+    public Builder withProperty(String key, String value) {
+      propertiesBuilder.put(key, value);
+      return this;
+    }
+
+    public CreateNamespaceRequest build() {
+      String[] namespaceLevels = namespaceBuilder.build().toArray(new String[0]);
+      Preconditions.checkState(namespaceLevels.length > 0,
+          "Cannot create a CreateNamespaceRequest with an empty namespace.");
+      return new CreateNamespaceRequest(namespaceLevels, propertiesBuilder.build());
+
+    }
+  }
+}

api/src/main/java/org/apache/iceberg/rest/CreateNamespaceResponse.java

@@ -0,0 +1,120 @@
+/*
+ * 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.iceberg.rest;
+
+import java.util.Map;
+import org.apache.iceberg.catalog.Namespace;
+import org.apache.iceberg.relocated.com.google.common.base.Preconditions;
+
+/**
+ * Represents a REST response to a create a namespace / database request.
+ *
+ * The properties returned will include all the user provided properties from the
+ * request, as well as any server-side added properties.
+ *
+ * Example server-side added properties could include things such as "created-at"
+ * or "owner".
+ *
+ * Presently, the JSON looks as follows:
+ *  { "namespace": "ns1.ns2.ns3", "properties": { "owner": "hank", "created-at": "1425744000000" } }
+ *
+ * Eventually, the idea is to wrap responses in IcebergHttpResponse so that it has a more standardized
+ * structure, including the possibility of richer metadata on errors, such as tracing telemetry or follw
+ * up user instruction.
+ *
+ * {
+ *   "error": { },
+ *   "data": {
+ *     "namespace": "ns1.ns2.ns3",
+ *     "properties": {
+ *       "owner": "hank",
+ *       "created-at": "1425744000000"
+ *     }
+ *   }
+ * }
+ *
+ * For an error response, we'll see something like the following:
+ *
+ * {
+ *   "data": { },
+ *   "error": {
+ *     "message": "Namespace already exists",
+ *     "type": "AlreadyExistsException",
+ *     "code": 40901
+ *   }
+ * }
+ */
+public class CreateNamespaceResponse {
+  private Namespace namespace;
+  private Map<String, String> properties;
+
+  private CreateNamespaceResponse() {
+  }
+
+  private CreateNamespaceResponse(Namespace namespace, Map<String, String> properties) {
+    this.namespace = namespace;
+    this.properties = properties;
+  }
+
+  public Namespace getNamespace() {
+    return namespace;
+  }
+
+  public void setNamespace(Namespace namespace) {
+    this.namespace = namespace;
+  }
+
+  public Map<String, String> getProperties() {
+    return properties;
+  }
+
+  public void setProperties(Map<String, String> properties) {
+    this.properties = properties;
+  }
+
+  public static Builder builder() {
+    return new Builder();
+  }
+
+  public static class Builder {
+    private Namespace namespace;
+    private Map<String, String> properties;
+
+    private Builder() {
+
+    }
+
+    public Builder withNamespace(Namespace ns) {
+      this.namespace = ns;
+      return this;
+    }
+
+    public Builder withProperties(Map<String, String> props) {
+      this.properties = props;
+      return this;
+    }
+
+    public CreateNamespaceResponse build() {
+      Preconditions.checkArgument(namespace != null && !namespace.isEmpty(),
+          "Cannot create a CreateNamespaceResponse with a null or empty namespace");
+      return new CreateNamespaceResponse(namespace, properties);
+    }
+  }
+}

build.gradle

@@ -120,6 +120,9 @@ subprojects {
     testImplementation 'org.slf4j:slf4j-simple'
     testImplementation 'org.mockito:mockito-core'
     testImplementation 'org.assertj:assertj-core'
+    testImplementation 'org.mock-server:mockserver-junit-jupiter'
+    testImplementation 'org.mock-server:mockserver-netty'
+    testImplementation 'org.mock-server:mockserver-client-java'
   }
 
   test {
@@ -221,6 +224,8 @@ project(':iceberg-core') {
       exclude group: 'org.slf4j', module: 'slf4j-log4j12'
     }
 
+    implementation 'org.apache.httpcomponents.client5:httpclient5'
+
     testImplementation "org.xerial:sqlite-jdbc"
     testImplementation project(path: ':iceberg-api', configuration: 'testArtifacts')
   }