Возможность передавать в качестве обработчика строку, приводимую к описанию оповещения

Author: nixel2007

github.os

@@ -57,8 +57,17 @@
 	Сообщить(Элемент.Имя);
 КонецЦикла;
 
-// githubUsers.sort(_.followers)
+Потоки.ИзКоллекции(Таблица)
+	.Фильтровать("Результат = ДополнительныеПараметры.Элемент.Местоположение = ""Россия""")
+	.Сортировать("Результат = ДополнительныеПараметры.Элемент1.Фолловеры < ДополнительныеПараметры.Элемент2.Фолловеры")
+	.Первые(5)
+	.Сортировать("Результат = ДополнительныеПараметры.Элемент1.Контрибьюции < ДополнительныеПараметры.Элемент2.Контрибьюции")
+	.Первые(3)
+	.ДляКаждого("Сообщить(ДополнительныеПараметры.Элемент.Имя)");
+
+// githubUsers
 // 	.filter(_.location == 'Russia') 
+//	.sort(_.followers)
 // 	.take(1000)
 // 	.sort(_.contributions)
 // 	.take(256)

src/Классы/Поток.os

@@ -1,10 +1,13 @@
 #Использовать notify
 #Использовать logos
+#Использовать tempfiles
 
 Перем Лог;
 
 Перем Конвейер;
 Перем ПотокСлужебный;
+Перем ЛокальныйМенеджерВременныхФайлов;
+Перем ВременныеОписанияОповещений;
 
 // Общее API
 
@@ -35,35 +38,51 @@
 
 КонецФункции
 
-Функция Различные(ОбработчикСравнения = Неопределено) Экспорт
+Функция Различные(Знач ОбработчикСравнения = Неопределено, Знач ДополнительныеПараметры = Неопределено) Экспорт
 
 	Если ОбработчикСравнения = Неопределено Тогда
 		ОбработчикСравнения = Потоки.СтандартныйОбработчикСравнения();
+	Иначе
+		Если ТипЗнч(ОбработчикСравнения) = Тип("Строка") Тогда
+			ОбработчикСравнения = СформироватьВременноеОписаниеОповещения(ОбработчикСравнения, ДополнительныеПараметры);
+		КонецЕсли;	
 	КонецЕсли;
 
 	ПоложитьЯчейкуВКонвейер("Различные", ОбработчикСравнения);
 	Возврат ЭтотОбъект;
 
 КонецФункции
 
-Функция Обработать(ОписаниеОповещения) Экспорт
+Функция Обработать(Знач ОписаниеОповещения, Знач ДополнительныеПараметры = Неопределено) Экспорт
+	
+	Если ТипЗнч(ОписаниеОповещения) = Тип("Строка") Тогда
+		ОписаниеОповещения = СформироватьВременноеОписаниеОповещения(ОписаниеОповещения, ДополнительныеПараметры);
+	КонецЕсли;
 
 	ПоложитьЯчейкуВКонвейер("Обработать", ОписаниеОповещения);
 	Возврат ЭтотОбъект;
 
 КонецФункции
 
-Функция Фильтровать(ОписаниеОповещения) Экспорт
-	
+Функция Фильтровать(Знач ОписаниеОповещения, Знач ДополнительныеПараметры = Неопределено) Экспорт
+		
+	Если ТипЗнч(ОписаниеОповещения) = Тип("Строка") Тогда
+		ОписаниеОповещения = СформироватьВременноеОписаниеОповещения(ОписаниеОповещения, ДополнительныеПараметры);
+	КонецЕсли;
+
 	ПоложитьЯчейкуВКонвейер("Фильтровать", ОписаниеОповещения);
 	Возврат ЭтотОбъект;
 
 КонецФункции
 
-Функция Сортировать(Знач ОбработчикСравнения = Неопределено) Экспорт
+Функция Сортировать(Знач ОбработчикСравнения = Неопределено, Знач ДополнительныеПараметры = Неопределено) Экспорт
 
 	Если ОбработчикСравнения = Неопределено Тогда
 		ОбработчикСравнения = Потоки.СтандартныйОбработчикСравнения();
+	Иначе
+		Если ТипЗнч(ОбработчикСравнения) = Тип("Строка") Тогда
+			ОбработчикСравнения = СформироватьВременноеОписаниеОповещения(ОбработчикСравнения, ДополнительныеПараметры);
+		КонецЕсли;
 	КонецЕсли;
 
 	ПоложитьЯчейкуВКонвейер("Сортировать", ОбработчикСравнения);
@@ -132,10 +151,14 @@
 
 КонецФункции
 
-Функция ДляКаждого(ОписаниеОповещения) Экспорт
+Функция ДляКаждого(Знач ОписаниеОповещения, Знач ДополнительныеПараметры = Неопределено) Экспорт
 
 	Лог.Отладка("ДляКаждого");
-	
+
+	Если ТипЗнч(ОписаниеОповещения) = Тип("Строка") Тогда
+		ОписаниеОповещения = СформироватьВременноеОписаниеОповещения(ОписаниеОповещения, ДополнительныеПараметры);
+	КонецЕсли;
+
 	ПройтиКонвейер();
 
 	Результат = Новый Массив;
@@ -144,16 +167,22 @@
 
 	ПотокСлужебный.ВыполнитьОбработать(Результат, ДополнительныеПараметры);
 
+	ОчиститьВременныеОписанияОповещений();
+
 	Возврат Результат;
 
 КонецФункции
 
-Функция Минимум(ОбработчикСравнения = Неопределено) Экспорт
+Функция Минимум(Знач ОбработчикСравнения = Неопределено, Знач ДополнительныеПараметры = Неопределено) Экспорт
 
 	Лог.Отладка("Минимум");
 
 	Если ОбработчикСравнения = Неопределено Тогда
 		ОбработчикСравнения = Потоки.СтандартныйОбработчикСравнения();
+	Иначе
+		Если ТипЗнч(ОбработчикСравнения) = Тип("Строка") Тогда
+			ОбработчикСравнения = СформироватьВременноеОписаниеОповещения(ОбработчикСравнения, ДополнительныеПараметры);
+		КонецЕсли;
 	КонецЕсли;
 
 	ПройтиКонвейер();
@@ -164,6 +193,8 @@
 
 	ПотокСлужебный.ВыполнитьСортировать(Результат, ДополнительныеПараметры);
 
+	ОчиститьВременныеОписанияОповещений();
+
 	Если Результат.Количество() = 0 Тогда
 		Возврат Неопределено;
 	Иначе
@@ -172,12 +203,16 @@
 
 КонецФункции
 
-Функция Максимум(ОбработчикСравнения = Неопределено) Экспорт
+Функция Максимум(Знач ОбработчикСравнения = Неопределено, Знач ДополнительныеПараметры = Неопределено) Экспорт
 
 	Лог.Отладка("Максимум");
 
 	Если ОбработчикСравнения = Неопределено Тогда
 		ОбработчикСравнения = Потоки.СтандартныйОбработчикСравнения();
+	Иначе
+		Если ТипЗнч(ОбработчикСравнения) = Тип("Строка") Тогда
+			ОбработчикСравнения = СформироватьВременноеОписаниеОповещения(ОбработчикСравнения, ДополнительныеПараметры);
+		КонецЕсли;
 	КонецЕсли;
 
 	ПройтиКонвейер();
@@ -188,6 +223,8 @@
 
 	ПотокСлужебный.ВыполнитьСортировать(Результат, ДополнительныеПараметры);
 
+	ОчиститьВременныеОписанияОповещений();
+		
 	Если Результат.Количество() = 0 Тогда
 		Возврат Неопределено;
 	Иначе
@@ -196,10 +233,14 @@
 
 КонецФункции
 
-Функция Сократить(Обработчик, НачальноеЗначение = Неопределено) Экспорт
+Функция Сократить(Знач Обработчик, Знач НачальноеЗначение = Неопределено, Знач ДополнительныеПараметры = Неопределено) Экспорт
 
 	Лог.Отладка("Сократить");
 
+	Если ТипЗнч(Обработчик) = Тип("Строка") Тогда
+		Обработчик = СформироватьВременноеОписаниеОповещения(Обработчик, ДополнительныеПараметры);
+	КонецЕсли;
+
 	ПройтиКонвейер();
 
 	Результат = НачальноеЗначение;
@@ -212,6 +253,8 @@
 		ОписанияОповещений.ВыполнитьОбработкуОповещения(Обработчик, Результат);
 	КонецЦикла;
 
+	ОчиститьВременныеОписанияОповещений();
+	
 	Возврат Результат;
 
 КонецФункции
@@ -224,7 +267,6 @@
 
 	Коллекция = ПотокСлужебный.ПолучитьКоллекцию();
 	КэшКолонок = ПотокСлужебный.ПолучитьКэшКолонок();
-	Лог.Информация(КэшКолонок.Количество());
 
 	Результат = Новый(ТипРезультата);
 
@@ -264,10 +306,14 @@
 
 КонецФункции
 
-Функция ЛюбойСоответствует(ОписаниеОповещения) Экспорт
+Функция ЛюбойСоответствует(Знач ОписаниеОповещения, Знач ДополнительныеПараметры = Неопределено) Экспорт
 
 	Лог.Отладка("ЛюбойСоответствует");
 
+	Если ТипЗнч(ОписаниеОповещения) = Тип("Строка") Тогда
+		ОписаниеОповещения = СформироватьВременноеОписаниеОповещения(ОписаниеОповещения, ДополнительныеПараметры);
+	КонецЕсли;
+
 	ПройтиКонвейер();
 
 	Коллекция = ПотокСлужебный.ПолучитьКоллекцию();
@@ -289,14 +335,20 @@
 		КонецЕсли;
 	КонецЦикла;
 
+	ОчиститьВременныеОписанияОповещений();
+	
 	Возврат Результат;
 
 КонецФункции
 
-Функция ВсеСоответствуют(ОписаниеОповещения) Экспорт
+Функция ВсеСоответствуют(Знач ОписаниеОповещения, Знач ДополнительныеПараметры = Неопределено) Экспорт
 
 	Лог.Отладка("ВсеСоответствуют");
 
+	Если ТипЗнч(ОписаниеОповещения) = Тип("Строка") Тогда
+		ОписаниеОповещения = СформироватьВременноеОписаниеОповещения(ОписаниеОповещения, ДополнительныеПараметры);
+	КонецЕсли;
+
 	ПройтиКонвейер();
 
 	Коллекция = ПотокСлужебный.ПолучитьКоллекцию();
@@ -317,15 +369,21 @@
 			Прервать;
 		КонецЕсли;
 	КонецЦикла;
+
+	ОчиститьВременныеОписанияОповещений();
 
 	Возврат Результат;
 
 КонецФункции
 
-Функция ВсеНеСоответствуют(ОписаниеОповещения) Экспорт
+Функция ВсеНеСоответствуют(Знач ОписаниеОповещения, Знач ДополнительныеПараметры = Неопределено) Экспорт
 
 	Лог.Отладка("ВсеНеСоответствуют");
 
+	Если ТипЗнч(ОписаниеОповещения) = Тип("Строка") Тогда
+		ОписаниеОповещения = СформироватьВременноеОписаниеОповещения(ОписаниеОповещения, ДополнительныеПараметры);
+	КонецЕсли;
+
 	ПройтиКонвейер();
 
 	Коллекция = ПотокСлужебный.ПолучитьКоллекцию();
@@ -346,6 +404,8 @@
 			Прервать;
 		КонецЕсли;
 	КонецЦикла;
+
+	ОчиститьВременныеОписанияОповещений();
 
 	Возврат Результат;
 
@@ -396,8 +456,44 @@
 
 КонецПроцедуры
 
+Функция СформироватьВременноеОписаниеОповещения(ПользовательскоеВыражение, ДополнительныеПараметры)
+
+	Если ДополнительныеПараметры = Неопределено Тогда
+		ДополнительныеПараметры = Новый Структура;
+	КонецЕсли;
+
+	ПутьКФайлуШаблона = ОбъединитьПути(ТекущийСценарий().Каталог, "ШаблонИзолированногоКласса.os");
+	ЧтениеТекста = Новый ЧтениеТекста(ПутьКФайлуШаблона, КодировкаТекста.UTF8NoBom);	
+	ТекстИзолированногоКласса = ЧтениеТекста.Прочитать();
+
+	ТекстИзолированногоКласса = СтрЗаменить(ТекстИзолированногоКласса, "А = 0;", ПользовательскоеВыражение);
+	
+	ВременныйФайл = ЛокальныйМенеджерВременныхФайлов.НовоеИмяФайла("os");
+	ЗаписьТекста = Новый ЗаписьТекста(ВременныйФайл);
+	ЗаписьТекста.Записать(ТекстИзолированногоКласса);
+	ЗаписьТекста.Закрыть();
+
+	ВременныйСценарий = ЗагрузитьСценарий(ВременныйФайл);
+
+	ОписаниеОповещения = ОписанияОповещений.Создать(
+		"ОбработкаОповещения", 
+		ВременныйСценарий, 
+		ДополнительныеПараметры
+	);
+
+	Возврат ОписаниеОповещения;
+
+КонецФункции
+
+Процедура ОчиститьВременныеОписанияОповещений()
+	ЛокальныйМенеджерВременныхФайлов.Удалить();
+	ВременныеОписанияОповещений = Новый Массив;
+КонецПроцедуры
+
 Процедура Инициализация()
 	Конвейер = Новый Массив;
+	ВременныеОписанияОповещений = Новый Массив;
+	ЛокальныйМенеджерВременныхФайлов = Новый МенеджерВременныхФайлов;
 	Лог = Логирование.ПолучитьЛог("oscript.lib.stream");
 
 	ПутьКСценарию_ПотокСлужебный = ОбъединитьПути(ТекущийСценарий().Каталог, "ПотокСлужебный.os");

src/Классы/ШаблонИзолированногоКласса.os

@@ -0,0 +1,5 @@
+Процедура ОбработкаОповещения(Результат, ДополнительныеПараметры) Экспорт
+
+	А = 0;
+
+КонецПроцедуры

test.os

@@ -84,10 +84,15 @@
 	.ДляКаждого(Потоки.СтандартныйОбработчик_Сообщить());
 
 Строка = "Я
-|многострочная
-|строка";
+|строка
+|многострочная";
 
 Потоки
 	.ИзСтроки(Строка, Символы.ПС)
 	.Сортировать()
 	.ДляКаждого(Потоки.СтандартныйОбработчик_Сообщить());
+
+Потоки
+	.ИзСтроки(Строка, Символы.ПС)
+	.Фильтровать("Результат = СтрДлина(ДополнительныеПараметры.Элемент) > 1")
+	.ДляКаждого("Сообщить(ДополнительныеПараметры.Элемент)");