eduVPN / vpn-server-api

        return $stmt->fetchAll(PDO::FETCH_ASSOC);

    }

    public function addUserMessage($userId, $type, $message)

    {

        $this->addUser($userId);

        $stmt = $this->db->prepare(

<<< 'SQL'

    INSERT INTO user_messages 

        (user_id, type, message, date_time) 

    VALUES

        (:user_id, :type, :message, :date_time)

SQL

        );

        $stmt->bindValue(':user_id', $userId, PDO::PARAM_STR);

        $stmt->bindValue(':type', $type, PDO::PARAM_STR);

        $stmt->bindValue(':message', $message, PDO::PARAM_STR);

        $stmt->bindValue(':date_time', $this->dateTime->format('Y-m-d H:i:s'), PDO::PARAM_STR);

        $stmt->execute();

    }

    // TokenStorageInterface

        }

    }

    private function addUser($userId)

    {

        $stmt = $this->db->prepare(

<<< 'SQL'

    SELECT 

        COUNT(*)

    FROM 

        users

    WHERE user_id = :user_id

SQL

        );

        $stmt->bindValue(':user_id', $userId, PDO::PARAM_STR);

        $stmt->execute();

        if (1 !== (int) $stmt->fetchColumn()) {

            // user does not exist yet

            $stmt = $this->db->prepare(

<<< 'SQL'

    INSERT INTO 

        users (

            user_id,

            date_time

        )

    VALUES (

        :user_id,

        :date_time

    )

SQL

            );

            $stmt->bindValue(':user_id', $userId, PDO::PARAM_STR);

            $stmt->bindValue(':date_time', $this->dateTime->format('Y-m-d H:i:s'), PDO::PARAM_STR);

            $stmt->execute();

        }

    }

}