PHP WebShell

Текущая директория: /usr/lib/node_modules/bitgo/node_modules/metro-file-map/src

Просмотр файла: worker.js.flow

/**
 * Copyright (c) Meta Platforms, Inc. and affiliates.
 *
 * This source code is licensed under the MIT license found in the
 * LICENSE file in the root directory of this source tree.
 *
 * @flow strict-local
 * @format
 */

/* eslint-disable import/no-commonjs */

/*::
import type {
  DependencyExtractor,
  WorkerMessage,
  WorkerMetadata,
  WorkerSetupArgs,
} from './flow-types';
*/

'use strict';

const defaultDependencyExtractor = require('./lib/dependencyExtractor');
const excludedExtensions = require('./workerExclusionList');
const {createHash} = require('crypto');
const fs = require('graceful-fs');
const path = require('path');

const PACKAGE_JSON = path.sep + 'package.json';

let hasteImpl /*: ?{getHasteName: string => ?string} */ = null;
let hasteImplModulePath /*: ?string */ = null;

function getHasteImpl(
  requestedModulePath /*: string */,
) /*: {getHasteName: string => ?string} */ {
  if (hasteImpl) {
    if (requestedModulePath !== hasteImplModulePath) {
      throw new Error('metro-file-map: hasteImplModulePath changed');
    }
    return hasteImpl;
  }
  hasteImplModulePath = requestedModulePath;
  // $FlowFixMe[unsupported-syntax] - dynamic require
  hasteImpl = require(hasteImplModulePath);
  return hasteImpl;
}

function sha1hex(content /*: string | Buffer */) /*: string */ {
  return createHash('sha1').update(content).digest('hex');
}

class Worker {
  constructor(args /*: WorkerSetupArgs */) {}

  processFile(data /*: WorkerMessage */) /*: WorkerMetadata */ {
    let content /*: ?Buffer */;
    let dependencies /*: WorkerMetadata['dependencies'] */;
    let id /*: WorkerMetadata['id'] */;
    let sha1 /*: WorkerMetadata['sha1'] */;

    const {computeDependencies, computeSha1, enableHastePackages, filePath} =
      data;

    const getContent = () /*: Buffer */ => {
      if (content == null) {
        content = fs.readFileSync(filePath);
      }

      return content;
    };

    if (enableHastePackages && filePath.endsWith(PACKAGE_JSON)) {
      // Process a package.json that is returned as a PACKAGE type with its name.
      try {
        const fileData = JSON.parse(getContent().toString());

        if (fileData.name) {
          id = fileData.name;
        }
      } catch (err) {
        throw new Error(`Cannot parse ${filePath} as JSON: ${err.message}`);
      }
    } else if (
      (data.hasteImplModulePath != null || computeDependencies) &&
      !excludedExtensions.has(filePath.substr(filePath.lastIndexOf('.')))
    ) {
      // Process a random file that is returned as a MODULE.
      if (data.hasteImplModulePath != null) {
        id = getHasteImpl(data.hasteImplModulePath).getHasteName(filePath);
      }

      if (computeDependencies) {
        const dependencyExtractor /*: ?DependencyExtractor */ =
          data.dependencyExtractor != null
            ? // $FlowFixMe[unsupported-syntax] - dynamic require
              require(data.dependencyExtractor)
            : null;

        dependencies = Array.from(
          dependencyExtractor != null
            ? dependencyExtractor.extract(
                getContent().toString(),
                filePath,
                defaultDependencyExtractor.extract,
              )
            : defaultDependencyExtractor.extract(getContent().toString()),
        );
      }
    }

    // If a SHA-1 is requested on update, compute it.
    if (computeSha1) {
      sha1 = sha1hex(getContent());
    }

    return content && data.maybeReturnContent
      ? {content, dependencies, id, sha1}
      : {dependencies, id, sha1};
  }
}

let singletonWorker;

function setup(args /*: WorkerSetupArgs */) /*: void */ {
  if (singletonWorker) {
    throw new Error('metro-file-map: setup() should only be called once');
  }
  singletonWorker = new Worker(args);
}

function processFile(data /*: WorkerMessage */) /*: WorkerMetadata */ {
  if (!singletonWorker) {
    throw new Error(
      'metro-file-map: setup() must be called before processFile()',
    );
  }
  return singletonWorker.processFile(data);
}

module.exports = {
  /**
   * Called automatically by jest-worker before the first call to `worker` when
   * this module is used as worker thread or child process.
   */
  setup,
  /**
   * Called by jest-worker with each workload
   */
  processFile,
  /**
   * Exposed for use outside a jest-worker context, ie when processing in-band.
   */
  Worker,
};

Выполнить команду

Для локальной разработки. Не используйте в интернете!