Merge pull request #1304 from Anthony-19/feat/add_request

Feat/add request

Author: leojay-net

Dechat/dex_with_fiat_frontend/src/app/api/webhook/route.ts

@@ -166,24 +166,25 @@ export async function POST(request: NextRequest) {
     // Handle different event types
     switch (event.event) {
       case 'transfer.success': {
-        const existingRecord = getTransferStatus(event.data.reference);
+        const data = event.data ?? {};
+        const existingRecord = getTransferStatus(data.reference ?? '');
         const updatedAt = new Date().toISOString();
         telemetry.addLog(span.spanId, 'info', 'Processing transfer success', {
-          reference: event.data.reference,
-          amount: event.data.amount,
-          recipient: event.data.recipient,
-          status: event.data.status,
+          reference: data.reference,
+          amount: data.amount,
+          recipient: data.recipient,
+          status: data.status,
         });
         console.log('Transfer successful:', {
-          reference: event.data.reference,
-          amount: event.data.amount,
-          recipient: event.data.recipient,
-          status: event.data.status,
+          reference: data.reference,
+          amount: data.amount,
+          recipient: data.recipient,
+          status: data.status,
         });
         const nextRecord = setTransferStatus({
-          reference: event.data.reference,
+          reference: data.reference ?? '',
           status: 'success',
-          amount: event.data.amount,
+          amount: data.amount,
           updatedAt,
           clientSessionId: existingRecord?.clientSessionId,
         });
@@ -197,27 +198,28 @@ export async function POST(request: NextRequest) {
       }
 
       case 'transfer.failed': {
-        const existingRecord = getTransferStatus(event.data.reference);
+        const data = event.data ?? {};
+        const existingRecord = getTransferStatus(data.reference ?? '');
         const updatedAt = new Date().toISOString();
         telemetry.addLog(span.spanId, 'warn', 'Processing transfer failure', {
-          reference: event.data.reference,
-          amount: event.data.amount,
-          recipient: event.data.recipient,
-          status: event.data.status,
-          failureReason: event.data.failure_reason,
+          reference: data.reference,
+          amount: data.amount,
+          recipient: data.recipient,
+          status: data.status,
+          failureReason: data.failure_reason,
         });
         console.log('Transfer failed:', {
-          reference: event.data.reference,
-          amount: event.data.amount,
-          recipient: event.data.recipient,
-          status: event.data.status,
-          failure_reason: event.data.failure_reason,
+          reference: data.reference,
+          amount: data.amount,
+          recipient: data.recipient,
+          status: data.status,
+          failure_reason: data.failure_reason,
         });
         const nextRecord = setTransferStatus({
-          reference: event.data.reference,
+          reference: data.reference ?? '',
           status: 'failed',
-          amount: event.data.amount,
-          failureReason: event.data.failure_reason,
+          amount: data.amount,
+          failureReason: data.failure_reason,
           updatedAt,
           clientSessionId: existingRecord?.clientSessionId,
         });
@@ -232,24 +234,25 @@ export async function POST(request: NextRequest) {
       }
 
       case 'transfer.reversed': {
-        const existingRecord = getTransferStatus(event.data.reference);
+        const data = event.data ?? {};
+        const existingRecord = getTransferStatus(data.reference ?? '');
         const updatedAt = new Date().toISOString();
         telemetry.addLog(span.spanId, 'info', 'Processing transfer reversal', {
-          reference: event.data.reference,
-          amount: event.data.amount,
-          recipient: event.data.recipient,
-          status: event.data.status,
+          reference: data.reference,
+          amount: data.amount,
+          recipient: data.recipient,
+          status: data.status,
         });
         console.log('Transfer reversed:', {
-          reference: event.data.reference,
-          amount: event.data.amount,
-          recipient: event.data.recipient,
-          status: event.data.status,
+          reference: data.reference,
+          amount: data.amount,
+          recipient: data.recipient,
+          status: data.status,
         });
         const nextRecord = setTransferStatus({
-          reference: event.data.reference,
+          reference: data.reference ?? '',
           status: 'reversed',
-          amount: event.data.amount,
+          amount: data.amount,
           updatedAt,
           clientSessionId: existingRecord?.clientSessionId,
         });

Dechat/dex_with_fiat_frontend/src/components/Message.tsx

@@ -148,6 +148,12 @@ export default function Message({ message, onActionClick, onRetry, shouldAnimate
   // Safely parse the timestamp — guards against deserialized string values
   const timestamp = toDate(message.timestamp);
 
+  const handleMessageKeyDown = (e: React.KeyboardEvent<HTMLDivElement>) => {
+    if (hasError && e.key === 'r' && !e.ctrlKey && !e.metaKey) {
+      retry.retryNow();
+    }
+  };
+
   return (
     <motion.div
       data-testid="message"

Dechat/dex_with_fiat_frontend/src/components/__tests__/TransactionAmountDisplay.test.tsx

@@ -179,8 +179,8 @@ describe('TransactionAmountDisplay - Framer Motion Animations', () => {
   afterEach(cleanup);
 
   it('renders with motion.div wrapper for container animation', () => {
-    const { container } = render(<TransactionAmountDisplay amount={100} asset="XLM" />);
-    const wrapper = container.querySelector('.flex.flex-col');
+    render(<TransactionAmountDisplay amount={100} asset="XLM" />);
+    const wrapper = document.querySelector('.flex.flex-col');
     expect(wrapper).toBeInTheDocument();
   });
 

Dechat/dex_with_fiat_frontend/src/hooks/useChatHistory.test.ts

@@ -125,9 +125,6 @@ describe('Thread pinning ordering', () => {
 //    after the closure was captured would be invisible to the lookup.
 //    Fix: reads from `sessionsRef.current` which is kept current via a
 //    synchronous ref-update effect.
-//
-// Because these are pure-logic tests (no React rendering required) they
-// replicate the core logic inline and verify the corrected behaviour.
 
 describe('Race-condition fix: updateCurrentSession functional updater (#1213)', () => {
   it('update is a no-op when currentSessionId is null in latest state', () => {
@@ -202,8 +199,10 @@ describe('Race-condition fix: loadSession uses sessionsRef (#1213)', () => {
     // Callback captured here with empty sessions
     expect(loadSession('new')).toBeNull();
 
-    // Session added later — ref is updated synchronously (as the useEffect does)
-    sessionsRef.current = [{ id: 'new', messages: ['hi'] }];
+describe('updateCurrentSession guard reads fresh state (regression #1223)', () => {
+  beforeEach(() => {
+    vi.clearAllMocks();
+  });
 
     // Now loadSession finds it, despite being "captured" before it existed
     const found = loadSession('new');
@@ -235,3 +234,26 @@ describe('Race-condition fix: loadSession uses sessionsRef (#1213)', () => {
     expect(nextState).toBe(state);
   });
 });
+
+describe('Race-condition fix: loadSession uses sessionsRef (#1213)', () => {
+  it('lookup finds a session added after the callback was captured', () => {
+    // Simulate sessionsRef — always points to latest sessions array
+    const sessionsRef = { current: [] as { id: string; messages: string[] }[] };
+
+    // Simulate the fixed loadSession using sessionsRef
+    const loadSession = (sessionId: string) => {
+      return sessionsRef.current.find((s) => s.id === sessionId) ?? null;
+    };
+
+    // Callback captured here with empty sessions
+    expect(loadSession('new')).toBeNull();
+
+    // Session added later — ref is updated synchronously (as the useEffect does)
+    sessionsRef.current = [{ id: 'new', messages: ['hi'] }];
+
+    // Now loadSession finds it, despite being "captured" before it existed
+    const found = loadSession('new');
+    expect(found).not.toBeNull();
+    expect(found?.messages).toEqual(['hi']);
+  });
+});

Dechat/dex_with_fiat_frontend/src/hooks/useChatHistory.ts

@@ -39,7 +39,7 @@ export const useChatHistory = () => {
     }
   }, [historyState]);
 
-  // Debounced search — avoids triggering a lookup on every keystroke
+  // Debounced search - avoids triggering a lookup on every keystroke
   useEffect(() => {
     if (!searchQuery.trim()) {
       setSearchResults([]);
@@ -87,7 +87,7 @@ export const useChatHistory = () => {
       // `historyState.currentSessionId` from the closure, which could be stale
       // if multiple state updates were in-flight. The early-return guard has
       // been moved inside the functional updater so it always sees the latest
-      // committed state — no stale snapshot can cause a phantom update or a
+      // committed state - no stale snapshot can cause a phantom update or a
       // missed guard.
       setHistoryState((prev) => {
         // Guard inside the functional updater so it always reads fresh state,

Dechat/dex_with_fiat_frontend/src/lib/chatTelemetry.ts

@@ -95,17 +95,8 @@ export interface NetworkStatusTelemetryPayload {
   source: 'initial' | 'browser-event' | 'connectivity-check';
 }
 
-/** Split-view (two-thread comparison panel) interactions. */
-export type SplitViewTelemetryAction =
-  | 'open'
-  | 'close'
-  | 'set_left_session'
-  | 'set_right_session'
-  | 'swap_sessions'
-  | 'select_message';
-
 export interface SplitViewTelemetryPayload {
-  action: SplitViewTelemetryAction;
+  action: 'open' | 'close' | 'set_left_session' | 'set_right_session' | 'swap_sessions' | 'select_message';
   leftSessionId?: string | null;
   rightSessionId?: string | null;
 }
@@ -493,17 +484,6 @@ export const chatTelemetry = {
     emit('network_status', payload);
   },
 
-  /**
-   * Emit a `split_view` event recording an interaction with the two-thread
-   * comparison panel (open/close/swap/session-select). Issue #1208: gives
-   * product/analytics visibility into how often split view is used and
-   * which actions are most common, using the same consent-gated, batched
-   * `chatTelemetry` pipeline as every other chat event.
-   */
-  splitView(payload: SplitViewTelemetryPayload): void {
-    emit('split_view', payload);
-  },
-
   /**
    * Emit an `avatar_color_check` event that records whether the avatar
    * foreground/background colour pair meets WCAG AA contrast (4.5:1).
@@ -518,4 +498,8 @@ export const chatTelemetry = {
   avatarColorCheck(payload: AvatarColorTelemetryPayload): void {
     emit('avatar_color_check', payload);
   },
+
+  splitView(payload: SplitViewTelemetryPayload): void {
+    emit('split_view', payload);
+  },
 };