libs-gsweb/GSWAdaptors/common/GSWAppRequest.c

/* GSWAppRequest.c - GSWeb: Adaptors: App Request
   Copyright (C) 1999 Free Software Foundation, Inc.
   
   Written by:	Manuel Guesdon <mguesdon@sbuilders.com>
   Date: 		Jully 1999
   
   This file is part of the GNUstep Web Library.
   
   This library is free software; you can redistribute it and/or
   modify it under the terms of the GNU Library General Public
   License as published by the Free Software Foundation; either
   version 2 of the License, or (at your option) any later version.
   
   This library is distributed in the hope that it will be useful,
   but WITHOUT ANY WARRANTY; without even the implied warranty of
   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
   Library General Public License for more details.
   
   You should have received a copy of the GNU Library General Public
   License along with this library; if not, write to the Free
   Software Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
*/

#include <stdio.h>
#include <ctype.h>
#include <string.h>
#include <stdlib.h>
#include <sys/param.h>

#include "config.h"
#include "GSWUtil.h"
#include "GSWDict.h"
#include "GSWString.h"
#include "GSWConfig.h"
#include "GSWURLUtil.h"
#include "GSWAppRequestStruct.h"
#include "GSWAppConnect.h"
#include "GSWHTTPRequest.h"
#include "GSWHTTPResponse.h"
#include "GSWAppRequest.h"
#include "GSWHTTPHeaders.h"
#include "GSWLoadBalancing.h"
#include "GSWTemplates.h"

unsigned long glbRequestsNb = 0;
unsigned long glbResponsesNb = 0;

/*

HTTP/1.0 302 Apple WebObjects
x-webobjects-refusenewsessions: 900
Location: /cgi-bin/WebObjects/cancer.woa
x-webobjects-refusing-redirection: YES
x-webobjects-loadaverage: 1
Content-Length: 152

Sorry, your request could not immediately be processed. Please try this URL: <a href="/cgi-bin/WebObjects/cancer.woa">/cgi-bin/WebObjects/cancer.woa</a>
Connection closed by foreign host.

*/

//--------------------------------------------------------------------
GSWHTTPResponse* GSWAppRequest_SendAppRequestToApp(GSWHTTPRequest** p_ppHTTPRequest,
												   GSWURLComponents* p_pURLComponents,
												   GSWAppRequest* p_pAppRequest,
												   CONST char* p_pszHTTPVersion,
												   void* p_pLogServerData)
{
  GSWHTTPResponse* pHTTPResponse=NULL;
  BOOL fAppFound=FALSE;
  BOOL fAppNotResponding=FALSE;
  int iAttemptsRemaining=APP_CONNECT_RETRIES_NB;
  AppConnectHandle hConnect=NULL;
  char *appName = NULL;
  int	appInstance = 0;

  GSWLog(GSW_DEBUG,p_pLogServerData,"Start GSWAppRequest_SendAppRequestToApp");

  if (p_pAppRequest->iInstance>0) //-1 or 0 mean any instance
	fAppFound = GSWLoadBalancing_FindInstance(p_pAppRequest,p_pLogServerData, p_pURLComponents);
  else
	fAppFound = GSWLoadBalancing_FindApp(p_pAppRequest,p_pLogServerData, p_pURLComponents);

  if (!fAppFound)
	{
	  GSWLog(GSW_WARNING,p_pLogServerData,"App not found");
	  //TODO
	  // Call AppStart daemon
	};

  while (!pHTTPResponse && fAppFound && iAttemptsRemaining-->0)
	{
	  fAppNotResponding=FALSE;
	  GSWLog(GSW_INFO,p_pLogServerData,"Trying to contact %s:%d on %s(%d)",
			 p_pAppRequest->pszName,
			 p_pAppRequest->iInstance,
			 p_pAppRequest->pszHost,
			 p_pAppRequest->iPort);
	  
	  hConnect = GSWApp_Open(p_pAppRequest,p_pLogServerData);
	  if (hConnect)
		{
		  if (p_pAppRequest->eType==EAppType_LoadBalanced)
			GSWLoadBalancing_StartAppRequest(p_pAppRequest,p_pLogServerData);
		  
		  GSWLog(GSW_INFO,p_pLogServerData,"%s:%d on %s(%d) connected",
				 p_pAppRequest->pszName,
				 p_pAppRequest->iInstance,
				 p_pAppRequest->pszHost,
				 p_pAppRequest->iPort);
		  
		  GSWHTTPRequest_HTTPToAppRequest(*p_ppHTTPRequest,
										  p_pAppRequest,
										  p_pURLComponents,
										  p_pszHTTPVersion,
										  p_pLogServerData);
		  if (GSWHTTPRequest_SendRequest(*p_ppHTTPRequest,
										 hConnect,
										 p_pLogServerData) != 0)
			{
			  GSWLog(GSW_ERROR,p_pLogServerData,"Failed to send request");
			  GSWApp_Close(hConnect,p_pLogServerData);
			  hConnect=NULL;
			  fAppNotResponding=TRUE;
			}
		  else
			{
			  GSWLog(GSW_INFO,p_pLogServerData,
					 "Request %s sent, awaiting response",
					 (*p_ppHTTPRequest)->pszRequest);
			
			  appName = strdup(p_pAppRequest->pszName);
			  appInstance = p_pAppRequest->iInstance;

			  p_pAppRequest->pRequest = NULL;
			  pHTTPResponse = GSWHTTPResponse_GetResponse(hConnect,p_pLogServerData);
			  p_pAppRequest->pResponse = pHTTPResponse;
			  
			  if (p_pAppRequest->eType == EAppType_LoadBalanced)
				GSWLoadBalancing_StopAppRequest(p_pAppRequest,p_pLogServerData);
				  
			  GSWApp_Close(hConnect,p_pLogServerData);
			  hConnect=NULL;
					  
			  glbResponsesNb++;
			  if (pHTTPResponse)
				{
			  char *value = GSWDict_ValueForKey(pHTTPResponse->pHeaders,"x-gsweb-refusing-redirection");
			  if (value && (strncmp(value,"YES",3)==0)) {
			  	// refuseNewSessions == YES in app
				GSWLog(GSW_INFO,p_pLogServerData,"### This app (%s / %d) is refusing all new sessions ###", appName, appInstance);
				GSWAppInfo_Set(appName, appInstance, TRUE);
			  }

				  GSWLog(GSW_INFO,p_pLogServerData,
						 "received: %d %s",
						 pHTTPResponse->uStatus,
						 pHTTPResponse->pszStatusMessage);
				};
			  if (appName) {
				free(appName); appName = NULL;
			  }
			};
		}
	  else
		{
		  fAppNotResponding=TRUE;
		  GSWLog(GSW_WARNING,p_pLogServerData,"%s:%d NOT LISTENING on %s:%d",
				p_pAppRequest->pszName,
				p_pAppRequest->iInstance,
				p_pAppRequest->pszHost,
				p_pAppRequest->iPort);
		  //TODO
		  /*
		  if (p_pAppRequest->eType == EAppType_Auto)
		  GSWLoadBalancing_MarkNotRespondingApp(p_pAppRequest,p_pLogServerData);

		  else*/ if (p_pAppRequest->eType==EAppType_LoadBalanced)
			{
			  GSWLoadBalancing_MarkNotRespondingApp(p_pAppRequest,p_pLogServerData);
			  if (iAttemptsRemaining-->0)
				fAppFound=GSWLoadBalancing_FindApp(p_pAppRequest,p_pLogServerData, p_pURLComponents);
			};
		};
	};
  if (fAppNotResponding)
	{
	  pHTTPResponse = GSWHTTPResponse_BuildErrorResponse(p_pAppRequest,
														 GSWTemplate_ErrorNoResponseMessage(TRUE),
														 p_pLogServerData);
	};
  if (!pHTTPResponse)
	{
	  GSWLog(GSW_WARNING,p_pLogServerData,
			 "Application %s not found or not responding",
			 p_pAppRequest->pszName);
	  pHTTPResponse = GSWDumpConfigFile(p_pURLComponents,p_pLogServerData);
	  if (!pHTTPResponse)
		{
		  pHTTPResponse = GSWHTTPResponse_BuildErrorResponse(p_pAppRequest,"No App Found",p_pLogServerData);
		  pHTTPResponse->uStatus = 404;
		  if (pHTTPResponse->pszStatusMessage)
			{
			  free(pHTTPResponse->pszStatusMessage);
			  pHTTPResponse->pszStatusMessage=NULL;
			};
		  pHTTPResponse->pszStatusMessage = strdup("File Not found");
		}
	};
  GSWHTTPRequest_Free(*p_ppHTTPRequest,p_pLogServerData);
  *p_ppHTTPRequest=NULL;
  GSWLog(GSW_DEBUG,p_pLogServerData,"Stop GSWAppRequest_SendAppRequestToApp");
  return pHTTPResponse;
};

//--------------------------------------------------------------------
GSWHTTPResponse* GSWAppRequest_HandleRequest(GSWHTTPRequest** p_ppHTTPRequest,
											 GSWURLComponents* p_pURLComponents,
											 CONST char* p_pszHTTPVersion,
											 CONST char* p_pszDocRoot,
											 CONST char* p_pszTestAppName,
											 void* p_pLogServerData)
{
  GSWHTTPResponse* pHTTPResponse=NULL;
  GSWLog(GSW_DEBUG,p_pLogServerData,"Start GSWAppRequest_HandleRequest");
  glbRequestsNb++;
  if (!p_pURLComponents)
	{
	  GSWLog(GSW_CRITICAL,p_pLogServerData,"p_pURLComponents is NULL in GSWAppRequest_HandleRequest");
	}
  else
	{
	  if (p_pURLComponents->stAppName.iLength<=0
		  || !p_pURLComponents->stAppName.pszStart)
		{
		  pHTTPResponse=GSWHTTPResponse_BuildErrorResponse(NULL,"No Application Name",p_pLogServerData);
		}
	  else
		{
		  char szAppName[MAXPATHLEN+1]="";
		  char szHost[MAXHOSTNAMELEN+1]="";
		  GSWAppRequest stAppRequest;
		  memset(&stAppRequest,0,sizeof(stAppRequest));

		  GSWLog(GSW_DEBUG,p_pLogServerData,"Copy AppName");
		  // Get App Name
		  strncpy(szAppName,
				  p_pURLComponents->stAppName.pszStart,
				  p_pURLComponents->stAppName.iLength);
		  szAppName[p_pURLComponents->stAppName.iLength]=0;

		  DeleteTrailingSlash(szAppName);
		  if (strcmp(szAppName,p_pszTestAppName)==0)
			pHTTPResponse=GSWHTTPResponse_BuildStatusResponse(*p_ppHTTPRequest,p_pLogServerData);
		  else
			{
			  GSWLog(GSW_DEBUG,p_pLogServerData,"Get HostByName");
			  // Get Host Name
			  if (p_pURLComponents->stAppHost.iLength>0 && p_pURLComponents->stAppHost.pszStart)
				{
				  strncpy(szHost,
						  p_pURLComponents->stAppHost.pszStart,
						  p_pURLComponents->stAppHost.iLength);
				  szHost[p_pURLComponents->stAppHost.iLength] = '\0';
				};
		  
			  // Get Request Instance Number
			  GSWLog(GSW_DEBUG,p_pLogServerData,"Get Request Instance Number");
		  
			  // in URL  ?
			  if (p_pURLComponents->stAppNumber.iLength>0 && p_pURLComponents->stAppNumber.pszStart)
				stAppRequest.iInstance = atoi(p_pURLComponents->stAppNumber.pszStart);
			  
			  // In Cookie ?
			  else
				{
				  CONST char* pszCookie=GSWHTTPRequest_HeaderForKey(*p_ppHTTPRequest,g_szHeader_Cookie);
				  if (pszCookie)
					{
					  CONST char* pszInstanceCookie=strstr(pszCookie, g_szGSWeb_InstanceCookie[GSWNAMES_INDEX]);
					  if (pszInstanceCookie)
                                            {
                                              stAppRequest.iInstance = atoi(pszInstanceCookie + strlen(g_szGSWeb_InstanceCookie[GSWNAMES_INDEX]));
                                              GSWLog(GSW_INFO,p_pLogServerData,"Cookie instance %d from %s",
                                                     stAppRequest.iInstance,
                                                     pszCookie);
                                            }
                                          else
                                            {
                                              pszInstanceCookie=strstr(pszCookie, g_szGSWeb_InstanceCookie[WONAMES_INDEX]);
                                              if (pszInstanceCookie)
						{
						  stAppRequest.iInstance = atoi(pszInstanceCookie + strlen(g_szGSWeb_InstanceCookie[WONAMES_INDEX]));
						  GSWLog(GSW_INFO,p_pLogServerData,"Cookie instance %d from %s",
                                                         stAppRequest.iInstance,
                                                         pszCookie);
						};
                                            };
					};
				};
			  
			  stAppRequest.pszName = szAppName;
			  stAppRequest.pszHost = szHost;
			  stAppRequest.pszDocRoot = p_pszDocRoot;
			  stAppRequest.pRequest = *p_ppHTTPRequest;
			  stAppRequest.uURLVersion = (p_pURLComponents->stVersion.pszStart) ? 
				atoi(p_pURLComponents->stVersion.pszStart) : GSWEB_VERSION_MAJOR;
		  
			  GSWLog(GSW_DEBUG,p_pLogServerData,"Add Header");
			  GSWHTTPRequest_AddHeader(*p_ppHTTPRequest,
									   g_szHeader_GSWeb_ServerAdaptor,
									   g_szGSWeb_ServerAndAdaptorVersion);
			  GSWLog(GSW_DEBUG,p_pLogServerData,"SendAppRequestToApp");
			  pHTTPResponse=GSWAppRequest_SendAppRequestToApp(p_ppHTTPRequest,
															  p_pURLComponents,
															  &stAppRequest,
															  p_pszHTTPVersion,
															  p_pLogServerData);
			};
		};
	};
  GSWLog(GSW_DEBUG,p_pLogServerData,"Stop GSWAppRequest_HandleRequest");
  return pHTTPResponse;
};