% Retrieve a ltpda_uo from a repository
%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
%
% FUNCTION:    fromRepository
%
% DESCRIPTION: Retrieve a ltpda_uo from a repository
%
% CALL:        obj = fromRepository(pl)
%
% PARAMETER:   pl: Parameter list object
%
% VERSION:     $Id: fromRepository.m,v 1.8 2010/10/29 16:09:11 ingo Exp $
%
%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
function coll = fromRepository(coll, pli)
  
  VERSION = '$Id: fromRepository.m,v 1.8 2010/10/29 16:09:11 ingo Exp $';
  
  % get object info
  ii = collection.getInfo('collection', 'From Repository');
  % Set the method version string in the minfo object
  ii.setMversion([VERSION '-->' ii.mversion]);
  
  % Check if the user supplied a DB connection
  conn = find(pli, 'conn');
  
  % Add default values if necessary
  if isempty(conn)
    pl = combine(pli, ii.plists);
  else
    pl = pli;
  end
  plh = copy(pl, 1);
  
  % Get parameters
  hostname = find(pl, 'hostname');
  database = find(pl, 'database');
  user     = find(pl, 'user');
  passwd   = find(pl, 'passwd');
  ids      = find(pl, 'id');
  cids     = find(pl, 'cid');
  bin      = find(pl, 'binary');
  
  collFound  = false;
  
  %%% check if using binary or not: 'yes'/'no' or true/false or
  %%% 'true'/'false'
  bin = utils.prog.yes2true(bin);
  
  % do we have a connection?
  closeConn = 0;
  if isempty(conn)
    closeConn = 1;
    % Connect to repository
    % Connect to repository
    if ~isempty(user) && ~isempty(passwd)
      conn = utils.jmysql.connect(hostname, database, user, passwd);
    else
      conn = utils.jmysql.connect(hostname, database);
    end
  end
  if ~isa(conn, 'database') && ~isa(conn, 'mpipeline.repository.RepositoryConnection')
    error('### connection to the database failed.');
  end
  
  if ~isempty(cids)
    for kk=1:numel(cids)
      cid = cids(kk);
      if isa(conn, 'database')
        % get the ids from the cid
        ids = [ids utils.mysql.getObjIds(conn,cid)];
      else
        c_ids = mpipeline.repository.MySQLUtils.getObjectIDsFromCollectionID(conn, cid);
        ids = [ids c_ids.'];
      end
    end
  end
  
  % Get each ID
  Nids     = length(ids);
  collObjs = {};
  
  for kk=1:Nids
    
    %---- copy the input plist because each object should get an other plist
    plh = copy(pl, 1);
    
    %---- This id
    id = ids(kk);
    utils.helper.msg(utils.const.msg.OPROC2, 'retrieving ID %d', id);
    
    try
      %---- call database constructor
      if bin
        try
          robj = ltpda_uo.retrieve(conn, 'binary', id);
        catch
          warning('!!! Unable to do binary retrieval for object %d; trying to retrieve XML instead.', id);
          robj = ltpda_uo.retrieve(conn, id);
        end
      else
        robj = ltpda_uo.retrieve(conn, id);
      end
      
      %  - remove connection object from plist first
      if isempty(hostname) || isempty(database)
        txt = textscan(conn.URL, '%s', 'Delimiter', '/', 'CollectOutput', 1);
        plc = plist('hostname', txt{1}{3}, 'database', txt{1}{4});
        plh = combine(pli, plc);
      end
      
      %---- remove the connection from the history plist
      if plh.isparam('conn')
        plh.remove('conn');
      end
      
      %---- Set only the ID of the current object to the plist
      plh.pset('ID', id);
      
      %---- Add history
      robj.addHistoryWoChangingUUID(robj.getInfo(class(robj), 'From Repository'), plh, [], robj.hist);
      
      %---- Add to output array
      if isa(robj, 'collection')
        if numel(ids) == 1
          coll = robj;
          return
        end
        
        if numel(robj.objs)>0
          collFound = true;
          collObjs = [collObjs; robj.objs(:)];
        end
      else
        collObjs = [collObjs; {robj}];
      end
    catch Exception
      if closeConn
        close(conn);
      end
      throw(Exception)
    end
    
  end
  
  % close connection
  if closeConn
    if isa(conn, 'database')
      close(conn);
    else
      conn.closeConnection;
    end
  end
  
  if collFound
    warning(sprintf(['!!! The output collection contains the contents of at least one retrieved collection.' ...
      '\nThe history of those collection objects is discarded. The internal objects of those ' ...
      'objects is retained.']));
  end
  if isempty(collObjs)
    warning('!!! No objects were retrieved from the ids %s and/or collection id %s', mat2str(ids), mat2str(cid));
  end
  
  % Define collection-plist for the history
  plh.pset('id', pli.find('id'));
  plh.pset('cid', pli.find('cid'));
  
  % Set properties from the plist
  coll.setProperties(pl);
  coll.objs = collObjs;
  coll.addHistory(ii, plh, [], []);
  
end