ArtemDzhereleiko
5 years ago
13 changed files with 643 additions and 6 deletions
@ -0,0 +1,183 @@ |
|||
/** |
|||
* Copyright © 2016-2021 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 { |
|||
private final SmppSmsProviderConfiguration config; |
|||
|
|||
private 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; |
|||
initSmppSession(); |
|||
} |
|||
|
|||
@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.info("SMPP submit command status: {}", response.getCommandStatus()); |
|||
} catch (Exception e) { |
|||
throw new RuntimeException(e); |
|||
} |
|||
|
|||
return countMessageSegments(message); |
|||
} |
|||
|
|||
public synchronized void checkSmppSession() { |
|||
if (!smppSession.isOpened()) { |
|||
smppSession = initSmppSession(); |
|||
} |
|||
} |
|||
|
|||
private 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)); |
|||
} |
|||
} |
|||
|
|||
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,117 @@ |
|||
/** |
|||
* Copyright © 2016-2021 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,101 @@ |
|||
<form [formGroup]="smppSmsProviderConfigurationFormGroup" style="padding-bottom: 16px;"> |
|||
<mat-form-field class="mat-block"> |
|||
<mat-label>SMPP version</mat-label> |
|||
<input required matInput formControlName="protocolVersion"> |
|||
<mat-error *ngIf="smppSmsProviderConfigurationFormGroup.get('protocolVersion').hasError('required')"> |
|||
SMPP version is required |
|||
</mat-error> |
|||
</mat-form-field> |
|||
<mat-form-field fxFlex class="mat-block"> |
|||
<mat-label>SMPP host</mat-label> |
|||
<input required matInput formControlName="host"> |
|||
<mat-error *ngIf="smppSmsProviderConfigurationFormGroup.get('host').hasError('required')"> |
|||
SMPP host is required |
|||
</mat-error> |
|||
</mat-form-field> |
|||
<mat-form-field fxFlex class="mat-block" style="margin-right: 8px;"> |
|||
<mat-label>SMPP port</mat-label> |
|||
<input required matInput type="number" formControlName="port"> |
|||
<mat-error *ngIf="smppSmsProviderConfigurationFormGroup.get('port').hasError('required')"> |
|||
SMPP port is required |
|||
</mat-error> |
|||
</mat-form-field> |
|||
<mat-form-field fxFlex class="mat-block"> |
|||
<mat-label>System ID</mat-label> |
|||
<input required matInput formControlName="systemId"> |
|||
<mat-error *ngIf="smppSmsProviderConfigurationFormGroup.get('systemId').hasError('required')"> |
|||
System ID is required |
|||
</mat-error> |
|||
</mat-form-field> |
|||
<mat-form-field class="mat-block"> |
|||
<mat-label>Password</mat-label> |
|||
<input required matInput formControlName="password"> |
|||
<mat-error *ngIf="smppSmsProviderConfigurationFormGroup.get('password').hasError('required')"> |
|||
Password is required |
|||
</mat-error> |
|||
</mat-form-field> |
|||
<mat-form-field class="mat-block"> |
|||
<mat-label>System type</mat-label> |
|||
<input matInput formControlName="systemType"> |
|||
</mat-form-field> |
|||
<mat-form-field class="mat-block"> |
|||
<mat-label>Bind type</mat-label> |
|||
<mat-select formControlName="bindType"> |
|||
<mat-option *ngFor="let bindType of bindTypes" [value]="bindType.value"> |
|||
{{bindType.name}} |
|||
</mat-option> |
|||
</mat-select> |
|||
</mat-form-field> |
|||
<mat-form-field class="mat-block"> |
|||
<mat-label>Service type</mat-label> |
|||
<input matInput formControlName="serviceType"> |
|||
</mat-form-field> |
|||
<mat-form-field class="mat-block"> |
|||
<mat-label>Source address</mat-label> |
|||
<input matInput formControlName="sourceAddress"> |
|||
</mat-form-field> |
|||
<mat-form-field class="mat-block"> |
|||
<mat-label>Source TON</mat-label> |
|||
<mat-select formControlName="sourceTon"> |
|||
<mat-option *ngFor="let sourceTon of sourcesTon" [value]="sourceTon.value"> |
|||
{{sourceTon.name}} |
|||
</mat-option> |
|||
</mat-select> |
|||
</mat-form-field> |
|||
<mat-form-field class="mat-block"> |
|||
<mat-label>Source NPI</mat-label> |
|||
<mat-select formControlName="sourceNpi"> |
|||
<mat-option *ngFor="let sourceNpi of sourcesNpi" [value]="sourceNpi.value"> |
|||
{{sourceNpi.name}} |
|||
</mat-option> |
|||
</mat-select> |
|||
</mat-form-field> |
|||
<mat-form-field class="mat-block"> |
|||
<mat-label translate>Destination TON (Type of Number)</mat-label> |
|||
<mat-select formControlName="destinationTon"> |
|||
<mat-option *ngFor="let destinationTon of destinationsTon" [value]="destinationTon.value"> |
|||
{{destinationTon.name}} |
|||
</mat-option> |
|||
</mat-select> |
|||
</mat-form-field> |
|||
<mat-form-field class="mat-block"> |
|||
<mat-label>Destination NPI (Numbering Plan Identification)</mat-label> |
|||
<mat-select formControlName="destinationNpi"> |
|||
<mat-option *ngFor="let destinationNpi of destinationsNpi" [value]="destinationNpi.value"> |
|||
{{destinationNpi.name}} |
|||
</mat-option> |
|||
</mat-select> |
|||
</mat-form-field> |
|||
<mat-form-field class="mat-block"> |
|||
<mat-label>Address range</mat-label> |
|||
<input matInput formControlName="addressRange"> |
|||
</mat-form-field> |
|||
<mat-form-field class="mat-block"> |
|||
<mat-label>Coding Scheme</mat-label> |
|||
<mat-select formControlName="codingScheme"> |
|||
<mat-option *ngFor="let codingScheme of codingSchemes" [value]="codingScheme.value"> |
|||
{{codingScheme.name}} |
|||
</mat-option> |
|||
</mat-select> |
|||
</mat-form-field> |
|||
</form> |
|||
@ -0,0 +1,163 @@ |
|||
import { Component, forwardRef, Input, OnInit } from '@angular/core'; |
|||
import { ControlValueAccessor, FormBuilder, FormGroup, NG_VALUE_ACCESSOR, Validators } from '@angular/forms'; |
|||
import { |
|||
AwsSnsSmsProviderConfiguration, SmppSmsProviderConfiguration, |
|||
SmsProviderConfiguration, |
|||
SmsProviderType |
|||
} 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; |
|||
bindTypes = [ |
|||
{value: 'TX', name: 'Transmitter'}, |
|||
{value: 'RX', name: 'Receiver'}, |
|||
{value: 'TRX', name: 'Transciever'}, |
|||
] |
|||
|
|||
sourcesTon = [ |
|||
{value: 0, name: 'Unknown'}, |
|||
{value: 1, name: 'International'}, |
|||
{value: 2, name: 'National'}, |
|||
{value: 3, name: 'Network Specific'}, |
|||
{value: 4, name: 'Subscriber Number'}, |
|||
{value: 5, name: 'Alphanumeric'}, |
|||
{value: 6, name: 'Abbreviated'} |
|||
] |
|||
|
|||
sourcesNpi = [ |
|||
{value: 0, name: 'Unknown'}, |
|||
{value: 1, name: 'ISDN/telephone numbering plan (E163/E164)'}, |
|||
{value: 3, name: 'Data numbering plan (X.121)'}, |
|||
{value: 4, name: 'Telex numbering plan (F.69)'}, |
|||
{value: 5, name: 'Land Mobile (E.212)'}, |
|||
{value: 8, name: 'National numbering plan'}, |
|||
{value: 9, name: 'Private numbering plan'}, |
|||
{value: 10, name: 'ERMES numbering plan (ETSI DE/PS 3 01-3)'}, |
|||
{value: 13, name: 'Internet (IP)'}, |
|||
{value: 18, name: 'WAP Client Id (to be defined by WAP Forum)'}, |
|||
] |
|||
|
|||
destinationsTon = [ |
|||
{value: 0, name: 'Unknown'}, |
|||
{value: 1, name: 'International'}, |
|||
{value: 2, name: 'National'}, |
|||
{value: 3, name: 'Network Specific'}, |
|||
{value: 4, name: 'Subscriber Number'}, |
|||
{value: 5, name: 'Alphanumeric'}, |
|||
{value: 6, name: 'Abbreviated'}, |
|||
] |
|||
|
|||
destinationsNpi = [ |
|||
{value: 0, name: 'Unknown'}, |
|||
{value: 1, name: 'ISDN/telephone numbering plan (E163/E164)'}, |
|||
{value: 3, name: 'Data numbering plan (X.121)'}, |
|||
{value: 4, name: 'Telex numbering plan (F.69)'}, |
|||
{value: 6, name: 'Land Mobile (E.212)'}, |
|||
{value: 8, name: 'National numbering plan'}, |
|||
{value: 9, name: 'Private numbering plan'}, |
|||
{value: 10, name: 'ERMES numbering plan (ETSI DE/PS 3 01-3)'}, |
|||
{value: 13, name: 'Internet (IP)'}, |
|||
{value: 18, name: 'WAP Client Id (to be defined by WAP Forum)'}, |
|||
] |
|||
|
|||
codingSchemes = [ |
|||
{value: 0, name: 'SMSC Default Alphabet (ASCII for short and long code and to GSM for toll-free)'}, |
|||
{value: 1, name: 'IA5 (ASCII for short and long code, Latin 9 for toll-free (ISO-8859-9))'}, |
|||
{value: 2, name: 'Octet Unspecified (8-bit binary)'}, |
|||
{value: 3, name: 'Latin 1 (ISO-8859-1)'}, |
|||
{value: 4, name: 'Octet Unspecified (8-bit binary)'}, |
|||
{value: 5, name: 'JIS (X 0208-1990)'}, |
|||
{value: 6, name: 'Cyrillic (ISO-8859-5)'}, |
|||
{value: 7, name: 'Latin/Hebrew (ISO-8859-8)'}, |
|||
{value: 8, name: 'UCS2/UTF-16 (ISO/IEC-10646)'}, |
|||
{value: 9, name: 'Pictogram Encoding'}, |
|||
{value: 10, name: 'Music Codes (ISO-2022-JP)'}, |
|||
{value: 13, name: 'Extended Kanji JIS (X 0212-1990)'}, |
|||
{value: 14, name: 'Korean Graphic Character Set (KS C 5601/KS X 1001)'}, |
|||
] |
|||
|
|||
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