lbry-desktop/ui/component/livestreamLink/view.jsx

75 lines
2 KiB
React
Raw Normal View History

// @flow
2021-03-19 21:14:31 +01:00
import { BITWAVE_API } from 'constants/livestream';
import React from 'react';
import Card from 'component/common/card';
import ClaimPreview from 'component/claimPreview';
import { Lbry } from 'lbry-redux';
type Props = {
channelClaim: ChannelClaim,
};
export default function LivestreamLink(props: Props) {
const { channelClaim } = props;
const [livestreamClaim, setLivestreamClaim] = React.useState(false);
const [isLivestreaming, setIsLivestreaming] = React.useState(false);
const livestreamChannelId = channelClaim.claim_id || ''; // TODO: fail in a safer way, probably
React.useEffect(() => {
2021-03-25 21:26:33 +01:00
if (livestreamChannelId) {
Lbry.claim_search({
channel_ids: [livestreamChannelId],
has_no_source: true,
claim_type: ['stream'],
})
2021-03-25 21:26:33 +01:00
.then((res) => {
if (res && res.items && res.items.length > 0) {
const claim = res.items[res.items.length - 1];
setLivestreamClaim(claim);
}
})
.catch(() => {});
}
}, [livestreamChannelId]);
React.useEffect(() => {
2021-03-19 21:14:31 +01:00
function fetchIsStreaming() {
2021-03-22 23:42:51 +01:00
// $FlowFixMe Bitwave's API can handle garbage
2021-03-22 05:16:39 +01:00
fetch(`${BITWAVE_API}/${livestreamChannelId}`)
2021-03-19 21:14:31 +01:00
.then((res) => res.json())
.then((res) => {
if (res && res.success && res.data && res.data.live) {
2021-03-19 21:14:31 +01:00
setIsLivestreaming(true);
} else {
setIsLivestreaming(false);
}
})
.catch((e) => {});
}
2021-03-19 21:14:31 +01:00
let interval;
if (livestreamChannelId) {
if (!interval) fetchIsStreaming();
interval = setInterval(fetchIsStreaming, 10 * 1000);
2021-03-19 21:14:31 +01:00
}
2021-03-19 21:14:31 +01:00
return () => {
if (interval) {
clearInterval(interval);
}
};
}, [livestreamChannelId]);
if (!livestreamClaim || !isLivestreaming) {
return null;
}
return (
<Card
className="livestream__channel-link"
2021-03-23 02:06:51 +01:00
title={__('Live stream in progress')}
actions={<ClaimPreview uri={livestreamClaim.canonical_url} livestream type="inline" />}
/>
);
}