committed by
GitHub
17 changed files with 1104 additions and 9 deletions
@ -0,0 +1,186 @@ |
|||
/** |
|||
* Copyright © 2016-2022 The Thingsboard Authors |
|||
* |
|||
* Licensed 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. |
|||
*/ |
|||
package org.thingsboard.server.service.sms.smpp; |
|||
|
|||
import lombok.extern.slf4j.Slf4j; |
|||
import org.apache.commons.lang3.StringUtils; |
|||
import org.apache.commons.lang3.exception.ExceptionUtils; |
|||
import org.smpp.Connection; |
|||
import org.smpp.Data; |
|||
import org.smpp.Session; |
|||
import org.smpp.TCPIPConnection; |
|||
import org.smpp.TimeoutException; |
|||
import org.smpp.WrongSessionStateException; |
|||
import org.smpp.pdu.Address; |
|||
import org.smpp.pdu.BindReceiver; |
|||
import org.smpp.pdu.BindRequest; |
|||
import org.smpp.pdu.BindResponse; |
|||
import org.smpp.pdu.BindTransciever; |
|||
import org.smpp.pdu.BindTransmitter; |
|||
import org.smpp.pdu.PDUException; |
|||
import org.smpp.pdu.SubmitSM; |
|||
import org.smpp.pdu.SubmitSMResp; |
|||
import org.thingsboard.rule.engine.api.sms.exception.SmsException; |
|||
import org.thingsboard.server.common.data.sms.config.SmppSmsProviderConfiguration; |
|||
import org.thingsboard.server.service.sms.AbstractSmsSender; |
|||
|
|||
import java.io.IOException; |
|||
import java.util.Optional; |
|||
|
|||
@Slf4j |
|||
public class SmppSmsSender extends AbstractSmsSender { |
|||
protected SmppSmsProviderConfiguration config; |
|||
|
|||
protected Session smppSession; |
|||
|
|||
public SmppSmsSender(SmppSmsProviderConfiguration config) { |
|||
if (config.getBindType() == null) { |
|||
config.setBindType(SmppSmsProviderConfiguration.SmppBindType.TX); |
|||
} |
|||
if (StringUtils.isNotEmpty(config.getSourceAddress())) { |
|||
if (config.getSourceTon() == null) { |
|||
config.setSourceTon((byte) 5); |
|||
} |
|||
if (config.getSourceNpi() == null) { |
|||
config.setSourceNpi((byte) 0); |
|||
} |
|||
} |
|||
if (config.getDestinationTon() == null) { |
|||
config.setDestinationTon((byte) 5); |
|||
} |
|||
if (config.getDestinationNpi() == null) { |
|||
config.setDestinationNpi((byte) 0); |
|||
} |
|||
|
|||
this.config = config; |
|||
this.smppSession = initSmppSession(); |
|||
} |
|||
|
|||
private SmppSmsSender() {} // for testing purposes
|
|||
|
|||
|
|||
@Override |
|||
public int sendSms(String numberTo, String message) throws SmsException { |
|||
try { |
|||
checkSmppSession(); |
|||
|
|||
SubmitSM request = new SubmitSM(); |
|||
if (StringUtils.isNotEmpty(config.getServiceType())) { |
|||
request.setServiceType(config.getServiceType()); |
|||
} |
|||
if (StringUtils.isNotEmpty(config.getSourceAddress())) { |
|||
request.setSourceAddr(new Address(config.getSourceTon(), config.getSourceNpi(), config.getSourceAddress())); |
|||
} |
|||
request.setDestAddr(new Address(config.getDestinationTon(), config.getDestinationNpi(), prepareNumber(numberTo))); |
|||
request.setShortMessage(message); |
|||
request.setDataCoding(Optional.ofNullable(config.getCodingScheme()).orElse((byte) 0)); |
|||
request.setReplaceIfPresentFlag((byte) 0); |
|||
request.setEsmClass((byte) 0); |
|||
request.setProtocolId((byte) 0); |
|||
request.setPriorityFlag((byte) 0); |
|||
request.setRegisteredDelivery((byte) 0); |
|||
request.setSmDefaultMsgId((byte) 0); |
|||
|
|||
SubmitSMResp response = smppSession.submit(request); |
|||
|
|||
log.debug("SMPP submit command status: {}", response.getCommandStatus()); |
|||
} catch (Exception e) { |
|||
throw new RuntimeException(e); |
|||
} |
|||
|
|||
return countMessageSegments(message); |
|||
} |
|||
|
|||
private synchronized void checkSmppSession() { |
|||
if (smppSession == null || !smppSession.isOpened()) { |
|||
smppSession = initSmppSession(); |
|||
} |
|||
} |
|||
|
|||
protected Session initSmppSession() { |
|||
try { |
|||
Connection connection = new TCPIPConnection(config.getHost(), config.getPort()); |
|||
Session session = new Session(connection); |
|||
|
|||
BindRequest bindRequest; |
|||
switch (config.getBindType()) { |
|||
case TX: |
|||
bindRequest = new BindTransmitter(); |
|||
break; |
|||
case RX: |
|||
bindRequest = new BindReceiver(); |
|||
break; |
|||
case TRX: |
|||
bindRequest = new BindTransciever(); |
|||
break; |
|||
default: |
|||
throw new UnsupportedOperationException("Unsupported bind type " + config.getBindType()); |
|||
} |
|||
|
|||
bindRequest.setSystemId(config.getSystemId()); |
|||
bindRequest.setPassword(config.getPassword()); |
|||
|
|||
byte interfaceVersion; |
|||
switch (config.getProtocolVersion()) { |
|||
case "3.3": |
|||
interfaceVersion = Data.SMPP_V33; |
|||
break; |
|||
case "3.4": |
|||
interfaceVersion = Data.SMPP_V34; |
|||
break; |
|||
default: |
|||
throw new UnsupportedOperationException("Unsupported SMPP version: " + config.getProtocolVersion()); |
|||
} |
|||
bindRequest.setInterfaceVersion(interfaceVersion); |
|||
|
|||
if (StringUtils.isNotEmpty(config.getSystemType())) { |
|||
bindRequest.setSystemType(config.getSystemType()); |
|||
} |
|||
if (StringUtils.isNotEmpty(config.getAddressRange())) { |
|||
bindRequest.setAddressRange(config.getDestinationTon(), config.getDestinationNpi(), config.getAddressRange()); |
|||
} |
|||
|
|||
BindResponse bindResponse = session.bind(bindRequest); |
|||
log.debug("SMPP bind response: {}", bindResponse.debugString()); |
|||
|
|||
if (bindResponse.getCommandStatus() != 0) { |
|||
throw new IllegalStateException("Error status when binding: " + bindResponse.getCommandStatus()); |
|||
} |
|||
|
|||
return session; |
|||
} catch (Exception e) { |
|||
throw new IllegalArgumentException("Failed to establish SMPP session: " + ExceptionUtils.getRootCauseMessage(e), e); |
|||
} |
|||
} |
|||
|
|||
private String prepareNumber(String number) { |
|||
if (config.getDestinationTon() == Data.GSM_TON_INTERNATIONAL) { |
|||
return StringUtils.removeStart(number, "+"); |
|||
} |
|||
return number; |
|||
} |
|||
|
|||
@Override |
|||
public void destroy() { |
|||
try { |
|||
smppSession.unbind(); |
|||
smppSession.close(); |
|||
} catch (TimeoutException | PDUException | IOException | WrongSessionStateException e) { |
|||
throw new RuntimeException(e); |
|||
} |
|||
|
|||
} |
|||
} |
|||
@ -0,0 +1,121 @@ |
|||
/** |
|||
* Copyright © 2016-2022 The Thingsboard Authors |
|||
* |
|||
* Licensed 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. |
|||
*/ |
|||
package org.thingsboard.server.service.sms.smpp; |
|||
|
|||
import org.apache.commons.lang3.StringUtils; |
|||
import org.assertj.core.api.Assertions; |
|||
import org.junit.Before; |
|||
import org.junit.Ignore; |
|||
import org.junit.Test; |
|||
import org.junit.runner.RunWith; |
|||
import org.mockito.junit.MockitoJUnitRunner; |
|||
import org.smpp.Session; |
|||
import org.smpp.pdu.SubmitSMResp; |
|||
import org.thingsboard.server.common.data.sms.config.SmppSmsProviderConfiguration; |
|||
|
|||
import java.lang.reflect.Constructor; |
|||
import java.net.UnknownHostException; |
|||
|
|||
import static org.assertj.core.api.Assertions.assertThatThrownBy; |
|||
import static org.junit.Assert.fail; |
|||
import static org.mockito.ArgumentMatchers.any; |
|||
import static org.mockito.ArgumentMatchers.argThat; |
|||
import static org.mockito.Mockito.mock; |
|||
import static org.mockito.Mockito.never; |
|||
import static org.mockito.Mockito.spy; |
|||
import static org.mockito.Mockito.times; |
|||
import static org.mockito.Mockito.verify; |
|||
import static org.mockito.Mockito.when; |
|||
|
|||
@RunWith(MockitoJUnitRunner.class) |
|||
public class SmppSmsSenderTest { |
|||
|
|||
SmppSmsSender smppSmsSender; |
|||
SmppSmsProviderConfiguration smppConfig; |
|||
Session smppSession; |
|||
|
|||
@Before |
|||
public void beforeEach() throws Exception { |
|||
Constructor<SmppSmsSender> constructor = SmppSmsSender.class.getDeclaredConstructor(); |
|||
constructor.setAccessible(true); |
|||
smppSmsSender = spy(constructor.newInstance()); |
|||
|
|||
smppSession = mock(Session.class); |
|||
smppSmsSender.smppSession = smppSession; |
|||
|
|||
smppConfig = new SmppSmsProviderConfiguration(); |
|||
smppSmsSender.config = smppConfig; |
|||
} |
|||
|
|||
@Test |
|||
public void testSendSms() throws Exception { |
|||
when(smppSession.isOpened()).thenReturn(true); |
|||
when(smppSession.submit(any())).thenReturn(new SubmitSMResp()); |
|||
setDefaultSmppConfig(); |
|||
|
|||
String number = "123545"; |
|||
String message = "message"; |
|||
smppSmsSender.sendSms(number, message); |
|||
|
|||
verify(smppSmsSender, never()).initSmppSession(); |
|||
verify(smppSession).submit(argThat(submitRequest -> { |
|||
try { |
|||
return submitRequest.getShortMessage().equals(message) && |
|||
submitRequest.getDestAddr().getAddress().equals(number) && |
|||
submitRequest.getServiceType().equals(smppConfig.getServiceType()) && |
|||
(StringUtils.isEmpty(smppConfig.getSourceAddress()) ? submitRequest.getSourceAddr().getAddress().equals("") |
|||
: submitRequest.getSourceAddr().getAddress().equals(smppConfig.getSourceAddress()) && |
|||
submitRequest.getSourceAddr().getTon() == smppConfig.getSourceTon() && |
|||
submitRequest.getSourceAddr().getNpi() == smppConfig.getSourceNpi()) && |
|||
submitRequest.getDestAddr().getTon() == smppConfig.getDestinationTon() && |
|||
submitRequest.getDestAddr().getNpi() == smppConfig.getDestinationNpi() && |
|||
submitRequest.getDataCoding() == smppConfig.getCodingScheme() && |
|||
submitRequest.getReplaceIfPresentFlag() == 0 && |
|||
submitRequest.getEsmClass() == 0 && |
|||
submitRequest.getProtocolId() == 0 && |
|||
submitRequest.getPriorityFlag() == 0 && |
|||
submitRequest.getRegisteredDelivery() == 0 && |
|||
submitRequest.getSmDefaultMsgId() == 0; |
|||
} catch (Exception e) { |
|||
fail(e.getMessage()); |
|||
return false; |
|||
} |
|||
})); |
|||
} |
|||
|
|||
private void setDefaultSmppConfig() { |
|||
smppConfig.setProtocolVersion("3.3"); |
|||
smppConfig.setHost("smpphost"); |
|||
smppConfig.setPort(5687); |
|||
smppConfig.setSystemId("213131"); |
|||
smppConfig.setPassword("35125q"); |
|||
|
|||
smppConfig.setSystemType(""); |
|||
smppConfig.setBindType(SmppSmsProviderConfiguration.SmppBindType.TX); |
|||
smppConfig.setServiceType(""); |
|||
|
|||
smppConfig.setSourceAddress(""); |
|||
smppConfig.setSourceTon((byte) 5); |
|||
smppConfig.setSourceNpi((byte) 0); |
|||
|
|||
smppConfig.setDestinationTon((byte) 5); |
|||
smppConfig.setDestinationNpi((byte) 0); |
|||
|
|||
smppConfig.setAddressRange(""); |
|||
smppConfig.setCodingScheme((byte) 0); |
|||
} |
|||
|
|||
} |
|||
@ -0,0 +1 @@ |
|||
mock-maker-inline |
|||
@ -0,0 +1,117 @@ |
|||
/** |
|||
* Copyright © 2016-2022 The Thingsboard Authors |
|||
* |
|||
* Licensed 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. |
|||
*/ |
|||
package org.thingsboard.server.common.data.sms.config; |
|||
|
|||
import io.swagger.annotations.ApiModelProperty; |
|||
import lombok.Data; |
|||
|
|||
@Data |
|||
public class SmppSmsProviderConfiguration implements SmsProviderConfiguration { |
|||
@ApiModelProperty(value = "SMPP version", allowableValues = "3.3, 3.4", required = true) |
|||
private String protocolVersion; |
|||
|
|||
@ApiModelProperty(value = "SMPP host", required = true) |
|||
private String host; |
|||
@ApiModelProperty(value = "SMPP port", required = true) |
|||
private Integer port; |
|||
|
|||
@ApiModelProperty(value = "System ID", required = true) |
|||
private String systemId; |
|||
@ApiModelProperty(value = "Password", required = true) |
|||
private String password; |
|||
|
|||
@ApiModelProperty(value = "System type", required = false) |
|||
private String systemType; |
|||
@ApiModelProperty(value = "TX - Transmitter, RX - Receiver, TRX - Transciever. By default TX is used", required = false) |
|||
private SmppBindType bindType; |
|||
@ApiModelProperty(value = "Service type", required = false) |
|||
private String serviceType; |
|||
|
|||
@ApiModelProperty(value = "Source address", required = false) |
|||
private String sourceAddress; |
|||
@ApiModelProperty(value = "Source TON (Type of Number). Needed is source address is set. 5 by default.\n" + |
|||
"0 - Unknown\n" + |
|||
"1 - International\n" + |
|||
"2 - National\n" + |
|||
"3 - Network Specific\n" + |
|||
"4 - Subscriber Number\n" + |
|||
"5 - Alphanumeric\n" + |
|||
"6 - Abbreviated", required = false) |
|||
private Byte sourceTon; |
|||
@ApiModelProperty(value = "Source NPI (Numbering Plan Identification). Needed is source address is set. 0 by default.\n" + |
|||
"0 - Unknown\n" + |
|||
"1 - ISDN/telephone numbering plan (E163/E164)\n" + |
|||
"3 - Data numbering plan (X.121)\n" + |
|||
"4 - Telex numbering plan (F.69)\n" + |
|||
"6 - Land Mobile (E.212) =6\n" + |
|||
"8 - National numbering plan\n" + |
|||
"9 - Private numbering plan\n" + |
|||
"10 - ERMES numbering plan (ETSI DE/PS 3 01-3)\n" + |
|||
"13 - Internet (IP)\n" + |
|||
"18 - WAP Client Id (to be defined by WAP Forum)", required = false) |
|||
private Byte sourceNpi; |
|||
|
|||
@ApiModelProperty(value = "Destination TON (Type of Number). 5 by default.\n" + |
|||
"0 - Unknown\n" + |
|||
"1 - International\n" + |
|||
"2 - National\n" + |
|||
"3 - Network Specific\n" + |
|||
"4 - Subscriber Number\n" + |
|||
"5 - Alphanumeric\n" + |
|||
"6 - Abbreviated", required = false) |
|||
private Byte destinationTon; |
|||
@ApiModelProperty(value = "Destination NPI (Numbering Plan Identification). 0 by default.\n" + |
|||
"0 - Unknown\n" + |
|||
"1 - ISDN/telephone numbering plan (E163/E164)\n" + |
|||
"3 - Data numbering plan (X.121)\n" + |
|||
"4 - Telex numbering plan (F.69)\n" + |
|||
"6 - Land Mobile (E.212) =6\n" + |
|||
"8 - National numbering plan\n" + |
|||
"9 - Private numbering plan\n" + |
|||
"10 - ERMES numbering plan (ETSI DE/PS 3 01-3)\n" + |
|||
"13 - Internet (IP)\n" + |
|||
"18 - WAP Client Id (to be defined by WAP Forum)", required = false) |
|||
private Byte destinationNpi; |
|||
|
|||
@ApiModelProperty(value = "Address range", required = false) |
|||
private String addressRange; |
|||
|
|||
@ApiModelProperty(allowableValues = "0-10,13-14", |
|||
value = "0 - SMSC Default Alphabet (ASCII for short and long code and to GSM for toll-free, used as default)\n" + |
|||
"1 - IA5 (ASCII for short and long code, Latin 9 for toll-free (ISO-8859-9))\n" + |
|||
"2 - Octet Unspecified (8-bit binary)\n" + |
|||
"3 - Latin 1 (ISO-8859-1)\n" + |
|||
"4 - Octet Unspecified (8-bit binary)\n" + |
|||
"5 - JIS (X 0208-1990)\n" + |
|||
"6 - Cyrillic (ISO-8859-5)\n" + |
|||
"7 - Latin/Hebrew (ISO-8859-8)\n" + |
|||
"8 - UCS2/UTF-16 (ISO/IEC-10646)\n" + |
|||
"9 - Pictogram Encoding\n" + |
|||
"10 - Music Codes (ISO-2022-JP)\n" + |
|||
"13 - Extended Kanji JIS (X 0212-1990)\n" + |
|||
"14 - Korean Graphic Character Set (KS C 5601/KS X 1001)", required = false) |
|||
private Byte codingScheme; |
|||
|
|||
@Override |
|||
public SmsProviderType getType() { |
|||
return SmsProviderType.SMPP; |
|||
} |
|||
|
|||
public enum SmppBindType { |
|||
TX, RX, TRX |
|||
} |
|||
|
|||
} |
|||
@ -0,0 +1,162 @@ |
|||
<!-- |
|||
|
|||
Copyright © 2016-2022 The Thingsboard Authors |
|||
|
|||
Licensed 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. |
|||
|
|||
--> |
|||
<form [formGroup]="smppSmsProviderConfigurationFormGroup" style="padding-bottom: 16px;"> |
|||
<div fxLayout="row wrap" fxLayoutGap="6px"> |
|||
<mat-form-field fxFlex.lt-sm="100" fxFlex.gt-sm="15" class="mat-block"> |
|||
<mat-label translate>admin.smpp-provider.smpp-version</mat-label> |
|||
<mat-select formControlName="protocolVersion"> |
|||
<mat-option *ngFor="let smppVersion of smppVersions" [value]="smppVersion.value"> |
|||
{{smppVersion.value}} |
|||
</mat-option> |
|||
</mat-select> |
|||
</mat-form-field> |
|||
<mat-form-field fxFlex class="mat-block"> |
|||
<mat-label translate>admin.smpp-provider.smpp-host</mat-label> |
|||
<input required matInput formControlName="host"> |
|||
<mat-error *ngIf="smppSmsProviderConfigurationFormGroup.get('host').hasError('required')"> |
|||
{{'admin.smpp-provider.smpp-host-required' | translate}} |
|||
</mat-error> |
|||
</mat-form-field> |
|||
<mat-form-field fxFlex.lt-sm="100" fxFlex.gt-sm="30" class="mat-block"> |
|||
<mat-label translate>admin.smpp-provider.smpp-port</mat-label> |
|||
<input required matInput type="number" formControlName="port"> |
|||
<mat-error *ngIf="smppSmsProviderConfigurationFormGroup.get('port').hasError('required')"> |
|||
{{'admin.smpp-provider.smpp-port-required' | translate}} |
|||
</mat-error> |
|||
</mat-form-field> |
|||
</div> |
|||
<div fxLayout="row wrap" fxLayoutGap="6px"> |
|||
<mat-form-field fxFlex class="mat-block"> |
|||
<mat-label translate>admin.smpp-provider.system-id</mat-label> |
|||
<input required matInput formControlName="systemId"> |
|||
<mat-error *ngIf="smppSmsProviderConfigurationFormGroup.get('systemId').hasError('required')"> |
|||
{{'admin.smpp-provider.system-id-required' | translate}} |
|||
</mat-error> |
|||
</mat-form-field> |
|||
<mat-form-field fxFlex class="mat-block"> |
|||
<mat-label translate>admin.smpp-provider.password</mat-label> |
|||
<input required matInput type="password" autocomplete="new-password" formControlName="password"> |
|||
<tb-toggle-password matSuffix></tb-toggle-password> |
|||
<mat-error *ngIf="smppSmsProviderConfigurationFormGroup.get('password').hasError('required')"> |
|||
{{'admin.smpp-provider.password-required' | translate}} |
|||
</mat-error> |
|||
</mat-form-field> |
|||
</div> |
|||
<mat-accordion multi> |
|||
<mat-expansion-panel> |
|||
<mat-expansion-panel-header> |
|||
<mat-panel-title translate> |
|||
admin.smpp-provider.type-settings |
|||
</mat-panel-title> |
|||
</mat-expansion-panel-header> |
|||
<ng-template matExpansionPanelContent> |
|||
<mat-form-field class="mat-block"> |
|||
<mat-label translate>admin.smpp-provider.system-type</mat-label> |
|||
<input matInput formControlName="systemType"> |
|||
</mat-form-field> |
|||
<mat-form-field class="mat-block"> |
|||
<mat-label translate>admin.smpp-provider.bind-type</mat-label> |
|||
<mat-select formControlName="bindType"> |
|||
<mat-option *ngFor="let bindType of bindTypes" [value]="bindType"> |
|||
{{bindTypesTranslation.get(bindType) | translate}} |
|||
</mat-option> |
|||
</mat-select> |
|||
</mat-form-field> |
|||
<mat-form-field class="mat-block"> |
|||
<mat-label translate>admin.smpp-provider.service-type</mat-label> |
|||
<input matInput formControlName="serviceType"> |
|||
</mat-form-field> |
|||
</ng-template> |
|||
</mat-expansion-panel> |
|||
<mat-expansion-panel> |
|||
<mat-expansion-panel-header> |
|||
<mat-panel-title translate> |
|||
admin.smpp-provider.source-settings |
|||
</mat-panel-title> |
|||
</mat-expansion-panel-header> |
|||
<ng-template matExpansionPanelContent> |
|||
<mat-form-field class="mat-block"> |
|||
<mat-label translate>admin.smpp-provider.source-address</mat-label> |
|||
<input matInput formControlName="sourceAddress"> |
|||
</mat-form-field> |
|||
<mat-form-field class="mat-block"> |
|||
<mat-label translate>admin.smpp-provider.source-ton</mat-label> |
|||
<mat-select formControlName="sourceTon"> |
|||
<mat-option *ngFor="let sourceTon of typeOfNumber" [value]="typeOfNumberMap.get(sourceTon).value"> |
|||
{{typeOfNumberMap.get(sourceTon).name | translate}} |
|||
</mat-option> |
|||
</mat-select> |
|||
</mat-form-field> |
|||
<mat-form-field class="mat-block"> |
|||
<mat-label translate>admin.smpp-provider.source-npi</mat-label> |
|||
<mat-select formControlName="sourceNpi"> |
|||
<mat-option *ngFor="let sourceNpi of numberingPlanIdentification" [value]="numberingPlanIdentificationMap.get(sourceNpi).value"> |
|||
{{numberingPlanIdentificationMap.get(sourceNpi).name | translate}} |
|||
</mat-option> |
|||
</mat-select> |
|||
</mat-form-field> |
|||
</ng-template> |
|||
</mat-expansion-panel> |
|||
<mat-expansion-panel> |
|||
<mat-expansion-panel-header> |
|||
<mat-panel-title translate> |
|||
admin.smpp-provider.destination-settings |
|||
</mat-panel-title> |
|||
</mat-expansion-panel-header> |
|||
<ng-template matExpansionPanelContent> |
|||
<mat-form-field class="mat-block"> |
|||
<mat-label translate>admin.smpp-provider.destination-ton</mat-label> |
|||
<mat-select formControlName="destinationTon"> |
|||
<mat-option *ngFor="let destinationTon of typeOfNumber" [value]="typeOfNumberMap.get(destinationTon).value"> |
|||
{{typeOfNumberMap.get(destinationTon).name | translate}} |
|||
</mat-option> |
|||
</mat-select> |
|||
</mat-form-field> |
|||
<mat-form-field class="mat-block"> |
|||
<mat-label translate>admin.smpp-provider.destination-npi</mat-label> |
|||
<mat-select formControlName="destinationNpi"> |
|||
<mat-option *ngFor="let destinationNpi of numberingPlanIdentification" [value]="numberingPlanIdentificationMap.get(destinationNpi).value"> |
|||
{{numberingPlanIdentificationMap.get(destinationNpi).name | translate}} |
|||
</mat-option> |
|||
</mat-select> |
|||
</mat-form-field> |
|||
</ng-template> |
|||
</mat-expansion-panel> |
|||
<mat-expansion-panel> |
|||
<mat-expansion-panel-header> |
|||
<mat-panel-title translate> |
|||
admin.smpp-provider.additional-settings |
|||
</mat-panel-title> |
|||
</mat-expansion-panel-header> |
|||
<ng-template matExpansionPanelContent> |
|||
<mat-form-field class="mat-block"> |
|||
<mat-label translate>admin.smpp-provider.address-range</mat-label> |
|||
<input matInput formControlName="addressRange"> |
|||
</mat-form-field> |
|||
<mat-form-field class="mat-block"> |
|||
<mat-label translate>admin.smpp-provider.coding-scheme</mat-label> |
|||
<mat-select formControlName="codingScheme"> |
|||
<mat-option *ngFor="let codingScheme of codingSchemes" [value]="codingSchemesMap.get(codingScheme).value"> |
|||
{{codingSchemesMap.get(codingScheme).name | translate}} |
|||
</mat-option> |
|||
</mat-select> |
|||
</mat-form-field> |
|||
</ng-template> |
|||
</mat-expansion-panel> |
|||
</mat-accordion> |
|||
</form> |
|||
@ -0,0 +1,137 @@ |
|||
///
|
|||
/// Copyright © 2016-2022 The Thingsboard Authors
|
|||
///
|
|||
/// Licensed 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.
|
|||
///
|
|||
|
|||
import { Component, forwardRef, Input, OnInit } from '@angular/core'; |
|||
import { ControlValueAccessor, FormBuilder, FormGroup, NG_VALUE_ACCESSOR, Validators } from '@angular/forms'; |
|||
import { |
|||
AwsSnsSmsProviderConfiguration, |
|||
BindTypes, |
|||
bindTypesTranslationMap, |
|||
CodingSchemes, |
|||
codingSchemesMap, |
|||
NumberingPlanIdentification, |
|||
numberingPlanIdentificationMap, |
|||
SmppSmsProviderConfiguration, |
|||
smppVersions, |
|||
SmsProviderConfiguration, |
|||
SmsProviderType, |
|||
TypeOfNumber, |
|||
typeOfNumberMap |
|||
} from '@shared/models/settings.models'; |
|||
import { isDefinedAndNotNull } from '@core/utils'; |
|||
import { coerceBooleanProperty } from '@angular/cdk/coercion'; |
|||
|
|||
@Component({ |
|||
selector: 'tb-smpp-sms-provider-configuration', |
|||
templateUrl: './smpp-sms-provider-configuration.component.html', |
|||
styleUrls: [], |
|||
providers: [{ |
|||
provide: NG_VALUE_ACCESSOR, |
|||
useExisting: forwardRef(() => SmppSmsProviderConfigurationComponent), |
|||
multi: true |
|||
}] |
|||
}) |
|||
|
|||
export class SmppSmsProviderConfigurationComponent implements ControlValueAccessor, OnInit{ |
|||
constructor(private fb: FormBuilder) { |
|||
} |
|||
private requiredValue: boolean; |
|||
|
|||
get required(): boolean { |
|||
return this.requiredValue; |
|||
} |
|||
|
|||
@Input() |
|||
set required(value: boolean) { |
|||
this.requiredValue = coerceBooleanProperty(value); |
|||
} |
|||
@Input() |
|||
disabled: boolean; |
|||
|
|||
smppSmsProviderConfigurationFormGroup: FormGroup; |
|||
|
|||
smppVersions = smppVersions; |
|||
|
|||
bindTypes = Object.keys(BindTypes); |
|||
bindTypesTranslation = bindTypesTranslationMap; |
|||
|
|||
typeOfNumber = Object.keys(TypeOfNumber); |
|||
typeOfNumberMap = typeOfNumberMap; |
|||
|
|||
numberingPlanIdentification = Object.keys(NumberingPlanIdentification); |
|||
numberingPlanIdentificationMap = numberingPlanIdentificationMap; |
|||
|
|||
codingSchemes = Object.keys(CodingSchemes); |
|||
codingSchemesMap = codingSchemesMap; |
|||
|
|||
private propagateChange = (v: any) => { }; |
|||
|
|||
ngOnInit(): void { |
|||
this.smppSmsProviderConfigurationFormGroup = this.fb.group({ |
|||
protocolVersion: [null, [Validators.required]], |
|||
host: [null, [Validators.required]], |
|||
port: [null, [Validators.required]], |
|||
systemId: [null, [Validators.required]], |
|||
password: [null, [Validators.required]], |
|||
systemType: [null], |
|||
bindType: [null, []], |
|||
serviceType: [null, []], |
|||
sourceAddress: [null, []], |
|||
sourceTon: [null, []], |
|||
sourceNpi: [null, []], |
|||
destinationTon: [null, []], |
|||
destinationNpi: [null, []], |
|||
addressRange: [null, []], |
|||
codingScheme: [null, []], |
|||
}); |
|||
|
|||
this.smppSmsProviderConfigurationFormGroup.valueChanges.subscribe(() => { |
|||
this.updateValue(); |
|||
}); |
|||
} |
|||
|
|||
registerOnChange(fn: any): void { |
|||
this.propagateChange = fn; |
|||
} |
|||
|
|||
registerOnTouched(fn: any): void { |
|||
} |
|||
|
|||
setDisabledState(isDisabled: boolean): void { |
|||
this.disabled = isDisabled; |
|||
if (this.disabled) { |
|||
this.smppSmsProviderConfigurationFormGroup.disable({emitEvent: false}); |
|||
} else { |
|||
this.smppSmsProviderConfigurationFormGroup.enable({emitEvent: false}); |
|||
} |
|||
} |
|||
|
|||
writeValue(value: AwsSnsSmsProviderConfiguration | null): void { |
|||
if (isDefinedAndNotNull(value)) { |
|||
this.smppSmsProviderConfigurationFormGroup.patchValue(value, {emitEvent: false}); |
|||
} |
|||
} |
|||
|
|||
private updateValue() { |
|||
let configuration: SmppSmsProviderConfiguration = null; |
|||
if (this.smppSmsProviderConfigurationFormGroup.valid) { |
|||
configuration = this.smppSmsProviderConfigurationFormGroup.value; |
|||
(configuration as SmsProviderConfiguration).type = SmsProviderType.SMPP; |
|||
} |
|||
this.propagateChange(configuration); |
|||
} |
|||
|
|||
} |
|||
Loading…
Reference in new issue