/**
 * Copyright (c) 2009 Red Hat, Inc.
 *
 * This software is licensed to you under the GNU General Public License,
 * version 2 (GPLv2). There is NO WARRANTY for this software, express or
 * implied, including the implied warranties of MERCHANTABILITY or FITNESS
 * FOR A PARTICULAR PURPOSE. You should have received a copy of GPLv2
 * along with this software; if not, see
 * http://www.gnu.org/licenses/old-licenses/gpl-2.0.txt.
 *
 * Red Hat trademarks are not licensed under GPLv2. No permission is
 * granted to use or replicate Red Hat trademarks that are incorporated
 * in this software or its documentation.
 */
package org.fedoraproject.candlepin.model;

import java.util.HashSet;
import java.util.LinkedList;
import java.util.List;
import java.util.Set;

import org.hibernate.criterion.Restrictions;

import com.wideplay.warp.persist.Transactional;

public class ProductCurator extends AbstractHibernateCurator<Product> {

    public ProductCurator() {
        super(Product.class);
    }

    public Product lookupByName(String name) {
        return (Product) currentSession().createCriteria(Product.class)
            .add(Restrictions.like("name", name))
            .uniqueResult();
    }

    public Product lookupByLabel(String label) {
        return (Product) currentSession().createCriteria(Product.class)
            .add(Restrictions.like("label", label))
            .uniqueResult();
    }
    
    @SuppressWarnings("unchecked")
    public List<Product> listAll() {
        List<Product> results = (List<Product>) currentSession()
            .createCriteria(Product.class).list();
        if (results == null) {
            return new LinkedList<Product>();
        }
        else {
            return results;
        }
    }
    
    @Transactional
    public Product update(Product updated) {
        Product existingProduct = find(updated.getId());
        if (existingProduct == null) {
            return create(updated);
        }
        
        if (updated.getChildProducts() != null) {
            existingProduct.setChildProducts(bulkUpdate(updated.getChildProducts()));
        }
        existingProduct.setLabel(updated.getLabel());
        existingProduct.setName(updated.getName());
        save(existingProduct);
        flush();
        
        return existingProduct;
    }
    
    @Transactional
    public Set<Product> bulkUpdate(Set<Product> products) {
        Set<Product> toReturn = new HashSet<Product>();
        for(Product toUpdate: products) {
            toReturn.add(update(toUpdate));
        }
        return toReturn;
    }

}