39 Commits

Author SHA1 Message Date
Alberto Soutullo
baf9e4f0be Logger adjustments (#37)
* Add TRACE to logger.py

* Modify logs
2025-11-04 14:41:57 +01:00
Alberto Soutullo
3061696515 Multiple consumers (#35)
* Improve async_utils.py for use multiple consumers and add custom typings

* Use queues for getting sender requests, and add custom typing

* Add function_on_queue_item

* Accept friend requests with multiple consumers

* Use previous changes in idle_relay scenario.

* Use consumers variable

* Simplify sentinel to decouple consumers from send_friend_requests and accept_friend_requests

* Add missing dataclasses.py

* Update src/setup_status.py

Co-authored-by: PearsonWhite <PearsonWhite602@gmail.com>

* Update src/setup_status.py

Co-authored-by: PearsonWhite <PearsonWhite602@gmail.com>

* Create cleanup_queue_on_event

* Decouple queue cleanup from accept friend request

---------

Co-authored-by: PearsonWhite <PearsonWhite602@gmail.com>
2025-10-17 19:03:35 +02:00
Alberto Soutullo
b2e19c4747 Asynq utils (#33)
* Create async queue utils

* Change from signal queue to message list.

* Change send_friend_requests to use asynq utils

* Adjust accept_friend_requests with latest changes

* Modifications to idle_relay

* Update src/signal_client.py

Co-authored-by: PearsonWhite <PearsonWhite602@gmail.com>

* Update src/async_utils.py

Co-authored-by: PearsonWhite <PearsonWhite602@gmail.com>

* Add traceback to error

* Directly await enqueue jobs instead of do asyncio.gather. Also move collector_task to gather.

* Refactor double queue approach

* Remove double quotes

* Return complete partial object

---------

Co-authored-by: PearsonWhite <PearsonWhite602@gmail.com>
2025-10-07 15:14:59 +02:00
Alberto Soutullo
a92c7cde89 Second benchmark additions (#32)
* Change controlbox pull to Always

* Update status-init to fix discovery issues.

* Improve logging in inject_messages_group_chat

* Save messages in a list with timestamps

* Add method for cleanup signals on logout (probably to avoid issues when loging in and searching for signals)

* Save last loging time
2025-09-29 19:29:38 +02:00
Alberto Soutullo
045d5e0039 Send group message (#26)
* Add inject_messages_group_chat

* Add send_group_message scenario

* Return group id from create_group_chat

* Finish correctly send_group_message
2025-09-29 19:10:09 +02:00
Alberto Soutullo
6d24829955 Create private group (#25)
* Add add_contacts and create_group_chat

* Add imports

* Add create_private_group scenario

* Remove duplicated import

* Create multiple groups without overlapping
2025-09-29 16:34:21 +02:00
Alberto Soutullo
4eaabd153a Send one-to-one (#24)
* Add inject_messages_one_to_one

* Add send_one_to_one_message scenario
2025-09-26 20:56:50 +02:00
Alberto Soutullo
375eac575d Contact request (#23)
* Add decline_friend_requests

* Add contact_request

* Add decline_contact_request to wakuext
2025-09-26 20:04:57 +02:00
Alberto Soutullo
93dfebf31c Idle light (#22)
* Add idle_light scenario

* Update src/benchmark_scenarios/private_chats.py

Co-authored-by: PearsonWhite <PearsonWhite602@gmail.com>

---------

Co-authored-by: PearsonWhite <PearsonWhite602@gmail.com>
2025-09-26 19:05:12 +02:00
Alberto Soutullo
e23e1d3f88 Idle relay (#21)
* Add send_friend_requests and accept_friend_requests setup functions

* Add idle_relay scenario

* Add missing import
2025-09-26 16:53:42 +02:00
Alberto Soutullo
8ae0a1f24a Minor improvements (#20)
* Improve find_signal_containing_string by retrieving data from the buffer instead.

* Delete olf function

* Add helper functions for retrieving data in a message

* Fix error in reject_community_requests
2025-09-26 16:21:45 +02:00
Alberto Soutullo
c8c474294c Add isolated_traffic_request_to_join (#19) 2025-09-26 16:12:14 +02:00
Alberto Soutullo
47a4665b87 Isolated traffic chat messages 1 (#18)
* Add isolated_traffic_chat_messages_1

* Add isolated_traffic_chat_messages_2

* Remove unnecessary logout

* Update src/benchmark_scenarios/communities.py

Co-authored-by: PearsonWhite <PearsonWhite602@gmail.com>

* Update src/benchmark_scenarios/communities.py

Co-authored-by: PearsonWhite <PearsonWhite602@gmail.com>

* Stop correct nodes

---------

Co-authored-by: PearsonWhite <PearsonWhite602@gmail.com>
2025-09-26 15:41:14 +02:00
Alberto Soutullo
a38160ac1a Request to join comm mix (#17)
* Add reject_community_requests

* Add decline_request_to_join_community

* Minor comments

* Add missing code

* Fix rebased code
2025-09-26 14:47:41 +02:00
Alberto Soutullo
d6c71775a6 Message sending scenario (#31)
* Change parameter in inject_messages to a better naming

* Add message_sending community performance

* Add missing await

* Add missing community id and shut down nodes
2025-09-25 19:09:48 +02:00
Alberto Soutullo
953119721d Add store_performance (#30) 2025-09-25 18:08:29 +02:00
Alberto Soutullo
466674bc48 Setup StatusBackend functions (#29)
* Add functions to set up status nodes

* Fixed error when login into a node.

* Add functions to send and accept friend requests

* Split requests into apply and accept and other changes

* Started changing setup_status with previous changes

* Improve logout

* Cleanup setup_status.py

* Reduced logs to DEBUG to avoid noise

* Add subscription_performance

* Fix wrong import in communities.py
2025-09-25 18:00:49 +02:00
Alberto Soutullo
2c6f8a57b8 Buffered queue (#14)
* Import enum from local

* Change class name because of previous rebase

* Fix double await because of previous changes in RPCClient

* Change Singal class to create a stream with a bufferedqueue and an asyncgenerator

* Change StatusBackend to use previous signal changes. Removed __aexit__ to have better control over lifetime

* Clean imports

* Add enums class
2025-09-25 10:40:02 +02:00
Alberto Soutullo
8b518b75b2 Asyncio (#13)
* Change RPCClient to be Async with aiohttp

* Change Service to be async with AsyncRPCClient

* Change AccountService to async due to Service changes

* Change WakuextService to async due to Service changes

* Change WalletService to async due to Service changes

* Change SignalClient to async

* Favored composition over inheritance in StatusBackend, also make async needed changes

* Make inject messages async
2025-07-02 18:03:11 +02:00
Alberto Soutullo
a3c0ece4af Message injection (#11)
* Add inject_messages

* Add missing typing

* Change response to _

* Change Exception to AssertionError

* Add comment
2025-07-01 15:58:39 +02:00
Alberto Soutullo
43ca491129 StatusBackend class (#10)
* Add status backend class

* Add missing typing

* Remove unnecessary flag

* Change exception error

* Rename init_status_backend to start_status_backend

* Rename find_public_key to set_public_key

* Add comment
2025-07-01 15:56:00 +02:00
Alberto Soutullo
a82a2a743b Services (#9)
* Add service class

* Add account service class

* Add wallet service class

* Add wakuext service class

* Add missing typing

* Add more missing typing
2025-07-01 00:01:26 +02:00
Alberto Soutullo
f43ae0630f RPC & Signal clients (#8)
* Add RPC client

* Add signal client

* Add missing typing to SignalClient

* Add missing typing to RpcClient

* Remove skip validation from verify_is_valid_json_rpc_response

* TODOS for delta_count

* Rename pattern to string
2025-06-30 23:02:33 +02:00
Alberto Soutullo
35996310a5 Add kube utils (#7) 2025-06-30 21:54:26 +02:00
Alberto Soutullo
fae339bfcf Add logger (#6) 2025-06-30 21:53:50 +02:00
Alberto Soutullo
d284b21f1a Merge pull request #5 from vacp2p/Alberto/deployment_files
Add deployment files
2025-06-30 21:26:22 +02:00
Alberto Soutullo
27fe7884f5 Merge pull request #4 from vacp2p/Alberto/init-util
Add status-init
2025-06-30 21:26:01 +02:00
Alberto Soutullo
fdb544d2f5 Add WEBSOCKET_URL env to yaml 2025-06-30 19:03:37 +02:00
Alberto Soutullo
42802c99c7 Remove unnecessary docker commands 2025-06-30 19:00:21 +02:00
Alberto Soutullo
44d253956c Remove unnecessary python dependencies 2025-06-30 18:56:59 +02:00
Alberto Soutullo
51074f03be Merge pull request #3 from vacp2p/Alberto/utils-init
Add status-subscriber
2025-06-30 18:52:07 +02:00
Alberto Soutullo
877d0a4156 Add deployment files 2025-06-30 17:51:57 +02:00
Alberto Soutullo
7eb5b94135 Add status-init docker util 2025-06-30 17:50:54 +02:00
Alberto Soutullo
57ebdb141b Add status-subscriber docker utils 2025-06-30 17:33:50 +02:00
Alberto Soutullo
b9e1b3b0d7 Merge pull request #2 from vacp2p/Alberto/controlbox
Add controlbox
2025-06-30 17:30:22 +02:00
Alberto Soutullo
74a585fe02 Add controlbox 2025-06-27 22:34:33 +02:00
Alberto Soutullo
7e83bdfa0e Merge pull request #1 from vacp2p/Alberto/base_manifests
Add base-manifests
2025-06-27 22:19:31 +02:00
Alberto Soutullo
7d0089fa10 Add base-manifests 2025-06-27 17:56:35 +02:00
Alberto Soutullo
ab4bc88a30 Create .gitignore 2025-06-27 17:50:53 +02:00