package eu.faircode.email; /* This file is part of Safe email. Safe email 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. NetGuard 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 NetGuard. If not, see . Copyright 2018 by Marcel Bokhorst (M66B) */ import android.content.Context; import android.content.Intent; import android.util.Log; import org.json.JSONArray; import java.util.ArrayList; import java.util.Date; import java.util.List; import androidx.annotation.NonNull; import androidx.localbroadcastmanager.content.LocalBroadcastManager; import androidx.room.Entity; import androidx.room.ForeignKey; import androidx.room.Index; import androidx.room.PrimaryKey; import static androidx.room.ForeignKey.CASCADE; @Entity( tableName = EntityOperation.TABLE_NAME, foreignKeys = { @ForeignKey(childColumns = "folder", entity = EntityFolder.class, parentColumns = "id", onDelete = CASCADE), @ForeignKey(childColumns = "message", entity = EntityMessage.class, parentColumns = "id", onDelete = CASCADE) }, indices = { @Index(value = {"folder"}), @Index(value = {"message"}) } ) public class EntityOperation { static final String TABLE_NAME = "operation"; @PrimaryKey(autoGenerate = true) public Long id; @NonNull public Long folder; @NonNull public Long message; @NonNull public String name; @NonNull public String args; @NonNull public Long created; public static final String SEEN = "seen"; public static final String ADD = "add"; public static final String MOVE = "move"; public static final String DELETE = "delete"; public static final String SEND = "send"; public static final String ATTACHMENT = "attachment"; private static List queue = new ArrayList<>(); static void queue(DB db, EntityMessage message, String name) { JSONArray jsonArray = new JSONArray(); queue(db, message, name, jsonArray); } static void queue(DB db, EntityMessage message, String name, Object value) { JSONArray jsonArray = new JSONArray(); jsonArray.put(value); queue(db, message, name, jsonArray); } static void queue(DB db, EntityMessage message, String name, Object value1, Object value2) { JSONArray jsonArray = new JSONArray(); jsonArray.put(value1); jsonArray.put(value2); queue(db, message, name, jsonArray); } private static void queue(DB db, EntityMessage message, String name, JSONArray jsonArray) { EntityOperation operation = new EntityOperation(); operation.folder = message.folder; operation.message = message.id; operation.name = name; operation.args = jsonArray.toString(); operation.created = new Date().getTime(); operation.id = db.operation().insertOperation(operation); Intent intent = new Intent(); intent.setType("account/" + (SEND.equals(name) ? "outbox" : message.account)); intent.setAction(ServiceSynchronize.ACTION_PROCESS_OPERATIONS); intent.putExtra("folder", message.folder); synchronized (queue) { queue.add(intent); } Log.i(Helper.TAG, "Queued op=" + operation.id + "/" + operation.name + " msg=" + message.folder + "/" + operation.message + " args=" + operation.args); } public static void process(Context context) { // Processing needs to be done after committing to the database LocalBroadcastManager lbm = LocalBroadcastManager.getInstance(context); synchronized (queue) { for (Intent intent : queue) lbm.sendBroadcast(intent); queue.clear(); } } @Override public boolean equals(Object obj) { if (obj instanceof EntityOperation) { EntityOperation other = (EntityOperation) obj; return (this.folder.equals(other.folder) && this.message.equals(other.message) && this.name.equals(other.name) && this.args.equals(other.args)); } else return false; } }