package main

import (
    "bufio"
    "fmt"
    "log"
    "os"
    "os/exec"
)

func main() {
    log.SetFlags(0)
    r, w, err := os.Pipe()
    if err != nil {
        log.Fatalf("Error creating pipe: %v", err)
    }

    defer r.Close()
    defer w.Close()

    cmd := exec.Command("sudo", "/usr/bin/bootc", "upgrade", fmt.Sprintf("--progress-fd=%d", w.Fd))
    log.Printf("File descriptor: %d", w.Fd)
    cmd.ExtraFiles = []*os.File{w}

    err = cmd.Start()
    if err != nil {
        log.Fatalf("Failed to start cmd: %v", err)
    }
    scanner := bufio.NewScanner(r)
    scanner.Split(bufio.ScanLines)
    for scanner.Scan() {
        log.Printf("%s", scanner.Text())
    }
    if err := cmd.Wait(); err != nil {
        log.Printf("Error waiting for command: %v", err)
    }
    err = cmd.Wait()

    if err != nil {
        log.Println(cmd.Stdout)
        log.Fatalf("Command errored: %v", err)
    }
}

package main

import (
    "bufio"
    "fmt"
    "log"
    "os"
    "os/exec"
)

func main() {
    log.SetFlags(0)
    r, w, err := os.Pipe()
    if err != nil {
        log.Fatalf("Error creating pipe: %v", err)
    }

    defer r.Close()
    defer w.Close()

    cmd := exec.Command("sudo", "/usr/bin/bootc", "upgrade", fmt.Sprintf("--progress-fd=%d", w.Fd))
    log.Printf("File descriptor: %d", w.Fd)
    cmd.ExtraFiles = []*os.File{w}

    err = cmd.Start()
    if err != nil {
        log.Fatalf("Failed to start cmd: %v", err)
    }
    scanner := bufio.NewScanner(r)
    scanner.Split(bufio.ScanLines)
    for scanner.Scan() {
        log.Printf("%s", scanner.Text())
    }
    if err := cmd.Wait(); err != nil {
        log.Printf("Error waiting for command: %v", err)
    }
    err = cmd.Wait()

    if err != nil {
        log.Println(cmd.Stdout)
        log.Fatalf("Command errored: %v", err)
    }
}