FM / pages

/opt/canhelp/node_modules/next/dist/esm/client/dev/hot-reloader/pages/

/opt/canhelp/node_modules/next/dist/esm/client/dev/hot-reloader/pages

Name	Size	Mode	Actions
hot-reloader-pages.js	16253	0644	edit dl rm
hot-reloader-pages.js.map	25671	0644	edit dl rm
websocket.js	3091	0644	edit dl rm
websocket.js.map	5383	0644	edit dl rm

Edit: /opt/canhelp/node_modules/next/dist/esm/client/dev/hot-reloader/pages/websocket.js.map (5383B)

{"version":3,"sources":["../../../../../src/client/dev/hot-reloader/pages/websocket.ts"],"sourcesContent":["import {\n  isTerminalLoggingEnabled,\n  logQueue,\n} from '../../../../next-devtools/userspace/app/forward-logs'\nimport {\n  HMR_ACTIONS_SENT_TO_BROWSER,\n  type HMR_ACTION_TYPES,\n} from '../../../../server/dev/hot-reloader-types'\nimport { getSocketUrl } from '../get-socket-url'\n\nlet source: WebSocket\n\ntype ActionCallback = (action: HMR_ACTION_TYPES) => void\n\nconst eventCallbacks: Array<ActionCallback> = []\n\nexport function addMessageListener(callback: ActionCallback) {\n  eventCallbacks.push(callback)\n}\n\nexport function sendMessage(data: string) {\n  if (!source || source.readyState !== source.OPEN) return\n  return source.send(data)\n}\n\nlet reconnections = 0\nlet reloading = false\nlet serverSessionId: number | null = null\n\nexport function connectHMR(options: { path: string; assetPrefix: string }) {\n  function init() {\n    if (source) source.close()\n\n    function handleOnline() {\n      if (isTerminalLoggingEnabled) {\n        logQueue.onSocketReady(source)\n      }\n      reconnections = 0\n      window.console.log('[HMR] connected')\n    }\n\n    function handleMessage(event: MessageEvent<string>) {\n      // While the page is reloading, don't respond to any more messages.\n      // On reconnect, the server may send an empty list of changes if it was restarted.\n      if (reloading) {\n        return\n      }\n\n      // Coerce into HMR_ACTION_TYPES as that is the format.\n      const msg: HMR_ACTION_TYPES = JSON.parse(event.data)\n\n      if (\n        'action' in msg &&\n        msg.action === HMR_ACTIONS_SENT_TO_BROWSER.TURBOPACK_CONNECTED\n      ) {\n        if (\n          serverSessionId !== null &&\n          serverSessionId !== msg.data.sessionId\n        ) {\n          // Either the server's session id has changed and it's a new server, or\n          // it's been too long since we disconnected and we should reload the page.\n          // There could be 1) unhandled server errors and/or 2) stale content.\n          // Perform a hard reload of the page.\n          window.location.reload()\n\n          reloading = true\n          return\n        }\n\n        serverSessionId = msg.data.sessionId\n      }\n\n      for (const eventCallback of eventCallbacks) {\n        eventCallback(msg)\n      }\n    }\n\n    let timer: ReturnType<typeof setTimeout>\n    function handleDisconnect() {\n      source.onerror = null\n      source.onclose = null\n      source.close()\n      reconnections++\n      // After 25 reconnects we'll want to reload the page as it indicates the dev server is no longer running.\n      if (reconnections > 25) {\n        reloading = true\n        window.location.reload()\n        return\n      }\n\n      clearTimeout(timer)\n      // Try again after 5 seconds\n      timer = setTimeout(init, reconnections > 5 ? 5000 : 1000)\n    }\n\n    const url = getSocketUrl(options.assetPrefix)\n\n    source = new window.WebSocket(`${url}${options.path}`)\n    source.onopen = handleOnline\n    source.onerror = handleDisconnect\n    source.onclose = handleDisconnect\n    source.onmessage = handleMessage\n  }\n\n  init()\n}\n"],"names":["isTerminalLoggingEnabled","logQueue","HMR_ACTIONS_SENT_TO_BROWSER","getSocketUrl","source","eventCallbacks","addMessageListener","callback","push","sendMessage","data","readyState","OPEN","send","reconnections","reloading","serverSessionId","connectHMR","options","init","close","handleOnline","onSocketReady","window","console","log","handleMessage","event","msg","JSON","parse","action","TURBOPACK_CONNECTED","sessionId","location","reload","eventCallback","timer","handleDisconnect","onerror","onclose","clearTimeout","setTimeout","url","assetPrefix","WebSocket","path","onopen","onmessage"],"mappings":"AAAA,SACEA,wBAAwB,EACxBC,QAAQ,QACH,uDAAsD;AAC7D,SACEC,2BAA2B,QAEtB,4CAA2C;AAClD,SAASC,YAAY,QAAQ,oBAAmB;AAEhD,IAAIC;AAIJ,MAAMC,iBAAwC,EAAE;AAEhD,OAAO,SAASC,mBAAmBC,QAAwB;IACzDF,eAAeG,IAAI,CAACD;AACtB;AAEA,OAAO,SAASE,YAAYC,IAAY;IACtC,IAAI,CAACN,UAAUA,OAAOO,UAAU,KAAKP,OAAOQ,IAAI,EAAE;IAClD,OAAOR,OAAOS,IAAI,CAACH;AACrB;AAEA,IAAII,gBAAgB;AACpB,IAAIC,YAAY;AAChB,IAAIC,kBAAiC;AAErC,OAAO,SAASC,WAAWC,OAA8C;IACvE,SAASC;QACP,IAAIf,QAAQA,OAAOgB,KAAK;QAExB,SAASC;YACP,IAAIrB,0BAA0B;gBAC5BC,SAASqB,aAAa,CAAClB;YACzB;YACAU,gBAAgB;YAChBS,OAAOC,OAAO,CAACC,GAAG,CAAC;QACrB;QAEA,SAASC,cAAcC,KAA2B;YAChD,mEAAmE;YACnE,kFAAkF;YAClF,IAAIZ,WAAW;gBACb;YACF;YAEA,sDAAsD;YACtD,MAAMa,MAAwBC,KAAKC,KAAK,CAACH,MAAMjB,IAAI;YAEnD,IACE,YAAYkB,OACZA,IAAIG,MAAM,KAAK7B,4BAA4B8B,mBAAmB,EAC9D;gBACA,IACEhB,oBAAoB,QACpBA,oBAAoBY,IAAIlB,IAAI,CAACuB,SAAS,EACtC;oBACA,uEAAuE;oBACvE,0EAA0E;oBAC1E,qEAAqE;oBACrE,qCAAqC;oBACrCV,OAAOW,QAAQ,CAACC,MAAM;oBAEtBpB,YAAY;oBACZ;gBACF;gBAEAC,kBAAkBY,IAAIlB,IAAI,CAACuB,SAAS;YACtC;YAEA,KAAK,MAAMG,iBAAiB/B,eAAgB;gBAC1C+B,cAAcR;YAChB;QACF;QAEA,IAAIS;QACJ,SAASC;YACPlC,OAAOmC,OAAO,GAAG;YACjBnC,OAAOoC,OAAO,GAAG;YACjBpC,OAAOgB,KAAK;YACZN;YACA,yGAAyG;YACzG,IAAIA,gBAAgB,IAAI;gBACtBC,YAAY;gBACZQ,OAAOW,QAAQ,CAACC,MAAM;gBACtB;YACF;YAEAM,aAAaJ;YACb,4BAA4B;YAC5BA,QAAQK,WAAWvB,MAAML,gBAAgB,IAAI,OAAO;QACtD;QAEA,MAAM6B,MAAMxC,aAAae,QAAQ0B,WAAW;QAE5CxC,SAAS,IAAImB,OAAOsB,SAAS,CAAC,AAAC,KAAEF,MAAMzB,QAAQ4B,IAAI;QACnD1C,OAAO2C,MAAM,GAAG1B;QAChBjB,OAAOmC,OAAO,GAAGD;QACjBlC,OAAOoC,OAAO,GAAGF;QACjBlC,OAAO4C,SAAS,GAAGtB;IACrB;IAEAP;AACF","ignoreList":[0]}

cmd: