models

type Block struct {
	Timestamp   time.Time `ch:"timestamp" json:"timestamp"`
	Network     string    `ch:"network" json:"network"`
	Number      uint64    `ch:"number" json:"number"`
	Hash        string    `ch:"hash" json:"hash"`
	Key         string    `ch:"key" json:"key"`
	Metadata    string    `ch:"metadata" json:"metadata"`
	DASRows     uint32    `ch:"das_rows" json:"das_rows"`
	DASColumns  uint32    `ch:"das_columns" json:"das_columns"`
	SampleUntil time.Time `ch:"sample_until" json:"sample_until"`
}

type GeneralVisit struct {
	GenericVisit           []*SampleGenericVisit
	GenericValueVisit      []*SampleValueVisit
	GenericPeerInfoVisit   []*PeerInfoVisit
	GenericIPNSRecordVisit []*IPNSRecordVisit
}

type IPNSRecordVisit struct {
	VisitRound    uint64        `ch:"visit_round" json:"visit_round"` // Round number of the crawling visit
	Timestamp     time.Time     `ch:"timestamp" json:"timestamp"`     // When the peer was visited
	Record        string        `ch:"record" json:"record"`           // Unique identifier of the IPNS record
	RecordType    string        `ch:"record_type" json:"record_type"` // Type of IPNS record (e.g., "ipns-record", "dns-link")
	Quorum        uint8         `ch:"quorum" json:"quorum"`           // Quorum target for the DHT lookup
	SeqNumber     uint32        `ch:"seq_number" json:"seq_number"`   // The highest found version for the ipns record
	TTL           time.Duration `ch:"ttl" json:"ttl"`
	IsValid       bool          `ch:"is_valid" json:"is_valid"`
	IsRetrievable bool          `ch:"is_retrievable" json:"is_retrievable"` // Whether the item was retrievable or not from the Network
	Result        string        `ch:"result" json:"result"`                 // Resulting CID/Link representation
	Duration      time.Duration `ch:"duration" json:"duration"`             // Time taken to establish connection/gather info
	Error         string        `ch:"error" json:"error"`                   // Error message if visit failed
}

type PeerInfoVisit struct {
	VisitRound      uint64                `ch:"visit_round" json:"visit_round"`         // Round number of the crawling visit
	Timestamp       time.Time             `ch:"timestamp" json:"timestamp"`             // When the peer was visited
	Network         string                `ch:"network" json:"network"`                 // Network identifier (e.g., "ipfs", "libp2p")
	PeerID          string                `ch:"peerID" json:"peerID"`                   // Unique identifier of the peer
	Duration        time.Duration         `ch:"duration" json:"duration"`               // Time taken to establish connection/gather info
	AgentVersion    string                `ch:"agentVersion" json:"agentVersion"`       // Software version reported by the peer
	Protocols       []protocol.ID         `ch:"protocols" json:"protocols"`             // List of protocols supported by the peer
	ProtocolVersion string                `ch:"protocolVersion" json:"protocolVersion"` // Version of the main protocol
	MultiAddresses  []multiaddr.Multiaddr `ch:"multiAddresses" json:"multiAddresses"`   // Network addresses where peer can be reached
	Error           string                `ch:"error" json:"error"`                     // Error message if visit failed
}

type SampleGenericVisit struct {
	VisitType     string    `ch:"visit_type" json:"visit_type"`
	VisitRound    uint64    `ch:"visit_round" json:"visit_round"`
	Network       string    `ch:"network" json:"network"`
	Timestamp     time.Time `ch:"timestamp" json:"timestamp"`
	Key           string    `ch:"key" json:"key"`
	DurationMs    int64     `ch:"duration_ms" json:"duration_ms"`
	ResponseItems int32     `ch:"response_items" json:"response_items"`
	Peers         []string  `ch:"peer_ids" json:"peer_ids"`
	Error         string    `ch:"error" json:"error"`
}

type SampleValueVisit struct {
	VisitType     string    `ch:"visit_type" json:"visit_type"`
	VisitRound    uint64    `ch:"visit_round" json:"visit_round"`
	Network       string    `ch:"network" json:"network"`
	Timestamp     time.Time `ch:"timestamp" json:"timestamp"`
	Key           string    `ch:"key" json:"key"`
	BlockNumber   uint64    `ch:"block_number" json:"block_number"`
	DASRow        uint32    `ch:"das_row" json:"rdas_row"`
	DASColumn     uint32    `ch:"das_column" json:"das_column"`
	DurationMs    int64     `ch:"duration_ms" json:"duration_ms"`
	IsRetrievable bool      `ch:"is_retrievable" json:"is_retrievable"`
	Bytes         int32     `ch:"bytes" json:"bytes"`
	Error         string    `ch:"error" json:"error"`
}

type SamplingItem struct {
	Timestamp   time.Time `ch:"timestamp" json:"timestamp"`
	Network     string    `ch:"network" json:"network"`
	ItemType    string    `ch:"item_type" json:"item_type"`
	SampleType  string    `ch:"sample_type" json:"sample_type"`
	BlockLink   uint64    `ch:"block_link" json:"block_link"`
	Key         string    `ch:"key" json:"key"`
	Hash        string    `ch:"hash" json:"hash"`
	DASRow      uint32    `ch:"das_row" json:"das_row"`
	DASColumn   uint32    `ch:"das_column" json:"das_column"`
	Metadata    string    `ch:"metadata" json:"metadata"`
	Traceable   bool      `ch:"traceable" json:"traceable"`
	SampleUntil time.Time `ch:"sample_until" json:"sample_until"`
	NextVisit   time.Time // internal for the ItemSet
}