iSharkFly-Docs
/
java-tutorials
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Merge pull request #11769 from sazzer/BAEL-5229 

BAEL-5229: Code for Fauna article
This commit is contained in:
Loredana Crusoveanu 2022-03-07 19:43:11 +02:00 committed by GitHub
parent a578bb86f6 f4c03153a1
commit 91791ea3f6
13 changed files with 361 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
persistence-modules/fauna/.gitignore vendored Normal file
View File

@ -0,0 +1 @@
/application.properties

56
persistence-modules/fauna/pom.xml Normal file
View File

@ -0,0 +1,56 @@
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.6.2</version>
<relativePath/> <!-- lookup parent from repository -->
</parent>
<groupId>com.baeldung</groupId>
<artifactId>fauna-blog</artifactId>
<version>0.0.1-SNAPSHOT</version>
<name>fauna-blog</name>
<description>Blogging Service built with FaunaDB</description>
<properties>
<java.version>17</java.version>
</properties>
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-security</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>com.faunadb</groupId>
<artifactId>faunadb-java</artifactId>
<version>4.2.0</version>
<scope>compile</scope>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.springframework.security</groupId>
<artifactId>spring-security-test</artifactId>
<scope>test</scope>
</dependency>
</dependencies>
<build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
</plugin>
</plugins>
</build>
</project>

13
persistence-modules/fauna/src/main/java/com/baeldung/faunablog/FaunaBlogApplication.java Normal file
View File

@ -0,0 +1,13 @@
package com.baeldung.faunablog;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
@SpringBootApplication
public class FaunaBlogApplication {
public static void main(String[] args) {
SpringApplication.run(FaunaBlogApplication.class, args);
}
}

25
persistence-modules/fauna/src/main/java/com/baeldung/faunablog/FaunaConfiguration.java Normal file
View File

@ -0,0 +1,25 @@
package com.baeldung.faunablog;
import com.faunadb.client.FaunaClient;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import java.net.MalformedURLException;
@Configuration
class FaunaConfiguration {
@Value("https://db.${fauna.region}.fauna.com/")
private String faunaUrl;
@Value("${fauna.secret}")
private String faunaSecret;
@Bean
FaunaClient getFaunaClient() throws MalformedURLException {
return FaunaClient.builder()
.withEndpoint(faunaUrl)
.withSecret(faunaSecret)
.build();
}
}

35
persistence-modules/fauna/src/main/java/com/baeldung/faunablog/WebSecurityConfiguration.java Normal file
View File

@ -0,0 +1,35 @@
package com.baeldung.faunablog;
import com.baeldung.faunablog.users.FaunaUserDetailsService;
import com.faunadb.client.FaunaClient;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.security.config.annotation.method.configuration.EnableGlobalMethodSecurity;
import org.springframework.security.config.annotation.web.builders.HttpSecurity;
import org.springframework.security.config.annotation.web.configuration.EnableWebSecurity;
import org.springframework.security.config.annotation.web.configuration.WebSecurityConfigurerAdapter;
import org.springframework.security.core.userdetails.UserDetailsService;
@Configuration
@EnableWebSecurity
@EnableGlobalMethodSecurity(prePostEnabled = true)
public class WebSecurityConfiguration extends WebSecurityConfigurerAdapter {
@Autowired
private FaunaClient faunaClient;
@Override
protected void configure(HttpSecurity http) throws Exception {
http.csrf().disable();
http.authorizeRequests()
.antMatchers("/**").permitAll()
.and().httpBasic();
}
@Bean
@Override
public UserDetailsService userDetailsService() {
return new FaunaUserDetailsService(faunaClient);
}
}

3
persistence-modules/fauna/src/main/java/com/baeldung/faunablog/posts/Author.java Normal file
View File

@ -0,0 +1,3 @@
package com.baeldung.faunablog.posts;
public record Author(String username, String name) {}

5
persistence-modules/fauna/src/main/java/com/baeldung/faunablog/posts/Post.java Normal file
View File

@ -0,0 +1,5 @@
package com.baeldung.faunablog.posts;
import java.time.Instant;
public record Post(String id, String title, String content, Author author, Instant created, Long version) {}

50
persistence-modules/fauna/src/main/java/com/baeldung/faunablog/posts/PostsController.java Normal file
View File

@ -0,0 +1,50 @@
package com.baeldung.faunablog.posts;
import com.faunadb.client.errors.NotFoundException;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.HttpStatus;
import org.springframework.security.access.prepost.PreAuthorize;
import org.springframework.security.core.context.SecurityContextHolder;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.server.ResponseStatusException;
import java.util.List;
import java.util.concurrent.ExecutionException;
@RestController
@RequestMapping("/posts")
public class PostsController {
@Autowired
private PostsService postsService;
@GetMapping
public List<Post> listPosts(@RequestParam(value = "author", required = false) String author) throws ExecutionException, InterruptedException {
return author == null ? postsService.getAllPosts() : postsService.getAuthorPosts("graham");
}
@GetMapping("/{id}")
public Post getPost(@PathVariable("id") String id, @RequestParam(value = "before", required = false) Long before)
throws ExecutionException, InterruptedException {
return postsService.getPost(id, before);
}
@PostMapping
@ResponseStatus(HttpStatus.NO_CONTENT)
@PreAuthorize("isAuthenticated()")
public void createPost(@RequestBody UpdatedPost post) throws ExecutionException, InterruptedException {
String name = SecurityContextHolder.getContext().getAuthentication().getName();
postsService.createPost(name, post.title(), post.content());
}
@PutMapping("/{id}")
@ResponseStatus(HttpStatus.NO_CONTENT)
@PreAuthorize("isAuthenticated()")
public void updatePost(@PathVariable("id") String id, @RequestBody UpdatedPost post)
throws ExecutionException, InterruptedException {
postsService.updatePost(id, post.title(), post.content());
}
@ExceptionHandler(NotFoundException.class)
@ResponseStatus(HttpStatus.NOT_FOUND)
public void postNotFound() {}
}

124
persistence-modules/fauna/src/main/java/com/baeldung/faunablog/posts/PostsService.java Normal file
View File

@ -0,0 +1,124 @@
package com.baeldung.faunablog.posts;
import com.faunadb.client.FaunaClient;
import com.faunadb.client.types.Value;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import java.time.Instant;
import java.util.Collection;
import java.util.List;
import java.util.concurrent.ExecutionException;
import java.util.stream.Collectors;
import static com.faunadb.client.query.Language.*;
@Component
public class PostsService {
@Autowired
private FaunaClient faunaClient;
Post getPost(String id, Long before) throws ExecutionException, InterruptedException {
var query = Get(Ref(Collection("posts"), id));
if (before != null) {
query = At(Value(before - 1), query);
}
var postResult= faunaClient.query(
Let(
"post", query
).in(
Obj(
"post", Var("post"),
"author", Get(Select(Arr(Value("data"), Value("authorRef")), Var("post")))
)
)).get();
return parsePost(postResult);
}
List<Post> getAllPosts() throws ExecutionException, InterruptedException {
var postsResult = faunaClient.query(Map(
Paginate(
Join(
Documents(Collection("posts")),
Index("posts_sort_by_created_desc")
)
),
Lambda(
Arr(Value("extra"), Value("ref")),
Obj(
"post", Get(Var("ref")),
"author", Get(Select(Arr(Value("data"), Value("authorRef")), Get(Var("ref"))))
)
)
)).get();
var posts = postsResult.at("data").asCollectionOf(Value.class).get();
return posts.stream().map(this::parsePost).collect(Collectors.toList());
}
List<Post> getAuthorPosts(String author) throws ExecutionException, InterruptedException {
var postsResult = faunaClient.query(Map(
Paginate(
Join(
Match(Index("posts_by_author"), Select(Value("ref"), Get(Match(Index("users_by_username"), Value(author))))),
Index("posts_sort_by_created_desc")
)
),
Lambda(
Arr(Value("extra"), Value("ref")),
Obj(
"post", Get(Var("ref")),
"author", Get(Select(Arr(Value("data"), Value("authorRef")), Get(Var("ref"))))
)
)
)).get();
var posts = postsResult.at("data").asCollectionOf(Value.class).get();
return posts.stream().map(this::parsePost).collect(Collectors.toList());
}
public void createPost(String author, String title, String contents) throws ExecutionException, InterruptedException {
faunaClient.query(
Create(Collection("posts"),
Obj(
"data", Obj(
"title", Value(title),
"contents", Value(contents),
"created", Now(),
"authorRef", Select(Value("ref"), Get(Match(Index("users_by_username"), Value(author)))))
)
)
).get();
}
public void updatePost(String id, String title, String contents) throws ExecutionException, InterruptedException {
faunaClient.query(
Update(Ref(Collection("posts"), id),
Obj(
"data", Obj(
"title", Value(title),
"contents", Value(contents))
)
)
).get();
}
private Post parsePost(Value entry) {
var author = entry.at("author");
var post = entry.at("post");
return new Post(
post.at("ref").to(Value.RefV.class).get().getId(),
post.at("data", "title").to(String.class).get(),
post.at("data", "contents").to(String.class).get(),
new Author(
author.at("data", "username").to(String.class).get(),
author.at("data", "name").to(String.class).get()
),
post.at("data", "created").to(Instant.class).get(),
post.at("ts").to(Long.class).get()
);
}
}

3
persistence-modules/fauna/src/main/java/com/baeldung/faunablog/posts/UpdatedPost.java Normal file
View File

@ -0,0 +1,3 @@
package com.baeldung.faunablog.posts;
public record UpdatedPost(String title, String content) {}

44
persistence-modules/fauna/src/main/java/com/baeldung/faunablog/users/FaunaUserDetailsService.java Normal file
View File

@ -0,0 +1,44 @@
package com.baeldung.faunablog.users;
import com.faunadb.client.FaunaClient;
import com.faunadb.client.types.Value;
import org.springframework.security.core.userdetails.User;
import org.springframework.security.core.userdetails.UserDetails;
import org.springframework.security.core.userdetails.UserDetailsService;
import org.springframework.security.core.userdetails.UsernameNotFoundException;
import java.util.concurrent.ExecutionException;
import static com.faunadb.client.query.Language.*;
public class FaunaUserDetailsService implements UserDetailsService {
private FaunaClient faunaClient;
public FaunaUserDetailsService(FaunaClient faunaClient) {
this.faunaClient = faunaClient;
}
@Override
public UserDetails loadUserByUsername(String username) throws UsernameNotFoundException {
try {
Value user = faunaClient.query(Map(
Paginate(Match(Index("users_by_username"), Value(username))),
Lambda(Value("user"), Get(Var("user")))))
.get();
Value userData = user.at("data").at(0).orNull();
if (userData == null) {
throw new UsernameNotFoundException("User not found");
}
return User.withDefaultPasswordEncoder()
.username(userData.at("data", "username").to(String.class).orNull())
.password(userData.at("data", "password").to(String.class).orNull())
.roles("USER")
.build();
} catch (ExecutionException | InterruptedException e) {
throw new RuntimeException(e);
}
}
}

0
persistence-modules/fauna/src/main/resources/application.properties Normal file
View File

2
pom.xml
View File

@ -1347,6 +1347,7 @@
<module>spring-boot-modules/spring-boot-cassandre</module>
<module>spring-boot-modules/spring-boot-camel</module>
<module>testing-modules/testing-assertions</module>
<module>persistence-modules/fauna</module>
</modules>
</profile>
@ -1409,6 +1410,7 @@
<module>spring-boot-modules/spring-boot-cassandre</module>
<module>spring-boot-modules/spring-boot-camel</module>
<module>testing-modules/testing-assertions</module>
<module>persistence-modules/fauna</module>
</modules>
</profile>
</profiles>