86 lines
1.6 KiB
JavaScript
Executable File
86 lines
1.6 KiB
JavaScript
Executable File
import React from 'react';
|
|
import { connect } from 'react-redux';
|
|
import { bindActionCreators } from 'redux';
|
|
import * as coreActions from '../services/core/actions';
|
|
import { SnapStream } from './SnapStream.tsx';
|
|
|
|
class Stream extends React.Component {
|
|
constructor(props) {
|
|
super(props);
|
|
|
|
if (props.enabled && props.streaming_enabled) {
|
|
this.start();
|
|
}
|
|
}
|
|
|
|
start = () => {
|
|
const {
|
|
host,
|
|
port,
|
|
ssl,
|
|
} = this.props;
|
|
|
|
if (this.snapstream) {
|
|
this.snapstream.play();
|
|
} else {
|
|
const baseUrl = `${ssl ? 'wss' : 'ws'}://${host}:${port}`;
|
|
this.snapstream = new SnapStream(baseUrl);
|
|
}
|
|
}
|
|
|
|
stop = () => {
|
|
if (this.snapstream) {
|
|
this.snapstream.stop();
|
|
this.snapstream = null;
|
|
}
|
|
}
|
|
|
|
componentDidUpdate = ({
|
|
streaming_enabled: prevStreamingEnabled,
|
|
}) => {
|
|
const {
|
|
enabled,
|
|
streaming_enabled,
|
|
} = this.props;
|
|
|
|
if (!prevStreamingEnabled && enabled && streaming_enabled) {
|
|
this.start();
|
|
}
|
|
if (!enabled || !streaming_enabled) {
|
|
this.stop();
|
|
}
|
|
}
|
|
|
|
render = () => null;
|
|
}
|
|
|
|
const mapStateToProps = (state) => {
|
|
const {
|
|
snapcast: {
|
|
enabled,
|
|
streaming_enabled,
|
|
host,
|
|
port,
|
|
ssl,
|
|
},
|
|
pusher: {
|
|
username,
|
|
},
|
|
} = state;
|
|
|
|
return {
|
|
enabled,
|
|
streaming_enabled,
|
|
host,
|
|
port,
|
|
ssl,
|
|
username,
|
|
};
|
|
};
|
|
|
|
const mapDispatchToProps = (dispatch) => ({
|
|
coreActions: bindActionCreators(coreActions, dispatch),
|
|
});
|
|
|
|
export default connect(mapStateToProps, mapDispatchToProps)(Stream);
|