feat(provider): add provider bid pre-check support types

docs/proto/provider.md

@@ -46,6 +46,10 @@
      - [Status](#akash.provider.v1.Status)
 
  - [akash/provider/v1/service.proto](#akash/provider/v1/service.proto)
+     - [BidPreCheckRequest](#akash.provider.v1.BidPreCheckRequest)
+     - [BidPreCheckResponse](#akash.provider.v1.BidPreCheckResponse)
+     - [GroupBidPreCheck](#akash.provider.v1.GroupBidPreCheck)
+
      - [ProviderRPC](#akash.provider.v1.ProviderRPC)
 
  - [akash/inventory/v1/memory.proto](#akash/inventory/v1/memory.proto)
@@ -646,6 +650,55 @@
  ## akash/provider/v1/service.proto
 
 
+
+ <a name="akash.provider.v1.BidPreCheckRequest"></a>
+
+ ### BidPreCheckRequest
+ BidPreCheckRequest is request type for the BidPreCheck RPC method
+
+
+ | Field | Type | Label | Description |
+ | ----- | ---- | ----- | ----------- |
+ | `groups` | [akash.deployment.v1beta3.GroupSpec](#akash.deployment.v1beta3.GroupSpec) | repeated |  |
+
+
+
+
+
+
+ <a name="akash.provider.v1.BidPreCheckResponse"></a>
+
+ ### BidPreCheckResponse
+ PreBidCheckResponse is response type for the PreBidCheck RPC method
+
+
+ | Field | Type | Label | Description |
+ | ----- | ---- | ----- | ----------- |
+ | `group_bid_pre_checks` | [GroupBidPreCheck](#akash.provider.v1.GroupBidPreCheck) | repeated |  |
+ | `total_price` | [cosmos.base.v1beta1.DecCoin](#cosmos.base.v1beta1.DecCoin) |  |  |
+
+
+
+
+
+
+ <a name="akash.provider.v1.GroupBidPreCheck"></a>
+
+ ### GroupBidPreCheck
+ GroupBidPreCheck contains bid information for a specific group
+
+
+ | Field | Type | Label | Description |
+ | ----- | ---- | ----- | ----------- |
+ | `name` | [string](#string) |  |  |
+ | `min_bid_price` | [cosmos.base.v1beta1.DecCoin](#cosmos.base.v1beta1.DecCoin) |  |  |
+ | `reason` | [string](#string) |  |  |
+ | `can_bid` | [bool](#bool) |  |  |
+
+
+
+
+
   <!-- end messages -->
 
   <!-- end enums -->
@@ -662,6 +715,7 @@
  | ----------- | ------------ | ------------- | ------------| ------- | -------- |
  | `GetStatus` | [.google.protobuf.Empty](#google.protobuf.Empty) | [Status](#akash.provider.v1.Status) | GetStatus defines a method to query provider state buf:lint:ignore RPC_REQUEST_RESPONSE_UNIQUE buf:lint:ignore RPC_RESPONSE_STANDARD_NAME | GET|/v1/status|
  | `StreamStatus` | [.google.protobuf.Empty](#google.protobuf.Empty) | [Status](#akash.provider.v1.Status) stream | Status defines a method to stream provider state buf:lint:ignore RPC_REQUEST_RESPONSE_UNIQUE buf:lint:ignore RPC_RESPONSE_STANDARD_NAME | |
+ | `BidPreCheck` | [BidPreCheckRequest](#akash.provider.v1.BidPreCheckRequest) | [BidPreCheckResponse](#akash.provider.v1.BidPreCheckResponse) | BidPreCheck defines a method to check if a provider can bid on a manifest buf:lint:ignore RPC_REQUEST_RESPONSE_UNIQUE buf:lint:ignore RPC_RESPONSE_STANDARD_NAME | POST|/v1/bidprecheck|
 
   <!-- end services -->
 

go/node/types/v1beta3/attribute.go

@@ -1,6 +1,7 @@
 package v1beta3
 
 import (
+	fmt "fmt"
 	"path/filepath"
 	"reflect"
 	"regexp"
@@ -378,3 +379,52 @@ func (attr Attributes) AnyIN(group AttributesGroup) bool {
 	}
 	return false
 }
+
+// GetNonMatchingAttributes returns attributes from 'a' that don't match any attribute in 'b'.
+// For example:
+// a:
+//
+//	region: us-east-1
+//	class: beta1
+//	persistent: true
+//
+// b:
+//
+//	region: us-east-1
+//	class: beta2
+//
+// Returns:
+//
+//	class: beta1
+//	persistent: true
+//
+// This is useful for finding attributes that need to be satisfied when matching requirements.
+func (attr Attributes) GetNonMatchingAttributes(b Attributes) Attributes {
+	var nonMatching Attributes
+
+	for _, req := range attr {
+		found := false
+		for _, attr := range b {
+			if req.SubsetOf(attr) {
+				found = true
+				break
+			}
+		}
+		if !found {
+			nonMatching = append(nonMatching, req)
+		}
+	}
+
+	return nonMatching
+}
+
+func (attr Attributes) String() string {
+	out := ""
+	for i, v := range attr {
+		out += fmt.Sprintf("%s=%s", v.Key, v.Value)
+		if i < len(attr)-1 {
+			out += ", "
+		}
+	}
+	return out
+}

go/node/types/v1beta3/attribute_test.go

@@ -180,3 +180,80 @@ func TestAttributes_Dup(t *testing.T) {
 	dAttrs := attrs.Dup()
 	require.Equal(t, attrs, dAttrs)
 }
+
+func TestAttributes_GetNonMatchingAttributes(t *testing.T) {
+	attr1 := Attributes{
+		{Key: "key1", Value: "val1"},
+		{Key: "key2", Value: "val2"},
+		{Key: "key3", Value: "val3"},
+	}
+
+	attr2 := Attributes{
+		{Key: "key1", Value: "val1"},
+		{Key: "key3", Value: "val3"},
+		{Key: "key4", Value: "val4"},
+	}
+
+	nonMatching := attr1.GetNonMatchingAttributes(attr2)
+	require.Len(t, nonMatching, 1)
+	require.Equal(t, "key2", nonMatching[0].Key)
+	require.Equal(t, "val2", nonMatching[0].Value)
+
+	// Test with empty attributes
+	empty := Attributes{}
+	nonMatching = empty.GetNonMatchingAttributes(attr1)
+	require.Empty(t, nonMatching)
+
+	// Test with no matches
+	attr3 := Attributes{
+		{Key: "key5", Value: "val5"},
+		{Key: "key6", Value: "val6"},
+	}
+	nonMatching = attr3.GetNonMatchingAttributes(attr1)
+	require.Equal(t, nonMatching, attr3)
+}
+
+func TestAttributes_String(t *testing.T) {
+	tests := []struct {
+		name     string
+		attrs    Attributes
+		expected string
+	}{
+		{
+			"single attribute",
+			Attributes{
+				{Key: "key1", Value: "val1"},
+			},
+			"key1=val1",
+		},
+		{
+			"multiple attributes",
+			Attributes{
+				{Key: "key1", Value: "val1"},
+				{Key: "key2", Value: "val2"},
+				{Key: "key3", Value: "val3"},
+			},
+			"key1=val1, key2=val2, key3=val3",
+		},
+		{
+			"empty attributes",
+			Attributes{},
+			"",
+		},
+		{
+			"attributes with special characters",
+			Attributes{
+				{Key: "key/1", Value: "val/1"},
+				{Key: "key.2", Value: "val.2"},
+			},
+			"key/1=val/1, key.2=val.2",
+		},
+	}
+
+	for _, test := range tests {
+		t.Run(test.name, func(t *testing.T) {
+			result := test.attrs.String()
+			require.Equal(t, test.expected, result)
+		})
+	}
+}

go/provider/client/client.go

@@ -30,6 +30,7 @@
 	dtypes "github.com/akash-network/akash-api/go/node/deployment/v1beta3"
 	mtypes "github.com/akash-network/akash-api/go/node/market/v1beta4"
 	ptypes "github.com/akash-network/akash-api/go/node/provider/v1beta3"
+	providerv1 "github.com/akash-network/akash-api/go/provider/v1"
 	ajwt "github.com/akash-network/akash-api/go/util/jwt"
 	atls "github.com/akash-network/akash-api/go/util/tls"
 )
@@ -52,9 +53,7 @@
 	PingPeriod = 10 * time.Second
 )
 
-var (
-	ErrNotInitialized = errors.New("rest: not initialized")
-)
+var ErrNotInitialized = errors.New("rest: not initialized")
 
 type ReqClient interface {
 	DialContext(ctx context.Context, urlStr string, requestHeader http.Header) (*websocket.Conn, *http.Response, error)
@@ -65,7 +64,7 @@
 type Client interface {
 	NewReqClient(ctx context.Context) ReqClient
 	Status(ctx context.Context) (*ProviderStatus, error)
-	Validate(ctx context.Context, gspec dtypes.GroupSpec) (ValidateGroupSpecResult, error)
+	Validate(ctx context.Context, gspecs dtypes.GroupSpecs) (providerv1.BidPreCheckResponse, error)
 	SubmitManifest(ctx context.Context, dseq uint64, mani manifest.Manifest) error
 	GetManifest(ctx context.Context, id mtypes.LeaseID) (manifest.Manifest, error)
 	LeaseStatus(ctx context.Context, id mtypes.LeaseID) (LeaseStatus, error)
@@ -381,35 +380,37 @@
 	return &obj, nil
 }
 
-func (c *client) Validate(ctx context.Context, gspec dtypes.GroupSpec) (ValidateGroupSpecResult, error) {
+func (c *client) Validate(ctx context.Context, gspecs dtypes.GroupSpecs) (providerv1.BidPreCheckResponse, error) {
 	uri, err := MakeURI(c.host, ValidatePath())
 	if err != nil {
-		return ValidateGroupSpecResult{}, err
+		return providerv1.BidPreCheckResponse{}, err
 	}
 
-	if err = gspec.ValidateBasic(); err != nil {
-		return ValidateGroupSpecResult{}, err
+	for _, gspec := range gspecs {
+		if err = gspec.ValidateBasic(); err != nil {
+			return providerv1.BidPreCheckResponse{}, err
+		}
 	}
 
-	bgspec, err := json.Marshal(gspec)
+	bgspecs, err := json.Marshal(gspecs)
 	if err != nil {
-		return ValidateGroupSpecResult{}, err
+		return providerv1.BidPreCheckResponse{}, err
 	}
 
-	req, err := http.NewRequestWithContext(ctx, "GET", uri, bytes.NewReader(bgspec))
+	req, err := http.NewRequestWithContext(ctx, "GET", uri, bytes.NewReader(bgspecs))
 	if err != nil {
-		return ValidateGroupSpecResult{}, err
+		return providerv1.BidPreCheckResponse{}, err
 	}
 	req.Header.Set("Content-Type", contentTypeJSON)
 
 	if err = c.setAuth(req.Header); err != nil {
-		return ValidateGroupSpecResult{}, err
+		return providerv1.BidPreCheckResponse{}, err
 	}
 
 	rCl := c.NewReqClient(ctx)
 	resp, err := rCl.Do(req)
 	if err != nil {
-		return ValidateGroupSpecResult{}, err
+		return providerv1.BidPreCheckResponse{}, err
 	}
 
 	buf := &bytes.Buffer{}
@@ -419,17 +420,17 @@
 	}()
 
 	if err != nil {
-		return ValidateGroupSpecResult{}, err
+		return providerv1.BidPreCheckResponse{}, err
 	}
 
 	err = createClientResponseErrorIfNotOK(resp, buf)
 	if err != nil {
-		return ValidateGroupSpecResult{}, err
+		return providerv1.BidPreCheckResponse{}, err
 	}
 
-	var obj ValidateGroupSpecResult
+	var obj providerv1.BidPreCheckResponse
 	if err = json.NewDecoder(buf).Decode(&obj); err != nil {
-		return ValidateGroupSpecResult{}, err
+		return providerv1.BidPreCheckResponse{}, err
 	}
 
 	return obj, nil
@@ -459,7 +460,6 @@
 
 	rCl := c.NewReqClient(ctx)
 	resp, err := rCl.Do(req)
-
 	if err != nil {
 		return err
 	}
@@ -493,7 +493,6 @@
 
 	rCl := c.NewReqClient(ctx)
 	resp, err := rCl.Do(req)
-
 	if err != nil {
 		return nil, err
 	}
@@ -803,8 +802,8 @@
 	id mtypes.LeaseID,
 	services string,
 	follow bool,
-	_ int64) (*ServiceLogs, error) {
-
+	_ int64,
+) (*ServiceLogs, error) {
 	endpoint, err := url.Parse(c.host.String() + "/" + ServiceLogsPath(id))
 	if err != nil {
 		return nil, err

go/provider/client/types.go

@@ -1,8 +1,6 @@
 package rest
 
 import (
-	sdk "github.com/cosmos/cosmos-sdk/types"
-
 	inventoryV1 "github.com/akash-network/akash-api/go/inventory/v1"
 	manifest "github.com/akash-network/akash-api/go/manifest/v2beta2"
 )
@@ -108,12 +106,6 @@ type LeaseEvent struct {
 	Object              LeaseEventObject `json:"object" yaml:"object"`
 }
 
-// ValidateGroupSpecResult represents the result of validating a group specification,
-// including the minimum bid price required.
-type ValidateGroupSpecResult struct {
-	MinBidPrice sdk.DecCoin `json:"min_bid_price"`
-}
-
 // MigrateRequestBody represents a request to migrate hostnames to a new deployment,
 // including the list of hostnames and destination deployment/group sequence numbers.
 type MigrateRequestBody struct {