timjonesdev

FROM mongo:4.0

# files used to initialize the database
COPY ./init-db.d/ /docker-entrypoint-initdb.d

# add this command to a js file in the init directory
# formatted on newlines for better readability
RUN echo "rs.initiate(
  {
    _id: 'rs0', 

timjonesdev

com.mongodb.MongoCommandException: 
Command failed with error 40573 (Location40573): 
'The $changeStream stage is only supported on replica sets' on server localhost:27017. 
The full response is: 
{ 
  "ok" : 0.0, 
  "errmsg" : "The $changeStream stage is only supported on replica sets", 
  "code" : 40573, 
  "codeName" : "Location40573" 
}

timjonesdev

FROM mongo:4.0

COPY init.js /init.js

timjonesdev

# this assumes that your docker-compose.yml file is located in ./docker
up-db-local:	rebuild-mongo
	pushd docker &&\
	docker-compose up -d mongo &&\
	popd

rebuild-mongo:
	pushd docker &&\
	docker-compose build mongo-seed &&\
	docker-compose up mongo-seed &&\

timjonesdev

import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
import org.springframework.data.mongodb.core.mapping.Document;

@Data
@Builder
@AllArgsConstructor
@NoArgsConstructor

timjonesdev

import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
import org.bson.types.ObjectId;
import org.springframework.data.annotation.Id;
import org.springframework.data.mongodb.core.mapping.Document;
import org.springframework.data.mongodb.core.mapping.Field;

import java.util.ArrayList;

timjonesdev

db.teams.insert(
    [
        {
            "_id": ObjectId("5d0c18c190d2b33ae629aaa7"),
            "name": "HingleMcCringleberry",
            "players": [
                {"name": "Nick Chubb", "score": 0},
                {"name": "James Conner", "score": 0},
                {"name": "Julio Jones", "score": 0},
                {"name": "Michael Thomas", "score": 0}

timjonesdev

import dev.timjones.reactive.data.model.Team;
import org.bson.types.ObjectId;
import org.springframework.data.mongodb.repository.Query;
import org.springframework.data.mongodb.repository.ReactiveMongoRepository;
import reactor.core.publisher.Mono;

public interface TeamRepository extends ReactiveMongoRepository<Team, ObjectId> {

    @Query(value = "{ 'players.name' : ?0 }")
    Mono<Team> findDistinctByPlayerName(String playerName);

timjonesdev

import com.mongodb.reactivestreams.client.MongoClient;
import com.mongodb.reactivestreams.client.MongoClients;
import org.springframework.context.annotation.Bean;
import org.springframework.data.mongodb.config.AbstractReactiveMongoConfiguration;
import org.springframework.data.mongodb.core.ReactiveMongoTemplate;
import org.springframework.data.mongodb.repository.config.EnableReactiveMongoRepositories;

/**
 * Config class to set up necessary components for watching the MongoDB change stream
 */

timjonesdev

    /**
     * Watch for changes to the teams collection
     *
     * @return a subscription to the change stream
     */
    public Flux<Team> watchForTeamCollectionChanges() {
        // set changestream options to watch for any changes to the businesses collection
        ChangeStreamOptions options = ChangeStreamOptions.builder()
                .filter(Aggregation.newAggregation(Team.class,
                        Aggregation.match(