Single place to import EventEmitter from

xmppjs · Jan 6, 2025 · a29e515 · a29e515
1 parent b835091
commit a29e515
Show file tree

Hide file tree

Showing 10 changed files with 21 additions and 11 deletions.
diff --git a/package-lock.json b/package-lock.json
diff --git a/packages/client/README.md b/packages/client/README.md
@@ -55,12 +55,14 @@ xmpp.on("offline", () => {
   console.log("offline");
 });
 
-xmpp.once("stanza", async (stanza) => {
+xmpp.on("stanza", onStanza);
+async function onStanza(stanza) {
   if (stanza.is("message")) {
+    xmpp.off("stanza", onStanza);
     await xmpp.send(xml("presence", { type: "unavailable" }));
     await xmpp.stop();
   }
-});
+}
 
 xmpp.on("online", async (address) => {
   console.log("online as", address.toString());

diff --git a/packages/client/example.js b/packages/client/example.js
@@ -25,12 +25,14 @@ xmpp.on("offline", () => {
   console.log("offline");
 });
 
-xmpp.once("stanza", async (stanza) => {
+xmpp.on("stanza", onStanza);
+async function onStanza(stanza) {
   if (stanza.is("message")) {
+    xmpp.off("stanza", onStanza);
     await xmpp.send(xml("presence", { type: "unavailable" }));
     await xmpp.stop();
   }
-});
+}
 
 xmpp.on("online", async (address) => {
   console.log("online as", address.toString());

diff --git a/packages/component/example.js b/packages/component/example.js
@@ -18,7 +18,7 @@ xmpp.on("offline", () => {
   console.log("offline");
 });
 
-xmpp.once("stanza", async (stanza) => {
+xmpp.on("stanza", async (stanza) => {
   if (stanza.is("message")) {
     await xmpp.stop();
   }

diff --git a/packages/events/index.js b/packages/events/index.js
@@ -1,4 +1,4 @@
-import EventEmitter from "events";
+import { EventEmitter } from "events";
 
 import timeout from "./lib/timeout.js";
 import delay from "./lib/delay.js";

diff --git a/packages/events/test/promise.test.js b/packages/events/test/promise.test.js
@@ -1,5 +1,5 @@
 import promise from "../lib/promise.js";
-import EventEmitter from "node:events";
+import { EventEmitter } from "../index.js";
 
 class Socket extends EventEmitter {
   constructor(fn) {

diff --git a/packages/tls/lib/Socket.js b/packages/tls/lib/Socket.js
@@ -1,5 +1,5 @@
 import tls from "tls";
-import { EventEmitter } from "events";
+import { EventEmitter } from "@xmpp/events";
 
 class Socket extends EventEmitter {
   constructor() {

diff --git a/packages/tls/package.json b/packages/tls/package.json
@@ -10,7 +10,8 @@
   "main": "index.js",
   "dependencies": {
     "@xmpp/connection": "^0.14.0",
-    "@xmpp/connection-tcp": "^0.14.0"
+    "@xmpp/connection-tcp": "^0.14.0",
+    "@xmpp/events": "^0.14.0"
   },
   "keywords": [
     "XMPP",

diff --git a/packages/xml/lib/Parser.js b/packages/xml/lib/Parser.js
@@ -1,6 +1,6 @@
 import LtxParser from "ltx/lib/parsers/ltx.js";
 import Element from "ltx/lib/Element.js";
-import EventEmitter from "events";
+import { EventEmitter } from "@xmpp/events";
 import XMLError from "./XMLError.js";
 
 class Parser extends EventEmitter {

diff --git a/packages/xml/package.json b/packages/xml/package.json
@@ -16,6 +16,7 @@
     "presence"
   ],
   "dependencies": {
+    "@xmpp/events": "^0.14.0",
     "ltx": "^3.1.1"
   },
   "engines": {