Add nop info lookup token option (#1768)

* add nop info lookup token

* refactoring

* make headerfunc unexported

* fix testifylint errors

* fix import order

* Update pkg/chipingress/client_test.go

Co-authored-by: Jordan Krage <jmank88@gmail.com>

* Enable continue-on-error for golangci_lint job

Allow module linting to continue on errors.

* Use module path for golangci-lint report XML

* Add debug step to find path to xml report for golangci-lint

* refactor for lint

* Show working dir

* Revert "Show working dir"

This reverts commit 46d22f6.

* Revert "Add debug step to find path to xml report for golangci-lint"

This reverts commit 36b468d.

---------

Co-authored-by: Jordan Krage <jmank88@gmail.com>
Co-authored-by: chainchad <96362174+chainchad@users.noreply.github.com>

Author: 3 people

.github/workflows/golangci_lint.yml

@@ -22,6 +22,8 @@ jobs:
     if: ${{ github.event_name != 'merge_group' }}
     needs: detect-modules
     runs-on: ubuntu-latest
+    # Modules are independent
+    continue-on-error: true
     strategy:
       matrix:
         module: ${{ fromJSON(needs.detect-modules.outputs.modules) }}
@@ -50,6 +52,7 @@ jobs:
           checkout-repo: false
           golangci-lint-version: v${{ steps.get-version.outputs.version }}
           go-directory: ${{ matrix.module }}
+          golangci-lint-args: --output.text.path=stdout --output.checkstyle.path=${{ matrix.module }}/golangci-lint-report.xml
 
   golangci-lint:
     # Required sink job that waits for all lint jobs to complete

pkg/chipingress/auth.go

@@ -14,6 +14,12 @@ type HeaderProvider interface {
 	Headers(ctx context.Context) (map[string]string, error)
 }
 
+type headerProviderFunc func(ctx context.Context) (map[string]string, error)
+
+func (f headerProviderFunc) Headers(ctx context.Context) (map[string]string, error) {
+	return f(ctx)
+}
+
 // Basic-Auth authentication for Chip Ingress
 type basicAuthCredentials struct {
 	authHeader map[string]string

pkg/chipingress/client.go

@@ -44,13 +44,14 @@ type Opt func(*clientConfig)
 
 // clientConfig is the configuration for the ChipIngressClient.
 type clientConfig struct {
-	transportCredentials credentials.TransportCredentials
-	perRPCCredentials    credentials.PerRPCCredentials
-	headerProvider       HeaderProvider
-	insecureConnection   bool
-	host                 string
-	meterProvider        metric.MeterProvider
-	tracerProvider       trace.TracerProvider
+	transportCredentials  credentials.TransportCredentials
+	perRPCCredentials     credentials.PerRPCCredentials
+	headerProvider        HeaderProvider
+	insecureConnection    bool
+	host                  string
+	meterProvider         metric.MeterProvider
+	tracerProvider        trace.TracerProvider
+	nopInfoHeaderProvider HeaderProvider
 }
 
 func newClientConfig(host string) *clientConfig {
@@ -59,8 +60,9 @@ func newClientConfig(host string) *clientConfig {
 		perRPCCredentials: nil,
 		host:              host,
 		// Default to insecure connection
-		insecureConnection:   true,
-		transportCredentials: insecure.NewCredentials(),
+		insecureConnection:    true,
+		transportCredentials:  insecure.NewCredentials(),
+		nopInfoHeaderProvider: nil,
 	}
 	return cfg
 }
@@ -116,6 +118,10 @@ func NewClient(address string, opts ...Opt) (Client, error) {
 		// NOTE: not supporting streaming interceptors
 	}
 
+	if cfg.nopInfoHeaderProvider != nil {
+		grpcOpts = append(grpcOpts, grpc.WithUnaryInterceptor(newHeaderInterceptor(cfg.nopInfoHeaderProvider)))
+	}
+
 	conn, err := grpc.NewClient(address, grpcOpts...)
 	if err != nil {
 		return nil, err
@@ -226,6 +232,16 @@ func WithTracerProvider(provider trace.TracerProvider) Opt {
 	return func(c *clientConfig) { c.tracerProvider = provider }
 }
 
+func WithNOPLookup() Opt {
+	return func(c *clientConfig) {
+		c.nopInfoHeaderProvider = headerProviderFunc(func(ctx context.Context) (map[string]string, error) {
+			return map[string]string{
+				"x-include-nop-info": "true",
+			}, nil
+		})
+	}
+}
+
 // newHeaderInterceptor creates a unary interceptor that adds headers from a HeaderProvider
 func newHeaderInterceptor(provider HeaderProvider) grpc.UnaryClientInterceptor {
 	return func(ctx context.Context, method string, req, reply interface{}, cc *grpc.ClientConn, invoker grpc.UnaryInvoker, opts ...grpc.CallOption) error {