service

Documentation

Index

• Constants
• Variables
• func NewUploadService() (core.Service, []core.ContextBuilderOption, error)
• type SHAReader
  • func NewSHAReader(reader io.ReadCloser) *SHAReader
  • func (r *SHAReader) CID() cid.Cid
  • func (r *SHAReader) Close() error
  • func (r *SHAReader) Read(p []byte) (int, error)
  • func (r *SHAReader) Sum() string
• type UploadService
  • func (s *UploadService) AddQueuedPin(ctx context.Context, pin messages.Pin, userId uint, uploaderIP string) (*messages.PinStatus, error)
  • func (s *UploadService) CompletePin(ctx context.Context, pin *pluginDb.IPFSPinView, node format.Node) error
  • func (s *UploadService) CreatePinnedPin(ctx context.Context, c cid.Cid, operation models.RequestOperationType, ...) (*pluginDb.IPFSPinView, bool, error)
  • func (s *UploadService) CreateQueuedPin(ctx context.Context, c cid.Cid, userId uint, uploaderIP string, name string, ...) (*pluginDb.IPFSPinView, error)
  • func (s *UploadService) DeletePin(ctx context.Context, id uuid.UUID, userID uint) error
  • func (s *UploadService) DeletePinRequest(ctx context.Context, id uuid.UUID) error
  • func (s *UploadService) DetectPartialStatus(ctx context.Context, block blocks.Block) (bool, *pluginDb.IPFSPin, error)
  • func (s *UploadService) DetectUpdatePartialStatus(ctx context.Context, block blocks.Block) error
  • func (s *UploadService) GetBlockMeta(ctx context.Context, c cid.Cid) (*messages.BlockMetaResponse, error)
  • func (s *UploadService) GetChildPins(ctx context.Context, parentID any) ([]*pluginDb.IPFSPinView, error)
  • func (s *UploadService) GetPinByIdentifier(ctx context.Context, identifier interface{}, userID uint) (*pluginDb.IPFSPinView, error)
  • func (s *UploadService) GetPinStatus(ctx context.Context, id uuid.UUID, userID uint) (*messages.PinStatus, error)
  • func (s *UploadService) GetPins(ctx context.Context, req messages.GetPinsRequest, userId uint) (*messages.PinResults, error)
  • func (s *UploadService) HandlePostUpload(ctx context.Context, reader io.ReadSeekCloser, userId uint, uploaderIP string) error
  • func (s *UploadService) ID() string
  • func (s *UploadService) PinRequestStatusFailed(ctx context.Context, id any) error
  • func (s *UploadService) PinRequestStatusPinned(ctx context.Context, id any) error
  • func (s *UploadService) PinRequestStatusPinning(ctx context.Context, id any) error
  • func (s *UploadService) PinRequestStatusQueued(ctx context.Context, id any) error
  • func (s *UploadService) ReplacePin(ctx context.Context, id uuid.UUID, newPin messages.Pin, userID uint) (*messages.PinStatus, error)
  • func (s *UploadService) SetTusUploadRequestID(ctx context.Context, requestId uint) error
  • func (s *UploadService) UpdatePartialStatus(ctx context.Context, id uint, partial bool) error
  • func (s *UploadService) UpdatePinParent(ctx context.Context, requestID uuid.UUID, parentRequestID uuid.UUID) error
  • func (s *UploadService) UpdatePinRequestStatus(ctx context.Context, id any, status pluginDb.PinningStatus) error
  • func (s *UploadService) UpdatePinnedPinParent(ctx context.Context, requestID, parentRequestID uuid.UUID) error

Constants

const UPLOAD_SERVICE = "ipfs_upload_service"

Variables

var (
	ErrStorageQuotaExceeded  = errors.New("storage quota exceeded")
	ErrUploadQuotaExceeded   = errors.New("upload quota exceeded")
	ErrDownloadQuotaExceeded = errors.New("download quota exceeded")
)

Functions

func NewUploadService

func NewUploadService() (core.Service, []core.ContextBuilderOption, error)

Types

type SHAReader

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

func NewSHAReader

func NewSHAReader(reader io.ReadCloser) *SHAReader

func (*SHAReader) CID

func (r *SHAReader) CID() cid.Cid

func (*SHAReader) Close

func (r *SHAReader) Close() error

func (*SHAReader) Read

func (r *SHAReader) Read(p []byte) (int, error)

func (*SHAReader) Sum

func (r *SHAReader) Sum() string

type UploadService

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

func (*UploadService) AddQueuedPin

func (s *UploadService) AddQueuedPin(ctx context.Context, pin messages.Pin, userId uint, uploaderIP string) (*messages.PinStatus, error)

func (*UploadService) CompletePin

func (s *UploadService) CompletePin(ctx context.Context, pin *pluginDb.IPFSPinView, node format.Node) error

func (*UploadService) CreatePinnedPin

func (s *UploadService) CreatePinnedPin(ctx context.Context, c cid.Cid, operation models.RequestOperationType, size uint64, userId uint, uploaderIP string, name string, isInternal, isRoot bool, requestID, parentRequestID *uuid.UUID) (*pluginDb.IPFSPinView, bool, error)

func (*UploadService) CreateQueuedPin

func (s *UploadService) CreateQueuedPin(ctx context.Context, c cid.Cid, userId uint, uploaderIP string, name string, isInternal bool, parentRequestID *uuid.UUID, createCron bool) (*pluginDb.IPFSPinView, error)

func (*UploadService) DeletePin

func (s *UploadService) DeletePin(ctx context.Context, id uuid.UUID, userID uint) error

func (*UploadService) DeletePinRequest

func (s *UploadService) DeletePinRequest(ctx context.Context, id uuid.UUID) error

func (*UploadService) DetectPartialStatus

func (s *UploadService) DetectPartialStatus(ctx context.Context, block blocks.Block) (bool, *pluginDb.IPFSPin, error)

func (*UploadService) DetectUpdatePartialStatus

func (s *UploadService) DetectUpdatePartialStatus(ctx context.Context, block blocks.Block) error

func (*UploadService) GetBlockMeta

func (s *UploadService) GetBlockMeta(ctx context.Context, c cid.Cid) (*messages.BlockMetaResponse, error)

func (*UploadService) GetChildPins

func (s *UploadService) GetChildPins(ctx context.Context, parentID any) ([]*pluginDb.IPFSPinView, error)

func (*UploadService) GetPinByIdentifier

func (s *UploadService) GetPinByIdentifier(ctx context.Context, identifier interface{}, userID uint) (*pluginDb.IPFSPinView, error)

func (*UploadService) GetPinStatus

func (s *UploadService) GetPinStatus(ctx context.Context, id uuid.UUID, userID uint) (*messages.PinStatus, error)

func (*UploadService) GetPins

func (s *UploadService) GetPins(ctx context.Context, req messages.GetPinsRequest, userId uint) (*messages.PinResults, error)

func (*UploadService) HandlePostUpload

func (s *UploadService) HandlePostUpload(ctx context.Context, reader io.ReadSeekCloser, userId uint, uploaderIP string) error

func (*UploadService) ID

func (s *UploadService) ID() string

func (*UploadService) PinRequestStatusFailed

func (s *UploadService) PinRequestStatusFailed(ctx context.Context, id any) error

func (*UploadService) PinRequestStatusPinned

func (s *UploadService) PinRequestStatusPinned(ctx context.Context, id any) error

func (*UploadService) PinRequestStatusPinning

func (s *UploadService) PinRequestStatusPinning(ctx context.Context, id any) error

func (*UploadService) PinRequestStatusQueued

func (s *UploadService) PinRequestStatusQueued(ctx context.Context, id any) error

func (*UploadService) ReplacePin

func (s *UploadService) ReplacePin(ctx context.Context, id uuid.UUID, newPin messages.Pin, userID uint) (*messages.PinStatus, error)

func (*UploadService) SetTusUploadRequestID

func (s *UploadService) SetTusUploadRequestID(ctx context.Context, requestId uint) error

func (*UploadService) UpdatePartialStatus

func (s *UploadService) UpdatePartialStatus(ctx context.Context, id uint, partial bool) error

func (*UploadService) UpdatePinParent

func (s *UploadService) UpdatePinParent(ctx context.Context, requestID uuid.UUID, parentRequestID uuid.UUID) error

func (*UploadService) UpdatePinRequestStatus

func (s *UploadService) UpdatePinRequestStatus(ctx context.Context, id any, status pluginDb.PinningStatus) error

func (*UploadService) UpdatePinnedPinParent

func (s *UploadService) UpdatePinnedPinParent(ctx context.Context, requestID, parentRequestID uuid.UUID) error