cppcomet/comet-server

CppComet - easy to use and fast in work.

Comet server is written in C++, for storing data using MySQL.

Features

Comet technology – allows sending arbitrary messages to client through server initiative

• Api for more then 9 languages. CometQL API allows you connect to server by mysql protocol.
• Good documentation in Russian and English languages
• Supports users authenticating on the server
• Allow sending a private message to users
• Allows you to send public messages to users via channels
• Allows subscription from JavaScript to changing other user’s status
• Allows subscription to updates of online users list in real-time
• Sending messages to channel from JS
• Allows get information when users were online

How it fast

Report about load testing of 64,000 connections online

How it works

• Introduction to comet technology EN and RU

Documentation and examples

Documentation in Russian and English languages

• How to build and run EN or RU
• CometQL API documentation EN or RU (To connect to the comet server api from any server-side language is used CometQL)
• JavaScript API documentation EN or RU (To connect to the server from JavaScript API use file from api/CometServerApi.js )

Demo

• https://github.com/CppComet/php-chat-example ( One of the simplest way to create php websockets chat with CppComet )
• https://codepen.io/Levhav/pen/vJWWqW ( Creating a simple chat using CppComet )
• https://cppcomet.github.io/comet-server/demo/simple-chat/simple-chat.html
• https://github.com/CppComet/auth-example

Demo access to server API

For testing CppComet without install on vps you can use free cloud service with same api. In the all examples I will use demonstration access from comet-server.com for those who could not or were too lazy to deploy the server on their vps.

For demo access use credentials:

Login: 15
Password:lPXBFPqNg3f661JcegBY0N0dPXqUBdHXqj2cHf04PZgLHxT6z55e20ozojvMRvB8
Host: app.comet-server.ru

Example of connecting to cometQL api from console using mysql-client:

mysql -h app.comet-server.ru -u15 -plPXBFPqNg3f661JcegBY0N0dPXqUBdHXqj2cHf04PZgLHxT6z55e20ozojvMRvB8 -DCometQL_v1 --skip-ssl

Simple chat demo

Simple chat demo page

On this gif animation you see how send message to web chat from CppComet api.

We connect to CppComet by mysql protocol and send CometQL query.

For connect to demo server use this command:

mysql -h app.comet-server.ru -u15 -plPXBFPqNg3f661JcegBY0N0dPXqUBdHXqj2cHf04PZgLHxT6z55e20ozojvMRvB8 -DCometQL_v1 --skip-ssl

For send message to demo chat use this query:

INSERT INTO pipes_messages (name, event, message)VALUES("web_MainPageChat", "", '{ "text":"My text","name":"My name"}' );

License

GNU AGPLv3

comet-server's Issues

Сlustering mechanism

In this issue, i will be adding message about a process of work under clustering mechanism. If you want to get the email message when clustering will be completed then subscribe to this issue.

CometServerApi.js:824 Invalid pipe name subscription web_chat_pipe chatControl

При обновлении slave вкладки на master вкладке выходит ошибка
CometServerApi.js:824 Invalid pipe name subscription web_chat_pipe chatControl

Я так понял что слейв говорит мастеру на что ему нужно подписаться.

Добавил в _cometServerApi.prototype.subscription

console.log('subscription: ', name);

и увидел следующую картину:
при инициализации мастера:

subscription:  web_chat_pipe.msg
subscription:  answer_to_web_chat_pipe
subscription:  chatControl.clean

а после обновления слейва в мастере вот это:

subscription:  subscription
web_chat_pipe
chatControl

Invalid pipe name subscription
web_chat_pipe
chatControl

видимо слейв отдает мастеру все подписки одним текстом да еще и в урезанном виде.

MySQL connection not established Got packets out of order

I did everything as written in the instructions, but got this error.
MySQL 8
Ubuntu 20.04

Error text:
[Tag = dbLink, Level = 500] mysql_real_connect localhost: 3306 user = root
[Tag = dbLink, Level = 200] MySQL connection not established
Got packets out of order
ip = localhost: 3306 user = root password = root db_name = comet_db [errno = 1156]
[Tag = Any, Level = 200] Error: MySQL connection not established (attempt = 4)

Command systemctl stop comet.service does not work on Ubuntu 16

Command systemctl stop comet.service does not work on Ubuntu 16

add deleting api query for pipes history

Query DELETE FROM 'users messages' WHERE 'id'=2 can delete all records from user history. But will be useful delete only part of messages queue

Debian package

For simple deploy as non-changeable binary need Debian package instead docker/make.

incorrect marker value in function track_pipe_users (getTrackPipeUsers)

incorrect marker value in function track_pipe_users (getTrackPipeUsers)

add functions for aggregating statistics of using servers

add functions for aggregating statistics of using servers
more info on page http://statistics.comet-server.ru/api/statistics

_cometServerApi.prototype.send_msg("pipe_log\n"+pipe_name+"\n"+marker+"\n");

На новой версии CometServerApi.js перестает работать subscription из-за
_cometServerApi.prototype.send_msg("pipe_log\n"+pipe_name+"\n"+marker+"\n");

Судя по коду marker не инициализируется если callBack не задан

возврат к старой версии _cometServerApi.prototype.send_msg("pipe_log\n"+pipe_name+"\n"+_cometServerApi.prototype.custom_id+"\n"); решает проблему

Improve startup scripts

Improve startup scripts for right installation CppComet after building.
At this time installation not work, and service must be started only from build directory.

Support PostgreSQL as Database backend

When we application with PostgreSQL is not so good use another DB engine like MySQL for other services.

on restart mysql connection must be close correctly

When you restart, the mysql connection should be properly closed, but now it does not close the mysql connection correctly.

Answer to web_pipe_send function comes to all tabs in browser

Answer to web_pipe_send function comes to all tabs in browser

add the option to disable using localstorage.

add the option to disable using localstorage.

cmake syntax error

yacc: e - line 112 of "src/CometQL.y", syntax error
%lex-param { void* qInfo }

return promise in cometApi.start

tabSignal.connect is not a function

Ошибка "tabSignal.connect is not a function" выходит только на Опере (хотя может и еще где), в Хроме и Фаере ее нету.

Анализ показал что tabSignal.connect undefined для Оперы

make error

root@v42471: /comet-server# make
[ 2%] Building CXX object CMakeFiles/cppcomet.dir/src/main.cpp.o
In file included from /root/comet-server/dependencies/jwt-cpp/src/include/jwt/claimvalidator.h:26:0,
from /root/comet-server/dependencies/jwt-cpp/src/include/jwt/jwt.h:31,
from /root/comet-server/dependencies/jwt-cpp/src/include/jwt/jwt_all.h:26,
from /root/comet-server/src/internalApi.h:20,
from /root/comet-server/src/user_index.h:27,
from /root/comet-server/src/devManager.h:11,
from /root/comet-server/src/main.cpp:17:
/root/comet-server/dependencies/jwt-cpp/src/include/jwt/json.hpp: In function ‘bool nlohmann::operator<(nlohmann::basic_json<ObjectType, ArrayType, StringType, BooleanType, NumberIntegerType, NumberUnsignedType, NumberFloatType, AllocatorType, JSONSerializer>::const_reference, nlohmann::basic_json<ObjectType, ArrayType, StringType, BooleanType, NumberIntegerType, NumberUnsignedType, NumberFloatType, AllocatorType, JSONSerializer>::const_reference)’:
/root/comet-server/dependencies/jwt-cpp/src/include/jwt/json.hpp:5704:50: error: wrong number of template arguments (1, should be 2)
return *lhs.m_value.array < *rhs.m_value.array;
^~~~~
In file included from /usr/include/c++/7/tuple:39:0,
from /usr/include/c++/7/bits/stl_map.h:63,
from /usr/include/c++/7/map:61,
from /root/comet-server/src/TagTimer.h:8,
from /root/comet-server/src/main.h:131,
from /root/comet-server/src/main.cpp:14:
/usr/include/c++/7/array:94:12: note: provided for ‘template<class _Tp, long unsigned int _Nm> struct std::array’
struct array
^~~~~
CMakeFiles/cppcomet.dir/build.make:158: recipe for target 'CMakeFiles/cppcomet.dir/src/main.cpp.o' failed
make[2]: *** [CMakeFiles/cppcomet.dir/src/main.cpp.o] Error 1
CMakeFiles/Makefile2:67: recipe for target 'CMakeFiles/cppcomet.dir/all' failed
make[1]: *** [CMakeFiles/cppcomet.dir/all] Error 2
Makefile:129: recipe for target 'all' failed
make: *** [all] Error 2

Error if remove file /tmp/cpp.comet

echo 'exit' > /tmp/cpp.comet in comet-service.sh does not create a pipe but a simple file. to which the fork child process hangs.

Функция приватного доступа в чат доступный пользователям только для чтения

Вопрос в том можно ли запретить (защитить общий канал) от отправки в него сообщений из вне (из JS)
Например я хочу при необходимости вывести у всех пользователей сразу сообщение "Через 15 минут сайт закрывается на техническое обслуживание. Сохраните документы с которыми работаете и выйдите из системы". Но мне нужно гарантировать что никак кроме как из моего PHP (CometQL) подобный сигнал не будет отправлен пользователям.
Сейчас насколько я понял общие каналы (без авторизации) открыты и на чтение и на запись одновременно и при желании какой нибудь хакер может отправить в него чтонибудь свое)

Stop function is active until the master tab is closed

The function is active until the master tab is closed. If you close the connection tab, the new connection master will reinstall.