Feat/views pulsar topic #2505
Ticket(s) / Related Merge Requests
Summary of Changes
Created new ViewsTopic to manage views events through a pulsar topic
Testing Considerations
Run php cli.php EventStreams exec_batch --subscription="Core\Entities\EventStreams\ViewEventStreamSubscription" --batch_total_amount=1000 --exec_timeout_in_seconds=30
in order to start a consumer that will log the events that it receives when a view is registered in the FE
Deployment Considerations
Regression Scope
Platform Affected (web, mobile, etc)
Developer Testing Completed
Screenshots / Screen Recording
/var/www/Minds/engine # php cli.php EventStreams exec_batch --subscription="Core\Entities\EventStreams\ViewEventStreamSubscription" --batch_total_amount=1000 --exec_timeout_in_seconds=30
[17-Feb-2023 16:00:11 UTC] Xdebug: [Step Debug] Could not connect to debugging client. Tried: docker.for.mac.localhost:9003 (through xdebug.client_host/xdebug.client_port) :-(
2023-02-17 16:00:12.166 INFO [140525138340680] ClientConnection:189 | [<none> -> pulsar://pulsar:6650] Create ClientConnection, timeout=10000
2023-02-17 16:00:12.167 INFO [140525138340680] ConnectionPool:96 | Created connection for pulsar://pulsar:6650
2023-02-17 16:00:12.172 INFO [140525044620032] ClientConnection:375 | [172.18.0.10:39666 -> 172.18.0.7:6650] Connected to broker
2023-02-17 16:00:12.186 INFO [140525044620032] HandlerBase:64 | [persistent://minds-com/engine/event-view, views, 0] Getting connection from pool
2023-02-17 16:00:12.191 INFO [140525044620032] ClientConnection:189 | [<none> -> pulsar://pulsar:6650] Create ClientConnection, timeout=10000
2023-02-17 16:00:12.191 INFO [140525044620032] ConnectionPool:96 | Created connection for pulsar://localhost:6650
2023-02-17 16:00:12.192 INFO [140525044620032] ClientConnection:377 | [172.18.0.10:39678 -> 172.18.0.7:6650] Connected to broker through proxy. Logical broker: pulsar://localhost:6650
2023-02-17 16:00:12.257 INFO [140525044620032] ConsumerImpl:224 | [persistent://minds-com/engine/event-view, views, 0] Created consumer on broker [172.18.0.10:39678 -> 172.18.0.7:6650]
2023-02-17 16:00:12.258 INFO [140525044620032] MultiTopicsConsumerImpl:95 | Successfully Subscribed to Topics
[17-Feb-2023 16:00:24 UTC] {"user_guid":"1426158691500953604","entity_urn":"urn:activity:1437111286595850260","entity_guid":"urn:activity:1437111286595850260","entity_owner_guid":"1426158691500953604","entity_type":"activity","entity_subtype":"","cm_platform":"web","cm_source":"feed\/subscribed","cm_timestamp":1676649624,"cm_salt":"ujcjxeehs","cm_medium":"feed","cm_campaign":"","cm_page_token":"fa6e5020-0b2e082f-124bdfcf-a9b86c9f-26dc707e-3ed3f4a1","cm_delta":1578,"cm_position":18,"cm_served_by_guid":null}
[17-Feb-2023 16:00:24 UTC] {"user_guid":"1426158691500953604","entity_urn":"urn:activity:1437113065681195019","entity_guid":"urn:activity:1437113065681195019","entity_owner_guid":"2859659010675249146","entity_type":"activity","entity_subtype":"","cm_platform":"web","cm_source":"feed\/subscribed","cm_timestamp":1676649624,"cm_salt":"ujcjxeehs","cm_medium":"feed","cm_campaign":"","cm_page_token":"fa6e5020-0b2e082f-124bdfcf-a9b86c9f-26dc707e-3ed3f4a1","cm_delta":1578,"cm_position":17,"cm_served_by_guid":null}
[17-Feb-2023 16:00:27 UTC] {"user_guid":"1426158691500953604","entity_urn":"urn:activity:1437111200100913171","entity_guid":"urn:activity:1437111200100913171","entity_owner_guid":"2859659010675249146","entity_type":"activity","entity_subtype":"","cm_platform":"web","cm_source":"feed\/subscribed","cm_timestamp":1676649627,"cm_salt":"ujcjxeehs","cm_medium":"feed","cm_campaign":"","cm_page_token":"fa6e5020-0b2e082f-124bdfcf-a9b86c9f-26dc707e-3ed3f4a1","cm_delta":1578,"cm_position":19,"cm_served_by_guid":null}
Does this impact
-
Localization -
Dark/light mode -
Guest mode
Definition of Done Checklist
-
The Acceptance Criteria has been met -
Code is tested: Testing includes unit/spec, E2E/automated and manual testing -
Merge requests description has been filled out