fix unit-tests pipeline

Author: j-rafique

pkg/raptorq/helper.go

@@ -3,14 +3,9 @@ package raptorq
 import (
 	"bytes"
 	"context"
-	"encoding/json"
 	"github.com/LumeraProtocol/supernode/pkg/errors"
-	"github.com/LumeraProtocol/supernode/pkg/logtrace"
-	"github.com/LumeraProtocol/supernode/pkg/lumera"
 	"github.com/LumeraProtocol/supernode/pkg/utils"
 	"github.com/cosmos/btcutil/base58"
-	"math/rand/v2"
-	"os"
 	"strconv"
 )
 
@@ -19,135 +14,6 @@ const (
 	SeparatorByte       byte = 46 // separator in dd_and_fingerprints.signature i.e. '.'
 )
 
-// EncoderParameters represents the encoding params used by raptorq services
-type EncoderParameters struct {
-	Oti []byte
-}
-
-// EncodeInfo represents the response returns by encodeInfo method
-type EncodeInfo struct {
-	SymbolIDFiles map[string]RawSymbolIDFile
-	EncoderParam  EncoderParameters
-}
-
-// Encode represents the response returns by Encode method
-type Encode struct {
-	Symbols      map[string][]byte
-	EncoderParam EncoderParameters
-}
-
-// Decode represents the response returns by Decode method
-type Decode struct {
-	File []byte
-}
-
-func (s *raptorQServerClient) encodeInfo(ctx context.Context, taskID string, data []byte, copies uint32, blockHash string, pastelID string) (*EncodeInfo, error) {
-	s.semaphore <- struct{}{} // Acquire slot
-	defer func() {
-		<-s.semaphore // Release the semaphore slot
-	}()
-
-	if data == nil {
-		return nil, errors.Errorf("invalid data")
-	}
-
-	_, inputPath, err := createInputEncodeFile(s.config.RqFilesDir, data)
-	if err != nil {
-		return nil, errors.Errorf("create input file: %w", err)
-	}
-	res, err := s.EncodeMetaData(ctx, EncodeMetadataRequest{
-		FilesNumber: copies,
-		BlockHash:   blockHash,
-		PastelId:    pastelID,
-		Path:        inputPath,
-	})
-	if err != nil {
-		return nil, errors.Errorf("encode metadata %s: %w", res.Path, err)
-	}
-
-	filesMap, err := scanSymbolIDFiles(res.Path)
-	if err != nil {
-		return nil, errors.Errorf("scan symbol id files folder %s: %w", res.Path, err)
-	}
-
-	if len(filesMap) != int(copies) {
-		return nil, errors.Errorf("symbol id files count not match: expect %d, output %d", copies, len(filesMap))
-	}
-
-	if err := s.store.StoreSymbolDirectory(taskID, res.Path); err != nil {
-		return nil, errors.Errorf("store symbol directory: %w", err)
-	}
-
-	output := &EncodeInfo{
-		SymbolIDFiles: filesMap,
-		EncoderParam: EncoderParameters{
-			Oti: res.EncoderParameters,
-		},
-	}
-
-	if err := os.Remove(inputPath); err != nil {
-		logtrace.Error(ctx, "encode info: error removing input file", logtrace.Fields{"Path": inputPath})
-	}
-
-	return output, nil
-}
-
-type generateRQIDsRequest struct {
-	lc             lumera.Client
-	signedData     string
-	rawFile        RawSymbolIDFile
-	creatorAddress string
-	maxFiles       uint32
-}
-
-type generateRQIDsResponse struct {
-	RQIDsIc    uint32
-	RQIDs      []string
-	RQIDsFile  []byte
-	RQIDsFiles [][]byte
-	signature  []byte
-}
-
-func (s *raptorQServerClient) generateRQIDs(ctx context.Context, req generateRQIDsRequest) (generateRQIDsResponse, error) {
-	// RQID file generated by supernode
-	rqIDsfile, err := json.Marshal(req.rawFile)
-	if err != nil {
-		return generateRQIDsResponse{}, errors.Errorf("marshal rqID file")
-	}
-	encRqIDsfile := utils.B64Encode(rqIDsfile)
-
-	creatorSignature, err := ValidateRQIDs(req.lc, req.signedData, encRqIDsfile, req.rawFile.SymbolIdentifiers, req.creatorAddress)
-	if err != nil {
-		return generateRQIDsResponse{}, errors.Errorf("error validating RQIDs")
-	}
-
-	var buffer bytes.Buffer
-	buffer.Write(encRqIDsfile)
-	buffer.WriteString(".")
-	buffer.Write(creatorSignature)
-	rqIDFile := buffer.Bytes()
-
-	RQIDsIc := rand.Uint32()
-	RQIDs, RQIDsFiles, err := GetIDFiles(ctx, rqIDFile, RQIDsIc, req.maxFiles)
-	if err != nil {
-		return generateRQIDsResponse{}, errors.Errorf("get ID Files: %w", err)
-	}
-
-	comp, err := utils.HighCompress(ctx, rqIDFile)
-	if err != nil {
-		return generateRQIDsResponse{}, errors.Errorf("compress: %w", err)
-	}
-	RQIDsFile := utils.B64Encode(comp)
-
-	return generateRQIDsResponse{
-		RQIDsIc:    RQIDsIc,
-		RQIDs:      RQIDs,
-		RQIDsFile:  RQIDsFile,
-		RQIDsFiles: RQIDsFiles,
-		signature:  creatorSignature,
-	}, nil
-}
-
 // GetIDFiles generates ID Files for dd_and_fingerprints files and rq_id files
 // file is b64 encoded file appended with signatures and compressed, ic is the initial counter
 // and max is the number of ids to generate

sdk/task/manager.go

@@ -188,7 +188,7 @@ func (m *ManagerImpl) handleEvent(ctx context.Context, e event.Event) {
 	case event.TaskFailed:
 		var err error
 		if errMsg, ok := e.Data["error"].(string); ok {
-			err = fmt.Errorf(errMsg)
+			err = fmt.Errorf("%s", errMsg)
 			m.logger.Error(ctx, "Task failed", "taskID", e.TaskID, "taskType", e.TaskType, "error", errMsg)
 		} else {
 			m.logger.Error(ctx, "Task failed with unknown error", "taskID", e.TaskID, "taskType", e.TaskType)

supernode/services/cascade/helper.go

@@ -134,7 +134,7 @@ func (task *CascadeRegistrationTask) wrapErr(ctx context.Context, msg string, er
 	}
 	logtrace.Error(ctx, msg, f)
 
-	return status.Errorf(codes.Internal, msg)
+	return status.Errorf(codes.Internal, "%s", msg)
 }
 
 // extractSignatureAndFirstPart extracts the signature and first part from the encoded data