origJsCamera.go

// Copyright 2019 kdevb0x Ltd. All rights reserved.
// Use of this source code is governed by the BSD 3-Clause license
// The full license text can be found in the LICENSE file.

// +build wasm,js

package quikface // import "github.com/kdevb0x/quikface"

import (
	"io"
	"syscall/js"

	"github.com/dennwc/dom"
	// using both webrtc because each pkg has diff features.
	"github.com/dennwc/dom/net/webrtc"

	rtc "github.com/pion/webrtc/v2"
	"github.com/pion/rtp/codecs"
	"github.com/pion/rtp"
)

var (
	_ webrtc.Local
)

type MediaStream interface {
	// returns the instances unique 36 char string
	Id() string
	GetAudioTracks []MediaStreamTrack
	GetTrackById(id string) (MediaStreamTrack, error)
	GetVideoTracks() []MediaStreamTrack

}

// JSAudioTrack represents an audio track from the browsers MediaStream.
type JSAudioTrack struct {
	jsval js.Value
	Track *rtc.Track
}

// JSVideoTrack represents a video track from the browsers MediaStream.
type JSVideoTrack struct {
	jsval js.Value
	Track *rtc.Track
}

func (au *JSAudioTrack) Id() string {

}

// InitBrowserCam instantiates the webcam through the browsers
// navigator.MediaDevices.getUserMedia API.
func InitBrowserCam() (MediaStream, error) {
	var localVideo = dom.GetDocument().QuerySelector("localVideo")
	goconstraints := map[string]interface{}{"audio": true, "video": map[string]interface{}{"facingMode": "user"}}
	constraints := js.ValueOf(goconstraints)
	mediaDevices := js.Global().Get("navigator").Get("mediaDevices")

	getUserMediaPromise := mediaDevices.Call("getUserMedia", constraints)

	/*
	var localVidTrack *JSVideoTrack
	var localAudioTrack *JSAudioTrack
	streamfunc := js.AsyncCallbackOf(func(streams []js.Value) {
		if len(streams) > 0 {
			for _, stream := range streams {
				for _, track := stream.Call("getTracks") {
					if track.Get("kind").String() == "video" {
						localVidTrack = &JSVideoTrack{track}
					}
				}
				var vidTrack = stream.Call("getVideoTracks")
			}
		}

	})
	*/
	getUserMediaPromise.Call("onSuccess", js.FuncOf(goRTCStreamCallback))
	// getUserMediaPromise.Call("onError", js.FuncOf(/* TODO: implement */ goRTCStreamErrorCallback))


}

// initGoRTCSession signiture matches that needed for js.FuncOf callback.
func goRTCStreamCallback(this js.Value, args []js.Value) interface{} {
	var offer = rtc.SessionDescription{}
	vtracks := this.Call("getVideoTracks")
	mediaEngine := rtc.MediaEngine{}
	// vidcodec := mediaEngine.RegiserCodecByKind(rtc.RTPCodecTypeVideo)
	if err := mediaEngine.PopulateFromSDP(offer); err == nil {
		videoCodecs := mediaEngine.GetCodecsByKind(rtc.RTPCodecTypeVideo)
		api := rtc.NewApi(rtc.WithMediaEngine(mediaEngine))
		var rtcConfig = rtc.Configuration{
			ICEServers: []rtc.ICEServer{
				{
					URLs: []string{"stun:stun.l.google.com:19302"},
				},
			},
		}
		peerconn, err := api.NewPeerConnection(rtcConfig)
		if err != nil {
			println(err.Error())
		}
		err = peerconn.SetRemoteDescription(offer)
		if err != nil {
			println(err.Error())
		}
		// track to send to local browser
		btrack, err := peerconn.NewTrack()
		peerconn.AddTransceiver(rtc.RTPCodecTypeVideo)
		peerconn.OnTrack
}