stations.test.flow.yaml

import:
  - stations.flow.yaml

tests:
  examples/citi-bike/test/station-updates:
    - ingest:
        description: Two bikes leave (from Marin & Newport) and arrive at Harborside.
        collection: examples/citi-bike/rides
        documents:
          - bike_id: &bikeA 8675
            begin:
              station: &Marin { id: 3276, name: "Marin Light Rail" }
              timestamp: &ts1 "2020-09-01T09:21:12.3090Z"
            end:
              station: &Harborside { id: 3639, name: "Harborside" }
              timestamp: &ts2 "2020-09-01T13:48:12.3830Z"

          - bike_id: &bikeB 17558
            begin:
              station: &Newport { id: 3202, name: "Newport PATH" }
              timestamp: *ts1
            end:
              station: *Harborside
              timestamp: *ts2

    - verify:
        description: Expect stations reflect the trips.
        collection: examples/citi-bike/stations
        documents:
          - <<: *Newport
            departure: { ride: 1 }
          - <<: *Marin
            departure: { ride: 1 }
          - <<: *Harborside
            arrival: { ride: 2 }
            stable: { add: [*bikeA, *bikeB] }

    - ingest:
        description: Bike A rides to Marin. Bike B is relocated, and rides from Marin to Newport.
        collection: examples/citi-bike/rides
        documents:
          - bike_id: *bikeA
            begin:
              station: *Harborside
              timestamp: &ts3 "2020-09-01T14:33:35.1020Z"
            end:
              station: *Marin
              timestamp: &ts4 "2020-09-01T16:49:30.1610Z"
          - bike_id: *bikeB
            begin:
              station: *Marin
              timestamp: *ts3
            end:
              station: *Newport
              timestamp: *ts4

    - verify:
        description: Expect stations reflect the additional ride and relocation.
        collection: examples/citi-bike/stations
        documents:
          - <<: *Newport
            arrival: { ride: 1 }
            departure: { ride: 1 }
            stable: { add: [*bikeB] }
          - <<: *Marin
            arrival: { ride: 1, move: 1 }
            departure: { ride: 2 }
            stable: { add: [*bikeA] }
          - <<: *Harborside
            arrival: { ride: 2 }
            departure: { ride: 1, move: 1 }
            stable: { add: [] }