class AWSService {
    static sfSessionId = '';
    static insertModule = 'Insert AWS ';
    static updateModule = 'Update AWS ';
    static queryModule = 'Query AWS ';
    static searchModule = 'Search AWS ';
    static confirmTrans = 'Confirm Transaction To AWS';
    static successStatus = 'success';
    static failStatus = 'fail';
    static insertCalloutLog(module,url,request,response,status){
        if(this.sfSessionId){
            sforce.connection.sessionId = this.sfSessionId;
            let transLog = new sforce.SObject('Transaction_Log__c');
            transLog.AWS_Data_Id__c = '';
            transLog.Module__c = module;
            transLog.Interface_URL__c = url;
            transLog.Request__c = request;
            transLog.Response__c = response;
            transLog.Status__c = status;
            let insertLogResult = sforce.connection.create([transLog]);     
            if(insertLogResult[0].getBoolean(this.successStatus)) {
                console.log('Insert Log Id: ' + insertLogResult[0].id);
                return insertLogResult[0].id;
            }else {
                console.log('Faield to insert log');
                return '';
            }
        }       
    }
    //Search Contact
    static search(searchUrl,requestSearchPayload,searchBack,token) {
        fetch(searchUrl, {
            method: 'POST',
            body: requestSearchPayload,
            headers: {
                'Content-Type': 'application/json',
                'pi-token': token
            }
        }).then((data) => {
            return data.json();
        }).then((result) => {
            this.insertCalloutLog(this.searchModule,searchUrl,JSON.stringify(requestSearchPayload),JSON.stringify(result),this.successStatus);
            searchBack(result);      
        }).catch(error => {
            this.insertCalloutLog(this.searchModule,searchUrl,JSON.stringify(requestSearchPayload),JSON.stringify(error),this.failStatus);
            console.log(error);
        });
    }

    //query
    static query(queryURL, awsDataId, queryback, token) {
        fetch(queryURL + '?dataId=' + awsDataId, {
            method: 'GET',
            headers: {
                'Content-Type': 'application/json',
                'pi-token': token
            }
        }).then((data) => {         
            return data.json();
        }).then((data) => {
            this.insertCalloutLog(this.queryModule,queryURL,queryURL + '?dataId=' + awsDataId,JSON.stringify(data),this.successStatus);
            queryback(data);
        }).catch(error => {
            this.insertCalloutLog(this.queryModule,queryURL,queryURL + '?dataId=' + awsDataId,JSON.stringify(error),this.failStatus);
            console.log(error);
        });
    }

    //queryTSRepair
    static queryTSRepair(queryURL, awsDataId, queryback, token,number) {
        fetch(queryURL + '?dataId=' + awsDataId, {
            method: 'GET',
            headers: {
                'Content-Type': 'application/json',
                'pi-token': token
            }
        }).then((data) => {         
            return data.json();
        }).then((data) => {
            this.insertCalloutLog(this.queryModule,queryURL,queryURL + '?dataId=' + awsDataId,JSON.stringify(data),this.successStatus);
            queryback(data,number);
        }).catch(error => {
            this.insertCalloutLog(this.queryModule,queryURL,queryURL + '?dataId=' + awsDataId,JSON.stringify(error),this.failStatus);
            console.log(error);
        });
    }

    //insert
    static insert(newURL, payloadJson, payloadForNewPI, controllerSaveMethod, token, transactionURL,isNewMode,insertOrUpdateBack,redirectCallBack) {
        console.log('Process New PI Data');
        console.log(JSON.stringify(payloadForNewPI));
        fetch(newURL, {
            method: 'POST',
            body: payloadForNewPI,
            headers: {
                'Content-Type': 'application/json',
                'pi-token': token
            }
        }).then((data) => {
            console.log('data=' + JSON.stringify(data));
            return data.json();
        }).then((result) => {
            this.insertCalloutLog(this.insertModule,newURL,JSON.stringify(payloadForNewPI),JSON.stringify(result),this.successStatus);
            AWSService.back(result, payloadJson, transactionURL, token, controllerSaveMethod,isNewMode,insertOrUpdateBack,redirectCallBack);
        }).catch(error => {
            this.insertCalloutLog(this.insertModule,newURL,JSON.stringify(payloadForNewPI),JSON.stringify(error),this.failStatus);
            console.log(error);
        });
    }

    //update
    static update(updateURL, payloadJson, payloadForNewPI, controllerSaveMethod, token, transactionURL,isNewMode,insertOrUpdateBack,redirectCallBack) {
        console.log('Process New PI Data');
        console.log(JSON.stringify(payloadForNewPI));
        fetch(updateURL, {
            method: 'POST',
            body: payloadForNewPI,
            headers: {
                'Content-Type': 'application/json',
                'pi-token': token
            }
        }).then((data) => {
            console.log('data=' + JSON.stringify(data));
            return data.json();
        }).then((result) => {
            this.insertCalloutLog(this.updateModule,updateURL,JSON.stringify(payloadForNewPI),JSON.stringify(result),this.successStatus);
            AWSService.back(result, payloadJson, transactionURL, token, controllerSaveMethod,isNewMode,insertOrUpdateBack,redirectCallBack);
        }).catch(error => {
            this.insertCalloutLog(this.updateModule,updateURL,JSON.stringify(payloadForNewPI),JSON.stringify(error),this.failStatus);
            console.log(error);
        });
    }

    //update
    static post(postURL, payloadForNewPI, callback, token) {
        console.log('Process New PI Data');
        console.log(JSON.stringify(payloadForNewPI));
        fetch(postURL, {
            method: 'POST',
            body: payloadForNewPI,
            headers: {
                'Content-Type': 'application/json',
                'pi-token': token
            }
        }).then((data) => {
            console.log('data=' + JSON.stringify(data));
            return data.json();
        }).then((result) => {
            this.insertCalloutLog(this.insertModule,postURL,JSON.stringify(payloadForNewPI),JSON.stringify(result),this.successStatus);
            callback(result);
        }).catch(error => {
            this.insertCalloutLog(this.insertModule,postURL,JSON.stringify(payloadForNewPI),JSON.stringify(error),this.failStatus);
            console.log(error);
        });
    }

    static sfdcBack = function sfdcBack(event, result, transId, token, transactionURL,redirectCallBack) {
        let sfId = '';
        if (event.status) {
            console.log('sf Id from SF Backend:' + JSON.stringify(result));
            if (result.status == 'success') {
                sfId = result.recordId;
                let transParameters = {
                    txId: transId,
                    sfRecordId:sfId,
                    isSuccess: 1
                };
                console.log(transParameters);
                fetch(transactionURL, {
                    method: 'POST',
                    body: JSON.stringify(transParameters),
                    headers: {
                        'Content-Type': 'application/json',
                        'pi-token': token
                    }
                }).then((result) => {
                    this.insertCalloutLog(this.confirmTrans,transactionURL,JSON.stringify(transParameters),JSON.stringify(result),this.successStatus);
                    redirectCallBack(sfId,'');
                }).catch(error => {
                    this.insertCalloutLog(this.confirmTrans,transactionURL,JSON.stringify(transParameters),JSON.stringify(error),this.failStatus);
                    console.log(error);
                });
            } else {
                let errorMsg = result.message;
                let transParameters = {
                    txId: transId,
                    sfRecordId:sfId,
                    isSuccess: 0
                };
                console.log(transParameters);
                fetch(transactionURL, {
                    method: 'POST',
                    body: JSON.stringify(transParameters),
                    headers: {
                        'Content-Type': 'application/json',
                        'pi-token': token
                    }
                }).then((result) => {
                    this.insertCalloutLog(this.confirmTrans,transactionURL,JSON.stringify(transParameters),JSON.stringify(result),this.successStatus);
                    redirectCallBack('',errorMsg);
                }).catch(error => {
                    this.insertCalloutLog(this.confirmTrans,transactionURL,JSON.stringify(transParameters),JSON.stringify(error),this.failStatus);
                    console.log(error);
                });
            }
        }
    }

    // AWSService.back(result, payloadJson, transactionURL, token, controllerSaveMethod);
    static back = function back(result, payloadJson, transactionURL, token, controllerSaveMethod,isNewMode,insertOrUpdateBack,redirectCallBack) {
        let payloadJsonStr = JSON.stringify(insertOrUpdateBack(payloadJson, result,isNewMode));
        let transId = result.txId + '';
        Visualforce.remoting.Manager.invokeAction(
            controllerSaveMethod, // example '{!$RemoteAction.NewAndEditLeadController.saveLead}'
            payloadJsonStr, transId, isNewMode,
            function (result, event) {
                AWSService.sfdcBack(event, result, transId, token, transactionURL,redirectCallBack);
            },
            { escape: true }
        );
    }
};