/**
 * Class ManageSessionsByNightTime
 * @package Core\Listener
 */
class ManageSessionsByNightTime extends AbstractManageSessions
{

    /**
     * @var string|null
     */
    private $userId = null;

    /**
     * @param LifecycleEventArgs $args
     * @throws \Exception
     */
    public function postUpdate(LifecycleEventArgs $args)
    {
        /** @var User $userEntity */
        $userEntity = $args->getObject();

        $changeSet = $this->em->getUnitOfWork()->getEntityChangeSet($userEntity);

        // some logic

        $this->userId = $userEntity->getId();
    }

    /**
     * @param PostFlushEventArgs $args
     */
    public function postFlush(PostFlushEventArgs $args)
    {
        if (is_null($this->userId)) return;

        $this->producerSessionProcessor->publish(
            Json::encode([
                'userId' => $this->userId,
                'options' => [
                    'generateNew' => true,
                    'generateNewJIT' => true,
                ]
            ])
        );

        $this->userId = null;
    }

}