Skip to content

Commit

Permalink
fix(deps): patch for credo core and credo hooks
Browse files Browse the repository at this point in the history
Signed-off-by: Bryce McMath <bryce.j.mcmath@gmail.com>
  • Loading branch information
bryce-mcmath committed Feb 5, 2025
1 parent 5519d8f commit af2aa92
Show file tree
Hide file tree
Showing 5 changed files with 214 additions and 254 deletions.
28 changes: 20 additions & 8 deletions .yarn/patches/@credo-ts-core-npm-0.5.11-9122d8c9b8.patch
Original file line number Diff line number Diff line change
@@ -1,5 +1,17 @@
diff --git a/build/agent/Agent.js b/build/agent/Agent.js
index c80ba74c75de6418b7c874364d2c6a3552e322e9..1727fa4c08c80c95f9c154c3f678de2f1c2c362e 100644
--- a/build/agent/Agent.js
+++ b/build/agent/Agent.js
@@ -104,6 +104,7 @@ class Agent extends BaseAgent_1.BaseAgent {
}
async initialize() {
const stop$ = this.dependencyManager.resolve(constants_1.InjectionSymbols.Stop$);
+ stop$.next(false);
// Listen for new messages (either from transports or somewhere else in the framework / extensions)
// We create this before doing any other initialization, so the initialization could already receive messages
this.messageSubscription = this.eventEmitter
diff --git a/build/transport/WsOutboundTransport.js b/build/transport/WsOutboundTransport.js
index ab9df20f9fedc4def4f486b9431ac669e899e609..220157c6082b6c9761e021e611e66510dd9a05fd 100644
index ab9df20f9fedc4def4f486b9431ac669e899e609..2e9e43a528fab6a01e52d54506891060adb917cc 100644
--- a/build/transport/WsOutboundTransport.js
+++ b/build/transport/WsOutboundTransport.js
@@ -43,7 +43,16 @@ class WsOutboundTransport {
Expand All @@ -9,14 +21,14 @@ index ab9df20f9fedc4def4f486b9431ac669e899e609..220157c6082b6c9761e021e611e66510
- stillOpenSocketClosingPromises.push(new Promise((resolve) => socket.once('close', resolve)));
+ stillOpenSocketClosingPromises.push(
+ new Promise((resolve) => {
+ const closeHandler = () => {
+ socket.removeEventListener('close', closeHandler)
+ resolve()
+ }
+
+ socket.addEventListener('close', closeHandler)
+ const closeHandler = () => {
+ socket.removeEventListener('close', closeHandler)
+ resolve()
+ }
+
+ socket.addEventListener('close', closeHandler)
+ })
+ );
+ );
socket.close();
}
});
Loading

0 comments on commit af2aa92

Please sign in to comment.