package christie.datagear;

import christie.datagear.command.*;
import christie.datagear.dg.DataGear;

/**
 * Created by e125769 on 12/7/17.
 */
public class LocalDataGearManager extends DataGearManager {

    public void put(String key, Object data) {//main use
        DataGear dg = new DataGear(data);
        put(key, dg);
    }

    public void put(String key, DataGear dg){
        runCommand(new PutCommand(1, "local", key, dg));
    }

    public void runCommand(Command cm){
        switch (cm.type) {
            case PUT:
                dataGears.setData(cm);

                if (waitList.containsKey(cm.key)){
                    runCommand(waitList.getAndRemoveCommand(cm.key));
                }

                break;
            case TAKE:
            case REMOTETAKE:
            case PEEK:
            case REMOTEPEEK:
                if (dataGears.containsKey(cm.key)) {
                    cm.setDg(dataGears.getData(cm));
                    cm.execute();
                } else {
                    waitList.add(cm);
                }
                break;
            case REPLY:
                cm.execute();
                break;

        }
    }

    @Override
    public void resolveWaitCommand(String key, DataGear dg) {

    }

    @Override
    public void finish() {
        System.exit(0);
    }

    @Override
    public void close() {

    }

    @Override
    public void shutdown() {

    }
}