204 lines
8.6 KiB
C#
204 lines
8.6 KiB
C#
/*
|
|
* Copyright (c) Contributors, http://opensimulator.org/
|
|
* See CONTRIBUTORS.TXT for a full list of copyright holders.
|
|
*
|
|
* Redistribution and use in source and binary forms, with or without
|
|
* modification, are permitted provided that the following conditions are met:
|
|
* * Redistributions of source code must retain the above copyright
|
|
* notice, this list of conditions and the following disclaimer.
|
|
* * Redistributions in binary form must reproduce the above copyright
|
|
* notice, this list of conditions and the following disclaimer in the
|
|
* documentation and/or other materials provided with the distribution.
|
|
* * Neither the name of the OpenSimulator Project nor the
|
|
* names of its contributors may be used to endorse or promote products
|
|
* derived from this software without specific prior written permission.
|
|
*
|
|
* THIS SOFTWARE IS PROVIDED BY THE DEVELOPERS ``AS IS'' AND ANY
|
|
* EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
|
|
* WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
|
|
* DISCLAIMED. IN NO EVENT SHALL THE CONTRIBUTORS BE LIABLE FOR ANY
|
|
* DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
|
|
* (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
|
|
* LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
|
|
* ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
|
|
* (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
|
|
* SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
|
|
*/
|
|
|
|
using System;
|
|
using System.Reflection;
|
|
|
|
using OpenSim.Framework;
|
|
|
|
using OpenMetaverse;
|
|
using OpenMetaverse.StructuredData;
|
|
|
|
using log4net;
|
|
using Nini.Config;
|
|
|
|
namespace osWebRtcVoice
|
|
{
|
|
// Class that provides the local IWebRtcVoiceService interface to the JsonRPC Robust
|
|
// server. This is used by the region servers to talk to the Robust server.
|
|
public class WebRtcVoiceServiceConnector : IWebRtcVoiceService
|
|
{
|
|
private static readonly ILog m_log = LogManager.GetLogger(MethodBase.GetCurrentMethod().DeclaringType);
|
|
private static readonly string LogHeader = "[WEBRTC VOICE SERVICE CONNECTOR]";
|
|
private bool m_Enabled = false;
|
|
private bool m_MessageDetails = false;
|
|
private IConfigSource m_Config;
|
|
|
|
string m_serverURI = "http://localhost:8080";
|
|
|
|
public WebRtcVoiceServiceConnector(IConfigSource pConfig)
|
|
{
|
|
m_Config = pConfig;
|
|
IConfig moduleConfig = m_Config.Configs["WebRtcVoice"];
|
|
|
|
if (moduleConfig is not null)
|
|
{
|
|
m_Enabled = moduleConfig.GetBoolean("Enabled", false);
|
|
if (m_Enabled)
|
|
{
|
|
m_serverURI = moduleConfig.GetString("WebRtcVoiceServerURI", string.Empty);
|
|
if (string.IsNullOrWhiteSpace(m_serverURI))
|
|
{
|
|
m_log.Error($"{LogHeader} WebRtcVoiceServiceConnector enabled but no WebRtcVoiceServerURI specified");
|
|
m_Enabled = false;
|
|
}
|
|
else
|
|
{
|
|
m_log.Info($"{LogHeader} WebRtcVoiceServiceConnector enabled");
|
|
}
|
|
|
|
m_MessageDetails = moduleConfig.GetBoolean("MessageDetails", false);
|
|
}
|
|
}
|
|
}
|
|
|
|
// Create a local viewer session. This gets a local viewer session ID that is
|
|
// later changed when the ProvisionVoiceAccountRequest response is returned
|
|
// so that the viewer session ID is the same here as from the WebRTC service.
|
|
public IVoiceViewerSession CreateViewerSession(OSDMap pRequest, UUID pUserID, UUID pSceneID)
|
|
{
|
|
m_log.Debug($"{LogHeader} CreateViewerSession");
|
|
return new VoiceViewerSession(this, pUserID, pSceneID);
|
|
}
|
|
|
|
public OSDMap ProvisionVoiceAccountRequest(OSDMap pRequest, UUID pUserID, UUID pSceneID)
|
|
{
|
|
m_log.Debug($"{LogHeader} ProvisionVoiceAccountRequest without ViewerSession. uID={pUserID}, sID={pSceneID}");
|
|
return null;
|
|
}
|
|
|
|
// Received a ProvisionVoiceAccountRequest from a viewer. Forward it to the WebRTC service.
|
|
public OSDMap ProvisionVoiceAccountRequest(IVoiceViewerSession pVSession, OSDMap pRequest, UUID pUserID, UUID pSceneID)
|
|
{
|
|
m_log.Debug($"{LogHeader} VoiceSignalingRequest. uID={pUserID}, sID={pSceneID}");
|
|
OSDMap req = new()
|
|
{
|
|
{ "request", pRequest },
|
|
{ "userID", pUserID.ToString() },
|
|
{ "scene", pSceneID.ToString() }
|
|
};
|
|
var resp = JsonRpcRequest("provision_voice_account_request", m_serverURI, req);
|
|
|
|
// Kludge to sync the viewer session number in our IVoiceViewerSession with the one from the WebRTC service.
|
|
if (resp.TryGetString("viewer_session", out string otherViewerSessionId))
|
|
{
|
|
m_log.Debug(
|
|
$"{LogHeader} ProvisionVoiceAccountRequest: syncing viewSessionID. old={pVSession.ViewerSessionID}, new={otherViewerSessionId}");
|
|
VoiceViewerSession.UpdateViewerSessionId(pVSession, otherViewerSessionId);
|
|
}
|
|
|
|
return resp;
|
|
}
|
|
|
|
public OSDMap VoiceSignalingRequest(OSDMap pRequest, UUID pUserID, UUID pSceneID)
|
|
{
|
|
m_log.Debug($"{LogHeader} VoiceSignalingRequest without ViewerSession. uID={pUserID}, sID={pSceneID}");
|
|
return null;
|
|
}
|
|
|
|
public OSDMap VoiceSignalingRequest(IVoiceViewerSession pVSession, OSDMap pRequest, UUID pUserID, UUID pSceneID)
|
|
{
|
|
m_log.DebugFormat("{0} VoiceSignalingRequest. uID={1}, sID={2}", LogHeader, pUserID, pSceneID);
|
|
OSDMap req = new()
|
|
{
|
|
{ "request", pRequest },
|
|
{ "userID", pUserID.ToString() },
|
|
{ "scene", pSceneID.ToString() }
|
|
};
|
|
return JsonRpcRequest("voice_signaling_request", m_serverURI, req);
|
|
}
|
|
|
|
public OSDMap JsonRpcRequest(string method, string uri, OSDMap pParams)
|
|
{
|
|
string jsonId = UUID.Random().ToString();
|
|
|
|
if(string.IsNullOrWhiteSpace(uri))
|
|
return null;
|
|
|
|
OSDMap request = new()
|
|
{
|
|
{ "jsonrpc", OSD.FromString("2.0") },
|
|
{ "id", OSD.FromString(jsonId) },
|
|
{ "method", OSD.FromString(method) },
|
|
{ "params", pParams }
|
|
};
|
|
|
|
OSDMap outerResponse = null;
|
|
try
|
|
{
|
|
if (m_MessageDetails) m_log.Debug($"{LogHeader}: request: {request}");
|
|
|
|
outerResponse = WebUtil.PostToService(uri, request, 10000, true);
|
|
|
|
if (m_MessageDetails) m_log.Debug($"{LogHeader}: response: {outerResponse}");
|
|
}
|
|
catch (Exception e)
|
|
{
|
|
m_log.Error($"{LogHeader}: JsonRpc request '{method}' to {uri} failed: {e.Message}");
|
|
m_log.Debug($"{LogHeader}: request: {request}");
|
|
return new OSDMap()
|
|
{
|
|
{ "error", OSD.FromString(e.Message) }
|
|
};
|
|
}
|
|
|
|
if (!outerResponse.TryGetOSDMap("_Result", out OSDMap response))
|
|
{
|
|
string errm = $"JsonRpc request '{method}' to {1} returned an invalid response: {OSDParser.SerializeJsonString(outerResponse)}";
|
|
m_log.Error(errm);
|
|
return new OSDMap()
|
|
{
|
|
{ "error", errm }
|
|
};
|
|
}
|
|
|
|
OSD osdtmp;
|
|
if (response.TryGetValue("error", out osdtmp))
|
|
{
|
|
string errm = $"JsonRpc request '{method}' to {uri} returned an error: {OSDParser.SerializeJsonString(osdtmp)}";
|
|
m_log.Error(errm);
|
|
return new OSDMap()
|
|
{
|
|
{ "error", errm }
|
|
};
|
|
}
|
|
|
|
if (!response.TryGetOSDMap("result", out OSDMap resultmap ))
|
|
{
|
|
string errm = $"JsonRpc request '{method}' to {uri} returned result as non-OSDMap: {OSDParser.SerializeJsonString(outerResponse)}";
|
|
m_log.Error(errm);
|
|
return new OSDMap()
|
|
{
|
|
{ "error", errm }
|
|
};
|
|
}
|
|
|
|
return resultmap;
|
|
}
|
|
|
|
}
|
|
} |