Skip to content

Commit

Permalink
Corrections needed for Bebop to handle Outside mode
Browse files Browse the repository at this point in the history
  • Loading branch information
deadprogram committed Oct 24, 2015
1 parent fdf5576 commit 24ccd3d
Show file tree
Hide file tree
Showing 5 changed files with 195 additions and 48 deletions.
48 changes: 0 additions & 48 deletions examples/bebop_ps3.go
Original file line number Diff line number Diff line change
@@ -1,11 +1,7 @@
package main

import (
"fmt"
"io"
"io/ioutil"
"math"
"os/exec"
"time"

"github.com/hybridgroup/gobot"
Expand All @@ -18,40 +14,6 @@ type pair struct {
y float64
}

func ffmpeg() (stdin io.WriteCloser, stderr io.ReadCloser, err error) {
ffmpeg := exec.Command("ffmpeg", "-i", "pipe:0", "http://localhost:8090/bebop.ffm")

stderr, err = ffmpeg.StderrPipe()

if err != nil {
return
}

stdin, err = ffmpeg.StdinPipe()

if err != nil {
return
}

if err = ffmpeg.Start(); err != nil {
return
}

go func() {
for {
buf, err := ioutil.ReadAll(stderr)
if err != nil {
fmt.Println(err)
}
if len(buf) > 0 {
fmt.Println(string(buf))
}
}
}()

return stdin, stderr, nil
}

func main() {
gbot := gobot.NewGobot()

Expand All @@ -65,16 +27,6 @@ func main() {
drone := bebop.NewBebopDriver(bebopAdaptor, "Drone")

work := func() {
video, _, _ := ffmpeg()

go func() {
for {
if _, err := video.Write(<-drone.Video()); err != nil {
fmt.Println(err)
return
}
}
}()

offset := 32767.0
rightStick := pair{x: 0, y: 0}
Expand Down
188 changes: 188 additions & 0 deletions examples/bebop_ps3_video.go
Original file line number Diff line number Diff line change
@@ -0,0 +1,188 @@
package main

import (
"fmt"
"io"
"io/ioutil"
"math"
"os/exec"
"time"

"github.com/hybridgroup/gobot"
"github.com/hybridgroup/gobot/platforms/bebop"
"github.com/hybridgroup/gobot/platforms/joystick"
)

type pair struct {
x float64
y float64
}

func ffmpeg() (stdin io.WriteCloser, stderr io.ReadCloser, err error) {
ffmpeg := exec.Command("ffmpeg", "-i", "pipe:0", "http://localhost:8090/bebop.ffm")

stderr, err = ffmpeg.StderrPipe()

if err != nil {
return
}

stdin, err = ffmpeg.StdinPipe()

if err != nil {
return
}

if err = ffmpeg.Start(); err != nil {
return
}

go func() {
for {
buf, err := ioutil.ReadAll(stderr)
if err != nil {
fmt.Println(err)
}
if len(buf) > 0 {
fmt.Println(string(buf))
}
}
}()

return stdin, stderr, nil
}

func main() {
gbot := gobot.NewGobot()

joystickAdaptor := joystick.NewJoystickAdaptor("ps3")
joystick := joystick.NewJoystickDriver(joystickAdaptor,
"ps3",
"./platforms/joystick/configs/dualshock3.json",
)

bebopAdaptor := bebop.NewBebopAdaptor("Drone")
drone := bebop.NewBebopDriver(bebopAdaptor, "Drone")

work := func() {
video, _, _ := ffmpeg()

go func() {
for {
if _, err := video.Write(<-drone.Video()); err != nil {
fmt.Println(err)
return
}
}
}()

offset := 32767.0
rightStick := pair{x: 0, y: 0}
leftStick := pair{x: 0, y: 0}

recording := false

gobot.On(joystick.Event("circle_press"), func(data interface{}) {
if recording {
drone.StopRecording()
} else {
drone.StartRecording()
}
recording = !recording
})

gobot.On(joystick.Event("square_press"), func(data interface{}) {
drone.HullProtection(true)
drone.TakeOff()
})
gobot.On(joystick.Event("triangle_press"), func(data interface{}) {
drone.Stop()
})
gobot.On(joystick.Event("x_press"), func(data interface{}) {
drone.Land()
})
gobot.On(joystick.Event("left_x"), func(data interface{}) {
val := float64(data.(int16))
if leftStick.x != val {
leftStick.x = val
}
})
gobot.On(joystick.Event("left_y"), func(data interface{}) {
val := float64(data.(int16))
if leftStick.y != val {
leftStick.y = val
}
})
gobot.On(joystick.Event("right_x"), func(data interface{}) {
val := float64(data.(int16))
if rightStick.x != val {
rightStick.x = val
}
})
gobot.On(joystick.Event("right_y"), func(data interface{}) {
val := float64(data.(int16))
if rightStick.y != val {
rightStick.y = val
}
})

gobot.Every(10*time.Millisecond, func() {
pair := leftStick
if pair.y < -10 {
drone.Forward(validatePitch(pair.y, offset))
} else if pair.y > 10 {
drone.Backward(validatePitch(pair.y, offset))
} else {
drone.Forward(0)
}

if pair.x > 10 {
drone.Right(validatePitch(pair.x, offset))
} else if pair.x < -10 {
drone.Left(validatePitch(pair.x, offset))
} else {
drone.Right(0)
}
})

gobot.Every(10*time.Millisecond, func() {
pair := rightStick
if pair.y < -10 {
drone.Up(validatePitch(pair.y, offset))
} else if pair.y > 10 {
drone.Down(validatePitch(pair.y, offset))
} else {
drone.Up(0)
}

if pair.x > 20 {
drone.Clockwise(validatePitch(pair.x, offset))
} else if pair.x < -20 {
drone.CounterClockwise(validatePitch(pair.x, offset))
} else {
drone.Clockwise(0)
}
})
}

robot := gobot.NewRobot("bebop",
[]gobot.Connection{joystickAdaptor, bebopAdaptor},
[]gobot.Device{joystick, drone},
work,
)

gbot.AddRobot(robot)

gbot.Start()
}

func validatePitch(data float64, offset float64) int {
value := math.Abs(data) / offset
if value >= 0.1 {
if value <= 1.0 {
return int((float64(int(value*100)) / 100) * 100)
}
return 100
}
return 0
}
1 change: 1 addition & 0 deletions platforms/bebop/bebop_adaptor.go
Original file line number Diff line number Diff line change
Expand Up @@ -25,6 +25,7 @@ type drone interface {
StartRecording() error
StopRecording() error
HullProtection(protect bool) error
Outdoor(outdoor bool) error
}

// BebopAdaptor is gobot.Adaptor representation for the Bebop
Expand Down
5 changes: 5 additions & 0 deletions platforms/bebop/bebop_driver.go
Original file line number Diff line number Diff line change
Expand Up @@ -129,3 +129,8 @@ func (a *BebopDriver) StopRecording() error {
func (a *BebopDriver) HullProtection(protect bool) error {
return a.adaptor().drone.HullProtection(protect)
}

// Outdoor tells the drone if flying Outdoor or not. This is needed to adjust flight characteristics of the Bebop.
func (a *BebopDriver) Outdoor(outdoor bool) error {
return a.adaptor().drone.Outdoor(outdoor)
}
1 change: 1 addition & 0 deletions platforms/bebop/test_helper.go
Original file line number Diff line number Diff line change
Expand Up @@ -19,3 +19,4 @@ func (t testDrone) Video() chan []byte { return nil }
func (t testDrone) StartRecording() error { return nil }
func (t testDrone) StopRecording() error { return nil }
func (t testDrone) HullProtection(protect bool) error { return nil }
func (t testDrone) Outdoor(outdoor bool) error { return nil }

0 comments on commit 24ccd3d

Please sign in to comment.