compressHistory.coffee 542 B

1234567891011121314151617181920
  1. {db, ObjectId} = require "./app/coffee/mongojs"
  2. ConversionManager = require "./app/coffee/ConversionManager"
  3. async = require "async"
  4. db.docOps.find { }, { doc_id: true }, (error, docs) ->
  5. throw error if error?
  6. jobs = []
  7. for doc in docs
  8. do (doc) ->
  9. jobs.push (callback) ->
  10. doc_id = doc.doc_id.toString()
  11. ConversionManager.convertOldRawUpdates doc_id, (error) ->
  12. return callback(error) if error?
  13. console.log doc_id, "DONE"
  14. callback()
  15. async.series jobs, (error) ->
  16. throw error if error?
  17. process.exit()