171f16e427
Logging ( #24 )
...
* logging with simple-logger
* refactor Agent.Client
* move logging to Agent.Client
* clean up
* log command name only
2021-01-22 08:59:47 +00:00
a8e21ac6e6
sql quasi-qouter ( #26 )
2021-01-22 07:51:45 +00:00
ddbf00fc46
Sending messages end to end ( #21 )
...
* duplex connection end-to-end (working, debug logs)
* agent: send, receive, acknowledge messages
* logging proposal
* logging: client/server (dis)connections
* agent scenario testing framework
* add tests, remove logs
* clean up
2021-01-20 21:01:54 +00:00
1a40b91331
parse agent messages with attoparsec ( #18 )
...
* parse agent messages with attoparsec (WIP)
* agent: refactor parsers
* agent: parse commands and responses with attoparsec
* refactor UTCTime parser
* fix: updateRcvQueueStatus args
* remove outdated comment
* message parsing: PR feedback
Co-authored-by: Efim Poberezkin <efim.poberezkin@gmail.com >
2021-01-18 20:53:02 +00:00
a7f136e81a
correct variable name
2021-01-17 20:03:07 +00:00
826a9acb9d
agent store: add getReceiveQueue
2021-01-17 23:06:23 +04:00
2491a23742
agent store: add update queue methods ( #19 )
2021-01-17 22:46:47 +04:00
8d6bce98f9
Receive messages ( #17 )
...
* framework to parse and process agent messages
* update SMPClient functions to accept private key
* process messages (WIP)
* agent: create reply queue and send REPLY message with qInfo
* refactor agent commands
* refactor processSMPTransmission
* agent: logic to process REPLY message
2021-01-17 11:33:26 +00:00
0a877d68e4
tests: randomize db file name to fix io errors ( #16 )
...
* tests: check file doesn't exist in store tests after
* Revert "tests: check file doesn't exist in store tests after"
This reverts commit de624433a92769109+epoberezkin@users.noreply.github.com >
2021-01-16 22:02:18 +04:00
2659110e96
receiving messages and remaining client functions ( #15 )
...
* SMPClient queues for messages and notifications
* style
* SMPClient: put all messages (and uncorrelated server commands) to provided TBQueue
2021-01-15 15:54:43 +00:00
bdeedd7705
agent store: add createMsg ( #14 )
2021-01-15 13:32:11 +04:00
3ad0bffaab
SMPClient returns errors via ExceptT ( #13 )
2021-01-13 19:49:45 +00:00
c72deeda28
SMP client library ( #9 )
...
* functions to send SMP commands and receive responses
* refactor agent: use SMPClient
* fix tests, remove ServerClient.hs
* refactor processCommand
* fix Agent.hs
* fix SMPClient, tests
* "forever" to SMPClient process
2021-01-13 19:32:21 +00:00
9f8dc23bcb
agent tests ( #8 )
2021-01-12 15:08:01 +00:00
253f4e39c9
JOIN command ( #4 )
...
* parse JOIN command
* parse JOIN command
* serialize NEW command
* parse and serialize CON response
* process JOIN command: SEND confirmation (WIP)
* process response to the confirmation from JOIN command
* remove comment
2021-01-11 18:31:10 +00:00
7f22dcd496
agent store: add updateQueueStatus tests
2021-01-11 19:34:30 +04:00
f5aaab3861
agent store: fix updateQueueStatus
2021-01-10 23:43:57 +04:00
b9cdc6a09d
agent store: add updateQueueStatus; TODO finalize, tests
2021-01-10 16:08:19 +04:00
ef028c135d
agent SQLiteStore: method stubs
2021-01-09 20:54:41 +00:00
394803b3cf
remove/fix compiler warnings
2021-01-09 20:48:07 +00:00
ea6496ca24
better MonadUnliftIO instance for ExceptT; fix tests
2021-01-09 20:35:19 +00:00
d1c5e9df7b
agent: ErrorType constructor for store errors, exceptions are caught
2021-01-09 19:55:42 +00:00
3dbdb948ae
agent: respond with INV (TODO: store exception blows up; select does not work without port
2021-01-09 19:23:32 +00:00
a1c4ce6448
refactor store: simplify
2021-01-09 13:04:13 +00:00
0d0a12f778
refactor store: m (Either e a) => ExceptT e m a
2021-01-09 11:18:52 +00:00
75f58f8ba4
remove unnecessary bindings
2021-01-09 08:31:21 +00:00
af5bd101cb
agent store: make create connection methods return ()
2021-01-08 15:51:33 +04:00
19238c6cc4
agent store: add deleteConn and tests
2021-01-07 17:58:46 +04:00
e692cb0119
add addRcvQueue and tests
2021-01-07 14:00:53 +04:00
51cc602bdb
agent store: refactor addSndQueue
2021-01-06 20:22:00 +00:00
5a6b1c67a9
add test testAddSndQueue
2021-01-06 23:01:53 +04:00
94d0be5d27
add test for addSndQueue
2021-01-06 22:35:04 +04:00
61092e8371
add implemented addSndQueue
2021-01-06 22:11:55 +04:00
1c32fccb39
[WIP] add addSndQueue
2021-01-06 18:03:55 +04:00
6e6ad0fb9b
agent store: getConn with tests
2021-01-05 20:31:01 +00:00
a555c4e510
agent store: getSndQueue
2021-01-05 19:42:50 +00:00
4a19602be6
agent store: getRcvQueue
2021-01-05 19:34:47 +00:00
a28462d496
add select functions drafts
2021-01-05 19:44:44 +04:00
5d2e77f41d
test: agent SQLite createRcvConnection
2021-01-04 20:25:02 +00:00
2e761b20f6
remove commented queries
2021-01-04 18:01:11 +04:00
9a1ffb349a
add insertSndQueue, insertSndConnection and implementation of createSndConn
2021-01-04 17:48:29 +04:00
15cf2e9fff
upsertServer: use select to get server ID
2021-01-04 10:39:20 +00:00
650971fa02
method to insert connection ( #3 )
2021-01-03 18:05:50 +00:00
3d4f43a051
add NOT NULL constraints
2021-01-03 12:47:12 +00:00
6526e421e8
insertWithLock
2021-01-03 11:44:07 +00:00
48967167c4
add table mutexes for insert queries (to get inserted ID thread-safely via single connection)
2021-01-03 11:31:06 +00:00
d260a464d6
add error handling, function to process SMP responses
2021-01-03 10:42:41 +00:00
24bca7650e
throw exception from Transport.StartTCPClient when no provided address works (and on empty list of addresses)
2021-01-02 16:55:43 +00:00
80b4ff365d
TCP client: try all resolved addresses, not just the first
2020-12-30 21:25:49 +00:00
f3cd3eac58
add protocol version in TCP welcome
2020-12-30 18:50:50 +00:00
Evgeny Poberezkin