Commit8f2a45a

committed

chore: make fmt

1 parent291fab9 commit8f2a45aCopy full SHA for 8f2a45a

File tree

-7

lines changed

-7

lines changed

Lines changed: 7 additions & 6 deletions

Original file line number	Diff line number	Diff line change
`@@ -30,9 +30,11 @@ var (`
`30`	`30`	`ErrNoMCPConfigFound=xerrors.New("no MCP config found")`
`31`	`31`	`)`
`32`	`32`
`33`		`-var_ proto.DRPCAuthorizerServer=&Server{}`
`34`		`-var_ proto.DRPCMCPConfiguratorServer=&Server{}`
`35`		`-var_ proto.DRPCRecorderServer=&Server{}`
	`33`	`+var (`
	`34`	`+_ proto.DRPCAuthorizerServer=&Server{}`
	`35`	`+_ proto.DRPCMCPConfiguratorServer=&Server{}`
	`36`	`+_ proto.DRPCRecorderServer=&Server{}`
	`37`	`+)`
`36`	`38`
`37`	`39`	`typestoreinterface {`
`38`	`40`	`// Recorder-related queries.`
`@@ -307,11 +309,10 @@ func (s Server) GetMCPServerAccessTokensBatch(ctx context.Context, in proto.Ge`
`307`	`309`	`gofunc() {`
`308`	`310`	`deferwg.Done()`
`309`	`311`
`310`		`-mu.Lock()`
`311`		`-defermu.Unlock()`
`312`		`-`
`313`	`312`	`// TODO: timeout.`
`314`	`313`	`valid,_,err:=eac.ValidateToken(ctx,link.OAuthToken())`
	`314`	`+mu.Lock()`
	`315`	`+defermu.Unlock()`
`315`	`316`	`if!valid {`
`316`	`317`	`// TODO: attempt refresh.`
`317`	`318`	`s.logger.Warn(ctx,"invalid/expired access token, cannot auto-configure MCP",slog.F("provider",link.ProviderID),slog.Error(err))`

Lines changed: 1 addition & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -525,7 +525,7 @@ func TestRecordToolUsage(t *testing.T) {`
`525`	`525`	`)`
`526`	`526`	`}`
`527`	`527`
`528`		`-// testRecordMethod is a helper that abstracts the common testing pattern for all Record* methods`
	`528`	`+// testRecordMethod is a helper that abstracts the common testing pattern for all Record* methods.`
`529`	`529`	`functestRecordMethod[Reqany,Respany](`
`530`	`530`	`t*testing.T,`
`531`	`531`	`callMethodfunc(*aibridgedserver.Server, context.Context,Req) (Resp,error),`

Comments

(0)