122 lines
2.4 KiB
JavaScript
122 lines
2.4 KiB
JavaScript
'use strict';
|
|
|
|
var React = require('react-native');
|
|
var {
|
|
AppRegistry,
|
|
StyleSheet,
|
|
Text,
|
|
View,
|
|
} = React;
|
|
|
|
// require('./test/simple/test-dgram-address')
|
|
// require('./test/simple/test-dgram-bind-default-address')
|
|
// require('./test/simple/test-dgram-bind-shared-ports')
|
|
|
|
function randomPort() {
|
|
return Math.random() * 65536 | 0
|
|
}
|
|
|
|
var dgram = require('RCTUDP')
|
|
var a = dgram.createSocket('udp4')
|
|
var aPort = randomPort()
|
|
a.bind(bPort, function(err) {
|
|
if (err) throw err
|
|
|
|
console.log('address', a.address())
|
|
})
|
|
|
|
var b = dgram.createSocket('udp4')
|
|
var bPort = randomPort()
|
|
b.bind(bPort, function(err) {
|
|
if (err) throw err
|
|
|
|
console.log('address', b.address())
|
|
})
|
|
|
|
a.on('message', function(data, rinfo) {
|
|
var str = String.fromCharCode.apply(null, new Uint8Array(data));
|
|
console.log('a received', str, rinfo)
|
|
a.close()
|
|
b.close()
|
|
})
|
|
|
|
b.on('message', function(data, rinfo) {
|
|
var str = String.fromCharCode.apply(null, new Uint8Array(data));
|
|
console.log('b received', str, rinfo)
|
|
|
|
// echo back
|
|
b.send(data, 0, data.length, aPort, '127.0.0.1', function(err) {
|
|
if (err) throw err
|
|
|
|
console.log('sent')
|
|
})
|
|
})
|
|
|
|
b.once('listening', function() {
|
|
var msg = toByteArray('hello')
|
|
a.send(msg, 0, msg.length, bPort, '127.0.0.1', function(err) {
|
|
if (err) throw err
|
|
|
|
console.log('sent')
|
|
})
|
|
})
|
|
|
|
var rctsockets = React.createClass({
|
|
render: function() {
|
|
return (
|
|
<View style={styles.container}>
|
|
<Text style={styles.welcome}>
|
|
Open Dev Tools to see socket chatter
|
|
</Text>
|
|
</View>
|
|
);
|
|
}
|
|
});
|
|
|
|
var styles = StyleSheet.create({
|
|
container: {
|
|
flex: 1,
|
|
justifyContent: 'center',
|
|
alignItems: 'center',
|
|
backgroundColor: '#F5FCFF',
|
|
},
|
|
welcome: {
|
|
fontSize: 20,
|
|
textAlign: 'center',
|
|
margin: 10,
|
|
},
|
|
instructions: {
|
|
textAlign: 'center',
|
|
color: '#333333',
|
|
marginBottom: 5,
|
|
},
|
|
});
|
|
|
|
|
|
function toByteArray(obj) {
|
|
if (typeof obj === 'object') {
|
|
var i = 0
|
|
var arr = []
|
|
while (true) {
|
|
if (!(i in obj)) break
|
|
|
|
arr.push(+obj[i])
|
|
i++
|
|
}
|
|
|
|
return new Uint8Array(arr)
|
|
}
|
|
else if (typeof obj !== 'string') {
|
|
throw new Error('unsupported format')
|
|
}
|
|
|
|
var uint = new Uint8Array(obj.length);
|
|
for (var i = 0, l = obj.length; i < l; i++){
|
|
uint[i] = obj.charCodeAt(i);
|
|
}
|
|
|
|
return new Uint8Array(uint);
|
|
}
|
|
|
|
AppRegistry.registerComponent('react-native-udp', () => rctsockets);
|