Commit cce6c50c authored by Mark Harding's avatar Mark Harding
Browse files

(chore): single notifications now through cassandra

parent a9152cfa

Core/Notification/CassandraRepository.php

+2 −2
Original line number Original line Diff line number Diff line
@@ -104,7 +104,7 @@ class CassandraRepository 
     */

     */

    public function get($urn)

    public function get($urn)

    {

    {

        list ($to_guid, $uuid) = explode('-', $this->urn->setUrn($urn)->getNss());

        list ($to_guid, $uuid) = explode('-', $this->urn->setUrn($urn)->getNss(), 2);





        $response = $this->getList([

        $response = $this->getList([

            'to_guid' => $to_guid,

            'to_guid' => $to_guid,

Core/Notification/Manager.php

+6 −3
Original line number Original line Diff line number Diff line
@@ -63,10 +63,13 @@ class Manager 
     */

     */

    public function getSingle($urn)

    public function getSingle($urn)

    {

    {

        if (strpos($urn, 'urn:') !== FALSE) {

        if (strpos($urn, 'urn:') === FALSE) {

            return $this->cassandraRepository->get($urn);

            $urn = "urn:notification:" . implode('-', [

                    $this->user->getGuid(),

                    $urn

                ]);

        }

        }

        return $this->repository->get($urn);

        return $this->cassandraRepository->get($urn);

    }

    }





    /**

    /**