send

type APIError struct {
	Error     string `json:"error"`
	Message   string `json:"message"`
	RequestID string `json:"request_id,omitempty"`
}

type APIResponse struct {
	RequestID string      `json:"request_id"`
	Data      interface{} `json:"data,omitempty"`
	Message   string      `json:"message,omitempty"`
}

type BlobMsgStore struct {
	// contains filtered or unexported fields
}

type Config struct {
	DefaultTimeout      time.Duration
	MaxTimeout          time.Duration
	ObjectPollInterval  time.Duration
	RequestCheckTimeout time.Duration
	MaxBodySize         int64
}

type Headers map[string]string

type MessageDispatcher interface {
	Dispatch(datasite string, msg *syftmsg.Message) bool
}

type MessageRequest struct {
	SyftURL utils.SyftBoxURL `form:"x-syft-url" binding:"required"`  // Binds to the syft url using UnmarshalParam
	From    string           `form:"x-syft-from" binding:"required"` // The sender of the message
	Timeout int              `form:"timeout" binding:"gte=0"`        // The timeout for the request in milliseconds
	AsRaw   bool             `form:"x-syft-raw" default:"false"`     // If true, the request body will be read and sent as is
	Method  string           // Will be set from request method
	Headers Headers          // Will be set from request headers
}

type PollInfo struct {
	PollURL string `json:"poll_url"`
}

type PollObjectRequest struct {
	RequestID string           `form:"x-syft-request-id" binding:"required"`
	From      string           `form:"x-syft-from" binding:"required"`
	SyftURL   utils.SyftBoxURL `form:"x-syft-url" binding:"required"`
	Timeout   int              `form:"timeout,omitempty" binding:"gte=0"` // Timeout in milliseconds
	UserAgent string           `form:"user-agent,omitempty"`
	AsRaw     bool             `form:"x-syft-raw" default:"false"` // If true, the request body will be read and sent as is
}

type PollResult struct {
	Status    int
	RequestID string
	Response  map[string]interface{}
}

type PollStatus string

type RPCMsgStore interface {
	StoreMsg(ctx context.Context, path string, msgBytes []byte) error
	GetMsg(ctx context.Context, path string) (io.ReadCloser, error)
	DeleteMsg(ctx context.Context, path string) error
}

type SendHandler struct {
	// contains filtered or unexported fields
}

type SendResult struct {
	Status    int
	RequestID string
	PollURL   string
	Response  map[string]interface{}
}

type SendService struct {
	// contains filtered or unexported fields
}

type SendServiceInterface interface {
	SendMessage(ctx context.Context, req *MessageRequest, bodyBytes []byte) (*SendResult, error)
	PollForResponse(ctx context.Context, req *PollObjectRequest) (*PollResult, error)

	GetConfig() *Config
	// contains filtered or unexported methods
}

type WSMsgDispatcher struct {
	// contains filtered or unexported fields
}