Function resourceReplaceLogWriter

provisioner/terraform/executor.go:435–459

resourceReplaceLogWriter highlights log lines relating to resource replacement by elevating their log level. This will help template admins to visually find problematic resources easier. The WriteCloser must be closed by the caller to end logging, after which the returned channel will be closed to

(sink logSink, logger slog.Logger)

// The WriteCloser must be closed by the caller to end logging, after which the returned channel will be closed to
// indicate that logging of the written data has finished.  Failure to close the WriteCloser will leak a goroutine.
func resourceReplaceLogWriter(sink logSink, logger slog.Logger) (io.WriteCloser, <-chan struct{}) {
	r, w := io.Pipe()
	done := make(chan struct{})

	go func() {
		defer close(done)

		scanner := bufio.NewScanner(r)
		for scanner.Scan() {
			line := scanner.Bytes()
			level := proto.LogLevel_INFO

			// Terraform indicates that a resource will be deleted and recreated by showing the change along with this substring.
			if bytes.Contains(line, []byte("# forces replacement")) {
				level = proto.LogLevel_WARN
			}

			sink.ProvisionLog(level, string(line))
		}
		if err := scanner.Err(); err != nil {
			logger.Error(context.Background(), "failed to read terraform log", slog.Error(err))
		}
	}()
	return w, done
}

// showPlan must only be called while the lock is held.
func (e *executor) showPlan(ctx, killCtx context.Context, stdoutWriter, stderrWriter io.WriteCloser, planfilePath string) error {