diff --git a/go.mod b/go.mod index a8c16f36..adee00e0 100755 --- a/go.mod +++ b/go.mod @@ -11,7 +11,7 @@ require ( github.com/google/uuid v1.6.0 github.com/hashicorp/go-hclog v1.6.3 github.com/nats-io/nats.go v1.36.0 - github.com/opengovern/og-util v1.1.8 + github.com/opengovern/og-util v1.1.9 github.com/opengovern/opencomply v0.475.2 github.com/shurcooL/githubv4 v0.0.0-20240727222349-48295856cce7 github.com/spf13/cobra v1.8.1 diff --git a/go.sum b/go.sum index 0dc600ef..5e082c33 100644 --- a/go.sum +++ b/go.sum @@ -727,6 +727,8 @@ github.com/olekukonko/tablewriter v0.0.5 h1:P2Ga83D34wi1o9J6Wh1mRuqd4mF/x/lgBS7N github.com/olekukonko/tablewriter v0.0.5/go.mod h1:hPp6KlRPjbx+hW8ykQs1w3UBbZlj6HuIJcUGPhkA7kY= github.com/opengovern/og-util v1.1.8 h1:Ij/sG074H6KtmkPuaNj1XjiwZvTp3DplFA/MLUzHBK4= github.com/opengovern/og-util v1.1.8/go.mod h1:dyn8rhmxq59o1jnbgGfmcUvW7iB/eN6OxoTUUx6jEHA= +github.com/opengovern/og-util v1.1.9 h1:Pswy4yOEcUS9FZW/3ThTBNNtRdyhhGdW9oj/GJ5WpwY= +github.com/opengovern/og-util v1.1.9/go.mod h1:dyn8rhmxq59o1jnbgGfmcUvW7iB/eN6OxoTUUx6jEHA= github.com/opengovern/opencomply v0.475.2 h1:JHs12+mhJb9HzFZYMLLgw079PRa+qLKntugvwWiCVL0= github.com/opengovern/opencomply v0.475.2/go.mod h1:FsJTfdLz+DDRAzW2/KyCFRxVxM89jMysP7ZfQjaS8+A= github.com/opensearch-project/opensearch-go/v2 v2.3.0 h1:nQIEMr+A92CkhHrZgUhcfsrZjibvB3APXf2a1VwCmMQ= diff --git a/pkg/sdk/es/resources_clients.go b/pkg/sdk/es/resources_clients.go index 51b9ea96..d81fce67 100644 --- a/pkg/sdk/es/resources_clients.go +++ b/pkg/sdk/es/resources_clients.go @@ -122,9 +122,9 @@ func ListArtifact(ctx context.Context, d *plugin.QueryData, _ *plugin.HydrateDat plugin.Logger(ctx).Error("ListArtifact NewSelfClientCached", "error", err) return nil, err } - accountId, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyAccountID) + integrationID, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyIntegrationID) if err != nil { - plugin.Logger(ctx).Error("ListArtifact GetConfigTableValueOrNil for OpenGovernanceConfigKeyAccountID", "error", err) + plugin.Logger(ctx).Error("ListArtifact GetConfigTableValueOrNil for OpenGovernanceConfigKeyIntegrationID", "error", err) return nil, err } encodedResourceCollectionFilters, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyResourceCollectionFilters) @@ -138,7 +138,7 @@ func ListArtifact(ctx context.Context, d *plugin.QueryData, _ *plugin.HydrateDat return nil, err } - paginator, err := k.NewArtifactPaginator(essdk.BuildFilter(ctx, d.QueryContext, listArtifactFilters, "github", accountId, encodedResourceCollectionFilters, clientType), d.QueryContext.Limit) + paginator, err := k.NewArtifactPaginator(essdk.BuildFilter(ctx, d.QueryContext, listArtifactFilters, integrationID, encodedResourceCollectionFilters, clientType), d.QueryContext.Limit) if err != nil { plugin.Logger(ctx).Error("ListArtifact NewArtifactPaginator", "error", err) return nil, err @@ -189,7 +189,7 @@ func GetArtifact(ctx context.Context, d *plugin.QueryData, _ *plugin.HydrateData if err != nil { return nil, err } - accountId, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyAccountID) + integrationID, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyIntegrationID) if err != nil { return nil, err } @@ -203,7 +203,7 @@ func GetArtifact(ctx context.Context, d *plugin.QueryData, _ *plugin.HydrateData } limit := int64(1) - paginator, err := k.NewArtifactPaginator(essdk.BuildFilter(ctx, d.QueryContext, getArtifactFilters, "github", accountId, encodedResourceCollectionFilters, clientType), &limit) + paginator, err := k.NewArtifactPaginator(essdk.BuildFilter(ctx, d.QueryContext, getArtifactFilters, integrationID, encodedResourceCollectionFilters, clientType), &limit) if err != nil { return nil, err } @@ -337,9 +337,9 @@ func ListRunner(ctx context.Context, d *plugin.QueryData, _ *plugin.HydrateData) plugin.Logger(ctx).Error("ListRunner NewSelfClientCached", "error", err) return nil, err } - accountId, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyAccountID) + integrationID, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyIntegrationID) if err != nil { - plugin.Logger(ctx).Error("ListRunner GetConfigTableValueOrNil for OpenGovernanceConfigKeyAccountID", "error", err) + plugin.Logger(ctx).Error("ListRunner GetConfigTableValueOrNil for OpenGovernanceConfigKeyIntegrationID", "error", err) return nil, err } encodedResourceCollectionFilters, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyResourceCollectionFilters) @@ -353,7 +353,7 @@ func ListRunner(ctx context.Context, d *plugin.QueryData, _ *plugin.HydrateData) return nil, err } - paginator, err := k.NewRunnerPaginator(essdk.BuildFilter(ctx, d.QueryContext, listRunnerFilters, "github", accountId, encodedResourceCollectionFilters, clientType), d.QueryContext.Limit) + paginator, err := k.NewRunnerPaginator(essdk.BuildFilter(ctx, d.QueryContext, listRunnerFilters, integrationID, encodedResourceCollectionFilters, clientType), d.QueryContext.Limit) if err != nil { plugin.Logger(ctx).Error("ListRunner NewRunnerPaginator", "error", err) return nil, err @@ -404,7 +404,7 @@ func GetRunner(ctx context.Context, d *plugin.QueryData, _ *plugin.HydrateData) if err != nil { return nil, err } - accountId, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyAccountID) + integrationID, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyIntegrationID) if err != nil { return nil, err } @@ -418,7 +418,7 @@ func GetRunner(ctx context.Context, d *plugin.QueryData, _ *plugin.HydrateData) } limit := int64(1) - paginator, err := k.NewRunnerPaginator(essdk.BuildFilter(ctx, d.QueryContext, getRunnerFilters, "github", accountId, encodedResourceCollectionFilters, clientType), &limit) + paginator, err := k.NewRunnerPaginator(essdk.BuildFilter(ctx, d.QueryContext, getRunnerFilters, integrationID, encodedResourceCollectionFilters, clientType), &limit) if err != nil { return nil, err } @@ -549,9 +549,9 @@ func ListSecret(ctx context.Context, d *plugin.QueryData, _ *plugin.HydrateData) plugin.Logger(ctx).Error("ListSecret NewSelfClientCached", "error", err) return nil, err } - accountId, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyAccountID) + integrationID, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyIntegrationID) if err != nil { - plugin.Logger(ctx).Error("ListSecret GetConfigTableValueOrNil for OpenGovernanceConfigKeyAccountID", "error", err) + plugin.Logger(ctx).Error("ListSecret GetConfigTableValueOrNil for OpenGovernanceConfigKeyIntegrationID", "error", err) return nil, err } encodedResourceCollectionFilters, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyResourceCollectionFilters) @@ -565,7 +565,7 @@ func ListSecret(ctx context.Context, d *plugin.QueryData, _ *plugin.HydrateData) return nil, err } - paginator, err := k.NewSecretPaginator(essdk.BuildFilter(ctx, d.QueryContext, listSecretFilters, "github", accountId, encodedResourceCollectionFilters, clientType), d.QueryContext.Limit) + paginator, err := k.NewSecretPaginator(essdk.BuildFilter(ctx, d.QueryContext, listSecretFilters, integrationID, encodedResourceCollectionFilters, clientType), d.QueryContext.Limit) if err != nil { plugin.Logger(ctx).Error("ListSecret NewSecretPaginator", "error", err) return nil, err @@ -613,7 +613,7 @@ func GetSecret(ctx context.Context, d *plugin.QueryData, _ *plugin.HydrateData) if err != nil { return nil, err } - accountId, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyAccountID) + integrationID, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyIntegrationID) if err != nil { return nil, err } @@ -627,7 +627,7 @@ func GetSecret(ctx context.Context, d *plugin.QueryData, _ *plugin.HydrateData) } limit := int64(1) - paginator, err := k.NewSecretPaginator(essdk.BuildFilter(ctx, d.QueryContext, getSecretFilters, "github", accountId, encodedResourceCollectionFilters, clientType), &limit) + paginator, err := k.NewSecretPaginator(essdk.BuildFilter(ctx, d.QueryContext, getSecretFilters, integrationID, encodedResourceCollectionFilters, clientType), &limit) if err != nil { return nil, err } @@ -758,9 +758,9 @@ func ListWorkflowRun(ctx context.Context, d *plugin.QueryData, _ *plugin.Hydrate plugin.Logger(ctx).Error("ListWorkflowRun NewSelfClientCached", "error", err) return nil, err } - accountId, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyAccountID) + integrationID, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyIntegrationID) if err != nil { - plugin.Logger(ctx).Error("ListWorkflowRun GetConfigTableValueOrNil for OpenGovernanceConfigKeyAccountID", "error", err) + plugin.Logger(ctx).Error("ListWorkflowRun GetConfigTableValueOrNil for OpenGovernanceConfigKeyIntegrationID", "error", err) return nil, err } encodedResourceCollectionFilters, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyResourceCollectionFilters) @@ -774,7 +774,7 @@ func ListWorkflowRun(ctx context.Context, d *plugin.QueryData, _ *plugin.Hydrate return nil, err } - paginator, err := k.NewWorkflowRunPaginator(essdk.BuildFilter(ctx, d.QueryContext, listWorkflowRunFilters, "github", accountId, encodedResourceCollectionFilters, clientType), d.QueryContext.Limit) + paginator, err := k.NewWorkflowRunPaginator(essdk.BuildFilter(ctx, d.QueryContext, listWorkflowRunFilters, integrationID, encodedResourceCollectionFilters, clientType), d.QueryContext.Limit) if err != nil { plugin.Logger(ctx).Error("ListWorkflowRun NewWorkflowRunPaginator", "error", err) return nil, err @@ -822,7 +822,7 @@ func GetWorkflowRun(ctx context.Context, d *plugin.QueryData, _ *plugin.HydrateD if err != nil { return nil, err } - accountId, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyAccountID) + integrationID, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyIntegrationID) if err != nil { return nil, err } @@ -836,7 +836,7 @@ func GetWorkflowRun(ctx context.Context, d *plugin.QueryData, _ *plugin.HydrateD } limit := int64(1) - paginator, err := k.NewWorkflowRunPaginator(essdk.BuildFilter(ctx, d.QueryContext, getWorkflowRunFilters, "github", accountId, encodedResourceCollectionFilters, clientType), &limit) + paginator, err := k.NewWorkflowRunPaginator(essdk.BuildFilter(ctx, d.QueryContext, getWorkflowRunFilters, integrationID, encodedResourceCollectionFilters, clientType), &limit) if err != nil { return nil, err } @@ -970,9 +970,9 @@ func ListBlob(ctx context.Context, d *plugin.QueryData, _ *plugin.HydrateData) ( plugin.Logger(ctx).Error("ListBlob NewSelfClientCached", "error", err) return nil, err } - accountId, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyAccountID) + integrationID, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyIntegrationID) if err != nil { - plugin.Logger(ctx).Error("ListBlob GetConfigTableValueOrNil for OpenGovernanceConfigKeyAccountID", "error", err) + plugin.Logger(ctx).Error("ListBlob GetConfigTableValueOrNil for OpenGovernanceConfigKeyIntegrationID", "error", err) return nil, err } encodedResourceCollectionFilters, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyResourceCollectionFilters) @@ -986,7 +986,7 @@ func ListBlob(ctx context.Context, d *plugin.QueryData, _ *plugin.HydrateData) ( return nil, err } - paginator, err := k.NewBlobPaginator(essdk.BuildFilter(ctx, d.QueryContext, listBlobFilters, "github", accountId, encodedResourceCollectionFilters, clientType), d.QueryContext.Limit) + paginator, err := k.NewBlobPaginator(essdk.BuildFilter(ctx, d.QueryContext, listBlobFilters, integrationID, encodedResourceCollectionFilters, clientType), d.QueryContext.Limit) if err != nil { plugin.Logger(ctx).Error("ListBlob NewBlobPaginator", "error", err) return nil, err @@ -1037,7 +1037,7 @@ func GetBlob(ctx context.Context, d *plugin.QueryData, _ *plugin.HydrateData) (i if err != nil { return nil, err } - accountId, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyAccountID) + integrationID, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyIntegrationID) if err != nil { return nil, err } @@ -1051,7 +1051,7 @@ func GetBlob(ctx context.Context, d *plugin.QueryData, _ *plugin.HydrateData) (i } limit := int64(1) - paginator, err := k.NewBlobPaginator(essdk.BuildFilter(ctx, d.QueryContext, getBlobFilters, "github", accountId, encodedResourceCollectionFilters, clientType), &limit) + paginator, err := k.NewBlobPaginator(essdk.BuildFilter(ctx, d.QueryContext, getBlobFilters, integrationID, encodedResourceCollectionFilters, clientType), &limit) if err != nil { return nil, err } @@ -1183,9 +1183,9 @@ func ListBranch(ctx context.Context, d *plugin.QueryData, _ *plugin.HydrateData) plugin.Logger(ctx).Error("ListBranch NewSelfClientCached", "error", err) return nil, err } - accountId, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyAccountID) + integrationID, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyIntegrationID) if err != nil { - plugin.Logger(ctx).Error("ListBranch GetConfigTableValueOrNil for OpenGovernanceConfigKeyAccountID", "error", err) + plugin.Logger(ctx).Error("ListBranch GetConfigTableValueOrNil for OpenGovernanceConfigKeyIntegrationID", "error", err) return nil, err } encodedResourceCollectionFilters, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyResourceCollectionFilters) @@ -1199,7 +1199,7 @@ func ListBranch(ctx context.Context, d *plugin.QueryData, _ *plugin.HydrateData) return nil, err } - paginator, err := k.NewBranchPaginator(essdk.BuildFilter(ctx, d.QueryContext, listBranchFilters, "github", accountId, encodedResourceCollectionFilters, clientType), d.QueryContext.Limit) + paginator, err := k.NewBranchPaginator(essdk.BuildFilter(ctx, d.QueryContext, listBranchFilters, integrationID, encodedResourceCollectionFilters, clientType), d.QueryContext.Limit) if err != nil { plugin.Logger(ctx).Error("ListBranch NewBranchPaginator", "error", err) return nil, err @@ -1248,7 +1248,7 @@ func GetBranch(ctx context.Context, d *plugin.QueryData, _ *plugin.HydrateData) if err != nil { return nil, err } - accountId, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyAccountID) + integrationID, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyIntegrationID) if err != nil { return nil, err } @@ -1262,7 +1262,7 @@ func GetBranch(ctx context.Context, d *plugin.QueryData, _ *plugin.HydrateData) } limit := int64(1) - paginator, err := k.NewBranchPaginator(essdk.BuildFilter(ctx, d.QueryContext, getBranchFilters, "github", accountId, encodedResourceCollectionFilters, clientType), &limit) + paginator, err := k.NewBranchPaginator(essdk.BuildFilter(ctx, d.QueryContext, getBranchFilters, integrationID, encodedResourceCollectionFilters, clientType), &limit) if err != nil { return nil, err } @@ -1392,9 +1392,9 @@ func ListBranchProtection(ctx context.Context, d *plugin.QueryData, _ *plugin.Hy plugin.Logger(ctx).Error("ListBranchProtection NewSelfClientCached", "error", err) return nil, err } - accountId, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyAccountID) + integrationID, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyIntegrationID) if err != nil { - plugin.Logger(ctx).Error("ListBranchProtection GetConfigTableValueOrNil for OpenGovernanceConfigKeyAccountID", "error", err) + plugin.Logger(ctx).Error("ListBranchProtection GetConfigTableValueOrNil for OpenGovernanceConfigKeyIntegrationID", "error", err) return nil, err } encodedResourceCollectionFilters, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyResourceCollectionFilters) @@ -1408,7 +1408,7 @@ func ListBranchProtection(ctx context.Context, d *plugin.QueryData, _ *plugin.Hy return nil, err } - paginator, err := k.NewBranchProtectionPaginator(essdk.BuildFilter(ctx, d.QueryContext, listBranchProtectionFilters, "github", accountId, encodedResourceCollectionFilters, clientType), d.QueryContext.Limit) + paginator, err := k.NewBranchProtectionPaginator(essdk.BuildFilter(ctx, d.QueryContext, listBranchProtectionFilters, integrationID, encodedResourceCollectionFilters, clientType), d.QueryContext.Limit) if err != nil { plugin.Logger(ctx).Error("ListBranchProtection NewBranchProtectionPaginator", "error", err) return nil, err @@ -1455,7 +1455,7 @@ func GetBranchProtection(ctx context.Context, d *plugin.QueryData, _ *plugin.Hyd if err != nil { return nil, err } - accountId, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyAccountID) + integrationID, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyIntegrationID) if err != nil { return nil, err } @@ -1469,7 +1469,7 @@ func GetBranchProtection(ctx context.Context, d *plugin.QueryData, _ *plugin.Hyd } limit := int64(1) - paginator, err := k.NewBranchProtectionPaginator(essdk.BuildFilter(ctx, d.QueryContext, getBranchProtectionFilters, "github", accountId, encodedResourceCollectionFilters, clientType), &limit) + paginator, err := k.NewBranchProtectionPaginator(essdk.BuildFilter(ctx, d.QueryContext, getBranchProtectionFilters, integrationID, encodedResourceCollectionFilters, clientType), &limit) if err != nil { return nil, err } @@ -1620,9 +1620,9 @@ func ListCommit(ctx context.Context, d *plugin.QueryData, _ *plugin.HydrateData) plugin.Logger(ctx).Error("ListCommit NewSelfClientCached", "error", err) return nil, err } - accountId, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyAccountID) + integrationID, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyIntegrationID) if err != nil { - plugin.Logger(ctx).Error("ListCommit GetConfigTableValueOrNil for OpenGovernanceConfigKeyAccountID", "error", err) + plugin.Logger(ctx).Error("ListCommit GetConfigTableValueOrNil for OpenGovernanceConfigKeyIntegrationID", "error", err) return nil, err } encodedResourceCollectionFilters, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyResourceCollectionFilters) @@ -1636,7 +1636,7 @@ func ListCommit(ctx context.Context, d *plugin.QueryData, _ *plugin.HydrateData) return nil, err } - paginator, err := k.NewCommitPaginator(essdk.BuildFilter(ctx, d.QueryContext, listCommitFilters, "github", accountId, encodedResourceCollectionFilters, clientType), d.QueryContext.Limit) + paginator, err := k.NewCommitPaginator(essdk.BuildFilter(ctx, d.QueryContext, listCommitFilters, integrationID, encodedResourceCollectionFilters, clientType), d.QueryContext.Limit) if err != nil { plugin.Logger(ctx).Error("ListCommit NewCommitPaginator", "error", err) return nil, err @@ -1704,7 +1704,7 @@ func GetCommit(ctx context.Context, d *plugin.QueryData, _ *plugin.HydrateData) if err != nil { return nil, err } - accountId, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyAccountID) + integrationID, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyIntegrationID) if err != nil { return nil, err } @@ -1718,7 +1718,7 @@ func GetCommit(ctx context.Context, d *plugin.QueryData, _ *plugin.HydrateData) } limit := int64(1) - paginator, err := k.NewCommitPaginator(essdk.BuildFilter(ctx, d.QueryContext, getCommitFilters, "github", accountId, encodedResourceCollectionFilters, clientType), &limit) + paginator, err := k.NewCommitPaginator(essdk.BuildFilter(ctx, d.QueryContext, getCommitFilters, integrationID, encodedResourceCollectionFilters, clientType), &limit) if err != nil { return nil, err } @@ -1853,9 +1853,9 @@ func ListCommunityProfile(ctx context.Context, d *plugin.QueryData, _ *plugin.Hy plugin.Logger(ctx).Error("ListCommunityProfile NewSelfClientCached", "error", err) return nil, err } - accountId, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyAccountID) + integrationID, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyIntegrationID) if err != nil { - plugin.Logger(ctx).Error("ListCommunityProfile GetConfigTableValueOrNil for OpenGovernanceConfigKeyAccountID", "error", err) + plugin.Logger(ctx).Error("ListCommunityProfile GetConfigTableValueOrNil for OpenGovernanceConfigKeyIntegrationID", "error", err) return nil, err } encodedResourceCollectionFilters, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyResourceCollectionFilters) @@ -1869,7 +1869,7 @@ func ListCommunityProfile(ctx context.Context, d *plugin.QueryData, _ *plugin.Hy return nil, err } - paginator, err := k.NewCommunityProfilePaginator(essdk.BuildFilter(ctx, d.QueryContext, listCommunityProfileFilters, "github", accountId, encodedResourceCollectionFilters, clientType), d.QueryContext.Limit) + paginator, err := k.NewCommunityProfilePaginator(essdk.BuildFilter(ctx, d.QueryContext, listCommunityProfileFilters, integrationID, encodedResourceCollectionFilters, clientType), d.QueryContext.Limit) if err != nil { plugin.Logger(ctx).Error("ListCommunityProfile NewCommunityProfilePaginator", "error", err) return nil, err @@ -1921,7 +1921,7 @@ func GetCommunityProfile(ctx context.Context, d *plugin.QueryData, _ *plugin.Hyd if err != nil { return nil, err } - accountId, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyAccountID) + integrationID, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyIntegrationID) if err != nil { return nil, err } @@ -1935,7 +1935,7 @@ func GetCommunityProfile(ctx context.Context, d *plugin.QueryData, _ *plugin.Hyd } limit := int64(1) - paginator, err := k.NewCommunityProfilePaginator(essdk.BuildFilter(ctx, d.QueryContext, getCommunityProfileFilters, "github", accountId, encodedResourceCollectionFilters, clientType), &limit) + paginator, err := k.NewCommunityProfilePaginator(essdk.BuildFilter(ctx, d.QueryContext, getCommunityProfileFilters, integrationID, encodedResourceCollectionFilters, clientType), &limit) if err != nil { return nil, err } @@ -2064,9 +2064,9 @@ func ListGitIgnore(ctx context.Context, d *plugin.QueryData, _ *plugin.HydrateDa plugin.Logger(ctx).Error("ListGitIgnore NewSelfClientCached", "error", err) return nil, err } - accountId, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyAccountID) + integrationID, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyIntegrationID) if err != nil { - plugin.Logger(ctx).Error("ListGitIgnore GetConfigTableValueOrNil for OpenGovernanceConfigKeyAccountID", "error", err) + plugin.Logger(ctx).Error("ListGitIgnore GetConfigTableValueOrNil for OpenGovernanceConfigKeyIntegrationID", "error", err) return nil, err } encodedResourceCollectionFilters, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyResourceCollectionFilters) @@ -2080,7 +2080,7 @@ func ListGitIgnore(ctx context.Context, d *plugin.QueryData, _ *plugin.HydrateDa return nil, err } - paginator, err := k.NewGitIgnorePaginator(essdk.BuildFilter(ctx, d.QueryContext, listGitIgnoreFilters, "github", accountId, encodedResourceCollectionFilters, clientType), d.QueryContext.Limit) + paginator, err := k.NewGitIgnorePaginator(essdk.BuildFilter(ctx, d.QueryContext, listGitIgnoreFilters, integrationID, encodedResourceCollectionFilters, clientType), d.QueryContext.Limit) if err != nil { plugin.Logger(ctx).Error("ListGitIgnore NewGitIgnorePaginator", "error", err) return nil, err @@ -2126,7 +2126,7 @@ func GetGitIgnore(ctx context.Context, d *plugin.QueryData, _ *plugin.HydrateDat if err != nil { return nil, err } - accountId, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyAccountID) + integrationID, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyIntegrationID) if err != nil { return nil, err } @@ -2140,7 +2140,7 @@ func GetGitIgnore(ctx context.Context, d *plugin.QueryData, _ *plugin.HydrateDat } limit := int64(1) - paginator, err := k.NewGitIgnorePaginator(essdk.BuildFilter(ctx, d.QueryContext, getGitIgnoreFilters, "github", accountId, encodedResourceCollectionFilters, clientType), &limit) + paginator, err := k.NewGitIgnorePaginator(essdk.BuildFilter(ctx, d.QueryContext, getGitIgnoreFilters, integrationID, encodedResourceCollectionFilters, clientType), &limit) if err != nil { return nil, err } @@ -2304,9 +2304,9 @@ func ListIssue(ctx context.Context, d *plugin.QueryData, _ *plugin.HydrateData) plugin.Logger(ctx).Error("ListIssue NewSelfClientCached", "error", err) return nil, err } - accountId, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyAccountID) + integrationID, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyIntegrationID) if err != nil { - plugin.Logger(ctx).Error("ListIssue GetConfigTableValueOrNil for OpenGovernanceConfigKeyAccountID", "error", err) + plugin.Logger(ctx).Error("ListIssue GetConfigTableValueOrNil for OpenGovernanceConfigKeyIntegrationID", "error", err) return nil, err } encodedResourceCollectionFilters, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyResourceCollectionFilters) @@ -2320,7 +2320,7 @@ func ListIssue(ctx context.Context, d *plugin.QueryData, _ *plugin.HydrateData) return nil, err } - paginator, err := k.NewIssuePaginator(essdk.BuildFilter(ctx, d.QueryContext, listIssueFilters, "github", accountId, encodedResourceCollectionFilters, clientType), d.QueryContext.Limit) + paginator, err := k.NewIssuePaginator(essdk.BuildFilter(ctx, d.QueryContext, listIssueFilters, integrationID, encodedResourceCollectionFilters, clientType), d.QueryContext.Limit) if err != nil { plugin.Logger(ctx).Error("ListIssue NewIssuePaginator", "error", err) return nil, err @@ -2401,7 +2401,7 @@ func GetIssue(ctx context.Context, d *plugin.QueryData, _ *plugin.HydrateData) ( if err != nil { return nil, err } - accountId, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyAccountID) + integrationID, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyIntegrationID) if err != nil { return nil, err } @@ -2415,7 +2415,7 @@ func GetIssue(ctx context.Context, d *plugin.QueryData, _ *plugin.HydrateData) ( } limit := int64(1) - paginator, err := k.NewIssuePaginator(essdk.BuildFilter(ctx, d.QueryContext, getIssueFilters, "github", accountId, encodedResourceCollectionFilters, clientType), &limit) + paginator, err := k.NewIssuePaginator(essdk.BuildFilter(ctx, d.QueryContext, getIssueFilters, integrationID, encodedResourceCollectionFilters, clientType), &limit) if err != nil { return nil, err } @@ -2555,9 +2555,9 @@ func ListLicense(ctx context.Context, d *plugin.QueryData, _ *plugin.HydrateData plugin.Logger(ctx).Error("ListLicense NewSelfClientCached", "error", err) return nil, err } - accountId, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyAccountID) + integrationID, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyIntegrationID) if err != nil { - plugin.Logger(ctx).Error("ListLicense GetConfigTableValueOrNil for OpenGovernanceConfigKeyAccountID", "error", err) + plugin.Logger(ctx).Error("ListLicense GetConfigTableValueOrNil for OpenGovernanceConfigKeyIntegrationID", "error", err) return nil, err } encodedResourceCollectionFilters, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyResourceCollectionFilters) @@ -2571,7 +2571,7 @@ func ListLicense(ctx context.Context, d *plugin.QueryData, _ *plugin.HydrateData return nil, err } - paginator, err := k.NewLicensePaginator(essdk.BuildFilter(ctx, d.QueryContext, listLicenseFilters, "github", accountId, encodedResourceCollectionFilters, clientType), d.QueryContext.Limit) + paginator, err := k.NewLicensePaginator(essdk.BuildFilter(ctx, d.QueryContext, listLicenseFilters, integrationID, encodedResourceCollectionFilters, clientType), d.QueryContext.Limit) if err != nil { plugin.Logger(ctx).Error("ListLicense NewLicensePaginator", "error", err) return nil, err @@ -2628,7 +2628,7 @@ func GetLicense(ctx context.Context, d *plugin.QueryData, _ *plugin.HydrateData) if err != nil { return nil, err } - accountId, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyAccountID) + integrationID, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyIntegrationID) if err != nil { return nil, err } @@ -2642,7 +2642,7 @@ func GetLicense(ctx context.Context, d *plugin.QueryData, _ *plugin.HydrateData) } limit := int64(1) - paginator, err := k.NewLicensePaginator(essdk.BuildFilter(ctx, d.QueryContext, getLicenseFilters, "github", accountId, encodedResourceCollectionFilters, clientType), &limit) + paginator, err := k.NewLicensePaginator(essdk.BuildFilter(ctx, d.QueryContext, getLicenseFilters, integrationID, encodedResourceCollectionFilters, clientType), &limit) if err != nil { return nil, err } @@ -2840,9 +2840,9 @@ func ListOrganization(ctx context.Context, d *plugin.QueryData, _ *plugin.Hydrat plugin.Logger(ctx).Error("ListOrganization NewSelfClientCached", "error", err) return nil, err } - accountId, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyAccountID) + integrationID, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyIntegrationID) if err != nil { - plugin.Logger(ctx).Error("ListOrganization GetConfigTableValueOrNil for OpenGovernanceConfigKeyAccountID", "error", err) + plugin.Logger(ctx).Error("ListOrganization GetConfigTableValueOrNil for OpenGovernanceConfigKeyIntegrationID", "error", err) return nil, err } encodedResourceCollectionFilters, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyResourceCollectionFilters) @@ -2856,7 +2856,7 @@ func ListOrganization(ctx context.Context, d *plugin.QueryData, _ *plugin.Hydrat return nil, err } - paginator, err := k.NewOrganizationPaginator(essdk.BuildFilter(ctx, d.QueryContext, listOrganizationFilters, "github", accountId, encodedResourceCollectionFilters, clientType), d.QueryContext.Limit) + paginator, err := k.NewOrganizationPaginator(essdk.BuildFilter(ctx, d.QueryContext, listOrganizationFilters, integrationID, encodedResourceCollectionFilters, clientType), d.QueryContext.Limit) if err != nil { plugin.Logger(ctx).Error("ListOrganization NewOrganizationPaginator", "error", err) return nil, err @@ -2971,7 +2971,7 @@ func GetOrganization(ctx context.Context, d *plugin.QueryData, _ *plugin.Hydrate if err != nil { return nil, err } - accountId, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyAccountID) + integrationID, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyIntegrationID) if err != nil { return nil, err } @@ -2985,7 +2985,7 @@ func GetOrganization(ctx context.Context, d *plugin.QueryData, _ *plugin.Hydrate } limit := int64(1) - paginator, err := k.NewOrganizationPaginator(essdk.BuildFilter(ctx, d.QueryContext, getOrganizationFilters, "github", accountId, encodedResourceCollectionFilters, clientType), &limit) + paginator, err := k.NewOrganizationPaginator(essdk.BuildFilter(ctx, d.QueryContext, getOrganizationFilters, integrationID, encodedResourceCollectionFilters, clientType), &limit) if err != nil { return nil, err } @@ -3117,9 +3117,9 @@ func ListOrgCollaborators(ctx context.Context, d *plugin.QueryData, _ *plugin.Hy plugin.Logger(ctx).Error("ListOrgCollaborators NewSelfClientCached", "error", err) return nil, err } - accountId, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyAccountID) + integrationID, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyIntegrationID) if err != nil { - plugin.Logger(ctx).Error("ListOrgCollaborators GetConfigTableValueOrNil for OpenGovernanceConfigKeyAccountID", "error", err) + plugin.Logger(ctx).Error("ListOrgCollaborators GetConfigTableValueOrNil for OpenGovernanceConfigKeyIntegrationID", "error", err) return nil, err } encodedResourceCollectionFilters, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyResourceCollectionFilters) @@ -3133,7 +3133,7 @@ func ListOrgCollaborators(ctx context.Context, d *plugin.QueryData, _ *plugin.Hy return nil, err } - paginator, err := k.NewOrgCollaboratorsPaginator(essdk.BuildFilter(ctx, d.QueryContext, listOrgCollaboratorsFilters, "github", accountId, encodedResourceCollectionFilters, clientType), d.QueryContext.Limit) + paginator, err := k.NewOrgCollaboratorsPaginator(essdk.BuildFilter(ctx, d.QueryContext, listOrgCollaboratorsFilters, integrationID, encodedResourceCollectionFilters, clientType), d.QueryContext.Limit) if err != nil { plugin.Logger(ctx).Error("ListOrgCollaborators NewOrgCollaboratorsPaginator", "error", err) return nil, err @@ -3182,7 +3182,7 @@ func GetOrgCollaborators(ctx context.Context, d *plugin.QueryData, _ *plugin.Hyd if err != nil { return nil, err } - accountId, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyAccountID) + integrationID, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyIntegrationID) if err != nil { return nil, err } @@ -3196,7 +3196,7 @@ func GetOrgCollaborators(ctx context.Context, d *plugin.QueryData, _ *plugin.Hyd } limit := int64(1) - paginator, err := k.NewOrgCollaboratorsPaginator(essdk.BuildFilter(ctx, d.QueryContext, getOrgCollaboratorsFilters, "github", accountId, encodedResourceCollectionFilters, clientType), &limit) + paginator, err := k.NewOrgCollaboratorsPaginator(essdk.BuildFilter(ctx, d.QueryContext, getOrgCollaboratorsFilters, integrationID, encodedResourceCollectionFilters, clientType), &limit) if err != nil { return nil, err } @@ -3341,9 +3341,9 @@ func ListOrgAlertDependabot(ctx context.Context, d *plugin.QueryData, _ *plugin. plugin.Logger(ctx).Error("ListOrgAlertDependabot NewSelfClientCached", "error", err) return nil, err } - accountId, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyAccountID) + integrationID, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyIntegrationID) if err != nil { - plugin.Logger(ctx).Error("ListOrgAlertDependabot GetConfigTableValueOrNil for OpenGovernanceConfigKeyAccountID", "error", err) + plugin.Logger(ctx).Error("ListOrgAlertDependabot GetConfigTableValueOrNil for OpenGovernanceConfigKeyIntegrationID", "error", err) return nil, err } encodedResourceCollectionFilters, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyResourceCollectionFilters) @@ -3357,7 +3357,7 @@ func ListOrgAlertDependabot(ctx context.Context, d *plugin.QueryData, _ *plugin. return nil, err } - paginator, err := k.NewOrgAlertDependabotPaginator(essdk.BuildFilter(ctx, d.QueryContext, listOrgAlertDependabotFilters, "github", accountId, encodedResourceCollectionFilters, clientType), d.QueryContext.Limit) + paginator, err := k.NewOrgAlertDependabotPaginator(essdk.BuildFilter(ctx, d.QueryContext, listOrgAlertDependabotFilters, integrationID, encodedResourceCollectionFilters, clientType), d.QueryContext.Limit) if err != nil { plugin.Logger(ctx).Error("ListOrgAlertDependabot NewOrgAlertDependabotPaginator", "error", err) return nil, err @@ -3419,7 +3419,7 @@ func GetOrgAlertDependabot(ctx context.Context, d *plugin.QueryData, _ *plugin.H if err != nil { return nil, err } - accountId, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyAccountID) + integrationID, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyIntegrationID) if err != nil { return nil, err } @@ -3433,7 +3433,7 @@ func GetOrgAlertDependabot(ctx context.Context, d *plugin.QueryData, _ *plugin.H } limit := int64(1) - paginator, err := k.NewOrgAlertDependabotPaginator(essdk.BuildFilter(ctx, d.QueryContext, getOrgAlertDependabotFilters, "github", accountId, encodedResourceCollectionFilters, clientType), &limit) + paginator, err := k.NewOrgAlertDependabotPaginator(essdk.BuildFilter(ctx, d.QueryContext, getOrgAlertDependabotFilters, integrationID, encodedResourceCollectionFilters, clientType), &limit) if err != nil { return nil, err } @@ -3567,9 +3567,9 @@ func ListOrgExternalIdentity(ctx context.Context, d *plugin.QueryData, _ *plugin plugin.Logger(ctx).Error("ListOrgExternalIdentity NewSelfClientCached", "error", err) return nil, err } - accountId, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyAccountID) + integrationID, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyIntegrationID) if err != nil { - plugin.Logger(ctx).Error("ListOrgExternalIdentity GetConfigTableValueOrNil for OpenGovernanceConfigKeyAccountID", "error", err) + plugin.Logger(ctx).Error("ListOrgExternalIdentity GetConfigTableValueOrNil for OpenGovernanceConfigKeyIntegrationID", "error", err) return nil, err } encodedResourceCollectionFilters, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyResourceCollectionFilters) @@ -3583,7 +3583,7 @@ func ListOrgExternalIdentity(ctx context.Context, d *plugin.QueryData, _ *plugin return nil, err } - paginator, err := k.NewOrgExternalIdentityPaginator(essdk.BuildFilter(ctx, d.QueryContext, listOrgExternalIdentityFilters, "github", accountId, encodedResourceCollectionFilters, clientType), d.QueryContext.Limit) + paginator, err := k.NewOrgExternalIdentityPaginator(essdk.BuildFilter(ctx, d.QueryContext, listOrgExternalIdentityFilters, integrationID, encodedResourceCollectionFilters, clientType), d.QueryContext.Limit) if err != nil { plugin.Logger(ctx).Error("ListOrgExternalIdentity NewOrgExternalIdentityPaginator", "error", err) return nil, err @@ -3634,7 +3634,7 @@ func GetOrgExternalIdentity(ctx context.Context, d *plugin.QueryData, _ *plugin. if err != nil { return nil, err } - accountId, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyAccountID) + integrationID, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyIntegrationID) if err != nil { return nil, err } @@ -3648,7 +3648,7 @@ func GetOrgExternalIdentity(ctx context.Context, d *plugin.QueryData, _ *plugin. } limit := int64(1) - paginator, err := k.NewOrgExternalIdentityPaginator(essdk.BuildFilter(ctx, d.QueryContext, getOrgExternalIdentityFilters, "github", accountId, encodedResourceCollectionFilters, clientType), &limit) + paginator, err := k.NewOrgExternalIdentityPaginator(essdk.BuildFilter(ctx, d.QueryContext, getOrgExternalIdentityFilters, integrationID, encodedResourceCollectionFilters, clientType), &limit) if err != nil { return nil, err } @@ -3778,9 +3778,9 @@ func ListOrgMembers(ctx context.Context, d *plugin.QueryData, _ *plugin.HydrateD plugin.Logger(ctx).Error("ListOrgMembers NewSelfClientCached", "error", err) return nil, err } - accountId, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyAccountID) + integrationID, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyIntegrationID) if err != nil { - plugin.Logger(ctx).Error("ListOrgMembers GetConfigTableValueOrNil for OpenGovernanceConfigKeyAccountID", "error", err) + plugin.Logger(ctx).Error("ListOrgMembers GetConfigTableValueOrNil for OpenGovernanceConfigKeyIntegrationID", "error", err) return nil, err } encodedResourceCollectionFilters, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyResourceCollectionFilters) @@ -3794,7 +3794,7 @@ func ListOrgMembers(ctx context.Context, d *plugin.QueryData, _ *plugin.HydrateD return nil, err } - paginator, err := k.NewOrgMembersPaginator(essdk.BuildFilter(ctx, d.QueryContext, listOrgMembersFilters, "github", accountId, encodedResourceCollectionFilters, clientType), d.QueryContext.Limit) + paginator, err := k.NewOrgMembersPaginator(essdk.BuildFilter(ctx, d.QueryContext, listOrgMembersFilters, integrationID, encodedResourceCollectionFilters, clientType), d.QueryContext.Limit) if err != nil { plugin.Logger(ctx).Error("ListOrgMembers NewOrgMembersPaginator", "error", err) return nil, err @@ -3841,7 +3841,7 @@ func GetOrgMembers(ctx context.Context, d *plugin.QueryData, _ *plugin.HydrateDa if err != nil { return nil, err } - accountId, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyAccountID) + integrationID, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyIntegrationID) if err != nil { return nil, err } @@ -3855,7 +3855,7 @@ func GetOrgMembers(ctx context.Context, d *plugin.QueryData, _ *plugin.HydrateDa } limit := int64(1) - paginator, err := k.NewOrgMembersPaginator(essdk.BuildFilter(ctx, d.QueryContext, getOrgMembersFilters, "github", accountId, encodedResourceCollectionFilters, clientType), &limit) + paginator, err := k.NewOrgMembersPaginator(essdk.BuildFilter(ctx, d.QueryContext, getOrgMembersFilters, integrationID, encodedResourceCollectionFilters, clientType), &limit) if err != nil { return nil, err } @@ -4044,9 +4044,9 @@ func ListPullRequest(ctx context.Context, d *plugin.QueryData, _ *plugin.Hydrate plugin.Logger(ctx).Error("ListPullRequest NewSelfClientCached", "error", err) return nil, err } - accountId, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyAccountID) + integrationID, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyIntegrationID) if err != nil { - plugin.Logger(ctx).Error("ListPullRequest GetConfigTableValueOrNil for OpenGovernanceConfigKeyAccountID", "error", err) + plugin.Logger(ctx).Error("ListPullRequest GetConfigTableValueOrNil for OpenGovernanceConfigKeyIntegrationID", "error", err) return nil, err } encodedResourceCollectionFilters, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyResourceCollectionFilters) @@ -4060,7 +4060,7 @@ func ListPullRequest(ctx context.Context, d *plugin.QueryData, _ *plugin.Hydrate return nil, err } - paginator, err := k.NewPullRequestPaginator(essdk.BuildFilter(ctx, d.QueryContext, listPullRequestFilters, "github", accountId, encodedResourceCollectionFilters, clientType), d.QueryContext.Limit) + paginator, err := k.NewPullRequestPaginator(essdk.BuildFilter(ctx, d.QueryContext, listPullRequestFilters, integrationID, encodedResourceCollectionFilters, clientType), d.QueryContext.Limit) if err != nil { plugin.Logger(ctx).Error("ListPullRequest NewPullRequestPaginator", "error", err) return nil, err @@ -4166,7 +4166,7 @@ func GetPullRequest(ctx context.Context, d *plugin.QueryData, _ *plugin.HydrateD if err != nil { return nil, err } - accountId, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyAccountID) + integrationID, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyIntegrationID) if err != nil { return nil, err } @@ -4180,7 +4180,7 @@ func GetPullRequest(ctx context.Context, d *plugin.QueryData, _ *plugin.HydrateD } limit := int64(1) - paginator, err := k.NewPullRequestPaginator(essdk.BuildFilter(ctx, d.QueryContext, getPullRequestFilters, "github", accountId, encodedResourceCollectionFilters, clientType), &limit) + paginator, err := k.NewPullRequestPaginator(essdk.BuildFilter(ctx, d.QueryContext, getPullRequestFilters, integrationID, encodedResourceCollectionFilters, clientType), &limit) if err != nil { return nil, err } @@ -4382,9 +4382,9 @@ func ListRepository(ctx context.Context, d *plugin.QueryData, _ *plugin.HydrateD plugin.Logger(ctx).Error("ListRepository NewSelfClientCached", "error", err) return nil, err } - accountId, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyAccountID) + integrationID, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyIntegrationID) if err != nil { - plugin.Logger(ctx).Error("ListRepository GetConfigTableValueOrNil for OpenGovernanceConfigKeyAccountID", "error", err) + plugin.Logger(ctx).Error("ListRepository GetConfigTableValueOrNil for OpenGovernanceConfigKeyIntegrationID", "error", err) return nil, err } encodedResourceCollectionFilters, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyResourceCollectionFilters) @@ -4398,7 +4398,7 @@ func ListRepository(ctx context.Context, d *plugin.QueryData, _ *plugin.HydrateD return nil, err } - paginator, err := k.NewRepositoryPaginator(essdk.BuildFilter(ctx, d.QueryContext, listRepositoryFilters, "github", accountId, encodedResourceCollectionFilters, clientType), d.QueryContext.Limit) + paginator, err := k.NewRepositoryPaginator(essdk.BuildFilter(ctx, d.QueryContext, listRepositoryFilters, integrationID, encodedResourceCollectionFilters, clientType), d.QueryContext.Limit) if err != nil { plugin.Logger(ctx).Error("ListRepository NewRepositoryPaginator", "error", err) return nil, err @@ -4517,7 +4517,7 @@ func GetRepository(ctx context.Context, d *plugin.QueryData, _ *plugin.HydrateDa if err != nil { return nil, err } - accountId, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyAccountID) + integrationID, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyIntegrationID) if err != nil { return nil, err } @@ -4531,7 +4531,7 @@ func GetRepository(ctx context.Context, d *plugin.QueryData, _ *plugin.HydrateDa } limit := int64(1) - paginator, err := k.NewRepositoryPaginator(essdk.BuildFilter(ctx, d.QueryContext, getRepositoryFilters, "github", accountId, encodedResourceCollectionFilters, clientType), &limit) + paginator, err := k.NewRepositoryPaginator(essdk.BuildFilter(ctx, d.QueryContext, getRepositoryFilters, integrationID, encodedResourceCollectionFilters, clientType), &limit) if err != nil { return nil, err } @@ -4675,9 +4675,9 @@ func ListRelease(ctx context.Context, d *plugin.QueryData, _ *plugin.HydrateData plugin.Logger(ctx).Error("ListRelease NewSelfClientCached", "error", err) return nil, err } - accountId, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyAccountID) + integrationID, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyIntegrationID) if err != nil { - plugin.Logger(ctx).Error("ListRelease GetConfigTableValueOrNil for OpenGovernanceConfigKeyAccountID", "error", err) + plugin.Logger(ctx).Error("ListRelease GetConfigTableValueOrNil for OpenGovernanceConfigKeyIntegrationID", "error", err) return nil, err } encodedResourceCollectionFilters, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyResourceCollectionFilters) @@ -4691,7 +4691,7 @@ func ListRelease(ctx context.Context, d *plugin.QueryData, _ *plugin.HydrateData return nil, err } - paginator, err := k.NewReleasePaginator(essdk.BuildFilter(ctx, d.QueryContext, listReleaseFilters, "github", accountId, encodedResourceCollectionFilters, clientType), d.QueryContext.Limit) + paginator, err := k.NewReleasePaginator(essdk.BuildFilter(ctx, d.QueryContext, listReleaseFilters, integrationID, encodedResourceCollectionFilters, clientType), d.QueryContext.Limit) if err != nil { plugin.Logger(ctx).Error("ListRelease NewReleasePaginator", "error", err) return nil, err @@ -4752,7 +4752,7 @@ func GetRelease(ctx context.Context, d *plugin.QueryData, _ *plugin.HydrateData) if err != nil { return nil, err } - accountId, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyAccountID) + integrationID, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyIntegrationID) if err != nil { return nil, err } @@ -4766,7 +4766,7 @@ func GetRelease(ctx context.Context, d *plugin.QueryData, _ *plugin.HydrateData) } limit := int64(1) - paginator, err := k.NewReleasePaginator(essdk.BuildFilter(ctx, d.QueryContext, getReleaseFilters, "github", accountId, encodedResourceCollectionFilters, clientType), &limit) + paginator, err := k.NewReleasePaginator(essdk.BuildFilter(ctx, d.QueryContext, getReleaseFilters, integrationID, encodedResourceCollectionFilters, clientType), &limit) if err != nil { return nil, err } @@ -4897,9 +4897,9 @@ func ListRepoCollaborators(ctx context.Context, d *plugin.QueryData, _ *plugin.H plugin.Logger(ctx).Error("ListRepoCollaborators NewSelfClientCached", "error", err) return nil, err } - accountId, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyAccountID) + integrationID, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyIntegrationID) if err != nil { - plugin.Logger(ctx).Error("ListRepoCollaborators GetConfigTableValueOrNil for OpenGovernanceConfigKeyAccountID", "error", err) + plugin.Logger(ctx).Error("ListRepoCollaborators GetConfigTableValueOrNil for OpenGovernanceConfigKeyIntegrationID", "error", err) return nil, err } encodedResourceCollectionFilters, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyResourceCollectionFilters) @@ -4913,7 +4913,7 @@ func ListRepoCollaborators(ctx context.Context, d *plugin.QueryData, _ *plugin.H return nil, err } - paginator, err := k.NewRepoCollaboratorsPaginator(essdk.BuildFilter(ctx, d.QueryContext, listRepoCollaboratorsFilters, "github", accountId, encodedResourceCollectionFilters, clientType), d.QueryContext.Limit) + paginator, err := k.NewRepoCollaboratorsPaginator(essdk.BuildFilter(ctx, d.QueryContext, listRepoCollaboratorsFilters, integrationID, encodedResourceCollectionFilters, clientType), d.QueryContext.Limit) if err != nil { plugin.Logger(ctx).Error("ListRepoCollaborators NewRepoCollaboratorsPaginator", "error", err) return nil, err @@ -4961,7 +4961,7 @@ func GetRepoCollaborators(ctx context.Context, d *plugin.QueryData, _ *plugin.Hy if err != nil { return nil, err } - accountId, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyAccountID) + integrationID, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyIntegrationID) if err != nil { return nil, err } @@ -4975,7 +4975,7 @@ func GetRepoCollaborators(ctx context.Context, d *plugin.QueryData, _ *plugin.Hy } limit := int64(1) - paginator, err := k.NewRepoCollaboratorsPaginator(essdk.BuildFilter(ctx, d.QueryContext, getRepoCollaboratorsFilters, "github", accountId, encodedResourceCollectionFilters, clientType), &limit) + paginator, err := k.NewRepoCollaboratorsPaginator(essdk.BuildFilter(ctx, d.QueryContext, getRepoCollaboratorsFilters, integrationID, encodedResourceCollectionFilters, clientType), &limit) if err != nil { return nil, err } @@ -5101,9 +5101,9 @@ func ListRepoAlertDependabot(ctx context.Context, d *plugin.QueryData, _ *plugin plugin.Logger(ctx).Error("ListRepoAlertDependabot NewSelfClientCached", "error", err) return nil, err } - accountId, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyAccountID) + integrationID, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyIntegrationID) if err != nil { - plugin.Logger(ctx).Error("ListRepoAlertDependabot GetConfigTableValueOrNil for OpenGovernanceConfigKeyAccountID", "error", err) + plugin.Logger(ctx).Error("ListRepoAlertDependabot GetConfigTableValueOrNil for OpenGovernanceConfigKeyIntegrationID", "error", err) return nil, err } encodedResourceCollectionFilters, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyResourceCollectionFilters) @@ -5117,7 +5117,7 @@ func ListRepoAlertDependabot(ctx context.Context, d *plugin.QueryData, _ *plugin return nil, err } - paginator, err := k.NewRepoAlertDependabotPaginator(essdk.BuildFilter(ctx, d.QueryContext, listRepoAlertDependabotFilters, "github", accountId, encodedResourceCollectionFilters, clientType), d.QueryContext.Limit) + paginator, err := k.NewRepoAlertDependabotPaginator(essdk.BuildFilter(ctx, d.QueryContext, listRepoAlertDependabotFilters, integrationID, encodedResourceCollectionFilters, clientType), d.QueryContext.Limit) if err != nil { plugin.Logger(ctx).Error("ListRepoAlertDependabot NewRepoAlertDependabotPaginator", "error", err) return nil, err @@ -5160,7 +5160,7 @@ func GetRepoAlertDependabot(ctx context.Context, d *plugin.QueryData, _ *plugin. if err != nil { return nil, err } - accountId, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyAccountID) + integrationID, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyIntegrationID) if err != nil { return nil, err } @@ -5174,7 +5174,7 @@ func GetRepoAlertDependabot(ctx context.Context, d *plugin.QueryData, _ *plugin. } limit := int64(1) - paginator, err := k.NewRepoAlertDependabotPaginator(essdk.BuildFilter(ctx, d.QueryContext, getRepoAlertDependabotFilters, "github", accountId, encodedResourceCollectionFilters, clientType), &limit) + paginator, err := k.NewRepoAlertDependabotPaginator(essdk.BuildFilter(ctx, d.QueryContext, getRepoAlertDependabotFilters, integrationID, encodedResourceCollectionFilters, clientType), &limit) if err != nil { return nil, err } @@ -5315,9 +5315,9 @@ func ListRepoDeployment(ctx context.Context, d *plugin.QueryData, _ *plugin.Hydr plugin.Logger(ctx).Error("ListRepoDeployment NewSelfClientCached", "error", err) return nil, err } - accountId, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyAccountID) + integrationID, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyIntegrationID) if err != nil { - plugin.Logger(ctx).Error("ListRepoDeployment GetConfigTableValueOrNil for OpenGovernanceConfigKeyAccountID", "error", err) + plugin.Logger(ctx).Error("ListRepoDeployment GetConfigTableValueOrNil for OpenGovernanceConfigKeyIntegrationID", "error", err) return nil, err } encodedResourceCollectionFilters, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyResourceCollectionFilters) @@ -5331,7 +5331,7 @@ func ListRepoDeployment(ctx context.Context, d *plugin.QueryData, _ *plugin.Hydr return nil, err } - paginator, err := k.NewRepoDeploymentPaginator(essdk.BuildFilter(ctx, d.QueryContext, listRepoDeploymentFilters, "github", accountId, encodedResourceCollectionFilters, clientType), d.QueryContext.Limit) + paginator, err := k.NewRepoDeploymentPaginator(essdk.BuildFilter(ctx, d.QueryContext, listRepoDeploymentFilters, integrationID, encodedResourceCollectionFilters, clientType), d.QueryContext.Limit) if err != nil { plugin.Logger(ctx).Error("ListRepoDeployment NewRepoDeploymentPaginator", "error", err) return nil, err @@ -5389,7 +5389,7 @@ func GetRepoDeployment(ctx context.Context, d *plugin.QueryData, _ *plugin.Hydra if err != nil { return nil, err } - accountId, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyAccountID) + integrationID, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyIntegrationID) if err != nil { return nil, err } @@ -5403,7 +5403,7 @@ func GetRepoDeployment(ctx context.Context, d *plugin.QueryData, _ *plugin.Hydra } limit := int64(1) - paginator, err := k.NewRepoDeploymentPaginator(essdk.BuildFilter(ctx, d.QueryContext, getRepoDeploymentFilters, "github", accountId, encodedResourceCollectionFilters, clientType), &limit) + paginator, err := k.NewRepoDeploymentPaginator(essdk.BuildFilter(ctx, d.QueryContext, getRepoDeploymentFilters, integrationID, encodedResourceCollectionFilters, clientType), &limit) if err != nil { return nil, err } @@ -5534,9 +5534,9 @@ func ListRepoEnvironment(ctx context.Context, d *plugin.QueryData, _ *plugin.Hyd plugin.Logger(ctx).Error("ListRepoEnvironment NewSelfClientCached", "error", err) return nil, err } - accountId, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyAccountID) + integrationID, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyIntegrationID) if err != nil { - plugin.Logger(ctx).Error("ListRepoEnvironment GetConfigTableValueOrNil for OpenGovernanceConfigKeyAccountID", "error", err) + plugin.Logger(ctx).Error("ListRepoEnvironment GetConfigTableValueOrNil for OpenGovernanceConfigKeyIntegrationID", "error", err) return nil, err } encodedResourceCollectionFilters, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyResourceCollectionFilters) @@ -5550,7 +5550,7 @@ func ListRepoEnvironment(ctx context.Context, d *plugin.QueryData, _ *plugin.Hyd return nil, err } - paginator, err := k.NewRepoEnvironmentPaginator(essdk.BuildFilter(ctx, d.QueryContext, listRepoEnvironmentFilters, "github", accountId, encodedResourceCollectionFilters, clientType), d.QueryContext.Limit) + paginator, err := k.NewRepoEnvironmentPaginator(essdk.BuildFilter(ctx, d.QueryContext, listRepoEnvironmentFilters, integrationID, encodedResourceCollectionFilters, clientType), d.QueryContext.Limit) if err != nil { plugin.Logger(ctx).Error("ListRepoEnvironment NewRepoEnvironmentPaginator", "error", err) return nil, err @@ -5598,7 +5598,7 @@ func GetRepoEnvironment(ctx context.Context, d *plugin.QueryData, _ *plugin.Hydr if err != nil { return nil, err } - accountId, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyAccountID) + integrationID, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyIntegrationID) if err != nil { return nil, err } @@ -5612,7 +5612,7 @@ func GetRepoEnvironment(ctx context.Context, d *plugin.QueryData, _ *plugin.Hydr } limit := int64(1) - paginator, err := k.NewRepoEnvironmentPaginator(essdk.BuildFilter(ctx, d.QueryContext, getRepoEnvironmentFilters, "github", accountId, encodedResourceCollectionFilters, clientType), &limit) + paginator, err := k.NewRepoEnvironmentPaginator(essdk.BuildFilter(ctx, d.QueryContext, getRepoEnvironmentFilters, integrationID, encodedResourceCollectionFilters, clientType), &limit) if err != nil { return nil, err } @@ -5747,9 +5747,9 @@ func ListRepoRuleSet(ctx context.Context, d *plugin.QueryData, _ *plugin.Hydrate plugin.Logger(ctx).Error("ListRepoRuleSet NewSelfClientCached", "error", err) return nil, err } - accountId, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyAccountID) + integrationID, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyIntegrationID) if err != nil { - plugin.Logger(ctx).Error("ListRepoRuleSet GetConfigTableValueOrNil for OpenGovernanceConfigKeyAccountID", "error", err) + plugin.Logger(ctx).Error("ListRepoRuleSet GetConfigTableValueOrNil for OpenGovernanceConfigKeyIntegrationID", "error", err) return nil, err } encodedResourceCollectionFilters, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyResourceCollectionFilters) @@ -5763,7 +5763,7 @@ func ListRepoRuleSet(ctx context.Context, d *plugin.QueryData, _ *plugin.Hydrate return nil, err } - paginator, err := k.NewRepoRuleSetPaginator(essdk.BuildFilter(ctx, d.QueryContext, listRepoRuleSetFilters, "github", accountId, encodedResourceCollectionFilters, clientType), d.QueryContext.Limit) + paginator, err := k.NewRepoRuleSetPaginator(essdk.BuildFilter(ctx, d.QueryContext, listRepoRuleSetFilters, integrationID, encodedResourceCollectionFilters, clientType), d.QueryContext.Limit) if err != nil { plugin.Logger(ctx).Error("ListRepoRuleSet NewRepoRuleSetPaginator", "error", err) return nil, err @@ -5815,7 +5815,7 @@ func GetRepoRuleSet(ctx context.Context, d *plugin.QueryData, _ *plugin.HydrateD if err != nil { return nil, err } - accountId, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyAccountID) + integrationID, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyIntegrationID) if err != nil { return nil, err } @@ -5829,7 +5829,7 @@ func GetRepoRuleSet(ctx context.Context, d *plugin.QueryData, _ *plugin.HydrateD } limit := int64(1) - paginator, err := k.NewRepoRuleSetPaginator(essdk.BuildFilter(ctx, d.QueryContext, getRepoRuleSetFilters, "github", accountId, encodedResourceCollectionFilters, clientType), &limit) + paginator, err := k.NewRepoRuleSetPaginator(essdk.BuildFilter(ctx, d.QueryContext, getRepoRuleSetFilters, integrationID, encodedResourceCollectionFilters, clientType), &limit) if err != nil { return nil, err } @@ -5965,9 +5965,9 @@ func ListRepoSBOM(ctx context.Context, d *plugin.QueryData, _ *plugin.HydrateDat plugin.Logger(ctx).Error("ListRepoSBOM NewSelfClientCached", "error", err) return nil, err } - accountId, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyAccountID) + integrationID, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyIntegrationID) if err != nil { - plugin.Logger(ctx).Error("ListRepoSBOM GetConfigTableValueOrNil for OpenGovernanceConfigKeyAccountID", "error", err) + plugin.Logger(ctx).Error("ListRepoSBOM GetConfigTableValueOrNil for OpenGovernanceConfigKeyIntegrationID", "error", err) return nil, err } encodedResourceCollectionFilters, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyResourceCollectionFilters) @@ -5981,7 +5981,7 @@ func ListRepoSBOM(ctx context.Context, d *plugin.QueryData, _ *plugin.HydrateDat return nil, err } - paginator, err := k.NewRepoSBOMPaginator(essdk.BuildFilter(ctx, d.QueryContext, listRepoSBOMFilters, "github", accountId, encodedResourceCollectionFilters, clientType), d.QueryContext.Limit) + paginator, err := k.NewRepoSBOMPaginator(essdk.BuildFilter(ctx, d.QueryContext, listRepoSBOMFilters, integrationID, encodedResourceCollectionFilters, clientType), d.QueryContext.Limit) if err != nil { plugin.Logger(ctx).Error("ListRepoSBOM NewRepoSBOMPaginator", "error", err) return nil, err @@ -6034,7 +6034,7 @@ func GetRepoSBOM(ctx context.Context, d *plugin.QueryData, _ *plugin.HydrateData if err != nil { return nil, err } - accountId, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyAccountID) + integrationID, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyIntegrationID) if err != nil { return nil, err } @@ -6048,7 +6048,7 @@ func GetRepoSBOM(ctx context.Context, d *plugin.QueryData, _ *plugin.HydrateData } limit := int64(1) - paginator, err := k.NewRepoSBOMPaginator(essdk.BuildFilter(ctx, d.QueryContext, getRepoSBOMFilters, "github", accountId, encodedResourceCollectionFilters, clientType), &limit) + paginator, err := k.NewRepoSBOMPaginator(essdk.BuildFilter(ctx, d.QueryContext, getRepoSBOMFilters, integrationID, encodedResourceCollectionFilters, clientType), &limit) if err != nil { return nil, err } @@ -6190,9 +6190,9 @@ func ListRepoVulnerabilityAlert(ctx context.Context, d *plugin.QueryData, _ *plu plugin.Logger(ctx).Error("ListRepoVulnerabilityAlert NewSelfClientCached", "error", err) return nil, err } - accountId, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyAccountID) + integrationID, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyIntegrationID) if err != nil { - plugin.Logger(ctx).Error("ListRepoVulnerabilityAlert GetConfigTableValueOrNil for OpenGovernanceConfigKeyAccountID", "error", err) + plugin.Logger(ctx).Error("ListRepoVulnerabilityAlert GetConfigTableValueOrNil for OpenGovernanceConfigKeyIntegrationID", "error", err) return nil, err } encodedResourceCollectionFilters, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyResourceCollectionFilters) @@ -6206,7 +6206,7 @@ func ListRepoVulnerabilityAlert(ctx context.Context, d *plugin.QueryData, _ *plu return nil, err } - paginator, err := k.NewRepoVulnerabilityAlertPaginator(essdk.BuildFilter(ctx, d.QueryContext, listRepoVulnerabilityAlertFilters, "github", accountId, encodedResourceCollectionFilters, clientType), d.QueryContext.Limit) + paginator, err := k.NewRepoVulnerabilityAlertPaginator(essdk.BuildFilter(ctx, d.QueryContext, listRepoVulnerabilityAlertFilters, integrationID, encodedResourceCollectionFilters, clientType), d.QueryContext.Limit) if err != nil { plugin.Logger(ctx).Error("ListRepoVulnerabilityAlert NewRepoVulnerabilityAlertPaginator", "error", err) return nil, err @@ -6265,7 +6265,7 @@ func GetRepoVulnerabilityAlert(ctx context.Context, d *plugin.QueryData, _ *plug if err != nil { return nil, err } - accountId, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyAccountID) + integrationID, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyIntegrationID) if err != nil { return nil, err } @@ -6279,7 +6279,7 @@ func GetRepoVulnerabilityAlert(ctx context.Context, d *plugin.QueryData, _ *plug } limit := int64(1) - paginator, err := k.NewRepoVulnerabilityAlertPaginator(essdk.BuildFilter(ctx, d.QueryContext, getRepoVulnerabilityAlertFilters, "github", accountId, encodedResourceCollectionFilters, clientType), &limit) + paginator, err := k.NewRepoVulnerabilityAlertPaginator(essdk.BuildFilter(ctx, d.QueryContext, getRepoVulnerabilityAlertFilters, integrationID, encodedResourceCollectionFilters, clientType), &limit) if err != nil { return nil, err } @@ -6409,9 +6409,9 @@ func ListStargazer(ctx context.Context, d *plugin.QueryData, _ *plugin.HydrateDa plugin.Logger(ctx).Error("ListStargazer NewSelfClientCached", "error", err) return nil, err } - accountId, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyAccountID) + integrationID, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyIntegrationID) if err != nil { - plugin.Logger(ctx).Error("ListStargazer GetConfigTableValueOrNil for OpenGovernanceConfigKeyAccountID", "error", err) + plugin.Logger(ctx).Error("ListStargazer GetConfigTableValueOrNil for OpenGovernanceConfigKeyIntegrationID", "error", err) return nil, err } encodedResourceCollectionFilters, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyResourceCollectionFilters) @@ -6425,7 +6425,7 @@ func ListStargazer(ctx context.Context, d *plugin.QueryData, _ *plugin.HydrateDa return nil, err } - paginator, err := k.NewStargazerPaginator(essdk.BuildFilter(ctx, d.QueryContext, listStargazerFilters, "github", accountId, encodedResourceCollectionFilters, clientType), d.QueryContext.Limit) + paginator, err := k.NewStargazerPaginator(essdk.BuildFilter(ctx, d.QueryContext, listStargazerFilters, integrationID, encodedResourceCollectionFilters, clientType), d.QueryContext.Limit) if err != nil { plugin.Logger(ctx).Error("ListStargazer NewStargazerPaginator", "error", err) return nil, err @@ -6472,7 +6472,7 @@ func GetStargazer(ctx context.Context, d *plugin.QueryData, _ *plugin.HydrateDat if err != nil { return nil, err } - accountId, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyAccountID) + integrationID, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyIntegrationID) if err != nil { return nil, err } @@ -6486,7 +6486,7 @@ func GetStargazer(ctx context.Context, d *plugin.QueryData, _ *plugin.HydrateDat } limit := int64(1) - paginator, err := k.NewStargazerPaginator(essdk.BuildFilter(ctx, d.QueryContext, getStargazerFilters, "github", accountId, encodedResourceCollectionFilters, clientType), &limit) + paginator, err := k.NewStargazerPaginator(essdk.BuildFilter(ctx, d.QueryContext, getStargazerFilters, integrationID, encodedResourceCollectionFilters, clientType), &limit) if err != nil { return nil, err } @@ -6619,9 +6619,9 @@ func ListTag(ctx context.Context, d *plugin.QueryData, _ *plugin.HydrateData) (i plugin.Logger(ctx).Error("ListTag NewSelfClientCached", "error", err) return nil, err } - accountId, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyAccountID) + integrationID, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyIntegrationID) if err != nil { - plugin.Logger(ctx).Error("ListTag GetConfigTableValueOrNil for OpenGovernanceConfigKeyAccountID", "error", err) + plugin.Logger(ctx).Error("ListTag GetConfigTableValueOrNil for OpenGovernanceConfigKeyIntegrationID", "error", err) return nil, err } encodedResourceCollectionFilters, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyResourceCollectionFilters) @@ -6635,7 +6635,7 @@ func ListTag(ctx context.Context, d *plugin.QueryData, _ *plugin.HydrateData) (i return nil, err } - paginator, err := k.NewTagPaginator(essdk.BuildFilter(ctx, d.QueryContext, listTagFilters, "github", accountId, encodedResourceCollectionFilters, clientType), d.QueryContext.Limit) + paginator, err := k.NewTagPaginator(essdk.BuildFilter(ctx, d.QueryContext, listTagFilters, integrationID, encodedResourceCollectionFilters, clientType), d.QueryContext.Limit) if err != nil { plugin.Logger(ctx).Error("ListTag NewTagPaginator", "error", err) return nil, err @@ -6685,7 +6685,7 @@ func GetTag(ctx context.Context, d *plugin.QueryData, _ *plugin.HydrateData) (in if err != nil { return nil, err } - accountId, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyAccountID) + integrationID, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyIntegrationID) if err != nil { return nil, err } @@ -6699,7 +6699,7 @@ func GetTag(ctx context.Context, d *plugin.QueryData, _ *plugin.HydrateData) (in } limit := int64(1) - paginator, err := k.NewTagPaginator(essdk.BuildFilter(ctx, d.QueryContext, getTagFilters, "github", accountId, encodedResourceCollectionFilters, clientType), &limit) + paginator, err := k.NewTagPaginator(essdk.BuildFilter(ctx, d.QueryContext, getTagFilters, integrationID, encodedResourceCollectionFilters, clientType), &limit) if err != nil { return nil, err } @@ -6853,9 +6853,9 @@ func ListTeam(ctx context.Context, d *plugin.QueryData, _ *plugin.HydrateData) ( plugin.Logger(ctx).Error("ListTeam NewSelfClientCached", "error", err) return nil, err } - accountId, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyAccountID) + integrationID, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyIntegrationID) if err != nil { - plugin.Logger(ctx).Error("ListTeam GetConfigTableValueOrNil for OpenGovernanceConfigKeyAccountID", "error", err) + plugin.Logger(ctx).Error("ListTeam GetConfigTableValueOrNil for OpenGovernanceConfigKeyIntegrationID", "error", err) return nil, err } encodedResourceCollectionFilters, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyResourceCollectionFilters) @@ -6869,7 +6869,7 @@ func ListTeam(ctx context.Context, d *plugin.QueryData, _ *plugin.HydrateData) ( return nil, err } - paginator, err := k.NewTeamPaginator(essdk.BuildFilter(ctx, d.QueryContext, listTeamFilters, "github", accountId, encodedResourceCollectionFilters, clientType), d.QueryContext.Limit) + paginator, err := k.NewTeamPaginator(essdk.BuildFilter(ctx, d.QueryContext, listTeamFilters, integrationID, encodedResourceCollectionFilters, clientType), d.QueryContext.Limit) if err != nil { plugin.Logger(ctx).Error("ListTeam NewTeamPaginator", "error", err) return nil, err @@ -6940,7 +6940,7 @@ func GetTeam(ctx context.Context, d *plugin.QueryData, _ *plugin.HydrateData) (i if err != nil { return nil, err } - accountId, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyAccountID) + integrationID, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyIntegrationID) if err != nil { return nil, err } @@ -6954,7 +6954,7 @@ func GetTeam(ctx context.Context, d *plugin.QueryData, _ *plugin.HydrateData) (i } limit := int64(1) - paginator, err := k.NewTeamPaginator(essdk.BuildFilter(ctx, d.QueryContext, getTeamFilters, "github", accountId, encodedResourceCollectionFilters, clientType), &limit) + paginator, err := k.NewTeamPaginator(essdk.BuildFilter(ctx, d.QueryContext, getTeamFilters, integrationID, encodedResourceCollectionFilters, clientType), &limit) if err != nil { return nil, err } @@ -7084,9 +7084,9 @@ func ListTeamMembers(ctx context.Context, d *plugin.QueryData, _ *plugin.Hydrate plugin.Logger(ctx).Error("ListTeamMembers NewSelfClientCached", "error", err) return nil, err } - accountId, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyAccountID) + integrationID, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyIntegrationID) if err != nil { - plugin.Logger(ctx).Error("ListTeamMembers GetConfigTableValueOrNil for OpenGovernanceConfigKeyAccountID", "error", err) + plugin.Logger(ctx).Error("ListTeamMembers GetConfigTableValueOrNil for OpenGovernanceConfigKeyIntegrationID", "error", err) return nil, err } encodedResourceCollectionFilters, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyResourceCollectionFilters) @@ -7100,7 +7100,7 @@ func ListTeamMembers(ctx context.Context, d *plugin.QueryData, _ *plugin.Hydrate return nil, err } - paginator, err := k.NewTeamMembersPaginator(essdk.BuildFilter(ctx, d.QueryContext, listTeamMembersFilters, "github", accountId, encodedResourceCollectionFilters, clientType), d.QueryContext.Limit) + paginator, err := k.NewTeamMembersPaginator(essdk.BuildFilter(ctx, d.QueryContext, listTeamMembersFilters, integrationID, encodedResourceCollectionFilters, clientType), d.QueryContext.Limit) if err != nil { plugin.Logger(ctx).Error("ListTeamMembers NewTeamMembersPaginator", "error", err) return nil, err @@ -7147,7 +7147,7 @@ func GetTeamMembers(ctx context.Context, d *plugin.QueryData, _ *plugin.HydrateD if err != nil { return nil, err } - accountId, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyAccountID) + integrationID, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyIntegrationID) if err != nil { return nil, err } @@ -7161,7 +7161,7 @@ func GetTeamMembers(ctx context.Context, d *plugin.QueryData, _ *plugin.HydrateD } limit := int64(1) - paginator, err := k.NewTeamMembersPaginator(essdk.BuildFilter(ctx, d.QueryContext, getTeamMembersFilters, "github", accountId, encodedResourceCollectionFilters, clientType), &limit) + paginator, err := k.NewTeamMembersPaginator(essdk.BuildFilter(ctx, d.QueryContext, getTeamMembersFilters, integrationID, encodedResourceCollectionFilters, clientType), &limit) if err != nil { return nil, err } @@ -7287,9 +7287,9 @@ func ListTeamRepository(ctx context.Context, d *plugin.QueryData, _ *plugin.Hydr plugin.Logger(ctx).Error("ListTeamRepository NewSelfClientCached", "error", err) return nil, err } - accountId, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyAccountID) + integrationID, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyIntegrationID) if err != nil { - plugin.Logger(ctx).Error("ListTeamRepository GetConfigTableValueOrNil for OpenGovernanceConfigKeyAccountID", "error", err) + plugin.Logger(ctx).Error("ListTeamRepository GetConfigTableValueOrNil for OpenGovernanceConfigKeyIntegrationID", "error", err) return nil, err } encodedResourceCollectionFilters, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyResourceCollectionFilters) @@ -7303,7 +7303,7 @@ func ListTeamRepository(ctx context.Context, d *plugin.QueryData, _ *plugin.Hydr return nil, err } - paginator, err := k.NewTeamRepositoryPaginator(essdk.BuildFilter(ctx, d.QueryContext, listTeamRepositoryFilters, "github", accountId, encodedResourceCollectionFilters, clientType), d.QueryContext.Limit) + paginator, err := k.NewTeamRepositoryPaginator(essdk.BuildFilter(ctx, d.QueryContext, listTeamRepositoryFilters, integrationID, encodedResourceCollectionFilters, clientType), d.QueryContext.Limit) if err != nil { plugin.Logger(ctx).Error("ListTeamRepository NewTeamRepositoryPaginator", "error", err) return nil, err @@ -7346,7 +7346,7 @@ func GetTeamRepository(ctx context.Context, d *plugin.QueryData, _ *plugin.Hydra if err != nil { return nil, err } - accountId, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyAccountID) + integrationID, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyIntegrationID) if err != nil { return nil, err } @@ -7360,7 +7360,7 @@ func GetTeamRepository(ctx context.Context, d *plugin.QueryData, _ *plugin.Hydra } limit := int64(1) - paginator, err := k.NewTeamRepositoryPaginator(essdk.BuildFilter(ctx, d.QueryContext, getTeamRepositoryFilters, "github", accountId, encodedResourceCollectionFilters, clientType), &limit) + paginator, err := k.NewTeamRepositoryPaginator(essdk.BuildFilter(ctx, d.QueryContext, getTeamRepositoryFilters, integrationID, encodedResourceCollectionFilters, clientType), &limit) if err != nil { return nil, err } @@ -7490,9 +7490,9 @@ func ListTrafficViewDaily(ctx context.Context, d *plugin.QueryData, _ *plugin.Hy plugin.Logger(ctx).Error("ListTrafficViewDaily NewSelfClientCached", "error", err) return nil, err } - accountId, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyAccountID) + integrationID, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyIntegrationID) if err != nil { - plugin.Logger(ctx).Error("ListTrafficViewDaily GetConfigTableValueOrNil for OpenGovernanceConfigKeyAccountID", "error", err) + plugin.Logger(ctx).Error("ListTrafficViewDaily GetConfigTableValueOrNil for OpenGovernanceConfigKeyIntegrationID", "error", err) return nil, err } encodedResourceCollectionFilters, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyResourceCollectionFilters) @@ -7506,7 +7506,7 @@ func ListTrafficViewDaily(ctx context.Context, d *plugin.QueryData, _ *plugin.Hy return nil, err } - paginator, err := k.NewTrafficViewDailyPaginator(essdk.BuildFilter(ctx, d.QueryContext, listTrafficViewDailyFilters, "github", accountId, encodedResourceCollectionFilters, clientType), d.QueryContext.Limit) + paginator, err := k.NewTrafficViewDailyPaginator(essdk.BuildFilter(ctx, d.QueryContext, listTrafficViewDailyFilters, integrationID, encodedResourceCollectionFilters, clientType), d.QueryContext.Limit) if err != nil { plugin.Logger(ctx).Error("ListTrafficViewDaily NewTrafficViewDailyPaginator", "error", err) return nil, err @@ -7553,7 +7553,7 @@ func GetTrafficViewDaily(ctx context.Context, d *plugin.QueryData, _ *plugin.Hyd if err != nil { return nil, err } - accountId, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyAccountID) + integrationID, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyIntegrationID) if err != nil { return nil, err } @@ -7567,7 +7567,7 @@ func GetTrafficViewDaily(ctx context.Context, d *plugin.QueryData, _ *plugin.Hyd } limit := int64(1) - paginator, err := k.NewTrafficViewDailyPaginator(essdk.BuildFilter(ctx, d.QueryContext, getTrafficViewDailyFilters, "github", accountId, encodedResourceCollectionFilters, clientType), &limit) + paginator, err := k.NewTrafficViewDailyPaginator(essdk.BuildFilter(ctx, d.QueryContext, getTrafficViewDailyFilters, integrationID, encodedResourceCollectionFilters, clientType), &limit) if err != nil { return nil, err } @@ -7697,9 +7697,9 @@ func ListTrafficViewWeekly(ctx context.Context, d *plugin.QueryData, _ *plugin.H plugin.Logger(ctx).Error("ListTrafficViewWeekly NewSelfClientCached", "error", err) return nil, err } - accountId, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyAccountID) + integrationID, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyIntegrationID) if err != nil { - plugin.Logger(ctx).Error("ListTrafficViewWeekly GetConfigTableValueOrNil for OpenGovernanceConfigKeyAccountID", "error", err) + plugin.Logger(ctx).Error("ListTrafficViewWeekly GetConfigTableValueOrNil for OpenGovernanceConfigKeyIntegrationID", "error", err) return nil, err } encodedResourceCollectionFilters, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyResourceCollectionFilters) @@ -7713,7 +7713,7 @@ func ListTrafficViewWeekly(ctx context.Context, d *plugin.QueryData, _ *plugin.H return nil, err } - paginator, err := k.NewTrafficViewWeeklyPaginator(essdk.BuildFilter(ctx, d.QueryContext, listTrafficViewWeeklyFilters, "github", accountId, encodedResourceCollectionFilters, clientType), d.QueryContext.Limit) + paginator, err := k.NewTrafficViewWeeklyPaginator(essdk.BuildFilter(ctx, d.QueryContext, listTrafficViewWeeklyFilters, integrationID, encodedResourceCollectionFilters, clientType), d.QueryContext.Limit) if err != nil { plugin.Logger(ctx).Error("ListTrafficViewWeekly NewTrafficViewWeeklyPaginator", "error", err) return nil, err @@ -7760,7 +7760,7 @@ func GetTrafficViewWeekly(ctx context.Context, d *plugin.QueryData, _ *plugin.Hy if err != nil { return nil, err } - accountId, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyAccountID) + integrationID, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyIntegrationID) if err != nil { return nil, err } @@ -7774,7 +7774,7 @@ func GetTrafficViewWeekly(ctx context.Context, d *plugin.QueryData, _ *plugin.Hy } limit := int64(1) - paginator, err := k.NewTrafficViewWeeklyPaginator(essdk.BuildFilter(ctx, d.QueryContext, getTrafficViewWeeklyFilters, "github", accountId, encodedResourceCollectionFilters, clientType), &limit) + paginator, err := k.NewTrafficViewWeeklyPaginator(essdk.BuildFilter(ctx, d.QueryContext, getTrafficViewWeeklyFilters, integrationID, encodedResourceCollectionFilters, clientType), &limit) if err != nil { return nil, err } @@ -7911,9 +7911,9 @@ func ListTree(ctx context.Context, d *plugin.QueryData, _ *plugin.HydrateData) ( plugin.Logger(ctx).Error("ListTree NewSelfClientCached", "error", err) return nil, err } - accountId, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyAccountID) + integrationID, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyIntegrationID) if err != nil { - plugin.Logger(ctx).Error("ListTree GetConfigTableValueOrNil for OpenGovernanceConfigKeyAccountID", "error", err) + plugin.Logger(ctx).Error("ListTree GetConfigTableValueOrNil for OpenGovernanceConfigKeyIntegrationID", "error", err) return nil, err } encodedResourceCollectionFilters, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyResourceCollectionFilters) @@ -7927,7 +7927,7 @@ func ListTree(ctx context.Context, d *plugin.QueryData, _ *plugin.HydrateData) ( return nil, err } - paginator, err := k.NewTreePaginator(essdk.BuildFilter(ctx, d.QueryContext, listTreeFilters, "github", accountId, encodedResourceCollectionFilters, clientType), d.QueryContext.Limit) + paginator, err := k.NewTreePaginator(essdk.BuildFilter(ctx, d.QueryContext, listTreeFilters, integrationID, encodedResourceCollectionFilters, clientType), d.QueryContext.Limit) if err != nil { plugin.Logger(ctx).Error("ListTree NewTreePaginator", "error", err) return nil, err @@ -7981,7 +7981,7 @@ func GetTree(ctx context.Context, d *plugin.QueryData, _ *plugin.HydrateData) (i if err != nil { return nil, err } - accountId, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyAccountID) + integrationID, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyIntegrationID) if err != nil { return nil, err } @@ -7995,7 +7995,7 @@ func GetTree(ctx context.Context, d *plugin.QueryData, _ *plugin.HydrateData) (i } limit := int64(1) - paginator, err := k.NewTreePaginator(essdk.BuildFilter(ctx, d.QueryContext, getTreeFilters, "github", accountId, encodedResourceCollectionFilters, clientType), &limit) + paginator, err := k.NewTreePaginator(essdk.BuildFilter(ctx, d.QueryContext, getTreeFilters, integrationID, encodedResourceCollectionFilters, clientType), &limit) if err != nil { return nil, err } @@ -8178,9 +8178,9 @@ func ListUser(ctx context.Context, d *plugin.QueryData, _ *plugin.HydrateData) ( plugin.Logger(ctx).Error("ListUser NewSelfClientCached", "error", err) return nil, err } - accountId, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyAccountID) + integrationID, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyIntegrationID) if err != nil { - plugin.Logger(ctx).Error("ListUser GetConfigTableValueOrNil for OpenGovernanceConfigKeyAccountID", "error", err) + plugin.Logger(ctx).Error("ListUser GetConfigTableValueOrNil for OpenGovernanceConfigKeyIntegrationID", "error", err) return nil, err } encodedResourceCollectionFilters, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyResourceCollectionFilters) @@ -8194,7 +8194,7 @@ func ListUser(ctx context.Context, d *plugin.QueryData, _ *plugin.HydrateData) ( return nil, err } - paginator, err := k.NewUserPaginator(essdk.BuildFilter(ctx, d.QueryContext, listUserFilters, "github", accountId, encodedResourceCollectionFilters, clientType), d.QueryContext.Limit) + paginator, err := k.NewUserPaginator(essdk.BuildFilter(ctx, d.QueryContext, listUserFilters, integrationID, encodedResourceCollectionFilters, clientType), d.QueryContext.Limit) if err != nil { plugin.Logger(ctx).Error("ListUser NewUserPaginator", "error", err) return nil, err @@ -8294,7 +8294,7 @@ func GetUser(ctx context.Context, d *plugin.QueryData, _ *plugin.HydrateData) (i if err != nil { return nil, err } - accountId, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyAccountID) + integrationID, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyIntegrationID) if err != nil { return nil, err } @@ -8308,7 +8308,7 @@ func GetUser(ctx context.Context, d *plugin.QueryData, _ *plugin.HydrateData) (i } limit := int64(1) - paginator, err := k.NewUserPaginator(essdk.BuildFilter(ctx, d.QueryContext, getUserFilters, "github", accountId, encodedResourceCollectionFilters, clientType), &limit) + paginator, err := k.NewUserPaginator(essdk.BuildFilter(ctx, d.QueryContext, getUserFilters, integrationID, encodedResourceCollectionFilters, clientType), &limit) if err != nil { return nil, err } @@ -8447,9 +8447,9 @@ func ListWorkflow(ctx context.Context, d *plugin.QueryData, _ *plugin.HydrateDat plugin.Logger(ctx).Error("ListWorkflow NewSelfClientCached", "error", err) return nil, err } - accountId, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyAccountID) + integrationID, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyIntegrationID) if err != nil { - plugin.Logger(ctx).Error("ListWorkflow GetConfigTableValueOrNil for OpenGovernanceConfigKeyAccountID", "error", err) + plugin.Logger(ctx).Error("ListWorkflow GetConfigTableValueOrNil for OpenGovernanceConfigKeyIntegrationID", "error", err) return nil, err } encodedResourceCollectionFilters, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyResourceCollectionFilters) @@ -8463,7 +8463,7 @@ func ListWorkflow(ctx context.Context, d *plugin.QueryData, _ *plugin.HydrateDat return nil, err } - paginator, err := k.NewWorkflowPaginator(essdk.BuildFilter(ctx, d.QueryContext, listWorkflowFilters, "github", accountId, encodedResourceCollectionFilters, clientType), d.QueryContext.Limit) + paginator, err := k.NewWorkflowPaginator(essdk.BuildFilter(ctx, d.QueryContext, listWorkflowFilters, integrationID, encodedResourceCollectionFilters, clientType), d.QueryContext.Limit) if err != nil { plugin.Logger(ctx).Error("ListWorkflow NewWorkflowPaginator", "error", err) return nil, err @@ -8519,7 +8519,7 @@ func GetWorkflow(ctx context.Context, d *plugin.QueryData, _ *plugin.HydrateData if err != nil { return nil, err } - accountId, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyAccountID) + integrationID, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyIntegrationID) if err != nil { return nil, err } @@ -8533,7 +8533,7 @@ func GetWorkflow(ctx context.Context, d *plugin.QueryData, _ *plugin.HydrateData } limit := int64(1) - paginator, err := k.NewWorkflowPaginator(essdk.BuildFilter(ctx, d.QueryContext, getWorkflowFilters, "github", accountId, encodedResourceCollectionFilters, clientType), &limit) + paginator, err := k.NewWorkflowPaginator(essdk.BuildFilter(ctx, d.QueryContext, getWorkflowFilters, integrationID, encodedResourceCollectionFilters, clientType), &limit) if err != nil { return nil, err } @@ -8667,9 +8667,9 @@ func ListCodeOwner(ctx context.Context, d *plugin.QueryData, _ *plugin.HydrateDa plugin.Logger(ctx).Error("ListCodeOwner NewSelfClientCached", "error", err) return nil, err } - accountId, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyAccountID) + integrationID, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyIntegrationID) if err != nil { - plugin.Logger(ctx).Error("ListCodeOwner GetConfigTableValueOrNil for OpenGovernanceConfigKeyAccountID", "error", err) + plugin.Logger(ctx).Error("ListCodeOwner GetConfigTableValueOrNil for OpenGovernanceConfigKeyIntegrationID", "error", err) return nil, err } encodedResourceCollectionFilters, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyResourceCollectionFilters) @@ -8683,7 +8683,7 @@ func ListCodeOwner(ctx context.Context, d *plugin.QueryData, _ *plugin.HydrateDa return nil, err } - paginator, err := k.NewCodeOwnerPaginator(essdk.BuildFilter(ctx, d.QueryContext, listCodeOwnerFilters, "github", accountId, encodedResourceCollectionFilters, clientType), d.QueryContext.Limit) + paginator, err := k.NewCodeOwnerPaginator(essdk.BuildFilter(ctx, d.QueryContext, listCodeOwnerFilters, integrationID, encodedResourceCollectionFilters, clientType), d.QueryContext.Limit) if err != nil { plugin.Logger(ctx).Error("ListCodeOwner NewCodeOwnerPaginator", "error", err) return nil, err @@ -8734,7 +8734,7 @@ func GetCodeOwner(ctx context.Context, d *plugin.QueryData, _ *plugin.HydrateDat if err != nil { return nil, err } - accountId, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyAccountID) + integrationID, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyIntegrationID) if err != nil { return nil, err } @@ -8748,7 +8748,7 @@ func GetCodeOwner(ctx context.Context, d *plugin.QueryData, _ *plugin.HydrateDat } limit := int64(1) - paginator, err := k.NewCodeOwnerPaginator(essdk.BuildFilter(ctx, d.QueryContext, getCodeOwnerFilters, "github", accountId, encodedResourceCollectionFilters, clientType), &limit) + paginator, err := k.NewCodeOwnerPaginator(essdk.BuildFilter(ctx, d.QueryContext, getCodeOwnerFilters, integrationID, encodedResourceCollectionFilters, clientType), &limit) if err != nil { return nil, err } diff --git a/pkg/sdk/runable/steampipe_es_client_generator/main.go b/pkg/sdk/runable/steampipe_es_client_generator/main.go index f30e1f12..0894c5eb 100755 --- a/pkg/sdk/runable/steampipe_es_client_generator/main.go +++ b/pkg/sdk/runable/steampipe_es_client_generator/main.go @@ -179,9 +179,9 @@ func List{{ .Name }}(ctx context.Context, d *plugin.QueryData, _ *plugin.Hydrate plugin.Logger(ctx).Error("List{{ .Name }} NewSelfClientCached", "error", err) return nil, err } - accountId, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyAccountID) + integrationID, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyIntegrationID) if err != nil { - plugin.Logger(ctx).Error("List{{ .Name }} GetConfigTableValueOrNil for OpenGovernanceConfigKeyAccountID", "error", err) + plugin.Logger(ctx).Error("List{{ .Name }} GetConfigTableValueOrNil for OpenGovernanceConfigKeyIntegrationID", "error", err) return nil, err } encodedResourceCollectionFilters, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyResourceCollectionFilters) @@ -195,7 +195,7 @@ func List{{ .Name }}(ctx context.Context, d *plugin.QueryData, _ *plugin.Hydrate return nil, err } - paginator, err := k.New{{ .Name }}Paginator(essdk.BuildFilter(ctx, d.QueryContext, list{{ .Name }}Filters, "{{ .IntegrationType }}", accountId, encodedResourceCollectionFilters, clientType), d.QueryContext.Limit) + paginator, err := k.New{{ .Name }}Paginator(essdk.BuildFilter(ctx, d.QueryContext, list{{ .Name }}Filters, integrationID, encodedResourceCollectionFilters, clientType), d.QueryContext.Limit) if err != nil { plugin.Logger(ctx).Error("List{{ .Name }} New{{ .Name }}Paginator", "error", err) return nil, err @@ -242,7 +242,7 @@ func Get{{ .Name }}(ctx context.Context, d *plugin.QueryData, _ *plugin.HydrateD if err != nil { return nil, err } - accountId, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyAccountID) + integrationID, err := sc.GetConfigTableValueOrNil(ctx, steampipesdk.OpenGovernanceConfigKeyIntegrationID) if err != nil { return nil, err } @@ -256,7 +256,7 @@ func Get{{ .Name }}(ctx context.Context, d *plugin.QueryData, _ *plugin.HydrateD } limit := int64(1) - paginator, err := k.New{{ .Name }}Paginator(essdk.BuildFilter(ctx, d.QueryContext, get{{ .Name }}Filters, "{{ .IntegrationType }}", accountId, encodedResourceCollectionFilters, clientType), &limit) + paginator, err := k.New{{ .Name }}Paginator(essdk.BuildFilter(ctx, d.QueryContext, get{{ .Name }}Filters, integrationID, encodedResourceCollectionFilters, clientType), &limit) if err != nil { return nil, err } diff --git a/steampipe-plugin-github/github/plugin.go b/steampipe-plugin-github/github/plugin.go index 22864010..52db43ec 100644 --- a/steampipe-plugin-github/github/plugin.go +++ b/steampipe-plugin-github/github/plugin.go @@ -37,7 +37,6 @@ func Plugin(ctx context.Context) *plugin.Plugin { "github_organization_member": tableGitHubOrganizationMember(), "github_organization_collaborator": tableGitHubOrganizationCollaborator(), "github_pull_request": tableGitHubPullRequest(), - "github_pull_request_comment": tableGitHubPullRequestComment(), "github_pull_request_review": tableGitHubPullRequestReview(), "github_rate_limit": tableGitHubRateLimit(), "github_rate_limit_graphql": tableGitHubRateLimitGraphQL(), diff --git a/steampipe-plugin-github/github/table_github_pull_request_comment.go b/steampipe-plugin-github/github/table_github_pull_request_comment.go index 19361ddb..d4a9061c 100644 --- a/steampipe-plugin-github/github/table_github_pull_request_comment.go +++ b/steampipe-plugin-github/github/table_github_pull_request_comment.go @@ -17,7 +17,7 @@ func tableGitHubPullRequestComment() *plugin.Table { ShouldIgnoreError: isNotFoundError([]string{"404"}), Hydrate: tableGitHubRepositoryPullRequestCommentList, }, - Columns: commonColumns(sharedCommentsColumns()), + //Columns: commonColumns(sharedCommentsColumns()), } }