Thanks for that useful contribution!
I am currently doing something similar, but with different api in the background (which is not that handy). One question that I have is (how) did you initialize the progress json before starting the stream the first time?