How to use injectFn method in Cypress

...151        });152    };153    it('Should get the concept with conceptSetName and create a obs mapper with the concept and if there no saved observation for the same concept', function () {154        observationsService.fetch.and.returnValue(specUtil.simplePromise({"data": []}));155        injectFn();156        expect(conceptSetService.getConcept).toHaveBeenCalled();157        expect(observationsService.fetch).toHaveBeenCalled();158        expect(scope.promiseResolved).toBe(true);159        expect(scope.editMode).toBeFalsy();160        expect(scope.observations[0]).toBeDefined();161        expect(scope.observations[0].concept.name).toBe("Expected Date of Discharge Set");162        expect(scope.observations[0].groupMembers).toBeDefined();163        expect(scope.observations[0].groupMembers.length).toBe(1);164        expect(scope.observations[0].groupMembers[0].concept.name).toBe("Expected Date of Discharge");165        expect(scope.observations[0].groupMembers[0].value).toBeUndefined();166        expect(scope.observations[0].groupMembers[0].disabled).toBeTruthy();167    });168    it('Should get the concept with conceptSetName and create a obs mapper with the concept and if there is saved observation for the same concept exist copy values to mapped observation', function () {169        observationsService.fetch.and.returnValue(specUtil.simplePromise({"data": [observation]}));170        injectFn();171        expect(conceptSetService.getConcept).toHaveBeenCalled();172        expect(observationsService.fetch).toHaveBeenCalled();173        expect(scope.promiseResolved).toBe(true);174        expect(scope.editMode).toBeFalsy();175        expect(scope.observations[0]).toBeDefined();176        expect(scope.observations[0].concept.name).toBe("Expected Date of Discharge Set");177        expect(scope.observations[0].groupMembers).toBeDefined();178        expect(scope.observations[0].groupMembers.length).toBe(1);179        expect(scope.observations[0].groupMembers[0].concept.name).toBe("Expected Date of Discharge");180        expect(scope.observations[0].groupMembers[0].value).toBe("2017-01-03");181        expect(scope.observations[0].groupMembers[0].disabled).toBeTruthy();182    });183    it('Should enable obs on edit and reset the changes made observation on cancel, i.e reset back to last saved obs and disable them', function () {184        observationsService.fetch.and.returnValue(specUtil.simplePromise({"data": [observation]}));185        injectFn();186        expect(scope.editMode).toBeFalsy();187        expect(scope.observations[0].groupMembers[0].value).toEqual("2017-01-03");188        expect(conceptSetService.getConcept).toHaveBeenCalled();189        expect(observationsService.fetch).toHaveBeenCalled();190        scope.edit();191        expect(scope.editMode).toBeTruthy();192        scope.observations[0].groupMembers[0].value = "2020-01-13";193        scope.cancel();194        expect(scope.editMode).toBeFalsy();195        expect(scope.observations[0].groupMembers[0].value).toEqual("2017-01-03");196    });197    it('Should enable obs on edit and save the observations with the changes made', function () {198        observationsService.fetch.and.returnValue(specUtil.simplePromise({"data": [observation]}));199        injectFn();200        expect(scope.editMode).toBeFalsy();201        expect(scope.visitTypeUuid).toBe("visitTypeUuid");202        expect(scope.observations[0].groupMembers[0].value).toEqual("2017-01-03");203        expect(conceptSetService.getConcept).toHaveBeenCalled();204        expect(observationsService.fetch).toHaveBeenCalled();205        scope.edit();206        expect(scope.editMode).toBeTruthy();207        scope.observations[0].groupMembers[0].value = "2020-01-13";208        scope.save();209        expect(scope.editMode).toBeFalsy();210        expect(scope.observations[0].groupMembers[0].value).toEqual("2020-01-13");211        expect(encounterService.create).toHaveBeenCalled();212    });213    it('Should reset observation values, if fetch the observations returns empty array for patient', function () {214        observationsService.fetch.and.returnValue(specUtil.simplePromise({"data": []}));215        injectFn();216        expect(scope.editMode).toBeFalsy();217        expect(conceptSetService.getConcept).toHaveBeenCalled();218        expect(observationsService.fetch).toHaveBeenCalled();219        scope.patient = {uuid: "newPatientUuid"};220        scope.$digest();221        expect(observationsService.fetch).toHaveBeenCalled();222        //scope.observations[0].groupMembers[0].value = "2020-01-13";223        expect(scope.editMode).toBeFalsy();224        expect(scope.observations[0].groupMembers[0].value).toBeUndefined();225    });226    it('Should set onBedManagement to true when current state is bedmanagement', function () {227        state = {current : {name : "bedManagement.bed"}};228        injectFn();229        expect(scope.onBedManagement).toBeTruthy();230    });231    it('Should set onBedManagement to false when current state is not bedmanagement', function () {232        state = {current : {name : ""}};233        injectFn();234        expect(scope.onBedManagement).toBeFalsy();235    });236    it('Should throw a message when trying to save empty fields', function () {237        observationsService.fetch.and.returnValue(specUtil.simplePromise({"data": []}));238        injectFn();239        scope.observations = [{concept : {name : "IPD Expected DD"}, groupMembers : [{value : ""} ,{value : ""}]}];240        scope.savedObservations = [{concept : {name : "IPD Expected DD"}, groupMembers : [{value : ""} ,{value : ""}]}];241        scope.$digest();242        scope.save();243        expect(messagingService.showMessage).toHaveBeenCalled();244    });...

...250		injectCheck: function ( obj, key, injectFn ) {251			var spy,252				val = obj[ key ];253			spy = function () {254				injectFn();255				return val.apply( this, arguments );256			};257			// Make the spy inherit from the original so that its static methods are also258			// visible in the spy (e.g. when we inject a check into mw.log, mw.log.warn259			// must remain accessible).260			// XXX: https://github.com/jshint/jshint/issues/2656261			/*jshint ignore:start */262			/*jshint proto:true */263			spy.__proto__ = val;264			/*jshint ignore:end */265			// Objects are by reference, members (unless objects) are not.266			obj[ key ] = spy;267		}268	};...

1//========================2// 录音接口相关3//========================4import { removeArray } from '../../../util/lang'5/**6 * 是否存在音频插件7 * @return {Boolean} [description]8 */9function hasRecordPlugin(callback, id) {10  //iframe模式下插件的查找11  if (GLOBALIFRAME) {12    if (GLOBALCONTEXT.Recorder) {13      callback(`${Xut.config.data.originalAppId}-${id}`)14    }15    return16  }17  //单独apk情况下18  if (window.cordova && Xut.Plugin.Recorder) {19    callback(`${Xut.config.data.originalAppId}-${id}`)20  }21}22export function extendRecord(access, $$globalSwiper) {23  //正在录音中24  let recording = false25  //下一个动作的回调26  let currentNextCallback = null27  //当前运行的重复执行方法28  let cuurentRepeatCallback = null29  //播放的id合集30  let playIds = []31  /**32   * 给录音的回调动作33   * 增加一个当前页面接管的全局接口34   * 意思就是用户再不录音的情况下，失败的动作中35   * 会弹出一个可以继续往下走的动作，而不会造成死循环36   * 跳到下一个默认录音动作37   * 这样代码默认会绑定最后一个录音的成功动作38   */39  Xut.Assist.RecordNextAction = function(callback) {40    //执行自己的隐藏41    callback && callback()42    if (currentNextCallback) {43      setTimeout(function() {44        //执行当前成功的回调45        currentNextCallback()46      }, 1000)47    } else {48      Xut.$warn('record', `没有currentSucceedCallback,无法继续下个动画`)49    }50  }51  /**52   * 重复录音53   * 自动定位到当前失败的录音上54   * callback 是成功回调的关闭55   */56  Xut.Assist.RecordRepeat = function(callback) {57    //执行自己的隐藏58    callback && callback()59    if (cuurentRepeatCallback) {60      setTimeout(function() {61        //执行当前成功的回调62        cuurentRepeatCallback()63      }, 500)64    } else {65      Xut.$warn('record', `没有cuurentRepeatCallback,无法重复当前动画`)66    }67  }68  /**69   * 脚本函数70   * 1:id71   * 2:提供成功与失败回调72   * 3：injectFn可以注入处理函数73   * Xut.Assist.RecordStart(id, {74   *   succeed: function() {75   *     Xut.Assist.Run(1)76   *   },77   *   fail: function() {78   *     Xut.Assist.Run(2)79   *   }80   * })81   */82  Xut.Assist.RecordStart = function(injectFn, id, callback = {}) {83    if (!injectFn) {84      Xut.$warn('record', `没有传递录音的必要数据${injectFn}`)85      return86    }87    //如果不通过ppt处理，那么只会传递2个参数88    //如果只传递了2个参数id/callback89    if (typeof injectFn !== 'function') {90      let a = id91      id = injectFn92      callback = a93    }94    hasRecordPlugin(function(newId) {95      Xut.Assist.RecordStop(function() {96        Xut.$warn('record', `当前有音频在录制，先强制停止`)97      })98      Xut.$warn('record', `开始录音,id:${newId}`)99      //如果有执行成功回调100      if (callback.succeed) {101        currentNextCallback = callback.succeed102      }103      //如果有注入重新运行的回调104      if (injectFn) {105        cuurentRepeatCallback = injectFn106      }107      recording = true108      Xut.Plugin.Recorder.startRecord(newId,109        //成功110        function() {111          recording = false112          Xut.$warn('record', `录音完成,id:${newId}`)113          callback.succeed && callback.succeed()114        },115        function() {116          //失败117          recording = false118          Xut.$warn('record', `录音失败,id:${newId}`)119          callback.fail && callback.fail()120        })121    }, id)122  }123  /**124   * 停止录音125   * 每次翻页都会调用一次126   * 1 清空记录127   * 2 判断如果还有录音的，强制停止128   */129  Xut.Assist.RecordStop = function(callback) {130    //翻页清空131    currentNextCallback = null132    cuurentRepeatCallback = null133    if (recording) {134      hasRecordPlugin(function() {135        callback && callback136        recording = false137        Xut.Plugin.Recorder.stopRecord()138      })139    }140  }141  /**142   * 播放录音143   * failCallback 播放录音失败回调144   * 播放成功与播放失败145   */146  Xut.Assist.RecordPlay = function(id, failCallback) {147    if (!id) {148      Xut.$warn('record', `播放录音失败,缺少id:${id}`)149      return150    }151    hasRecordPlugin(function(newId) {152      //如果上一个还在播，先停止，保持只播一个153      Xut.Assist.RecordPlayStop()154      playIds.push(newId)155      Xut.$warn('record', `播放录音,id:${newId}`)156      Xut.Plugin.Recorder.startPlay(newId, function() {157        removeArray(playIds, newId)158        Xut.$warn('record', `播放录音成功:${newId},id合集编号:${playIds.toString()},数量:${playIds.length}`)159      }, function() {160        Xut.$warn('record', `播放录音失败,id合集编号:${playIds.toString()}`)161        removeArray(playIds, newId)162        failCallback && failCallback()163      })164    }, id)165  }166  /**167   * 播放停止168   * ids  一个或者数组169   * 1 播放之前停止170   * 2 翻页停止171   * 3 强制停止172   */173  Xut.Assist.RecordPlayStop = function(id) {174    //强制停止,传递是外部接口的直接id175    if (id) {176      hasRecordPlugin(function(newId) {177        if (!newId) {178          Xut.$warn('record', `停止录音失败,缺少id:${id}`)179          return180        }181        removeArray(playIds, newId)182        Xut.$warn('record', `播放录音停止,id:${newId}`)183        Xut.Plugin.Recorder.stopPlay(newId)184      }, id)185    } else if (playIds.length) {186      Xut.$warn('record', `停止播放音乐,id合集编号:${playIds.toString()},数量:${playIds.length}`)187      //翻页停止，或者播放之前停止，传递是封装后的id188      hasRecordPlugin(function() {189        playIds.forEach(function(newId) {190          Xut.$warn('record', `播放录音停止,id:${newId}`)191          Xut.Plugin.Recorder.stopPlay(newId)192          removeArray(playIds, newId)193        })194      })195    }196  }...

1function withCache(fn) {2    let cached;3	return () => cached = cached ? cached : fn()4}5function extractWBMods() {6    let mods, id = Date.now();7    window.webpackJsonp.push([8        [id],9        {10            [id]: (mod, exports, __webpack_require__) => {11                    mods =  __webpack_require__.c;12            }13        },14        [[id]],15    ]);16    return mods;17}18function extractConstants() {19    const mods = getWBMods();20    let name;21    for (name in mods) {22        mod = mods[name];23        if (mod.exports24            && mod.exports.hasOwnProperty('ACK')25            && mod.exports.hasOwnProperty('KEY_SECRET')26        ) {27            return mod.exports;28        }29    }30}31const getWBMods = withCache(extractWBMods);32const getConstants = withCache(extractConstants);33function getSession() {34    let35        key, value,36        i = 0,37        keys = Object.keys(window.localStorage),38        res = new Array(keys.length);39        len = keys.length;40    for(; i < len; i++) {41        key = keys[i];42        value = window.localStorage[key];43        res[i] = {key, value};44    }45    return res;46}47function setSession(items) {48    let49        obj,50        len = items.length,51        i = 0;52    for (;i < len; i++) {53        obj = items[i];54        window.localStorage.setItem(obj.key, obj.value);55    }56}57function attachTo(listener, ctx, cb) {58    listener.push({59        context: undefined,60        ctx,61        callback: cb,62    });63}64/*65    inject attachs a `injectFn` function to the target listener which intercepts66    new messages.67    inject will not attach the same `injectFn` function twice.68    If `trial` = true no listener will be attached, this is useful for testing or69    checking if the needed listener is available70*/71function inject(injectFn, trial) {72    const mods = getWBMods();73    let name, listener, mod;74    for (name in mods) {75        mod = mods[name];76        try {77            listener = mod.exports.default._events.alert_new_msg;78        } catch(err) {79            if (err instanceof TypeError) {80                continue;81            } else {82                throw err;83            }84        }85        if (Array.isArray(listener)) {86            if (trial) return true;87            if (listener.length >= 2 && !!listener.find(evt => evt.callback === injectFn)) return false;88            return attachTo(listener, mod.exports.default, injectFn);89        }90    }91    return false;92}93function waitForReady() {94    let timeout, timer;95    timeout = setTimeout(() => {96        clearInterval(timer);97        emit('wa:ready-timeout');98    }, 45e3);99    timer = setInterval(() => {100        if (inject(null, true)) {101            clearInterval(timer);102            clearTimeout(timeout);103            emit('wa:ready');104        }105    }, 50);106}107function emitMessage(data) {108    emit('wa:message', data);109}110function storageHas(item) {111    return !!window.localStorage.getItem(item);112}113function storageGet(item) {114    return JSON.parse(window.localStorage.getItem(item));115}116function isLoggedIn() {117    return !!storageHas("WASecretBundle")118        && !!storageHas("logout-token");119}120function getLastWID() {121    const { KEY_LAST_WID } = getConstants();122    return storageGet(KEY_LAST_WID);...

...4  if (typeof func === 'function') {5    const code = [6      `self.injectFn = ${ func.toString() };\n`,7      'self.onmessage = (e) => {\n',8      ' const result = self.injectFn(e.data);\n',9      ' self.postMessage(result);\n',10      '}'11    ];12    const blob = new Blob(code, { type: 'text/javascript' });13    const url = URL.createObjectURL(blob);14    const worker = new Worker(url);15    worker.cleanup = () => {16      URL.revokeObjectURL(url);17      worker.terminate();18    };19    return worker20  } else {21    console.error('参数必须是一个函数')22  }...

1var path = require('path')2var utils = require('./utils')3function inject(state) {4  var drivers = ['./drivers/terminal.js', ];5  var drivers = {6    'source.js': './drivers/javascript.js',7    'source.shell': './drivers/terminal.js',8  };9  var filename = drivers[utils.ftype()];10  if (!filename) {11    return false;12  }13  var injectFn, driver;14  try {15    var driver = utils.frequire(path.join(__dirname, filename));16    injectFn = driver(state);17    if (injectFn) {18      return injectFn;19    }20  } catch (e) {21    console.log('inject driver failed:')22    console.log(e)23    return false;24  }25  return false;26}...

1import * as _ from "lodash";2global.injectNg = function(modName, objectMap) {3  beforeEach(angular.mock.module(modName));4  let injections = _.pairs(objectMap);5  6  let injectFn = function(...values) {7    for(let i = 0; i < values.length; i++) {8      let name = injections[i][0];9      let value = values[i];10      this[name] = value;11    }12  };13  injectFn.$inject = _.map(injections, _.last);14  beforeEach(inject(injectFn));...