File tree Expand file tree Collapse file tree 1 file changed +5
-5
lines changed
Expand file tree Collapse file tree 1 file changed +5
-5
lines changed Original file line number Diff line number Diff line change @@ -176,17 +176,17 @@ func contextNamespace(c context.Context) string {
176176
177177func gcsPayloadHandler (handler APIHandler ) APIHandler {
178178 return func (c context.Context , payload io.Reader ) (interface {}, error ) {
179- p , err := io . ReadAll ( payload )
180- if err != nil {
181- return nil , fmt .Errorf ("io.ReadAll : %w" , err )
179+ var gcsURL string
180+ if err := json . NewDecoder ( payload ). Decode ( & gcsURL ); err != nil {
181+ return nil , fmt .Errorf ("json.NewDecoder(payload).Decode(&gcsURL) : %w" , err )
182182 }
183- payloadURL := string ( p )
183+ gcsURL = strings . TrimPrefix ( gcsURL , "gs://" )
184184 clientGCS , err := gcs .NewClient (c )
185185 if err != nil {
186186 return nil , fmt .Errorf ("gcs.NewClient: %w" , err )
187187 }
188188 defer clientGCS .Close ()
189- gcsFile , err := clientGCS .Read (payloadURL )
189+ gcsFile , err := clientGCS .Read (gcsURL )
190190 if err != nil {
191191 return nil , fmt .Errorf ("clientGCS.Read: %w" , err )
192192 }
You can’t perform that action at this time.
0 commit comments