Merge pull request #811 from CAFECA-IO/bug/switch_ticker

Bug/switch ticker

src/contexts/market_context.tsx

@@ -265,7 +265,6 @@ export const MarketProvider = ({children}: IMarketProvider) => {
     const ticker: ITickerData = availableTickersRef.current[tickerId];
     if (!ticker) return {...defaultResultFailed};
     setSelectedTicker(ticker);
-    notificationCtx.emitter.emit(TideBitEvent.TICKER_CHANGE, ticker);
     await listMarketTrades(ticker.instId);
     syncCandlestickData();
     // ++ TODO: get from api
@@ -278,6 +277,7 @@ export const MarketProvider = ({children}: IMarketProvider) => {
     if (isGetTickerLiveStatisticsSuccess)
       setTickerLiveStatistics(tickerLiveStatistics as ITickerLiveStatistics);
     await getGuaranteedStopFeePercentage(ticker.instId);
+    notificationCtx.emitter.emit(TideBitEvent.TICKER_CHANGE, ticker);
     return {...defaultResultSuccess};
   };
 
@@ -570,8 +570,8 @@ export const MarketProvider = ({children}: IMarketProvider) => {
   const init = async () => {
     await getTideBitPromotion();
     await getWebsiteReserve();
-    await listTickers();
     await listCurrencies();
+    await listTickers();
     setIsCFDTradable(true);
     return await Promise.resolve();
   };

src/contexts/user_context.tsx

@@ -1642,10 +1642,10 @@ export const UserProvider = ({children}: IUserProvider) => {
   );
   React.useMemo(
     () =>
-      notificationCtx.emitter.on(TideBitEvent.TICKER_CHANGE, (ticker: ITickerData) => {
+      notificationCtx.emitter.on(TideBitEvent.TICKER_CHANGE, async (ticker: ITickerData) => {
         if (!selectedTickerRef.current || ticker.instId !== selectedTickerRef.current?.instId) {
           setSelectedTicker(ticker);
-          listCFDs(ticker?.currency);
+          await listCFDs(ticker?.currency);
         }
       }),
     []

src/contexts/worker_context.tsx

@@ -57,7 +57,7 @@ export const WorkerProvider = ({children}: IWorkerProvider) => {
   const [publicChannel, setPublicChannel, publicChannelRef] = useState<Channel | null>(null);
   const jobQueueOfWS = useRef<((...args: []) => Promise<void>)[]>([]);
   const jobQueueOfAPI = useRef<((...args: []) => Promise<void>)[]>([]);
-  const [sockedId, setSocketId, sockedIdRef] = useState<string | null>(null);
+  const [socketId, setSocketId, socketIdRef] = useState<string | null>(null);
   /* Deprecated: callback in requestHandler (Tzuhan - 20230420)
   const requests = useRef<IRequest>({});
   */
@@ -139,19 +139,10 @@ export const WorkerProvider = ({children}: IWorkerProvider) => {
         },
       },
     });
-    // eslint-disable-next-line no-console
-    console.log('pusher', pusher);
-    setPuser(pusher);
     pusher.connection.bind('connected', function () {
       const socketId = pusher.connection.socket_id;
-      // Deprecated: [debug] (20230523 - tzuhan)
-      // eslint-disable-next-line no-console
-      console.log('pusher My socket ID is ' + socketId);
-      setSocketId(sockedId);
+      setSocketId(socketId);
       const channel = pusherRef.current?.subscribe(PusherChannel.GLOBAL_CHANNEL);
-      // Deprecated: [debug] (20230523 - tzuhan)
-      // eslint-disable-next-line no-console
-      console.log('channel ', channel);
       if (channel) {
         setPublicChannel(channel);
         subscribeTickers();

src/pages/trade/cfd/[tickerId].tsx

@@ -47,10 +47,10 @@ const Trading = (props: IPageProps) => {
     }
   }, []);
 
-  useEffect(() => {
-    if ((marketCtx?.selectedTickerRef?.current?.currency?.toString() ?? '') === currency) return;
-    redirectToTicker();
-  }, [marketCtx.availableTickers]);
+  // useEffect(() => {
+  //   if ((marketCtx?.selectedTickerRef?.current?.currency?.toString() ?? '') === currency) return;
+  //   redirectToTicker();
+  // }, [marketCtx.availableTickers]);
 
   if (!router.isFallback && !props.tickerId) {
     return <Error statusCode={404} />;