Consolidate all stream logic in Streams. Add test for goal events stream.
Set up goal notification pipeline