package org.kuali.mobility.push.dao;
   
   import java.util.List;
   
   import org.apache.log4j.Logger;
   import org.kuali.mobility.push.entity.PushDeviceTuple;
   import org.kuali.mobility.push.service.PushService;
   import org.springframework.beans.factory.annotation.Autowired;
   
  
  /**
   * A task which will run at a configured interval to check for notifications that has to be sent.
   * 
   * @author Kuali Mobility Team (mobility.dev@kuali.org)
   * @since 2.1.0
   */
  public class PushInitBean {
  
  	/** A reference to a logger */
  	private static final Logger LOG = Logger.getLogger(PushInitBean.class);
  
  	/**
  	 * A reference to the <code>PushService</code>
  	 */
  	@Autowired
  	private PushService pushService;
  	
  	/**
  	 * Runs the task to send notifications
  	 */
  	public void checkPushes() {
  		try{
  			List<PushDeviceTuple> tuplelist = this.pushService.findUnsentPushTuples();
  			int numberOfPendingPushes = tuplelist.size();
  			if(numberOfPendingPushes > 0){
  				LOG.info("Checked for unsent Push notifications, found " + numberOfPendingPushes + " pending push notification.");
  				pushService.sendPush(tuplelist);						
  			}else{
  				LOG.info("Checked for unsent Push notifications, found 0 pending push notifications.");
  			}
  		}catch(Exception e){
  			LOG.error("Exception while running Task", e);
  		}
  	}
  	
  	/**
  	 * Sets the reference to the <code>PushService</code>
  	 * @param pushService
  	 */
  	public void setPushService(PushService pushService){
  		this.pushService = pushService;
  	}
  }