Skip to content

Commit

Permalink
Merge pull request #244 from sktston/revert-240-feature/add-log
Browse files Browse the repository at this point in the history
Revert "Add log"
  • Loading branch information
baegjae authored Feb 17, 2024
2 parents 2357449 + 5ae3097 commit f954c9c
Show file tree
Hide file tree
Showing 2 changed files with 0 additions and 23 deletions.
13 changes: 0 additions & 13 deletions aries_cloudagent/core/dispatcher.py
Original file line number Diff line number Diff line change
Expand Up @@ -216,9 +216,6 @@ async def handle_message(
outcome="Dispatcher.handle_message.START",
)

if "connections/1.0/request" in inbound_message.receipt.raw_message:
LOGGER.info("TEMP_LOG_0629 " + "start handle_message")

context = RequestContext(profile)
context.message = message
context.message_receipt = inbound_message.receipt
Expand All @@ -233,26 +230,19 @@ async def handle_message(

context.injector.bind_instance(BaseResponder, responder)

if "connections/1.0/request" in inbound_message.receipt.raw_message:
LOGGER.info("TEMP_LOG_0629 " + "after responder")

# When processing oob attach message we supply the connection id
# associated with the inbound message
if inbound_message.connection_id:
async with self.profile.session() as session:
connection = await ConnRecord.retrieve_by_id(
session, inbound_message.connection_id
)
if "connections/1.0/request" in inbound_message.receipt.raw_message:
LOGGER.info("TEMP_LOG_0629 " + "after retrieve_by_id")
else:
connection_mgr = ConnectionManager(profile)
connection = await connection_mgr.find_inbound_connection(
inbound_message.receipt
)
del connection_mgr
if "connections/1.0/request" in inbound_message.receipt.raw_message:
LOGGER.info("TEMP_LOG_0629 " + "after find_inbound_connection")

if connection:
inbound_message.connection_id = connection.connection_id
Expand All @@ -274,9 +264,6 @@ async def handle_message(
handler = self.collector.wrap_coro(handler, [handler.__qualname__])
await handler(context, responder)

if "connections/1.0/request" in inbound_message.receipt.raw_message:
LOGGER.info("TEMP_LOG_0629 " + "after handle")

trace_event(
self.profile.settings,
context.message,
Expand Down
10 changes: 0 additions & 10 deletions aries_cloudagent/protocols/connections/v1_0/manager.py
Original file line number Diff line number Diff line change
Expand Up @@ -38,7 +38,6 @@
from .messages.problem_report import ProblemReportReason
from .models.connection_detail import ConnectionDetail

LOGGER = logging.getLogger(__name__)

class ConnectionManagerError(BaseError):
"""Connection error."""
Expand Down Expand Up @@ -1174,9 +1173,6 @@ async def resolve_inbound_connection(self, receipt: MessageReceipt) -> ConnRecor
"""

if "connections/1.0/request" in receipt.raw_message:
LOGGER.info("TEMP_LOG_0629 " + "start resolve_inbound_connection")

if receipt.sender_verkey:
try:
receipt.sender_did = await self.find_did_for_key(receipt.sender_verkey)
Expand All @@ -1187,9 +1183,6 @@ async def resolve_inbound_connection(self, receipt: MessageReceipt) -> ConnRecor
receipt.sender_verkey,
)

if "connections/1.0/request" in receipt.raw_message:
LOGGER.info("TEMP_LOG_0629 " + "after find_did_for_key")

# # SKT: temp, skip issuers that use non-public invitation
# if receipt.recipient_verkey:
issuer_list_non_public = ["1957", "2848"]
Expand Down Expand Up @@ -1221,9 +1214,6 @@ async def resolve_inbound_connection(self, receipt: MessageReceipt) -> ConnRecor
receipt.recipient_verkey,
)

if "connections/1.0/request" in receipt.raw_message:
LOGGER.info("TEMP_LOG_0629 " + "after get_local_did_for_verkey")

return await self.find_connection(
receipt.sender_did, receipt.recipient_did, receipt.recipient_verkey, True
)
Expand Down

0 comments on commit f954c9c

Please sign in to comment.