X-Git-Url: https://git.kengrimes.com/?p=henge%2Fkiak.git;a=blobdiff_plain;f=client.js;h=8989989306690daf5d71a50d675476ad783e2017;hp=69ac81e485c6dab006104c4db46c2306d7f775f8;hb=d5073d238a4bf9fa96adabf6872a67e6b92fc832;hpb=10b1fcdf58cde8a6c6d5ebfa4bba76ef2adcf3dd diff --git a/client.js b/client.js index 69ac81e..8989989 100644 --- a/client.js +++ b/client.js @@ -8,25 +8,28 @@ document.body = body Do this until...? Can be used for either reconnecting or waiting for answer*/ function pollServerTimeout(url, data, resolve, reject) { console.log('Polling server with offer ' + data) - const request = XMLHttpRequest() + const request = new XMLHttpRequest() request.open('GET', url) request.setRequestHeader('Content-Type', 'application/json' ) + request.setRequestHeader('X-Strapp-Type', 'o' ) request.onreadystatechange = () => { if (request.status === 200) { - console.log('recieved answer from host ' + request.response) + console.log(request.response) resolve(request.response) } else if (request.status === 504) { + console.log('timed out, resending') pollServerTimeout(url, data, resolve, reject) } else { - reject('server errored out with ' + request.status) + reject('server unhandled response of status ' + request.status) } } - request.send(data) + console.log(data) + request.send('data in stufff and stuff in data') } -/* TODO: Possible to pass resolve/reject to functions? */ +/* TODO: All this does is wrap a function in a promise */ function pollServer(url, clientPubKey, func) { return new Promise((resolve, reject) => { func(url, clientPubKey, resolve, reject ) @@ -35,38 +38,60 @@ function pollServer(url, clientPubKey, func) { /* TODO: duplicate in both client.js and host.js */ function getPublicKey() { - /* Check local storage for public key */ - if (window.localStorage.getItem('public-key') === undefined) { - /* If doesn't exist, generate public and private key pair, store in - local storage */ - crypto.subtle.generateKey({name:'RSA-OAEP', length: 192}, true, ['encrypt', 'decrypt']) - .then((keyPair) => { - /* TODO: Do we need to store the private key as well? */ - window.localStorage.setItem('public-key', keyPair.type.public.toString()) - }) - } - console.log(window.localStorage.getItem('public-key')) - return window.localStorage.getItem('public-key') + return new Promise( (resolve, reject) => { + /* Check local storage for public key */ + if (!window.localStorage.getItem('public-key')) { + console.log('public key is undefined') + /* If doesn't exist, generate public and private key pair, store in + local storage */ + crypto.subtle.generateKey( + { name:'RSA-OAEP', + modulusLength: 2048, + publicExponent: new Uint8Array([0x01, 0x00, 0x01]), + hash: {name: "SHA-256"} + }, + true, + ['encrypt', 'decrypt'] + ).then((keyPair) => { + /* TODO: Do we need to store the private key as well? */ + crypto.subtle.exportKey('jwk', keyPair.publicKey) + .then((exportedKey) => { + window.localStorage.setItem('publicKey', exportedKey) + console.log('public key is' + window.localStorage.getItem('publicKey')) + resolve(exportedKey) + }) + + }) + } + else { + resolve(window.localStorage.getItem('publicKey')) + } + }) + } /* Create, set, and get client Offer. Poll server for host answer. Set host answer as client remoteDescription */ const cpc = new RTCPeerConnection() +console.log('creating offer') cpc.createOffer().then((offer) => { - console.log('creating offer which is ' + offer) return cpc.setLocalDescription(offer) }).then(() => { console.log('sessionDescriptionInit = ' + cpc.localDescription) - const cpk = getPublicKey() - let offer = { - cmd: '> sdp pubKey' - sdp: cpc.localDescription, - pubKey: cpk - } - /* Poll for answer */ - return pollServer(window.location, offer, pollServerTimeout) -}).then((answer) => { - console.log(answer) - /* TODO: State machine to parse answer */ - cpc.setRemoteDescription(answer.sdp) + getPublicKey().then((cpk) => { + console.log('cpk is' + cpk) + let offer = { + cmd: '> sdp pubKey', + sdp: cpc.localDescription, + pubKey: cpk + } + /* Poll for answer */ + return pollServer(window.location, offer, pollServerTimeout) + }).then((answer) => { + //console.log(answer) + /* TODO: State machine to parse answer */ + cpc.setRemoteDescription(answer.sdp) + }).catch( (err) => { + console.log('error in sdp handshake: ' + err) + }) })