source: trunk/FACT++/src/InterpreterV8.h@ 14629

Last change on this file since 14629 was 14629, checked in by tbretz, 12 years ago
Check only if state was already defined since script start; added a getState to return corrent state; Dispose global context; converted some custom objects (Sky, Local, moon, Database) into real object so that they can be questioned with 'instanceof'
File size: 10.1 KB
Line 
1#ifndef FACT_InterpreterV8
2#define FACT_InterpreterV8
3
4#include <map>
5#include <set>
6#include <list>
7#include <string>
8#include <thread>
9
10#ifdef HAVE_V8
11#include <v8.h>
12#endif
13
14#include "State.h"
15#include "Description.h"
16#include "EventImp.h"
17
18class Database;
19
20class InterpreterV8
21{
22 static InterpreterV8 *This;
23
24 // The main thread id, needed to be able to terminate
25 // the thread forcefully from 'the outside'
26 int fThreadId;
27 std::set<int> fThreadIds;
28
29 v8::Persistent<v8::Context> fGlobalContext;
30
31 // A loookup table which allows to indentify the
32 // the JavaScript object corrsponding to the
33 // service name (for checking of an .onchange
34 // subscription exists for that object)
35 std::map<std::string, v8::Persistent<v8::Object>> fReverseMap;
36
37 // Lookup table for the callbacks in cases of state changes
38 std::map<std::string, v8::Persistent<v8::Value>> fStateCallbacks;
39
40 // List of all timeout threads
41 std::vector<std::thread> fTimeout;
42
43 // List of all states already set
44 std::vector<std::pair<int, std::string>> fStates;
45
46 static v8::Handle<v8::FunctionTemplate> fTemplateLocal;
47 static v8::Handle<v8::FunctionTemplate> fTemplateSky;
48 static v8::Handle<v8::FunctionTemplate> fTemplateMoon;
49 static v8::Handle<v8::FunctionTemplate> fTemplateDatabase;
50
51#ifdef HAVE_SQL
52 std::list<Database*> fDatabases;
53#endif
54
55#ifdef HAVE_V8
56 void Terminate();
57
58 bool ReportException(v8::TryCatch* try_catch);
59 bool ExecuteFile(const std::string &name, bool main=false);
60 v8::Handle<v8::Value> ExecuteCode(const std::string &code, const std::string &file="internal", bool main=false);
61 v8::Handle<v8::Value> ExecuteInternal(const std::string &code);
62
63 void ThreadTimeout(v8::Persistent<v8::Function> func, uint32_t ms);
64
65 v8::Handle<v8::Value> FuncWait(const v8::Arguments& args);
66 v8::Handle<v8::Value> FuncSend(const v8::Arguments& args);
67 v8::Handle<v8::Value> FuncSleep(const v8::Arguments& args);
68 v8::Handle<v8::Value> FuncTimeout(const v8::Arguments& args);
69 v8::Handle<v8::Value> FuncPrint(const v8::Arguments& args);
70 v8::Handle<v8::Value> FuncAlarm(const v8::Arguments& args);
71 v8::Handle<v8::Value> FuncOut(const v8::Arguments& args);
72 v8::Handle<v8::Value> FuncFile(const v8::Arguments& args);
73 v8::Handle<v8::Value> FuncInclude(const v8::Arguments& args);
74 v8::Handle<v8::Value> FuncExit(const v8::Arguments& args);
75 v8::Handle<v8::Value> FuncState(const v8::Arguments& args);
76 v8::Handle<v8::Value> FuncSetState(const v8::Arguments& args);
77 v8::Handle<v8::Value> FuncGetState(const v8::Arguments& args);
78 v8::Handle<v8::Value> FuncNewState(const v8::Arguments& args);
79 //v8::Handle<v8::Value> FuncOpen(const v8::Arguments& args);
80 v8::Handle<v8::Value> FuncSubscribe(const v8::Arguments& args);
81 v8::Handle<v8::Value> FuncGetData(const v8::Arguments &args);
82 v8::Handle<v8::Value> FuncClose(const v8::Arguments &args);
83 v8::Handle<v8::Value> FuncQuery(const v8::Arguments &args);
84 v8::Handle<v8::Value> FuncDatabase(const v8::Arguments &args);
85 v8::Handle<v8::Value> FuncDbQuery(const v8::Arguments &args);
86 v8::Handle<v8::Value> FuncDbClose(const v8::Arguments &args);
87 v8::Handle<v8::Value> OnChangeSet(v8::Local<v8::String>, v8::Local<v8::Value>, const v8::AccessorInfo &);
88
89 static double GetDataMember(const v8::Arguments &args, const char *name);
90
91 static v8::Handle<v8::Value> LocalToString(const v8::Arguments &args);
92 static v8::Handle<v8::Value> SkyToString(const v8::Arguments &args);
93 static v8::Handle<v8::Value> MoonToString(const v8::Arguments &args);
94 static v8::Handle<v8::Value> LocalDist(const v8::Arguments &args);
95 static v8::Handle<v8::Value> MoonDisk(const v8::Arguments &args);
96 static v8::Handle<v8::Value> LocalToSky(const v8::Arguments &args);
97 static v8::Handle<v8::Value> SkyToLocal(const v8::Arguments &args);
98 static v8::Handle<v8::Value> MoonToLocal(const v8::Arguments &args);
99 static v8::Handle<v8::Value> ConstructorMoon(const v8::Arguments &args);
100 static v8::Handle<v8::Value> ConstructorSky(const v8::Arguments &args);
101 static v8::Handle<v8::Value> ConstructorLocal(const v8::Arguments &args);
102
103 static v8::Handle<v8::Value> FuncVersion(const v8::Arguments&);
104 static v8::Handle<v8::Value> WrapInclude(const v8::Arguments &args) { if (This) return This->FuncInclude(args); else return v8::Undefined(); }
105 static v8::Handle<v8::Value> WrapFile(const v8::Arguments &args) { if (This) return This->FuncFile(args); else return v8::Undefined(); }
106 static v8::Handle<v8::Value> WrapPrint(const v8::Arguments &args) { if (This) return This->FuncPrint(args); else return v8::Undefined(); }
107 static v8::Handle<v8::Value> WrapAlarm(const v8::Arguments &args) { if (This) return This->FuncAlarm(args); else return v8::Undefined(); }
108 static v8::Handle<v8::Value> WrapOut(const v8::Arguments &args) { if (This) return This->FuncOut(args); else return v8::Undefined(); }
109 static v8::Handle<v8::Value> WrapWait(const v8::Arguments &args) { if (This) return This->FuncWait(args); else return v8::Undefined(); }
110 static v8::Handle<v8::Value> WrapSend(const v8::Arguments &args) { if (This) return This->FuncSend(args); else return v8::Undefined(); }
111 static v8::Handle<v8::Value> WrapSleep(const v8::Arguments &args) { if (This) return This->FuncSleep(args); else return v8::Undefined(); }
112 static v8::Handle<v8::Value> WrapTimeout(const v8::Arguments &args) { if (This) return This->FuncTimeout(args); else return v8::Undefined(); }
113 static v8::Handle<v8::Value> WrapExit(const v8::Arguments &args) { if (This) return This->FuncExit(args); else return v8::Undefined(); }
114 static v8::Handle<v8::Value> WrapState(const v8::Arguments &args) { if (This) return This->FuncState(args); else return v8::Undefined(); }
115 static v8::Handle<v8::Value> WrapNewState(const v8::Arguments &args) { if (This) return This->FuncNewState(args); else return v8::Undefined(); }
116 static v8::Handle<v8::Value> WrapSetState(const v8::Arguments &args) { if (This) return This->FuncSetState(args); else return v8::Undefined(); }
117 static v8::Handle<v8::Value> WrapGetState(const v8::Arguments &args) { if (This) return This->FuncGetState(args); else return v8::Undefined(); }
118 //static v8::Handle<v8::Value> WrapOpen(const v8::Arguments &args) { if (This) return This->FuncOpen(args); else return v8::Undefined(); }
119 static v8::Handle<v8::Value> WrapSubscribe(const v8::Arguments &args){ if (This) return This->FuncSubscribe(args);else return v8::Undefined(); }
120 static v8::Handle<v8::Value> WrapGetData(const v8::Arguments &args) { if (This) return This->FuncGetData(args); else return v8::Undefined(); }
121 static v8::Handle<v8::Value> WrapClose(const v8::Arguments &args) { if (This) return This->FuncClose(args); else return v8::Undefined(); }
122 static v8::Handle<v8::Value> WrapQuery(const v8::Arguments &args) { if (This) return This->FuncQuery(args); else return v8::Undefined(); }
123 static v8::Handle<v8::Value> WrapDatabase(const v8::Arguments &args) { if (This) return This->FuncDatabase(args); else return v8::Undefined(); }
124 static v8::Handle<v8::Value> WrapDbQuery(const v8::Arguments &args) { if (This) return This->FuncDbQuery(args); else return v8::Undefined(); }
125 static v8::Handle<v8::Value> WrapDbClose(const v8::Arguments &args) { if (This) return This->FuncDbClose(args); else return v8::Undefined(); }
126 static v8::Handle<v8::Value> WrapOnChangeSet(v8::Local<v8::String> prop, v8::Local<v8::Value> value, const v8::AccessorInfo &info)
127 {
128 if (This) return This->OnChangeSet(prop, value, info); else return v8::Undefined();
129 }
130
131 static v8::Handle<v8::Value> OnChangeGet(v8::Local<v8::String>, const v8::AccessorInfo &)
132 {
133 return v8::Handle<v8::Value>();
134 }
135
136 static v8::Handle<v8::Value> Convert(char type, const char* &ptr);
137 v8::Handle<v8::Value> ConvertEvent(const EventImp *evt, uint64_t, const char *str);
138#endif
139
140public:
141 InterpreterV8() : fThreadId(-1)
142 {
143 This = this;
144 }
145 virtual ~InterpreterV8()
146 {
147 This = 0;
148
149#ifdef HAVE_V8
150 v8::Locker locker;
151 v8::V8::Dispose();
152#endif
153 }
154
155 virtual void JsLoad(const std::string &) { }
156 virtual void JsStart(const std::string &) { }
157 virtual void JsEnd(const std::string &) { }
158 virtual void JsPrint(const std::string &) { }
159 virtual void JsAlarm(const std::string & = "") { }
160 virtual void JsOut(const std::string &) { }
161 virtual void JsResult(const std::string &) { }
162 virtual void JsException(const std::string &) { }
163 virtual bool JsSend(const std::string &) { return true; }
164 //virtual void JsSleep(uint32_t) { }
165 //virtual int JsWait(const std::string &, int32_t, uint32_t) { return -1; };
166 virtual State JsState(const std::string &) { return State(); };
167 virtual void *JsSubscribe(const std::string &) { return 0; };
168 virtual bool JsUnsubscribe(const std::string &) { return false; };
169
170 virtual bool JsNewState(int, const std::string&, const std::string&) { return false; }
171 virtual bool JsSetState(int) { return false; }
172 virtual bool JsHasState(int) const { return false; }
173 virtual bool JsHasState(const std::string &) const { return false; }
174 virtual int JsGetState(const std::string &) const { return -2; }
175 virtual State JsGetCurrentState() const { return State(); }
176
177 virtual std::vector<Description> JsDescription(const std::string &) { return std::vector<Description>(); };
178 virtual std::pair<uint64_t, EventImp *> JsGetEvent(const std::string &) { return std::make_pair(0, (EventImp*)0); };
179
180 void JsHandleEvent(const EventImp &, uint64_t, const std::string &);
181 void JsHandleState(const std::string &, const State &);
182
183 void AddFormatToGlobal() const;
184
185 bool JsRun(const std::string &, const std::map<std::string,std::string> & = std::map<std::string,std::string>());
186 static void JsStop();
187};
188
189#ifndef HAVE_V8
190inline bool InterpreterV8::JsRun(const std::string &, const std::map<std::string,std::string> &) { return false; }
191inline void InterpreterV8::JsStop() { }
192#endif
193
194#endif
Note: See TracBrowser for help on using the repository browser.