/*
 *  SSHTools - Java SSH2 API
 *
 *  Copyright (C) 2002-2003 Lee David Painter and Contributors.
 *
 *  Contributions made by:
 *
 *  Brett Smith
 *  Richard Pernavas
 *  Erwin Bolwidt
 *
 *  This program is free software; you can redistribute it and/or
 *  modify it under the terms of the GNU General Public License
 *  as published by the Free Software Foundation; either version 2
 *  of the License, or (at your option) any later version.
 *
 *  This program is distributed in the hope that it will be useful,
 *  but WITHOUT ANY WARRANTY; without even the implied warranty of
 *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 *  GNU General Public License for more details.
 *
 *  You should have received a copy of the GNU General Public License
 *  along with this program; if not, write to the Free Software
 *  Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301, USA.
 */
package com.sshtools.j2ssh.agent;

import com.sshtools.j2ssh.transport.publickey.*;

import org.apache.commons.logging.*;

import java.io.*;

import java.util.*;


/**
 *
 *
 * @author $author$
 * @version $Revision: 1.14 $
 */
public class KeyStore {
    private static Log log = LogFactory.getLog(KeyStore.class);
    HashMap publickeys = new HashMap();
    HashMap privatekeys = new HashMap();
    HashMap constraints = new HashMap();
    Vector index = new Vector();
    Vector listeners = new Vector();
    String lockedPassword = null;

    /**
     * Creates a new KeyStore object.
     */
    public KeyStore() {
    }

    /**
     *
     *
     * @return
     */
    public Map getPublicKeys() {
        return (Map) publickeys.clone();
    }

    /**
     *
     *
     * @param key
     *
     * @return
     */
    public int indexOf(SshPublicKey key) {
        return index.indexOf(key);
    }

    /**
     *
     *
     * @param i
     *
     * @return
     */
    public SshPublicKey elementAt(int i) {
        return (SshPublicKey) index.elementAt(i);
    }

    /**
     *
     *
     * @param key
     *
     * @return
     */
    public String getDescription(SshPublicKey key) {
        return (String) publickeys.get(key);
    }

    /**
     *
     *
     * @param key
     *
     * @return
     */
    public KeyConstraints getKeyConstraints(SshPublicKey key) {
        return (KeyConstraints) constraints.get(key);
    }

    /**
     *
     *
     * @return
     */
    public int size() {
        return index.size();
    }

    /**
     *
     *
     * @param listener
     */
    public void addKeyStoreListener(KeyStoreListener listener) {
        listeners.add(listener);
    }

    /**
     *
     *
     * @param listener
     */
    public void removeKeyStoreListener(KeyStoreListener listener) {
        listeners.remove(listener);
    }

    /**
     *
     *
     * @param prvkey
     * @param pubkey
     * @param description
     * @param cs
     *
     * @return
     *
     * @throws IOException
     */
    public boolean addKey(SshPrivateKey prvkey, SshPublicKey pubkey,
        String description, KeyConstraints cs) throws IOException {
        synchronized (publickeys) {
            if (!publickeys.containsKey(pubkey)) {
                publickeys.put(pubkey, description);
                privatekeys.put(pubkey, prvkey);
                constraints.put(pubkey, cs);
                index.add(pubkey);

                Iterator it = listeners.iterator();
                KeyStoreListener listener;

                while (it.hasNext()) {
                    listener = (KeyStoreListener) it.next();
                    listener.onAddKey(this);
                }

                return true;
            } else {
                return false;
            }
        }
    }

    /**
     *
     */
    public void deleteAllKeys() {
        synchronized (publickeys) {
            publickeys.clear();
            privatekeys.clear();
            constraints.clear();
            index.clear();

            Iterator it = listeners.iterator();
            KeyStoreListener listener;

            while (it.hasNext()) {
                listener = (KeyStoreListener) it.next();
                listener.onDeleteAllKeys(this);
            }
        }
    }

    /**
     *
     *
     * @param pubkey
     * @param forwardingNodes
     * @param data
     *
     * @return
     *
     * @throws KeyTimeoutException
     * @throws InvalidSshKeyException
     * @throws InvalidSshKeySignatureException
     */
    public byte[] performHashAndSign(SshPublicKey pubkey, List forwardingNodes,
        byte[] data)
        throws KeyTimeoutException, InvalidSshKeyException, 
            InvalidSshKeySignatureException {
        synchronized (publickeys) {
            if (privatekeys.containsKey(pubkey)) {
                SshPrivateKey key = (SshPrivateKey) privatekeys.get(pubkey);
                KeyConstraints cs = (KeyConstraints) constraints.get(pubkey);

                if (cs.canUse()) {
                    if (!cs.hasTimedOut()) {
                        cs.use();

                        byte[] sig = key.generateSignature(data);
                        Iterator it = listeners.iterator();
                        KeyStoreListener listener;

                        while (it.hasNext()) {
                            listener = (KeyStoreListener) it.next();
                            listener.onKeyOperation(this, "hash-and-sign");
                        }

                        return sig;
                    } else {
                        throw new KeyTimeoutException();
                    }
                } else {
                    throw new KeyTimeoutException();
                }
            } else {
                throw new InvalidSshKeyException("The key does not exist");
            }
        }
    }

    /**
     *
     *
     * @param pubkey
     * @param description
     *
     * @return
     *
     * @throws IOException
     */
    public boolean deleteKey(SshPublicKey pubkey, String description)
        throws IOException {
        synchronized (publickeys) {
            if (publickeys.containsKey(pubkey)) {
                String desc = (String) publickeys.get(pubkey);

                if (description.equals(desc)) {
                    publickeys.remove(pubkey);
                    privatekeys.remove(pubkey);
                    constraints.remove(pubkey);
                    index.remove(pubkey);

                    Iterator it = listeners.iterator();
                    KeyStoreListener listener;

                    while (it.hasNext()) {
                        listener = (KeyStoreListener) it.next();
                        listener.onDeleteKey(this);
                    }

                    return true;
                }
            }

            return false;
        }
    }

    /**
     *
     *
     * @param password
     *
     * @return
     *
     * @throws IOException
     */
    public boolean lock(String password) throws IOException {
        synchronized (publickeys) {
            if (lockedPassword == null) {
                lockedPassword = password;

                Iterator it = listeners.iterator();
                KeyStoreListener listener;

                while (it.hasNext()) {
                    listener = (KeyStoreListener) it.next();
                    listener.onLock(this);
                }

                return true;
            } else {
                return false;
            }
        }
    }

    /**
     *
     *
     * @param password
     *
     * @return
     *
     * @throws IOException
     */
    public boolean unlock(String password) throws IOException {
        synchronized (publickeys) {
            if (lockedPassword != null) {
                if (password.equals(lockedPassword)) {
                    lockedPassword = null;

                    Iterator it = listeners.iterator();
                    KeyStoreListener listener;

                    while (it.hasNext()) {
                        listener = (KeyStoreListener) it.next();
                        listener.onUnlock(this);
                    }

                    return true;
                }
            }

            return false;
        }
    }
}