@@ -5,10 +5,10 @@ import (
55 "fmt"
66 "os"
77
8+ cfg "github.com/conductorone/baton-postgresql/pkg/config"
89 "github.com/conductorone/baton-sdk/pkg/connectorbuilder"
910 "github.com/conductorone/baton-sdk/pkg/types"
1011 "github.com/grpc-ecosystem/go-grpc-middleware/logging/zap/ctxzap"
11- "github.com/spf13/viper"
1212 "go.uber.org/zap"
1313
1414 "github.com/conductorone/baton-postgresql/pkg/connector"
@@ -20,7 +20,7 @@ var version = "dev"
2020func main () {
2121 ctx := context .Background ()
2222
23- _ , cmd , err := configschema .DefineConfiguration (ctx , "baton-postgresql" , getConnector , configuration )
23+ _ , cmd , err := configschema .DefineConfiguration (ctx , "baton-postgresql" , getConnector , cfg . Config )
2424 if err != nil {
2525 fmt .Fprintln (os .Stderr , err .Error ())
2626 os .Exit (1 )
@@ -35,10 +35,10 @@ func main() {
3535 }
3636}
3737
38- func getConnector (ctx context.Context , v * viper. Viper ) (types.ConnectorServer , error ) {
38+ func getConnector (ctx context.Context , pgc * cfg. Postgresql ) (types.ConnectorServer , error ) {
3939 l := ctxzap .Extract (ctx )
4040
41- cb , err := connector .New (ctx , v . GetString ( "dsn" ), v . GetStringSlice ( "schemas" ), v . GetBool ( "include-columns" ), v . GetBool ( "include-large-objects" ) )
41+ cb , err := connector .New (ctx , pgc . Dsn , pgc . Schemas , pgc . IncludeColumns , pgc . IncludeLargeObjects )
4242 if err != nil {
4343 l .Error ("error creating connector" , zap .Error (err ))
4444 return nil , err
0 commit comments