Tello Gobot API tello.VideoFrameEvent Not Firing

[cgbsu]

Hello, I am trying to get video feed from a tello drone, I am using the Gobot API and it just seems like the tello.VideoFrameEvent is not firing, I see no message from it, and the main thread's loop never progresses past waiting on the stream from ffmpeg (I also tried this with mplayer). I can get other events to work (commented out) but not this one.

/*
You must have ffmpeg and OpenCV installed in order to run this code. It will connect to the Tello
and then open a window using OpenCV showing the streaming video.

How to run

        go run examples/tello_opencv.go

this is based on merging two existing tutorials:
https://medium.com/@fonseka.live/detect-faces-using-golang-and-opencv-fbe7a48db055
and
https://gobot.io/documentation/examples/tello_opencv/

and of course the classifier

https://raw.githubusercontent.com/opencv/opencv/master/data/haarcascades/haarcascade_frontalface_default.xml

added updates to make windows and mac friendly
https://medium.com/tarkalabs/automating-dji-tello-drone-using-gobot-2b711bf42af6

*/

package main

import (
    "fmt"
    "io"
    "log"
    "os/exec"
    "time"

    "gobot.io/x/gobot"
    "gobot.io/x/gobot/platforms/dji/tello"
    "gocv.io/x/gocv"
    "golang.org/x/image/colornames"
    //"image/color"
)

const (
    frameSize = 960 * 720 * 3
)

func main() {
    drone := tello.NewDriver( "8890" )
    //window := opencv.NewWindowDriver()
    window := gocv.NewWindow( "Demo2" )
    classifier := gocv.NewCascadeClassifier()
    classifier.Load( "haarcascade_frontalface_default.xml" )
    fmt.Println( "Cascade loaded" )
    defer classifier.Close()
    ffmpeg := exec.Command( "ffmpeg", "-i", "pipe:0", "-pix_fmt", "bgr24", "-vcodec", "rawvideo",
        "-an", "-sn", "-s", "960x720", "-f", "rawvideo", "pipe:1" )
    ffmpegIn, _ := ffmpeg.StdinPipe()
    ffmpegOut, _ := ffmpeg.StdoutPipe()
    work := func() {

        if err := ffmpeg.Start(); err != nil {
            fmt.Println( err )
            return
        }
        //count:=0

        drone.On( tello.ConnectedEvent, func( data interface{} ) {
            fmt.Println( "Connected" )
            drone.StartVideo()
            drone.SetVideoEncoderRate( tello.VideoBitRateAuto )
            drone.SetExposure( 0 )
            gobot.Every( 100*time.Millisecond, func() {
                drone.StartVideo()
            } )
        })

        drone.On( tello.VideoFrameEvent, func( data interface{} ) {
            fmt.Println( "Got video data" )
            pkt := data.([]byte)
            if _, err := ffmpegIn.Write( pkt ); err != nil {
                fmt.Println( err )
            }
        } )

        /*drone.On( tello.FlightDataEvent, func( data interface{} ) {
            // TODO: protect flight data from race condition
            flightData := data.( *tello.FlightData )
            fmt.Println( "battery power:", flightData.BatteryPercentage )
        } )*/

        /*drone.On( tello.WifiDataEvent, func( data interface{} ) {
            fmt.Println( "WifiDataEvent" )
            fmt.Println( data )
        } )*/

        /*drone.On( tello.LogEvent, func( data interface{} ) {
            fmt.Println( "Log Event" )
            fmt.Println( data )
        } )*/

    }

    robot := gobot.NewRobot( "tello",
        []gobot.Connection{},
        []gobot.Device{ drone },
        work,
    )

    robot.Start( false )
    for {
        fmt.Println( "TEST" )
        buf := make( []byte, frameSize )
        if _, err := io.ReadFull( ffmpegOut, buf ); err != nil {
            fmt.Println(err)
            continue
        }
        fmt.Println( "Making image from bytes" )
        img, err := gocv.NewMatFromBytes( 720, 960, gocv.MatTypeCV8UC3, buf )
        if err != nil {
            log.Print( err )
            continue
        }
        if img.Empty() {
            fmt.Println( "No image data" )
            continue
        }
        fmt.Println( "Looking for rectangles" )
        imageRectangles := classifier.DetectMultiScale(img)

        for _, rect := range imageRectangles {
            log.Println( "found a face,", rect )
            gocv.Rectangle( &img, rect, colornames.Cadetblue, 3 )
        }
        fmt.Println( "Show image" )
        window.IMShow( img )
        //if window.WaitKey( 1 ) >= 0 {
        //    break
        //}
        //if count < 1000 {
        //
        //}
        //window.WaitKey( 1 )
        //count +=1
    }
}

I do see the "Connected" message so drone.startVideo() should be executing and I have confirmed the other callback is working gobot.Every

Also I don't know if it is of any consequence but I am having a similar problem with the tello.FlightDataEvent with this little script I wrote to check the battery level

package main

import (
    "fmt"
    "bufio"
    "os"
    "time"
    "gobot.io/x/gobot"
    "gobot.io/x/gobot/platforms/dji/tello"
)

func main() {
    drone := tello.NewDriver("8888")
    work := func() {
        drone.On( tello.ConnectedEvent, func( data interface{} ) {
            fmt.Println( "Connected" )
            gobot.Every( 100*time.Millisecond, func() {
            } )
        })
        drone.On( tello.FlightDataEvent, func( data interface{} ) {
            // TODO: protect flight data from race condition
            flightData := data.( *tello.FlightData )
            fmt.Println( "Battery power:", flightData.BatteryPercentage, "%" )
        } )
    }
    robot := gobot.NewRobot( "tello",
        []gobot.Connection{},
        []gobot.Device{ drone },
        work,
    )
    reader := bufio.NewReader( os.Stdin )
    robot.Start( false )
    for {
        fmt.Println( "-----" )
        reader.ReadString( '\n' )
    }
}

Central Question: Does anyone have any idea why this event may not be firing/I cant get video data back?

This is my first thread here, so hello and I hope I have followed the forum's preferences for posting!

Thank you for reading!