--- parser3/src/classes/op.C	2024/09/13 04:01:22	1.263
+++ parser3/src/classes/op.C	2026/04/25 13:38:46	1.280
@@ -1,7 +1,7 @@
 /** @file
 	Parser: parser @b operators.
 
-	Copyright (c) 2001-2023 Art. Lebedev Studio (http://www.artlebedev.com)
+	Copyright (c) 2001-2026 Art. Lebedev Studio (https://www.artlebedev.com)
 	Authors: Konstantin Morshnev <moko@design.ru>, Alexandr Petrosian <paf@design.ru>
 */
 
@@ -17,8 +17,13 @@
 #include "pa_vmethod_frame.h"
 #include "pa_vclass.h"
 #include "pa_charset.h"
+#include "pa_varray.h"
 
-volatile const char * IDENT_OP_C="$Id: op.C,v 1.263 2024/09/13 04:01:22 moko Exp $";
+#ifdef HAVE_SYSLOG
+#include "syslog.h"
+#endif
+
+volatile const char * IDENT_OP_C="$Id: op.C,v 1.280 2026/04/25 13:38:46 moko Exp $";
 
 // defines
 
@@ -76,7 +81,15 @@ public:
 		ULN("json", JSON);
 		#undef ULN
 	}
-} untaint_lang_name2enum;
+
+	static Untaint_lang_name2enum &instance(){
+		static Untaint_lang_name2enum *singleton=NULL;
+		if(!singleton)
+			singleton=new Untaint_lang_name2enum;
+		return *singleton;
+	}
+
+};
 
 // methods
 
@@ -97,7 +110,7 @@ static void _if(Request& r, MethodParams
 }
 
 String::Language get_untaint_lang(const String& lang_name){
-	String::Language lang=untaint_lang_name2enum.get(lang_name);
+	String::Language lang=Untaint_lang_name2enum::instance().get(lang_name);
 	if(!lang)
 		throw Exception(PARSER_RUNTIME,	&lang_name, "invalid taint language");
 	return lang;
@@ -174,30 +187,20 @@ static void _process(Request& r, MethodP
 		size_t options_index=index+1;
 		if(options_index<params.count())
 			if(HashStringValue* options=params.as_hash(options_index)) {
-
-				int valid_options=0;
 				for(HashStringValue::Iterator i(*options); i; i.next() ){
-
 					String::Body key=i.key();
 					Value* value=i.value();
-
 					if(key == "main") {
-						valid_options++;
 						main_alias=&value->as_string();
 					} else if(key == "file") {
-						valid_options++;
 						file_alias=&value->as_string();
 					} else if(key == "lineno") {
-						valid_options++;
 						line_no_alias_offset=value->as_int();
 					} else if(key == "replace") {
-						valid_options++;
 						allow_class_replace=r.process(*value).as_bool();
-					}
+					} else
+						throw Exception(PARSER_RUNTIME, 0, CALLED_WITH_INVALID_OPTION);
 				}
-
-				if(valid_options!=options->count())
-					throw Exception(PARSER_RUNTIME, 0, CALLED_WITH_INVALID_OPTION);
 			}
 
 		uint processe_file_no=file_alias ? r.register_file(r.full_disk_path(*file_alias)) : pseudo_file_no__process;
@@ -279,7 +282,7 @@ static void _while(Request& r, MethodPar
 }
 
 static void _use(Request& r, MethodParams& params) {
-	Value& vfile=params.as_no_junction(0, FILE_NAME_MUST_NOT_BE_CODE);
+	const String& file_name=params.as_file_name(0);
 
 	const String* use_origin=0;
 	bool allow_class_replace=false;
@@ -287,28 +290,16 @@ static void _use(Request& r, MethodParam
 
 	if(params.count()==2)
 		if(HashStringValue* options=params.as_hash(1)) {
-			int valid_options=0;
 			for(HashStringValue::Iterator i(*options); i; i.next() ){
-
 				String::Body key=i.key();
 				Value* value=i.value();
-
 				if(key == "origin") {
-					valid_options++;
 					use_origin=&value->as_string();
-				}
-
-				if(key == "replace") {
-					valid_options++;
+				} else if(key == "replace") {
 					allow_class_replace=r.process(*value).as_bool();
-				}
-
-				if(key == "main") {
-					valid_options++;
+				} else if(key == "main") {
 					load_auto_p=r.process(*value).as_bool();
-				}
-
-				if(valid_options!=options->count())
+				} else
 					throw Exception(PARSER_RUNTIME, 0, CALLED_WITH_INVALID_OPTION);
 			}
 		}
@@ -319,7 +310,7 @@ static void _use(Request& r, MethodParam
 
 	Temp_class_replace class_replace(r, allow_class_replace);
 
-	r.use_file(vfile.as_string(), use_origin, load_auto_p);
+	r.use_file(file_name, use_origin, load_auto_p);
 }
 
 static void set_skip(Request& r, Request::Skip askip) {
@@ -401,7 +392,7 @@ static void _eval(Request& r, MethodPara
 		if(fmt.is_empty()){
 			r.write(value_result);
 		} else {
-			r.write(String(format(value_result.as_double(), fmt.cstrm())));
+			r.write(String(format_double(value_result.as_double(), fmt.cstrm())));
 		}
 	} else
 		r.write(value_result);
@@ -672,7 +663,8 @@ static void locked_process_and_cache_put
 		prolog.expires=info.scope->expires;
 		
 		// buffer -write> file
-		write(f, serialized.str, serialized.length);
+		if(write(f, serialized.str, serialized.length)<0)
+			throw Exception("file.write", 0, "write failed: %s (%d)",  strerror(errno), errno);
 	} else // expired!
 		info.scope->expires=0; // flag it so that could be easily checked by caller
 }
@@ -707,7 +699,7 @@ struct Cache_get_result {
 };
 #endif
 
-static Cache_get_result cache_get(Request_charsets& charsets, const String& file_spec, time_t now) {
+static Cache_get_result cache_get(const String& file_spec, time_t now) {
 	Cache_get_result result={0, false};
 
 	File_read_result file=file_read_binary(file_spec, false /*fail_on_read_problem*/);
@@ -730,7 +722,7 @@ static Cache_get_result cache_get(Reques
 static time_t as_expires(Request& r, MethodParams& params, int index, time_t now) {
 	time_t result;
 	if(VDate* vdate=dynamic_cast<VDate*>(&params[index]))
-		result=vdate->get_time();
+		result=(time_t)vdate->get_time();
 	else
 		result=now+(time_t)params.as_double(index, "lifespan must be date or number", r);
 	
@@ -789,7 +781,7 @@ static void _cache(Request& r, MethodPar
 		catch_code=&params.as_junction(3, "catch_code must be code");
 
 	if(scope.expires>now) {
-		Cache_get_result cached=cache_get(r.charsets, file_spec, now);
+		Cache_get_result cached=cache_get(file_spec, now);
 
 		if(cached.body) { // have cached copy
 			if(cached.expired) {
@@ -893,6 +885,46 @@ static void _sleep_operator(Request& r,
 		pa_sleep((int)trunc(seconds), (int)trunc((seconds-trunc(seconds))*1000000));
 }
 
+static void _a_operator(Request& r, MethodParams& params) {
+	VArray& result=*new VArray;
+	ArrayValue& array=result.array();
+
+	int count=params.count();
+	for(int i=0; i<count; i++)
+		array+=&r.process(params[i]);
+	array.confirm_all_used();
+
+	r.write(result);
+}
+
+#ifdef HAVE_SYSLOG
+static int log_level(const String &name){
+	if(name.is_empty()) return LOG_INFO;
+	const char *sname = str_upper(name.cstr());
+
+	if(!strcmp(sname,"INFO")) return LOG_INFO;
+	if(!strcmp(sname,"WARNING")) return LOG_WARNING;
+	if(!strcmp(sname,"ERROR")) return LOG_ERR;
+	if(!strcmp(sname,"DEBUG")) return LOG_DEBUG;
+	throw Exception("syslog", &name, "invalid log level value");
+}
+#endif
+
+static void _syslog_operator(Request& r, MethodParams& params) {
+	const char* message=params.as_string(1, "message must be string").cstr();
+#ifdef HAVE_SYSLOG
+	const char* ident=params.as_string(0, "ident must be string").cstr();
+	int level=params.count()>2 ? log_level(params.as_string(2, "level must be string")) : LOG_INFO;
+
+	openlog(*ident ? ident : "parser3", LOG_PID, LOG_USER);
+	syslog(level, "%s", message);
+	closelog();
+	(void)r;
+#else
+	SAPI::log(r.sapi_info, "syslog: %s", message);
+#endif
+}
+
 #if defined(WIN32) && defined(_DEBUG) && !defined(_WIN64)
 #	define PA_BPT
 static void _bpt(Request&, MethodParams&) {
@@ -981,6 +1013,12 @@ VClassMAIN::VClassMAIN(): VClass(MAIN_CL
 	add_native_method("throw", Method::CT_ANY, _throw_operator, 1, 3);
 
 	add_native_method("sleep", Method::CT_ANY, _sleep_operator, 1, 1);
+
+	// equivalent to ^array::create[...]
+	add_native_method("A", Method::CT_ANY, _a_operator, 0, 10000, Method::CO_WITHOUT_FRAME);
+
+	// ^syslog[ident;message[;info|warning|error|debug]]
+	add_native_method("syslog", Method::CT_ANY, _syslog_operator, 2, 3);
 }
 
 // constructor & configurator