OpenConext / Stepup-Middleware

     * @param SensitiveDataMessageStream $sensitiveDataMessageStream

     * @return void

     */

    public function append(SensitiveDataMessageStream $sensitiveDataMessageStream)

    {

        $this->connection->beginTransaction();

        try {

            foreach ($sensitiveDataMessageStream as $sensitiveDataMessage) {

                /** @var SensitiveDataMessage $sensitiveDataMessage */

                $this->connection->insert('event_stream_sensitive_data', [

                    'identity_id'    => (string) $sensitiveDataMessage->getIdentityId(),

                    'playhead'       => $sensitiveDataMessage->getPlayhead(),

                    'sensitive_data' => json_encode((object) $sensitiveDataMessage->getSensitiveData()->serialize()),

                ]);

            }

            $this->connection->commit();

        } catch (CoreException $e) {

            $this->connection->rollBack();

            throw new RuntimeException('An exception occurred while appending sensitive data', 0, $e);

        }

    }

    /**

     * @param SensitiveDataMessageStream $sensitiveDataMessageStream

     * @param SensitiveDataMessageStream $sensitiveDataMessageStream

     * @return void

     */

    public function modify(SensitiveDataMessageStream $sensitiveDataMessageStream)

    {

        $this->connection->beginTransaction();

        try {

            foreach ($sensitiveDataMessageStream as $sensitiveDataMessage) {

                /** @var SensitiveDataMessage $sensitiveDataMessage */

                $this->connection->update(

                    'event_stream_sensitive_data',

                    ['sensitive_data' => json_encode((object) $sensitiveDataMessage->getSensitiveData()->serialize())],

                    [

                        'identity_id' => (string) $sensitiveDataMessage->getIdentityId(),

                        'playhead'    => $sensitiveDataMessage->getPlayhead(),

                    ]

                );

            }

            $this->connection->commit();

        } catch (CoreException $e) {

            $this->connection->rollBack();

            throw new RuntimeException('An exception occurred while updating sensitive data', 0, $e);

        }

    }

}