| const packages = [ |
| 'micropip', |
| 'packaging', |
| 'requests', |
| 'beautifulsoup4', |
| 'numpy', |
| 'pandas', |
| 'matplotlib', |
| 'scikit-learn', |
| 'scipy', |
| 'regex', |
| 'sympy', |
| 'tiktoken', |
| 'seaborn', |
| 'pytz', |
| 'black', |
| 'openai' |
| ]; |
|
|
| import { loadPyodide } from 'pyodide'; |
| import { setGlobalDispatcher, ProxyAgent } from 'undici'; |
| import { writeFile, readFile, copyFile, readdir, rmdir } from 'fs/promises'; |
|
|
| |
| |
| |
| |
| function initNetworkProxyFromEnv() { |
| |
| |
| |
| |
| const allProxy = process.env.all_proxy || process.env.ALL_PROXY; |
| const httpsProxy = process.env.https_proxy || process.env.HTTPS_PROXY; |
| const httpProxy = process.env.http_proxy || process.env.HTTP_PROXY; |
| const preferedProxy = httpsProxy || allProxy || httpProxy; |
| |
| |
| |
| |
| if (!preferedProxy || !preferedProxy.startsWith('http')) return; |
| let preferedProxyURL; |
| try { |
| preferedProxyURL = new URL(preferedProxy).toString(); |
| } catch { |
| console.warn(`Invalid network proxy URL: "${preferedProxy}"`); |
| return; |
| } |
| const dispatcher = new ProxyAgent({ uri: preferedProxyURL }); |
| setGlobalDispatcher(dispatcher); |
| console.log(`Initialized network proxy "${preferedProxy}" from env`); |
| } |
|
|
| async function downloadPackages() { |
| console.log('Setting up pyodide + micropip'); |
|
|
| let pyodide; |
| try { |
| pyodide = await loadPyodide({ |
| packageCacheDir: 'static/pyodide' |
| }); |
| } catch (err) { |
| console.error('Failed to load Pyodide:', err); |
| return; |
| } |
|
|
| const packageJson = JSON.parse(await readFile('package.json')); |
| const pyodideVersion = packageJson.dependencies.pyodide.replace('^', ''); |
|
|
| try { |
| const pyodidePackageJson = JSON.parse(await readFile('static/pyodide/package.json')); |
| const pyodidePackageVersion = pyodidePackageJson.version.replace('^', ''); |
|
|
| if (pyodideVersion !== pyodidePackageVersion) { |
| console.log('Pyodide version mismatch, removing static/pyodide directory'); |
| await rmdir('static/pyodide', { recursive: true }); |
| } |
| } catch (err) { |
| console.log('Pyodide package not found, proceeding with download.', err); |
| } |
|
|
| try { |
| console.log('Loading micropip package'); |
| await pyodide.loadPackage('micropip'); |
|
|
| const micropip = pyodide.pyimport('micropip'); |
| console.log('Downloading Pyodide packages:', packages); |
|
|
| try { |
| for (const pkg of packages) { |
| console.log(`Installing package: ${pkg}`); |
| await micropip.install(pkg); |
| } |
| } catch (err) { |
| console.error('Package installation failed:', err); |
| return; |
| } |
|
|
| console.log('Pyodide packages downloaded, freezing into lock file'); |
|
|
| try { |
| const lockFile = await micropip.freeze(); |
| await writeFile('static/pyodide/pyodide-lock.json', lockFile); |
| } catch (err) { |
| console.error('Failed to write lock file:', err); |
| } |
| } catch (err) { |
| console.error('Failed to load or install micropip:', err); |
| } |
| } |
|
|
| async function copyPyodide() { |
| console.log('Copying Pyodide files into static directory'); |
| |
| for await (const entry of await readdir('node_modules/pyodide')) { |
| await copyFile(`node_modules/pyodide/${entry}`, `static/pyodide/${entry}`); |
| } |
| } |
|
|
| initNetworkProxyFromEnv(); |
| await downloadPackages(); |
| await copyPyodide(); |
|
|