package com.c2kernel.entity.proxy;

import java.io.IOException;
import java.net.DatagramPacket;
import java.net.InetAddress;
import java.util.StringTokenizer;

import com.c2kernel.common.InvalidDataException;


/**************************************************************************
 *
 * $Revision: 1.11 $
 * $Date: 2005/05/10 11:40:09 $
 *
 * Copyright (C) 2003 CERN - European Organization for Nuclear Research
 * All rights reserved.
 **************************************************************************/

public class ProxyMessage {

    // special server message paths
    public static final String BYEPATH = "bye";
    public static final String ADDPATH = "add";
    public static final String DELPATH = "del";
    public static final String PINGPATH = "ping";
    public static final boolean ADDED = false;
    public static final boolean DELETED = true;
    public static final int NA = -1;

    static ProxyMessage byeMessage = new ProxyMessage(NA, BYEPATH, ADDED);
    static ProxyMessage pingMessage = new ProxyMessage(NA, PINGPATH, ADDED);

    private int sysKey = NA;
    private String path = "";
    private String server = null;
    private boolean state = ADDED;

    public ProxyMessage() {
        super();
    }
    public ProxyMessage(int sysKey, String path, boolean state) {
        this();
        setSysKey(sysKey);
        setPath(path);
        setState(state);
    }

    public ProxyMessage(String line) throws InvalidDataException, IOException {
        if (line == null)
            throw new IOException("Null proxy message");
        StringTokenizer tok = new StringTokenizer(line,":");
        if (tok.countTokens()!=2)
            throw new InvalidDataException("String '"+line+"' does not constitute a valid proxy message.", "");
        sysKey = Integer.parseInt(tok.nextToken());
        path = tok.nextToken();
        if (path.startsWith("-")) {
            state = DELETED;
            path = path.substring(1);
        }
    }

    public ProxyMessage(DatagramPacket packet) throws InvalidDataException, IOException {
        this(new String(packet.getData()));
    }

    public int getSysKey() {
        return sysKey;
    }

    public void setSysKey(int sysKey) {
        this.sysKey = sysKey;
    }

    public String getPath() {
        return path;
    }

    public void setPath(String newPath) {
        this.path = newPath;
    }

    public boolean getState() {
        return state;
    }

    public void setState(boolean state) {
        this.state = state;
    }

    @Override
	public String toString() {
        return sysKey+":"+(state?"-":"")+path;
    }
    public DatagramPacket getPacket(ProxySubscriber host) {
        return getPacket(host.getHost(), host.getPort());
    }

    public DatagramPacket getPacket(InetAddress host, int port) {
        byte[] packetString = toString().getBytes();
        return new DatagramPacket(packetString, packetString.length, host, port);
    }

    public String getServer() {
        return server;
    }

    public void setServer(String server) {
        this.server = server;
    }
}