SmartGecko / GovernorFramework

     * @param string $sagaType Type type of saga the association value belongs to

     * @param string $sagaIdentifier The saga related to the association value

     */

    protected function storeAssociationValue(

        AssociationValue $associationValue,

        $sagaType,

        $sagaIdentifier

    ) {

        $this->mongoTemplate->sagaCollection()->update(

            ['sagaIdentifier' => $sagaIdentifier, 'sagaType' => $sagaType],

            [

                '$push' => [

                    'associations' => [

                        'key' => $associationValue->getPropertyKey(),

                        'value' => $associationValue->getPropertyValue()

                    ]

                ]

            ]

        );

    }

    /**

     * Removes the association value that has been associated with Saga, identified with the given

     * @param string $sagaType The type of the Saga to remove the association from

     * @param string $sagaIdentifier The identifier of the Saga to remove the association from

     */

    protected function removeAssociationValue(

        AssociationValue $associationValue,

        $sagaType,

        $sagaIdentifier

    ) {

        $this->mongoTemplate->sagaCollection()->update(

            ['sagaIdentifier' => $sagaIdentifier, 'sagaType' => $sagaType],

            [

                '$pull' => [

                    'associations' => [

                        'key' => $associationValue->getPropertyKey(),

                        'value' => $associationValue->getPropertyValue()

                    ]

                ]

            ]

        );

    }

    /**

     * Loads a known Saga instance by its unique identifier. Returned Sagas must be {@link #commit(Saga) committed}