package jp.ac.u_ryukyu.ie.cr.jungleNetwork.transaction;


import jp.ac.u_ryukyu.ie.cr.jungle.data.list.List;
import jp.ac.u_ryukyu.ie.cr.jungle.persistent.ChangeList;
import jp.ac.u_ryukyu.ie.cr.jungle.persistent.ChangeListWriter;
import jp.ac.u_ryukyu.ie.cr.jungle.query.traverser.InterfaceTraverser;
import jp.ac.u_ryukyu.ie.cr.jungle.store.TreeContext;
import jp.ac.u_ryukyu.ie.cr.jungle.store.logger.TreeOperationLog;
import jp.ac.u_ryukyu.ie.cr.jungle.store.operations.TreeOperation;
import jp.ac.u_ryukyu.ie.cr.jungle.transaction.context.DefaultTreeContext;
import jp.ac.u_ryukyu.ie.cr.jungle.transaction.manager.TransactionManager;
import jp.ac.u_ryukyu.ie.cr.jungle.transaction.node.TreeNode;
import jp.ac.u_ryukyu.ie.cr.jungle.query.traverser.DefaultInterfaceTraverser;
import jp.ac.u_ryukyu.ie.cr.jungle.tree.TreeType;
import jp.ac.u_ryukyu.ie.cr.jungle.util.DefaultEither;
import jp.ac.u_ryukyu.ie.cr.jungle.util.Either;
import jp.ac.u_ryukyu.ie.cr.jungle.util.jungleError.DefaultError;
import jp.ac.u_ryukyu.ie.cr.jungle.util.jungleError.Error;

import java.util.Iterator;
import java.util.concurrent.atomic.AtomicReference;

public class NetworkTransactionManager implements TransactionManager {
    private final AtomicReference<TreeContext> repository;
    private final TreeContext tip;
    private final ChangeListWriter writer;
    private final String uuid;
    private final String treeName;

    public NetworkTransactionManager(String _treeName, ChangeListWriter _writer, TreeContext _tip, AtomicReference<TreeContext> _repository, String _uuid) {
        repository = _repository;
        tip = _tip;
        writer = _writer;
        uuid = _uuid;
        treeName = _treeName;
    }

    @Override
    public Either<Error, TransactionManager> commit(TreeNode newRoot, final TreeOperationLog _log,List<TreeNode> editNodeList) {
        long currentRevision = tip.revision();
        long nextRevision = currentRevision + 1;

        ChangeList list = new ChangeList() {
            @Override
            public Iterator<TreeOperation> iterator() {
                return _log.iterator();
            }

            @Override
            public String uuid() {
                return uuid;
            }

            @Override
            public String getTreeName() {
                return treeName;
            }

            @Override
            public int getTreeType() {
                return TreeType.DEFAULT;
            }

            @Override
            public TreeOperationLog getLog() {
                return _log;
            }
        };

        InterfaceTraverser traverser = new DefaultInterfaceTraverser(newRoot, true);
        traverser.createIndex();
        TreeContext newTreeContext = new DefaultTreeContext(newRoot, tip, list, uuid, treeName, nextRevision, traverser);


        if (repository.compareAndSet(newTreeContext.prev(), newTreeContext)) {
            TransactionManager txManager = new NetworkTransactionManager(treeName, writer, newTreeContext, repository, uuid);
            return DefaultEither.newB(txManager);
        }

        return DefaultEither.newA((Error) new DefaultError());

    }

    @Override
    public Either<Error, TransactionManager> flashCommit(TreeNode _newRoot, TreeOperationLog _log) {
        return null;//commit(_newRoot, _log);
    }

    @Override
    public long getRevision() {
        return tip.revision();
    }

    @Override
    public String getUUID() {
        return uuid;
    }

}