@@ -54,16 +54,12 @@ let isNeptuneIAMAuth = false;
54
54
let createUpdatePipeline = false ;
55
55
let createUpdatePipelineName = '' ;
56
56
let createUpdatePipelineEndpoint = '' ;
57
- let createUpdatePipelineEndpointRO = '' ;
58
- let createUpdatePipelineDualLambdas = false ;
59
57
let createUpdatePipelineRegion = '' ;
60
58
let createUpdatePipelineNeptuneDatabaseName = '' ;
61
59
let removePipelineName = '' ;
62
60
let inputCDKpipeline = false ;
63
61
let inputCDKpipelineName = '' ;
64
62
let inputCDKpipelineEnpoint = '' ;
65
- let inputCDKpipelineEnpointRO = '' ;
66
- let inputCDKpipelineDualLambdas = false ;
67
63
let inputCDKpipelineFile = '' ;
68
64
let inputCDKpipelineRegion = '' ;
69
65
let inputCDKpipelineDatabaseName = '' ;
@@ -196,14 +192,8 @@ function processArgs() {
196
192
case '--create-update-aws-pipeline-neptune-endpoint' :
197
193
createUpdatePipelineEndpoint = array [ index + 1 ] ;
198
194
break ;
199
- case 'pro' :
200
- case '--create-update-aws-pipeline-neptune-endpoint-ro' :
201
- createUpdatePipelineEndpointRO = array [ index + 1 ] ;
202
- break ;
195
+ case 'pro' :
203
196
case '-p2l' :
204
- case '--create-update-aws-pipeline-dual-lambdas' :
205
- createUpdatePipelineDualLambdas = true ;
206
- break ;
207
197
case '-pd' :
208
198
case '--create-update-aws-pipeline-neptune-database-name' :
209
199
createUpdatePipelineNeptuneDatabaseName = array [ index + 1 ] ;
@@ -221,12 +211,7 @@ function processArgs() {
221
211
inputCDKpipelineEnpoint = array [ index + 1 ] ;
222
212
break ;
223
213
case 'cro' :
224
- case '--output-aws-pipeline-cdk-neptume-endpoint-ro' :
225
- inputCDKpipelineEnpointRO = array [ index + 1 ] ;
226
- break ;
227
214
case '-c2l' :
228
- case '--output-aws-pipeline-cdk-neptume-dual-lambas' :
229
- inputCDKpipelineDualLambdas = true ;
230
215
case '-cd' :
231
216
case '--output-aws-pipeline-cdk-neptume-database-name' :
232
217
inputCDKpipelineDatabaseName = array [ index + 1 ] ;
@@ -321,7 +306,7 @@ async function main() {
321
306
322
307
let neptuneRegionParts = inputGraphDBSchemaNeptuneEndpoint . split ( '.' ) ;
323
308
let neptuneRegion = '' ;
324
- if ( neptuneType == 'neptune-db' )
309
+ if ( neptuneType == 'neptune-db' )
325
310
neptuneRegion = neptuneRegionParts [ 2 ] ;
326
311
else
327
312
neptuneRegion = neptuneRegionParts [ 1 ] ;
@@ -614,19 +599,6 @@ async function main() {
614
599
let neptuneHost = endpointParts [ 0 ] ;
615
600
let neptunePort = endpointParts [ 1 ] ;
616
601
617
- let neptuneHostRO = '' ;
618
- let neptunePortRO = '' ;
619
- if ( createUpdatePipelineEndpointRO != '' ) {
620
- let endpointPartsRO = createUpdatePipelineEndpointRO . split ( ':' ) ;
621
- if ( endpointPartsRO . length < 2 ) {
622
- msg = 'Neptune read only endpoint must be in the form of host:port' ;
623
- loggerError ( msg ) ;
624
- process . exit ( 1 ) ;
625
- }
626
- neptuneHostRO = endpointPartsRO [ 0 ] ;
627
- neptunePortRO = endpointPartsRO [ 1 ] ;
628
- }
629
-
630
602
msg = '\nCreating AWS pipeline resources' ;
631
603
loggerLog ( msg , ! quiet ) ;
632
604
await createUpdateAWSpipeline ( createUpdatePipelineName ,
@@ -641,9 +613,6 @@ async function main() {
641
613
isNeptuneIAMAuth ,
642
614
neptuneHost ,
643
615
neptunePort ,
644
- neptuneHostRO ,
645
- neptunePortRO ,
646
- createUpdatePipelineDualLambdas ,
647
616
outputFolderPath ,
648
617
neptuneType ) ;
649
618
} catch ( err ) {
0 commit comments