2019-01-17 13:29:35 +00:00
|
|
|
package eu.faircode.email;
|
|
|
|
|
|
|
|
/*
|
|
|
|
This file is part of FairEmail.
|
|
|
|
|
|
|
|
FairEmail is free software: you can redistribute it and/or modify
|
|
|
|
it under the terms of the GNU General Public License as published by
|
|
|
|
the Free Software Foundation, either version 3 of the License, or
|
|
|
|
(at your option) any later version.
|
|
|
|
|
|
|
|
FairEmail is distributed in the hope that it will be useful,
|
|
|
|
but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
|
|
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
|
|
GNU General Public License for more details.
|
|
|
|
|
|
|
|
You should have received a copy of the GNU General Public License
|
|
|
|
along with FairEmail. If not, see <http://www.gnu.org/licenses/>.
|
|
|
|
|
|
|
|
Copyright 2018-2019 by Marcel Bokhorst (M66B)
|
|
|
|
*/
|
|
|
|
|
|
|
|
import android.content.Context;
|
|
|
|
|
|
|
|
import org.json.JSONException;
|
|
|
|
import org.json.JSONObject;
|
|
|
|
|
2019-01-18 13:04:05 +00:00
|
|
|
import java.util.Enumeration;
|
2019-01-17 13:29:35 +00:00
|
|
|
import java.util.regex.Pattern;
|
|
|
|
|
2019-01-18 10:58:55 +00:00
|
|
|
import javax.mail.Address;
|
2019-01-18 13:04:05 +00:00
|
|
|
import javax.mail.Header;
|
|
|
|
import javax.mail.Message;
|
|
|
|
import javax.mail.MessagingException;
|
2019-01-18 10:58:55 +00:00
|
|
|
import javax.mail.internet.InternetAddress;
|
|
|
|
|
2019-01-17 13:29:35 +00:00
|
|
|
import androidx.annotation.NonNull;
|
|
|
|
import androidx.room.Entity;
|
|
|
|
import androidx.room.ForeignKey;
|
|
|
|
import androidx.room.Index;
|
|
|
|
import androidx.room.PrimaryKey;
|
|
|
|
|
|
|
|
import static androidx.room.ForeignKey.CASCADE;
|
|
|
|
|
|
|
|
@Entity(
|
|
|
|
tableName = EntityRule.TABLE_NAME,
|
|
|
|
foreignKeys = {
|
|
|
|
@ForeignKey(childColumns = "folder", entity = EntityFolder.class, parentColumns = "id", onDelete = CASCADE),
|
|
|
|
},
|
|
|
|
indices = {
|
|
|
|
@Index(value = {"folder"}),
|
|
|
|
@Index(value = {"order"})
|
|
|
|
}
|
|
|
|
)
|
|
|
|
public class EntityRule {
|
|
|
|
static final String TABLE_NAME = "rule";
|
|
|
|
|
|
|
|
@PrimaryKey(autoGenerate = true)
|
|
|
|
public Long id;
|
|
|
|
@NonNull
|
|
|
|
public Long folder;
|
|
|
|
@NonNull
|
|
|
|
public String name;
|
|
|
|
@NonNull
|
|
|
|
public int order;
|
|
|
|
@NonNull
|
2019-01-17 21:25:22 +00:00
|
|
|
public boolean enabled;
|
|
|
|
@NonNull
|
2019-01-18 10:58:55 +00:00
|
|
|
public boolean stop;
|
|
|
|
@NonNull
|
2019-01-17 13:29:35 +00:00
|
|
|
public String condition;
|
|
|
|
@NonNull
|
|
|
|
public String action;
|
|
|
|
|
|
|
|
static final int TYPE_SEEN = 1;
|
|
|
|
static final int TYPE_UNSEEN = 2;
|
|
|
|
static final int TYPE_MOVE = 3;
|
|
|
|
|
2019-01-18 13:04:05 +00:00
|
|
|
boolean matches(Context context, EntityMessage message, Message imessage) throws MessagingException {
|
2019-01-17 21:41:00 +00:00
|
|
|
try {
|
|
|
|
JSONObject jcondition = new JSONObject(condition);
|
|
|
|
|
2019-01-18 10:58:55 +00:00
|
|
|
JSONObject jsender = jcondition.optJSONObject("sender");
|
|
|
|
if (jsender != null) {
|
2019-01-18 13:04:05 +00:00
|
|
|
String value = jsender.getString("value");
|
2019-01-18 10:58:55 +00:00
|
|
|
boolean regex = jsender.getBoolean("regex");
|
|
|
|
|
|
|
|
boolean matches = false;
|
|
|
|
if (message.from != null) {
|
|
|
|
for (Address from : message.from) {
|
|
|
|
InternetAddress ia = (InternetAddress) from;
|
|
|
|
String personal = ia.getPersonal();
|
|
|
|
String formatted = ((personal == null ? "" : personal + " ") + "<" + ia.getAddress() + ">");
|
2019-01-18 13:04:05 +00:00
|
|
|
if (matches(value, formatted, regex)) {
|
2019-01-18 10:58:55 +00:00
|
|
|
matches = true;
|
|
|
|
break;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
if (!matches)
|
|
|
|
return false;
|
2019-01-17 21:41:00 +00:00
|
|
|
}
|
|
|
|
|
2019-01-18 10:58:55 +00:00
|
|
|
JSONObject jsubject = jcondition.optJSONObject("subject");
|
|
|
|
if (jsubject != null) {
|
2019-01-18 13:04:05 +00:00
|
|
|
String value = jsubject.getString("value");
|
2019-01-18 10:58:55 +00:00
|
|
|
boolean regex = jsubject.getBoolean("regex");
|
|
|
|
|
2019-01-18 13:04:05 +00:00
|
|
|
if (!matches(value, message.subject, regex))
|
|
|
|
return false;
|
|
|
|
}
|
|
|
|
|
|
|
|
JSONObject jheader = jcondition.optJSONObject("header");
|
|
|
|
if (jheader != null) {
|
|
|
|
String value = jheader.getString("value");
|
|
|
|
boolean regex = jheader.getBoolean("regex");
|
|
|
|
|
|
|
|
boolean matches = false;
|
|
|
|
Enumeration<Header> headers = imessage.getAllHeaders();
|
|
|
|
while (headers.hasMoreElements()) {
|
|
|
|
Header header = headers.nextElement();
|
|
|
|
String formatted = header.getName() + ": " + header.getValue();
|
|
|
|
if (matches(value, formatted, regex)) {
|
|
|
|
matches = true;
|
|
|
|
break;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
if (!matches)
|
2019-01-18 10:58:55 +00:00
|
|
|
return false;
|
2019-01-17 21:41:00 +00:00
|
|
|
}
|
2019-01-18 10:58:55 +00:00
|
|
|
|
|
|
|
// Safeguard
|
2019-01-18 13:04:05 +00:00
|
|
|
if (jsender == null && jsubject == null && jheader == null)
|
2019-01-18 10:58:55 +00:00
|
|
|
return false;
|
2019-01-17 21:41:00 +00:00
|
|
|
} catch (JSONException ex) {
|
|
|
|
Log.e(ex);
|
2019-01-18 10:58:55 +00:00
|
|
|
return false;
|
2019-01-17 13:29:35 +00:00
|
|
|
}
|
|
|
|
|
2019-01-18 10:58:55 +00:00
|
|
|
return true;
|
2019-01-17 13:29:35 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
private boolean matches(String needle, String haystack, boolean regex) {
|
2019-01-18 10:58:55 +00:00
|
|
|
Log.i("Matches needle=" + needle + " haystack=" + haystack + " regex=" + regex);
|
|
|
|
|
|
|
|
if (needle == null || haystack == null)
|
|
|
|
return false;
|
|
|
|
|
2019-01-17 13:29:35 +00:00
|
|
|
if (regex) {
|
|
|
|
Pattern pattern = Pattern.compile(needle);
|
|
|
|
return pattern.matcher(haystack).matches();
|
|
|
|
} else
|
2019-01-18 13:04:05 +00:00
|
|
|
return haystack.toLowerCase().contains(needle.toLowerCase());
|
2019-01-17 13:29:35 +00:00
|
|
|
}
|
|
|
|
|
2019-01-17 21:41:00 +00:00
|
|
|
void execute(Context context, DB db, EntityMessage message) {
|
|
|
|
try {
|
|
|
|
JSONObject jargs = new JSONObject(action);
|
|
|
|
int type = jargs.getInt("type");
|
2019-01-18 11:26:02 +00:00
|
|
|
Log.i("Executing rule=" + type + ":" + name + " message=" + message.id);
|
2019-01-17 21:41:00 +00:00
|
|
|
|
|
|
|
switch (type) {
|
|
|
|
case TYPE_SEEN:
|
|
|
|
onActionSeen(context, db, message, true);
|
|
|
|
break;
|
|
|
|
case TYPE_UNSEEN:
|
|
|
|
onActionSeen(context, db, message, false);
|
|
|
|
break;
|
|
|
|
case TYPE_MOVE:
|
|
|
|
onActionMove(context, db, message, jargs);
|
|
|
|
break;
|
|
|
|
}
|
|
|
|
} catch (JSONException ex) {
|
|
|
|
Log.e(ex);
|
2019-01-17 13:29:35 +00:00
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
private void onActionSeen(Context context, DB db, EntityMessage message, boolean seen) {
|
|
|
|
EntityOperation.queue(context, db, message, EntityOperation.SEEN, seen);
|
2019-01-17 21:41:00 +00:00
|
|
|
message.seen = seen;
|
2019-01-17 13:29:35 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
private void onActionMove(Context context, DB db, EntityMessage message, JSONObject jargs) throws JSONException {
|
|
|
|
long target = jargs.getLong("target");
|
2019-01-18 08:43:29 +00:00
|
|
|
EntityOperation.queue(context, db, message, EntityOperation.MOVE, target, false);
|
2019-01-17 13:29:35 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
@Override
|
|
|
|
public boolean equals(Object obj) {
|
|
|
|
if (obj instanceof EntityRule) {
|
|
|
|
EntityRule other = (EntityRule) obj;
|
|
|
|
return this.folder.equals(other.folder) &&
|
|
|
|
this.name.equals(other.name) &&
|
2019-01-17 21:25:22 +00:00
|
|
|
this.order == other.order &&
|
|
|
|
this.enabled == other.enabled &&
|
2019-01-18 10:58:55 +00:00
|
|
|
this.stop == other.stop &&
|
2019-01-17 13:29:35 +00:00
|
|
|
this.condition.equals(other.condition) &&
|
2019-01-17 21:25:22 +00:00
|
|
|
this.action.equals(other.action);
|
2019-01-17 13:29:35 +00:00
|
|
|
} else
|
|
|
|
return false;
|
|
|
|
}
|
|
|
|
}
|