parser3/src/classes/file.C - diff

Return to file.C CVS log

Up to [parser3project] / parser3 / src / classes

Diff for /parser3/src/classes/file.C between versions 1.67 and 1.88

version 1.67, 2001/12/15 21:28:17	version 1.88, 2002/06/18 14:24:00
Line 1	Line 1
/** @file	/** @file
Parser: @b file parser class.	Parser: @b file parser class.

Copyright (c) 2001 ArtLebedev Group (http://www.artlebedev.com)	Copyright (c) 2001, 2002 ArtLebedev Group (http://www.artlebedev.com)
Author: Alexander Petrosyan <paf@design.ru> (http://paf.design.ru)	Author: Alexandr Petrosian <paf@design.ru> (http://paf.design.ru)

$Id$	$Id$
*/	*/
Line 22	Line 22
#include "pa_vtable.h"	#include "pa_vtable.h"
#include "pa_charset.h"	#include "pa_charset.h"

// consts

// defines	// defines

#define FILE_CLASS_NAME "file"

#define TEXT_MODE_NAME "text"	#define TEXT_MODE_NAME "text"

	// consts

	/// from apache-1.3\|src\|support\|suexec.c
	static const char *suexec_safe_env_lst[]={
	"AUTH_TYPE",
	"CONTENT_LENGTH",
	"CONTENT_TYPE",
	"DATE_GMT",
	"DATE_LOCAL",
	"DOCUMENT_NAME",
	"DOCUMENT_PATH_INFO",
	"DOCUMENT_ROOT",
	"DOCUMENT_URI",
	"FILEPATH_INFO",
	"GATEWAY_INTERFACE",
	"LAST_MODIFIED",
	"PATH_INFO",
	"PATH_TRANSLATED",
	"QUERY_STRING",
	"QUERY_STRING_UNESCAPED",
	"REMOTE_ADDR",
	"REMOTE_HOST",
	"REMOTE_IDENT",
	"REMOTE_PORT",
	"REMOTE_USER",
	"REDIRECT_QUERY_STRING",
	"REDIRECT_STATUS",
	"REDIRECT_URL",
	"REQUEST_METHOD",
	"REQUEST_URI",
	"SCRIPT_FILENAME",
	"SCRIPT_NAME",
	"SCRIPT_URI",
	"SCRIPT_URL",
	"SERVER_ADMIN",
	"SERVER_NAME",
	"SERVER_ADDR",
	"SERVER_PORT",
	"SERVER_PROTOCOL",
	"SERVER_SOFTWARE",
	"UNIQUE_ID",
	"USER_NAME",
	"TZ",
	NULL
	};

// class	// class

class MFile : public Methoded {	class MFile : public Methoded {
Line 61 static void _save(Request& r, const Stri	Line 103 static void _save(Request& r, const Stri
}	}

static void _delete(Request& r, const String&, MethodParams *params) {	static void _delete(Request& r, const String&, MethodParams *params) {
Pool& pool=r.pool();
Value& vfile_name=params->as_no_junction(0, "file name must not be code");	Value& vfile_name=params->as_no_junction(0, "file name must not be code");

// unlink	// unlink
file_delete(pool, r.absolute(vfile_name.as_string()));	file_delete(r.absolute(vfile_name.as_string()));
}	}

static void _move(Request& r, const String&, MethodParams *params) {	static void _move(Request& r, const String&, MethodParams *params) {
Pool& pool=r.pool();
Value& vfrom_file_name=params->as_no_junction(0, "from file name must not be code");	Value& vfrom_file_name=params->as_no_junction(0, "from file name must not be code");
Value& vto_file_name=params->as_no_junction(1, "to file name must not be code");	Value& vto_file_name=params->as_no_junction(1, "to file name must not be code");

// move	// move
file_move(pool,	file_move(
r.absolute(vfrom_file_name.as_string()),	r.absolute(vfrom_file_name.as_string()),
r.absolute(vto_file_name.as_string()));	r.absolute(vto_file_name.as_string()));
}	}
Line 87 static void _find(Request& r, const Stri	Line 127 static void _find(Request& r, const Stri

// passed file name simply exists in current dir	// passed file name simply exists in current dir
if(file_readable(r.absolute(lfile_name))) {	if(file_readable(r.absolute(lfile_name))) {
r.write_no_lang(*new(pool) VString(lfile_name));	r.write_no_lang(lfile_name);
return;	return;
}	}

// scan .. dirs for result	// scan .. dirs for result
for(int i=0; i<FIND_MONKEY_MAX_HOPS; i++) {	for(int i=0; i<FIND_MONKEY_MAX_HOPS; i++) {
String test_name(pool);	String local_test_name(pool);
for(int j=0; j<i; j++)	for(int j=0; j<i; j++)
test_name.APPEND_CONST("../");	local_test_name.APPEND_CONST("../");
test_name.append(lfile_name, String::UL_CLEAN);	local_test_name.append(lfile_name, String::UL_CLEAN);
if(file_readable(r.absolute(test_name))) {	if(file_readable(r.absolute(local_test_name))) {
r.write_no_lang(new(pool) VString(new(pool) String(test_name)));	r.write_no_lang(*new(pool) String(local_test_name));
return;	return;
}	}
}	}
Line 149 static void _stat(Request& r, const Stri	Line 189 static void _stat(Request& r, const Stri
ff.put(*new(pool) String(pool, "cdate"), new(pool) VDate(pool, ctime));	ff.put(*new(pool) String(pool, "cdate"), new(pool) VDate(pool, ctime));
}	}

	static bool is_safe_env_key(const char *key) {
	if(strncasecmp(key, "HTTP_", 5)==0)
	return true;
	if(strncasecmp(key, "CGI_", 4)==0)
	return true;
	for(int i=0; suexec_safe_env_lst[i]; i++) {
	if(strcasecmp(key, suexec_safe_env_lst[i])==0)
	return true;
	}
	return false;
	}
static void append_env_pair(const Hash::Key& key, Hash::Val value, void info) {	static void append_env_pair(const Hash::Key& key, Hash::Val value, void info) {
Hash& hash=static_cast<Hash >(info);	Hash& hash=static_cast<Hash >(info);
	if(!is_safe_env_key(key.cstr()))
	throw Exception("parser.runtime",
	&key,
	"not safe environment variable");
hash.put(key, &static_cast<Value *>(value)->as_string());	hash.put(key, &static_cast<Value *>(value)->as_string());
}	}

static void pass_cgi_header_attribute(Array::Item value, void info) {	static void pass_cgi_header_attribute(Array::Item value, void info) {
String& string=static_cast<String >(value);	String& string=static_cast<String >(value);
Hash& hash=static_cast<Hash >(info);	Hash& hash=static_cast<Hash >(info);
Line 163 static void pass_cgi_header_attribute(Ar	Line 217 static void pass_cgi_header_attribute(Ar
new(string.pool()) VString(string.mid(colon_pos+1, string.size())));	new(string.pool()) VString(string.mid(colon_pos+1, string.size())));
}	}
/** @todo fix `` in perl - they produced flipping consoles and no output to perl	/** @todo fix `` in perl - they produced flipping consoles and no output to perl
@test EPASS, ECSTR [touched them when optimized hash]
*/	*/
static void _exec_cgi(Request& r, const String& method_name, MethodParams *params,	static void _exec_cgi(Request& r, const String& method_name, MethodParams *params,
bool cgi) {	bool cgi) {
Line 181 static void _exec_cgi(Request& r, const	Line 234 static void _exec_cgi(Request& r, const
name##value.APPEND_CONST(value_cstr); \	name##value.APPEND_CONST(value_cstr); \
env.put(name##key, &name##value); \	env.put(name##key, &name##value); \
}	}
#define EPASS(name) \	// passing SAPI::environment
String name##key(pool, #name); \	if(const char const pairs=SAPI::environment(pool)) {
String name##value(pool); \	while(const char pair=pairs++)
if(const char *value_cstr=SAPI::get_env(pool, #name)) { \	if(const char *eq_at=strchr(pair, '=')) {
name##value.APPEND_CONST(value_cstr); \	String& key=*new(pool) String(pool, pair, eq_at-pair);
env.put(name##key, &name##value); \	String& value=*new(pool) String(pool, eq_at+1);
}	env.put(key, &value);
	}
	}

// const	// const
ECSTR(GATEWAY_INTERFACE, "CGI/1.1");	ECSTR(GATEWAY_INTERFACE, "CGI/1.1");
Line 202 static void _exec_cgi(Request& r, const	Line 257 static void _exec_cgi(Request& r, const
snprintf(content_length_cstr, MAX_NUMBER, "%u", r.info.content_length);	snprintf(content_length_cstr, MAX_NUMBER, "%u", r.info.content_length);
String content_length(pool, content_length_cstr);	String content_length(pool, content_length_cstr);
ECSTR(CONTENT_LENGTH, content_length_cstr);	ECSTR(CONTENT_LENGTH, content_length_cstr);
ECSTR(HTTP_COOKIE, r.info.cookie);	// SCRIPT_*
ECSTR(HTTP_USER_AGENT, r.info.user_agent);
// passing some SAPI:get_env-s
EPASS(SERVER_PROTOCOL);
EPASS(SERVER_NAME);
EPASS(SERVER_PORT);
EPASS(HTTP_REFERER);
EPASS(REMOTE_ADDR);
EPASS(REMOTE_HOST);
EPASS(REMOTE_USER);
// SCRIPT_NAME
env.put(*new(pool) String(pool, "SCRIPT_NAME"), &script_name);	env.put(*new(pool) String(pool, "SCRIPT_NAME"), &script_name);
#ifdef WIN32	//env.put(*new(pool) String(pool, "SCRIPT_FILENAME"), ??&script_name);
// WIN32 shell
EPASS(COMSPEC);
#endif

if(params->size()>1) {	if(params->size()>1) {
Value& venv=params->as_no_junction(1, "env must not be code");	Value& venv=params->as_no_junction(1, "env must not be code");
Line 238 static void _exec_cgi(Request& r, const	Line 280 static void _exec_cgi(Request& r, const
//out.APPEND_CONST("content-type:text/plain\nheader:test-header\n\ntest-body");	//out.APPEND_CONST("content-type:text/plain\nheader:test-header\n\ntest-body");
//out<<in;	//out<<in;
String& err=*new(pool) String(pool);	String& err=*new(pool) String(pool);
int status=pa_exec(script_name, &env, argv, in, out, err);	int status=pa_exec(false/forced_allow/, script_name, &env, argv, in, out, err);

VFile& self=static_cast<VFile >(r.self);	VFile& self=static_cast<VFile >(r.self);

Line 254 static void _exec_cgi(Request& r, const	Line 296 static void _exec_cgi(Request& r, const
}	}
if(pos<0) {	if(pos<0) {
delim_size=0; // calm down, compiler	delim_size=0; // calm down, compiler
throw Exception(0, 0,	throw Exception(0,
&method_name,	&method_name,
"output does not contain CGI header; exit code=%d; outsize=%u; out: \"%s\"; errsize=%u; err: \"%s\"",	"output does not contain CGI header; exit status=%d; stdoutsize=%u; stdout: \"%s\"; stderrsize=%u; stderr: \"%s\"",
status,	status,
(uint)out.size(), out.cstr(),	(uint)out.size(), out.cstr(),
(uint)err.size(), err.cstr());	(uint)err.size(), err.cstr());
Line 303 static void _list(Request& r, const Stri	Line 345 static void _list(Request& r, const Stri

const String *regexp;	const String *regexp;
pcre *regexp_code;	pcre *regexp_code;
int ovecsize;	const int ovecsize=(1/match/)*3;
int *ovector;	int ovector[ovecsize];
if(params->size()>1) {	if(params->size()>1) {
regexp=&params->as_no_junction(1, "regexp must not be code").as_string();	regexp=&params->as_no_junction(1, "regexp must not be code").as_string();

Line 316 static void _list(Request& r, const Stri	Line 358 static void _list(Request& r, const Stri
pool.get_client_charset().pcre_tables);	pool.get_client_charset().pcre_tables);

if(!regexp_code)	if(!regexp_code)
throw Exception(0, 0,	throw Exception(0,
&regexp->mid(erroffset, regexp->size()),	&regexp->mid(erroffset, regexp->size()),
"regular expression syntax error - %s", errptr);	"regular expression syntax error - %s", errptr);

ovector=(int )pool.malloc(sizeof(int)(ovecsize=(1/match/)*3));
} else	} else
regexp_code=0;	regexp_code=0;

Line 344 static void _list(Request& r, const Stri	Line 384 static void _list(Request& r, const Stri
suits=false;	suits=false;
else if(exec_result<0) {	else if(exec_result<0) {
(*pcre_free)(regexp_code);	(*pcre_free)(regexp_code);
throw Exception(0, 0,	throw Exception(0,
regexp,	regexp,
"regular expression execute (%d)",	"regular expression execute (%d)",
exec_result);	exec_result);
Line 369 static void _list(Request& r, const Stri	Line 409 static void _list(Request& r, const Stri

// write out result	// write out result
VTable& result=*new(pool) VTable(pool, &table);	VTable& result=*new(pool) VTable(pool, &table);
result.set_name(method_name);
r.write_no_lang(result);	r.write_no_lang(result);
}	}

// constructor	#ifndef DOXYGEN
	struct Lock_execute_body_info {
	Request *r;
	Value *body_code;
	};
	#endif
	static void lock_execute_body(int , void *context) {
	Lock_execute_body_info& info=static_cast<Lock_execute_body_info >(context);

MFile::MFile(Pool& apool) : Methoded(apool) {	// execute body
set_name(*NEW String(pool(), FILE_CLASS_NAME));	info.r->write_assign_lang(info.r->process(*info.body_code));
	};
	static void _lock(Request& r, const String& method_name, MethodParams *params) {
	const String& file_spec=r.absolute(params->as_string(0, "file name must be string"));
	Value& body_code=params->as_junction(1, "body must be code");

	Lock_execute_body_info info={&r, &body_code};
	file_write_action_under_lock(file_spec, "lock", lock_execute_body, &info);
	}

	// constructor

	MFile::MFile(Pool& apool) : Methoded(apool, "file") {
// ^save[mode;file-name]	// ^save[mode;file-name]
add_native_method("save", Method::CT_DYNAMIC, _save, 2, 2);	add_native_method("save", Method::CT_DYNAMIC, _save, 2, 2);

Line 413 MFile::MFile(Pool& apool) : Methoded(apo	Line 469 MFile::MFile(Pool& apool) : Methoded(apo
// ^file:list[path][regexp]	// ^file:list[path][regexp]
add_native_method("list", Method::CT_STATIC, _list, 1, 2);	add_native_method("list", Method::CT_STATIC, _list, 1, 2);

	// ^file:lock[path]{code}
	add_native_method("lock", Method::CT_STATIC, _lock, 2, 2);

}	}

// global variable	// global variable

E-mail:

Removed from v.1.67
changed lines
	Added in v.1.88