import React, { Component } from 'react'; import { View, Text, StyleSheet, TouchableOpacity, ScrollView } from 'react-native'; import PropTypes from 'prop-types'; import Icon from 'react-native-vector-icons/MaterialIcons'; import { responsive } from 'react-native-responsive-ui'; import equal from 'deep-equal'; import database from '../../lib/realm'; import RocketChat from '../../lib/rocketchat'; import log from '../../utils/log'; import I18n from '../../i18n'; const styles = StyleSheet.create({ container: { position: 'absolute', top: 0, width: '100%', maxHeight: 246 }, item: { backgroundColor: '#F1F2F4', height: 54, borderBottomWidth: StyleSheet.hairlineWidth, borderColor: '#CACED1', justifyContent: 'center', paddingHorizontal: 20 }, row: { flexDirection: 'row', alignItems: 'center' }, descriptionContainer: { flexDirection: 'column', flex: 1, marginLeft: 10 }, descriptionText: { fontSize: 16, lineHeight: 20, color: '#54585E' }, progress: { position: 'absolute', bottom: 0, backgroundColor: '#1D74F5', height: 3 }, tryAgainButtonText: { color: '#1D74F5', fontSize: 16, fontWeight: '500', lineHeight: 20 } }); @responsive export default class UploadProgress extends Component { static propTypes = { window: PropTypes.object, rid: PropTypes.string } constructor(props) { super(props); this.state = { uploads: [] }; const { rid } = this.props; this.uploads = database.objects('uploads').filtered('rid = $0', rid); this.uploads.addListener(this.updateUploads); } componentDidMount() { this.uploads.forEach((u) => { if (!RocketChat.isUploadActive(u.path)) { database.write(() => { const [upload] = database.objects('uploads').filtered('path = $0', u.path); if (upload) { upload.error = true; } }); } }); } shouldComponentUpdate(nextProps, nextState) { const { uploads } = this.state; const { window } = this.props; if (nextProps.window.width !== window.width) { return true; } if (!equal(nextState.uploads, uploads)) { return true; } return false; } componentWillUnmount() { this.uploads.removeAllListeners(); } deleteUpload = (item) => { database.write(() => database.delete(item)); } cancelUpload = async(item) => { try { await RocketChat.cancelUpload(item.path); } catch (e) { log('UploadProgess.cancelUpload', e); } } tryAgain = async(item) => { const { rid } = this.props; try { database.write(() => { item.error = false; }); await RocketChat.sendFileMessage(rid, item); } catch (e) { log('UploadProgess.tryAgain', e); } } updateUploads = () => { const uploads = this.uploads.map(item => JSON.parse(JSON.stringify(item))); this.setState({ uploads }); } renderItemContent = (item) => { const { window } = this.props; if (!item.error) { return ( [ {I18n.t('Uploading')} {item.name} this.cancelUpload(item)} /> , ] ); } return ( {I18n.t('Error_uploading')} {item.name} this.tryAgain(item)}> {I18n.t('Try_again')} this.deleteUpload(item)} /> ); } renderItem = (item, index) => ( {this.renderItemContent(item)} ); render() { const { uploads } = this.state; return ( {uploads.map((item, i) => this.renderItem(item, i))} ); } }