Allow the user to choose one of multiple pubsub services

- Use bootstrap's collapse feature to show/hide entity features

Author: jcbrand

src/headless/index.js

@@ -30,7 +30,7 @@ import './plugins/bosh/index.js'; // XEP-0206 BOSH
 import './plugins/caps/index.js'; // XEP-0115 Entity Capabilities
 export { ChatBox, Message, Messages } from './plugins/chat/index.js'; // RFC-6121 Instant messaging
 import './plugins/chatboxes/index.js';
-import './plugins/disco/index.js'; // XEP-0030 Service discovery
+export { DiscoEntity, DiscoEntities } from './plugins/disco/index.js'; // XEP-0030 Service discovery
 import './plugins/adhoc/index.js'; // XEP-0050 Ad Hoc Commands
 import './plugins/headlines/index.js'; // Support for headline messages
 export { Device, Devices, DeviceList, DeviceLists } from './plugins/omemo/index.js'; // Support for headline messages

src/headless/plugins/disco/index.js

@@ -19,6 +19,8 @@ import {
 
 const { Strophe } = converse.env;
 
+export { DiscoEntity, DiscoEntities };
+
 /**
  * @typedef {Object} DiscoState
  * @property {Array} _identities

src/headless/types/index.d.ts

@@ -21,6 +21,7 @@ export { Collection, EventEmitter, Model } from "@converse/skeletor";
 export { Builder, Stanza } from "strophe.js";
 export { Bookmark, Bookmarks } from "./plugins/bookmarks/index.js";
 export { ChatBox, Message, Messages } from "./plugins/chat/index.js";
+export { DiscoEntity, DiscoEntities } from "./plugins/disco/index.js";
 export { Device, Devices, DeviceList, DeviceLists } from "./plugins/omemo/index.js";
 export { MUCMessage, MUCMessages, MUC, MUCOccupant, MUCOccupants } from "./plugins/muc/index.js";
 export { RosterContact, RosterContacts, RosterFilter, Presence, Presences } from "./plugins/roster/index.js";

src/headless/types/plugins/disco/index.d.ts

@@ -2,4 +2,7 @@ export type DiscoState = {
     _identities: any[];
     _features: any[];
 };
+import DiscoEntity from './entity.js';
+import DiscoEntities from './entities.js';
+export { DiscoEntity, DiscoEntities };
 //# sourceMappingURL=index.d.ts.map

src/headless/types/plugins/pubsub/api.d.ts

@@ -38,10 +38,10 @@ declare namespace _default {
          * Creates a PubSub node at a given service
          * @param {string} jid - The PubSub service JID
          * @param {string} node - The node to create
-         * @param {PubSubConfigOptions} config The configuration options
+         * @param {PubSubConfigOptions} [config] The configuration options
          * @returns {Promise<void>}
          */
-        function create(jid: string, node: string, config: import("./types").PubSubConfigOptions): Promise<void>;
+        function create(jid: string, node: string, config?: import("./types").PubSubConfigOptions): Promise<void>;
         /**
          * Subscribes the local user to a PubSub node.
          *

src/headless/types/shared/_converse.d.ts

@@ -79,7 +79,7 @@ export class ConversePrivateGlobal extends ConversePrivateGlobal_base {
      */
     state: any;
     initSession(): void;
-    session: Model;
+    session: any;
     /**
      * Translate the given string based on the current locale.
      * @method __

src/headless/types/shared/connection/index.d.ts

@@ -5,7 +5,11 @@ declare const Connection_base: typeof import("strophe.js/src/types/connection").
  * via BOSH or websocket inside a shared worker).
  */
 export class Connection extends Connection_base {
-    constructor(service: any, options: any);
+    /**
+     * @param {string} service - The BOSH or WebSocket service URL.
+     * @param {import('strophe.js/src/types/connection').ConnectionOptions} options
+     */
+    constructor(service: string, options: import("strophe.js/src/types/connection").ConnectionOptions);
     send_initial_presence: boolean;
     debouncedReconnect: import("lodash").DebouncedFunc<() => Promise<any>>;
     /** @param {Element} body */
@@ -111,11 +115,6 @@ export class Connection extends Connection_base {
  * The MockConnection class is used during testing, to mock an XMPP connection.
  */
 export class MockConnection extends Connection {
-    /**
-     * @param {string} service - The BOSH or WebSocket service URL.
-     * @param {import('strophe.js/src/types/connection').ConnectionOptions} options - The configuration options
-     */
-    constructor(service: string, options: import("strophe.js/src/types/connection").ConnectionOptions);
     sent_stanzas: any[];
     IQ_stanzas: any[];
     IQ_ids: any[];

src/plugins/roomslist/styles/roomsgroups.scss

@@ -1,6 +1,11 @@
 .conversejs {
-
     #chatrooms {
+        .collapsed {
+            height: 0 !important;
+            overflow: hidden !important;
+            padding: 0 !important;
+        }
+
         .muc-domain-group-toggle {
             margin: 0.75em 0 0.25em 0;
         }

src/plugins/rosterview/styles/roster.scss

@@ -1,6 +1,11 @@
 .conversejs {
-
     #controlbox {
+        .collapsed {
+            height: 0 !important;
+            overflow: hidden !important;
+            padding: 0 !important;
+        }
+
         .open-contacts-toggle, .open-contacts-toggle .fa {
             color: var(--chat-color) !important;
             &:hover {

src/plugins/todo/PLAN.md

@@ -0,0 +1,37 @@
+# TODO Plugin Implementation Plan
+
+This document outlines the step-by-step plan to add multi-list TODO functionality using XEP-0060 PubSub. Each step can be checked off as it’s implemented.
+
+- [x] 1. Add `api.disco.entities.find(feature)` in `src/headless/plugins/disco/api.js` to lookup JIDs advertising a feature.  
+- [x] 2. In `src/headless/plugins/pubsub/api.js`, add `pubsub.subscribe(jid, node)` and `pubsub.unsubscribe(jid, node)`
+- [ ] 3. Modify `src/plugins/todo/plugin.js` to:  
+  - [ ] Discovers the PubSub service JID via `api.disco.entities.find('http://jabber.org/protocol/pubsub')`.  
+  - [ ] Subscribes to the master index node `urn:conversejs:todolists:1`.  
+  - [ ] Listens for item-add and item-delete events to track available TODO lists.  
+- [ ] 4. For each index entry, subscribe/unsubscribe to its list node and:  
+  - [ ] Fetch existing items via `api.pubsub.items(serviceJid, node)`.  
+  - [ ] Emit high-level events for list item additions/removals.  
+- [ ] 5. Implement payload parsing/serialization in PEP Bookmarks style (XEP-0402) or JSON inside `<item>` payloads.  
+- [ ] 6. Expose CRUD methods on `api.apps.todo`:  
+  - [ ] `listLists(): Promise<Array<{ node, title }>>`  
+  - [ ] `createList(node, title): Promise<void>`  
+  - [ ] `deleteList(node): Promise<void>`  
+  - [ ] `listItems(node): Promise<Item[]>`  
+  - [ ] `addItem(node, data): Promise<void>`  
+  - [ ] `removeItem(node, id): Promise<void>`  
+- [ ] 7. Maintain internal state of lists/items and fire events via `api.emit('todo:lists', lists)` and `api.emit('todo:items', node, items)`.  
+- [ ] 8. Write tests for:  
+  - [x] `api.disco.entities.find`  
+  - [x] `api.pubsub.subscribe/unsubscribe`  
+  - [ ] Index module behavior  
+  - [ ] CRUD API methods  
+- [ ] 9. Update documentation in `src/plugins/todo/README.md` and project docs.
+
+Once all items are checked, the multi-list TODO plugin will support dynamic discovery, subscription, and management of multiple TODO lists via XMPP PubSub.  
+
+---
+
+When adding a new TODO list, let the user enter a name for the list.
+
+Then, upon submission, automatically look for a pubsub service on the user's domain.
+If none is found, return to the form with a new input to let the user specify a PubSub service.