package ca.cdr.api.model.json;

/*
 * #%L
 * Smile CDR - CDR
 * %%
 * Copyright (C) 2016 - 2024 Smile CDR, Inc.
 * %%
 * All rights reserved.
 * #L%
 */

import ca.cdr.api.model.enm.TransactionLogBodyTypeEnum;
import ca.cdr.api.model.enm.TransactionLogEventSubTypeEnum;
import ca.cdr.api.model.enm.TransactionLogOutcomeEnum;
import ca.cdr.api.model.enm.TransactionLogStepTypeEnum;
import ca.cdr.api.pub.hl7v2.model.MappingMessage;
import ca.cdr.api.util.MappingMessageUtil;
import ca.cdr.api.validator.enm.RequestValidatingResultEnum;
import com.fasterxml.jackson.annotation.JsonProperty;
import com.fasterxml.jackson.databind.annotation.JsonDeserialize;
import com.fasterxml.jackson.databind.annotation.JsonSerialize;
import io.swagger.v3.oas.annotations.media.Schema;
import jakarta.annotation.Nullable;
import jakarta.servlet.http.HttpServletRequest;

import java.sql.Timestamp;
import java.util.Date;
import java.util.List;

import static java.util.Objects.nonNull;
import static org.apache.commons.lang3.StringUtils.isNotBlank;

public class TransactionLogStepJson implements IModelJson {

        @JsonProperty(value = "body")
        private StringWrapper myBody;

        @JsonProperty(value = "bodyType")
        private TransactionLogBodyTypeEnum myBodyType;

        @JsonProperty(value = "endpointLocalHost")
        private String myEndpointLocalHost;

        @JsonProperty(value = "endpointLocalPort")
        private Integer myEndpointLocalPort;

        @JsonProperty(value = "endpointRemoteHost")
        private String myEndpointRemoteHost;

        @JsonProperty(value = "endpointRemotePort")
        private Integer myEndpointRemotePort;

        @JsonProperty("id")
        private Long myId;

        @JsonProperty("initialTimestamp")
        @JsonSerialize(using = JsonDateSerializer.class)
        @JsonDeserialize(using = JsonDateDeserializer.class)
        private Date myInitialTimestamp;

        @JsonProperty("outcome")
        private TransactionLogOutcomeEnum myOutcome;

        @JsonProperty(value = "processingTime")
        private Long myProcessingTime;

        @JsonProperty("requestUrl")
        private String myRequestUrl;

        @JsonProperty("requestVerb")
        private String myRequestVerb;

        @JsonProperty("subType")
        private TransactionLogEventSubTypeEnum mySubType;

        @JsonProperty("type")
        private TransactionLogStepTypeEnum myType;

        @Schema(description = "The HTTP response status, e.g. 200 or 404")
        @JsonProperty("responseStatus")
        private Short myResponseStatus;

        @JsonProperty("requestValidatingResult")
        private RequestValidatingResultEnum myRequestValidatingResult;

        @JsonProperty("subscriptionId")
        private String mySubscriptionId;

        private Long userId;

        private String userModuleId;

        private String userNodeId;

        private String username;

        private String userFamilyName;

        private String userGivenName;
        private Long myPid;

        private String clientId;

        private String clientNodeId;

        private String clientModuleId;

        private String clientPid;

        private String clientName;

        public Long getUserId() {
                return userId;
        }

        public void setUserId(Long userId) {
                this.userId = userId;
        }

        public String getUserModuleId() {
                return userModuleId;
        }

        public void setUserModuleId(String userModuleId) {
                this.userModuleId = userModuleId;
        }

        public String getUserNodeId() {
                return userNodeId;
        }

        public void setUserNodeId(String userNodeId) {
                this.userNodeId = userNodeId;
        }

        public String getUsername() {
                return username;
        }

        public void setUsername(String username) {
                this.username = username;
        }

        public String getUserFamilyName() {
                return userFamilyName;
        }

        public void setUserFamilyName(String userFamilyName) {
                this.userFamilyName = userFamilyName;
        }

        public String getUserGivenName() {
                return userGivenName;
        }

        public void setUserGivenName(String userGivenName) {
                this.userGivenName = userGivenName;
        }

        public String getBody() {
                return nonNull(this.myBody) ? this.myBody.getStringValue() : null;
        }

        public void setBody(String theBody) {
                this.myBody = nonNull(theBody) ? new StringWrapper(theBody) : null;
        }

        public TransactionLogBodyTypeEnum getBodyType() {
                return myBodyType;
        }

        public void setBodyType(TransactionLogBodyTypeEnum theBodyType) {
                myBodyType = theBodyType;
        }

        public String getEndpointLocalHost() {
                return myEndpointLocalHost;
        }

        public void setEndpointLocalHost(String theEndpointLocalHost) {
                myEndpointLocalHost = theEndpointLocalHost;
        }

        public Integer getEndpointLocalPort() {
                return myEndpointLocalPort;
        }

        public void setEndpointLocalPort(Integer theEndpointLocalPort) {
                myEndpointLocalPort = theEndpointLocalPort;
        }

        public String getEndpointRemoteHost() {
                return myEndpointRemoteHost;
        }

        public void setEndpointRemoteHost(String theEndpointRemoteHost) {
                myEndpointRemoteHost = theEndpointRemoteHost;
        }

        public Integer getEndpointRemotePort() {
                return myEndpointRemotePort;
        }

        public void setEndpointRemotePort(Integer theEndpointRemotePort) {
                myEndpointRemotePort = theEndpointRemotePort;
        }

        public Long getId() {
                return myId;
        }

        public void setId(Long thePid) {
                myId = thePid;
        }

        public Date getInitialTimestamp() {
                return myInitialTimestamp;
        }

        public void setInitialTimestamp(Date theTimestamp) {
                myInitialTimestamp = theTimestamp;
                if (myInitialTimestamp instanceof Timestamp) {
                        myInitialTimestamp = new Date(myInitialTimestamp.getTime());
                }
        }

        public TransactionLogOutcomeEnum getOutcome() {
                return myOutcome;
        }

        public void setOutcome(TransactionLogOutcomeEnum theOutcome) {
                myOutcome = theOutcome;
        }

        public Long getProcessingTime() {
                return myProcessingTime;
        }

        public void setProcessingTime(Long theProcessingTime) {
                myProcessingTime = theProcessingTime;
        }

        public String getRequestUrl() {
                return myRequestUrl;
        }

        public void setRequestUrl(String theRequestUrl) {
                myRequestUrl = theRequestUrl;
        }

        public String getRequestVerb() {
                return myRequestVerb;
        }

        public void setRequestVerb(String theRequestVerb) {
                myRequestVerb = theRequestVerb;
        }

        public TransactionLogEventSubTypeEnum getSubType() {
                return mySubType;
        }

        public void setSubType(TransactionLogEventSubTypeEnum theSubType) {
                mySubType = theSubType;
        }

        public TransactionLogStepTypeEnum getType() {
                return myType;
        }

        public void setType(TransactionLogStepTypeEnum theType) {
                myType = theType;
        }

        public Short getResponseStatus() {
                return myResponseStatus;
        }

        public void setResponseStatus(Short theResponseStatus) {
                myResponseStatus = theResponseStatus;
        }

        public RequestValidatingResultEnum getRequestValidatingResult() {
                return myRequestValidatingResult;
        }

        public void setRequestValidatingResult(RequestValidatingResultEnum theRequestValidatingResult) {
                myRequestValidatingResult = theRequestValidatingResult;
        }

        public String getSubscriptionId() {
                return mySubscriptionId;
        }

        public void setSubscriptionId(String theSubscriptionId) {
                mySubscriptionId = theSubscriptionId;
        }

        public Long getPid() {
                return myPid;
        }

        public void setPid(Long thePid) {
                myPid = thePid;
        }

        public String getClientId() {
                return this.clientId;
        }

        public void setClientId(String theClientId) {
                this.clientId = theClientId;
        }

        public String getClientModuleId() {
                return clientModuleId;
        }

        public void setClientModuleId(String clientModuleId) {
                this.clientModuleId = clientModuleId;
        }

        public String getClientNodeId() {
                return clientNodeId;
        }

        public void setClientNodeId(String clientNodeId) {
                this.clientNodeId = clientNodeId;
        }

        public String getClientPid() {
                return clientPid;
        }

        public void setClientPid(String clientPid) {
                this.clientPid = clientPid;
        }

        public String getClientName() {
                return clientName;
        }

        public void setClientName(String clientName) {
                this.clientName = clientName;
        }

        @Override
        public String toString() {
                String retval = null;
                if (getType() != null) {
                        retval = getType().toString();
                        if (getSubType() != null) {
                                retval += "/" + getSubType();
                        }
                }
                return retval;
        }

        /**
         * Given a set of mapping issues (if any), generate a {@link TransactionLogStepJson}
         * that can be sent to the transaction log service. Will only return
         * an object if any issues are actually present, otherwise returns null.
         *
         * @return Returns null if no issues detected
         */
        @Nullable
        public static TransactionLogStepJson createTransactionLogStepForProcessing(List<MappingMessage> theIssues) {
                boolean haveErrors = MappingMessageUtil.haveErrors(theIssues);

                // Construct a markdown message containing any processing
                // messages
                StringBuilder messageMarkdown = new StringBuilder();
                for (MappingMessage nextIssue : theIssues) {
                        if (messageMarkdown.length() > 0) {
                                messageMarkdown.append("\n");
                        }
                        messageMarkdown.append("* ");
                        messageMarkdown.append("[**").append(nextIssue.getLevel().name()).append("**] ");
                        if (isNotBlank(nextIssue.getPath())) {
                                messageMarkdown.append(" `").append(nextIssue.getPath()).append("` - ");
                        }
                        messageMarkdown.append(nextIssue.getMessage());
                }

                // Add a processing step if there were any messages
                // generated during conversion
                String messageMarkdownString = messageMarkdown.toString();
                TransactionLogStepJson mapStep = null;
                if (messageMarkdownString.length() > 0) {
                        TransactionLogOutcomeEnum outcome = TransactionLogOutcomeEnum.SUCCESS;
                        if (haveErrors) {
                                outcome = TransactionLogOutcomeEnum.FAIL;
                        }

                        mapStep = new TransactionLogStepJson();
                        mapStep.setOutcome(outcome);
                        mapStep.setType(TransactionLogStepTypeEnum.PROCESSING);
                        mapStep.setBody(messageMarkdownString);
                        mapStep.setBodyType(TransactionLogBodyTypeEnum.MESSAGE_MARKDOWN);
                        mapStep.setInitialTimestamp(new Date());
                }
                return mapStep;
        }

        public static class StringWrapper {

                private String myValue;

                public StringWrapper(String theValue) {
                        this.myValue = theValue;
                }

                public String getStringValue() {
                        return myValue;
                }
        }

        public void setRequestUrlFromServletRequest(HttpServletRequest theRequest) {
                StringBuffer requestURL = theRequest.getRequestURL();
                String queryString = theRequest.getQueryString();

                if (queryString == null) {
                        setRequestUrl(requestURL.toString());
                } else {
                        setRequestUrl(requestURL.append('?').append(queryString).toString());
                }
        }

        public void populateRequestAddresses(HttpServletRequest theRequest) {
                setEndpointRemoteHost(theRequest.getRemoteAddr());
                setEndpointRemotePort(theRequest.getRemotePort());
                setEndpointLocalHost(theRequest.getLocalAddr());
                setEndpointLocalPort(theRequest.getLocalPort());
        }
}