1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
|
/*
* Copyright (C) Rafal Szczesniak 2007
*/
/**
* Swat Net Manager class finite state machine
*/
qx.OO.defineClass("swat.module.netmgr.Fsm", swat.main.AbstractModuleFsm,
function()
{
swat.main.AbstractModuleFsm.call(this);
});
qx.Proto.buildFsm = function(module)
{
var fsm = module.fsm;
var _this = this;
/*
* State: Idle
*
* Actions upon entry
* - if returning from RPC, display the result
*
* Transition on:
* "changeselection" on tree
*/
var state = new qx.util.fsm.State(
"State_Idle",
{
"onentry" :
function(fsm, event)
{
if (fsm.getPreviousState() == "State_AwaitRpcResult")
{
var rpcRequest = _this.popRpcRequest();
var result = rpcRequest.getUserData("result");
var origins = swat.main.AbstractModuleFsm.JsonRpc_Origin;
var serverErrors = swat.main.AbstractModuleFsm.JsonRpc_ServerError;
if (result.type == "failed" &&
result.data.origin == origins.Server &&
result.data.code == serverErrors.ResourceError)
{
alert("Error when receiving rpc: '" + result.id + "'" + " exception: " + result.data);
}
else
{
// get the result of the call and apply it
var gui = swat.module.netmgr.Gui.getInstance();
gui.displayData(module, rpcRequest);
}
rpcRequest.request.dispose();
rpcRequest.request = null;
}
},
"events" :
{
"appear" :
{
"swat.main.canvas" :
"Transition_Idle_to_AwaitRpcResult_via_canvas_appear",
"vlayout":
"Transition_Idle_to_AwaitRpcResult_via_vlayout_appear"
},
"changeSelection" :
{
"tree" :
"Transition_Idle_to_Idle_via_tree_selection_changed"
},
"changeNetCtx" :
{
"swat.module.netmgr.Gui" :
"Transition_Idle_to_AwaitRpcResult_via_netCtx_changed"
}
}
});
// Replace the initial Idle state with this one
fsm.replaceState(state, true);
var trans = new qx.util.fsm.Transition(
"Transition_Idle_to_AwaitRpcResult_via_canvas_appear",
{
"nextState" : "State_AwaitRpcResult",
"ontransition" : function(fsm, event)
{
// Create default NetContext
var request = _this.callRpc(fsm, "samba.ejsnet", "NetContext", []);
request.setUserData("requestType", "NetContext");
}
});
// Add the new transition
state.addTransition(trans);
var trans = new qx.util.fsm.Transition(
"Transition_Idle_to_AwaitRpcResult_via_vlayout_appear",
{
"nextState" : "State_AwaitRpcResult",
"ontransition" :
function(fsm, event)
{
// Request our netbios name to add proper node to the tree
var request = _this.callRpc(fsm, "samba.config", "lp_get", [ "netbios name" ]);
request.setUserData("requestType", "hostname");
}
});
// Add the new transition
state.addTransition(trans);
var trans = new qx.util.fsm.Transition(
"Transition_Idle_to_Idle_via_tree_selection_changed",
{
"nextState" : "State_AwaitRpcResult",
"ontransition" : function(fsm, event)
{
var nodes = event.getData();
var selectedNode = nodes[0];
var gui = swat.module.netmgr.Gui.getInstance();
var parentNode = gui.getParentNode(module, selectedNode);
// Change current NetContext if necessary for this host
if (parentNode.netCtx != undefined)
{
module.setNetCtx(parentNode.netCtx);
}
var nodeName = selectedNode.label;
var callName = undefined; // rpc call name
var callArgs = [ gui.getNetCtx() ]; // NetContex goes first
switch (nodeName)
{
case "Users":
callName = "UserMgr";
break;
case "Groups":
case "Domain":
case "Services":
alert("View not implemented yet");
break;
default:
alert("Undefined call selected for node=['" + nodeName + "']");
}
// Bail out if no appropriate call name has been found
if (callName == undefined) return;
var req = _this.callRpc(fsm, "samba.ejsnet", callName, callArgs);
req.setUserData("requestType", "UserMgr");
}
});
// Add the new transition
state.addTransition(trans);
var trans = new qx.util.fsm.Transition(
"Transition_Idle_to_AwaitRpcResult_via_netCtx_changed",
{
"nextState" : "State_AwaitRpcResult",
"ontransition" : function(fsm, event)
{
var netCtxId = 0;
var req = _this.callRpc(fsm, "samba.ejsnet", "NetContextCreds", [ netCtxId ]);
req.setUserData("requestType", "NetContextCreds");
}
});
state.addTransition(trans);
blockedEvents =
{
"appear":
{
"tree" : qx.util.fsm.FiniteStateMachine.EventHandling.BLOCKED,
"vlayout" : qx.util.fsm.FiniteStateMachine.EventHandling.BLOCKED
}
}
// Add blocked events
this.addAwaitRpcResultState(module, blockedEvents);
};
/**
* Singleton Instance Getter
*/
qx.Class.getInstance = qx.lang.Function.returnInstance;
|
