tickets

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

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

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

type Loggable interface {
	Loggable() map[string]interface{}
}

type NotInitializeError struct{}

type Ticket interface {
	Publisher() peer.ID // Needed because the ticket receiver should send ack to ticket sender
	SendTo() peer.ID
	Cid() cid.Cid
	Level() int64 // Higher level, lower priority
	//Valid(peer.ID, peer.ID) bool
	GetSize() int64
	GetState() int32
	BasicInfo() string
	//Called when receive ack for this Ticket
	ACKed()
	//Called when receive cancel for thie Ticket
	Canceled()
	//TODO: Add digital signature to ticket. - Riften
	//Signature String
	ToProto() *pb.Ticket

	SetPublisher(peer.ID)
	SetTimeStamp(timeStamp int64)

	Loggable
}

type TicketAck interface {
	// Publisher, Receiver, Cid should return the same value as Ticket
	// They identify the ack for specific ticket
	Publisher() peer.ID
	Receiver() peer.ID
	Cid() cid.Cid

	// Type of ack
	ACK() int32
	ToProto() *pb.TicketAck

	//Loggable() map[string]interface{}
	Loggable
}

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

type TicketStore interface {
	AddTicket(ticket Ticket) error // called after sending a ticket
	AddTickets(ticket []Ticket) error
	GetTickets(cid cid.Cid) ([]Ticket, error)
	//GetTicketsByCids(cids []cid.Cid) (map[cid.Cid] []Ticket, error)
	RemoveTicket(pid peer.ID, cid cid.Cid) error // remove a specific ticket from the `sended ticket list`, called after receive a reject
	RemoveTicketEqualsTo(ticket Ticket)
	Clean()
	RemoveCanceled() int

	PopTickets() *TicketTask

	TicketNumber() int
	TicketSize() int64

	// Interfaces for sending tickets - Add by Jerry
	RemoveTickets(pid peer.ID, cids []cid.Cid) error     // remove a set of tickets from the `sended ticket list`
	PrepareSending(acks []TicketAck) error               // called if don't have corresponding block when receiving an ACK, put the entry on a list
	RemoveSendingTask(pid peer.ID, cids []cid.Cid) error // remove a specific task from the `prepared sending task list`, called after receive a reject
	PopSendingTasks(cids []cid.Cid) ([]TicketAck, error) // pop all tasks for a specific cid in `prepared sending task list`, called when a block is received
	PredictTime() int64                                  // Get the predicted time used to complete all the tickets sent. Return time in millsecond

	// Interfaces for receving tickets - Add by Jerry
	StoreReceivedTickets(tickets []Ticket) error
	GetReceivedTicket(cids []cid.Cid) (map[cid.Cid]Ticket, error)
}

type TicketTask struct {
	Target  peer.ID
	Tickets []Ticket
}