Eventstore event generation script

generate_events.sh

#!/bin/bash
sendToStream(){
  local EVENT_UUID=`uuidgen`
  echo "Sending $1 event with shared ID $2"
  AUTH="-u admin:changeit"
  curl $AUTH -i -d "{\"type\":\"$1\", \"foo$1\":\"we did a $1 kind of thing.\",\"id\":\"$2\"}" "http://127.0.0.1:2113/streams/$1-$2" -H "Content-Type:application/json" -H "ES-EventType: $1-event" -H "ES-EventId: $EVENT_UUID"
  echo "Curl return value $?"
}


SHARED_UUID=`uuidgen`
for i in {1..10}
do
  echo "Unique ID to use for correlation is: $SHARED_UUID"

  sendToStream a $SHARED_UUID
  sendToStream b $SHARED_UUID
  echo "#---------------------------#"
done

echo "Sending unifying C event"
sendToStream c $SHARED_UUID

get-ab-object.js

fromAll()
.when({
    $init: function(){
        return {
            fooa: "",
            foob: "",
            fooc: ""
        }
    },
    $any: function(s,e){
        log(JSON.stringify(e));
        if(e.body && e.body.fooa){
            s.fooa = e.body.fooa;
        } else if (e.body && e.body.foob){
            s.foob = e.body.foob;
        } else if (e.body && e.body.fooc){
            s.fooc = e.body.fooc;
        }

        if(s.fooa && s.foob && s.fooc){
            log("We have a full object!");
        } else {
            log("Still missing some properties");
        }
    }
})