michael@0: /* -*- Mode: Java; c-basic-offset: 4; tab-width: 4; indent-tabs-mode: nil; -*-
michael@0:  * This Source Code Form is subject to the terms of the Mozilla Public
michael@0:  * License, v. 2.0. If a copy of the MPL was not distributed with this
michael@0:  * file, You can obtain one at http://mozilla.org/MPL/2.0/. */
michael@0: 
michael@0: package org.mozilla.gecko;
michael@0: 
michael@0: import android.app.Activity;
michael@0: import android.app.PendingIntent;
michael@0: import android.content.BroadcastReceiver;
michael@0: import android.content.ContentResolver;
michael@0: import android.content.ContentUris;
michael@0: import android.content.ContentValues;
michael@0: import android.content.Context;
michael@0: import android.content.Intent;
michael@0: import android.content.IntentFilter;
michael@0: import android.database.Cursor;
michael@0: import android.net.Uri;
michael@0: import android.os.Bundle;
michael@0: import android.os.Handler;
michael@0: import android.os.Looper;
michael@0: import android.telephony.SmsManager;
michael@0: import android.telephony.SmsMessage;
michael@0: import android.util.Log;
michael@0: 
michael@0: import static android.telephony.SmsMessage.MessageClass;
michael@0: 
michael@0: import java.util.ArrayList;
michael@0: 
michael@0: /**
michael@0:  * This class is returning unique ids for PendingIntent requestCode attribute.
michael@0:  * There are only |Integer.MAX_VALUE - Integer.MIN_VALUE| unique IDs available,
michael@0:  * and they wrap around.
michael@0:  */
michael@0: class PendingIntentUID
michael@0: {
michael@0:   static private int sUID = Integer.MIN_VALUE;
michael@0: 
michael@0:   static public int generate() { return sUID++; }
michael@0: }
michael@0: 
michael@0: /**
michael@0:  * The envelope class contains all information that are needed to keep track of
michael@0:  * a sent SMS.
michael@0:  */
michael@0: class Envelope
michael@0: {
michael@0:   enum SubParts {
michael@0:     SENT_PART,
michael@0:     DELIVERED_PART
michael@0:   }
michael@0: 
michael@0:   protected int       mId;
michael@0:   protected int       mMessageId;
michael@0:   protected long      mMessageTimestamp;
michael@0: 
michael@0:   /**
michael@0:    * Number of sent/delivered remaining parts.
michael@0:    * @note The array has much slots as SubParts items.
michael@0:    */
michael@0:   protected int[]     mRemainingParts;
michael@0: 
michael@0:   /**
michael@0:    * Whether sending/delivering is currently failing.
michael@0:    * @note The array has much slots as SubParts items.
michael@0:    */
michael@0:   protected boolean[] mFailing;
michael@0: 
michael@0:   /**
michael@0:    * Error type (only for sent).
michael@0:    */
michael@0:   protected int       mError;
michael@0: 
michael@0:   public Envelope(int aId, int aParts) {
michael@0:     mId = aId;
michael@0:     mMessageId = -1;
michael@0:     mMessageTimestamp = 0;
michael@0:     mError = GeckoSmsManager.kNoError;
michael@0: 
michael@0:     int size = Envelope.SubParts.values().length;
michael@0:     mRemainingParts = new int[size];
michael@0:     mFailing = new boolean[size];
michael@0: 
michael@0:     for (int i=0; i<size; ++i) {
michael@0:       mRemainingParts[i] = aParts;
michael@0:       mFailing[i] = false;
michael@0:     }
michael@0:   }
michael@0: 
michael@0:   public void decreaseRemainingParts(Envelope.SubParts aType) {
michael@0:     --mRemainingParts[aType.ordinal()];
michael@0: 
michael@0:     if (mRemainingParts[SubParts.SENT_PART.ordinal()] >
michael@0:         mRemainingParts[SubParts.DELIVERED_PART.ordinal()]) {
michael@0:       Log.e("GeckoSmsManager", "Delivered more parts than we sent!?");
michael@0:     }
michael@0:   }
michael@0: 
michael@0:   public boolean arePartsRemaining(Envelope.SubParts aType) {
michael@0:     return mRemainingParts[aType.ordinal()] != 0;
michael@0:   }
michael@0: 
michael@0:   public void markAsFailed(Envelope.SubParts aType) {
michael@0:     mFailing[aType.ordinal()] = true;
michael@0:   }
michael@0: 
michael@0:   public boolean isFailing(Envelope.SubParts aType) {
michael@0:     return mFailing[aType.ordinal()];
michael@0:   }
michael@0: 
michael@0:   public int getMessageId() {
michael@0:     return mMessageId;
michael@0:   }
michael@0: 
michael@0:   public void setMessageId(int aMessageId) {
michael@0:     mMessageId = aMessageId;
michael@0:   }
michael@0: 
michael@0:   public long getMessageTimestamp() {
michael@0:     return mMessageTimestamp;
michael@0:   }
michael@0: 
michael@0:   public void setMessageTimestamp(long aMessageTimestamp) {
michael@0:     mMessageTimestamp = aMessageTimestamp;
michael@0:   }
michael@0: 
michael@0:   public int getError() {
michael@0:     return mError;
michael@0:   }
michael@0: 
michael@0:   public void setError(int aError) {
michael@0:     mError = aError;
michael@0:   }
michael@0: }
michael@0: 
michael@0: /**
michael@0:  * Postman class is a singleton that manages Envelope instances.
michael@0:  */
michael@0: class Postman
michael@0: {
michael@0:   public static final int kUnknownEnvelopeId = -1;
michael@0: 
michael@0:   private static final Postman sInstance = new Postman();
michael@0: 
michael@0:   private ArrayList<Envelope> mEnvelopes = new ArrayList<Envelope>(1);
michael@0: 
michael@0:   private Postman() {}
michael@0: 
michael@0:   public static Postman getInstance() {
michael@0:     return sInstance;
michael@0:   }
michael@0: 
michael@0:   public int createEnvelope(int aParts) {
michael@0:     /*
michael@0:      * We are going to create the envelope in the first empty slot in the array
michael@0:      * list. If there is no empty slot, we create a new one.
michael@0:      */
michael@0:     int size = mEnvelopes.size();
michael@0: 
michael@0:     for (int i=0; i<size; ++i) {
michael@0:       if (mEnvelopes.get(i) == null) {
michael@0:         mEnvelopes.set(i, new Envelope(i, aParts));
michael@0:         return i;
michael@0:       }
michael@0:     }
michael@0: 
michael@0:     mEnvelopes.add(new Envelope(size, aParts));
michael@0:     return size;
michael@0:   }
michael@0: 
michael@0:   public Envelope getEnvelope(int aId) {
michael@0:     if (aId < 0 || mEnvelopes.size() <= aId) {
michael@0:       Log.e("GeckoSmsManager", "Trying to get an unknown Envelope!");
michael@0:       return null;
michael@0:     }
michael@0: 
michael@0:     Envelope envelope = mEnvelopes.get(aId);
michael@0:     if (envelope == null) {
michael@0:       Log.e("GeckoSmsManager", "Trying to get an empty Envelope!");
michael@0:     }
michael@0: 
michael@0:     return envelope;
michael@0:   }
michael@0: 
michael@0:   public void destroyEnvelope(int aId) {
michael@0:     if (aId < 0 || mEnvelopes.size() <= aId) {
michael@0:       Log.e("GeckoSmsManager", "Trying to destroy an unknown Envelope!");
michael@0:       return;
michael@0:     }
michael@0: 
michael@0:     if (mEnvelopes.set(aId, null) == null) {
michael@0:       Log.e("GeckoSmsManager", "Trying to destroy an empty Envelope!");
michael@0:     }
michael@0:   }
michael@0: }
michael@0: 
michael@0: class SmsIOThread extends Thread {
michael@0:   private final static SmsIOThread sInstance = new SmsIOThread();
michael@0: 
michael@0:   private Handler mHandler;
michael@0: 
michael@0:   public static SmsIOThread getInstance() {
michael@0:     return sInstance;
michael@0:   }
michael@0: 
michael@0:   public boolean execute(Runnable r) {
michael@0:     return mHandler.post(r);
michael@0:   }
michael@0: 
michael@0:   @Override
michael@0:   public void run() {
michael@0:     Looper.prepare();
michael@0: 
michael@0:     mHandler = new Handler();
michael@0: 
michael@0:     Looper.loop();
michael@0:   }
michael@0: }
michael@0: 
michael@0: class MessagesListManager
michael@0: {
michael@0:   private static final MessagesListManager sInstance = new MessagesListManager();
michael@0: 
michael@0:   public static MessagesListManager getInstance() {
michael@0:     return sInstance;
michael@0:   }
michael@0: 
michael@0:   private ArrayList<Cursor> mCursors = new ArrayList<Cursor>(0);
michael@0: 
michael@0:   public int add(Cursor aCursor) {
michael@0:     int size = mCursors.size();
michael@0: 
michael@0:     for (int i=0; i<size; ++i) {
michael@0:       if (mCursors.get(i) == null) {
michael@0:         mCursors.set(i, aCursor);
michael@0:         return i;
michael@0:       }
michael@0:     }
michael@0: 
michael@0:     mCursors.add(aCursor);
michael@0:     return size;
michael@0:   }
michael@0: 
michael@0:   public Cursor get(int aId) {
michael@0:     if (aId < 0 || mCursors.size() <= aId) {
michael@0:       Log.e("GeckoSmsManager", "Trying to get an unknown list!");
michael@0:       return null;
michael@0:     }
michael@0: 
michael@0:     Cursor cursor = mCursors.get(aId);
michael@0:     if (cursor == null) {
michael@0:       Log.e("GeckoSmsManager", "Trying to get an empty list!");
michael@0:     }
michael@0: 
michael@0:     return cursor;
michael@0:   }
michael@0: 
michael@0:   public void remove(int aId) {
michael@0:     if (aId < 0 || mCursors.size() <= aId) {
michael@0:       Log.e("GeckoSmsManager", "Trying to destroy an unknown list!");
michael@0:       return;
michael@0:     }
michael@0: 
michael@0:     Cursor cursor = mCursors.set(aId, null);
michael@0:     if (cursor == null) {
michael@0:       Log.e("GeckoSmsManager", "Trying to destroy an empty list!");
michael@0:       return;
michael@0:     }
michael@0: 
michael@0:     cursor.close();
michael@0:   }
michael@0: 
michael@0:   public void clear() {
michael@0:     for (int i=0; i<mCursors.size(); ++i) {
michael@0:       Cursor c = mCursors.get(i);
michael@0:       if (c != null) {
michael@0:         c.close();
michael@0:       }
michael@0:     }
michael@0: 
michael@0:     mCursors.clear();
michael@0:   }
michael@0: }
michael@0: 
michael@0: public class GeckoSmsManager
michael@0:   extends BroadcastReceiver
michael@0:   implements ISmsManager
michael@0: {
michael@0:   public final static String ACTION_SMS_RECEIVED  = "android.provider.Telephony.SMS_RECEIVED";
michael@0:   public final static String ACTION_SMS_SENT      = "org.mozilla.gecko.SMS_SENT";
michael@0:   public final static String ACTION_SMS_DELIVERED = "org.mozilla.gecko.SMS_DELIVERED";
michael@0: 
michael@0:   /*
michael@0:    * Make sure that the following error codes are in sync with |ErrorType| in:
michael@0:    * dom/mobilemessage/src/Types.h
michael@0:    * The error code are owned by the DOM.
michael@0:    */
michael@0:   public final static int kNoError               = 0;
michael@0:   public final static int kNoSignalError         = 1;
michael@0:   public final static int kNotFoundError         = 2;
michael@0:   public final static int kUnknownError          = 3;
michael@0:   public final static int kInternalError         = 4;
michael@0:   public final static int kNoSimCardError        = 5;
michael@0:   public final static int kRadioDisabledError    = 6;
michael@0:   public final static int kInvalidAddressError   = 7;
michael@0:   public final static int kFdnCheckError         = 8;
michael@0:   public final static int kNonActiveSimCardError = 9;
michael@0:   public final static int kStorageFullError      = 10;
michael@0:   public final static int kSimNotMatchedError    = 11;
michael@0: 
michael@0:   private final static int kMaxMessageSize    = 160;
michael@0: 
michael@0:   private final static Uri kSmsContentUri     = Uri.parse("content://sms");
michael@0:   private final static Uri kSmsSentContentUri = Uri.parse("content://sms/sent");
michael@0: 
michael@0:   private final static int kSmsTypeInbox      = 1;
michael@0:   private final static int kSmsTypeSentbox    = 2;
michael@0: 
michael@0:   /*
michael@0:    * Keep the following state codes in syng with |DeliveryState| in:
michael@0:    * dom/mobilemessage/src/Types.h
michael@0:    */
michael@0:   private final static int kDeliveryStateSent          = 0;
michael@0:   private final static int kDeliveryStateReceived      = 1;
michael@0:   private final static int kDeliveryStateSending       = 2;
michael@0:   private final static int kDeliveryStateError         = 3;
michael@0:   private final static int kDeliveryStateUnknown       = 4;
michael@0:   private final static int kDeliveryStateNotDownloaded = 5;
michael@0:   private final static int kDeliveryStateEndGuard      = 6;
michael@0: 
michael@0:   /*
michael@0:    * Keep the following status codes in sync with |DeliveryStatus| in:
michael@0:    * dom/mobilemessage/src/Types.h
michael@0:    */
michael@0:   private final static int kDeliveryStatusNotApplicable = 0;
michael@0:   private final static int kDeliveryStatusSuccess       = 1;
michael@0:   private final static int kDeliveryStatusPending       = 2;
michael@0:   private final static int kDeliveryStatusError         = 3;
michael@0: 
michael@0:   /*
michael@0:    * android.provider.Telephony.Sms.STATUS_*. Duplicated because they're not
michael@0:    * part of Android public API.
michael@0:    */
michael@0:   private final static int kInternalDeliveryStatusNone     = -1;
michael@0:   private final static int kInternalDeliveryStatusComplete = 0;
michael@0:   private final static int kInternalDeliveryStatusPending  = 32;
michael@0:   private final static int kInternalDeliveryStatusFailed   = 64;
michael@0: 
michael@0:   /*
michael@0:    * Keep the following values in sync with |MessageClass| in:
michael@0:    * dom/mobilemessage/src/Types.h
michael@0:    */
michael@0:   private final static int kMessageClassNormal  = 0;
michael@0:   private final static int kMessageClassClass0  = 1;
michael@0:   private final static int kMessageClassClass1  = 2;
michael@0:   private final static int kMessageClassClass2  = 3;
michael@0:   private final static int kMessageClassClass3  = 4;
michael@0: 
michael@0:   private final static String[] kRequiredMessageRows = new String[] { "_id", "address", "body", "date", "type", "status" };
michael@0: 
michael@0:   public GeckoSmsManager() {
michael@0:     SmsIOThread.getInstance().start();
michael@0:   }
michael@0: 
michael@0:   @Override
michael@0:   public void start() {
michael@0:     IntentFilter smsFilter = new IntentFilter();
michael@0:     smsFilter.addAction(GeckoSmsManager.ACTION_SMS_RECEIVED);
michael@0:     smsFilter.addAction(GeckoSmsManager.ACTION_SMS_SENT);
michael@0:     smsFilter.addAction(GeckoSmsManager.ACTION_SMS_DELIVERED);
michael@0: 
michael@0:     GeckoAppShell.getContext().registerReceiver(this, smsFilter);
michael@0:   }
michael@0: 
michael@0:   @Override
michael@0:   public void onReceive(Context context, Intent intent) {
michael@0:     if (intent.getAction().equals(ACTION_SMS_RECEIVED)) {
michael@0:       // TODO: Try to find the receiver number to be able to populate
michael@0:       //       SmsMessage.receiver.
michael@0:       // TODO: Get the id and the date from the stock app saved message.
michael@0:       //       Using the stock app saved message require us to wait for it to
michael@0:       //       be saved which can lead to race conditions.
michael@0: 
michael@0:       Bundle bundle = intent.getExtras();
michael@0: 
michael@0:       if (bundle == null) {
michael@0:         return;
michael@0:       }
michael@0: 
michael@0:       Object[] pdus = (Object[]) bundle.get("pdus");
michael@0: 
michael@0:       for (int i=0; i<pdus.length; ++i) {
michael@0:         SmsMessage msg = SmsMessage.createFromPdu((byte[])pdus[i]);
michael@0: 
michael@0:         notifySmsReceived(msg.getDisplayOriginatingAddress(),
michael@0:                           msg.getDisplayMessageBody(),
michael@0:                           getGeckoMessageClass(msg.getMessageClass()),
michael@0:                           System.currentTimeMillis());
michael@0:       }
michael@0: 
michael@0:       return;
michael@0:     }
michael@0: 
michael@0:     if (intent.getAction().equals(ACTION_SMS_SENT) ||
michael@0:         intent.getAction().equals(ACTION_SMS_DELIVERED)) {
michael@0:       Bundle bundle = intent.getExtras();
michael@0: 
michael@0:       if (bundle == null || !bundle.containsKey("envelopeId") ||
michael@0:           !bundle.containsKey("number") || !bundle.containsKey("message") ||
michael@0:           !bundle.containsKey("requestId")) {
michael@0:         Log.e("GeckoSmsManager", "Got an invalid ACTION_SMS_SENT/ACTION_SMS_DELIVERED!");
michael@0:         return;
michael@0:       }
michael@0: 
michael@0:       int envelopeId = bundle.getInt("envelopeId");
michael@0:       Postman postman = Postman.getInstance();
michael@0: 
michael@0:       Envelope envelope = postman.getEnvelope(envelopeId);
michael@0:       if (envelope == null) {
michael@0:         Log.e("GeckoSmsManager", "Got an invalid envelope id (or Envelope has been destroyed)!");
michael@0:         return;
michael@0:       }
michael@0: 
michael@0:       Envelope.SubParts part = intent.getAction().equals(ACTION_SMS_SENT)
michael@0:                                  ? Envelope.SubParts.SENT_PART
michael@0:                                  : Envelope.SubParts.DELIVERED_PART;
michael@0:       envelope.decreaseRemainingParts(part);
michael@0: 
michael@0: 
michael@0:       if (getResultCode() != Activity.RESULT_OK) {
michael@0:         switch (getResultCode()) {
michael@0:           case SmsManager.RESULT_ERROR_NULL_PDU:
michael@0:             envelope.setError(kInternalError);
michael@0:             break;
michael@0:           case SmsManager.RESULT_ERROR_NO_SERVICE:
michael@0:           case SmsManager.RESULT_ERROR_RADIO_OFF:
michael@0:             envelope.setError(kNoSignalError);
michael@0:             break;
michael@0:           case SmsManager.RESULT_ERROR_GENERIC_FAILURE:
michael@0:           default:
michael@0:             envelope.setError(kUnknownError);
michael@0:             break;
michael@0:         }
michael@0:         envelope.markAsFailed(part);
michael@0:         Log.i("GeckoSmsManager", "SMS part sending failed!");
michael@0:       }
michael@0: 
michael@0:       if (envelope.arePartsRemaining(part)) {
michael@0:         return;
michael@0:       }
michael@0: 
michael@0:       if (envelope.isFailing(part)) {
michael@0:         if (part == Envelope.SubParts.SENT_PART) {
michael@0:           notifySmsSendFailed(envelope.getError(), bundle.getInt("requestId"));
michael@0:           Log.i("GeckoSmsManager", "SMS sending failed!");
michael@0:         } else {
michael@0:           notifySmsDelivery(envelope.getMessageId(),
michael@0:                             kDeliveryStatusError,
michael@0:                             bundle.getString("number"),
michael@0:                             bundle.getString("message"),
michael@0:                             envelope.getMessageTimestamp());
michael@0:           Log.i("GeckoSmsManager", "SMS delivery failed!");
michael@0:         }
michael@0:       } else {
michael@0:         if (part == Envelope.SubParts.SENT_PART) {
michael@0:           String number = bundle.getString("number");
michael@0:           String message = bundle.getString("message");
michael@0:           long timestamp = System.currentTimeMillis();
michael@0: 
michael@0:           int id = saveSentMessage(number, message, timestamp);
michael@0: 
michael@0:           notifySmsSent(id, number, message, timestamp,
michael@0:                         bundle.getInt("requestId"));
michael@0: 
michael@0:           envelope.setMessageId(id);
michael@0:           envelope.setMessageTimestamp(timestamp);
michael@0: 
michael@0:           Log.i("GeckoSmsManager", "SMS sending was successfull!");
michael@0:         } else {
michael@0:           notifySmsDelivery(envelope.getMessageId(),
michael@0:                             kDeliveryStatusSuccess,
michael@0:                             bundle.getString("number"),
michael@0:                             bundle.getString("message"),
michael@0:                             envelope.getMessageTimestamp());
michael@0:           Log.i("GeckoSmsManager", "SMS successfully delivered!");
michael@0:         }
michael@0:       }
michael@0: 
michael@0:       // Destroy the envelope object only if the SMS has been sent and delivered.
michael@0:       if (!envelope.arePartsRemaining(Envelope.SubParts.SENT_PART) &&
michael@0:           !envelope.arePartsRemaining(Envelope.SubParts.DELIVERED_PART)) {
michael@0:         postman.destroyEnvelope(envelopeId);
michael@0:       }
michael@0: 
michael@0:       return;
michael@0:     }
michael@0:   }
michael@0: 
michael@0:   @Override
michael@0:   public void send(String aNumber, String aMessage, int aRequestId) {
michael@0:     int envelopeId = Postman.kUnknownEnvelopeId;
michael@0: 
michael@0:     try {
michael@0:       SmsManager sm = SmsManager.getDefault();
michael@0: 
michael@0:       Intent sentIntent = new Intent(ACTION_SMS_SENT);
michael@0:       Intent deliveredIntent = new Intent(ACTION_SMS_DELIVERED);
michael@0: 
michael@0:       Bundle bundle = new Bundle();
michael@0:       bundle.putString("number", aNumber);
michael@0:       bundle.putString("message", aMessage);
michael@0:       bundle.putInt("requestId", aRequestId);
michael@0: 
michael@0:       if (aMessage.length() <= kMaxMessageSize) {
michael@0:         envelopeId = Postman.getInstance().createEnvelope(1);
michael@0:         bundle.putInt("envelopeId", envelopeId);
michael@0: 
michael@0:         sentIntent.putExtras(bundle);
michael@0:         deliveredIntent.putExtras(bundle);
michael@0: 
michael@0:         /*
michael@0:          * There are a few things to know about getBroadcast and pending intents:
michael@0:          * - the pending intents are in a shared pool maintained by the system;
michael@0:          * - each pending intent is identified by a token;
michael@0:          * - when a new pending intent is created, if it has the same token as
michael@0:          *   another intent in the pool, one of them has to be removed.
michael@0:          *
michael@0:          * To prevent having a hard time because of this situation, we give a
michael@0:          * unique id to all pending intents we are creating. This unique id is
michael@0:          * generated by GetPendingIntentUID().
michael@0:          */
michael@0:         PendingIntent sentPendingIntent =
michael@0:           PendingIntent.getBroadcast(GeckoAppShell.getContext(),
michael@0:                                      PendingIntentUID.generate(), sentIntent,
michael@0:                                      PendingIntent.FLAG_CANCEL_CURRENT);
michael@0: 
michael@0:         PendingIntent deliveredPendingIntent =
michael@0:           PendingIntent.getBroadcast(GeckoAppShell.getContext(),
michael@0:                                      PendingIntentUID.generate(), deliveredIntent,
michael@0:                                      PendingIntent.FLAG_CANCEL_CURRENT);
michael@0: 
michael@0:         sm.sendTextMessage(aNumber, "", aMessage,
michael@0:                            sentPendingIntent, deliveredPendingIntent);
michael@0:       } else {
michael@0:         ArrayList<String> parts = sm.divideMessage(aMessage);
michael@0:         envelopeId = Postman.getInstance().createEnvelope(parts.size());
michael@0:         bundle.putInt("envelopeId", envelopeId);
michael@0: 
michael@0:         sentIntent.putExtras(bundle);
michael@0:         deliveredIntent.putExtras(bundle);
michael@0: 
michael@0:         ArrayList<PendingIntent> sentPendingIntents =
michael@0:           new ArrayList<PendingIntent>(parts.size());
michael@0:         ArrayList<PendingIntent> deliveredPendingIntents =
michael@0:           new ArrayList<PendingIntent>(parts.size());
michael@0: 
michael@0:         for (int i=0; i<parts.size(); ++i) {
michael@0:           sentPendingIntents.add(
michael@0:             PendingIntent.getBroadcast(GeckoAppShell.getContext(),
michael@0:                                        PendingIntentUID.generate(), sentIntent,
michael@0:                                        PendingIntent.FLAG_CANCEL_CURRENT)
michael@0:           );
michael@0: 
michael@0:           deliveredPendingIntents.add(
michael@0:             PendingIntent.getBroadcast(GeckoAppShell.getContext(),
michael@0:                                        PendingIntentUID.generate(), deliveredIntent,
michael@0:                                        PendingIntent.FLAG_CANCEL_CURRENT)
michael@0:           );
michael@0:         }
michael@0: 
michael@0:         sm.sendMultipartTextMessage(aNumber, "", parts, sentPendingIntents,
michael@0:                                     deliveredPendingIntents);
michael@0:       }
michael@0:     } catch (Exception e) {
michael@0:       Log.e("GeckoSmsManager", "Failed to send an SMS: ", e);
michael@0: 
michael@0:       if (envelopeId != Postman.kUnknownEnvelopeId) {
michael@0:         Postman.getInstance().destroyEnvelope(envelopeId);
michael@0:       }
michael@0: 
michael@0:       notifySmsSendFailed(kUnknownError, aRequestId);
michael@0:     }
michael@0:   }
michael@0: 
michael@0:   public int saveSentMessage(String aRecipient, String aBody, long aDate) {
michael@0:     try {
michael@0:       ContentValues values = new ContentValues();
michael@0:       values.put("address", aRecipient);
michael@0:       values.put("body", aBody);
michael@0:       values.put("date", aDate);
michael@0:       // Always 'PENDING' because we always request status report.
michael@0:       values.put("status", kInternalDeliveryStatusPending);
michael@0: 
michael@0:       ContentResolver cr = GeckoAppShell.getContext().getContentResolver();
michael@0:       Uri uri = cr.insert(kSmsSentContentUri, values);
michael@0: 
michael@0:       long id = ContentUris.parseId(uri);
michael@0: 
michael@0:       // The DOM API takes a 32bits unsigned int for the id. It's unlikely that
michael@0:       // we happen to need more than that but it doesn't cost to check.
michael@0:       if (id > Integer.MAX_VALUE) {
michael@0:         throw new IdTooHighException();
michael@0:       }
michael@0: 
michael@0:       return (int)id;
michael@0:     } catch (IdTooHighException e) {
michael@0:       Log.e("GeckoSmsManager", "The id we received is higher than the higher allowed value.");
michael@0:       return -1;
michael@0:     } catch (Exception e) {
michael@0:       Log.e("GeckoSmsManager", "Something went wrong when trying to write a sent message", e);
michael@0:       return -1;
michael@0:     }
michael@0:   }
michael@0: 
michael@0:   @Override
michael@0:   public void getMessage(int aMessageId, int aRequestId) {
michael@0:     class GetMessageRunnable implements Runnable {
michael@0:       private int mMessageId;
michael@0:       private int mRequestId;
michael@0: 
michael@0:       GetMessageRunnable(int aMessageId, int aRequestId) {
michael@0:         mMessageId = aMessageId;
michael@0:         mRequestId = aRequestId;
michael@0:       }
michael@0: 
michael@0:       @Override
michael@0:       public void run() {
michael@0:         Cursor cursor = null;
michael@0: 
michael@0:         try {
michael@0:           ContentResolver cr = GeckoAppShell.getContext().getContentResolver();
michael@0:           Uri message = ContentUris.withAppendedId(kSmsContentUri, mMessageId);
michael@0: 
michael@0:           cursor = cr.query(message, kRequiredMessageRows, null, null, null);
michael@0:           if (cursor == null || cursor.getCount() == 0) {
michael@0:             throw new NotFoundException();
michael@0:           }
michael@0: 
michael@0:           if (cursor.getCount() != 1) {
michael@0:             throw new TooManyResultsException();
michael@0:           }
michael@0: 
michael@0:           cursor.moveToFirst();
michael@0: 
michael@0:           if (cursor.getInt(cursor.getColumnIndex("_id")) != mMessageId) {
michael@0:             throw new UnmatchingIdException();
michael@0:           }
michael@0: 
michael@0:           int type = cursor.getInt(cursor.getColumnIndex("type"));
michael@0:           int deliveryStatus;
michael@0:           String sender = "";
michael@0:           String receiver = "";
michael@0: 
michael@0:           if (type == kSmsTypeInbox) {
michael@0:             deliveryStatus = kDeliveryStatusSuccess;
michael@0:             sender = cursor.getString(cursor.getColumnIndex("address"));
michael@0:           } else if (type == kSmsTypeSentbox) {
michael@0:             deliveryStatus = getGeckoDeliveryStatus(cursor.getInt(cursor.getColumnIndex("status")));
michael@0:             receiver = cursor.getString(cursor.getColumnIndex("address"));
michael@0:           } else {
michael@0:             throw new InvalidTypeException();
michael@0:           }
michael@0: 
michael@0:           notifyGetSms(cursor.getInt(cursor.getColumnIndex("_id")),
michael@0:                        deliveryStatus,
michael@0:                        receiver, sender,
michael@0:                        cursor.getString(cursor.getColumnIndex("body")),
michael@0:                        cursor.getLong(cursor.getColumnIndex("date")),
michael@0:                        mRequestId);
michael@0:         } catch (NotFoundException e) {
michael@0:           Log.i("GeckoSmsManager", "Message id " + mMessageId + " not found");
michael@0:           notifyGetSmsFailed(kNotFoundError, mRequestId);
michael@0:         } catch (UnmatchingIdException e) {
michael@0:           Log.e("GeckoSmsManager", "Requested message id (" + mMessageId +
michael@0:                                    ") is different from the one we got.");
michael@0:           notifyGetSmsFailed(kUnknownError, mRequestId);
michael@0:         } catch (TooManyResultsException e) {
michael@0:           Log.e("GeckoSmsManager", "Get too many results for id " + mMessageId);
michael@0:           notifyGetSmsFailed(kUnknownError, mRequestId);
michael@0:         } catch (InvalidTypeException e) {
michael@0:           Log.i("GeckoSmsManager", "Message has an invalid type, we ignore it.");
michael@0:           notifyGetSmsFailed(kNotFoundError, mRequestId);
michael@0:         } catch (Exception e) {
michael@0:           Log.e("GeckoSmsManager", "Error while trying to get message", e);
michael@0:           notifyGetSmsFailed(kUnknownError, mRequestId);
michael@0:         } finally {
michael@0:           if (cursor != null) {
michael@0:             cursor.close();
michael@0:           }
michael@0:         }
michael@0:       }
michael@0:     }
michael@0: 
michael@0:     if (!SmsIOThread.getInstance().execute(new GetMessageRunnable(aMessageId, aRequestId))) {
michael@0:       Log.e("GeckoSmsManager", "Failed to add GetMessageRunnable to the SmsIOThread");
michael@0:       notifyGetSmsFailed(kUnknownError, aRequestId);
michael@0:     }
michael@0:   }
michael@0: 
michael@0:   @Override
michael@0:   public void deleteMessage(int aMessageId, int aRequestId) {
michael@0:     class DeleteMessageRunnable implements Runnable {
michael@0:       private int mMessageId;
michael@0:       private int mRequestId;
michael@0: 
michael@0:       DeleteMessageRunnable(int aMessageId, int aRequestId) {
michael@0:         mMessageId = aMessageId;
michael@0:         mRequestId = aRequestId;
michael@0:       }
michael@0: 
michael@0:       @Override
michael@0:       public void run() {
michael@0:         try {
michael@0:           ContentResolver cr = GeckoAppShell.getContext().getContentResolver();
michael@0:           Uri message = ContentUris.withAppendedId(kSmsContentUri, mMessageId);
michael@0: 
michael@0:           int count = cr.delete(message, null, null);
michael@0: 
michael@0:           if (count > 1) {
michael@0:             throw new TooManyResultsException();
michael@0:           }
michael@0: 
michael@0:           notifySmsDeleted(count == 1, mRequestId);
michael@0:         } catch (TooManyResultsException e) {
michael@0:           Log.e("GeckoSmsManager", "Delete more than one message?", e);
michael@0:           notifySmsDeleteFailed(kUnknownError, mRequestId);
michael@0:         } catch (Exception e) {
michael@0:           Log.e("GeckoSmsManager", "Error while trying to delete a message", e);
michael@0:           notifySmsDeleteFailed(kUnknownError, mRequestId);
michael@0:         }
michael@0:       }
michael@0:     }
michael@0: 
michael@0:     if (!SmsIOThread.getInstance().execute(new DeleteMessageRunnable(aMessageId, aRequestId))) {
michael@0:       Log.e("GeckoSmsManager", "Failed to add GetMessageRunnable to the SmsIOThread");
michael@0:       notifySmsDeleteFailed(kUnknownError, aRequestId);
michael@0:     }
michael@0:   }
michael@0: 
michael@0:   @Override
michael@0:   public void createMessageList(long aStartDate, long aEndDate, String[] aNumbers, int aNumbersCount, int aDeliveryState, boolean aReverse, int aRequestId) {
michael@0:     class CreateMessageListRunnable implements Runnable {
michael@0:       private long     mStartDate;
michael@0:       private long     mEndDate;
michael@0:       private String[] mNumbers;
michael@0:       private int      mNumbersCount;
michael@0:       private int      mDeliveryState;
michael@0:       private boolean  mReverse;
michael@0:       private int      mRequestId;
michael@0: 
michael@0:       CreateMessageListRunnable(long aStartDate, long aEndDate, String[] aNumbers, int aNumbersCount, int aDeliveryState, boolean aReverse, int aRequestId) {
michael@0:         mStartDate = aStartDate;
michael@0:         mEndDate = aEndDate;
michael@0:         mNumbers = aNumbers;
michael@0:         mNumbersCount = aNumbersCount;
michael@0:         mDeliveryState = aDeliveryState;
michael@0:         mReverse = aReverse;
michael@0:         mRequestId = aRequestId;
michael@0:       }
michael@0: 
michael@0:       @Override
michael@0:       public void run() {
michael@0:         Cursor cursor = null;
michael@0:         boolean closeCursor = true;
michael@0: 
michael@0:         try {
michael@0:           // TODO: should use the |selectionArgs| argument in |ContentResolver.query()|.
michael@0:           ArrayList<String> restrictions = new ArrayList<String>();
michael@0: 
michael@0:           if (mStartDate != 0) {
michael@0:             restrictions.add("date >= " + mStartDate);
michael@0:           }
michael@0: 
michael@0:           if (mEndDate != 0) {
michael@0:             restrictions.add("date <= " + mEndDate);
michael@0:           }
michael@0: 
michael@0:           if (mNumbersCount > 0) {
michael@0:             String numberRestriction = "address IN ('" + mNumbers[0] + "'";
michael@0: 
michael@0:             for (int i=1; i<mNumbersCount; ++i) {
michael@0:               numberRestriction += ", '" + mNumbers[i] + "'";
michael@0:             }
michael@0:             numberRestriction += ")";
michael@0: 
michael@0:             restrictions.add(numberRestriction);
michael@0:           }
michael@0: 
michael@0:           if (mDeliveryState == kDeliveryStateUnknown) {
michael@0:             restrictions.add("type IN ('" + kSmsTypeSentbox + "', '" + kSmsTypeInbox + "')");
michael@0:           } else if (mDeliveryState == kDeliveryStateSent) {
michael@0:             restrictions.add("type = " + kSmsTypeSentbox);
michael@0:           } else if (mDeliveryState == kDeliveryStateReceived) {
michael@0:             restrictions.add("type = " + kSmsTypeInbox);
michael@0:           } else {
michael@0:             throw new UnexpectedDeliveryStateException();
michael@0:           }
michael@0: 
michael@0:           String restrictionText = restrictions.size() > 0 ? restrictions.get(0) : "";
michael@0: 
michael@0:           for (int i=1; i<restrictions.size(); ++i) {
michael@0:             restrictionText += " AND " + restrictions.get(i);
michael@0:           }
michael@0: 
michael@0:           ContentResolver cr = GeckoAppShell.getContext().getContentResolver();
michael@0:           cursor = cr.query(kSmsContentUri, kRequiredMessageRows, restrictionText, null,
michael@0:                             mReverse ? "date DESC" : "date ASC");
michael@0: 
michael@0:           if (cursor.getCount() == 0) {
michael@0:             notifyNoMessageInList(mRequestId);
michael@0:             return;
michael@0:           }
michael@0: 
michael@0:           cursor.moveToFirst();
michael@0: 
michael@0:           int type = cursor.getInt(cursor.getColumnIndex("type"));
michael@0:           int deliveryStatus;
michael@0:           String sender = "";
michael@0:           String receiver = "";
michael@0: 
michael@0:           if (type == kSmsTypeInbox) {
michael@0:             deliveryStatus = kDeliveryStatusSuccess;
michael@0:             sender = cursor.getString(cursor.getColumnIndex("address"));
michael@0:           } else if (type == kSmsTypeSentbox) {
michael@0:             deliveryStatus = getGeckoDeliveryStatus(cursor.getInt(cursor.getColumnIndex("status")));
michael@0:             receiver = cursor.getString(cursor.getColumnIndex("address"));
michael@0:           } else {
michael@0:             throw new UnexpectedDeliveryStateException();
michael@0:           }
michael@0: 
michael@0:           int listId = MessagesListManager.getInstance().add(cursor);
michael@0:           closeCursor = false;
michael@0:           notifyListCreated(listId,
michael@0:                             cursor.getInt(cursor.getColumnIndex("_id")),
michael@0:                             deliveryStatus,
michael@0:                             receiver, sender,
michael@0:                             cursor.getString(cursor.getColumnIndex("body")),
michael@0:                             cursor.getLong(cursor.getColumnIndex("date")),
michael@0:                             mRequestId);
michael@0:         } catch (UnexpectedDeliveryStateException e) {
michael@0:           Log.e("GeckoSmsManager", "Unexcepted delivery state type", e);
michael@0:           notifyReadingMessageListFailed(kUnknownError, mRequestId);
michael@0:         } catch (Exception e) {
michael@0:           Log.e("GeckoSmsManager", "Error while trying to create a message list cursor", e);
michael@0:           notifyReadingMessageListFailed(kUnknownError, mRequestId);
michael@0:         } finally {
michael@0:           // Close the cursor if MessagesListManager isn't taking care of it.
michael@0:           // We could also just check if it is in the MessagesListManager list but
michael@0:           // that would be less efficient.
michael@0:           if (cursor != null && closeCursor) {
michael@0:             cursor.close();
michael@0:           }
michael@0:         }
michael@0:       }
michael@0:     }
michael@0: 
michael@0:     if (!SmsIOThread.getInstance().execute(new CreateMessageListRunnable(aStartDate, aEndDate, aNumbers, aNumbersCount, aDeliveryState, aReverse, aRequestId))) {
michael@0:       Log.e("GeckoSmsManager", "Failed to add CreateMessageListRunnable to the SmsIOThread");
michael@0:       notifyReadingMessageListFailed(kUnknownError, aRequestId);
michael@0:     }
michael@0:   }
michael@0: 
michael@0:   @Override
michael@0:   public void getNextMessageInList(int aListId, int aRequestId) {
michael@0:     class GetNextMessageInListRunnable implements Runnable {
michael@0:       private int mListId;
michael@0:       private int mRequestId;
michael@0: 
michael@0:       GetNextMessageInListRunnable(int aListId, int aRequestId) {
michael@0:         mListId = aListId;
michael@0:         mRequestId = aRequestId;
michael@0:       }
michael@0: 
michael@0:       @Override
michael@0:       public void run() {
michael@0:         try {
michael@0:           Cursor cursor = MessagesListManager.getInstance().get(mListId);
michael@0: 
michael@0:           if (!cursor.moveToNext()) {
michael@0:             MessagesListManager.getInstance().remove(mListId);
michael@0:             notifyNoMessageInList(mRequestId);
michael@0:             return;
michael@0:           }
michael@0: 
michael@0:           int type = cursor.getInt(cursor.getColumnIndex("type"));
michael@0:           int deliveryStatus;
michael@0:           String sender = "";
michael@0:           String receiver = "";
michael@0: 
michael@0:           if (type == kSmsTypeInbox) {
michael@0:             deliveryStatus = kDeliveryStatusSuccess;
michael@0:             sender = cursor.getString(cursor.getColumnIndex("address"));
michael@0:           } else if (type == kSmsTypeSentbox) {
michael@0:             deliveryStatus = getGeckoDeliveryStatus(cursor.getInt(cursor.getColumnIndex("status")));
michael@0:             receiver = cursor.getString(cursor.getColumnIndex("address"));
michael@0:           } else {
michael@0:             throw new UnexpectedDeliveryStateException();
michael@0:           }
michael@0: 
michael@0:           int listId = MessagesListManager.getInstance().add(cursor);
michael@0:           notifyGotNextMessage(cursor.getInt(cursor.getColumnIndex("_id")),
michael@0:                                deliveryStatus,
michael@0:                                receiver, sender,
michael@0:                                cursor.getString(cursor.getColumnIndex("body")),
michael@0:                                cursor.getLong(cursor.getColumnIndex("date")),
michael@0:                                mRequestId);
michael@0:         } catch (UnexpectedDeliveryStateException e) {
michael@0:           Log.e("GeckoSmsManager", "Unexcepted delivery state type", e);
michael@0:           notifyReadingMessageListFailed(kUnknownError, mRequestId);
michael@0:         } catch (Exception e) {
michael@0:           Log.e("GeckoSmsManager", "Error while trying to get the next message of a list", e);
michael@0:           notifyReadingMessageListFailed(kUnknownError, mRequestId);
michael@0:         }
michael@0:       }
michael@0:     }
michael@0: 
michael@0:     if (!SmsIOThread.getInstance().execute(new GetNextMessageInListRunnable(aListId, aRequestId))) {
michael@0:       Log.e("GeckoSmsManager", "Failed to add GetNextMessageInListRunnable to the SmsIOThread");
michael@0:       notifyReadingMessageListFailed(kUnknownError, aRequestId);
michael@0:     }
michael@0:   }
michael@0: 
michael@0:   @Override
michael@0:   public void clearMessageList(int aListId) {
michael@0:     MessagesListManager.getInstance().remove(aListId);
michael@0:   }
michael@0: 
michael@0:   @Override
michael@0:   public void stop() {
michael@0:     GeckoAppShell.getContext().unregisterReceiver(this);
michael@0:   }
michael@0: 
michael@0:   @Override
michael@0:   public void shutdown() {
michael@0:     SmsIOThread.getInstance().interrupt();
michael@0:     MessagesListManager.getInstance().clear();
michael@0:   }
michael@0: 
michael@0:   private int getGeckoDeliveryStatus(int aDeliveryStatus) {
michael@0:     if (aDeliveryStatus == kInternalDeliveryStatusNone) {
michael@0:       return kDeliveryStatusNotApplicable;
michael@0:     }
michael@0:     if (aDeliveryStatus >= kInternalDeliveryStatusFailed) {
michael@0:       return kDeliveryStatusError;
michael@0:     }
michael@0:     if (aDeliveryStatus >= kInternalDeliveryStatusPending) {
michael@0:       return kDeliveryStatusPending;
michael@0:     }
michael@0:     return kDeliveryStatusSuccess;
michael@0:   }
michael@0: 
michael@0:   private int getGeckoMessageClass(MessageClass aMessageClass) {
michael@0:     switch (aMessageClass) {
michael@0:       case CLASS_0:
michael@0:         return kMessageClassClass0;
michael@0:       case CLASS_1:
michael@0:         return kMessageClassClass1;
michael@0:       case CLASS_2:
michael@0:         return kMessageClassClass2;
michael@0:       case CLASS_3:
michael@0:         return kMessageClassClass3;
michael@0:       default:
michael@0:         return kMessageClassNormal;
michael@0:     }
michael@0:   }
michael@0: 
michael@0:   class IdTooHighException extends Exception {
michael@0:     private static final long serialVersionUID = 29935575131092050L;
michael@0:   }
michael@0: 
michael@0:   class InvalidTypeException extends Exception {
michael@0:     private static final long serialVersionUID = 47436856832535912L;
michael@0:   }
michael@0: 
michael@0:   class NotFoundException extends Exception {
michael@0:     private static final long serialVersionUID = 1940676816633984L;
michael@0:   }
michael@0: 
michael@0:   class TooManyResultsException extends Exception {
michael@0:     private static final long serialVersionUID = 51883196784325305L;
michael@0:   }
michael@0: 
michael@0:   class UnexpectedDeliveryStateException extends Exception {
michael@0:     private static final long serialVersionUID = 494122763684005716L;
michael@0:   }
michael@0: 
michael@0:   class UnmatchingIdException extends Exception {
michael@0:     private static final long serialVersionUID = 158467542575633280L;
michael@0:   }
michael@0: 
michael@0:   private static native void notifySmsReceived(String aSender, String aBody, int aMessageClass, long aTimestamp);
michael@0:   private static native void notifySmsSent(int aId, String aReceiver, String aBody, long aTimestamp, int aRequestId);
michael@0:   private static native void notifySmsDelivery(int aId, int aDeliveryStatus, String aReceiver, String aBody, long aTimestamp);
michael@0:   private static native void notifySmsSendFailed(int aError, int aRequestId);
michael@0:   private static native void notifyGetSms(int aId, int aDeliveryStatus, String aReceiver, String aSender, String aBody, long aTimestamp, int aRequestId);
michael@0:   private static native void notifyGetSmsFailed(int aError, int aRequestId);
michael@0:   private static native void notifySmsDeleted(boolean aDeleted, int aRequestId);
michael@0:   private static native void notifySmsDeleteFailed(int aError, int aRequestId);
michael@0:   private static native void notifyNoMessageInList(int aRequestId);
michael@0:   private static native void notifyListCreated(int aListId, int aMessageId, int aDeliveryStatus, String aReceiver, String aSender, String aBody, long aTimestamp, int aRequestId);
michael@0:   private static native void notifyGotNextMessage(int aMessageId, int aDeliveryStatus, String aReceiver, String aSender, String aBody, long aTimestamp, int aRequestId);
michael@0:   private static native void notifyReadingMessageListFailed(int aError, int aRequestId);
michael@0: }