aboutsummaryrefslogtreecommitdiffstatshomepage
diff options
context:
space:
mode:
authorJustin Clarke Casey2009-02-11 18:46:51 +0000
committerJustin Clarke Casey2009-02-11 18:46:51 +0000
commit162a59ba17af6c1fe16036ae3d1510d5c895b914 (patch)
tree610429265416a6c6ac13500795d049eac324a9da
parent* More inventory archive invocation to a proper region module (diff)
downloadopensim-SC_OLD-162a59ba17af6c1fe16036ae3d1510d5c895b914.zip
opensim-SC_OLD-162a59ba17af6c1fe16036ae3d1510d5c895b914.tar.gz
opensim-SC_OLD-162a59ba17af6c1fe16036ae3d1510d5c895b914.tar.bz2
opensim-SC_OLD-162a59ba17af6c1fe16036ae3d1510d5c895b914.tar.xz
* Refactor inventory archive code to allow direct invocation in order to support future unit tests
* Add a file I missed out from the last commit (the build was probably fine without it)
-rw-r--r--OpenSim/Region/Application/OpenSimBase.cs4
-rw-r--r--OpenSim/Region/CoreModules/Avatar/Inventory/Archiver/InventoryArchiveReadRequest.cs67
-rw-r--r--OpenSim/Region/CoreModules/Avatar/Inventory/Archiver/InventoryArchiveWriteRequest.cs90
-rw-r--r--OpenSim/Region/CoreModules/Avatar/Inventory/Archiver/InventoryArchiverModule.cs169
-rw-r--r--OpenSim/Region/Framework/Interfaces/IInventoryArchiverModule.cs52
5 files changed, 328 insertions, 54 deletions
diff --git a/OpenSim/Region/Application/OpenSimBase.cs b/OpenSim/Region/Application/OpenSimBase.cs
index 6592a9b..43cb127 100644
--- a/OpenSim/Region/Application/OpenSimBase.cs
+++ b/OpenSim/Region/Application/OpenSimBase.cs
@@ -164,7 +164,7 @@ namespace OpenSim
164 } 164 }
165 165
166 /// <summary> 166 /// <summary>
167 /// Performs startup specific to this region server, including initialization of the scene 167 /// Performs startup specific to the region server, including initialization of the scene
168 /// such as loading configuration from disk. 168 /// such as loading configuration from disk.
169 /// </summary> 169 /// </summary>
170 protected override void StartupSpecific() 170 protected override void StartupSpecific()
@@ -175,7 +175,7 @@ namespace OpenSim
175 175
176 LibraryRootFolder libraryRootFolder = new LibraryRootFolder(m_configSettings.LibrariesXMLFile); 176 LibraryRootFolder libraryRootFolder = new LibraryRootFolder(m_configSettings.LibrariesXMLFile);
177 177
178 // StandAlone mode? is determined by !startupConfig.GetBoolean("gridmode", false) 178 // Standalone mode is determined by !startupConfig.GetBoolean("gridmode", false)
179 if (m_configSettings.Standalone) 179 if (m_configSettings.Standalone)
180 { 180 {
181 InitialiseStandaloneServices(libraryRootFolder); 181 InitialiseStandaloneServices(libraryRootFolder);
diff --git a/OpenSim/Region/CoreModules/Avatar/Inventory/Archiver/InventoryArchiveReadRequest.cs b/OpenSim/Region/CoreModules/Avatar/Inventory/Archiver/InventoryArchiveReadRequest.cs
index 704296c..7e57275 100644
--- a/OpenSim/Region/CoreModules/Avatar/Inventory/Archiver/InventoryArchiveReadRequest.cs
+++ b/OpenSim/Region/CoreModules/Avatar/Inventory/Archiver/InventoryArchiveReadRequest.cs
@@ -50,13 +50,37 @@ namespace OpenSim.Region.CoreModules.Avatar.Inventory.Archiver
50 protected TarArchiveReader archive; 50 protected TarArchiveReader archive;
51 private static System.Text.ASCIIEncoding m_asciiEncoding = new System.Text.ASCIIEncoding(); 51 private static System.Text.ASCIIEncoding m_asciiEncoding = new System.Text.ASCIIEncoding();
52 52
53 private string m_firstName;
54 private string m_lastName;
55 private string m_invPath;
56
57 /// <value>
58 /// The stream from which the inventory archive will be loaded.
59 /// </value>
60 private Stream m_loadStream;
61
53 CommunicationsManager commsManager; 62 CommunicationsManager commsManager;
54 63
55 public InventoryArchiveReadRequest(CommunicationsManager commsManager) 64 public InventoryArchiveReadRequest(
65 string firstName, string lastName, string invPath, string loadPath, CommunicationsManager commsManager)
66 : this(
67 firstName,
68 lastName,
69 invPath,
70 new GZipStream(new FileStream(loadPath, FileMode.Open), CompressionMode.Decompress),
71 commsManager)
56 { 72 {
57 //List<string> serialisedObjects = new List<string>();
58 this.commsManager = commsManager;
59 } 73 }
74
75 public InventoryArchiveReadRequest(
76 string firstName, string lastName, string invPath, Stream loadStream, CommunicationsManager commsManager)
77 {
78 m_firstName = firstName;
79 m_lastName = lastName;
80 m_invPath = invPath;
81 m_loadStream = loadStream;
82 this.commsManager = commsManager;
83 }
60 84
61 protected InventoryItemBase loadInvItem(string path, string contents) 85 protected InventoryItemBase loadInvItem(string path, string contents)
62 { 86 {
@@ -137,17 +161,17 @@ namespace OpenSim.Region.CoreModules.Avatar.Inventory.Archiver
137 return item; 161 return item;
138 } 162 }
139 163
140 public void execute(string firstName, string lastName, string invPath, string loadPath) 164 public void Execute()
141 { 165 {
142 string filePath = "ERROR"; 166 string filePath = "ERROR";
143 int successfulAssetRestores = 0; 167 int successfulAssetRestores = 0;
144 int failedAssetRestores = 0; 168 int failedAssetRestores = 0;
145 int successfulItemRestores = 0; 169 int successfulItemRestores = 0;
146 170
147 UserProfileData userProfile = commsManager.UserService.GetUserProfile(firstName, lastName); 171 UserProfileData userProfile = commsManager.UserService.GetUserProfile(m_firstName, m_lastName);
148 if (null == userProfile) 172 if (null == userProfile)
149 { 173 {
150 m_log.ErrorFormat("[CONSOLE]: Failed to find user {0} {1}", firstName, lastName); 174 m_log.ErrorFormat("[INVENTORY ARCHIVER]: Failed to find user {0} {1}", m_firstName, m_lastName);
151 return; 175 return;
152 } 176 }
153 177
@@ -155,8 +179,8 @@ namespace OpenSim.Region.CoreModules.Avatar.Inventory.Archiver
155 if (null == userInfo) 179 if (null == userInfo)
156 { 180 {
157 m_log.ErrorFormat( 181 m_log.ErrorFormat(
158 "[CONSOLE]: Failed to find user info for {0} {1} {2}", 182 "[INVENTORY ARCHIVER]: Failed to find user info for {0} {1} {2}",
159 firstName, lastName, userProfile.ID); 183 m_firstName, m_lastName, userProfile.ID);
160 184
161 return; 185 return;
162 } 186 }
@@ -164,33 +188,32 @@ namespace OpenSim.Region.CoreModules.Avatar.Inventory.Archiver
164 if (!userInfo.HasReceivedInventory) 188 if (!userInfo.HasReceivedInventory)
165 { 189 {
166 m_log.ErrorFormat( 190 m_log.ErrorFormat(
167 "[CONSOLE]: Have not yet received inventory info for user {0} {1} {2}", 191 "[INVENTORY ARCHIVER]: Have not yet received inventory info for user {0} {1} {2}",
168 firstName, lastName, userProfile.ID); 192 m_firstName, m_lastName, userProfile.ID);
169 193
170 return; 194 return;
171 } 195 }
172 196
173 InventoryFolderImpl inventoryFolder = userInfo.RootFolder.FindFolderByPath(invPath); 197 InventoryFolderImpl inventoryFolder = userInfo.RootFolder.FindFolderByPath(m_invPath);
174 198
175 if (null == inventoryFolder) 199 if (null == inventoryFolder)
176 { 200 {
177 // TODO: Later on, automatically create this folder if it does not exist 201 // TODO: Later on, automatically create this folder if it does not exist
178 m_log.ErrorFormat("[ARCHIVER]: Inventory path {0} does not exist", invPath); 202 m_log.ErrorFormat("[INVENTORY ARCHIVER]: Inventory path {0} does not exist", m_invPath);
179 203
180 return; 204 return;
181 } 205 }
182 206
183 archive 207 archive = new TarArchiveReader(m_loadStream);
184 = new TarArchiveReader(new GZipStream(
185 new FileStream(loadPath, FileMode.Open), CompressionMode.Decompress));
186 208
187 byte[] data; 209 byte[] data;
188 TarArchiveReader.TarEntryType entryType; 210 TarArchiveReader.TarEntryType entryType;
189 while ((data = archive.ReadEntry(out filePath, out entryType)) != null) 211 while ((data = archive.ReadEntry(out filePath, out entryType)) != null)
190 { 212 {
191 if (entryType == TarArchiveReader.TarEntryType.TYPE_DIRECTORY) { 213 if (entryType == TarArchiveReader.TarEntryType.TYPE_DIRECTORY) {
192 m_log.WarnFormat("[ARCHIVER]: Ignoring directory entry {0}", filePath); 214 m_log.WarnFormat("[INVENTORY ARCHIVER]: Ignoring directory entry {0}", filePath);
193 } else if (filePath.StartsWith(ArchiveConstants.ASSETS_PATH)) 215 }
216 else if (filePath.StartsWith(ArchiveConstants.ASSETS_PATH))
194 { 217 {
195 if (LoadAsset(filePath, data)) 218 if (LoadAsset(filePath, data))
196 successfulAssetRestores++; 219 successfulAssetRestores++;
@@ -219,8 +242,8 @@ namespace OpenSim.Region.CoreModules.Avatar.Inventory.Archiver
219 242
220 archive.Close(); 243 archive.Close();
221 244
222 m_log.DebugFormat("[ARCHIVER]: Restored {0} assets", successfulAssetRestores); 245 m_log.DebugFormat("[INVENTORY ARCHIVER]: Restored {0} assets", successfulAssetRestores);
223 m_log.InfoFormat("[ARCHIVER]: Restored {0} items", successfulItemRestores); 246 m_log.InfoFormat("[INVENTORY ARCHIVER]: Restored {0} items", successfulItemRestores);
224 } 247 }
225 248
226 /// <summary> 249 /// <summary>
@@ -239,7 +262,7 @@ namespace OpenSim.Region.CoreModules.Avatar.Inventory.Archiver
239 if (i == -1) 262 if (i == -1)
240 { 263 {
241 m_log.ErrorFormat( 264 m_log.ErrorFormat(
242 "[ARCHIVER]: Could not find extension information in asset path {0} since it's missing the separator {1}. Skipping", 265 "[INVENTORY ARCHIVER]: Could not find extension information in asset path {0} since it's missing the separator {1}. Skipping",
243 assetPath, ArchiveConstants.ASSET_EXTENSION_SEPARATOR); 266 assetPath, ArchiveConstants.ASSET_EXTENSION_SEPARATOR);
244 267
245 return false; 268 return false;
@@ -252,7 +275,7 @@ namespace OpenSim.Region.CoreModules.Avatar.Inventory.Archiver
252 { 275 {
253 sbyte assetType = ArchiveConstants.EXTENSION_TO_ASSET_TYPE[extension]; 276 sbyte assetType = ArchiveConstants.EXTENSION_TO_ASSET_TYPE[extension];
254 277
255 m_log.DebugFormat("[ARCHIVER]: Importing asset {0}, type {1}", uuid, assetType); 278 m_log.DebugFormat("[INVENTORY ARCHIVER]: Importing asset {0}, type {1}", uuid, assetType);
256 279
257 AssetBase asset = new AssetBase(new UUID(uuid), "RandomName"); 280 AssetBase asset = new AssetBase(new UUID(uuid), "RandomName");
258 281
@@ -266,7 +289,7 @@ namespace OpenSim.Region.CoreModules.Avatar.Inventory.Archiver
266 else 289 else
267 { 290 {
268 m_log.ErrorFormat( 291 m_log.ErrorFormat(
269 "[ARCHIVER]: Tried to dearchive data with path {0} with an unknown type extension {1}", 292 "[INVENTORY ARCHIVER]: Tried to dearchive data with path {0} with an unknown type extension {1}",
270 assetPath, extension); 293 assetPath, extension);
271 294
272 return false; 295 return false;
diff --git a/OpenSim/Region/CoreModules/Avatar/Inventory/Archiver/InventoryArchiveWriteRequest.cs b/OpenSim/Region/CoreModules/Avatar/Inventory/Archiver/InventoryArchiveWriteRequest.cs
index 90e2fcd..bfa4de9 100644
--- a/OpenSim/Region/CoreModules/Avatar/Inventory/Archiver/InventoryArchiveWriteRequest.cs
+++ b/OpenSim/Region/CoreModules/Avatar/Inventory/Archiver/InventoryArchiveWriteRequest.cs
@@ -43,29 +43,53 @@ namespace OpenSim.Region.CoreModules.Avatar.Inventory.Archiver
43{ 43{
44 public class InventoryArchiveWriteRequest 44 public class InventoryArchiveWriteRequest
45 { 45 {
46 private static readonly ILog m_log = LogManager.GetLogger(MethodBase.GetCurrentMethod().DeclaringType); 46 private static readonly ILog m_log = LogManager.GetLogger(MethodBase.GetCurrentMethod().DeclaringType);
47 47
48 protected TarArchiveWriter archive; 48 protected TarArchiveWriter archive = new TarArchiveWriter();
49 protected CommunicationsManager commsManager; 49 protected CommunicationsManager commsManager;
50 Dictionary<UUID, int> assetUuids; 50 protected Dictionary<UUID, int> assetUuids = new Dictionary<UUID, int>();
51
52 private string m_firstName;
53 private string m_lastName;
54 private string m_invPath;
51 55
52 /// <value> 56 /// <value>
53 /// The path to which the inventory archive will be saved. 57 /// The stream to which the inventory archive will be saved.
54 /// </value> 58 /// </value>
55 private string m_savePath; 59 private Stream m_saveStream;
56 60
57 public InventoryArchiveWriteRequest(CommunicationsManager commsManager) 61 /// <summary>
62 /// Constructor
63 /// </summary>
64 public InventoryArchiveWriteRequest(
65 string firstName, string lastName, string invPath, string savePath, CommunicationsManager commsManager)
66 : this(
67 firstName,
68 lastName,
69 invPath,
70 new GZipStream(new FileStream(savePath, FileMode.Create), CompressionMode.Compress),
71 commsManager)
72 {
73 }
74
75 /// <summary>
76 /// Constructor
77 /// </summary>
78 public InventoryArchiveWriteRequest(
79 string firstName, string lastName, string invPath, Stream saveStream, CommunicationsManager commsManager)
58 { 80 {
59 archive = new TarArchiveWriter(); 81 m_firstName = firstName;
82 m_lastName = lastName;
83 m_invPath = invPath;
84 m_saveStream = saveStream;
60 this.commsManager = commsManager; 85 this.commsManager = commsManager;
61 assetUuids = new Dictionary<UUID, int>();
62 } 86 }
63 87
64 protected void ReceivedAllAssets(IDictionary<UUID, AssetBase> assetsFound, ICollection<UUID> assetsNotFoundUuids) 88 protected void ReceivedAllAssets(IDictionary<UUID, AssetBase> assetsFound, ICollection<UUID> assetsNotFoundUuids)
65 { 89 {
66 AssetsArchiver assetsArchiver = new AssetsArchiver(assetsFound); 90 AssetsArchiver assetsArchiver = new AssetsArchiver(assetsFound);
67 assetsArchiver.Archive(archive); 91 assetsArchiver.Archive(archive);
68 archive.WriteTar(new GZipStream(new FileStream(m_savePath, FileMode.Create), CompressionMode.Compress)); 92 archive.WriteTar(m_saveStream);
69 } 93 }
70 94
71 protected void saveInvItem(InventoryItemBase inventoryItem, string path) 95 protected void saveInvItem(InventoryItemBase inventoryItem, string path)
@@ -158,21 +182,21 @@ namespace OpenSim.Region.CoreModules.Avatar.Inventory.Archiver
158 } 182 }
159 } 183 }
160 184
161 public void execute(string firstName, string lastName, string invPath, string savePath) 185 public void Execute()
162 { 186 {
163 m_savePath = savePath; 187 UserProfileData userProfile = commsManager.UserService.GetUserProfile(m_firstName, m_lastName);
164
165 UserProfileData userProfile = commsManager.UserService.GetUserProfile(firstName, lastName);
166 if (null == userProfile) 188 if (null == userProfile)
167 { 189 {
168 m_log.ErrorFormat("[CONSOLE]: Failed to find user {0} {1}", firstName, lastName); 190 m_log.ErrorFormat("[INVENTORY ARCHIVER]: Failed to find user {0} {1}", m_firstName, m_lastName);
169 return; 191 return;
170 } 192 }
171 193
172 CachedUserInfo userInfo = commsManager.UserProfileCacheService.GetUserDetails(userProfile.ID); 194 CachedUserInfo userInfo = commsManager.UserProfileCacheService.GetUserDetails(userProfile.ID);
173 if (null == userInfo) 195 if (null == userInfo)
174 { 196 {
175 m_log.ErrorFormat("[CONSOLE]: Failed to find user info for {0} {1} {2}", firstName, lastName, userProfile.ID); 197 m_log.ErrorFormat(
198 "[INVENTORY ARCHIVER]: Failed to find user info for {0} {1} {2}",
199 m_firstName, m_lastName, userProfile.ID);
176 return; 200 return;
177 } 201 }
178 202
@@ -184,34 +208,36 @@ namespace OpenSim.Region.CoreModules.Avatar.Inventory.Archiver
184 // Eliminate double slashes and any leading / on the path. This might be better done within InventoryFolderImpl 208 // Eliminate double slashes and any leading / on the path. This might be better done within InventoryFolderImpl
185 // itself (possibly at a small loss in efficiency). 209 // itself (possibly at a small loss in efficiency).
186 string[] components 210 string[] components
187 = invPath.Split(new string[] { InventoryFolderImpl.PATH_DELIMITER }, StringSplitOptions.RemoveEmptyEntries); 211 = m_invPath.Split(new string[] { InventoryFolderImpl.PATH_DELIMITER }, StringSplitOptions.RemoveEmptyEntries);
188 invPath = String.Empty; 212 m_invPath = String.Empty;
189 foreach (string c in components) 213 foreach (string c in components)
190 { 214 {
191 invPath += c + InventoryFolderImpl.PATH_DELIMITER; 215 m_invPath += c + InventoryFolderImpl.PATH_DELIMITER;
192 } 216 }
193 217
194 // Annoyingly Split actually returns the original string if the input string consists only of delimiters 218 // Annoyingly Split actually returns the original string if the input string consists only of delimiters
195 // Therefore if we still start with a / after the split, then we need the root folder 219 // Therefore if we still start with a / after the split, then we need the root folder
196 if (invPath.Length == 0) 220 if (m_invPath.Length == 0)
197 { 221 {
198 inventoryFolder = userInfo.RootFolder; 222 inventoryFolder = userInfo.RootFolder;
199 } 223 }
200 else 224 else
201 { 225 {
202 invPath = invPath.Remove(invPath.LastIndexOf(InventoryFolderImpl.PATH_DELIMITER)); 226 m_invPath = m_invPath.Remove(m_invPath.LastIndexOf(InventoryFolderImpl.PATH_DELIMITER));
203 inventoryFolder = userInfo.RootFolder.FindFolderByPath(invPath); 227 inventoryFolder = userInfo.RootFolder.FindFolderByPath(m_invPath);
204 } 228 }
205 229
206 // The path may point to an item instead 230 // The path may point to an item instead
207 if (inventoryFolder == null) 231 if (inventoryFolder == null)
208 { 232 {
209 inventoryItem = userInfo.RootFolder.FindItemByPath(invPath); 233 inventoryItem = userInfo.RootFolder.FindItemByPath(m_invPath);
210 } 234 }
211 } 235 }
212 else 236 else
213 { 237 {
214 m_log.ErrorFormat("[CONSOLE]: Have not yet received inventory info for user {0} {1} {2}", firstName, lastName, userProfile.ID); 238 m_log.ErrorFormat(
239 "[INVENTORY ARCHIVER]: Have not yet received inventory info for user {0} {1} {2}",
240 m_firstName, m_lastName, userProfile.ID);
215 return; 241 return;
216 } 242 }
217 243
@@ -219,21 +245,25 @@ namespace OpenSim.Region.CoreModules.Avatar.Inventory.Archiver
219 { 245 {
220 if (null == inventoryItem) 246 if (null == inventoryItem)
221 { 247 {
222 m_log.ErrorFormat("[CONSOLE]: Could not find inventory entry at path {0}", invPath); 248 m_log.ErrorFormat("[INVENTORY ARCHIVER]: Could not find inventory entry at path {0}", m_invPath);
223 return; 249 return;
224 } 250 }
225 else 251 else
226 { 252 {
227 m_log.InfoFormat("[CONSOLE]: Found item {0} {1} at {2}", inventoryItem.Name, inventoryItem.ID, 253 m_log.InfoFormat(
228 invPath); 254 "[INVENTORY ARCHIVER]: Found item {0} {1} at {2}",
255 inventoryItem.Name, inventoryItem.ID, m_invPath);
256
229 //get and export item info 257 //get and export item info
230 saveInvItem(inventoryItem, invPath); 258 saveInvItem(inventoryItem, m_invPath);
231 } 259 }
232 } 260 }
233 else 261 else
234 { 262 {
235 m_log.InfoFormat("[CONSOLE]: Found folder {0} {1} at {2}", inventoryFolder.Name, inventoryFolder.ID, 263 m_log.InfoFormat(
236 invPath); 264 "[INVENTORY ARCHIVER]: Found folder {0} {1} at {2}",
265 inventoryFolder.Name, inventoryFolder.ID, m_invPath);
266
237 //recurse through all dirs getting dirs and files 267 //recurse through all dirs getting dirs and files
238 saveInvDir(inventoryFolder, ""); 268 saveInvDir(inventoryFolder, "");
239 } 269 }
diff --git a/OpenSim/Region/CoreModules/Avatar/Inventory/Archiver/InventoryArchiverModule.cs b/OpenSim/Region/CoreModules/Avatar/Inventory/Archiver/InventoryArchiverModule.cs
new file mode 100644
index 0000000..0c489e5
--- /dev/null
+++ b/OpenSim/Region/CoreModules/Avatar/Inventory/Archiver/InventoryArchiverModule.cs
@@ -0,0 +1,169 @@
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 OpenSim 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
28using System.Collections.Generic;
29using System.IO;
30using System.Reflection;
31using log4net;
32using Nini.Config;
33using OpenMetaverse;
34using OpenSim.Framework.Communications;
35using OpenSim.Region.Framework.Interfaces;
36using OpenSim.Region.Framework.Scenes;
37
38namespace OpenSim.Region.CoreModules.Avatar.Inventory.Archiver
39{
40 /// <summary>
41 /// This module loads and saves OpenSimulator inventory archives
42 /// </summary>
43 public class InventoryArchiverModule : IRegionModule, IInventoryArchiverModule
44 {
45 private static readonly ILog m_log = LogManager.GetLogger(MethodBase.GetCurrentMethod().DeclaringType);
46
47 public string Name { get { return "Inventory Archiver Module"; } }
48
49 public bool IsSharedModule { get { return true; } }
50
51 /// <summary>
52 /// The file to load and save inventory if no filename has been specified
53 /// </summary>
54 protected const string DEFAULT_INV_BACKUP_FILENAME = "user-inventory_iar.tar.gz";
55
56 /// <value>
57 /// All scenes that this module knows about
58 /// </value>
59 private Dictionary<UUID, Scene> m_scenes = new Dictionary<UUID, Scene>();
60
61 /// <value>
62 /// The comms manager we will use for all comms requests
63 /// </value>
64 private CommunicationsManager m_commsManager;
65
66 public void Initialise(Scene scene, IConfigSource source)
67 {
68 if (m_scenes.Count == 0)
69 {
70 scene.RegisterModuleInterface<IInventoryArchiverModule>(this);
71 m_commsManager = scene.CommsManager;
72
73 scene.AddCommand(
74 this, "load iar",
75 "load iar <first> <last> <inventory path> [<archive path>]",
76 "Load user inventory archive. EXPERIMENTAL, PLEASE DO NOT USE YET", HandleLoadInvConsoleCommand);
77
78 scene.AddCommand(
79 this, "save iar",
80 "save iar <first> <last> <inventory path> [<archive path>]",
81 "Save user inventory archive. EXPERIMENTAL, PLEASE DO NOT USE YET", HandleSaveInvConsoleCommand);
82 }
83
84 m_scenes[scene.RegionInfo.RegionID] = scene;
85 }
86
87 public void PostInitialise()
88 {
89 }
90
91 public void Close()
92 {
93 }
94
95 public void DearchiveInventory(string firstName, string lastName, string invPath, Stream loadStream)
96 {
97 if (m_scenes.Count > 0)
98 {
99 new InventoryArchiveReadRequest(firstName, lastName, invPath, loadStream, m_commsManager).Execute();
100 }
101 }
102
103 public void ArchiveInventory(string firstName, string lastName, string invPath, Stream saveStream)
104 {
105 if (m_scenes.Count > 0)
106 {
107 new InventoryArchiveWriteRequest(firstName, lastName, invPath, saveStream, m_commsManager).Execute();
108 }
109 }
110
111 public void DearchiveInventory(string firstName, string lastName, string invPath, string loadPath)
112 {
113 if (m_scenes.Count > 0)
114 {
115 new InventoryArchiveReadRequest(firstName, lastName, invPath, loadPath, m_commsManager).Execute();
116 }
117 }
118
119 public void ArchiveInventory(string firstName, string lastName, string invPath, string savePath)
120 {
121 if (m_scenes.Count > 0)
122 {
123 new InventoryArchiveWriteRequest(firstName, lastName, invPath, savePath, m_commsManager).Execute();
124 }
125 }
126
127 /// <summary>
128 /// Load inventory from an inventory file archive
129 /// </summary>
130 /// <param name="cmdparams"></param>
131 protected void HandleLoadInvConsoleCommand(string module, string[] cmdparams)
132 {
133 if (cmdparams.Length < 5)
134 {
135 m_log.Error(
136 "[INVENTORY ARCHIVER]: usage is load iar <first name> <last name> <inventory path> [<load file path>]");
137 return;
138 }
139
140 string firstName = cmdparams[2];
141 string lastName = cmdparams[3];
142 string invPath = cmdparams[4];
143 string loadPath = (cmdparams.Length > 5 ? cmdparams[5] : DEFAULT_INV_BACKUP_FILENAME);
144
145 DearchiveInventory(firstName, lastName, invPath, loadPath);
146 }
147
148 /// <summary>
149 /// Save inventory to a file archive
150 /// </summary>
151 /// <param name="cmdparams"></param>
152 protected void HandleSaveInvConsoleCommand(string module, string[] cmdparams)
153 {
154 if (cmdparams.Length < 5)
155 {
156 m_log.Error(
157 "[INVENTORY ARCHIVER]: usage is save iar <first name> <last name> <inventory path> [<save file path>]");
158 return;
159 }
160
161 string firstName = cmdparams[2];
162 string lastName = cmdparams[3];
163 string invPath = cmdparams[4];
164 string savePath = (cmdparams.Length > 5 ? cmdparams[5] : DEFAULT_INV_BACKUP_FILENAME);
165
166 ArchiveInventory(firstName, lastName, invPath, savePath);
167 }
168 }
169}
diff --git a/OpenSim/Region/Framework/Interfaces/IInventoryArchiverModule.cs b/OpenSim/Region/Framework/Interfaces/IInventoryArchiverModule.cs
new file mode 100644
index 0000000..0e1e851
--- /dev/null
+++ b/OpenSim/Region/Framework/Interfaces/IInventoryArchiverModule.cs
@@ -0,0 +1,52 @@
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 OpenSim 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
28using System.IO;
29
30namespace OpenSim.Region.Framework.Interfaces
31{
32 public interface IInventoryArchiverModule
33 {
34 /// <summary>
35 /// Dearchive a user's inventory folder from the given stream
36 /// </summary>
37 /// <param name="firstName"></param>
38 /// <param name="lastName"></param>
39 /// <param name="invPath">The inventory path in which to place the loaded folders and items</param>
40 /// <param name="loadStream">The stream from which the inventory archive will be loaded</param>
41 void DearchiveInventory(string firstName, string lastName, string invPath, Stream loadStream);
42
43 /// <summary>
44 /// Archive a user's inventory folder to the given stream
45 /// </summary>
46 /// <param name="firstName"></param>
47 /// <param name="lastName"></param>
48 /// <param name="invPath">The inventory path from which the inventory should be saved.</param>
49 /// <param name="saveStream">The stream to which the inventory archive will be saved</param>
50 void ArchiveInventory(string firstName, string lastName, string invPath, Stream saveStream);
51 }
52}