XEP-0482: add initial support

XEP-0050: make prev action possible when there is no next action (fixes #3516 )
Obviously the session has to allow for it, which must be modified in a handler.
2025-02-09 18:52:28 +01:00 · 2025-02-09 16:14:08 +01:00 · 2025-02-09 15:52:43 +01:00 · 2025-02-09 15:35:40 +01:00 · 2025-02-09 13:39:57 +01:00 · 2025-02-09 12:31:15 +01:00
87 changed files with 2227 additions and 336 deletions
--- a/.github/pull_request_template.md
+++ b/.github/pull_request_template.md
@ -1,13 +0,0 @@
-################ Please use Gitlab instead of Github ###################################
-
-Hello, thank you for contributing to slixmpp!
-
-You’re about to open a pull request on github. However this github repository is not the official place for contributions on slixmpp.
-
-Please open your merge request on https://lab.louiz.org/poezio/slixmpp/
-
-You should be able to log in there with your github credentials, clone the slixmpp repository in your namespace, push your existing pull request into a new branch, and then open a merge request with one click, within 3 minutes.
-
-This will help us review your contribution, avoid spreading things everywhere and it will even run the tests automatically with your changes.
-
-Thank you.
--- a/.gitlab-ci.yml
+++ b/.gitlab-ci.yml
@ -1,81 +0,0 @@
-stages:
-  - lint
-  - test
-  - trigger
-
-mypy:
-  stage: lint
-  tags:
-    - docker
-  image: python:3
-  script:
-    - pip3 install mypy
-    - mypy slixmpp
-
-test-3.7:
-  stage: test
-  tags:
-    - docker
-  image: python:3.7
-  script:
-    - apt-get update
-    - apt-get install -y python3 python3-pip cython3 gpg
-    - pip3 install emoji aiohttp cryptography
-    - ./run_tests.py
-
-test-3.10:
-  stage: test
-  tags:
-    - docker
-  image: python:3.10
-  script:
-    - apt update
-    - apt-get install -y python3 python3-pip cython3 gpg
-    - pip3 install emoji aiohttp cryptography
-    - ./run_tests.py
-
-test-3.11:
-  stage: test
-  tags:
-    - docker
-  image: python:3.11
-  script:
-    - apt-get update
-    - apt-get install -y python3 python3-pip cython3 gpg
-    - pip3 install emoji aiohttp cryptography
-    - ./run_tests.py
-
-test-3.12:
-  stage: test
-  tags:
-    - docker
-  image: python:3.12-rc
-  allow_failure: true
-  script:
-    - apt-get update
-    - apt-get install -y python3 python3-pip cython3 gpg
-    - pip3 install emoji aiohttp cryptography
-    - ./run_tests.py
-
-test_integration:
-  stage: test
-  tags:
-    - docker
-  image: python:3
-  only:
-    variables:
-        - $CI_ACCOUNT1
-        - $CI_ACCOUNT2
-  script:
-    - apt-get update
-    - apt-get install -y python3 python3-pip cython3 gpg
-    - pip3 install emoji aiohttp aiodns
-    - ./run_integration_tests.py
-
-trigger_poezio:
-  stage: trigger
-  tags:
-    - docker
-  image: curlimages/curl:7.79.1
-  script:
-    - curl --request POST -F token="$SLIXMPP_TRIGGER_TOKEN" -F ref=master https://lab.louiz.org/api/v4/projects/18/trigger/pipeline
--- a/.travis.yml
+++ b/.travis.yml
@ -1,7 +0,0 @@
-language: python
-python:
-  - "3.7"
-  - "3.8-dev"
-install:
-  - "pip install ."
-script: testall.py
--- a/.woodpecker/lint.yml
+++ b/.woodpecker/lint.yml
@ -1,3 +1,6 @@
+when:
+  event: [ push, pull_request ]
+
 steps:
  mypy:
    image: python:3
--- a/.woodpecker/test-integration.yml
+++ b/.woodpecker/test-integration.yml
@ -1,7 +1,20 @@
+when:
+  event: [ push, pull_request ]
+
 steps:
  test_integration:
    image: "python:3.11"
-    secrets: [ci_account1, ci_account1_password, ci_account2, ci_account2_password, ci_muc_server]
+    environment:
+      CI_ACCOUNT1:
+        from_secret: ci_account1
+      CI_ACCOUNT1_PASSWORD:
+        from_secret: ci_account1_password
+      CI_ACCOUNT2:
+        from_secret: ci_account2
+      CI_ACCOUNT2_PASSWORD:
+        from_secret: ci_account2_password
+      CI_MUC_SERVER:
+        from_secret: ci_muc_server
    commands:
      - apt-get update
      - apt-get install -y python3-pip cython3 gpg idn libidn-dev
--- a/.woodpecker/test.yml
+++ b/.woodpecker/test.yml
@ -1,17 +1,19 @@
+when:
+  event: [ push, pull_request ]
+
 steps:
  unit_tests:
    image: "python:${TAG}"
    commands:
    - apt-get update
    - apt-get install -y python3 python3-pip cython3 gpg
-    - pip3 install emoji aiohttp cryptography
+    - pip3 install emoji aiohttp cryptography setuptools
    - ./run_tests.py

 matrix:
  TAG:
-    - "3.7"
    - "3.9"
-    - "3.8"
    - "3.10"
    - "3.11"
    - "3.12"
+    - "3.13"
--- a/doap.xml
+++ b/doap.xml
@ -616,6 +616,14 @@
            <xmpp:since>1.0</xmpp:since>
        </xmpp:SupportedXep>
    </implements>
+    <implements>
+        <xmpp:SupportedXep>
+            <xmpp:xep rdf:resource="https://xmpp.org/extensions/xep-0264.html"/>
+            <xmpp:status>complete</xmpp:status>
+            <xmpp:version>0.4.2</xmpp:version>
+            <xmpp:since>1.8.6</xmpp:since>
+        </xmpp:SupportedXep>
+    </implements>
    <implements>
        <xmpp:SupportedXep>
            <xmpp:xep rdf:resource="https://xmpp.org/extensions/xep-0270.html"/>
@ -682,6 +690,14 @@
            <xmpp:since>1.0</xmpp:since>
        </xmpp:SupportedXep>
    </implements>
+    <implements>
+        <xmpp:SupportedXep>
+            <xmpp:xep rdf:resource="https://xmpp.org/extensions/xep-0317.html"/>
+            <xmpp:status>complete</xmpp:status>
+            <xmpp:version>1.8.6</xmpp:version>
+            <xmpp:since>0.2</xmpp:since>
+        </xmpp:SupportedXep>
+    </implements>
    <implements>
        <xmpp:SupportedXep>
            <xmpp:xep rdf:resource="https://xmpp.org/extensions/xep-0319.html"/>
@ -856,7 +872,7 @@
        <xmpp:SupportedXep>
            <xmpp:xep rdf:resource="https://xmpp.org/extensions/xep-0424.html"/>
            <xmpp:status>complete</xmpp:status>
-            <xmpp:version>0.3.0</xmpp:version>
+            <xmpp:version>0.4.0</xmpp:version>
            <xmpp:since>1.6.0</xmpp:since>
        </xmpp:SupportedXep>
    </implements>
@ -864,7 +880,7 @@
        <xmpp:SupportedXep>
            <xmpp:xep rdf:resource="https://xmpp.org/extensions/xep-0425.html"/>
            <xmpp:status>complete</xmpp:status>
-            <xmpp:version>0.2.1</xmpp:version>
+            <xmpp:version>0.3.0</xmpp:version>
            <xmpp:since>1.6.0</xmpp:since>
        </xmpp:SupportedXep>
    </implements>
@ -900,13 +916,53 @@
            <xmpp:since>1.6.0</xmpp:since>
        </xmpp:SupportedXep>
    </implements>
+    <implements>
+        <xmpp:SupportedXep>
+            <xmpp:xep rdf:resource="https://xmpp.org/extensions/xep-0446.html"/>
+            <xmpp:status>complete</xmpp:status>
+            <xmpp:version>0.2.0</xmpp:version>
+            <xmpp:since>1.8.7</xmpp:since>
+        </xmpp:SupportedXep>
+    </implements>
    <implements>
        <xmpp:SupportedXep>
            <xmpp:xep rdf:resource="https://xmpp.org/extensions/xep-0454.html"/>
            <xmpp:status>partial</xmpp:status>
            <xmpp:version>0.1.0</xmpp:version>
            <xmpp:since>1.8.1</xmpp:since>
-						<xmpp:note>no thumbnail support</xmpp:note>
+            <xmpp:note>no thumbnail support</xmpp:note>
+        </xmpp:SupportedXep>
+    </implements>
+    <implements>
+        <xmpp:SupportedXep>
+            <xmpp:xep rdf:resource="https://xmpp.org/extensions/xep-0469.html"/>
+            <xmpp:status>partial</xmpp:status>
+            <xmpp:version>0.1.0</xmpp:version>
+            <xmpp:since>1.8.6</xmpp:since>
+        </xmpp:SupportedXep>
+    </implements>
+    <implements>
+        <xmpp:SupportedXep>
+            <xmpp:xep rdf:resource="https://xmpp.org/extensions/xep-0482.html"/>
+            <xmpp:status>complete</xmpp:status>
+            <xmpp:version>0.1.0</xmpp:version>
+            <xmpp:since>1.8.7</xmpp:since>
+        </xmpp:SupportedXep>
+    </implements>
+    <implements>
+        <xmpp:SupportedXep>
+            <xmpp:xep rdf:resource="https://xmpp.org/extensions/xep-0490.html"/>
+            <xmpp:status>complete</xmpp:status>
+            <xmpp:version>0.1.0</xmpp:version>
+            <xmpp:since>1.8.6</xmpp:since>
+        </xmpp:SupportedXep>
+    </implements>
+    <implements>
+        <xmpp:SupportedXep>
+            <xmpp:xep rdf:resource="https://xmpp.org/extensions/xep-0492.html"/>
+            <xmpp:status>complete</xmpp:status>
+            <xmpp:version>0.1.0</xmpp:version>
+            <xmpp:since>1.8.7</xmpp:since>
        </xmpp:SupportedXep>
    </implements>

@ -1071,5 +1127,12 @@
            <file-release rdf:resource="https://codeberg.org/poezio/slixmpp/archive/slix-1.8.5.tar.gz"/>
        </Version>
    </release>
+    <release>
+        <Version>
+            <revision>1.8.6</revision>
+            <created>2024-12-26</created>
+            <file-release rdf:resource="https://codeberg.org/poezio/slixmpp/archive/slix-1.8.6.tar.gz"/>
+        </Version>
+    </release>
 </Project>
 </rdf:RDF>
--- a/docs/api/plugins/index.rst
+++ b/docs/api/plugins/index.rst
@ -17,6 +17,7 @@ Plugin index
    xep_0049
    xep_0050
    xep_0054
+    xep_0055
    xep_0059
    xep_0060
    xep_0065
@ -31,6 +32,7 @@ Plugin index
    xep_0085
    xep_0086
    xep_0092
+    xep_0100
    xep_0106
    xep_0107
    xep_0108
@ -62,12 +64,15 @@ Plugin index
    xep_0256
    xep_0257
    xep_0258
+    xep_0264
    xep_0279
    xep_0280
+    xep_0292
    xep_0297
    xep_0300
    xep_0308
    xep_0313
+    xep_0317
    xep_0319
    xep_0332
    xep_0333
@ -79,9 +84,13 @@ Plugin index
    xep_0359
    xep_0363
    xep_0369
+    xep_0372
    xep_0377
    xep_0380
+    xep_0382
+    xep_0385
    xep_0394
+    xep_0402
    xep_0403
    xep_0404
    xep_0405
@ -94,3 +103,9 @@ Plugin index
    xep_0439
    xep_0441
    xep_0444
+    xep_0446
+    xep_0447
+    xep_0461
+    xep_0469
+    xep_0490
+    xep_0492
--- a/docs/api/plugins/xep_0100.rst
+++ b/docs/api/plugins/xep_0100.rst
@ -1,5 +1,5 @@

-XEP-0106: Gateway interaction
+XEP-0100: Gateway interaction
 =============================

 .. module:: slixmpp.plugins.xep_0100
--- a/docs/api/plugins/xep_0264.rst
+++ b/docs/api/plugins/xep_0264.rst
@ -0,0 +1,18 @@
+
+XEP-0264: Jingle Content Thumbnails
+===================================
+
+.. module:: slixmpp.plugins.xep_0264
+
+.. autoclass:: XEP_0264
+    :members:
+    :exclude-members: session_bind, plugin_init, plugin_end
+
+
+Stanza elements
+---------------
+
+.. automodule:: slixmpp.plugins.xep_0264.stanza
+    :members:
+    :undoc-members:
+
--- a/docs/api/plugins/xep_0317.rst
+++ b/docs/api/plugins/xep_0317.rst
@ -0,0 +1,18 @@
+
+XEP-0317: Hats
+==============
+
+.. module:: slixmpp.plugins.xep_0317
+
+.. autoclass:: XEP_0317
+    :members:
+    :exclude-members: session_bind, plugin_init, plugin_end
+
+
+Stanza elements
+---------------
+
+.. automodule:: slixmpp.plugins.xep_0317.stanza
+    :members:
+    :undoc-members:
+
--- a/docs/api/plugins/xep_0372.rst
+++ b/docs/api/plugins/xep_0372.rst
@ -0,0 +1,18 @@
+
+XEP-0372: References
+====================
+
+.. module:: slixmpp.plugins.xep_0372
+
+.. autoclass:: XEP_0372
+    :members:
+    :exclude-members: session_bind, plugin_init, plugin_end
+
+
+Stanza elements
+---------------
+
+.. automodule:: slixmpp.plugins.xep_0372.stanza
+    :members:
+    :undoc-members:
+
--- a/docs/api/plugins/xep_0382.rst
+++ b/docs/api/plugins/xep_0382.rst
@ -0,0 +1,18 @@
+
+XEP-0382: Spoiler Messages
+==========================
+
+.. module:: slixmpp.plugins.xep_0382
+
+.. autoclass:: XEP_0382
+    :members:
+    :exclude-members: session_bind, plugin_init, plugin_end
+
+
+Stanza elements
+---------------
+
+.. automodule:: slixmpp.plugins.xep_0382.stanza
+    :members:
+    :undoc-members:
+
--- a/docs/api/plugins/xep_0385.rst
+++ b/docs/api/plugins/xep_0385.rst
@ -0,0 +1,18 @@
+
+XEP-0385: Stateless Inline Media Sharing (SIMS)
+===============================================
+
+.. module:: slixmpp.plugins.xep_0385
+
+.. autoclass:: XEP_0385
+    :members:
+    :exclude-members: session_bind, plugin_init, plugin_end
+
+
+Stanza elements
+---------------
+
+.. automodule:: slixmpp.plugins.xep_0385.stanza
+    :members:
+    :undoc-members:
+
--- a/docs/api/plugins/xep_0402.rst
+++ b/docs/api/plugins/xep_0402.rst
@ -0,0 +1,18 @@
+
+XEP-0402: PEP Native Bookmarks
+==============================
+
+.. module:: slixmpp.plugins.xep_0402
+
+.. autoclass:: XEP_0402
+    :members:
+    :exclude-members: session_bind, plugin_init, plugin_end
+
+
+Stanza elements
+---------------
+
+.. automodule:: slixmpp.plugins.xep_0402.stanza
+    :members:
+    :undoc-members:
+
--- a/docs/api/plugins/xep_0446.rst
+++ b/docs/api/plugins/xep_0446.rst
@ -0,0 +1,18 @@
+
+XEP-0446: File metadata element
+===============================
+
+.. module:: slixmpp.plugins.xep_0446
+
+.. autoclass:: XEP_0446
+    :members:
+    :exclude-members: session_bind, plugin_init, plugin_end
+
+
+Stanza elements
+---------------
+
+.. automodule:: slixmpp.plugins.xep_0446.stanza
+    :members:
+    :undoc-members:
+
--- a/docs/api/plugins/xep_0447.rst
+++ b/docs/api/plugins/xep_0447.rst
@ -0,0 +1,18 @@
+
+XEP-0447: Stateless File Sharing
+================================
+
+.. module:: slixmpp.plugins.xep_0447
+
+.. autoclass:: XEP_0447
+    :members:
+    :exclude-members: session_bind, plugin_init, plugin_end
+
+
+Stanza elements
+---------------
+
+.. automodule:: slixmpp.plugins.xep_0447.stanza
+    :members:
+    :undoc-members:
+
--- a/docs/api/plugins/xep_0461.rst
+++ b/docs/api/plugins/xep_0461.rst
@ -0,0 +1,18 @@
+
+XEP-0461: Message Replies
+=========================
+
+.. module:: slixmpp.plugins.xep_0461
+
+.. autoclass:: XEP_0461
+    :members:
+    :exclude-members: session_bind, plugin_init, plugin_end
+
+
+Stanza elements
+---------------
+
+.. automodule:: slixmpp.plugins.xep_0461.stanza
+    :members:
+    :undoc-members:
+
--- a/docs/api/plugins/xep_0469.rst
+++ b/docs/api/plugins/xep_0469.rst
@ -0,0 +1,17 @@
+XEP-0469: Bookmark Pinning
+==========================
+
+.. module:: slixmpp.plugins.xep_0469
+
+.. autoclass:: XEP_0469
+    :members:
+    :exclude-members: session_bind, plugin_init, plugin_end
+
+
+Stanza elements
+---------------
+
+.. automodule:: slixmpp.plugins.xep_0469.stanza
+    :members:
+    :undoc-members:
+
--- a/docs/api/plugins/xep_0490.rst
+++ b/docs/api/plugins/xep_0490.rst
@ -0,0 +1,18 @@
+
+XEP-0490: Message Displayed Synchronization
+===========================================
+
+.. module:: slixmpp.plugins.xep_0490
+
+.. autoclass:: XEP_0490
+    :members:
+    :exclude-members: session_bind, plugin_init, plugin_end
+
+
+Stanza elements
+---------------
+
+.. automodule:: slixmpp.plugins.xep_0490.stanza
+    :members:
+    :undoc-members:
+
--- a/docs/api/plugins/xep_0492.rst
+++ b/docs/api/plugins/xep_0492.rst
@ -0,0 +1,18 @@
+
+XEP-0492: Chat Notification Settings
+====================================
+
+.. module:: slixmpp.plugins.xep_0492
+
+.. autoclass:: XEP_0492
+    :members:
+    :exclude-members: session_bind, plugin_init, plugin_end
+
+
+Stanza elements
+---------------
+
+.. automodule:: slixmpp.plugins.xep_0492.stanza
+    :members:
+    :undoc-members:
+
--- a/docs/event_index.rst
+++ b/docs/event_index.rst
@ -167,8 +167,9 @@ processing the same stanza twice.
        - **Data:** :py:class:`~.Message`
        - **Source:** :py:class:`BaseXMPP <.BaseXMPP>`

-        Makes the contents of message stanzas available whenever one is received. Be
-        sure to check the message type in order to handle error messages.
+        Makes the contents of message stanzas that include <body> tags available
+        whenever one is received.
+        Be sure to check the message type to handle error messages appropriately.

    message_error
        - **Data:** :py:class:`~.Message`
--- a/docs/projects.rst
+++ b/docs/projects.rst
@ -1,6 +1,8 @@
 Projects Using Slixmpp
 ======================

+This page enumerates software in the form of applications, bots and gateways utilizing the XMPP protocols with slixmpp.
+
 Applications
 ------------

@ -8,7 +10,8 @@ sendxmpp-py
 ~~~~~~~~~~~
 sendxmpp is a command line program and is the XMPP equivalent of sendmail. It is a Python version of the original sendxmpp which is written in Perl.

- `Source <https://github.com/moparisthebest/sendxmpp-py>`_
+- `Source <https://code.moparisthebest.com/moparisthebest/sendxmpp-py>`__
+- `Groupchat <xmpp:xmpp-ircd@chatrooms.hackerposse.com?join>`__

 Bots
 ----
@ -17,63 +20,65 @@ BotLogMauve
 ~~~~~~~~~~~
 XMPP bot which logs groupchat messages. Logs are in text format, with one file per day and per groupchat.

- `Source <https://git.khaganat.net/khaganat/BotLogMauve>`_
+- `Source <https://git.khaganat.net/khaganat/BotLogMauve>`__
+
+BukuBot
+~~~~~~~
+BukuBot makes it possible to manage and search your bookmarks from your chat.
+
+- `Source <https://codeberg.org/sch/BukuBot>`__

 LinkBot
 ~~~~~~~
 This bot reveals the title of any shared link in a groupchat for quick content insight.

- `Source <https://git.xmpp-it.net/mario/XMPPBot>`_
+- `Source <https://git.xmpp-it.net/mario/XMPPBot>`__

 llama-bot
 ~~~~~~~~~
 Llama-bot enables engaging communication with the LLM (large language model) of llama.cpp, providing seamless and dynamic conversation with it.

- `Groupchat <xmpp:slixmpp@muc.poez.io?join>`_
- `Source <https://github.com/decent-im/llama-bot>`_
- `Demo <xmpp:llama@decent.im?message>`_
+- `Source <https://github.com/decent-im/llama-bot>`__
+- `Demo <xmpp:llama@decent.im?message>`__

 Morbot
 ~~~~~~
 Morbot is a simple Slixmpp bot that will take new articles from listed RSS feeds and send them to assigned XMPP MUCs.

- `Groupchat <xmpp:slixmpp@muc.poez.io?join>`_
- `Source <https://codeberg.org/TheCoffeMaker/Morbot>`_
+- `Source <https://codeberg.org/TheCoffeMaker/Morbot>`__

 Slixfeed
 ~~~~~~~~
 Slixfeed aims to be an easy to use and fully-featured news aggregator bot for XMPP. It provides a convenient access to Blogs, Fediverse and News websites along with filtering functionality.

- `Groupchat <xmpp:slixfeed@chat.woodpeckersnest.space?join>`_
- `Source <https://gitgud.io/sjehuda/slixfeed>`_
+- `Groupchat <xmpp:slixfeed@chat.woodpeckersnest.space?join>`__
+- `Source <https://gitgud.io/sjehuda/slixfeed>`__

 sms4you
 ~~~~~~~
 sms4you forwards messages from and to SMS and connects either with sms4you-xmpp or sms4you-email to choose the other mean of communication. Nice for receiving or sending SMS, independently from carrying a SIM card.

- `Groupchat <xmpp:slixmpp@muc.poez.io?join>`_
- `Homepage <https://sms4you-team.pages.debian.net/sms4you/>`_
- `Source <https://salsa.debian.org/sms4you-team/sms4you>`_
+- `Homepage <https://sms4you-team.pages.debian.net/sms4you/>`__
+- `Source <https://salsa.debian.org/sms4you-team/sms4you>`__

 Stable Diffusion
 ~~~~~~~~~~~~~~~~
 XMPP bot that generates digital images from textual descriptions.

- `Groupchat <xmpp:slidge@conference.nicoco.fr?join>`_
- `Source <https://www.nicoco.fr/blog/2022/08/31/xmpp-bot-stable-diffusion/>`_
+- `Groupchat <xmpp:slidge@conference.nicoco.fr?join>`__
+- `Source <https://www.nicoco.fr/blog/2022/08/31/xmpp-bot-stable-diffusion/>`__

 WhisperBot
 ~~~~~~~~~~
 XMPP bot that transliterates audio messages using OpenAI's Whisper libraries.

- `Groupchat <xmpp:slixmpp@muc.poez.io?join>`_
- `Source <https://codeberg.org/TheCoffeMaker/WhisperBot>`_
+- `Source <https://codeberg.org/TheCoffeMaker/WhisperBot>`__

 XMPP MUC Message Gateway
 ~~~~~~~~~~~~~~~~~~~~~~~~
 A multipurpose JSON forwarder microservice from HTTP POST to XMPP MUC room over TLSv1.2 with SliXMPP.

- `Source <https://github.com/immanuelfodor/xmpp-muc-message-gateway>`_
+- `Source <https://github.com/immanuelfodor/xmpp-muc-message-gateway>`__

 Services
 --------
@ -82,14 +87,14 @@ AtomToPubsub
 ~~~~~~~~~~~~
 AtomToPubsub is a simple Python script that parses Atom + RSS feeds and pushes the entries to a designated XMPP Pubsub Node.

- `Groupchat <xmpp:movim@conference.movim.eu?join>`_
- `Source <https://github.com/imattau/atomtopubsub>`_
+- `Groupchat <xmpp:movim@conference.movim.eu?join>`__
+- `Source <https://github.com/imattau/atomtopubsub>`__

 Slidge
 ~~~~~~

 Slidge is a general purpose XMPP gateway framework in Python.

- `Groupchat <xmpp:slidge@conference.nicoco.fr?join>`_
- `Homepage <https://slidge.im/core/>`_
- `Source <https://sr.ht/~nicoco/slidge>`_
+- `Groupchat <xmpp:slidge@conference.nicoco.fr?join>`__
+- `Homepage <https://slidge.im/core/>`__
+- `Source <https://sr.ht/~nicoco/slidge>`__
--- a/docs/using_asyncio.rst
+++ b/docs/using_asyncio.rst
@ -50,10 +50,39 @@ Running the event loop
 only run for this amount of time, and if ``forever`` is False it will
 run until disconnection).

+This wrapper should be removed in slixmpp 1.9.0.
+
 Therefore you can handle the event loop in any way you like
 instead of using ``process()``.


+Using connect()
+~~~~~~~~~~~~~~~
+
+:meth:`.XMLStream.connect` schedules a lot of things in the background, but that
+only holds true if the event loop is running!
+
+That is why in all examples we usually call connect() right before calling
+a `loop.run_…` function, or the deprecated `process()` function.
+
+Using a different event loop
+~~~~~~~~~~~~~~~~~~~~~~~~~~~~
+
+Immediately upon XMPP object creation (`ClientXMPP` / `ComponentXMPP`) you
+should sets its `loop` attribute to whatever you want, and ideally this
+should work. This path is less tested, so it may break, if that is the case
+please report a bug.
+
+Any access to the `loop` attribute if not user-initialized will set it
+to the default asyncio event loop by default.
+
+.. warning::
+
+    If the loop attribute is modified at runtime, the application will probably
+    end up in an hybrid state and asyncio may complain loudly that things bound
+    to an event loop are being ran in another. Try to avoid that situation.
+
+
 Examples
 ~~~~~~~~

@ -73,10 +102,11 @@ callbacks while everything is not ready.
    callback = lambda _: client.connected_event.set()
    client.add_event_handler('session_start', callback)
    client.connect()
+    loop = asyncio.get_event_loop()
    loop.run_until_complete(event.wait())
    # do some other stuff before running the event loop, e.g.
    # loop.run_until_complete(httpserver.init())
-    client.process()
+    loop.run_forever()


 Use with other asyncio-based libraries
@ -106,7 +136,7 @@ a simple <message>.
    client.add_event_handler('session_start', get_pythonorg)
    client.add_event_handler('session_start', get_asyncioorg)
    client.connect()
-    client.process()
+    client.loop.run_until_complete(client.disconnected)


 Blocking Iq
@ -136,6 +166,6 @@ JID indicating its findings.

    client = ExampleClient('jid@example', 'password')
    client.connect()
-    client.process()
+    client.loop.run_until_complete(client.disconnected)


--- a/examples/imghdr.py
+++ b/examples/imghdr.py
@ -0,0 +1,184 @@
+"""
+Recognize image file formats based on their first few bytes.
+
+
+Taken from cpython 3.11 source code before the removal in 3.13.
+
+Licensed under Zero-Clause BSD
+
+"""
+
+from os import PathLike
+import warnings
+
+__all__ = ["what"]
+
+
+warnings._deprecated(__name__, remove=(3, 13))
+
+
+#-------------------------#
+# Recognize image headers #
+#-------------------------#
+
+def what(file, h=None):
+    f = None
+    try:
+        if h is None:
+            if isinstance(file, (str, PathLike)):
+                f = open(file, 'rb')
+                h = f.read(32)
+            else:
+                location = file.tell()
+                h = file.read(32)
+                file.seek(location)
+        for tf in tests:
+            res = tf(h, f)
+            if res:
+                return res
+    finally:
+        if f: f.close()
+    return None
+
+
+#---------------------------------#
+# Subroutines per image file type #
+#---------------------------------#
+
+tests = []
+
+def test_jpeg(h, f):
+    """JPEG data with JFIF or Exif markers; and raw JPEG"""
+    if h[6:10] in (b'JFIF', b'Exif'):
+        return 'jpeg'
+    elif h[:4] == b'\xff\xd8\xff\xdb':
+        return 'jpeg'
+
+tests.append(test_jpeg)
+
+def test_png(h, f):
+    if h.startswith(b'\211PNG\r\n\032\n'):
+        return 'png'
+
+tests.append(test_png)
+
+def test_gif(h, f):
+    """GIF ('87 and '89 variants)"""
+    if h[:6] in (b'GIF87a', b'GIF89a'):
+        return 'gif'
+
+tests.append(test_gif)
+
+def test_tiff(h, f):
+    """TIFF (can be in Motorola or Intel byte order)"""
+    if h[:2] in (b'MM', b'II'):
+        return 'tiff'
+
+tests.append(test_tiff)
+
+def test_rgb(h, f):
+    """SGI image library"""
+    if h.startswith(b'\001\332'):
+        return 'rgb'
+
+tests.append(test_rgb)
+
+def test_pbm(h, f):
+    """PBM (portable bitmap)"""
+    if len(h) >= 3 and \
+        h[0] == ord(b'P') and h[1] in b'14' and h[2] in b' \t\n\r':
+        return 'pbm'
+
+tests.append(test_pbm)
+
+def test_pgm(h, f):
+    """PGM (portable graymap)"""
+    if len(h) >= 3 and \
+        h[0] == ord(b'P') and h[1] in b'25' and h[2] in b' \t\n\r':
+        return 'pgm'
+
+tests.append(test_pgm)
+
+def test_ppm(h, f):
+    """PPM (portable pixmap)"""
+    if len(h) >= 3 and \
+        h[0] == ord(b'P') and h[1] in b'36' and h[2] in b' \t\n\r':
+        return 'ppm'
+
+tests.append(test_ppm)
+
+def test_rast(h, f):
+    """Sun raster file"""
+    if h.startswith(b'\x59\xA6\x6A\x95'):
+        return 'rast'
+
+tests.append(test_rast)
+
+def test_xbm(h, f):
+    """X bitmap (X10 or X11)"""
+    if h.startswith(b'#define '):
+        return 'xbm'
+
+tests.append(test_xbm)
+
+def test_bmp(h, f):
+    if h.startswith(b'BM'):
+        return 'bmp'
+
+tests.append(test_bmp)
+
+def test_webp(h, f):
+    if h.startswith(b'RIFF') and h[8:12] == b'WEBP':
+        return 'webp'
+
+tests.append(test_webp)
+
+def test_exr(h, f):
+    if h.startswith(b'\x76\x2f\x31\x01'):
+        return 'exr'
+
+tests.append(test_exr)
+
+#--------------------#
+# Small test program #
+#--------------------#
+
+def test():
+    import sys
+    recursive = 0
+    if sys.argv[1:] and sys.argv[1] == '-r':
+        del sys.argv[1:2]
+        recursive = 1
+    try:
+        if sys.argv[1:]:
+            testall(sys.argv[1:], recursive, 1)
+        else:
+            testall(['.'], recursive, 1)
+    except KeyboardInterrupt:
+        sys.stderr.write('\n[Interrupted]\n')
+        sys.exit(1)
+
+def testall(list, recursive, toplevel):
+    import sys
+    import os
+    for filename in list:
+        if os.path.isdir(filename):
+            print(filename + '/:', end=' ')
+            if recursive or toplevel:
+                print('recursing down:')
+                import glob
+                names = glob.glob(os.path.join(glob.escape(filename), '*'))
+                testall(names, recursive, 0)
+            else:
+                print('*** directory (use -r) ***')
+        else:
+            print(filename + ':', end=' ')
+            sys.stdout.flush()
+            try:
+                print(what(filename))
+            except OSError:
+                print('*** not found ***')
+
+if __name__ == '__main__':
+    test()
+
--- a/itests/imghdr.py
+++ b/itests/imghdr.py
@ -0,0 +1,184 @@
+"""
+Recognize image file formats based on their first few bytes.
+
+
+Taken from cpython 3.11 source code before the removal in 3.13.
+
+Licensed under Zero-Clause BSD
+
+"""
+
+from os import PathLike
+import warnings
+
+__all__ = ["what"]
+
+
+warnings._deprecated(__name__, remove=(3, 13))
+
+
+#-------------------------#
+# Recognize image headers #
+#-------------------------#
+
+def what(file, h=None):
+    f = None
+    try:
+        if h is None:
+            if isinstance(file, (str, PathLike)):
+                f = open(file, 'rb')
+                h = f.read(32)
+            else:
+                location = file.tell()
+                h = file.read(32)
+                file.seek(location)
+        for tf in tests:
+            res = tf(h, f)
+            if res:
+                return res
+    finally:
+        if f: f.close()
+    return None
+
+
+#---------------------------------#
+# Subroutines per image file type #
+#---------------------------------#
+
+tests = []
+
+def test_jpeg(h, f):
+    """JPEG data with JFIF or Exif markers; and raw JPEG"""
+    if h[6:10] in (b'JFIF', b'Exif'):
+        return 'jpeg'
+    elif h[:4] == b'\xff\xd8\xff\xdb':
+        return 'jpeg'
+
+tests.append(test_jpeg)
+
+def test_png(h, f):
+    if h.startswith(b'\211PNG\r\n\032\n'):
+        return 'png'
+
+tests.append(test_png)
+
+def test_gif(h, f):
+    """GIF ('87 and '89 variants)"""
+    if h[:6] in (b'GIF87a', b'GIF89a'):
+        return 'gif'
+
+tests.append(test_gif)
+
+def test_tiff(h, f):
+    """TIFF (can be in Motorola or Intel byte order)"""
+    if h[:2] in (b'MM', b'II'):
+        return 'tiff'
+
+tests.append(test_tiff)
+
+def test_rgb(h, f):
+    """SGI image library"""
+    if h.startswith(b'\001\332'):
+        return 'rgb'
+
+tests.append(test_rgb)
+
+def test_pbm(h, f):
+    """PBM (portable bitmap)"""
+    if len(h) >= 3 and \
+        h[0] == ord(b'P') and h[1] in b'14' and h[2] in b' \t\n\r':
+        return 'pbm'
+
+tests.append(test_pbm)
+
+def test_pgm(h, f):
+    """PGM (portable graymap)"""
+    if len(h) >= 3 and \
+        h[0] == ord(b'P') and h[1] in b'25' and h[2] in b' \t\n\r':
+        return 'pgm'
+
+tests.append(test_pgm)
+
+def test_ppm(h, f):
+    """PPM (portable pixmap)"""
+    if len(h) >= 3 and \
+        h[0] == ord(b'P') and h[1] in b'36' and h[2] in b' \t\n\r':
+        return 'ppm'
+
+tests.append(test_ppm)
+
+def test_rast(h, f):
+    """Sun raster file"""
+    if h.startswith(b'\x59\xA6\x6A\x95'):
+        return 'rast'
+
+tests.append(test_rast)
+
+def test_xbm(h, f):
+    """X bitmap (X10 or X11)"""
+    if h.startswith(b'#define '):
+        return 'xbm'
+
+tests.append(test_xbm)
+
+def test_bmp(h, f):
+    if h.startswith(b'BM'):
+        return 'bmp'
+
+tests.append(test_bmp)
+
+def test_webp(h, f):
+    if h.startswith(b'RIFF') and h[8:12] == b'WEBP':
+        return 'webp'
+
+tests.append(test_webp)
+
+def test_exr(h, f):
+    if h.startswith(b'\x76\x2f\x31\x01'):
+        return 'exr'
+
+tests.append(test_exr)
+
+#--------------------#
+# Small test program #
+#--------------------#
+
+def test():
+    import sys
+    recursive = 0
+    if sys.argv[1:] and sys.argv[1] == '-r':
+        del sys.argv[1:2]
+        recursive = 1
+    try:
+        if sys.argv[1:]:
+            testall(sys.argv[1:], recursive, 1)
+        else:
+            testall(['.'], recursive, 1)
+    except KeyboardInterrupt:
+        sys.stderr.write('\n[Interrupted]\n')
+        sys.exit(1)
+
+def testall(list, recursive, toplevel):
+    import sys
+    import os
+    for filename in list:
+        if os.path.isdir(filename):
+            print(filename + '/:', end=' ')
+            if recursive or toplevel:
+                print('recursing down:')
+                import glob
+                names = glob.glob(os.path.join(glob.escape(filename), '*'))
+                testall(names, recursive, 0)
+            else:
+                print('*** directory (use -r) ***')
+        else:
+            print(filename + ':', end=' ')
+            sys.stdout.flush()
+            try:
+                print(what(filename))
+            except OSError:
+                print('*** not found ***')
+
+if __name__ == '__main__':
+    test()
+
--- a/itests/test_retract.py
+++ b/itests/test_retract.py
@ -23,7 +23,6 @@ class TestRetract(SlixIntegration):
            fallback_text='Twas a mistake',
        )
        msg = await self.clients[1].wait_until('message_retract')
-        self.assertEqual(msg['apply_to']['id'], 'toto')
-        self.assertTrue(msg['apply_to']['retract'])
+        self.assertEqual(msg['retract']['id'], 'toto')

 suite = unittest.TestLoader().loadTestsFromTestCase(TestRetract)
--- a/run_integration_tests.py
+++ b/run_integration_tests.py
@ -5,7 +5,7 @@ import logging
 import unittest

 from argparse import ArgumentParser
-from distutils.core import Command
+from setuptools import Command
 from importlib import import_module
 from pathlib import Path

--- a/run_tests.py
+++ b/run_tests.py
@ -5,7 +5,7 @@ import logging
 import unittest

 from argparse import ArgumentParser
-from distutils.core import Command
+from setuptools import Command
 from importlib import import_module
 from pathlib import Path

--- a/setup.py
+++ b/setup.py
@ -33,12 +33,17 @@ CLASSIFIERS = [
    'Programming Language :: Python :: 3.7',
    'Programming Language :: Python :: 3.8',
    'Programming Language :: Python :: 3.9',
+    'Programming Language :: Python :: 3.10',
+    'Programming Language :: Python :: 3.11',
+    'Programming Language :: Python :: 3.12',
+    'Programming Language :: Python :: 3.13',
    'Topic :: Internet :: XMPP',
    'Topic :: Software Development :: Libraries :: Python Modules',
 ]

 packages = [str(mod.parent) for mod in Path('slixmpp').rglob('__init__.py')]

+
 def check_include(library_name, header):
    command = [os.environ.get('PKG_CONFIG', 'pkg-config'), '--cflags', library_name]
    try:
@ -59,6 +64,7 @@ def check_include(library_name, header):
            print('%s headers not found.' % library_name)
            return False

+
 HAS_PYTHON_HEADERS = check_include('python3', 'Python.h')
 HAS_STRINGPREP_HEADERS = check_include('libidn', 'stringprep.h')

@ -87,7 +93,7 @@ setup(
    packages=packages,
    ext_modules=ext_modules,
    install_requires=[
-        'aiodns>=1.0',
+        'aiodns >= 1.0; sys_platform=="linux" or sys_platform=="darwin"',
        'pyasn1',
        'pyasn1_modules',
        'typing_extensions; python_version < "3.8.0"',
--- a/slixmpp/init.py
+++ b/slixmpp/init.py
@ -27,3 +27,9 @@ from slixmpp.clientxmpp import ClientXMPP
 from slixmpp.componentxmpp import ComponentXMPP

 from slixmpp.version import __version__, __version_info__
+
+__all__ = [
+    'Message', 'Presence', 'Iq', 'JID', 'InvalidJID', 'ET', 'ElementBase',
+    'register_stanza_plugin', 'XMLStream', 'BaseXMPP', 'ClientXMPP', 'ComponentXMPP',
+    '__version__', '__version_info__'
+]
--- a/slixmpp/basexmpp.py
+++ b/slixmpp/basexmpp.py
@ -315,13 +315,12 @@ class BaseXMPP(XMLStream):
        pres['lang'] = self.default_lang
        return pres

-    def make_iq(self, id: str = "0", ifrom: OptJidStr = None,
+    def make_iq(self, id: Optional[str] = None, ifrom: OptJidStr = None,
                ito: OptJidStr = None, itype: Optional[IqTypes] = None,
                iquery: Optional[str] = None) -> stanza.Iq:
        """Create a new :class:`~.Iq` stanza with a given Id and from JID.

        :param id: An ideally unique ID value for this stanza thread.
-                   Defaults to 0.
        :param ifrom: The from :class:`~.JID`
                      to use for this stanza.
        :param ito: The destination :class:`~.JID`
@ -332,7 +331,8 @@ class BaseXMPP(XMLStream):
        :param iquery: Optional namespace for adding a query element.
        """
        iq = self.Iq()
-        iq['id'] = str(id)
+        if id is not None:
+            iq['id'] = str(id)
        iq['to'] = ito
        iq['from'] = ifrom
        iq['type'] = itype
--- a/slixmpp/clientxmpp.py
+++ b/slixmpp/clientxmpp.py
@ -139,7 +139,7 @@ class ClientXMPP(BaseXMPP):

    def connect(self, address: Optional[Tuple[str, int]] = None,  # type: ignore
                use_ssl: Optional[bool] = None, force_starttls: Optional[bool] = None,
-                disable_starttls: Optional[bool] = None) -> None:
+                disable_starttls: Optional[bool] = None) -> asyncio.Future:
        """Connect to the XMPP server.

        When no address is given, a SRV lookup for the server will
@ -166,8 +166,9 @@ class ClientXMPP(BaseXMPP):
            host, port = (self.boundjid.host, 5222)
            self.dns_service = 'xmpp-client'

-        XMLStream.connect(self, host, port, use_ssl=use_ssl,
-                          force_starttls=force_starttls, disable_starttls=disable_starttls)
+        return XMLStream.connect(self, host, port, use_ssl=use_ssl,
+                                 force_starttls=force_starttls,
+                                 disable_starttls=disable_starttls)

    def register_feature(self, name: str, handler: Callable, restart: bool = False, order: int = 5000) -> None:
        """Register a stream feature handler.
--- a/slixmpp/componentxmpp.py
+++ b/slixmpp/componentxmpp.py
@ -9,6 +9,7 @@
 import logging
 import hashlib

+from asyncio import Future
 from typing import Optional

 from slixmpp import Message, Iq, Presence
@ -97,7 +98,7 @@ class ComponentXMPP(BaseXMPP):

    def connect(self, host: Optional[str] = None, port: int = 0, use_ssl: Optional[bool] = None,
                force_starttls: Optional[bool] = None,
-                disable_starttls: Optional[bool] = None) -> None:
+                disable_starttls: Optional[bool] = None) -> Future:
        """Connect to the server.


@ -118,7 +119,7 @@ class ComponentXMPP(BaseXMPP):
        self.server_name = self.boundjid.host

        log.debug("Connecting to %s:%s", host, port)
-        XMLStream.connect(self, host=self.server_host, port=self.server_port, use_ssl=use_ssl)
+        return XMLStream.connect(self, host=self.server_host, port=self.server_port, use_ssl=use_ssl)

    def incoming_filter(self, xml):
        """
--- a/slixmpp/exceptions.py
+++ b/slixmpp/exceptions.py
@ -135,6 +135,7 @@ _DEFAULT_ERROR_TYPES: Dict[ErrorConditions, ErrorTypes] = {
    "not-allowed": "cancel",
    "not-authorized": "auth",
    "payment-required": "auth",
+    "policy-violation": "modify",
    "recipient-unavailable": "wait",
    "redirect": "modify",
    "registration-required": "auth",
--- a/slixmpp/plugins/init.py
+++ b/slixmpp/plugins/init.py
@ -112,15 +112,19 @@ PLUGINS = [
    'xep_0421',  # Anonymous unique occupant identifiers for MUCs
    'xep_0422',  # Message Fastening
    'xep_0424',  # Message Retraction
-    'xep_0425',  # Message Moderation
+    'xep_0425',  # Moderated Message Retraction
    'xep_0428',  # Message Fallback
    'xep_0437',  # Room Activity Indicators
    'xep_0439',  # Quick Response
    'xep_0441',  # Message Archive Management Preferences
    'xep_0444',  # Message Reactions
+    'xep_0446',  # File metadata element
    'xep_0447',  # Stateless file sharing
    'xep_0461',  # Message Replies
    'xep_0469',  # Bookmarks Pinning
+    'xep_0482',  # Call Invites
+    'xep_0490',  # Message Displayed Synchronization
+    'xep_0492',  # Chat Notification Settings
    # Meant to be imported by plugins
 ]

--- a/slixmpp/plugins/base.py
+++ b/slixmpp/plugins/base.py
@ -6,14 +6,18 @@
 # Part of Slixmpp: The Slick XMPP Library
 # :copyright: (c) 2012 Nathanael C. Fritz
 # :license: MIT, see LICENSE for more details
+from __future__ import annotations

 import sys
 import copy
 import logging
 import threading

-from typing import Any, Dict, Set, ClassVar
+from typing import Any, Dict, Set, ClassVar, Union, TYPE_CHECKING

+if TYPE_CHECKING:
+    from slixmpp.clientxmpp import ClientXMPP
+    from slixmpp.componentxmpp import ComponentXMPP

 log = logging.getLogger(__name__)

@ -272,7 +276,7 @@ class BasePlugin(object):
    #: `plugin.config['foo']`.
    default_config: ClassVar[Dict[str, Any]] = {}

-    def __init__(self, xmpp, config=None):
+    def __init__(self, xmpp: Union[ClientXMPP,ComponentXMPP], config=None):
        self.xmpp = xmpp
        if self.xmpp:
            self.api = self.xmpp.api.wrap(self.name)
--- a/slixmpp/plugins/xep_0004/stanza/field.py
+++ b/slixmpp/plugins/xep_0004/stanza/field.py
@ -1,8 +1,9 @@
-
 # Slixmpp: The Slick XMPP Library
 # Copyright (C) 2011 Nathanael C. Fritz, Lance J.T. Stout
 # This file is part of Slixmpp.
 # See the file LICENSE for copying permission.
+import logging
+
 from slixmpp.xmlstream import ElementBase, ET


@ -78,7 +79,14 @@ class FormField(ElementBase):
        reqXML = self.xml.find('{%s}required' % self.namespace)
        return reqXML is not None

-    def get_value(self, convert=True):
+    def get_value(self, convert=True, convert_list=False):
+        """
+        Gets the value for this field
+
+        :param convert: Convert truthy values to boolean
+        :param convert_list: Convert text-multi fields to a string with
+            \n as separator for values
+        """
        valsXML = self.xml.findall('{%s}value' % self.namespace)
        if len(valsXML) == 0:
            return None
@ -92,7 +100,7 @@ class FormField(ElementBase):
                if valXML.text is None:
                    valXML.text = ''
                values.append(valXML.text)
-            if self._type == 'text-multi' and convert:
+            if self._type == 'text-multi' and convert_list:
                values = "\n".join(values)
            return values
        else:
@ -127,6 +135,17 @@ class FormField(ElementBase):
        del self['value']
        valXMLName = '{%s}value' % self.namespace

+        if not self._type:
+            if isinstance(value, bool):
+                log.debug("Passed a 'boolean' as value of an untyped field, assuming it is a 'boolean'")
+                self._type = "boolean"
+            elif isinstance(value, str):
+                log.debug("Passed a 'str' as value of an untyped field, assuming it is a 'text-single'")
+                self._type = "text-single"
+            elif isinstance(value, (list, tuple)):
+                log.debug("Passed a %s as value of an untyped field, assuming it is a 'text-multi'")
+                self._type = "text-multi"
+
        if self._type == 'boolean':
            if value in self.true_values:
                valXML = ET.Element(valXMLName)
@ -180,3 +199,6 @@ FormField.setOptions = FormField.set_options
 FormField.setRequired = FormField.set_required
 FormField.setTrue = FormField.set_true
 FormField.setValue = FormField.set_value
+
+
+log = logging.getLogger(__name__)
--- a/slixmpp/plugins/xep_0009/rpc.py
+++ b/slixmpp/plugins/xep_0009/rpc.py
@ -162,7 +162,7 @@ class XEP_0009(BasePlugin):
        if not forwarded and self.xmpp.event_handled('jabber_rpc_method_call') > 1:
            return
        # Reply with error by default
-        error = self.client.plugin['xep_0009']._item_not_found(iq)
+        error = self.xmpp.plugin['xep_0009']._item_not_found(iq)
        error.send()

    def _on_jabber_rpc_method_response(self, iq, forwarded=False):
@ -175,7 +175,7 @@ class XEP_0009(BasePlugin):
        """
        if not forwarded and self.xmpp.event_handled('jabber_rpc_method_response') > 1:
            return
-        error = self.client.plugin['xep_0009']._recpient_unavailable(iq)
+        error = self.xmpp.plugin['xep_0009']._recipient_unvailable(iq)
        error.send()

    def _on_jabber_rpc_method_fault(self, iq, forwarded=False):
@ -188,7 +188,7 @@ class XEP_0009(BasePlugin):
        """
        if not forwarded and self.xmpp.event_handled('jabber_rpc_method_fault') > 1:
            return
-        error = self.client.plugin['xep_0009']._recpient_unavailable(iq)
+        error = self.xmpp.plugin['xep_0009']._recipient_unvailable(iq)
        error.send()

    def _on_jabber_rpc_error(self, iq, forwarded=False):
@ -201,7 +201,7 @@ class XEP_0009(BasePlugin):
        """
        if not forwarded and self.xmpp.event_handled('jabber_rpc_error') > 1:
            return
-        error = self.client.plugin['xep_0009']._recpient_unavailable(iq, iq.get_payload())
+        error = self.xmpp.plugin['xep_0009']._recipient_unvailable(iq)
        error.send()

    def _send_fault(self, iq, fault_xml): #
--- a/slixmpp/plugins/xep_0030/disco.py
+++ b/slixmpp/plugins/xep_0030/disco.py
@ -57,6 +57,9 @@ class XEP_0030(BasePlugin):
    Given   Given   A single node
    ====== ======= ============================

+    Adding information for a given node without specifying the JID will
+    use the bound JID and therefore must be done after the bind happens.
+
    Stream Handlers:

    ::
--- a/slixmpp/plugins/xep_0030/stanza/info.py
+++ b/slixmpp/plugins/xep_0030/stanza/info.py
@ -9,6 +9,7 @@ from typing import (
    Set,
    Tuple,
    Union,
+    Dict,
 )
 from slixmpp.xmlstream import ElementBase, ET

@ -144,6 +145,25 @@ class DiscoInfo(ElementBase):
                    return True
        return False

+    def dict_identities(self, lang: Optional[str] = None) -> Set[Dict[str, str]]:
+        """
+        Return the set of all identities, each one as a dict with
+        category, type, xml_lang, and name keys.
+
+        :param lang: If there is a need to filter identities by lang.
+        """
+        ids = self.get_identities(lang=lang, dedupe=True)
+        dict_ids = set()
+        for identity in ids:
+            dict_ids.add({
+                'category': identity[0],
+                'type': identity[1],
+                'xml_lang': identity[2],
+                'name': identity[3],
+            })
+        return dict_ids
+
+
    def get_identities(self, lang: Optional[str] = None, dedupe: bool = True
                       ) -> Iterable[IdentityType]:
        """
@ -165,11 +185,11 @@ class DiscoInfo(ElementBase):
            identities = []
        for id_xml in self.xml.findall('{%s}identity' % self.namespace):
            xml_lang = id_xml.attrib.get('{%s}lang' % self.xml_ns, None)
+            category = id_xml.attrib.get('category', None)
+            type_ = id_xml.attrib.get('type', None)
+            name = id_xml.attrib.get('name', None)
            if lang is None or xml_lang == lang:
-                id = (id_xml.attrib['category'],
-                      id_xml.attrib['type'],
-                      id_xml.attrib.get('{%s}lang' % self.xml_ns, None),
-                      id_xml.attrib.get('name', None))
+                id = (category, type_, xml_lang, name)
                if isinstance(identities, set):
                    identities.add(id)
                else:
@ -253,10 +273,12 @@ class DiscoInfo(ElementBase):
        else:
            features = []
        for feature_xml in self.xml.findall('{%s}feature' % self.namespace):
-            if isinstance(features, set):
-                features.add(feature_xml.attrib['var'])
-            else:
-                features.append(feature_xml.attrib['var'])
+            feature = feature_xml.attrib.get('var', None)
+            if feature:
+                if isinstance(features, set):
+                    features.add(feature)
+                else:
+                    features.append(feature)
        return features

    def set_features(self, features: Iterable[str]):
--- a/slixmpp/plugins/xep_0045/muc.py
+++ b/slixmpp/plugins/xep_0045/muc.py
@ -49,11 +49,13 @@ from slixmpp.plugins.xep_0045.stanza import (
    MUCUserItem,
 )
 from slixmpp.types import (
+    JidStr,
    MucRole,
    MucAffiliation,
    MucRoomItem,
    MucRoomItemKeys,
    PresenceArgs,
+    PresenceShows,
 )

 JoinResult = Tuple[Presence, Message, List[Presence], List[Message]]
@ -187,7 +189,7 @@ class XEP_0045(BasePlugin):
    def _handle_config_change(self, msg: Message):
        """Handle a MUC configuration change (with status code)."""
        self.xmpp.event('groupchat_config_status', msg)
-        self.xmpp.event('muc::%s::config_status' % msg['from'].bare , msg)
+        self.xmpp.event('muc::%s::config_status' % msg['from'].bare, msg)

    def _client_handle_presence(self, pr: Presence):
        """As a client, handle a presence stanza"""
@ -264,7 +266,7 @@ class XEP_0045(BasePlugin):
                            seconds: Optional[int] = None,
                            since: Optional[datetime] = None,
                            presence_options: Optional[PresenceArgs] = None,
-                            timeout: Optional[int] = None) -> JoinResult:
+                            timeout: int = 300) -> JoinResult:
        """
        Try to join a MUC and block until we are joined or get an error.

@ -310,7 +312,7 @@ class XEP_0045(BasePlugin):
        stanza.send()
        return await self._await_join(room, timeout)

-    async def _await_join(self, room: JID, timeout: Optional[int] = None) -> JoinResult:
+    async def _await_join(self, room: JID, timeout: int = 300) -> JoinResult:
        """Do the heavy lifting for awaiting a MUC join

        A muc join, once the join stanza is sent, is:
@ -358,7 +360,7 @@ class XEP_0045(BasePlugin):
        return (pres, subject, occupant_buffer, history_buffer)

    def join_muc(self, room: JID, nick: str, maxhistory="0", password='',
-                 pstatus='', pshow='', pfrom='') -> asyncio.Future:
+                 pstatus='', pshow: PresenceShows='chat', pfrom: JidStr='') -> asyncio.Future:
        """ Join the specified room, requesting 'maxhistory' lines of history.

        .. deprecated:: 1.8.0
@ -412,7 +414,7 @@ class XEP_0045(BasePlugin):
            )
        del self.rooms[room]

-    def set_subject(self, room: JID, subject: str, *, mfrom: Optional[JID] = None):
+    def set_subject(self, room: JidStr, subject: str, *, mfrom: Optional[JID] = None):
        """Set a room’s subject.

        :param room: JID of the room.
@ -423,7 +425,7 @@ class XEP_0045(BasePlugin):
        msg['subject'] = subject
        msg.send()

-    async def get_room_config(self, room: JID, ifrom: Optional[JID] = None,
+    async def get_room_config(self, room: JidStr, ifrom: Optional[JID] = None,
                              **iqkwargs) -> Form:
        """Get the room config form in 0004 plugin format.

@ -438,7 +440,7 @@ class XEP_0045(BasePlugin):
            raise ValueError("Configuration form not found")
        return form

-    async def set_room_config(self, room: JID, config: Form, *,
+    async def set_room_config(self, room: JidStr, config: Form, *,
                              ifrom: Optional[JID] = None, **iqkwargs):
        """Send a room config form.

@ -451,8 +453,8 @@ class XEP_0045(BasePlugin):
        iq = self.xmpp.make_iq_set(query, ito=room, ifrom=ifrom)
        await iq.send(**iqkwargs)

-    async def cancel_config(self, room: JID, *,
-                            ifrom: Optional[JID] = None, **iqkwargs):
+    async def cancel_config(self, room: JidStr, *,
+                            ifrom: Optional[JidStr] = None, **iqkwargs):
        """Cancel a requested config form.

        :param room: Room to cancel the form for.
@ -462,8 +464,8 @@ class XEP_0045(BasePlugin):
        iq = self.xmpp.make_iq_set(query, ito=room, ifrom=ifrom)
        await iq.send(**iqkwargs)

-    async def destroy(self, room: JID, reason: str = '', altroom: Optional[JID] = None, *,
-                      ifrom: Optional[JID] = None, **iqkwargs):
+    async def destroy(self, room: JidStr, reason: str = '', altroom: Optional[JidStr] = None, *,
+                      ifrom: Optional[JidStr] = None, **iqkwargs):
        """Destroy a room.

        :param room: Room JID to destroy.
@ -479,10 +481,10 @@ class XEP_0045(BasePlugin):
            iq['mucowner_query']['destroy']['reason'] = reason
        await iq.send(**iqkwargs)

-    async def set_affiliation(self, room: JID, affiliation: MucAffiliation, *,
-                              jid: Optional[JID] = None,
+    async def set_affiliation(self, room: JidStr, affiliation: MucAffiliation, *,
+                              jid: Optional[JidStr] = None,
                              nick: Optional[str] = None, reason: str = '',
-                              ifrom: Optional[JID] = None, **iqkwargs):
+                              ifrom: Optional[JidStr] = None, **iqkwargs):
        """ Change room affiliation for a JID or nickname.

        :param room: Room to modify.
@ -493,7 +495,7 @@ class XEP_0045(BasePlugin):
        if affiliation not in AFFILIATIONS:
            raise ValueError('%s is not a valid affiliation' % affiliation)
        if affiliation == 'outcast' and not jid:
-            raise ValueError('Outcast affiliation requires a using a jid')
+            raise ValueError('Outcast affiliation requires using a jid')
        if not any((jid, nick)):
            raise ValueError('One of jid or nick must be set')
        iq = self.xmpp.make_iq_set(ito=room, ifrom=ifrom)
@ -506,8 +508,8 @@ class XEP_0045(BasePlugin):
            iq['mucadmin_query']['item']['reason'] = reason
        await iq.send(**iqkwargs)

-    async def get_affiliation_list(self, room: JID, affiliation: MucAffiliation, *,
-                                   ifrom: Optional[JID] = None, **iqkwargs) -> List[JID]:
+    async def get_affiliation_list(self, room: JidStr, affiliation: MucAffiliation, *,
+                                   ifrom: Optional[JidStr] = None, **iqkwargs) -> List[JID]:
        """Get a list of JIDs with the specified affiliation

        :param room: Room to get affiliations from.
@ -518,9 +520,9 @@ class XEP_0045(BasePlugin):
        result = await iq.send(**iqkwargs)
        return [item['jid'] for item in result['mucadmin_query']]

-    async def send_affiliation_list(self, room: JID,
-                                    affiliations: List[Tuple[JID, MucAffiliation]], *,
-                                    ifrom: Optional[JID] = None, **iqkwargs):
+    async def send_affiliation_list(self, room: JidStr,
+                                    affiliations: List[Tuple[JidStr, MucAffiliation]], *,
+                                    ifrom: Optional[JidStr] = None, **iqkwargs):
        """Send an affiliation delta list.

        :param room: Room to send the affiliations to.
@ -534,8 +536,8 @@ class XEP_0045(BasePlugin):
            iq['mucadmin_query'].append(item)
        await iq.send(**iqkwargs)

-    async def set_role(self, room: JID, nick: str, role: MucRole, *,
-                       reason: str = '', ifrom: Optional[JID] = None, **iqkwargs):
+    async def set_role(self, room: JidStr, nick: str, role: MucRole, *,
+                       reason: str = '', ifrom: Optional[JidStr] = None, **iqkwargs):
        """ Change role property of a nick in a room.
            Typically, roles are temporary (they last only as long as you are in the
            room), whereas affiliations are permanent (they last across groupchat
@ -555,8 +557,8 @@ class XEP_0045(BasePlugin):
            iq['mucadmin_query']['item']['reason'] = reason
        await iq.send(**iqkwargs)

-    async def get_roles_list(self, room: JID, role: MucRole, *,
-                             ifrom: Optional[JID] = None, **iqkwargs) -> List[str]:
+    async def get_roles_list(self, room: JidStr, role: MucRole, *,
+                             ifrom: Optional[JidStr] = None, **iqkwargs) -> List[str]:
        """"Get a list of JIDs with the specified role

        :param room: Room to get roles from.
@ -567,8 +569,8 @@ class XEP_0045(BasePlugin):
        result = await iq.send(**iqkwargs)
        return [item['nick'] for item in result['mucadmin_query']]

-    async def send_role_list(self, room: JID, roles: List[Tuple[str, MucRole]], *,
-                             ifrom: Optional[JID] = None, **iqkwargs):
+    async def send_role_list(self, room: JidStr, roles: List[Tuple[str, MucRole]], *,
+                             ifrom: Optional[JidStr] = None, **iqkwargs):
        """Send a role delta list.

        :param room: Room to send the roles to.
@ -582,8 +584,8 @@ class XEP_0045(BasePlugin):
            iq['mucadmin_query'].append(item)
        await iq.send(**iqkwargs)

-    def invite(self, room: JID, jid: JID, reason: str = '', *,
-               mfrom: Optional[JID] = None):
+    def invite(self, room: JidStr, jid: JidStr, reason: str = '', *,
+               mfrom: Optional[JidStr] = None):
        """ Invite a jid to a room (mediated invitation).

        :param room: Room to invite the user in.
@ -596,8 +598,8 @@ class XEP_0045(BasePlugin):
            msg['muc']['invite']['reason'] = reason
        self.xmpp.send(msg)

-    def invite_server(self, room: JID, jid: JID,
-                         invite_from: JID, reason: str = ''):
+    def invite_server(self, room: JidStr, jid: JidStr,
+                         invite_from: JidStr, reason: str = ''):
        """Send a mediated invite to a user, as a MUC service.

        .. versionadded:: 1.8.0
@ -615,8 +617,8 @@ class XEP_0045(BasePlugin):
            msg['muc']['invite']['reason'] = reason
        msg.send()

-    def decline(self, room: JID, jid: JID, reason: str = '', *,
-                mfrom: Optional[JID] = None):
+    def decline(self, room: JidStr, jid: JidStr, reason: str = '', *,
+                mfrom: Optional[JidStr] = None):
        """Decline a mediated invitation.

        :param room: Room the invitation came from.
@ -629,7 +631,7 @@ class XEP_0045(BasePlugin):
            msg['muc']['decline']['reason'] = reason
        self.xmpp.send(msg)

-    def request_voice(self, room: JID, role: str, *, mfrom: Optional[JID] = None):
+    def request_voice(self, room: JidStr, role: str, *, mfrom: Optional[JidStr] = None):
        """Request voice in a moderated room.

        :param room: Room to request voice from.
@ -646,29 +648,49 @@ class XEP_0045(BasePlugin):
        """Check if a JID is present in a room.

        :param room: Room to check.
-        :param jid: JID to check.
+        :param jid: FULL JID to check.
        """
+        bare_match = False
        for nick in self.rooms[room]:
            entry = self.rooms[room][nick]
            if not entry.get('jid'):
                continue
-            if entry is not None and entry['jid'].full == jid:
+
+            if entry['jid'] == jid.full:
                return True
-        return False
+            elif JID(entry['jid']).bare == jid.bare:
+                bare_match = True
+        
+        if bare_match:
+            logging.info(
+                "Could not retrieve full JID, falling back to bare JID for %s in %s",
+                jid, room
+            )
+        return bare_match

    def get_nick(self, room: JID, jid: JID) -> Optional[str]:
        """Get the nickname of a specific JID in a room.

        :param room: Room to inspect.
-        :param jid: JID whose nick to return.
+        :param jid: FULL JID whose nick to return.
        """
+        bare_match = None
        for nick in self.rooms[room]:
            entry = self.rooms[room][nick]
            if not entry.get('jid'):
                continue
-            if entry is not None and entry['jid'].full == jid:
+
+            if entry['jid'] == jid.full:
                return nick
-        return None
+            elif JID(entry['jid']).bare == jid.bare:
+                bare_match = nick
+        
+        if bare_match:
+            logging.info(
+                "Could not retrieve full JID, falling back to bare JID for %s in %s",
+                jid, room
+            )
+        return bare_match

    def get_joined_rooms(self) -> List[JID]:
        """Get the list of rooms we sent a join presence to
@ -704,7 +726,7 @@ class XEP_0045(BasePlugin):
            raise ValueError("Room %s is not joined" % room)
        return list(self.rooms[room].keys())

-    def get_users_by_affiliation(self, room: JID, affiliation='member', *, ifrom: Optional[JID] = None):
+    def get_users_by_affiliation(self, room: JidStr, affiliation='member', *, ifrom: Optional[JidStr] = None):
        # Preserve old API
        if affiliation not in AFFILIATIONS:
            raise ValueError("Affiliation %s does not exist" % affiliation)
--- a/slixmpp/plugins/xep_0045/stanza.py
+++ b/slixmpp/plugins/xep_0045/stanza.py
@ -28,7 +28,7 @@ class MUCBase(ElementBase):
    plugin_attrib = 'muc'
    interfaces = {'affiliation', 'role', 'jid', 'nick', 'room', 'status_codes'}

-    def get_status_codes(self) -> Set[str]:
+    def get_status_codes(self) -> Set[int]:
        status = self.xml.findall(f'{{{NS_USER}}}status')
        return {int(status.attrib['code']) for status in status}

@ -275,7 +275,8 @@ class MUCUserItem(ElementBase):
        jid = self.xml.attrib.get('jid', None)
        if jid:
            return JID(jid)
-        return jid
+        else:
+            return None


 class MUCActor(ElementBase):
@ -288,7 +289,8 @@ class MUCActor(ElementBase):
        jid = self.xml.attrib.get('jid', None)
        if jid:
            return JID(jid)
-        return jid
+        else:
+            return None


 class MUCDestroy(ElementBase):
--- a/slixmpp/plugins/xep_0050/adhoc.py
+++ b/slixmpp/plugins/xep_0050/adhoc.py
@ -326,7 +326,10 @@ class XEP_0050(BasePlugin):
            iq['command']['actions'] = actions
            iq['command']['status'] = 'executing'
        else:
-            iq['command']['actions'] = ['complete']
+            actions = ['complete']
+            if session['allow_prev']:
+                actions.append('prev')
+            iq['command']['actions'] = actions
            iq['command']['status'] = 'executing'

        iq['command']['notes'] = session['notes']
--- a/slixmpp/plugins/xep_0060/pubsub.py
+++ b/slixmpp/plugins/xep_0060/pubsub.py
@ -464,10 +464,10 @@ class XEP_0060(BasePlugin):
        """
        Retrieve the ItemIDs hosted by a given node, using disco.
        """
-        self.xmpp['xep_0030'].get_items(jid, node, ifrom=ifrom,
-                                        callback=callback, timeout=timeout,
-                                        iterator=iterator,
-                                        timeout_callback=timeout_callback)
+        return self.xmpp['xep_0030'].get_items(jid, node, ifrom=ifrom,
+                                               callback=callback, timeout=timeout,
+                                               iterator=iterator,
+                                               timeout_callback=timeout_callback)

    def modify_affiliations(self, jid, node, affiliations=None, ifrom=None,
                            timeout_callback=None, callback=None,
--- a/slixmpp/plugins/xep_0199/ping.py
+++ b/slixmpp/plugins/xep_0199/ping.py
@ -137,7 +137,14 @@ class XEP_0199(BasePlugin):
    async def _keepalive(self, event=None):
        log.debug("Keepalive ping...")
        try:
-            rtt = await self.ping(self.xmpp.boundjid.host, timeout=self.timeout)
+            ifrom = None
+            if self.xmpp.is_component:
+                ifrom = self.xmpp.boundjid
+            rtt = await self.ping(
+                self.xmpp.boundjid.host,
+                timeout=self.timeout,
+                ifrom=ifrom
+            )
        except IqTimeout:
            log.debug("Did not receive ping back in time. " + \
                      "Requesting Reconnect.")
--- a/slixmpp/plugins/xep_0223.py
+++ b/slixmpp/plugins/xep_0223.py
@ -20,6 +20,18 @@ class XEP_0223(BasePlugin):

    """
    XEP-0223: Persistent Storage of Private Data via PubSub
+
+    If a specific pubsub node requires additional publish options, edit the
+    :attr:`.node_profile` attribute of this plugin:
+
+    .. code-block:: python
+
+        self.xmpp.plugin["xep_0223"].node_profiles["urn:some:node"] = {
+            "pubsub#max_items" = "max"
+        }
+
+    This makes :meth:`.store` add these publish options whenever it is called
+    for the ``urn:some:node`` node.
    """

    name = 'xep_0223'
@ -28,6 +40,7 @@ class XEP_0223(BasePlugin):

    profile = {'pubsub#persist_items': True,
               'pubsub#access_model': 'whitelist'}
+    node_profiles = dict[str, dict[str, str]]()

    def configure(self, node: str, **iqkwargs) -> Future:
        """
@ -35,8 +48,12 @@ class XEP_0223(BasePlugin):

        :param node: Node to set the configuration at.
        """
-        config = self.xmpp['xep_0004'].Form()
+        config = self.xmpp['xep_0004'].stanza.Form()
        config['type'] = 'submit'
+        config.add_field(
+            var='FORM_TYPE',
+            ftype='hidden',
+            value='http://jabber.org/protocol/pubsub#node_config')

        for field, value in self.profile.items():
            config.add_field(var=field, value=value)
@ -70,7 +87,8 @@ class XEP_0223(BasePlugin):
                value='http://jabber.org/protocol/pubsub#publish-options')

        fields = options['fields']
-        for field, value in self.profile.items():
+        profile = self.profile | self.node_profiles.get(node, {})
+        for field, value in profile.items():
            if field not in fields:
                options.add_field(var=field)
            options.get_fields()[field]['value'] = value
--- a/slixmpp/plugins/xep_0231/bob.py
+++ b/slixmpp/plugins/xep_0231/bob.py
@ -10,6 +10,7 @@ from asyncio import Future
 from typing import Optional

 from slixmpp import JID
+from slixmpp.exceptions import XMPPError
 from slixmpp.stanza import Iq, Message, Presence
 from slixmpp.xmlstream.handler import CoroutineCallback
 from slixmpp.xmlstream.matcher import StanzaPath
@ -139,6 +140,13 @@ class XEP_0231(BasePlugin):
            self.xmpp.event('bob', iq)
        elif iq['type'] == 'get':
            data = await self.api['get_bob'](iq['to'], None, iq['from'], args=cid)
+
+            if data is None:
+                raise XMPPError(
+                    "item-not-found",
+                    f"Bits of binary '{cid}' is not available",
+                )
+
            if isinstance(data, Iq):
                data['id'] = iq['id']
                data.send()
--- a/slixmpp/plugins/xep_0292/init.py
+++ b/slixmpp/plugins/xep_0292/init.py
@ -1,5 +1,6 @@
 from slixmpp.plugins.base import register_plugin

 from . import stanza, vcard4
+from .vcard4 import XEP_0292

 register_plugin(vcard4.XEP_0292)
--- a/slixmpp/plugins/xep_0308/correction.py
+++ b/slixmpp/plugins/xep_0308/correction.py
@ -1,12 +1,12 @@
-
 # Slixmpp: The Slick XMPP Library
 # Copyright (C) 2012 Nathanael C. Fritz, Lance J.T. Stout
 # This file is part of Slixmpp.
 # See the file LICENSE for copying permissio
 import logging
+from typing import Optional

-import slixmpp
 from slixmpp.stanza import Message
+from slixmpp.jid import JID
 from slixmpp.xmlstream.handler import Callback
 from slixmpp.xmlstream.matcher import StanzaPath
 from slixmpp.xmlstream import register_stanza_plugin
@ -45,5 +45,59 @@ class XEP_0308(BasePlugin):
    def session_bind(self, jid):
        self.xmpp.plugin['xep_0030'].add_feature(Replace.namespace)

-    def _handle_correction(self, msg):
+    def is_correction(self, msg: Message):
+        return msg.xml.find('{%s}replace' % Replace.namespace) is not None
+
+    def _handle_correction(self, msg: Message):
        self.xmpp.event('message_correction', msg)
+
+    def build_correction(self, id_to_replace: str, mto: JID,
+                         mfrom: Optional[JID] = None, mtype: str = 'chat',
+                         mbody: str = '') -> Message:
+        """
+        Build a corrected message.
+
+        :param id_to_replace: The id of the original message.
+        :param mto: Recipient of the message, must be the same as the original
+                    message.
+        :param mfrom: Sender of the message, must be the same as the original
+                      message.
+        :param mtype: Type of the message, must be the send as the original
+                      message.
+        :param mbody: The corrected message body.
+        """
+        msg = self.xmpp.make_message(
+            mto=mto,
+            mfrom=mfrom,
+            mbody=mbody,
+            mtype=mtype
+        )
+        msg['replace']['id'] = id_to_replace
+        return msg
+
+    def correct_message(self, msg: Message, body: str) -> Message:
+        """
+        Send a correction to an existing message.
+
+        :param msg: The message that must be replaced.
+        :param body: The body to set in the correcting message.
+        :returns: The message that was sent.
+        """
+        to_replace = msg['id']
+        mto = msg['to']
+        mfrom = msg['from']
+        mtype = msg['type']
+        if not to_replace:
+            raise ValueError('No available ID for replacing the message')
+        if not mto:
+            raise ValueError('No available recipient JID')
+
+        new = self.build_correction(
+            id_to_replace=to_replace,
+            mto=mto,
+            mfrom=mfrom,
+            mtype=mtype,
+            mbody=body,
+        )
+        new.send()
+        return new
--- a/slixmpp/plugins/xep_0356/privilege.py
+++ b/slixmpp/plugins/xep_0356/privilege.py
@ -138,10 +138,10 @@ class XEP_0356(BasePlugin):

        Raises ValueError if the server did not advertise the corresponding privileges

-        :param jid: user we want to add or modify roster items
-        :param roster_items: a dict containing the roster items' JIDs as keys and
-            nested dicts containing names, subscriptions and groups.
-            Example:
+        Here is an example of a roster_items value:
+
+        .. code-block:: json
+
            {
                "friend1@example.com": {
                    "name": "Friend 1",
@ -152,8 +152,13 @@ class XEP_0356(BasePlugin):
                    "name": "Friend 2",
                    "subscription": "from",
                    "groups": ["group3"],
-            },
-        }
+                },
+            }
+
+        :param jid: user we want to add or modify roster items
+        :param roster_items: a dict containing the roster items' JIDs as keys and
+                             nested dicts containing names, subscriptions and groups.
+
        """
        if isinstance(jid, str):
            jid = JID(jid)
--- a/slixmpp/plugins/xep_0424/init.py
+++ b/slixmpp/plugins/xep_0424/init.py
@ -4,7 +4,6 @@
 # This file is part of Slixmpp.
 # See the file LICENSE for copying permission.
 from slixmpp.plugins.base import register_plugin
-from slixmpp.plugins.xep_0424.stanza import *
-from slixmpp.plugins.xep_0424.retraction import XEP_0424
+from .retraction import XEP_0424

 register_plugin(XEP_0424)
--- a/slixmpp/plugins/xep_0424/retraction.py
+++ b/slixmpp/plugins/xep_0424/retraction.py
@ -31,7 +31,7 @@ class XEP_0424(BasePlugin):
        stanza.register_plugins()
        self.xmpp.register_handler(Callback(
            "Message Retracted",
-            StanzaPath("message/apply_to/retract"),
+            StanzaPath("message/retract"),
            self._handle_retract_message,
        ))

@ -64,7 +64,6 @@ class XEP_0424(BasePlugin):
        if include_fallback:
            msg['body'] = fallback_text
            msg.enable('fallback')
-        msg['apply_to']['id'] = id
-        msg['apply_to'].enable('retract')
+        msg['retract']['id'] = id
        msg.enable('store')
        msg.send()
--- a/slixmpp/plugins/xep_0424/stanza.py
+++ b/slixmpp/plugins/xep_0424/stanza.py
@ -8,28 +8,27 @@ from slixmpp.xmlstream import (
    ElementBase,
    register_stanza_plugin,
 )
-from slixmpp.plugins.xep_0422.stanza import ApplyTo
-from slixmpp.plugins.xep_0359 import OriginID


-NS = 'urn:xmpp:message-retract:0'
+NS = 'urn:xmpp:message-retract:1'


 class Retract(ElementBase):
    namespace = NS
    name = 'retract'
    plugin_attrib = 'retract'
+    interfaces = {'reason', 'id'}
+    sub_interfaces = {'reason'}


 class Retracted(ElementBase):
    namespace = NS
    name = 'retracted'
    plugin_attrib = 'retracted'
-    interfaces = {'stamp'}
+    interfaces = {'stamp', 'id', 'reason'}
+    sub_interfaces = {'reason'}


 def register_plugins():
-    register_stanza_plugin(ApplyTo, Retract)
+    register_stanza_plugin(Message, Retract)
    register_stanza_plugin(Message, Retracted)
-
-    register_stanza_plugin(Retracted, OriginID)
--- a/slixmpp/plugins/xep_0425/moderation.py
+++ b/slixmpp/plugins/xep_0425/moderation.py
@ -13,10 +13,10 @@ from slixmpp.plugins.xep_0425 import stanza


 class XEP_0425(BasePlugin):
-    '''XEP-0425: Message Moderation'''
+    '''XEP-0425: Moderated Message Retraction'''

    name = 'xep_0425'
-    description = 'XEP-0425: Message Moderation'
+    description = 'XEP-0425: Moderated Message Retraction'
    dependencies = {'xep_0424', 'xep_0421'}
    stanza = stanza
    namespace = stanza.NS
@ -25,7 +25,7 @@ class XEP_0425(BasePlugin):
        stanza.register_plugins()
        self.xmpp.register_handler(Callback(
            'Moderated Message',
-            StanzaPath('message/apply_to/moderated/retract'),
+            StanzaPath('message/retract/moderated'),
            self._handle_moderated,
        ))

@ -42,7 +42,7 @@ class XEP_0425(BasePlugin):
    async def moderate(self, room: JID, id: str, reason: str = '', *,
                       ifrom: Optional[JID] = None, **iqkwargs):
        iq = self.xmpp.make_iq_set(ito=room.bare, ifrom=ifrom)
-        iq['apply_to']['id'] = id
-        iq['apply_to']['moderate']['reason'] = reason
-        iq['apply_to']['moderate'].enable('retract')
+        iq['moderate']['id'] = id
+        iq['moderate']['reason'] = reason
+        iq['moderate'].enable('retract')
        await iq.send(**iqkwargs)
--- a/slixmpp/plugins/xep_0425/stanza.py
+++ b/slixmpp/plugins/xep_0425/stanza.py
@ -8,19 +8,18 @@ from slixmpp.xmlstream import (
    ElementBase,
    register_stanza_plugin,
 )
-from slixmpp.plugins.xep_0422.stanza import ApplyTo
 from slixmpp.plugins.xep_0421.stanza import OccupantId
 from slixmpp.plugins.xep_0424.stanza import Retract, Retracted


-NS = 'urn:xmpp:message-moderate:0'
+NS = 'urn:xmpp:message-moderate:1'


 class Moderate(ElementBase):
    namespace = NS
    name = 'moderate'
    plugin_attrib = 'moderate'
-    interfaces = {'reason'}
+    interfaces = {'id', 'reason'}
    sub_interfaces = {'reason'}


@ -28,17 +27,17 @@ class Moderated(ElementBase):
    namespace = NS
    name = 'moderated'
    plugin_attrib = 'moderated'
-    interfaces = {'reason', 'by'}
-    sub_interfaces = {'reason'}
+    interfaces = {'by'}


 def register_plugins():
-    register_stanza_plugin(Iq, ApplyTo)
-    register_stanza_plugin(ApplyTo, Moderate)
+    # for moderation requests
+    register_stanza_plugin(Iq, Moderate)
    register_stanza_plugin(Moderate, Retract)

-    register_stanza_plugin(Message, Moderated)
-    register_stanza_plugin(ApplyTo, Moderated)
-    register_stanza_plugin(Moderated, Retract)
-    register_stanza_plugin(Moderated, Retracted)
+    # for moderation events
+    register_stanza_plugin(Retract, Moderated)
    register_stanza_plugin(Moderated, OccupantId)
+
+    # for tombstones
+    register_stanza_plugin(Retracted, Moderated)
--- a/slixmpp/plugins/xep_0446/file_metadata.py
+++ b/slixmpp/plugins/xep_0446/file_metadata.py
@ -18,3 +18,7 @@ class XEP_0446(BasePlugin):
    name = "xep_0446"
    description = "XEP-0446: File metadata element"
    stanza = stanza
+    dependencies = {'xep_0300', 'xep_0264'}
+
+    def plugin_init(self):
+        stanza.register_plugins()
--- a/slixmpp/plugins/xep_0446/stanza.py
+++ b/slixmpp/plugins/xep_0446/stanza.py
@ -1,7 +1,10 @@
 from datetime import datetime
+from typing import Optional

 from slixmpp.plugins.xep_0082 import format_datetime, parse
-from slixmpp.xmlstream import ElementBase
+from slixmpp.plugins.xep_0300 import Hash
+from slixmpp.plugins.xep_0264.stanza import Thumbnail
+from slixmpp.xmlstream import ElementBase, register_stanza_plugin

 NS = "urn:xmpp:file:metadata:0"

@ -10,15 +13,42 @@ class File(ElementBase):
    name = "file"
    namespace = NS
    plugin_attrib = "file"
-    interfaces = sub_interfaces = {"media-type", "name", "date", "size", "hash", "desc"}
+    interfaces = sub_interfaces = {
+        "media-type",
+        "name",
+        "date",
+        "size",
+        "desc",
+        "width",
+        "height",
+        "length"
+    }
+
+    def set_width(self, width: int):
+        self.__set_if_positive("width", width)
+
+    def get_width(self) -> Optional[int]:
+        return _positive_int_or_none(self._get_sub_text("width"))
+
+    def set_height(self, height: int):
+        self.__set_if_positive("height", height)
+
+    def get_height(self) -> Optional[int]:
+        return _positive_int_or_none(self._get_sub_text("height"))
+
+    def set_length(self, length: int):
+        self.__set_if_positive("length", length)
+
+    def get_length(self) -> Optional[int]:
+        return _positive_int_or_none(self._get_sub_text("length"))

    def set_size(self, size: int):
-        self._set_sub_text("size", str(size))
+        self.__set_if_positive("size", size)

-    def get_size(self):
-        return _int_or_none(self._get_sub_text("size"))
+    def get_size(self) -> Optional[int]:
+        return _positive_int_or_none(self._get_sub_text("size"))

-    def get_date(self):
+    def get_date(self) -> Optional[datetime]:
        try:
            return parse(self._get_sub_text("date"))
        except ValueError:
@ -30,9 +60,18 @@ class File(ElementBase):
        except ValueError:
            pass

+    def __set_if_positive(self, key: str, value: int):
+        if value <= 0:
+            raise ValueError(f"Invalid value for element {key}: {value}")
+        self._set_sub_text(key, str(value))

-def _int_or_none(v):
+
+def _positive_int_or_none(v: str) -> Optional[int]:
    try:
        return int(v)
    except ValueError:
        return None
+
+def register_plugins():
+    register_stanza_plugin(File, Hash)
+    register_stanza_plugin(File, Thumbnail)
--- a/slixmpp/plugins/xep_0461/reply.py
+++ b/slixmpp/plugins/xep_0461/reply.py
@ -1,3 +1,5 @@
+from typing import Optional
+
 from slixmpp.plugins import BasePlugin
 from slixmpp.types import JidStr
 from slixmpp.xmlstream import StanzaBase
@ -36,13 +38,35 @@ class XEP_0461(BasePlugin):
    def _handle_reply_to_message(self, msg: StanzaBase):
        self.xmpp.event("message_reply", msg)

-    def send_reply(self, reply_to: JidStr, reply_id: str, **msg_kwargs):
+    def make_reply(self, reply_to: JidStr, reply_id: str,
+                   fallback: Optional[str] = None,
+                   quoted_nick: Optional[str] = None, **msg_kwargs):
+        """Create a replies message stanza
+
+        :param reply_to: Full JID of the quoted author
+        :param reply_id: ID of the message to reply to
+        :param fallback: Body of the quoted message
+        :param quoted_nick: nickname of the quoted participant
+        :param msg_kwargs: Parameters are consistent with the make_message method,
+            required parameters are ``mto`` and ``mbody``
+        """
+
+        msg = self.xmpp.make_message(**msg_kwargs)
+        msg["reply"]["to"] = reply_to
+        msg["reply"]["id"] = reply_id
+        if fallback:
+            msg["reply"].add_quoted_fallback(fallback, quoted_nick)
+        return msg
+
+    def send_reply(self, reply_to: JidStr, reply_id: str,
+                   fallback: Optional[str] = None,
+                   quoted_nick: Optional[str] = None, **msg_kwargs):
        """

        :param reply_to: Full JID of the quoted author
        :param reply_id: ID of the message to reply to
+        :param fallback: Body of the quoted message
+        :param quoted_nick: nickname of the quoted participant
        """
-        msg = self.xmpp.make_message(**msg_kwargs)
-        msg["reply"]["to"] = reply_to
-        msg["reply"]["id"] = reply_id
+        msg = self.make_reply(reply_to, reply_id, fallback, quoted_nick, **msg_kwargs)
        msg.send()
--- a/slixmpp/plugins/xep_0461/stanza.py
+++ b/slixmpp/plugins/xep_0461/stanza.py
@ -14,11 +14,12 @@ class Reply(ElementBase):
    interfaces = {"id", "to"}

    def add_quoted_fallback(self, fallback: str, nickname: Optional[str] = None):
-        """
+        r"""
        Add plain text fallback for clients not implementing XEP-0461.

+
        ``msg["reply"].add_quoted_fallback("Some text", "Bob")`` will
-        prepend "> Bob:\n> Some text\n" to the body of the message, and set the
+        prepend ``> Bob:\n> Some text\n`` to the body of the message, and set the
        fallback_body attributes accordingly, so that clients implementing
        XEP-0461 can hide the fallback text.

@ -30,11 +31,11 @@ class Reply(ElementBase):
        if nickname:
            quoted = "> " + nickname + ":\n" + quoted
        msg["body"] = quoted + msg["body"]
-        fallback = Fallback()
-        fallback["for"] = NS
-        fallback["body"]["start"] = 0
-        fallback["body"]["end"] = len(quoted)
-        msg.append(fallback)
+        fallback_elem = Fallback()
+        fallback_elem["for"] = NS
+        fallback_elem["body"]["start"] = 0
+        fallback_elem["body"]["end"] = len(quoted)
+        msg.append(fallback_elem)

    def get_fallback_body(self) -> str:
        msg = self.parent()
@ -51,6 +52,23 @@ class Reply(ElementBase):
        else:
            return ""
        
+    def strip_fallback_content(self) -> str:
+        msg = self.parent() 
+        for fallback in msg["fallbacks"]:
+            if fallback["for"] == NS:
+                break
+        else:
+            return msg["body"]
+
+        start = fallback["body"]["start"]
+        end = fallback["body"]["end"]
+        body = msg["body"]
+
+        if 0 <= start < end <= len(body):
+            return body[:start] + body[end:]
+        else:
+            return body
+

 def register_plugins():
    register_stanza_plugin(Message, Reply)
--- a/slixmpp/plugins/xep_0482/init.py
+++ b/slixmpp/plugins/xep_0482/init.py
@ -0,0 +1,11 @@
+# Slixmpp: The Slick XMPP Library
+# Copyright (C) 2025 Mathieu Pasquet
+# This file is part of Slixmpp.
+# See the file LICENSE for copying permissio
+from slixmpp.plugins.base import register_plugin
+
+from slixmpp.plugins.xep_0482 import stanza
+from slixmpp.plugins.xep_0482.call_invites import XEP_0482
+
+
+register_plugin(XEP_0482)
--- a/slixmpp/plugins/xep_0482/call_invites.py
+++ b/slixmpp/plugins/xep_0482/call_invites.py
@ -0,0 +1,55 @@
+# Slixmpp: The Slick XMPP Library
+# Copyright (C) 2025 Mathieu Pasquet
+# This file is part of Slixmpp.
+# See the file LICENSE for copying permissio
+import logging
+from typing import Optional
+
+from slixmpp.stanza import Message
+from slixmpp.jid import JID
+from slixmpp.xmlstream.handler import Callback
+from slixmpp.xmlstream.matcher import StanzaPath
+from slixmpp.xmlstream import register_stanza_plugin
+from slixmpp.plugins import BasePlugin
+from slixmpp.plugins.xep_0482 import stanza
+
+
+log = logging.getLogger(__name__)
+
+
+class XEP_0482(BasePlugin):
+
+    """
+    XEP-0482: Call Invites
+
+    This plugin defines the stanza elements for Call Invites, as well as new
+    events:
+
+    - `call-invite`
+    - `call-reject`
+    - `call-retract`
+    - `call-leave`
+    - `call-left`
+    """
+
+    name = 'xep_0482'
+    description = 'XEP-0482: Call Invites'
+    dependencies = set()
+    stanza = stanza
+
+    def plugin_init(self):
+        stanza.register_plugins()
+
+        for event in ('invite', 'reject', 'retract', 'leave', 'left'):
+            self.xmpp.register_handler(
+                Callback(f'Call {event}',
+                         StanzaPath(f'message/call-{event}'),
+                         self._handle_event))
+    def _handle_event(self, message):
+        for event in ('invite', 'reject', 'retract', 'leave', 'left'):
+            if message.get_plugin(f'call-{event}', check=True):
+                self.xmpp.event(f'call-{event}')
+
+    def plugin_end(self):
+        for event in ('invite', 'reject', 'retract', 'leave', 'left'):
+            self.xmpp.remove_handler(f'Call {event}')
--- a/slixmpp/plugins/xep_0482/stanza.py
+++ b/slixmpp/plugins/xep_0482/stanza.py
@ -0,0 +1,102 @@
+# Slixmpp: The Slick XMPP Library
+# Copyright (C) 2025 Mathieu Pasquet
+# This file is part of Slixmpp.
+# See the file LICENSE for copying permission
+
+from typing import Tuple, List, Optional
+from slixmpp import Message
+from slixmpp.jid import JID
+from slixmpp.xmlstream import ElementBase, register_stanza_plugin
+
+NS = 'urn:xmpp:call-invites:0'
+
+
+class Jingle(ElementBase):
+    name = 'jingle'
+    namespace = NS
+    plugin_attrib = 'jingle'
+    plugin_multi_attrib = 'jingles'
+    interfaces = {'sid', 'jid'}
+
+    def set_jid(self, value: JID) -> None:
+        if not isinstance(value, JID):
+            try:
+                value = JID(value)
+            except ValueError:
+                raise ValueError(f'"jid" must be a valid JID object')
+        self.xml.attrib['jid'] = value.full
+
+    def get_jid(self) -> Optional[JID]:
+        try:
+            return JID(self.xml.attrib.get('jid', ''))
+        except ValueError:
+            return None
+
+
+class External(ElementBase):
+    name = 'external'
+    namespace = NS
+    plugin_attrib = 'external'
+    plugin_multi_attrib = 'externals'
+    interfaces = {'uri'}
+
+
+class Invite(ElementBase):
+    name = 'invite'
+    namespace = NS
+    plugin_attrib = 'call-invite'
+    interfaces = {'video'}
+
+    def get_methods(self) -> Tuple[List[Jingle], List[External]]:
+        return (self['jingles'], self['externals'])
+
+    def set_video(self, value: bool) -> None:
+        if not isinstance(value, bool):
+            raise ValueError(f'Invalid value for the video attribute: {value}')
+        self.xml.attrib['video'] = str(value).lower()
+
+    def get_video(self) -> bool:
+        vid = self.xml.attrib.get('video', 'false').lower()
+        return vid == 'true'
+
+
+class Retract(ElementBase):
+    name = 'retract'
+    namespace = NS
+    plugin_attrib = 'call-retract'
+    interfaces = {'id'}
+
+
+class Accept(ElementBase):
+    name = 'accept'
+    namespace = NS
+    plugin_attrib = 'call-accept'
+    interfaces = {'id'}
+
+
+class Reject(ElementBase):
+    name = 'reject'
+    namespace = NS
+    plugin_attrib = 'call-reject'
+    interfaces = {'id'}
+
+
+class Left(ElementBase):
+    name = 'left'
+    namespace = NS
+    plugin_attrib = 'call-left'
+    interfaces = {'id'}
+
+
+def register_plugins() -> None:
+    register_stanza_plugin(Message, Invite)
+    register_stanza_plugin(Message, Retract)
+    register_stanza_plugin(Message, Accept)
+    register_stanza_plugin(Message, Reject)
+    register_stanza_plugin(Message, Left)
+
+    register_stanza_plugin(Invite, Jingle, iterable=True)
+    register_stanza_plugin(Invite, External, iterable=True)
+
+    register_stanza_plugin(Accept, Jingle)
+    register_stanza_plugin(Accept, External)
--- a/slixmpp/plugins/xep_0490/init.py
+++ b/slixmpp/plugins/xep_0490/init.py
@ -0,0 +1,8 @@
+from slixmpp.plugins.base import register_plugin
+
+from . import stanza
+from .mds import XEP_0490
+
+register_plugin(XEP_0490)
+
+__all__ = ['stanza', 'XEP_0490']
--- a/slixmpp/plugins/xep_0490/mds.py
+++ b/slixmpp/plugins/xep_0490/mds.py
@ -0,0 +1,42 @@
+from asyncio import Future
+
+from slixmpp import Iq
+from slixmpp.plugins import BasePlugin
+from slixmpp.types import JidStr
+
+from . import stanza
+from ..xep_0004 import Form
+
+
+class XEP_0490(BasePlugin):
+    """
+    XEP-0490: Message Displayed Synchronization
+    """
+
+    name = "xep_0490"
+    description = "XEP-0490: Message Displayed Synchronization"
+    dependencies = {"xep_0060", "xep_0163", "xep_0223", "xep_0359"}
+    stanza = stanza
+
+    def plugin_init(self):
+        stanza.register_plugin()
+        self.xmpp.plugin["xep_0163"].register_pep(
+            "message_displayed_synchronization",
+            stanza.Displayed,
+        )
+        self.xmpp.plugin["xep_0223"].node_profiles[self.stanza.NS] = {
+            "pubsub#max_items": "max",
+            "pubsub#send_last_published_item": "never",
+        }
+
+    def flag_chat(self, chat: JidStr, stanza_id: str, **kwargs) -> Future[Iq]:
+        displayed = stanza.Displayed()
+        displayed["stanza_id"]["id"] = stanza_id
+        return self.xmpp.plugin["xep_0223"].store(
+            displayed, node=stanza.NS, id=str(chat), **kwargs
+        )
+
+    def catch_up(self, **kwargs):
+        return self.xmpp.plugin["xep_0060"].get_items(
+            self.xmpp.boundjid.bare, stanza.NS, **kwargs
+        )
--- a/slixmpp/plugins/xep_0490/stanza.py
+++ b/slixmpp/plugins/xep_0490/stanza.py
@ -0,0 +1,17 @@
+from slixmpp import register_stanza_plugin
+from slixmpp.plugins.xep_0060.stanza import Item
+from slixmpp.xmlstream import ElementBase
+from slixmpp.plugins.xep_0359.stanza import StanzaID
+
+NS = "urn:xmpp:mds:displayed:0"
+
+
+class Displayed(ElementBase):
+    namespace = NS
+    name = "displayed"
+    plugin_attrib = "displayed"
+
+
+def register_plugin():
+    register_stanza_plugin(Displayed, StanzaID)
+    register_stanza_plugin(Item, Displayed)
--- a/slixmpp/plugins/xep_0492/init.py
+++ b/slixmpp/plugins/xep_0492/init.py
@ -0,0 +1,13 @@
+# Slixmpp: The Slick XMPP Library
+# Copyright (C) 2025 nicoco
+# This file is part of Slixmpp.
+# See the file LICENSE for copying permission.
+
+from slixmpp.plugins.base import register_plugin
+
+from . import stanza
+from .notify import XEP_0492
+
+register_plugin(XEP_0492)
+
+__all__ = ["stanza", "XEP_0492"]
--- a/slixmpp/plugins/xep_0492/notify.py
+++ b/slixmpp/plugins/xep_0492/notify.py
@ -0,0 +1,21 @@
+# Slixmpp: The Slick XMPP Library
+# Copyright (C) 2025 nicoco
+# This file is part of Slixmpp.
+# See the file LICENSE for copying permission.
+
+from slixmpp.plugins import BasePlugin
+from . import stanza
+
+
+class XEP_0492(BasePlugin):
+    """
+    XEP-0492: Chat notification settings
+    """
+
+    name = "xep_0492"
+    description = "XEP-0492: Chat notification settings"
+    dependencies = {"xep_0402"}
+    stanza = stanza
+
+    def plugin_init(self):
+        stanza.register_plugin()
--- a/slixmpp/plugins/xep_0492/stanza.py
+++ b/slixmpp/plugins/xep_0492/stanza.py
@ -0,0 +1,106 @@
+# Slixmpp: The Slick XMPP Library
+# Copyright (C) 2025 nicoco
+# This file is part of Slixmpp.
+# See the file LICENSE for copying permission.
+
+from typing import Literal, Optional, cast
+
+from slixmpp import register_stanza_plugin
+from slixmpp.plugins.xep_0402.stanza import Extensions
+from slixmpp.types import ClientTypes
+from slixmpp.xmlstream import ElementBase
+
+NS = "urn:xmpp:notification-settings:0"
+
+WhenLiteral = Literal["never", "always", "on-mention"]
+
+
+class Notify(ElementBase):
+    """
+    Chat notification settings element
+
+
+    To enable it on a Conference element, use configure() like this:
+
+    .. code-block::python
+
+        # C being a Conference element
+        C['extensions']["notify"].configure("always", client_type="pc")
+
+    Which will add the <notify> element to the <extensions> element.
+    """
+
+    namespace = NS
+    name = "notify"
+    plugin_attrib = "notify"
+    interfaces = {"notify"}
+
+    def configure(self, when: WhenLiteral, client_type: Optional[ClientTypes] = None) -> None:
+        """
+        Configure the chat notification settings for this bookmark.
+
+        This method ensures that there are no conflicting settings, e.g.,
+        both a <never /> and a <always /> element.
+        """
+        cls = _CLASS_MAP[when]
+        element = cls()
+        if client_type is not None:
+            element["client-type"] = client_type
+
+        match = client_type if client_type is not None else ""
+        for child in self:
+            if isinstance(child, _Base) and child["client-type"] == match:
+                self.xml.remove(child.xml)
+
+        self.append(element)
+
+    def get_config(
+        self, client_type: Optional[ClientTypes] = None
+    ) -> Optional[WhenLiteral]:
+        """
+        Get the chat notification settings for this bookmark.
+
+        :param client_type: Optionally, get the notification for a specific client type.
+            If unset, returns the global notification setting.
+
+        :return: The chat notification setting as a string, or None if unset.
+        """
+        match = client_type if client_type is not None else ""
+        for child in self:
+            if isinstance(child, _Base) and child["client-type"] == match:
+                return cast(WhenLiteral, child.name)
+        return None
+
+
+class _Base(ElementBase):
+    namespace = NS
+    interfaces = {"client-type"}
+
+
+class Never(_Base):
+    name = "never"
+
+
+class Always(_Base):
+    name = "always"
+
+
+class OnMention(_Base):
+    name = "on-mention"
+
+
+class Advanced(ElementBase):
+    namespace = NS
+    name = plugin_attrib = "advanced"
+
+
+_CLASS_MAP = {
+    "never": Never,
+    "always": Always,
+    "on-mention": OnMention,
+}
+
+
+def register_plugin():
+    register_stanza_plugin(Extensions, Notify)
+    register_stanza_plugin(Notify, Advanced)
--- a/slixmpp/pluginsdict.py
+++ b/slixmpp/pluginsdict.py
@ -103,6 +103,7 @@ from slixmpp.plugins.xep_0437 import XEP_0437
 from slixmpp.plugins.xep_0439 import XEP_0439
 from slixmpp.plugins.xep_0444 import XEP_0444
 from slixmpp.plugins.xep_0461 import XEP_0461
+from slixmpp.plugins.xep_0490 import XEP_0490


 class PluginsDict(TypedDict):
@ -199,3 +200,4 @@ class PluginsDict(TypedDict):
    xep_0439: XEP_0439
    xep_0444: XEP_0444
    xep_0461: XEP_0461
+    xep_0490: XEP_0490
--- a/slixmpp/types.py
+++ b/slixmpp/types.py
@ -53,17 +53,20 @@ MucAffiliation = Literal[
    'outcast', 'member', 'admin', 'owner', 'none'
 ]

+OptJid = Optional[JID]
+JidStr = Union[str, JID]
+OptJidStr = Optional[Union[str, JID]]

 class PresenceArgs(TypedDict, total=False):
-    pfrom: JID
-    pto: JID
+    pfrom: JidStr
+    pto: JidStr
    pshow: PresenceShows
    ptype: PresenceTypes
    pstatus: str


 class MucRoomItem(TypedDict, total=False):
-    jid: JID
+    jid: str
    role: MucRole
    affiliation: MucAffiliation
    show: Optional[PresenceShows]
@ -75,10 +78,6 @@ MucRoomItemKeys = Literal[
    'jid', 'role', 'affiliation', 'show', 'status',  'alt_nick',
 ]

-OptJid = Optional[JID]
-JidStr = Union[str, JID]
-OptJidStr = Optional[Union[str, JID]]
-
 MAMDefault = Literal['always', 'never', 'roster']

 FilterString = Literal['in', 'out', 'out_sync']
@ -98,6 +97,7 @@ ErrorConditions = Literal[
    "not-allowed",
    "not-authorized",
    "payment-required",
+    "policy-violation",
    "recipient-unavailable",
    "redirect",
    "registration-required",
@ -110,8 +110,21 @@ ErrorConditions = Literal[
    "unexpected-request",
 ]

+# https://xmpp.org/registrar/disco-categories.html#client
+ClientTypes = Literal[
+    "bot",
+    "console",
+    "game",
+    "handheld",
+    "pc",
+    "phone",
+    "sms",
+    "tablet",
+    "web",
+]
+
 __all__ = [
    'Protocol', 'TypedDict', 'Literal', 'OptJid', 'OptJidStr', 'JidStr', 'MAMDefault',
    'PresenceTypes', 'PresenceShows', 'MessageTypes', 'IqTypes', 'MucRole',
-    'MucAffiliation', 'FilterString', 'ErrorConditions', 'ErrorTypes'
+    'MucAffiliation', 'FilterString', 'ErrorConditions', 'ErrorTypes', 'ClientTypes'
 ]
--- a/slixmpp/version.py
+++ b/slixmpp/version.py
@ -5,5 +5,5 @@
 # We don't want to have to import the entire library
 # just to get the version info for setup.py

-__version__ = '1.8.5'
-__version_info__ = (1, 8, 5)
+__version__ = '1.8.6'
+__version_info__ = (1, 8, 6)
--- a/slixmpp/xmlstream/stanzabase.py
+++ b/slixmpp/xmlstream/stanzabase.py
@ -732,6 +732,9 @@ class ElementBase(object):
                return plugin[full_attrib]
            return plugin
        else:
+            # XXX: This is legacy from SleekXMPP
+            #      We've probably missed the opportunity to fix it
+            logging.warning("Unknown stanza interface: %s" % full_attrib)
            return ''

    def __setitem__(self, attrib: str, value: Any) -> Any:
@ -1230,7 +1233,7 @@ class ElementBase(object):
            if type(item) == XML_TYPE:
                return self.appendxml(item)
            else:
-                raise TypeError
+                raise TypeError(f"Cannot append {item!r} to a stanza")
        self.xml.append(item.xml)
        if item.__class__ == self.plugin_tag_map.get(item.tag_name(), None):
            self.init_plugin(item.plugin_attrib,
--- a/slixmpp/xmlstream/xmlstream.py
+++ b/slixmpp/xmlstream/xmlstream.py
@ -281,7 +281,8 @@ class XMLStream(asyncio.BaseProtocol):
    __slow_tasks: List[Task]
    __queued_stanzas: List[Tuple[Union[StanzaBase, str], bool]]

-    def __init__(self, host: str = '', port: int = 0):
+    def __init__(self, host: str = '', port: int = 0,
+                 ssl_context: Optional[ssl.SSLContext] = None):
        self.transport = None
        self.socket = None
        self._connect_loop_wait = 0
@ -298,9 +299,12 @@ class XMLStream(asyncio.BaseProtocol):
        # A dict of {name: handle}
        self.scheduled_events = {}

-        self.ssl_context = ssl.create_default_context()
-        self.ssl_context.check_hostname = True
-        self.ssl_context.verify_mode = ssl.CERT_REQUIRED
+        if ssl_context is None:
+            self.ssl_context = ssl.create_default_context()
+            self.ssl_context.check_hostname = True
+            self.ssl_context.verify_mode = ssl.CERT_REQUIRED
+        else:
+            self.ssl_context = ssl_context

        self.event_when_connected = "connected"

@ -371,7 +375,23 @@ class XMLStream(asyncio.BaseProtocol):
    @property
    def loop(self) -> AbstractEventLoop:
        if self._loop is None:
-            self._loop = asyncio.get_event_loop()
+            try:
+                with warnings.catch_warnings():
+                    warnings.simplefilter("ignore")
+                    self._loop = asyncio.get_event_loop()
+            # We do not know what exception will be raised in the future
+            # instead of the warning
+            except Exception:
+                try:
+                    current = asyncio.get_running_loop()
+                except RuntimeError:
+                    current = None
+                if current is not None:
+                    self._loop = current
+                else:
+                    loop = asyncio.new_event_loop()
+                    asyncio.set_event_loop(loop)
+                    self._loop = loop
        return self._loop

    @loop.setter
@ -405,9 +425,10 @@ class XMLStream(asyncio.BaseProtocol):
            self.disconnected.set_result(True)
        self.disconnected = asyncio.Future()

-    def connect(self, host: str = '', port: int = 0, use_ssl: Optional[bool] = None,
+    def connect(self, host: str = '', port: int = 0,
+                use_ssl: Optional[bool] = None,
                force_starttls: Optional[bool] = None,
-                disable_starttls: Optional[bool] = None) -> None:
+                disable_starttls: Optional[bool] = None) -> asyncio.Future:
        """Create a new socket and connect to the server.

        :param host: The name of the desired server for the connection.
@ -426,6 +447,7 @@ class XMLStream(asyncio.BaseProtocol):
                               upgrade to TLS, even if the server provides
                               it.  Use this for example if you’re on
                               localhost
+        :returns: A future on the current connection attempt

        """
        if self._run_out_filters is None or self._run_out_filters.done():
@ -457,8 +479,14 @@ class XMLStream(asyncio.BaseProtocol):
            self._connect_routine(),
            loop=self.loop,
        )
+        return self._current_connection_attempt

-    async def _connect_routine(self) -> None:
+    async def _connect_routine(self) -> Optional[asyncio.Future]:
+        """
+        Returns None if the attempt was canceled or if the connection succeeded
+        (cancelling done manually by the library user, so that should be known)
+        or the next connection attempt future if a new try has been scheduled.
+        """
        self.event_when_connected = "connected"

        if self._connect_loop_wait > 0:
@ -483,7 +511,7 @@ class XMLStream(asyncio.BaseProtocol):
            ssl_context = None

        if self._current_connection_attempt is None:
-            return
+            return None
        try:
            server_hostname = self.default_domain if self.use_ssl else None
            await self.loop.create_connection(lambda: self,
@ -495,11 +523,12 @@ class XMLStream(asyncio.BaseProtocol):
        except Socket.gaierror as e:
            self.event('connection_failed',
                       'No DNS record available for %s' % self.default_domain)
-            self.reschedule_connection_attempt()
+            return self.reschedule_connection_attempt()
        except OSError as e:
            log.debug('Connection failed: %s', e)
            self.event("connection_failed", e)
-            self.reschedule_connection_attempt()
+            return self.reschedule_connection_attempt()
+        return None

    def process(self, *, forever: bool = True, timeout: Optional[int] = None) -> None:
        """Process all the available XMPP events (receiving or sending data on the
@ -635,19 +664,22 @@ class XMLStream(asyncio.BaseProtocol):
        self._set_disconnected_future()
        self.event("disconnected", self.disconnect_reason or exception)

-    def reschedule_connection_attempt(self) -> None:
+    def reschedule_connection_attempt(self) -> Optional[asyncio.Future]:
        """
        Increase the exponential back-off and initate another background
        _connect_routine call to connect to the server.
+
+        :returns: A future on the next scheduled connection attempt.
        """
        # abort if there is no ongoing connection attempt
        if self._current_connection_attempt is None:
-            return
+            return None
        self._connect_loop_wait = min(300, self._connect_loop_wait * 2 + 1)
        self._current_connection_attempt = asyncio.ensure_future(
            self._connect_routine(),
            loop=self.loop,
        )
+        return self._current_connection_attempt

    def cancel_connection_attempt(self) -> None:
        """
@ -1350,6 +1382,7 @@ class XMLStream(asyncio.BaseProtocol):
            if isinstance(data, (RootStanza, str)) and not passthrough:
                self.__queued_stanzas.append((data, use_filters))
                log.debug('NOT SENT: %s %s', type(data), data)
+                self.event('stanza_not_sent', data)
                return
        self.waiting_queue.put_nowait((data, use_filters))

@ -1413,7 +1446,11 @@ class XMLStream(asyncio.BaseProtocol):

        # Convert the raw XML object into a stanza object. If no registered
        # stanza type applies, a generic StanzaBase stanza will be used.
-        stanza: Optional[StanzaBase] = self._build_stanza(xml)
+        try:
+            stanza: Optional[StanzaBase] = self._build_stanza(xml)
+        except Exception as exc:
+            log.exception("Unable to parse stanza: %s,\n%s", exc, xml)
+            stanza = None
        for filter in self.__filters['in']:
            if stanza is not None:
                filter = cast(SyncFilter, filter)
--- a/tests/test_stanza_xep_0004.py
+++ b/tests/test_stanza_xep_0004.py
@ -95,6 +95,21 @@ class TestDataForms(SlixTest):
          </message>
        """)

+    def testMultiLineField(self):
+        msg = self.Message()
+        form = msg['form']
+        form.addField(var='f1',
+                      value='Some text\non several\n\nlines')
+        self.check(msg, """
+          <message>
+            <x xmlns="jabber:x:data" type="form">
+              <field var="f1">
+                <value>Some text\non several\n\nlines</value>
+              </field>
+            </x>
+          </message>
+        """)
+
    def testSetValues(self):
        """Testing setting form values"""

@ -117,7 +132,7 @@ class TestDataForms(SlixTest):
                <value>b</value>
              </field>
            </x>
-          </message>""")
+          </message>""", use_values=False)

    def testSubmitType(self):
        """Test that setting type to 'submit' clears extra details"""
--- a/tests/test_stanza_xep_0055.py
+++ b/tests/test_stanza_xep_0055.py
@ -34,6 +34,7 @@ class TestJabberSearch(SlixTest):
            ifrom="juliet@capulet.com/balcony", ito="characters.shakespeare.lit"
        )
        iq["search"]["form"].add_field(var="x-gender", value="male")
+        iq["id"] = "0"
        self.check(
            iq,
            """
--- a/tests/test_stanza_xep_0308.py
+++ b/tests/test_stanza_xep_0308.py
@ -0,0 +1,26 @@
+import unittest
+from slixmpp import Message
+from slixmpp.test import SlixTest
+from slixmpp.plugins.xep_0308 import Replace
+from slixmpp.xmlstream import register_stanza_plugin
+
+
+class TestCorrectStanza(SlixTest):
+
+    def setUp(self):
+        register_stanza_plugin(Message, Replace)
+
+    def testBuild(self):
+        """Test that the element is created correctly."""
+        msg = Message()
+        msg['type'] = 'chat'
+        msg['replace']['id'] = 'toto123'
+
+        self.check(msg, """
+          <message type="chat">
+            <replace xmlns="urn:xmpp:message-correct:0" id="toto123"/>
+          </message>
+        """)
+
+
+suite = unittest.TestLoader().loadTestsFromTestCase(TestCorrectStanza)
--- a/tests/test_stanza_xep_0424.py
+++ b/tests/test_stanza_xep_0424.py
@ -2,38 +2,33 @@ import unittest
 from slixmpp import Message
 from slixmpp.test import SlixTest
 from slixmpp.plugins.xep_0424 import stanza
-from slixmpp.plugins.xep_0422 import stanza as astanza


 class TestRetraction(SlixTest):

    def setUp(self):
-        astanza.register_plugins()
        stanza.register_plugins()

    def testRetract(self):
        message = Message()
-        message['apply_to']['id'] = 'some-id'
-        message['apply_to']['retract']
+        message['retract']['id'] = 'some-id'

        self.check(message, """
 <message>
-  <apply-to xmlns="urn:xmpp:fasten:0" id="some-id">
-      <retract xmlns="urn:xmpp:message-retract:0"/>
-  </apply-to>
+  <retract xmlns="urn:xmpp:message-retract:1" id="some-id"/>
 </message>
        """, use_values=False)

    def testRetracted(self):
        message = Message()
        message['retracted']['stamp'] = '2019-09-20T23:09:32Z'
-        message['retracted']['origin_id']['id'] = 'originid'
+        message['retracted']['id'] = 'originid'

        self.check(message, """
 <message>
-  <retracted stamp="2019-09-20T23:09:32Z" xmlns="urn:xmpp:message-retract:0">
-    <origin-id xmlns="urn:xmpp:sid:0" id="originid"/>
-  </retracted>
+  <retracted stamp="2019-09-20T23:09:32Z"
+             xmlns="urn:xmpp:message-retract:1"
+             id="originid" /> 
 </message>
        """)

--- a/tests/test_stanza_xep_0425.py
+++ b/tests/test_stanza_xep_0425.py
@ -1,45 +1,48 @@
 import unittest
 from slixmpp import Message, Iq, JID
 from slixmpp.test import SlixTest
+from slixmpp.plugins.xep_0424 import stanza as stanza424
 from slixmpp.plugins.xep_0425 import stanza


 class TestModeration(SlixTest):

    def setUp(self):
+        stanza424.register_plugins()
        stanza.register_plugins()

    def testModerate(self):
        iq = Iq()
        iq['type'] = 'set'
        iq['id'] = 'a'
-        iq['apply_to']['id'] = 'some-id'
-        iq['apply_to']['moderate'].enable('retract')
-        iq['apply_to']['moderate']['reason'] = 'R'
+        iq['moderate']['id'] = 'some-id'
+        iq['moderate'].enable('retract')
+        iq['moderate']['reason'] = 'R'

        self.check(iq, """
 <iq type='set' id='a'>
-  <apply-to id="some-id" xmlns="urn:xmpp:fasten:0">
-    <moderate xmlns='urn:xmpp:message-moderate:0'>
-      <retract xmlns='urn:xmpp:message-retract:0'/>
-      <reason>R</reason>
-    </moderate>
-  </apply-to>
+  <moderate xmlns='urn:xmpp:message-moderate:1' id='some-id'>
+    <retract xmlns='urn:xmpp:message-retract:1'/>
+    <reason>R</reason>
+  </moderate>
 </iq>
-        """, use_values=False)
+        """)

    def testModerated(self):
        message = Message()
-        message['moderated']['by'] = JID('toto@titi')
-        message['moderated']['retracted']['stamp'] = '2019-09-20T23:09:32Z'
-        message['moderated']['reason'] = 'R'
+        message['retract']['id'] = 'some-id'
+        message['retract']['moderated']['by'] = JID('toto@titi')
+        message['retract']['moderated']['occupant-id']['id'] = 'oc-id'
+        message['retract']['reason'] = 'R'

        self.check(message, """
 <message>
-  <moderated xmlns="urn:xmpp:message-moderate:0" by="toto@titi">
-    <retracted stamp="2019-09-20T23:09:32Z" xmlns="urn:xmpp:message-retract:0" />
+  <retract id='some-id' xmlns='urn:xmpp:message-retract:1'>
+    <moderated by='toto@titi' xmlns='urn:xmpp:message-moderate:1'>
+      <occupant-id xmlns="urn:xmpp:occupant-id:0" id="oc-id" />
+    </moderated>
    <reason>R</reason>
-  </moderated>
+  </retract>
 </message>
        """)

--- a/tests/test_stanza_xep_0446.py
+++ b/tests/test_stanza_xep_0446.py
@ -0,0 +1,101 @@
+import unittest
+
+from slixmpp.test import SlixTest
+from slixmpp.plugins.xep_0446 import stanza
+
+
+class TestFileMeta(SlixTest):
+    def setUp(self):
+        stanza.register_plugins()
+
+    def test_simple(self):
+        file = stanza.File()
+        file["desc"] = "a description"
+        file["name"] = "toto.jpg"
+        file["media-type"] = "image/jpeg"
+        file["height"] = 1024
+        file["width"] = 768
+        file["size"] = 2048
+        self.check(
+            file,
+            """
+            <file xmlns='urn:xmpp:file:metadata:0'>
+              <desc>a description</desc>
+              <name>toto.jpg</name>
+              <media-type>image/jpeg</media-type>
+              <height>1024</height>
+              <width>768</width>
+              <size>2048</size>
+            </file>
+            """,
+        )
+
+    def test_bad_value(self):
+        file = stanza.File()
+        file["desc"] = "My great video"
+        file["name"] = "toto.mp4"
+        file["media-type"] = "video/3gpp"
+        file["height"] = 1024
+        file["width"] = 768
+        with self.assertRaises(ValueError):
+            file["length"] = -100
+
+    def test_hash_element(self):
+        file = stanza.File()
+        file["desc"] = "My great video"
+        file["name"] = "toto.3gp"
+        file["media-type"] = "video/3gpp"
+        file["height"] = 1024
+        file["width"] = 768
+        file["length"] = 2000
+        file["hash"]["algo"] = "sha3-256"
+        file["hash"]["value"] = "abcdef="
+        self.check(
+            file,
+            """
+            <file xmlns='urn:xmpp:file:metadata:0'>
+              <desc>My great video</desc>
+              <name>toto.3gp</name>
+              <media-type>video/3gpp</media-type>
+              <height>1024</height>
+              <width>768</width>
+              <length>2000</length>
+              <hash xmlns='urn:xmpp:hashes:2' algo="sha3-256">abcdef=</hash>
+            </file>
+            """,
+        )
+
+    def test_thumbnail_element(self):
+        file = stanza.File()
+        file["desc"] = "a description"
+        file["name"] = "toto.jpg"
+        file["media-type"] = "image/jpeg"
+        file["height"] = 1024
+        file["width"] = 768
+        file["size"] = 2048
+        file["thumbnail"]["media-type"] = "image/png"
+        file["thumbnail"]["uri"] = "cid:sha1+deadbeef@bob.xmpp.org"
+        file["thumbnail"]["width"] = 128
+        file["thumbnail"]["height"] = 96
+        self.check(
+            file,
+            """
+            <file xmlns='urn:xmpp:file:metadata:0'>
+              <desc>a description</desc>
+              <name>toto.jpg</name>
+              <media-type>image/jpeg</media-type>
+              <height>1024</height>
+              <width>768</width>
+              <size>2048</size>
+              <thumbnail xmlns='urn:xmpp:thumbs:1'
+                 uri='cid:sha1+deadbeef@bob.xmpp.org'
+                 media-type='image/png'
+                 width='128'
+                 height='96'/>
+            </file>
+            """,
+        )
+
+
+
+suite = unittest.TestLoader().loadTestsFromTestCase(TestFileMeta)
--- a/tests/test_stanza_xep_0482.py
+++ b/tests/test_stanza_xep_0482.py
@ -0,0 +1,42 @@
+import unittest
+from slixmpp import Message
+from slixmpp.jid import JID
+from slixmpp.test import SlixTest
+from slixmpp.plugins.xep_0482 import stanza
+from slixmpp.plugins.xep_0482.stanza import External, Jingle
+from slixmpp.xmlstream import register_stanza_plugin
+
+
+class TestCallInviteStanza(SlixTest):
+
+    def setUp(self):
+        stanza.register_plugins()
+
+    def test_invite(self):
+        """Test that the element is created correctly."""
+        msg = Message()
+        msg['call-invite']['video'] = True
+        jingle = Jingle()
+        jingle['sid'] = 'toto'
+        jingle['jid'] = JID('toto@example.com/m')
+        external = External()
+        external['uri'] = "https://example.com/call"
+        msg['call-invite'].append(jingle)
+        msg['call-invite'].append(external)
+
+        self.check(msg, """
+<message>
+  <invite xmlns="urn:xmpp:call-invites:0" video="true">
+    <jingle sid="toto" jid="toto@example.com/m" />
+    <external uri="https://example.com/call" />
+  </invite>
+</message>
+        """)
+
+        self.assertEqual(
+            msg['call-invite'].get_methods(),
+            ([jingle], [external]),
+        )
+
+
+suite = unittest.TestLoader().loadTestsFromTestCase(TestCallInviteStanza)
--- a/tests/test_stanza_xep_0492.py
+++ b/tests/test_stanza_xep_0492.py
@ -0,0 +1,178 @@
+# Slixmpp: The Slick XMPP Library
+# Copyright (C) 2025 nicoco
+# This file is part of Slixmpp.
+# See the file LICENSE for copying permission.
+
+import unittest
+
+from slixmpp import register_stanza_plugin, ElementBase
+from slixmpp.test import SlixTest
+from slixmpp.plugins.xep_0492 import stanza
+from slixmpp.plugins.xep_0402 import stanza as b_stanza
+
+
+class TestNotificationSetting(SlixTest):
+    def setUp(self):
+        b_stanza.register_plugin()
+        stanza.register_plugin()
+
+    def test_never(self):
+        bookmark = b_stanza.Conference()
+        bookmark["extensions"]["notify"].configure("never")
+        self.check(
+            bookmark,
+            """
+            <conference xmlns='urn:xmpp:bookmarks:1'>
+              <extensions>
+                <notify xmlns='urn:xmpp:notification-settings:0'>
+                  <never />
+                </notify>
+              </extensions>
+            </conference>
+            """,
+            use_values=False,
+        )
+
+    def test_always(self):
+        bookmark = b_stanza.Conference()
+        bookmark["extensions"]["notify"].configure("always")
+        self.check(
+            bookmark,
+            """
+            <conference xmlns='urn:xmpp:bookmarks:1'>
+              <extensions>
+                <notify xmlns='urn:xmpp:notification-settings:0'>
+                  <always />
+                </notify>
+              </extensions>
+            </conference>
+            """,
+            use_values=False,
+        )
+
+    def test_on_mention(self):
+        bookmark = b_stanza.Conference()
+        bookmark["extensions"]["notify"].configure("on-mention")
+        self.check(
+            bookmark,
+            """
+            <conference xmlns='urn:xmpp:bookmarks:1'>
+              <extensions>
+                <notify xmlns='urn:xmpp:notification-settings:0'>
+                  <on-mention />
+                </notify>
+              </extensions>
+            </conference>
+            """,
+            use_values=False,
+        )
+
+    def test_advanced(self):
+        bookmark = b_stanza.Conference()
+        bookmark["extensions"]["notify"].configure("never", client_type="pc")
+        bookmark["extensions"]["notify"].configure("on-mention", client_type="mobile")
+
+        register_stanza_plugin(stanza.Advanced, AdvancedExtension)
+        bookmark["extensions"]["notify"]["advanced"].enable("cool")
+        bookmark["extensions"]["notify"]["advanced"]["cool"]["attrib"] = "cool-attrib"
+        bookmark["extensions"]["notify"]["advanced"]["cool"]["content"] = "cool-content"
+        self.check(
+            bookmark,
+            """
+            <conference xmlns='urn:xmpp:bookmarks:1'>
+              <extensions>
+                <notify xmlns='urn:xmpp:notification-settings:0'>
+                  <never client-type="pc" />
+                  <on-mention client-type="mobile" />
+                  <advanced>
+                    <cool xmlns="cool-ns" attrib="cool-attrib">cool-content</cool>
+                  </advanced>
+                </notify>
+              </extensions>
+            </conference>
+            """,
+            use_values=False,
+        )
+
+    def test_change_config(self):
+        bookmark = b_stanza.Conference()
+        bookmark["extensions"]["notify"].configure("never")
+        bookmark["extensions"]["notify"].configure("never", client_type="pc")
+        bookmark["extensions"]["notify"].configure("on-mention", client_type="mobile")
+
+        self.check(
+            bookmark,
+            """
+            <conference xmlns='urn:xmpp:bookmarks:1'>
+              <extensions>
+                <notify xmlns='urn:xmpp:notification-settings:0'>
+                  <never />
+                  <never client-type="pc" />
+                  <on-mention client-type="mobile" />
+                </notify>
+              </extensions>
+            </conference>
+            """,
+            use_values=False,
+        )
+
+        bookmark["extensions"]["notify"].configure("always")
+
+        self.check(
+            bookmark,
+            """
+            <conference xmlns='urn:xmpp:bookmarks:1'>
+              <extensions>
+                <notify xmlns='urn:xmpp:notification-settings:0'>
+                  <always />
+                  <never client-type="pc" />
+                  <on-mention client-type="mobile" />
+                </notify>
+              </extensions>
+            </conference>
+            """,
+            use_values=False,
+        )
+
+        bookmark["extensions"]["notify"].configure("always", "mobile")
+
+        self.check(
+            bookmark,
+            """
+            <conference xmlns='urn:xmpp:bookmarks:1'>
+              <extensions>
+                <notify xmlns='urn:xmpp:notification-settings:0'>
+                  <always />
+                  <never client-type="pc" />
+                  <always client-type="mobile" />
+                </notify>
+              </extensions>
+            </conference>
+            """,
+            use_values=False,
+        )
+
+    def test_get_config(self):
+        bookmark = b_stanza.Conference()
+        bookmark["extensions"]["notify"].configure("never")
+        bookmark["extensions"]["notify"].configure("never", client_type="pc")
+        bookmark["extensions"]["notify"].configure("on-mention", client_type="mobile")
+
+        self.assertEqual(bookmark["extensions"]["notify"].get_config(), "never")
+        self.assertEqual(bookmark["extensions"]["notify"].get_config("pc"), "never")
+        self.assertEqual(
+            bookmark["extensions"]["notify"].get_config("mobile"), "on-mention"
+        )
+
+
+class AdvancedExtension(ElementBase):
+    namespace = "cool-ns"
+    name = "cool"
+    plugin_attrib = name
+    interfaces = {"attrib", "content"}
+
+    def set_content(self, content: str):
+        self.xml.text = content
+
+
+suite = unittest.TestLoader().loadTestsFromTestCase(TestNotificationSetting)
--- a/tests/test_stream_xep_0223.py
+++ b/tests/test_stream_xep_0223.py
@ -0,0 +1,28 @@
+import unittest
+from slixmpp.test import SlixTest
+
+
+class TestPrivatePEP(SlixTest):
+
+    def testConfigureNode(self):
+        self.stream_start(mode='client', plugins=['xep_0223'])
+
+        self.xmpp.plugin['xep_0223'].configure(node="toto")
+        self.send("""
+<iq type="set" id="1">
+  <pubsub xmlns='http://jabber.org/protocol/pubsub#owner'>
+    <configure node='toto'>
+      <x xmlns='jabber:x:data' type='submit'>
+        <field var='FORM_TYPE' type='hidden'>
+          <value>http://jabber.org/protocol/pubsub#node_config</value>
+        </field>
+        <field var='pubsub#persist_items'><value>1</value></field>
+        <field var='pubsub#access_model'><value>whitelist</value></field>
+      </x>
+    </configure>
+  </pubsub>
+</iq>
+        """)
+
+
+suite = unittest.TestLoader().loadTestsFromTestCase(TestPrivatePEP)
--- a/tests/test_stream_xep_0308.py
+++ b/tests/test_stream_xep_0308.py
@ -0,0 +1,53 @@
+import unittest
+from slixmpp.jid import JID
+from slixmpp.test import SlixTest
+
+
+class TestStreamCorrect(SlixTest):
+
+    def test_recv_correct(self):
+        self.stream_start(mode='client', plugins=['xep_0308'])
+
+        recv = []
+
+        def recv_correct(msg):
+            recv.append(msg)
+
+        self.xmpp.add_event_handler('message_correction', recv_correct)
+
+        self.recv("""
+            <message from="example.com" to="toto@example">
+                <replace xmlns="urn:xmpp:message-correct:0" id="tototo"/>
+                <body>oucou</body>
+            </message>
+        """)
+        received = recv[0]
+        self.assertEqual(received['replace']['id'], "tototo")
+
+
+    def test_send_correct(self):
+        self.stream_start(mode='client', plugins=['xep_0308'])
+
+        corrected = self.xmpp.plugin['xep_0308'].build_correction(
+            id_to_replace="12345",
+            mto=JID('toto@example.com'),
+            mbody="I am replacing",
+        )
+        self.assertEqual(corrected['replace']['id'], '12345')
+        self.assertEqual(corrected['to'], JID('toto@example.com'))
+        self.assertEqual(corrected['body'], 'I am replacing')
+        corrected['id'] = 'my id'
+
+        corrected = self.xmpp.plugin['xep_0308'].correct_message(
+            corrected,
+            'This is new',
+        )
+        self.send("""
+            <message type="chat" to="toto@example.com">
+                <body>This is new</body>
+                <replace xmlns="urn:xmpp:message-correct:0" id="my id" />
+            </message>
+        """)
+
+
+suite = unittest.TestLoader().loadTestsFromTestCase(TestStreamCorrect)
--- a/tests/test_stream_xep_0461.py
+++ b/tests/test_stream_xep_0461.py
@ -8,12 +8,14 @@ class TestReply(SlixTest):
        self.stream_start(plugins=["xep_0461"])

    def testFallBackBody(self):
-        async def on_reply(msg):
+        def on_reply(msg):
            start = msg["fallback"]["body"]["start"]
            end = msg["fallback"]["body"]["end"]
            self.xmpp["xep_0461"].send_reply(
                reply_to=msg.get_from(),
                reply_id=msg.get_id(),
+                fallback=msg["reply"].strip_fallback_content(),
+                quoted_nick="res",
                mto="test@test.com",
                mbody=f"{start} to {end}",
            )
@ -26,7 +28,7 @@ class TestReply(SlixTest):
              <reply xmlns="urn:xmpp:reply:0" id="some-id" />
              <body>&gt; quoted\nsome-body</body>
                <fallback xmlns='urn:xmpp:fallback:0' for='urn:xmpp:reply:0'>
-                   <body start="0" end="8" />
+                   <body start="0" end="9" />
                </fallback>
            </message>
            """
@ -34,8 +36,11 @@ class TestReply(SlixTest):
        self.send(
            """
            <message xmlns="jabber:client" to="test@test.com" type="normal">
+              <body>&gt; res:\n&gt; some-body\n0 to 9</body>
              <reply xmlns="urn:xmpp:reply:0" id="other-id" to="from@from.com/res" />
-              <body>0 to 8</body>
+              <fallback xmlns='urn:xmpp:fallback:0' for='urn:xmpp:reply:0'>
+                <body start="0" end="19" />
+              </fallback>
            </message>
            """
        )
--- a/tests/test_stream_xep_0490.py
+++ b/tests/test_stream_xep_0490.py
@ -0,0 +1,135 @@
+import unittest.mock
+
+from slixmpp.test import SlixTest
+# from slixmpp.plugins import xep_0490
+
+
+class TestMessageDisplaySynchronization(SlixTest):
+    def setUp(self):
+        self.stream_start(jid="juliet@capulet.lit", plugins={"xep_0490"})
+
+    def test_catch_up(self):
+        future = self.xmpp.plugin["xep_0490"].catch_up()
+        self.send(  # language=XML
+            """
+            <iq type="get" to="juliet@capulet.lit" id="1">
+              <pubsub xmlns="http://jabber.org/protocol/pubsub">
+                <items node="urn:xmpp:mds:displayed:0" />
+              </pubsub>
+            </iq>
+            """
+        )
+        self.recv(  # language=XML
+            """
+            <iq type='result'
+                to='juliet@capulet.lit/balcony'
+                id='1'>
+              <pubsub xmlns='http://jabber.org/protocol/pubsub'>
+                <items node='urn:xmpp:mds:displayed:0'>
+                  <item id='romeo@montegue.lit'>
+                    <displayed xmlns='urn:xmpp:mds:displayed:0'>
+                      <stanza-id xmlns='urn:xmpp:sid:0'
+                                 id='0f710f2b-52ed-4d52-b928-784dad74a52b'
+                                 by='juliet@capulet.lit'/>
+                    </displayed>
+                  </item>
+                  <item id='example@conference.shakespeare.lit'>
+                    <displayed xmlns='urn:xmpp:mds:displayed:0'>
+                      <stanza-id xmlns='urn:xmpp:sid:0'
+                                 id='ca21deaf-812c-48f1-8f16-339a674f2864'
+                                 by='example@conference.shakespeare.lit'/>
+                    </displayed>
+                  </item>
+                </items>
+              </pubsub>
+            </iq>
+            """
+        )
+        iq = future.result()
+        item = list(iq["pubsub"]["items"])
+        self.assertEqual(item[0]["id"], "romeo@montegue.lit")
+        self.assertEqual(
+            item[0]["displayed"]["stanza_id"]["id"],
+            "0f710f2b-52ed-4d52-b928-784dad74a52b",
+        )
+
+        self.assertEqual(item[1]["id"], "example@conference.shakespeare.lit")
+        self.assertEqual(
+            item[1]["displayed"]["stanza_id"]["id"],
+            "ca21deaf-812c-48f1-8f16-339a674f2864",
+        )
+
+    def test_flag_chat(self):
+        self.xmpp.plugin["xep_0490"].flag_chat(
+            "romeo@montegue.lit", "0f710f2b-52ed-4d52-b928-784dad74a52b"
+        )
+        self.send(  # language=XML
+            """
+            <iq type='set' id='1'>
+              <pubsub xmlns='http://jabber.org/protocol/pubsub'>
+                <publish node='urn:xmpp:mds:displayed:0'>
+                  <item id='romeo@montegue.lit'>
+                    <displayed xmlns='urn:xmpp:mds:displayed:0'>
+                      <stanza-id xmlns='urn:xmpp:sid:0' 
+                                 id="0f710f2b-52ed-4d52-b928-784dad74a52b" />
+                    </displayed>
+                  </item>
+                </publish>
+                <publish-options>
+                  <x xmlns='jabber:x:data' type='submit'>
+                    <field var='FORM_TYPE' type='hidden'>
+                      <value>http://jabber.org/protocol/pubsub#publish-options</value>
+                    </field>
+                    <field var='pubsub#persist_items'>
+                      <value>1</value>
+                    </field>
+                    <field var='pubsub#max_items'>
+                      <value>max</value>
+                    </field>
+                    <field var='pubsub#send_last_published_item'>
+                      <value>never</value>
+                    </field>
+                    <field var='pubsub#access_model'>
+                      <value>whitelist</value>
+                    </field>
+                  </x>
+                </publish-options>
+              </pubsub>
+            </iq>
+            """,
+            use_values=False,
+        )
+
+    def test_notification(self):
+        handler = unittest.mock.Mock()
+
+        self.xmpp.add_event_handler(
+            "message_displayed_synchronization_publish", handler
+        )
+        self.recv(  # language=XML
+            """
+            <message from='juliet@capulet.lit' to='juliet@capulet.lit/balcony' type='headline' id='new-displayed-pep-event'>
+              <event xmlns='http://jabber.org/protocol/pubsub#event'>
+                <items node='urn:xmpp:mds:displayed:0'>
+                  <item id='romeo@montegue.lit'>
+                    <displayed xmlns='urn:xmpp:mds:displayed:0'>
+                      <stanza-id xmlns='urn:xmpp:sid:0' by='juliet@capulet.lit' id='0423e3a9-d516-493d-bb06-bee0e51ab9fb'/>
+                    </displayed>
+                  </item>
+                </items>
+              </event>
+            </message>
+            """
+        )
+        handler.assert_called()
+        msg = handler.call_args[0][0]
+        self.assertEqual(
+            msg["pubsub_event"]["items"]["item"]["id"], "romeo@montegue.lit"
+        )
+        self.assertEqual(
+            msg["pubsub_event"]["items"]["item"]["displayed"]["stanza_id"]["id"],
+            "0423e3a9-d516-493d-bb06-bee0e51ab9fb",
+        )
+
+
+suite = unittest.TestLoader().loadTestsFromTestCase(TestMessageDisplaySynchronization)
--- a/tox.ini
+++ b/tox.ini
@ -1,5 +0,0 @@
-[tox]
-envlist = py34
-[testenv]
-deps = nose
-commands = nosetests --where=tests --exclude=live -i slixtest.py
Author	SHA1	Message	Date
mathieui	a30f76892b	XEP-0482: add initial support	2025-02-09 18:52:28 +01:00
mathieui	3de8ee97b5	XEP-0050: make prev action possible when there is no next action (fixes #3516 ) Obviously the session has to allow for it, which must be modified in a handler.	2025-02-09 16:14:08 +01:00
mathieui	0de9df92c4	xmlstream: do not use the category param to catch_warnings Added in debian 3.11.	2025-02-09 15:52:43 +01:00
mathieui	04d5c43853	xmlstream/client/componentxmpp: Make mypy happy again borked in the previous commit regarding connect().	2025-02-09 15:35:40 +01:00
mathieui	0707786057	xmlstream: "cleanl" create a new event loop if none is set Relates to #3542	2025-02-09 13:39:57 +01:00
mathieui	1c762c6b25	doc: add more info for XEP-0030 (fix #3433 )	2025-02-09 12:31:15 +01:00
mathieui	f94a4f2dbd	xmlstream: return a future on connect() which can make sense for users of the lib to wait on.	2025-02-09 12:12:07 +01:00
mathieui	75ea0bf039	XEP-0308: add tests	2025-02-08 19:51:02 +00:00
mathieui	4cf1286332	XEP-0308: add utility functions to build and correct messages without needing to go into the xml schema details.	2025-02-08 19:51:02 +00:00
mathieui	8a127f61d0	XEP-0223: fix node standalone configuration (fixes #3555 ) also add a stream test for that	2025-02-08 12:52:33 +01:00
mathieui	1f14fb54c2	XEP-0060: fix get_item_ids (fix #3548 ) missing return statement, the function would work with callbacks, but that is a bit meh.	2025-02-08 12:30:02 +01:00
mathieui	651e0ea593	docs: improve using_asyncio page (hopefully fixes #3562 ) make event loop usage a bit clearer, and fix the examples.	2025-02-08 12:26:17 +01:00
mathieui	4ac41a5250	Add a way to get identities as dict (fixes #3566 )	2025-02-08 12:11:07 +01:00
mathieui	e03b7661c1	XEP-0446: complete support and tests	2025-02-07 20:33:22 +00:00
DinoThor	e955cd308a	Fix bad reference with client & method call	2025-02-07 13:52:15 +00:00
mathieui	2db5e0199c	docs: add lots of missing xeps, fix some issues sphinx was unhappy with some formatting artifacts	2025-02-03 00:16:51 +01:00
mathieui	bf2e006f88	docs: fix bad targets in projects page and actually the slixmpp chat room is not a chatroom for random bots written with slixmpp	2025-02-02 23:43:00 +01:00
mathieui	8c8bb5da8b	doap: add missing xep 264 and 469 support	2025-01-31 12:23:11 +01:00
mathieui	bd638f1b39	doap: add hats support since 1.8.6	2025-01-31 11:12:37 +01:00
mathieui	0ff9e3661d	XMLStream: allow custom sslcontext provisioning (fixes #3582 ) For some applications that have strict requirements on blocking calls, it might be beneficial to create the SSLContext in advance and provide it to the client/componentxmpp instance that will be going through kwargs until XMLStream. The context will be reconfigured later on based on user parameters, but it is highly recommended to set it up in a secure way.	2025-01-30 11:08:41 +00:00
mathieui	5ec378cccd	xep-0055: fix stanza test	2025-01-30 09:35:41 +01:00
nicoco	a9fc955eda	fix: add default error type for "payment-required" condition	2025-01-27 16:36:07 +01:00
nicoco	05860f71ac	ci: follow linter recommendations	2025-01-27 16:36:07 +01:00
mathieui	1482bcc395	basexmpp: make_iq no longer defaults to id="0" having a hardcoded default ID in make_iq is a bad idea, particularly since it will overwrite the (good) id produced byt Iq() when a stream is available. This is arguably a breaking change, but I certainly hope it is not breaking anything in the real world.	2025-01-26 18:03:15 +01:00
nicoco	2e736bc715	feat: support XEP-0492 (Chat Notification Settings)	2025-01-26 16:24:31 +00:00
nicoco	8d984cd8a1	XEP-0004: fix: prevent multiple <values> for 'text-single' field According to XEP-0004: - if there is no "type" attribute on a <field />, we should assume it is "text-single"; - "text-single" MUST NOT contain morethan one <value />. Before this patch, not specifying a field type and passing a multi-line string would result in an illegal stanza. While it would be cleaner to log a warning or even raise an exception if set_value() is called with an incompatible type, this breaks a lot of tests and backward-compatibility, so we introduce some heuristic in FormField.set_value() to infer the field type based on the provided value instead. I also changed FormField.get_value() so that it returns a list by default for 'text-multi' fields. This is a breaking change, but I have not found the justification for the previous behaviour.	2025-01-24 14:33:16 +00:00
nicoco	100014651c	cq: remove unused files	2025-01-24 15:30:24 +01:00
nicoco	f9a9a0dcb7	fix: add default error type for "policy-violation" condition	2025-01-24 09:53:42 +01:00
nicoco	c585ec5983	fix: add missing "policy-violation" to error conditions	2025-01-22 21:32:57 +01:00
nicoco	27bbb1ef95	xep_0425: add missing 'id' attribute to 'Moderate' stanza plugin	2024-12-30 14:46:25 +01:00
mathieui	5dfc622539	itests: fix XEP-0424 test broken due to the new XEP version	2024-12-29 01:08:05 +01:00
mathieui	2ab9b5a05c	ci: add setuptools, remove 3.7/3.8 and add 3.13	2024-12-29 00:50:53 +01:00
mathieui	09d9320b91	Release 1.8.6	2024-12-26 22:39:49 +01:00
mathieui	fbf298c36d	XEP-0030: fix tests Use None as the "no value" value, rather than ''.	2024-12-26 09:42:33 +01:00
mathieui	7153d79006	itests/examples: integrate imghdr code directly (fix #3570 ) Python 3.13 removes it, and I would rather not add another dependency only for tests or examples…	2024-12-14 16:08:49 +01:00
mathieui	1d3e03a923	XEP-0030: make read operations more resilient Reading valid XML which does not respect the XEP schema should not crash the parser badly.	2024-12-14 16:00:24 +01:00
mathieui	3d0b09e2e2	xmlstream: prevent stanza parsing from crashing the whole thing If an error happened while parsing a stanza, it would bring the whole program down and disconnect instead of logging an error. And the DEBUG log happened afterwards (so, never).	2024-12-14 15:52:51 +01:00
nicoco	23544731ef	Support XEP-0490 (Message Display Synchronization)	2024-12-11 21:29:37 +00:00
nicoco	a18a6c4eb8	xep-0425: update to version 0.3.0	2024-12-11 21:24:12 +00:00
nicoco	dd903b1792	xep-0424: update to version 0.4.0	2024-12-11 21:24:12 +00:00
mathieui	cf3b30120e	repo: remove github pull request template codeberg annoyingly picks it up, which creates confusion for contributors	2024-12-11 22:18:38 +01:00
jinyu	d86dccaf85	enhancement: Update type hints	2024-12-11 21:17:23 +00:00
jinyu	075812adf3	fix: Update msg_kwargs documentation to clarify required parameters for make_message	2024-12-11 21:16:37 +00:00
jinyu	8955ece461	Fix missing parameters	2024-12-11 21:16:37 +00:00
jinyu	5051c60262	enhancement: Refactor reply handling in XEP-0461; add fallback support and improve message construction	2024-12-11 21:16:37 +00:00
mathieui	c495eb73fc	xmlstream: add stanza_not_sent event (fixes #3559 )	2024-12-11 22:01:34 +01:00
jinyu	12c516d365	fix: Add future annotations import to base.py for improved type hinting	2024-11-19 18:44:33 +01:00
jinyu	d9b0b6dfe6	fix: Correct JID comparison in MUC plugin for bare JID matching	2024-11-19 18:44:27 +01:00
jinyu	7979e3b603	Resolve circular import	2024-11-19 18:44:20 +01:00
jinyu	f24a7679e5	enhancement: Improve JID handling and logging in MUC plugin; update status code return type	2024-11-19 18:44:11 +01:00
jinyu	df0ecfc142	Update the type of BasePlugin.xmpp to BaseXMPP. Increase the timeout for join_muc_wait.	2024-11-19 18:43:58 +01:00
jinyu	e79b98b266	add default timeout value	2024-11-19 18:43:49 +01:00
jinyu	5ed5e60b20	Fix: AttributeError in get_nick and jid_in_room due to incorrect JID type	2024-11-19 18:43:41 +01:00
mathieui	e5fe53ef45	tests: remove distutils use	2024-10-08 10:31:15 +02:00
mathieui	93608bd2f4	setup.py: Add python versions	2024-10-08 10:29:28 +02:00
nicoco	3b2386ee2f	stanzabase: Pass problematic object to TypeError raised by ElementBase.append() This should help debugging those type of errors.	2024-09-27 13:00:28 +02:00
nicoco	b94c6716f7	xep-0231: fix TypeError when BoB cannot be found Although it is not documented whether the get_bob API call can return None, the default implementation can, which raises a TypeError when the requested BoB is not available. This commit prevents such TypeError by raising a XMPPError instead. References: https://todo.sr.ht/~nicoco/slidcord/23	2024-09-27 10:28:24 +02:00
jinyu	db8ce9187c	feat: Add is_correction method to XEP-0308 Last Message Correction plugin	2024-09-08 00:39:10 +08:00
mathieui	7f926a944a	setup.py: Do not install aiodns on windows (fix #3556 ) aiodns is broken on the default windows event loop and the workaround has significant downsides. This has downsides too as it prevents resolution of SRV records by default.	2024-08-25 13:18:31 +02:00
sch	e96f8e1ed0	Correct an MUC-related error message which indicates the requirement of a JID	2024-06-20 19:00:20 +00:00
sch	c8c0bb9134	Add BukuBot Add BukuBot for bookmarks	2024-06-04 10:22:24 +00:00
schimoni	825c51b87d	Add descriptive introduction and new links to project sendxmpp-py Add descriptive introduction; Change URL of repository sendxmpp-py; Add groupchat to project sendxmpp-py.	2024-05-22 12:39:14 +00:00
mathieui	7c79f28587	XEP-0199: handle component case for keepalive ping	2024-03-22 20:48:36 +01:00