/*
 * CDDL HEADER START
 *
 * The contents of this file are subject to the terms of the
 * Common Development and Distribution License (the "License").
 * You may not use this file except in compliance with the License.
 *
 * You can obtain a copy of the license at usr/src/OPENSOLARIS.LICENSE
 * or http://www.opensolaris.org/os/licensing.
 * See the License for the specific language governing permissions
 * and limitations under the License.
 *
 * When distributing Covered Code, include this CDDL HEADER in each
 * file and include the License file at usr/src/OPENSOLARIS.LICENSE.
 * If applicable, add the following below this CDDL HEADER, with the
 * fields enclosed by brackets "[]" replaced with your own identifying
 * information: Portions Copyright [yyyy] [name of copyright owner]
 *
 * CDDL HEADER END
 */
/*
 * Copyright (c) 1999 by Sun Microsystems, Inc.
 * All rights reserved.
 *
 */

//  SDAAdvert.java:   Server Side DAAdvert Message.
//  Author:           James Kempf
//  Created On:       Tue Feb 10 15:00:39 1998
//  Last Modified By: James Kempf
//  Last Modified On: Tue Nov 17 12:12:18 1998
//  Update Count:     82
//

package com.sun.slp;

import java.util.*;
import java.io.*;


/**
 * The SDAAdvert class models the SLP DAAdvert message.
 *
 * @author James Kempf
 */

class SDAAdvert extends SrvLocMsgImpl {

    SDAAdvert(SrvLocHeader hdr,
	      short xid,
	      long timestamp,
	      ServiceURL url,
	      Vector scopes,
	      Vector attrs)
	throws ServiceLocationException {

	// Note that we don't need a server side header here because
	//  we will not be parsing anything in.

	try {
	    this.hdr = (SrvLocHeader)hdr.clone();

	} catch (CloneNotSupportedException ex) {

	    // We know it's supported.

	}

	this.hdr.xid = xid;
	this.hdr.functionCode = SrvLocHeader.DAAdvert;
	this.hdr.mcast = false;
	this.hdr.previousResponders = null;  // we don't want this around.
	this.hdr.errCode = ServiceLocationException.OK;
	this.hdr.overflow = false;
	this.hdr.length = 0;
	this.hdr.fresh = false;

	this.initialize(timestamp, url, scopes, attrs);

    }


    // Initialize the message.

    void
	initialize(long timestamp,
		   ServiceURL url,
		   Vector scopes,
		   Vector attrs)
	throws ServiceLocationException {

	SLPServerHeaderV2 hdr = (SLPServerHeaderV2)this.hdr;
	hdr.scopes = (Vector)scopes.clone();

	ServiceType serviceType = url.getServiceType();

	if (!serviceType.equals(Defaults.DA_SERVICE_TYPE)) {
	    throw
		new ServiceLocationException(
				ServiceLocationException.PARSE_ERROR,
				"sdaadv_nondaurl",
				new Object[] {serviceType});

	}

	if (timestamp < 0) {
	    throw
		new ServiceLocationException(
				ServiceLocationException.PARSE_ERROR,
				"sdaadv_neg",
				new Object[0]);
	}

	// Validate scope list.

	DATable.validateScopes(scopes, hdr.locale);
	hdr.scopes = (Vector)scopes;

	// Escape scope strings.

	hdr.escapeScopeStrings(scopes);

	// Parse out the payload.

	ByteArrayOutputStream baos = new ByteArrayOutputStream();

	String surl = url.toString();

	// Parse out the timestamp

	putInt32(hdr, timestamp, baos);
	byte[] timestampBytes = baos.toByteArray();

	// Parse out the URL.

	byte[] urlBytes = hdr.putString(surl, baos);

	// Parse out the scope list.

	byte[] scopeBytes =
	    hdr.parseCommaSeparatedListOut(scopes, baos);

	// Parse out the attributes.

	byte[] attrBytes = hdr.parseAttributeVectorOut(attrs,
						       url.getLifetime(),
						       false,
						       null,
						       baos,
						       false);

	// Parse out SPI list
	String spisString = "";
	// First get DA SPIs from DA SPIs property
	LinkedList spiList = AuthBlock.getSPIList("sun.net.slp.SPIs");
	if (spiList != null && !spiList.isEmpty()) {

	    StringBuffer spiBuf = new StringBuffer();
	    spiBuf.append(spiList.getFirst().toString());

	    for (int i = 1; i < spiList.size(); i++) {
		spiBuf.append(',');
		spiBuf.append(spiList.get(i).toString());
	    }
	    spisString = spiBuf.toString();
	}

	byte[] spiBytes = hdr.putString(spisString, baos);

	// Parse out auth block, if necessary.

	Hashtable auth = null;

	if (SLPConfig.getSLPConfig().getHasSecurity()) {
	    Object[] message = new Object[9];

	    // None of the strings have leading length fields, so add them here
	    message[0] = timestampBytes;

	    ByteArrayOutputStream abaos = new ByteArrayOutputStream();
	    hdr.putInteger(urlBytes.length, abaos);
	    message[1] = abaos.toByteArray();
	    message[2] = urlBytes;

	    abaos = new ByteArrayOutputStream();
	    hdr.putInteger(attrBytes.length, abaos);
	    message[3] = abaos.toByteArray();
	    message[4] = attrBytes;

	    abaos = new ByteArrayOutputStream();
	    hdr.putInteger(scopeBytes.length, abaos);
	    message[5] = abaos.toByteArray();
	    message[6] = scopeBytes;

	    abaos = new ByteArrayOutputStream();
	    hdr.putInteger(spiBytes.length, abaos);
	    message[7] = abaos.toByteArray();
	    message[8] = spiBytes;

	    auth =
		hdr.getCheckedAuthBlockList(message,
			SLPConfig.getSLPConfig().getAdvertHeartbeatTime());

	    // Parse out auth blocks.
	    baos.write((byte)(auth.size() & 0xFF));	// auth block count
	    hdr.nbytes += 1;
	    AuthBlock.externalizeAll(hdr, auth, baos);

	} else {

	    baos.write((byte)0);

	}

	// Save bytes.

	hdr.payload = baos.toByteArray();

	hdr.constructDescription("DAAdvert",
				 "        timestamp="+timestamp+"\n"+
				 "        URL="+url+"\n"+
				 "        attrs="+attrs+"\n"+
				 "        SPIs="+spisString+"\n"+
				 "        auth block="+AuthBlock.desc(auth) +
				 "\n");
    }

    // Put out the lower 32 bits of the timestamp.

    static private void
	putInt32(SrvLocHeader hdr, long i,  ByteArrayOutputStream baos) {
	baos.write((byte) ((i >> 24) & 0xFF));
	baos.write((byte) ((i >> 16) & 0xFF));
	baos.write((byte) ((i >> 8)  & 0xFF));
	baos.write((byte) (i & 0XFF));

	hdr.nbytes += 4;
    }

}