package gw.solr.consistency

uses gw.solr.utils.PLSolrUtils
uses org.apache.solr.common.SolrInputDocument
uses org.apache.solr.client.solrj.request.UpdateRequest
uses org.json.simple.JSONArray
uses org.json.simple.JSONObject

uses java.util.Collection


@ReadOnly
class UpdateProcessor extends ConsistencyProcessor {
    
  construct(msgObj : JSONArray, tracker : ConsistencyTracker) {
    super(msgObj, new JSONArray(), PLSolrUtils.URN_TAG, tracker)
    
    (_newMsgObj as JSONArray).ensureCapacity(msgObj.size())
  }
  
  override function children() : Collection {
    return _msgObj as JSONArray
  }
  
  override function addChild( ur : UpdateRequest, docObj : JSONObject ) {
    var sid = new SolrInputDocument() 
    for(entry in docObj.entrySet()) {
      var key = entry.Key as String
      var val = entry.Value
      if(val typeis JSONArray) {
        for(element in val) {
          sid.addField(key, element)
        }
      } else {
        sid.addField(key, val)
      }
    }
    ur.add(sid)
  }

}