How to use init method of td Package

Best Go-testdeep code snippet using td.init

init_test.go

Source:init_test.go

...59			Ui:               ui,60		},61	}62	args := []string{63		"-from-module=" + testFixturePath("init"),64		dir,65	}66	if code := c.Run(args); code != 0 {67		t.Fatalf("bad: \n%s", ui.ErrorWriter.String())68	}69	if _, err := os.Stat(filepath.Join(dir, "hello.tf")); err != nil {70		t.Fatalf("err: %s", err)71	}72}73func TestInit_fromModule_cwdDest(t *testing.T) {74	// Create a temporary working directory that is empty75	td := tempDir(t)76	os.MkdirAll(td, os.ModePerm)77	defer os.RemoveAll(td)78	defer testChdir(t, td)()79	ui := new(cli.MockUi)80	c := &InitCommand{81		Meta: Meta{82			testingOverrides: metaOverridesForProvider(testProvider()),83			Ui:               ui,84		},85	}86	args := []string{87		"-from-module=" + testFixturePath("init"),88	}89	if code := c.Run(args); code != 0 {90		t.Fatalf("bad: \n%s", ui.ErrorWriter.String())91	}92	if _, err := os.Stat(filepath.Join(td, "hello.tf")); err != nil {93		t.Fatalf("err: %s", err)94	}95}96// https://github.com/hashicorp/terraform/issues/51897func TestInit_fromModule_dstInSrc(t *testing.T) {98	dir := tempDir(t)99	if err := os.MkdirAll(dir, 0755); err != nil {100		t.Fatalf("err: %s", err)101	}102	// Change to the temporary directory103	cwd, err := os.Getwd()104	if err != nil {105		t.Fatalf("err: %s", err)106	}107	if err := os.Chdir(dir); err != nil {108		t.Fatalf("err: %s", err)109	}110	defer os.Chdir(cwd)111	if _, err := os.Create("issue518.tf"); err != nil {112		t.Fatalf("err: %s", err)113	}114	ui := new(cli.MockUi)115	c := &InitCommand{116		Meta: Meta{117			testingOverrides: metaOverridesForProvider(testProvider()),118			Ui:               ui,119		},120	}121	args := []string{122		"-from-module=.",123		"foo",124	}125	if code := c.Run(args); code != 0 {126		t.Fatalf("bad: \n%s", ui.ErrorWriter.String())127	}128	if _, err := os.Stat(filepath.Join(dir, "foo", "issue518.tf")); err != nil {129		t.Fatalf("err: %s", err)130	}131}132func TestInit_get(t *testing.T) {133	// Create a temporary working directory that is empty134	td := tempDir(t)135	copy.CopyDir(testFixturePath("init-get"), td)136	defer os.RemoveAll(td)137	defer testChdir(t, td)()138	ui := new(cli.MockUi)139	c := &InitCommand{140		Meta: Meta{141			testingOverrides: metaOverridesForProvider(testProvider()),142			Ui:               ui,143		},144	}145	args := []string{}146	if code := c.Run(args); code != 0 {147		t.Fatalf("bad: \n%s", ui.ErrorWriter.String())148	}149	// Check output150	output := ui.OutputWriter.String()151	if !strings.Contains(output, "Getting source") {152		t.Fatalf("doesn't look like get: %s", output)153	}154}155func TestInit_getUpgradeModules(t *testing.T) {156	// Create a temporary working directory that is empty157	td := tempDir(t)158	os.MkdirAll(td, 0755)159	// copy.CopyDir(testFixturePath("init-get"), td)160	defer os.RemoveAll(td)161	defer testChdir(t, td)()162	ui := new(cli.MockUi)163	c := &InitCommand{164		Meta: Meta{165			testingOverrides: metaOverridesForProvider(testProvider()),166			Ui:               ui,167		},168	}169	args := []string{170		"-get=true",171		"-get-plugins=false",172		"-upgrade",173		testFixturePath("init-get"),174	}175	if code := c.Run(args); code != 0 {176		t.Fatalf("command did not complete successfully:\n%s", ui.ErrorWriter.String())177	}178	// Check output179	output := ui.OutputWriter.String()180	if !strings.Contains(output, "Updating source") {181		t.Fatalf("doesn't look like get upgrade: %s", output)182	}183}184func TestInit_backend(t *testing.T) {185	// Create a temporary working directory that is empty186	td := tempDir(t)187	copy.CopyDir(testFixturePath("init-backend"), td)188	defer os.RemoveAll(td)189	defer testChdir(t, td)()190	ui := new(cli.MockUi)191	c := &InitCommand{192		Meta: Meta{193			testingOverrides: metaOverridesForProvider(testProvider()),194			Ui:               ui,195		},196	}197	args := []string{}198	if code := c.Run(args); code != 0 {199		t.Fatalf("bad: \n%s", ui.ErrorWriter.String())200	}201	if _, err := os.Stat(filepath.Join(DefaultDataDir, DefaultStateFilename)); err != nil {202		t.Fatalf("err: %s", err)203	}204}205func TestInit_backendUnset(t *testing.T) {206	// Create a temporary working directory that is empty207	td := tempDir(t)208	copy.CopyDir(testFixturePath("init-backend"), td)209	defer os.RemoveAll(td)210	defer testChdir(t, td)()211	{212		ui := new(cli.MockUi)213		c := &InitCommand{214			Meta: Meta{215				testingOverrides: metaOverridesForProvider(testProvider()),216				Ui:               ui,217			},218		}219		// Init220		args := []string{}221		if code := c.Run(args); code != 0 {222			t.Fatalf("bad: \n%s", ui.ErrorWriter.String())223		}224		if _, err := os.Stat(filepath.Join(DefaultDataDir, DefaultStateFilename)); err != nil {225			t.Fatalf("err: %s", err)226		}227	}228	{229		// Unset230		if err := ioutil.WriteFile("main.tf", []byte(""), 0644); err != nil {231			t.Fatalf("err: %s", err)232		}233		ui := new(cli.MockUi)234		c := &InitCommand{235			Meta: Meta{236				testingOverrides: metaOverridesForProvider(testProvider()),237				Ui:               ui,238			},239		}240		args := []string{"-force-copy"}241		if code := c.Run(args); code != 0 {242			t.Fatalf("bad: \n%s", ui.ErrorWriter.String())243		}244		s := testStateRead(t, filepath.Join(245			DefaultDataDir, DefaultStateFilename))246		if !s.Backend.Empty() {247			t.Fatal("should not have backend config")248		}249	}250}251func TestInit_backendConfigFile(t *testing.T) {252	// Create a temporary working directory that is empty253	td := tempDir(t)254	copy.CopyDir(testFixturePath("init-backend-config-file"), td)255	defer os.RemoveAll(td)256	defer testChdir(t, td)()257	ui := new(cli.MockUi)258	c := &InitCommand{259		Meta: Meta{260			testingOverrides: metaOverridesForProvider(testProvider()),261			Ui:               ui,262		},263	}264	args := []string{"-backend-config", "input.config"}265	if code := c.Run(args); code != 0 {266		t.Fatalf("bad: \n%s", ui.ErrorWriter.String())267	}268	// Read our saved backend config and verify we have our settings269	state := testStateRead(t, filepath.Join(DefaultDataDir, DefaultStateFilename))270	if v := state.Backend.Config["path"]; v != "hello" {271		t.Fatalf("bad: %#v", v)272	}273}274func TestInit_backendConfigFileChange(t *testing.T) {275	// Create a temporary working directory that is empty276	td := tempDir(t)277	copy.CopyDir(testFixturePath("init-backend-config-file-change"), td)278	defer os.RemoveAll(td)279	defer testChdir(t, td)()280	// Ask input281	defer testInputMap(t, map[string]string{282		"backend-migrate-to-new": "no",283	})()284	ui := new(cli.MockUi)285	c := &InitCommand{286		Meta: Meta{287			testingOverrides: metaOverridesForProvider(testProvider()),288			Ui:               ui,289		},290	}291	args := []string{"-backend-config", "input.config"}292	if code := c.Run(args); code != 0 {293		t.Fatalf("bad: \n%s", ui.ErrorWriter.String())294	}295	// Read our saved backend config and verify we have our settings296	state := testStateRead(t, filepath.Join(DefaultDataDir, DefaultStateFilename))297	if v := state.Backend.Config["path"]; v != "hello" {298		t.Fatalf("bad: %#v", v)299	}300}301func TestInit_backendConfigKV(t *testing.T) {302	// Create a temporary working directory that is empty303	td := tempDir(t)304	copy.CopyDir(testFixturePath("init-backend-config-kv"), td)305	defer os.RemoveAll(td)306	defer testChdir(t, td)()307	ui := new(cli.MockUi)308	c := &InitCommand{309		Meta: Meta{310			testingOverrides: metaOverridesForProvider(testProvider()),311			Ui:               ui,312		},313	}314	args := []string{"-backend-config", "path=hello"}315	if code := c.Run(args); code != 0 {316		t.Fatalf("bad: \n%s", ui.ErrorWriter.String())317	}318	// Read our saved backend config and verify we have our settings319	state := testStateRead(t, filepath.Join(DefaultDataDir, DefaultStateFilename))320	if v := state.Backend.Config["path"]; v != "hello" {321		t.Fatalf("bad: %#v", v)322	}323}324func TestInit_targetSubdir(t *testing.T) {325	// Create a temporary working directory that is empty326	td := tempDir(t)327	os.MkdirAll(td, 0755)328	defer os.RemoveAll(td)329	defer testChdir(t, td)()330	// copy the source into a subdir331	copy.CopyDir(testFixturePath("init-backend"), filepath.Join(td, "source"))332	ui := new(cli.MockUi)333	c := &InitCommand{334		Meta: Meta{335			testingOverrides: metaOverridesForProvider(testProvider()),336			Ui:               ui,337		},338	}339	args := []string{340		"source",341	}342	if code := c.Run(args); code != 0 {343		t.Fatalf("bad: \n%s", ui.ErrorWriter.String())344	}345	if _, err := os.Stat(filepath.Join(td, DefaultDataDir, DefaultStateFilename)); err != nil {346		t.Fatalf("err: %s", err)347	}348	// a data directory should not have been added to out working dir349	if _, err := os.Stat(filepath.Join(td, "source", DefaultDataDir)); !os.IsNotExist(err) {350		t.Fatalf("err: %s", err)351	}352}353func TestInit_backendReinitWithExtra(t *testing.T) {354	td := tempDir(t)355	copy.CopyDir(testFixturePath("init-backend-empty"), td)356	defer os.RemoveAll(td)357	defer testChdir(t, td)()358	m := testMetaBackend(t, nil)359	opts := &BackendOpts{360		ConfigExtra: map[string]interface{}{"path": "hello"},361		Init:        true,362	}363	b, err := m.backendConfig(opts)364	if err != nil {365		t.Fatal(err)366	}367	ui := new(cli.MockUi)368	c := &InitCommand{369		Meta: Meta{370			testingOverrides: metaOverridesForProvider(testProvider()),371			Ui:               ui,372		},373	}374	args := []string{"-backend-config", "path=hello"}375	if code := c.Run(args); code != 0 {376		t.Fatalf("bad: \n%s", ui.ErrorWriter.String())377	}378	// Read our saved backend config and verify we have our settings379	state := testStateRead(t, filepath.Join(DefaultDataDir, DefaultStateFilename))380	if v := state.Backend.Config["path"]; v != "hello" {381		t.Fatalf("bad: %#v", v)382	}383	if state.Backend.Hash != b.Hash {384		t.Fatal("mismatched state and config backend hashes")385	}386	if state.Backend.Rehash() != b.Rehash() {387		t.Fatal("mismatched state and config re-hashes")388	}389	// init again and make sure nothing changes390	if code := c.Run(args); code != 0 {391		t.Fatalf("bad: \n%s", ui.ErrorWriter.String())392	}393	state = testStateRead(t, filepath.Join(DefaultDataDir, DefaultStateFilename))394	if v := state.Backend.Config["path"]; v != "hello" {395		t.Fatalf("bad: %#v", v)396	}397	if state.Backend.Hash != b.Hash {398		t.Fatal("mismatched state and config backend hashes")399	}400}401// move option from config to -backend-config args402func TestInit_backendReinitConfigToExtra(t *testing.T) {403	td := tempDir(t)404	copy.CopyDir(testFixturePath("init-backend"), td)405	defer os.RemoveAll(td)406	defer testChdir(t, td)()407	ui := new(cli.MockUi)408	c := &InitCommand{409		Meta: Meta{410			testingOverrides: metaOverridesForProvider(testProvider()),411			Ui:               ui,412		},413	}414	if code := c.Run([]string{"-input=false"}); code != 0 {415		t.Fatalf("bad: \n%s", ui.ErrorWriter.String())416	}417	// Read our saved backend config and verify we have our settings418	state := testStateRead(t, filepath.Join(DefaultDataDir, DefaultStateFilename))419	if v := state.Backend.Config["path"]; v != "foo" {420		t.Fatalf("bad: %#v", v)421	}422	backendHash := state.Backend.Hash423	// init again but remove the path option from the config424	cfg := "terraform {\n  backend \"local\" {}\n}\n"425	if err := ioutil.WriteFile("main.tf", []byte(cfg), 0644); err != nil {426		t.Fatal(err)427	}428	args := []string{"-input=false", "-backend-config=path=foo"}429	if code := c.Run(args); code != 0 {430		t.Fatalf("bad: \n%s", ui.ErrorWriter.String())431	}432	state = testStateRead(t, filepath.Join(DefaultDataDir, DefaultStateFilename))433	if state.Backend.Hash == backendHash {434		t.Fatal("state.Backend.Hash was not updated")435	}436}437// make sure inputFalse stops execution on migrate438func TestInit_inputFalse(t *testing.T) {439	td := tempDir(t)440	copy.CopyDir(testFixturePath("init-backend"), td)441	defer os.RemoveAll(td)442	defer testChdir(t, td)()443	ui := new(cli.MockUi)444	c := &InitCommand{445		Meta: Meta{446			testingOverrides: metaOverridesForProvider(testProvider()),447			Ui:               ui,448		},449	}450	args := []string{"-input=false", "-backend-config=path=foo"}451	if code := c.Run([]string{"-input=false"}); code != 0 {452		t.Fatalf("bad: \n%s", ui.ErrorWriter)453	}454	// write different states for foo and bar455	s := terraform.NewState()456	s.Lineage = "foo"457	if err := (&state.LocalState{Path: "foo"}).WriteState(s); err != nil {458		t.Fatal(err)459	}460	s.Lineage = "bar"461	if err := (&state.LocalState{Path: "bar"}).WriteState(s); err != nil {462		t.Fatal(err)463	}464	ui = new(cli.MockUi)465	c = &InitCommand{466		Meta: Meta{467			testingOverrides: metaOverridesForProvider(testProvider()),468			Ui:               ui,469		},470	}471	args = []string{"-input=false", "-backend-config=path=bar"}472	if code := c.Run(args); code == 0 {473		t.Fatal("init should have failed", ui.OutputWriter)474	}475	errMsg := ui.ErrorWriter.String()476	if !strings.Contains(errMsg, "input disabled") {477		t.Fatal("expected input disabled error, got", errMsg)478	}479	ui = new(cli.MockUi)480	c = &InitCommand{481		Meta: Meta{482			testingOverrides: metaOverridesForProvider(testProvider()),483			Ui:               ui,484		},485	}486	// A missing input=false should abort rather than loop infinitely487	args = []string{"-backend-config=path=bar"}488	if code := c.Run(args); code == 0 {489		t.Fatal("init should have failed", ui.OutputWriter)490	}491}492func TestInit_getProvider(t *testing.T) {493	// Create a temporary working directory that is empty494	td := tempDir(t)495	copy.CopyDir(testFixturePath("init-get-providers"), td)496	defer os.RemoveAll(td)497	defer testChdir(t, td)()498	overrides := metaOverridesForProvider(testProvider())499	ui := new(cli.MockUi)500	m := Meta{501		testingOverrides: overrides,502		Ui:               ui,503	}504	installer := &mockProviderInstaller{505		Providers: map[string][]string{506			// looking for an exact version507			"exact": []string{"1.2.3"},508			// config requires >= 2.3.3509			"greater_than": []string{"2.3.4", "2.3.3", "2.3.0"},510			// config specifies511			"between": []string{"3.4.5", "2.3.4", "1.2.3"},512		},513		Dir: m.pluginDir(),514	}515	c := &InitCommand{516		Meta:              m,517		providerInstaller: installer,518	}519	args := []string{520		"-backend=false", // should be possible to install plugins without backend init521	}522	if code := c.Run(args); code != 0 {523		t.Fatalf("bad: \n%s", ui.ErrorWriter.String())524	}525	if !installer.PurgeUnusedCalled {526		t.Errorf("init didn't purge providers, but should have")527	}528	// check that we got the providers for our config529	exactPath := filepath.Join(c.pluginDir(), installer.FileName("exact", "1.2.3"))530	if _, err := os.Stat(exactPath); os.IsNotExist(err) {531		t.Fatal("provider 'exact' not downloaded")532	}533	greaterThanPath := filepath.Join(c.pluginDir(), installer.FileName("greater_than", "2.3.4"))534	if _, err := os.Stat(greaterThanPath); os.IsNotExist(err) {535		t.Fatal("provider 'greater_than' not downloaded")536	}537	betweenPath := filepath.Join(c.pluginDir(), installer.FileName("between", "2.3.4"))538	if _, err := os.Stat(betweenPath); os.IsNotExist(err) {539		t.Fatal("provider 'between' not downloaded")540	}541	t.Run("future-state", func(t *testing.T) {542		// getting providers should fail if a state from a newer version of543		// terraform exists, since InitCommand.getProviders needs to inspect that544		// state.545		s := terraform.NewState()546		s.TFVersion = "100.1.0"547		local := &state.LocalState{548			Path: local.DefaultStateFilename,549		}550		if err := local.WriteState(s); err != nil {551			t.Fatal(err)552		}553		ui := new(cli.MockUi)554		m.Ui = ui555		c := &InitCommand{556			Meta:              m,557			providerInstaller: installer,558		}559		if code := c.Run(nil); code == 0 {560			t.Fatal("expected error, got:", ui.OutputWriter)561		}562		errMsg := ui.ErrorWriter.String()563		if !strings.Contains(errMsg, "future Terraform version") {564			t.Fatal("unexpected error:", errMsg)565		}566	})567}568// make sure we can locate providers in various paths569func TestInit_findVendoredProviders(t *testing.T) {570	// Create a temporary working directory that is empty571	td := tempDir(t)572	configDirName := "init-get-providers"573	copy.CopyDir(testFixturePath(configDirName), filepath.Join(td, configDirName))574	defer os.RemoveAll(td)575	defer testChdir(t, td)()576	ui := new(cli.MockUi)577	m := Meta{578		testingOverrides: metaOverridesForProvider(testProvider()),579		Ui:               ui,580	}581	c := &InitCommand{582		Meta:              m,583		providerInstaller: &mockProviderInstaller{},584	}585	// make our plugin paths586	if err := os.MkdirAll(c.pluginDir(), 0755); err != nil {587		t.Fatal(err)588	}589	if err := os.MkdirAll(DefaultPluginVendorDir, 0755); err != nil {590		t.Fatal(err)591	}592	// add some dummy providers593	// the auto plugin directory594	exactPath := filepath.Join(c.pluginDir(), "terraform-provider-exact_v1.2.3_x4")595	if err := ioutil.WriteFile(exactPath, []byte("test bin"), 0755); err != nil {596		t.Fatal(err)597	}598	// the vendor path599	greaterThanPath := filepath.Join(DefaultPluginVendorDir, "terraform-provider-greater_than_v2.3.4_x4")600	if err := ioutil.WriteFile(greaterThanPath, []byte("test bin"), 0755); err != nil {601		t.Fatal(err)602	}603	// Check the current directory too604	betweenPath := filepath.Join(".", "terraform-provider-between_v2.3.4_x4")605	if err := ioutil.WriteFile(betweenPath, []byte("test bin"), 0755); err != nil {606		t.Fatal(err)607	}608	args := []string{configDirName}609	if code := c.Run(args); code != 0 {610		t.Fatalf("bad: \n%s", ui.ErrorWriter.String())611	}612}613// make sure we can locate providers defined in the legacy rc file614func TestInit_rcProviders(t *testing.T) {615	// Create a temporary working directory that is empty616	td := tempDir(t)617	configDirName := "init-legacy-rc"618	copy.CopyDir(testFixturePath(configDirName), filepath.Join(td, configDirName))619	defer os.RemoveAll(td)620	defer testChdir(t, td)()621	pluginDir := filepath.Join(td, "custom")622	pluginPath := filepath.Join(pluginDir, "terraform-provider-legacy")623	ui := new(cli.MockUi)624	m := Meta{625		Ui: ui,626		PluginOverrides: &PluginOverrides{627			Providers: map[string]string{628				"legacy": pluginPath,629			},630		},631	}632	c := &InitCommand{633		Meta:              m,634		providerInstaller: &mockProviderInstaller{},635	}636	// make our plugin paths637	if err := os.MkdirAll(pluginDir, 0755); err != nil {638		t.Fatal(err)639	}640	if err := ioutil.WriteFile(pluginPath, []byte("test bin"), 0755); err != nil {641		t.Fatal(err)642	}643	args := []string{configDirName}644	if code := c.Run(args); code != 0 {645		t.Fatalf("bad: \n%s", ui.ErrorWriter.String())646	}647}648func TestInit_getUpgradePlugins(t *testing.T) {649	// Create a temporary working directory that is empty650	td := tempDir(t)651	copy.CopyDir(testFixturePath("init-get-providers"), td)652	defer os.RemoveAll(td)653	defer testChdir(t, td)()654	ui := new(cli.MockUi)655	m := Meta{656		testingOverrides: metaOverridesForProvider(testProvider()),657		Ui:               ui,658	}659	installer := &mockProviderInstaller{660		Providers: map[string][]string{661			// looking for an exact version662			"exact": []string{"1.2.3"},663			// config requires >= 2.3.3664			"greater_than": []string{"2.3.4", "2.3.3", "2.3.0"},665			// config specifies666			"between": []string{"3.4.5", "2.3.4", "1.2.3"},667		},668		Dir: m.pluginDir(),669	}670	err := os.MkdirAll(m.pluginDir(), os.ModePerm)671	if err != nil {672		t.Fatal(err)673	}674	exactUnwanted := filepath.Join(m.pluginDir(), installer.FileName("exact", "0.0.1"))675	err = ioutil.WriteFile(exactUnwanted, []byte{}, os.ModePerm)676	if err != nil {677		t.Fatal(err)678	}679	greaterThanUnwanted := filepath.Join(m.pluginDir(), installer.FileName("greater_than", "2.3.3"))680	err = ioutil.WriteFile(greaterThanUnwanted, []byte{}, os.ModePerm)681	if err != nil {682		t.Fatal(err)683	}684	betweenOverride := installer.FileName("between", "2.3.4") // intentionally directly in cwd, and should override auto-install685	err = ioutil.WriteFile(betweenOverride, []byte{}, os.ModePerm)686	if err != nil {687		t.Fatal(err)688	}689	c := &InitCommand{690		Meta:              m,691		providerInstaller: installer,692	}693	args := []string{694		"-upgrade=true",695	}696	if code := c.Run(args); code != 0 {697		t.Fatalf("command did not complete successfully:\n%s", ui.ErrorWriter.String())698	}699	files, err := ioutil.ReadDir(m.pluginDir())700	if err != nil {701		t.Fatal(err)702	}703	if !installer.PurgeUnusedCalled {704		t.Errorf("init -upgrade didn't purge providers, but should have")705	}706	gotFilenames := make([]string, len(files))707	for i, info := range files {708		gotFilenames[i] = info.Name()709	}710	sort.Strings(gotFilenames)711	wantFilenames := []string{712		"lock.json",713		// no "between" because the file in cwd overrides it714		// The mock PurgeUnused doesn't actually purge anything, so the dir715		// includes both our old and new versions.716		"terraform-provider-exact_v0.0.1_x4",717		"terraform-provider-exact_v1.2.3_x4",718		"terraform-provider-greater_than_v2.3.3_x4",719		"terraform-provider-greater_than_v2.3.4_x4",720	}721	if !reflect.DeepEqual(gotFilenames, wantFilenames) {722		t.Errorf("wrong directory contents after upgrade\ngot:  %#v\nwant: %#v", gotFilenames, wantFilenames)723	}724}725func TestInit_getProviderMissing(t *testing.T) {726	// Create a temporary working directory that is empty727	td := tempDir(t)728	copy.CopyDir(testFixturePath("init-get-providers"), td)729	defer os.RemoveAll(td)730	defer testChdir(t, td)()731	ui := new(cli.MockUi)732	m := Meta{733		testingOverrides: metaOverridesForProvider(testProvider()),734		Ui:               ui,735	}736	installer := &mockProviderInstaller{737		Providers: map[string][]string{738			// looking for exact version 1.2.3739			"exact": []string{"1.2.4"},740			// config requires >= 2.3.3741			"greater_than": []string{"2.3.4", "2.3.3", "2.3.0"},742			// config specifies743			"between": []string{"3.4.5", "2.3.4", "1.2.3"},744		},745		Dir: m.pluginDir(),746	}747	c := &InitCommand{748		Meta:              m,749		providerInstaller: installer,750	}751	args := []string{}752	if code := c.Run(args); code == 0 {753		t.Fatalf("expceted error, got output: \n%s", ui.OutputWriter.String())754	}755	if !strings.Contains(ui.ErrorWriter.String(), "no suitable version for provider") {756		t.Fatalf("unexpected error output: %s", ui.ErrorWriter)757	}758}759func TestInit_getProviderHaveLegacyVersion(t *testing.T) {760	// Create a temporary working directory that is empty761	td := tempDir(t)762	copy.CopyDir(testFixturePath("init-providers-lock"), td)763	defer os.RemoveAll(td)764	defer testChdir(t, td)()765	if err := ioutil.WriteFile("terraform-provider-test", []byte("provider bin"), 0755); err != nil {766		t.Fatal(err)767	}768	// provider test has a version constraint in the config, which should769	// trigger the getProvider error below.770	ui := new(cli.MockUi)771	c := &InitCommand{772		Meta: Meta{773			testingOverrides: metaOverridesForProvider(testProvider()),774			Ui:               ui,775		},776		providerInstaller: callbackPluginInstaller(func(provider string, req discovery.Constraints) (discovery.PluginMeta, error) {777			return discovery.PluginMeta{}, fmt.Errorf("EXPECTED PROVIDER ERROR %s", provider)778		}),779	}780	args := []string{}781	if code := c.Run(args); code == 0 {782		t.Fatalf("expceted error, got output: \n%s", ui.OutputWriter.String())783	}784	if !strings.Contains(ui.ErrorWriter.String(), "EXPECTED PROVIDER ERROR test") {785		t.Fatalf("unexpected error output: %s", ui.ErrorWriter)786	}787}788func TestInit_getProviderCheckRequiredVersion(t *testing.T) {789	// Create a temporary working directory that is empty790	td := tempDir(t)791	copy.CopyDir(testFixturePath("init-check-required-version"), td)792	defer os.RemoveAll(td)793	defer testChdir(t, td)()794	ui := new(cli.MockUi)795	c := &InitCommand{796		Meta: Meta{797			testingOverrides: metaOverridesForProvider(testProvider()),798			Ui:               ui,799		},800	}801	args := []string{}802	if code := c.Run(args); code != 1 {803		t.Fatalf("bad: \n%s", ui.ErrorWriter.String())804	}805}806func TestInit_providerLockFile(t *testing.T) {807	// Create a temporary working directory that is empty808	td := tempDir(t)809	copy.CopyDir(testFixturePath("init-provider-lock-file"), td)810	defer os.RemoveAll(td)811	defer testChdir(t, td)()812	ui := new(cli.MockUi)813	m := Meta{814		testingOverrides: metaOverridesForProvider(testProvider()),815		Ui:               ui,816	}817	installer := &mockProviderInstaller{818		Providers: map[string][]string{819			"test": []string{"1.2.3"},820		},821		Dir: m.pluginDir(),822	}823	c := &InitCommand{824		Meta:              m,825		providerInstaller: installer,826	}827	args := []string{}828	if code := c.Run(args); code != 0 {829		t.Fatalf("bad: \n%s", ui.ErrorWriter.String())830	}831	providersLockFile := fmt.Sprintf(832		".terraform/plugins/%s_%s/lock.json",833		runtime.GOOS, runtime.GOARCH,834	)835	buf, err := ioutil.ReadFile(providersLockFile)836	if err != nil {837		t.Fatalf("failed to read providers lock file %s: %s", providersLockFile, err)838	}839	// The hash in here is for the empty files that mockGetProvider produces840	wantLockFile := strings.TrimSpace(`841{842  "test": "e3b0c44298fc1c149afbf4c8996fb92427ae41e4649b934ca495991b7852b855"843}844`)845	if string(buf) != wantLockFile {846		t.Errorf("wrong provider lock file contents\ngot:  %s\nwant: %s", buf, wantLockFile)847	}848}849func TestInit_pluginDirReset(t *testing.T) {850	td, err := ioutil.TempDir("", "tf")851	if err != nil {852		t.Fatal(err)853	}854	defer os.RemoveAll(td)855	defer testChdir(t, td)()856	ui := new(cli.MockUi)857	c := &InitCommand{858		Meta: Meta{859			testingOverrides: metaOverridesForProvider(testProvider()),860			Ui:               ui,861		},862		providerInstaller: &mockProviderInstaller{},863	}864	// make our vendor paths865	pluginPath := []string{"a", "b", "c"}866	for _, p := range pluginPath {867		if err := os.MkdirAll(p, 0755); err != nil {868			t.Fatal(err)869		}870	}871	// run once and save the -plugin-dir872	args := []string{"-plugin-dir", "a"}873	if code := c.Run(args); code != 0 {874		t.Fatalf("bad: \n%s", ui.ErrorWriter)875	}876	pluginDirs, err := c.loadPluginPath()877	if err != nil {878		t.Fatal(err)879	}880	if len(pluginDirs) != 1 || pluginDirs[0] != "a" {881		t.Fatalf(`expected plugin dir ["a"], got %q`, pluginDirs)882	}883	ui = new(cli.MockUi)884	c = &InitCommand{885		Meta: Meta{886			testingOverrides: metaOverridesForProvider(testProvider()),887			Ui:               ui,888		},889		providerInstaller: &mockProviderInstaller{},890	}891	// make sure we remove the plugin-dir record892	args = []string{"-plugin-dir="}893	if code := c.Run(args); code != 0 {894		t.Fatalf("bad: \n%s", ui.ErrorWriter)895	}896	pluginDirs, err = c.loadPluginPath()897	if err != nil {898		t.Fatal(err)899	}900	if len(pluginDirs) != 0 {901		t.Fatalf("expected no plugin dirs got %q", pluginDirs)902	}903}904// Test user-supplied -plugin-dir905func TestInit_pluginDirProviders(t *testing.T) {906	td := tempDir(t)907	copy.CopyDir(testFixturePath("init-get-providers"), td)908	defer os.RemoveAll(td)909	defer testChdir(t, td)()910	ui := new(cli.MockUi)911	m := Meta{912		testingOverrides: metaOverridesForProvider(testProvider()),913		Ui:               ui,914	}915	c := &InitCommand{916		Meta:              m,917		providerInstaller: &mockProviderInstaller{},918	}919	// make our vendor paths920	pluginPath := []string{"a", "b", "c"}921	for _, p := range pluginPath {922		if err := os.MkdirAll(p, 0755); err != nil {923			t.Fatal(err)924		}925	}926	// add some dummy providers in our plugin dirs927	for i, name := range []string{928		"terraform-provider-exact_v1.2.3_x4",929		"terraform-provider-greater_than_v2.3.4_x4",930		"terraform-provider-between_v2.3.4_x4",931	} {932		if err := ioutil.WriteFile(filepath.Join(pluginPath[i], name), []byte("test bin"), 0755); err != nil {933			t.Fatal(err)934		}935	}936	args := []string{937		"-plugin-dir", "a",938		"-plugin-dir", "b",939		"-plugin-dir", "c",940	}941	if code := c.Run(args); code != 0 {942		t.Fatalf("bad: \n%s", ui.ErrorWriter)943	}944}945// Test user-supplied -plugin-dir doesn't allow auto-install946func TestInit_pluginDirProvidersDoesNotGet(t *testing.T) {947	td := tempDir(t)948	copy.CopyDir(testFixturePath("init-get-providers"), td)949	defer os.RemoveAll(td)950	defer testChdir(t, td)()951	ui := new(cli.MockUi)952	m := Meta{953		testingOverrides: metaOverridesForProvider(testProvider()),954		Ui:               ui,955	}956	c := &InitCommand{957		Meta: m,958		providerInstaller: callbackPluginInstaller(func(provider string, req discovery.Constraints) (discovery.PluginMeta, error) {959			t.Fatalf("plugin installer should not have been called for %q", provider)960			return discovery.PluginMeta{}, nil961		}),962	}963	// make our vendor paths964	pluginPath := []string{"a", "b"}965	for _, p := range pluginPath {966		if err := os.MkdirAll(p, 0755); err != nil {967			t.Fatal(err)968		}969	}970	// add some dummy providers in our plugin dirs971	for i, name := range []string{972		"terraform-provider-exact_v1.2.3_x4",973		"terraform-provider-greater_than_v2.3.4_x4",974	} {975		if err := ioutil.WriteFile(filepath.Join(pluginPath[i], name), []byte("test bin"), 0755); err != nil {976			t.Fatal(err)977		}978	}979	args := []string{980		"-plugin-dir", "a",981		"-plugin-dir", "b",982	}983	if code := c.Run(args); code == 0 {984		// should have been an error985		t.Fatalf("bad: \n%s", ui.OutputWriter)986	}987}988// Verify that plugin-dir doesn't prevent discovery of internal providers989func TestInit_pluginWithInternal(t *testing.T) {990	td := tempDir(t)991	copy.CopyDir(testFixturePath("init-internal"), td)992	defer os.RemoveAll(td)993	defer testChdir(t, td)()994	ui := new(cli.MockUi)995	m := Meta{996		testingOverrides: metaOverridesForProvider(testProvider()),997		Ui:               ui,998	}999	c := &InitCommand{1000		Meta: m,1001	}1002	args := []string{"-plugin-dir", "./"}1003	//args := []string{}1004	if code := c.Run(args); code != 0 {1005		t.Fatalf("error: %s", ui.ErrorWriter)...

timer.go

Source:timer.go

...5	"go-common/library/log"6)7const (8	timerFormat      = "2006-01-02 15:04:05"9	infiniteDuration = itime.Duration(1<<63 - 1)10)11var (12	timerLazyDelay = 300 * itime.Millisecond13)14// TimerData timer data.15type TimerData struct {16	Key    string17	expire itime.Time18	fn     func()19	index  int20	next   *TimerData21}22// Delay delay duration.23func (td *TimerData) Delay() itime.Duration {24	return td.expire.Sub(itime.Now())25}26// ExpireString expire string.27func (td *TimerData) ExpireString() string {28	return td.expire.Format(timerFormat)29}30// Timer timer.31type Timer struct {32	lock   sync.Mutex33	free   *TimerData34	timers []*TimerData35	signal *itime.Timer36	num    int37}38// NewTimer new a timer.39// A heap must be initialized before any of the heap operations40// can be used. Init is idempotent with respect to the heap invariants41// and may be called whenever the heap invariants may have been invalidated.42// Its complexity is O(n) where n = h.Len().43//44func NewTimer(num int) (t *Timer) {45	t = new(Timer)46	t.init(num)47	return t48}49// Init init the timer.50func (t *Timer) Init(num int) {51	t.init(num)52}53func (t *Timer) init(num int) {54	t.signal = itime.NewTimer(infiniteDuration)55	t.timers = make([]*TimerData, 0, num)56	t.num = num57	t.grow()58	go t.start()59}60func (t *Timer) grow() {61	var (62		i   int63		td  *TimerData64		tds = make([]TimerData, t.num)65	)66	t.free = &(tds[0])67	td = t.free68	for i = 1; i < t.num; i++ {69		td.next = &(tds[i])70		td = td.next71	}72	td.next = nil73}74// get get a free timer data.75func (t *Timer) get() (td *TimerData) {76	if td = t.free; td == nil {77		t.grow()78		td = t.free79	}80	t.free = td.next81	return82}83// put put back a timer data.84func (t *Timer) put(td *TimerData) {85	td.fn = nil86	td.next = t.free87	t.free = td88}89// Add add the element x onto the heap. The complexity is90// O(log(n)) where n = h.Len().91func (t *Timer) Add(expire itime.Duration, fn func()) (td *TimerData) {92	t.lock.Lock()93	td = t.get()94	td.expire = itime.Now().Add(expire)95	td.fn = fn96	t.add(td)97	t.lock.Unlock()98	return99}100// Del removes the element at index i from the heap.101// The complexity is O(log(n)) where n = h.Len().102func (t *Timer) Del(td *TimerData) {103	t.lock.Lock()104	t.del(td)105	t.put(td)106	t.lock.Unlock()107}108// Push pushes the element x onto the heap. The complexity is109// O(log(n)) where n = h.Len().110func (t *Timer) add(td *TimerData) {111	var d itime.Duration112	td.index = len(t.timers)113	// add to the minheap last node114	t.timers = append(t.timers, td)115	t.up(td.index)116	if td.index == 0 {117		// if first node, signal start goroutine118		d = td.Delay()119		t.signal.Reset(d)120		if Debug {121			log.Info("timer: add reset delay %d ms", int64(d)/int64(itime.Millisecond))122		}123	}124	if Debug {125		log.Info("timer: push item key: %s, expire: %s, index: %d", td.Key, td.ExpireString(), td.index)126	}127}128func (t *Timer) del(td *TimerData) {129	var (130		i    = td.index131		last = len(t.timers) - 1132	)133	if i < 0 || i > last || t.timers[i] != td {134		// already remove, usually by expire135		if Debug {136			log.Info("timer del i: %d, last: %d, %p", i, last, td)137		}138		return139	}140	if i != last {141		t.swap(i, last)142		t.down(i, last)143		t.up(i)144	}145	// remove item is the last node146	t.timers[last].index = -1 // for safety147	t.timers = t.timers[:last]148	if Debug {149		log.Info("timer: remove item key: %s, expire: %s, index: %d", td.Key, td.ExpireString(), td.index)150	}151}152// Set update timer data.153func (t *Timer) Set(td *TimerData, expire itime.Duration) {154	t.lock.Lock()155	t.del(td)156	td.expire = itime.Now().Add(expire)157	t.add(td)158	t.lock.Unlock()159}160// start start the timer.161func (t *Timer) start() {162	for {163		t.expire()164		<-t.signal.C165	}166}167// expire removes the minimum element (according to Less) from the heap.168// The complexity is O(log(n)) where n = max.169// It is equivalent to Del(0).170func (t *Timer) expire() {171	var (172		fn func()173		td *TimerData174		d  itime.Duration175	)176	t.lock.Lock()177	for {178		if len(t.timers) == 0 {179			d = infiniteDuration180			if Debug {181				log.Info("timer: no other instance")182			}183			break184		}185		td = t.timers[0]186		if d = td.Delay(); d > 0 {187			break188		}189		fn = td.fn190		// let caller put back191		t.del(td)192		t.lock.Unlock()193		if fn == nil {...

create_actor.go

Source:create_actor.go

...78		WithDefaultGasFeeCap(200).79		WithDefaultGasPremium(1).80		WithActorState(drivers.DefaultBuiltinActorsState...).Build(t)81	defer td.Complete()82	var initialBal = abi_spec.NewTokenAmount(1_000_000_000_000)83	var toSend = abi_spec.NewTokenAmount(10_000)84	sender, _ := td.NewAccountActor(drivers.SECP, initialBal)85	receiver, receiverID := td.NewAccountActor(drivers.SECP, initialBal)86	firstPaychAddr := utils.NewIDAddr(t, utils.IdFromAddress(receiverID)+1)87	secondPaychAddr := utils.NewIDAddr(t, utils.IdFromAddress(receiverID)+2)88	firstInitRet := td.ComputeInitActorExecReturn(sender, 0, 0, firstPaychAddr)89	secondInitRet := td.ComputeInitActorExecReturn(sender, 1, 0, secondPaychAddr)90	td.ApplyExpect(91		td.MessageProducer.CreatePaymentChannelActor(sender, receiver, chain.Value(toSend), chain.Nonce(0)),92		chain.MustSerialize(&firstInitRet),93	)94	td.ApplyExpect(95		td.MessageProducer.CreatePaymentChannelActor(sender, receiver, chain.Value(toSend), chain.Nonce(1)),96		chain.MustSerialize(&secondInitRet),97	)98}...

init

Using AI Code Generation

1func main() {2    td := td{}3    td.init()4    td.print()5}6func main() {7    td := td{}8    td.init()9    td.print()10}11The init() me

init

Using AI Code Generation

1import (2func main() {3    fmt.Println("Hello, World!")4    td := new(TD)5    td.init()6    td.print()7}8import (9func main() {10    fmt.Println("Hello, World!")11    td := TD{}12    td.init()13    td.print()14}15import (16func main() {17    fmt.Println("Hello, World!")18    td := TD{}19    td.print()20}21import (22func main() {23    fmt.Println("Hello, World!")24    td := TD{}25    td.init()26    td.print()27    td.print()28}29import (30func main() {31    fmt.Println("Hello, World!")32    td := TD{}33    td.print()34    td.init()35    td.print()36}37import (38func main() {39    fmt.Println("Hello, World!")40    td := TD{}41    td.print()42    td.print()43    td.init()44    td.print()45}46import (47func main() {48    fmt.Println("Hello, World!")49    td := TD{}50    td.print()51    td.print()52    td.print()53    td.init()54    td.print()55}56import (57func main() {58    fmt.Println("Hello, World!")59    td := TD{}60    td.print()61    td.print()62    td.print()63    td.print()64    td.init()65    td.print()66}67import (68func main() {69    fmt.Println("Hello, World!")70    td := TD{}71    td.print()

init

Using AI Code Generation

1import (2func main() {3 fmt.Println("main method")4 test.Td()5}6It is not possible to call init() function from

init

Using AI Code Generation

1import (2func main() {3    fmt.Println(td.Td)4}5Go - init() method6Go - init() method 27Go - init() method 38Go - init() method 49Go - init() method 510Go - init() method 611Go - init() method 712Go - init() method 813Go - init() method 914Go - init() method 1015Go - init() method 1116Go - init() method 1217Go - init() method 1318Go - init() method 1419Go - init() method 1520Go - init() method 1621Go - init() method 1722Go - init() method 1823Go - init() method 1924Go - init() method 2025Go - init() method 2126Go - init() method 2227Go - init() method 2328Go - init() method 2429Go - init() method 2530Go - init() method 2631Go - init() method 2732Go - init() method 2833Go - init() method 2934Go - init() method 3035Go - init() method 3136Go - init() method 3237Go - init() method 3338Go - init() method 3439Go - init() method 3540Go - init() method 3641Go - init() method 3742Go - init() method 3843Go - init() method 3944Go - init() method 4045Go - init() method 4146Go - init() method 4247Go - init() method 4348Go - init() method 4449Go - init() method 4550Go - init() method 4651Go - init() method 4752Go - init() method 4853Go - init() method 4954Go - init() method 5055Go - init() method 5156Go - init() method 5257Go - init() method 53

init

Using AI Code Generation

1func main() {2    td.Init()3    fmt.Println("Hello World")4}5import (6func init() {7    fmt.Println("I am in init method")8}9func main() {10    fmt.Println("Hello World")11}12import (13func init() {14    fmt.Println("I am in init method")15}16func init() {17    fmt.Println("I am in init method 2")18}19func main() {20    fmt.Println("Hello World")21}22import (23func init() {24    fmt.Println("I am in init method")25}26func init() {27    fmt.Println("I am in init method 2")28}29func init() {30    fmt.Println("I am in init method 3")31}32func main() {33    fmt.Println("Hello World")34}35import (36func init() {37    fmt.Println("I am in init method")38}39func init() {40    fmt.Println("I am in init method 2")41}42func init() {43    fmt.Println("I am in init method 3")44}45func main() {46    fmt.Println("Hello World")47}48import (49func init() {50    fmt.Println("I am in init method")51}52func init() {53    fmt.Println("I am in init method 2")54}

init

Using AI Code Generation

1import "fmt"2func main(){3        fmt.Println("Hello World")4        td1 := td{"Hello","World"}5        td1.print()6        td1.print1()7}8import "fmt"9type td struct {10}11func (t td) print(){12        fmt.Println(t.a,t.b)13}14func (t td) print1(){15        fmt.Println(t.a,t.b)16}17func init(){18        fmt.Println("Init method called")19}

init

Using AI Code Generation

1func main() {2 td := new(TD)3 td.init()4 td.print()5 td.print()6 td.print()7}

init

Using AI Code Generation

1import (2func main() {3	fmt.Println("Hello, world.")4	td.Print()5}6The init method will be executed when the package is imported. The init method can be used to initialize variables, and the main method can be used to call the init method. The init method can be used to initialize variables. The init method i

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.