sun/slp/SSrvMsg.java

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

    }
}