database

type AuditActorMetadata = map[string]any

type AuditRecord struct {
	ID            int64                   `db:"id"`
	UUID          uuid.UUID               `db:"uuid"`
	CreatedAt     time.Time               `db:"created_at"`
	Action        AuditRecordActionType   `db:"action"`
	ResourceType  AuditRecordResourceType `db:"resource_type"`
	Source        AuditRecordSourceType   `db:"source"`
	ActorID       *int64                  `db:"actor_id"`
	ActorName     string                  `db:"actor_name"`
	ActorMetadata AuditActorMetadata      `db:"actor_metadata"`
	Resource      AuditResource           `db:"resource"`
}

type AuditRecordActionType string

type AuditRecordResourceType string

type AuditRecordSourceType string

type AuditRecordsCreateParams struct {
	Action        AuditRecordActionType   `db:"action"`
	ResourceType  AuditRecordResourceType `db:"resource_type"`
	Source        AuditRecordSourceType   `db:"source"`
	ActorID       *int64                  `db:"actor_id"`
	ActorName     string                  `db:"actor_name"`
	ActorMetadata AuditActorMetadata      `db:"actor_metadata"`
	Resource      AuditResource           `db:"resource"`
}

type AuditRecordsListParams struct {
	ActorID      *int64     `db:"actor_id"`
	ActorName    string     `db:"actor_name"`
	ResourceType string     `db:"resource_type"`
	Action       string     `db:"action"`
	FromAt       *time.Time `db:"from_at"`
	ToAt         *time.Time `db:"to_at"`
	PageOffset   int64      `db:"page_offset"`
	PageLimit    int64      `db:"page_limit"`
}

type AuditResource = json.RawMessage

type DB struct {
	*Queries
	// contains filtered or unexported fields
}

type DBTX interface {
	Exec(context.Context, string, ...interface{}) (pgconn.CommandTag, error)
	Query(context.Context, string, ...interface{}) (pgx.Rows, error)
	QueryRow(context.Context, string, ...interface{}) pgx.Row
}

type DNSRecord struct {
	ID             *int64        `db:"id"`
	PayloadID      int64         `db:"payload_id"`
	Name           string        `db:"name"`
	Type           DNSRecordType `db:"type"`
	TTL            int           `db:"ttl"`
	Values         []string      `db:"values"`
	Strategy       DNSStrategy   `db:"strategy"`
	LastAnswer     []string      `db:"last_answer"`
	LastAccessedAt *time.Time    `db:"last_accessed_at"`
	CreatedAt      time.Time     `db:"created_at"`
	Index          int           `db:"index"`
}

type DNSRecordType string

type DNSRecordsCreateParams struct {
	PayloadID      int64         `db:"payload_id"`
	Name           string        `db:"name"`
	Type           DNSRecordType `db:"type"`
	TTL            int           `db:"ttl"`
	Values         []string      `db:"values"`
	Strategy       DNSStrategy   `db:"strategy"`
	LastAnswer     []string      `db:"last_answer"`
	LastAccessedAt *time.Time    `db:"last_accessed_at"`
}

type DNSRecordsGetByPayloadNameAndTypeParams struct {
	PayloadID int64         `db:"payload_id"`
	Name      string        `db:"name"`
	Type      DNSRecordType `db:"type"`
}

type DNSRecordsUpdateParams struct {
	ID             *int64        `db:"id"`
	PayloadID      int64         `db:"payload_id"`
	Name           string        `db:"name"`
	Type           DNSRecordType `db:"type"`
	TTL            int           `db:"ttl"`
	Values         []string      `db:"values"`
	Strategy       DNSStrategy   `db:"strategy"`
	LastAnswer     []string      `db:"last_answer"`
	LastAccessedAt *time.Time    `db:"last_accessed_at"`
}

type DNSStrategy string

type Event struct {
	ID         int64      `db:"id"`
	PayloadID  int64      `db:"payload_id"`
	Protocol   string     `db:"protocol"`
	Meta       EventsMeta `db:"meta"`
	RemoteAddr string     `db:"remote_addr"`
	ReceivedAt time.Time  `db:"received_at"`
	CreatedAt  time.Time  `db:"created_at"`
	UUID       uuid.UUID  `db:"uuid"`
	Data       [][]byte   `db:"data"`
}

type EventsCreateParams struct {
	UUID       uuid.UUID  `db:"uuid"`
	PayloadID  int64      `db:"payload_id"`
	Protocol   string     `db:"protocol"`
	Data       [][]byte   `db:"data"`
	Meta       EventsMeta `db:"meta"`
	RemoteAddr string     `db:"remote_addr"`
	ReceivedAt time.Time  `db:"received_at"`
}

type EventsGetByPayloadAndIndexRow struct {
	Event Event `db:"event"`
	Index int64 `db:"index"`
}

type EventsListByPayloadIDParams struct {
	PayloadID int64 `db:"payload_id"`
	Limit     int64 `db:"limit"`
	Offset    int64 `db:"offset"`
}

type EventsListByPayloadIDRow struct {
	Event Event `db:"event"`
	Index int64 `db:"index"`
}

type EventsMeta struct {
	// Protocol-specific metadata (only one is populated per event)
	DNS  *dnsx.Meta  `json:"dns,omitempty"`
	HTTP *httpx.Meta `json:"http,omitempty"`
	SMTP *smtpx.Meta `json:"smtp,omitempty"`
	FTP  *ftpx.Meta  `json:"ftp,omitempty"`

	// Common fields across protocols
	Secure bool `json:"secure,omitempty"`

	// GeoIP information (populated by event handler for all protocols)
	GeoIP *geoipx.Meta `json:"geoip,omitempty"`
}

type HTTPHeaders = map[string][]string

type HTTPRoute struct {
	ID        int64       `db:"id"`
	PayloadID int64       `db:"payload_id"`
	Method    string      `db:"method"`
	Path      string      `db:"path"`
	Code      int         `db:"code"`
	Headers   HTTPHeaders `db:"headers"`
	Body      []byte      `db:"body"`
	IsDynamic bool        `db:"is_dynamic"`
	CreatedAt time.Time   `db:"created_at"`
	Index     int         `db:"index"`
}

type HTTPRoutesCreateParams struct {
	PayloadID int64       `db:"payload_id"`
	Method    string      `db:"method"`
	Path      string      `db:"path"`
	Code      int         `db:"code"`
	Headers   HTTPHeaders `db:"headers"`
	Body      []byte      `db:"body"`
	IsDynamic bool        `db:"is_dynamic"`
}

type HTTPRoutesGetByPayloadMethodAndPathParams struct {
	PayloadID int64  `db:"payload_id"`
	Method    string `db:"method"`
	Path      string `db:"path"`
}

type HTTPRoutesUpdateParams struct {
	ID        int64       `db:"id"`
	PayloadID int64       `db:"payload_id"`
	Method    string      `db:"method"`
	Path      string      `db:"path"`
	Code      int         `db:"code"`
	Headers   HTTPHeaders `db:"headers"`
	Body      []byte      `db:"body"`
	IsDynamic bool        `db:"is_dynamic"`
}

type NullAuditRecordActionType struct {
	AuditRecordActionType AuditRecordActionType
	Valid                 bool // Valid is true if AuditRecordActionType is not NULL
}

type NullAuditRecordResourceType struct {
	AuditRecordResourceType AuditRecordResourceType
	Valid                   bool // Valid is true if AuditRecordResourceType is not NULL
}

type NullAuditRecordSourceType struct {
	AuditRecordSourceType AuditRecordSourceType
	Valid                 bool // Valid is true if AuditRecordSourceType is not NULL
}

type NullDNSRecordType struct {
	DNSRecordType DNSRecordType
	Valid         bool // Valid is true if DNSRecordType is not NULL
}

type NullDNSStrategy struct {
	DNSStrategy DNSStrategy
	Valid       bool // Valid is true if DNSStrategy is not NULL
}

type Payload struct {
	ID              int64     `db:"id"`
	UserID          int64     `db:"user_id"`
	Subdomain       string    `db:"subdomain"`
	Name            string    `db:"name"`
	CreatedAt       time.Time `db:"created_at"`
	NotifyProtocols []string  `db:"notify_protocols"`
	StoreEvents     bool      `db:"store_events"`
}

type PayloadsCreateParams struct {
	UserID          int64    `db:"user_id"`
	Subdomain       string   `db:"subdomain"`
	Name            string   `db:"name"`
	NotifyProtocols []string `db:"notify_protocols"`
	StoreEvents     bool     `db:"store_events"`
}

type PayloadsFindByUserAndNameParams struct {
	UserID int64  `db:"user_id"`
	Name   string `db:"name"`
	Limit  int64  `db:"limit"`
	Offset int64  `db:"offset"`
}

type PayloadsUpdateParams struct {
	ID              int64    `db:"id"`
	Subdomain       string   `db:"subdomain"`
	UserID          int64    `db:"user_id"`
	Name            string   `db:"name"`
	NotifyProtocols []string `db:"notify_protocols"`
	StoreEvents     bool     `db:"store_events"`
}

type Querier interface {
	AuditRecordsCreate(ctx context.Context, arg AuditRecordsCreateParams) (*AuditRecord, error)
	AuditRecordsGetByID(ctx context.Context, id int64) (*AuditRecord, error)
	AuditRecordsList(ctx context.Context, arg AuditRecordsListParams) ([]*AuditRecord, error)
	DNSRecordsCreate(ctx context.Context, arg DNSRecordsCreateParams) (*DNSRecord, error)
	DNSRecordsDelete(ctx context.Context, id *int64) error
	DNSRecordsDeleteAllByPayloadID(ctx context.Context, payloadID int64) ([]*DNSRecord, error)
	DNSRecordsDeleteAllByPayloadIDAndName(ctx context.Context, payloadID int64, name string) ([]*DNSRecord, error)
	DNSRecordsGetByID(ctx context.Context, id *int64) (*DNSRecord, error)
	DNSRecordsGetByPayloadID(ctx context.Context, payloadID int64) ([]*DNSRecord, error)
	DNSRecordsGetByPayloadIDAndIndex(ctx context.Context, payloadID int64, index int) (*DNSRecord, error)
	DNSRecordsGetByPayloadNameAndType(ctx context.Context, arg DNSRecordsGetByPayloadNameAndTypeParams) (*DNSRecord, error)
	DNSRecordsGetCountByPayloadID(ctx context.Context, payloadID int64) (int64, error)
	DNSRecordsUpdate(ctx context.Context, arg DNSRecordsUpdateParams) (*DNSRecord, error)
	EventsCreate(ctx context.Context, arg EventsCreateParams) (*Event, error)
	EventsGetByID(ctx context.Context, id int64) (*Event, error)
	EventsGetByPayloadAndIndex(ctx context.Context, payloadID int64, index int64) (*EventsGetByPayloadAndIndexRow, error)
	EventsListByPayloadID(ctx context.Context, arg EventsListByPayloadIDParams) ([]*EventsListByPayloadIDRow, error)
	HTTPRoutesCreate(ctx context.Context, arg HTTPRoutesCreateParams) (*HTTPRoute, error)
	HTTPRoutesDelete(ctx context.Context, id int64) error
	HTTPRoutesDeleteAllByPayloadID(ctx context.Context, payloadID int64) ([]*HTTPRoute, error)
	HTTPRoutesDeleteAllByPayloadIDAndPath(ctx context.Context, payloadID int64, path string) ([]*HTTPRoute, error)
	HTTPRoutesGetByID(ctx context.Context, id int64) (*HTTPRoute, error)
	HTTPRoutesGetByPayloadID(ctx context.Context, payloadID int64) ([]*HTTPRoute, error)
	HTTPRoutesGetByPayloadIDAndIndex(ctx context.Context, payloadID int64, index int) (*HTTPRoute, error)
	HTTPRoutesGetByPayloadMethodAndPath(ctx context.Context, arg HTTPRoutesGetByPayloadMethodAndPathParams) (*HTTPRoute, error)
	HTTPRoutesUpdate(ctx context.Context, arg HTTPRoutesUpdateParams) (*HTTPRoute, error)
	PayloadsCreate(ctx context.Context, arg PayloadsCreateParams) (*Payload, error)
	PayloadsDelete(ctx context.Context, id int64) (*Payload, error)
	PayloadsDeleteByNamePart(ctx context.Context, userID int64, name string) ([]*Payload, error)
	PayloadsFindByUserAndName(ctx context.Context, arg PayloadsFindByUserAndNameParams) ([]*Payload, error)
	PayloadsFindByUserID(ctx context.Context, userID int64) ([]*Payload, error)
	PayloadsGetAllSubdomains(ctx context.Context) ([]string, error)
	PayloadsGetByID(ctx context.Context, id int64) (*Payload, error)
	PayloadsGetBySubdomain(ctx context.Context, subdomain string) (*Payload, error)
	PayloadsGetByUserAndName(ctx context.Context, userID int64, name string) (*Payload, error)
	PayloadsUpdate(ctx context.Context, arg PayloadsUpdateParams) (*Payload, error)
	UsersCreate(ctx context.Context, arg UsersCreateParams) (*User, error)
	UsersDelete(ctx context.Context, id int64) error
	UsersGetAdmin(ctx context.Context) (*User, error)
	UsersGetByAPIToken(ctx context.Context, token string) (*User, error)
	UsersGetByID(ctx context.Context, id int64) (*User, error)
	UsersGetByLarkID(ctx context.Context, id string) (*User, error)
	UsersGetByName(ctx context.Context, name string) (*User, error)
	UsersGetBySlackID(ctx context.Context, id string) (*User, error)
	UsersGetByTelegramID(ctx context.Context, id int64) (*User, error)
	UsersList(ctx context.Context) ([]*User, error)
	UsersUpdate(ctx context.Context, arg UsersUpdateParams) (*User, error)
}

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

type User struct {
	ID         int64     `db:"id"`
	Name       string    `db:"name"`
	CreatedAt  time.Time `db:"created_at"`
	IsAdmin    bool      `db:"is_admin"`
	CreatedBy  *int64    `db:"created_by"`
	TelegramID *int64    `db:"telegram_id"`
	SlackID    *string   `db:"slack_id"`
	LarkID     *string   `db:"lark_id"`
	APIToken   *string   `db:"api_token"`
}

type UsersCreateParams struct {
	Name       string  `db:"name"`
	IsAdmin    bool    `db:"is_admin"`
	CreatedBy  *int64  `db:"created_by"`
	APIToken   *string `db:"api_token"`
	TelegramID *int64  `db:"telegram_id"`
	LarkID     *string `db:"lark_id"`
	SlackID    *string `db:"slack_id"`
}

type UsersUpdateParams struct {
	ID         int64   `db:"id"`
	Name       string  `db:"name"`
	IsAdmin    bool    `db:"is_admin"`
	CreatedBy  *int64  `db:"created_by"`
	APIToken   *string `db:"api_token"`
	TelegramID *int64  `db:"telegram_id"`
	LarkID     *string `db:"lark_id"`
	SlackID    *string `db:"slack_id"`
}