chore: add the core code with correct module

Author: owenrumney

go.mod

@@ -1,3 +1,67 @@
 module github.com/infracost/cli
 
-go 1.25.7
+go 1.25.5
+
+require (
+	github.com/Masterminds/semver/v3 v3.4.0
+	github.com/MicahParks/keyfunc/v3 v3.7.0
+	github.com/golang-jwt/jwt/v5 v5.3.0
+	github.com/google/go-cmp v0.7.0
+	github.com/google/uuid v1.6.0
+	github.com/hashicorp/go-hclog v1.6.3
+	github.com/hashicorp/go-plugin v1.7.0
+	github.com/infracost/config v0.3.8
+	github.com/infracost/go-proto v0.2.1
+	github.com/infracost/proto v1.21.0
+	github.com/liamg/tml v0.7.1
+	github.com/rs/zerolog v1.34.0
+	github.com/shirou/gopsutil v3.21.11+incompatible
+	github.com/spf13/cobra v1.10.2
+	github.com/spf13/pflag v1.0.9
+	github.com/stretchr/testify v1.11.1
+	golang.org/x/mod v0.32.0
+	golang.org/x/oauth2 v0.34.0
+	golang.org/x/text v0.33.0
+	google.golang.org/grpc v1.78.0
+	google.golang.org/protobuf v1.36.11
+)
+
+require (
+	github.com/MicahParks/jwkset v0.11.0 // indirect
+	github.com/agext/levenshtein v1.2.3 // indirect
+	github.com/agnivade/levenshtein v1.2.1 // indirect
+	github.com/apparentlymart/go-textseg/v15 v15.0.0 // indirect
+	github.com/davecgh/go-spew v1.1.2-0.20180830191138-d8f796af33cc // indirect
+	github.com/dlclark/regexp2 v1.2.0 // indirect
+	github.com/fatih/color v1.18.0 // indirect
+	github.com/go-ole/go-ole v1.2.6 // indirect
+	github.com/gobwas/glob v0.2.3 // indirect
+	github.com/golang/protobuf v1.5.4 // indirect
+	github.com/hashicorp/hcl/v2 v2.24.0 // indirect
+	github.com/hashicorp/yamux v0.1.2 // indirect
+	github.com/inconshreveable/mousetrap v1.1.0 // indirect
+	github.com/json-iterator/go v1.1.12 // indirect
+	github.com/kr/pretty v0.3.1 // indirect
+	github.com/mattn/go-colorable v0.1.14 // indirect
+	github.com/mattn/go-isatty v0.0.20 // indirect
+	github.com/mitchellh/go-wordwrap v1.0.1 // indirect
+	github.com/modern-go/concurrent v0.0.0-20180228061459-e0a39a4cb421 // indirect
+	github.com/modern-go/reflect2 v1.0.2 // indirect
+	github.com/oklog/run v1.1.0 // indirect
+	github.com/pmezard/go-difflib v1.0.1-0.20181226105442-5d4384ee4fb2 // indirect
+	github.com/soongo/path-to-regexp v1.6.4 // indirect
+	github.com/tklauser/go-sysconf v0.3.16 // indirect
+	github.com/tklauser/numcpus v0.11.0 // indirect
+	github.com/yusufpapurcu/wmi v1.2.4 // indirect
+	github.com/zclconf/go-cty v1.17.0 // indirect
+	go.opentelemetry.io/otel v1.39.0 // indirect
+	go.opentelemetry.io/otel/sdk/metric v1.39.0 // indirect
+	golang.org/x/net v0.49.0 // indirect
+	golang.org/x/sync v0.19.0 // indirect
+	golang.org/x/sys v0.41.0 // indirect
+	golang.org/x/time v0.14.0 // indirect
+	golang.org/x/tools v0.41.0 // indirect
+	google.golang.org/genproto/googleapis/rpc v0.0.0-20251222181119-0a764e51fe1b // indirect
+	gopkg.in/check.v1 v1.0.0-20201130134442-10cb98267c6c // indirect
+	gopkg.in/yaml.v3 v3.0.1 // indirect
+)

go.sum

@@ -0,0 +1,34 @@
+package api
+
+import (
+	"context"
+	"net/http"
+
+	"github.com/infracost/cli/internal/trace"
+	"golang.org/x/oauth2"
+)
+
+func Client(ctx context.Context, source oauth2.TokenSource, orgID string) *http.Client {
+	base, transport := baseClient(ctx, source)
+	return &http.Client{
+		Transport: &CustomHeaders{
+			Base: transport,
+			Headers: map[string]string{
+				"X-Infracost-Trace-ID": trace.ID,
+				"User-Agent":           trace.UserAgent,
+				"x-infracost-org-id":   orgID,
+			},
+		},
+		CheckRedirect: base.CheckRedirect,
+		Jar:           base.Jar,
+		Timeout:       base.Timeout,
+	}
+}
+
+func baseClient(ctx context.Context, source oauth2.TokenSource) (*http.Client, http.RoundTripper) {
+	if source == nil {
+		return http.DefaultClient, http.DefaultTransport
+	}
+	client := oauth2.NewClient(ctx, source)
+	return client, client.Transport
+}

internal/api/client.go

@@ -0,0 +1,66 @@
+package dashboard
+
+import (
+	"context"
+	"encoding/json"
+	"errors"
+	"fmt"
+	"net/http"
+	"strings"
+
+	"github.com/infracost/cli/internal/api/dashboard/graphql"
+)
+
+type Client struct {
+	client *http.Client
+	config *Config
+}
+
+type RunParameters struct {
+	OrganizationID string `json:"organizationId"`
+	RepositoryName string `json:"repositoryName"`
+
+	UsageDefaults     json.RawMessage   `json:"usageDefaults"`
+	ProductionFilters []json.RawMessage `json:"productionFilters"`
+	TagPolicies       []json.RawMessage `json:"tagPolicies"`
+	FinopsPolicies    []json.RawMessage `json:"finopsPolicies"`
+}
+
+func (c *Client) RunParameters(ctx context.Context, repoURL, branchName string) (RunParameters, error) {
+	const query = `query RunParameters($repoUrl: String, $branchName: String) {
+  runParameters(repoUrl: $repoUrl, branchName: $branchName) {
+    organizationId
+    repositoryName
+    usageDefaults
+    productionFilters
+    tagPolicies
+    finopsPolicies
+  }
+}`
+
+	type response struct {
+		RunParameters RunParameters `json:"runParameters"`
+	}
+
+	variables := map[string]interface{}{}
+	if repoURL != "" {
+		variables["repoUrl"] = repoURL
+	}
+	if branchName != "" {
+		variables["branchName"] = branchName
+	}
+
+	r, err := graphql.Query[response](ctx, c.client, fmt.Sprintf("%s/graphql", c.config.Endpoint), query, variables)
+	if err != nil {
+		return RunParameters{}, err
+	}
+
+	if len(r.Errors) > 0 {
+		var errs []string
+		for _, e := range r.Errors {
+			errs = append(errs, e.Message)
+		}
+		return r.Data.RunParameters, errors.New(strings.Join(errs, ";"))
+	}
+	return r.Data.RunParameters, nil
+}

internal/api/dashboard/client.go

@@ -0,0 +1,38 @@
+package dashboard
+
+import (
+	"net/http"
+
+	"github.com/infracost/cli/pkg/environment"
+)
+
+var (
+	defaultValues = map[environment.Environment]map[string]string{
+		environment.Production: {
+			"endpoint": "https://dashboard.api.infracost.io",
+		},
+		environment.Development: {
+			"endpoint": "https://dashboard.api.dev.infracost.io",
+		},
+		environment.Local: {
+			"endpoint": "http://localhost:5000",
+		},
+	}
+)
+
+type Config struct {
+	Endpoint string `env:"INFRACOST_CLI_DASHBOARD_ENDPOINT" flag:"dashboard-endpoint;hidden" usage:"The endpoint for the Infracost dashboard"`
+}
+
+func (c *Config) Client(client *http.Client) *Client {
+	return &Client{
+		client: client,
+		config: c,
+	}
+}
+
+func (c *Config) ApplyDefaults(env environment.Environment) {
+	if c.Endpoint == "" {
+		c.Endpoint = defaultValues[env]["endpoint"]
+	}
+}

internal/api/dashboard/config.go

@@ -0,0 +1,54 @@
+package graphql
+
+import (
+	"bytes"
+	"context"
+	"encoding/json"
+	"net/http"
+)
+
+type Response[T any] struct {
+	Data   T       `json:"data"`
+	Errors []Error `json:"errors,omitempty"`
+}
+
+type Error struct {
+	Message string `json:"message"`
+}
+
+type Request struct {
+	Query     string                 `json:"query"`
+	Variables map[string]interface{} `json:"variables,omitempty"`
+}
+
+func Query[T any](ctx context.Context, client *http.Client, endpoint string, query string, variables map[string]interface{}) (Response[T], error) {
+	request := Request{
+		Query:     query,
+		Variables: variables,
+	}
+
+	bytes := new(bytes.Buffer)
+	if err := json.NewEncoder(bytes).Encode(request); err != nil {
+		return Response[T]{}, err
+	}
+	req, err := http.NewRequestWithContext(ctx, http.MethodPost, endpoint, bytes)
+	if err != nil {
+		return Response[T]{}, err
+	}
+
+	req.Header.Set("Content-Type", "application/json")
+	r, err := client.Do(req) // #nosec G704 -- request target originates from config file
+	if err != nil {
+		return Response[T]{}, err
+	}
+	defer func() {
+		_ = r.Body.Close()
+	}()
+
+	var response Response[T]
+	if err := json.NewDecoder(r.Body).Decode(&response); err != nil {
+		return Response[T]{}, err
+	}
+
+	return response, nil
+}

internal/api/dashboard/graphql/graphql.go

@@ -0,0 +1,69 @@
+package events
+
+import (
+	"bytes"
+	"context"
+	"encoding/json"
+	"fmt"
+	"net/http"
+
+	"github.com/infracost/cli/internal/logging"
+)
+
+type Client struct {
+	client *http.Client
+	config *Config
+}
+
+func (c *Client) Push(ctx context.Context, event string, extra ...interface{}) {
+	if isTest, ok := metadata["isTest"].(bool); ok && isTest {
+		return
+	}
+
+	if len(extra)%2 != 0 {
+		panic("events.Push: extra args must be key-value pairs")
+	}
+
+	env := make(map[string]interface{}, len(metadata)+len(extra)/2)
+	for k, v := range metadata {
+		env[k] = v
+	}
+	for i := 0; i < len(extra); i += 2 {
+		key, ok := extra[i].(string)
+		if !ok {
+			panic(fmt.Sprintf("events.Push: extra arg %d must be a string key", i))
+		}
+		env[key] = extra[i+1]
+	}
+
+	body := struct {
+		Event string                 `json:"event"`
+		Env   map[string]interface{} `json:"env"`
+	}{
+		Event: event,
+		Env:   env,
+	}
+
+	buf, err := json.Marshal(body)
+	if err != nil {
+		logging.WithError(err).Msg("events: failed to marshal event")
+		return
+	}
+
+	req, err := http.NewRequestWithContext(ctx, http.MethodPost, fmt.Sprintf("%s/event", c.config.Endpoint), bytes.NewReader(buf))
+	if err != nil {
+		logging.WithError(err).Msg("events: failed to create request")
+		return
+	}
+	req.Header.Set("Content-Type", "application/json")
+
+	resp, err := c.client.Do(req) //nolint:gosec // endpoint is from CLI config, not user input
+	if err != nil {
+		logging.WithError(err).Msg("events: failed to send event")
+		return
+	}
+	if err := resp.Body.Close(); err != nil {
+		logging.WithError(err).Msg("events: failed to close response body")
+		return
+	}
+}

internal/api/events/client.go

@@ -0,0 +1,21 @@
+package events
+
+import (
+	"net/http"
+)
+
+type Config struct {
+	Endpoint string `env:"INFRACOST_CLI_EVENTS_ENDPOINT" flag:"events-endpoint;hidden" usage:"The endpoint for the Infracost events service" default:"https://pricing.api.infracost.io"`
+}
+
+func (c *Config) Client(client *http.Client) *Client {
+	// The events client may be used before config defaults are applied (e.g.
+	// to report early errors), so ensure the endpoint is always set.
+	if c.Endpoint == "" {
+		c.Endpoint = "https://pricing.api.infracost.io"
+	}
+	return &Client{
+		client: client,
+		config: c,
+	}
+}