package org.gcube.portlets.user.geoportaldataentry.client;

import static org.gcube.application.geoportal.client.GeoportalAbstractPlugin.mongoConcessioni;

import java.util.ArrayList;
import java.util.Arrays;
import java.util.HashMap;
import java.util.Iterator;
import java.util.List;
import java.util.Map;

import org.bson.Document;
import org.gcube.application.geoportal.common.model.legacy.Concessione;
import org.gcube.application.geoportal.common.model.rest.QueryRequest;
import org.gcube.application.geoportal.common.model.rest.QueryRequest.OrderedRequest;
import org.gcube.application.geoportal.common.model.rest.QueryRequest.OrderedRequest.Direction;
import org.gcube.application.geoportal.common.model.rest.QueryRequest.PagedRequest;
import org.gcube.application.geoportal.common.rest.MongoConcessioni;
import org.gcube.common.authorization.library.provider.SecurityTokenProvider;
import org.gcube.common.scope.api.ScopeProvider;
import org.gcube.portlets.user.geoportaldataentry.server.config.GNARoleRitghtsConfigReader;
import org.gcube.portlets.user.geoportaldataentry.shared.RoleRights;
import org.junit.Before;
import org.junit.Test;

import com.mongodb.BasicDBObject;

public class TestClass {

	private static String TOKEN = "8e74a17c-92f1-405a-b591-3a6090066248-98187548";
	private static String CONTEXT = "/gcube/devsec/devVRE";
	private static String USERNAME = "francesco.mangiacrapa";

	@Before
	public void init() {
		ScopeProvider.instance.set(CONTEXT);
		SecurityTokenProvider.instance.set(TOKEN);
	}

	//@Test
	public void getListConcessioniTest() throws Exception {
		MongoConcessioni clientMongo = mongoConcessioni().build();
		Iterator<Concessione> concessioni = clientMongo.getList();
		List<Concessione> listOfConcessioni = new ArrayList<Concessione>();
		if (concessioni != null) {
			while (concessioni.hasNext()) {
				Concessione concessione = (Concessione) concessioni.next();
				listOfConcessioni.add(concessione);

			}
		}
		int i = 0;
		for (Concessione concessione : listOfConcessioni) {
			System.out.println(++i + " " + concessione);
		}
	}
	
	@Test
	public void queryConcessioniTest() throws Exception {
		try {
		MongoConcessioni clientMongo = mongoConcessioni().build();
		int offsetIndex = 0;
		int limitIndex = 25;
		Direction sDirection = Direction.ASCENDING;
		List<String> orderByFields = Arrays.asList("nome");
		
		String searchByField = "nome";
		String serchValue = "mock";
		
		Map<String, Object> searchFields = new HashMap<String, Object>();
		searchFields.put(searchByField, serchValue);

		
		QueryRequest request = new QueryRequest();
		PagedRequest paging = new PagedRequest();
		paging.setOffset(offsetIndex);
		paging.setLimit(limitIndex);
		request.setPaging(paging);

		OrderedRequest ordering = new OrderedRequest();

		ordering.setDirection(sDirection);

		ordering.setFields(orderByFields);
		request.setOrdering(ordering);
		
		Document query = null;
		
		if(searchFields!=null) {
			
//			BasicDBObjectBuilder builder = BasicDBObjectBuilder.start();
//			BasicDBObject bs = null;
//			query = new Document();
//			
//			for (String key : searchFields.keySet()) {
//				//builder.append(key, new BasicDBObject("$eq", searchFields.get(key)));
//				//query.put(key, new BasicDBObject("$eq", searchFields.get(key)));
//				query = new Document(key, searchFields.get(key));
//			}
//			
//			request.setFilter(query);
			
			query = new Document();

			for (String key : searchFields.keySet()) {
				//query.put(key, searchFields.get(key));
				query.put(key, new BasicDBObject("$eq", searchFields.get(key)));
			}

			request.setFilter(query);
			
		}
		
		System.out.println("Paging offset: " + offsetIndex + ", limit: " + limitIndex);
		System.out.println("Direction: " + sDirection);
		System.out.println("Order by Fields: " + orderByFields);
		System.out.println("Search for: " + query);
		System.out.println("Search for Query to JSON: "+query.toJson());
		
		Iterator<Concessione> concessioni = clientMongo.query(request);
		
		
		if (concessioni != null) {
			while (concessioni.hasNext()) {
				Concessione concessione = (Concessione) concessioni.next();
				System.out.println(concessione.getNome());

			}
			
		}
		}catch (Exception e) {
			e.printStackTrace();
		}
	}

	//@Test
	public void readUserRights() throws Exception {
		new GNARoleRitghtsConfigReader();
		List<RoleRights> listUserRights = GNARoleRitghtsConfigReader.readRoleRightsConfig();
		System.out.println(listUserRights);
	}

}