Skip to content

Add support for Couchbase's role based access #16389

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Closed
wants to merge 9 commits into from
Closed

Add support for Couchbase's role based access #16389

Show file tree
Hide file tree
Changes from 7 commits
Commits
Show all changes
9 commits
Select commit Hold shift + click to select a range
7f81cc1
#16388 couchbase 5.x and later auth
Mar 29, 2019
91c798b
#16388 javadoc added
Mar 29, 2019
67270fd
#16388 checkstyle fixs
Mar 29, 2019
74f8f57
#16388 rolebaseacces properties added for new couchbase client
Mar 30, 2019
e0aeb65
#16388 review fixs
Apr 9, 2019
e772ad0
Merge remote-tracking branch 'upstream/master' into feature/16388
Apr 9, 2019
f098f02
#16388 null check fix
Apr 9, 2019
38df10b
#16388 fix openbucket on RBAC
Apr 10, 2019
8e19ebd
Merge remote-tracking branch 'upstream/master' into feature/16388
Apr 10, 2019
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
13 changes: 12 additions & 1 deletion ...rc/main/java/org/springframework/boot/autoconfigure/couchbase/CouchbaseConfiguration.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -57,7 +57,14 @@ public DefaultCouchbaseEnvironment couchbaseEnvironment() {
@Bean
@Primary
public Cluster couchbaseCluster() {
return CouchbaseCluster.create(couchbaseEnvironment(), determineBootstrapHosts());
CouchbaseCluster couchbaseCluster = CouchbaseCluster
.create(couchbaseEnvironment(), determineBootstrapHosts());
if (this.properties.getUsername().isEmpty()
|| this.properties.getPassword().isEmpty()) {
return couchbaseCluster;
}
return couchbaseCluster.authenticate(this.properties.getUsername(),
this.properties.getPassword());
}

/**
Expand All @@ -79,6 +86,10 @@ public ClusterInfo couchbaseClusterInfo() {
@Bean
@Primary
public Bucket couchbaseClient() {
if (this.properties.getUsername().isEmpty()
|| this.properties.getPassword().isEmpty()) {
return couchbaseCluster().openBucket(this.properties.getBucket().getName());
Copy link

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

This condition should be inverted. If RBAC username or password are empty we should call the openBucket method that takes a bucket password.

Sorry if I missed this earlier.

Copy link
Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

This condition should be inverted. If RBAC username or password are empty we should call the openBucket method that takes a bucket password.

Sorry if I missed this earlier.

Thanks. I inverted it. 👍

}
return couchbaseCluster().openBucket(this.properties.getBucket().getName(),
this.properties.getBucket().getPassword());
}
Expand Down
27 changes: 26 additions & 1 deletion ...e/src/main/java/org/springframework/boot/autoconfigure/couchbase/CouchbaseProperties.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/

package org.springframework.boot.autoconfigure.couchbase;

import java.time.Duration;
Expand Down Expand Up @@ -42,6 +41,16 @@ public class CouchbaseProperties {

private final Env env = new Env();

/**
* Password of the cluster on RBA(role base access).
*/
private String password = "";

/**
* Username of the cluster on RBA(role base access).
*/
private String username = "";

public List<String> getBootstrapHosts() {
return this.bootstrapHosts;
}
Expand All @@ -58,6 +67,22 @@ public Env getEnv() {
return this.env;
}

public String getPassword() {
return this.password;
}

public void setPassword(String password) {
this.password = password;
}

public String getUsername() {
return this.username;
}

public void setUsername(String username) {
this.username = username;
}

public static class Bucket {

/**
Expand Down