sdk api updates

Author: mateeullahmalik

sdk/action/client.go

@@ -3,7 +3,6 @@ package action
 import (
 	"context"
 	"fmt"
-	"os"
 
 	"github.com/LumeraProtocol/supernode/sdk/config"
 	"github.com/LumeraProtocol/supernode/sdk/event"
@@ -15,7 +14,7 @@ import (
 
 // Client defines the interface for action operations
 type Client interface {
-	StartCascade(ctx context.Context, fileHash string, actionID string, filePath string, signedData string) (string, error)
+	StartCascade(ctx context.Context, data []byte, actionID string) (string, error)
 	DeleteTask(ctx context.Context, taskID string) error
 	GetTask(ctx context.Context, taskID string) (*task.TaskEntry, bool)
 	SubscribeToEvents(ctx context.Context, eventType event.EventType, handler event.Handler) error
@@ -54,36 +53,20 @@ func NewClient(ctx context.Context, config config.Config, logger log.Logger, key
 
 // StartCascade initiates a cascade operation
 func (c *ClientImpl) StartCascade(ctx context.Context,
-	fileHash string,
+	data []byte,
 	actionID string,
-	filePath string,
-	signedData string,
 ) (string, error) {
-	c.logger.Debug(ctx, "Starting cascade operation",
-		"fileHash", fileHash,
-		"actionID", actionID,
-		"filePath", filePath,
-	)
-
-	if fileHash == "" {
-		c.logger.Error(ctx, "Empty file hash provided")
-		return "", ErrEmptyFileHash
-	}
+
 	if actionID == "" {
 		c.logger.Error(ctx, "Empty action ID provided")
 		return "", ErrEmptyActionID
 	}
-	if filePath == "" {
-		c.logger.Error(ctx, "Empty file path provided")
-		return "", ErrEmptyFilePath
-	}
-	_, err := os.Stat(filePath)
-	if err != nil {
-		c.logger.Error(ctx, "File not found", "filePath", filePath)
-		return "", ErrEmptyFileNotFound
+	if len(data) == 0 {
+		c.logger.Error(ctx, "Empty data provided")
+		return "", ErrEmptyData
 	}
 
-	taskID, err := c.taskManager.CreateCascadeTask(ctx, fileHash, actionID, filePath, signedData)
+	taskID, err := c.taskManager.CreateCascadeTask(ctx, data, actionID)
 	if err != nil {
 		c.logger.Error(ctx, "Failed to create cascade task", "error", err)
 		return "", fmt.Errorf("failed to create cascade task: %w", err)

sdk/action/errors.go

@@ -6,15 +6,14 @@ import (
 )
 
 var (
-	ErrEmptyFileHash     = errors.New("file hash cannot be empty")
-	ErrEmptyActionID     = errors.New("action ID cannot be empty")
-	ErrEmptyFilePath     = errors.New("file path cannot be empty")
-	ErrEmptyFileNotFound = errors.New("file not found at the specified path")
-	ErrNoValidAction     = errors.New("no action found with the specified ID")
-	ErrInvalidAction     = errors.New("action is not in a valid state")
-	ErrNoSupernodes      = errors.New("no valid supernodes available")
-	ErrTaskCreation      = errors.New("failed to create task")
-	ErrCommunication     = errors.New("communication with supernode failed")
+	ErrEmptyData     = errors.New("data cannot be empty")
+	ErrEmptyActionID = errors.New("action ID cannot be empty")
+	ErrEmptyFileName = errors.New("file name cannot be empty")
+	ErrNoValidAction = errors.New("no action found with the specified ID")
+	ErrInvalidAction = errors.New("action is not in a valid state")
+	ErrNoSupernodes  = errors.New("no valid supernodes available")
+	ErrTaskCreation  = errors.New("failed to create task")
+	ErrCommunication = errors.New("communication with supernode failed")
 )
 
 // SupernodeError represents an error related to supernode operations

sdk/adapters/supernodeservice/types.go

@@ -6,16 +6,12 @@ import (
 	"google.golang.org/grpc"
 )
 
-type UploadInputDataRequest struct {
-	Filename   string
-	ActionID   string
-	DataHash   string
-	SignedData string
-	RqMax      int32
-	FilePath   string
+type CascadeSupernodeRegisterRequest struct {
+	data     []byte
+	actionID string
 }
 
-type UploadInputDataResponse struct {
+type CascadeSupernodeRegisterResponse struct {
 	Success bool
 	Message string
 }

sdk/config/config.go

@@ -9,7 +9,7 @@ const (
 	DefaultLocalCosmosAddress = "lumera1qv3"     // Example address - replace with actual
 	DefaultChainID            = "lumera-testnet" // Example chain ID - replace with actual
 	DefaultGRPCAddr           = "127.0.0.1:9090"
-	DefaultTimeout            = 10 * time.Second
+	DefaultTimeout            = 10
 )
 
 // AccountConfig holds peer-to-peer addresses, ports, etc.
@@ -19,9 +19,10 @@ type AccountConfig struct {
 
 // LumeraConfig wraps all chain-specific dials.
 type LumeraConfig struct {
-	GRPCAddr string        // REQUIRED – e.g. "127.0.0.1:9090"
-	ChainID  string        // REQUIRED – e.g. "lumera-mainnet"
-	Timeout  time.Duration // OPTIONAL – defaults to DefaultTimeout
+	GRPCAddr string // REQUIRED – e.g. "127.0.0.1:9090"
+	ChainID  string // REQUIRED – e.g. "lumera-mainnet"
+	Timeout  int    // OPTIONAL – defaults to DefaultTimeout
+	KeyName  string
 }
 
 type Config struct {

sdk/task/cascade.go

@@ -24,23 +24,20 @@ const (
 
 type CascadeTask struct {
 	BaseTask
-	FileHash   string
-	FilePath   string
-	SignedData string
+	data     []byte
+	actionId string
 }
 
 // NewCascadeTask creates a new CascadeTask using a BaseTask plus cascade-specific parameters
 func NewCascadeTask(
 	base BaseTask,
-	fileHash string,
-	filePath string,
-	signedData string,
+	data []byte,
+	actionId string,
+
 ) *CascadeTask {
 	return &CascadeTask{
-		BaseTask:   base,
-		FileHash:   fileHash,
-		FilePath:   filePath,
-		SignedData: signedData,
+		BaseTask: base,
+		data:     data,
 	}
 }
 
@@ -156,7 +153,7 @@ func (t *CascadeTask) registerWithSupernodes(ctx context.Context, supernodes lum
 	clientFactory := net.NewClientFactory(ctx, t.logger, t.keyring, factoryCfg)
 
 	req := &supernodeservice.UploadInputDataRequest{
-		Filename:   filepath.Base(t.FilePath),
+		Data:       filepath.Base(t.FilePath),
 		ActionID:   t.ActionID,
 		DataHash:   t.FileHash,
 		SignedData: t.SignedData,

sdk/task/manager.go

@@ -17,7 +17,7 @@ const MAX_EVENT_WORKERS = 100
 
 // Manager handles task creation and management
 type Manager interface {
-	CreateCascadeTask(ctx context.Context, fileHash, actionID, filePath string, signedData string) (string, error)
+	CreateCascadeTask(ctx context.Context, data []byte, actionID string) (string, error)
 	GetTask(ctx context.Context, taskID string) (*TaskEntry, bool)
 	DeleteTask(ctx context.Context, taskID string) error
 	SubscribeToEvents(ctx context.Context, eventType event.EventType, handler event.Handler)
@@ -84,14 +84,9 @@ func NewManager(
 // CreateCascadeTask creates and starts a Cascade task using the new pattern
 func (m *ManagerImpl) CreateCascadeTask(
 	ctx context.Context,
-	fileHash string,
+	data []byte,
 	actionID string,
-	filePath string,
-	signedData string,
 ) (string, error) {
-	m.logger.Info(ctx, "Creating cascade task",
-		"fileHash", fileHash,
-		"actionID", actionID)
 
 	// Generate task ID
 	// slice this to 8 bytes
@@ -110,7 +105,7 @@ func (m *ManagerImpl) CreateCascadeTask(
 		logger:   m.logger,
 	}
 	// Create cascade-specific task
-	task := NewCascadeTask(baseTask, fileHash, filePath, signedData)
+	task := NewCascadeTask(baseTask, data, actionID)
 
 	// Store task in cache
 	m.taskCache.Set(ctx, taskID, task, TaskTypeCascade)

sdk/task/task.go

@@ -29,7 +29,6 @@ const (
 )
 
 // EventCallback is a function that processes events from tasks
-// Now includes context parameter for proper context propagation
 type EventCallback func(ctx context.Context, e event.Event)
 
 // Task is the interface that all task types must implement