mirror of
https://github.com/nerzhul/ownCloud-SMS-App.git
synced 2025-06-27 09:46:23 +00:00
Coding style + removal some class copy
This commit is contained in:
parent
ac239f1f71
commit
22f0790f2e
@ -166,10 +166,10 @@ public class MainActivity extends Activity {
|
||||
|
||||
if (cMon.isValid()) {
|
||||
// Now fetch messages since last stored date
|
||||
JSONArray smsList = new SmsFetcher(ctx)
|
||||
.bufferMessagesSinceDate((long) 0);
|
||||
JSONArray smsList = new JSONArray();
|
||||
new SmsFetcher(ctx).bufferMessagesSinceDate(smsList, (long) 0);
|
||||
|
||||
if (smsList != null) {
|
||||
if (smsList.length() > 0) {
|
||||
OCSMSNotificationManager nMgr = new OCSMSNotificationManager(ctx);
|
||||
nMgr.setSyncProcessMsg();
|
||||
new SyncTask(getApplicationContext(), smsList).execute();
|
||||
|
@ -119,10 +119,11 @@ public class ContactListActivity extends Activity implements ASyncContactLoad {
|
||||
null,
|
||||
ContactsContract.CommonDataKinds.Phone.CONTACT_ID + " = ?",
|
||||
new String[]{contactId}, null);
|
||||
|
||||
while ((phones != null) && phones.moveToNext()) {
|
||||
String phoneNumber = phones.getString(phones.getColumnIndex(ContactsContract.CommonDataKinds.Phone.NUMBER))
|
||||
.replaceAll(" ", "");
|
||||
r.add(phoneNumber);
|
||||
r.add(phones.getString(phones.getColumnIndex(
|
||||
ContactsContract.CommonDataKinds.Phone.NUMBER))
|
||||
.replaceAll(" ", ""));
|
||||
}
|
||||
|
||||
if (phones != null) {
|
||||
|
@ -74,12 +74,13 @@ public class ConnectivityChanged extends BroadcastReceiver implements ASyncSMSSy
|
||||
Log.d(ConnectivityChanged.TAG,"Synced Last:" + lastMessageSynced);
|
||||
|
||||
// Now fetch messages since last stored date
|
||||
JSONArray smsList = new SmsFetcher(context).bufferMessagesSinceDate(lastMessageSynced);
|
||||
JSONArray smsList = new JSONArray();
|
||||
new SmsFetcher(context).bufferMessagesSinceDate(smsList, lastMessageSynced);
|
||||
|
||||
AtomicReference<ConnectivityMonitor> cMon = new AtomicReference<>(new ConnectivityMonitor(context));
|
||||
|
||||
// Synchronize if network is valid and there are SMS
|
||||
if (cMon.get().isValid() && (smsList != null)) {
|
||||
if (cMon.get().isValid() && (smsList.length() > 0)) {
|
||||
new SyncTask(context, smsList).execute();
|
||||
}
|
||||
}
|
||||
|
@ -85,9 +85,10 @@ public interface ASyncContactLoad {
|
||||
Cursor cur = cr.query(ContactsContract.Contacts.CONTENT_URI,
|
||||
null, null, null, null);
|
||||
if (((cur != null) ? cur.getCount() : 0) > 0) {
|
||||
String id, name;
|
||||
while ((cur != null) && cur.moveToNext()) {
|
||||
String id = cur.getString(cur.getColumnIndex(ContactsContract.Contacts._ID));
|
||||
String name = cur.getString(cur.getColumnIndex(ContactsContract.Contacts.DISPLAY_NAME));
|
||||
id = cur.getString(cur.getColumnIndex(ContactsContract.Contacts._ID));
|
||||
name = cur.getString(cur.getColumnIndex(ContactsContract.Contacts.DISPLAY_NAME));
|
||||
if (Integer.parseInt(cur.getString(
|
||||
cur.getColumnIndex(ContactsContract.Contacts.HAS_PHONE_NUMBER))) > 0) {
|
||||
|
||||
|
@ -152,7 +152,8 @@ public class OCSMSOwnCloudClient {
|
||||
fetcher.setExistingSentMessages(sentSmsList);
|
||||
fetcher.setExistingDraftsMessages(draftsSmsList);
|
||||
|
||||
smsList = fetcher.fetchAllMessages();
|
||||
smsList = new JSONArray();
|
||||
fetcher.fetchAllMessages(smsList);
|
||||
|
||||
// Get maximum message date present in smsList to keep a step when connectivity changes
|
||||
lastMsgDate = fetcher.getLastMessageDate();
|
||||
@ -329,7 +330,7 @@ public class OCSMSOwnCloudClient {
|
||||
}
|
||||
}
|
||||
|
||||
if(status == HttpStatus.SC_OK) {
|
||||
if (status == HttpStatus.SC_OK) {
|
||||
String response;
|
||||
try {
|
||||
response = req.getResponseBodyAsString();
|
||||
|
@ -38,15 +38,13 @@ public class SmsFetcher {
|
||||
_existingDraftsMessages = null;
|
||||
}
|
||||
|
||||
public JSONArray fetchAllMessages() {
|
||||
_jsonDataDump = new JSONArray();
|
||||
bufferMailboxMessages(MailboxID.INBOX);
|
||||
bufferMailboxMessages(MailboxID.SENT);
|
||||
bufferMailboxMessages(MailboxID.DRAFTS);
|
||||
return _jsonDataDump;
|
||||
public void fetchAllMessages(JSONArray result) {
|
||||
bufferMailboxMessages(result, MailboxID.INBOX);
|
||||
bufferMailboxMessages(result, MailboxID.SENT);
|
||||
bufferMailboxMessages(result, MailboxID.DRAFTS);
|
||||
}
|
||||
|
||||
private void bufferMailboxMessages(MailboxID mbID) {
|
||||
private void bufferMailboxMessages(JSONArray result, MailboxID mbID) {
|
||||
String mbURI = mapMailboxIDToURI(mbID);
|
||||
|
||||
if ((_context == null) || (mbURI == null)) {
|
||||
@ -71,8 +69,9 @@ public class SmsFetcher {
|
||||
JSONObject entry = new JSONObject();
|
||||
|
||||
try {
|
||||
String colName;
|
||||
for(int idx=0;idx<c.getColumnCount();idx++) {
|
||||
String colName = c.getColumnName(idx);
|
||||
colName = c.getColumnName(idx);
|
||||
|
||||
// Id column is must be an integer
|
||||
switch (colName) {
|
||||
@ -101,14 +100,14 @@ public class SmsFetcher {
|
||||
// Mailbox ID is required by server
|
||||
entry.put("mbox", mbID.ordinal());
|
||||
|
||||
_jsonDataDump.put(entry);
|
||||
result.put(entry);
|
||||
|
||||
} catch (JSONException e) {
|
||||
Log.e(SmsFetcher.TAG, "JSON Exception when reading SMS Mailbox", e);
|
||||
c.close();
|
||||
}
|
||||
}
|
||||
while(c.moveToNext());
|
||||
while (c.moveToNext());
|
||||
|
||||
Log.d(SmsFetcher.TAG, c.getCount() + " messages read from " + mbURI);
|
||||
|
||||
@ -136,8 +135,9 @@ public class SmsFetcher {
|
||||
|
||||
try {
|
||||
Integer mboxId = -1;
|
||||
String colName;
|
||||
for(int idx = 0;idx < c.getColumnCount(); idx++) {
|
||||
String colName = c.getColumnName(idx);
|
||||
colName = c.getColumnName(idx);
|
||||
|
||||
// Id column is must be an integer
|
||||
switch (colName) {
|
||||
@ -178,16 +178,14 @@ public class SmsFetcher {
|
||||
}
|
||||
|
||||
// Used by ConnectivityChanged Event
|
||||
public JSONArray bufferMessagesSinceDate(Long sinceDate) {
|
||||
_jsonDataDump = new JSONArray();
|
||||
bufferMessagesSinceDate(MailboxID.INBOX, sinceDate);
|
||||
bufferMessagesSinceDate(MailboxID.SENT, sinceDate);
|
||||
bufferMessagesSinceDate(MailboxID.DRAFTS, sinceDate);
|
||||
return _jsonDataDump;
|
||||
public void bufferMessagesSinceDate(JSONArray result, Long sinceDate) {
|
||||
bufferMessagesSinceDate(result, MailboxID.INBOX, sinceDate);
|
||||
bufferMessagesSinceDate(result, MailboxID.SENT, sinceDate);
|
||||
bufferMessagesSinceDate(result, MailboxID.DRAFTS, sinceDate);
|
||||
}
|
||||
|
||||
// Used by ConnectivityChanged Event
|
||||
public void bufferMessagesSinceDate(MailboxID mbID, Long sinceDate) {
|
||||
public void bufferMessagesSinceDate(JSONArray result, MailboxID mbID, Long sinceDate) {
|
||||
String mbURI = mapMailboxIDToURI(mbID);
|
||||
|
||||
if ((_context == null) || (mbURI == null)) {
|
||||
@ -203,8 +201,9 @@ public class SmsFetcher {
|
||||
JSONObject entry = new JSONObject();
|
||||
|
||||
try {
|
||||
for(int idx=0;idx<c.getColumnCount();idx++) {
|
||||
String colName = c.getColumnName(idx);
|
||||
String colName;
|
||||
for (int idx = 0; idx < c.getColumnCount(); idx++) {
|
||||
colName = c.getColumnName(idx);
|
||||
|
||||
// Id column is must be an integer
|
||||
switch (colName) {
|
||||
@ -233,14 +232,14 @@ public class SmsFetcher {
|
||||
// Mailbox ID is required by server
|
||||
entry.put("mbox", mbID.ordinal());
|
||||
|
||||
_jsonDataDump.put(entry);
|
||||
result.put(entry);
|
||||
|
||||
} catch (JSONException e) {
|
||||
Log.e(SmsFetcher.TAG, "JSON Exception when reading SMS Mailbox", e);
|
||||
c.close();
|
||||
}
|
||||
}
|
||||
while(c.moveToNext());
|
||||
while (c.moveToNext());
|
||||
|
||||
Log.d(SmsFetcher.TAG, c.getCount() + " messages read from " + mbURI);
|
||||
|
||||
@ -273,23 +272,23 @@ public class SmsFetcher {
|
||||
existingMessages = _existingDraftsMessages;
|
||||
} else if (_mbID == MailboxID.SENT) {
|
||||
existingMessages = _existingSentMessages;
|
||||
}
|
||||
} else {
|
||||
return "";
|
||||
}
|
||||
|
||||
// Note: The default case isn't possible, we check the mailbox before
|
||||
|
||||
StringBuilder sb = new StringBuilder();
|
||||
if (existingMessages != null) {
|
||||
int len = existingMessages.length();
|
||||
for (int i = 0; i < len; i++) {
|
||||
try {
|
||||
if (sb.length() > 0) {
|
||||
sb.append(",");
|
||||
}
|
||||
sb.append(existingMessages.getInt(i));
|
||||
} catch (JSONException ignored) {
|
||||
int len = existingMessages.length();
|
||||
for (int i = 0; i < len; i++) {
|
||||
try {
|
||||
if (sb.length() > 0) {
|
||||
sb.append(",");
|
||||
}
|
||||
sb.append(existingMessages.getInt(i));
|
||||
} catch (JSONException ignored) {
|
||||
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
return sb.toString();
|
||||
}
|
||||
@ -311,7 +310,6 @@ public class SmsFetcher {
|
||||
}
|
||||
|
||||
private final Context _context;
|
||||
private JSONArray _jsonDataDump;
|
||||
private JSONArray _existingInboxMessages;
|
||||
private JSONArray _existingSentMessages;
|
||||
private JSONArray _existingDraftsMessages;
|
||||
|
Loading…
x
Reference in New Issue
Block a user