(feat): store activity owner_guid for all views - closes #822

Controllers/api/v2/analytics/views.php

@@ -53,6 +53,7 @@ class views implements Interfaces\Api
  $viewsManager->record(
  (new Core\Analytics\Views\View())
  ->setEntityUrn($boost->getEntity()->getUrn())
+ ->setOwnerGuid((string) $boost->getEntity()->getOwnerGuid())
  ->setClientMeta($_POST['client_meta'] ?? [])
  );
  } catch (\Exception $e) {
@@ -105,6 +106,7 @@ class views implements Interfaces\Api
  $viewsManager->record(
  (new Core\Analytics\Views\View())
  ->setEntityUrn($activity->getUrn())
+ ->setOwnerGuid((string) $activity->getOwnerGuid())
  ->setClientMeta($_POST['client_meta'] ?? [])
  );
  } catch (\Exception $e) {

Core/Analytics/Views/ElasticRepository.php

@@ -55,6 +55,7 @@ class ElasticRepository
  'uuid' => $view->getUuid(),
  '@timestamp' => $view->getTimestamp() * 1000,
  'entity_urn' => $view->getEntityUrn(),
+ 'owner_guid' => $view->getOwnerGuid(),
  'page_token' => $view->getPageToken(),
  'campaign' => $view->getCampaign(),
  'delta' => (int) $view->getDelta(),

Core/Analytics/Views/Repository.php

@@ -104,6 +104,7 @@ class Repository
  ->setDay((int) $row['day'] ?: null)
  ->setUuid($row['uuid']->uuid() ?: null)
  ->setEntityUrn($row['entity_urn'])
+ ->setOwnerGuid($row['owner_guid'])
  ->setPageToken($row['page_token'])
  ->setPosition((int) $row['position'])
  ->setSource($row['platform'])
@@ -135,13 +136,14 @@ class Repository
  $timestamp = $view->getTimestamp() ?: time();
  $date = new DateTime("@{$timestamp}", new DateTimeZone('utc'));
 
- $cql = "INSERT INTO views (year, month, day, uuid, entity_urn, page_token, position, platform, source, medium, campaign, delta) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)";
+ $cql = "INSERT INTO views (year, month, day, uuid, entity_urn, owner_guid, page_token, position, platform, source, medium, campaign, delta) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)";
  $values = [
  (int) ($view->getYear() ?? $date->format('Y')),
  new Tinyint((int) ($view->getMonth() ?? $date->format('m'))),
  new Tinyint((int) ($view->getDay() ?? $date->format('d'))),
  new Timeuuid($view->getUuid() ?? $timestamp * 1000),
  $view->getEntityUrn() ?: '',
+ (string) ($view->getOwnerGuid() ?? ''),
  $view->getPageToken() ?: '',
  (int) ($view->getPosition() ?? -1),
  $view->getPlatform() ?: '',

Core/Analytics/Views/View.php

@@ -21,6 +21,8 @@ use Minds\Traits\MagicAttributes;
  * @method string getUuid()
  * @method View setEntityUrn(string $entityUrn)
  * @method string getEntityUrn()
+ * @method View setOwnerGuid(string $ownerGuid)
+ * @method string getOwnerGuid()
  * @method View setPageToken(string $pageToken)
  * @method string getPageToken()
  * @method View setPosition(int $position)
@@ -57,6 +59,9 @@ class View
  /** @var string */
  protected $entityUrn;
 
+ /** @var string */
+ protected $ownerGuid;
+
  /** @var string */
  protected $pageToken;
 

Core/Provisioner/Provisioners/cassandra-provision.cql

@@ -1445,3 +1445,5 @@ CREATE TABLE minds.email_campaign_logs (
  email_campaign_id text,
  PRIMARY KEY (receiver_guid, time_sent)
 ) WITH CLUSTERING ORDER BY (time_sent desc);
+
+ALTER TABLE minds.views ADD owner_guid text;
\ No newline at end of file

Spec/Core/Analytics/Views/RepositorySpec.php

@@ -61,6 +61,10 @@ class RepositorySpec extends ObjectBehavior
  ->shouldBeCalled()
  ->willReturn('urn:test:123123');
 
+ $view->getOwnerGuid()
+ ->shouldBeCalled()
+ ->wilLReturn('789');
+
  $view->getPageToken()
  ->shouldBeCalled()
  ->willReturn('1234-qwe-qwe-1234');
@@ -98,13 +102,14 @@ class RepositorySpec extends ObjectBehavior
  $statement['values'][2]->toInt() === 29 &&
  $statement['values'][3]->uuid() === 'abc-123-456-def' &&
  $statement['values'][4] === 'urn:test:123123' &&
- $statement['values'][5] === '1234-qwe-qwe-1234' &&
- $statement['values'][6] === 5 &&
- $statement['values'][7] === 'php' &&
- $statement['values'][8] === 'phpspec' &&
- $statement['values'][9] === 'test' &&
- $statement['values'][10] === 'urn:phpspec:234234' &&
- $statement['values'][11] === 100;
+ $statement['values'][5] === '789' &&
+ $statement['values'][6] === '1234-qwe-qwe-1234' &&
+ $statement['values'][7] === 5 &&
+ $statement['values'][8] === 'php' &&
+ $statement['values'][9] === 'phpspec' &&
+ $statement['values'][10] === 'test' &&
+ $statement['values'][11] === 'urn:phpspec:234234' &&
+ $statement['values'][12] === 100;
  }), true)
  ->shouldBeCalled()
  ->willReturn(true);
@@ -143,6 +148,10 @@ class RepositorySpec extends ObjectBehavior
  ->shouldBeCalled()
  ->willReturn('urn:test:123123');
 
+ $view->getOwnerGuid()
+ ->shouldBeCalled()
+ ->willReturn(789);
+
  $view->getPageToken()
  ->shouldBeCalled()
  ->willReturn('1234-qwe-qwe-1234');
@@ -180,13 +189,14 @@ class RepositorySpec extends ObjectBehavior
  $statement['values'][2]->toInt() === 29 &&
  $statement['values'][3]->time() === $now * 1000 &&
  $statement['values'][4] === 'urn:test:123123' &&
- $statement['values'][5] === '1234-qwe-qwe-1234' &&
- $statement['values'][6] === 5 &&
- $statement['values'][7] === 'php' &&
- $statement['values'][8] === 'phpspec' &&
- $statement['values'][9] === 'test' &&
- $statement['values'][10] === 'urn:phpspec:234234' &&
- $statement['values'][11] === 100;
+ $statement['values'][5] === '789' &&
+ $statement['values'][6] === '1234-qwe-qwe-1234' &&
+ $statement['values'][7] === 5 &&
+ $statement['values'][8] === 'php' &&
+ $statement['values'][9] === 'phpspec' &&
+ $statement['values'][10] === 'test' &&
+ $statement['values'][11] === 'urn:phpspec:234234' &&
+ $statement['values'][12] === 100;
  }), true)
  ->shouldBeCalled()
  ->willReturn(true);