Skip to content

feat: WebsocketReader and WebsocketWriter components#77

Merged
toby-coleman merged 14 commits intomainfrom
feat/websocket-component
Feb 26, 2025
Merged

feat: WebsocketReader and WebsocketWriter components#77
toby-coleman merged 14 commits intomainfrom
feat/websocket-component

Conversation

@toby-coleman
Copy link
Contributor

Summary

Adds plugboard.library components for reading/writing from/to websocket servers.

Changes

  • WebsocketReader acts as a data source, connecting to a websocket server, receiving messages and making them available as outputs.
  • WebsocketWriter sends data from the plugboard process to a websocket server.

@toby-coleman
Copy link
Contributor Author

One thing I realised while doing this... currently we don't have a graceful way to shutdown the process when SIGINT/SIGTERM is received, i.e. ideally the WebsocketReader would know when it is going to shutdown and all await self.io.close() to stop the rest of the Process.

@toby-coleman
Copy link
Contributor Author

One thing I realised while doing this... currently we don't have a graceful way to shutdown the process when SIGINT/SIGTERM is received, i.e. ideally the WebsocketReader would know when it is going to shutdown and all await self.io.close() to stop the rest of the Process.

Add #86 to track this.

@toby-coleman toby-coleman merged commit a16cf5b into main Feb 26, 2025
2 checks passed
@toby-coleman toby-coleman deleted the feat/websocket-component branch February 26, 2025 19:42
toby-coleman added a commit that referenced this pull request Mar 15, 2025
# Summary
Adds `plugboard.library` components for reading/writing from/to
websocket servers.

# Changes
* `WebsocketReader` acts as a data source, connecting to a websocket
server, receiving messages and making them available as outputs.
* `WebsocketWriter` sends data from the plugboard process to a websocket
server.
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant