/* -*- Mode: c++; c-basic-offset: 2; indent-tabs-mode: nil; tab-width: 40 -*- */ /* vim: set ts=2 et sw=2 tw=80: */ /* This Source Code Form is subject to the terms of the Mozilla Public * License, v. 2.0. If a copy of the MPL was not distributed with this file, * You can obtain one at http://mozilla.org/MPL/2.0/. */ #include "BluetoothUtils.h" #include "BluetoothReplyRunnable.h" #include "BluetoothService.h" #include "jsapi.h" #include "mozilla/dom/ScriptSettings.h" #include "mozilla/dom/bluetooth/BluetoothTypes.h" #include "nsContentUtils.h" #include "nsISystemMessagesInternal.h" #include "nsServiceManagerUtils.h" #include "nsXULAppAPI.h" BEGIN_BLUETOOTH_NAMESPACE void UuidToString(const BluetoothUuid& aUuid, nsAString& aString) { char uuidStr[37]; uint32_t uuid0, uuid4; uint16_t uuid1, uuid2, uuid3, uuid5; memcpy(&uuid0, &aUuid.mUuid[0], sizeof(uint32_t)); memcpy(&uuid1, &aUuid.mUuid[4], sizeof(uint16_t)); memcpy(&uuid2, &aUuid.mUuid[6], sizeof(uint16_t)); memcpy(&uuid3, &aUuid.mUuid[8], sizeof(uint16_t)); memcpy(&uuid4, &aUuid.mUuid[10], sizeof(uint32_t)); memcpy(&uuid5, &aUuid.mUuid[14], sizeof(uint16_t)); sprintf(uuidStr, "%.8x-%.4x-%.4x-%.4x-%.8x%.4x", ntohl(uuid0), ntohs(uuid1), ntohs(uuid2), ntohs(uuid3), ntohl(uuid4), ntohs(uuid5)); aString.Truncate(); aString.AssignLiteral(uuidStr); } bool SetJsObject(JSContext* aContext, const BluetoothValue& aValue, JS::Handle aObj) { MOZ_ASSERT(aContext && aObj); if (aValue.type() != BluetoothValue::TArrayOfBluetoothNamedValue) { BT_WARNING("SetJsObject: Invalid parameter type"); return false; } const nsTArray& arr = aValue.get_ArrayOfBluetoothNamedValue(); for (uint32_t i = 0; i < arr.Length(); i++) { JS::Rooted val(aContext); const BluetoothValue& v = arr[i].value(); switch(v.type()) { case BluetoothValue::TnsString: { JSString* jsData = JS_NewUCStringCopyN(aContext, v.get_nsString().BeginReading(), v.get_nsString().Length()); NS_ENSURE_TRUE(jsData, false); val = STRING_TO_JSVAL(jsData); break; } case BluetoothValue::Tuint32_t: val = INT_TO_JSVAL(v.get_uint32_t()); break; case BluetoothValue::Tbool: val = BOOLEAN_TO_JSVAL(v.get_bool()); break; default: BT_WARNING("SetJsObject: Parameter is not handled"); break; } if (!JS_SetProperty(aContext, aObj, NS_ConvertUTF16toUTF8(arr[i].name()).get(), val)) { BT_WARNING("Failed to set property"); return false; } } return true; } bool BroadcastSystemMessage(const nsAString& aType, const BluetoothValue& aData) { mozilla::AutoSafeJSContext cx; NS_ASSERTION(!::JS_IsExceptionPending(cx), "Shouldn't get here when an exception is pending!"); nsCOMPtr systemMessenger = do_GetService("@mozilla.org/system-message-internal;1"); NS_ENSURE_TRUE(systemMessenger, false); JS::Rooted value(cx); if (aData.type() == BluetoothValue::TnsString) { JSString* jsData = JS_NewUCStringCopyN(cx, aData.get_nsString().BeginReading(), aData.get_nsString().Length()); value = STRING_TO_JSVAL(jsData); } else if (aData.type() == BluetoothValue::TArrayOfBluetoothNamedValue) { JS::Rooted obj(cx, JS_NewPlainObject(cx)); if (!obj) { BT_WARNING("Failed to new JSObject for system message!"); return false; } if (!SetJsObject(cx, aData, obj)) { BT_WARNING("Failed to set properties of system message!"); return false; } value = JS::ObjectValue(*obj); } else { BT_WARNING("Not support the unknown BluetoothValue type"); return false; } systemMessenger->BroadcastMessage(aType, value, JS::UndefinedHandleValue); return true; } bool BroadcastSystemMessage(const nsAString& aType, const InfallibleTArray& aData) { mozilla::AutoSafeJSContext cx; NS_ASSERTION(!::JS_IsExceptionPending(cx), "Shouldn't get here when an exception is pending!"); JS::Rooted obj(cx, JS_NewPlainObject(cx)); if (!obj) { BT_WARNING("Failed to new JSObject for system message!"); return false; } if (!SetJsObject(cx, aData, obj)) { BT_WARNING("Failed to set properties of system message!"); return false; } nsCOMPtr systemMessenger = do_GetService("@mozilla.org/system-message-internal;1"); NS_ENSURE_TRUE(systemMessenger, false); JS::Rooted value(cx, JS::ObjectValue(*obj)); systemMessenger->BroadcastMessage(aType, value, JS::UndefinedHandleValue); return true; } void DispatchBluetoothReply(BluetoothReplyRunnable* aRunnable, const BluetoothValue& aValue, const nsAString& aErrorStr) { // Reply will be deleted by the runnable after running on main thread BluetoothReply* reply; if (!aErrorStr.IsEmpty()) { nsString err(aErrorStr); reply = new BluetoothReply(BluetoothReplyError(STATUS_FAIL, err)); } else { MOZ_ASSERT(aValue.type() != BluetoothValue::T__None); reply = new BluetoothReply(BluetoothReplySuccess(aValue)); } aRunnable->SetReply(reply); if (NS_FAILED(NS_DispatchToMainThread(aRunnable))) { BT_WARNING("Failed to dispatch to main thread!"); } } void DispatchBluetoothReply(BluetoothReplyRunnable* aRunnable, const BluetoothValue& aValue, const enum BluetoothStatus aStatusCode) { // Reply will be deleted by the runnable after running on main thread BluetoothReply* reply; if (aStatusCode != STATUS_SUCCESS) { reply = new BluetoothReply(BluetoothReplyError(aStatusCode, EmptyString())); } else { MOZ_ASSERT(aValue.type() != BluetoothValue::T__None); reply = new BluetoothReply(BluetoothReplySuccess(aValue)); } aRunnable->SetReply(reply); if (NS_FAILED(NS_DispatchToMainThread(aRunnable))) { BT_WARNING("Failed to dispatch to main thread!"); } } void DispatchStatusChangedEvent(const nsAString& aType, const nsAString& aAddress, bool aStatus) { MOZ_ASSERT(NS_IsMainThread()); InfallibleTArray data; BT_APPEND_NAMED_VALUE(data, "address", nsString(aAddress)); BT_APPEND_NAMED_VALUE(data, "status", aStatus); BluetoothSignal signal(nsString(aType), NS_LITERAL_STRING(KEY_ADAPTER), data); BluetoothService* bs = BluetoothService::Get(); NS_ENSURE_TRUE_VOID(bs); bs->DistributeSignal(signal); } bool IsMainProcess() { return XRE_GetProcessType() == GeckoProcessType_Default; } END_BLUETOOTH_NAMESPACE