119 lines
2.4 KiB
JavaScript
119 lines
2.4 KiB
JavaScript
import Meteor from 'react-native-meteor';
|
|
import Random from 'react-native-meteor/lib/Random';
|
|
import realm from './realm';
|
|
|
|
export { Accounts } from 'react-native-meteor';
|
|
|
|
export function connect(cb) {
|
|
const currentServer = realm.objects('servers').filtered('current = true')[0];
|
|
const url = `${ currentServer.id }/websocket`;
|
|
|
|
Meteor.connect(url);
|
|
|
|
Meteor.ddp.on('connected', () => {
|
|
console.log('connected');
|
|
|
|
Meteor.call('public-settings/get', (err, data) => {
|
|
if (err) {
|
|
console.error(err);
|
|
}
|
|
|
|
realm.write(() => {
|
|
data.forEach((item) => {
|
|
const setting = {
|
|
_id: item._id
|
|
};
|
|
if (typeof item.value === 'string') {
|
|
setting.value = item.value;
|
|
}
|
|
realm.create('settings', setting, true);
|
|
});
|
|
});
|
|
|
|
cb();
|
|
});
|
|
|
|
Meteor.ddp.on("changed", ddbMessage => {
|
|
console.log('changed', ddbMessage);
|
|
if (ddbMessage.collection === 'stream-room-messages') {
|
|
setTimeout(function() {
|
|
realm.write(() => {
|
|
const message = ddbMessage.fields.args[0];
|
|
message.temp = false;
|
|
realm.create('messages', message, true);
|
|
});
|
|
}, 1000)
|
|
}
|
|
});
|
|
});
|
|
}
|
|
|
|
export function loginWithPassword(selector, password, cb) {
|
|
Meteor.loginWithPassword(selector, password, (err, data) => {
|
|
cb && cb();
|
|
});
|
|
}
|
|
|
|
export function loadSubscriptions(cb) {
|
|
Meteor.call('subscriptions/get', (err, data) => {
|
|
if (err) {
|
|
console.error(err);
|
|
}
|
|
|
|
realm.write(() => {
|
|
data.forEach((subscription) => {
|
|
// const subscription = {
|
|
// _id: item._id
|
|
// };
|
|
// if (typeof item.value === 'string') {
|
|
// subscription.value = item.value;
|
|
// }
|
|
realm.create('subscriptions', subscription, true);
|
|
});
|
|
});
|
|
|
|
cb && cb();
|
|
});
|
|
}
|
|
|
|
export function loadMessagesForRoom(rid) {
|
|
Meteor.call('loadHistory', rid, null, 50, (err, data) => {
|
|
if (err) {
|
|
console.error(err);
|
|
}
|
|
|
|
realm.write(() => {
|
|
data.messages.forEach((message) => {
|
|
message.temp = false;
|
|
realm.create('messages', message, true);
|
|
});
|
|
});
|
|
});
|
|
|
|
Meteor.subscribe('stream-room-messages', rid, false);
|
|
}
|
|
|
|
export function sendMessage(rid, msg, cb) {
|
|
const _id = Random.id();
|
|
const user = Meteor.user();
|
|
|
|
realm.write(() => {
|
|
realm.create('messages', {
|
|
_id,
|
|
rid,
|
|
msg,
|
|
ts: new Date,
|
|
_updatedAt: new Date,
|
|
temp: true,
|
|
u: {
|
|
_id: user._id,
|
|
username: user.username
|
|
}
|
|
}, true);
|
|
});
|
|
|
|
Meteor.call('sendMessage', {_id, rid, msg}, (err, data) => {
|
|
cb && cb();
|
|
});
|
|
}
|