import React, { Component, Fragment } from 'react'; import { connect } from 'react-redux'; import * as requestActions from '../../redux/requestActions'; import { saveAs } from 'file-saver/FileSaver'; import { client } from './FileSharing'; class FileChatEntry extends Component { state = { active : false, numPeers : 0, progress : 0, files : null }; saveFile = (file) => { file.getBlob((err, blob) => { if (err) { return this.props.notify({ text : 'An error occurred while saving a file' }); } saveAs(blob, file.name); }); }; handleTorrent = (torrent) => { // Torrent already done, this can happen if the // same file was sent multiple times. if (torrent.progress === 1) { this.setState({ files : torrent.files, numPeers : torrent.numPeers, progress : 1, active : false }); return; } const onProgress = () => { this.setState({ numPeers : torrent.numPeers, progress : torrent.progress }); }; onProgress(); setInterval(onProgress, 500); torrent.on('done', () => { onProgress(); clearInterval(onProgress); this.setState({ files : torrent.files, active : false }); }); }; download = () => { this.setState({ active : true }); const magnet = this.props.message.file.magnet; const existingTorrent = client.get(magnet); if (existingTorrent) { // Never add duplicate torrents, use the existing one instead. return this.handleTorrent(existingTorrent); } client.add(magnet, this.handleTorrent); } render() { return (
{!this.state.active && !this.state.files && (

A new file was shared.

)} {this.state.active && this.state.numPeers === 0 && (
Locating peers
)} {this.state.active && this.state.numPeers > 0 && ( )} {this.state.files && (
{this.state.files.map((file, i) => (
))}
)}
); } } const mapDispatchToProps = { notify : requestActions.notify }; export default connect( undefined, mapDispatchToProps )(FileChatEntry);