mgebbe@19: # Copyright (C) 2014 by Intevation GmbH
mgebbe@19: # Author: Mathias Gebbe <mgebbe@intevation.de>
mgebbe@19: #
mgebbe@19: # This file is Free Software under the Apache License, Version 2.0;
mgebbe@19: # and comes with NO WARRANTY!
mgebbe@19: # See the documentation coming with pumpbridge for details.
mgebbe@19: 
mgebbe@19: _ = require("underscore")
mgebbe@19: async = require("async")
mgebbe@19: Facebook = require("./facebook")
mgebbe@19: Usermap = require("./usermap")
mgebbe@19: Google = require("./google")
mgebbe@19: Config = require ("./config")
mgebbe@19: config = Config.config
mgebbe@19: Twitter = require("./twitter")(config)
mgebbe@19: 
mgebbe@19: databank = require("databank")
mgebbe@19: Databank = databank.Databank
mgebbe@19: DatabankObject = databank.DatabankObject
mgebbe@19: 
mgebbe@19: db = Databank.get(config.driver, config.params)
mgebbe@19: DatabankObject.bank = db
mgebbe@19: 
mgebbe@19: syncFromESN = () ->
mgebbe@19:   console.log 'syncFromESN'
mgebbe@19: 
mgebbe@21:   ####
mgebbe@21:   # Facebook
mgebbe@21:   try
mgebbe@21:     Usermap.scan ((user) ->
mgebbe@21:       if user.id.indexOf('@facebook') isnt -1
mgebbe@21:         console.log "start sync for facebook user"
mgebbe@21:         Facebook.sync(user)
mgebbe@21:     ), (err) ->
mgebbe@21:   catch err
mgebbe@21:     console.log 'Error!' + err
mgebbe@21: 
mgebbe@21:   # Twitter
mgebbe@21:   try
mgebbe@21:     Usermap.scan ((user) ->
mgebbe@21:       if user.id.indexOf('@twitter') isnt -1
mgebbe@21:         console.log "start sync for twitter user"
mgebbe@22:         Twitter.syncToESN(user)
mgebbe@22:         Twitter.syncFromESN(user)
mgebbe@21:     ), (err) ->
mgebbe@21:   catch err
mgebbe@21:     console.log 'Error!' + err
mgebbe@21: 
mgebbe@21:   # Google
mgebbe@21:   try
mgebbe@21:     Usermap.scan ((user) ->
mgebbe@21:       if user.id.indexOf('@google') isnt -1
mgebbe@21:         console.log "start sync for google user"
mgebbe@21:         Google.sync(user)
mgebbe@21:     ), (err) ->
mgebbe@21:   catch err
mgebbe@21:     console.log 'Error!' + err
mgebbe@21:   ####
mgebbe@19: 
mgebbe@19:   return
mgebbe@19: 
mgebbe@19: sync = () ->
mgebbe@19: 
mgebbe@19:   # Do this every xx minutes
mgebbe@19:   console.log '\n\n\n' + "starting sync deamon"
mgebbe@19:   interval = config.interval
mgebbe@19:   if not (interval?)
mgebbe@19:     interval =  15 * 60 * 1000 # 900 000 ms (15min)
mgebbe@22: 
mgebbe@21:   async.waterfall [
mgebbe@21:     (callback) ->
mgebbe@21:        db.connect(config.params, callback)
mgebbe@21:   ], (err, result) ->
mgebbe@21:     setInterval syncFromESN, interval
mgebbe@21:     syncFromESN()
mgebbe@19: 
mgebbe@19:   return
mgebbe@19: 
mgebbe@19: sync()