add server saga

This commit is contained in:
Guilherme Gazzo 2017-08-30 00:03:35 -03:00
parent 93f839bfc3
commit ff75ed6578
25 changed files with 266 additions and 245 deletions

View File

@ -12,11 +12,11 @@ function createRequestTypes(base, types = defaultTypes) {
// Login events // Login events
export const LOGIN = createRequestTypes('LOGIN', [...defaultTypes, 'SET_TOKEN', 'SUBMIT']); export const LOGIN = createRequestTypes('LOGIN', [...defaultTypes, 'SET_TOKEN', 'SUBMIT']);
export const ROOMS = createRequestTypes('ROOMS'); export const ROOMS = createRequestTypes('ROOMS');
export const APP = createRequestTypes('APP', ['READY']); export const APP = createRequestTypes('APP', ['READY', 'INIT']);
export const MESSAGES = createRequestTypes('MESSAGES'); export const MESSAGES = createRequestTypes('MESSAGES');
export const CREATE_CHANNEL = createRequestTypes('CREATE_CHANNEL'); export const CREATE_CHANNEL = createRequestTypes('CREATE_CHANNEL', [...defaultTypes, 'REQUEST_USERS', 'SUCCESS_USERS', 'FAILURE_USERS', 'SET_USERS']);
export const NAVIGATION = createRequestTypes('NAVIGATION', ['SET']); export const NAVIGATION = createRequestTypes('NAVIGATION', ['SET']);
export const SERVER = createRequestTypes('SERVER', ['SELECT', 'CHANGED']); export const SERVER = createRequestTypes('SERVER', [...defaultTypes, 'SELECT', 'CHANGED', 'ADD']);
export const METEOR = createRequestTypes('METEOR_CONNECT', [...defaultTypes, 'DISCONNECT']); export const METEOR = createRequestTypes('METEOR_CONNECT', [...defaultTypes, 'DISCONNECT']);
export const LOGOUT = 'LOGOUT'; // logout is always success export const LOGOUT = 'LOGOUT'; // logout is always success

View File

@ -20,3 +20,32 @@ export function createChannelFailure(err) {
err err
}; };
} }
export function createChannelRequestUsers(data) {
return {
type: types.CREATE_CHANNEL.REQUEST_USERS,
data
};
}
export function createChannelSetUsers(data) {
return {
type: types.CREATE_CHANNEL.SET_USERS,
data
};
}
export function createChannelSuccessUsers(data) {
return {
type: types.CREATE_CHANNEL.SUCCESS_USERS,
data
};
}
export function createChannelFailureUsers(err) {
return {
type: types.CREATE_CHANNEL.FAILURE_USERS,
err
};
}

View File

@ -6,6 +6,12 @@ export function appReady() {
type: APP.READY type: APP.READY
}; };
} }
export function appInit() {
return {
type: APP.INIT
};
}
export function setCurrentServer(server) { export function setCurrentServer(server) {
return { return {
type: types.SET_CURRENT_SERVER, type: types.SET_CURRENT_SERVER,

View File

@ -28,7 +28,7 @@ export function loginFailure(err) {
}; };
} }
export function setToken(user) { export function setToken(user = {}) {
return { return {
type: types.LOGIN.SET_TOKEN, type: types.LOGIN.SET_TOKEN,
token: user.token, token: user.token,

View File

@ -6,6 +6,37 @@ export function setServer(server) {
server server
}; };
} }
export function serverRequest(server) {
console.log(server);
return {
type: SERVER.REQUEST,
server
};
}
export function addServer(server) {
console.log(server);
return {
type: SERVER.ADD,
server
};
}
export function serverSuccess() {
return {
type: SERVER.SUCCESS
};
}
export function serverFailure(err) {
return {
type: SERVER.FAILURE,
err
};
}
export function changedServer(server) { export function changedServer(server) {
return { return {
type: SERVER.CHANGED, type: SERVER.CHANGED,

View File

@ -1,12 +1,10 @@
import React from 'react'; import React from 'react';
import PropTypes from 'prop-types'; import PropTypes from 'prop-types';
import { View, Text, StyleSheet } from 'react-native'; import { View, Text, StyleSheet } from 'react-native';
import { CachedImage } from 'react-native-img-cache';
import { emojify } from 'react-emojione'; import { emojify } from 'react-emojione';
import Markdown from 'react-native-easy-markdown'; import Markdown from 'react-native-easy-markdown';
import moment from 'moment'; import moment from 'moment';
import Avatar from './avatar';
import avatarInitialsAndColor from '../utils/avatarInitialsAndColor';
import Card from './message/card'; import Card from './message/card';
const styles = StyleSheet.create({ const styles = StyleSheet.create({
@ -20,26 +18,6 @@ const styles = StyleSheet.create({
flexDirection: 'row', flexDirection: 'row',
transform: [{ scaleY: -1 }] transform: [{ scaleY: -1 }]
}, },
avatarContainer: {
backgroundColor: '#eee',
width: 40,
height: 40,
marginRight: 10,
borderRadius: 5
},
avatar: {
width: 40,
height: 40,
borderRadius: 5,
position: 'absolute'
},
avatarInitials: {
margin: 2,
textAlign: 'center',
lineHeight: 36,
fontSize: 22,
color: '#ffffff'
},
texts: { texts: {
flex: 1 flex: 1
}, },
@ -87,33 +65,17 @@ export default class Message extends React.PureComponent {
const username = item.alias || item.u.username; const username = item.alias || item.u.username;
let { initials, color } = avatarInitialsAndColor(username);
const avatar = item.avatar || `${ this.props.baseUrl }/avatar/${ item.u.username }`;
if (item.avatar) {
initials = '';
color = 'transparent';
}
let aliasUsername;
if (item.alias) {
aliasUsername = <Text style={styles.alias}>@{item.u.username}</Text>;
}
const time = moment(item.ts).format(this.props.Message_TimeFormat); const time = moment(item.ts).format(this.props.Message_TimeFormat);
return ( return (
<View style={[styles.message, extraStyle]}> <View style={[styles.message, extraStyle]}>
<View style={[styles.avatarContainer, { backgroundColor: color }]}> <Avatar style={{ marginRight: 10 }} text={item.avatar ? '' : username} size={40} baseUrl={this.props.baseUrl} avatar={item.avatar} />
<Text style={styles.avatarInitials}>{initials}</Text>
<CachedImage style={styles.avatar} source={{ uri: avatar }} />
</View>
<View style={[styles.content]}> <View style={[styles.content]}>
<View style={styles.usernameView}> <View style={styles.usernameView}>
<Text onPress={this._onPress} style={styles.username}> <Text onPress={this._onPress} style={styles.username}>
{username} {username}
</Text> </Text>
{aliasUsername}<Text style={styles.time}>{time}</Text> {item.alias && <Text style={styles.alias}>@{item.u.username}</Text>}<Text style={styles.time}>{time}</Text>
</View> </View>
{this.attachments()} {this.attachments()}
<Markdown> <Markdown>

View File

@ -1,9 +1,8 @@
import React from 'react'; import React from 'react';
import { CachedImage } from 'react-native-img-cache';
import MaterialCommunityIcons from 'react-native-vector-icons/MaterialCommunityIcons'; import MaterialCommunityIcons from 'react-native-vector-icons/MaterialCommunityIcons';
import PropTypes from 'prop-types'; import PropTypes from 'prop-types';
import { View, Text, StyleSheet, TouchableOpacity } from 'react-native'; import { View, Text, StyleSheet, TouchableOpacity } from 'react-native';
import Avatar from './avatar';
import avatarInitialsAndColor from '../utils/avatarInitialsAndColor'; import avatarInitialsAndColor from '../utils/avatarInitialsAndColor';
const styles = StyleSheet.create({ const styles = StyleSheet.create({
@ -81,12 +80,8 @@ export default class RoomItem extends React.PureComponent {
} }
if (type === 'd') { if (type === 'd') {
const { initials, color } = avatarInitialsAndColor(name);
return ( return (
<View style={[styles.iconContainer, { backgroundColor: color }]}> <Avatar text={name} baseUrl={baseUrl} size={40} borderRadius={20} />
<Text style={styles.avatarInitials}>{initials}</Text>
<CachedImage style={styles.avatar} source={{ uri: `${ baseUrl }/avatar/${ name }` }} />
</View>
); );
} }

View File

@ -4,49 +4,48 @@ import { StyleSheet, Text, View } from 'react-native';
import { CachedImage } from 'react-native-img-cache'; import { CachedImage } from 'react-native-img-cache';
import avatarInitialsAndColor from '../utils/avatarInitialsAndColor'; import avatarInitialsAndColor from '../utils/avatarInitialsAndColor';
const styles = StyleSheet.create({
iconContainer: {
overflow: 'hidden',
justifyContent: 'center',
alignItems: 'center'
},
avatar: {
position: 'absolute'
},
avatarInitials: {
color: '#ffffff'
} });
const styles = StyleSheet.create({ iconContainer: { class Avatar extends React.PureComponent {
height: 40, render() {
width: 40, const { text = '', size = 25, baseUrl = this.props.baseUrl,
borderRadius: 20, borderRadius = 5, style, avatar } = this.props;
overflow: 'hidden', const { initials, color } = avatarInitialsAndColor(`${ text }`);
justifyContent: 'center', return (
alignItems: 'center' <View style={[styles.iconContainer, {
}, backgroundColor: color,
icon: { width: size,
fontSize: 20, height: size,
color: '#fff' borderRadius
}, }, style]}
avatar: { >
width: 40, <Text style={[styles.avatarInitials, { fontSize: size / 2 }]}>{initials}</Text>
height: 40, { (avatar || baseUrl) && <CachedImage
position: 'absolute' style={[styles.avatar, { width: size,
}, height: size }]}
avatarInitials: { source={{ uri: avatar || `${ baseUrl }/avatar/${ text }` }}
fontSize: 20, />}
color: '#ffffff' </View>);
} }); }
}
Avatar.propTypes = {
const avatar = ({ text = '', width = 25, height = 25, fontSize = 12, baseUrl, style: PropTypes.object,
borderRadius = 2, style }) => {
const { initials, color } = avatarInitialsAndColor(`${ text }`);
return (
<View style={[styles.iconContainer, { backgroundColor: color }, { width,
height,
borderRadius }, style]}
>
<Text style={[styles.avatarInitials, { fontSize }]}>{initials}</Text>
{ baseUrl ? <CachedImage style={styles.avatar} source={{ uri: `${ baseUrl }/avatar/${ name }` }} /> : null}
</View>);
};
avatar.propTypes = {
baseUrl: PropTypes.string, baseUrl: PropTypes.string,
text: PropTypes.string.isRequired, text: PropTypes.string.isRequired,
width: PropTypes.number, avatar: PropTypes.string,
fontSize: PropTypes.number, size: PropTypes.number,
height: PropTypes.number,
borderRadius: PropTypes.number borderRadius: PropTypes.number
}; };
export default avatar; export default Avatar;

View File

@ -74,8 +74,8 @@ const styles = StyleSheet.create({
const renderTag = (item, index) => (<Item key={item} label={item} onPress={() => this.props.onPress(item, index)} />); const renderTag = (item, index) => (<Item key={item} label={item} onPress={() => this.props.onPress(item, index)} />);
const renderItemResult = ({ item = '' }) => ( const renderItemResult = ({ item = '', onPress }) => (
<View style={styles.result_item}> <View style={styles.result_item} onPress={onPress}>
<Avatar text={item} width={40} height={40} fontSize={20} style={{ marginRight: 5 }} /> <Avatar text={item} width={40} height={40} fontSize={20} style={{ marginRight: 5 }} />
<Text>@{item}</Text> <Text>@{item}</Text>
</View>); </View>);
@ -102,11 +102,11 @@ export default class tags extends React.PureComponent {
onChangeText={this.props.onChangeText} onChangeText={this.props.onChangeText}
/> />
</View> </View>
{this.props.result ? <FlatList {this.props.result && this.props.result.length ? <FlatList
keyExtractor={item => item} keyExtractor={item => item}
style={styles.result} style={styles.result}
data={this.props.result || []} data={this.props.result || []}
renderItem={this.props.renderItemResult || renderItemResult} renderItem={e => (this.props.renderItemResult || renderItemResult)(e, this.props.onSelect)}
/> : null} /> : null}
</View>); </View>);
} }

View File

@ -1,11 +1,16 @@
import PropTypes from 'prop-types'; import PropTypes from 'prop-types';
import React from 'react'; import React from 'react';
import { connect } from 'react-redux'; import { connect } from 'react-redux';
import { Text } from 'react-native'; import * as Animatable from 'react-native-animatable';
import setNavigator from './actions/navigator'; import setNavigator from './actions/navigator';
import { appInit } from './actions';
import LoginView from './views/login'; import LoginView from './views/login';
import ListServerView from './views/serverList'; import ListServerView from './views/serverList';
import { Keyboard, Text, TextInput, View, Image, TouchableOpacity } from 'react-native';
import styles from './views/Styles';
import store from './lib/createStore'; import store from './lib/createStore';
// //
@ -22,16 +27,16 @@ export const authenticated = WrappedComponent => class _p extends React.PureComp
constructor() { constructor() {
super(); super();
this.login = store.getState().login; this.login = store.getState().login;
console.log('this.login.token', this.login.token);
if (!this.login.token || this.login.failure) { if (!this.login.token || this.login.failure) {
return store.getState().navigator.resetTo({ return store.getState().navigator.resetTo({
screen: 'Login' screen: 'Login',
animationType: 'none'
}); });
} }
} }
render() { render() {
// Wraps the input component in a container, without mutating it. Good! // Wraps the input component in a container, without mutating it. Good!
return <WrappedComponent {...this.props} />; return ((this.login.isAuthenticated || this.login.user) && <WrappedComponent {...this.props} />);
} }
}; };
// //
@ -43,7 +48,7 @@ export class PublicScreen extends React.PureComponent {
// } // }
// } // }
render() { render() {
return !this.login.isAuthenticated || !this.login.user ? null : (<ListServerView {...this.props} />); return ((this.login.isAuthenticated || this.login.user) && <ListServerView {...this.props} />);
} }
} }
@ -66,21 +71,29 @@ export class PrivateScreen extends React.PureComponent {
// logged: state.login.isAuthenticated // logged: state.login.isAuthenticated
}), dispatch => ({ }), dispatch => ({
// navigate: routeName => dispatch(NavigationActions.navigate({ routeName })), // navigate: routeName => dispatch(NavigationActions.navigate({ routeName })),
setNavigator: navigator => dispatch(setNavigator(navigator)) setNavigator: navigator => dispatch(setNavigator(navigator)),
appInit: () => dispatch(appInit())
})) }))
export const HomeScreen = class extends React.PureComponent { export const HomeScreen = class extends React.PureComponent {
static propTypes = { static propTypes = {
setNavigator: PropTypes.func.isRequired, setNavigator: PropTypes.func.isRequired,
navigator: PropTypes.object.isRequired navigator: PropTypes.object.isRequired
} }
static navigatorStyle = {
navBarHidden: true
};
componentWillMount() { componentWillMount() {
this.props.setNavigator(this.props.navigator); this.props.setNavigator(this.props.navigator);
this.props.navigator.resetTo({ this.props.appInit();
screen: 'public' //
}); // this.props.navigator.setDrawerEnabled({
// side: 'left', // the side of the drawer since you can have two, 'left' / 'right'
// enabled: false // should the drawer be enabled or disabled (locked closed)
// });
} }
render() { render() {
return (<Text>oieee</Text>); return (<View style={styles.logoContainer}><Animatable.Text animation='pulse' easing='ease-out' iterationCount='infinite' style={{ textAlign: 'center' }}>
<Image style={styles.logo} source={require('./images/logo.png')} />
</Animatable.Text></View>);
} }
}; };

View File

@ -23,12 +23,8 @@ const call = (method, ...params) => new Promise((resolve, reject) => {
const RocketChat = { const RocketChat = {
createChannel({ name, users, type }) { createChannel({ name, users, type }) {
console.log('FISTALEU', { name, users, type });
return new Promise((resolve, reject) => { return new Promise((resolve, reject) => {
Meteor.call(type ? 'createChannel' : 'createPrivateGroup', name, users, type, (err, res) => { Meteor.call(type ? 'createChannel' : 'createPrivateGroup', name, users, type, (err, res) => (err ? reject(err) : resolve(res)));
console.log(err, res);
return (err ? reject(err) : resolve(res));
});
}); });
}, },
@ -40,7 +36,15 @@ const RocketChat = {
console.warn(`AsyncStorage error: ${ error.message }`); console.warn(`AsyncStorage error: ${ error.message }`);
} }
}, },
async testServer(url) {
if (/^(https?:\/\/)?(((\w|[0-9])+(\.(\w|[0-9-_])+)+)|localhost)(:\d+)?$/.test(url)) {
const response = await fetch(url, { method: 'HEAD' });
if (response.status === 200 && response.headers.get('x-instance-id') != null && response.headers.get('x-instance-id').length) {
return url;
}
}
throw new Error({ error: 'invalid server' });
},
connect(_url) { connect(_url) {
return new Promise((resolve) => { return new Promise((resolve) => {
const url = `${ _url }/websocket`; const url = `${ _url }/websocket`;
@ -69,7 +73,7 @@ const RocketChat = {
const setting = { const setting = {
_id: item._id _id: item._id
}; };
setting._server = { id: reduxStore.getState().server }; setting._server = { id: reduxStore.getState().server.server };
if (settingsType[item.type]) { if (settingsType[item.type]) {
setting[settingsType[item.type]] = item.value; setting[settingsType[item.type]] = item.value;
realm.create('settings', setting, true); realm.create('settings', setting, true);
@ -87,7 +91,7 @@ const RocketChat = {
realm.write(() => { realm.write(() => {
const message = ddbMessage.fields.args[0]; const message = ddbMessage.fields.args[0];
message.temp = false; message.temp = false;
message._server = { id: reduxStore.getState().server }; message._server = { id: reduxStore.getState().server.server };
// write('messages', message); // write('messages', message);
realm.create('messages', message, true); realm.create('messages', message, true);
}); });
@ -97,7 +101,7 @@ const RocketChat = {
// console.log(ddbMessage); // console.log(ddbMessage);
realm.write(() => { realm.write(() => {
const data = ddbMessage.fields.args[1]; const data = ddbMessage.fields.args[1];
data._server = { id: reduxStore.getState().server }; data._server = { id: reduxStore.getState().server.server };
realm.create('subscriptions', data, true); realm.create('subscriptions', data, true);
}); });
} }
@ -108,13 +112,11 @@ const RocketChat = {
}, },
login(params, callback) { login(params, callback) {
console.log('login(params, callback)');
return new Promise((resolve, reject) => { return new Promise((resolve, reject) => {
Meteor._startLoggingIn(); Meteor._startLoggingIn();
return Meteor.call('login', params, (err, result) => { return Meteor.call('login', params, (err, result) => {
Meteor._endLoggingIn(); Meteor._endLoggingIn();
Meteor._handleLoginCallback(err, result); Meteor._handleLoginCallback(err, result);
console.log('login(params, callback)asdas', err, result);
if (err) { if (err) {
reject(err); reject(err);
} else { } else {
@ -183,7 +185,7 @@ const RocketChat = {
// if (typeof item.value === 'string') { // if (typeof item.value === 'string') {
// subscription.value = item.value; // subscription.value = item.value;
// } // }
subscription._server = { id: reduxStore.getState().server }; subscription._server = { id: reduxStore.getState().server.server };
// write('subscriptions', subscription); // write('subscriptions', subscription);
realm.create('subscriptions', subscription, true); realm.create('subscriptions', subscription, true);
}); });
@ -207,7 +209,7 @@ const RocketChat = {
realm.write(() => { realm.write(() => {
data.messages.forEach((message) => { data.messages.forEach((message) => {
message.temp = false; message.temp = false;
message._server = { id: reduxStore.getState().server }; message._server = { id: reduxStore.getState().server.server };
// write('messages', message); // write('messages', message);
realm.create('messages', message, true); realm.create('messages', message, true);
}); });
@ -237,7 +239,7 @@ const RocketChat = {
ts: new Date(), ts: new Date(),
_updatedAt: new Date(), _updatedAt: new Date(),
temp: true, temp: true,
_server: { id: reduxStore.getState().server }, _server: { id: reduxStore.getState().server.server },
u: { u: {
_id: reduxStore.getState().login.user.id || '1', _id: reduxStore.getState().login.user.id || '1',
username: reduxStore.getState().login.user.id username: reduxStore.getState().login.user.id
@ -381,7 +383,6 @@ const RocketChat = {
return subscription; return subscription;
}); });
// Meteor.subscribe('stream-notify-user', `${ Meteor.userId() }/rooms-changed`, false); // Meteor.subscribe('stream-notify-user', `${ Meteor.userId() }/rooms-changed`, false);
console.log('getRooms resolved', reduxStore.getState().server, data);
realm.write(() => { realm.write(() => {
data.forEach((subscription) => { data.forEach((subscription) => {
// const subscription = { // const subscription = {
@ -390,7 +391,7 @@ const RocketChat = {
// if (typeof item.value === 'string') { // if (typeof item.value === 'string') {
// subscription.value = item.value; // subscription.value = item.value;
// } // }
subscription._server = { id: reduxStore.getState().server }; subscription._server = { id: reduxStore.getState().server.server };
// write('subscriptions', subscription); // write('subscriptions', subscription);
realm.create('subscriptions', subscription, true); realm.create('subscriptions', subscription, true);
}); });

View File

@ -1,9 +1,36 @@
import { SERVER } from '../actions/actionsTypes'; import { SERVER } from '../actions/actionsTypes';
export default function server(state = '', action) { const initialState = {
connecting: false,
connected: false,
errorMessage: '',
failure: false,
server: ''
};
export default function server(state = initialState, action) {
switch (action.type) { switch (action.type) {
case SERVER.REQUEST:
return { ...state,
connecting: true,
failure: false
};
case SERVER.SUCCESS:
return { ...state,
connecting: false,
connected: true,
failure: false
};
case SERVER.FAILURE:
return { ...state,
connecting: false,
connected: false,
failure: true,
errorMessage: action.err
};
case SERVER.SELECT: case SERVER.SELECT:
return action.server; return { ...state, server: action.server };
default: default:
return state; return state;
} }

View File

@ -1,10 +1,10 @@
import { take, put, call, fork, takeLatest, select } from 'redux-saga/effects'; import { put, call, takeLatest, select } from 'redux-saga/effects';
import { METEOR } from '../actions/actionsTypes'; import { METEOR } from '../actions/actionsTypes';
import RocketChat from '../lib/rocketchat'; import RocketChat from '../lib/rocketchat';
import { connectSuccess, connectFailure } from '../actions/connect'; import { connectSuccess, connectFailure } from '../actions/connect';
const getServer = ({ server }) => server; const getServer = ({ server }) => server.server;
const connect = url => RocketChat.connect(url); const connect = url => RocketChat.connect(url);
@ -17,14 +17,11 @@ const test = function* test() {
yield put(connectFailure(err.status)); yield put(connectFailure(err.status));
} }
}; };
const watchConnect = function* watchConnect() { // const watchConnect = function* watchConnect() {
yield takeLatest(METEOR.REQUEST, test); // };
while (true) {
yield take(METEOR.DISCONNECT);
}
};
const root = function* root() { const root = function* root() {
yield fork(watchConnect); yield takeLatest(METEOR.REQUEST, test);
// yield fork(watchConnect);
// yield fork(auto); // yield fork(auto);
}; };
export default root; export default root;

View File

@ -1,13 +1,22 @@
import { AsyncStorage } from 'react-native'; import { AsyncStorage } from 'react-native';
import { call, put } from 'redux-saga/effects'; import { call, put, select, take } from 'redux-saga/effects';
import * as actions from '../actions'; import * as actions from '../actions';
import { setServer } from '../actions/server'; import { setServer } from '../actions/server';
import { APP } from '../actions/actionsTypes';
const restore = function* restore() { const restore = function* restore() {
try { try {
yield take(APP.INIT);
const { navigator } = yield select(state => state);
const currentServer = yield call([AsyncStorage, 'getItem'], 'currentServer'); const currentServer = yield call([AsyncStorage, 'getItem'], 'currentServer');
yield put(actions.appReady({})); yield put(actions.appReady({}));
if (currentServer) { yield put(setServer(currentServer)); } if (currentServer) {
yield put(setServer(currentServer));
} else {
navigator.resetTo({
screen: 'ListServer'
});
}
} catch (e) { } catch (e) {
console.log(e); console.log(e);
} }

View File

@ -1,12 +1,12 @@
import { AsyncStorage } from 'react-native'; import { AsyncStorage } from 'react-native';
import { take, put, call, takeEvery, fork, select, all, race } from 'redux-saga/effects'; import { take, put, call, takeEvery, fork, select, all, race } from 'redux-saga/effects';
import * as types from '../actions/actionsTypes'; import * as types from '../actions/actionsTypes';
import { loginRequest, loginSuccess, loginFailure, setToken } from '../actions/login'; import { loginRequest, loginSuccess, loginFailure, setToken, logout } from '../actions/login';
import RocketChat from '../lib/rocketchat'; import RocketChat from '../lib/rocketchat';
const TOKEN_KEY = 'reactnativemeteor_usertoken'; const TOKEN_KEY = 'reactnativemeteor_usertoken';
const getUser = state => state.login; const getUser = state => state.login;
const getServer = state => state.server; const getServer = state => state.server.server;
const loginCall = args => (args.resume ? RocketChat.login(args) : RocketChat.loginWithPassword(args)); const loginCall = args => (args.resume ? RocketChat.login(args) : RocketChat.loginWithPassword(args));
const getToken = function* getToken() { const getToken = function* getToken() {
@ -20,6 +20,8 @@ const getToken = function* getToken() {
} catch (e) { } catch (e) {
console.log('getTokenerr', e); console.log('getTokenerr', e);
} }
} else {
yield put(setToken());
} }
}; };
@ -27,10 +29,9 @@ const handleLoginWhenServerChanges = function* handleLoginWhenServerChanges() {
// do { // do {
try { try {
yield take(types.METEOR.SUCCESS); yield take(types.METEOR.SUCCESS);
yield call(getToken);
const { navigator } = yield select(state => state); const { navigator } = yield select(state => state);
navigator.resetTo({
screen: 'Rooms'
});
const user = yield select(getUser); const user = yield select(getUser);
if (user.token) { if (user.token) {
yield put(loginRequest({ resume: user.token })); yield put(loginRequest({ resume: user.token }));
@ -47,6 +48,9 @@ const handleLoginWhenServerChanges = function* handleLoginWhenServerChanges() {
// }); // });
// } // }
} }
navigator.resetTo({
screen: 'Rooms'
});
} catch (e) { } catch (e) {
console.log(e); console.log(e);
} }
@ -66,8 +70,11 @@ const handleLoginRequest = function* handleLoginRequest() {
const response = yield call(loginCall, credentials); const response = yield call(loginCall, credentials);
yield put(loginSuccess(response)); yield put(loginSuccess(response));
} catch (err) { } catch (err) {
// console.log('login failed'); if (err.error === 403) {
yield put(loginFailure(err)); yield put(logout());
} else {
yield put(loginFailure(err));
}
} }
} }
}; };
@ -93,7 +100,6 @@ const handleLoginSubmit = function* handleLoginSubmit() {
}; };
const root = function* root() { const root = function* root() {
yield takeEvery(types.SERVER.CHANGED, getToken);
yield takeEvery(types.SERVER.CHANGED, handleLoginWhenServerChanges); yield takeEvery(types.SERVER.CHANGED, handleLoginWhenServerChanges);
yield fork(handleLoginRequest); yield fork(handleLoginRequest);
yield takeEvery(types.LOGIN.SUCCESS, saveToken); yield takeEvery(types.LOGIN.SUCCESS, saveToken);

View File

@ -7,7 +7,6 @@ import { changedServer } from '../actions/server';
const selectServer = function* selectServer({ server }) { const selectServer = function* selectServer({ server }) {
yield put(disconnect()); yield put(disconnect());
yield put(changedServer(server)); yield put(changedServer(server));
yield console.log('SERVER->', server);
yield call([AsyncStorage, 'setItem'], 'currentServer', server); yield call([AsyncStorage, 'setItem'], 'currentServer', server);
yield put(connectRequest(server)); yield put(connectRequest(server));
}; };

View File

@ -1,6 +1,12 @@
import { AVATAR_COLORS } from '../constants/colors'; import { AVATAR_COLORS } from '../constants/colors';
export default function(username = '') { export default function(username = '') {
if (username === '') {
return {
initials: '',
colors: 'transparent'
};
}
const position = username.length % AVATAR_COLORS.length; const position = username.length % AVATAR_COLORS.length;
const color = AVATAR_COLORS[position]; const color = AVATAR_COLORS[position];

View File

@ -119,7 +119,7 @@ class LoginView extends React.Component {
function mapStateToProps(state) { function mapStateToProps(state) {
// console.log(Object.keys(state)); // console.log(Object.keys(state));
return { return {
server: state.server, server: state.server.server,
Accounts_EmailOrUsernamePlaceholder: state.settings.Accounts_EmailOrUsernamePlaceholder, Accounts_EmailOrUsernamePlaceholder: state.settings.Accounts_EmailOrUsernamePlaceholder,
Accounts_PasswordPlaceholder: state.settings.Accounts_PasswordPlaceholder, Accounts_PasswordPlaceholder: state.settings.Accounts_PasswordPlaceholder,
login: state.login login: state.login

View File

@ -46,7 +46,7 @@ const styles = StyleSheet.create({
@connect(state => ({ @connect(state => ({
server: state.server, server: state.server.server,
Site_Url: state.settings.Site_Url, Site_Url: state.settings.Site_Url,
Message_TimeFormat: state.settings.Message_TimeFormat, Message_TimeFormat: state.settings.Message_TimeFormat,
loading: state.messages.isFetching loading: state.messages.isFetching

View File

@ -56,10 +56,10 @@ const styles = StyleSheet.create({
const ds = new ListView.DataSource({ rowHasChanged: (r1, r2) => r1 !== r2 }); const ds = new ListView.DataSource({ rowHasChanged: (r1, r2) => r1 !== r2 });
@connect(state => ({ @connect(state => ({
server: state.server, server: state.server.server,
login: state.login, login: state.login,
Site_Url: state.settings.Site_Url, Site_Url: state.settings.Site_Url,
canShowList: state.login.token.length || state.login.user.token canShowList: state.login.token || state.login.user.token
}), dispatch => ({ }), dispatch => ({
login: () => dispatch(actions.login()), login: () => dispatch(actions.login()),
connect: () => dispatch(server.connectRequest()) connect: () => dispatch(server.connectRequest())

View File

@ -65,7 +65,7 @@ const zeroconf = new Zeroconf();
@connect(state => ({ @connect(state => ({
server: state.server server: state.server.server
}), dispatch => ({ }), dispatch => ({
selectServer: server => dispatch(setServer(server)) selectServer: server => dispatch(setServer(server))
})) }))

View File

@ -2,9 +2,8 @@ import React from 'react';
import PropTypes from 'prop-types'; import PropTypes from 'prop-types';
import { Navigation } from 'react-native-navigation'; import { Navigation } from 'react-native-navigation';
import { Text, TextInput, View, StyleSheet } from 'react-native'; import { Text, TextInput, View, StyleSheet } from 'react-native';
import _ from 'underscore'; import { connect } from 'react-redux';
import realm from '../lib/realm'; import { serverRequest, addServer } from '../actions/server';
import KeyboardView from '../components/KeyboardView'; import KeyboardView from '../components/KeyboardView';
const styles = StyleSheet.create({ const styles = StyleSheet.create({
@ -47,10 +46,17 @@ const styles = StyleSheet.create({
flexGrow: 1 flexGrow: 1
} }
}); });
@connect(state => ({
validInstance: !state.server.failure,
validating: state.server.connecting
}), dispatch => ({
validateServer: url => dispatch(serverRequest(url)),
addServer: url => dispatch(addServer(url))
}))
export default class NewServerView extends React.Component { export default class NewServerView extends React.Component {
static propTypes = { static propTypes = {
navigator: PropTypes.object.isRequired navigator: PropTypes.object.isRequired,
validateServer: PropTypes.func.isRequired
} }
static navigationOptions = () => ({ static navigationOptions = () => ({
@ -66,37 +72,11 @@ export default class NewServerView extends React.Component {
}; };
this.submit = () => { this.submit = () => {
let url = this.state.text.trim(); this.props.addServer(this.completeUrl(this.state.text.trim() || this.state.defaultServer));
if (!url) {
url = this.state.defaultServer;
} else {
url = this.completeUrl(this.state.text);
}
this.setState({
editable: false
});
this.inputElement.blur();
this.validateServer(url).then(() => {
realm.write(() => {
realm.create('servers', { id: url, current: false }, true);
});
Navigation.dismissModal({
animationType: 'slide-down'
});
}).catch(() => {
this.setState({
editable: true
});
this.inputElement.focus();
});
}; };
} }
componentDidMount() { componentDidMount() {
this._mounted = true;
this.props.navigator.setTitle({ this.props.navigator.setTitle({
title: 'New server' title: 'New server'
}); });
@ -111,11 +91,6 @@ export default class NewServerView extends React.Component {
this.props.navigator.setOnNavigatorEvent(this.onNavigatorEvent.bind(this)); this.props.navigator.setOnNavigatorEvent(this.onNavigatorEvent.bind(this));
} }
componentWillUnmount() {
this._mounted = false;
}
onNavigatorEvent = (event) => { onNavigatorEvent = (event) => {
if (event.type === 'NavBarButtonPress') { if (event.type === 'NavBarButtonPress') {
if (event.id === 'close') { if (event.id === 'close') {
@ -128,62 +103,8 @@ export default class NewServerView extends React.Component {
onChangeText = (text) => { onChangeText = (text) => {
this.setState({ text }); this.setState({ text });
this.props.validateServer(this.completeUrl(text));
this.validateServerDebounced(text);
} }
validateServer = url => new Promise((resolve, reject) => {
url = this.completeUrl(url);
this.setState({
validating: false,
url
});
if (/^(https?:\/\/)?(((\w|[0-9])+(\.(\w|[0-9-_])+)+)|localhost)(:\d+)?$/.test(url)) {
this.setState({
validating: true
});
fetch(url, { method: 'HEAD' })
.then((response) => {
if (!this._mounted) {
return;
}
if (response.status === 200 && response.headers.get('x-instance-id') != null && response.headers.get('x-instance-id').length) {
this.setState({
validInstance: true,
validating: false
});
resolve(url);
} else {
this.setState({
validInstance: false,
validating: false
});
reject(url);
}
})
.catch(() => {
if (!this._mounted) {
return;
}
this.setState({
validInstance: false,
validating: false
});
reject(url);
});
} else {
this.setState({
validInstance: undefined
});
reject(url);
}
})
validateServerDebounced = _.debounce(this.validateServer, 1000)
completeUrl = (url) => { completeUrl = (url) => {
url = url.trim(); url = url.trim();
@ -203,7 +124,10 @@ export default class NewServerView extends React.Component {
} }
renderValidation = () => { renderValidation = () => {
if (this.state.validating) { if (!this.state.text.trim()) {
return null;
}
if (this.props.validating) {
return ( return (
<Text style={[styles.validateText, styles.validatingText]}> <Text style={[styles.validateText, styles.validatingText]}>
Validating {this.state.url} ... Validating {this.state.url} ...
@ -211,7 +135,7 @@ export default class NewServerView extends React.Component {
); );
} }
if (this.state.validInstance) { if (this.props.validInstance) {
return ( return (
<Text style={[styles.validateText, styles.validText]}> <Text style={[styles.validateText, styles.validText]}>
{this.state.url} is a valid Rocket.Chat instance {this.state.url} is a valid Rocket.Chat instance
@ -219,7 +143,7 @@ export default class NewServerView extends React.Component {
); );
} }
if (this.state.validInstance === false) { if (!this.state.validInstance) {
return ( return (
<Text style={[styles.validateText, styles.invalidText]}> <Text style={[styles.validateText, styles.invalidText]}>
{this.state.url} is not a valid Rocket.Chat instance {this.state.url} is not a valid Rocket.Chat instance

View File

@ -21,6 +21,7 @@
"react-emojione": "^3.1.10", "react-emojione": "^3.1.10",
"react-native": "0.46.1", "react-native": "0.46.1",
"react-native-action-button": "^2.7.2", "react-native-action-button": "^2.7.2",
"react-native-animatable": "^1.2.3",
"react-native-card-view": "0.0.3", "react-native-card-view": "0.0.3",
"react-native-easy-markdown": "git+https://github.com/lappalj4/react-native-easy-markdown.git", "react-native-easy-markdown": "git+https://github.com/lappalj4/react-native-easy-markdown.git",
"react-native-fetch-blob": "^0.10.8", "react-native-fetch-blob": "^0.10.8",

View File

@ -0,0 +1,13 @@
import React from 'react';
import { ScrollView } from 'react-native';
import Avatar from '../../app/components/avatar';
export default (
<ScrollView>
<Avatar text={'test'} />
<Avatar size={40} text={'aa'} />
<Avatar size={30} text={'bb'} />
<Avatar text={'test'} borderRadius={2} />
</ScrollView>
);

View File

@ -8,6 +8,9 @@ import { storiesOf } from '@storybook/react-native';
import DirectMessage from './Channels/DirectMessage'; import DirectMessage from './Channels/DirectMessage';
import TagInput from './TagInput'; import TagInput from './TagInput';
import Avatar from './Avatar';
storiesOf('Avatar', module).add('avatar', () => Avatar);
storiesOf('Tag Input', module).add('Tag Input', () => TagInput); storiesOf('Tag Input', module).add('Tag Input', () => TagInput);
storiesOf('Channel Cell', module).add('Direct Messages', () => DirectMessage); storiesOf('Channel Cell', module).add('Direct Messages', () => DirectMessage);