/*
 * Licensed to the Apache Software Foundation (ASF) under one
 * or more contributor license agreements.  See the NOTICE file
 * distributed with this work for additional information
 * regarding copyright ownership.  The ASF licenses this file
 * to you under the Apache License, Version 2.0 (the
 * "License"); you may not use this file except in compliance
 * with the License.  You may obtain a copy of the License at
 *
 *   http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing,
 * software distributed under the License is distributed on an
 * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
 * KIND, either express or implied.  See the License for the
 * specific language governing permissions and limitations
 * under the License.
 */

package org.apache.tuscany.nosqldatastore.couchdb;

import org.apache.tuscany.nosqldatastore.Database;
import org.apache.tuscany.nosqldatastore.Group;
import org.apache.tuscany.nosqldatastore.exception.GroupNotFoundException;
import org.jcouchdb.db.Server;
import org.jcouchdb.document.DesignDocument;
import org.jcouchdb.exception.CouchDBException;

public class CouchDBDatatabase implements Database{

    private org.jcouchdb.db.Database db;
    private String dbname;

    CouchDBDatatabase(String dbname) throws CouchDBException{
        this.dbname = dbname;
        db = new org.jcouchdb.db.Database("localhost",dbname);
        Server server = db.getServer();
        if(!server.listDatabases().contains(dbname)){
            server.createDatabase(dbname);
            return;
        }
        System.out.println("Connect to the existing database...");
    }

    public Group createGroup(String groupId) {
        CouchDBGroup group = new CouchDBGroup(db,groupId);
        return group;
    }

    public Group getGroup(String groupId) {
        CouchDBGroup group = new CouchDBGroup(db,groupId);
        return group;
    }

    public void deleteGroup(String groupId) throws GroupNotFoundException{
        DesignDocument doc = db.getDesignDocument(groupId);
        if(doc != null){
            db.delete(doc);
            return;
        }
        throw new GroupNotFoundException("Group does not exists "+groupId);
    }
}