import { Location } from '@angular/common';
import { Component, OnDestroy } from '@angular/core';
import { ActivatedRoute } from '@angular/router';
import * as _ from 'underscore';
import { TranslateService } from '@ngx-translate/core';
import { SyncService } from '../../core/services/sync.service';
import { NetworkService } from '../../core/services/network.service';
import { statusType, ToastService } from '../../core';
import { DbService } from '../../core/services/db.service';
import { urlConstants } from '../../core/constants/urlConstants';
import { SharingFeatureService } from '../../core/services/sharing-feature.service';

var environment = {
  db: {
    projects: "project.db",
    categories: "categories.db",
  },
  deepLinkAppsUrl: ''
};

@Component({
  selector: 'app-sync',
  templateUrl: './sync.page.html',
  styleUrls: ['./sync.page.scss'],
})
export class SyncPage implements  OnDestroy {

  projectId;
  projectDetails;
  allProjects = [];
  syncIndex: number = 0;
  allStrings;
  progressPercentage = 0;
  attachments = [];
  imageUploadIndex = 0;
  taskId;
  fileName;
  isShare;
  syncCompletedProjects = [];
  isSubmission;
  retryCount: number = 0;

  constructor(
    private routerparam: ActivatedRoute,
    private toast: ToastService,
    private location: Location,
    private syncServ: SyncService,
    private translate: TranslateService,
    private db: DbService,
    private network: NetworkService,
    private share: SharingFeatureService) {
    this.db.createPouchDB(environment.db.projects);
    this.translate
      .get([
        "FRMELEMNTS_MSG_PROJCET_ALREADY_UPTODATE",
        "FRMELEMNTS_MSG_SUCCESSFULLY_SYNCED",
        "FRMELEMNTS_MSG_SOMETHING_WENT_WRONG",
        "FRMELEMNTS_MSG_SYNC_FAILED",
        "FRMELEMNTS_MSG_OFFLINE",
        "FRMELEMNTS_MSG_SUCCESSFULLY_SUBMITTED"
      ])
      .subscribe((data) => {
        this.allStrings = data
      });
    if (this.network.isNetworkAvailable) {
      this.routerparam.queryParams.subscribe((params) => {
        if (params && params.projectId) {
          //Sync only single project
          this.projectId = params.projectId;
          this.taskId = params.taskId ? params.taskId : '';
          this.isShare = params.share == 'true';
          this.fileName = params.fileName;
          this.getProjectFromId(params.projectId);
          this.isSubmission = params.isSubmission || false;
        } else {
          //sync mutiple projects
          this.getAllUnSyncedProject();
        }
      })
    } else {
      this.toast.showMessage('FRMELEMNTS_MSG_OFFLINE', 'danger');
      this.location.back();
    }
  }


  ngOnDestroy() {
  }

  //get single project from db
  getProjectFromId(projectId) {
    this.db.customQuery({
      selector: {
        _id: projectId,
        $or: [
          { isNew: true },
          { isEdit: true },
        ]
      }
    }).then(success => {
      if (success['docs'].length) {
        this.allProjects.push(success['docs'][0]);
        this.checkForActions();
      } else {
        this.location.back()
        this.toast.showMessage(this.allStrings['FRMELEMNTS_MSG_SUCCESSFULLY_SYNCED']);
        // this.toast.showMessage(this.allStrings['FRMELEMNTS_MSG_PROJCET_ALREADY_UPTODATE'], 'danger')
      }
    }, error => { })
  }

  //get all new and edited projects (for overall sync)
  getAllUnSyncedProject() {
    this.db.customQuery({
      selector: {
        $or: [
          { isNew: true },
          { isEdit: true },
        ]
      }
    }).then(success => {
      if (success['docs'].length) {
        this.allProjects = this.allProjects.concat(success['docs']);
        this.checkForActions();
      } else {
        this.location.back()
        this.toast.showMessage(this.allStrings['FRMELEMNTS_MSG_PROJCET_ALREADY_UPTODATE'])
      }
    }, error => { })
  }

  //Check if the project is new or edited existing
  checkForActions() {
    if (this.allProjects[this.syncIndex]) {
      if (this.allProjects[this.syncIndex].isNew) {
        this.createProjectCall()
      } else {
        this.attachments = this.syncServ.getAllAttachmentOfProject(this.allProjects[this.syncIndex]);
        this.attachments.length ? this.getImageUploadUrls() : this.doSyncCall();
      }
      this.calculateProgressPercentage()
    } else {
      this.syncIndex = 0;
      this.showSuccessToast();
      if (this.isShare) {
        this.getPdfUrl(this.fileName, this.taskId);
      }
      this.location.back();
    }
  }

  showSuccessToast() {
    const toast = this.allProjects[this.syncIndex].status === statusType.submitted ? this.allStrings['FRMELEMNTS_MSG_SUCCESSFULLY_SUBMITTED'] : this.allStrings['FRMELEMNTS_MSG_SUCCESSFULLY_SYNCED'] ;
    this.toast.showMessage(toast);
  }

  calculateProgressPercentage() {
    let percent = ((this.syncCompletedProjects.length) / this.allProjects.length) * 100;
    this.progressPercentage = Math.round(percent);
  }

  //create projectId API call for new projects
  createProjectCall() {
    this.syncServ.createNewProject().then(success => {
      this.updateProjectDoc(success.result);
    }).catch(error => {
      this.toast.showMessage(this.allStrings['FRMELEMNTS_MSG_SOMETHING_WENT_WRONG'], 'danger');
      this.location.back();
    })
  }

  //Map project id to existing doc. create a new doc and delete the old doc
  updateProjectDoc(newPrjctDetails) {
    const _rev = this.allProjects[this.syncIndex]._rev;
    const oldPrjstId = this.allProjects[this.syncIndex]._id;
    this.allProjects[this.syncIndex]._id = newPrjctDetails._id;
    this.allProjects[this.syncIndex].lastDownloadedAt = newPrjctDetails.lastDownloadedAt;
    delete this.allProjects[this.syncIndex]._rev;
    //remove is isNew flag from project meta, task and sub task
    const newObj = this.syncServ.removeKeys(this.allProjects[this.syncIndex], ['isNew'])
    this.db.create(newObj).then(success => {
      this.allProjects[this.syncIndex]._rev = success.rev;
      this.db.delete(oldPrjstId, _rev).then(deleteSuccess => {
        this.attachments = this.syncServ.getAllAttachmentOfProject(this.allProjects[this.syncIndex]);
        this.attachments.length ? this.getImageUploadUrls() : this.doSyncCall();
      }).catch(deletError => {
        this.toast.showMessage(this.allStrings['FRMELEMNTS_MSG_SOMETHING_WENT_WRONG'], 'danger');
        this.location.back();
      })
    }).catch(error => {
      this.toast.showMessage(this.allStrings['FRMELEMNTS_MSG_SOMETHING_WENT_WRONG'], 'danger');
      this.location.back();

    })
  }

  //Syn project API call
  doSyncCall() {
    this.allProjects[this.syncIndex].status = (this.isSubmission ==='true') ?  statusType.submitted :this.allProjects[this.syncIndex].status;
    const paylod = this.createSyncPayload();
    this.syncServ.syncApiRequest(paylod).then(success => {
      this.allProjects[this.syncIndex] = this.syncServ.removeKeys(this.allProjects[this.syncIndex], ['isNew', 'isEdit']);
      (success.result && success.result.programId) ? this.allProjects[this.syncIndex]['programId'] = success.result.programId : null;
      this.updateSyncedDataToDb();
    }).catch(error => {
      this.location.back();
    })
  }

  //update the synced data to local
  updateSyncedDataToDb() {
    this.db.update(this.allProjects[this.syncIndex]).then(success => {
      this.syncCompletedProjects.push(this.allProjects[this.syncIndex]);
      this.syncIndex++;
      this.resetImageUploadVariables()
      this.checkForActions();
    })
  }

  createSyncPayload() {
    const payload = { ...this.allProjects[this.syncIndex] };
    const filteredTasks = _.filter(payload.tasks, (task) => {
      return task.isNew || task.isEdit
    })
    delete payload.createdAt;
    delete payload.updatedAt;
    delete payload.downloaded
    payload.tasks = filteredTasks;
    return this.syncServ.removeKeys(payload, ['isNew', 'isEdit'])
  }

  getImageUploadUrls() {
    const project = { ...this.allProjects[this.syncIndex] };
    this.syncServ.getImageUploadUrls(project).then(imageInfo => {
      for (let i = 0; i < this.attachments.length; i++) {
        this.attachments[i].uploadUrl = imageInfo[i].url;
        this.attachments[i].cloudStorage = imageInfo[i].cloudStorage;
        for (const key of Object.keys(imageInfo[i].payload)) {
          this.attachments[i][key] = imageInfo[i].payload[key];
        }
      }
      this.cloudUpload(this.attachments[this.imageUploadIndex])
    })
  }

  resetImageUploadVariables() {
    this.imageUploadIndex = 0;
    this.attachments = [];
  }

  cloudUpload(imageDetails) {
    this.syncServ.cloudImageUpload(imageDetails).then(success => {
      this.retryCount =0;
      delete this.attachments[this.imageUploadIndex].cloudStorage;
      delete this.attachments[this.imageUploadIndex].uploadUrl;
      delete this.attachments[this.imageUploadIndex].isUploaded;
      if (this.imageUploadIndex + 1 < this.attachments.length) {
        this.imageUploadIndex++;
        this.cloudUpload(this.attachments[this.imageUploadIndex])
      } else {
        this.doSyncCall();
      }
    }).catch(error => {
      this.retryCount++;
      if (this.retryCount > 3) {
        this.translate.get('FRMELEMNTS_MSG_EVIDENCE_UPLOAD_FAILED').subscribe((translations) => {
          this.toast.showMessage(translations,'danger');
        });
        this.location.back();
      } else {
        this.cloudUpload(this.attachments[this.imageUploadIndex]);
      }
    })
  }




  getPdfUrl(fileName=this.allProjects[this.syncIndex]?.title, taskId?) {
   let task_id = taskId ? taskId : '';
    const config = {
      url: urlConstants.API_URLS.GET_SHARABLE_PDF + this.projectId + '?tasks=' + task_id,
    };
    this.share.getFileUrl(config, fileName);
  }
}