pikpak

package
v0.0.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 28, 2024 License: AGPL-3.0 Imports: 27 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	OSSUserAgent               = "aliyun-sdk-android/2.9.13(Linux/Android 14/M2004j7ac;UKQ1.231108.001)"
	OssSecurityTokenHeaderName = "X-OSS-Security-Token"
	ThreadsNum                 = 10
)
View Source 
const (
	AndroidClientID      = "YNxT9w7GMdWvEOKa"
	AndroidClientSecret  = "dbw2OtmVEeuUvIptb1Coyg"
	AndroidClientVersion = "1.49.3"
	AndroidPackageName   = "com.pikcloud.pikpak"
	AndroidSdkVersion    = "2.0.4.204101"
	WebClientID          = "YUMx5nI8ZU8Ap8pm"
	WebClientSecret      = "dbw2OtmVEeuUvIptb1Coyg"
	WebClientVersion     = "undefined"
	WebPackageName       = "drive.mypikpak.com"
	WebSdkVersion        = "8.0.3"
	PCClientID           = "YvtoWO6GNHiuCl7x"
	PCClientSecret       = "1NIH5R1IEe2pAxZE3hv3uA"
	PCClientVersion      = "undefined" // 2.5.6.4831
	PCPackageName        = "mypikpak.com"
	PCSdkVersion         = "8.0.3"
)

Variables

View Source 
var AndroidAlgorithms = []string{
	"7xOq4Z8s",
	"QE9/9+IQco",
	"WdX5J9CPLZp",
	"NmQ5qFAXqH3w984cYhMeC5TJR8j",
	"cc44M+l7GDhav",
	"KxGjo/wHB+Yx8Lf7kMP+/m9I+",
	"wla81BUVSmDkctHDpUT",
	"c6wMr1sm1WxiR3i8LDAm3W",
	"hRLrEQCFNYi0PFPV",
	"o1J41zIraDtJPNuhBu7Ifb/q3",
	"U",
	"RrbZvV0CTu3gaZJ56PVKki4IeP",
	"NNuRbLckJqUp1Do0YlrKCUP",
	"UUwnBbipMTvInA0U0E9",
	"VzGc",
}
View Source 
var PCAlgorithms = []string{
	"KHBJ07an7ROXDoK7Db",
	"G6n399rSWkl7WcQmw5rpQInurc1DkLmLJqE",
	"JZD1A3M4x+jBFN62hkr7VDhkkZxb9g3rWqRZqFAAb",
	"fQnw/AmSlbbI91Ik15gpddGgyU7U",
	"/Dv9JdPYSj3sHiWjouR95NTQff",
	"yGx2zuTjbWENZqecNI+edrQgqmZKP",
	"ljrbSzdHLwbqcRn",
	"lSHAsqCkGDGxQqqwrVu",
	"TsWXI81fD1",
	"vk7hBjawK/rOSrSWajtbMk95nfgf3",
}
View Source 
var WebAlgorithms = []string{
	"fyZ4+p77W1U4zcWBUwefAIFhFxvADWtT1wzolCxhg9q7etmGUjXr",
	"uSUX02HYJ1IkyLdhINEFcCf7l2",
	"iWt97bqD/qvjIaPXB2Ja5rsBWtQtBZZmaHH2rMR41",
	"3binT1s/5a1pu3fGsN",
	"8YCCU+AIr7pg+yd7CkQEY16lDMwi8Rh4WNp5",
	"DYS3StqnAEKdGddRP8CJrxUSFh",
	"crquW+4",
	"ryKqvW9B9hly+JAymXCIfag5Z",
	"Hr08T/NDTX1oSJfHk90c",
	"i",
}

Functions

func BuildCustomUserAgent 

func BuildCustomUserAgent(deviceID, clientID, appName, sdkVersion, clientVersion, packageName, userID string) string

func GetAction 

func GetAction(method string, url string) string

func OssOption 

func OssOption(params *S3Params) []oss.Option

OssOption get options

func SplitFile 

func SplitFile(fileSize int64) (chunks []oss.FileChunk, err error)

func SplitFileByPartNum 

func SplitFileByPartNum(fileSize int64, chunkNum int) ([]oss.FileChunk, error)

SplitFileByPartNum splits big file into parts by the num of parts. Split the file with specified parts count, returns the split result when error is nil.

func SplitFileByPartSize 

func SplitFileByPartSize(fileSize int64, chunkSize int64) ([]oss.FileChunk, error)

SplitFileByPartSize splits big file into parts by the size of parts. Splits the file by the part size. Returns the FileChunk when error is nil.

Types

type Addition 

type Addition struct {
	driver.RootID
	Username           string `json:"username" required:"true"`
	Password           string `json:"password" required:"true"`
	Platform           string `json:"platform" required:"true" default:"web" type:"select" options:"android,web,pc"`
	RefreshToken       string `json:"refresh_token" required:"true" default:""`
	RefreshTokenMethod string `json:"refresh_token_method" required:"true" type:"select" options:"oauth2,http"`
	CaptchaToken       string `json:"captcha_token" default:""`
	DeviceID           string `json:"device_id"  required:"false" default:""`
	DisableMediaLink   bool   `json:"disable_media_link" default:"true"`
}

type CaptchaTokenRequest 

type CaptchaTokenRequest struct {
	Action       string            `json:"action"`
	CaptchaToken string            `json:"captcha_token"`
	ClientID     string            `json:"client_id"`
	DeviceID     string            `json:"device_id"`
	Meta         map[string]string `json:"meta"`
	RedirectUri  string            `json:"redirect_uri"`
}

type CaptchaTokenResponse 

type CaptchaTokenResponse struct {
	CaptchaToken string `json:"captcha_token"`
	ExpiresIn    int64  `json:"expires_in"`
	Url          string `json:"url"`
}

type Common 

type Common struct {
	CaptchaToken string
	UserID       string
	// 必要值,签名相关
	ClientID      string
	ClientSecret  string
	ClientVersion string
	PackageName   string
	Algorithms    []string
	DeviceID      string
	UserAgent     string
	// 验证码token刷新成功回调
	RefreshCTokenCk func(token string)
	// contains filtered or unexported fields
}

func (*Common) GetCaptchaSign 

func (c *Common) GetCaptchaSign() (timestamp, sign string)

GetCaptchaSign 获取验证码签名

func (*Common) GetCaptchaToken 

func (c *Common) GetCaptchaToken() string

func (*Common) GetDeviceID 

func (c *Common) GetDeviceID() string

func (*Common) GetUserAgent 

func (c *Common) GetUserAgent() string

func (*Common) GetUserID 

func (c *Common) GetUserID() string

func (*Common) SetCaptchaToken 

func (c *Common) SetCaptchaToken(captchaToken string)

func (*Common) SetDeviceID 

func (c *Common) SetDeviceID(deviceID string)

func (*Common) SetUserAgent 

func (c *Common) SetUserAgent(userAgent string)

func (*Common) SetUserID 

func (c *Common) SetUserID(userID string)

type ErrResp 

type ErrResp struct {
	ErrorCode        int64  `json:"error_code"`
	ErrorMsg         string `json:"error"`
	ErrorDescription string `json:"error_description"`
}

func (*ErrResp) Error 

func (e *ErrResp) Error() string

func (*ErrResp) IsError 

func (e *ErrResp) IsError() bool

type File 

type File struct {
	Id             string    `json:"id"`
	Kind           string    `json:"kind"`
	Name           string    `json:"name"`
	CreatedTime    time.Time `json:"created_time"`
	ModifiedTime   time.Time `json:"modified_time"`
	Hash           string    `json:"hash"`
	Size           string    `json:"size"`
	ThumbnailLink  string    `json:"thumbnail_link"`
	WebContentLink string    `json:"web_content_link"`
	Medias         []Media   `json:"medias"`
}

type Files 

type Files struct {
	Files         []File `json:"files"`
	NextPageToken string `json:"next_page_token"`
}

type Media 

type Media struct {
	MediaId   string `json:"media_id"`
	MediaName string `json:"media_name"`
	Video     struct {
		Height     int    `json:"height"`
		Width      int    `json:"width"`
		Duration   int    `json:"duration"`
		BitRate    int    `json:"bit_rate"`
		FrameRate  int    `json:"frame_rate"`
		VideoCodec string `json:"video_codec"`
		AudioCodec string `json:"audio_codec"`
		VideoType  string `json:"video_type"`
	} `json:"video"`
	Link struct {
		Url    string    `json:"url"`
		Token  string    `json:"token"`
		Expire time.Time `json:"expire"`
	} `json:"link"`
	NeedMoreQuota  bool          `json:"need_more_quota"`
	VipTypes       []interface{} `json:"vip_types"`
	RedirectLink   string        `json:"redirect_link"`
	IconLink       string        `json:"icon_link"`
	IsDefault      bool          `json:"is_default"`
	Priority       int           `json:"priority"`
	IsOrigin       bool          `json:"is_origin"`
	ResolutionName string        `json:"resolution_name"`
	IsVisible      bool          `json:"is_visible"`
	Category       string        `json:"category"`
}

type OfflineDownloadResp 

type OfflineDownloadResp struct {
	File       *string     `json:"file"`
	Task       OfflineTask `json:"task"`
	UploadType string      `json:"upload_type"`
	URL        struct {
		Kind string `json:"kind"`
	} `json:"url"`
}

添加离线下载响应

type OfflineListResp 

type OfflineListResp struct {
	ExpiresIn     int64         `json:"expires_in"`
	NextPageToken string        `json:"next_page_token"`
	Tasks         []OfflineTask `json:"tasks"`
}

离线下载列表

type OfflineTask 

type OfflineTask struct {
	Callback          string            `json:"callback"`
	CreatedTime       string            `json:"created_time"`
	FileID            string            `json:"file_id"`
	FileName          string            `json:"file_name"`
	FileSize          string            `json:"file_size"`
	IconLink          string            `json:"icon_link"`
	ID                string            `json:"id"`
	Kind              string            `json:"kind"`
	Message           string            `json:"message"`
	Name              string            `json:"name"`
	Params            Params            `json:"params"`
	Phase             string            `json:"phase"` // PHASE_TYPE_RUNNING, PHASE_TYPE_ERROR, PHASE_TYPE_COMPLETE, PHASE_TYPE_PENDING
	Progress          int64             `json:"progress"`
	ReferenceResource ReferenceResource `json:"reference_resource"`
	Space             string            `json:"space"`
	StatusSize        int64             `json:"status_size"`
	Statuses          []string          `json:"statuses"`
	ThirdTaskID       string            `json:"third_task_id"`
	Type              string            `json:"type"`
	UpdatedTime       string            `json:"updated_time"`
	UserID            string            `json:"user_id"`
}

offlineTask

type Params 

type Params struct {
	Age         string  `json:"age"`
	MIMEType    *string `json:"mime_type,omitempty"`
	PredictType string  `json:"predict_type"`
	URL         string  `json:"url"`
}

type PikPak 

type PikPak struct {
	model.Storage
	Addition
	*Common
	RefreshToken string
	AccessToken  string
	// contains filtered or unexported fields
}

func (*PikPak) Config 

func (d *PikPak) Config() driver.Config

func (*PikPak) Copy 

func (d *PikPak) Copy(ctx context.Context, srcObj, dstDir model.Obj) error

func (*PikPak) DeleteOfflineTasks 

func (d *PikPak) DeleteOfflineTasks(ctx context.Context, taskIDs []string, deleteFiles bool) error

func (*PikPak) Drop 

func (d *PikPak) Drop(ctx context.Context) error

func (*PikPak) GetAddition 

func (d *PikPak) GetAddition() driver.Additional

func (*PikPak) Init 

func (d *PikPak) Init(ctx context.Context) (err error)
func (d *PikPak) Link(ctx context.Context, file model.Obj, args model.LinkArgs) (*model.Link, error)

func (*PikPak) List 

func (d *PikPak) List(ctx context.Context, dir model.Obj, args model.ListArgs) ([]model.Obj, error)

func (*PikPak) MakeDir 

func (d *PikPak) MakeDir(ctx context.Context, parentDir model.Obj, dirName string) error

func (*PikPak) Move 

func (d *PikPak) Move(ctx context.Context, srcObj, dstDir model.Obj) error

func (*PikPak) OfflineDownload 

func (d *PikPak) OfflineDownload(ctx context.Context, fileUrl string, parentDir model.Obj, fileName string) (*OfflineTask, error)

离线下载文件

func (*PikPak) OfflineList 

func (d *PikPak) OfflineList(ctx context.Context, nextPageToken string, phase []string) ([]OfflineTask, error)

获取离线下载任务列表 phase 可能的取值： PHASE_TYPE_RUNNING, PHASE_TYPE_ERROR, PHASE_TYPE_COMPLETE, PHASE_TYPE_PENDING

func (*PikPak) Put 

func (d *PikPak) Put(ctx context.Context, dstDir model.Obj, stream model.FileStreamer, up driver.UpdateProgress) error

func (*PikPak) RefreshCaptchaTokenAtLogin 

func (d *PikPak) RefreshCaptchaTokenAtLogin(action, userID string) error

RefreshCaptchaTokenAtLogin 刷新验证码token(登录后)

func (*PikPak) RefreshCaptchaTokenInLogin 

func (d *PikPak) RefreshCaptchaTokenInLogin(action, username string) error

RefreshCaptchaTokenInLogin 刷新验证码token(登录时)

func (*PikPak) Remove 

func (d *PikPak) Remove(ctx context.Context, obj model.Obj) error

func (*PikPak) Rename 

func (d *PikPak) Rename(ctx context.Context, srcObj model.Obj, newName string) error

func (*PikPak) UploadByMultipart 

func (d *PikPak) UploadByMultipart(params *S3Params, fileSize int64, stream model.FileStreamer, up driver.UpdateProgress) error

func (*PikPak) UploadByOSS 

func (d *PikPak) UploadByOSS(params *S3Params, stream model.FileStreamer, up driver.UpdateProgress) error

type ReferenceResource 

type ReferenceResource struct {
	Type          string                 `json:"@type"`
	Audit         interface{}            `json:"audit"`
	Hash          string                 `json:"hash"`
	IconLink      string                 `json:"icon_link"`
	ID            string                 `json:"id"`
	Kind          string                 `json:"kind"`
	Medias        []Media                `json:"medias"`
	MIMEType      string                 `json:"mime_type"`
	Name          string                 `json:"name"`
	Params        map[string]interface{} `json:"params"`
	ParentID      string                 `json:"parent_id"`
	Phase         string                 `json:"phase"`
	Size          string                 `json:"size"`
	Space         string                 `json:"space"`
	Starred       bool                   `json:"starred"`
	Tags          []string               `json:"tags"`
	ThumbnailLink string                 `json:"thumbnail_link"`
}

type S3Params 

type S3Params struct {
	AccessKeyID     string    `json:"access_key_id"`
	AccessKeySecret string    `json:"access_key_secret"`
	Bucket          string    `json:"bucket"`
	Endpoint        string    `json:"endpoint"`
	Expiration      time.Time `json:"expiration"`
	Key             string    `json:"key"`
	SecurityToken   string    `json:"security_token"`
}

type UploadTaskData 

type UploadTaskData struct {
	UploadType string `json:"upload_type"`
	//UPLOAD_TYPE_RESUMABLE
	Resumable *struct {
		Kind     string   `json:"kind"`
		Params   S3Params `json:"params"`
		Provider string   `json:"provider"`
	} `json:"resumable"`

	File File `json:"file"`
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.