Autopsy  4.4.1
Graphical digital forensics platform for The Sleuth Kit and other tools.
AddRawImageTask.java
Go to the documentation of this file.
1 package org.sleuthkit.autopsy.datasourceprocessors;
2 
3 /*
4  * Autopsy Forensic Browser
5  *
6  * Copyright 2011-2016 Basis Technology Corp.
7  * Contact: carrier <at> sleuthkit <dot> org
8  *
9  * Licensed under the Apache License, Version 2.0 (the "License");
10  * you may not use this file except in compliance with the License.
11  * You may obtain a copy of the License at
12  *
13  * http://www.apache.org/licenses/LICENSE-2.0
14  *
15  * Unless required by applicable law or agreed to in writing, software
16  * distributed under the License is distributed on an "AS IS" BASIS,
17  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
18  * See the License for the specific language governing permissions and
19  * limitations under the License.
20  */
21 
22 
23 import java.io.File;
24 import java.nio.file.Paths;
25 import java.util.ArrayList;
26 import java.util.List;
27 import java.util.logging.Level;
32 import org.sleuthkit.datamodel.Content;
33 import org.sleuthkit.datamodel.Image;
34 import org.sleuthkit.datamodel.SleuthkitCase;
35 import org.sleuthkit.datamodel.TskCoreException;
36 import org.sleuthkit.datamodel.TskFileRange;
37 import org.openide.util.NbBundle.Messages;
38 
39 /*
40  * A runnable that adds a raw data source to a case database.
41  */
42 final class AddRawImageTask implements Runnable {
43 
44  private static final Logger logger = Logger.getLogger(AddRawImageTask.class.getName());
45  private final String deviceId;
46  private final String imageFilePath;
47  private final String timeZone;
48  private final long chunkSize;
49  private final DataSourceProcessorProgressMonitor progressMonitor;
50  private final DataSourceProcessorCallback callback;
51  private boolean criticalErrorOccurred;
52  private static final long TWO_GB = 2000000000L;
53 
70  AddRawImageTask(String deviceId, String imageFilePath, String timeZone, long chunkSize, DataSourceProcessorProgressMonitor progressMonitor, DataSourceProcessorCallback callback) {
71  this.deviceId = deviceId;
72  this.imageFilePath = imageFilePath;
73  this.timeZone = timeZone;
74  this.chunkSize = chunkSize;
75  this.callback = callback;
76  this.progressMonitor = progressMonitor;
77  }
78 
82  @Override
83  public void run() {
84  /*
85  * Process the input image file.
86  */
87  progressMonitor.setIndeterminate(true);
88  progressMonitor.setProgress(0);
89  List<Content> newDataSources = new ArrayList<>();
90  List<String> errorMessages = new ArrayList<>();
91  addImageToCase(newDataSources, errorMessages);
92 
93  progressMonitor.setProgress(100);
94 
99  if (criticalErrorOccurred) {
101  } else if (!errorMessages.isEmpty()) {
103  } else {
105  }
106  callback.done(result, errorMessages, newDataSources);
107  criticalErrorOccurred = false;
108  }
109 
120  @Messages({"AddRawImageTask.progress.add.text=Adding raw image: ",
121  "AddRawImageTask.image.critical.error.adding=Critical error adding ",
122  "AddRawImageTask.for.device=for device ",
123  "AddRawImageTask.image.notExisting=is not existing.",
124  "AddRawImageTask.image.noncritical.error.adding=Non-critical error adding "})
125  private void addImageToCase(List<Content> dataSources, List<String> errorMessages) {
126  progressMonitor.setProgressText(Bundle.AddRawImageTask_progress_add_text() + imageFilePath);
127  List<String> imageFilePaths = new ArrayList<>();
128  SleuthkitCase caseDatabase = Case.getCurrentCase().getSleuthkitCase();
129  caseDatabase.acquireExclusiveLock();
130 
131  File imageFile = Paths.get(imageFilePath).toFile();
132  if (!imageFile.exists()) {
133  String errorMessage = Bundle.AddRawImageTask_image_critical_error_adding() + imageFilePath + Bundle.AddRawImageTask_for_device()
134  + deviceId + Bundle.AddRawImageTask_image_notExisting();
135  errorMessages.add(errorMessage);
136  logger.log(Level.SEVERE, errorMessage);
137  criticalErrorOccurred = true;
138  return;
139  }
140 
141  imageFilePaths.add(imageFilePath);
142 
143  try {
144  /*
145  * Get Image that will be added to case
146  */
147  Image dataSource = caseDatabase.addImageInfo(0, imageFilePaths, timeZone); //TODO: change hard coded deviceId.
148  dataSources.add(dataSource);
149  List<TskFileRange> fileRanges = new ArrayList<>();
150 
151  /*
152  * Verify the size of the new image. Note that it may not be what is
153  * expected, but at least part of it was added to the case.
154  */
155  String verificationError = dataSource.verifyImageSize();
156  if (!verificationError.isEmpty()) {
157  errorMessages.add(Bundle.AddRawImageTask_image_noncritical_error_adding() + imageFilePaths + Bundle.AddRawImageTask_for_device() + deviceId + ":" + verificationError);
158  }
159 
160  long imageSize = dataSource.getSize();
161  int sequence = 0;
162  //start byte and end byte
163  long start = 0;
164  if (chunkSize > 0 && imageSize >= TWO_GB) {
165  for (double size = TWO_GB; size < dataSource.getSize(); size += TWO_GB) {
166  fileRanges.add(new TskFileRange(start, TWO_GB, sequence));
167  start += TWO_GB;
168  sequence++;
169  }
170 
171  }
172  double leftoverSize = imageSize - sequence * TWO_GB;
173  fileRanges.add(new TskFileRange(start, (long)leftoverSize, sequence));
174 
175 
176  caseDatabase.addLayoutFiles(dataSource, fileRanges);
177 
178  } catch (TskCoreException ex) {
179  String errorMessage = Bundle.AddRawImageTask_image_critical_error_adding() + imageFilePaths + Bundle.AddRawImageTask_for_device() + deviceId + ":" + ex.getLocalizedMessage();
180  errorMessages.add(errorMessage);
181  logger.log(Level.SEVERE, errorMessage, ex);
182  criticalErrorOccurred = true;
183  } finally {
184  caseDatabase.releaseExclusiveLock();
185  }
186 
187  }
188 }
void done(DataSourceProcessorResult result, List< String > errList, List< Content > newDataSources)
synchronized static Logger getLogger(String name)
Definition: Logger.java:161

Copyright © 2012-2016 Basis Technology. Generated on: Fri Sep 29 2017
This work is licensed under a Creative Commons Attribution-Share Alike 3.0 United States License.