PHEE-296: Update outboundMessageTable Schema for email service. (#71)

Author: logoutdhaval

src/main/java/org/fineract/messagegateway/sms/domain/OutboundMessages.java

@@ -62,15 +62,21 @@ public class OutboundMessages extends AbstractPersistableCustom<Long> {
 	@Column(name = "mobile_number", nullable = false)
 	private String mobileNumber;
 
-	@Column(name = "message", nullable = false)
+	@Column(name = "message", nullable = true)
 	private String message;
 
+	@Column(name = "email", nullable = true)
+	private String email;
+
 	@Column(name = "sms_bridge_id", nullable = false)
 	private Long bridgeId;
 
 	@Column(name = "response")
 	private String response;
 
+	@Column(name = "type", nullable = false)
+	private String type;
+
 	protected OutboundMessages() {
 
 	}
@@ -201,6 +207,21 @@ public String getResponse() {
 	public void setResponse(String response) {
 		this.response = response;
 	}
+	public String getEmail() {
+		return email;
+	}
+
+	public void setEmail(String email) {
+		this.email = email;
+	}
+	public String getType() {
+		return type;
+	}
+
+	public void setType(String type) {
+		this.type = type;
+	}
+
 
 	@Override
     public String toString() {

src/main/java/org/fineract/messagegateway/sms/providers/Provider.java

@@ -29,7 +29,9 @@ public abstract class Provider {
 
 	public abstract void sendMessage(final SMSBridge smsBridgeConfig, final OutboundMessages message)
 	        throws MessageGatewayException ;
-	
+	public abstract void sendEmail(final SMSBridge smsBridgeConfig, final OutboundMessages message)
+			throws MessageGatewayException ;
+
 	protected String encodeBase64(final SMSBridge smsBridgeConfig) {
 		String tenant = smsBridgeConfig.getTenantId().toString() ;
 		String username = smsBridgeConfig.getConfigValue(MessageGatewayConstants.PROVIDER_ACCOUNT_ID) ;

src/main/java/org/fineract/messagegateway/sms/providers/impl/dummy/DummySMSProvider.java

@@ -46,7 +46,10 @@ public void sendMessage(SMSBridge smsBridgeConfig, OutboundMessages message) thr
 			message.setDeliveredOnDate(new Date());
 		}
 	}
+	@Override
+	public void sendEmail(SMSBridge smsBridgeConfig, OutboundMessages message){
 
+	}
 	@Override
 	public void updateStatusByMessageId(SMSBridge bridge, String externalId, String orchestrator) throws MessageGatewayException {
 

src/main/java/org/fineract/messagegateway/sms/providers/impl/infobip/InfoBipMessageProvider.java

@@ -84,7 +84,10 @@ public void sendMessage(SMSBridge smsBridgeConfig, OutboundMessages message) thr
 		message.setDeliveryStatus(InfoBipStatus.smsStatus(sentMessageInfo.getStatus().getGroupId()).getValue());
 		logger.debug("InfoBipMessageProvider.sendMessage():"+InfoBipStatus.smsStatus(sentMessageInfo.getStatus().getGroupId()).getValue());
 	}
+	@Override
+	public void sendEmail(SMSBridge smsBridgeConfig, OutboundMessages message){
 
+	}
 	@Override
 	public void updateStatusByMessageId(SMSBridge bridge, String externalId, String orchestrator) throws MessageGatewayException {
 

src/main/java/org/fineract/messagegateway/sms/providers/impl/jasmin/JasminSMSProvider.java

@@ -110,6 +110,10 @@ public void sendMessage(SMSBridge smsBridgeConfig, OutboundMessages message) thr
 			throw new MessageGatewayException(e.getMessage());
 		}
 
+	}
+	@Override
+	public void sendEmail(SMSBridge smsBridgeConfig, OutboundMessages message){
+
 	}
 
 	@Override

src/main/java/org/fineract/messagegateway/sms/providers/impl/rapidpro/RapidProSMSProvider.java

@@ -96,7 +96,10 @@ public void sendMessage(SMSBridge smsBridgeConfig, OutboundMessages message)
             throw new MessageGatewayException(e.getMessage());
         }
     }
+    @Override
+    public void sendEmail(SMSBridge smsBridgeConfig, OutboundMessages message){
 
+    }
     @Override
     public void updateStatusByMessageId(SMSBridge bridge, String externalId, String orchestrator) throws MessageGatewayException {
 

src/main/java/org/fineract/messagegateway/sms/providers/impl/safaricom/SafaricomAPIResourse.java

@@ -0,0 +1,10 @@
+package org.fineract.messagegateway.sms.providers.impl.safaricom;
+
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+@RestController
+@RequestMapping("/")
+public class SafaricomAPIResourse {
+
+}

src/main/java/org/fineract/messagegateway/sms/providers/impl/safaricom/SafaricomServiceProvider.java

@@ -0,0 +1,25 @@
+package org.fineract.messagegateway.sms.providers.impl.safaricom;
+
+import org.fineract.messagegateway.exception.MessageGatewayException;
+import org.fineract.messagegateway.sms.domain.OutboundMessages;
+import org.fineract.messagegateway.sms.domain.SMSBridge;
+import org.fineract.messagegateway.sms.providers.Provider;
+
+public class SafaricomServiceProvider extends Provider {
+    @Override
+    public void sendEmail(SMSBridge smsBridgeConfig, OutboundMessages message){
+
+    }
+    @Override
+    public void sendMessage(SMSBridge smsBridgeConfig, OutboundMessages message){
+
+    }
+    @Override
+    public void updateStatusByMessageId(SMSBridge bridge, String externalId,String orchestrator) throws MessageGatewayException{
+
+    }
+    @Override
+    public void publishZeebeVariable(OutboundMessages message){
+
+    }
+}

src/main/java/org/fineract/messagegateway/sms/providers/impl/telerivet/TelerivetMessageProvider.java

@@ -119,7 +119,10 @@ public void sendMessage(SMSBridge smsBridgeConfig, OutboundMessages message) thr
             message.setDeliveryErrorMessage(e.getMessage());
         }
     }
+    @Override
+    public void sendEmail(SMSBridge smsBridgeConfig, OutboundMessages message){
 
+    }
     @Override
     public void updateStatusByMessageId(SMSBridge bridge, String externalId,String orchestrator) throws MessageGatewayException {
         Message msg = null;

src/main/java/org/fineract/messagegateway/sms/providers/impl/twilio/TwilioMessageProvider.java

@@ -88,6 +88,10 @@ public void sendMessage(final SMSBridge smsBridgeConfig, final OutboundMessages
         	message.setDeliveryErrorMessage(e.getMessage());
         }
     }
+    @Override
+    public void sendEmail(final SMSBridge smsBridgeConfig, final OutboundMessages message){
+
+    }
 
     @Override
     public void updateStatusByMessageId(SMSBridge bridge, String externalId, String orchestrator) throws MessageGatewayException {

src/main/resources/db/migration/V8__Updating_Outbound_Message_Schema.sql

@@ -0,0 +1,21 @@
+--
+-- Licensed to the Apache Software Foundation (ASF) under one
+-- or more contributor license agreements. See the NOTICE file
+-- distributed with this work for additional information
+-- regarding copyright ownership. The ASF licenses this file
+-- to you under the Apache License, Version 2.0 (the
+-- "License"); you may not use this file except in compliance
+-- with the License. You may obtain a copy of the License at
+--
+-- http://www.apache.org/licenses/LICENSE-2.0
+--
+-- Unless required by applicable law or agreed to in writing,
+-- software distributed under the License is distributed on an
+-- "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+-- KIND, either express or implied. See the License for the
+-- specific language governing permissions and limitations
+-- under the License.
+--
+ALTER TABLE m_outbound_messages ADD COLUMN email text DEFAULT NULL;
+ALTER TABLE m_outbound_messages ADD COLUMN type varchar(30) NOT NULL;
+ALTER TABLE m_outbound_messages MODIFY COLUMN message VARCHAR(4096) NULL;