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-dev): Bump pytest-ruff from 0.1.1 to 0.3.1 in /oid4vci #93

Closed
wants to merge 7 commits into from
Closed

chore(deps-dev): Bump pytest-ruff from 0.1.1 to 0.3.1 in /oid4vci #93

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
7 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
2cf661d
:sparkles: add group_id to metadata (#73)
ff137 Mar 11, 2024
4af401b
chore(deps-dev): Bump pytest-ruff from 0.1.1 to 0.3.1 in /oid4vci
dependabot[bot] Mar 11, 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
11 changes: 6 additions & 5 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 @@ -26,7 +26,7 @@ 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.1"

# testing
mock= "~4.0"
Expand Down
739 changes: 331 additions & 408 deletions redis_events/integration/poetry.lock
View file
Open in desktop

Large diffs are not rendered by default.

6 changes: 3 additions & 3 deletions redis_events/integration/pyproject.toml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -11,11 +11,11 @@ pytest-asyncio = "^0.21.0"
asynctest = "^0.13.0"
requests = "^2.31.0"
aiohttp = "^3.7.4"
aries-cloudagent = { version = ">=0.10.3, < 1.0.0" }
fastapi = "^0.109.1"
aries-cloudagent = { version = "0.11.0" }
fastapi = "^0.109.2"
nest-asyncio = "^1.5.5"
pydantic = "^1.8.2"
redis = "^4.1.4"
redis = "^5.0.3"
uvicorn = "0.16.0"

[tool.poetry.dev-dependencies]
Expand Down
921 changes: 423 additions & 498 deletions redis_events/poetry.lock
View file
Open in desktop

Large diffs are not rendered by default.

10 changes: 5 additions & 5 deletions redis_events/pyproject.toml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -9,25 +9,25 @@ python = "^3.9"

# Define ACA-Py as an optional/extra dependancy so it can be
# explicitly installed with the plugin if desired.
aries-cloudagent = { version = ">=0.10.3, < 1.0.0", optional = true }
aries-cloudagent = { version = "0.11.0", optional = true }
aiohttp = "^3.7.4"
fastapi = "^0.109.2"
nest-asyncio = "^1.5.5"
pydantic = "^1.8.2"
redis = "^4.1.4"
redis = "^5.0.3"
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-asyncio = "^0.21.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
24 changes: 16 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,21 @@ 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")
group_id = profile.settings.get("wallet.group_id")

metadata = {"time_ns": time.time_ns()}
metadata_wallet_id = {"x-wallet-id": wallet_id} if wallet_id else {}
metadata_group_id = {"group_id": group_id} if group_id else {}
metadata_origin = {"origin": origin} if origin else {}
metadata.update(metadata_wallet_id)
metadata.update(metadata_group_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