FairEmail/app/src/main/java/eu/faircode/email/DaoAttachment.java

124 lines
4.1 KiB
Java

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-2020 by Marcel Bokhorst (M66B)
*/
import androidx.lifecycle.LiveData;
import androidx.room.Dao;
import androidx.room.Insert;
import androidx.room.Query;
import java.util.List;
@Dao
public interface DaoAttachment {
@Query("SELECT * FROM attachment" +
" WHERE message = :message" +
" ORDER BY sequence, subsequence")
LiveData<List<EntityAttachment>> liveAttachments(long message);
@Query("SELECT ifnull(MAX(sequence), 0)" +
" FROM attachment" +
" WHERE message = :message")
int getAttachmentSequence(long message);
@Query("SELECT * FROM attachment" +
" WHERE message = :message" +
" ORDER BY sequence, subsequence")
List<EntityAttachment> getAttachments(long message);
@Query("SELECT * FROM attachment" +
" WHERE id = :id")
EntityAttachment getAttachment(long id);
@Query("SELECT * FROM attachment" +
" WHERE message = :message" +
" AND sequence = :sequence")
EntityAttachment getAttachment(long message, int sequence);
@Query("SELECT * FROM attachment" +
" WHERE message = :message" +
" AND cid = :cid" +
" LIMIT 1")
EntityAttachment getAttachment(long message, String cid);
@Query("SELECT id FROM attachment" +
" WHERE available")
List<Long> getAttachmentAvailable();
@Query("UPDATE attachment" +
" SET message = :message" +
" WHERE id = :id")
void setMessage(long id, long message);
@Query("UPDATE attachment" +
" SET error = NULL, progress = :progress, available = 0" +
" WHERE id = :id")
void setProgress(long id, Integer progress);
@Query("UPDATE attachment" +
" SET size = :size, error = NULL, progress = NULL, available = 1" +
" WHERE id = :id")
void setDownloaded(long id, Long size);
@Query("UPDATE attachment" +
" SET size = NULL, progress = NULL, available = :available" +
" WHERE id = :id")
void setAvailable(long id, boolean available);
@Query("UPDATE attachment" +
" SET error = :error, progress = NULL, available = 0" +
" WHERE id = :id")
void setError(long id, String error);
@Query("UPDATE attachment" +
" SET disposition = :disposition" +
" WHERE id = :id")
void setDisposition(long id, String disposition);
@Query("UPDATE attachment" +
" SET cid = :cid" +
" WHERE id = :id")
void setCid(long id, String cid);
@Query("UPDATE attachment" +
" SET available = 0" +
" WHERE EXISTS" +
" (SELECT * FROM attachment a" +
" JOIN message ON message.id = a.message" +
" JOIN folder ON folder.id = message.folder" +
" WHERE a.id = attachment.id" +
" AND a.available" +
" AND message.ui_seen" +
" AND NOT message.ui_flagged" +
" AND message.received < :now - (folder.sync_days + 1) * 24 * 3600 * 1000)")
int purge(long now);
@Insert
long insertAttachment(EntityAttachment attachment);
@Query("DELETE FROM attachment" +
" WHERE id = :id")
int deleteAttachment(long id);
@Query("DELETE FROM attachment" +
" WHERE message = :message")
int deleteAttachments(long message);
}