migrateagent

type AdvanceOptions struct {
	// AckEmpty accepts volumes that hold no files on either side.
	AckEmpty bool
}

type AdvanceResult struct {
	Advanced bool     `json:"advanced"`
	Reason   string   `json:"reason,omitempty"`
	Evidence []string `json:"evidence,omitempty"`
}

type AppVolume struct {
	Name   string `json:"name"`
	Source string `json:"source"`
}

type AuditSaver interface {
	SaveAuditEntry(ctx context.Context, e store.AuditEntry) error
}

type Auditor struct {
	Saver  AuditSaver
	Logger *slog.Logger
	Now    func() time.Time
}

type Comparison struct {
	Name        string `json:"name"`
	Source      string `json:"source"`
	SourceFiles int64  `json:"source_files"`
	SourceBytes int64  `json:"source_bytes"`
	TargetFiles int64  `json:"target_files"`
	TargetBytes int64  `json:"target_bytes"`
	Status      string `json:"status"`
	TargetFrom  string `json:"target_from,omitempty"`
	Detail      string `json:"detail,omitempty"`
}

type Config struct {
	TokenTTL       time.Duration
	SessionMax     time.Duration
	RequestTimeout time.Duration
	VolumesDir     string
	// EnrollRate is the enroll attempts one source address may make per EnrollWindow.
	EnrollRate   int
	EnrollWindow time.Duration
	// AgentFieldMax caps the version, os and arch strings an agent reports.
	AgentFieldMax int
}

type ContainerDoc struct {
	ID              string     `json:"id"`
	Name            string     `json:"name"`
	Image           string     `json:"image"`
	State           string     `json:"state"`
	Status          string     `json:"status"`
	EnvKeys         []string   `json:"env_keys,omitempty"`
	Mounts          []MountDoc `json:"mounts,omitempty"`
	Ports           []string   `json:"ports,omitempty"`
	DatabaseEngine  string     `json:"database_engine,omitempty"`
	DatabaseVersion string     `json:"database_version,omitempty"`
	// Unlisted is true when no imported app matches this container, so a
	// platform API read would not have shown it.
	Unlisted bool `json:"unlisted"`
}

type Created struct {
	ID        string    `json:"id"`
	Token     string    `json:"token"`
	ExpiresAt time.Time `json:"expires_at"`
}

type Event struct {
	Action    string
	SessionID string
	Actor     string
	Status    int
	Remote    string
	Detail    map[string]any
}

type ImportedRef struct {
	App      string
	SourceID string
}

type InventoryDoc struct {
	DockerVersion string         `json:"docker_version"`
	Containers    []ContainerDoc `json:"containers"`
	Volumes       []VolumeDoc    `json:"volumes"`
	NetworkCount  int            `json:"network_count"`
	CollectedAt   time.Time      `json:"collected_at"`
}

type MountDoc struct {
	Type        string `json:"type"`
	Name        string `json:"name,omitempty"`
	Source      string `json:"source,omitempty"`
	Destination string `json:"destination"`
	ReadOnly    bool   `json:"read_only"`
}

type ScanDoc struct {
	At    time.Time `json:"at"`
	Stats []StatDoc `json:"stats"`
}

type Service struct {
	migrationpb.UnimplementedMigrationServiceServer
	// contains filtered or unexported fields
}

type SessionView struct {
	ID               string     `json:"id"`
	Label            string     `json:"label"`
	State            string     `json:"state"`
	TokenExpiresAt   time.Time  `json:"token_expires_at"`
	SessionExpiresAt *time.Time `json:"session_expires_at,omitempty"`
	ConnectedAt      *time.Time `json:"connected_at,omitempty"`
	LastSeenAt       *time.Time `json:"last_seen_at,omitempty"`
	AgentVersion     string     `json:"agent_version,omitempty"`
	AgentOS          string     `json:"agent_os,omitempty"`
	AgentArch        string     `json:"agent_arch,omitempty"`
	CreatedBy        string     `json:"created_by,omitempty"`
	CreatedAt        time.Time  `json:"created_at"`
}

type Signer interface {
	SignClientCSR(commonName string, csrDER []byte, validFor time.Duration, now time.Time) (agent.IssuedCert, error)
	CertPEM() []byte
}

type StatDoc struct {
	Target            string `json:"target"`
	Files             int64  `json:"files"`
	Bytes             int64  `json:"bytes"`
	ChangedDuringScan bool   `json:"changed_during_scan,omitempty"`
	Error             string `json:"error,omitempty"`
}

type Store interface {
	SaveMigrationAgentSession(ctx context.Context, s store.MigrationAgentSession) error
	GetMigrationAgentSession(ctx context.Context, id string) (store.MigrationAgentSession, error)
	ListMigrationAgentSessions(ctx context.Context) ([]store.MigrationAgentSession, error)
	RedeemMigrationAgentToken(ctx context.Context, id, fingerprint, serial string, sessionExpires, now time.Time) error
	SetMigrationAgentState(ctx context.Context, id, state string, now time.Time) error
	TouchMigrationAgentSession(ctx context.Context, id, version, goos, arch string, now time.Time) error
	SaveMigrationAgentInventory(ctx context.Context, id, inventoryJSON string, now time.Time) error
	SaveMigrationAgentScan(ctx context.Context, id, scanJSON string, now time.Time) error
	AuditSaver
}

type TargetStat struct {
	Files int64
	Bytes int64
	Err   string
	// Operator marks numbers typed in by the caller instead of measured here.
	Operator bool
}

type VolumeDoc struct {
	Name   string `json:"name"`
	Driver string `json:"driver"`
}