Autopsy  4.0
Graphical digital forensics platform for The Sleuth Kit and other tools.
TangoMessageAnalyzer.java
Go to the documentation of this file.
1 /*
2  * Autopsy Forensic Browser
3  *
4  * Copyright 2014 Basis Technology Corp.
5  * Contact: carrier <at> sleuthkit <dot> org
6  *
7  * Licensed under the Apache License, Version 2.0 (the "License");
8  * you may not use this file except in compliance with the License.
9  * You may obtain a copy of the License at
10  *
11  * http://www.apache.org/licenses/LICENSE-2.0
12  *
13  * Unless required by applicable law or agreed to in writing, software
14  * distributed under the License is distributed on an "AS IS" BASIS,
15  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
16  * See the License for the specific language governing permissions and
17  * limitations under the License.
18  */
19 package org.sleuthkit.autopsy.modules.android;
20 
21 import java.io.File;
22 import java.sql.Connection;
23 import java.sql.DriverManager;
24 import java.sql.ResultSet;
25 import java.sql.SQLException;
26 import java.sql.Statement;
27 import java.util.List;
28 import java.util.logging.Level;
29 import org.apache.commons.codec.binary.Base64;
30 import org.openide.util.NbBundle;
37 import org.sleuthkit.datamodel.AbstractFile;
38 import org.sleuthkit.datamodel.BlackboardArtifact;
39 import org.sleuthkit.datamodel.BlackboardAttribute;
40 import org.sleuthkit.datamodel.Content;
41 import org.sleuthkit.datamodel.TskCoreException;
42 
46 class TangoMessageAnalyzer {
47 
48  private static final String moduleName = AndroidModuleFactory.getModuleName();
49  private static final Logger logger = Logger.getLogger(TangoMessageAnalyzer.class.getName());
50  private static Blackboard blackboard;
51 
52  public static void findTangoMessages(Content dataSource, FileManager fileManager) {
53  blackboard = Case.getCurrentCase().getServices().getBlackboard();
54  List<AbstractFile> absFiles;
55  try {
56  absFiles = fileManager.findFiles(dataSource, "tc.db"); //NON-NLS
57  for (AbstractFile abstractFile : absFiles) {
58  try {
59  File jFile = new File(Case.getCurrentCase().getTempDirectory(), abstractFile.getName());
60  ContentUtils.writeToFile(abstractFile, jFile);
61  findTangoMessagesInDB(jFile.toString(), abstractFile);
62  } catch (Exception e) {
63  logger.log(Level.SEVERE, "Error parsing Tango messages", e); //NON-NLS
64  }
65  }
66  } catch (TskCoreException e) {
67  logger.log(Level.SEVERE, "Error finding Tango messages", e); //NON-NLS
68  }
69  }
70 
71  private static void findTangoMessagesInDB(String DatabasePath, AbstractFile f) {
72  Connection connection = null;
73  ResultSet resultSet = null;
74  Statement statement = null;
75 
76  if (DatabasePath == null || DatabasePath.isEmpty()) {
77  return;
78  }
79  try {
80  Class.forName("org.sqlite.JDBC"); //NON-NLS //load JDBC driver
81  connection = DriverManager.getConnection("jdbc:sqlite:" + DatabasePath); //NON-NLS
82  statement = connection.createStatement();
83  } catch (ClassNotFoundException | SQLException e) {
84  logger.log(Level.SEVERE, "Error opening database", e); //NON-NLS
85  return;
86  }
87 
88  try {
89  resultSet = statement.executeQuery(
90  "SELECT conv_id, create_time,direction,payload FROM messages ORDER BY create_time DESC;"); //NON-NLS
91 
92  String conv_id; // seems to wrap around the message found in payload after decoding from base-64
93  String direction; // 1 incoming, 2 outgoing
94  String payload; // seems to be a base64 message wrapped by the conv_id
95 
96  while (resultSet.next()) {
97  conv_id = resultSet.getString("conv_id"); //NON-NLS
98  Long create_time = Long.valueOf(resultSet.getString("create_time")) / 1000; //NON-NLS
99  if (resultSet.getString("direction").equals("1")) { //NON-NLS
100  direction = "Incoming"; //NON-NLS
101  } else {
102  direction = "Outgoing"; //NON-NLS
103  }
104  payload = resultSet.getString("payload"); //NON-NLS
105 
106  BlackboardArtifact bba = f.newArtifact(BlackboardArtifact.ARTIFACT_TYPE.TSK_MESSAGE); //create a call log and then add attributes from result set.
107  bba.addAttribute(new BlackboardAttribute(BlackboardAttribute.ATTRIBUTE_TYPE.TSK_DATETIME, moduleName, create_time));
108  bba.addAttribute(new BlackboardAttribute(BlackboardAttribute.ATTRIBUTE_TYPE.TSK_DIRECTION, moduleName, direction));
109  bba.addAttribute(new BlackboardAttribute(BlackboardAttribute.ATTRIBUTE_TYPE.TSK_TEXT, moduleName, decodeMessage(conv_id, payload)));
110  bba.addAttribute(new BlackboardAttribute(BlackboardAttribute.ATTRIBUTE_TYPE.TSK_MESSAGE_TYPE, moduleName,
111  NbBundle.getMessage(TangoMessageAnalyzer.class,
112  "TangoMessageAnalyzer.bbAttribute.tangoMessage")));
113 
114  try {
115  // index the artifact for keyword search
116  blackboard.indexArtifact(bba);
117  } catch (Blackboard.BlackboardException ex) {
118  logger.log(Level.SEVERE, NbBundle.getMessage(Blackboard.class, "Blackboard.unableToIndexArtifact.error.msg", bba.getDisplayName()), ex); //NON-NLS
119  MessageNotifyUtil.Notify.error(
120  NbBundle.getMessage(Blackboard.class, "Blackboard.unableToIndexArtifact.exception.msg"), bba.getDisplayName());
121  }
122  }
123  } catch (Exception e) {
124  logger.log(Level.SEVERE, "Error parsing Tango messages to the Blackboard", e); //NON-NLS
125  } finally {
126  try {
127  if (resultSet != null) {
128  resultSet.close();
129  }
130  statement.close();
131  connection.close();
132  } catch (Exception e) {
133  logger.log(Level.SEVERE, "Error closing database", e); //NON-NLS
134  }
135  }
136  }
137 
138  //take the message string which is wrapped by a certain string, and return the text enclosed.
139  private static String decodeMessage(String wrapper, String message) {
140  String result = "";
141  byte[] decoded = Base64.decodeBase64(message);
142  try {
143  String Z = new String(decoded, "UTF-8");
144  result = Z.split(wrapper)[1];
145  } catch (Exception e) {
146  logger.log(Level.SEVERE, "Error decoding a Tango message", e); //NON-NLS
147  }
148  return result;
149  }
150 }

Copyright © 2012-2015 Basis Technology. Generated on: Wed Apr 6 2016
This work is licensed under a Creative Commons Attribution-Share Alike 3.0 United States License.