@@ -21,7 +21,6 @@ import (
21
21
"testing"
22
22
23
23
"github.com/go-test/deep"
24
- "github.com/openlyinc/pointy"
25
24
)
26
25
27
26
func TestEventTriggers_List (t * testing.T ) {
@@ -57,7 +56,7 @@ func TestEventTriggers_List(t *testing.T) {
57
56
Type : "type" ,
58
57
FunctionID : "1" ,
59
58
FunctionName : "name" ,
60
- Disabled : pointy . Bool (false ),
59
+ Disabled : pointer (false ),
61
60
},
62
61
}
63
62
@@ -99,7 +98,7 @@ func TestEventTriggers_Get(t *testing.T) {
99
98
Type : "type" ,
100
99
FunctionID : "1" ,
101
100
FunctionName : "name" ,
102
- Disabled : pointy . Bool (false ),
101
+ Disabled : pointer (false ),
103
102
}
104
103
105
104
if diff := deep .Equal (trigger , & expected ); diff != nil {
@@ -118,20 +117,20 @@ func TestEventTriggers_CreateDatabase(t *testing.T) {
118
117
Name : "Test event trigger" ,
119
118
Type : "DATABASE" ,
120
119
FunctionID : "60c2badbbd2b5c170e91292d" ,
121
- Disabled : pointy . Bool (false ),
120
+ Disabled : pointer (false ),
122
121
Config : & EventTriggerConfig {
123
122
OperationTypes : []string {"INSERT" , "UPDATE" , "REPLACE" , "DELETE" },
124
123
Database : "database" ,
125
124
Collection : "collection" ,
126
125
ServiceID : "60c2badbbd2b5c170e91292c" ,
127
126
Match : `{"updateDescription.updatedFields.status": {"$exists": true}}` ,
128
127
Project : `{"updateDescription.updatedFields.FieldA": 1, "operationType": 1}` ,
129
- FullDocument : pointy . Bool (false ),
130
- FullDocumentBeforeChange : pointy . Bool (false ),
131
- TolerateResumeErrors : pointy . Bool (true ),
132
- SkipCatchupEvents : pointy . Bool (true ),
133
- MaximumThroughput : pointy . Bool (true ),
134
- Unordered : pointy . Bool (false ),
128
+ FullDocument : pointer (false ),
129
+ FullDocumentBeforeChange : pointer (false ),
130
+ TolerateResumeErrors : pointer (true ),
131
+ SkipCatchupEvents : pointer (true ),
132
+ MaximumThroughput : pointer (true ),
133
+ Unordered : pointer (false ),
135
134
},
136
135
EventProcessors : map [string ]interface {}{
137
136
"AWS_EVENTBRIDGE" : map [string ]interface {}{
@@ -239,7 +238,7 @@ func TestEventTriggers_CreateDatabase(t *testing.T) {
239
238
Type : "DATABASE" ,
240
239
FunctionID : "60c2badbbd2b5c170e91292d" ,
241
240
FunctionName : "name" ,
242
- Disabled : pointy . Bool (false ),
241
+ Disabled : pointer (false ),
243
242
Config : EventTriggerConfig {
244
243
OperationTypes : []string {"INSERT" , "UPDATE" , "REPLACE" , "DELETE" },
245
244
Database : "sample_airbnb" ,
@@ -254,12 +253,12 @@ func TestEventTriggers_CreateDatabase(t *testing.T) {
254
253
"operationType" : float64 (1 ),
255
254
"updateDescription.updatedFields.FieldA" : float64 (1 ),
256
255
},
257
- FullDocument : pointy . Bool (false ),
258
- FullDocumentBeforeChange : pointy . Bool (false ),
259
- Unordered : pointy . Bool (false ),
260
- TolerateResumeErrors : pointy . Bool (true ),
261
- SkipCatchupEvents : pointy . Bool (true ),
262
- MaximumThroughput : pointy . Bool (true ),
256
+ FullDocument : pointer (false ),
257
+ FullDocumentBeforeChange : pointer (false ),
258
+ Unordered : pointer (false ),
259
+ TolerateResumeErrors : pointer (true ),
260
+ SkipCatchupEvents : pointer (true ),
261
+ MaximumThroughput : pointer (true ),
263
262
ClusterName : "cluster name" ,
264
263
},
265
264
EventProcessors : map [string ]interface {}{
@@ -271,7 +270,7 @@ func TestEventTriggers_CreateDatabase(t *testing.T) {
271
270
},
272
271
},
273
272
},
274
- LastModified : pointy . Int64 (int64 (1623793011 )),
273
+ LastModified : pointer (int64 (1623793011 )),
275
274
}
276
275
277
276
if diff := deep .Equal (updatedEventTriggersServiceOp , & expected ); diff != nil {
@@ -290,7 +289,7 @@ func TestEventTriggers_CreateAuthentication(t *testing.T) {
290
289
Name : "Test event trigger" ,
291
290
Type : "AUTHENTICATION" ,
292
291
FunctionID : "60c2badbbd2b5c170e91292d" ,
293
- Disabled : pointy . Bool (false ),
292
+ Disabled : pointer (false ),
294
293
Config : & EventTriggerConfig {
295
294
OperationType : "LOGIN" ,
296
295
Providers : []string {"anon-user" , "local-userpass" },
@@ -379,7 +378,7 @@ func TestEventTriggers_CreateAuthentication(t *testing.T) {
379
378
Type : "AUTHENTICATION" ,
380
379
FunctionID : "60c2badbbd2b5c170e91292d" ,
381
380
FunctionName : "name" ,
382
- Disabled : pointy . Bool (false ),
381
+ Disabled : pointer (false ),
383
382
Config : EventTriggerConfig {
384
383
OperationType : "LOGIN" ,
385
384
Providers : []string {"anon-user" , "local-userpass" },
@@ -395,7 +394,7 @@ func TestEventTriggers_CreateAuthentication(t *testing.T) {
395
394
},
396
395
},
397
396
},
398
- LastModified : pointy . Int64 (int64 (1623793011 )),
397
+ LastModified : pointer (int64 (1623793011 )),
399
398
}
400
399
401
400
if diff := deep .Equal (updatedEventTriggersServiceOp , & expected ); diff != nil {
@@ -414,7 +413,7 @@ func TestEventTriggers_CreateScheduled(t *testing.T) {
414
413
Name : "Test event trigger" ,
415
414
Type : "SCHEDULED" ,
416
415
FunctionID : "60c2badbbd2b5c170e91292d" ,
417
- Disabled : pointy . Bool (false ),
416
+ Disabled : pointer (false ),
418
417
Config : & EventTriggerConfig {
419
418
Schedule : "* * * * *" ,
420
419
},
@@ -496,7 +495,7 @@ func TestEventTriggers_CreateScheduled(t *testing.T) {
496
495
Type : "SCHEDULED" ,
497
496
FunctionID : "60c2badbbd2b5c170e91292d" ,
498
497
FunctionName : "name" ,
499
- Disabled : pointy . Bool (false ),
498
+ Disabled : pointer (false ),
500
499
Config : EventTriggerConfig {
501
500
Schedule : "* * * * *" ,
502
501
ScheduleType : "ADVANCED" ,
@@ -510,7 +509,7 @@ func TestEventTriggers_CreateScheduled(t *testing.T) {
510
509
},
511
510
},
512
511
},
513
- LastModified : pointy . Int64 (int64 (1623793011 )),
512
+ LastModified : pointer (int64 (1623793011 )),
514
513
}
515
514
516
515
if diff := deep .Equal (updatedEventTriggersServiceOp , & expected ); diff != nil {
@@ -530,7 +529,7 @@ func TestEventTriggers_Update(t *testing.T) {
530
529
Name : "Test event trigger update" ,
531
530
Type : "Test event trigger update" ,
532
531
FunctionID : "1" ,
533
- Disabled : pointy . Bool (false ),
532
+ Disabled : pointer (false ),
534
533
Config : & EventTriggerConfig {
535
534
OperationTypes : []string {"INSERT" , "UPDATE" },
536
535
OperationType : "CREATE" ,
@@ -540,7 +539,7 @@ func TestEventTriggers_Update(t *testing.T) {
540
539
ServiceID : "3" ,
541
540
Match : `{"updateDescription.updatedFields.status": {"$exists": true}}` ,
542
541
Project : `{"updateDescription.updatedFields.FieldA": 1, "operationType": 1}` ,
543
- FullDocument : pointy . Bool (false ),
542
+ FullDocument : pointer (false ),
544
543
Schedule : "weekday" ,
545
544
},
546
545
EventProcessors : map [string ]interface {}{
@@ -616,7 +615,7 @@ func TestEventTriggers_Update(t *testing.T) {
616
615
Type : "type" ,
617
616
FunctionID : "1" ,
618
617
FunctionName : "name" ,
619
- Disabled : pointy . Bool (false ),
618
+ Disabled : pointer (false ),
620
619
}
621
620
622
621
if diff := deep .Equal (updatedEventTriggersServiceOp , & expected ); diff != nil {
0 commit comments