How to use WithState method of internal Package

...211		ctx.actionRouter,212		header,213		state,214		ctx.accounts,215		ctx.balances.WithState(state),216		ctx.currencies,217		ctx.feePool.WithState(state),218		ctx.validators.WithState(state),219		ctx.witnesses.WithState(state),220		ctx.domains.WithState(state),221		ctx.delegators.WithState(state),222		ctx.netwkDelegators.WithState(state),223		ctx.evidenceStore.WithState(state),224		ctx.btcTrackers.WithState(state),225		ctx.ethTrackers.WithState(state),226		ctx.jobStore,227		ctx.lockScriptStore,228		log.NewLoggerWithPrefix(ctx.logWriter, "action").WithLevel(log.Level(ctx.cfg.Node.LogLevel)),229		ctx.proposalMaster.WithState(state),230		ctx.rewardMaster.WithState(state),231		ctx.govern.WithState(state),232		ctx.extStores.WithState(state),233		ctx.govupdate,234		ctx.stateDB.WithState(state),235	)236	return actionCtx237}238func (ctx *context) ID() {}239func (ctx *context) Accounts() accounts.Wallet {240	return ctx.accounts241}242func (ctx *context) ValidatorCtx() *identity.ValidatorContext {243	return identity.NewValidatorContext(244		ctx.balances.WithState(ctx.deliver),245		ctx.feePool.WithState(ctx.deliver),246		ctx.delegators.WithState(ctx.deliver),247		ctx.evidenceStore.WithState(ctx.deliver),248		ctx.govern.WithState(ctx.deliver),249		ctx.currencies,250		ctx.validators.WithState(ctx.deliver),251	)252}253// Returns a balance.Context254func (ctx *context) Balances() *balance.Context {255	return balance.NewContext(256		log.NewLoggerWithPrefix(ctx.logWriter, "balances").WithLevel(log.Level(ctx.cfg.Node.LogLevel)),257		ctx.balances,258		ctx.currencies)259}260func (ctx *context) Web3Services(node *consensus.Node) map[string]web3types.Web3Service {261	web3Ctx := web3.NewContext(262		log.NewLoggerWithPrefix(ctx.logWriter, "web3").WithLevel(log.Level(ctx.cfg.Node.LogLevel)),263		node,264		ctx.feePool,265		&ctx.node,266		&ctx.cfg,267		ctx.chainstate,268		ctx.currencies,269	)270	return web3Ctx.ServiceList()271}272func (ctx *context) Services() (service.Map, error) {273	extSvcs, err := client.NewExtServiceContext(ctx.cfg.Network.RPCAddress, ctx.cfg.Network.SDKAddress)274	if err != nil {275		return nil, errors.Wrap(err, "failed to start service context")276	}277	btcTrackers := bitcoin.NewTrackerStore("btct", storage.NewState(ctx.chainstate))278	btcTrackers.SetConfig(ctx.btcTrackers.GetConfig())279	feePool := fees.NewStore("f", storage.NewState(ctx.chainstate))280	feePool.SetupOpt(ctx.feePool.GetOpt())281	ethTracker := ethereum.NewTrackerStore("etht", "ethfailed", "ethsuccess", storage.NewState(ctx.chainstate))282	ethTracker.SetupOption(ctx.ethTrackers.GetOption())283	onsStore := ons.NewDomainStore("d", storage.NewState(ctx.chainstate))284	proposalMaster := NewProposalMasterStore(ctx.chainstate)285	proposalMaster.Proposal.SetOptions(ctx.proposalMaster.Proposal.GetOptions())286	rewardMaster := NewRewardMasterStore(ctx.chainstate)287	rewardMaster.SetOptions(ctx.rewardMaster.GetOptions())288	netwkDelegators := netwkDeleg.NewMasterStore("deleg", "delegRwz", storage.NewState(ctx.chainstate))289	svcCtx := &service.Context{290		Balances:        balance.NewStore("b", storage.NewState(ctx.chainstate)),291		Accounts:        ctx.accounts,292		Currencies:      ctx.currencies,293		FeePool:         feePool,294		Cfg:             ctx.cfg,295		NodeContext:     ctx.node,296		ValidatorSet:    identity.NewValidatorStore("v", "purged", storage.NewState(ctx.chainstate)),297		WitnessSet:      identity.NewWitnessStore("w", storage.NewState(ctx.chainstate)),298		Domains:         onsStore,299		Delegators:      delegation.NewDelegationStore("st", storage.NewState(ctx.chainstate)),300		NetwkDelegators: netwkDelegators,301		ProposalMaster:  proposalMaster,302		EvidenceStore:   evidence.NewEvidenceStore("es", storage.NewState(ctx.chainstate)),303		RewardMaster:    rewardMaster,304		ExtStores:       ctx.extStores,305		ExtServiceMap:   ctx.extServiceMap,306		Router:          ctx.actionRouter,307		Logger:          log.NewLoggerWithPrefix(ctx.logWriter, "rpc").WithLevel(log.Level(ctx.cfg.Node.LogLevel)),308		Services:        extSvcs,309		EthTrackers:     ethTracker,310		Trackers:        btcTrackers,311		Govern:          governance.NewStore("g", storage.NewState(ctx.chainstate)),312		GovUpdate:       ctx.govupdate,313		Contracts:       ctx.contracts,314		AccountKeeper:   ctx.accountKeeper,315		StateDB:         ctx.stateDB,316	}317	return service.NewMap(svcCtx)318}319func (ctx *context) Restful() (service.RestfulRouter, error) {320	extSvcs, err := client.NewExtServiceContext(ctx.cfg.Network.RPCAddress, ctx.cfg.Network.SDKAddress)321	if err != nil {322		return nil, errors.Wrap(err, "failed to start service context")323	}324	svcCtx := &service.Context{325		Cfg:            ctx.cfg,326		Balances:       ctx.balances,327		Accounts:       ctx.accounts,328		Currencies:     ctx.currencies,329		FeePool:        ctx.feePool,330		NodeContext:    ctx.node,331		ValidatorSet:   ctx.validators,332		Domains:        ctx.domains,333		ProposalMaster: ctx.proposalMaster,334		Router:         ctx.actionRouter,335		Logger:         log.NewLoggerWithPrefix(ctx.logWriter, "restful").WithLevel(log.Level(ctx.cfg.Node.LogLevel)),336		Services:       extSvcs,337		Trackers:      ctx.btcTrackers,338		Contracts:     ctx.contracts,339		AccountKeeper: ctx.accountKeeper,340		StateDB:       ctx.stateDB,341	}342	return service.NewRestfulService(svcCtx).Router(), nil343}344type StorageCtx struct {345	Balances        *balance.Store346	Domains         *ons.DomainStore347	Validators      *identity.ValidatorStore // Set of validators currently active348	Delegators      *delegation.DelegationStore349	RewardMaster    *rewards.RewardMasterStore350	ProposalMaster  *governance.ProposalMasterStore351	NetwkDelegators *network_delegation.MasterStore352	FeePool         *fees.Store353	Govern          *governance.Store354	Trackers        *ethereum.TrackerStore //TODO: Create struct to contain all tracker types including Bitcoin.355	Currencies *balance.CurrencySet356	FeeOption  *fees.FeeOption357	Hash       []byte358	Version    int64359	Chainstate *storage.ChainState360}361func (ctx *context) Storage() StorageCtx {362	return StorageCtx{363		Version:         ctx.chainstate.Version,364		Hash:            ctx.chainstate.Hash,365		Chainstate:      ctx.chainstate,366		Balances:        ctx.balances,367		Domains:         ctx.domains,368		Validators:      ctx.validators,369		Delegators:      ctx.delegators,370		RewardMaster:    ctx.rewardMaster,371		ProposalMaster:  ctx.proposalMaster,372		NetwkDelegators: ctx.netwkDelegators,373		FeePool:         ctx.feePool,374		Govern:          ctx.govern,375		Currencies:      ctx.currencies,376		FeeOption:       ctx.feePool.GetOpt(),377		Trackers:        ctx.ethTrackers,378	}379}380// Close all things that need to be closed381func (ctx *context) Close() {382	closers := []closer{ctx.db, ctx.accounts, ctx.rpc, ctx.jobBus}383	for _, closer := range closers {384		err := closer.Close()385		if err != nil {386			panic(err)387		}388	}389}390func (ctx *context) Node() node.Context {391	return ctx.node392}393func (ctx *context) Validators() *identity.ValidatorStore {394	return ctx.validators395}396func (ctx *context) Replay(version int64) error {397	return ctx.chainstate.ClearFrom(version)398}399func (ctx *context) JobContext() *event.JobsContext {400	return event.NewJobsContext(401		ctx.cfg,402		ctx.internalService,403		ctx.btcTrackers,404		ctx.validators,405		ctx.node.ValidatorECDSAPrivateKey(), // BTC private key406		ctx.node.ValidatorECDSAPrivateKey(), // ETH private key407		ctx.node.ValidatorAddress(),         // validator address generated from validator key408		ctx.lockScriptStore,409		ctx.ethTrackers.WithState(ctx.deliver),410		ctx.proposalMaster.WithState(ctx.deliver),411		log.NewLoggerWithPrefix(ctx.logWriter, "internal_jobs").WithLevel(log.Level(ctx.cfg.Node.LogLevel)))412}...

...51		var calledB int52		m := NewManager(53			WithResource(NewResource(54				WithName("A"),55				WithState(&testState{}),56				WithCreate(func(s *testState, v int) error {57					s.Value = v58					return nil59				}),60			)),61			WithResource(NewResource(62				WithName("B"),63				WithCreate(func(s *testState) error {64					calledB = s.Value65					return nil66				}),67			)),68		)69		// Create70		require.NoError(m.CreateAll(int(42)))71		// Ensure we called all72		require.Equal(calledB, 42)73		// Ensure we have state74		require.NotNil(m.State())75	})76	t.Run("With one resource and a declared resource response to populate", func(t *testing.T) {77		require := require.New(t)78		type State struct {79			InternalId string `json:"internalId"`80		}81		// Declare our expected results82		expectedState := State{InternalId: "a_id"}83		expectedStateJson, _ := json.Marshal(expectedState)84		expectedDr := pb.DeclaredResource{85			Name:                "A",86			Type:                "T",87			Platform:            "test",88			CategoryDisplayHint: pb.ResourceCategoryDisplayHint_OTHER,89			StateJson:           string(expectedStateJson),90		}91		var dcr component.DeclaredResourcesResp92		m := NewManager(93			WithDeclaredResourcesResp(&dcr),94			WithResource(NewResource(95				WithName(expectedDr.Name),96				WithType(expectedDr.Type),97				WithCreate(func(state *State) error {98					state.InternalId = expectedState.InternalId99					return nil100				}),101				WithState(&State{}),102				WithPlatform(expectedDr.Platform),103				WithCategoryDisplayHint(expectedDr.CategoryDisplayHint),104			)),105		)106		// Create107		var state State108		require.NoError(m.CreateAll(&state))109		// Ensure we populated the declared resource110		require.NotEmpty(dcr.DeclaredResources)111		declaredResource := dcr.DeclaredResources[0]112		require.NotEmpty(declaredResource.Name)113		require.Equal(declaredResource.Name, expectedDr.Name)114		require.Equal(declaredResource.Type, expectedDr.Type)115		require.Equal(declaredResource.StateJson, expectedDr.StateJson)116		require.Equal(declaredResource.CategoryDisplayHint, expectedDr.CategoryDisplayHint)117	})118	t.Run("rollback on error", func(t *testing.T) {119		require := require.New(t)120		var destroyOrder []string121		m := NewManager(122			WithResource(NewResource(123				WithName("A"),124				WithState(&testState{}),125				WithCreate(func(s *testState, v int) error {126					s.Value = v127					return nil128				}),129				WithDestroy(func() error {130					destroyOrder = append(destroyOrder, "A")131					return nil132				}),133			)),134			WithResource(NewResource(135				WithName("B"),136				WithState(&testState2{}),137				WithCreate(func(s *testState) error {138					return errors.New("whelp")139				}),140				WithDestroy(func() error {141					destroyOrder = append(destroyOrder, "B")142					return nil143				}),144			)),145			WithResource(NewResource(146				WithName("C"),147				WithCreate(func(s *testState2) error {148					return nil149				}),150				WithDestroy(func() error {151					destroyOrder = append(destroyOrder, "C")152					return nil153				}),154			)),155		)156		// Create157		err := m.CreateAll(int(42))158		require.Error(err)159		require.Equal("whelp", err.Error())160		// Ensure we called destroy161		require.Equal([]string{"B", "A"}, destroyOrder)162		// Ensure we have no state163		require.NotNil(m.State())164	})165}166func TestManagerDestroyAll(t *testing.T) {167	var calledB int32168	require := require.New(t)169	// init is a function so that we can reinitialize an empty manager170	// for this test to test loading state171	var destroyOrder []string172	var destroyState int32173	init := func() *Manager {174		return NewManager(175			WithResource(NewResource(176				WithName("A"),177				WithState(&testproto.Data{}),178				WithCreate(func(s *testproto.Data, v int32) error {179					s.Number = v180					return nil181				}),182				WithDestroy(func(s *testproto.Data) error {183					destroyOrder = append(destroyOrder, "A")184					destroyState = s.Number185					return nil186				}),187			)),188			WithResource(NewResource(189				WithName("B"),190				WithCreate(func(s *testproto.Data) error {191					calledB = s.Number192					return nil193				}),194				WithDestroy(func() error {195					destroyOrder = append(destroyOrder, "B")196					return nil197				}),198			)),199		)200	}201	// Create202	m := init()203	require.NoError(m.CreateAll(int32(42)))204	// Ensure we called all205	require.Equal(calledB, int32(42))206	// Create a new manager, load the state, and verify it works207	m2 := init()208	require.NoError(m2.LoadState(m.State()))209	// Grab our resource state210	actual := m2.Resource("A").State().(*testproto.Data)211	require.NotNil(actual)212	require.Equal(actual.Number, int32(42))213	// Destroy214	require.NoError(m2.DestroyAll())215	// Ensure we destroyed216	require.Equal([]string{"B", "A"}, destroyOrder)217	require.Equal(destroyState, int32(42))218}219func TestManagerDestroyAll_noDestroyFunc(t *testing.T) {220	var calledB int32221	require := require.New(t)222	// init is a function so that we can reinitialize an empty manager223	// for this test to test loading state224	var destroyOrder []string225	init := func() *Manager {226		return NewManager(227			WithResource(NewResource(228				WithName("A"),229				WithState(&testproto.Data{}),230				WithCreate(func(s *testproto.Data, v int32) error {231					s.Number = v232					return nil233				}),234			)),235			WithResource(NewResource(236				WithName("B"),237				WithCreate(func(s *testproto.Data) error {238					calledB = s.Number239					return nil240				}),241				WithDestroy(func() error {242					destroyOrder = append(destroyOrder, "B")243					return nil244				}),245			)),246		)247	}248	// Create249	m := init()250	require.NoError(m.CreateAll(int32(42)))251	// Ensure we called all252	require.Equal(calledB, int32(42))253	// Create a new manager, load the state, and verify it works254	m2 := init()255	require.NoError(m2.LoadState(m.State()))256	// Grab our resource state257	actual := m2.Resource("A").State().(*testproto.Data)258	require.NotNil(actual)259	require.Equal(actual.Number, int32(42))260	// Destroy261	require.NoError(m2.DestroyAll())262	// Ensure we destroyed263	require.Equal([]string{"B"}, destroyOrder)264}265func TestManagerDestroyAll_loadState(t *testing.T) {266	require := require.New(t)267	// init is a function so that we can reinitialize an empty manager268	// for this test to test loading state269	var destroyOrder []string270	var destroyState int32271	init := func() *Manager {272		return NewManager(273			WithResource(NewResource(274				WithName("A"),275				WithState(&testproto.Data{}),276				WithCreate(func(s *testproto.Data, v int32) error {277					s.Number = v278					return nil279				}),280				WithDestroy(func(s *testproto.Data) error {281					destroyOrder = append(destroyOrder, "A")282					destroyState = s.Number283					return nil284				}),285			)),286			WithResource(NewResource(287				WithName("B"),288				WithState(&testState{}),289				WithCreate(func(s *testproto.Data) error {290					return nil291				}),292				WithDestroy(func() error {293					destroyOrder = append(destroyOrder, "B")294					return nil295				}),296			)),297		)298	}299	// Create manager300	m := init()301	// Manually set some destroy state302	require.NoError(m.Resource("A").SetState(&testproto.Data{Number: 42}))303	require.NoError(m.Resource("B").SetState(&testState{}))304	// Destroy305	require.NoError(m.DestroyAll())306	// Ensure we destroyed307	require.Equal([]string{"B", "A"}, destroyOrder)308	require.Equal(destroyState, int32(42))309}310// TestStatus_Manager tests the Manager's ability to call resource status311// methods and present them for creating a report312func TestStatus_Manager(t *testing.T) {313	require := require.New(t)314	init := func() *Manager {315		return NewManager(316			// state with status317			WithResource(NewResource(318				WithName("A"),319				WithState(&testState{}),320				WithCreate(func(s *testState, v int) error {321					s.Value = v322					return nil323				}),324				WithStatus(func(s *testState, sr *StatusResponse) error {325					rr := &pb.StatusReport_Resource{326						Name:   fmt.Sprintf(statusNameTpl, s.Value),327						Health: pb.StatusReport_READY,328					}329					sr.Resources = append(sr.Resources, rr)330					return nil331				}),332			)),333			// no state, with status334			WithResource(NewResource(335				WithName("B"),336				WithCreate(func(s *testState) error {337					// no-op338					return nil339				}),340				WithStatus(func(sr *StatusResponse) error {341					rr := &pb.StatusReport_Resource{342						Name:   "no state here",343						Health: pb.StatusReport_DOWN,344					}345					sr.Resources = append(sr.Resources, rr)346					return nil347				}),348			)),349			// state and multiple status reports350			WithResource(NewResource(351				WithName("C"),352				WithState(&testState2{}),353				WithCreate(func(s *testState2, vs string) error {354					v, _ := strconv.Atoi(vs)355					s.Value = v356					return nil357				}),358				WithStatus(func(s *testState2, sr *StatusResponse) error {359					rr := &pb.StatusReport_Resource{360						Name:   fmt.Sprintf(statusNameTpl, s.Value),361						Health: pb.StatusReport_ALIVE,362					}363					// make sure we can return more than 1 StatusReport_Resource364					// in a single Resource Status method365					rr2 := &pb.StatusReport_Resource{366						Name:   fmt.Sprintf(statusNameTpl, s.Value+1),367						Health: pb.StatusReport_ALIVE,368					}369					sr.Resources = append(sr.Resources, rr, rr2)370					return nil371				}),372			)),373			// state, no status374			WithResource(NewResource(375				WithName("D"),376				WithState(&testState3{}),377				WithCreate(func(s *testState3) error {378					s.Value = 0379					return nil380				}),381			)),382		)383	}384	// Create385	m := init()386	require.NoError(m.CreateAll(42, "13"))387	// Get status for each resource388	reports, err := m.StatusAll()389	require.NoError(err)390	require.Len(reports, 4)391	sort.Sort(byName(reports))392	require.Equal("no state here", reports[0].Name)393	require.Equal(fmt.Sprintf(statusNameTpl, 13), reports[1].Name)394	require.Equal(fmt.Sprintf(statusNameTpl, 14), reports[2].Name)395	require.Equal(fmt.Sprintf(statusNameTpl, 42), reports[3].Name)396	// Generate overall status report397	statusReport, err := m.StatusReport()398	require.NoError(err)399	require.NotNil(statusReport)400	require.True(statusReport.External)401	require.NotNil(statusReport.GeneratedTime)402	require.Equal(statusReport.Health, pb.StatusReport_PARTIAL)403	require.Equal(statusReport.HealthMessage, "2 C ALIVE, 1 A READY, 1 B DOWN")404	// Destroy405	require.NoError(m.DestroyAll())406}407// TestStatus_Manager_LoopRepro is a regression test for a loop discovered while408// implementing StatusAll involving using Resource Manager with a single409// Resource that reports a status.410// See https://github.com/hashicorp/waypoint-plugin-sdk/pull/43 for additional411// background.412func TestStatus_Manager_LoopRepro(t *testing.T) {413	require := require.New(t)414	init := func() *Manager {415		return NewManager(416			WithResource(NewResource(417				WithName("C"),418				WithState(&testState{}),419				WithCreate(func(s *testState, vs string) error {420					v, _ := strconv.Atoi(vs)421					s.Value = v422					return nil423				}),424				WithStatus(func(s *testState, sr *StatusResponse) error {425					rr := &pb.StatusReport_Resource{426						Name: fmt.Sprintf(statusNameTpl, s.Value),427					}428					// make sure we can return more than 1 StatusReport_Resource429					// in a single Resource Status method430					rr2 := &pb.StatusReport_Resource{431						Name: fmt.Sprintf(statusNameTpl, s.Value+1),432					}...

...32			It("does not run the pending tests", func() {33				Ω(rt.TrackedRuns()).Should(ConsistOf("A", "B", "D"))34			})35			It("reports on the pending tests", func() {36				Ω(reporter.Did.WithState(types.SpecStatePassed).Names()).Should(ConsistOf("A", "B", "D"))37				Ω(reporter.Did.WithState(types.SpecStatePending).Names()).Should(ConsistOf("C", "E", "F"))38			})39			It("reports on the suite with accurate numbers", func() {40				Ω(reporter.End).Should(BeASuiteSummary(true, NSpecs(6), NPassed(3), NPending(3), NWillRun(3), NSkipped(0)))41			})42			It("does not include a special suite failure reason", func() {43				Ω(reporter.End.SpecialSuiteFailureReasons).Should(BeEmpty())44			})45		})46		Context("with config.FailOnPending", func() {47			BeforeEach(func() {48				conf.FailOnPending = true49				success, hPF := RunFixture("pending tests", fixture)50				Ω(success).Should(BeFalse())51				Ω(hPF).Should(BeFalse())52			})53			It("reports on the suite with accurate numbers", func() {54				Ω(reporter.End).Should(BeASuiteSummary(false, NPassed(3), NSpecs(6), NPending(3), NWillRun(3), NSkipped(0)))55			})56			It("includes a special suite failure reason", func() {57				Ω(reporter.End.SpecialSuiteFailureReasons).Should(ContainElement("Detected pending specs and --fail-on-pending is set"))58			})59		})60	})61	Describe("with programmatic focus", func() {62		var success bool63		var hasProgrammaticFocus bool64		BeforeEach(func() {65			success, hasProgrammaticFocus = RunFixture("focused tests", func() {66				It("A", rt.T("A"))67				It("B", rt.T("B"))68				FDescribe("focused container", func() {69					It("C", rt.T("C"))70					It("D", rt.T("D"))71					PIt("E", rt.T("E"))72				})73				FDescribe("focused container with focused child", func() {74					It("F", rt.T("F"))75					It("G", Focus, rt.T("G"))76				})77				Describe("container", func() {78					It("H", rt.T("H"))79				})80				FIt("I", rt.T("I"))81			})82			Ω(success).Should(BeTrue())83		})84		It("should return true for hasProgrammaticFocus", func() {85			Ω(hasProgrammaticFocus).Should(BeTrue())86		})87		It("should report that the suite hasProgrammaticFocus", func() {88			Ω(reporter.Begin.SuiteHasProgrammaticFocus).Should(BeTrue())89			Ω(reporter.End.SuiteHasProgrammaticFocus).Should(BeTrue())90		})91		It("should run the focused tests, honoring the nested focus policy", func() {92			Ω(rt.TrackedRuns()).Should(ConsistOf("C", "D", "G", "I"))93		})94		It("should report on the tests correctly", func() {95			Ω(reporter.Did.WithState(types.SpecStateSkipped).Names()).Should(ConsistOf("A", "B", "F", "H"))96			Ω(reporter.Did.WithState(types.SpecStatePending).Names()).Should(ConsistOf("E"))97			Ω(reporter.Did.WithState(types.SpecStatePassed).Names()).Should(ConsistOf("C", "D", "G", "I"))98		})99		It("report on the suite with accurate numbers", func() {100			Ω(reporter.End).Should(BeASuiteSummary(true, NPassed(4), NSkipped(4), NPending(1), NSpecs(9), NWillRun(4)))101		})102	})103	Describe("with config.FocusStrings and config.SkipStrings", func() {104		BeforeEach(func() {105			conf.FocusStrings = []string{"blue", "green"}106			conf.SkipStrings = []string{"red"}107			success, _ := RunFixture("cli focus tests", func() {108				It("blue.1", rt.T("blue.1"))109				It("blue.2", rt.T("blue.2"))110				Describe("blue.container", func() {111					It("yellow.1", rt.T("yellow.1"))112					It("red.1", rt.T("red.1"))113					PIt("blue.3", rt.T("blue.3"))114				})115				Describe("green.container", func() {116					It("yellow.2", rt.T("yellow.2"))117					It("green.1", rt.T("green.1"))118				})119				Describe("red.2", func() {120					It("green.2", rt.T("green.2"))121				})122				FIt("red.3", rt.T("red.3"))123			})124			Ω(success).Should(BeTrue())125		})126		It("should run tests that match", func() {127			Ω(rt.TrackedRuns()).Should(ConsistOf("blue.1", "blue.2", "yellow.1", "yellow.2", "green.1"))128		})129		It("should report on the tests correctly", func() {130			Ω(reporter.Did.WithState(types.SpecStateSkipped).Names()).Should(ConsistOf("red.1", "green.2", "red.3"))131			Ω(reporter.Did.WithState(types.SpecStatePending).Names()).Should(ConsistOf("blue.3"))132			Ω(reporter.Did.WithState(types.SpecStatePassed).Names()).Should(ConsistOf("blue.1", "blue.2", "yellow.1", "yellow.2", "green.1"))133		})134		It("report on the suite with accurate numbers", func() {135			Ω(reporter.End).Should(BeASuiteSummary(true, NPassed(5), NSkipped(3), NPending(1), NSpecs(9), NWillRun(5)))136		})137	})138	Describe("when no tests will end up running", func() {139		BeforeEach(func() {140			conf.FocusStrings = []string{"red"}141			success, _ := RunFixture("cli focus tests", func() {142				BeforeSuite(rt.T("bef-suite"))143				AfterSuite(rt.T("aft-suite"))144				It("blue.1", rt.T("blue.1"))145				It("blue.2", rt.T("blue.2"))146			})147			Ω(success).Should(BeTrue())148		})149		It("does not run the BeforeSuite or the AfterSuite", func() {150			Ω(rt).Should(HaveTrackedNothing())151		})152	})153	Describe("Skip()", func() {154		BeforeEach(func() {155			success, _ := RunFixture("Skip() tests", func() {156				Describe("container to ensure order", func() {157					It("A", rt.T("A"))158					Describe("container", func() {159						BeforeEach(rt.T("bef", func() {160							failer.Skip("skip in Bef", cl)161							panic("boom") //simulates what Ginkgo DSL does162						}))163						It("B", rt.T("B"))164						It("C", rt.T("C"))165						AfterEach(rt.T("aft"))166					})167					It("D", rt.T("D", func() {168						failer.Skip("skip D", cl)169						panic("boom") //simulates what Ginkgo DSL does170					}))171				})172			})173			Ω(success).Should(BeTrue())174		})175		It("skips the tests that are Skipped()", func() {176			Ω(rt).Should(HaveTracked("A", "bef", "aft", "bef", "aft", "D"))177			Ω(reporter.Did.WithState(types.SpecStatePassed).Names()).Should(ConsistOf("A"))178			Ω(reporter.Did.WithState(types.SpecStateSkipped).Names()).Should(ConsistOf("B", "C", "D"))179			Ω(reporter.Did.Find("B").Failure.Message).Should(Equal("skip in Bef"))180			Ω(reporter.Did.Find("B").Failure.Location).Should(Equal(cl))181			Ω(reporter.Did.Find("D").Failure.Message).Should(Equal("skip D"))182			Ω(reporter.Did.Find("D").Failure.Location).Should(Equal(cl))183		})184		It("report on the suite with accurate numbers", func() {185			Ω(reporter.End).Should(BeASuiteSummary(true, NPassed(1), NSkipped(3), NPending(0), NSpecs(4), NWillRun(4)))186		})187	})188})...

1import (2func main() {3	ctx, cancel := context.WithCancel(context.Background())4	defer cancel()5	go func() {6		time.Sleep(2 * time.Second)7		fmt.Println("cancelling context")8		cancel()9	}()10	select {11	case <-ctx.Done():12		fmt.Println("context cancelled")13	}14}15import (16func main() {17	ctx, cancel := context.WithTimeout(context.Background(), 1*time.Second)18	defer cancel()19	go func() {20		time.Sleep(2 * time.Second)21		fmt.Println("cancelling context")22		cancel()23	}()24	select {25	case <-ctx.Done():26		fmt.Println("context cancelled")27	}28}29import (30func main() {31	d := time.Now().Add(1 * time.Second)32	ctx, cancel := context.WithDeadline(context.Background(), d)33	defer cancel()34	go func() {35		time.Sleep(2 * time.Second)36		fmt.Println("cancelling context")37		cancel()38	}()39	select {40	case <-ctx.Done():41		fmt.Println("context cancelled")42	}43}44import (45func main() {46	ctx := context.WithValue(context.Background(), "key", "value")47	fmt.Println(ctx.Value("key"))48}49import (50func main() {51	ctx, cancel := context.WithCancel(context.Background())52	defer cancel()53	go func() {54		time.Sleep(2 * time.Second)55		fmt.Println("cancelling context")56		cancel()57	}()58	select {59	case <-ctx.Done():60		fmt.Println("context cancelled")61	}62}63import (64func main() {65	ctx, cancel := context.WithTimeout(context.Background

1import (2func main() {3        ctx := context.Background()4        ctx, cancel := context.WithCancel(ctx)5        ctx = context.WithValue(ctx, "key", "value")6        go func() {7                time.Sleep(1 * time.Second)8                cancel()9        }()10        select {11        case <-ctx.Done():12                fmt.Println("done")13        }14}15import (16func main() {17        ctx := context.Background()18        ctx, cancel := context.WithCancel(ctx)19        go func() {20                time.Sleep(1 * time.Second)21                cancel()22        }()23        select {24        case <-ctx.Done():25                fmt.Println("done")26        }27}28import (29func main() {30        ctx := context.Background()31        ctx, cancel := context.WithCancel(ctx)32        go func() {33                time.Sleep(1 * time.Second)34                cancel()35        }()36        select {37        case <-ctx.Done():38                fmt.Println("done")39        }40}41import (42func main() {43        ctx := context.Background()44        ctx, cancel := context.WithCancel(ctx)45        go func() {46                time.Sleep(1 * time.Second)47                cancel()48        }()49        select {50        case <-ctx.Done():51                fmt.Println("done")52        }53}54import (55func main() {56        ctx := context.Background()57        ctx, cancel := context.WithCancel(ctx)58        go func() {59                time.Sleep(1 * time.Second)60                cancel()61        }()62        select {63        case <-ctx.Done():64                fmt.Println("done")65        }66}67import (

1import (2func main() {3	anaconda.SetConsumerKey("consumer_key")4	anaconda.SetConsumerSecret("consumer_secret")5	api := anaconda.NewTwitterApi("access_token", "access_token_secret")6	tweet, err := api.GetTweet(12345, nil)7	if err != nil {8		fmt.Println(err)9	}10	fmt.Println(tweet.Text)11}12import (13func main() {14	anaconda.SetConsumerKey("consumer_key")15	anaconda.SetConsumerSecret("consumer_secret")16	api := anaconda.NewTwitterApi("access_token", "access_token_secret")17	tweet, err := api.GetTweet(12345, anaconda.WithState())18	if err != nil {19		fmt.Println(err)20	}21	fmt.Println(tweet.Text)22}23github.com/ChimeraCoder/anaconda.(*TwitterApi).GetTweet(0xc0420620c0, 0x2f9, 0x0, 0x0, 0x0, 0x0, 0x0)24main.main()

1import (2type internal struct {3}4func (i *internal) WithState(state string) *internal {5}6func (i *internal) Print() {7fmt.Println(i.state)8}9func main() {10i := internal{}.WithState("Hi")11i.Print()12}13import (14type internal struct {15}16func (i *internal) WithState(state string) *internal {17}18func (i *internal) Print() {19fmt.Println(i.state)20}21func main() {22i := internal{}23i.WithState("Hi")24i.Print()25}

1func main() {2    s = &State{}3    println(s)4}5func main() {6    s = &State{}7    println(s)8}9func main() {10    s = &State{}11    println(s)12}13func main() {14    s = &State{}15    println(s)16}17func main() {18    s = &State{}19    println(s)20}21func main() {22    s = &State{}23    println(s)24}25func main() {26    s = &State{}27    println(s)28}29func main() {30    s = &State{}31    println(s)32}33func main() {34    s = &State{}35    println(s)36}37func main() {38    s = &State{}39    println(s)40}41func main() {42    s = &State{}43    println(s)44}45func main() {46    s = &State{}47    println(s)48}49func main() {50    s = &State{}51    println(s)52}

1import (2func main() {3	c := context.Background()4	c, cancel := context.WithCancel(c)5	defer cancel()6	c = context.WithState(c, "foo", "bar")7	fmt.Println(c.Value("foo"))8}9import (10func main() {11	c := context.Background()12	c, cancel := context.WithCancel(c)13	defer cancel()14	c = context.WithValue(c, "foo", "bar")15	fmt.Println(c.Value("foo"))16}17import (18func main() {19	c := context.Background()20	c, cancel := context.WithCancel(c)21	defer cancel()22	c, _ = context.WithTimeout(c, 100*time.Millisecond)23	fmt.Println(c.Value("foo"))24}25import (26func main() {27	c := context.Background()28	c, cancel := context.WithCancel(c)29	defer cancel()30	c, _ = context.WithDeadline(c, time.Now().Add(100*time.Millisecond))31	fmt.Println(c.Value("foo"))32}33import (34func main() {35	c := context.Background()36	c, cancel := context.WithCancel(c)37	defer cancel()38	c, _ = context.WithCancel(c)39	fmt.Println(c.Value("foo"))40}

1func main() {2    ctx := context.WithValue(context.Background(), "key", "value")3    ctx = context.WithValue(ctx, "newkey", "newvalue")4    ctx = context.WithValue(ctx, "newkey2", "newvalue2")5    ctx = context.WithValue(ctx, "newkey3", "newvalue3")6    ctx = context.WithValue(ctx, "newkey4", "newvalue4")7    ctx = context.WithValue(ctx, "newkey5", "newvalue5")8    ctx = context.WithValue(ctx, "newkey6", "newvalue6")9    ctx = context.WithValue(ctx, "newkey7", "newvalue7")10    ctx = context.WithValue(ctx, "newkey8", "newvalue8")11    ctx = context.WithValue(ctx, "newkey9", "newvalue9")12    ctx = context.WithValue(ctx, "newkey10", "newvalue10")13    ctx = context.WithValue(ctx, "newkey11", "newvalue11")14    ctx = context.WithValue(ctx, "newkey12", "newvalue12")15    ctx = context.WithValue(ctx, "newkey13", "newvalue13")16    ctx = context.WithValue(ctx, "newkey14", "newvalue14")17    ctx = context.WithValue(ctx, "newkey15", "newvalue15")