move stream storage to mongo