seed

package module
v0.0.0-...-ca5c8a7 Latest Latest
Warning

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

 Go to latest Published: Nov 6, 2019 License: GPL-3.0 Imports: 27 Imported by: 2

README

SEED

シードはIPFSを利用して、ヴィデオをアップして、内容の索引を作ってツールです。

アテンション： 番号捜索のみ使用すれば、TelegramGroupを入れって、

/video 番号

を使って、番号を捜索してください。

或いは、Telegramのローボード@yinhe_botを使いって、

/video 番号

を使って、番号を捜索してください。

SEEDの使い方法：

SEED process //seed.jsonを読み出して、ipfsネートをアップします。

SEED pin 番号　//番号を探して、IPFSネートにPINをします。番号を入力しなければ、全ての番号PINをします。

SEED transfer //DBからjsonファイルへ転換する。

SEED update //jsonファイルを読み出して、ビデオの紹介を更新します。

JSONファイルのExample:

[
 [
   {
     "bangumi": "video",
     "alias": [
       "video1"
     ],
     "slice": true,
     "files": [
       "D:\\video\\Okita Souji.mp4",
     ],
     "Sharpness": "1080P",
     "poster_path": "D:\\video\\H\\p2526321708.webp",
     "role": [
       ""
     ],
     "publish": "2018-01-20"
   },
   ...
]

処理完了のJSONファイル：

[
    {
        "bangumi": "avvd01312",
        "type": "",
        "output": "",
        "vr": "",
        "thumb": "",
        "intro": "",
        "alias": [
            "Lady Ninja: Aoi kage",
            "极乐女忍者"
        ],
        "language": "",
        "caption": "",
        "poster": "QmZPAqK6Hc2pwrmU3mPJLdMUGpTadaBhN8vFwJ9ay2ULBe",
        "role": [
            "叶加濑麻衣",
            "赤井沙希",
            "鸟肌实",
            "坂口征夫",
            "阿部祐二"
        ],
        "director": "",
        "season": "",
        "Episode": "",
        "TotalEpisode": "",
        "sharpness": "",
        "group": "",
        "publish": "2018-01-20",
        "video_group_list": [],
        "source_info_list": [
            {
                "id": "QmQwp6XEcXauaiBjt3bUsSwcy7SomtE5ve74YRVfi2vCba",
                "public_key": "CAASpgIwggEiMA0GCSqGSIb3DQEBAQUAA4IBDwAwggEKAoIBAQC/voc3C3ZpdTuudhWcZIje7M2gE/V3Av33bUXqhaThmd/MVQZ1CVkzWSJmuYiv7Lq+Uop+pGwF2lKuNQ0xm3YeQrDTOgBkR2Gv8rF69VFdk1olIsFB7XvXwhpREP/l0BZ0u8hYML/gaePzDGpSXRSQi/tzgAbCwirhr18Vd+bh5VuaNcsT/hyCWxJv+uvPCnrrfBrViT7T6w+Oo2fcu8BhbyngBbT01aIhHwFbxuDuMHHDUhi6WvH5k3QPbEp9VNcLXmSiS6Lxvy/5tpUeBOosS99HtiWfswlOOJcjj0jfyMMcPXNgJNLfcoFw+idxW8aUgGnpTS0fixEEa0lk0Kz3AgMBAAE=",
                "addresses": [
                    "/ip4/10.0.75.1/tcp/4001/ipfs/QmQwp6XEcXauaiBjt3bUsSwcy7SomtE5ve74YRVfi2vCba",
                    "/ip4/169.254.112.168/tcp/4001/ipfs/QmQwp6XEcXauaiBjt3bUsSwcy7SomtE5ve74YRVfi2vCba",
                    "/ip4/169.254.206.232/tcp/4001/ipfs/QmQwp6XEcXauaiBjt3bUsSwcy7SomtE5ve74YRVfi2vCba",
                    "/ip4/169.254.248.113/tcp/4001/ipfs/QmQwp6XEcXauaiBjt3bUsSwcy7SomtE5ve74YRVfi2vCba",
                    "/ip4/192.168.1.47/tcp/4001/ipfs/QmQwp6XEcXauaiBjt3bUsSwcy7SomtE5ve74YRVfi2vCba",
                    "/ip4/169.254.55.142/tcp/4001/ipfs/QmQwp6XEcXauaiBjt3bUsSwcy7SomtE5ve74YRVfi2vCba",
                    "/ip4/127.0.0.1/tcp/4001/ipfs/QmQwp6XEcXauaiBjt3bUsSwcy7SomtE5ve74YRVfi2vCba",
                    "/ip4/172.29.42.81/tcp/4001/ipfs/QmQwp6XEcXauaiBjt3bUsSwcy7SomtE5ve74YRVfi2vCba",
                    "/ip6/::1/tcp/4001/ipfs/QmQwp6XEcXauaiBjt3bUsSwcy7SomtE5ve74YRVfi2vCba"
                ],
                "agent_version": "go-ipfs/0.4.19-dev/",
                "protocol_version": "ipfs/0.1.0"
            }
        ]
    },
    ...
]

Documentation

Index

Constants

View Source 
const TimeOutLimit = 5 * time.Second

Variables

This section is empty.

Functions

func APICallback 

func APICallback(v interface{}, cb APICallbackFunc) (Stepper, APICaller)

APICallback ...

func AddDir 

func AddDir(api *API, dir string) (path.Resolved, error)

AddDir ...

func AddFile 

func AddFile(api *API, filename string) (path.Resolved, error)

AddFile ...

func DatabaseCallback 

func DatabaseCallback(v interface{}, cb DatabaseCallbackFunc) (Stepper, DatabaseCaller)

DatabaseCallback ...

func DatabasePinCall 

func DatabasePinCall(p chan<- *model.Pin, fn func(session *xorm.Session) *xorm.Session) (Stepper, DatabaseCaller)

DatabasePinCall ...

func DatabaseUnfinishedCall 

func DatabaseUnfinishedCall(u chan<- *model.Unfinished, fn func(session *xorm.Session) *xorm.Session) (Stepper, DatabaseCaller)

DatabaseUnfinishedCall ...

func DatabaseVideoCall 

func DatabaseVideoCall(v chan<- *model.Video, fn func(session *xorm.Session) *xorm.Session) (Stepper, DatabaseCaller)

DatabaseVideoCall ...

func GetFiles 

func GetFiles(p string) (files []string)

GetFiles ...

func Hash 

func Hash(v interface{}) string

Hash ...

func IndexNumber 

func IndexNumber(index int) byte

IndexNumber ...

func IsPicture 

func IsPicture(name string) bool

IsPicture ...

func IsVideo 

func IsVideo(filename string) bool

IsVideo ...

func JSONRead 

func JSONRead(path string, v interface{}) error

JSONRead ...

func JSONWrite 

func JSONWrite(path string, v interface{}) error

JSONWrite ...

func LastSlice 

func LastSlice(s, sep string) string

LastSlice ...

func MoveCall 

func MoveCall(from, to string) (Stepper, MoveCaller)

MoveCall ...

func MustString 

func MustString(val, src string) string

MustString must string

func NumberIndex 

func NumberIndex(name string) int

NumberIndex ...

func OnlyName 

func OnlyName(name string) string

OnlyName ...

func OnlyNo 

func OnlyNo(name string) string

OnlyNo ...

func PathMD5 

func PathMD5(s ...string) string

PathMD5 ...

func ReadJSON 

func ReadJSON(path string, v interface{}) (e error)

ReadJSON ...

func SkipTypeVerify 

func SkipTypeVerify(tp model.Type, v ...interface{}) bool

SkipTypeVerify ...

func SkipVerify 

func SkipVerify(tp string, v ...interface{}) bool

SkipVerify ...

func SliceCall 

func SliceCall(file string, u *model.Unfinished, cb SliceCallbackFunc) (Stepper, SliceCaller)

SliceCall ...

func WriteJSON 

func WriteJSON(path string, v interface{}) (e error)

WriteJSON ...

Types

type API 

type API struct {
	*Thread
	// contains filtered or unexported fields
}

API ...

func NewAPI 

func NewAPI(path string) *API

NewAPI ...

func (*API) Failed 

func (api *API) Failed() bool

Failed ...

func (*API) Option 

func (api *API) Option(s Seeder)

Option ...

func (*API) Push 

func (api *API) Push(v interface{}) error

Push ...

func (*API) Run 

func (api *API) Run(ctx context.Context)

Run ...

func (*API) SetFailed 

func (api *API) SetFailed(failed bool)

SetFailed ...

type APICallbackFunc 

type APICallbackFunc func(api *API, ipapi *httpapi.HttpApi, v interface{}) (e error)

APICallbackFunc ...

type APICaller 

type APICaller interface {
	Call(*API, *httpapi.HttpApi) error
}

APICaller ...

type AfterInitOptions 

type AfterInitOptions func(Seeder)

AfterInitOptions ...

type BeforeUpdate 

type BeforeUpdate func(session *xorm.Session, modeler model.Modeler) (id interface{}, e error)

BeforeUpdate ...

type Database 

type Database struct {
	*Thread
	// contains filtered or unexported fields
}

Database ...

func NewDatabase 

func NewDatabase(eng *xorm.Engine, args ...DatabaseArgs) *Database

NewDatabase ...

func (*Database) Option 

func (db *Database) Option(seed Seeder)

Option ...

func (*Database) Push 

func (db *Database) Push(v interface{}) error

Push ...

func (*Database) RegisterSync 

func (db *Database) RegisterSync(v ...interface{})

RegisterSync ...

func (*Database) Run 

func (db *Database) Run(ctx context.Context)

Run ...

func (*Database) Sync 

func (db *Database) Sync() error

Sync ...

type DatabaseArgs 

type DatabaseArgs func(*Database)

DatabaseArgs ...

func DatabaseShowExecTimeArg 

func DatabaseShowExecTimeArg() DatabaseArgs

DatabaseShowExecTimeArg ...

func DatabaseShowSQLArg 

func DatabaseShowSQLArg() DatabaseArgs

DatabaseShowSQLArg ...

type DatabaseCallbackFunc 

type DatabaseCallbackFunc func(database *Database, eng *xorm.Engine, v interface{}) (e error)

DatabaseCallbackFunc ...

type DatabaseCaller 

type DatabaseCaller interface {
	Call(database *Database, eng *xorm.Engine) (e error)
}

DatabaseCaller ...

type Extend 

type Extend struct {
	Path    string `json:"path"`
	Message string `json:"message"`
}

Extend ...

type Initer 

type Initer interface {
	Init()
}

Initer ...

type Move 

type Move struct {
	*Thread

	ToPath string
	// contains filtered or unexported fields
}

Move ...

func NewMove 

func NewMove() *Move

NewMove ...

func (*Move) Push 

func (m *Move) Push(v interface{}) error

Push ...

func (*Move) Register 

func (m *Move) Register(ops ...Optioner)

Register ...

func (*Move) Run 

func (m *Move) Run(ctx context.Context)

Run ...

type MoveCallbackFunc 

type MoveCallbackFunc func(move *Move) error

MoveCallbackFunc ...

type MoveCaller 

type MoveCaller interface {
	Call(*Move) error
}

MoveCaller ...

type Optioner 

type Optioner interface {
	Option(Seeder)
}

Optioner set option

type Options 

type Options func(seeder Seeder)

Options ...

func MoveOption 

func MoveOption(stepper Stepper, Move *Move) Options

MoveOption ...

type PeerID 

type PeerID struct {
	Addresses       []string `json:"Addresses"`
	AgentVersion    string   `json:"AgentVersion"`
	ID              string   `json:"ID"`
	ProtocolVersion string   `json:"ProtocolVersion"`
	PublicKey       string   `json:"PublicKey"`
}

PeerID ...

func MyID 

func MyID(api *API) (*PeerID, error)

type Process 

type Process struct {
	*Thread
	// contains filtered or unexported fields
}

Process ...

func NewProcess 

func NewProcess() *Process

NewProcess ...

func (*Process) Option 

func (p *Process) Option(seeder Seeder)

Option ...

func (*Process) Push 

func (p *Process) Push(v interface{}) error

Push ...

func (*Process) Run 

func (p *Process) Run(ctx context.Context)

Run ...

type ProcessCallbackFunc 

type ProcessCallbackFunc func(*Process, *model.Video) error

ProcessCallbackFunc ...

type ProcessCaller 

type ProcessCaller interface {
	Call(process *Process) error
}

ProcessCaller ...

type PushFunc 

type PushFunc func(interface{}) error

PushFunc ...

type Pusher 

type Pusher interface {
	Push(interface{}) error
}

Pusher ...

type Runnable 

type Runnable interface {
	Run(context.Context)
}

Runnable ...

type Scale 

type Scale int64

Scale ... 

const HighScale Scale = 1080

HighScale ... 

const LowScale Scale = 480

LowScale ... 

const MiddleScale Scale = 720

MiddleScale ...

type Seeder 

type Seeder interface {
	Start()
	Wait()
	Stop()
	Context() context.Context
	PushTo(stepper Stepper, v interface{}) error
	GetThread(stepper Stepper) ThreadRun
	SetThread(stepper Stepper, threader ThreadRun)
	HasThread(stepper Stepper) bool
	SetBaseThread(stepper Stepper, threader Threader)
	IsBase(stepper Stepper) bool
	SetNormalThread(stepper Stepper, threader ThreadRun)
	IsNormal(stepper Stepper) bool
	Register(ops ...Optioner)
	RunTask(task *Task)
	AddTasker(tasker Tasker)
}

Seeder ...

func NewSeed 

func NewSeed(ops ...Optioner) Seeder

NewSeed ...

type Slice 

type Slice struct {
	*Thread
	Scale       Scale
	SliceOutput string
	SkipType    []interface{}
	SkipExist   bool
	SkipSlice   bool
	// contains filtered or unexported fields
}

Slice ...

func NewSlice 

func NewSlice() *Slice

NewSlice ...

func (*Slice) Option 

func (s *Slice) Option(seed Seeder)

Option ...

func (*Slice) Push 

func (s *Slice) Push(v interface{}) error

Push ...

func (*Slice) Run 

func (s *Slice) Run(ctx context.Context)

Run ...

type SliceCallbackFunc 

type SliceCallbackFunc func(s *Slice, sa *cmd.SplitArgs, v interface{}) (e error)

SliceCallbackFunc ...

type SliceCaller 

type SliceCaller interface {
	Call(*Slice) error
}

SliceCaller ...

type State 

type State int

State ... 

const (
	// StateWaiting ...
	StateWaiting State = iota
	// StateRunning ...
	StateRunning
	// StateStop ...
	StateStop
)

State ...

type Stepper 

type Stepper int

Stepper ... 

const (
	// StepperNone ...
	StepperNone Stepper = iota

	//StepperRDatabase ...
	//StepperRDatabase
	//StepperDatabase ...
	StepperDatabase

	//StepperAPI ...
	StepperAPI
	//StepperSlice ...
	StepperSlice
	// StepperProcess ...
	StepperProcess

	// StepperMoveInfo ...
	StepperMoveInfo

	// StepperMove ...
	StepperMove
	// StepperTransfer ...
	StepperTransfer
	// StepperPin ...
	StepperPin
	// StepperCheck ...
	StepperCheck
	// StepperUpdate ...
	StepperUpdate
	// StepperTask ...
	StepperTask

	// StepperMax ...
	StepperMax
)

StepperNone ...

type Task 

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

Task ...

func NewTask 

func NewTask(task TaskAble) *Task

NewTask ...

func (*Task) Push 

func (t *Task) Push(seeder Seeder) error

Push ...

type TaskAble 

type TaskAble interface {
	//Step() Stepper
	CallTask(Seeder, *Task) error
}

TaskAble ...

type TaskStep 

type TaskStep int

TaskStep ... 

const (
	TaskNone TaskStep = iota
	TaskInformation
	TaskMax
)

TaskStep ...

type Tasker 

type Tasker interface {
	Task() *Task
}

Tasker ...

type Thread 

type Thread struct {
	Seeder
	// contains filtered or unexported fields
}

Thread ...

func NewThread 

func NewThread() *Thread

NewThread ...

func (*Thread) AfterRun 

func (t *Thread) AfterRun(seed Seeder)

AfterRun ...

func (*Thread) BeforeRun 

func (t *Thread) BeforeRun(seed Seeder)

BeforeRun ...

func (*Thread) Done 

func (t *Thread) Done() <-chan bool

Done ...

func (*Thread) Finished 

func (t *Thread) Finished()

Finished ...

func (*Thread) Push 

func (t *Thread) Push(v interface{}) error

Push ...

func (*Thread) Run 

func (t *Thread) Run(context.Context)

Run ...

func (*Thread) SetState 

func (t *Thread) SetState(state State)

SetState ...

func (*Thread) State 

func (t *Thread) State() State

State ...

type ThreadBase 

type ThreadBase interface {
	State() State
	SetState(state State)
	Done() <-chan bool
	Finished()
}

ThreadBase ...

type ThreadRun 

type ThreadRun interface {
	Runnable
	Pusher
	BeforeRun(seed Seeder)
	AfterRun(seed Seeder)
}

ThreadRun ...

type Threader 

type Threader interface {
	ThreadRun
	ThreadBase
}

Threader ...

Source Files

View all Source files

Directories

Path Synopsis
cmd
checksum
fixbson
move
rename
trans

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.