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

//  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;

    }
}