straw_pipe.coffee

CAMP_CODES = 
  "0006": "gd"
  "0013": "jncamp"
  "0012": "jara"


Agent.check = ->
  true



Agent.receive = (evts)->
  @log 'events', evts
  aid = evts.agent_id
  items = evts.payload.items
  @log('receive events')
  msgs = [];
  e_list = items
  
  
  qs = _.map items, (e)=>
    memKey = [aid, e.PlayDate, e.GroupCode].join(":")
    remains = e.ProductRemainCount
      
    @memory(memKey).then (prev)=>
      @log(memKey + " : " + prev + ", " + remains)
      if !prev or (prev != remains)
        msg = [aid, e.PlayDate, e.GroupName, remains].join(" : ")
        msgs.push(msg)

  q.all(qs).then =>
    @memory(memKey, remains).then =>
      if msgs.length
        @create_event({title: "Huginn", url:"http://huginn.app.esfoo.com", message:msgs.join("\n")})