Aug 22, 2022 · Aug 17, 2022 · Aug 18, 2022 · Aug 18, 2022 · Aug 18, 2022 · Aug 19, 2022
diff --git a/cli/clitest/clitest.go b/cli/clitest/clitest.go
 // New creates a CLI instance with a configuration pointed to a
 // temporary testing directory.
 funcNew(t*testing.T,args...string) (*cobra.Command, config.Root) {
 cmd:=cli.Root()
 cmd:=cli.Root(cli.AGPL())
 dir:=t.TempDir()
 root:=config.Root(dir)
 cmd.SetArgs(append([]string{"--global-config",dir},args...))
diff --git a/cli/root.go b/cli/root.go
 "github.com/coder/coder/cli/cliflag"
 "github.com/coder/coder/cli/cliui"
 "github.com/coder/coder/cli/config"
 "github.com/coder/coder/coderd"
 "github.com/coder/coder/codersdk"
 )

 cobra.AddTemplateFuncs(templateFunctions)
 }

 funcRoot()*cobra.Command {
 funcCore() []*cobra.Command {
 return []*cobra.Command{
 configSSH(),
 create(),
 deleteWorkspace(),
 dotfiles(),
 gitssh(),
 list(),
 login(),
 logout(),
 parameters(),
 portForward(),
 publickey(),
 resetPassword(),
 schedules(),
 show(),
 ssh(),
 start(),
 state(),
 stop(),
 templates(),
 update(),
 users(),
 versionCmd(),
 wireguardPortForward(),
 workspaceAgent(),
 features(),
 }
 }

 funcAGPL() []*cobra.Command {
 all:=append(Core(),Server(coderd.New))
 returnall
 }

 funcRoot(subcommands []*cobra.Command)*cobra.Command {
 cmd:=&cobra.Command{
 Use:"coder",
 SilenceErrors:true,
 ),
 }

 cmd.AddCommand(
 configSSH(),
 create(),
 deleteWorkspace(),
 dotfiles(),
 gitssh(),
 list(),
 login(),
 logout(),
 parameters(),
 portForward(),
 publickey(),
 resetPassword(),
 schedules(),
 server(),
 show(),
 ssh(),
 start(),
 state(),
 stop(),
 templates(),
 update(),
 users(),
 versionCmd(),
 wireguardPortForward(),
 workspaceAgent(),
 features(),
 )
 cmd.AddCommand(subcommands...)

 cmd.SetUsageTemplate(usageTemplate())

diff --git a/cli/server.go b/cli/server.go
 )

 // nolint:gocyclo
 funcserver() *cobra.Command {
 funcServer(newAPI func(*coderd.Options) *coderd.API) *cobra.Command {
 var (
 accessURL             string
 address               string
 ), promAddress, "prometheus")()
 }

 coderAPI :=coderd.New(options)
 coderAPI :=newAPI(options)
 defer coderAPI.Close()

 client := codersdk.New(localURL)
 // nolint: revive
 func printLogo(cmd *cobra.Command, spooky bool) {
 if spooky {
 _, _ = fmt.Fprintf(cmd.OutOrStdout(), `▄████▄   ▒█████  ▓█████▄ ▓█████  ██▀███
 _, _ = fmt.Fprintf(cmd.OutOrStdout(), `▄████▄   ▒█████  ▓█████▄ ▓█████  ██▀███
 ▒██▀ ▀█  ▒██▒  ██▒▒██▀ ██▌▓█   ▀ ▓██ ▒ ██▒
 ▒▓█    ▄ ▒██░  ██▒░██   █▌▒███   ▓██ ░▄█ ▒
 ▒▓▓▄ ▄██▒▒██   ██░░▓█▄   ▌▒▓█  ▄ ▒██▀▀█▄
 ▒▓▓▄ ▄██▒▒██   ██░░▓█▄   ▌▒▓█  ▄ ▒██▀▀█▄
 ▒ ▓███▀ ░░ ████▓▒░░▒████▓ ░▒████▒░██▓ ▒██▒
 ░ ░▒ ▒  ░░ ▒░▒░▒░  ▒▒▓  ▒ ░░ ▒░ ░░ ▒▓ ░▒▓░
  ░  ▒     ░ ▒ ▒░  ░ ▒  ▒  ░ ░  ░  ░▒ ░ ▒░
 ░        ░ ░ ░ ▒   ░ ░  ░    ░     ░░   ░
 ░ ░          ░ ░     ░       ░  ░   ░
 ░                  ░
 ░        ░ ░ ░ ▒   ░ ░  ░    ░     ░░   ░
 ░ ░          ░ ░     ░       ░  ░   ░
 ░                  ░
 `)
 return
 }
diff --git a/cmd/coder/main.go b/cmd/coder/main.go
 funcmain() {
 rand.Seed(time.Now().UnixMicro())

 cmd,err:=cli.Root().ExecuteC()
 cmd,err:=cli.Root(cli.AGPL()).ExecuteC()
 iferr!=nil {
 iferrors.Is(err,cliui.Canceled) {
 os.Exit(1)
diff --git a/coderd/authorize.go b/coderd/authorize.go
 return objects, nil
 }

 type HTTPAuthorizer struct {
 Authorizer rbac.Authorizer
 Logger     slog.Logger
 }

 // Authorize will return false if the user is not authorized to do the action.
 // This function will log appropriately, but the caller must return an
 // error to the api client.
 //return
 //}
 func (api *API) Authorize(r *http.Request, action rbac.Action, object rbac.Objecter) bool {
 return api.httpAuth.Authorize(r, action, object)
 }

 // Authorize will return false if the user is not authorized to do the action.
 // This function will log appropriately, but the caller must return an
 // error to the api client.
 // Eg:
 //if !h.Authorize(...) {
 //httpapi.Forbidden(rw)
 //return
 //}
 func (h *HTTPAuthorizer) Authorize(r *http.Request, action rbac.Action, object rbac.Objecter) bool {
 roles := httpmw.AuthorizationUserRoles(r)
 err :=api.Authorizer.ByRoleName(r.Context(), roles.ID.String(), roles.Roles, action, object.RBACObject())
 err :=h.Authorizer.ByRoleName(r.Context(), roles.ID.String(), roles.Roles, action, object.RBACObject())
 if err != nil {
 // Log the errors for debugging
 internalError := new(rbac.UnauthorizedError)
 logger :=api.Logger
 logger :=h.Logger
 if xerrors.As(err, internalError) {
 logger =api.Logger.With(slog.F("internal", internalError.Internal()))
 logger =h.Logger.With(slog.F("internal", internalError.Internal()))
 }
 // Log information for debugging. This will be very helpful
 // in the early days
diff --git a/coderd/coderd.go b/coderd/coderd.go
 Telemetry            telemetry.Reporter
 TURNServer*turnconn.Server
 TracerProvider*sdktrace.TracerProvider
 LicenseHandler       http.Handler
 }

 // New constructs a Coder API handler.
 ifoptions.PrometheusRegistry==nil {
 options.PrometheusRegistry=prometheus.NewRegistry()
 }
 ifoptions.LicenseHandler==nil {
 options.LicenseHandler=licenses()
 }

 siteCacheDir:=options.CacheDir
 ifsiteCacheDir!="" {
 Options:options,
 Handler:r,
 siteHandler:site.Handler(site.FS(),binFS),
 httpAuth:&HTTPAuthorizer{
 Authorizer:options.Authorizer,
 Logger:options.Logger,
 },
 }
 api.workspaceAgentCache=wsconncache.New(api.dialWorkspaceAgent,0)
 oauthConfigs:=&httpmw.OAuth2Configs{
 r.Use(apiKeyMiddleware)
 r.Get("/",entitlements)
 })
 r.Route("/licenses",func(r chi.Router) {
 r.Use(apiKeyMiddleware)
 r.Mount("/",options.LicenseHandler)
 })
 })

 r.NotFound(compressHandler(http.HandlerFunc(api.siteHandler.ServeHTTP)).ServeHTTP)
 websocketWaitMutex  sync.Mutex
 websocketWaitGroup  sync.WaitGroup
 workspaceAgentCache*wsconncache.Cache
 httpAuth*HTTPAuthorizer
 }

 // Close waits for all WebSocket connections to drain before returning.
diff --git a/coderd/coderdtest/coderdtest.go b/coderd/coderdtest/coderdtest.go

 // IncludeProvisionerD when true means to start an in-memory provisionerD
 IncludeProvisionerDbool
 APIBuilderfunc(*coderd.Options)*coderd.API
 }

 // New constructs a codersdk client connected to an in-memory API instance.
 close(options.AutobuildStats)
 })
 }
 ifoptions.APIBuilder==nil {
 options.APIBuilder=coderd.New
 }

 // This can be hotswapped for a live database instance.
 db:=databasefake.New()
 })

 // We set the handler after server creation for the access URL.
 coderAPI:=coderd.New(&coderd.Options{
 coderAPI:=options.APIBuilder(&coderd.Options{
 AgentConnectionUpdateFrequency:150*time.Millisecond,
 // Force a long disconnection timeout to ensure
 // agents are not marked as disconnected during slow tests.
diff --git a/coderd/database/databasefake/databasefake.go b/coderd/database/databasefake/databasefake.go
 workspaceBuilds:make([]database.WorkspaceBuild,0),
 workspaceApps:make([]database.WorkspaceApp,0),
 workspaces:make([]database.Workspace,0),
 licenses:make([]database.License,0),
 },
 }
 }
 workspaceBuilds                []database.WorkspaceBuild
 workspaceApps                  []database.WorkspaceApp
 workspaces                     []database.Workspace
 licenses                       []database.License

 deploymentIDstring
 deploymentIDstring
 lastLicenseIDint32
 }

 // InTx doesn't rollback data properly for in-memory yet.
 returnq.deploymentID,nil
 }

 func (q*fakeQuerier)InsertLicense(
 _ context.Context,arg database.InsertLicenseParams) (database.License,error) {
 q.mutex.RLock()
 deferq.mutex.RUnlock()

 l:= database.License{
 ID:q.lastLicenseID+1,
 UploadedAt:arg.UploadedAt,
 JWT:arg.JWT,
 Exp:arg.Exp,
 }
 q.lastLicenseID=l.ID
 q.licenses=append(q.licenses,l)
 returnl,nil
 }

 func (q*fakeQuerier)GetUserLinkByLinkedID(_ context.Context,idstring) (database.UserLink,error) {
 q.mutex.RLock()
 deferq.mutex.RUnlock()
diff --git a/coderd/database/dump.sql b/coderd/database/dump.sql
diff --git a/coderd/database/migrations/000037_jwt_licenses.down.sql b/coderd/database/migrations/000037_jwt_licenses.down.sql
 -- Valid licenses don't fit into old format, so delete all data
 DELETEFROM licenses;
 ALTERTABLE licenses DROP COLUMN jwt;
 ALTERTABLE licenses RENAME COLUMN uploaded_at to created_at;
 ALTERTABLE licenses ADD COLUMN license jsonbNOT NULL;
 ALTERTABLE licenses DROP COLUMN exp;

diff --git a/coderd/database/migrations/000037_jwt_licenses.up.sql b/coderd/database/migrations/000037_jwt_licenses.up.sql
 -- No valid licenses should exist, but to be sure, drop all rows
 DELETEFROM licenses;
 ALTERTABLE licenses DROP COLUMN license;
 ALTERTABLE licenses RENAME COLUMN created_at to uploaded_at;
 ALTERTABLE licenses ADD COLUMN jwttextNOT NULL;
 -- prevent adding the same license more than once
 ALTERTABLE licenses ADDCONSTRAINT licenses_jwt_key UNIQUE (jwt);
 ALTERTABLE licenses ADD COLUMN exptimestamp with time zoneNOT NULL;
 COMMENT ON COLUMN licenses.exp IS'exp tracks the claim of the same name in the JWT, and we include it here so that we can easily query for licenses that have not yet expired.';

diff --git a/coderd/database/models.go b/coderd/database/models.go
diff --git a/coderd/database/querier.go b/coderd/database/querier.go
Original file line number	Diff line number	Diff line change
Expand Up		@@ -21,7 +21,7 @@ import (
		// New creates a CLI instance with a configuration pointed to a
		// temporary testing directory.
		funcNew(ttesting.T,args...string) (cobra.Command, config.Root) {
		cmd:=cli.Root()
		cmd:=cli.Root(cli.AGPL())
		dir:=t.TempDir()
		root:=config.Root(dir)
		cmd.SetArgs(append([]string{"--global-config",dir},args...))
Expand Down
Original file line number	Diff line number	Diff line change
Expand Up		@@ -20,6 +20,7 @@ import (
		"github.com/coder/coder/cli/cliflag"
		"github.com/coder/coder/cli/cliui"
		"github.com/coder/coder/cli/config"
		"github.com/coder/coder/coderd"
		"github.com/coder/coder/codersdk"
		)

Expand DownExpand Up		@@ -58,7 +59,42 @@ func init() {
		cobra.AddTemplateFuncs(templateFunctions)
		}

		funcRoot()*cobra.Command {
		funcCore() []*cobra.Command {
		return []*cobra.Command{
		configSSH(),
		create(),
		deleteWorkspace(),
		dotfiles(),
		gitssh(),
		list(),
		login(),
		logout(),
		parameters(),
		portForward(),
		publickey(),
		resetPassword(),
		schedules(),
		show(),
		ssh(),
		start(),
		state(),
		stop(),
		templates(),
		update(),
		users(),
		versionCmd(),
		wireguardPortForward(),
		workspaceAgent(),
		features(),
		}
		}

		funcAGPL() []*cobra.Command {
		all:=append(Core(),Server(coderd.New))
		returnall
		}

		funcRoot(subcommands []cobra.Command)cobra.Command {
		cmd:=&cobra.Command{
		Use:"coder",
		SilenceErrors:true,
Expand DownExpand Up		@@ -109,34 +145,7 @@ func Root() *cobra.Command {
		),
		}

		cmd.AddCommand(
		configSSH(),
		create(),
		deleteWorkspace(),
		dotfiles(),
		gitssh(),
		list(),
		login(),
		logout(),
		parameters(),
		portForward(),
		publickey(),
		resetPassword(),
		schedules(),
		server(),
		show(),
		ssh(),
		start(),
		state(),
		stop(),
		templates(),
		update(),
		users(),
		versionCmd(),
		wireguardPortForward(),
		workspaceAgent(),
		features(),
		)
		cmd.AddCommand(subcommands...)

		cmd.SetUsageTemplate(usageTemplate())

Expand Down
Original file line number	Diff line number	Diff line change
Expand Up		@@ -68,7 +68,7 @@ import (
		)

		// nolint:gocyclo
		funcserver() *cobra.Command {
		funcServer(newAPI func(coderd.Options) coderd.API) *cobra.Command {
		var (
		accessURL string
		address string
Expand DownExpand Up		@@ -434,7 +434,7 @@ func server() *cobra.Command {
		), promAddress, "prometheus")()
		}

		coderAPI :=coderd.New(options)
		coderAPI :=newAPI(options)
		defer coderAPI.Close()

		client := codersdk.New(localURL)
Expand DownExpand Up		@@ -885,16 +885,16 @@ func newProvisionerDaemon(ctx context.Context, coderAPI *coderd.API,
		// nolint: revive
		func printLogo(cmd *cobra.Command, spooky bool) {
		if spooky {
		_, _ = fmt.Fprintf(cmd.OutOrStdout(), `▄████▄ ▒█████ ▓█████▄ ▓█████ ██▀███
		_, _ = fmt.Fprintf(cmd.OutOrStdout(), `▄████▄ ▒█████ ▓█████▄ ▓█████ ██▀███
		▒██▀ ▀█ ▒██▒ ██▒▒██▀ ██▌▓█ ▀ ▓██ ▒ ██▒
		▒▓█ ▄ ▒██░ ██▒░██ █▌▒███ ▓██ ░▄█ ▒
		▒▓▓▄ ▄██▒▒██ ██░░▓█▄ ▌▒▓█ ▄ ▒██▀▀█▄
		▒▓▓▄ ▄██▒▒██ ██░░▓█▄ ▌▒▓█ ▄ ▒██▀▀█▄
		▒ ▓███▀ ░░ ████▓▒░░▒████▓ ░▒████▒░██▓ ▒██▒
		░ ░▒ ▒ ░░ ▒░▒░▒░ ▒▒▓ ▒ ░░ ▒░ ░░ ▒▓ ░▒▓░
		░ ▒ ░ ▒ ▒░ ░ ▒ ▒ ░ ░ ░ ░▒ ░ ▒░
		░ ░ ░ ░ ▒ ░ ░ ░ ░ ░░ ░
		░ ░ ░ ░ ░ ░ ░ ░
		░ ░
		░ ░ ░ ░ ▒ ░ ░ ░ ░ ░░ ░
		░ ░ ░ ░ ░ ░ ░ ░
		░ ░
		`)
		return
		}
Expand Down
Original file line number	Diff line number	Diff line change
Expand Up		@@ -15,7 +15,7 @@ import (
		funcmain() {
		rand.Seed(time.Now().UnixMicro())

		cmd,err:=cli.Root().ExecuteC()
		cmd,err:=cli.Root(cli.AGPL()).ExecuteC()
		iferr!=nil {
		iferrors.Is(err,cliui.Canceled) {
		os.Exit(1)
Expand Down
Original file line number	Diff line number	Diff line change
Expand Up		@@ -27,6 +27,11 @@ func AuthorizeFilter[O rbac.Objecter](api API, r http.Request, action rbac.Act
		return objects, nil
		}

		type HTTPAuthorizer struct {
		Authorizer rbac.Authorizer
		Logger slog.Logger
spikecurtis marked this conversation as resolved. Show resolvedHide resolved
		}

		// Authorize will return false if the user is not authorized to do the action.
		// This function will log appropriately, but the caller must return an
		// error to the api client.
Expand All		@@ -36,14 +41,26 @@ func AuthorizeFilter[O rbac.Objecter](api API, r http.Request, action rbac.Act
		//return
		//}
		func (api API) Authorize(r http.Request, action rbac.Action, object rbac.Objecter) bool {
		return api.httpAuth.Authorize(r, action, object)
		}

		// Authorize will return false if the user is not authorized to do the action.
		// This function will log appropriately, but the caller must return an
		// error to the api client.
		// Eg:
		//if !h.Authorize(...) {
		//httpapi.Forbidden(rw)
		//return
		//}
		func (h HTTPAuthorizer) Authorize(r http.Request, action rbac.Action, object rbac.Objecter) bool {
		roles := httpmw.AuthorizationUserRoles(r)
		err :=api.Authorizer.ByRoleName(r.Context(), roles.ID.String(), roles.Roles, action, object.RBACObject())
		err :=h.Authorizer.ByRoleName(r.Context(), roles.ID.String(), roles.Roles, action, object.RBACObject())
		if err != nil {
		// Log the errors for debugging
		internalError := new(rbac.UnauthorizedError)
		logger :=api.Logger
		logger :=h.Logger
		if xerrors.As(err, internalError) {
		logger =api.Logger.With(slog.F("internal", internalError.Internal()))
		logger =h.Logger.With(slog.F("internal", internalError.Internal()))
		}
		// Log information for debugging. This will be very helpful
		// in the early days
Expand Down
Original file line number	Diff line number	Diff line change
Expand Up		@@ -66,6 +66,7 @@ type Options struct {
		Telemetry telemetry.Reporter
		TURNServer*turnconn.Server
		TracerProvider*sdktrace.TracerProvider
		LicenseHandler http.Handler
		}

		// New constructs a Coder API handler.
Expand All		@@ -92,6 +93,9 @@ func New(options Options) API {
		ifoptions.PrometheusRegistry==nil {
		options.PrometheusRegistry=prometheus.NewRegistry()
		}
		ifoptions.LicenseHandler==nil {
		options.LicenseHandler=licenses()
		}

		siteCacheDir:=options.CacheDir
		ifsiteCacheDir!="" {
Expand All		@@ -107,6 +111,10 @@ func New(options Options) API {
		Options:options,
		Handler:r,
		siteHandler:site.Handler(site.FS(),binFS),
		httpAuth:&HTTPAuthorizer{
		Authorizer:options.Authorizer,
		Logger:options.Logger,
		},
		}
		api.workspaceAgentCache=wsconncache.New(api.dialWorkspaceAgent,0)
		oauthConfigs:=&httpmw.OAuth2Configs{
Expand DownExpand Up		@@ -395,6 +403,10 @@ func New(options Options) API {
		r.Use(apiKeyMiddleware)
		r.Get("/",entitlements)
		})
		r.Route("/licenses",func(r chi.Router) {
		r.Use(apiKeyMiddleware)
		r.Mount("/",options.LicenseHandler)
spikecurtis marked this conversation as resolved. Show resolvedHide resolved
		})
		})

		r.NotFound(compressHandler(http.HandlerFunc(api.siteHandler.ServeHTTP)).ServeHTTP)
Expand All		@@ -409,6 +421,7 @@ type API struct {
		websocketWaitMutex sync.Mutex
		websocketWaitGroup sync.WaitGroup
		workspaceAgentCache*wsconncache.Cache
		httpAuth*HTTPAuthorizer
		}

		// Close waits for all WebSocket connections to drain before returning.
Expand Down
Original file line number	Diff line number	Diff line change
Expand Up		@@ -73,6 +73,7 @@ type Options struct {

		// IncludeProvisionerD when true means to start an in-memory provisionerD
		IncludeProvisionerDbool
		APIBuilderfunc(coderd.Options)coderd.API
kylecarbs marked this conversation as resolved. Show resolvedHide resolved
		}

		// New constructs a codersdk client connected to an in-memory API instance.
Expand DownExpand Up		@@ -122,6 +123,9 @@ func newWithCloser(t testing.T, options Options) (*codersdk.Client, io.Closer)
		close(options.AutobuildStats)
		})
		}
		ifoptions.APIBuilder==nil {
		options.APIBuilder=coderd.New
		}

		// This can be hotswapped for a live database instance.
		db:=databasefake.New()
Expand DownExpand Up		@@ -177,7 +181,7 @@ func newWithCloser(t testing.T, options Options) (*codersdk.Client, io.Closer)
		})

		// We set the handler after server creation for the access URL.
		coderAPI:=coderd.New(&coderd.Options{
		coderAPI:=options.APIBuilder(&coderd.Options{
		AgentConnectionUpdateFrequency:150*time.Millisecond,
		// Force a long disconnection timeout to ensure
		// agents are not marked as disconnected during slow tests.
Expand Down
Original file line number	Diff line number	Diff line change
Expand Up		@@ -42,6 +42,7 @@ func New() database.Store {
		workspaceBuilds:make([]database.WorkspaceBuild,0),
		workspaceApps:make([]database.WorkspaceApp,0),
		workspaces:make([]database.Workspace,0),
		licenses:make([]database.License,0),
		},
		}
		}
Expand DownExpand Up		@@ -92,8 +93,10 @@ type data struct {
		workspaceBuilds []database.WorkspaceBuild
		workspaceApps []database.WorkspaceApp
		workspaces []database.Workspace
		licenses []database.License

		deploymentIDstring
		deploymentIDstring
		lastLicenseIDint32
		}

		// InTx doesn't rollback data properly for in-memory yet.
Expand DownExpand Up		@@ -2277,6 +2280,22 @@ func (q *fakeQuerier) GetDeploymentID(_ context.Context) (string, error) {
		returnq.deploymentID,nil
		}

		func (q*fakeQuerier)InsertLicense(
		_ context.Context,arg database.InsertLicenseParams) (database.License,error) {
		q.mutex.RLock()
		deferq.mutex.RUnlock()

		l:= database.License{
		ID:q.lastLicenseID+1,
		UploadedAt:arg.UploadedAt,
		JWT:arg.JWT,
		Exp:arg.Exp,
		}
		q.lastLicenseID=l.ID
		q.licenses=append(q.licenses,l)
		returnl,nil
		}

		func (q*fakeQuerier)GetUserLinkByLinkedID(_ context.Context,idstring) (database.UserLink,error) {
		q.mutex.RLock()
		deferq.mutex.RUnlock()
Expand Down
Original file line number	Diff line number	Diff line change
		@@ -0,0 +1,7 @@
		-- Valid licenses don't fit into old format, so delete all data
		DELETEFROM licenses;
		ALTERTABLE licenses DROP COLUMN jwt;
		ALTERTABLE licenses RENAME COLUMN uploaded_at to created_at;
		ALTERTABLE licenses ADD COLUMN license jsonbNOT NULL;
		ALTERTABLE licenses DROP COLUMN exp;
Original file line number	Diff line number	Diff line change
		@@ -0,0 +1,10 @@
		-- No valid licenses should exist, but to be sure, drop all rows
		DELETEFROM licenses;
		ALTERTABLE licenses DROP COLUMN license;
		ALTERTABLE licenses RENAME COLUMN created_at to uploaded_at;
		ALTERTABLE licenses ADD COLUMN jwttextNOT NULL;
Copy link Member kylecarbsAug 21, 2022 Choose a reason for hiding this comment The reason will be displayed to describe this comment to others.Learn more. In`sqlc.go` you can add a rename for this column so the output is`JWT` instead of`Jwt`.
		-- prevent adding the same license more than once
		ALTERTABLE licenses ADDCONSTRAINT licenses_jwt_key UNIQUE (jwt);
		ALTERTABLE licenses ADD COLUMN exptimestamp with time zoneNOT NULL;
		COMMENT ON COLUMN licenses.exp IS'exp tracks the claim of the same name in the JWT, and we include it here so that we can easily query for licenses that have not yet expired.';