Модуль WebSocket клиента

Полный серверный непривилегированный контроллер своих клиентских данных и собственного регистрационного журнала.

Функция ПроверитьСвойКлюч(Ключ) Экспорт
    Если ТипЗнч(Ключ) <> Тип("Строка") Или Лев(Ключ, 17) <> "own-ws85-persist-" Тогда
        ВызватьИсключение "Нужен только свой ключ сохраненного WebSocket-опыта";
    КонецЕсли;
    Хвост = Сред(Ключ, 18);
    UUID = Новый УникальныйИдентификатор(Хвост);
    Если Строка(UUID) <> Хвост Тогда
        ВызватьИсключение "Нужен точный собственный UUID, не произвольное имя";
    КонецЕсли;
    Возврат Ключ;
КонецФункции

Функция ПолучитьСвоиМетаданные() Экспорт
    ПроверитьСвойПустойСтенд();
    Если ИмяПользователя() <> "УчебныйWS85" Или Метаданные.WebSocketКлиенты.Количество() <> 1 Тогда
        ВызватьИсключение "Нужен свой пользователь и единственный собственный метаобъект";
    КонецЕсли;
    Описание = Метаданные.WebSocketКлиенты.Найти("Эхо85");
    Если Описание = Неопределено Или Описание.Предопределенный Или Описание.ПодключатьАвтоматически
        Или Описание.URLСервера <> "ws://127.0.0.1:18485/own-ws85" Тогда
        ВызватьИсключение "Нужно свое непредопределенное Эхо85 с ручным подключением к loopback";
    КонецЕсли;
    Возврат Описание;
КонецФункции

Процедура СверитьСвоегоКлиента(Клиент, Ключ) Экспорт
    ПроверитьСвойКлюч(Ключ);
    Описание = ПолучитьСвоиМетаданные();
    Если ТипЗнч(Клиент) <> Тип("WebSocketКлиент") Или Клиент.Предопределенный Или Клиент.Ключ <> Ключ
        Или Клиент.Метаданные <> Описание Или Клиент.URLСервера <> "ws://127.0.0.1:18485/own-ws85"
        Или Клиент.ИмяПользователяИнформационнойБазы <> "УчебныйWS85" Или Клиент.ПодключатьАвтоматически Тогда
        ВызватьИсключение "Не совпал паспорт своего клиента; существующий чужой объект не меняется";
    КонецЕсли;
КонецПроцедуры

Функция ПолучитьСвоегоКлиента(Ключ) Экспорт
    ПроверитьСвойКлюч(Ключ);
    Клиент = WebSocketКлиенты.НайтиПоКлючу(Ключ);
    Если Клиент = Неопределено Тогда
        ВызватьИсключение "Свой сохраненный клиент не найден";
    КонецЕсли;
    СверитьСвоегоКлиента(Клиент, Ключ);
    Возврат Клиент;
КонецФункции

Процедура НастроитьСвоиПараметры(Клиент, Ключ) Экспорт
    СверитьСвоегоКлиента(Клиент, Ключ);
    Параметры = Клиент.ПараметрыСоединения;
    Если ТипЗнч(Параметры) <> Тип("ПараметрыWebSocketКлиентСоединения") Тогда
        ВызватьИсключение "Нужен настоящий readonly-источник изменяемых сетевых параметров";
    КонецЕсли;
    Параметры.ИспользоватьАутентификациюОС = Ложь;
    Параметры.ИспользоватьПроксиОС = Ложь;
    Параметры.Пользователь = "own-ws85";
    Параметры.Пароль = "own-local-only";
    Параметры.Таймаут = 10;
    Заголовки = Новый Соответствие;
    Заголовки.Вставить("X-Own-Lab", "owned-ws85-direct");
    Параметры.Заголовки = Заголовки;
    Параметры.ДополнительныеПараметры = Новый Структура("Метка,Ключ", "owned-ws85-persistent", Ключ);
КонецПроцедуры

Процедура ЗаписатьСвоеСобытие(Ключ, Имя, Комментарий, Ошибка = Ложь) Экспорт
    ПроверитьСвойКлюч(Ключ);
    Описание = ПолучитьСвоиМетаданные();
    Разрешенные = СтрРазделить("ПередПодключением,Открытие,ТекстEcho,ДвоичныйEcho,Ошибка,Закрытие,Подготовлен,ПодключениеЗапрошено,ОтключениеЗапрошено,УдалениеЗапрошено", ",");
    Если Разрешенные.Найти(Имя) = Неопределено Тогда
        ВызватьИсключение "Событие не принадлежит собственному учебному протоколу";
    КонецЕсли;
    БезПароля = СтрЗаменить(Комментарий, "own-local-only", "[учебный пароль скрыт]");
    БезПароля = СтрЗаменить(БезПароля, "b3duLXdzODU6b3duLWxvY2FsLW9ubHk=", "[учебный Basic скрыт]");
    Уровень = ?(Ошибка, УровеньЖурналаРегистрации.Ошибка, УровеньЖурналаРегистрации.Информация);
    ЗаписьЖурналаРегистрации("OwnWS85." + Имя, Уровень, Описание, Ключ, Лев(БезПароля, 1200));
КонецПроцедуры

Функция ПолучитьКлючСвоегоСобытия(Соединение) Экспорт
    ПолучитьСвоиМетаданные();
    Если ТипЗнч(Соединение) <> Тип("WebSocketКлиентСоединение") Или Соединение.URLСервера <> "ws://127.0.0.1:18485/own-ws85"
        Или Соединение.ИмяПользователяИнформационнойБазы <> "УчебныйWS85" Тогда
        ВызватьИсключение "Событие не принадлежит своему локальному соединению";
    КонецЕсли;
    Параметры = Соединение.Параметры;
    Дополнительные = Параметры.ДополнительныеПараметры;
    Если ТипЗнч(Дополнительные) <> Тип("Структура") Или Дополнительные.Метка <> "owned-ws85-persistent" Тогда
        ВызватьИсключение "Нет собственного паспорта события";
    КонецЕсли;
    Возврат ПроверитьСвойКлюч(Дополнительные.Ключ);
КонецФункции

Функция ЗавершитьСвоеСоединениеПослеОшибки(Соединение, Ключ, ТекстОшибки) Экспорт
    Если ПолучитьКлючСвоегоСобытия(Соединение) <> Ключ Тогда
        ВызватьИсключение "Чужое или неподтвержденное соединение не закрывается";
    КонецЕсли;
    ИтогОшибки = ТекстОшибки;
    Попытка
        ЗаписатьСвоеСобытие(Ключ, "Ошибка", ТекстОшибки, Истина);
    Исключение
        ИтогОшибки = ИтогОшибки + " Журнал НЕ записан: " + ОписаниеОшибки();
    КонецПопытки;
    Попытка
        Соединение.Закрыть();
    Исключение
        ИтогОшибки = ИтогОшибки + " Свое закрытие НЕ подтверждено: " + ОписаниеОшибки();
    КонецПопытки;
    Возврат ИтогОшибки;
КонецФункции

Функция ПодготовитьСвоегоКлиента(Ключ, Согласие) Экспорт
    Если Не Согласие Тогда ВызватьИсключение "Нужно согласие на запись только своего нового клиента"; КонецЕсли;
    ПроверитьСвойКлюч(Ключ);
    Описание = ПолучитьСвоиМетаданные();
    Если WebSocketКлиенты.НайтиПоКлючу(Ключ) <> Неопределено Тогда
        ВызватьИсключение "Ключ уже занят; существующий клиент не перезаписывается";
    КонецЕсли;
    Клиент = WebSocketКлиенты.СоздатьКлиента(Описание, Ключ);
    Клиент.URLСервера = "ws://127.0.0.1:18485/own-ws85";
    Клиент.ИмяПользователяИнформационнойБазы = "УчебныйWS85";
    Клиент.ПодключатьАвтоматически = Ложь;
    СверитьСвоегоКлиента(Клиент, Ключ);
    Попытка
        НастроитьСвоиПараметры(Клиент, Ключ);
        Клиент.Записать();
        Повторно = ПолучитьСвоегоКлиента(Ключ);
        Если Повторно.ПолучитьТекущееСоединение() <> Неопределено Тогда
            ВызватьИсключение "Подготовка не должна автоматически открывать соединение";
        КонецЕсли;
        ЗаписатьСвоеСобытие(Ключ, "Подготовлен", "Свой клиент записан, автоподключение выключено");
    Исключение
        ОшибкаПодготовки = ОписаниеОшибки();
        Попытка
            СверитьСвоегоКлиента(Клиент, Ключ);
            Если Клиент.ПолучитьТекущееСоединение() <> Неопределено Тогда Клиент.Отключить(); КонецЕсли;
            Клиент.Удалить();
        Исключение
            ОшибкаПодготовки = ОшибкаПодготовки + " Удаление своего нового клиента после ошибки НЕ подтверждено: " + ОписаниеОшибки();
        КонецПопытки;
        ВызватьИсключение ОшибкаПодготовки;
    КонецПопытки;
    Возврат "Свой клиент записан без подключения. Сохраните ключ для журнала и завершения: " + Ключ;
КонецФункции

Функция ПодключитьСвоегоКлиента(Ключ, Согласие) Экспорт
    Если Не Согласие Тогда ВызватьИсключение "Нужно согласие на свое локальное соединение"; КонецЕсли;
    Клиент = ПолучитьСвоегоКлиента(Ключ);
    Если Клиент.ПолучитьТекущееСоединение() <> Неопределено Тогда
        ВызватьИсключение "Текущее собственное соединение уже предоставлено; повторное подключение не начинается";
    КонецЕсли;
    Попытка
        Соединение = Клиент.Подключить();
        Если Соединение <> Неопределено И ТипЗнч(Соединение) <> Тип("WebSocketКлиентСоединение") Тогда
            ВызватьИсключение "Не совпал тип результата Подключить";
        КонецЕсли;
        ЗаписатьСвоеСобытие(Ключ, "ПодключениеЗапрошено", "Подключить выполнен; результат типа " + Строка(ТипЗнч(Соединение)));
    Исключение
        ОшибкаПодключения = ОписаниеОшибки();
        Попытка
            Клиент.Отключить();
        Исключение
            ОшибкаПодключения = ОшибкаПодключения + " Собственное отключение после ошибки НЕ подтверждено: " + ОписаниеОшибки();
        КонецПопытки;
        ВызватьИсключение ОшибкаПодключения;
    КонецПопытки;
    Возврат "Подключение запрошено. Echo подтверждают отдельные события OwnWS85.ТекстEcho и OwnWS85.ДвоичныйEcho своего ключа";
КонецФункции

Функция ПрочитатьСвойСтатус(Ключ) Экспорт
    Клиент = ПолучитьСвоегоКлиента(Ключ);
    Возврат "Фактическое состояние своего клиента: " + Строка(Клиент.ПолучитьСостояниеСоединения())
        + "; автоподключение: " + Строка(Клиент.ПодключатьАвтоматически)
        + ". Этот статус не доказывает получение сообщений; откройте журнал OwnWS85 по своему ключу";
КонецФункции

Функция ОтключитьСвоегоКлиента(Ключ) Экспорт
    Клиент = ПолучитьСвоегоКлиента(Ключ);
    Клиент.Отключить();
    Если Клиент.ПодключатьАвтоматически Тогда
        ВызватьИсключение "Отключить не выключил собственное автоподключение";
    КонецЕсли;
    ЗаписатьСвоеСобытие(Ключ, "ОтключениеЗапрошено", "Прежнее соединение после Отключить больше не используется");
    Возврат ПрочитатьСвойСтатус(Ключ) + ". Ранее полученный объект соединения НЕ использовать";
КонецФункции

Функция УдалитьСвоегоКлиента(Ключ, Согласие) Экспорт
    Если Не Согласие Тогда ВызватьИсключение "Нужно согласие на удаление только своего сохраненного клиента"; КонецЕсли;
    Клиент = ПолучитьСвоегоКлиента(Ключ);
    Если Клиент.ПолучитьСостояниеСоединения() <> СостояниеWebSocketСоединения.Закрыто Тогда
        ВызватьИсключение "Сначала отключите и отдельно подтвердите фактическое Закрыто";
    КонецЕсли;
    ЗаписатьСвоеСобытие(Ключ, "УдалениеЗапрошено", "Удаляется только проверенный собственный непредопределенный клиент");
    Клиент.Удалить();
    После = WebSocketКлиенты.НайтиПоКлючу(Ключ);
    Если После = Неопределено Тогда
        Возврат "Удалить выполнен; менеджер не нашел клиента своего ключа. Журнал событий не удалялся";
    КонецЕсли;
    Возврат "Удалить выполнен; менеджер еще предоставил объект типа " + Строка(ТипЗнч(После))
        + ". Не считать это подтверждением исчезновения объекта; исследуйте только свой стенд. Журнал не удалялся";
КонецФункции


Процедура ПроверитьСвойПустойСтенд()
    Если Метаданные.Справочники.Количество() <> 0 Или Метаданные.Документы.Количество() <> 0 Или Метаданные.Перечисления.Количество() <> 0 Или Метаданные.РегистрыСведений.Количество() <> 0 Или Метаданные.РегистрыНакопления.Количество() <> 0 Или Метаданные.РегистрыБухгалтерии.Количество() <> 0 Или Метаданные.РегистрыРасчета.Количество() <> 0 Или Метаданные.ПланыВидовХарактеристик.Количество() <> 0 Или Метаданные.ПланыВидовРасчета.Количество() <> 0 Или Метаданные.ПланыСчетов.Количество() <> 0 Или Метаданные.ПланыОбмена.Количество() <> 0 Или Метаданные.Последовательности.Количество() <> 0 Или Метаданные.БизнесПроцессы.Количество() <> 0 Или Метаданные.Задачи.Количество() <> 0 Или Метаданные.ОбщиеРеквизиты.Количество() <> 0 Или Метаданные.ПодпискиНаСобытия.Количество() <> 0 Или Метаданные.РегламентныеЗадания.Количество() <> 0 Или Метаданные.ВнешниеИсточникиДанных.Количество() <> 0 Тогда
        ВызватьИсключение "Нужен только свой новый пустой учебный стенд";
    КонецЕсли;
    Если Метаданные.ЕстьИзмененияРасширениямиКонфигурации() Тогда
        ВызватьИсключение "Свой сеанс не должен изменяться расширениями";
    КонецЕсли;
    Источники = Новый Массив;
    Источники.Добавить(ИсточникРасширенийКонфигурации.БазаДанных);
    Источники.Добавить(ИсточникРасширенийКонфигурации.СеансАктивные);
    Источники.Добавить(ИсточникРасширенийКонфигурации.СеансОтключенные);
    Для Каждого Источник Из Источники Цикл
        Расширения = РасширенияКонфигурации.Получить(, Источник);
        Если ТипЗнч(Расширения) <> Тип("Массив") Тогда
            ВызватьИсключение "Native список расширений должен иметь тип Массив";
        КонецЕсли;
        Если Расширения.Количество() <> 0 Тогда
            ВызватьИсключение "В своём новом стенде нет расширений базы или сеанса";
        КонецЕсли;
    КонецЦикла;
    Если ТранзакцияАктивна() Тогда
        ВызватьИсключение "Чужая или вложенная активная транзакция не допускается";
    КонецЕсли;
КонецПроцедуры

Полный клиент-серверный пульт своих шести команд; клиенту возвращаются строки. Настоящий UUID сохранен для журнала и восстановления.

&НаКлиенте
Процедура ПриОткрытии(Отказ)
    Согласие = Ложь;
    КлючСтенда = "";
    КлючВосстановления = "";
    Результат = "Подготовьте свой сервер и права. Сохраненный клиент еще не создан";
КонецПроцедуры

&НаКлиенте
Процедура Подготовить85(Команда)
    Если Не Согласие Или КлючСтенда <> "" Тогда
        ВызватьИсключение "Нужны согласие и новый опыт; старый ключ не заменяется";
    КонецЕсли;
    КлючСтенда = "own-ws85-persist-" + Строка(Новый УникальныйИдентификатор);
    Результат = ПодготовитьНаСервере(КлючСтенда, Согласие);
КонецПроцедуры

&НаСервереБезКонтекста
Функция ПодготовитьНаСервере(Ключ, Согласие)
    Возврат УчебныйСохраненныйWS85.ПодготовитьСвоегоКлиента(Ключ, Согласие);
КонецФункции

&НаКлиенте
Процедура Подключить85(Команда)
    Результат = ПодключитьНаСервере(КлючСтенда, Согласие);
КонецПроцедуры

&НаСервереБезКонтекста
Функция ПодключитьНаСервере(Ключ, Согласие)
    Возврат УчебныйСохраненныйWS85.ПодключитьСвоегоКлиента(Ключ, Согласие);
КонецФункции

&НаКлиенте
Процедура Состояние85(Команда)
    Результат = СостояниеНаСервере(КлючСтенда);
КонецПроцедуры

&НаСервереБезКонтекста
Функция СостояниеНаСервере(Ключ)
    Возврат УчебныйСохраненныйWS85.ПрочитатьСвойСтатус(Ключ);
КонецФункции

&НаКлиенте
Процедура Отключить85(Команда)
    Результат = ОтключитьНаСервере(КлючСтенда);
КонецПроцедуры

&НаСервереБезКонтекста
Функция ОтключитьНаСервере(Ключ)
    Возврат УчебныйСохраненныйWS85.ОтключитьСвоегоКлиента(Ключ);
КонецФункции

&НаКлиенте
Процедура Удалить85(Команда)
    Результат = УдалитьНаСервере(КлючСтенда, Согласие);
КонецПроцедуры

&НаСервереБезКонтекста
Функция УдалитьНаСервере(Ключ, Согласие)
    Возврат УчебныйСохраненныйWS85.УдалитьСвоегоКлиента(Ключ, Согласие);
КонецФункции

&НаКлиенте
Процедура ВосстановитьКлюч85(Команда)
    Если Не Согласие Или КлючСтенда <> "" Тогда
        ВызватьИсключение "Для восстановления нужны согласие и пустой текущий ключ; другой опыт не подменяется";
    КонецЕсли;
    Проверка = СостояниеНаСервере(КлючВосстановления);
    КлючСтенда = КлючВосстановления;
    Результат = "Восстановлен только реально найденный собственный клиент. " + Проверка;
КонецПроцедуры

Полный ранее статически проверенный loopback-сервер Node.js/ws; не запускался на реальной сети.

const http=require('node:http');
const {WebSocketServer,WebSocket}=require('ws');
const host='127.0.0.1';
const port=18485;
const endpoint='/own-ws85';
const credentials='Basic '+Buffer.from('own-ws85:own-local-only','ascii').toString('base64');
const server=http.createServer((request,response)=>{response.writeHead(404);response.end('own-ws85 only');});
const sockets=new Set();
const wss=new WebSocketServer({noServer:true,maxPayload:4096,perMessageDeflate:false});
server.maxConnections=8;
server.headersTimeout=10000;
server.requestTimeout=10000;
function reportError(error) {console.error('own-ws85 failure:',error.code||error.message);}
function rejectUpgrade(socket,status,challenge='') {
  socket.end('HTTP/1.1 '+status+'\r\nConnection: close\r\nContent-Length: 0\r\n'+challenge+'\r\n');
}
server.on('connection',socket=>{
  sockets.add(socket);
  socket.setTimeout(60000,()=>socket.destroy());
  socket.on('error',reportError);
  socket.on('close',()=>sockets.delete(socket));
});
server.on('upgrade',(request,socket,head)=>{
  if(request.socket.remoteAddress!==host||request.method!=='GET'||request.url!==endpoint||request.headers.host!==host+':'+port||request.headers['x-own-lab']!=='owned-ws85-direct') {
    rejectUpgrade(socket,'403 Forbidden');return;
  }
  if(request.headers.authorization!==credentials) {
    rejectUpgrade(socket,'401 Unauthorized','WWW-Authenticate: Basic realm="own-ws85"\r\n');return;
  }
  if(wss.clients.size>=4) {rejectUpgrade(socket,'503 Service Unavailable');return;}
  try {wss.handleUpgrade(request,socket,head,ws=>wss.emit('connection',ws,request));}
  catch(error) {reportError(error);socket.destroy();}
});
wss.on('error',reportError);
wss.on('connection',ws=>{
  let received=0;
  ws.on('error',reportError);
  ws.on('message',(data,isBinary)=>{
    received++;
    if(received>8||data.length>512||ws.bufferedAmount>4096) {ws.close(1008,'own-lab limit');return;}
    if(ws.readyState!==WebSocket.OPEN) return;
    ws.send(data,{binary:isBinary},error=>{if(error){reportError(error);ws.terminate();}});
  });
  ws.on('close',code=>console.log('own-ws85 connection closed:',code));
});
server.on('error',error=>{reportError(error);process.exitCode=1;});
server.listen(port,host,()=>console.log('own-ws85 listening on ws://'+host+':'+port+endpoint));
process.once('SIGINT',()=>{
  for(const client of wss.clients) client.terminate();
  for(const socket of sockets) socket.destroy();
  wss.close();
  server.close(error=>{if(error){reportError(error);process.exitCode=1;}});
});