Skip to content

Commit ae741f8

Browse files
committed
feat: add started_at and payflow query parameters to base handler
- Initialize started_at from query string for duration tracking - Initialize payflow from query string for x402 payment flow - These fields are forwarded from Kong gateway for API usage recording
1 parent 56f0f49 commit ae741f8

1 file changed

Lines changed: 13 additions & 0 deletions

File tree

  • acedatacloud_scaffold/handlers

acedatacloud_scaffold/handlers/base.py

Lines changed: 13 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -145,11 +145,24 @@ def initialize_task_id(self):
145145
self.task_id = str(uuid4())
146146
logger.debug(f'task id {self.task_id}')
147147

148+
def initialize_started_at(self):
149+
started_at = self.request.query_arguments.get('started_at')
150+
self.started_at = started_at[0].decode(
151+
'utf-8') if started_at and len(started_at) > 0 else None
152+
logger.debug(f'started_at {self.started_at}')
153+
154+
def initialize_payflow(self):
155+
payflow = self.request.query_arguments.get('payflow')
156+
self.payflow = payflow[0].decode(
157+
'utf-8') if payflow and len(payflow) > 0 else None
158+
logger.debug(f'payflow {self.payflow}')
159+
148160
def initialize(self):
149161
self.initialize_trace_id()
150162
self.initialize_task_id()
151163
self.initialize_application_id()
152164
self.initialize_api_id()
153165
self.initialize_user_id()
154166
self.initialize_credential_id()
167+
self.initialize_started_at()
155168
self.initialize_payflow()

0 commit comments

Comments
 (0)