feat(x/ecocredit): query BatchInfo ORM

x/ecocredit/server/core/query_batch_info.go

@@ -0,0 +1,25 @@
+package core
+
+import (
+	"context"
+	"github.com/regen-network/regen-ledger/x/ecocredit"
+	v1 "github.com/regen-network/regen-ledger/x/ecocredit/v1"
+)
+
+// BatchInfo queries for information on a credit batch.
+func (k Keeper) BatchInfo(ctx context.Context, request *v1.QueryBatchInfoRequest) (*v1.QueryBatchInfoResponse, error) {
+	if err := ecocredit.ValidateDenom(request.BatchDenom); err != nil {
+		return nil, err
+	}
+
+	batch, err := k.stateStore.BatchInfoStore().GetByBatchDenom(ctx, request.BatchDenom)
+	if err != nil {
+		return nil, err
+	}
+
+	var bi v1.BatchInfo
+	if err = PulsarToGogoSlow(batch, &bi); err != nil {
+		return nil, err
+	}
+	return &v1.QueryBatchInfoResponse{Info: &bi}, nil
+}

x/ecocredit/server/core/query_batch_info_test.go

@@ -0,0 +1,31 @@
+package core
+
+import (
+	"github.com/cosmos/cosmos-sdk/orm/types/ormerrors"
+	ecocreditv1 "github.com/regen-network/regen-ledger/api/regen/ecocredit/v1"
+	v1 "github.com/regen-network/regen-ledger/x/ecocredit/v1"
+	"gotest.tools/v3/assert"
+	"testing"
+)
+
+func TestQuery_BatchInfo(t *testing.T) {
+	t.Parallel()
+	s := setupBase(t)
+	batchDenom := "C01-20200101-20220101-001"
+	assert.NilError(t, s.stateStore.BatchInfoStore().Insert(s.ctx, &ecocreditv1.BatchInfo{
+		ProjectId:  1,
+		BatchDenom: batchDenom,
+		Metadata:   nil,
+		StartDate:  nil,
+		EndDate:    nil,
+	}))
+
+	// invalid query
+	_, err := s.k.BatchInfo(s.ctx, &v1.QueryBatchInfoRequest{BatchDenom: "A00-00000000-00000000-000"})
+	assert.ErrorContains(t, err, ormerrors.NotFound.Error())
+
+	// good query
+	res, err := s.k.BatchInfo(s.ctx, &v1.QueryBatchInfoRequest{BatchDenom: batchDenom})
+	assert.NilError(t, err)
+	assert.Equal(t, uint64(1), res.Info.ProjectId)
+}