Snapshot of https://github.com/vepo/cdi-tutorial/blob/master/src/main/java/io/vepo/access/user/UserRepository.java

UserRepository.java

package io.vepo.access.user;

import static com.mongodb.client.model.Filters.and;
import static com.mongodb.client.model.Filters.eq;

import java.util.ArrayList;
import java.util.List;
import java.util.Optional;

import javax.enterprise.context.Dependent;
import javax.inject.Inject;

import com.mongodb.client.MongoCollection;

@Dependent
public class UserRepository {
	@Inject
	private MongoCollection<User> collection;

	public List<User> findAll() {
		return collection.find().into(new ArrayList<>());
	}

	public User create(User user) {
		collection.insertOne(user);
		return user;
	}

	public Optional<User> findByUsernameAndPassword(String username, String password) {
		return Optional
				.ofNullable(this.collection.find(and(eq("username", username), eq("password", password))).first());
	}

	public Optional<User> findByUsername(String username) {
		return Optional.ofNullable(this.collection.find(eq("username", username)).first());
	}

	public Optional<User> delete(String username) {
		return Optional.ofNullable(this.collection.findOneAndDelete(eq("username", username)));
	}
}