uploads

Documentation

Index

• type Service
  • func New(db *database.Database, pgpService *pgp.Service, jobsService *jobs.Service, ...) *Service
  • func (service *Service) FS() filesystem.FS
  • func (service *Service) GetAllFileUploadsByUploadID(uploadID uint) ([]*models.FileUpload, error)
  • func (service *Service) GetAllUploads() ([]*models.Upload, error)
  • func (service *Service) GetAllUploadsByUserID(userID uint) ([]*models.Upload, error)
  • func (service *Service) GetAllUploadsByUserIDPageLimit(userID uint, page, limit int) ([]*models.Upload, error)
  • func (service *Service) GetAllUploadsPageLimit(page, limit int) ([]*models.Upload, error)
  • func (service *Service) GetUpload(uploadID uint) (*models.Upload, error)
  • func (service *Service) GetUploadChanges(uploadID uint) (io.ReadCloser, error)
  • func (service *Service) GetUploadDSC(uploadID uint) (io.ReadCloser, error)
  • func (service *Service) GetUploadFile(uploadID uint, filename string) (io.ReadCloser, error)
  • func (service *Service) ProcessUpload(uploadParameters *UploadParameters, content io.Reader) (*models.Upload, error)
  • func (service *Service) UploadedFilesDirectory() string
  • func (service *Service) UploadsDirectory() string
• type UploadParameters

Types

type Service

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

Service manages uploads

func New

func New(db *database.Database, pgpService *pgp.Service, jobsService *jobs.Service, fs filesystem.FS) *Service

New creates a new upload service

func (*Service) FS

func (service *Service) FS() filesystem.FS

FS returns the services's filesystem

func (*Service) GetAllFileUploadsByUploadID

func (service *Service) GetAllFileUploadsByUploadID(uploadID uint) ([]*models.FileUpload, error)

GetAllFileUploadsByUploadID returns all FileUploads associated to an upload

func (*Service) GetAllUploads

func (service *Service) GetAllUploads() ([]*models.Upload, error)

GetAllUploads returns all uploads

func (*Service) GetAllUploadsByUserID

func (service *Service) GetAllUploadsByUserID(userID uint) ([]*models.Upload, error)

GetAllUploadsByUserID returns all uploads for a given user id

func (*Service) GetAllUploadsByUserIDPageLimit

func (service *Service) GetAllUploadsByUserIDPageLimit(userID uint, page, limit int) ([]*models.Upload, error)

GetAllUploadsByUserIDPageLimit returns all uploads for a given user id with pagination

func (*Service) GetAllUploadsPageLimit

func (service *Service) GetAllUploadsPageLimit(page, limit int) ([]*models.Upload, error)

GetAllUploadsPageLimit returns all uploads with pagination

func (*Service) GetUpload

func (service *Service) GetUpload(uploadID uint) (*models.Upload, error)

GetUpload returns an upload by ID

func (*Service) GetUploadChanges

func (service *Service) GetUploadChanges(uploadID uint) (io.ReadCloser, error)

GetUploadChanges returns the .changes of the upload with a matching id

func (*Service) GetUploadDSC

func (service *Service) GetUploadDSC(uploadID uint) (io.ReadCloser, error)

GetUploadDSC returns the DSC of the upload with a matching id

func (*Service) GetUploadFile

func (service *Service) GetUploadFile(uploadID uint, filename string) (io.ReadCloser, error)

GetUploadFile returns the file associated with the upload id and filename

func (*Service) ProcessUpload

func (service *Service) ProcessUpload(uploadParameters *UploadParameters, content io.Reader) (*models.Upload, error)

ProcessUpload receives uploaded files

func (*Service) UploadedFilesDirectory

func (service *Service) UploadedFilesDirectory() string

UploadedFilesDirectory contains files that are not yet associated with a package upload.

func (*Service) UploadsDirectory

func (service *Service) UploadsDirectory() string

UploadsDirectory contains completed uploads.

type UploadParameters

type UploadParameters struct {
	Filename      string
	ForwardUpload bool
	Autopkgtest   bool
}

UploadParameters defines upload behaviour