How to use getSimpleBundle method of js Package

Best K6 code snippet using js.getSimpleBundle

bundle_test.go

Source:bundle_test.go

...43	"go.k6.io/k6/lib/types"44	"go.k6.io/k6/loader"45)46const isWindows = runtime.GOOS == "windows"47func getSimpleBundle(tb testing.TB, filename, data string, opts ...interface{}) (*Bundle, error) {48	var (49		fs                        = afero.NewMemMapFs()50		rtOpts                    = lib.RuntimeOptions{}51		logger logrus.FieldLogger = testutils.NewLogger(tb)52	)53	for _, o := range opts {54		switch opt := o.(type) {55		case afero.Fs:56			fs = opt57		case lib.RuntimeOptions:58			rtOpts = opt59		case logrus.FieldLogger:60			logger = opt61		}62	}63	return NewBundle(64		logger,65		&loader.SourceData{66			URL:  &url.URL{Path: filename, Scheme: "file"},67			Data: []byte(data),68		},69		map[string]afero.Fs{"file": fs, "https": afero.NewMemMapFs()},70		rtOpts,71		metrics.NewRegistry(),72	)73}74func TestNewBundle(t *testing.T) {75	t.Parallel()76	t.Run("Blank", func(t *testing.T) {77		t.Parallel()78		_, err := getSimpleBundle(t, "/script.js", "")79		assert.EqualError(t, err, "no exported functions in script")80	})81	t.Run("Invalid", func(t *testing.T) {82		t.Parallel()83		_, err := getSimpleBundle(t, "/script.js", "\x00")84		assert.NotNil(t, err)85		assert.Contains(t, err.Error(), "SyntaxError: file:///script.js: Unexpected character '\x00' (1:0)\n> 1 | \x00\n")86	})87	t.Run("Error", func(t *testing.T) {88		t.Parallel()89		_, err := getSimpleBundle(t, "/script.js", `throw new Error("aaaa");`)90		exception := new(scriptException)91		assert.ErrorAs(t, err, &exception)92		assert.EqualError(t, err, "Error: aaaa\n\tat file:///script.js:1:7(2)\n")93	})94	t.Run("InvalidExports", func(t *testing.T) {95		t.Parallel()96		_, err := getSimpleBundle(t, "/script.js", `exports = null`)97		assert.EqualError(t, err, "exports must be an object")98	})99	t.Run("DefaultUndefined", func(t *testing.T) {100		t.Parallel()101		_, err := getSimpleBundle(t, "/script.js", `export default undefined;`)102		assert.EqualError(t, err, "no exported functions in script")103	})104	t.Run("DefaultNull", func(t *testing.T) {105		t.Parallel()106		_, err := getSimpleBundle(t, "/script.js", `export default null;`)107		assert.EqualError(t, err, "no exported functions in script")108	})109	t.Run("DefaultWrongType", func(t *testing.T) {110		t.Parallel()111		_, err := getSimpleBundle(t, "/script.js", `export default 12345;`)112		assert.EqualError(t, err, "no exported functions in script")113	})114	t.Run("Minimal", func(t *testing.T) {115		t.Parallel()116		_, err := getSimpleBundle(t, "/script.js", `export default function() {};`)117		assert.NoError(t, err)118	})119	t.Run("stdin", func(t *testing.T) {120		t.Parallel()121		b, err := getSimpleBundle(t, "-", `export default function() {};`)122		if assert.NoError(t, err) {123			assert.Equal(t, "file://-", b.Filename.String())124			assert.Equal(t, "file:///", b.BaseInitContext.pwd.String())125		}126	})127	t.Run("CompatibilityMode", func(t *testing.T) {128		t.Parallel()129		t.Run("Extended/ok/global", func(t *testing.T) {130			t.Parallel()131			rtOpts := lib.RuntimeOptions{132				CompatibilityMode: null.StringFrom(lib.CompatibilityModeExtended.String()),133			}134			_, err := getSimpleBundle(t, "/script.js",135				`module.exports.default = function() {}136				if (global.Math != Math) {137					throw new Error("global is not defined");138				}`, rtOpts)139			assert.NoError(t, err)140		})141		t.Run("Base/ok/Minimal", func(t *testing.T) {142			t.Parallel()143			rtOpts := lib.RuntimeOptions{144				CompatibilityMode: null.StringFrom(lib.CompatibilityModeBase.String()),145			}146			_, err := getSimpleBundle(t, "/script.js",147				`module.exports.default = function() {};`, rtOpts)148			assert.NoError(t, err)149		})150		t.Run("Base/err", func(t *testing.T) {151			t.Parallel()152			testCases := []struct {153				name       string154				compatMode string155				code       string156				expErr     string157			}{158				{159					"InvalidCompat", "es1", `export default function() {};`,160					`invalid compatibility mode "es1". Use: "extended", "base"`,161				},162				// ES2015 modules are not supported163				{164					"Modules", "base", `export default function() {};`,165					"file:///script.js: Line 1:1 Unexpected reserved word",166				},167				// BigInt is not supported168				{169					"BigInt", "base",170					`module.exports.default = function() {}; BigInt(1231412444)`,171					"ReferenceError: BigInt is not defined\n\tat file:///script.js:1:47(6)\n",172				},173			}174			for _, tc := range testCases {175				tc := tc176				t.Run(tc.name, func(t *testing.T) {177					t.Parallel()178					rtOpts := lib.RuntimeOptions{CompatibilityMode: null.StringFrom(tc.compatMode)}179					_, err := getSimpleBundle(t, "/script.js", tc.code, rtOpts)180					assert.EqualError(t, err, tc.expErr)181				})182			}183		})184	})185	t.Run("Options", func(t *testing.T) {186		t.Parallel()187		t.Run("Empty", func(t *testing.T) {188			t.Parallel()189			_, err := getSimpleBundle(t, "/script.js", `190				export let options = {};191				export default function() {};192			`)193			assert.NoError(t, err)194		})195		t.Run("Invalid", func(t *testing.T) {196			t.Parallel()197			invalidOptions := map[string]struct {198				Expr, Error string199			}{200				"Array":    {`[]`, "json: cannot unmarshal array into Go value of type lib.Options"},201				"Function": {`function(){}`, "json: unsupported type: func(goja.FunctionCall) goja.Value"},202			}203			for name, data := range invalidOptions {204				t.Run(name, func(t *testing.T) {205					_, err := getSimpleBundle(t, "/script.js", fmt.Sprintf(`206						export let options = %s;207						export default function() {};208					`, data.Expr))209					assert.EqualError(t, err, data.Error)210				})211			}212		})213		t.Run("Paused", func(t *testing.T) {214			t.Parallel()215			b, err := getSimpleBundle(t, "/script.js", `216				export let options = {217					paused: true,218				};219				export default function() {};220			`)221			if assert.NoError(t, err) {222				assert.Equal(t, null.BoolFrom(true), b.Options.Paused)223			}224		})225		t.Run("VUs", func(t *testing.T) {226			t.Parallel()227			b, err := getSimpleBundle(t, "/script.js", `228				export let options = {229					vus: 100,230				};231				export default function() {};232			`)233			if assert.NoError(t, err) {234				assert.Equal(t, null.IntFrom(100), b.Options.VUs)235			}236		})237		t.Run("Duration", func(t *testing.T) {238			t.Parallel()239			b, err := getSimpleBundle(t, "/script.js", `240				export let options = {241					duration: "10s",242				};243				export default function() {};244			`)245			if assert.NoError(t, err) {246				assert.Equal(t, types.NullDurationFrom(10*time.Second), b.Options.Duration)247			}248		})249		t.Run("Iterations", func(t *testing.T) {250			t.Parallel()251			b, err := getSimpleBundle(t, "/script.js", `252				export let options = {253					iterations: 100,254				};255				export default function() {};256			`)257			if assert.NoError(t, err) {258				assert.Equal(t, null.IntFrom(100), b.Options.Iterations)259			}260		})261		t.Run("Stages", func(t *testing.T) {262			t.Parallel()263			b, err := getSimpleBundle(t, "/script.js", `264				export let options = {265					stages: [],266				};267				export default function() {};268			`)269			if assert.NoError(t, err) {270				assert.Len(t, b.Options.Stages, 0)271			}272			t.Run("Empty", func(t *testing.T) {273				t.Parallel()274				b, err := getSimpleBundle(t, "/script.js", `275					export let options = {276						stages: [277							{},278						],279					};280					export default function() {};281				`)282				if assert.NoError(t, err) {283					if assert.Len(t, b.Options.Stages, 1) {284						assert.Equal(t, lib.Stage{}, b.Options.Stages[0])285					}286				}287			})288			t.Run("Target", func(t *testing.T) {289				t.Parallel()290				b, err := getSimpleBundle(t, "/script.js", `291					export let options = {292						stages: [293							{target: 10},294						],295					};296					export default function() {};297				`)298				if assert.NoError(t, err) {299					if assert.Len(t, b.Options.Stages, 1) {300						assert.Equal(t, lib.Stage{Target: null.IntFrom(10)}, b.Options.Stages[0])301					}302				}303			})304			t.Run("Duration", func(t *testing.T) {305				t.Parallel()306				b, err := getSimpleBundle(t, "/script.js", `307					export let options = {308						stages: [309							{duration: "10s"},310						],311					};312					export default function() {};313				`)314				if assert.NoError(t, err) {315					if assert.Len(t, b.Options.Stages, 1) {316						assert.Equal(t, lib.Stage{Duration: types.NullDurationFrom(10 * time.Second)}, b.Options.Stages[0])317					}318				}319			})320			t.Run("DurationAndTarget", func(t *testing.T) {321				t.Parallel()322				b, err := getSimpleBundle(t, "/script.js", `323					export let options = {324						stages: [325							{duration: "10s", target: 10},326						],327					};328					export default function() {};329				`)330				if assert.NoError(t, err) {331					if assert.Len(t, b.Options.Stages, 1) {332						assert.Equal(t, lib.Stage{Duration: types.NullDurationFrom(10 * time.Second), Target: null.IntFrom(10)}, b.Options.Stages[0])333					}334				}335			})336			t.Run("RampUpAndPlateau", func(t *testing.T) {337				t.Parallel()338				b, err := getSimpleBundle(t, "/script.js", `339					export let options = {340						stages: [341							{duration: "10s", target: 10},342							{duration: "5s"},343						],344					};345					export default function() {};346				`)347				if assert.NoError(t, err) {348					if assert.Len(t, b.Options.Stages, 2) {349						assert.Equal(t, lib.Stage{Duration: types.NullDurationFrom(10 * time.Second), Target: null.IntFrom(10)}, b.Options.Stages[0])350						assert.Equal(t, lib.Stage{Duration: types.NullDurationFrom(5 * time.Second)}, b.Options.Stages[1])351					}352				}353			})354		})355		t.Run("MaxRedirects", func(t *testing.T) {356			t.Parallel()357			b, err := getSimpleBundle(t, "/script.js", `358				export let options = {359					maxRedirects: 10,360				};361				export default function() {};362			`)363			if assert.NoError(t, err) {364				assert.Equal(t, null.IntFrom(10), b.Options.MaxRedirects)365			}366		})367		t.Run("InsecureSkipTLSVerify", func(t *testing.T) {368			t.Parallel()369			b, err := getSimpleBundle(t, "/script.js", `370				export let options = {371					insecureSkipTLSVerify: true,372				};373				export default function() {};374			`)375			if assert.NoError(t, err) {376				assert.Equal(t, null.BoolFrom(true), b.Options.InsecureSkipTLSVerify)377			}378		})379		t.Run("TLSCipherSuites", func(t *testing.T) {380			t.Parallel()381			for suiteName, suiteID := range lib.SupportedTLSCipherSuites {382				t.Run(suiteName, func(t *testing.T) {383					t.Parallel()384					script := `385					export let options = {386						tlsCipherSuites: ["%s"]387					};388					export default function() {};389					`390					script = fmt.Sprintf(script, suiteName)391					b, err := getSimpleBundle(t, "/script.js", script)392					if assert.NoError(t, err) {393						if assert.Len(t, *b.Options.TLSCipherSuites, 1) {394							assert.Equal(t, (*b.Options.TLSCipherSuites)[0], suiteID)395						}396					}397				})398			}399		})400		t.Run("TLSVersion", func(t *testing.T) {401			t.Parallel()402			t.Run("Object", func(t *testing.T) {403				t.Parallel()404				b, err := getSimpleBundle(t, "/script.js", `405					export let options = {406						tlsVersion: {407							min: "tls1.0",408							max: "tls1.2"409						}410					};411					export default function() {};412				`)413				if assert.NoError(t, err) {414					assert.Equal(t, b.Options.TLSVersion.Min, lib.TLSVersion(tls.VersionTLS10))415					assert.Equal(t, b.Options.TLSVersion.Max, lib.TLSVersion(tls.VersionTLS12))416				}417			})418			t.Run("String", func(t *testing.T) {419				t.Parallel()420				b, err := getSimpleBundle(t, "/script.js", `421					export let options = {422						tlsVersion: "tls1.0"423					};424					export default function() {};425				`)426				if assert.NoError(t, err) {427					assert.Equal(t, b.Options.TLSVersion.Min, lib.TLSVersion(tls.VersionTLS10))428					assert.Equal(t, b.Options.TLSVersion.Max, lib.TLSVersion(tls.VersionTLS10))429				}430			})431		})432		t.Run("Thresholds", func(t *testing.T) {433			t.Parallel()434			b, err := getSimpleBundle(t, "/script.js", `435				export let options = {436					thresholds: {437						http_req_duration: ["avg<100"],438					},439				};440				export default function() {};441			`)442			if assert.NoError(t, err) {443				if assert.Len(t, b.Options.Thresholds["http_req_duration"].Thresholds, 1) {444					assert.Equal(t, "avg<100", b.Options.Thresholds["http_req_duration"].Thresholds[0].Source)445				}446			}447		})448		t.Run("Unknown field", func(t *testing.T) {449			t.Parallel()450			logger := logrus.New()451			logger.SetLevel(logrus.InfoLevel)452			logger.Out = ioutil.Discard453			hook := testutils.SimpleLogrusHook{454				HookedLevels: []logrus.Level{logrus.WarnLevel, logrus.InfoLevel, logrus.ErrorLevel, logrus.FatalLevel, logrus.PanicLevel},455			}456			logger.AddHook(&hook)457			_, err := getSimpleBundle(t, "/script.js", `458				export let options = {459					something: {460						http_req_duration: ["avg<100"],461					},462				};463				export default function() {};464			`, logger)465			require.NoError(t, err)466			entries := hook.Drain()467			require.Len(t, entries, 1)468			assert.Equal(t, logrus.WarnLevel, entries[0].Level)469			require.Contains(t, entries[0].Message, "There were unknown fields")470			require.Contains(t, entries[0].Data["error"].(error).Error(), "unknown field \"something\"")471		})472	})473}474func getArchive(tb testing.TB, data string, rtOpts lib.RuntimeOptions) (*lib.Archive, error) {475	b, err := getSimpleBundle(tb, "script.js", data, rtOpts)476	if err != nil {477		return nil, err478	}479	return b.makeArchive(), nil480}481func TestNewBundleFromArchive(t *testing.T) {482	t.Parallel()483	es5Code := `module.exports.options = { vus: 12345 }; module.exports.default = function() { return "hi!" };`484	es6Code := `export let options = { vus: 12345 }; export default function() { return "hi!"; };`485	baseCompatModeRtOpts := lib.RuntimeOptions{CompatibilityMode: null.StringFrom(lib.CompatibilityModeBase.String())}486	extCompatModeRtOpts := lib.RuntimeOptions{CompatibilityMode: null.StringFrom(lib.CompatibilityModeExtended.String())}487	logger := testutils.NewLogger(t)488	checkBundle := func(t *testing.T, b *Bundle) {489		assert.Equal(t, lib.Options{VUs: null.IntFrom(12345)}, b.Options)490		bi, err := b.Instantiate(logger, 0, newModuleVUImpl())491		require.NoError(t, err)492		val, err := bi.exports[consts.DefaultFn](goja.Undefined())493		require.NoError(t, err)494		assert.Equal(t, "hi!", val.Export())495	}496	checkArchive := func(t *testing.T, arc *lib.Archive, rtOpts lib.RuntimeOptions, expError string) {497		b, err := NewBundleFromArchive(logger, arc, rtOpts, metrics.NewRegistry())498		if expError != "" {499			require.Error(t, err)500			assert.Contains(t, err.Error(), expError)501		} else {502			require.NoError(t, err)503			checkBundle(t, b)504		}505	}506	t.Run("es6_script_default", func(t *testing.T) {507		t.Parallel()508		arc, err := getArchive(t, es6Code, lib.RuntimeOptions{}) // default options509		require.NoError(t, err)510		require.Equal(t, lib.CompatibilityModeExtended.String(), arc.CompatibilityMode)511		checkArchive(t, arc, lib.RuntimeOptions{}, "") // default options512		checkArchive(t, arc, extCompatModeRtOpts, "")513		checkArchive(t, arc, baseCompatModeRtOpts, "Unexpected reserved word")514	})515	t.Run("es6_script_explicit", func(t *testing.T) {516		t.Parallel()517		arc, err := getArchive(t, es6Code, extCompatModeRtOpts)518		require.NoError(t, err)519		require.Equal(t, lib.CompatibilityModeExtended.String(), arc.CompatibilityMode)520		checkArchive(t, arc, lib.RuntimeOptions{}, "")521		checkArchive(t, arc, extCompatModeRtOpts, "")522		checkArchive(t, arc, baseCompatModeRtOpts, "Unexpected reserved word")523	})524	t.Run("es5_script_with_extended", func(t *testing.T) {525		t.Parallel()526		arc, err := getArchive(t, es5Code, lib.RuntimeOptions{})527		require.NoError(t, err)528		require.Equal(t, lib.CompatibilityModeExtended.String(), arc.CompatibilityMode)529		checkArchive(t, arc, lib.RuntimeOptions{}, "")530		checkArchive(t, arc, extCompatModeRtOpts, "")531		checkArchive(t, arc, baseCompatModeRtOpts, "")532	})533	t.Run("es5_script", func(t *testing.T) {534		t.Parallel()535		arc, err := getArchive(t, es5Code, baseCompatModeRtOpts)536		require.NoError(t, err)537		require.Equal(t, lib.CompatibilityModeBase.String(), arc.CompatibilityMode)538		checkArchive(t, arc, lib.RuntimeOptions{}, "")539		checkArchive(t, arc, extCompatModeRtOpts, "")540		checkArchive(t, arc, baseCompatModeRtOpts, "")541	})542	t.Run("es6_archive_with_wrong_compat_mode", func(t *testing.T) {543		t.Parallel()544		arc, err := getArchive(t, es6Code, baseCompatModeRtOpts)545		require.Error(t, err)546		require.Nil(t, arc)547	})548	t.Run("messed_up_archive", func(t *testing.T) {549		t.Parallel()550		arc, err := getArchive(t, es6Code, extCompatModeRtOpts)551		require.NoError(t, err)552		arc.CompatibilityMode = "blah"                                           // intentionally break the archive553		checkArchive(t, arc, lib.RuntimeOptions{}, "invalid compatibility mode") // fails when it uses the archive one554		checkArchive(t, arc, extCompatModeRtOpts, "")                            // works when I force the compat mode555		checkArchive(t, arc, baseCompatModeRtOpts, "Unexpected reserved word")   // failes because of ES6556	})557	t.Run("script_options_dont_overwrite_metadata", func(t *testing.T) {558		t.Parallel()559		code := `export let options = { vus: 12345 }; export default function() { return options.vus; };`560		arc := &lib.Archive{561			Type:        "js",562			FilenameURL: &url.URL{Scheme: "file", Path: "/script"},563			K6Version:   consts.Version,564			Data:        []byte(code),565			Options:     lib.Options{VUs: null.IntFrom(999)},566			PwdURL:      &url.URL{Scheme: "file", Path: "/"},567			Filesystems: nil,568		}569		b, err := NewBundleFromArchive(logger, arc, lib.RuntimeOptions{}, metrics.NewRegistry())570		require.NoError(t, err)571		bi, err := b.Instantiate(logger, 0, newModuleVUImpl())572		require.NoError(t, err)573		val, err := bi.exports[consts.DefaultFn](goja.Undefined())574		require.NoError(t, err)575		assert.Equal(t, int64(999), val.Export())576	})577}578func TestOpen(t *testing.T) {579	testCases := [...]struct {580		name           string581		openPath       string582		pwd            string583		isError        bool584		isArchiveError bool585	}{586		{587			name:     "notOpeningUrls",588			openPath: "github.com",589			isError:  true,590			pwd:      "/path/to",591		},592		{593			name:     "simple",594			openPath: "file.txt",595			pwd:      "/path/to",596		},597		{598			name:     "simple with dot",599			openPath: "./file.txt",600			pwd:      "/path/to",601		},602		{603			name:     "simple with two dots",604			openPath: "../to/file.txt",605			pwd:      "/path/not",606		},607		{608			name:     "fullpath",609			openPath: "/path/to/file.txt",610			pwd:      "/path/to",611		},612		{613			name:     "fullpath2",614			openPath: "/path/to/file.txt",615			pwd:      "/path",616		},617		{618			name:     "file is dir",619			openPath: "/path/to/",620			pwd:      "/path/to",621			isError:  true,622		},623		{624			name:     "file is missing",625			openPath: "/path/to/missing.txt",626			isError:  true,627		},628		{629			name:     "relative1",630			openPath: "to/file.txt",631			pwd:      "/path",632		},633		{634			name:     "relative2",635			openPath: "./path/to/file.txt",636			pwd:      "/",637		},638		{639			name:     "relative wonky",640			openPath: "../path/to/file.txt",641			pwd:      "/path",642		},643		{644			name:     "empty open doesn't panic",645			openPath: "",646			pwd:      "/path",647			isError:  true,648		},649	}650	fss := map[string]func() (afero.Fs, string, func()){651		"MemMapFS": func() (afero.Fs, string, func()) {652			fs := afero.NewMemMapFs()653			require.NoError(t, fs.MkdirAll("/path/to", 0o755))654			require.NoError(t, afero.WriteFile(fs, "/path/to/file.txt", []byte(`hi`), 0o644))655			return fs, "", func() {}656		},657		"OsFS": func() (afero.Fs, string, func()) {658			prefix, err := ioutil.TempDir("", "k6_open_test")659			require.NoError(t, err)660			fs := afero.NewOsFs()661			filePath := filepath.Join(prefix, "/path/to/file.txt")662			require.NoError(t, fs.MkdirAll(filepath.Join(prefix, "/path/to"), 0o755))663			require.NoError(t, afero.WriteFile(fs, filePath, []byte(`hi`), 0o644))664			if isWindows {665				fs = fsext.NewTrimFilePathSeparatorFs(fs)666			}667			return fs, prefix, func() { require.NoError(t, os.RemoveAll(prefix)) }668		},669	}670	logger := testutils.NewLogger(t)671	for name, fsInit := range fss {672		t.Run(name, func(t *testing.T) {673			t.Parallel()674			for _, tCase := range testCases {675				tCase := tCase676				testFunc := func(t *testing.T) {677					t.Parallel()678					fs, prefix, cleanUp := fsInit()679					defer cleanUp()680					fs = afero.NewReadOnlyFs(fs)681					openPath := tCase.openPath682					// if fullpath prepend prefix683					if openPath != "" && (openPath[0] == '/' || openPath[0] == '\\') {684						openPath = filepath.Join(prefix, openPath)685					}686					if isWindows {687						openPath = strings.Replace(openPath, `\`, `\\`, -1)688					}689					pwd := tCase.pwd690					if pwd == "" {691						pwd = "/path/to/"692					}693					data := `694						export let file = open("` + openPath + `");695						export default function() { return file };`696					sourceBundle, err := getSimpleBundle(t, filepath.ToSlash(filepath.Join(prefix, pwd, "script.js")), data, fs)697					if tCase.isError {698						assert.Error(t, err)699						return700					}701					require.NoError(t, err)702					arcBundle, err := NewBundleFromArchive(logger, sourceBundle.makeArchive(), lib.RuntimeOptions{}, metrics.NewRegistry())703					require.NoError(t, err)704					for source, b := range map[string]*Bundle{"source": sourceBundle, "archive": arcBundle} {705						b := b706						t.Run(source, func(t *testing.T) {707							bi, err := b.Instantiate(logger, 0, newModuleVUImpl())708							require.NoError(t, err)709							v, err := bi.exports[consts.DefaultFn](goja.Undefined())710							require.NoError(t, err)711							assert.Equal(t, "hi", v.Export())712						})713					}714				}715				t.Run(tCase.name, testFunc)716				if isWindows {717					// windowsify the testcase718					tCase.openPath = strings.Replace(tCase.openPath, `/`, `\`, -1)719					tCase.pwd = strings.Replace(tCase.pwd, `/`, `\`, -1)720					t.Run(tCase.name+" with windows slash", testFunc)721				}722			}723		})724	}725}726func TestBundleInstantiate(t *testing.T) {727	t.Parallel()728	t.Run("Run", func(t *testing.T) {729		t.Parallel()730		b, err := getSimpleBundle(t, "/script.js", `731		export let options = {732			vus: 5,733			teardownTimeout: '1s',734		};735		let val = true;736		export default function() { return val; }737	`)738		require.NoError(t, err)739		logger := testutils.NewLogger(t)740		bi, err := b.Instantiate(logger, 0, newModuleVUImpl())741		require.NoError(t, err)742		v, err := bi.exports[consts.DefaultFn](goja.Undefined())743		if assert.NoError(t, err) {744			assert.Equal(t, true, v.Export())745		}746	})747	t.Run("SetAndRun", func(t *testing.T) {748		t.Parallel()749		b, err := getSimpleBundle(t, "/script.js", `750		export let options = {751			vus: 5,752			teardownTimeout: '1s',753		};754		let val = true;755		export default function() { return val; }756	`)757		require.NoError(t, err)758		logger := testutils.NewLogger(t)759		bi, err := b.Instantiate(logger, 0, newModuleVUImpl())760		require.NoError(t, err)761		bi.Runtime.Set("val", false)762		v, err := bi.exports[consts.DefaultFn](goja.Undefined())763		if assert.NoError(t, err) {764			assert.Equal(t, false, v.Export())765		}766	})767	t.Run("Options", func(t *testing.T) {768		t.Parallel()769		b, err := getSimpleBundle(t, "/script.js", `770			export let options = {771				vus: 5,772				teardownTimeout: '1s',773			};774			let val = true;775			export default function() { return val; }776		`)777		require.NoError(t, err)778		logger := testutils.NewLogger(t)779		bi, err := b.Instantiate(logger, 0, newModuleVUImpl())780		require.NoError(t, err)781		// Ensure `options` properties are correctly marshalled782		jsOptions := bi.Runtime.Get("options").ToObject(bi.Runtime)783		vus := jsOptions.Get("vus").Export()784		assert.Equal(t, int64(5), vus)785		tdt := jsOptions.Get("teardownTimeout").Export()786		assert.Equal(t, "1s", tdt)787		// Ensure options propagate correctly from outside to the script788		optOrig := b.Options.VUs789		b.Options.VUs = null.IntFrom(10)790		bi2, err := b.Instantiate(logger, 0, newModuleVUImpl())791		assert.NoError(t, err)792		jsOptions = bi2.Runtime.Get("options").ToObject(bi2.Runtime)793		vus = jsOptions.Get("vus").Export()794		assert.Equal(t, int64(10), vus)795		b.Options.VUs = optOrig796	})797}798func TestBundleEnv(t *testing.T) {799	t.Parallel()800	rtOpts := lib.RuntimeOptions{Env: map[string]string{801		"TEST_A": "1",802		"TEST_B": "",803	}}804	data := `805		export default function() {806			if (__ENV.TEST_A !== "1") { throw new Error("Invalid TEST_A: " + __ENV.TEST_A); }807			if (__ENV.TEST_B !== "") { throw new Error("Invalid TEST_B: " + __ENV.TEST_B); }808		}809	`810	b1, err := getSimpleBundle(t, "/script.js", data, rtOpts)811	require.NoError(t, err)812	logger := testutils.NewLogger(t)813	b2, err := NewBundleFromArchive(logger, b1.makeArchive(), lib.RuntimeOptions{}, metrics.NewRegistry())814	require.NoError(t, err)815	bundles := map[string]*Bundle{"Source": b1, "Archive": b2}816	for name, b := range bundles {817		b := b818		t.Run(name, func(t *testing.T) {819			t.Parallel()820			assert.Equal(t, "1", b.RuntimeOptions.Env["TEST_A"])821			assert.Equal(t, "", b.RuntimeOptions.Env["TEST_B"])822			bi, err := b.Instantiate(logger, 0, newModuleVUImpl())823			if assert.NoError(t, err) {824				_, err := bi.exports[consts.DefaultFn](goja.Undefined())825				assert.NoError(t, err)826			}827		})828	}829}830func TestBundleNotSharable(t *testing.T) {831	t.Parallel()832	data := `833		export default function() {834			if (__ITER == 0) {835				if (typeof __ENV.something !== "undefined") {836					throw new Error("invalid something: " + __ENV.something + " should be undefined");837				}838				__ENV.something = __VU;839			} else if (__ENV.something != __VU) {840				throw new Error("invalid something: " + __ENV.something+ " should be "+ __VU);841			}842		}843	`844	b1, err := getSimpleBundle(t, "/script.js", data)845	require.NoError(t, err)846	logger := testutils.NewLogger(t)847	b2, err := NewBundleFromArchive(logger, b1.makeArchive(), lib.RuntimeOptions{}, metrics.NewRegistry())848	require.NoError(t, err)849	bundles := map[string]*Bundle{"Source": b1, "Archive": b2}850	vus, iters := 10, 1000851	for name, b := range bundles {852		b := b853		t.Run(name, func(t *testing.T) {854			t.Parallel()855			for i := 0; i < vus; i++ {856				bi, err := b.Instantiate(logger, uint64(i), newModuleVUImpl())857				require.NoError(t, err)858				for j := 0; j < iters; j++ {859					bi.Runtime.Set("__ITER", j)860					_, err := bi.exports[consts.DefaultFn](goja.Undefined())861					assert.NoError(t, err)862				}863			}864		})865	}866}867func TestBundleMakeArchive(t *testing.T) {868	t.Parallel()869	testCases := []struct {870		cm      lib.CompatibilityMode871		script  string872		exclaim string873	}{874		{875			lib.CompatibilityModeExtended, `876				import exclaim from "./exclaim.js";877				export let options = { vus: 12345 };878				export let file = open("./file.txt");879				export default function() { return exclaim(file); };`,880			`export default function(s) { return s + "!" };`,881		},882		{883			lib.CompatibilityModeBase, `884				var exclaim = require("./exclaim.js");885				module.exports.options = { vus: 12345 };886				module.exports.file = open("./file.txt");887				module.exports.default = function() { return exclaim(module.exports.file); };`,888			`module.exports.default = function(s) { return s + "!" };`,889		},890	}891	for _, tc := range testCases {892		tc := tc893		t.Run(tc.cm.String(), func(t *testing.T) {894			t.Parallel()895			fs := afero.NewMemMapFs()896			_ = fs.MkdirAll("/path/to", 0o755)897			_ = afero.WriteFile(fs, "/path/to/file.txt", []byte(`hi`), 0o644)898			_ = afero.WriteFile(fs, "/path/to/exclaim.js", []byte(tc.exclaim), 0o644)899			rtOpts := lib.RuntimeOptions{CompatibilityMode: null.StringFrom(tc.cm.String())}900			b, err := getSimpleBundle(t, "/path/to/script.js", tc.script, fs, rtOpts)901			assert.NoError(t, err)902			arc := b.makeArchive()903			assert.Equal(t, "js", arc.Type)904			assert.Equal(t, lib.Options{VUs: null.IntFrom(12345)}, arc.Options)905			assert.Equal(t, "file:///path/to/script.js", arc.FilenameURL.String())906			assert.Equal(t, tc.script, string(arc.Data))907			assert.Equal(t, "file:///path/to/", arc.PwdURL.String())908			exclaimData, err := afero.ReadFile(arc.Filesystems["file"], "/path/to/exclaim.js")909			assert.NoError(t, err)910			assert.Equal(t, tc.exclaim, string(exclaimData))911			fileData, err := afero.ReadFile(arc.Filesystems["file"], "/path/to/file.txt")912			assert.NoError(t, err)913			assert.Equal(t, `hi`, string(fileData))914			assert.Equal(t, consts.Version, arc.K6Version)...

getSimpleBundle

Using AI Code Generation

1import (2func main() {3	c := js.Global.Get("getSimpleBundle")4	fmt.Println(c)5}6import (7func main() {8	c := js.Global.Get("getSimpleBundle")9	fmt.Println(c)10}11import (12func main() {13	c := js.Global.Get("getSimpleBundle")14	fmt.Println(c)15}16import (17func main() {18	c := js.Global.Get("getSimpleBundle")19	fmt.Println(c)20}21import (22func main() {23	c := js.Global.Get("getSimpleBundle")24	fmt.Println(c)25}26import (27func main() {28	c := js.Global.Get("getSimpleBundle")29	fmt.Println(c)30}31import (32func main() {33	c := js.Global.Get("getSimpleBundle")34	fmt.Println(c)35}36import (37func main() {38	c := js.Global.Get("getSimpleBundle")39	fmt.Println(c)40}

getSimpleBundle

Using AI Code Generation

1public class Test {2    public static void main(String[] args) {3        ScriptEngineManager factory = new ScriptEngineManager();4        ScriptEngine engine = factory.getEngineByName("JavaScript");5        try {6            engine.eval("load('C:/Users/Abhishek/Desktop/1.js')");7            Invocable inv = (Invocable) engine;8            inv.invokeFunction("getSimpleBundle");9        } catch (ScriptException e) {10            e.printStackTrace();11        } catch (NoSuchMethodException e) {12            e.printStackTrace();13        }14    }15}16{key1=value1, key2=value2, key3=value3}

getSimpleBundle

Using AI Code Generation

1import "github.com/robertkrimen/otto"2import "fmt"3func main() {4vm := otto.New()5vm.Run(`6    var js = require('js');7    var bundle = js.getSimpleBundle();8    console.log(bundle);9}10function getSimpleBundle() {11    return {12        "address": {13        }14    }15}16module.exports = {17}

getSimpleBundle

Using AI Code Generation

1import (2func main() {3	bundle := js.Global.Get("getSimpleBundle").Invoke()4	value := bundle.Get("key")5	fmt.Println(value)6}

getSimpleBundle

Using AI Code Generation

1var bundleClass = Java.use("com.example.test.MyBundle");2var bundle = bundleClass.getSimpleBundle();3console.log("Bundle: " + bundle);4var bundleClass = Java.use("com.example.test.MyBundle");5var bundle = bundleClass.getBundle();6console.log("Bundle: " + bundle);7var bundleClass = Java.use("com.example.test.MyBundle");8var bundle = bundleClass.getBundle();9console.log("Bundle: " + bundle);10var bundleClass = Java.use("com.example.test.MyBundle");11var bundle = bundleClass.getBundle();12console.log("Bundle: " + bundle);13var bundleClass = Java.use("com.example.test.MyBundle");14var bundle = bundleClass.getBundle();15console.log("Bundle: " + bundle);16var bundleClass = Java.use("com.example.test.MyBundle");17var bundle = bundleClass.getBundle();18console.log("Bundle: " + bundle);19var bundleClass = Java.use("com.example.test.MyBundle");20var bundle = bundleClass.getBundle();21console.log("Bundle: " + bundle);22var bundleClass = Java.use("com.example.test.MyBundle");23var bundle = bundleClass.getBundle();24console.log("Bundle

Automation Testing Tutorials

Learn to execute automation testing from scratch with LambdaTest Learning Hub. Right from setting up the prerequisites to run your first automation test, to following best practices and diving deeper into advanced test scenarios. LambdaTest Learning Hubs compile a list of step-by-step guides to help you be proficient with different test automation frameworks i.e. Selenium, Cypress, TestNG etc.