Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

chore(deps): Bump marshmallow from 3.20.1 to 3.20.2 in /oid4vci #44

Closed
wants to merge 6 commits into from
Closed

chore(deps): Bump marshmallow from 3.20.1 to 3.20.2 in /oid4vci #44

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
6 commits
Select commit Hold shift + click to select a range
f2be3d4
:sparkles: add origin and timestamp to event metadata (#46)
ff137 Feb 28, 2024
99053ee
:art: reduce default log levels for handling webhooks (#60)
ff137 Mar 5, 2024
a937696
chore(deps-dev): Bump pytest-ruff from 0.1.1 to 0.3 in /redis_events …
dependabot[bot] Mar 5, 2024
185ea29
chore(deps-dev): Bump ruff from 0.1.11 to 0.3.0 in /redis_events (#50)
dependabot[bot] Mar 5, 2024
cfd1185
chore(deps): Bump redis from 4.6.0 to 5.0.2 in /redis_events (#24)
dependabot[bot] Mar 5, 2024
4f0a324
chore(deps): Bump marshmallow from 3.20.1 to 3.20.2 in /oid4vci
dependabot[bot] Mar 5, 2024
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
14 changes: 7 additions & 7 deletions oid4vci/poetry.lock
View file
Open in desktop

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

2 changes: 1 addition & 1 deletion oid4vci/pyproject.toml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -14,7 +14,7 @@ aries-cloudagent = { version = ">=0.10.3, < 1.0.0", optional = true }
aiohttp = "^3.8.5"
aries-askar = "~0.3.0"
aiohttp-cors = "^0.7.0"
marshmallow = "^3.20.1"
marshmallow = "^3.20.2"

[tool.poetry.extras]
aca-py = ["aries-cloudagent"]
Expand Down
58 changes: 31 additions & 27 deletions redis_events/poetry.lock
View file
Open in desktop

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

6 changes: 3 additions & 3 deletions redis_events/pyproject.toml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -14,20 +14,20 @@ aiohttp = "^3.7.4"
fastapi = "^0.109.2"
nest-asyncio = "^1.5.5"
pydantic = "^1.8.2"
redis = "^4.1.4"
redis = "^5.0.2"
uvicorn = "0.16.0"

[tool.poetry.extras]
aca-py = ["aries-cloudagent"]

[tool.poetry.dev-dependencies]
ruff = "^0.1.2"
ruff = "^0.3.0"
black = "23.7.0"
asynctest = "0.13.0"
pytest = "~7.4.0"
pytest-asyncio = "0.14.0"
pytest-cov = "2.10.1"
pytest-ruff = "^0.1.1"
pytest-ruff = "^0.3"
mock= "~4.0"
pre-commit = "^2.12.1"
pytest-mock = "^3.6.1"
Expand Down
21 changes: 13 additions & 8 deletions redis_events/redis_events/v1_0/redis_queue/events/__init__.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -4,6 +4,7 @@
import json
import logging
import re
import time
from string import Template
from typing import Any, Optional, cast

Expand Down Expand Up @@ -88,7 +89,7 @@ async def handle_event(profile: Profile, event: EventWithMetadata):
if not redis:
redis = await redis_setup(profile, event)

LOGGER.info("Handling event: %s", event)
LOGGER.debug("Handling event: %s", event)
wallet_id = cast(Optional[str], profile.settings.get("wallet.id"))
try:
event_payload = process_event_payload(event.payload)
Expand All @@ -112,14 +113,18 @@ async def handle_event(profile: Profile, event: EventWithMetadata):
config_events = get_config(profile.settings).event or EventConfig.default()
template = config_events.event_topic_maps[event.metadata.pattern.pattern]
redis_topic = Template(template).substitute(**payload)
LOGGER.info(f"Sending message {payload} with topic {redis_topic}")
LOGGER.debug(f"Sending message {payload} with topic {redis_topic}")

origin = profile.settings.get("default_label")

metadata = {"time_ns": time.time_ns()}
metadata_wallet_id = {"x-wallet-id": wallet_id} if wallet_id else {}
metadata_origin = {"origin": origin} if origin else {}
metadata.update(metadata_wallet_id)
metadata.update(metadata_origin)

outbound = str.encode(
json.dumps(
{
"payload": payload,
"metadata": {"x-wallet-id": wallet_id} if wallet_id else {},
}
),
json.dumps({"payload": payload, "metadata": metadata}),
)
await redis.rpush(
redis_topic,
Expand Down
Loading