Skip to content

Feat/views pulsar topic #2505

Fausto Arcidiacono requested to merge feat/views-pulsar-topic-e2505 into master

Ticket(s) / Related Merge Requests

#2505 (closed)

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

Merge request reports