Websocket

Оригинал статьи(wiki репы) и репозиторий с кодом находятся здесь.

Для начала слегка теории о том, зачем все это, что такое Soup, Websocket и немного остального.

libsoup - это HTTP клиент/сервер библиотека для GNOME. Использует объектную систему GObject и GLib Main Loop(спизжено с источника по ссылке)

WebSocket — протокол заднеприводной полнодуплексной связи поверх TCP-соединения, предназначенный для обмена сообщениями между браузером и веб-сервером в режиме реального времени.(источник опять по ссылке)

А теперь о том, что же я хотел и как меня это все напрягло. Возникла задача написать бота для Discord. Знания в программирование, на данный момент, у меня только в 2-х языках: Vala и Lua. Не долго думая побежал рыться в интернете на тему API Discord'a на языке Vala и наткнулся на заброшеный проект Valacord. В нем была реализована часть обращения к серверам посредством простых GET/POST запросов, но конская работа по наладке и поддержке Websocket соединения предстояла в будущем. Я полез рыться по Soup докам и..

кошка лягла на мышь.

В следующий раз напишу 2 страницы на тему клиента и сервера, и подводных камней, которые не очевидны и я с ними столкнулся.

Client

С клиентом не так все просто...

С клиентом, казалось бы, все просто: создали, подключились и "общаемся". Но не тут то было..

В первую очередь выделим место под экземпляр соединения за пределами основной функции чтобы иметь к ней доступ из остальной программы:

static Soup.WebsocketConnection websocket;

Для соединения нам понадобится Soup.Session, который соединит нас с сервером и Soup.Message с данными о сервере. Собственно:

var session = new Soup.Session();
var message = new Soup.Message("GET", "http://<server_host>[:server_port]/[path]");

• <server_host> - собственно адрес сервера

• [:server_port] - порт сервера, если требуется

• [path] - путь к соединению на сервере

Учтем, что Websocket работает над HTTP и GET. Указываем это при создании Soup.Message.

Затем создаем новый основной поток, в котором и будет ждать сообщений наш Soup.WebsocketConnection:

var loop = new MainLoop();

Вопросы? Поидее должны отсутствовать..️

Получаем экземпляр Soup.WebsocketConnection:

session.websocket_connect_async.begin(message, null, null, null, (obj, res) => {
    websocket = session.websocket_connect_async.end(res);
    websocket.message.connect(ws_message);
    websocket.closed.connect(ws_closed);
    websocket.error.connect(ws_error);
});

Тут то вот что происходит по строкам:

1. Функция websocket_connect_async() имеет такой синтаксис: public async WebsocketConnection websocket_connect_async (Message msg, string? origin, string[]? protocols, Cancellable? cancellable) throws Error

   соответственно мы указваем наш Soup.Message message, а остальные аргументы опускаем т.к. они нам не важны + асинхронная обвязка. (за подробностями по аргументам обратитесь к valadoc)
2. Тут, по завершению работы функции из первой строки, мы получаем заветное Soup.WebsocketConnection websocket

3. Соединяем сигнал получения сообщения от сервера с функцией, которую рассмотрим позже

4. Также сигнал закрытия соединения

5. И сигнал ошибки соединения, соответственно

ws_message(int type, Bytes message)

• type - тип полученного сообщения (BINARY|TEXT)public enum WebsocketDataType
• message - GLib.Bytes экземпляр, который хранит полученное сообщение

Код функции:

void ws_message(int type, Bytes message){
    stdout.printf((string)message.get_data());
}

На второй строке получаем наше сообщение в виде uint8[] из message.get_data() и представляем в виде строки.

ws_closet()

Тут все просто. Мы просто обрабатываем ситуацию, когда соединение закроется.

void ws_closed(){
    stdout.printf("WebSock closed!"); // я просто вывел сообщение
}

ws_error(Error error)

Функция получает экземпляр класса GLib.Error

void ws_error(Error error){
    int code = error.code;
    string message = error.message;
    stdout.printf("WS Error %d: %s\n".printf(code,message));
}

Тут вроде бы все тоже ясно и понятно. На этом эта статься заканчивается.️ Не судите строго, я в этом не силен.