mirror of
https://github.com/gyurix1968/guacamole-client.git
synced 2025-09-06 13:17:41 +00:00
Merge branch 'master' into GUAC-1193
This commit is contained in:
@@ -1,291 +0,0 @@
|
|||||||
/*
|
|
||||||
* Copyright (C) 2015 Glyptodon LLC
|
|
||||||
*
|
|
||||||
* Permission is hereby granted, free of charge, to any person obtaining a copy
|
|
||||||
* of this software and associated documentation files (the "Software"), to deal
|
|
||||||
* in the Software without restriction, including without limitation the rights
|
|
||||||
* to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
|
|
||||||
* copies of the Software, and to permit persons to whom the Software is
|
|
||||||
* furnished to do so, subject to the following conditions:
|
|
||||||
*
|
|
||||||
* The above copyright notice and this permission notice shall be included in
|
|
||||||
* all copies or substantial portions of the Software.
|
|
||||||
*
|
|
||||||
* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
|
|
||||||
* IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
|
|
||||||
* FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
|
|
||||||
* AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
|
|
||||||
* LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
|
|
||||||
* OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
|
|
||||||
* THE SOFTWARE.
|
|
||||||
*/
|
|
||||||
|
|
||||||
var Guacamole = Guacamole || {};
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Abstract audio channel which queues and plays arbitrary audio data.
|
|
||||||
*
|
|
||||||
* @constructor
|
|
||||||
*/
|
|
||||||
Guacamole.AudioChannel = function AudioChannel() {
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Reference to this AudioChannel.
|
|
||||||
*
|
|
||||||
* @private
|
|
||||||
* @type Guacamole.AudioChannel
|
|
||||||
*/
|
|
||||||
var channel = this;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* The earliest possible time that the next packet could play without
|
|
||||||
* overlapping an already-playing packet, in milliseconds.
|
|
||||||
*
|
|
||||||
* @private
|
|
||||||
* @type Number
|
|
||||||
*/
|
|
||||||
var nextPacketTime = Guacamole.AudioChannel.getTimestamp();
|
|
||||||
|
|
||||||
/**
|
|
||||||
* The last time that sync() was called, in milliseconds. If sync() has
|
|
||||||
* never been called, this will be the time the Guacamole.AudioChannel
|
|
||||||
* was created.
|
|
||||||
*
|
|
||||||
* @type Number
|
|
||||||
*/
|
|
||||||
var lastSync = nextPacketTime;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Notifies this Guacamole.AudioChannel that all audio up to the current
|
|
||||||
* point in time has been given via play(), and that any difference in time
|
|
||||||
* between queued audio packets and the current time can be considered
|
|
||||||
* latency.
|
|
||||||
*/
|
|
||||||
this.sync = function sync() {
|
|
||||||
|
|
||||||
// Calculate elapsed time since last sync
|
|
||||||
var now = Guacamole.AudioChannel.getTimestamp();
|
|
||||||
var elapsed = now - lastSync;
|
|
||||||
|
|
||||||
// Reschedule future playback time such that playback latency is
|
|
||||||
// bounded within the duration of the last audio frame
|
|
||||||
nextPacketTime = Math.min(nextPacketTime, now + elapsed);
|
|
||||||
|
|
||||||
// Record sync time
|
|
||||||
lastSync = now;
|
|
||||||
|
|
||||||
};
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Queues up the given data for playing by this channel once all previously
|
|
||||||
* queued data has been played. If no data has been queued, the data will
|
|
||||||
* play immediately.
|
|
||||||
*
|
|
||||||
* @param {String} mimetype
|
|
||||||
* The mimetype of the audio data provided.
|
|
||||||
*
|
|
||||||
* @param {Number} duration
|
|
||||||
* The duration of the data provided, in milliseconds.
|
|
||||||
*
|
|
||||||
* @param {Blob} data
|
|
||||||
* The blob of audio data to play.
|
|
||||||
*/
|
|
||||||
this.play = function play(mimetype, duration, data) {
|
|
||||||
|
|
||||||
var packet = new Guacamole.AudioChannel.Packet(mimetype, data);
|
|
||||||
|
|
||||||
// Determine exactly when packet CAN play
|
|
||||||
var packetTime = Guacamole.AudioChannel.getTimestamp();
|
|
||||||
if (nextPacketTime < packetTime)
|
|
||||||
nextPacketTime = packetTime;
|
|
||||||
|
|
||||||
// Schedule packet
|
|
||||||
packet.play(nextPacketTime);
|
|
||||||
|
|
||||||
// Update timeline
|
|
||||||
nextPacketTime += duration;
|
|
||||||
|
|
||||||
};
|
|
||||||
|
|
||||||
};
|
|
||||||
|
|
||||||
// Define context if available
|
|
||||||
if (window.AudioContext) {
|
|
||||||
try {Guacamole.AudioChannel.context = new AudioContext();}
|
|
||||||
catch (e){}
|
|
||||||
}
|
|
||||||
|
|
||||||
// Fallback to Webkit-specific AudioContext implementation
|
|
||||||
else if (window.webkitAudioContext) {
|
|
||||||
try {Guacamole.AudioChannel.context = new webkitAudioContext();}
|
|
||||||
catch (e){}
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Returns a base timestamp which can be used for scheduling future audio
|
|
||||||
* playback. Scheduling playback for the value returned by this function plus
|
|
||||||
* N will cause the associated audio to be played back N milliseconds after
|
|
||||||
* the function is called.
|
|
||||||
*
|
|
||||||
* @return {Number} An arbitrary channel-relative timestamp, in milliseconds.
|
|
||||||
*/
|
|
||||||
Guacamole.AudioChannel.getTimestamp = function() {
|
|
||||||
|
|
||||||
// If we have an audio context, use its timestamp
|
|
||||||
if (Guacamole.AudioChannel.context)
|
|
||||||
return Guacamole.AudioChannel.context.currentTime * 1000;
|
|
||||||
|
|
||||||
// If we have high-resolution timers, use those
|
|
||||||
if (window.performance) {
|
|
||||||
|
|
||||||
if (window.performance.now)
|
|
||||||
return window.performance.now();
|
|
||||||
|
|
||||||
if (window.performance.webkitNow)
|
|
||||||
return window.performance.webkitNow();
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
||||||
// Fallback to millisecond-resolution system time
|
|
||||||
return new Date().getTime();
|
|
||||||
|
|
||||||
};
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Abstract representation of an audio packet.
|
|
||||||
*
|
|
||||||
* @constructor
|
|
||||||
*
|
|
||||||
* @param {String} mimetype The mimetype of the data contained by this packet.
|
|
||||||
* @param {Blob} data The blob of sound data contained by this packet.
|
|
||||||
*/
|
|
||||||
Guacamole.AudioChannel.Packet = function(mimetype, data) {
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Schedules this packet for playback at the given time.
|
|
||||||
*
|
|
||||||
* @function
|
|
||||||
* @param {Number} when The time this packet should be played, in
|
|
||||||
* milliseconds.
|
|
||||||
*/
|
|
||||||
this.play = function(when) { /* NOP */ }; // Defined conditionally depending on support
|
|
||||||
|
|
||||||
// If audio API available, use it.
|
|
||||||
if (Guacamole.AudioChannel.context) {
|
|
||||||
|
|
||||||
var readyBuffer = null;
|
|
||||||
|
|
||||||
// By default, when decoding finishes, store buffer for future
|
|
||||||
// playback
|
|
||||||
var handleReady = function(buffer) {
|
|
||||||
readyBuffer = buffer;
|
|
||||||
};
|
|
||||||
|
|
||||||
// Read data and start decoding
|
|
||||||
var reader = new FileReader();
|
|
||||||
reader.onload = function() {
|
|
||||||
Guacamole.AudioChannel.context.decodeAudioData(
|
|
||||||
reader.result,
|
|
||||||
function(buffer) { handleReady(buffer); }
|
|
||||||
);
|
|
||||||
};
|
|
||||||
reader.readAsArrayBuffer(data);
|
|
||||||
|
|
||||||
// Set up buffer source
|
|
||||||
var source = Guacamole.AudioChannel.context.createBufferSource();
|
|
||||||
source.connect(Guacamole.AudioChannel.context.destination);
|
|
||||||
|
|
||||||
// Use noteOn() instead of start() if necessary
|
|
||||||
if (!source.start)
|
|
||||||
source.start = source.noteOn;
|
|
||||||
|
|
||||||
var play_when;
|
|
||||||
|
|
||||||
function playDelayed(buffer) {
|
|
||||||
source.buffer = buffer;
|
|
||||||
source.start(play_when / 1000);
|
|
||||||
}
|
|
||||||
|
|
||||||
/** @ignore */
|
|
||||||
this.play = function(when) {
|
|
||||||
|
|
||||||
play_when = when;
|
|
||||||
|
|
||||||
// If buffer available, play it NOW
|
|
||||||
if (readyBuffer)
|
|
||||||
playDelayed(readyBuffer);
|
|
||||||
|
|
||||||
// Otherwise, play when decoded
|
|
||||||
else
|
|
||||||
handleReady = playDelayed;
|
|
||||||
|
|
||||||
};
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
||||||
else {
|
|
||||||
|
|
||||||
var play_on_load = false;
|
|
||||||
|
|
||||||
// Create audio element to house and play the data
|
|
||||||
var audio = null;
|
|
||||||
try { audio = new Audio(); }
|
|
||||||
catch (e) {}
|
|
||||||
|
|
||||||
if (audio) {
|
|
||||||
|
|
||||||
// Read data and start decoding
|
|
||||||
var reader = new FileReader();
|
|
||||||
reader.onload = function() {
|
|
||||||
|
|
||||||
var binary = "";
|
|
||||||
var bytes = new Uint8Array(reader.result);
|
|
||||||
|
|
||||||
// Produce binary string from bytes in buffer
|
|
||||||
for (var i=0; i<bytes.byteLength; i++)
|
|
||||||
binary += String.fromCharCode(bytes[i]);
|
|
||||||
|
|
||||||
// Convert to data URI
|
|
||||||
audio.src = "data:" + mimetype + ";base64," + window.btoa(binary);
|
|
||||||
|
|
||||||
// Play if play was attempted but packet wasn't loaded yet
|
|
||||||
if (play_on_load)
|
|
||||||
audio.play();
|
|
||||||
|
|
||||||
};
|
|
||||||
reader.readAsArrayBuffer(data);
|
|
||||||
|
|
||||||
function play() {
|
|
||||||
|
|
||||||
// If audio data is ready, play now
|
|
||||||
if (audio.src)
|
|
||||||
audio.play();
|
|
||||||
|
|
||||||
// Otherwise, play when loaded
|
|
||||||
else
|
|
||||||
play_on_load = true;
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
||||||
/** @ignore */
|
|
||||||
this.play = function(when) {
|
|
||||||
|
|
||||||
// Calculate time until play
|
|
||||||
var now = Guacamole.AudioChannel.getTimestamp();
|
|
||||||
var delay = when - now;
|
|
||||||
|
|
||||||
// Play now if too late
|
|
||||||
if (delay < 0)
|
|
||||||
play();
|
|
||||||
|
|
||||||
// Otherwise, schedule later playback
|
|
||||||
else
|
|
||||||
window.setTimeout(play, delay);
|
|
||||||
|
|
||||||
};
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
||||||
};
|
|
652
guacamole-common-js/src/main/webapp/modules/AudioPlayer.js
Normal file
652
guacamole-common-js/src/main/webapp/modules/AudioPlayer.js
Normal file
@@ -0,0 +1,652 @@
|
|||||||
|
/*
|
||||||
|
* Copyright (C) 2015 Glyptodon LLC
|
||||||
|
*
|
||||||
|
* Permission is hereby granted, free of charge, to any person obtaining a copy
|
||||||
|
* of this software and associated documentation files (the "Software"), to deal
|
||||||
|
* in the Software without restriction, including without limitation the rights
|
||||||
|
* to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
|
||||||
|
* copies of the Software, and to permit persons to whom the Software is
|
||||||
|
* furnished to do so, subject to the following conditions:
|
||||||
|
*
|
||||||
|
* The above copyright notice and this permission notice shall be included in
|
||||||
|
* all copies or substantial portions of the Software.
|
||||||
|
*
|
||||||
|
* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
|
||||||
|
* IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
|
||||||
|
* FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
|
||||||
|
* AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
|
||||||
|
* LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
|
||||||
|
* OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
|
||||||
|
* THE SOFTWARE.
|
||||||
|
*/
|
||||||
|
|
||||||
|
var Guacamole = Guacamole || {};
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Abstract audio player which accepts, queues and plays back arbitrary audio
|
||||||
|
* data. It is up to implementations of this class to provide some means of
|
||||||
|
* handling a provided Guacamole.InputStream. Data received along the provided
|
||||||
|
* stream is to be played back immediately.
|
||||||
|
*
|
||||||
|
* @constructor
|
||||||
|
*/
|
||||||
|
Guacamole.AudioPlayer = function AudioPlayer() {
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Notifies this Guacamole.AudioPlayer that all audio up to the current
|
||||||
|
* point in time has been given via the underlying stream, and that any
|
||||||
|
* difference in time between queued audio data and the current time can be
|
||||||
|
* considered latency.
|
||||||
|
*/
|
||||||
|
this.sync = function sync() {
|
||||||
|
// Default implementation - do nothing
|
||||||
|
};
|
||||||
|
|
||||||
|
};
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Determines whether the given mimetype is supported by any built-in
|
||||||
|
* implementation of Guacamole.AudioPlayer, and thus will be properly handled
|
||||||
|
* by Guacamole.AudioPlayer.getInstance().
|
||||||
|
*
|
||||||
|
* @param {String} mimetype
|
||||||
|
* The mimetype to check.
|
||||||
|
*
|
||||||
|
* @returns {Boolean}
|
||||||
|
* true if the given mimetype is supported by any built-in
|
||||||
|
* Guacamole.AudioPlayer, false otherwise.
|
||||||
|
*/
|
||||||
|
Guacamole.AudioPlayer.isSupportedType = function isSupportedType(mimetype) {
|
||||||
|
|
||||||
|
return Guacamole.RawAudioPlayer.isSupportedType(mimetype);
|
||||||
|
|
||||||
|
};
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Returns a list of all mimetypes supported by any built-in
|
||||||
|
* Guacamole.AudioPlayer, in rough order of priority. Beware that only the core
|
||||||
|
* mimetypes themselves will be listed. Any mimetype parameters, even required
|
||||||
|
* ones, will not be included in the list. For example, "audio/L8" is a
|
||||||
|
* supported raw audio mimetype that is supported, but it is invalid without
|
||||||
|
* additional parameters. Something like "audio/L8;rate=44100" would be valid,
|
||||||
|
* however (see https://tools.ietf.org/html/rfc4856).
|
||||||
|
*
|
||||||
|
* @returns {String[]}
|
||||||
|
* A list of all mimetypes supported by any built-in Guacamole.AudioPlayer,
|
||||||
|
* excluding any parameters.
|
||||||
|
*/
|
||||||
|
Guacamole.AudioPlayer.getSupportedTypes = function getSupportedTypes() {
|
||||||
|
|
||||||
|
return Guacamole.RawAudioPlayer.getSupportedTypes();
|
||||||
|
|
||||||
|
};
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Returns an instance of Guacamole.AudioPlayer providing support for the given
|
||||||
|
* audio format. If support for the given audio format is not available, null
|
||||||
|
* is returned.
|
||||||
|
*
|
||||||
|
* @param {Guacamole.InputStream} stream
|
||||||
|
* The Guacamole.InputStream to read audio data from.
|
||||||
|
*
|
||||||
|
* @param {String} mimetype
|
||||||
|
* The mimetype of the audio data in the provided stream.
|
||||||
|
*
|
||||||
|
* @return {Guacamole.AudioPlayer}
|
||||||
|
* A Guacamole.AudioPlayer instance supporting the given mimetype and
|
||||||
|
* reading from the given stream, or null if support for the given mimetype
|
||||||
|
* is absent.
|
||||||
|
*/
|
||||||
|
Guacamole.AudioPlayer.getInstance = function getInstance(stream, mimetype) {
|
||||||
|
|
||||||
|
// Use raw audio player if possible
|
||||||
|
if (Guacamole.RawAudioPlayer.isSupportedType(mimetype))
|
||||||
|
return new Guacamole.RawAudioPlayer(stream, mimetype);
|
||||||
|
|
||||||
|
// No support for given mimetype
|
||||||
|
return null;
|
||||||
|
|
||||||
|
};
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Implementation of Guacamole.AudioPlayer providing support for raw PCM format
|
||||||
|
* audio. This player relies only on the Web Audio API and does not require any
|
||||||
|
* browser-level support for its audio formats.
|
||||||
|
*
|
||||||
|
* @constructor
|
||||||
|
* @augments Guacamole.AudioPlayer
|
||||||
|
* @param {Guacamole.InputStream} stream
|
||||||
|
* The Guacamole.InputStream to read audio data from.
|
||||||
|
*
|
||||||
|
* @param {String} mimetype
|
||||||
|
* The mimetype of the audio data in the provided stream, which must be a
|
||||||
|
* "audio/L8" or "audio/L16" mimetype with necessary parameters, such as:
|
||||||
|
* "audio/L16;rate=44100,channels=2".
|
||||||
|
*/
|
||||||
|
Guacamole.RawAudioPlayer = function RawAudioPlayer(stream, mimetype) {
|
||||||
|
|
||||||
|
/**
|
||||||
|
* The format of audio this player will decode.
|
||||||
|
*
|
||||||
|
* @private
|
||||||
|
* @type Guacamole.RawAudioPlayer._Format
|
||||||
|
*/
|
||||||
|
var format = Guacamole.RawAudioPlayer._Format.parse(mimetype);
|
||||||
|
|
||||||
|
/**
|
||||||
|
* An instance of a Web Audio API AudioContext object, or null if the
|
||||||
|
* Web Audio API is not supported.
|
||||||
|
*
|
||||||
|
* @private
|
||||||
|
* @type AudioContext
|
||||||
|
*/
|
||||||
|
var context = (function getAudioContext() {
|
||||||
|
|
||||||
|
// Fallback to Webkit-specific AudioContext implementation
|
||||||
|
var AudioContext = window.AudioContext || window.webkitAudioContext;
|
||||||
|
|
||||||
|
// Get new AudioContext instance if Web Audio API is supported
|
||||||
|
if (AudioContext) {
|
||||||
|
try {
|
||||||
|
return new AudioContext();
|
||||||
|
}
|
||||||
|
catch (e) {
|
||||||
|
// Do not use Web Audio API if not allowed by browser
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// Web Audio API not supported
|
||||||
|
return null;
|
||||||
|
|
||||||
|
})();
|
||||||
|
|
||||||
|
/**
|
||||||
|
* The earliest possible time that the next packet could play without
|
||||||
|
* overlapping an already-playing packet, in seconds. Note that while this
|
||||||
|
* value is in seconds, it is not an integer value and has microsecond
|
||||||
|
* resolution.
|
||||||
|
*
|
||||||
|
* @private
|
||||||
|
* @type Number
|
||||||
|
*/
|
||||||
|
var nextPacketTime = context.currentTime;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Guacamole.ArrayBufferReader wrapped around the audio input stream
|
||||||
|
* provided with this Guacamole.RawAudioPlayer was created.
|
||||||
|
*
|
||||||
|
* @private
|
||||||
|
* @type Guacamole.ArrayBufferReader
|
||||||
|
*/
|
||||||
|
var reader = new Guacamole.ArrayBufferReader(stream);
|
||||||
|
|
||||||
|
/**
|
||||||
|
* The minimum size of an audio packet split by splitAudioPacket(), in
|
||||||
|
* seconds. Audio packets smaller than this will not be split, nor will the
|
||||||
|
* split result of a larger packet ever be smaller in size than this
|
||||||
|
* minimum.
|
||||||
|
*
|
||||||
|
* @private
|
||||||
|
* @constant
|
||||||
|
* @type Number
|
||||||
|
*/
|
||||||
|
var MIN_SPLIT_SIZE = 0.02;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* The maximum amount of latency to allow between the buffered data stream
|
||||||
|
* and the playback position, in seconds. Initially, this is set to
|
||||||
|
* roughly one third of a second.
|
||||||
|
*
|
||||||
|
* @private
|
||||||
|
* @type Number
|
||||||
|
*/
|
||||||
|
var maxLatency = 0.3;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* The type of typed array that will be used to represent each audio packet
|
||||||
|
* internally. This will be either Int8Array or Int16Array, depending on
|
||||||
|
* whether the raw audio format is 8-bit or 16-bit.
|
||||||
|
*
|
||||||
|
* @private
|
||||||
|
* @constructor
|
||||||
|
*/
|
||||||
|
var SampleArray = (format.bytesPerSample === 1) ? window.Int8Array : window.Int16Array;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* The maximum absolute value of any sample within a raw audio packet
|
||||||
|
* received by this audio player. This depends only on the size of each
|
||||||
|
* sample, and will be 128 for 8-bit audio and 32768 for 16-bit audio.
|
||||||
|
*
|
||||||
|
* @private
|
||||||
|
* @type Number
|
||||||
|
*/
|
||||||
|
var maxSampleValue = (format.bytesPerSample === 1) ? 128 : 32768;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* The queue of all pending audio packets, as an array of sample arrays.
|
||||||
|
* Audio packets which are pending playback will be added to this queue for
|
||||||
|
* further manipulation prior to scheduling via the Web Audio API. Once an
|
||||||
|
* audio packet leaves this queue and is scheduled via the Web Audio API,
|
||||||
|
* no further modifications can be made to that packet.
|
||||||
|
*
|
||||||
|
* @private
|
||||||
|
* @type SampleArray[]
|
||||||
|
*/
|
||||||
|
var packetQueue = [];
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Given an array of audio packets, returns a single audio packet
|
||||||
|
* containing the concatenation of those packets.
|
||||||
|
*
|
||||||
|
* @private
|
||||||
|
* @param {SampleArray[]} packets
|
||||||
|
* The array of audio packets to concatenate.
|
||||||
|
*
|
||||||
|
* @returns {SampleArray}
|
||||||
|
* A single audio packet containing the concatenation of all given
|
||||||
|
* audio packets. If no packets are provided, this will be undefined.
|
||||||
|
*/
|
||||||
|
var joinAudioPackets = function joinAudioPackets(packets) {
|
||||||
|
|
||||||
|
// Do not bother joining if one or fewer packets are in the queue
|
||||||
|
if (packets.length <= 1)
|
||||||
|
return packets[0];
|
||||||
|
|
||||||
|
// Determine total sample length of the entire queue
|
||||||
|
var totalLength = 0;
|
||||||
|
packets.forEach(function addPacketLengths(packet) {
|
||||||
|
totalLength += packet.length;
|
||||||
|
});
|
||||||
|
|
||||||
|
// Append each packet within queue
|
||||||
|
var offset = 0;
|
||||||
|
var joined = new SampleArray(totalLength);
|
||||||
|
packets.forEach(function appendPacket(packet) {
|
||||||
|
joined.set(packet, offset);
|
||||||
|
offset += packet.length;
|
||||||
|
});
|
||||||
|
|
||||||
|
return joined;
|
||||||
|
|
||||||
|
};
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Given a single packet of audio data, splits off an arbitrary length of
|
||||||
|
* audio data from the beginning of that packet, returning the split result
|
||||||
|
* as an array of two packets. The split location is determined through an
|
||||||
|
* algorithm intended to minimize the liklihood of audible clicking between
|
||||||
|
* packets. If no such split location is possible, an array containing only
|
||||||
|
* the originally-provided audio packet is returned.
|
||||||
|
*
|
||||||
|
* @private
|
||||||
|
* @param {SampleArray} data
|
||||||
|
* The audio packet to split.
|
||||||
|
*
|
||||||
|
* @returns {SampleArray[]}
|
||||||
|
* An array of audio packets containing the result of splitting the
|
||||||
|
* provided audio packet. If splitting is possible, this array will
|
||||||
|
* contain two packets. If splitting is not possible, this array will
|
||||||
|
* contain only the originally-provided packet.
|
||||||
|
*/
|
||||||
|
var splitAudioPacket = function splitAudioPacket(data) {
|
||||||
|
|
||||||
|
var minValue = Number.MAX_VALUE;
|
||||||
|
var optimalSplitLength = data.length;
|
||||||
|
|
||||||
|
// Calculate number of whole samples in the provided audio packet AND
|
||||||
|
// in the minimum possible split packet
|
||||||
|
var samples = Math.floor(data.length / format.channels);
|
||||||
|
var minSplitSamples = Math.floor(format.rate * MIN_SPLIT_SIZE);
|
||||||
|
|
||||||
|
// Calculate the beginning of the "end" of the audio packet
|
||||||
|
var start = Math.max(
|
||||||
|
format.channels * minSplitSamples,
|
||||||
|
format.channels * (samples - minSplitSamples)
|
||||||
|
);
|
||||||
|
|
||||||
|
// For all samples at the end of the given packet, find a point where
|
||||||
|
// the perceptible volume across all channels is lowest (and thus is
|
||||||
|
// the optimal point to split)
|
||||||
|
for (var offset = start; offset < data.length; offset += format.channels) {
|
||||||
|
|
||||||
|
// Calculate the sum of all values across all channels (the result
|
||||||
|
// will be proportional to the average volume of a sample)
|
||||||
|
var totalValue = 0;
|
||||||
|
for (var channel = 0; channel < format.channels; channel++) {
|
||||||
|
totalValue += Math.abs(data[offset + channel]);
|
||||||
|
}
|
||||||
|
|
||||||
|
// If this is the smallest average value thus far, set the split
|
||||||
|
// length such that the first packet ends with the current sample
|
||||||
|
if (totalValue <= minValue) {
|
||||||
|
optimalSplitLength = offset + format.channels;
|
||||||
|
minValue = totalValue;
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
// If packet is not split, return the supplied packet untouched
|
||||||
|
if (optimalSplitLength === data.length)
|
||||||
|
return [data];
|
||||||
|
|
||||||
|
// Otherwise, split the packet into two new packets according to the
|
||||||
|
// calculated optimal split length
|
||||||
|
return [
|
||||||
|
new SampleArray(data.buffer.slice(0, optimalSplitLength * format.bytesPerSample)),
|
||||||
|
new SampleArray(data.buffer.slice(optimalSplitLength * format.bytesPerSample))
|
||||||
|
];
|
||||||
|
|
||||||
|
};
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Pushes the given packet of audio data onto the playback queue. Unlike
|
||||||
|
* other private functions within Guacamole.RawAudioPlayer, the type of the
|
||||||
|
* ArrayBuffer packet of audio data here need not be specific to the type
|
||||||
|
* of audio (as with SampleArray). The ArrayBuffer type provided by a
|
||||||
|
* Guacamole.ArrayBufferReader, for example, is sufficient. Any necessary
|
||||||
|
* conversions will be performed automatically internally.
|
||||||
|
*
|
||||||
|
* @private
|
||||||
|
* @param {ArrayBuffer} data
|
||||||
|
* A raw packet of audio data that should be pushed onto the audio
|
||||||
|
* playback queue.
|
||||||
|
*/
|
||||||
|
var pushAudioPacket = function pushAudioPacket(data) {
|
||||||
|
packetQueue.push(new SampleArray(data));
|
||||||
|
};
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Shifts off and returns a packet of audio data from the beginning of the
|
||||||
|
* playback queue. The length of this audio packet is determined
|
||||||
|
* dynamically according to the click-reduction algorithm implemented by
|
||||||
|
* splitAudioPacket().
|
||||||
|
*
|
||||||
|
* @returns {SampleArray}
|
||||||
|
* A packet of audio data pulled from the beginning of the playback
|
||||||
|
* queue.
|
||||||
|
*/
|
||||||
|
var shiftAudioPacket = function shiftAudioPacket() {
|
||||||
|
|
||||||
|
// Flatten data in packet queue
|
||||||
|
var data = joinAudioPackets(packetQueue);
|
||||||
|
if (!data)
|
||||||
|
return null;
|
||||||
|
|
||||||
|
// Pull an appropriate amount of data from the front of the queue
|
||||||
|
packetQueue = splitAudioPacket(data);
|
||||||
|
data = packetQueue.shift();
|
||||||
|
|
||||||
|
return data;
|
||||||
|
|
||||||
|
};
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Converts the given audio packet into an AudioBuffer, ready for playback
|
||||||
|
* by the Web Audio API. Unlike the raw audio packets received by this
|
||||||
|
* audio player, AudioBuffers require floating point samples and are split
|
||||||
|
* into isolated planes of channel-specific data.
|
||||||
|
*
|
||||||
|
* @private
|
||||||
|
* @param {SampleArray} data
|
||||||
|
* The raw audio packet that should be converted into a Web Audio API
|
||||||
|
* AudioBuffer.
|
||||||
|
*
|
||||||
|
* @returns {AudioBuffer}
|
||||||
|
* A new Web Audio API AudioBuffer containing the provided audio data,
|
||||||
|
* converted to the format used by the Web Audio API.
|
||||||
|
*/
|
||||||
|
var toAudioBuffer = function toAudioBuffer(data) {
|
||||||
|
|
||||||
|
// Calculate total number of samples
|
||||||
|
var samples = data.length / format.channels;
|
||||||
|
|
||||||
|
// Determine exactly when packet CAN play
|
||||||
|
var packetTime = context.currentTime;
|
||||||
|
if (nextPacketTime < packetTime)
|
||||||
|
nextPacketTime = packetTime;
|
||||||
|
|
||||||
|
// Get audio buffer for specified format
|
||||||
|
var audioBuffer = context.createBuffer(format.channels, samples, format.rate);
|
||||||
|
|
||||||
|
// Convert each channel
|
||||||
|
for (var channel = 0; channel < format.channels; channel++) {
|
||||||
|
|
||||||
|
var audioData = audioBuffer.getChannelData(channel);
|
||||||
|
|
||||||
|
// Fill audio buffer with data for channel
|
||||||
|
var offset = channel;
|
||||||
|
for (var i = 0; i < samples; i++) {
|
||||||
|
audioData[i] = data[offset] / maxSampleValue;
|
||||||
|
offset += format.channels;
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
return audioBuffer;
|
||||||
|
|
||||||
|
};
|
||||||
|
|
||||||
|
// Defer playback of received audio packets slightly
|
||||||
|
reader.ondata = function playReceivedAudio(data) {
|
||||||
|
|
||||||
|
// Push received samples onto queue
|
||||||
|
pushAudioPacket(new SampleArray(data));
|
||||||
|
|
||||||
|
// Shift off an arbitrary packet of audio data from the queue (this may
|
||||||
|
// be different in size from the packet just pushed)
|
||||||
|
var packet = shiftAudioPacket();
|
||||||
|
if (!packet)
|
||||||
|
return;
|
||||||
|
|
||||||
|
// Determine exactly when packet CAN play
|
||||||
|
var packetTime = context.currentTime;
|
||||||
|
if (nextPacketTime < packetTime)
|
||||||
|
nextPacketTime = packetTime;
|
||||||
|
|
||||||
|
// Set up buffer source
|
||||||
|
var source = context.createBufferSource();
|
||||||
|
source.connect(context.destination);
|
||||||
|
|
||||||
|
// Use noteOn() instead of start() if necessary
|
||||||
|
if (!source.start)
|
||||||
|
source.start = source.noteOn;
|
||||||
|
|
||||||
|
// Schedule packet
|
||||||
|
source.buffer = toAudioBuffer(packet);
|
||||||
|
source.start(nextPacketTime);
|
||||||
|
|
||||||
|
// Update timeline by duration of scheduled packet
|
||||||
|
nextPacketTime += packet.length / format.channels / format.rate;
|
||||||
|
|
||||||
|
};
|
||||||
|
|
||||||
|
/** @override */
|
||||||
|
this.sync = function sync() {
|
||||||
|
|
||||||
|
// Calculate elapsed time since last sync
|
||||||
|
var now = context.currentTime;
|
||||||
|
|
||||||
|
// Reschedule future playback time such that playback latency is
|
||||||
|
// bounded within a reasonable latency threshold
|
||||||
|
nextPacketTime = Math.min(nextPacketTime, now + maxLatency);
|
||||||
|
|
||||||
|
};
|
||||||
|
|
||||||
|
};
|
||||||
|
|
||||||
|
Guacamole.RawAudioPlayer.prototype = new Guacamole.AudioPlayer();
|
||||||
|
|
||||||
|
/**
|
||||||
|
* A description of the format of raw PCM audio received by a
|
||||||
|
* Guacamole.RawAudioPlayer. This object describes the number of bytes per
|
||||||
|
* sample, the number of channels, and the overall sample rate.
|
||||||
|
*
|
||||||
|
* @private
|
||||||
|
* @constructor
|
||||||
|
* @param {Guacamole.RawAudioPlayer._Format|Object} template
|
||||||
|
* The object whose properties should be copied into the corresponding
|
||||||
|
* properties of the new Guacamole.RawAudioPlayer._Format.
|
||||||
|
*/
|
||||||
|
Guacamole.RawAudioPlayer._Format = function _Format(template) {
|
||||||
|
|
||||||
|
/**
|
||||||
|
* The number of bytes in each sample of audio data. This value is
|
||||||
|
* independent of the number of channels.
|
||||||
|
*
|
||||||
|
* @type Number
|
||||||
|
*/
|
||||||
|
this.bytesPerSample = template.bytesPerSample;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* The number of audio channels (ie: 1 for mono, 2 for stereo).
|
||||||
|
*
|
||||||
|
* @type Number
|
||||||
|
*/
|
||||||
|
this.channels = template.channels;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* The number of samples per second, per channel.
|
||||||
|
*
|
||||||
|
* @type Number
|
||||||
|
*/
|
||||||
|
this.rate = template.rate;
|
||||||
|
|
||||||
|
};
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Parses the given mimetype, returning a new Guacamole.RawAudioPlayer._Format
|
||||||
|
* which describes the type of raw audio data represented by that mimetype. If
|
||||||
|
* the mimetype is not supported by Guacamole.RawAudioPlayer, null is returned.
|
||||||
|
*
|
||||||
|
* @private
|
||||||
|
* @param {String} mimetype
|
||||||
|
* The audio mimetype to parse.
|
||||||
|
*
|
||||||
|
* @returns {Guacamole.RawAudioPlayer._Format}
|
||||||
|
* A new Guacamole.RawAudioPlayer._Format which describes the type of raw
|
||||||
|
* audio data represented by the given mimetype, or null if the given
|
||||||
|
* mimetype is not supported.
|
||||||
|
*/
|
||||||
|
Guacamole.RawAudioPlayer._Format.parse = function parseFormat(mimetype) {
|
||||||
|
|
||||||
|
var bytesPerSample;
|
||||||
|
|
||||||
|
// Rate is absolutely required - if null is still present later, the
|
||||||
|
// mimetype must not be supported
|
||||||
|
var rate = null;
|
||||||
|
|
||||||
|
// Default for both "audio/L8" and "audio/L16" is one channel
|
||||||
|
var channels = 1;
|
||||||
|
|
||||||
|
// "audio/L8" has one byte per sample
|
||||||
|
if (mimetype.substring(0, 9) === 'audio/L8;') {
|
||||||
|
mimetype = mimetype.substring(9);
|
||||||
|
bytesPerSample = 1;
|
||||||
|
}
|
||||||
|
|
||||||
|
// "audio/L16" has two bytes per sample
|
||||||
|
else if (mimetype.substring(0, 10) === 'audio/L16;') {
|
||||||
|
mimetype = mimetype.substring(10);
|
||||||
|
bytesPerSample = 2;
|
||||||
|
}
|
||||||
|
|
||||||
|
// All other types are unsupported
|
||||||
|
else
|
||||||
|
return null;
|
||||||
|
|
||||||
|
// Parse all parameters
|
||||||
|
var parameters = mimetype.split(',');
|
||||||
|
for (var i = 0; i < parameters.length; i++) {
|
||||||
|
|
||||||
|
var parameter = parameters[i];
|
||||||
|
|
||||||
|
// All parameters must have an equals sign separating name from value
|
||||||
|
var equals = parameter.indexOf('=');
|
||||||
|
if (equals === -1)
|
||||||
|
return null;
|
||||||
|
|
||||||
|
// Parse name and value from parameter string
|
||||||
|
var name = parameter.substring(0, equals);
|
||||||
|
var value = parameter.substring(equals+1);
|
||||||
|
|
||||||
|
// Handle each supported parameter
|
||||||
|
switch (name) {
|
||||||
|
|
||||||
|
// Number of audio channels
|
||||||
|
case 'channels':
|
||||||
|
channels = parseInt(value);
|
||||||
|
break;
|
||||||
|
|
||||||
|
// Sample rate
|
||||||
|
case 'rate':
|
||||||
|
rate = parseInt(value);
|
||||||
|
break;
|
||||||
|
|
||||||
|
// All other parameters are unsupported
|
||||||
|
default:
|
||||||
|
return null;
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
};
|
||||||
|
|
||||||
|
// The rate parameter is required
|
||||||
|
if (rate === null)
|
||||||
|
return null;
|
||||||
|
|
||||||
|
// Return parsed format details
|
||||||
|
return new Guacamole.RawAudioPlayer._Format({
|
||||||
|
bytesPerSample : bytesPerSample,
|
||||||
|
channels : channels,
|
||||||
|
rate : rate
|
||||||
|
});
|
||||||
|
|
||||||
|
};
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Determines whether the given mimetype is supported by
|
||||||
|
* Guacamole.RawAudioPlayer.
|
||||||
|
*
|
||||||
|
* @param {String} mimetype
|
||||||
|
* The mimetype to check.
|
||||||
|
*
|
||||||
|
* @returns {Boolean}
|
||||||
|
* true if the given mimetype is supported by Guacamole.RawAudioPlayer,
|
||||||
|
* false otherwise.
|
||||||
|
*/
|
||||||
|
Guacamole.RawAudioPlayer.isSupportedType = function isSupportedType(mimetype) {
|
||||||
|
|
||||||
|
// No supported types if no Web Audio API
|
||||||
|
if (!window.AudioContext && !window.webkitAudioContext)
|
||||||
|
return false;
|
||||||
|
|
||||||
|
return Guacamole.RawAudioPlayer._Format.parse(mimetype) !== null;
|
||||||
|
|
||||||
|
};
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Returns a list of all mimetypes supported by Guacamole.RawAudioPlayer. Only
|
||||||
|
* the core mimetypes themselves will be listed. Any mimetype parameters, even
|
||||||
|
* required ones, will not be included in the list. For example, "audio/L8" is
|
||||||
|
* a raw audio mimetype that may be supported, but it is invalid without
|
||||||
|
* additional parameters. Something like "audio/L8;rate=44100" would be valid,
|
||||||
|
* however (see https://tools.ietf.org/html/rfc4856).
|
||||||
|
*
|
||||||
|
* @returns {String[]}
|
||||||
|
* A list of all mimetypes supported by Guacamole.RawAudioPlayer, excluding
|
||||||
|
* any parameters. If the necessary JavaScript APIs for playing raw audio
|
||||||
|
* are absent, this list will be empty.
|
||||||
|
*/
|
||||||
|
Guacamole.RawAudioPlayer.getSupportedTypes = function getSupportedTypes() {
|
||||||
|
|
||||||
|
// No supported types if no Web Audio API
|
||||||
|
if (!window.AudioContext && !window.webkitAudioContext)
|
||||||
|
return [];
|
||||||
|
|
||||||
|
// We support 8-bit and 16-bit raw PCM
|
||||||
|
return [
|
||||||
|
'audio/L8',
|
||||||
|
'audio/L16'
|
||||||
|
];
|
||||||
|
|
||||||
|
};
|
@@ -78,12 +78,12 @@ Guacamole.Client = function(tunnel) {
|
|||||||
var layers = {};
|
var layers = {};
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* All audio channels currentl in use by the client. Initially, this will
|
* All audio players currently in use by the client. Initially, this will
|
||||||
* be empty, but channels may be allocated by the server upon request.
|
* be empty, but audio players may be allocated by the server upon request.
|
||||||
*
|
*
|
||||||
* @type Object.<Number, Guacamole.AudioChannel>
|
* @type Object.<Number, Guacamole.AudioPlayer>
|
||||||
*/
|
*/
|
||||||
var audioChannels = {};
|
var audioPlayers = {};
|
||||||
|
|
||||||
// No initial parsers
|
// No initial parsers
|
||||||
var parsers = [];
|
var parsers = [];
|
||||||
@@ -440,6 +440,25 @@ Guacamole.Client = function(tunnel) {
|
|||||||
*/
|
*/
|
||||||
this.onerror = null;
|
this.onerror = null;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Fired when a audio stream is created. The stream provided to this event
|
||||||
|
* handler will contain its own event handlers for received data.
|
||||||
|
*
|
||||||
|
* @event
|
||||||
|
* @param {Guacamole.InputStream} stream
|
||||||
|
* The stream that will receive audio data from the server.
|
||||||
|
*
|
||||||
|
* @param {String} mimetype
|
||||||
|
* The mimetype of the audio data which will be received.
|
||||||
|
*
|
||||||
|
* @return {Guacamole.AudioPlayer}
|
||||||
|
* An object which implements the Guacamole.AudioPlayer interface and
|
||||||
|
* has been initialied to play the data in the provided stream, or null
|
||||||
|
* if the built-in audio players of the Guacamole client should be
|
||||||
|
* used.
|
||||||
|
*/
|
||||||
|
this.onaudio = null;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Fired when the clipboard of the remote client is changing.
|
* Fired when the clipboard of the remote client is changing.
|
||||||
*
|
*
|
||||||
@@ -499,27 +518,6 @@ Guacamole.Client = function(tunnel) {
|
|||||||
*/
|
*/
|
||||||
this.onsync = null;
|
this.onsync = null;
|
||||||
|
|
||||||
/**
|
|
||||||
* Returns the audio channel having the given index, creating a new channel
|
|
||||||
* if necessary.
|
|
||||||
*
|
|
||||||
* @param {Number} index
|
|
||||||
* The index of the audio channel to retrieve.
|
|
||||||
*
|
|
||||||
* @returns {Guacamole.AudioChannel}
|
|
||||||
* The audio channel having the given index.
|
|
||||||
*/
|
|
||||||
var getAudioChannel = function getAudioChannel(index) {
|
|
||||||
|
|
||||||
// Get audio channel, creating it first if necessary
|
|
||||||
var audio_channel = audioChannels[index];
|
|
||||||
if (!audio_channel)
|
|
||||||
audio_channel = audioChannels[index] = new Guacamole.AudioChannel();
|
|
||||||
|
|
||||||
return audio_channel;
|
|
||||||
|
|
||||||
};
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Returns the layer with the given index, creating it if necessary.
|
* Returns the layer with the given index, creating it if necessary.
|
||||||
* Positive indices refer to visible layers, an index of zero refers to
|
* Positive indices refer to visible layers, an index of zero refers to
|
||||||
@@ -626,24 +624,30 @@ Guacamole.Client = function(tunnel) {
|
|||||||
"audio": function(parameters) {
|
"audio": function(parameters) {
|
||||||
|
|
||||||
var stream_index = parseInt(parameters[0]);
|
var stream_index = parseInt(parameters[0]);
|
||||||
var channel = getAudioChannel(parseInt(parameters[1]));
|
var mimetype = parameters[1];
|
||||||
var mimetype = parameters[2];
|
|
||||||
var duration = parseFloat(parameters[3]);
|
|
||||||
|
|
||||||
// Create stream
|
// Create stream
|
||||||
var stream = streams[stream_index] =
|
var stream = streams[stream_index] =
|
||||||
new Guacamole.InputStream(guac_client, stream_index);
|
new Guacamole.InputStream(guac_client, stream_index);
|
||||||
|
|
||||||
// Assemble entire stream as a blob
|
// Get player instance via callback
|
||||||
var blob_reader = new Guacamole.BlobReader(stream, mimetype);
|
var audioPlayer = null;
|
||||||
|
if (guac_client.onaudio)
|
||||||
|
audioPlayer = guac_client.onaudio(stream, mimetype);
|
||||||
|
|
||||||
// Play blob as audio
|
// If unsuccessful, try to use a default implementation
|
||||||
blob_reader.onend = function() {
|
if (!audioPlayer)
|
||||||
channel.play(mimetype, duration, blob_reader.getBlob());
|
audioPlayer = Guacamole.AudioPlayer.getInstance(stream, mimetype);
|
||||||
};
|
|
||||||
|
|
||||||
// Send success response
|
// If we have successfully retrieved an audio player, send success response
|
||||||
guac_client.sendAck(stream_index, "OK", 0x0000);
|
if (audioPlayer) {
|
||||||
|
audioPlayers[stream_index] = audioPlayer;
|
||||||
|
guac_client.sendAck(stream_index, "OK", 0x0000);
|
||||||
|
}
|
||||||
|
|
||||||
|
// Otherwise, mimetype must be unsupported
|
||||||
|
else
|
||||||
|
guac_client.sendAck(stream_index, "BAD TYPE", 0x030F);
|
||||||
|
|
||||||
},
|
},
|
||||||
|
|
||||||
@@ -1113,11 +1117,11 @@ Guacamole.Client = function(tunnel) {
|
|||||||
// Flush display, send sync when done
|
// Flush display, send sync when done
|
||||||
display.flush(function displaySyncComplete() {
|
display.flush(function displaySyncComplete() {
|
||||||
|
|
||||||
// Synchronize all audio channels
|
// Synchronize all audio players
|
||||||
for (var index in audioChannels) {
|
for (var index in audioPlayers) {
|
||||||
var audioChannel = audioChannels[index];
|
var audioPlayer = audioPlayers[index];
|
||||||
if (audioChannel)
|
if (audioPlayer)
|
||||||
audioChannel.sync();
|
audioPlayer.sync();
|
||||||
}
|
}
|
||||||
|
|
||||||
// Send sync response to server
|
// Send sync response to server
|
||||||
|
@@ -325,6 +325,7 @@ Guacamole.Keyboard = function(element) {
|
|||||||
var keycodeKeysyms = {
|
var keycodeKeysyms = {
|
||||||
8: [0xFF08], // backspace
|
8: [0xFF08], // backspace
|
||||||
9: [0xFF09], // tab
|
9: [0xFF09], // tab
|
||||||
|
12: [0xFF0B, 0xFF0B, 0xFF0B, 0xFFB5], // clear / KP 5
|
||||||
13: [0xFF0D], // enter
|
13: [0xFF0D], // enter
|
||||||
16: [0xFFE1, 0xFFE1, 0xFFE2], // shift
|
16: [0xFFE1, 0xFFE1, 0xFFE2], // shift
|
||||||
17: [0xFFE3, 0xFFE3, 0xFFE4], // ctrl
|
17: [0xFFE3, 0xFFE3, 0xFFE4], // ctrl
|
||||||
@@ -333,19 +334,34 @@ Guacamole.Keyboard = function(element) {
|
|||||||
20: [0xFFE5], // caps lock
|
20: [0xFFE5], // caps lock
|
||||||
27: [0xFF1B], // escape
|
27: [0xFF1B], // escape
|
||||||
32: [0x0020], // space
|
32: [0x0020], // space
|
||||||
33: [0xFF55], // page up
|
33: [0xFF55, 0xFF55, 0xFF55, 0xFFB9], // page up / KP 9
|
||||||
34: [0xFF56], // page down
|
34: [0xFF56, 0xFF56, 0xFF56, 0xFFB3], // page down / KP 3
|
||||||
35: [0xFF57], // end
|
35: [0xFF57, 0xFF57, 0xFF57, 0xFFB1], // end / KP 1
|
||||||
36: [0xFF50], // home
|
36: [0xFF50, 0xFF50, 0xFF50, 0xFFB7], // home / KP 7
|
||||||
37: [0xFF51], // left arrow
|
37: [0xFF51, 0xFF51, 0xFF51, 0xFFB4], // left arrow / KP 4
|
||||||
38: [0xFF52], // up arrow
|
38: [0xFF52, 0xFF52, 0xFF52, 0xFFB8], // up arrow / KP 8
|
||||||
39: [0xFF53], // right arrow
|
39: [0xFF53, 0xFF53, 0xFF53, 0xFFB6], // right arrow / KP 6
|
||||||
40: [0xFF54], // down arrow
|
40: [0xFF54, 0xFF54, 0xFF54, 0xFFB2], // down arrow / KP 2
|
||||||
45: [0xFF63], // insert
|
45: [0xFF63, 0xFF63, 0xFF63, 0xFFB0], // insert / KP 0
|
||||||
46: [0xFFFF], // delete
|
46: [0xFFFF, 0xFFFF, 0xFFFF, 0xFFAE], // delete / KP decimal
|
||||||
91: [0xFFEB], // left window key (hyper_l)
|
91: [0xFFEB], // left window key (hyper_l)
|
||||||
92: [0xFF67], // right window key (menu key?)
|
92: [0xFF67], // right window key (menu key?)
|
||||||
93: null, // select key
|
93: null, // select key
|
||||||
|
96: [0xFFB0], // KP 0
|
||||||
|
97: [0xFFB1], // KP 1
|
||||||
|
98: [0xFFB2], // KP 2
|
||||||
|
99: [0xFFB3], // KP 3
|
||||||
|
100: [0xFFB4], // KP 4
|
||||||
|
101: [0xFFB5], // KP 5
|
||||||
|
102: [0xFFB6], // KP 6
|
||||||
|
103: [0xFFB7], // KP 7
|
||||||
|
104: [0xFFB8], // KP 8
|
||||||
|
105: [0xFFB9], // KP 9
|
||||||
|
106: [0xFFAA], // KP multiply
|
||||||
|
107: [0xFFAB], // KP add
|
||||||
|
109: [0xFFAD], // KP subtract
|
||||||
|
110: [0xFFAE], // KP decimal
|
||||||
|
111: [0xFFAF], // KP divide
|
||||||
112: [0xFFBE], // f1
|
112: [0xFFBE], // f1
|
||||||
113: [0xFFBF], // f2
|
113: [0xFFBF], // f2
|
||||||
114: [0xFFC0], // f3
|
114: [0xFFC0], // f3
|
||||||
@@ -583,8 +599,8 @@ Guacamole.Keyboard = function(element) {
|
|||||||
typedCharacter = String.fromCharCode(parseInt(hex, 16));
|
typedCharacter = String.fromCharCode(parseInt(hex, 16));
|
||||||
}
|
}
|
||||||
|
|
||||||
// If single character, use that as typed character
|
// If single character and not keypad, use that as typed character
|
||||||
else if (identifier.length === 1)
|
else if (identifier.length === 1 && location !== 3)
|
||||||
typedCharacter = identifier;
|
typedCharacter = identifier;
|
||||||
|
|
||||||
// Otherwise, look up corresponding keysym
|
// Otherwise, look up corresponding keysym
|
||||||
|
@@ -100,7 +100,7 @@ public class ExtensionModule extends ServletModule {
|
|||||||
/**
|
/**
|
||||||
* Service for adding and retrieving language resources.
|
* Service for adding and retrieving language resources.
|
||||||
*/
|
*/
|
||||||
private final LanguageResourceService languageResourceService = new LanguageResourceService();
|
private final LanguageResourceService languageResourceService;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Returns the classloader that should be used as the parent classloader
|
* Returns the classloader that should be used as the parent classloader
|
||||||
@@ -139,6 +139,7 @@ public class ExtensionModule extends ServletModule {
|
|||||||
*/
|
*/
|
||||||
public ExtensionModule(Environment environment) {
|
public ExtensionModule(Environment environment) {
|
||||||
this.environment = environment;
|
this.environment = environment;
|
||||||
|
this.languageResourceService = new LanguageResourceService(environment);
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
@@ -36,6 +36,9 @@ import org.codehaus.jackson.JsonNode;
|
|||||||
import org.codehaus.jackson.map.ObjectMapper;
|
import org.codehaus.jackson.map.ObjectMapper;
|
||||||
import org.codehaus.jackson.node.JsonNodeFactory;
|
import org.codehaus.jackson.node.JsonNodeFactory;
|
||||||
import org.codehaus.jackson.node.ObjectNode;
|
import org.codehaus.jackson.node.ObjectNode;
|
||||||
|
import org.glyptodon.guacamole.GuacamoleException;
|
||||||
|
import org.glyptodon.guacamole.environment.Environment;
|
||||||
|
import org.glyptodon.guacamole.net.basic.properties.BasicGuacamoleProperties;
|
||||||
import org.glyptodon.guacamole.net.basic.resource.ByteArrayResource;
|
import org.glyptodon.guacamole.net.basic.resource.ByteArrayResource;
|
||||||
import org.glyptodon.guacamole.net.basic.resource.Resource;
|
import org.glyptodon.guacamole.net.basic.resource.Resource;
|
||||||
import org.glyptodon.guacamole.net.basic.resource.WebApplicationResource;
|
import org.glyptodon.guacamole.net.basic.resource.WebApplicationResource;
|
||||||
@@ -76,6 +79,13 @@ public class LanguageResourceService {
|
|||||||
*/
|
*/
|
||||||
private static final Pattern LANGUAGE_KEY_PATTERN = Pattern.compile(".*/([a-z]+(_[A-Z]+)?)\\.json");
|
private static final Pattern LANGUAGE_KEY_PATTERN = Pattern.compile(".*/([a-z]+(_[A-Z]+)?)\\.json");
|
||||||
|
|
||||||
|
/**
|
||||||
|
* The set of all language keys which are explicitly listed as allowed
|
||||||
|
* within guacamole.properties, or null if all defined languages should be
|
||||||
|
* allowed.
|
||||||
|
*/
|
||||||
|
private final Set<String> allowedLanguages;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Map of all language resources by language key. Language keys are
|
* Map of all language resources by language key. Language keys are
|
||||||
* language and country code pairs, separated by an underscore, like
|
* language and country code pairs, separated by an underscore, like
|
||||||
@@ -86,6 +96,35 @@ public class LanguageResourceService {
|
|||||||
*/
|
*/
|
||||||
private final Map<String, Resource> resources = new HashMap<String, Resource>();
|
private final Map<String, Resource> resources = new HashMap<String, Resource>();
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Creates a new service for tracking and parsing available translations
|
||||||
|
* which reads its configuration from the given environment.
|
||||||
|
*
|
||||||
|
* @param environment
|
||||||
|
* The environment from which the configuration properties of this
|
||||||
|
* service should be read.
|
||||||
|
*/
|
||||||
|
public LanguageResourceService(Environment environment) {
|
||||||
|
|
||||||
|
Set<String> parsedAllowedLanguages;
|
||||||
|
|
||||||
|
// Parse list of available languages from properties
|
||||||
|
try {
|
||||||
|
parsedAllowedLanguages = environment.getProperty(BasicGuacamoleProperties.ALLOWED_LANGUAGES);
|
||||||
|
logger.debug("Available languages will be restricted to: {}", parsedAllowedLanguages);
|
||||||
|
}
|
||||||
|
|
||||||
|
// Warn of failure to parse
|
||||||
|
catch (GuacamoleException e) {
|
||||||
|
parsedAllowedLanguages = null;
|
||||||
|
logger.error("Unable to parse list of allowed languages: {}", e.getMessage());
|
||||||
|
logger.debug("Error parsing list of allowed languages.", e);
|
||||||
|
}
|
||||||
|
|
||||||
|
this.allowedLanguages = parsedAllowedLanguages;
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Derives a language key from the filename within the given path, if
|
* Derives a language key from the filename within the given path, if
|
||||||
* possible. If the filename is not a valid language key, null is returned.
|
* possible. If the filename is not a valid language key, null is returned.
|
||||||
@@ -184,6 +223,31 @@ public class LanguageResourceService {
|
|||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Returns whether a language having the given key should be allowed to be
|
||||||
|
* loaded. If language availability restrictions are imposed through
|
||||||
|
* guacamole.properties, this may return false in some cases. By default,
|
||||||
|
* this function will always return true. Note that just because a language
|
||||||
|
* key is allowed to be loaded does not imply that the language key is
|
||||||
|
* valid.
|
||||||
|
*
|
||||||
|
* @param languageKey
|
||||||
|
* The language key of the language to test.
|
||||||
|
*
|
||||||
|
* @return
|
||||||
|
* true if the given language key should be allowed to be loaded, false
|
||||||
|
* otherwise.
|
||||||
|
*/
|
||||||
|
private boolean isLanguageAllowed(String languageKey) {
|
||||||
|
|
||||||
|
// If no list is provided, all languages are implicitly available
|
||||||
|
if (allowedLanguages == null)
|
||||||
|
return true;
|
||||||
|
|
||||||
|
return allowedLanguages.contains(languageKey);
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Adds or overlays the given language resource, which need not exist in
|
* Adds or overlays the given language resource, which need not exist in
|
||||||
* the ServletContext. If a language resource is already defined for the
|
* the ServletContext. If a language resource is already defined for the
|
||||||
@@ -202,6 +266,12 @@ public class LanguageResourceService {
|
|||||||
*/
|
*/
|
||||||
public void addLanguageResource(String key, Resource resource) {
|
public void addLanguageResource(String key, Resource resource) {
|
||||||
|
|
||||||
|
// Skip loading of language if not allowed
|
||||||
|
if (!isLanguageAllowed(key)) {
|
||||||
|
logger.debug("OMITTING language: \"{}\"", key);
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
// Merge language resources if already defined
|
// Merge language resources if already defined
|
||||||
Resource existing = resources.get(key);
|
Resource existing = resources.get(key);
|
||||||
if (existing != null) {
|
if (existing != null) {
|
||||||
|
@@ -24,6 +24,7 @@ package org.glyptodon.guacamole.net.basic.properties;
|
|||||||
|
|
||||||
import org.glyptodon.guacamole.properties.FileGuacamoleProperty;
|
import org.glyptodon.guacamole.properties.FileGuacamoleProperty;
|
||||||
import org.glyptodon.guacamole.properties.IntegerGuacamoleProperty;
|
import org.glyptodon.guacamole.properties.IntegerGuacamoleProperty;
|
||||||
|
import org.glyptodon.guacamole.properties.StringGuacamoleProperty;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Properties used by the default Guacamole web application.
|
* Properties used by the default Guacamole web application.
|
||||||
@@ -73,4 +74,17 @@ public class BasicGuacamoleProperties {
|
|||||||
|
|
||||||
};
|
};
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Comma-separated list of all allowed languages, where each language is
|
||||||
|
* represented by a language key, such as "en" or "en_US". If specified,
|
||||||
|
* only languages within this list will be listed as available by the REST
|
||||||
|
* service.
|
||||||
|
*/
|
||||||
|
public static final StringSetProperty ALLOWED_LANGUAGES = new StringSetProperty() {
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public String getName() { return "allowed-languages"; }
|
||||||
|
|
||||||
|
};
|
||||||
|
|
||||||
}
|
}
|
||||||
|
@@ -0,0 +1,66 @@
|
|||||||
|
/*
|
||||||
|
* Copyright (C) 2015 Glyptodon LLC
|
||||||
|
*
|
||||||
|
* Permission is hereby granted, free of charge, to any person obtaining a copy
|
||||||
|
* of this software and associated documentation files (the "Software"), to deal
|
||||||
|
* in the Software without restriction, including without limitation the rights
|
||||||
|
* to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
|
||||||
|
* copies of the Software, and to permit persons to whom the Software is
|
||||||
|
* furnished to do so, subject to the following conditions:
|
||||||
|
*
|
||||||
|
* The above copyright notice and this permission notice shall be included in
|
||||||
|
* all copies or substantial portions of the Software.
|
||||||
|
*
|
||||||
|
* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
|
||||||
|
* IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
|
||||||
|
* FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
|
||||||
|
* AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
|
||||||
|
* LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
|
||||||
|
* OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
|
||||||
|
* THE SOFTWARE.
|
||||||
|
*/
|
||||||
|
|
||||||
|
package org.glyptodon.guacamole.net.basic.properties;
|
||||||
|
|
||||||
|
import java.util.Arrays;
|
||||||
|
import java.util.HashSet;
|
||||||
|
import java.util.List;
|
||||||
|
import java.util.Set;
|
||||||
|
import java.util.regex.Pattern;
|
||||||
|
import org.glyptodon.guacamole.GuacamoleException;
|
||||||
|
import org.glyptodon.guacamole.properties.GuacamoleProperty;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* A GuacamoleProperty whose value is a Set of unique Strings. The string value
|
||||||
|
* parsed to produce this set is a comma-delimited list. Duplicate values are
|
||||||
|
* ignored, as is any whitespace following delimiters. To maintain
|
||||||
|
* compatibility with the behavior of Java properties in general, only
|
||||||
|
* whitespace at the beginning of each value is ignored; trailing whitespace
|
||||||
|
* becomes part of the value.
|
||||||
|
*
|
||||||
|
* @author Michael Jumper
|
||||||
|
*/
|
||||||
|
public abstract class StringSetProperty implements GuacamoleProperty<Set<String>> {
|
||||||
|
|
||||||
|
/**
|
||||||
|
* A pattern which matches against the delimiters between values. This is
|
||||||
|
* currently simply a comma and any following whitespace. Parts of the
|
||||||
|
* input string which match this pattern will not be included in the parsed
|
||||||
|
* result.
|
||||||
|
*/
|
||||||
|
private static final Pattern DELIMITER_PATTERN = Pattern.compile(",\\s*");
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public Set<String> parseValue(String values) throws GuacamoleException {
|
||||||
|
|
||||||
|
// If no property provided, return null.
|
||||||
|
if (values == null)
|
||||||
|
return null;
|
||||||
|
|
||||||
|
// Split string into a set of individual values
|
||||||
|
List<String> valueList = Arrays.asList(DELIMITER_PATTERN.split(values));
|
||||||
|
return new HashSet<String>(valueList);
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
@@ -1,38 +0,0 @@
|
|||||||
/*
|
|
||||||
* Copyright (C) 2014 Glyptodon LLC
|
|
||||||
*
|
|
||||||
* Permission is hereby granted, free of charge, to any person obtaining a copy
|
|
||||||
* of this software and associated documentation files (the "Software"), to deal
|
|
||||||
* in the Software without restriction, including without limitation the rights
|
|
||||||
* to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
|
|
||||||
* copies of the Software, and to permit persons to whom the Software is
|
|
||||||
* furnished to do so, subject to the following conditions:
|
|
||||||
*
|
|
||||||
* The above copyright notice and this permission notice shall be included in
|
|
||||||
* all copies or substantial portions of the Software.
|
|
||||||
*
|
|
||||||
* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
|
|
||||||
* IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
|
|
||||||
* FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
|
|
||||||
* AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
|
|
||||||
* LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
|
|
||||||
* OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
|
|
||||||
* THE SOFTWARE.
|
|
||||||
*/
|
|
||||||
|
|
||||||
package org.glyptodon.guacamole.net.basic.rest;
|
|
||||||
|
|
||||||
import java.lang.annotation.ElementType;
|
|
||||||
import java.lang.annotation.Retention;
|
|
||||||
import java.lang.annotation.RetentionPolicy;
|
|
||||||
import java.lang.annotation.Target;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Marks that a method exposes functionality from the Guacamole AuthenticationProvider
|
|
||||||
* using a REST interface.
|
|
||||||
*
|
|
||||||
* @author James Muehlner
|
|
||||||
*/
|
|
||||||
@Retention(RetentionPolicy.RUNTIME)
|
|
||||||
@Target({ElementType.METHOD})
|
|
||||||
public @interface AuthProviderRESTExposure {}
|
|
@@ -1,5 +1,5 @@
|
|||||||
/*
|
/*
|
||||||
* Copyright (C) 2014 Glyptodon LLC
|
* Copyright (C) 2015 Glyptodon LLC
|
||||||
*
|
*
|
||||||
* Permission is hereby granted, free of charge, to any person obtaining a copy
|
* Permission is hereby granted, free of charge, to any person obtaining a copy
|
||||||
* of this software and associated documentation files (the "Software"), to deal
|
* of this software and associated documentation files (the "Software"), to deal
|
||||||
@@ -34,13 +34,16 @@ import org.slf4j.Logger;
|
|||||||
import org.slf4j.LoggerFactory;
|
import org.slf4j.LoggerFactory;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* A method interceptor to wrap some custom exception handling around methods
|
* A method interceptor which wraps custom exception handling around methods
|
||||||
* that expose AuthenticationProvider functionality through the REST interface.
|
* which can throw GuacamoleExceptions and which are exposed through the REST
|
||||||
* Translates various types of GuacamoleExceptions into appropriate HTTP responses.
|
* interface. The various types of GuacamoleExceptions are automatically
|
||||||
*
|
* translated into appropriate HTTP responses, including JSON describing the
|
||||||
|
* error that occurred.
|
||||||
|
*
|
||||||
* @author James Muehlner
|
* @author James Muehlner
|
||||||
|
* @author Michael Jumper
|
||||||
*/
|
*/
|
||||||
public class AuthProviderRESTExceptionWrapper implements MethodInterceptor {
|
public class RESTExceptionWrapper implements MethodInterceptor {
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public Object invoke(MethodInvocation invocation) throws Throwable {
|
public Object invoke(MethodInvocation invocation) throws Throwable {
|
@@ -0,0 +1,109 @@
|
|||||||
|
/*
|
||||||
|
* Copyright (C) 2015 Glyptodon LLC
|
||||||
|
*
|
||||||
|
* Permission is hereby granted, free of charge, to any person obtaining a copy
|
||||||
|
* of this software and associated documentation files (the "Software"), to deal
|
||||||
|
* in the Software without restriction, including without limitation the rights
|
||||||
|
* to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
|
||||||
|
* copies of the Software, and to permit persons to whom the Software is
|
||||||
|
* furnished to do so, subject to the following conditions:
|
||||||
|
*
|
||||||
|
* The above copyright notice and this permission notice shall be included in
|
||||||
|
* all copies or substantial portions of the Software.
|
||||||
|
*
|
||||||
|
* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
|
||||||
|
* IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
|
||||||
|
* FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
|
||||||
|
* AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
|
||||||
|
* LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
|
||||||
|
* OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
|
||||||
|
* THE SOFTWARE.
|
||||||
|
*/
|
||||||
|
|
||||||
|
package org.glyptodon.guacamole.net.basic.rest;
|
||||||
|
|
||||||
|
import com.google.inject.matcher.AbstractMatcher;
|
||||||
|
import java.lang.annotation.Annotation;
|
||||||
|
import java.lang.reflect.Method;
|
||||||
|
import javax.ws.rs.HttpMethod;
|
||||||
|
import org.glyptodon.guacamole.GuacamoleException;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* A Guice Matcher which matches only methods which throw GuacamoleException
|
||||||
|
* (or a subclass thereof) and are explicitly annotated as with an HTTP method
|
||||||
|
* annotation like <code>@GET</code> or <code>@POST</code>. Any method which
|
||||||
|
* throws GuacamoleException and is annotated with an annotation that is
|
||||||
|
* annotated with <code>@HttpMethod</code> will match.
|
||||||
|
*
|
||||||
|
* @author Michael Jumper
|
||||||
|
*/
|
||||||
|
public class RESTMethodMatcher extends AbstractMatcher<Method> {
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Returns whether the given method throws the specified exception type,
|
||||||
|
* including any subclasses of that type.
|
||||||
|
*
|
||||||
|
* @param method
|
||||||
|
* The method to test.
|
||||||
|
*
|
||||||
|
* @param exceptionType
|
||||||
|
* The exception type to test for.
|
||||||
|
*
|
||||||
|
* @return
|
||||||
|
* true if the given method throws an exception of the specified type,
|
||||||
|
* false otherwise.
|
||||||
|
*/
|
||||||
|
private boolean methodThrowsException(Method method,
|
||||||
|
Class<? extends Exception> exceptionType) {
|
||||||
|
|
||||||
|
// Check whether the method throws an exception of the specified type
|
||||||
|
for (Class<?> thrownType : method.getExceptionTypes()) {
|
||||||
|
if (exceptionType.isAssignableFrom(thrownType))
|
||||||
|
return true;
|
||||||
|
}
|
||||||
|
|
||||||
|
// No such exception is declared to be thrown
|
||||||
|
return false;
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Returns whether the given method is annotated as a REST method. A REST
|
||||||
|
* method is annotated with an annotation which is annotated with
|
||||||
|
* <code>@HttpMethod</code>.
|
||||||
|
*
|
||||||
|
* @param method
|
||||||
|
* The method to test.
|
||||||
|
*
|
||||||
|
* @return
|
||||||
|
* true if the given method is annotated as a REST method, false
|
||||||
|
* otherwise.
|
||||||
|
*/
|
||||||
|
private boolean isRESTMethod(Method method) {
|
||||||
|
|
||||||
|
// Check whether the required REST annotations are present
|
||||||
|
for (Annotation annotation : method.getAnnotations()) {
|
||||||
|
|
||||||
|
// A method is a REST method if it is annotated with @HttpMethod
|
||||||
|
Class<? extends Annotation> annotationType = annotation.annotationType();
|
||||||
|
if (annotationType.isAnnotationPresent(HttpMethod.class))
|
||||||
|
return true;
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
// The method is not an HTTP method
|
||||||
|
return false;
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public boolean matches(Method method) {
|
||||||
|
|
||||||
|
// Guacamole REST methods are REST methods which throw
|
||||||
|
// GuacamoleExceptions
|
||||||
|
return isRESTMethod(method)
|
||||||
|
&& methodThrowsException(method, GuacamoleException.class);
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
@@ -46,11 +46,11 @@ public class RESTServletModule extends ServletModule {
|
|||||||
@Override
|
@Override
|
||||||
protected void configureServlets() {
|
protected void configureServlets() {
|
||||||
|
|
||||||
// Bind @AuthProviderRESTExposure annotation
|
// Automatically translate GuacamoleExceptions for REST methods
|
||||||
bindInterceptor(
|
bindInterceptor(
|
||||||
Matchers.any(),
|
Matchers.any(),
|
||||||
Matchers.annotatedWith(AuthProviderRESTExposure.class),
|
new RESTMethodMatcher(),
|
||||||
new AuthProviderRESTExceptionWrapper()
|
new RESTExceptionWrapper()
|
||||||
);
|
);
|
||||||
|
|
||||||
// Bind convenience services used by the REST API
|
// Bind convenience services used by the REST API
|
||||||
|
@@ -47,7 +47,6 @@ import org.glyptodon.guacamole.net.auth.permission.SystemPermission;
|
|||||||
import org.glyptodon.guacamole.net.auth.permission.SystemPermissionSet;
|
import org.glyptodon.guacamole.net.auth.permission.SystemPermissionSet;
|
||||||
import org.glyptodon.guacamole.net.basic.GuacamoleSession;
|
import org.glyptodon.guacamole.net.basic.GuacamoleSession;
|
||||||
import org.glyptodon.guacamole.net.basic.rest.APIPatch;
|
import org.glyptodon.guacamole.net.basic.rest.APIPatch;
|
||||||
import org.glyptodon.guacamole.net.basic.rest.AuthProviderRESTExposure;
|
|
||||||
import org.glyptodon.guacamole.net.basic.rest.ObjectRetrievalService;
|
import org.glyptodon.guacamole.net.basic.rest.ObjectRetrievalService;
|
||||||
import org.glyptodon.guacamole.net.basic.rest.PATCH;
|
import org.glyptodon.guacamole.net.basic.rest.PATCH;
|
||||||
import org.glyptodon.guacamole.net.basic.rest.auth.AuthenticationService;
|
import org.glyptodon.guacamole.net.basic.rest.auth.AuthenticationService;
|
||||||
@@ -107,7 +106,6 @@ public class ActiveConnectionRESTService {
|
|||||||
* If an error is encountered while retrieving active connections.
|
* If an error is encountered while retrieving active connections.
|
||||||
*/
|
*/
|
||||||
@GET
|
@GET
|
||||||
@AuthProviderRESTExposure
|
|
||||||
public Map<String, APIActiveConnection> getActiveConnections(@QueryParam("token") String authToken,
|
public Map<String, APIActiveConnection> getActiveConnections(@QueryParam("token") String authToken,
|
||||||
@PathParam("dataSource") String authProviderIdentifier,
|
@PathParam("dataSource") String authProviderIdentifier,
|
||||||
@QueryParam("permission") List<ObjectPermission.Type> permissions)
|
@QueryParam("permission") List<ObjectPermission.Type> permissions)
|
||||||
@@ -166,7 +164,6 @@ public class ActiveConnectionRESTService {
|
|||||||
* If an error occurs while deleting the active connections.
|
* If an error occurs while deleting the active connections.
|
||||||
*/
|
*/
|
||||||
@PATCH
|
@PATCH
|
||||||
@AuthProviderRESTExposure
|
|
||||||
public void patchTunnels(@QueryParam("token") String authToken,
|
public void patchTunnels(@QueryParam("token") String authToken,
|
||||||
@PathParam("dataSource") String authProviderIdentifier,
|
@PathParam("dataSource") String authProviderIdentifier,
|
||||||
List<APIPatch<String>> patches) throws GuacamoleException {
|
List<APIPatch<String>> patches) throws GuacamoleException {
|
||||||
|
@@ -39,6 +39,7 @@ import javax.ws.rs.core.MediaType;
|
|||||||
import javax.ws.rs.core.MultivaluedMap;
|
import javax.ws.rs.core.MultivaluedMap;
|
||||||
import javax.xml.bind.DatatypeConverter;
|
import javax.xml.bind.DatatypeConverter;
|
||||||
import org.glyptodon.guacamole.GuacamoleException;
|
import org.glyptodon.guacamole.GuacamoleException;
|
||||||
|
import org.glyptodon.guacamole.GuacamoleResourceNotFoundException;
|
||||||
import org.glyptodon.guacamole.GuacamoleSecurityException;
|
import org.glyptodon.guacamole.GuacamoleSecurityException;
|
||||||
import org.glyptodon.guacamole.environment.Environment;
|
import org.glyptodon.guacamole.environment.Environment;
|
||||||
import org.glyptodon.guacamole.net.auth.AuthenticatedUser;
|
import org.glyptodon.guacamole.net.auth.AuthenticatedUser;
|
||||||
@@ -49,10 +50,7 @@ import org.glyptodon.guacamole.net.auth.credentials.CredentialsInfo;
|
|||||||
import org.glyptodon.guacamole.net.auth.credentials.GuacamoleCredentialsException;
|
import org.glyptodon.guacamole.net.auth.credentials.GuacamoleCredentialsException;
|
||||||
import org.glyptodon.guacamole.net.auth.credentials.GuacamoleInvalidCredentialsException;
|
import org.glyptodon.guacamole.net.auth.credentials.GuacamoleInvalidCredentialsException;
|
||||||
import org.glyptodon.guacamole.net.basic.GuacamoleSession;
|
import org.glyptodon.guacamole.net.basic.GuacamoleSession;
|
||||||
import org.glyptodon.guacamole.net.basic.rest.APIError;
|
|
||||||
import org.glyptodon.guacamole.net.basic.rest.APIRequest;
|
import org.glyptodon.guacamole.net.basic.rest.APIRequest;
|
||||||
import org.glyptodon.guacamole.net.basic.rest.AuthProviderRESTExposure;
|
|
||||||
import org.glyptodon.guacamole.net.basic.rest.APIException;
|
|
||||||
import org.slf4j.Logger;
|
import org.slf4j.Logger;
|
||||||
import org.slf4j.LoggerFactory;
|
import org.slf4j.LoggerFactory;
|
||||||
|
|
||||||
@@ -464,7 +462,6 @@ public class TokenRESTService {
|
|||||||
* If an error prevents successful authentication.
|
* If an error prevents successful authentication.
|
||||||
*/
|
*/
|
||||||
@POST
|
@POST
|
||||||
@AuthProviderRESTExposure
|
|
||||||
public APIAuthenticationResult createToken(@FormParam("username") String username,
|
public APIAuthenticationResult createToken(@FormParam("username") String username,
|
||||||
@FormParam("password") String password,
|
@FormParam("password") String password,
|
||||||
@FormParam("token") String token,
|
@FormParam("token") String token,
|
||||||
@@ -523,16 +520,20 @@ public class TokenRESTService {
|
|||||||
* Invalidates a specific auth token, effectively logging out the associated
|
* Invalidates a specific auth token, effectively logging out the associated
|
||||||
* user.
|
* user.
|
||||||
*
|
*
|
||||||
* @param authToken The token being invalidated.
|
* @param authToken
|
||||||
|
* The token being invalidated.
|
||||||
|
*
|
||||||
|
* @throws GuacamoleException
|
||||||
|
* If the specified token does not exist.
|
||||||
*/
|
*/
|
||||||
@DELETE
|
@DELETE
|
||||||
@Path("/{token}")
|
@Path("/{token}")
|
||||||
@AuthProviderRESTExposure
|
public void invalidateToken(@PathParam("token") String authToken)
|
||||||
public void invalidateToken(@PathParam("token") String authToken) {
|
throws GuacamoleException {
|
||||||
|
|
||||||
GuacamoleSession session = tokenSessionMap.remove(authToken);
|
GuacamoleSession session = tokenSessionMap.remove(authToken);
|
||||||
if (session == null)
|
if (session == null)
|
||||||
throw new APIException(APIError.Type.NOT_FOUND, "No such token.");
|
throw new GuacamoleResourceNotFoundException("No such token.");
|
||||||
|
|
||||||
session.invalidate();
|
session.invalidate();
|
||||||
|
|
||||||
|
@@ -49,7 +49,6 @@ import org.glyptodon.guacamole.net.auth.permission.ObjectPermissionSet;
|
|||||||
import org.glyptodon.guacamole.net.auth.permission.SystemPermission;
|
import org.glyptodon.guacamole.net.auth.permission.SystemPermission;
|
||||||
import org.glyptodon.guacamole.net.auth.permission.SystemPermissionSet;
|
import org.glyptodon.guacamole.net.auth.permission.SystemPermissionSet;
|
||||||
import org.glyptodon.guacamole.net.basic.GuacamoleSession;
|
import org.glyptodon.guacamole.net.basic.GuacamoleSession;
|
||||||
import org.glyptodon.guacamole.net.basic.rest.AuthProviderRESTExposure;
|
|
||||||
import org.glyptodon.guacamole.net.basic.rest.ObjectRetrievalService;
|
import org.glyptodon.guacamole.net.basic.rest.ObjectRetrievalService;
|
||||||
import org.glyptodon.guacamole.net.basic.rest.auth.AuthenticationService;
|
import org.glyptodon.guacamole.net.basic.rest.auth.AuthenticationService;
|
||||||
import org.glyptodon.guacamole.net.basic.rest.history.APIConnectionRecord;
|
import org.glyptodon.guacamole.net.basic.rest.history.APIConnectionRecord;
|
||||||
@@ -106,7 +105,6 @@ public class ConnectionRESTService {
|
|||||||
*/
|
*/
|
||||||
@GET
|
@GET
|
||||||
@Path("/{connectionID}")
|
@Path("/{connectionID}")
|
||||||
@AuthProviderRESTExposure
|
|
||||||
public APIConnection getConnection(@QueryParam("token") String authToken,
|
public APIConnection getConnection(@QueryParam("token") String authToken,
|
||||||
@PathParam("dataSource") String authProviderIdentifier,
|
@PathParam("dataSource") String authProviderIdentifier,
|
||||||
@PathParam("connectionID") String connectionID)
|
@PathParam("connectionID") String connectionID)
|
||||||
@@ -142,7 +140,6 @@ public class ConnectionRESTService {
|
|||||||
*/
|
*/
|
||||||
@GET
|
@GET
|
||||||
@Path("/{connectionID}/parameters")
|
@Path("/{connectionID}/parameters")
|
||||||
@AuthProviderRESTExposure
|
|
||||||
public Map<String, String> getConnectionParameters(@QueryParam("token") String authToken,
|
public Map<String, String> getConnectionParameters(@QueryParam("token") String authToken,
|
||||||
@PathParam("dataSource") String authProviderIdentifier,
|
@PathParam("dataSource") String authProviderIdentifier,
|
||||||
@PathParam("connectionID") String connectionID)
|
@PathParam("connectionID") String connectionID)
|
||||||
@@ -196,7 +193,6 @@ public class ConnectionRESTService {
|
|||||||
*/
|
*/
|
||||||
@GET
|
@GET
|
||||||
@Path("/{connectionID}/history")
|
@Path("/{connectionID}/history")
|
||||||
@AuthProviderRESTExposure
|
|
||||||
public List<APIConnectionRecord> getConnectionHistory(@QueryParam("token") String authToken,
|
public List<APIConnectionRecord> getConnectionHistory(@QueryParam("token") String authToken,
|
||||||
@PathParam("dataSource") String authProviderIdentifier,
|
@PathParam("dataSource") String authProviderIdentifier,
|
||||||
@PathParam("connectionID") String connectionID)
|
@PathParam("connectionID") String connectionID)
|
||||||
@@ -236,7 +232,6 @@ public class ConnectionRESTService {
|
|||||||
*/
|
*/
|
||||||
@DELETE
|
@DELETE
|
||||||
@Path("/{connectionID}")
|
@Path("/{connectionID}")
|
||||||
@AuthProviderRESTExposure
|
|
||||||
public void deleteConnection(@QueryParam("token") String authToken,
|
public void deleteConnection(@QueryParam("token") String authToken,
|
||||||
@PathParam("dataSource") String authProviderIdentifier,
|
@PathParam("dataSource") String authProviderIdentifier,
|
||||||
@PathParam("connectionID") String connectionID)
|
@PathParam("connectionID") String connectionID)
|
||||||
@@ -276,7 +271,6 @@ public class ConnectionRESTService {
|
|||||||
*/
|
*/
|
||||||
@POST
|
@POST
|
||||||
@Produces(MediaType.TEXT_PLAIN)
|
@Produces(MediaType.TEXT_PLAIN)
|
||||||
@AuthProviderRESTExposure
|
|
||||||
public String createConnection(@QueryParam("token") String authToken,
|
public String createConnection(@QueryParam("token") String authToken,
|
||||||
@PathParam("dataSource") String authProviderIdentifier,
|
@PathParam("dataSource") String authProviderIdentifier,
|
||||||
APIConnection connection) throws GuacamoleException {
|
APIConnection connection) throws GuacamoleException {
|
||||||
@@ -321,7 +315,6 @@ public class ConnectionRESTService {
|
|||||||
*/
|
*/
|
||||||
@PUT
|
@PUT
|
||||||
@Path("/{connectionID}")
|
@Path("/{connectionID}")
|
||||||
@AuthProviderRESTExposure
|
|
||||||
public void updateConnection(@QueryParam("token") String authToken,
|
public void updateConnection(@QueryParam("token") String authToken,
|
||||||
@PathParam("dataSource") String authProviderIdentifier,
|
@PathParam("dataSource") String authProviderIdentifier,
|
||||||
@PathParam("connectionID") String connectionID,
|
@PathParam("connectionID") String connectionID,
|
||||||
|
@@ -41,7 +41,6 @@ import org.glyptodon.guacamole.net.auth.Directory;
|
|||||||
import org.glyptodon.guacamole.net.auth.UserContext;
|
import org.glyptodon.guacamole.net.auth.UserContext;
|
||||||
import org.glyptodon.guacamole.net.auth.permission.ObjectPermission;
|
import org.glyptodon.guacamole.net.auth.permission.ObjectPermission;
|
||||||
import org.glyptodon.guacamole.net.basic.GuacamoleSession;
|
import org.glyptodon.guacamole.net.basic.GuacamoleSession;
|
||||||
import org.glyptodon.guacamole.net.basic.rest.AuthProviderRESTExposure;
|
|
||||||
import org.glyptodon.guacamole.net.basic.rest.ObjectRetrievalService;
|
import org.glyptodon.guacamole.net.basic.rest.ObjectRetrievalService;
|
||||||
import org.glyptodon.guacamole.net.basic.rest.auth.AuthenticationService;
|
import org.glyptodon.guacamole.net.basic.rest.auth.AuthenticationService;
|
||||||
import org.slf4j.Logger;
|
import org.slf4j.Logger;
|
||||||
@@ -96,7 +95,6 @@ public class ConnectionGroupRESTService {
|
|||||||
*/
|
*/
|
||||||
@GET
|
@GET
|
||||||
@Path("/{connectionGroupID}")
|
@Path("/{connectionGroupID}")
|
||||||
@AuthProviderRESTExposure
|
|
||||||
public APIConnectionGroup getConnectionGroup(@QueryParam("token") String authToken,
|
public APIConnectionGroup getConnectionGroup(@QueryParam("token") String authToken,
|
||||||
@PathParam("dataSource") String authProviderIdentifier,
|
@PathParam("dataSource") String authProviderIdentifier,
|
||||||
@PathParam("connectionGroupID") String connectionGroupID)
|
@PathParam("connectionGroupID") String connectionGroupID)
|
||||||
@@ -138,7 +136,6 @@ public class ConnectionGroupRESTService {
|
|||||||
*/
|
*/
|
||||||
@GET
|
@GET
|
||||||
@Path("/{connectionGroupID}/tree")
|
@Path("/{connectionGroupID}/tree")
|
||||||
@AuthProviderRESTExposure
|
|
||||||
public APIConnectionGroup getConnectionGroupTree(@QueryParam("token") String authToken,
|
public APIConnectionGroup getConnectionGroupTree(@QueryParam("token") String authToken,
|
||||||
@PathParam("dataSource") String authProviderIdentifier,
|
@PathParam("dataSource") String authProviderIdentifier,
|
||||||
@PathParam("connectionGroupID") String connectionGroupID,
|
@PathParam("connectionGroupID") String connectionGroupID,
|
||||||
@@ -176,7 +173,6 @@ public class ConnectionGroupRESTService {
|
|||||||
*/
|
*/
|
||||||
@DELETE
|
@DELETE
|
||||||
@Path("/{connectionGroupID}")
|
@Path("/{connectionGroupID}")
|
||||||
@AuthProviderRESTExposure
|
|
||||||
public void deleteConnectionGroup(@QueryParam("token") String authToken,
|
public void deleteConnectionGroup(@QueryParam("token") String authToken,
|
||||||
@PathParam("dataSource") String authProviderIdentifier,
|
@PathParam("dataSource") String authProviderIdentifier,
|
||||||
@PathParam("connectionGroupID") String connectionGroupID)
|
@PathParam("connectionGroupID") String connectionGroupID)
|
||||||
@@ -218,7 +214,6 @@ public class ConnectionGroupRESTService {
|
|||||||
*/
|
*/
|
||||||
@POST
|
@POST
|
||||||
@Produces(MediaType.TEXT_PLAIN)
|
@Produces(MediaType.TEXT_PLAIN)
|
||||||
@AuthProviderRESTExposure
|
|
||||||
public String createConnectionGroup(@QueryParam("token") String authToken,
|
public String createConnectionGroup(@QueryParam("token") String authToken,
|
||||||
@PathParam("dataSource") String authProviderIdentifier,
|
@PathParam("dataSource") String authProviderIdentifier,
|
||||||
APIConnectionGroup connectionGroup) throws GuacamoleException {
|
APIConnectionGroup connectionGroup) throws GuacamoleException {
|
||||||
@@ -263,7 +258,6 @@ public class ConnectionGroupRESTService {
|
|||||||
*/
|
*/
|
||||||
@PUT
|
@PUT
|
||||||
@Path("/{connectionGroupID}")
|
@Path("/{connectionGroupID}")
|
||||||
@AuthProviderRESTExposure
|
|
||||||
public void updateConnectionGroup(@QueryParam("token") String authToken,
|
public void updateConnectionGroup(@QueryParam("token") String authToken,
|
||||||
@PathParam("dataSource") String authProviderIdentifier,
|
@PathParam("dataSource") String authProviderIdentifier,
|
||||||
@PathParam("connectionGroupID") String connectionGroupID,
|
@PathParam("connectionGroupID") String connectionGroupID,
|
||||||
|
@@ -38,7 +38,6 @@ import org.glyptodon.guacamole.environment.LocalEnvironment;
|
|||||||
import org.glyptodon.guacamole.form.Form;
|
import org.glyptodon.guacamole.form.Form;
|
||||||
import org.glyptodon.guacamole.net.auth.UserContext;
|
import org.glyptodon.guacamole.net.auth.UserContext;
|
||||||
import org.glyptodon.guacamole.net.basic.GuacamoleSession;
|
import org.glyptodon.guacamole.net.basic.GuacamoleSession;
|
||||||
import org.glyptodon.guacamole.net.basic.rest.AuthProviderRESTExposure;
|
|
||||||
import org.glyptodon.guacamole.net.basic.rest.ObjectRetrievalService;
|
import org.glyptodon.guacamole.net.basic.rest.ObjectRetrievalService;
|
||||||
import org.glyptodon.guacamole.net.basic.rest.auth.AuthenticationService;
|
import org.glyptodon.guacamole.net.basic.rest.auth.AuthenticationService;
|
||||||
import org.glyptodon.guacamole.protocols.ProtocolInfo;
|
import org.glyptodon.guacamole.protocols.ProtocolInfo;
|
||||||
@@ -86,7 +85,6 @@ public class SchemaRESTService {
|
|||||||
*/
|
*/
|
||||||
@GET
|
@GET
|
||||||
@Path("/users/attributes")
|
@Path("/users/attributes")
|
||||||
@AuthProviderRESTExposure
|
|
||||||
public Collection<Form> getUserAttributes(@QueryParam("token") String authToken,
|
public Collection<Form> getUserAttributes(@QueryParam("token") String authToken,
|
||||||
@PathParam("dataSource") String authProviderIdentifier)
|
@PathParam("dataSource") String authProviderIdentifier)
|
||||||
throws GuacamoleException {
|
throws GuacamoleException {
|
||||||
@@ -118,7 +116,6 @@ public class SchemaRESTService {
|
|||||||
*/
|
*/
|
||||||
@GET
|
@GET
|
||||||
@Path("/connections/attributes")
|
@Path("/connections/attributes")
|
||||||
@AuthProviderRESTExposure
|
|
||||||
public Collection<Form> getConnectionAttributes(@QueryParam("token") String authToken,
|
public Collection<Form> getConnectionAttributes(@QueryParam("token") String authToken,
|
||||||
@PathParam("dataSource") String authProviderIdentifier)
|
@PathParam("dataSource") String authProviderIdentifier)
|
||||||
throws GuacamoleException {
|
throws GuacamoleException {
|
||||||
@@ -151,7 +148,6 @@ public class SchemaRESTService {
|
|||||||
*/
|
*/
|
||||||
@GET
|
@GET
|
||||||
@Path("/connectionGroups/attributes")
|
@Path("/connectionGroups/attributes")
|
||||||
@AuthProviderRESTExposure
|
|
||||||
public Collection<Form> getConnectionGroupAttributes(@QueryParam("token") String authToken,
|
public Collection<Form> getConnectionGroupAttributes(@QueryParam("token") String authToken,
|
||||||
@PathParam("dataSource") String authProviderIdentifier)
|
@PathParam("dataSource") String authProviderIdentifier)
|
||||||
throws GuacamoleException {
|
throws GuacamoleException {
|
||||||
@@ -186,7 +182,6 @@ public class SchemaRESTService {
|
|||||||
*/
|
*/
|
||||||
@GET
|
@GET
|
||||||
@Path("/protocols")
|
@Path("/protocols")
|
||||||
@AuthProviderRESTExposure
|
|
||||||
public Map<String, ProtocolInfo> getProtocols(@QueryParam("token") String authToken,
|
public Map<String, ProtocolInfo> getProtocols(@QueryParam("token") String authToken,
|
||||||
@PathParam("dataSource") String authProviderIdentifier)
|
@PathParam("dataSource") String authProviderIdentifier)
|
||||||
throws GuacamoleException {
|
throws GuacamoleException {
|
||||||
|
@@ -39,8 +39,10 @@ import javax.ws.rs.Produces;
|
|||||||
import javax.ws.rs.QueryParam;
|
import javax.ws.rs.QueryParam;
|
||||||
import javax.ws.rs.core.Context;
|
import javax.ws.rs.core.Context;
|
||||||
import javax.ws.rs.core.MediaType;
|
import javax.ws.rs.core.MediaType;
|
||||||
|
import org.glyptodon.guacamole.GuacamoleClientException;
|
||||||
import org.glyptodon.guacamole.GuacamoleException;
|
import org.glyptodon.guacamole.GuacamoleException;
|
||||||
import org.glyptodon.guacamole.GuacamoleResourceNotFoundException;
|
import org.glyptodon.guacamole.GuacamoleResourceNotFoundException;
|
||||||
|
import org.glyptodon.guacamole.GuacamoleSecurityException;
|
||||||
import org.glyptodon.guacamole.net.auth.AuthenticationProvider;
|
import org.glyptodon.guacamole.net.auth.AuthenticationProvider;
|
||||||
import org.glyptodon.guacamole.net.auth.Credentials;
|
import org.glyptodon.guacamole.net.auth.Credentials;
|
||||||
import org.glyptodon.guacamole.net.auth.Directory;
|
import org.glyptodon.guacamole.net.auth.Directory;
|
||||||
@@ -53,12 +55,9 @@ import org.glyptodon.guacamole.net.auth.permission.Permission;
|
|||||||
import org.glyptodon.guacamole.net.auth.permission.SystemPermission;
|
import org.glyptodon.guacamole.net.auth.permission.SystemPermission;
|
||||||
import org.glyptodon.guacamole.net.auth.permission.SystemPermissionSet;
|
import org.glyptodon.guacamole.net.auth.permission.SystemPermissionSet;
|
||||||
import org.glyptodon.guacamole.net.basic.GuacamoleSession;
|
import org.glyptodon.guacamole.net.basic.GuacamoleSession;
|
||||||
import org.glyptodon.guacamole.net.basic.rest.APIError;
|
|
||||||
import org.glyptodon.guacamole.net.basic.rest.APIPatch;
|
import org.glyptodon.guacamole.net.basic.rest.APIPatch;
|
||||||
import static org.glyptodon.guacamole.net.basic.rest.APIPatch.Operation.add;
|
import static org.glyptodon.guacamole.net.basic.rest.APIPatch.Operation.add;
|
||||||
import static org.glyptodon.guacamole.net.basic.rest.APIPatch.Operation.remove;
|
import static org.glyptodon.guacamole.net.basic.rest.APIPatch.Operation.remove;
|
||||||
import org.glyptodon.guacamole.net.basic.rest.AuthProviderRESTExposure;
|
|
||||||
import org.glyptodon.guacamole.net.basic.rest.APIException;
|
|
||||||
import org.glyptodon.guacamole.net.basic.rest.ObjectRetrievalService;
|
import org.glyptodon.guacamole.net.basic.rest.ObjectRetrievalService;
|
||||||
import org.glyptodon.guacamole.net.basic.rest.PATCH;
|
import org.glyptodon.guacamole.net.basic.rest.PATCH;
|
||||||
import org.glyptodon.guacamole.net.basic.rest.auth.AuthenticationService;
|
import org.glyptodon.guacamole.net.basic.rest.auth.AuthenticationService;
|
||||||
@@ -150,7 +149,6 @@ public class UserRESTService {
|
|||||||
* If an error is encountered while retrieving users.
|
* If an error is encountered while retrieving users.
|
||||||
*/
|
*/
|
||||||
@GET
|
@GET
|
||||||
@AuthProviderRESTExposure
|
|
||||||
public List<APIUser> getUsers(@QueryParam("token") String authToken,
|
public List<APIUser> getUsers(@QueryParam("token") String authToken,
|
||||||
@PathParam("dataSource") String authProviderIdentifier,
|
@PathParam("dataSource") String authProviderIdentifier,
|
||||||
@QueryParam("permission") List<ObjectPermission.Type> permissions)
|
@QueryParam("permission") List<ObjectPermission.Type> permissions)
|
||||||
@@ -205,7 +203,6 @@ public class UserRESTService {
|
|||||||
*/
|
*/
|
||||||
@GET
|
@GET
|
||||||
@Path("/{username}")
|
@Path("/{username}")
|
||||||
@AuthProviderRESTExposure
|
|
||||||
public APIUser getUser(@QueryParam("token") String authToken,
|
public APIUser getUser(@QueryParam("token") String authToken,
|
||||||
@PathParam("dataSource") String authProviderIdentifier,
|
@PathParam("dataSource") String authProviderIdentifier,
|
||||||
@PathParam("username") String username)
|
@PathParam("username") String username)
|
||||||
@@ -241,7 +238,6 @@ public class UserRESTService {
|
|||||||
*/
|
*/
|
||||||
@POST
|
@POST
|
||||||
@Produces(MediaType.TEXT_PLAIN)
|
@Produces(MediaType.TEXT_PLAIN)
|
||||||
@AuthProviderRESTExposure
|
|
||||||
public String createUser(@QueryParam("token") String authToken,
|
public String createUser(@QueryParam("token") String authToken,
|
||||||
@PathParam("dataSource") String authProviderIdentifier, APIUser user)
|
@PathParam("dataSource") String authProviderIdentifier, APIUser user)
|
||||||
throws GuacamoleException {
|
throws GuacamoleException {
|
||||||
@@ -285,7 +281,6 @@ public class UserRESTService {
|
|||||||
*/
|
*/
|
||||||
@PUT
|
@PUT
|
||||||
@Path("/{username}")
|
@Path("/{username}")
|
||||||
@AuthProviderRESTExposure
|
|
||||||
public void updateUser(@QueryParam("token") String authToken,
|
public void updateUser(@QueryParam("token") String authToken,
|
||||||
@PathParam("dataSource") String authProviderIdentifier,
|
@PathParam("dataSource") String authProviderIdentifier,
|
||||||
@PathParam("username") String username, APIUser user)
|
@PathParam("username") String username, APIUser user)
|
||||||
@@ -299,14 +294,11 @@ public class UserRESTService {
|
|||||||
|
|
||||||
// Validate data and path are sane
|
// Validate data and path are sane
|
||||||
if (!user.getUsername().equals(username))
|
if (!user.getUsername().equals(username))
|
||||||
throw new APIException(APIError.Type.BAD_REQUEST,
|
throw new GuacamoleClientException("Username in path does not match username provided JSON data.");
|
||||||
"Username in path does not match username provided JSON data.");
|
|
||||||
|
|
||||||
// A user may not use this endpoint to modify himself
|
// A user may not use this endpoint to modify himself
|
||||||
if (userContext.self().getIdentifier().equals(user.getUsername())) {
|
if (userContext.self().getIdentifier().equals(user.getUsername()))
|
||||||
throw new APIException(APIError.Type.PERMISSION_DENIED,
|
throw new GuacamoleSecurityException("Permission denied.");
|
||||||
"Permission denied.");
|
|
||||||
}
|
|
||||||
|
|
||||||
// Get the user
|
// Get the user
|
||||||
User existingUser = retrievalService.retrieveUser(userContext, username);
|
User existingUser = retrievalService.retrieveUser(userContext, username);
|
||||||
@@ -349,7 +341,6 @@ public class UserRESTService {
|
|||||||
*/
|
*/
|
||||||
@PUT
|
@PUT
|
||||||
@Path("/{username}/password")
|
@Path("/{username}/password")
|
||||||
@AuthProviderRESTExposure
|
|
||||||
public void updatePassword(@QueryParam("token") String authToken,
|
public void updatePassword(@QueryParam("token") String authToken,
|
||||||
@PathParam("dataSource") String authProviderIdentifier,
|
@PathParam("dataSource") String authProviderIdentifier,
|
||||||
@PathParam("username") String username,
|
@PathParam("username") String username,
|
||||||
@@ -369,18 +360,15 @@ public class UserRESTService {
|
|||||||
// Verify that the old password was correct
|
// Verify that the old password was correct
|
||||||
try {
|
try {
|
||||||
AuthenticationProvider authProvider = userContext.getAuthenticationProvider();
|
AuthenticationProvider authProvider = userContext.getAuthenticationProvider();
|
||||||
if (authProvider.authenticateUser(credentials) == null) {
|
if (authProvider.authenticateUser(credentials) == null)
|
||||||
throw new APIException(APIError.Type.PERMISSION_DENIED,
|
throw new GuacamoleSecurityException("Permission denied.");
|
||||||
"Permission denied.");
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
||||||
// Pass through any credentials exceptions as simple permission denied
|
// Pass through any credentials exceptions as simple permission denied
|
||||||
catch (GuacamoleCredentialsException e) {
|
catch (GuacamoleCredentialsException e) {
|
||||||
throw new APIException(APIError.Type.PERMISSION_DENIED,
|
throw new GuacamoleSecurityException("Permission denied.");
|
||||||
"Permission denied.");
|
|
||||||
}
|
}
|
||||||
|
|
||||||
// Get the user directory
|
// Get the user directory
|
||||||
Directory<User> userDirectory = userContext.getUserDirectory();
|
Directory<User> userDirectory = userContext.getUserDirectory();
|
||||||
|
|
||||||
@@ -414,7 +402,6 @@ public class UserRESTService {
|
|||||||
*/
|
*/
|
||||||
@DELETE
|
@DELETE
|
||||||
@Path("/{username}")
|
@Path("/{username}")
|
||||||
@AuthProviderRESTExposure
|
|
||||||
public void deleteUser(@QueryParam("token") String authToken,
|
public void deleteUser(@QueryParam("token") String authToken,
|
||||||
@PathParam("dataSource") String authProviderIdentifier,
|
@PathParam("dataSource") String authProviderIdentifier,
|
||||||
@PathParam("username") String username)
|
@PathParam("username") String username)
|
||||||
@@ -458,7 +445,6 @@ public class UserRESTService {
|
|||||||
*/
|
*/
|
||||||
@GET
|
@GET
|
||||||
@Path("/{username}/permissions")
|
@Path("/{username}/permissions")
|
||||||
@AuthProviderRESTExposure
|
|
||||||
public APIPermissionSet getPermissions(@QueryParam("token") String authToken,
|
public APIPermissionSet getPermissions(@QueryParam("token") String authToken,
|
||||||
@PathParam("dataSource") String authProviderIdentifier,
|
@PathParam("dataSource") String authProviderIdentifier,
|
||||||
@PathParam("username") String username)
|
@PathParam("username") String username)
|
||||||
@@ -499,11 +485,14 @@ public class UserRESTService {
|
|||||||
*
|
*
|
||||||
* @param permission
|
* @param permission
|
||||||
* The permission being added or removed from the set.
|
* The permission being added or removed from the set.
|
||||||
|
*
|
||||||
|
* @throws GuacamoleException
|
||||||
|
* If the requested patch operation is not supported.
|
||||||
*/
|
*/
|
||||||
private <PermissionType extends Permission> void updatePermissionSet(
|
private <PermissionType extends Permission> void updatePermissionSet(
|
||||||
APIPatch.Operation operation,
|
APIPatch.Operation operation,
|
||||||
PermissionSetPatch<PermissionType> permissionSetPatch,
|
PermissionSetPatch<PermissionType> permissionSetPatch,
|
||||||
PermissionType permission) {
|
PermissionType permission) throws GuacamoleException {
|
||||||
|
|
||||||
// Add or remove permission based on operation
|
// Add or remove permission based on operation
|
||||||
switch (operation) {
|
switch (operation) {
|
||||||
@@ -520,8 +509,7 @@ public class UserRESTService {
|
|||||||
|
|
||||||
// Unsupported patch operation
|
// Unsupported patch operation
|
||||||
default:
|
default:
|
||||||
throw new APIException(APIError.Type.BAD_REQUEST,
|
throw new GuacamoleClientException("Unsupported patch operation: \"" + operation + "\"");
|
||||||
"Unsupported patch operation: \"" + operation + "\"");
|
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -553,7 +541,6 @@ public class UserRESTService {
|
|||||||
*/
|
*/
|
||||||
@PATCH
|
@PATCH
|
||||||
@Path("/{username}/permissions")
|
@Path("/{username}/permissions")
|
||||||
@AuthProviderRESTExposure
|
|
||||||
public void patchPermissions(@QueryParam("token") String authToken,
|
public void patchPermissions(@QueryParam("token") String authToken,
|
||||||
@PathParam("dataSource") String authProviderIdentifier,
|
@PathParam("dataSource") String authProviderIdentifier,
|
||||||
@PathParam("username") String username,
|
@PathParam("username") String username,
|
||||||
@@ -645,7 +632,7 @@ public class UserRESTService {
|
|||||||
|
|
||||||
// Otherwise, the path is not supported
|
// Otherwise, the path is not supported
|
||||||
else
|
else
|
||||||
throw new APIException(APIError.Type.BAD_REQUEST, "Unsupported patch path: \"" + path + "\"");
|
throw new GuacamoleClientException("Unsupported patch path: \"" + path + "\"");
|
||||||
|
|
||||||
} // end for each patch operation
|
} // end for each patch operation
|
||||||
|
|
||||||
|
@@ -1,5 +1,5 @@
|
|||||||
/*
|
/*
|
||||||
* Copyright (C) 2014 Glyptodon LLC
|
* Copyright (C) 2015 Glyptodon LLC
|
||||||
*
|
*
|
||||||
* Permission is hereby granted, free of charge, to any person obtaining a copy
|
* Permission is hereby granted, free of charge, to any person obtaining a copy
|
||||||
* of this software and associated documentation files (the "Software"), to deal
|
* of this software and associated documentation files (the "Software"), to deal
|
||||||
@@ -31,82 +31,11 @@ angular.module('client').factory('guacAudio', [function guacAudio() {
|
|||||||
return new (function() {
|
return new (function() {
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Array of codecs to test.
|
* Array of all supported audio mimetypes.
|
||||||
*
|
*
|
||||||
* @type String[]
|
* @type String[]
|
||||||
*/
|
*/
|
||||||
var codecs = [
|
this.supported = Guacamole.AudioPlayer.getSupportedTypes();
|
||||||
'audio/ogg; codecs="vorbis"',
|
|
||||||
'audio/mp4; codecs="mp4a.40.5"',
|
|
||||||
'audio/mpeg; codecs="mp3"',
|
|
||||||
'audio/webm; codecs="vorbis"',
|
|
||||||
'audio/wav; codecs=1'
|
|
||||||
];
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Array of all codecs that are reported as "probably" supported.
|
|
||||||
*
|
|
||||||
* @type String[]
|
|
||||||
*/
|
|
||||||
var probably_supported = [];
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Array of all codecs that are reported as "maybe" supported.
|
|
||||||
*
|
|
||||||
* @type String[]
|
|
||||||
*/
|
|
||||||
var maybe_supported = [];
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Internal audio element for the sake of testing codec support. If
|
|
||||||
* audio is explicitly not supported by the browser, this will instead
|
|
||||||
* be null.
|
|
||||||
*
|
|
||||||
* @type Audio
|
|
||||||
*/
|
|
||||||
var audio = null;
|
|
||||||
|
|
||||||
// Attempt to create audio element
|
|
||||||
try {
|
|
||||||
audio = new Audio();
|
|
||||||
}
|
|
||||||
catch (e) {
|
|
||||||
// If creation fails, allow audio to remain null
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Array of all supported audio mimetypes, ordered by liklihood of
|
|
||||||
* working.
|
|
||||||
*/
|
|
||||||
this.supported = [];
|
|
||||||
|
|
||||||
// Build array of supported audio formats (if audio supported at all)
|
|
||||||
if (audio) {
|
|
||||||
codecs.forEach(function(mimetype) {
|
|
||||||
|
|
||||||
var support_level = audio.canPlayType(mimetype);
|
|
||||||
|
|
||||||
// Trim semicolon and trailer
|
|
||||||
var semicolon = mimetype.indexOf(";");
|
|
||||||
if (semicolon !== -1)
|
|
||||||
mimetype = mimetype.substring(0, semicolon);
|
|
||||||
|
|
||||||
// Partition by probably/maybe
|
|
||||||
if (support_level === "probably")
|
|
||||||
probably_supported.push(mimetype);
|
|
||||||
else if (support_level === "maybe")
|
|
||||||
maybe_supported.push(mimetype);
|
|
||||||
|
|
||||||
});
|
|
||||||
|
|
||||||
// Add probably supported types first
|
|
||||||
Array.prototype.push.apply(
|
|
||||||
this.supported, probably_supported);
|
|
||||||
|
|
||||||
// Prioritize "maybe" supported types second
|
|
||||||
Array.prototype.push.apply(
|
|
||||||
this.supported, maybe_supported);
|
|
||||||
}
|
|
||||||
|
|
||||||
})();
|
})();
|
||||||
|
|
||||||
|
@@ -28,14 +28,94 @@
|
|||||||
z-index: 20;
|
z-index: 20;
|
||||||
|
|
||||||
font-size: 0.8em;
|
font-size: 0.8em;
|
||||||
padding: 0.5em;
|
|
||||||
|
|
||||||
width: 4in;
|
width: 4in;
|
||||||
max-width: 100%;
|
max-width: 100%;
|
||||||
|
max-height: 3in;
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
#file-transfer-dialog .transfer-manager {
|
#file-transfer-dialog .transfer-manager {
|
||||||
|
|
||||||
|
/* IE10 */
|
||||||
|
display: -ms-flexbox;
|
||||||
|
-ms-flex-align: stretch;
|
||||||
|
-ms-flex-direction: column;
|
||||||
|
|
||||||
|
/* Ancient Mozilla */
|
||||||
|
display: -moz-box;
|
||||||
|
-moz-box-align: stretch;
|
||||||
|
-moz-box-orient: vertical;
|
||||||
|
|
||||||
|
/* Ancient WebKit */
|
||||||
|
display: -webkit-box;
|
||||||
|
-webkit-box-align: stretch;
|
||||||
|
-webkit-box-orient: vertical;
|
||||||
|
|
||||||
|
/* Old WebKit */
|
||||||
|
display: -webkit-flex;
|
||||||
|
-webkit-align-items: stretch;
|
||||||
|
-webkit-flex-direction: column;
|
||||||
|
|
||||||
|
/* W3C */
|
||||||
|
display: flex;
|
||||||
|
align-items: stretch;
|
||||||
|
flex-direction: column;
|
||||||
|
|
||||||
|
max-width: inherit;
|
||||||
|
max-height: inherit;
|
||||||
|
|
||||||
border: 1px solid rgba(0, 0, 0, 0.5);
|
border: 1px solid rgba(0, 0, 0, 0.5);
|
||||||
box-shadow: 1px 1px 2px rgba(0, 0, 0, 0.25);
|
box-shadow: 1px 1px 2px rgba(0, 0, 0, 0.25);
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
#file-transfer-dialog .transfer-manager .header {
|
||||||
|
-ms-flex: 0 0 auto;
|
||||||
|
-moz-box-flex: 0;
|
||||||
|
-webkit-box-flex: 0;
|
||||||
|
-webkit-flex: 0 0 auto;
|
||||||
|
flex: 0 0 auto;
|
||||||
|
}
|
||||||
|
|
||||||
|
#file-transfer-dialog .transfer-manager .transfer-manager-body {
|
||||||
|
|
||||||
|
-ms-flex: 1 1 auto;
|
||||||
|
-moz-box-flex: 1;
|
||||||
|
-webkit-box-flex: 1;
|
||||||
|
-webkit-flex: 1 1 auto;
|
||||||
|
flex: 1 1 auto;
|
||||||
|
|
||||||
|
overflow: auto;
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
/*
|
||||||
|
* Shrink maximum height if viewport is too small for default 3in dialog.
|
||||||
|
*/
|
||||||
|
@media all and (max-height: 3in) {
|
||||||
|
|
||||||
|
#file-transfer-dialog {
|
||||||
|
max-height: 1.5in;
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
/*
|
||||||
|
* If viewport is too small for even the 1.5in dialog, fit all available space.
|
||||||
|
*/
|
||||||
|
@media all and (max-height: 1.5in) {
|
||||||
|
|
||||||
|
#file-transfer-dialog {
|
||||||
|
height: 100%;
|
||||||
|
}
|
||||||
|
|
||||||
|
#file-transfer-dialog .transfer-manager {
|
||||||
|
position: absolute;
|
||||||
|
left: 0.5em;
|
||||||
|
top: 0.5em;
|
||||||
|
right: 0.5em;
|
||||||
|
bottom: 0.5em;
|
||||||
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
@@ -27,15 +27,17 @@
|
|||||||
<button ng-click="clearCompletedTransfers()">{{'CLIENT.ACTION_CLEAR_COMPLETED_TRANSFERS' | translate}}</button>
|
<button ng-click="clearCompletedTransfers()">{{'CLIENT.ACTION_CLEAR_COMPLETED_TRANSFERS' | translate}}</button>
|
||||||
</div>
|
</div>
|
||||||
|
|
||||||
<!-- Sent/received files files -->
|
<!-- Sent/received files -->
|
||||||
<div class="transfers">
|
<div class="transfer-manager-body">
|
||||||
<guac-file-transfer
|
<div class="transfers">
|
||||||
transfer="upload"
|
<guac-file-transfer
|
||||||
ng-repeat="upload in client.uploads">
|
transfer="upload"
|
||||||
</guac-file-transfer><guac-file-transfer
|
ng-repeat="upload in client.uploads">
|
||||||
transfer="download"
|
</guac-file-transfer><guac-file-transfer
|
||||||
ng-repeat="download in client.downloads">
|
transfer="download"
|
||||||
</guac-file-transfer>
|
ng-repeat="download in client.downloads">
|
||||||
|
</guac-file-transfer>
|
||||||
|
</div>
|
||||||
</div>
|
</div>
|
||||||
|
|
||||||
</div>
|
</div>
|
||||||
|
@@ -29,9 +29,10 @@
|
|||||||
angular.module('locale').factory('translationLoader', ['$injector', function translationLoader($injector) {
|
angular.module('locale').factory('translationLoader', ['$injector', function translationLoader($injector) {
|
||||||
|
|
||||||
// Required services
|
// Required services
|
||||||
var $http = $injector.get('$http');
|
var $http = $injector.get('$http');
|
||||||
var $q = $injector.get('$q');
|
var $q = $injector.get('$q');
|
||||||
var cacheService = $injector.get('cacheService');
|
var cacheService = $injector.get('cacheService');
|
||||||
|
var languageService = $injector.get('languageService');
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Satisfies a translation request for the given key by searching for the
|
* Satisfies a translation request for the given key by searching for the
|
||||||
@@ -62,22 +63,48 @@ angular.module('locale').factory('translationLoader', ['$injector', function tra
|
|||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
// Attempt to retrieve language
|
/**
|
||||||
$http({
|
* Continues trying possible translation files until no possibilities
|
||||||
cache : cacheService.languages,
|
* exist.
|
||||||
method : 'GET',
|
*
|
||||||
url : 'translations/' + encodeURIComponent(currentKey) + '.json'
|
* @private
|
||||||
})
|
*/
|
||||||
|
var tryNextTranslation = function tryNextTranslation() {
|
||||||
// Resolve promise if translation retrieved successfully
|
|
||||||
.success(function translationFileRetrieved(translation) {
|
|
||||||
deferred.resolve(translation);
|
|
||||||
})
|
|
||||||
|
|
||||||
// Retry with remaining languages if translation file could not be retrieved
|
|
||||||
.error(function translationFileUnretrievable() {
|
|
||||||
satisfyTranslation(deferred, requestedKey, remainingKeys);
|
satisfyTranslation(deferred, requestedKey, remainingKeys);
|
||||||
});
|
};
|
||||||
|
|
||||||
|
// Retrieve list of supported languages
|
||||||
|
languageService.getLanguages()
|
||||||
|
|
||||||
|
// Attempt to retrieve translation if language is supported
|
||||||
|
.success(function retrievedLanguages(languages) {
|
||||||
|
|
||||||
|
// Skip retrieval if language is not supported
|
||||||
|
if (!(currentKey in languages)) {
|
||||||
|
tryNextTranslation();
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
// Attempt to retrieve language
|
||||||
|
$http({
|
||||||
|
cache : cacheService.languages,
|
||||||
|
method : 'GET',
|
||||||
|
url : 'translations/' + encodeURIComponent(currentKey) + '.json'
|
||||||
|
})
|
||||||
|
|
||||||
|
// Resolve promise if translation retrieved successfully
|
||||||
|
.success(function translationFileRetrieved(translation) {
|
||||||
|
deferred.resolve(translation);
|
||||||
|
})
|
||||||
|
|
||||||
|
// Retry with remaining languages if translation file could not be
|
||||||
|
// retrieved
|
||||||
|
.error(tryNextTranslation);
|
||||||
|
|
||||||
|
})
|
||||||
|
|
||||||
|
// Retry with remaining languages if translation does not exist
|
||||||
|
.error(tryNextTranslation);
|
||||||
|
|
||||||
};
|
};
|
||||||
|
|
||||||
|
Reference in New Issue
Block a user