Implemented real-time parser.

And started implementation of historical consumption parsing.