Skip to content

Commit ad1ecd1

Browse files
ff137henrymsiska
ff137
and
henrymsiska
authored
🎉 NATS Plugin 🚧 (#666)
* ⬆️ Update lock files Signed-off-by: ff137 <[email protected]> * 🚀 take on NATS plugin Copied from redis_events plugin, and replaced redis with nats-py (and json with orjson) Signed-off-by: ff137 <[email protected]> * ✅ basic unit tests for events Signed-off-by: ff137 <[email protected]> * 👷 skip nats_events integration testing Signed-off-by: ff137 <[email protected]> * ✨ read `NATS_CREDS_FILE` from env vars Signed-off-by: ff137 <[email protected]> * Update nats_events/README.md Co-authored-by: Henry Msiska <[email protected]> Signed-off-by: Mourits de Beer <[email protected]> * 🎨 rename nats topic to subject Signed-off-by: ff137 <[email protected]> * 🎨 replace f-string interpolation in logs Signed-off-by: ff137 <[email protected]> * ✨ use JetStream. Define streams on startup Signed-off-by: ff137 <[email protected]> * ✨ bind and re-use JetStream context Signed-off-by: ff137 <[email protected]> * ✨ handle jetstream publish ack Signed-off-by: ff137 <[email protected]> * 🎨 remove use of `cast` Signed-off-by: ff137 <[email protected]> * 🎨 more clear setup of jetstream context, instead of just nats Signed-off-by: ff137 <[email protected]> * ✅ fix tests Signed-off-by: ff137 <[email protected]> * 🎨 update NATS subject map to use `.`-pattern Signed-off-by: ff137 <[email protected]> * Update nats_events/README.md Co-authored-by: Henry Msiska <[email protected]> Signed-off-by: Mourits de Beer <[email protected]> * 🙈 don't ignore vscode settings Signed-off-by: ff137 <[email protected]> * 🔧 vscode cspell settings Signed-off-by: ff137 <[email protected]> * 🎨 Signed-off-by: ff137 <[email protected]> * 🚧 add some verbose logging for testing Signed-off-by: ff137 <[email protected]> * 🎨 update method for nats connection args Signed-off-by: ff137 <[email protected]> * 🚧 debug timeout error for defining stream, change stream name Signed-off-by: ff137 <[email protected]> * 🚧 debug on_startup connecting to jetstream Signed-off-by: ff137 <[email protected]> * 🚧 test replacing . in name with _ Signed-off-by: ff137 <[email protected]> * ✨ publish with retry -- correctly handle PubAck Signed-off-by: ff137 <[email protected]> * 🎨 log payload and no longer only write `with-state` records Signed-off-by: ff137 <[email protected]> * 🎨 fix payload log type Signed-off-by: ff137 <[email protected]> * 🎨 log levels Signed-off-by: ff137 <[email protected]> * ✅ fix tests Signed-off-by: ff137 <[email protected]> * ✨ handle OutboundMessage type (make it serialisable) Signed-off-by: ff137 <[email protected]> * 🎨 retry should log error instead of raising exception Signed-off-by: ff137 <[email protected]> * 🎨 handle optional target types Signed-off-by: ff137 <[email protected]> * ✅ fix tests Signed-off-by: ff137 <[email protected]> * 🎨 add words to cspell list Signed-off-by: ff137 <[email protected]> * 🚧 remove define stream Signed-off-by: ff137 <[email protected]> * 🎨 define one stream with many subjects Signed-off-by: ff137 <[email protected]> * ⬆️ Update lock files Signed-off-by: ff137 <[email protected]> * ⬆️ Update lock files Signed-off-by: ff137 <[email protected]> --------- Signed-off-by: ff137 <[email protected]> Signed-off-by: Mourits de Beer <[email protected]> Co-authored-by: Henry Msiska <[email protected]>
1 parent a1cdae4 commit ad1ecd1

File tree

34 files changed

+11188
-7096
lines changed

34 files changed

+11188
-7096
lines changed

‎.github/dependabot.yml

+12
Original file line numberDiff line numberDiff line change
@@ -169,6 +169,18 @@ updates:
169169
- dependency-name: "*"
170170
update-types: ["version-update:semver-major"]
171171

172+
# Maintain dependencies for Python Packages
173+
- package-ecosystem: "pip"
174+
directory: "/nats_events"
175+
schedule:
176+
interval: "weekly"
177+
day: "monday"
178+
time: "04:00"
179+
timezone: "Canada/Pacific"
180+
ignore:
181+
- dependency-name: "*"
182+
update-types: ["version-update:semver-major"]
183+
172184
# Maintain dependencies for Python Packages
173185
- package-ecosystem: "pip"
174186
directory: "/oid4vci/integration/afj_runner"

‎.github/workflows/pr-integration-tests.yaml

+1-1
Original file line numberDiff line numberDiff line change
@@ -42,7 +42,7 @@ jobs:
4242
declare -a changed_dirs=()
4343
for dir in ./*/; do
4444
current_folder=$(basename "$dir")
45-
if [[ $current_folder == "plugin_globals" ]] || [[ $current_folder == "kafka_events" ]]; then
45+
if [[ $current_folder == "plugin_globals" ]] || [[ $current_folder == "kafka_events" ]] || [[ $current_folder == "nats_events" ]]; then
4646
continue
4747
fi
4848
for changed_file in ${{ steps.changed-files.outputs.all_changed_files }}; do

‎.gitignore

-1
Original file line numberDiff line numberDiff line change
@@ -5,6 +5,5 @@ __pycache__/
55
**/test-reports/
66
.coverage
77
coverage.xml
8-
settings.json
98
.env
109
.venv

‎.vscode/settings.json

+20
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,20 @@
1+
{
2+
"cSpell.words": [
3+
"acapy",
4+
"actionmenu",
5+
"aiohttp",
6+
"basicmessage",
7+
"basicmessages",
8+
"cloudagent",
9+
"CREDS",
10+
"crids",
11+
"devcontainer",
12+
"didcomm",
13+
"jetstream",
14+
"keylist",
15+
"linedata",
16+
"Pydantic",
17+
"resp",
18+
"verkey"
19+
]
20+
}

‎basicmessage_storage/integration/poetry.lock

+12-9
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

‎basicmessage_storage/poetry.lock

+516-506
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

‎connection_update/integration/poetry.lock

+491-481
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

‎connection_update/poetry.lock

+516-506
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

‎firebase_push_notifications/integration/poetry.lock

+12-9
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

0 commit comments

Comments
 (0)