@@ -273,7 +273,7 @@ func server() *cobra.Command {
273
273
}
274
274
}
275
275
276
- coderDaemon := coderd .New (options )
276
+ coderAPI := coderd .New (options )
277
277
client := codersdk .New (localURL )
278
278
if tlsEnable {
279
279
// Secure transport isn't needed for locally communicating!
@@ -299,7 +299,7 @@ func server() *cobra.Command {
299
299
errCh := make (chan error , 1 )
300
300
provisionerDaemons := make ([]* provisionerd.Server , 0 )
301
301
for i := 0 ; uint8 (i ) < provisionerDaemonCount ; i ++ {
302
- daemonClose , err := newProvisionerDaemon (cmd .Context (), coderDaemon , logger , cacheDir , errCh , dev )
302
+ daemonClose , err := newProvisionerDaemon (cmd .Context (), coderAPI , logger , cacheDir , errCh , dev )
303
303
if err != nil {
304
304
return xerrors .Errorf ("create provisioner daemon: %w" , err )
305
305
}
@@ -319,7 +319,7 @@ func server() *cobra.Command {
319
319
// These errors are typically noise like "TLS: EOF". Vault does similar:
320
320
// https://github.com/hashicorp/vault/blob/e2490059d0711635e529a4efcbaa1b26998d6e1c/command/server.go#L2714
321
321
ErrorLog : log .New (io .Discard , "" , 0 ),
322
- Handler : coderDaemon .Handler () ,
322
+ Handler : coderAPI .Handler ,
323
323
BaseContext : func (_ net.Listener ) context.Context {
324
324
return shutdownConnsCtx
325
325
},
@@ -387,15 +387,15 @@ func server() *cobra.Command {
387
387
signal .Notify (stopChan , os .Interrupt )
388
388
select {
389
389
case <- cmd .Context ().Done ():
390
- coderDaemon . CloseWait ()
390
+ coderAPI . Close ()
391
391
return cmd .Context ().Err ()
392
392
case err := <- tunnelErrChan :
393
393
if err != nil {
394
394
return err
395
395
}
396
396
case err := <- errCh :
397
397
shutdownConns ()
398
- coderDaemon . CloseWait ()
398
+ coderAPI . Close ()
399
399
return err
400
400
case <- stopChan :
401
401
}
@@ -459,7 +459,7 @@ func server() *cobra.Command {
459
459
460
460
_ , _ = fmt .Fprintf (cmd .OutOrStdout (), cliui .Styles .Prompt .String ()+ "Waiting for WebSocket connections to close...\n " )
461
461
shutdownConns ()
462
- coderDaemon . CloseWait ()
462
+ coderAPI . Close ()
463
463
return nil
464
464
},
465
465
}
@@ -555,7 +555,7 @@ func createFirstUser(cmd *cobra.Command, client *codersdk.Client, cfg config.Roo
555
555
}
556
556
557
557
// nolint:revive
558
- func newProvisionerDaemon (ctx context.Context , coderDaemon coderd.CoderD ,
558
+ func newProvisionerDaemon (ctx context.Context , coderAPI * coderd.API ,
559
559
logger slog.Logger , cacheDir string , errChan chan error , dev bool ) (* provisionerd.Server , error ) {
560
560
err := os .MkdirAll (cacheDir , 0700 )
561
561
if err != nil {
@@ -595,7 +595,7 @@ func newProvisionerDaemon(ctx context.Context, coderDaemon coderd.CoderD,
595
595
}()
596
596
provisioners [string (database .ProvisionerTypeEcho )] = proto .NewDRPCProvisionerClient (provisionersdk .Conn (echoClient ))
597
597
}
598
- return provisionerd .New (coderDaemon .ListenProvisionerDaemon , & provisionerd.Options {
598
+ return provisionerd .New (coderAPI .ListenProvisionerDaemon , & provisionerd.Options {
599
599
Logger : logger ,
600
600
PollInterval : 500 * time .Millisecond ,
601
601
UpdateInterval : 500 * time .Millisecond ,
0 commit comments