Skip to content

Commit

Permalink
fix: added file for last commit
Browse files Browse the repository at this point in the history 
chore: converted DEFAULTS.js
chore: added declare osc in @types
  • Loading branch information
@olzzon
olzzon committed May 29, 2019
1 parent eeb1673 commit 6197f2b
Show file tree
Hide file tree
Showing 3 changed files with 300 additions and 0 deletions.
1 change: 1 addition & 0 deletions src/@types/osc/index.d.ts
View file
Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
declare module 'osc'
0 src/constants/DEFAULTS.js → src/constants/DEFAULTS.ts
View file
File renamed without changes.
299 changes: 299 additions & 0 deletions src/utils/OscMixerConnection.ts
View file
Original file line number Diff line number Diff line change
@@ -0,0 +1,299 @@
//Node Modules:
import os from 'os'; // Used to display (log) network addresses on local machine
import osc from 'osc'; //Using OSC fork from PieceMeta/osc.js as it has excluded hardware serialport support and thereby is crossplatform

//Utils:
import { MixerProtocol, MixerProtocolPresets } from '../constants/MixerProtocolPresets';
import { behringerMeter, behringerGrpMeter } from './productSpecific/behringer';
import { midasMeter, midasGrpMeter } from './productSpecific/midas';

export class OscMixerConnection {
store: any;
mixerProtocol: MixerProtocol;
cmdChannelIndex: number;
oscConnection: any;

constructor() {
this.sendOutMessage = this.sendOutMessage.bind(this);
this.pingMixerCommand = this.pingMixerCommand.bind(this);

this.store = window.storeRedux.getState();
const unsubscribe = window.storeRedux.subscribe(() => {
this.store = window.storeRedux.getState();
});

this.mixerProtocol = MixerProtocolPresets[this.store.settings[0].mixerProtocol] || MixerProtocolPresets.genericMidi;

this.cmdChannelIndex = this.mixerProtocol.fromMixer.CHANNEL_OUT_GAIN.split('/').findIndex(ch => ch==='{channel}');

this.oscConnection = new osc.UDPPort({
localAddress: this.store.settings[0].localOscIp,
localPort: parseInt(this.store.settings[0].localOscPort),
remoteAddress: this.store.settings[0].machineOscIp,
remotePort: parseInt(this.store.settings[0].machineOscPort)
});
this.setupMixerConnection();
}

setupMixerConnection() {
this.oscConnection
.on("ready", () => {
console.log("Receiving state of desk");
this.mixerProtocol.initializeCommands.map((item) => {
if (item.oscMessage.includes("{channel}")) {
this.store.channels[0].channel.map((channel: any, index: any) => {
this.sendOutRequest(item.oscMessage,(index +1));
});
} else {
this.sendOutMessage(item.oscMessage, 1, item.value, item.type);
}
});
})
.on('message', (message: any) => {
if ( this.checkOscCommand(message.address, this.mixerProtocol.fromMixer
.CHANNEL_FADER_LEVEL)){
let ch = message.address.split("/")[this.cmdChannelIndex];
window.storeRedux.dispatch({
type:'SET_FADER_LEVEL',
channel: ch - 1,
level: message.args[0]
});
if (this.mixerProtocol.mode === 'master') {
if (this.store.channels[0].channel[ch - 1].pgmOn)
{
this.updateOutLevel(ch-1);
}
}
} else if ( this.checkOscCommand(message.address, this.mixerProtocol.fromMixer
.CHANNEL_OUT_GAIN)){
let ch = message.address.split("/")[this.cmdChannelIndex];
if (this.mixerProtocol.mode === 'master'
&& !this.store.channels[0].channel[ch - 1].fadeActive
&& message.args[0] > this.mixerProtocol.fader.min)
{
window.storeRedux.dispatch({
type:'SET_FADER_LEVEL',
channel: ch - 1,
level: message.args[0]
});
if (!this.store.channels[0].channel[ch - 1].pgmOn) {
window.storeRedux.dispatch({
type:'TOGGLE_PGM',
channel: ch - 1
});
}
}
} else if (this.checkOscCommand(message.address, this.mixerProtocol.fromMixer
.CHANNEL_VU)){
if (this.store.settings[0].mixerProtocol.includes('behringer')) {
behringerMeter(message.args);
} else if (this.store.settings[0].mixerProtocol.includes('midas')) {
midasMeter(message.args);
} else {
let ch = message.address.split("/")[this.cmdChannelIndex];
window.storeRedux.dispatch({
type:'SET_VU_LEVEL',
channel: ch - 1,
level: message.args[0]
});
}
} else if (this.checkOscCommand(message.address, this.mixerProtocol.fromMixer
.CHANNEL_NAME)) {
let ch = message.address.split("/")[this.cmdChannelIndex];
window.storeRedux.dispatch({
type:'SET_CHANNEL_LABEL',
channel: ch - 1,
label: message.args[0]
});
console.log("OSC message: ", message.address);
} else if ( this.checkOscCommand(message.address, this.mixerProtocol.fromMixer
.GRP_OUT_GAIN)){
let ch = message.address.split("/")[this.cmdChannelIndex];
if (!this.store.channels[0].grpFader[ch - 1].fadeActive
&& message.args[0] > this.mixerProtocol.fader.min)
{
window.storeRedux.dispatch({
type:'SET_GRP_FADER_LEVEL',
channel: ch - 1,
level: message.args[0]
});
if (!this.store.channels[0].grpFader[ch - 1].pgmOn) {
window.storeRedux.dispatch({
type:'TOGGLE_GRP_PGM',
channel: ch - 1
});
}
}
} else if (this.checkOscCommand(message.address, this.mixerProtocol.fromMixer
.GRP_VU)){
if (this.store.settings[0].mixerProtocol.includes('behringer')) {
behringerGrpMeter(message.args);
} else if (this.store.settings[0].mixerProtocol.includes('midas')) {
midasGrpMeter(message.args);
} else {
let ch = message.address.split("/")[this.cmdChannelIndex];
window.storeRedux.dispatch({
type:'SET_GRP_VU_LEVEL',
channel: ch - 1,
level: message.args[0]
});
}
} else if (this.checkOscCommand(message.address, this.mixerProtocol.fromMixer
.GRP_NAME)) {
let ch = message.address.split("/")[this.cmdChannelIndex];
window.storeRedux.dispatch({
type:'SET_GRP_LABEL',
channel: ch - 1,
label: message.args[0]
});
console.log("OSC message: ", message.address);
}
})
.on('error', (error: any) => {
console.log("Error : ", error);
console.log("Lost OSC connection");
});

this.oscConnection.open();
console.log(`OSC listening on port ` + this.store.settings[0].oscPort );

//Ping OSC mixer if mixerProtocol needs it.
if (this.mixerProtocol.pingTime > 0) {
let oscTimer = setInterval(
() => {
this.pingMixerCommand();
},
this.mixerProtocol.pingTime
);
}
}

pingMixerCommand() {
//Ping OSC mixer if mixerProtocol needs it.
this.mixerProtocol.pingCommand.map((command) => {
this.sendOutMessage(
command.oscMessage,
0,
command.value,
command.type
);
});
}

checkOscCommand(message: string, command: string) {
if (message === command) return true;

let cmdArray = command.split("{channel}");
if (message.substr(0, cmdArray[0].length) === cmdArray[0])
{
if (
message.substr(-cmdArray[1].length) === cmdArray[1] &&
message.length >= command.replace("{channel}", "").length
) {
return true;
} else if (
cmdArray[1] === "" &&
message.length >= command.replace("{channel}", "").length
) {
return true;
}
}
return false;
}

sendOutMessage(oscMessage: string, channel: number, value: string, type: string) {
let channelString = this.mixerProtocol.leadingZeros ? ("0"+channel).slice(-2) : channel.toString();
let message = oscMessage.replace(
"{channel}",
channelString
);
if (message != 'none') {
this.oscConnection.send({
address: message,
args: [
{
type: type,
value: value
}
]
});
}
}


sendOutGrpMessage(oscMessage: string, channel: number, value: string, type: string) {
let message = oscMessage.replace(
"{channel}",
String(channel)
);
if (message != 'none') {
this.oscConnection.send({
address: message,
args: [
{
type: type,
value: value
}
]
});
}
}

sendOutRequest(oscMessage: string, channel: number) {
let channelString = this.mixerProtocol.leadingZeros ? ("0"+channel).slice(-2) : channel.toString();
let message = oscMessage.replace(
"{channel}",
channelString
);
if (message != 'none') {
this.oscConnection.send({
address: message
});
}
}

updateOutLevel(channelIndex: number) {
this.sendOutMessage(
this.mixerProtocol.toMixer.CHANNEL_OUT_GAIN,
channelIndex+1,
this.store.channels[0].channel[channelIndex].outputLevel,
"f"
);
this.sendOutMessage(
this.mixerProtocol.toMixer.CHANNEL_FADER_LEVEL,
channelIndex+1,
this.store.channels[0].channel[channelIndex].faderLevel,
"f"
);
}

updateFadeIOLevel(channelIndex: number, outputLevel: number) {
this.sendOutMessage(
this.mixerProtocol.toMixer.CHANNEL_OUT_GAIN,
channelIndex+1,
String(outputLevel),
"f"
);
}


updateGrpOutLevel(channelIndex: number) {
this.sendOutGrpMessage(
this.mixerProtocol.toMixer.GRP_OUT_GAIN,
channelIndex+1,
this.store.channels[0].grpFader[channelIndex].outputLevel,
"f"
);
}

updateGrpFadeIOLevel(channelIndex: number, outputLevel: number) {
this.sendOutGrpMessage(
this.mixerProtocol.toMixer.GRP_OUT_GAIN,
channelIndex+1,
String(outputLevel),
"f"
);
}

}

0 comments on commit 6197f2b

Please sign in to comment.