This repository has been archived by the owner on Jul 17, 2020. It is now read-only.
-
-
Notifications
You must be signed in to change notification settings - Fork 2
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
Showing
9 changed files
with
386 additions
and
14 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,203 @@ | ||
| import grandiose from "grandiose"; | ||
| import uuidv4 from "uuid/v4"; | ||
| import Vue from "vue"; | ||
| import store from "../"; | ||
|
|
||
| const state = { | ||
| discovering: false, | ||
|
|
||
| receivers: { | ||
| // "receiver-uuidv4": { | ||
| // reciver: {}, // the receiver instance, | ||
| // outputId: "output-uuidv4", // id of an output canvas | ||
| // enabled: false // whether we should do anything with the incoming data from this receiver | ||
| // } | ||
| }, | ||
|
|
||
| sources: [ | ||
| // { | ||
| // name: "GINGER (Intel(R) HD Graphics 520 1)", | ||
| // urlAddress: "169.254.82.1:5962" | ||
| // }, | ||
| // { name: "GINGER (Test Pattern)", urlAddress: "169.254.82.1:5961" }, | ||
| // { | ||
| // name: "GINGER (TOSHIBA Web Camera - HD)", | ||
| // urlAddress: "169.254.82.1:5963" | ||
| // } | ||
| ], | ||
|
|
||
| discoveryOptions: { | ||
| showLocalSources: true | ||
| } | ||
| }; | ||
|
|
||
| function checkCpu() { | ||
| if (!grandiose.isSupportedCPU()) { | ||
| throw new Error("Your CPU is not supported for NDI"); | ||
| } | ||
| } | ||
|
|
||
| async function waitForFrame(receiverContext) { | ||
| const { receiver, outputId } = receiverContext; | ||
| const { | ||
| context, | ||
| context: { canvas } | ||
| } = store.state.outputs.auxillary[outputId]; | ||
|
|
||
| let dataFrame; | ||
|
|
||
| try { | ||
| dataFrame = await receiver.data(); | ||
| } catch (e) { | ||
| console.error(e); | ||
|
|
||
| if (receiverContext.enabled) { | ||
| waitForFrame(receiverContext); | ||
| } | ||
| } | ||
|
|
||
| if (dataFrame.type === "video") { | ||
| const { xres, yres, data: uint8array } = dataFrame; | ||
| const ui8c = new Uint8ClampedArray( | ||
| uint8array.buffer, | ||
| uint8array.byteOffset, | ||
| uint8array.byteLength / Uint8ClampedArray.BYTES_PER_ELEMENT | ||
| ); | ||
| const image = new ImageData(ui8c, dataFrame.xres); | ||
|
|
||
| if (canvas.width !== xres || canvas.height !== yres) { | ||
| canvas.width = xres; | ||
| canvas.height = yres; | ||
| } | ||
|
|
||
| context.putImageData(image, 0, 0); | ||
| } | ||
|
|
||
| if (receiverContext.enabled) { | ||
| waitForFrame(receiverContext); | ||
| } | ||
| } | ||
|
|
||
| const actions = { | ||
| async discoverSources({ commit }) { | ||
| checkCpu(); | ||
|
|
||
| commit("SET_DISCOVERING", true); | ||
|
|
||
| try { | ||
| const sources = await grandiose.find(state.discoveryOptions); | ||
| commit("SET_SOURCES", sources); | ||
| } catch (e) { | ||
| console.log(e); | ||
| } | ||
|
|
||
| commit("SET_DISCOVERING", false); | ||
| }, | ||
|
|
||
| setDiscoveryOptions({ commit }, options) { | ||
| commit("SET_DISCOVERY_OPTIONS", { ...state.discoveryOptions, ...options }); | ||
| }, | ||
|
|
||
| async createReceiver({ commit }, receiverOptions) { | ||
| receiverOptions.colorFormat = grandiose.COLOR_FORMAT_RGBX_RGBA; | ||
| receiverOptions.bandwidth = grandiose.BANDWIDTH_LOWEST; | ||
|
|
||
| const receiver = await grandiose.receive(receiverOptions); | ||
|
|
||
| const outputContext = await store.dispatch("outputs/getAuxillaryOutput", { | ||
| name: receiverOptions.source.name, | ||
| group: "NDI", | ||
| reactToResize: false | ||
| }); | ||
|
|
||
| const receiverId = uuidv4(); | ||
| const receiverContext = { | ||
| id: receiverId, | ||
| outputId: outputContext.id, | ||
| receiver, | ||
| enabled: false | ||
| }; | ||
|
|
||
| commit("ADD_RECIEVER", receiverContext); | ||
|
|
||
| return receiverContext; | ||
| }, | ||
|
|
||
| async enableReceiver({ commit }, { receiverId }) { | ||
| const receiverContext = state.receivers[receiverId]; | ||
|
|
||
| if (!receiverContext) { | ||
| throw new Error(`No receiver found with id ${receiverId}`); | ||
| } | ||
|
|
||
| receiverContext.enabled = true; | ||
|
|
||
| commit("UPDATE_RECIEVER", receiverContext); | ||
|
|
||
| waitForFrame(receiverContext); | ||
| }, | ||
|
|
||
| disableReceiver({ commit }, { receiverId }) { | ||
| const receiverContext = state.receivers[receiverId]; | ||
|
|
||
| if (!receiverContext) { | ||
| throw new Error(`No receiver found with id ${receiverId}`); | ||
| } | ||
|
|
||
| receiverContext.enabled = false; | ||
|
|
||
| commit("UPDATE_RECIEVER", receiverContext); | ||
| }, | ||
|
|
||
| async removeReceiver({ commit }, { receiverId }) { | ||
| const receiverContext = state.receivers[receiverId]; | ||
|
|
||
| if (!receiverContext) { | ||
| throw new Error(`No receiver found with id ${receiverId}`); | ||
| } | ||
|
|
||
| await store.dispatch("ndi/disableReceiver", { | ||
| receiverId: receiverContext.id | ||
| }); | ||
|
|
||
| await store.dispatch( | ||
| "outputs/removeAuxillaryOutput", | ||
| receiverContext.outputId | ||
| ); | ||
|
|
||
| commit("DELETE_RECIEVER", receiverContext); | ||
| } | ||
| }; | ||
|
|
||
| const mutations = { | ||
| SET_SOURCES(state, sources) { | ||
| state.sources = sources; | ||
| }, | ||
|
|
||
| SET_DISCOVERING(state, discovering) { | ||
| state.discovering = discovering; | ||
| }, | ||
|
|
||
| SET_DISCOVERY_OPTIONS(state, options) { | ||
| state.discoveryOptions = options; | ||
| }, | ||
|
|
||
| ADD_RECIEVER(state, receiverContext) { | ||
| Vue.set(state.receivers, receiverContext.id, receiverContext); | ||
| }, | ||
|
|
||
| UPDATE_RECIEVER(state, receiverContext) { | ||
| Vue.set(state.receivers, receiverContext.id, receiverContext); | ||
| }, | ||
|
|
||
| DELETE_RECIEVER(state, receiverContext) { | ||
| Vue.delete(state.receivers, receiverContext.id); | ||
| } | ||
| }; | ||
|
|
||
| export default { | ||
| namespaced: true, | ||
| state, | ||
| actions, | ||
| mutations | ||
| }; |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.