--- parser3/src/classes/memcached.C	2012/06/17 21:19:03	1.6
+++ parser3/src/classes/memcached.C	2026/10/13 23:16:35	1.22
@@ -1,7 +1,7 @@
 /** @file
 	Parser: memcached class.
 
-	Copyright (c) 2001-2012 Art. Lebedev Studio (http://www.artlebedev.com)
+	Copyright (c) 2001-2026 Art. Lebedev Studio (https://www.artlebedev.com)
 	Authors:
 		Ivan Poluyanov <ivan-poluyanov@yandex.ru>
 		Artem Stepanov <timofei1394@thesecure.in>
@@ -12,19 +12,20 @@
 #include "pa_request.h"
 #include "pa_vstring.h"
 #include "pa_vtable.h"
+#include "pa_varray.h"
 #include "pa_vbool.h"
 #include "pa_vmemcached.h"
 
-volatile const char * IDENT_MEMCACHED_C="$Id: memcached.C,v 1.6 2012/06/17 21:19:03 moko Exp $";
+volatile const char * IDENT_MEMCACHED_C="$Id: memcached.C,v 1.22 2026/10/13 23:16:35 moko Exp $";
 
 class MMemcached: public Methoded {
 public: // VStateless_class
-	Value* create_new_value(Pool&) { return new VMemcached(); }
+	Value* create_new_value(Pool& apool) { return new VMemcached(apool); }
 public:
 	MMemcached();
 };
 
-DECLARE_CLASS_VAR(memcached, new MMemcached, 0);
+DECLARE_CLASS_VAR(memcached, new MMemcached);
 
 static void _open(Request& r, MethodParams& params) {
 	VMemcached& self=GET_SELF(r, VMemcached);
@@ -32,25 +33,28 @@ static void _open(Request& r, MethodPara
 	time_t ttl=params.count()>1 ? params.as_int(1, "default expiration must be int", r) : 0;
 
 	if(HashStringValue* options=param_value.get_hash()){
+		bool connect=true;
 		String result;
 		for(HashStringValue::Iterator i(*options); i; i.next()){
-			if(Value *b=i.value()->as("bool")){
+			if(i.key() == "skip-connect"){
+				connect=!i.value()->as_bool();
+			} else if(Value *b=dynamic_cast<VBool*>(i.value())){
 				if(b->as_bool())
 					result << (result.is_empty() ? "--" : " --") << i.key();
 			} else {
 				const String& value=i.value()->as_string();
 				if(!value.is_empty())
-					result << (result.is_empty() ? "--" : " --") << i.key() << "=\"" << value.untaint_cstr(String::L_JS) << "\"";
+					result << (result.is_empty() ? "--" : " --") << i.key() << "=" << value;
 			}
 		}
-		self.open(result, ttl);
+		self.open(result, ttl, connect);
 	} else {
 		const String& connect_string=params.as_string(0, "param must be connection string or options hash");
 		self.open_parse(connect_string, ttl);
 	}
 }
 
-static void _flush(Request& r, MethodParams& params) {
+static void _clear(Request& r, MethodParams& params) {
 	VMemcached& self=GET_SELF(r, VMemcached);
 	time_t ttl=(params.count()>0) ? params.as_int(0, "expiration must be int", r) : 0;
 
@@ -59,38 +63,37 @@ static void _flush(Request& r, MethodPar
 
 static void _mget(Request& r, MethodParams& params) {
 	VMemcached& self=GET_SELF(r, VMemcached);
-	Value& param=params.as_no_junction(0, PARAM_MUST_NOT_BE_CODE);
 
-	if(param.is_string()){
+	ArrayString keys(params.count());
 
-		ArrayString keys(params.count());
-		
-		for(size_t i=0; i<params.count(); i++) {
-			keys+=&params.as_string(i, "key must be string");
-		}
-
-		r.write_no_lang(self.mget(keys));
-	} else {
-		Table* table=param.get_table();
-		if(table==0){
-			throw Exception("memcached", 0, "key must be string or table");
-		}
-		
-		ArrayString keys(table->count());
-		
-		for(size_t i=0; i<table->count(); i++) {
-			keys+=table->get(i)->get(0);
-		}
-
-		r.write_no_lang(self.mget(keys));
+	for(size_t i=0; i<params.count(); i++) {
+		Value& param=params.as_no_junction(i, PARAM_MUST_NOT_BE_CODE);
+		if(const String* string=param.get_string()){
+			keys+=string;
+		} else if(Table* table=param.get_table()){
+			for(size_t j=0; j<table->count(); j++)
+				keys+=table->get(j)->get(0);
+		} else if(VArray* array=dynamic_cast<VArray*>(&param)){
+			for(ArrayValue::Iterator j(array->array()); j; j.next()){
+				if(Value* value=j.value()){
+					const String* string=value->get_string();
+					if(!string)
+						value->bark("array element is '%s', it does not have string value");
+					keys+=string;
+				}
+			}
+		} else
+			throw Exception("memcached", 0, "key must be string, table or array of strings");
 	}
+
+	r.write(self.mget(keys));
 }
 
 static void _add(Request& r, MethodParams& params) {
 	VMemcached& self=GET_SELF(r, VMemcached);
 	const String& key=params.as_string(0, "key must be string");
 
-	r.write_no_lang(VBool::get(self.add(key, &params.as_no_junction(1, PARAM_MUST_NOT_BE_CODE))));
+	r.write(VBool::get(self.add(key, &params.as_no_junction(1, PARAM_MUST_NOT_BE_CODE))));
 }
 
 static void _delete(Request& r, MethodParams& params) {
@@ -100,10 +103,17 @@ static void _delete(Request& r, MethodPa
 	self.remove(key);
 }
 
+static void _release(Request& r, MethodParams&) {
+	VMemcached& self=GET_SELF(r, VMemcached);
+
+	self.quit();
+}
+
 MMemcached::MMemcached() : Methoded("memcached") {
 	add_native_method("open", Method::CT_DYNAMIC, _open, 1, 2);
-	add_native_method("flush", Method::CT_DYNAMIC, _flush, 0, 1);
+	add_native_method("clear", Method::CT_DYNAMIC, _clear, 0, 1);
 	add_native_method("mget", Method::CT_DYNAMIC, _mget, 1, 1000);
 	add_native_method("add", Method::CT_DYNAMIC, _add, 2, 2);
 	add_native_method("delete", Method::CT_DYNAMIC, _delete, 1, 1);
+	add_native_method("release", Method::CT_DYNAMIC, _release, 0, 0);
 }