/*
 * Copyright (c) 2000, 2017 Oracle and/or its affiliates. All rights reserved.
 *
 * This program and the accompanying materials are made available under the
 * terms of the Eclipse Public License v. 2.0, which is available at
 * http://www.eclipse.org/legal/epl-2.0.
 *
 * This Source Code may also be made available under the following Secondary
 * Licenses when the conditions for such availability set forth in the
 * Eclipse Public License v. 2.0 are satisfied: GNU General Public License,
 * version 2 with the GNU Classpath Exception, which is available at
 * https://www.gnu.org/software/classpath/license.html.
 *
 * SPDX-License-Identifier: EPL-2.0 OR GPL-2.0 WITH Classpath-exception-2.0
 */

/*
 * @(#)ClusterTakeoverInfo.java	1.12 06/28/07
 */

package com.sun.messaging.jmq.jmsserver.multibroker.raptor;

import com.sun.messaging.jmq.io.GPacket;
import com.sun.messaging.jmq.io.Status;
import com.sun.messaging.jmq.util.UID;
import com.sun.messaging.jmq.jmsserver.Globals;
import com.sun.messaging.jmq.jmsserver.resources.BrokerResources;
import com.sun.messaging.jmq.jmsserver.cluster.api.ha.HAClusteredBroker;
import com.sun.messaging.jmq.jmsserver.multibroker.raptor.ProtocolGlobals;
import com.sun.messaging.jmq.jmsserver.util.BrokerException;

/**
 * An instance of this class is intended to be used one direction only
 */

public class ClusterTakeoverInfo {
    private static boolean DEBUG = false;

    private GPacket pkt = null;

    private String brokerID = null;
    private UID storeSession = null;
    private UID brokerSession = null;
    private String brokerHost = null;
    private Long xid = null;
    // if issued or pkt originated from sender
    private boolean fromTaker = true;
    private String taker = null;
    private Long timestamp = null;
    private boolean timedout = false;

    private ClusterTakeoverInfo(String brokerID, UID storeSession, String brokerHost, UID brokerSession, Long xid, boolean fromTaker, boolean timedout) {
        this.brokerID = brokerID;
        this.storeSession = storeSession;
        this.brokerHost = brokerHost;
        this.brokerSession = brokerSession;
        this.xid = xid;
        this.fromTaker = fromTaker;
        this.timedout = timedout;
    }

    private ClusterTakeoverInfo(GPacket pkt) {
        assert (pkt.getType() == ProtocolGlobals.G_TAKEOVER_COMPLETE || pkt.getType() == ProtocolGlobals.G_TAKEOVER_PENDING
                || pkt.getType() == ProtocolGlobals.G_TAKEOVER_ABORT);

        this.pkt = pkt;
        brokerID = (String) pkt.getProp("brokerID");
        storeSession = new UID(((Long) pkt.getProp("storeSession")).longValue());
        Long v = (Long) pkt.getProp("brokerSession");
        if (v != null) {
            brokerSession = new UID(v.longValue());
        }
        brokerHost = (String) pkt.getProp("brokerHost");
        taker = (String) pkt.getProp("taker");
        fromTaker = (taker != null);
        timestamp = (Long) pkt.getProp("timestamp");
        if (timestamp != null) {
            timedout = (timestamp.equals(Long.valueOf(0)));
        }
        xid = (Long) pkt.getProp("X");
    }

    /**
     */
    public static ClusterTakeoverInfo newInstance(String brokerID, UID storeSession) {
        return new ClusterTakeoverInfo(brokerID, storeSession, null, null, null, false, false);
    }

    public static ClusterTakeoverInfo newInstance(String brokerID, UID storeSession, String brokerHost, UID brokerSession, Long xid, boolean fromTaker) {
        return new ClusterTakeoverInfo(brokerID, storeSession, brokerHost, brokerSession, xid, fromTaker, false);
    }

    public static ClusterTakeoverInfo newInstance(String brokerID, UID storeSession, String brokerHost, UID brokerSession, Long xid, boolean fromTaker,
            boolean timedout) {
        return new ClusterTakeoverInfo(brokerID, storeSession, brokerHost, brokerSession, xid, fromTaker, timedout);
    }

    /**
     *
     * @param pkt The GPacket to be unmarsheled
     */
    public static ClusterTakeoverInfo newInstance(GPacket pkt) {
        return new ClusterTakeoverInfo(pkt);
    }

    public GPacket getGPacket(short protocol) throws BrokerException {
//        assert ( protocol == ProtocolGlobals.G_TAKEOVER_COMPLETE ||
//                 protocol == ProtocolGlobals.G_TAKEOVER_PENDING ||
//                 protocol == ProtocolGlobals.G_TAKEOVER_ABORT );
        if (!Globals.getHAEnabled() && !Globals.isBDBStore()) {
            throw new BrokerException(Globals.getBrokerResources().getKString(BrokerResources.E_INTERNAL_BROKER_ERROR, "Broker is not running in HA mode"));
        }

        if (pkt != null) {
            assert (pkt.getType() == protocol);
            return pkt;
        }

        GPacket gp = GPacket.getInstance();
        gp.putProp("brokerID", brokerID);
        gp.putProp("storeSession", Long.valueOf(storeSession.longValue()));

        if (protocol == ProtocolGlobals.G_TAKEOVER_COMPLETE) {
            gp.setType(protocol);
            gp.setBit(gp.A_BIT, false);
            return gp;
        }

        HAClusteredBroker cb = (HAClusteredBroker) Globals.getClusterManager().getLocalBroker();
        if (protocol == ProtocolGlobals.G_TAKEOVER_PENDING) {
            gp.setType(ProtocolGlobals.G_TAKEOVER_PENDING);
            gp.setBit(gp.A_BIT, false);
            gp.putProp("brokerSession", Long.valueOf(brokerSession.longValue()));
            gp.putProp("brokerHost", brokerHost);
            if (fromTaker) {
                taker = cb.getBrokerName();
                gp.putProp("taker", taker);
                gp.putProp("timestamp", Long.valueOf(cb.getHeartbeat()));
                gp.setBit(gp.A_BIT, true);
            } else if (timedout) {
                gp.putProp("timestamp", Long.valueOf(0));
            }
            gp.putProp("X", xid);
            return gp;
        }

        if (protocol == ProtocolGlobals.G_TAKEOVER_ABORT) {
            gp.setType(ProtocolGlobals.G_TAKEOVER_ABORT);
            if (fromTaker) {
                gp.putProp("taker", cb.getBrokerName());
            }
            gp.setBit(gp.A_BIT, false);
            gp.putProp("X", xid);
            return gp;
        }
        throw new BrokerException("Unknown protocol: " + protocol);
    }

    public String getBrokerID() {
        return brokerID;
    }

    public UID getStoreSession() {
        return storeSession;
    }

    public Long getXid() {
        return xid;
    }

    public UID getBrokerSession() {
        return brokerSession;
    }

    public String getBrokerHost() {
        return brokerHost;
    }

    public String getTaker() {
        return taker;
    }

    public Long getTimestamp() {
        assert (pkt != null);
        return timestamp;
    }

    public boolean isTimedout() {
        return timedout;
    }

    public boolean isFromTaker() {
        return fromTaker;
    }

    @Override
    public String toString() {
        if (pkt == null) {
            return getTaker() + ":[brokerID=" + getBrokerID() + ", storeSession=" + getStoreSession() + "]"
                    + (getBrokerSession() == null ? "" : "brokerSession=" + getBrokerSession()) + ", xid=" + xid;
        }

        if (pkt.getType() == ProtocolGlobals.G_TAKEOVER_COMPLETE) {
            return "[brokerID=" + getBrokerID() + ", storeSession=" + getStoreSession() + "]";
        }

        if (pkt.getType() == ProtocolGlobals.G_TAKEOVER_PENDING) {
            String prefix = "";

            if (DEBUG) {
                if (getTaker() != null) {
                    prefix = getTaker() + "(" + ((timestamp == null) ? "" : "" + timestamp) + ":";
                }
                return prefix + "[brokerID=" + getBrokerID() + ", storeSession=" + getStoreSession() + "]"
                        + (getBrokerSession() == null ? "" : "brokerSession=" + getBrokerSession()) + ", " + getBrokerHost() + ", xid=" + xid;
            }
            return prefix + "[brokerID=" + getBrokerID() + ", storeSession=" + getStoreSession() + "]"
                    + (getBrokerSession() == null ? "" : "brokerSession=" + getBrokerSession()) + ", xid=" + xid;
        }

        return getTaker() + ":[brokerID=" + getBrokerID() + ", storeSession=" + getStoreSession() + "]"
                + (getBrokerSession() == null ? "" : "brokerSession=" + getBrokerSession()) + ", xid=" + xid;
    }

    public boolean needReply() {
        assert (pkt != null);
        return pkt.getBit(pkt.A_BIT);
    }

    public GPacket getReplyGPacket(short protocol, int status, String reason) {
        assert (pkt != null);
        assert (protocol == ProtocolGlobals.G_TAKEOVER_PENDING_REPLY);

        GPacket gp = GPacket.getInstance();
        gp.setType(protocol);
        gp.putProp("X", pkt.getProp("X"));
        gp.putProp("brokerID", pkt.getProp("brokerID"));
        gp.putProp("storeSession", pkt.getProp("storeSession"));
        gp.putProp("taker", pkt.getProp("taker"));
        gp.putProp("S", Integer.valueOf(status));
        if (reason != null) {
            gp.putProp("reason", reason);
        }

        return gp;
    }

    public static int getReplyStatus(GPacket reply) {
        return ((Integer) reply.getProp("S")).intValue();
    }

    public static String getReplyStatusReason(GPacket reply) {
        return (String) reply.getProp("reason");
    }

    public static Long getReplyXid(GPacket reply) {
        return (Long) reply.getProp("X");
    }

    public static String toString(GPacket reply) {
        StringBuffer buf = new StringBuffer();
        buf.append("\n\tstatus=").append(Status.getString(getReplyStatus(reply)));
        if (reply.getProp("reason") != null) {
            buf.append("\n\treason=").append(getReplyStatusReason(reply));
        }
        buf.append("[brokerID=").append((String) reply.getProp("brokerID"));
        buf.append(", storeSession=").append(reply.getProp("storeSession"));
        buf.append("]xid=").append(reply.getProp("X"));
        buf.append(", taker=").append((String) reply.getProp("taker"));
        return buf.toString();
    }
}
