ldc-com-app/ComApp/src/App/Controllers/SyncController.js

// Lodash
import _ from 'lodash';
// Http Client
import axios from 'axios';
// Network Infos
import NetInfo from "@react-native-community/netinfo";
// Application infos
import * as Application from 'expo-application';
// Database 
import { Setting, Contact, SendBrochure, Document } from '../../Database';

const api_token = 'G9Q62jt8eL8gN4Ls';

class SyncController {

    getUrlBo() {
        const test = Setting.get('bo_url');
        if (test === false || test === undefined) {
            return "noset";
        }
        return test.value;
    }

    getAppStoreUUID() {
        const test = Setting.get('AppStoreUUID');
        if (test === false || test === undefined) {
            return "noset";
        }
        return test.value;
    }

    async checkConnection() {
        return NetInfo.fetch();
    }

    async getVersion() {
        return axios({
            method: 'GET',
            url: this.getUrlBo() + '/api/version',
            responseType: 'json',
            params: {
                token: api_token,
                app_uuid: this.getAppStoreUUID(),
                app_version: Application.nativeApplicationVersion
            },
        });
    }

    async getUsers() {
        return axios({
            method: 'GET',
            url: this.getUrlBo() + '/api/users',
            responseType: 'json',
            params: {
                token: api_token
            },
        });
    }

    async getContacts(userId) {
        let contacts = Contact.getAll();
        return axios({
            method: 'POST',
            url: this.getUrlBo() + '/api/contacts',
            responseType: 'json',
            params: {
                token: api_token
            },
            data: {
                contacts: contacts,
                userId: userId,
            }
        });
    }

    async sendBrochure(brochure) {
        return axios({
            method: 'POST',
            url: this.getUrlBo() + '/api/sendBrochure',
            responseType: 'json',
            params: {
                token: api_token,
                emails: brochure,
            },
        });
    }

    async getDirectories() {
        return axios({
            method: 'GET',
            url: this.getUrlBo() + '/api/directories',
            responseType: 'json',
            params: {
                token: api_token
            },
        });
    }

    async getDocuments() {
        return axios({
            method: 'GET',
            url: this.getUrlBo() + '/api/documents',
            responseType: 'json',
            params: {
                token: api_token,
            },
        });
    }

    updateLastModificationDoc(id, date) {
        Document.update({ id: id, updated_at: date.toString() }, true);
    }

    updateVersion(version) {
        const localVersion = Setting.get('version');
        if (localVersion === false || localVersion === undefined) {
            Setting.add({ key: 'version', value: version });
        } else {
            Setting.update({ id: localVersion.id, key: 'version', value: version });
        }
    }

    updateShowIsActive(value) {
        const local = Setting.get('ShowIsActive');
        if (local === false || local === undefined) {
            Setting.add({ key: 'ShowIsActive', value: value });
        } else {
            Setting.update({ id: local.id, key: 'ShowIsActive', value: value });
        }
    }

    isSynced() {
        const brochures = SendBrochure.getAll();
        const Contacts = Contact.getAll();

        if (brochures !== undefined && Contacts !== undefined) {
            const noSynced = Contacts.filtered('synced = false');
            if (brochures.length > 0 || noSynced.length > 0) {
                return false;
            }
        }
        return true;
    }

    isLogged() {
        const logged = Setting.get('isLogged');
        const loggedTime = Setting.get('loggedTime');
        if (
            logged !== false &&
            loggedTime !== false &&
            logged !== undefined &&
            loggedTime !== undefined
        ) {
            let seconds =
                Math.abs(new Date(Number(loggedTime.value)) - Date.now()) / 1000;
            if (seconds < 14400) {
                // 4h
                return true;
            }
            return false;
        }
        return false;
    }

    needSync(callback) {
        NetInfo.fetch().then(state => {
            if (state.isConnected) {
                axios({
                    method: 'get',
                    url: this.getUrlBo() + '/version',
                    responseType: 'json',
                    params: {
                        token: api_token,
                    },
                })
                    .then(response => {
                        const localVersion = Setting.get('version');
                        if (
                            localVersion === undefined ||
                            localVersion === false ||
                            localVersion.value !== response.data.version
                        ) {
                            return callback();
                        }
                        return false;
                    })
                    .catch(function (error) {
                        console.log(error);
                    });
            }
            return false;
        });
        return false;
    }

    setInstalled(remove = false) {
        if (remove) {
            Setting.delete('installed');
        } else {
            Setting.add({ key: 'installed', value: "true" });
        }
    }

    isInstalled() {
        const test = Setting.get('installed');
        if (test === false || test === undefined) {
            return false;
        }
        return true;
    }
}

export default new SyncController();