[MOD] refactoring and add Push stream to MongoDB