Register GstSample marshaling functions

.github/workflows/build.yml

@@ -0,0 +1,28 @@
+name: Build
+
+on:
+  pull_request:
+    branches:
+      - main
+
+jobs:
+  matrix:
+    strategy:
+      matrix:
+        os: [ubuntu-latest, windows-latest, 'macos-latest']
+    runs-on: ${{ matrix.os }}
+    steps:
+      - name: Setup GStreamer
+        id:   setup_gstreamer
+        uses: blinemedical/setup-gstreamer@45324555100927b587d390d8cf3940f91fd3bdc9
+        with:
+          version: 1.22.0
+      - uses: actions/setup-go@v4
+        with:
+          go-version: '^1.21.0'
+      - name: checkout
+        uses: actions/checkout@v3
+      - name: build the appsink
+        run: cd examples/appsink && go build -x .
+
+

.github/workflows/tests.yml

@@ -1,21 +1,28 @@
 name: Tests
 
 on:
-  push:
-    branches: [ main ]
   pull_request:
-    branches: [ main ]
+    branches:
+      - main
 
 jobs:
-
   setup:
-    name: Tests
-    runs-on: ubuntu-20.04
+    name: Tests on codebase
+    runs-on: ubuntu-latest
     steps:
+      - name: Check out code into the Go module directory
+        uses: actions/checkout@v2
+
+      - name: Check formatting
+        uses: Jerome1337/gofmt-action@v1.0.5
+        with:
+          gofmt-path: '.'
+          gofmt-flags: '-l -d'
+
+      - name: Check spellings
+        uses: reviewdog/action-misspell@v1
+        with:
+          locale: "US"
+          fail_on_error: true
 
-    - name: Check out code into the Go module directory
-      uses: actions/checkout@v2
 
-    - name: Lint all packages
-      run: |
-        make docker-lint

README.md

@@ -1,14 +1,12 @@
-# go-gst
+![banner](./img/go-gst-banner.png)
 
-Go bindings for the GStreamer C libraries
+# go-gst: Go bindings for the GStreamer C libraries
 
-[![go.dev reference](https://img.shields.io/badge/go.dev-reference-007d9c?logo=go&logoColor=white&style=flat-rounded)](https://pkg.go.dev/github.com/tinyzimmer/go-gst)
-[![godoc reference](https://img.shields.io/badge/godoc-reference-blue.svg)](https://godoc.org/github.com/tinyzimmer/go-gst)
-[![GoReportCard](https://goreportcard.com/badge/github.com/nanomsg/mangos)](https://goreportcard.com/report/github.com/tinyzimmer/go-gst)
-![](https://github.com/tinyzimmer/go-gst/workflows/Tests/badge.svg)
+[![godoc reference](https://img.shields.io/badge/godoc-reference-blue.svg)](https://godoc.org/github.com/go-gst/go-gst)
+[![GoReportCard](https://goreportcard.com/badge/github.com/go-gst/go-gst)](https://goreportcard.com/report/github.com/go-gst/go-gst)
+<!-- ![](https://github.com/go-gst/go-gst/workflows/Tests/badge.svg) -->
 
-See the [godoc.org](https://godoc.org/github.com/tinyzimmer/go-gst) or [pkg.go.dev](https://pkg.go.dev/github.com/tinyzimmer/go-gst) references for documentation and examples.
-As the latter requires published tags, see godoc.org for the latest documentation of master at any point in time.
+See [pkg.go.dev](https://pkg.go.dev/github.com/go-gst/go-gst) references for documentation and examples.
 
 **This library has not been thoroughly tested and as such is not recommended for mission critical applications yet. If you'd like to try it out and encounter any bugs, feel free to open an Issue or PR. For more information see the [Contributing](#contributing) section.**
 
@@ -40,7 +38,7 @@ PS> $env:PKG_CONFIG_PATH='C:\gstreamer\1.0\mingw_x86_64\lib\pkgconfig'
 PS> go build .
 ```
 
-For more information, take a look at [this comment](https://github.com/tinyzimmer/go-gst/issues/3#issuecomment-760648278) with a good run down of the process from compilation to execution.
+For more information, take a look at [this comment](https://github.com/go-gst/go-gst/issues/3#issuecomment-760648278) with a good run down of the process from compilation to execution.
 
 ## Quickstart
 
@@ -56,8 +54,8 @@ import (
     "os"
     "strings"
 
-    "github.com/tinyzimmer/go-glib/glib"
-    "github.com/tinyzimmer/go-gst/gst"
+    "github.com/go-gst/go-glib/glib"
+    "github.com/go-gst/go-gst/gst"
 )
 
 func main() {

cmd/gst-plugin-gen/main.go

@@ -136,9 +136,9 @@ import "C"
 import (
 	"unsafe"
 
-	"github.com/tinyzimmer/go-gst/gst"
+	"github.com/go-gst/go-gst/gst"
 	{{- if (.Config.Element.Subclass | extendsFromBase) }}
-	"github.com/tinyzimmer/go-gst/gst/base"
+	"github.com/go-gst/go-gst/gst/base"
 	{{- end }}
 )
 

examples/appsink/main.go

@@ -6,11 +6,10 @@ import (
 	"math"
 	"os"
 	"os/signal"
-	"time"
 
-	"github.com/tinyzimmer/go-gst/examples"
-	"github.com/tinyzimmer/go-gst/gst"
-	"github.com/tinyzimmer/go-gst/gst/app"
+	"github.com/go-gst/go-gst/examples"
+	"github.com/go-gst/go-gst/gst"
+	"github.com/go-gst/go-gst/gst/app"
 )
 
 func createPipeline() (*gst.Pipeline, error) {
@@ -116,7 +115,7 @@ func mainLoop(pipeline *gst.Pipeline) error {
 
 	// Loop over messsages from the pipeline
 	for {
-		msg := bus.TimedPop(time.Duration(-1))
+		msg := bus.TimedPop(gst.ClockTimeNone)
 		if msg == nil {
 			break
 		}

examples/appsrc/main.go

@@ -7,11 +7,11 @@ import (
 	"image/color"
 	"time"
 
-	"github.com/tinyzimmer/go-glib/glib"
-	"github.com/tinyzimmer/go-gst/examples"
-	"github.com/tinyzimmer/go-gst/gst"
-	"github.com/tinyzimmer/go-gst/gst/app"
-	"github.com/tinyzimmer/go-gst/gst/video"
+	"github.com/go-gst/go-glib/glib"
+	"github.com/go-gst/go-gst/examples"
+	"github.com/go-gst/go-gst/gst"
+	"github.com/go-gst/go-gst/gst/app"
+	"github.com/go-gst/go-gst/gst/video"
 )
 
 const width = 320
@@ -76,7 +76,7 @@ func createPipeline() (*gst.Pipeline, error) {
 
 			// For each frame we produce, we set the timestamp when it should be displayed
 			// The autovideosink will use this information to display the frame at the right time.
-			buffer.SetPresentationTimestamp(time.Duration(i) * 500 * time.Millisecond)
+			buffer.SetPresentationTimestamp(gst.ClockTime(time.Duration(i) * 500 * time.Millisecond))
 
 			// Produce an image frame for this iteration.
 			pixels := produceImageFrame(palette[i])

examples/bins/main.go

@@ -2,9 +2,9 @@ package main
 
 import (
 	"fmt"
-	"github.com/tinyzimmer/go-glib/glib"
-	"github.com/tinyzimmer/go-gst/examples"
-	"github.com/tinyzimmer/go-gst/gst"
+	"github.com/go-gst/go-glib/glib"
+	"github.com/go-gst/go-gst/examples"
+	"github.com/go-gst/go-gst/gst"
 	"os"
 )
 

examples/common.go

@@ -3,7 +3,7 @@ package examples
 import (
 	"fmt"
 
-	"github.com/tinyzimmer/go-glib/glib"
+	"github.com/go-gst/go-glib/glib"
 )
 
 // Run is used to wrap the given function in a main loop and print any error

examples/custom_events/main.go

@@ -6,9 +6,9 @@ import (
 	"fmt"
 	"time"
 
-	"github.com/tinyzimmer/go-glib/glib"
-	"github.com/tinyzimmer/go-gst/examples"
-	"github.com/tinyzimmer/go-gst/gst"
+	"github.com/go-gst/go-glib/glib"
+	"github.com/go-gst/go-gst/examples"
+	"github.com/go-gst/go-gst/gst"
 )
 
 // ExampleCustomEvent demonstrates a custom event structue. Currerntly nested structs

examples/decodebin/main.go

@@ -6,7 +6,7 @@
 // Before the pipeline hasn't been prerolled, the decodebin can't possibly know what
 // format it gets as its input. So at first, the pipeline looks like this:
 //
-//   {filesrc} - {decodebin}
+//	{filesrc} - {decodebin}
 //
 // As soon as the decodebin has detected the stream format, it will try to decode every
 // contained stream to its raw format.
@@ -18,9 +18,9 @@
 // So for a file that contains one audio and one video stream,
 // the pipeline looks like the following:
 //
-//                          /-[audio]-{audioconvert}-{audioresample}-{autoaudiosink}
-//   {filesrc}-{decodebin}-|
-//                          \-[video]-{videoconvert}-{videoscale}-{autovideosink}
+//	                       /-[audio]-{audioconvert}-{audioresample}-{autoaudiosink}
+//	{filesrc}-{decodebin}-|
+//	                       \-[video]-{videoconvert}-{videoscale}-{autovideosink}
 //
 // Both auto-sinks at the end automatically select the best available (actual) sink. Since the
 // selection of available actual sinks is platform specific
@@ -38,9 +38,9 @@ import (
 	"os"
 	"strings"
 
-	"github.com/tinyzimmer/go-glib/glib"
-	"github.com/tinyzimmer/go-gst/examples"
-	"github.com/tinyzimmer/go-gst/gst"
+	"github.com/go-gst/go-glib/glib"
+	"github.com/go-gst/go-gst/examples"
+	"github.com/go-gst/go-gst/gst"
 )
 
 var srcFile string

examples/device_monitor/main.go

@@ -0,0 +1,75 @@
+// This example uses gstreamer's device monitor api.
+//
+// https://gstreamer.freedesktop.org/documentation/gstreamer/gstdevicemonitor.html
+package main
+
+import (
+	"fmt"
+
+	"github.com/go-gst/go-glib/glib"
+	"github.com/go-gst/go-gst/examples"
+	"github.com/go-gst/go-gst/gst"
+)
+
+func runPipeline(loop *glib.MainLoop) error {
+
+	gst.Init(nil)
+	fmt.Println("Running device monitor")
+	// if len(os.Args) < 2 {
+	// 	fmt.Printf("USAGE: %s <uri>\n", os.Args[0])
+	// 	os.Exit(1)
+	// }
+
+	// uri := os.Args[1]
+	fmt.Println("Creating device monitor")
+
+	monitor := gst.NewDeviceMonitor()
+	fmt.Println("Created device monitor", monitor)
+
+	// if err != nil {
+	// 	fmt.Println("ERROR:", err)
+	// 	os.Exit(2)
+	// }
+	caps := gst.NewCapsFromString("video/x-raw")
+
+	monitor.AddFilter("Video/Source", caps)
+
+	fmt.Println("Getting device monitor bus")
+	bus := monitor.GetBus()
+	fmt.Println("Got device monitor bus", bus)
+
+	bus.AddWatch(func(msg *gst.Message) bool {
+		switch msg.Type() {
+		case gst.MessageDeviceAdded:
+			message := msg.ParseDeviceAdded().GetDisplayName()
+			fmt.Println("Added: ", message)
+		case gst.MessageDeviceRemoved:
+			message := msg.ParseDeviceRemoved().GetDisplayName()
+			fmt.Println("Removed: ", message)
+		default:
+			// All messages implement a Stringer. However, this is
+			// typically an expensive thing to do and should be avoided.
+			fmt.Println("Type: ", msg.Type())
+			fmt.Println("Message: ", msg)
+		}
+		return true
+	})
+
+	fmt.Println("Starting device monitor")
+	monitor.Start()
+	fmt.Println("Started device monitor")
+	devices := monitor.GetDevices()
+	for i, v := range devices {
+		fmt.Printf("Device: %d %s\n", i, v.GetDisplayName())
+	}
+
+	loop.Run()
+
+	return nil
+}
+
+func main() {
+	examples.RunLoop(func(loop *glib.MainLoop) error {
+		return runPipeline(loop)
+	})
+}