/*

 * CDDL HEADER START

 *

 * The contents of this file are subject to the terms of the

 *

 * 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.

 *

 */

//  SSrvMsg.java:     Message class for SLP service request.

//  Author:           James Kempf

//  Created On:       Thu Oct  9 13:40:16 1997

//  Last Modified By: James Kempf

//  Last Modified On: Tue Oct 27 10:57:38 1998

//  Update Count:     112

//

package com.sun.slp;

import java.util.*;

import java.io.*;

/**

 * The SSrvMsg class models the SLP service (request, reply) message

 * server side. Subclasses for other versions can specialize the

 * initialize() and makeReply() methods.

 *

 * @author James Kempf

 */

class SSrvMsg extends SrvLocMsgImpl {

    String serviceType = "";	// service type and naming authority

    String query = "";		// the query

    String spi = "";

    protected SSrvMsg() {}

    // Construct a SSrvMsg from the byte input stream.

    SSrvMsg(SrvLocHeader hdr, DataInputStream dis)

	throws ServiceLocationException, IOException {

	super(hdr, SrvLocHeader.SrvReq);

	this.initialize(dis);

    }

    // Initialize the message from the input stream.

    void initialize(DataInputStream dis)

	throws ServiceLocationException, IOException {

	SLPServerHeaderV2 hdr = (SLPServerHeaderV2)getHeader();

	StringBuffer buf = new StringBuffer();

	// First get the previous responder.

	hdr.parsePreviousRespondersIn(dis);

	// Get the service type.

	hdr.getString(buf, dis);

	serviceType = buf.toString();

	if (serviceType.length() <= 0) {

	    throw

		new ServiceLocationException(

				ServiceLocationException.PARSE_ERROR,

				"srq_stype_missing",

				new Object[0]);

	}

	ServiceType t = new ServiceType(serviceType);

	serviceType = t.toString();

	// Get vector of scopes.

	hdr.getString(buf, dis);

	hdr.scopes = hdr.parseCommaSeparatedListIn(buf.toString(), true);

	// Validate, but check for empty if solicitation for DAAdvert

	//  or SAAdvert.

	if (hdr.scopes.size() <= 0) {

	    if (!t.equals(Defaults.DA_SERVICE_TYPE) &&

		!t.equals(Defaults.SA_SERVICE_TYPE)) {

		throw

		    new ServiceLocationException(

					ServiceLocationException.PARSE_ERROR,

					"no_scope_vector",

					new Object[0]);

	    }

	} else {

	    // Unescape scope strings.

	    hdr.unescapeScopeStrings(hdr.scopes);

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

	}

	// Get the query.

	hdr.getString(buf, dis);

	query = buf.toString();

	// Get the SPI

	hdr.getString(buf, dis);

	spi = buf.toString();

	hdr.constructDescription("SrvRqst",

				 "        service type=``" +

				 serviceType + "''\n" +

				 "        query=``" +

				 query + "''\n" +

				 "        spi=``" +

				 spi + "''");

    }

    // Construct a SSrvMsg from the arguments. This will be a SrvRply

    //  for transmission to the client.

    SrvLocMsg makeReply(Hashtable urls, Hashtable URLSignatures)

	throws ServiceLocationException {

	SLPServerHeaderV2 hdr =

	    ((SLPServerHeaderV2)getHeader()).makeReplyHeader();

	hdr.iNumReplies = urls.size();

	// keep this info so SAs can drop 0 replies

	ByteArrayOutputStream baos = new ByteArrayOutputStream();

	int n = urls.size();

	String authDesc = "\n";

	// Write out size.

	hdr.putInt(n, baos);

	Enumeration en = urls.keys();

	int nurls = 0;

	// Write out the members of the list, including the lifetime.

	while (en.hasMoreElements()) {

	    ServiceURL surl = (ServiceURL)en.nextElement();

	    Hashtable auth = null;

	    if (URLSignatures != null) {

		auth = (Hashtable)URLSignatures.get(surl);

		AuthBlock selectedAuth =

		    AuthBlock.getEquivalentAuth(spi, auth);

		auth = null;

		if (selectedAuth != null) {

		    auth = new Hashtable();

		    auth.put(spi, selectedAuth);

		}

		authDesc =

		    authDesc + "         " + surl.toString() + ": " +

		    (auth != null ?

		     selectedAuth.toString() :

		     "No Auth Block\n");

	    }

	    // Parse out a URL entry. Check overflow. If the packet has filled

	    //  up, then break out of the loop.

	    if (hdr.parseServiceURLOut(surl,

				       (auth != null),

				       auth,

				       baos,

				       true) == false) {

		// Note that we set overflow here because there are additional

		//  URL's, but we don't have to truncate the packet.

		hdr.overflow = true;

		// We need to rewrite the size to what it should be.

		byte[] bytes = baos.toByteArray();

		baos.reset();

		SrvLocHeader.putInteger(nurls, baos);

		baos.write(bytes, 2, bytes.length - 2);

		break;

	    }

	    nurls++;

	}

	hdr.payload = baos.toByteArray();

	// Construct description.

	hdr.constructDescription("SrvRply",

				 "        service URLs=``" + urls + "''\n" +

				 "        auth block=" + authDesc + "\n");

	return hdr;

    }

}