How to use _mergeState method in Cypress

1import assert from 'power-assert'2import {Chan} from './chan'3import {arrayPool} from './pools'4import {TimeoutChan} from './special-chans'5import {CLOSED, FAILED, ERROR} from './constants'6import {SEND_TYPE_VALUE, SEND_TYPE_ERROR} from './constants'7import {P_RESOLVED_WITH_TRUE, P_RESOLVED_WITH_FALSE} from './constants'8import {EventEmitterMixin} from './event-emitter'9const CANNOT_SEND_ERROR_MSG = `Sending and piping into a merge channel, as well as converting ` +10  `it into a send-only chan, is not supported. As a workaround, you can add one more channel ` +11  `into the merged set, and send/pipe into it.`12const EMPTY = []13const STATE_AWAITING_SEND = 014const STATE_ENQUEUEING_TAKES = 115const STATE_AWAITING_TAKE = 216const STATE_MERGING_SYNC = 317const STATE_ENDED = 418const STATE_NAMES = [19  'STATE_AWAITING_SEND', 'STATE_ENQUEUEING_TAKES', 'STATE_AWAITING_TAKE',20  'STATE_MERGING_SYNC', 'STATE_ENDED'21]22export class MergeChan extends Chan {23  constructor(srcs, bufferSize) {24    super(bufferSize)25    this._srcs = srcs26    this._mergeState = STATE_AWAITING_SEND27    this._syncSrcs = arrayPool.take()28    this._init(srcs)29    if (this._totalDataSrcs) {30      this._maybeSendNext()31    } else {32      this._end()33    }34  }35  _init(srcs) {36    this._onDrain = () => this._maybeSendNext()37    this.on('drain', this._onDrain)38    let timeoutSrcs = EMPTY39    let dataSrcs = arrayPool.take()40    for (let i = 0; i < srcs.length; ++i) {41      let chan = srcs[i]42      if (!chan.isClosed) {43        let isTimeout = chan instanceof TimeoutChan44        let src = this._makeSrc(chan, isTimeout)45        if (isTimeout) {46          if (timeoutSrcs === EMPTY) timeoutSrcs = arrayPool.take()47          timeoutSrcs.push(src)48        } else {49          dataSrcs.push(src)50        }51      }52    }53    this._timeoutSrcs = timeoutSrcs54    this._dataSrcs = dataSrcs55    this._totalTimeoutSrcs = timeoutSrcs.length56    this._totalDataSrcs = dataSrcs.length57  }58  _makeSrc(chan, isTimeout) {59    let src = { chan, cancel: undefined, onClosed: undefined,60      onTakenValue: undefined, onTakenError: undefined }61    if (isTimeout) {62      src.onTakenValue = onTakenValueFromTimeoutChan63    } else {64      src.onTakenValue = value => this._onTaken(value, SEND_TYPE_VALUE, src)65      src.onClosed = () => this._onSrcClosed(src)66      src.chan.on('closed', src.onClosed)67    }68    src.onTakenError = error => this._onTaken(error, SEND_TYPE_ERROR, src)69    return src70  }71  _maybeSendNext() {72    assert(this._mergeState == STATE_AWAITING_SEND || this._mergeState == STATE_AWAITING_TAKE)73    let canSendSync = this._super$canSendSync74    let canTakeMore = true75    let clearSyncState = true76    this._mergeState = STATE_MERGING_SYNC77    while (canSendSync && canTakeMore) {78      let syncResult = this._takeNextSync(clearSyncState)79      clearSyncState = false80      if (syncResult === FAILED) {81        canTakeMore = false82      } else {83        if (syncResult === ERROR) {84          syncResult = this._super$_sendSync(ERROR.value, true)85          assert(syncResult === true)86        } else {87          syncResult = this._super$_sendSync(syncResult, false)88          assert(syncResult === true)89        }90        canSendSync = this._super$canSendSync91      }92    }93    assert(canSendSync || canTakeMore)94    if (!this._totalDataSrcs) {95      // no srcs left alive => end merging96      this._end()97    } else if (!canSendSync) {98      // dst can't accept more data synchronously => wait until it can, then resume99      this._mergeState = STATE_AWAITING_SEND100      this.setNeedsDrain()101      this._cancelTakes()102    } else {103      assert(canTakeMore == false && this._canTakeNextSync() == false)104      this._mergeState = STATE_AWAITING_TAKE105      // srcs can't provide more data => wait until they can106      this._enqueueTakesFrom(this._timeoutSrcs, this._totalTimeoutSrcs)107      this._enqueueTakesFrom(this._dataSrcs, this._totalDataSrcs)108    }109  }110  get canTakeSync() {111    return super.canTakeSync || (this._mergeState != STATE_ENDED && this._canTakeNextSync())112  }113  _canTakeNextSync() {114    let srcs = this._timeoutSrcs115    let totalSrcs = this._totalTimeoutSrcs116    for (let i = 0; i < totalSrcs; ++i) {117      if (srcs[i].chan.canTakeSync) {118        return true119      }120    }121    srcs = this._dataSrcs122    totalSrcs = this._totalDataSrcs123    for (let i = 0; i < totalSrcs; ++i) {124      if (srcs[i].chan.canTakeSync) {125        return true126      }127    }128    return false129  }130  _takeSync() {131    if (this.isClosed) {132      return false133    }134    if (super._takeSync()) {135      return true136    }137    let result = this._takeNextSync(true)138    if (result === FAILED) {139      return false140    } else if (result === ERROR) {141      return result142    } else {143      this._value = result144      return true145    }146  }147  _takeNextSync(clearState) {148    let totalTimeoutSrcs = this._totalTimeoutSrcs149    let timeoutSrcs = this._timeoutSrcs150    for (let i = 0; i < totalTimeoutSrcs; ++i) {151      let {chan} = timeoutSrcs[i]152      if (chan.canTakeSync) {153        return chan._takeSync()154      }155    }156    let syncSrcs = this._syncSrcs157    let totalSyncSrcs158    if (clearState) {159      // clearState equals true when takeNextSync is running the first time during160      // the current event loop tick161      syncSrcs.length = 0162      let dataSrcs = this._dataSrcs163      let totalDataSrcs = this._totalDataSrcs164      let i = 0; while (i < totalDataSrcs) {165        let src = dataSrcs[i]166        // otherwise, src would have been removed from the list, see onSrcClosed()167        assert(src.chan.isClosed == false)168        if (src.chan.canTakeSync) {169          syncSrcs.push(src)170        }171        ++i172      }173      totalSyncSrcs = syncSrcs.length174    } else {175      // if we're running in the same tick as previous takeNextSync call, no channel176      // that was empty in the previous call can become non-empty; but the other way177      // is certainly possible178      totalSyncSrcs = syncSrcs.length179      let i = 0; while (i < totalSyncSrcs) {180        let src = syncSrcs[i], {chan} = src181        if (chan.canTakeSync) {182          ++i183        } else {184          syncSrcs.splice(i, 1); --totalSyncSrcs185        }186      }187    }188    if (totalSyncSrcs) {189      let i = (totalSyncSrcs == 1) ? 0 : Math.floor(totalSyncSrcs * Math.random())190      let ch = syncSrcs[i].chan191      let result = ch._takeSync()192      assert(result !== false)193      return result === ERROR ? result : ch.value194    }195    return FAILED196  }197  _enqueueTakesFrom(srcs, total) {198    assert(this._mergeState == STATE_AWAITING_TAKE)199    if (total == 0) return200    this._mergeState = STATE_ENQUEUEING_TAKES201    for (let i = 0; i < total; ++i) {202      let src = srcs[i]203      if (!src.cancel) {204        src.cancel = src.chan._take(src.onTakenValue, src.onTakenError, true)205      }206    }207    this._mergeState = STATE_AWAITING_TAKE208  }209  _cancelTakes() {210    this._cancelTakesFrom(this._timeoutSrcs, this._totalTimeoutSrcs)211    this._cancelTakesFrom(this._dataSrcs, this._totalDataSrcs)212  }213  _cancelTakesFrom(srcs, total) {214    for (let i = 0; i < total; ++i) {215      let src = srcs[i]216      if (src.cancel) {217        src.cancel()218        src.cancel = undefined219      }220    }221  }222  _onTaken(value, type, src) {223    assert(this._mergeState == STATE_AWAITING_TAKE, onTakenInvalidStateMsg(this._mergeState, src))224    src.cancel = undefined225    if (value == CLOSED) return226    let sent = this._super$_sendSync(value, type)227    assert(sent == true)228    this._maybeSendNext()229  }230  _onSrcClosed(src) {231    // otherwise this event would have not been received, see end()232    assert(this._mergeState != STATE_ENDED)233    src.chan.removeListener('closed', src.onClosed)234    let index = this._dataSrcs.indexOf(src)235    assert(index >= 0)236    this._dataSrcs.splice(index, 1)237    if (!--this._totalDataSrcs && this._mergeState != STATE_MERGING_SYNC) {238      this._end()239    }240  }241  _close() {242    super._close()243    if (this._mergeState != STATE_ENDED) {244      this._end()245    }246  }247  _end() {248    assert(this._mergeState != STATE_ENDED)249    this._mergeState = STATE_ENDED250    this.removeListener('drain', this._onDrain)251    freeSrcs(this._dataSrcs, this._totalDataSrcs)252    let totalTimeoutSrcs = this._totalTimeoutSrcs253    if (totalTimeoutSrcs) {254      assert(this._timeoutSrcs !== EMPTY)255      freeSrcs(this._timeoutSrcs, totalTimeoutSrcs)256    }257    arrayPool.put(this._syncSrcs)258    if (!this.isClosed) this.close()259  }260  _cancelTake(item) {261    let buf = this._buffer262    let index = buf.indexOf(item)263    if (index == -1) return264    buf.splice(index, 1)265    if (buf.length == 0) {266      this._cancelTakes()267    }268  }269  get _constructorName() {270    return 'chan.merge'271  }272  get _constructorArgsDesc() {273    return this._srcs274  }275  _maybeCanTakeSync(fn, mayReturnPromise) {276    if (this.canTakeSync) {277      return mayReturnPromise ? P_RESOLVED_WITH_TRUE : (fn(true), undefined)278    }279    if (this._mergeState == STATE_ENDED) {280      return mayReturnPromise ? P_RESOLVED_WITH_FALSE : (fn(false), undefined)281    }282    fn = callOnce1(fn)283    let srcs = this._dataSrcs284    for (let i = 0; i < srcs.length; ++i) {285      srcs[i].chan._maybeCanTakeSync(fn, false)286    }287    super._maybeCanTakeSync(fn, false)288  }289  get canSend() {290    return false291  }292  get canSendSync() {293    return false294  }295  _maybeCanSendSync(fn, mayReturnPromise) {296    if (mayReturnPromise) {297      return this.isActive ? P_RESOLVED_WITH_TRUE : P_RESOLVED_WITH_FALSE298    } else {299      fn(this.isActive)300    }301  }302  send(value, type) {303    this._throwSendingNotSupported()304  }305  _sendSync(value, type) {306    this._throwSendingNotSupported()307  }308  _send(value, type, fnVal, fnErr, needsCancelFn) {309    this._throwSendingNotSupported()310  }311  emit(event/* ...args */) {312    if (event == 'pipe') {313      this._throwSendingNotSupported()314    }315    this._super$emit.apply(this, arguments)316  }317  get sendOnly() {318    this._throwSendingNotSupported()319  }320  _throwSendingNotSupported() {321    throw new Error(CANNOT_SEND_ERROR_MSG)322  }323}324function freeSrcs(srcs, total) {325  for (let i = 0; i < total; ++i) {326    let src = srcs[i]327    if (src.onClosed) {328      src.chan.removeListener('closed', src.onClosed)329    }330    if (src.cancel) {331      src.cancel()332    }333  }334  arrayPool.put(srcs)335}336function onTakenValueFromTimeoutChan(value) {337  assert(false, `taken value ${value} from a timeout chan`)338}339function onTakenInvalidStateMsg(state, src) {340  return state == STATE_ENQUEUEING_TAKES341    ? `one of the source channels, ${src.chan}, called its _take callback synchronously ` +342      `despite the fact that it reported that it cannot be synchronously taken from`343    : `internal inconsistency error`344}345function callOnce1(fn) {346  let doCall = true; return arg => {347    if (doCall) {348      doCall = false349      fn(arg)350    }351  }352}353Object.defineProperties(MergeChan.prototype, {354  _super$emit: {355    value: EventEmitterMixin.emit,356    writable: true,357    enumerable: false,358    configurable: true359  },360  _super$_sendSync: {361    value: Chan.prototype._sendSync,362    writable: true,363    enumerable: false,364    configurable: true365  },366  _super$canSendSync: Object.getOwnPropertyDescriptor(Chan.prototype, 'canSendSync')...

...50function _mergeDetails(clientProject, project) {51    return lodash_1.default.extend({}, clientProject, project, { state: 'VALID' });52}53exports._mergeDetails = _mergeDetails;54function _mergeState(clientProject, state) {55    return lodash_1.default.extend({}, clientProject, { state });56}57exports._mergeState = _mergeState;58function _getProject(clientProject, authToken) {59    return (0, tslib_1.__awaiter)(this, void 0, void 0, function* () {60        debug('get project from api', clientProject.id, clientProject.path);61        try {62            const project = yield api_1.default.getProject(clientProject.id, authToken);63            debug('got project from api');64            return _mergeDetails(clientProject, project);65        }66        catch (err) {67            debug('failed to get project from api', err.statusCode);68            switch (err.statusCode) {69                case 404:70                    // project doesn't exist71                    return _mergeState(clientProject, 'INVALID');72                case 403:73                    // project exists, but user isn't authorized for it74                    return _mergeState(clientProject, 'UNAUTHORIZED');75                default:76                    throw err;77            }78        }79    });80}81exports._getProject = _getProject;82function getProjectStatuses(clientProjects = []) {83    return (0, tslib_1.__awaiter)(this, void 0, void 0, function* () {84        debug(`get project statuses for ${clientProjects.length} projects`);85        const authToken = yield user_1.default.ensureAuthToken();86        debug('got auth token: %o', { authToken: keys_1.default.hide(authToken) });87        const projects = ((yield api_1.default.getProjects(authToken)) || []);88        debug(`got ${projects.length} projects`);89        const projectsIndex = lodash_1.default.keyBy(projects, 'id');90        return Promise.all(lodash_1.default.map(clientProjects, (clientProject) => {91            debug('looking at', clientProject.path);92            // not a CI project, just mark as valid and return93            if (!clientProject.id) {94                debug('no project id');95                return _mergeState(clientProject, 'VALID');96            }97            const project = projectsIndex[clientProject.id];98            if (project) {99                debug('found matching:', project);100                // merge in details for matching project101                return _mergeDetails(clientProject, project);102            }103            debug('did not find matching:', project);104            // project has id, but no matching project found105            // check if it doesn't exist or if user isn't authorized106            return _getProject(clientProject, authToken);107        }));108    });109}110exports.getProjectStatuses = getProjectStatuses;111function getProjectStatus(clientProject) {112    return (0, tslib_1.__awaiter)(this, void 0, void 0, function* () {113        debug('get project status for client id %s at path %s', clientProject.id, clientProject.path);114        if (!clientProject.id) {115            debug('no project id');116            return Promise.resolve(_mergeState(clientProject, 'VALID'));117        }118        const authToken = yield user_1.default.ensureAuthToken();119        debug('got auth token: %o', { authToken: keys_1.default.hide(authToken) });120        return _getProject(clientProject, authToken);121    });122}123exports.getProjectStatus = getProjectStatus;124function remove(path) {125    return cache_1.default.removeProject(path);126}127exports.remove = remove;128function add(path, options) {129    return (0, tslib_1.__awaiter)(this, void 0, void 0, function* () {130        // don't cache a project if a non-default configFile is set...

1'use strict';2const fse = require('fs-extra');3const AffianceError = require('../error');4const gitRepo = require('../gitRepo');5const HookContextBase = require('./base');6const utils = require('../utils');7const fileUtils = require('../fileUtils');8module.exports = class HookContextPreCommit extends HookContextBase {9  constructor(config, argv, input) {10    super(config, argv, input);11    this.hookScriptName = 'pre-commit';12    this.hookConfigName = 'PreCommit';13    this._isAmendment = null;14  }15  isAmendment() {16    if (this._isAmendment === null) {17      let gitCommand = utils.grandParentCommand();18      // It's easy if 'git commit --amend' was used19      let easyAmendRegex = /\scommit(\s.*)?\s--amend(\s|$)/;20      this._isAmendment = !!gitCommand.match(easyAmendRegex);21      if(this._isAmendment) { return this._isAmendment; }22      // Check for git aliases that call `commit --amend`23      let commandOutput = utils.execSync('git config --get-regexp "^alias\\." "commit(\\s.*)?\\s--amend(\\s|$)"');24      if (!commandOutput) { return this._isAmendment; }25      let aliasRegex = /^alias\.([-\w]+)/gm;26      let matches = null;27      while ((matches = aliasRegex.exec(commandOutput)) !== null) {28        let matchRegex = new RegExp('git(\\.exe)?\\s+' + matches[1]);29        this._isAmendment = !!gitCommand.match(matchRegex);30        if(this._isAmendment) { return this._isAmendment; }31      }32    }33    return this._isAmendment;34  }35  anyChanges() {36    let commandResults = utils.execSync('git status -z --untracked-files=no').trim();37    let modifiedFiles = commandResults.split('\0').map((line) => {38      return line.replace(/[^\s]+\s+(.+)/, '$1');39    });40    return (modifiedFiles.length > 0);41  }42  setupEnvironment() {43    this.storeModifiedTimes();44    this.storeMergeState();45    this.storeCherryPickState();46    if (!gitRepo.isInitialCommit() && this.anyChanges()) {47      this._stashAttempted = true;48      let stashMessage = `Affiance: Stash of repo state before hook run at ${Date.now()}`;49      let command = `git -c commit.gpgsign=false stash save --keep-index --quiet "${stashMessage}"`;50      let commandResults = utils.execSync(command).trim();51      if (commandResults === false) {52        throw AffianceError.error(53          AffianceError.HookSetupFailed,54          'Unable to setup environment for commit-msg hook run.'55        );56      }57      let stashListResults = utils.execSync('git stash list -1').trim();58      this._changesStashed = !!stashListResults.match(new RegExp(stashMessage, 'g'));59    }60    this.restoreModifiedTimes();61  }62  // Restore unstaged changes and reset file modification times so it appears63  // as if nothing ever changed.64  //65  // We want to restore the modification times for each of the files after66  // every step to ensure as little time as possible has passed while the67  // modification time on the file was newer. This helps us play more nicely68  // with file watchers.69  cleanupEnvironment() {70    if (!(gitRepo.isInitialCommit() || (this._stashAttempted && !this._changesStashed)) ) {71      this.clearWorkingTree();72      this.restoreModifiedTimes();73    }74    if (this._changesStashed) {75      this.restoreWorkingTree();76      this.restoreModifiedTimes();77    }78    this.restoreMergeState();79    this.restoreCherryPickState();80    this.restoreModifiedTimes();81  }82  clearWorkingTree() {83    let removedSubmodules = gitRepo.stagedSubmoduleRemovals();84    let commandResult = utils.execSync('git reset --hard');85    if (commandResult === false) {86      throw AffianceError.error(87        AffianceError.HookCleanupFailed,88        'Unable to cleanup working tree for commit-msg hook run'89      );90    }91    for(let i in removedSubmodules) {92      fse.removeSync(removedSubmodules[i].path);93    }94  }95  restoreWorkingTree() {96    let commandResult = utils.execSync('git stash pop --index --quiet');97    if (commandResult === false) {98      throw AffianceError.error(99        AffianceError.HookCleanupFailed,100        'Unable to cleanup working tree for commit-msg hook run'101      );102    }103  }104  modifiedFiles() {105    if (!this._modifiedFiles) {106      let currentStaged = gitRepo.modifiedFiles({staged: true});107      this._modifiedFiles = currentStaged;108      if (this.isAmendment()) {109        let subCommand = 'show --format=%n';110        let previouslyModified = gitRepo.modifiedFiles({subCommand: subCommand});111        this._modifiedFiles = this._modifiedFiles.concat(this.filterModifiedFiles(previouslyModified));112      }113    }114    return this._modifiedFiles;115  }116  modifiedLinesInFile(filePath) {117    this._modifiedLinesByFile = this._modifiedLinesByFile || {};118    if (!this._modifiedLinesByFile[filePath]) {119      this._modifiedLinesByFile[filePath] = gitRepo.extractModifiedLines(filePath, {staged: true});120      if (this.isAmendment()) {121        let subCommand = 'show --format=%n';122        this._modifiedLinesByFile[filePath] = this._modifiedLinesByFile[filePath].concat(123          gitRepo.extractModifiedLines(filePath, {subCommand: subCommand})124        );125        this._modifiedLinesByFile[filePath].sort();126      }127    }128    return this._modifiedLinesByFile[filePath];129  }130  storeModifiedTimes() {131    this._modifiedTimes = {};132    let stagedFiles = this.modifiedFiles();133    let unstagedFiles = gitRepo.modifiedFiles({staged: false});134    stagedFiles.concat(unstagedFiles).forEach((filePath) => {135      if (fileUtils.isBrokenSymlink(filePath)) { return; }136      if (!fse.existsSync(filePath)) { return; }137      this._modifiedTimes[filePath] = fileUtils.modifiedTime(filePath);138    });139  }140  restoreModifiedTimes() {141    for(let modifiedFilePath in this._modifiedTimes) {142      if (fileUtils.isBrokenSymlink(modifiedFilePath)) { continue; }143      if (!fse.existsSync(modifiedFilePath)) { continue; }144      // `utimesSync` expects timestamps at the second resolution,145      // but we store the timestamp in ms.146      // Divide our stored value by 1000 to satisfy the api.147      let mtime = this._modifiedTimes[modifiedFilePath] / 1000;148      fse.utimesSync(modifiedFilePath, mtime, mtime);149    }150  }151  storeMergeState() {152    if (!this._mergeState) {153      this._mergeState = gitRepo.mergeState();154    }155    return this._mergeState;156  }157  restoreMergeState() {158    if (!this._mergeState) { return; }159    let gitDir = gitRepo.gitDir(gitRepo.repoRoot());160    if (this._mergeState.mergeHead) {161      let mergeModeFilePath = gitDir + '/MERGE_MODE';162      fse.ensureFileSync(mergeModeFilePath);163      let mergeHeadFilePath = gitDir + '/MERGE_HEAD';164      fse.writeFileSync(mergeHeadFilePath, this._mergeState.mergeHead);165      this._mergeState.mergeHead = null;166    }167    if (this._mergeState.mergeMsg) {168      let mergeMsgFilePath = gitDir + '/MERGE_MSG';169      fse.writeFileSync(mergeMsgFilePath, `${this._mergeState.mergeMsg}\n`);170      this._mergeState.mergeMsg = null;171    }172    this._mergeState = null;173  }174  storeCherryPickState() {175    if (!this._cherryPickState) {176      this._cherryPickState = gitRepo.cherryPickState();177    }178    return this._cherryPickState;179  }180  restoreCherryPickState() {181    if (!this._cherryPickState) { return; }182    let gitDir = gitRepo.gitDir(gitRepo.repoRoot());183    if (this._cherryPickState.cherryPickHead) {184      let cherryPickHeadFilePath = gitDir + '/CHERRY_PICK_HEAD';185      fse.writeFileSync(cherryPickHeadFilePath, this._cherryPickState.cherryPickHead);186      this._cherryPickState.cherryPickHead = null;187    }188    this._cherryPickState = null;189  }...

...22          <div className={grid.col50}>23            <Dropdown24              options={state.formValues.type_of_paper}25              labeltext='Type of paper'26              onChange={(value) => _mergeState({ order: { type_of_paper: value } })}27              value={state.order.type_of_paper}28              searchable={false}29              placeholder='Select essay type'/>30            <Dropdown31              options={state.formValues.academic_level}32              value={state.order.academic_level}33              placeholder='Select academic level'34              labeltext='Academic level'35              searchable={false}36              onChange={(value) => _mergeState({ order: { academic_level: value } })}/>37            <Dropdown38              options={state.formValues.subject_or_discipline}39              value={state.order.subject_or_discipline}40              placeholder='Subject, discipline'41              labeltext='Subject, discipline'42              searchable={false}43              onChange={(value) => _mergeState({ order: { subject_or_discipline: value } })}/>44            <Input45              name='topic'46              type='text'47              placeholder="Writer's choice"48              onChange={(event) => _mergeState({ order: { topic: event.target.value } })}49              labeltext='Topic'/>50          </div>51          <div className={grid.col50}>52            <Textarea53              name='paper_details'54              placeholder='Add details'55              labeltext='Paper details'56              value={state.order.paper_details}57              onChange={(event) => _mergeState({ order: { paper_details: event.target.value } })}/>58            <div className={styles.child140}>59              <Counter60                id='number_of_sources'61                labeltext='Sources number'62                count={state.order.number_of_sources}63                _mergeState={_mergeState}/>64              <Dropdown65                options={state.formValues.paper_format}66                value={state.order.paper_format}67                labeltext='Paper format'68                searchable={false}69                onChange={(value) => _mergeState({ order: { paper_format: value } })}/>70            </div>71            <FileDropZone72              files={state.order.files}73              _mergeState={_mergeState}/>74          </div>75        </div>76        <button77          onClick={nextStepHandler}78          className={`btn btn--primary ${styles.nextBtn}`}>Continue79        </button>80      </div>81    );82  }83}

...44          }45          var kind = this.receiver.track.kind;46          WebRTCModule.peerConnectionTransceiverSetDirection(this._peerConnectionId, this.id, val, kind, isShow, (successful, data) => {47              if (successful) {48                  this._mergeState(data.state);49                  this._direction = val;50                  resolve(val);51              } else {52                  reject(data);53                  console.warn("Unable to set direction: " + data);54              }55          });56        });57    }58    get currentDirection() {59        return this._currentDirection;60    }61    get sender() {62        return this._sender;63    }64    get receiver() {65        return this._receiver;66    }67    stop() {68        if (this._stopped) {69            return;70        }71        this._stopped = true;72        return new Promise((resolve, reject) => {73            WebRTCModule.peerConnectionTransceiverStop(this._peerConnectionId, this.id, (successful, data) => {74                if (successful) {75                    this._mergeState(data.state);76                    resolve();77                } else {78                    reject(new Error(data));79                }80            });81        });82    }83    _updateState(state) {84        this._mid = state.mid ? state.mid : null;85        this._direction = state.direction;86        this._currentDirection = state.currentDirection;87        if (state.isStopped) {88            this._stopped = true;89        }...

...52    }53    if (prevReadyState.done || prevReadyState.error) {54      if (nextReadyState.stale) {55        if (prevReadyState.error) {56          this._mergeState(nextReadyState, newEvents);57        }58        // Do nothing if stale data comes after server data.59      } else if (!nextReadyState.aborted) {60        warning(61          false,62          'RelayReadyState: Invalid state change from `%s` to `%s`.',63          JSON.stringify(prevReadyState),64          JSON.stringify(nextReadyState),65        );66      }67      return;68    }69    this._mergeState(nextReadyState, newEvents);70  }71  _mergeState(72    nextReadyState: PartialReadyState,73    newEvents: ?Array<ReadyStateEvent>,74  ): void {75    this._readyState = {76      ...this._readyState,77      ...nextReadyState,78      events:79        newEvents && newEvents.length80          ? [...this._readyState.events, ...newEvents]81          : this._readyState.events,82    };83    if (this._scheduled) {84      return;85    }...

...29}30Chromoon.prototype.onPopExec = function(arg){31}32Chromoon.prototype.setState = function(newState){33	this._mergeState(newState);34	// send state to Pop35	this._sendDataToChromeMessage('_set_data_for_pop', this.state);36	// send state to page37	this._sendStateToPage(this.state);38	// on state change39	this._onStateChange();40}41Chromoon.prototype._mergeState = function(newState){42	for(i in newState){43		this.state[i] = newState[i];44	}45}46Chromoon.prototype._onMessage = function(request, sender) {47	switch(request.action){48		case '_set_data_for_bg':49			this._mergeState(request.source);50			this._onStateChange();51			if(this._onStateChangeFromListener){ this._onStateChangeFromListener(this, this.state); };52			break;53		case '_give_me_state_for_pop':54			this._sendDataToChromeMessage('_set_data_for_pop', this.state);55			break;56	}57}...

...13    replaceTrack = (track: MediaStreamTrack | null) => {14        return new Promise((resolve, reject) => {15            WebRTCModule.peerConnectionTransceiverReplaceTrack(this._transceiver._peerConnectionId, this._transceiver.id, track ? track.id : null, (successful, data) => {16                if (successful) {17                    this._transceiver._mergeState(data.state);18                    resolve();19                } else {20                    reject(new Error(data));21                }22            });23        });24    }...