diff options
Diffstat (limited to 'OpenSim')
-rw-r--r-- | OpenSim/Framework/PluginManager.cs | 561 | ||||
-rw-r--r-- | OpenSim/Server/Base/CommandManager.cs | 359 | ||||
-rw-r--r-- | OpenSim/Server/Base/ServerUtils.cs | 163 | ||||
-rw-r--r-- | OpenSim/Server/Base/ServicesServerBase.cs | 10 | ||||
-rw-r--r-- | OpenSim/Server/Handlers/Base/ServerConnector.cs | 67 | ||||
-rw-r--r-- | OpenSim/Server/ServerMain.cs | 10 |
6 files changed, 1169 insertions, 1 deletions
diff --git a/OpenSim/Framework/PluginManager.cs b/OpenSim/Framework/PluginManager.cs new file mode 100644 index 0000000..188d90a --- /dev/null +++ b/OpenSim/Framework/PluginManager.cs | |||
@@ -0,0 +1,561 @@ | |||
1 | |||
2 | /* | ||
3 | * Copyright (c) Contributors, http://opensimulator.org/ | ||
4 | * See CONTRIBUTORS.TXT for a full list of copyright holders. | ||
5 | * | ||
6 | * Redistribution and use in source and binary forms, with or without | ||
7 | * modification, are permitted provided that the following conditions are met: | ||
8 | * * Redistributions of source code must retain the above copyright | ||
9 | * notice, this list of conditions and the following disclaimer. | ||
10 | * * Redistributions in binary form must reproduce the above copyright | ||
11 | * notice, this list of conditions and the following disclaimer in the | ||
12 | * documentation and/or other materials provided with the distribution. | ||
13 | * * Neither the name of the OpenSimulator Project nor the | ||
14 | * names of its contributors may be used to endorse or promote products | ||
15 | * derived from this software without specific prior written permission. | ||
16 | * | ||
17 | * THIS SOFTWARE IS PROVIDED BY THE DEVELOPERS ``AS IS'' AND ANY | ||
18 | * EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED | ||
19 | * WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE | ||
20 | * DISCLAIMED. IN NO EVENT SHALL THE CONTRIBUTORS BE LIABLE FOR ANY | ||
21 | * DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES | ||
22 | * (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; | ||
23 | * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND | ||
24 | * ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT | ||
25 | * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS | ||
26 | * SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. | ||
27 | */ | ||
28 | |||
29 | |||
30 | using System; | ||
31 | using System.Text; | ||
32 | using System.Linq; | ||
33 | using System.Collections; | ||
34 | using System.Collections.Generic; | ||
35 | using System.Collections.ObjectModel; | ||
36 | using Mono.Addins; | ||
37 | using Mono.Addins.Setup; | ||
38 | using Mono.Addins.Description; | ||
39 | using OpenSim.Framework; | ||
40 | |||
41 | |||
42 | namespace OpenSim.Framework | ||
43 | { | ||
44 | /// <summary> | ||
45 | /// Manager for registries and plugins | ||
46 | /// </summary> | ||
47 | public class PluginManager : SetupService | ||
48 | { | ||
49 | public AddinRegistry PluginRegistry; | ||
50 | |||
51 | public PluginManager(AddinRegistry registry): base (registry) | ||
52 | { | ||
53 | PluginRegistry = registry; | ||
54 | |||
55 | } | ||
56 | |||
57 | /// <summary> | ||
58 | /// Installs the plugin. | ||
59 | /// </summary> | ||
60 | /// <returns> | ||
61 | /// The plugin. | ||
62 | /// </returns> | ||
63 | /// <param name='args'> | ||
64 | /// Arguments. | ||
65 | /// </param> | ||
66 | public bool InstallPlugin(int ndx, out Dictionary<string, object> result) | ||
67 | { | ||
68 | Dictionary<string, object> res = new Dictionary<string, object>(); | ||
69 | |||
70 | PackageCollection pack = new PackageCollection(); | ||
71 | PackageCollection toUninstall; | ||
72 | DependencyCollection unresolved; | ||
73 | |||
74 | IProgressStatus ps = new ConsoleProgressStatus(false); | ||
75 | |||
76 | AddinRepositoryEntry[] available = GetSortedAvailbleAddins(); | ||
77 | |||
78 | if (ndx > (available.Length - 1)) | ||
79 | { | ||
80 | MainConsole.Instance.Output("Selection out of range"); | ||
81 | result = res; | ||
82 | return false; | ||
83 | } | ||
84 | |||
85 | AddinRepositoryEntry aentry = available[ndx]; | ||
86 | |||
87 | Package p = Package.FromRepository(aentry); | ||
88 | pack.Add(p); | ||
89 | |||
90 | ResolveDependencies(ps, pack, out toUninstall, out unresolved); | ||
91 | |||
92 | // Attempt to install the plugin disabled | ||
93 | if (Install(ps, pack) == true) | ||
94 | { | ||
95 | PluginRegistry.Update(ps); | ||
96 | Addin addin = PluginRegistry.GetAddin(aentry.Addin.Id); | ||
97 | PluginRegistry.DisableAddin(addin.Id); | ||
98 | addin.Enabled = false; | ||
99 | |||
100 | MainConsole.Instance.Output("Installation Success"); | ||
101 | ListInstalledAddins(out res); | ||
102 | result = res; | ||
103 | return true; | ||
104 | } | ||
105 | else | ||
106 | { | ||
107 | MainConsole.Instance.Output("Installation Failed"); | ||
108 | result = res; | ||
109 | return false; | ||
110 | } | ||
111 | } | ||
112 | |||
113 | // Remove plugin | ||
114 | /// <summary> | ||
115 | /// Uns the install. | ||
116 | /// </summary> | ||
117 | /// <param name='args'> | ||
118 | /// Arguments. | ||
119 | /// </param> | ||
120 | public void UnInstall(int ndx) | ||
121 | { | ||
122 | Addin[] addins = GetSortedAddinList("RobustPlugin"); | ||
123 | |||
124 | if (ndx > (addins.Length -1)) | ||
125 | { | ||
126 | MainConsole.Instance.Output("Selection out of range"); | ||
127 | return; | ||
128 | } | ||
129 | |||
130 | Addin addin = addins[ndx]; | ||
131 | MainConsole.Instance.OutputFormat("Uninstalling plugin {0}", addin.Id); | ||
132 | AddinManager.Registry.DisableAddin(addin.Id); | ||
133 | addin.Enabled = false; | ||
134 | IProgressStatus ps = new ConsoleProgressStatus(false); | ||
135 | Uninstall(ps, addin.Id); | ||
136 | MainConsole.Instance.Output("Uninstall Success - restart to complete operation"); | ||
137 | return; | ||
138 | } | ||
139 | |||
140 | /// <summary> | ||
141 | /// Checks the installed. | ||
142 | /// </summary> | ||
143 | /// <returns> | ||
144 | /// The installed. | ||
145 | /// </returns> | ||
146 | public string CheckInstalled() | ||
147 | { | ||
148 | return "CheckInstall"; | ||
149 | } | ||
150 | |||
151 | /// <summary> | ||
152 | /// Lists the installed addins. | ||
153 | /// </summary> | ||
154 | /// <param name='result'> | ||
155 | /// Result. | ||
156 | /// </param> | ||
157 | public void ListInstalledAddins(out Dictionary<string, object> result) | ||
158 | { | ||
159 | Dictionary<string, object> res = new Dictionary<string, object>(); | ||
160 | |||
161 | Addin[] addins = GetSortedAddinList("RobustPlugin"); | ||
162 | if(addins.Count() < 1) | ||
163 | { | ||
164 | MainConsole.Instance.Output("Error!"); | ||
165 | } | ||
166 | int count = 0; | ||
167 | foreach (Addin addin in addins) | ||
168 | { | ||
169 | Dictionary<string, object> r = new Dictionary<string, object>(); | ||
170 | r["enabled"] = addin.Enabled == true ? true : false; | ||
171 | r["name"] = addin.LocalId; | ||
172 | r["version"] = addin.Version; | ||
173 | |||
174 | res.Add(count.ToString(), r); | ||
175 | |||
176 | count++; | ||
177 | } | ||
178 | result = res; | ||
179 | return; | ||
180 | } | ||
181 | |||
182 | // List compatible plugins in registered repositories | ||
183 | /// <summary> | ||
184 | /// Lists the available. | ||
185 | /// </summary> | ||
186 | /// <param name='result'> | ||
187 | /// Result. | ||
188 | /// </param> | ||
189 | public void ListAvailable(out Dictionary<string, object> result) | ||
190 | { | ||
191 | Dictionary<string, object> res = new Dictionary<string, object>(); | ||
192 | |||
193 | AddinRepositoryEntry[] addins = GetSortedAvailbleAddins(); | ||
194 | |||
195 | int count = 0; | ||
196 | foreach (AddinRepositoryEntry addin in addins) | ||
197 | { | ||
198 | Dictionary<string, object> r = new Dictionary<string, object>(); | ||
199 | r["name"] = addin.Addin.Name; | ||
200 | r["version"] = addin.Addin.Version; | ||
201 | r["repository"] = addin.RepositoryName; | ||
202 | |||
203 | res.Add(count.ToString(), r); | ||
204 | count++; | ||
205 | } | ||
206 | result = res; | ||
207 | return; | ||
208 | } | ||
209 | |||
210 | // List available updates ** 1 | ||
211 | /// <summary> | ||
212 | /// Lists the updates. | ||
213 | /// </summary> | ||
214 | public void ListUpdates() | ||
215 | { | ||
216 | IProgressStatus ps = new ConsoleProgressStatus(true); | ||
217 | Console.WriteLine ("Looking for updates..."); | ||
218 | Repositories.UpdateAllRepositories (ps); | ||
219 | Console.WriteLine ("Available add-in updates:"); | ||
220 | bool found = false; | ||
221 | AddinRepositoryEntry[] entries = Repositories.GetAvailableUpdates(); | ||
222 | |||
223 | foreach (AddinRepositoryEntry entry in entries) | ||
224 | { | ||
225 | Console.WriteLine(String.Format("{0}",entry.Addin.Id)); | ||
226 | } | ||
227 | } | ||
228 | |||
229 | // Sync to repositories | ||
230 | /// <summary> | ||
231 | /// Update this instance. | ||
232 | /// </summary> | ||
233 | public string Update() | ||
234 | { | ||
235 | IProgressStatus ps = new ConsoleProgressStatus(true); | ||
236 | Repositories.UpdateAllRepositories(ps); | ||
237 | return "Update"; | ||
238 | } | ||
239 | |||
240 | // Register a repository | ||
241 | /// <summary> | ||
242 | /// Register a repository with our server. | ||
243 | /// </summary> | ||
244 | /// <returns> | ||
245 | /// result of the action | ||
246 | /// </returns> | ||
247 | /// <param name='repo'> | ||
248 | /// The URL of the repository we want to add | ||
249 | /// </param> | ||
250 | public bool AddRepository(string repo) | ||
251 | { | ||
252 | Repositories.RegisterRepository(null, repo, true); | ||
253 | PluginRegistry.Rebuild(null); | ||
254 | |||
255 | return true; | ||
256 | } | ||
257 | |||
258 | /// <summary> | ||
259 | /// Gets the repository. | ||
260 | /// </summary> | ||
261 | public void GetRepository() | ||
262 | { | ||
263 | Repositories.UpdateAllRepositories(new ConsoleProgressStatus(false)); | ||
264 | } | ||
265 | |||
266 | // Remove a repository from the list | ||
267 | /// <summary> | ||
268 | /// Removes the repository. | ||
269 | /// </summary> | ||
270 | /// <param name='args'> | ||
271 | /// Arguments. | ||
272 | /// </param> | ||
273 | public void RemoveRepository(string[] args) | ||
274 | { | ||
275 | AddinRepository[] reps = Repositories.GetRepositories(); | ||
276 | Array.Sort(reps, (r1,r2) => r1.Title.CompareTo(r2.Title)); | ||
277 | if (reps.Length == 0) | ||
278 | { | ||
279 | MainConsole.Instance.Output("No repositories have been registered."); | ||
280 | return; | ||
281 | } | ||
282 | |||
283 | int n = Convert.ToInt16(args[2]); | ||
284 | if (n > (reps.Length -1)) | ||
285 | { | ||
286 | MainConsole.Instance.Output("Selection out of range"); | ||
287 | return; | ||
288 | } | ||
289 | |||
290 | AddinRepository rep = reps[n]; | ||
291 | Repositories.RemoveRepository(rep.Url); | ||
292 | return; | ||
293 | } | ||
294 | |||
295 | // Enable repository | ||
296 | /// <summary> | ||
297 | /// Enables the repository. | ||
298 | /// </summary> | ||
299 | /// <param name='args'> | ||
300 | /// Arguments. | ||
301 | /// </param> | ||
302 | public void EnableRepository(string[] args) | ||
303 | { | ||
304 | AddinRepository[] reps = Repositories.GetRepositories(); | ||
305 | Array.Sort(reps, (r1,r2) => r1.Title.CompareTo(r2.Title)); | ||
306 | if (reps.Length == 0) | ||
307 | { | ||
308 | MainConsole.Instance.Output("No repositories have been registered."); | ||
309 | return; | ||
310 | } | ||
311 | |||
312 | int n = Convert.ToInt16(args[2]); | ||
313 | if (n > (reps.Length -1)) | ||
314 | { | ||
315 | MainConsole.Instance.Output("Selection out of range"); | ||
316 | return; | ||
317 | } | ||
318 | |||
319 | AddinRepository rep = reps[n]; | ||
320 | Repositories.SetRepositoryEnabled(rep.Url, true); | ||
321 | return; | ||
322 | } | ||
323 | |||
324 | // Disable a repository | ||
325 | /// <summary> | ||
326 | /// Disables the repository. | ||
327 | /// </summary> | ||
328 | /// <param name='args'> | ||
329 | /// Arguments. | ||
330 | /// </param> | ||
331 | public void DisableRepository(string[] args) | ||
332 | { | ||
333 | AddinRepository[] reps = Repositories.GetRepositories(); | ||
334 | Array.Sort(reps, (r1,r2) => r1.Title.CompareTo(r2.Title)); | ||
335 | if (reps.Length == 0) | ||
336 | { | ||
337 | MainConsole.Instance.Output("No repositories have been registered."); | ||
338 | return; | ||
339 | } | ||
340 | |||
341 | int n = Convert.ToInt16(args[2]); | ||
342 | if (n > (reps.Length -1)) | ||
343 | { | ||
344 | MainConsole.Instance.Output("Selection out of range"); | ||
345 | return; | ||
346 | } | ||
347 | |||
348 | AddinRepository rep = reps[n]; | ||
349 | Repositories.SetRepositoryEnabled(rep.Url, false); | ||
350 | return; | ||
351 | } | ||
352 | |||
353 | // List registered repositories | ||
354 | /// <summary> | ||
355 | /// Lists the repositories. | ||
356 | /// </summary> | ||
357 | /// <param name='result'> | ||
358 | /// Result. | ||
359 | /// </param> | ||
360 | public void ListRepositories(out Dictionary<string, object> result) | ||
361 | { | ||
362 | Dictionary<string, object> res = new Dictionary<string, object>(); | ||
363 | result = res; | ||
364 | |||
365 | AddinRepository[] reps = GetSortedAddinRepo(); | ||
366 | if (reps.Length == 0) | ||
367 | { | ||
368 | MainConsole.Instance.Output("No repositories have been registered."); | ||
369 | return; | ||
370 | } | ||
371 | |||
372 | int count = 0; | ||
373 | foreach (AddinRepository rep in reps) | ||
374 | { | ||
375 | Dictionary<string, object> r = new Dictionary<string, object>(); | ||
376 | r["enabled"] = rep.Enabled == true ? true : false; | ||
377 | r["name"] = rep.Name; | ||
378 | r["url"] = rep.Url; | ||
379 | |||
380 | res.Add(count.ToString(), r); | ||
381 | count++; | ||
382 | } | ||
383 | return; | ||
384 | } | ||
385 | |||
386 | /// <summary> | ||
387 | /// Updates the registry. | ||
388 | /// </summary> | ||
389 | public void UpdateRegistry() | ||
390 | { | ||
391 | PluginRegistry.Update(); | ||
392 | } | ||
393 | |||
394 | // Show plugin info | ||
395 | /// <summary> | ||
396 | /// Addins the info. | ||
397 | /// </summary> | ||
398 | /// <returns> | ||
399 | /// The info. | ||
400 | /// </returns> | ||
401 | /// <param name='args'> | ||
402 | /// Arguments. | ||
403 | /// </param> | ||
404 | public bool AddinInfo(int ndx, out Dictionary<string, object> result) | ||
405 | { | ||
406 | Dictionary<string, object> res = new Dictionary<string, object>(); | ||
407 | result = res; | ||
408 | |||
409 | Addin[] addins = GetSortedAddinList("RobustPlugin"); | ||
410 | |||
411 | if (ndx > (addins.Length - 1)) | ||
412 | { | ||
413 | MainConsole.Instance.Output("Selection out of range"); | ||
414 | return false; | ||
415 | } | ||
416 | // author category description | ||
417 | Addin addin = addins[ndx]; | ||
418 | |||
419 | res["author"] = addin.Description.Author; | ||
420 | res["category"] = addin.Description.Category; | ||
421 | res["description"] = addin.Description.Description; | ||
422 | res["name"] = addin.Name; | ||
423 | res["url"] = addin.Description.Url; | ||
424 | res["file_name"] = addin.Description.FileName; | ||
425 | |||
426 | result = res; | ||
427 | return true; | ||
428 | } | ||
429 | |||
430 | // Disable a plugin | ||
431 | /// <summary> | ||
432 | /// Disables the plugin. | ||
433 | /// </summary> | ||
434 | /// <param name='args'> | ||
435 | /// Arguments. | ||
436 | /// </param> | ||
437 | public void DisablePlugin(string[] args) | ||
438 | { | ||
439 | Addin[] addins = GetSortedAddinList("RobustPlugin"); | ||
440 | |||
441 | int n = Convert.ToInt16(args[2]); | ||
442 | if (n > (addins.Length -1)) | ||
443 | { | ||
444 | MainConsole.Instance.Output("Selection out of range"); | ||
445 | return; | ||
446 | } | ||
447 | |||
448 | Addin addin = addins[n]; | ||
449 | AddinManager.Registry.DisableAddin(addin.Id); | ||
450 | addin.Enabled = false; | ||
451 | return; | ||
452 | } | ||
453 | |||
454 | // Enable plugin | ||
455 | /// <summary> | ||
456 | /// Enables the plugin. | ||
457 | /// </summary> | ||
458 | /// <param name='args'> | ||
459 | /// Arguments. | ||
460 | /// </param> | ||
461 | public void EnablePlugin(string[] args) | ||
462 | { | ||
463 | Addin[] addins = GetSortedAddinList("RobustPlugin"); | ||
464 | |||
465 | int n = Convert.ToInt16(args[2]); | ||
466 | if (n > (addins.Length -1)) | ||
467 | { | ||
468 | MainConsole.Instance.Output("Selection out of range"); | ||
469 | return; | ||
470 | } | ||
471 | |||
472 | Addin addin = addins[n]; | ||
473 | |||
474 | addin.Enabled = true; | ||
475 | AddinManager.Registry.EnableAddin(addin.Id); | ||
476 | // AddinManager.Registry.Update(); | ||
477 | if(PluginRegistry.IsAddinEnabled(addin.Id)) | ||
478 | { | ||
479 | ConsoleProgressStatus ps = new ConsoleProgressStatus(false); | ||
480 | if (!AddinManager.AddinEngine.IsAddinLoaded(addin.Id)) | ||
481 | { | ||
482 | AddinManager.Registry.Rebuild(ps); | ||
483 | AddinManager.AddinEngine.LoadAddin(ps, addin.Id); | ||
484 | } | ||
485 | } | ||
486 | else | ||
487 | { | ||
488 | MainConsole.Instance.OutputFormat("Not Enabled in this domain {0}", addin.Name); | ||
489 | } | ||
490 | return; | ||
491 | } | ||
492 | |||
493 | |||
494 | |||
495 | #region Util | ||
496 | private void Testing() | ||
497 | { | ||
498 | Addin[] list = Registry.GetAddins(); | ||
499 | |||
500 | var addins = list.Where( a => a.Description.Category == "RobustPlugin"); | ||
501 | |||
502 | foreach (Addin addin in addins) | ||
503 | { | ||
504 | MainConsole.Instance.OutputFormat("Addin {0}", addin.Name); | ||
505 | } | ||
506 | } | ||
507 | |||
508 | // These will let us deal with numbered lists instead | ||
509 | // of needing to type in the full ids | ||
510 | private AddinRepositoryEntry[] GetSortedAvailbleAddins() | ||
511 | { | ||
512 | ArrayList list = new ArrayList(); | ||
513 | list.AddRange(Repositories.GetAvailableAddins()); | ||
514 | |||
515 | AddinRepositoryEntry[] addins = list.ToArray(typeof(AddinRepositoryEntry)) as AddinRepositoryEntry[]; | ||
516 | |||
517 | Array.Sort(addins,(r1,r2) => r1.Addin.Id.CompareTo(r2.Addin.Id)); | ||
518 | |||
519 | return addins; | ||
520 | } | ||
521 | |||
522 | private AddinRepository[] GetSortedAddinRepo() | ||
523 | { | ||
524 | ArrayList list = new ArrayList(); | ||
525 | list.AddRange(Repositories.GetRepositories()); | ||
526 | |||
527 | AddinRepository[] repos = list.ToArray(typeof(AddinRepository)) as AddinRepository[]; | ||
528 | Array.Sort (repos,(r1,r2) => r1.Name.CompareTo(r2.Name)); | ||
529 | |||
530 | return repos; | ||
531 | } | ||
532 | |||
533 | private Addin[] GetSortedAddinList(string category) | ||
534 | { | ||
535 | |||
536 | ArrayList xlist = new ArrayList(); | ||
537 | ArrayList list = new ArrayList(); | ||
538 | try | ||
539 | { | ||
540 | list.AddRange(PluginRegistry.GetAddins()); | ||
541 | } | ||
542 | catch(Exception e) | ||
543 | { | ||
544 | Addin[] x = xlist.ToArray(typeof(Addin)) as Addin[]; | ||
545 | return x; | ||
546 | } | ||
547 | |||
548 | foreach (Addin addin in list) | ||
549 | { | ||
550 | if (addin.Description.Category == category) | ||
551 | xlist.Add(addin); | ||
552 | } | ||
553 | |||
554 | Addin[] addins = xlist.ToArray(typeof(Addin)) as Addin[]; | ||
555 | Array.Sort(addins,(r1,r2) => r1.Id.CompareTo(r2.Id)); | ||
556 | |||
557 | return addins; | ||
558 | } | ||
559 | #endregion Util | ||
560 | } | ||
561 | } | ||
diff --git a/OpenSim/Server/Base/CommandManager.cs b/OpenSim/Server/Base/CommandManager.cs new file mode 100644 index 0000000..88aac00 --- /dev/null +++ b/OpenSim/Server/Base/CommandManager.cs | |||
@@ -0,0 +1,359 @@ | |||
1 | /* | ||
2 | * Copyright (c) Contributors, http://opensimulator.org/ | ||
3 | * See CONTRIBUTORS.TXT for a full list of copyright holders. | ||
4 | * | ||
5 | * Redistribution and use in source and binary forms, with or without | ||
6 | * modification, are permitted provided that the following conditions are met: | ||
7 | * * Redistributions of source code must retain the above copyright | ||
8 | * notice, this list of conditions and the following disclaimer. | ||
9 | * * Redistributions in binary form must reproduce the above copyright | ||
10 | * notice, this list of conditions and the following disclaimer in the | ||
11 | * documentation and/or other materials provided with the distribution. | ||
12 | * * Neither the name of the OpenSimulator Project nor the | ||
13 | * names of its contributors may be used to endorse or promote products | ||
14 | * derived from this software without specific prior written permission. | ||
15 | * | ||
16 | * THIS SOFTWARE IS PROVIDED BY THE DEVELOPERS ``AS IS'' AND ANY | ||
17 | * EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED | ||
18 | * WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE | ||
19 | * DISCLAIMED. IN NO EVENT SHALL THE CONTRIBUTORS BE LIABLE FOR ANY | ||
20 | * DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES | ||
21 | * (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; | ||
22 | * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND | ||
23 | * ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT | ||
24 | * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS | ||
25 | * SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. | ||
26 | */ | ||
27 | |||
28 | |||
29 | using System; | ||
30 | using System.Text; | ||
31 | using System.Linq; | ||
32 | using System.Collections; | ||
33 | using System.Collections.Generic; | ||
34 | using System.Collections.ObjectModel; | ||
35 | using Mono.Addins; | ||
36 | // using Mono.Addins.Setup; | ||
37 | using Mono.Addins.Description; | ||
38 | using OpenSim.Framework; | ||
39 | |||
40 | namespace OpenSim.Server.Base | ||
41 | { | ||
42 | /// <summary> | ||
43 | /// Command manager - | ||
44 | /// Wrapper for OpenSim.Framework.PluginManager to allow | ||
45 | /// us to add commands to the console to perform operations | ||
46 | /// on our repos and plugins | ||
47 | /// </summary> | ||
48 | public class CommandManager | ||
49 | { | ||
50 | public AddinRegistry PluginRegistry; | ||
51 | protected PluginManager PluginManager; | ||
52 | |||
53 | public CommandManager(AddinRegistry registry) | ||
54 | { | ||
55 | PluginRegistry = registry; | ||
56 | PluginManager = new PluginManager(PluginRegistry); | ||
57 | AddManagementCommands(); | ||
58 | } | ||
59 | |||
60 | private void AddManagementCommands() | ||
61 | { | ||
62 | // add plugin | ||
63 | MainConsole.Instance.Commands.AddCommand("Plugin", true, | ||
64 | "plugin add", "plugin add \"plugin index\"", | ||
65 | "Install plugin from repository.", | ||
66 | HandleConsoleInstallPlugin); | ||
67 | |||
68 | // remove plugin | ||
69 | MainConsole.Instance.Commands.AddCommand("Plugin", true, | ||
70 | "plugin remove", "plugin remove \"plugin index\"", | ||
71 | "Remove plugin from repository", | ||
72 | HandleConsoleUnInstallPlugin); | ||
73 | |||
74 | // list installed plugins | ||
75 | MainConsole.Instance.Commands.AddCommand("Plugin", true, | ||
76 | "plugin list installed", | ||
77 | "plugin list installed","List install plugins", | ||
78 | HandleConsoleListInstalledPlugin); | ||
79 | |||
80 | // list plugins available from registered repositories | ||
81 | MainConsole.Instance.Commands.AddCommand("Plugin", true, | ||
82 | "plugin list available", | ||
83 | "plugin list available","List available plugins", | ||
84 | HandleConsoleListAvailablePlugin); | ||
85 | // List available updates | ||
86 | MainConsole.Instance.Commands.AddCommand("Plugin", true, | ||
87 | "plugin updates", "plugin updates","List availble updates", | ||
88 | HandleConsoleListUpdates); | ||
89 | |||
90 | // Update plugin | ||
91 | MainConsole.Instance.Commands.AddCommand("Plugin", true, | ||
92 | "plugin update", "plugin update \"plugin index\"","Update the plugin", | ||
93 | HandleConsoleUpdatePlugin); | ||
94 | |||
95 | // Add repository | ||
96 | MainConsole.Instance.Commands.AddCommand("Repository", true, | ||
97 | "repo add", "repo add \"url\"","Add repository", | ||
98 | HandleConsoleAddRepo); | ||
99 | |||
100 | // Refresh repo | ||
101 | MainConsole.Instance.Commands.AddCommand("Repository", true, | ||
102 | "repo refresh", "repo refresh \"url\"", "Sync with a registered repository", | ||
103 | HandleConsoleGetRepo); | ||
104 | |||
105 | // Remove repository from registry | ||
106 | MainConsole.Instance.Commands.AddCommand("Repository", true, | ||
107 | "repo remove", | ||
108 | "repo remove \"[url | index]\"", | ||
109 | "Remove repository from registry", | ||
110 | HandleConsoleRemoveRepo); | ||
111 | |||
112 | // Enable repo | ||
113 | MainConsole.Instance.Commands.AddCommand("Repository", true, | ||
114 | "repo enable", "repo enable \"[url | index]\"", | ||
115 | "Enable registered repository", | ||
116 | HandleConsoleEnableRepo); | ||
117 | |||
118 | // Disable repo | ||
119 | MainConsole.Instance.Commands.AddCommand("Repository", true, | ||
120 | "repo disable", "repo disable\"[url | index]\"", | ||
121 | "Disable registered repository", | ||
122 | HandleConsoleDisableRepo); | ||
123 | |||
124 | // List registered repositories | ||
125 | MainConsole.Instance.Commands.AddCommand("Repository", true, | ||
126 | "repo list", "repo list", | ||
127 | "List registered repositories", | ||
128 | HandleConsoleListRepos); | ||
129 | |||
130 | // * | ||
131 | MainConsole.Instance.Commands.AddCommand("Plugin", true, | ||
132 | "plugin info", "plugin info \"plugin index\"","Show detailed information for plugin", | ||
133 | HandleConsoleShowAddinInfo); | ||
134 | |||
135 | // Plugin disable | ||
136 | MainConsole.Instance.Commands.AddCommand("Plugin", true, | ||
137 | "plugin disable", "plugin disable \"plugin index\"", | ||
138 | "Disable a plugin", | ||
139 | HandleConsoleDisablePlugin); | ||
140 | |||
141 | // Enable plugin | ||
142 | MainConsole.Instance.Commands.AddCommand("Plugin", true, | ||
143 | "plugin enable", "plugin enable \"plugin index\"", | ||
144 | "Enable the selected plugin plugin", | ||
145 | HandleConsoleEnablePlugin); | ||
146 | } | ||
147 | |||
148 | #region console handlers | ||
149 | // Handle our console commands | ||
150 | // | ||
151 | // Install plugin from registered repository | ||
152 | /// <summary> | ||
153 | /// Handles the console install plugin command. Attempts to install the selected plugin | ||
154 | /// and | ||
155 | /// </summary> | ||
156 | /// <param name='module'> | ||
157 | /// Module. | ||
158 | /// </param> | ||
159 | /// <param name='cmd'> | ||
160 | /// Cmd. | ||
161 | /// </param> | ||
162 | private void HandleConsoleInstallPlugin(string module, string[] cmd) | ||
163 | { | ||
164 | Dictionary<string, object> result = new Dictionary<string, object>(); | ||
165 | |||
166 | if (cmd.Length == 3) | ||
167 | { | ||
168 | int ndx = Convert.ToInt16(cmd[2]); | ||
169 | if (PluginManager.InstallPlugin(ndx, out result) == true) | ||
170 | { | ||
171 | ArrayList s = new ArrayList(); | ||
172 | s.AddRange(result.Keys); | ||
173 | s.Sort(); | ||
174 | |||
175 | var list = result.Keys.ToList(); | ||
176 | list.Sort(); | ||
177 | foreach (var k in list) | ||
178 | { | ||
179 | Dictionary<string, object> plugin = (Dictionary<string, object>)result[k]; | ||
180 | bool enabled = (bool)plugin["enabled"]; | ||
181 | MainConsole.Instance.OutputFormat("{0}) {1} {2} rev. {3}", | ||
182 | k, | ||
183 | enabled == true ? "[ ]" : "[X]", | ||
184 | plugin["name"], plugin["version"]); | ||
185 | } | ||
186 | } | ||
187 | } | ||
188 | return; | ||
189 | } | ||
190 | |||
191 | // Remove installed plugin | ||
192 | private void HandleConsoleUnInstallPlugin(string module, string[] cmd) | ||
193 | { | ||
194 | if (cmd.Length == 3) | ||
195 | { | ||
196 | int ndx = Convert.ToInt16(cmd[2]); | ||
197 | PluginManager.UnInstall(ndx); | ||
198 | } | ||
199 | return; | ||
200 | } | ||
201 | |||
202 | // List installed plugins | ||
203 | private void HandleConsoleListInstalledPlugin(string module, string[] cmd) | ||
204 | { | ||
205 | Dictionary<string, object> result = new Dictionary<string, object>(); | ||
206 | PluginManager.ListInstalledAddins(out result); | ||
207 | |||
208 | ArrayList s = new ArrayList(); | ||
209 | s.AddRange(result.Keys); | ||
210 | s.Sort(); | ||
211 | |||
212 | var list = result.Keys.ToList(); | ||
213 | list.Sort(); | ||
214 | foreach (var k in list) | ||
215 | { | ||
216 | Dictionary<string, object> plugin = (Dictionary<string, object>)result[k]; | ||
217 | bool enabled = (bool)plugin["enabled"]; | ||
218 | MainConsole.Instance.OutputFormat("{0}) {1} {2} rev. {3}", | ||
219 | k, | ||
220 | enabled == true ? "[ ]" : "[X]", | ||
221 | plugin["name"], plugin["version"]); | ||
222 | } | ||
223 | return; | ||
224 | } | ||
225 | |||
226 | // List available plugins on registered repositories | ||
227 | private void HandleConsoleListAvailablePlugin(string module, string[] cmd) | ||
228 | { | ||
229 | Dictionary<string, object> result = new Dictionary<string, object>(); | ||
230 | PluginManager.ListAvailable(out result); | ||
231 | |||
232 | var list = result.Keys.ToList(); | ||
233 | list.Sort(); | ||
234 | foreach (var k in list) | ||
235 | { | ||
236 | // name, version, repository | ||
237 | Dictionary<string, object> plugin = (Dictionary<string, object>)result[k]; | ||
238 | MainConsole.Instance.OutputFormat("{0}) {1} rev. {2} {3}", | ||
239 | k, | ||
240 | plugin["name"], | ||
241 | plugin["version"], | ||
242 | plugin["repository"]); | ||
243 | } | ||
244 | return; | ||
245 | } | ||
246 | |||
247 | // List available updates **not ready | ||
248 | private void HandleConsoleListUpdates(string module, string[] cmd) | ||
249 | { | ||
250 | PluginManager.ListUpdates(); | ||
251 | return; | ||
252 | } | ||
253 | |||
254 | // Update plugin **not ready | ||
255 | private void HandleConsoleUpdatePlugin(string module, string[] cmd) | ||
256 | { | ||
257 | MainConsole.Instance.Output(PluginManager.Update()); | ||
258 | return; | ||
259 | } | ||
260 | |||
261 | // Register repository | ||
262 | private void HandleConsoleAddRepo(string module, string[] cmd) | ||
263 | { | ||
264 | if ( cmd.Length == 3) | ||
265 | { | ||
266 | PluginManager.AddRepository(cmd[2]); | ||
267 | } | ||
268 | return; | ||
269 | } | ||
270 | |||
271 | // Get repository status **not working | ||
272 | private void HandleConsoleGetRepo(string module, string[] cmd) | ||
273 | { | ||
274 | PluginManager.GetRepository(); | ||
275 | return; | ||
276 | } | ||
277 | |||
278 | // Remove registered repository | ||
279 | private void HandleConsoleRemoveRepo(string module, string[] cmd) | ||
280 | { | ||
281 | if (cmd.Length == 3) | ||
282 | PluginManager.RemoveRepository(cmd); | ||
283 | return; | ||
284 | } | ||
285 | |||
286 | // Enable repository | ||
287 | private void HandleConsoleEnableRepo(string module, string[] cmd) | ||
288 | { | ||
289 | PluginManager.EnableRepository(cmd); | ||
290 | return; | ||
291 | } | ||
292 | |||
293 | // Disable repository | ||
294 | private void HandleConsoleDisableRepo(string module, string[] cmd) | ||
295 | { | ||
296 | PluginManager.DisableRepository(cmd); | ||
297 | return; | ||
298 | } | ||
299 | |||
300 | // List repositories | ||
301 | private void HandleConsoleListRepos(string module, string[] cmd) | ||
302 | { | ||
303 | Dictionary<string, object> result = new Dictionary<string, object>(); | ||
304 | PluginManager.ListRepositories(out result); | ||
305 | |||
306 | var list = result.Keys.ToList(); | ||
307 | list.Sort(); | ||
308 | foreach (var k in list) | ||
309 | { | ||
310 | Dictionary<string, object> repo = (Dictionary<string, object>)result[k]; | ||
311 | bool enabled = (bool)repo["enabled"]; | ||
312 | MainConsole.Instance.OutputFormat("{0}) {1} {2}", | ||
313 | k, | ||
314 | enabled == true ? "[ ]" : "[X]", | ||
315 | repo["name"], repo["url"]); | ||
316 | } | ||
317 | |||
318 | return; | ||
319 | } | ||
320 | |||
321 | // Show description information | ||
322 | private void HandleConsoleShowAddinInfo(string module, string[] cmd) | ||
323 | { | ||
324 | if (cmd.Length >= 3) | ||
325 | { | ||
326 | |||
327 | Dictionary<string, object> result = new Dictionary<string, object>(); | ||
328 | |||
329 | int ndx = Convert.ToInt16(cmd[2]); | ||
330 | PluginManager.AddinInfo(ndx, out result); | ||
331 | |||
332 | MainConsole.Instance.OutputFormat("Name: {0}\nURL: {1}\nFile: {2}\nAuthor: {3}\nCategory: {4}\nDesc: {5}", | ||
333 | result["name"], | ||
334 | result["url"], | ||
335 | result["file_name"], | ||
336 | result["author"], | ||
337 | result["category"], | ||
338 | result["description"]); | ||
339 | |||
340 | return; | ||
341 | } | ||
342 | } | ||
343 | |||
344 | // Disable plugin | ||
345 | private void HandleConsoleDisablePlugin(string module, string[] cmd) | ||
346 | { | ||
347 | PluginManager.DisablePlugin(cmd); | ||
348 | return; | ||
349 | } | ||
350 | |||
351 | // Enable plugin | ||
352 | private void HandleConsoleEnablePlugin(string module, string[] cmd) | ||
353 | { | ||
354 | PluginManager.EnablePlugin(cmd); | ||
355 | return; | ||
356 | } | ||
357 | #endregion | ||
358 | } | ||
359 | } \ No newline at end of file | ||
diff --git a/OpenSim/Server/Base/ServerUtils.cs b/OpenSim/Server/Base/ServerUtils.cs index 42c82cf..31b0446 100644 --- a/OpenSim/Server/Base/ServerUtils.cs +++ b/OpenSim/Server/Base/ServerUtils.cs | |||
@@ -33,11 +33,137 @@ using System.Xml.Serialization; | |||
33 | using System.Text; | 33 | using System.Text; |
34 | using System.Collections.Generic; | 34 | using System.Collections.Generic; |
35 | using log4net; | 35 | using log4net; |
36 | using Nini.Config; | ||
36 | using OpenSim.Framework; | 37 | using OpenSim.Framework; |
37 | using OpenMetaverse; | 38 | using OpenMetaverse; |
39 | using Mono.Addins; | ||
40 | using OpenSim.Framework.Servers.HttpServer; | ||
41 | using OpenSim.Framework.Servers; | ||
38 | 42 | ||
43 | |||
44 | [assembly:AddinRoot("Robust", "0.1")] | ||
39 | namespace OpenSim.Server.Base | 45 | namespace OpenSim.Server.Base |
40 | { | 46 | { |
47 | [TypeExtensionPoint(Path="/Robust/Connector", Name="RobustConnector")] | ||
48 | public interface IRobustConnector | ||
49 | { | ||
50 | string ConfigName | ||
51 | { | ||
52 | get; | ||
53 | } | ||
54 | |||
55 | bool Enabled | ||
56 | { | ||
57 | get; | ||
58 | } | ||
59 | |||
60 | string PluginPath | ||
61 | { | ||
62 | get; | ||
63 | set; | ||
64 | } | ||
65 | |||
66 | uint Configure(IConfigSource config); | ||
67 | void Initialize(IHttpServer server); | ||
68 | void Unload(); | ||
69 | } | ||
70 | |||
71 | public class PluginLoader | ||
72 | { | ||
73 | static readonly ILog m_log = LogManager.GetLogger(MethodBase.GetCurrentMethod().DeclaringType); | ||
74 | |||
75 | public AddinRegistry Registry | ||
76 | { | ||
77 | get; | ||
78 | private set; | ||
79 | } | ||
80 | |||
81 | public IConfigSource Config | ||
82 | { | ||
83 | get; | ||
84 | private set; | ||
85 | } | ||
86 | |||
87 | public PluginLoader(IConfigSource config, string registryPath) | ||
88 | { | ||
89 | Config = config; | ||
90 | |||
91 | Registry = new AddinRegistry(registryPath, "."); | ||
92 | AddinManager.Initialize(registryPath); | ||
93 | AddinManager.Registry.Update(); | ||
94 | CommandManager commandmanager = new CommandManager(Registry); | ||
95 | AddinManager.AddExtensionNodeHandler("/Robust/Connector", OnExtensionChanged); | ||
96 | } | ||
97 | |||
98 | private void OnExtensionChanged(object s, ExtensionNodeEventArgs args) | ||
99 | { | ||
100 | IRobustConnector connector = (IRobustConnector)args.ExtensionObject; | ||
101 | Addin a = Registry.GetAddin(args.ExtensionNode.Addin.Id); | ||
102 | |||
103 | if(a == null) | ||
104 | { | ||
105 | Registry.Rebuild(null); | ||
106 | a = Registry.GetAddin(args.ExtensionNode.Addin.Id); | ||
107 | } | ||
108 | |||
109 | switch(args.Change) | ||
110 | { | ||
111 | case ExtensionChange.Add: | ||
112 | if (a.AddinFile.Contains(Registry.DefaultAddinsFolder)) | ||
113 | { | ||
114 | m_log.InfoFormat("[SERVER]: Adding {0} from registry", a.Name); | ||
115 | connector.PluginPath = String.Format("{0}/{1}", Registry.DefaultAddinsFolder, a.Name.Replace(',', '.')); | ||
116 | } | ||
117 | else | ||
118 | { | ||
119 | m_log.InfoFormat("[SERVER]: Adding {0} from ./bin", a.Name); | ||
120 | connector.PluginPath = a.AddinFile; | ||
121 | } | ||
122 | LoadPlugin(connector); | ||
123 | break; | ||
124 | case ExtensionChange.Remove: | ||
125 | m_log.InfoFormat("[SERVER]: Removing {0}", a.Name); | ||
126 | UnloadPlugin(connector); | ||
127 | break; | ||
128 | } | ||
129 | } | ||
130 | |||
131 | private void LoadPlugin(IRobustConnector connector) | ||
132 | { | ||
133 | IHttpServer server = null; | ||
134 | uint port = connector.Configure(Config); | ||
135 | |||
136 | if(connector.Enabled) | ||
137 | { | ||
138 | server = GetServer(connector, port); | ||
139 | connector.Initialize(server); | ||
140 | } | ||
141 | else | ||
142 | { | ||
143 | m_log.InfoFormat("[SERVER]: {0} Disabled.", connector.ConfigName); | ||
144 | } | ||
145 | } | ||
146 | |||
147 | private void UnloadPlugin(IRobustConnector connector) | ||
148 | { | ||
149 | m_log.InfoFormat("[Server]: Unloading {0}", connector.ConfigName); | ||
150 | |||
151 | connector.Unload(); | ||
152 | } | ||
153 | |||
154 | private IHttpServer GetServer(IRobustConnector connector, uint port) | ||
155 | { | ||
156 | IHttpServer server; | ||
157 | |||
158 | if(port != 0) | ||
159 | server = MainServer.GetHttpServer(port); | ||
160 | else | ||
161 | server = MainServer.Instance; | ||
162 | |||
163 | return server; | ||
164 | } | ||
165 | } | ||
166 | |||
41 | public static class ServerUtils | 167 | public static class ServerUtils |
42 | { | 168 | { |
43 | private static readonly ILog m_log = LogManager.GetLogger(MethodBase.GetCurrentMethod().DeclaringType); | 169 | private static readonly ILog m_log = LogManager.GetLogger(MethodBase.GetCurrentMethod().DeclaringType); |
@@ -333,5 +459,42 @@ namespace OpenSim.Server.Base | |||
333 | 459 | ||
334 | return ret; | 460 | return ret; |
335 | } | 461 | } |
462 | |||
463 | public static IConfig GetConfig(string configFile, string configName) | ||
464 | { | ||
465 | IConfig config; | ||
466 | |||
467 | if (File.Exists(configFile)) | ||
468 | { | ||
469 | IConfigSource configsource = new IniConfigSource(configFile); | ||
470 | config = configsource.Configs[configName]; | ||
471 | } | ||
472 | else | ||
473 | config = null; | ||
474 | |||
475 | return config; | ||
476 | } | ||
477 | |||
478 | public static IConfigSource LoadInitialConfig(string url) | ||
479 | { | ||
480 | IConfigSource source = new XmlConfigSource(); | ||
481 | m_log.InfoFormat("[CONFIG]: {0} is a http:// URI, fetching ...", url); | ||
482 | |||
483 | // The ini file path is a http URI | ||
484 | // Try to read it | ||
485 | try | ||
486 | { | ||
487 | XmlReader r = XmlReader.Create(url); | ||
488 | IConfigSource cs = new XmlConfigSource(r); | ||
489 | source.Merge(cs); | ||
490 | } | ||
491 | catch (Exception e) | ||
492 | { | ||
493 | m_log.FatalFormat("[CONFIG]: Exception reading config from URI {0}\n" + e.ToString(), url); | ||
494 | Environment.Exit(1); | ||
495 | } | ||
496 | |||
497 | return source; | ||
498 | } | ||
336 | } | 499 | } |
337 | } | 500 | } |
diff --git a/OpenSim/Server/Base/ServicesServerBase.cs b/OpenSim/Server/Base/ServicesServerBase.cs index 5b23149..ecd69b0 100644 --- a/OpenSim/Server/Base/ServicesServerBase.cs +++ b/OpenSim/Server/Base/ServicesServerBase.cs | |||
@@ -56,6 +56,12 @@ namespace OpenSim.Server.Base | |||
56 | // | 56 | // |
57 | protected string[] m_Arguments; | 57 | protected string[] m_Arguments; |
58 | 58 | ||
59 | public string ConfigDirectory | ||
60 | { | ||
61 | get; | ||
62 | private set; | ||
63 | } | ||
64 | |||
59 | // Run flag | 65 | // Run flag |
60 | // | 66 | // |
61 | private bool m_Running = true; | 67 | private bool m_Running = true; |
@@ -134,6 +140,8 @@ namespace OpenSim.Server.Base | |||
134 | startupConfig = Config.Configs["Startup"]; | 140 | startupConfig = Config.Configs["Startup"]; |
135 | } | 141 | } |
136 | 142 | ||
143 | ConfigDirectory = startupConfig.GetString("ConfigDirectory", "."); | ||
144 | |||
137 | prompt = startupConfig.GetString("Prompt", prompt); | 145 | prompt = startupConfig.GetString("Prompt", prompt); |
138 | 146 | ||
139 | // Allow derived classes to load config before the console is | 147 | // Allow derived classes to load config before the console is |
@@ -242,4 +250,4 @@ namespace OpenSim.Server.Base | |||
242 | { | 250 | { |
243 | } | 251 | } |
244 | } | 252 | } |
245 | } \ No newline at end of file | 253 | } |
diff --git a/OpenSim/Server/Handlers/Base/ServerConnector.cs b/OpenSim/Server/Handlers/Base/ServerConnector.cs index 71876da..72014db 100644 --- a/OpenSim/Server/Handlers/Base/ServerConnector.cs +++ b/OpenSim/Server/Handlers/Base/ServerConnector.cs | |||
@@ -39,8 +39,75 @@ namespace OpenSim.Server.Handlers.Base | |||
39 | 39 | ||
40 | public class ServiceConnector : IServiceConnector | 40 | public class ServiceConnector : IServiceConnector |
41 | { | 41 | { |
42 | public virtual string ConfigURL | ||
43 | { | ||
44 | get { return String.Empty; } | ||
45 | } | ||
46 | |||
47 | public virtual string ConfigName | ||
48 | { | ||
49 | get; | ||
50 | protected set; | ||
51 | } | ||
52 | |||
53 | public virtual string ConfigFile | ||
54 | { | ||
55 | get; | ||
56 | protected set; | ||
57 | } | ||
58 | |||
59 | public virtual IConfigSource Config | ||
60 | { | ||
61 | get; | ||
62 | protected set; | ||
63 | } | ||
64 | |||
65 | public ServiceConnector() | ||
66 | { | ||
67 | } | ||
68 | |||
42 | public ServiceConnector(IConfigSource config, IHttpServer server, string configName) | 69 | public ServiceConnector(IConfigSource config, IHttpServer server, string configName) |
43 | { | 70 | { |
44 | } | 71 | } |
72 | |||
73 | // We call this from our plugin module to get our configuration | ||
74 | public IConfig GetConfig() | ||
75 | { | ||
76 | IConfig config = null; | ||
77 | config = ServerUtils.GetConfig(ConfigFile, ConfigName); | ||
78 | |||
79 | // Our file is not here? We can get one to bootstrap our plugin module | ||
80 | if ( config == null ) | ||
81 | { | ||
82 | IConfigSource remotesource = GetConfigSource(); | ||
83 | |||
84 | if (remotesource != null) | ||
85 | { | ||
86 | IniConfigSource initialconfig = new IniConfigSource(); | ||
87 | initialconfig.Merge (remotesource); | ||
88 | initialconfig.Save(ConfigFile); | ||
89 | } | ||
90 | |||
91 | config = remotesource.Configs[ConfigName]; | ||
92 | } | ||
93 | |||
94 | return config; | ||
95 | } | ||
96 | |||
97 | // We get our remote initial configuration for bootstrapping in case | ||
98 | // we have no configuration in our main file or in an existing | ||
99 | // modular config file. This is the last resort to bootstrap the | ||
100 | // configuration, likely a new plugin loading for the first time. | ||
101 | private IConfigSource GetConfigSource() | ||
102 | { | ||
103 | IConfigSource source = null; | ||
104 | |||
105 | source = ServerUtils.LoadInitialConfig(ConfigURL); | ||
106 | |||
107 | if (source == null) | ||
108 | System.Console.WriteLine(String.Format ("Config Url: {0} Not found!", ConfigURL)); | ||
109 | |||
110 | return source; | ||
111 | } | ||
45 | } | 112 | } |
46 | } | 113 | } |
diff --git a/OpenSim/Server/ServerMain.cs b/OpenSim/Server/ServerMain.cs index 45c13fb..8be69a9 100644 --- a/OpenSim/Server/ServerMain.cs +++ b/OpenSim/Server/ServerMain.cs | |||
@@ -34,6 +34,7 @@ using OpenSim.Framework.Servers; | |||
34 | using OpenSim.Framework.Servers.HttpServer; | 34 | using OpenSim.Framework.Servers.HttpServer; |
35 | using OpenSim.Server.Base; | 35 | using OpenSim.Server.Base; |
36 | using OpenSim.Server.Handlers.Base; | 36 | using OpenSim.Server.Handlers.Base; |
37 | using Mono.Addins; | ||
37 | 38 | ||
38 | namespace OpenSim.Server | 39 | namespace OpenSim.Server |
39 | { | 40 | { |
@@ -48,9 +49,13 @@ namespace OpenSim.Server | |||
48 | protected static List<IServiceConnector> m_ServiceConnectors = | 49 | protected static List<IServiceConnector> m_ServiceConnectors = |
49 | new List<IServiceConnector>(); | 50 | new List<IServiceConnector>(); |
50 | 51 | ||
52 | protected static PluginLoader loader; | ||
53 | |||
51 | public static int Main(string[] args) | 54 | public static int Main(string[] args) |
52 | { | 55 | { |
53 | m_Server = new HttpServerBase("R.O.B.U.S.T.", args); | 56 | m_Server = new HttpServerBase("R.O.B.U.S.T.", args); |
57 | |||
58 | string registryLocation; | ||
54 | 59 | ||
55 | IConfig serverConfig = m_Server.Config.Configs["Startup"]; | 60 | IConfig serverConfig = m_Server.Config.Configs["Startup"]; |
56 | if (serverConfig == null) | 61 | if (serverConfig == null) |
@@ -60,6 +65,8 @@ namespace OpenSim.Server | |||
60 | } | 65 | } |
61 | 66 | ||
62 | string connList = serverConfig.GetString("ServiceConnectors", String.Empty); | 67 | string connList = serverConfig.GetString("ServiceConnectors", String.Empty); |
68 | |||
69 | registryLocation = serverConfig.GetString("RegistryLocation","."); | ||
63 | 70 | ||
64 | IConfig servicesConfig = m_Server.Config.Configs["ServiceList"]; | 71 | IConfig servicesConfig = m_Server.Config.Configs["ServiceList"]; |
65 | if (servicesConfig != null) | 72 | if (servicesConfig != null) |
@@ -141,6 +148,9 @@ namespace OpenSim.Server | |||
141 | m_log.InfoFormat("[SERVER]: Failed to load {0}", conn); | 148 | m_log.InfoFormat("[SERVER]: Failed to load {0}", conn); |
142 | } | 149 | } |
143 | } | 150 | } |
151 | |||
152 | loader = new PluginLoader(m_Server.Config, registryLocation); | ||
153 | |||
144 | int res = m_Server.Run(); | 154 | int res = m_Server.Run(); |
145 | 155 | ||
146 | Environment.Exit(res); | 156 | Environment.Exit(res); |