package gw.solr.utils
uses java.util.Set
uses gw.pl.persistence.core.Bundle
uses gw.solr.request.AbstractDeleteRequest
uses gw.solr.request.AbstractIndexRequest
uses gw.solr.ISolrPolicyDeleteRequest
uses gw.api.extension.ExtensionInterfaces
uses gw.solr.ISolrPolicyIndexRequest
uses gw.pl.persistence.core.Key

class SolrIndexContext {
  
  var _bundle : Bundle as Bundle
  var _account : Account as Account
  var _deleteQueries : Set<String>  as DeleteQueries = {} 
  var _updateURNs : Set<String> as URNs = {} 
  var _updatedPeriods : Set<Key> as ProcessedUpdates = {}
  var _deletedPeriods : Set<Key> as ProcessedDeletes = {}
  var _deleteRequest : ISolrPolicyDeleteRequest as DeleteRequest = ExtensionInterfaces.ISolrPolicyDeleteRequestFactory.newInstance()
  var _indexRequest : ISolrPolicyIndexRequest as IndexRequest = ExtensionInterfaces.ISolrPolicyIndexRequestFactory.newInstance()
  
  construct(b : Bundle, a : Account) {
    _bundle = b 
    _account = a
  }
  
  function beanIsInBundle(bean : KeyableBean) : boolean{

    if (_bundle.UpdatedBeans.hasMatch(\ k -> k.ID == bean.ID)) {
      return true 
    }      
    if (_bundle.InsertedBeans.hasMatch(\ k -> k.ID == bean.ID)) {
      return true 
    }
    if (_bundle.RemovedBeans.hasMatch(\ k -> k.ID == bean.ID)) {
      return true 
    }    
    return false
    
  }
  
  function getBeanFromBundle(bean : KeyableBean) : KeyableBean{    
    return ExtensionInterfaces.IPCSolrUtilsExtensions.getBeanFromBundle(bean, _bundle)
  }  

 
  

}