dandri/simplexmq
1
0
Fork 0
mirror of https://github.com/simplex-chat/simplexmq.git synced 2026-03-30 20:45:52 +00:00
Code Issues Packages Projects Releases Wiki Activity
2,015 Commits 93 Branches 171 Tags
master
Commit Graph

1392 Commits

Author SHA1 Message Date
Evgeny
16cf5c8628 smp server: stats for END events and for SUB/DEL event batches (#1281) 
* smp server: count queued and sent END events

* fix

* shadowing

* stats for batches

* fix
 2024-08-26 14:58:18 +01:00
Evgeny
53e829a21c agent: store query errors, reduce slow query threshold to 1ms (#1277) 
* agent: collect query errors stats

* simplify

* test

* use microseconds

* parens

* revert change to track all queries, reduce threshold to 1 ms
 2024-08-24 14:51:26 +01:00
Evgeny
ab4acadcc1 agent: fix stuck connection commands when server is not responding (#1276) 
* agent: fix stuck connection commands when server is not responding

* fix

* rename

* test SKEY retry
 2024-08-24 13:54:20 +01:00
Evgeny
325e679bc4 ntf server: reduce PING interval to 1 minute, only mark subscriptions with END if it is received by the currently active client (#1275) 2024-08-24 11:34:59 +01:00
Evgeny
39f3cf3082 agent: only create notification subscriptions to connections without errors or with temporary errors (#1270) 2024-08-20 16:05:50 +01:00
Evgeny
2bdda1ff1f servers: safe compacting of store logs (#1269) 
* servers: safe compacting of store logs

* fix
 2024-08-20 13:36:37 +01:00
Evgeny
ac930dff30 smp server: possible race when creating client that might lead to memory leak (#1260) 2024-08-20 12:25:58 +01:00
Diogo
1cbf8c0015 agent: support changing user of the new connection (#1267) 
* agent: support new connection user id update

* another way for assertion

* add more tests to setConnUserId

* remove fdescribes

* allow rcv connection to change user id

* add functional test to api

* remove fdescribe

* refactor

---------

Co-authored-by: Evgeny Poberezkin <evgeny@poberezkin.com>
 2024-08-20 10:57:09 +01:00
Evgeny
571d148bdf agent: do not start delivery workers when there are no messages to deliver (#1263) 
* agent: use weak ThreadId and forkIO in workers instead of async (reduce memory)

* agent: do not start and exit delivery workers when there are no messages to deliver (#1264)

* agent: exit delivery workers when no messages to deliver

* only start delivery workers when there are pending messages

* fix

* focus test

* enable all tests

* lift

* do not exit workers when there is no work
 2024-08-18 21:30:06 +01:00
Evgeny
32a150eb40 agent: enable notifications for all connections (#1262) 2024-08-18 14:07:09 +01:00
Evgeny
5ad6e5f2f3 deps: upgrade tls to 1.9 (#1265) 
* deps: use tls-2.0

* roll back RCP "cleanup"

* use tls 1.9

---------

Co-authored-by: Alexander Bondarenko <486682+dpwiz@users.noreply.github.com>
 2024-08-18 13:55:12 +01:00
Evgeny
f229e135e3 agent: reduce subscription transactions (#1259) 
* agent: reduce subscription transactions

* nub

* remove commented
 2024-08-16 10:06:22 +01:00
Evgeny
47dd0c4c64 agent: do not send worker crash errors when agent is not active (stopped) (#1256) 2024-08-09 21:10:27 +01:00
Evgeny
7762b4d364 reduce the number of STM transactions (#1255) 
* reduce the number of STM transactions

* reduce STM more

* refactor

* remove more
 2024-08-09 16:38:46 +01:00
Evgeny
fc6b9c0e1b agent: stop statistics and cleanup when chat is stopped (#1251) 2024-08-07 13:14:09 +01:00
Evgeny
a017047c52 smp server: fix race when client is marked as subscribed after it is disconnected, preventing its GC (#1250) 
* smp server: fix race when client is marked as subscribed after it is disconnected, preventing its GC

* refactor
 2024-08-06 08:17:38 +01:00
Evgeny
f4d1a33ed8 agent: retry loop that resumes subscriptions as soon as agent is moved to foreground, suspend retry loops while agent is suspended (#1249) 
* agent: retry loop that resumes subscriptions as soon as agent is moved to foreground, suspend retry loops while agent is suspended

* reset retry enterval when moving to foreground

* account for network state too

* simplify

* typo

* simplify
 2024-08-05 15:09:46 +01:00
Evgeny Poberezkin
03ea151be5 agent: support additional messages for connection in message batches (#1247) 
* agent: support additional messages for connection in message batches

* fix, test

* test 2 connections

* use TVar instead of TMVar for GHC 8.10.7
 2024-07-30 17:12:29 +01:00
Evgeny Poberezkin
3753379ae4 agent: support dababase access with high priority for more responsive user actions (#1248) 
* agent: support dababase access with high priority for more responsive user actions

* rename, export

* fix
 2024-07-29 18:57:16 +01:00
Evgeny Poberezkin
5fa3c149e9 smp server: fix server-info, additional stats, allow expiring inactive clients which have prohibit subscriptions only (iOS NSE clients) (#1237) 
* smp server: fix server-info

* fix

* faster saving messages

* remove comment

* move ProhibitSub out of TVar

* subscription stats

* stabilize test

* order

Co-authored-by: spaced4ndy <8711996+spaced4ndy@users.noreply.github.com>

* more notification stats

* count ntf stats

* update server-info

---------

Co-authored-by: spaced4ndy <8711996+spaced4ndy@users.noreply.github.com>
 2024-07-25 16:06:40 +01:00
Evgeny Poberezkin
9093c7b120 agent, ntf server: only mark subscriptions as pending that were created by the disconnected client (#1242) 
* ntf server: only mark subscriptions as pending if the disconnected client is current

* add sessionId to subscribed queue

* add sessionId to subscriptions in ntf server agent

* fix
 2024-07-25 13:07:28 +01:00
Evgeny Poberezkin
47ae921b86 use strict Map (#1241) 2024-07-23 08:27:54 +01:00
spaced4ndy
c605156302 agent: getAgentSubsTotal api (#1238) 
* agent: getAgentSubsTotal api

* move

* export

* count sessions

* simplify

* simplify 2

---------

Co-authored-by: Evgeny Poberezkin <evgeny@poberezkin.com>
 2024-07-22 15:43:38 +01:00
Evgeny Poberezkin
051bf38bc7 agent: remove delays in notification processing, add notification stats (#1235) 
* agent: remove delays in notification processing, add notification stats

* do not replace token after failed check

* more stats

* refactor

* fix

* backwards compatible JSON parsing

* retry deleting subscription on temporary error

* remove attempts to get multiple notification messages

* fix JSON decoding to be backwards compatible
 2024-07-22 15:42:34 +01:00
Evgeny Poberezkin
8423c636a8 rename queueId to entId (can be message queue, proxied session and data blob ID to be added) (#1240) 2024-07-22 12:01:38 +01:00
Evgeny Poberezkin
cc5732f41f smp server: stats for commands retrieving messages when notifications are received (#1236) 
* more stats

* fix stats
 2024-07-20 14:10:10 +01:00
spaced4ndy
7565ddd91c agent: initialize ratchet on processing confirmation to support decryption of messages received before allowConnection; return SndQueueSecured from joinConnection, acceptContact (#1233) 2024-07-18 19:54:14 +04:00
Evgeny Poberezkin
e59a098e66 smp server: remove subscriptions from the clients when queues are deleted (#1234) 
* smp server: remove subscriptions from the clients when queues are deleted

* remove ntf subscriptions, update stats

* add GET stats
 2024-07-18 10:59:48 +01:00
Evgeny Poberezkin
8d56b0ba85 agent: allow starting only XFTP sending workers (#1232) 
* agent: allow starting only XFTP sending workers

* use Bool param

* flip bool

* update
 2024-07-17 13:01:17 +01:00
Evgeny Poberezkin
784d36d691 socks mode encoding (#1231) 
* socks mode encoding

* test delays

* test delay

* unused import
 2024-07-15 20:28:24 +01:00
Evgeny Poberezkin
291039159f ntf server: use SOCKS proxy to connect to onion-only SMP servers (#1229) 
* ntf server: use SOCKS proxy to connect to onion-only SMP servers

* fix test
 2024-07-14 23:19:02 +01:00
Evgeny Poberezkin
492d2f86bc smp server: additional control port commands to monitor server state (#1228) 
* smp server: additional control port commands to monitor server state

* fix

* space
 2024-07-13 22:34:10 +01:00
Evgeny Poberezkin
8dd54ced0e agent: retry proxied command on NO_SESSION error, to prevent failure of proxied interactive commands (like joining connection) (#1227) 2024-07-13 10:06:48 +01:00
Evgeny Poberezkin
e56bd0b47b agent: add known servers (#1225) 
* agent: add known servers

* test delays

* ServerCfg

* json encoding

* enabledServerCfg

* checkUserServers
 2024-07-12 12:41:55 +01:00
spaced4ndy
ff2b00a029 agent: change ProxyClientError json encoding (#1226) 2024-07-11 19:27:04 +04:00
Evgeny Poberezkin
26979ff6b5 smp server: simplify client subscriptions (#1223) 2024-07-09 08:36:03 +01:00
Evgeny Poberezkin
21abc5cabe smp server: reduce the number of threads by delivering message to subscription when it is sent (#1222) 
* smp server: reduce the number of threads by delivering message to subscription when it is sent

* test delay

* test delay
 2024-07-08 23:12:01 +01:00
Evgeny Poberezkin
6e76221e07 agent: fix possible dead lock between sending and receiving messages, stress test for message delivery (#1224) 
* agent: fix possible dead lock between sending and receiving messages, stress test for message delivery

* deliver events after the lock is released

* delayed delivery in command processing too

* tests: increase message expiration time
 2024-07-08 21:47:42 +01:00
Evgeny Poberezkin
743676421d ntf server: simplify and optimize subscriptions in server agent (#1219) 
* increase queue size

* simplify

* refactor to optimize memory usage and performance

* comment

* refactor

* test delays
 2024-07-07 21:17:12 +01:00
Evgeny Poberezkin
9d0774a58e agent: add queue information (#1217) 
* agent: add queue information to "debug delivery" response

* fix test

* rename

* encodings
 2024-07-03 19:32:27 +01:00
Evgeny Poberezkin
ce732c0efb agent: enable fast handshake (revert #1215) (#1216) 
* Revert "agent: disable fast handshake (#1215)"

This reverts commit aa1d8d6c8b.

* remove import

* test delays
 2024-07-03 18:05:27 +01:00
spaced4ndy
ae8e1c5e9a agent: servers stats improvements, fixes (#1208) 
* agent: reset stats startedAt time in memory

* getAgentSubsSummary

* change sub counting

* ack statistics

* add import

* instance

* Revert "instance"

This reverts commit 1f63740d56.

* Revert "add import"

This reverts commit ef72df8014.

* modify sub counting

* modify conn creation counting

* use int64

* file size stats

* remove import

* ack err counting

* conn del stats

* format

* new data

* add data

* toKB

* restore connCompleted

* use Int for counts

* use rq from scope

* remove getAgentSubsSummary

* fix connCompleted

* fix

* revert disabling stats

* use srv from scope

* combine ack stats

* modify

* comment

* count subs

* refactor

---------

Co-authored-by: Evgeny Poberezkin <evgeny@poberezkin.com>
 2024-07-03 12:36:15 +01:00
Evgeny Poberezkin
aa1d8d6c8b agent: disable fast handshake (#1215) 2024-07-02 13:40:37 +01:00
Evgeny Poberezkin
5c839b40c9 Merge branch 'master' into fast-connection 2024-07-01 21:14:32 +01:00
spaced4ndy
a50e2e74a5 agent: disable saving stats (#1214) 
* agent: disable stat saving

* disable migration

* schema

* disable restore
 2024-07-01 21:06:38 +01:00
Evgeny Poberezkin
26cfad5e88 do not use sndSecure when rotating queue (#1213) 2024-07-01 13:42:46 +01:00
Evgeny Poberezkin
a99ce6122c secure queue by sender via proxy (proxy SKEY command) (#1210) 
* client: secure queue by sender via proxy (proxy SKEY command)

* agent and server: proxy SKEY command
 2024-06-30 16:20:54 +01:00
Evgeny Poberezkin
a6b542b301 Merge branch 'master' into fast-connection 2024-06-30 15:00:28 +01:00
Evgeny Poberezkin
6a54a58a0d agent: remove legacy statistics (#1211) 
* agent: remove legacy statistics

* delays after disposeAgent

* delays

* enable all tests

* more delays
 2024-06-30 12:50:42 +01:00
Evgeny Poberezkin
9ee684b0f4 rfc: faster handshake protocol (#1203) 
* rfc: faster handshake protocol

* update

* 1 message

* SKEY

* use SKEY for both parties

* test

* update doc

* NEW command parameter

* add k=s param to queue URI

* fix

* add sndSecure field to queues

* make sender key non-optional in SndQueue (WIP, tests fail)

* fast handshake sometimes works (many tests fail)

* correctly handle SKEY retries, avoiding to re-generate the keys

* handle SKEY retries during async connection

* fix most tests (1 test fails)

* remove do

* fix contact requests encoding/tests

* export

* fix: ignore duplicate confirmations, fixes testBatchedPendingMessages

* do not store sndSecure in store log if it is false to allow server downgrade

* add connection invitation encoding tests
 2024-06-30 08:36:24 +01:00