back round 0 view raw

appview/oauth: allow customizing client timeouts in xrpc reqs #840

closed

opened by

oppi.li 1 week ago targeting master from op/tzszvtloukvm

Signed-off-by: oppiliappan me@oppi.li

options

unified split

Changed files

+17 -2

appview

oauth

oauth.go

repo

repo.go

+15 -2

appview/oauth/oauth.go

···

       202
       202
        
       	exp     int64

     

       203
       203
        
       	lxm     string

     

       204
       204
        
       	dev     bool

     

       205
       205
       +
       	timeout time.Duration

     

       205
       206
        
       }

     

       206
       207
        
       

     

       207
       208
        
       type ServiceClientOpt func(*ServiceClientOpts)

     

       209
       209
       +
       

     

       210
       210
       +
       func DefaultServiceClientOpts() ServiceClientOpts {

     

       211
       211
       +
       	return ServiceClientOpts{

     

       212
       212
       +
       		timeout: time.Second * 5,

     

       213
       213
       +
       	}

     

       214
       214
       +
       }

     

       208
       215
        
       

     

       209
       216
        
       func WithService(service string) ServiceClientOpt {

     

       210
       217
        
       	return func(s *ServiceClientOpts) {

     
···

       233
       240
        
       	}

     

       234
       241
        
       }

     

       235
       242
        
       

     

       243
       243
       +
       func WithTimeout(timeout time.Duration) ServiceClientOpt {

     

       244
       244
       +
       	return func(s *ServiceClientOpts) {

     

       245
       245
       +
       		s.timeout = timeout

     

       246
       246
       +
       	}

     

       247
       247
       +
       }

     

       248
       248
       +
       

     

       236
       249
        
       func (s *ServiceClientOpts) Audience() string {

     

       237
       250
        
       	return fmt.Sprintf("did:web:%s", s.service)

     

       238
       251
        
       }

     
···

       247
       260
        
       }

     

       248
       261
        
       

     

       249
       262
        
       func (o *OAuth) ServiceClient(r *http.Request, os ...ServiceClientOpt) (*xrpc.Client, error) {

     

       250
       250
       -
       	opts := ServiceClientOpts{}

     

       263
       263
       +
       	opts := DefaultServiceClientOpts()

     

       251
       264
        
       	for _, o := range os {

     

       252
       265
        
       		o(&opts)

     

       253
       266
        
       	}

     
···

       274
       287
        
       		},

     

       275
       288
        
       		Host: opts.Host(),

     

       276
       289
        
       		Client: &http.Client{

     

       277
       277
       -
       			Timeout: time.Second * 5,

     

       290
       290
       +
       			Timeout: opts.timeout,

     

       278
       291
        
       		},

     

       279
       292
        
       	}, nil

     

       280
       293
        
       }

appview/repo/repo.go

···

       1130
       1130
        
       		}

     

       1131
       1131
        
       		defer rollback()

     

       1132
       1132
        
       

     

       1133
       1133
       +
       		// TODO: this could coordinate better with the knot to recieve a clone status

     

       1133
       1134
        
       		client, err := rp.oauth.ServiceClient(

     

       1134
       1135
        
       			r,

     

       1135
       1136
        
       			oauth.WithService(targetKnot),

     

       1136
       1137
        
       			oauth.WithLxm(tangled.RepoCreateNSID),

     

       1137
       1138
        
       			oauth.WithDev(rp.config.Core.Dev),

     

       1139
       1139
       +
       			oauth.WithTimeout(time.Second*20), // big repos take time to clone

     

       1138
       1140
        
       		)

     

       1139
       1141
        
       		if err != nil {

     

       1140
       1142
        
       			l.Error("could not create service client", "err", err)