blob: 47957e8cdd3225a2b2af8390551cf2447da6824e [file] [log] [blame]
/*
* Licensed to the Apache Software Foundation (ASF) under one
* or more contributor license agreements. See the NOTICE file
* distributed with this work for additional information
* regarding copyright ownership. The ASF licenses this file
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing,
* software distributed under the License is distributed on an
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
* KIND, either express or implied. See the License for the
* specific language governing permissions and limitations
* under the License.
*/
/* $Rev$ $Date$ */
#ifndef tuscany_js_hpp
#define tuscany_js_hpp
/**
* Javascript evaluation functions.
*/
#define XP_UNIX
#ifdef WANT_MAINTAINER_WARNINGS
#pragma GCC diagnostic ignored "-Wunused-parameter"
#pragma GCC diagnostic ignored "-Wsign-compare"
#pragma GCC diagnostic ignored "-Wredundant-decls"
#endif
#include "jsapi.h"
#ifdef WANT_MAINTAINER_WARNINGS
#pragma GCC diagnostic warning "-Wunused-parameter"
#pragma GCC diagnostic warning "-Wsign-compare"
#pragma GCC diagnostic warning "-Wredundant-decls"
#endif
#include "string.hpp"
#include "list.hpp"
#include "value.hpp"
#include "element.hpp"
#include "monad.hpp"
#include "parallel.hpp"
namespace tuscany {
namespace js {
/**
* Report Javascript errors.
*/
void reportError(unused ::JSContext *cx, const char *message, JSErrorReport *report) {
cfailure << (const char*)(report->filename? report->filename : "<no filename>") << ":"
<< (int)report->lineno << ":" << message << endl;
}
/**
* Encapsulates a JavaScript runtime. Shared by multiple threads in
* a process.
*/
class JSRuntime {
public:
JSRuntime() {
// Create JS runtime
debug("js::jsruntime");
pthread_mutex_init(&mutex, NULL);
#ifdef WANT_THREADS
rt = JS_NewRuntime(32L * 1024L * 1024L);
#else
rt = JS_NewRuntime(8L * 1024L * 1024L);
#endif
if(rt == NULL)
cleanup();
}
operator ::JSRuntime*() const {
return rt;
}
~JSRuntime() {
debug("js::~jsruntime");
}
bool lock() {
//pthread_mutex_lock(&mutex);
return true;
}
bool unlock() {
//pthread_mutex_unlock(&mutex);
return true;
}
private:
bool cleanup() {
if(rt != NULL) {
JS_DestroyRuntime(rt);
rt = NULL;
}
JS_ShutDown();
return true;
}
pthread_mutex_t mutex;
::JSRuntime* rt;
} jsRuntime;
JSClass jsGlobalClass = { "global", JSCLASS_GLOBAL_FLAGS,
JS_PropertyStub, JS_PropertyStub,
JS_PropertyStub, JS_StrictPropertyStub,
JS_EnumerateStub, JS_ResolveStub,
JS_ConvertStub, JS_FinalizeStub,
JSCLASS_NO_OPTIONAL_MEMBERS };
/**
* Represents a JavaScript context. Maintains one context per thread.
*/
#ifdef WANT_THREADS
perthread_ptr<JSContext> jsContext;
#else
::JSContext* jsContext = NULL;
#endif
class JSContext {
public:
JSContext() {
debug("js::jscontext");
jsRuntime.lock();
// Create JS context if necessary
if (jsContext != NULL) {
cx = jsContext;
debug(cx, "js::jscontext::beginRequest::cx");
JS_SetContextThread(cx);
JS_BeginRequest(cx);
return;
}
debug("js::jscontext::newcontext");
cx = JS_NewContext(jsRuntime, 8192);
if(cx == NULL) {
jsRuntime.unlock();
return;
}
debug(cx, "js::jscontext::beginRequest::cx");
JS_SetContextThread(cx);
JS_BeginRequest(cx);
JS_SetOptions(cx, JSOPTION_VAROBJFIX /*| JSOPTION_JIT | JSOPTION_METHODJIT*/);
JS_SetVersion(cx, JSVERSION_LATEST);
JS_SetErrorReporter(cx, reportError);
JS_SetGCZeal(cx, 0);
// Create global JS object
global = JS_NewCompartmentAndGlobalObject(cx, &jsGlobalClass, NULL);
if(global == NULL) {
JS_DestroyContext(cx);
cleanup();
return;
}
JS_SetGlobalObject(cx, global);
// Populate global object with the standard globals, like Object and Array
if(!JS_InitStandardClasses(cx, global)) {
JS_DestroyContext(cx);
cleanup();
return;
}
jsContext = cx;
}
~JSContext() {
debug("js::~jscontext");
cleanup();
}
operator ::JSContext*() const {
return cx;
}
JSObject* getGlobal() const {
return global;
}
private:
bool cleanup() {
if(cx != NULL) {
if (cx != jsContext) {
debug(cx, "js::jscontext::endrequest::cx");
JS_EndRequest(cx);
JS_ClearContextThread(cx);
debug(cx, "js::jscontext::destroycontext::cx");
JS_DestroyContext(cx);
jsContext = NULL;
} else {
//debug(cx, "js::jscontext::maybegc::cx");
//JS_MaybeGC(cx);
debug(cx, "js::jscontext::endrequest::cx");
JS_EndRequest(cx);
JS_ClearContextThread(cx);
}
cx = NULL;
}
jsRuntime.unlock();
return true;
}
::JSContext* cx;
JSObject* global;
};
/**
* Returns true if a list represents a JS array.
*/
const bool isJSArray(const list<value>& l) {
if(isNil(l))
return true;
const value v = car(l);
if (isSymbol(v))
return false;
if(isList(v)) {
if(!isNil((list<value>)v) && isSymbol(car<value>(v)))
return false;
}
return true;
}
/**
* Converts JS properties to values.
*/
const list<value> jsPropertiesToValues(const list<value>& propertiesSoFar, JSObject* o, JSObject* i, const js::JSContext& cx) {
const value jsValToValue(const jsval& jsv, const js::JSContext& cx);
jsid id;
if(!JS_NextProperty(cx, i, &id))
return propertiesSoFar;
jsval idv;
JS_IdToValue(cx, id, &idv);
if (idv == JSVAL_VOID)
return propertiesSoFar;
jsval jsv;
if(!JS_GetPropertyById(cx, o, id, &jsv))
return propertiesSoFar;
const value val = jsValToValue(jsv, cx);
if(JSVAL_IS_STRING(idv)) {
char* cname = JS_EncodeString(cx, JSVAL_TO_STRING(idv));
const string name = cname;
JS_free(cx, cname);
if (isNil(val) && !isList(val))
return jsPropertiesToValues(cons<value> (mklist<value> (element, c_str(name), val), propertiesSoFar), o, i, cx);
//return jsPropertiesToValues(propertiesSoFar, o, i, cx);
if (substr(name, 0, 1) == atsign)
return jsPropertiesToValues(cons<value>(mklist<value>(attribute, c_str(substr(name, 1)), val), propertiesSoFar), o, i, cx);
if (isList(val) && !isJSArray(val))
return jsPropertiesToValues(cons<value>(cons<value>(element, cons<value>(c_str(name), list<value>(val))), propertiesSoFar), o, i, cx);
return jsPropertiesToValues(cons<value> (mklist<value> (element, c_str(name), val), propertiesSoFar), o, i, cx);
}
return jsPropertiesToValues(cons(val, propertiesSoFar), o, i, cx);
}
/**
* Converts a JS val to a value.
*/
const value jsValToValue(const jsval& jsv, const js::JSContext& cx) {
switch(JS_TypeOfValue(cx, jsv)) {
case JSTYPE_STRING: {
char* cvalue = JS_EncodeString(cx, JSVAL_TO_STRING(jsv));
const string svalue = string(cvalue);
JS_free(cx, cvalue);
return value(svalue);
}
case JSTYPE_BOOLEAN: {
return value((bool)JSVAL_TO_BOOLEAN(jsv));
}
case JSTYPE_NUMBER: {
double jsd;
JS_ValueToNumber(cx, jsv, &jsd);
return value((double)jsd);
}
case JSTYPE_OBJECT: {
JSObject* o = JSVAL_TO_OBJECT(jsv);
if (o == NULL)
return value();
JSObject* i = JS_NewPropertyIterator(cx, o);
if(i == NULL)
return value(list<value> ());
const value pv = jsPropertiesToValues(list<value> (), o, i, cx);
return pv;
}
default: {
return value();
}
}
}
/**
* Converts a list of values to JS array elements.
*/
JSObject* valuesToJSElements(JSObject* a, const list<value>& l, int i, const js::JSContext& cx) {
const jsval valueToJSVal(const value& val, const js::JSContext& cx);
if (isNil(l))
return a;
jsval pv = valueToJSVal(car(l), cx);
JS_SetElement(cx, a, i, &pv);
return valuesToJSElements(a, cdr(l), ++i, cx);
}
/**
* Converts a value to a JS val.
*/
const jsval valueToJSVal(const value& val, const js::JSContext& cx) {
JSObject* valuesToJSProperties(JSObject* o, const list<value>& l, const js::JSContext& cx);
switch(type(val)) {
case value::String: {
return STRING_TO_JSVAL(JS_NewStringCopyZ(cx, c_str((string)val)));
}
case value::Symbol: {
return STRING_TO_JSVAL(JS_NewStringCopyZ(cx, c_str((string)val)));
}
case value::Bool: {
return BOOLEAN_TO_JSVAL((bool)val);
}
case value::Number: {
jsval jsv = DOUBLE_TO_JSVAL((double)val);
return jsv;
}
case value::List: {
if (isJSArray(val)) {
JSObject* array = JS_NewArrayObject(cx, 0, NULL);
//debug(array, "js::valueToJSVal::new::array");
return OBJECT_TO_JSVAL(valuesToJSElements(array, val, 0, cx));
}
JSObject* child = JS_NewObject(cx, NULL, NULL, NULL);
//debug(child, "js::valueToJSVal::new::child");
return OBJECT_TO_JSVAL(valuesToJSProperties(child, val, cx));
}
case value::Nil: {
return JSVAL_NULL;
}
default: {
return JSVAL_VOID;
}
}
}
/**
* Converts a list of values to JS properties.
*/
JSObject* valuesToJSProperties(JSObject* o, const list<value>& l, const js::JSContext& cx) {
if (isNil(l))
return o;
// Write an attribute
const value token(car(l));
if (isTaggedList(token, attribute)) {
jsval pv = valueToJSVal(attributeValue(token), cx);
JS_SetProperty(cx, o, c_str(atsign + string(attributeName(token))), &pv);
} else if (isTaggedList(token, element)) {
// Write the value of an element
if (elementHasValue(token)) {
jsval pv = valueToJSVal(elementValue(token), cx);
JS_SetProperty(cx, o, c_str(string(elementName(token))), &pv);
} else {
// Write a parent element
JSObject* child = JS_NewObject(cx, NULL, NULL, NULL);
//debug(child, "js::valuesToJSProperties::new::child");
jsval pv = OBJECT_TO_JSVAL(child);
JS_SetProperty(cx, o, c_str(string(elementName(token))), &pv);
// Write its children
valuesToJSProperties(child, elementChildren(token), cx);
}
}
// Go on
return valuesToJSProperties(o, cdr(l), cx);
}
/**
* Evaluate a script provided as a string.
*/
const failable<value> evalScript(const string& s) {
js::JSContext cx;
jsval rval;
JSBool rc = JS_EvaluateScript(cx, cx.getGlobal(), c_str(s), (unsigned int)length(s), "eval.js", 1, &rval);
if (rc != JS_TRUE) {
return mkfailure<value>("Couldn't evaluate Javascript script.");
}
return jsValToValue(rval, cx);
}
}
}
#endif /* tuscany_js_hpp */