Files
zeekay 507a7da852 fix(realtime): swap Phoenix WebSocket transport for backend SSE
The FE connected realtime via Phoenix Channels (wss .../socket/v2), but the
Go backend serves no Phoenix endpoint — its realtime is SSE at
/v1/base/realtime (envelope {event,chain,data}). Result: repeating ws 404 ->
'Live updates temporarily delayed'.

lib/socket/sse.ts reimplements the slice of the Phoenix Socket/Channel API the
27 realtime consumers use, backed by one EventSource, behind the existing
SocketProvider/useSocketChannel/useSocketMessage seam — no consumer changes.
Envelope routes via an optional topic field or a hub-channel translation table
(blocks -> blocks:new_block/new_block today). CT harness becomes a tiny SSE
server with the same signatures. 12 vitest cases cover it.

Frontend-only; chain/indexer untouched. Data freshness remains gated on the
separate C-Chain-rollback/indexer-reorg owner items.
2026-06-28 09:01:10 -07:00

134 lines
5.4 KiB
TypeScript

import type { UseQueryResult } from '@tanstack/react-query';
import { useRouter } from 'next/router';
import React from 'react';
import type { Address } from 'types/api/address';
import type { AddressImplementation } from 'types/api/addressParams';
import type { SmartContract } from 'types/api/contract';
import type { ResourceError } from 'lib/api/resources';
import useApiQuery from 'lib/api/useApiQuery';
import { useMultichainContext } from 'lib/contexts/multichain';
import getQueryParamString from 'lib/router/getQueryParamString';
import type { Channel } from 'lib/socket/sse';
import * as stubs from 'stubs/contract';
import RoutedTabs from 'toolkit/components/RoutedTabs/RoutedTabs';
import DataFetchAlert from 'ui/shared/DataFetchAlert';
import ContractDetailsAlerts from './alerts/ContractDetailsAlerts';
import ContractSourceAddressSelector from './ContractSourceAddressSelector';
import ContractDetailsInfo from './info/ContractDetailsInfo';
import ContractDetailsInfoCreator from './info/ContractDetailsInfoCreator';
import ContractDetailsInfoImplementations from './info/ContractDetailsInfoImplementations';
import useContractDetailsTabs from './useContractDetailsTabs';
const TAB_LIST_PROPS = { className: 'flex-wrap gap-y-2' };
const LEFT_SLOT_PROPS = { className: 'w-full lg:w-auto' };
type Props = {
addressData: Address;
channel: Channel | undefined;
mainContractQuery: UseQueryResult<SmartContract, ResourceError>;
};
const ContractDetails = ({ addressData, channel, mainContractQuery }: Props) => {
const router = useRouter();
const sourceAddress = getQueryParamString(router.query.source_address);
const multichainContext = useMultichainContext();
const sourceItems: Array<AddressImplementation> = React.useMemo(() => {
const currentAddressDefaultName = addressData?.proxy_type === 'eip7702' ? 'Current address' : 'Current contract';
const currentAddressItem = { address_hash: addressData.hash, name: addressData?.name || currentAddressDefaultName };
if (!addressData || !addressData.implementations || addressData.implementations.length === 0) {
return [ currentAddressItem ];
}
return [
currentAddressItem,
...(addressData?.implementations.filter((item) => item.address_hash !== addressData.hash && item.name) || []),
];
}, [ addressData ]);
const [ selectedItem, setSelectedItem ] = React.useState<AddressImplementation | undefined>(undefined);
React.useEffect(() => {
if (!mainContractQuery.isPlaceholderData) {
setSelectedItem(sourceItems.find((item) => item.address_hash === sourceAddress) || sourceItems[0]);
}
}, [ mainContractQuery.isPlaceholderData, sourceAddress, sourceItems ]);
const contractQuery = useApiQuery('general:contract', {
pathParams: { hash: selectedItem?.address_hash },
queryOptions: {
enabled: Boolean(selectedItem?.address_hash && !mainContractQuery.isPlaceholderData && selectedItem.address_hash !== addressData.hash),
refetchOnMount: false,
placeholderData: addressData?.is_verified ? stubs.CONTRACT_CODE_VERIFIED : stubs.CONTRACT_CODE_UNVERIFIED,
},
});
const { data, isPlaceholderData, isError } = selectedItem?.address_hash !== addressData.hash ? contractQuery : mainContractQuery;
const tabs = useContractDetailsTabs({ data, isLoading: isPlaceholderData, addressData, sourceAddress: selectedItem?.address_hash });
if (isError) {
return <DataFetchAlert/>;
}
const addressSelector = sourceItems.length > 1 && selectedItem ? (
<ContractSourceAddressSelector
isLoading={ mainContractQuery.isPlaceholderData }
label="Source code"
items={ sourceItems }
selectedItem={ selectedItem }
onItemSelect={ setSelectedItem }
className="lg:mr-8"
/>
) : null;
return (
<>
<ContractDetailsAlerts
data={ mainContractQuery.data }
isLoading={ mainContractQuery.isPlaceholderData }
addressData={ addressData }
channel={ channel }
/>
{ mainContractQuery.data?.is_verified && (
<ContractDetailsInfo
data={ mainContractQuery.data }
isLoading={ mainContractQuery.isPlaceholderData }
addressData={ addressData }
/>
) }
{ !mainContractQuery.data?.is_verified && multichainContext && (
<div className="grid grid-cols-[auto_1fr] lg:grid-cols-[auto_1fr_auto_1fr] gap-y-4 gap-x-3 mb-8 empty:hidden">
{ addressData.creator_address_hash && addressData.creation_transaction_hash && (
<ContractDetailsInfoCreator
addressHash={ addressData.creator_address_hash }
txHash={ addressData.creation_transaction_hash }
creationStatus={ addressData.creation_status }
isLoading={ mainContractQuery.isPlaceholderData }
/>
) }
{ addressData.implementations && addressData.implementations.length > 0 && !mainContractQuery.isPlaceholderData && (
<ContractDetailsInfoImplementations
implementations={ addressData.implementations }
proxyType={ addressData.proxy_type }
/>
) }
</div>
) }
<RoutedTabs
tabs={ tabs }
isLoading={ isPlaceholderData }
variant="segmented"
size="sm"
leftSlot={ addressSelector }
listProps={ TAB_LIST_PROPS }
leftSlotProps={ LEFT_SLOT_PROPS }
/>
</>
);
};
export default ContractDetails;