diff --git a/framework/components/blockchain/blockchain.go b/framework/components/blockchain/blockchain.go index bf5444164..6a61cceb0 100644 --- a/framework/components/blockchain/blockchain.go +++ b/framework/components/blockchain/blockchain.go @@ -28,7 +28,7 @@ type Node struct { } func NewBlockchainNetwork(input *Input) (*Output, error) { - if input.Out != nil && framework.NoCache() { + if input.Out != nil && framework.UseCache() { return input.Out, nil } var out *Output diff --git a/framework/components/clnode/clnode.go b/framework/components/clnode/clnode.go index f99f736dd..bf2cbd4b5 100644 --- a/framework/components/clnode/clnode.go +++ b/framework/components/clnode/clnode.go @@ -44,7 +44,7 @@ type NodeOut struct { } func NewNode(in *Input) (*Output, error) { - if in.Out != nil && framework.NoCache() { + if in.Out != nil && framework.UseCache() { return in.Out, nil } pgOut, err := postgres.NewPostgreSQL(in.DbInput) diff --git a/framework/components/don/clnode.go b/framework/components/don/clnode.go index 7c253ccc9..8abbaae97 100644 --- a/framework/components/don/clnode.go +++ b/framework/components/don/clnode.go @@ -16,7 +16,7 @@ type Output struct { } func NewBasicDON(in *Input, bcOut *blockchain.Output, fakeUrl string) (*Output, error) { - if in.Out != nil && framework.NoCache() { + if in.Out != nil && framework.UseCache() { return in.Out, nil } nodeOuts := make([]*clnode.Output, 0) diff --git a/framework/output.go b/framework/output.go index 2e0b09bc2..d72334bae 100644 --- a/framework/output.go +++ b/framework/output.go @@ -8,7 +8,7 @@ import ( "strings" ) -func NoCache() bool { +func UseCache() bool { return os.Getenv("CTF_USE_CACHED_OUTPUTS") == "true" } @@ -21,6 +21,9 @@ func getBaseConfigPath() (string, error) { } func Store[T any](cfg *T) error { + if UseCache() { + return nil + } baseConfigPath, err := getBaseConfigPath() if err != nil { return err diff --git a/framework/promtail.go b/framework/promtail.go index ccc23bb98..de811091c 100644 --- a/framework/promtail.go +++ b/framework/promtail.go @@ -105,6 +105,9 @@ scrape_configs: } func NewLokiStreamer() error { + if UseCache() { + return nil + } ctx, cancel := context.WithTimeout(context.Background(), 10*time.Minute) defer cancel()