@@ -36,17 +36,17 @@ get_test_conns <- function(skip_backends = NULL) {
36
36
} else {
37
37
38
38
# Use the connection configured by the remote
39
- conn_list <- tibble :: lst(!! Sys.getenv(" BACKEND" ) : = !! Sys.getenv(" BACKEND_DRV" )) # nolint: object_name_linter
39
+ conn_list <- tibble :: lst(!! Sys.getenv(" BACKEND" ) : = !! Sys.getenv(" BACKEND_DRV" ))
40
40
41
41
# Use the connection configured by the remote
42
- conn_args <- tibble :: lst(!! Sys.getenv(" BACKEND" ) : = Sys.getenv(" BACKEND_ARGS" )) | > # nolint: object_name_linter
43
- purrr :: discard(~ identical(. , " " )) | >
44
- purrr :: map(~ eval(parse(text = . )))
42
+ conn_args <- tibble :: lst(!! Sys.getenv(" BACKEND" ) : = Sys.getenv(" BACKEND_ARGS" ))
43
+ conn_args <- purrr :: discard(conn_args , ~ identical(. , " " ))
44
+ conn_args <- purrr :: map(conn_args , ~ eval(parse(text = . )))
45
45
46
46
# Use the connection configured by the remote
47
- conn_post_connect <- tibble :: lst(!! Sys.getenv(" BACKEND" ) : = Sys.getenv(" BACKEND_POST_CONNECT" )) | > # nolint: object_name_linter
48
- purrr :: discard(~ identical(. , " " )) | >
49
- purrr :: map(~ eval(parse(text = . )))
47
+ conn_post_connect <- tibble :: lst(!! Sys.getenv(" BACKEND" ) : = Sys.getenv(" BACKEND_POST_CONNECT" ))
48
+ conn_post_connect <- purrr :: discard(conn_post_connect , ~ identical(. , " " ))
49
+ conn_post_connect <- purrr :: map(conn_post_connect , ~ eval(parse(text = . )))
50
50
51
51
}
52
52
@@ -60,9 +60,8 @@ get_test_conns <- function(skip_backends = NULL) {
60
60
61
61
# Combine all arguments
62
62
backends <- unique(c(names(conn_list ), names(conn_args ), names(conn_args_json )))
63
- conn_args <- backends | >
64
- purrr :: map(~ c(purrr :: pluck(conn_args , . ), purrr :: pluck(conn_args_json , . ))) | >
65
- stats :: setNames(backends )
63
+ conn_args <- purrr :: map(backends , ~ c(purrr :: pluck(conn_args , . ), purrr :: pluck(conn_args_json , . )))
64
+ names(conn_args ) <- backends
66
65
67
66
68
67
get_driver <- function (x = character (), ... ) { # nolint: object_usage_linter
@@ -83,28 +82,43 @@ get_test_conns <- function(skip_backends = NULL) {
83
82
checkmate :: assert_subset(names(conn_args ), names(conn_list ))
84
83
85
84
# Open connections
86
- drivers <- names(conn_list ) | >
87
- purrr :: map(~ do.call(get_driver , list (x = purrr :: pluck(conn_list , . )))) | >
88
- stats :: setNames(names(conn_list )) | >
89
- purrr :: discard(is.null )
85
+ drivers <- purrr :: map(names(conn_list ), ~ do.call(get_driver , list (x = purrr :: pluck(conn_list , . ))))
86
+ names(drivers ) <- names(conn_list )
87
+ drivers <- purrr :: discard(drivers , is.null )
90
88
91
- test_conns <- names(drivers ) | >
92
- purrr :: map(~ do.call(SCDB :: get_connection , c(list (drv = purrr :: pluck(drivers , . )), purrr :: pluck(conn_args , . )))) | >
93
- stats :: setNames(names(drivers )) | >
94
- purrr :: discard(is.null )
89
+ test_conn_args <- purrr :: map(
90
+ names(drivers ),
91
+ ~ c(list (" drv" = purrr :: pluck(drivers , . )), purrr :: pluck(conn_args , . ))
92
+ )
93
+
94
+ test_conns <- purrr :: map(
95
+ test_conn_args ,
96
+ ~ do.call(SCDB :: get_connection , args = . )
97
+ )
98
+ names(test_conns ) <- names(drivers )
99
+ test_conns <- purrr :: discard(test_conns , is.null )
95
100
96
101
# Skip backends if given
97
- test_conns <- test_conns | >
98
- purrr :: walk(\(conn ) {
99
- if (checkmate :: test_multi_class(conn , purrr :: pluck(skip_backends , .default = " " ))) {
100
- DBI :: dbDisconnect(conn )
102
+ test_conns <- purrr :: walk(
103
+ test_conns ,
104
+ ~ {
105
+ if (checkmate :: test_multi_class(. , purrr :: pluck(skip_backends , .default = " " ))) {
106
+ DBI :: dbDisconnect(. )
101
107
}
102
- }) | >
103
- purrr :: discard(\(conn ) checkmate :: test_multi_class(conn , purrr :: pluck(skip_backends , .default = " " )))
108
+ }
109
+ )
110
+ test_conns <- purrr :: discard(
111
+ test_conns ,
112
+ ~ checkmate :: test_multi_class(. , purrr :: pluck(skip_backends , .default = " " ))
113
+ )
104
114
105
115
# Run post_connect commands on the connections
106
- purrr :: walk2(test_conns , names(test_conns ),
107
- \(conn , conn_name ) purrr :: walk(purrr :: pluck(conn_post_connect , conn_name ), ~ DBI :: dbExecute(conn , . )))
116
+ purrr :: iwalk(
117
+ test_conns ,
118
+ function (conn , conn_name ) {
119
+ purrr :: walk(purrr :: pluck(conn_post_connect , conn_name ), ~ DBI :: dbExecute(conn , . ))
120
+ }
121
+ )
108
122
109
123
# Inform the user about the tested back ends:
110
124
msg <- paste(sep = " \n " ,
@@ -141,12 +155,12 @@ get_test_conns <- function(skip_backends = NULL) {
141
155
checkmate_err_msg <- function (expr ) {
142
156
tryCatch(
143
157
expr ,
144
- error = \ (e ) {
145
- e $ message | >
146
- stringr :: str_remove_all(stringr :: fixed(" \n *" )) | >
147
- stringr :: str_remove_all(stringr :: fixed(" * " )) | >
148
- simpleError( message = _) | >
149
- stop()
158
+ error = function (e ) {
159
+ msg <- e $ message
160
+ msg <- stringr :: str_remove_all(msg , stringr :: fixed(" \n *" ))
161
+ msg <- stringr :: str_remove_all(msg , stringr :: fixed(" * " ))
162
+
163
+ stop(simpleError( message = msg ) )
150
164
}
151
165
)
152
166
}
0 commit comments