fix: remove context.Background references

Author: ddebko

internal/auth/ldap/repository_auth_method_create.go

@@ -62,7 +62,7 @@ func (r *Repository) CreateAuthMethod(ctx context.Context, am *AuthMethod, opt .
 		return nil, errors.Wrap(ctx, err, op)
 	}
 
-	dbWrapper, err := r.kms.GetWrapper(context.Background(), am.ScopeId, kms.KeyPurposeDatabase)
+	dbWrapper, err := r.kms.GetWrapper(ctx, am.ScopeId, kms.KeyPurposeDatabase)
 	if err != nil {
 		return nil, errors.Wrap(ctx, err, op, errors.WithMsg("unable to get database wrapper"))
 	}

internal/auth/oidc/repository_auth_method_create.go

@@ -61,7 +61,7 @@ func (r *Repository) CreateAuthMethod(ctx context.Context, am *AuthMethod, opt .
 		return nil, errors.Wrap(ctx, err, op, errors.WithMsg("unable to get oplog wrapper"))
 	}
 
-	databaseWrapper, err := r.kms.GetWrapper(context.Background(), am.ScopeId, kms.KeyPurposeDatabase)
+	databaseWrapper, err := r.kms.GetWrapper(ctx, am.ScopeId, kms.KeyPurposeDatabase)
 	if err != nil {
 		return nil, errors.Wrap(ctx, err, op, errors.WithMsg("unable to get database wrapper"))
 	}

internal/credential/vault/jobs.go

@@ -264,7 +264,7 @@ func nextRenewal(ctx context.Context, j scheduler.Job) (time.Duration, error) {
 		return 0, errors.New(ctx, errors.Unknown, op, "unknown job")
 	}
 
-	rows, err := r.Query(context.Background(), query, nil)
+	rows, err := r.Query(ctx, query, nil)
 	if err != nil {
 		return 0, errors.Wrap(ctx, err, op)
 	}

internal/credential/vault/vault_token.go

@@ -75,7 +75,7 @@ func newToken(ctx context.Context, storeId string, token TokenSecret, accessor [
 	accessorCopy := make([]byte, len(accessor))
 	copy(accessorCopy, accessor)
 
-	hmac, err := crypto.HmacSha256WithPrk(context.Background(), tokenCopy, accessorCopy)
+	hmac, err := crypto.HmacSha256WithPrk(ctx, tokenCopy, accessorCopy)
 	if err != nil {
 		return nil, errors.Wrap(ctx, err, op, errors.WithCode(errors.Encrypt))
 	}

internal/daemon/controller/handler.go

@@ -686,7 +686,7 @@ func wrapHandlerWithCallbackInterceptor(h http.Handler, c *Controller) http.Hand
 
 				if strings.HasSuffix(req.URL.Path, "oidc:authenticate") {
 					if s, ok := values["state"].(string); ok {
-						stateWrapper, err := oidc.UnwrapMessage(context.Background(), s)
+						stateWrapper, err := oidc.UnwrapMessage(ctx, s)
 						if err != nil {
 							event.WriteError(ctx, op, err, event.WithInfoMsg("error marshaling state"))
 							w.WriteHeader(http.StatusInternalServerError)

internal/host/plugin/job_set_sync.go

@@ -148,7 +148,7 @@ func nextSync(ctx context.Context, j scheduler.Job) (time.Duration, error) {
 		return 0, errors.New(ctx, errors.Unknown, op, "unknown job")
 	}
 
-	rows, err := r.Query(context.Background(), query, []any{setSyncJobRunInterval})
+	rows, err := r.Query(ctx, query, []any{setSyncJobRunInterval})
 	if err != nil {
 		return 0, errors.Wrap(ctx, err, op)
 	}

internal/iam/repository_user.go

@@ -234,7 +234,7 @@ func (r *Repository) LookupUserWithLogin(ctx context.Context, accountId string,
 
 	acct := allocAccount()
 	acct.PublicId = accountId
-	err = r.reader.LookupByPublicId(context.Background(), &acct)
+	err = r.reader.LookupByPublicId(ctx, &acct)
 	if err != nil {
 		return nil, errors.Wrap(ctx, err, op, errors.WithMsg(fmt.Sprintf("unable to lookup account %s", accountId)))
 	}
@@ -329,7 +329,7 @@ func (r *Repository) allowUserAutoVivify(ctx context.Context, acct *authAccount)
 	}
 	acctScope := AllocScope()
 	acctScope.PublicId = acct.ScopeId
-	err := r.reader.LookupByPublicId(context.Background(), &acctScope)
+	err := r.reader.LookupByPublicId(ctx, &acctScope)
 	if err != nil {
 		return false, errors.Wrap(ctx, err, op, errors.WithMsg(fmt.Sprintf("unable to lookup account's scope %s", acct.ScopeId)))
 	}
@@ -733,7 +733,7 @@ func dissociateUserFromAccounts(ctx context.Context, repoKms *kms.Kms, reader db
 	for _, accountId := range accountIds {
 		acct := allocAccount()
 		acct.PublicId = accountId
-		err := reader.LookupByPublicId(context.Background(), &acct)
+		err := reader.LookupByPublicId(ctx, &acct)
 		if err != nil {
 			return errors.Wrap(ctx, err, op, errors.WithMsg(fmt.Sprintf("unable to lookup account %s", accountId)))
 		}

internal/oplog/writer.go

@@ -25,7 +25,7 @@ func (w *Writer) hasTable(ctx context.Context, tableName string) (bool, error) {
 	}
 	var count int64
 	rw := dbw.New(w.DB)
-	rows, err := rw.Query(context.Background(), "select count(*) from information_schema.tables where table_name = ? and table_type = ?", []any{tableName, "BASE TABLE"})
+	rows, err := rw.Query(ctx, "select count(*) from information_schema.tables where table_name = ? and table_type = ?", []any{tableName, "BASE TABLE"})
 	if err != nil {
 		return false, errors.Wrap(ctx, err, op)
 	}

internal/server/repository_worker.go

@@ -642,7 +642,7 @@ func (r *Repository) CreateWorker(ctx context.Context, worker *Worker, opt ...Op
 
 	var workerAuthRepo *WorkerAuthRepositoryStorage
 
-	databaseWrapper, err := r.kms.GetWrapper(context.Background(), worker.ScopeId, kms.KeyPurposeDatabase)
+	databaseWrapper, err := r.kms.GetWrapper(ctx, worker.ScopeId, kms.KeyPurposeDatabase)
 	if err != nil {
 		return nil, errors.Wrap(ctx, err, op, errors.WithMsg("unable to get database wrapper"))
 	}