@@ -75,9 +75,6 @@ func main() {
75
75
klog .InitFlags (nil )
76
76
flag .Parse ()
77
77
ctx := context .Background ()
78
- if err := validateFlags (); err != nil {
79
- klog .Exitf ("Invalid flags: %v" , err )
80
- }
81
78
82
79
signer , err := NewSecretManagerSigner (ctx , * signerPublicKeySecretName , * signerPrivateKeySecretName )
83
80
if err != nil {
@@ -204,10 +201,19 @@ func awaitSignal(doneFn func()) {
204
201
}
205
202
206
203
func newGCPStorage (ctx context.Context , signer note.Signer ) (* sctfe.CTStorage , error ) {
204
+ if len (* bucket ) == 0 {
205
+ return nil , errors .New ("missing bucket" )
206
+ }
207
+
208
+ if len (* spannerDB ) == 0 {
209
+ return nil , errors .New ("missing spannerDB" )
210
+ }
211
+
207
212
gcpCfg := gcpTessera.Config {
208
213
Bucket : * bucket ,
209
214
Spanner : * spannerDB ,
210
215
}
216
+
211
217
tesseraStorage , err := gcpTessera .New (ctx , gcpCfg , tessera .WithCheckpointSigner (signer ), tessera .WithCTLayout ())
212
218
if err != nil {
213
219
return nil , fmt .Errorf ("Failed to initialize GCP Tessera storage: %v" , err )
@@ -248,18 +254,3 @@ func (t *timestampFlag) Set(w string) error {
248
254
t .t = & tt
249
255
return nil
250
256
}
251
-
252
- func validateFlags () error {
253
- if len (* projectID ) == 0 {
254
- return errors .New ("missing projectID" )
255
- }
256
-
257
- if len (* bucket ) == 0 {
258
- return errors .New ("missing bucket" )
259
- }
260
-
261
- if len (* spannerDB ) == 0 {
262
- return errors .New ("missing spannerDB" )
263
- }
264
- return nil
265
- }
0 commit comments