org.eclipse.om2m.persistence.mongodb/src/main/java/org/eclipse/om2m/persistence/mongodb/dao/DescContainerByParentDAO.java

/*******************************************************************************
 * Copyright (c) 2014 - 2018 Orange.
 * All rights reserved. This program and the accompanying materials
 * are made available under the terms of the Eclipse Public License 2.0
 * which accompanies this distribution, and is available at
 * https://www.eclipse.org/legal/epl-2.0/
 *
 * Contributors:
 *    BAREAU Cyrille <cyrille.bareau@orange.com>, 
 *    BONNARDEL Gregory <gbonnardel.ext@orange.com>, 
 *******************************************************************************/
package org.eclipse.om2m.persistence.mongodb.dao;

import static com.mongodb.client.model.Filters.and;
import static com.mongodb.client.model.Filters.eq;

import org.bson.Document;
import org.eclipse.om2m.commons.constants.ShortName;
import org.eclipse.om2m.commons.entities.ContainerEntity;
import org.eclipse.om2m.persistence.mongodb.DBServiceImpl;
import org.eclipse.om2m.persistence.service.DAO;
import org.eclipse.om2m.persistence.service.DBTransaction;

public class DescContainerByParentDAO implements DAO<ContainerEntity> {

	private static final String DESC = "DESCRIPTOR";
	
	@Override
	public void create(DBTransaction dbTransaction, ContainerEntity resource) throws RuntimeException {
		throw new RuntimeException("Not implemented");
	}

	@Override
	public ContainerEntity find(DBTransaction dbTransaction, Object id)  {
		Document doc = DBServiceImpl.getInstance().getResourceCollection()
				.find(and(eq(ShortName.PARENT_ID, id), 
						eq(ShortName.RESOURCE_TYPE, 3), 
						eq(ShortName.RESOURCE_NAME, DESC))).first();
		return (doc == null) ? null
				: DBServiceImpl.getInstance().getGson().fromJson(doc.toJson(), ContainerEntity.class);
	}

	@Override
	public void update(DBTransaction dbTransaction, ContainerEntity resource) throws RuntimeException {
		throw new RuntimeException("Not implemented");
	}

	@Override
	public void delete(DBTransaction dbTransaction, ContainerEntity resource) throws RuntimeException {
		throw new RuntimeException("Not implemented");
	}

}