space-android/src/main/java/com/owncloud/android/jobs/FilesSyncJob.java

/**
 * Nextcloud Android client application
 *
 * @author Mario Danic
 * Copyright (C) 2017 Mario Danic
 * Copyright (C) 2017 Nextcloud
 *
 * This program is free software; you can redistribute it and/or
 * modify it under the terms of the GNU AFFERO GENERAL PUBLIC LICENSE
 * License as published by the Free Software Foundation; either
 * version 3 of the License, or any later version.
 *
 * This program 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 AFFERO GENERAL PUBLIC LICENSE for more details.
 *
 * You should have received a copy of the GNU Affero General Public
 * License along with this program.  If not, see <http://www.gnu.org/licenses/>.
 */

package com.owncloud.android.jobs;

import android.accounts.Account;
import android.content.ContentResolver;
import android.content.Context;
import android.os.PowerManager;
import android.support.annotation.NonNull;
import android.support.media.ExifInterface;
import android.text.TextUtils;

import com.evernote.android.job.Job;
import com.evernote.android.job.util.support.PersistableBundleCompat;
import com.owncloud.android.MainApp;
import com.owncloud.android.authentication.AccountUtils;
import com.owncloud.android.datamodel.FilesystemDataProvider;
import com.owncloud.android.datamodel.MediaFolderType;
import com.owncloud.android.datamodel.SyncedFolder;
import com.owncloud.android.datamodel.SyncedFolderProvider;
import com.owncloud.android.files.services.FileUploader;
import com.owncloud.android.lib.common.utils.Log_OC;
import com.owncloud.android.operations.UploadFileOperation;
import com.owncloud.android.utils.FileStorageUtils;
import com.owncloud.android.utils.FilesSyncHelper;
import com.owncloud.android.utils.MimeTypeUtil;

import java.io.File;
import java.io.IOException;
import java.text.ParsePosition;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.Locale;
import java.util.TimeZone;

/*
    Job that:
        - restarts existing jobs if required
        - finds new and modified files since we last run this
        - creates upload tasks
 */
public class FilesSyncJob extends Job {
    public static final String TAG = "FilesSyncJob";

    public static final String SKIP_CUSTOM = "skipCustom";

    @NonNull
    @Override
    protected Result onRunJob(Params params) {
        final Context context = MainApp.getAppContext();
        final ContentResolver contentResolver = context.getContentResolver();

        PowerManager powerManager = (PowerManager) context.getSystemService(Context.POWER_SERVICE);
        FileUploader.UploadRequester requester = new FileUploader.UploadRequester();
        PowerManager.WakeLock wakeLock = powerManager.newWakeLock(PowerManager.PARTIAL_WAKE_LOCK,
                TAG);
        wakeLock.acquire();

        PersistableBundleCompat bundle = params.getExtras();
        final boolean skipCustom = bundle.getBoolean(SKIP_CUSTOM, false);

        FilesSyncHelper.restartJobsIfNeeded();
        FilesSyncHelper.insertAllDBEntries(skipCustom);

        // Create all the providers we'll need
        final FilesystemDataProvider filesystemDataProvider = new FilesystemDataProvider(contentResolver);
        SyncedFolderProvider syncedFolderProvider = new SyncedFolderProvider(contentResolver);

        for (SyncedFolder syncedFolder : syncedFolderProvider.getSyncedFolders()) {
            if ((syncedFolder.isEnabled()) && (!skipCustom || MediaFolderType.CUSTOM != syncedFolder.getType())) {
                for (String path : filesystemDataProvider.getFilesForUpload(syncedFolder.getLocalPath(),
                        Long.toString(syncedFolder.getId()))) {
                    File file = new File(path);

                    Long lastModificationTime = file.lastModified();
                    final Locale currentLocale = context.getResources().getConfiguration().locale;

                    if (MediaFolderType.IMAGE == syncedFolder.getType()) {
                        String mimetypeString = FileStorageUtils.getMimeTypeFromName(file.getAbsolutePath());
                        if ("image/jpeg".equalsIgnoreCase(mimetypeString) || "image/tiff".
                                equalsIgnoreCase(mimetypeString)) {
                            try {
                                ExifInterface exifInterface = new ExifInterface(file.getAbsolutePath());
                                String exifDate = exifInterface.getAttribute(ExifInterface.TAG_DATETIME);
                                if (!TextUtils.isEmpty(exifDate)) {
                                    ParsePosition pos = new ParsePosition(0);
                                    SimpleDateFormat sFormatter = new SimpleDateFormat("yyyy:MM:dd HH:mm:ss",
                                            currentLocale);
                                    sFormatter.setTimeZone(TimeZone.getTimeZone(TimeZone.getDefault().getID()));
                                    Date dateTime = sFormatter.parse(exifDate, pos);
                                    lastModificationTime = dateTime.getTime();
                                }

                            } catch (IOException e) {
                                Log_OC.d(TAG, "Failed to get the proper time " + e.getLocalizedMessage());
                            }
                        }
                    }

                    boolean needsCharging = syncedFolder.getChargingOnly();
                    boolean needsWifi = syncedFolder.getWifiOnly();

                    String mimeType = MimeTypeUtil.getBestMimeTypeByFilename(file.getAbsolutePath());

                    Account account = AccountUtils.getOwnCloudAccountByName(context, syncedFolder.getAccount());

                    requester.uploadFileWithOverwrite(
                            context,
                            account,
                            file.getAbsolutePath(),
                            FileStorageUtils.getInstantUploadFilePath(
                                    currentLocale,
                                    syncedFolder.getRemotePath(), file.getName(),
                                    lastModificationTime,
                                    syncedFolder.getSubfolderByDate()),
                            syncedFolder.getUploadAction(),
                            mimeType,
                            true,           // create parent folder if not existent
                            UploadFileOperation.CREATED_AS_INSTANT_PICTURE,
                            needsWifi,
                            needsCharging,
                            true
                    );

                    filesystemDataProvider.updateFilesystemFileAsSentForUpload(path,
                            Long.toString(syncedFolder.getId()));
                }
            }
        }

        wakeLock.release();
        return Result.SUCCESS;
    }
}