func()

in src/statequery/storage.go [28:48]

• 14 lines of code
• 2 McCabe index (conditional complexity)

func (state *State) DumpState(ctx context.Context, bucket string) error {
	// Abort if no bucket has been specified
	client, err := storageSDK.NewClient(ctx)
	if err != nil {
		log.Println("bucket for state dumps not configured, skipping...")
		return err
	}

	// Create object key with timestamp
	stamp := fmt.Sprintf("%v", time.Now().UTC().Unix())
	object := fmt.Sprintf("state-%s.json", stamp)

	// Create GCS writer for new object
	writer := client.Bucket(bucket).Object(object).NewWriter(ctx)
	defer writer.Close()
	writer.ContentType = "application/json"

	// Encode state to the bucket writer
	json.NewEncoder(writer).Encode(state)
	return nil
}