1 mike  1.2 //%/////////////////////////////////////////////////////////////////////////////
  2           //
  3           // Copyright (c) 2000, 2001 BMC Software, Hewlett-Packard Company, IBM, 
  4           // The Open Group, Tivoli Systems
  5           //
  6           // Permission is hereby granted, free of charge, to any person obtaining a copy
  7           // of this software and associated documentation files (the "Software"), to 
  8           // deal in the Software without restriction, including without limitation the 
  9           // rights to use, copy, modify, merge, publish, distribute, sublicense, and/or 
 10           // sell copies of the Software, and to permit persons to whom the Software is
 11           // furnished to do so, subject to the following conditions:
 12           // 
 13           // THE ABOVE COPYRIGHT NOTICE AND THIS PERMISSION NOTICE SHALL BE INCLUDED IN 
 14           // ALL COPIES OR SUBSTANTIAL PORTIONS OF THE SOFTWARE. THE SOFTWARE IS PROVIDED
 15           // "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED, INCLUDING BUT NOT
 16           // LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR 
 17           // PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT 
 18           // HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN 
 19           // ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
 20           // WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
 21           //
 22 mike  1.2 //==============================================================================
 23           //
 24           // Author: Mike Brasher (k.schopmeyer@opengroup.org)
 25           //
 26           // Modified By:
 27           //
 28           //%/////////////////////////////////////////////////////////////////////////////
 29           
 30           #include <Pegasus/Common/HTTPAcceptor.h>
 31           #include <Pegasus/Common/FileSystem.h>
 32           #include <Pegasus/Common/HTTPConnection.h>
 33           #include <Pegasus/Common/HTTPMessage.h>
 34           
 35           #include "HTTPOptions.h"
 36           
 37           PEGASUS_NAMESPACE_BEGIN
 38           
 39           PEGASUS_USING_PEGASUS;
 40           PEGASUS_USING_STD;
 41           
 42           HTTPOptions::HTTPOptions()
 43 mike  1.2 {

 44 mday  1.3 #error  "this class does not appear to be used" // <<< Sat Feb  9 17:33:07 2002 mdd >>>

 45 mike  1.2 }
 46           
 47           HTTPOptions::~HTTPOptions()
 48           {
 49           
 50           }
 51           

 52 mday  1.4 void HTTPOptions::handleEnqueue(Message *message)
 53           {
 54              if (message)
 55              {
 56                 if (message->getType() == HTTP_MESSAGE)
 57                 {
 58           	 handleHTTPMessage((HTTPMessage*)message);
 59                 }
 60           
 61                 //delete message;
 62              }
 63           }
 64           

 65 mike  1.2 void HTTPOptions::handleEnqueue()
 66           {
 67           

 68 mday  1.4    Message* message = dequeue();
 69              handleEnqueue(message);
 70              

 71 mike  1.2 }
 72           
 73           void HTTPOptions::handleHTTPMessage(HTTPMessage* httpMessage)
 74           {
 75            

 76 mday  1.4    // Save queueId:

 77 mike  1.2 

 78 mday  1.4    Uint32 queueId = httpMessage->queueId;

 79 mike  1.2 

 80 mday  1.4    // Parse the HTTP message:
 81              String startLine;
 82              Array<HTTPHeader> headers;
 83              Sint8* content;
 84              Uint32 contentLength;

 85 mike  1.2 

 86 mday  1.4    httpMessage->parse(startLine, headers, content, contentLength);

 87 mike  1.2     

 88 mday  1.4    // Parse the request line:

 89 mike  1.2 

 90 mday  1.4    String methodName;
 91              String requestUri;
 92              String httpVersion;
 93           
 94              HTTPMessage::parseRequestLine(
 95                 startLine, methodName, requestUri, httpVersion);
 96           
 97              // Process M-POST and POST messages:
 98           
 99              if (methodName == "M-POST" || methodName == "POST")
100              {
101                 // Search for "CIMOperation" header:
102           
103                 String cimOperation;
104                 httpMessage->message.append('\0');
105           
106                 //SocketMessage* socketMessage = (SocketMessage*)httpMessage;
107           
108                 if (HTTPMessage::lookupHeader(
109           	     headers, "*CIMOperation", cimOperation, true))
110                 {
111 mday  1.4 	 //_operationMessageQueue->enqueue(socketMessage);
112           	 _operationMessageQueue->enqueue(httpMessage);
113                 }
114                 else if (HTTPMessage::lookupHeader(
115           		  headers, "*CIMExport", cimOperation, true))
116                 {
117           	 //_exportMessageQueue->enqueue(socketMessage);
118           	 _exportMessageQueue->enqueue(httpMessage);
119                 }
120                 else
121                 {
122           	 // ATTN: error discarded at this time!
123           	 return;
124                 }

125 mike  1.2 

126 mday  1.4    }
127              // ATTN: KS Add the else here for Post, etc.  Also go to OPTIONS here.

128 mike  1.2 }
129           
130           

131 mday  1.4 const char* HTTPOptions::getQueueName() const

132 mike  1.2 {

133 mday  1.4    return "HTTPOptions";

134 mike  1.2 }
135           
136           PEGASUS_NAMESPACE_END