types

type AgentAuthenticator interface {
	Authenticate(ctx context.Context, clientID, clientSecret string, tenantID string) (string, string, error)
}

type AgentConnection interface {
	TenantID() string
	AgentID() string
	SendJob(ctx context.Context, req *bridgeproto.JobRequest) (*bridgeproto.JobResult, error)
	Close() error
}

type AgentRegistry interface {
	Register(ctx context.Context, tenantID string, agentID string, conn AgentConnection) error
	Unregister(ctx context.Context, tenantID string, agentID string)
	Pick(ctx context.Context, tenantID string) (AgentConnection, error)
	Stats() RegistryStats
	ObserveQuery(tenantID, agentID string, latency time.Duration)
}

type Auth interface {
	IsAuthenticated() bool
	Authenticate(onComplete func(success bool, err error))
	ShowAuthModal()
}

type BridgeAgentCredential struct {
	ClientID     string `mapstructure:"clientID"`
	ClientSecret string `mapstructure:"clientSecret"`
	TenantID     string `mapstructure:"tenantID"`
	AgentID      string `mapstructure:"agentID"`
}

type BridgeConfig struct {
	Mode                    string                  `mapstructure:"mode"` // embedded | remote
	ServerURL               string                  `mapstructure:"serverURL"`
	ClientID                string                  `mapstructure:"clientID"`
	ClientSecret            string                  `mapstructure:"clientSecret"`
	TenantID                string                  `mapstructure:"tenantID"`
	AutoConnectOnRegister   bool                    `mapstructure:"autoConnectOnRegister"`
	CredentialFile          string                  `mapstructure:"credentialFile"`
	TLS                     BridgeTLSConfig         `mapstructure:"tls"`
	Allowed                 []BridgeAgentCredential `mapstructure:"allowedAgents"`
	DefaultTenant           string                  `mapstructure:"defaultTenant"`
	PprofEnabled            bool                    `mapstructure:"pprofEnabled"`
	PprofPath               string                  `mapstructure:"pprofPath"`
	CredentialReloadSeconds int                     `mapstructure:"credentialReloadSeconds"`
	MaxRowsPerQuery         int                     `mapstructure:"maxRowsPerQuery"`
	MaxResultBytes          int64                   `mapstructure:"maxResultBytes"`
	Loki                    *LokiConfig             `mapstructure:"loki"`
}

type BridgeTLSConfig struct {
	InsecureSkipVerify bool `mapstructure:"insecureSkipVerify"`
}

type ColorValue struct {
	Error           tcell.Color
	Warning         tcell.Color
	Notice          tcell.Color
	WindowColor     tcell.Color
	ModalColor      tcell.Color
	CommandBarColor tcell.Color
	PrimaryText     tcell.Color
	SecondaryText   tcell.Color
	AccentColor     tcell.Color
	AccentTextColor tcell.Color
	BorderColor     tcell.Color
	TableHeader     tcell.Color
	TableRow        tcell.Color
	StatusBarBg     tcell.Color
	StatusBarText   tcell.Color
}

type ComponentLayout struct {
	SplitSidebar *tview.Flex
	MainMenu     *tview.List
	SubMenuList  *tview.List
	LogList      *tview.TextView
	OutputPanel  *tview.Flex
}

type ComponentStyle struct {
	ButtonStyle         tcell.Style
	PlaceholderStyle    tcell.Style
	FieldStyle          tcell.Style
	ListMainTextStyle   tcell.Style
	ListSelectedStyle   tcell.Style
	ListBorderStyle     tcell.Style
	TextAreaStyle       tcell.Style
	TableHeaderStyle    tcell.Style
	TableCellStyle      tcell.Style
	TableSelectedStyle  tcell.Style
	StatusBarStyle      tcell.Style
	PickerCellStyle     tcell.Style
	PickerSelectedStyle tcell.Style
}

type CreateModalDialogParam struct {
	Title         string
	RootView      tview.Primitive
	Draggable     bool
	Resizeable    bool
	Size          WinSize
	FallbackFocus tview.Primitive
}

type DISConfig struct {
	LogLevel           slog.Level    `mapstructure:"logLevel"`
	JDBCConfig         *JDBCConfig   `mapstructure:"jdbcConfig"`
	Host               string        `mapstructure:"host"`
	User               string        `mapstructure:"user"`
	Password           string        `mapstructure:"password"`
	MaxIdleConnections int           `mapstructure:"maxIdleConnections"`
	MaxOpenConnections int           `mapstructure:"maxOpenConnections"`
	Bridge             *BridgeConfig `mapstructure:"bridge"`
}

type DISReaderRemote interface {
	// Tenant is optional when a default was configured; otherwise required.
	StartJDBCRunner(ctx context.Context, tenant string) error
	StopJDBCRunner(ctx context.Context, tenant string) error
	Connect(ctx context.Context, tenant string) error
	Disconnect(ctx context.Context, tenant string) error
	PingBridge(ctx context.Context) error                  // PingBridge checks if the communication with the gRPC bridge server is alive
	PingAgent(ctx context.Context, tenant string) error    // PingAgent checks if the communication with the remote agent is alive
	PingService(ctx context.Context, tenant string) error  // PingService checks if the Java JDBC service is responsive
	PingDatabase(ctx context.Context, tenant string) error // PingDatabase checks if the DIS AS/400 database is reachable via the JDBC service
	UnitService(tenant string) UnitService
	InvoiceService(tenant string) InvoiceService
	PartService(tenant string) PartService
	// UpdateAgentConfig pushes a new AgentConfig to connected agents (optionally filtered by tenant)
	// and updates the server defaults used for future connections. If broadcast is false, only future
	// connections will see the update.
	UpdateAgentConfig(ctx context.Context, cfg *bridgeproto.AgentConfig, tenant string, broadcast bool) error
	// ReadAgentConfig requests a sanitized view of the agent's current configuration.
	ReadAgentConfig(ctx context.Context, tenant string) (*bridgeproto.AgentConfigStatus, error)
}

type DISReaderService interface {
	GetConfig() *DISConfig
	GetLogger() *slog.Logger
	SetLogger(logger *slog.Logger)
	Shutdown() error
	AttachShutdownHook()
	Connect(ctx context.Context) error
	Disconnect(ctx context.Context) error
	PingService(ctx context.Context) error  // PingService checks if the Java JDBC service is responsive
	PingDatabase(ctx context.Context) error // PingDatabase checks if the DIS AS/400 database is reachable via the JDBC service
	RunDebugSearch(searchTerm string, opts DebugSearchOptions, progressChan chan<- ProgressStatus, eventChan chan<- TableEvent)
	UnitService() UnitService
	InvoiceService() InvoiceService
	PartService() PartService
}

type DISUIConfig struct {
	AppName     string            `mapstructure:"appName"`
	AppVersion  string            `mapstructure:"appVersion"`
	Theme       string            `mapstructure:"theme"`
	DIS         *DISConfig        `mapstructure:"disConfig"`
	Bridge      *BridgeConfig     `mapstructure:"bridge"`
	DebugSearch DebugSearchConfig `mapstructure:"debugSearch"`
}

type DebugSearchConfig struct {
	DefaultOutputMode string `mapstructure:"defaultOutputMode"`
	DefaultOutputPath string `mapstructure:"defaultOutputPath"`
}

type DebugSearchOptions struct {
	OutputMode DebugSearchOutputMode
	OutputPath string
}

type DebugSearchOutputMode string

type DuplicateRecordError struct {
	Type string      `json:"type"`
	Key  interface{} `json:"key"`
	// contains filtered or unexported fields
}

type Error interface {
	GetTag() string
	GetStatus() int
}

type Filter struct {
	Field    string      // lower-case logical field name
	Operator string      // SQL operator, e.g. "=", "LIKE", ">", "<", "IN", "NOT IN"
	Value    interface{} // the value to compare against
	Column   string      // the SQL column name - to be added by parser
}

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

type GetDefaultSortByFunc func() string

type GetSupportedSortBys func() []string

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

type InvalidParameterError struct {
	Parameter string `json:"parameter"`
	// contains filtered or unexported fields
}

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

type InvoiceItemSpec struct {
	DocumentNumber       string     `json:"documentNumber"`
	LineID               string     `json:"lineId"`
	Division             string     `json:"division"`
	OrderSource          string     `json:"orderSource"`
	CustomerNumber       string     `json:"customerNumber"`
	VendorCode           string     `json:"vendorCode"`
	PartNumber           string     `json:"partNumber"`
	PostingDate          time.Time  `json:"postingDate"`
	FormatType           string     `json:"formatType"`
	ExceptionCode        string     `json:"exceptionCode"`
	Classification       string     `json:"classification"`
	Description          string     `json:"description"`
	PriceCode            string     `json:"priceCode"`
	Cost                 float64    `json:"cost"`
	Location             string     `json:"location"`
	Quantity             float64    `json:"quantity"`
	Price                float64    `json:"price"`
	TaxCode              string     `json:"taxCode"`
	DiscountRate         float64    `json:"discountRate"`
	Memo                 *string    `json:"memo,omitempty"`
	Rebill               bool       `json:"rebill"`
	Posted               bool       `json:"posted"`
	Stocked              bool       `json:"stocked"`
	Warranty             bool       `json:"warranty"`
	SerializedWarranty   bool       `json:"serializedWarranty"`
	SerialNumber         *string    `json:"serialNumber,omitempty"`
	AuditDivision        *string    `json:"auditDivision,omitempty"`
	AuditVendorCode      *string    `json:"auditVendorCode,omitempty"`
	AuditPostingDate     *time.Time `json:"auditPostingDate,omitempty"`
	AlternateDivision    *string    `json:"alternateDivision,omitempty"`
	AlternatePostingDate *time.Time `json:"alternatePostingDate,omitempty"`
	DiscountIndicator    *string    `json:"discountIndicator,omitempty"`
	ExtendedDescription  *string    `json:"extendedDescription,omitempty"`
	ProcessCode          *string    `json:"processCode,omitempty"`
	DemandCode           *string    `json:"demandCode,omitempty"`
	SeasonalCode         *string    `json:"seasonalCode,omitempty"`
	FreightTaxCode       *string    `json:"freightTaxCode,omitempty"`
	OriginFlag           *string    `json:"originFlag,omitempty"`
	UserField1           *string    `json:"userField1,omitempty"`
	UserField2           *string    `json:"userField2,omitempty"`
}

type InvoiceListParamParser struct{}

type InvoiceService interface {
	GetItem(ctx context.Context, documentNumber string, lineID string) (*InvoiceItemSpec, error)
	ListItems(ctx context.Context, lp ListParams) ([]*InvoiceItemSpec, error)
	GetWholeGoodsInvoice(ctx context.Context, invoiceNumber string, lineItemNumber string) (*WholeGoodsInvoiceSpec, error)
	ListWholeGoodsInvoices(ctx context.Context, lp ListParams) ([]*WholeGoodsInvoiceSpec, error)
}

type JDBCConfig struct {
	JavaPath string `mapstructure:"javaPath"`
	JDBCPort string `mapstructure:"jdbcPort"`
	JarPath  string `mapstructure:"jarPath"`
	ClassDir string `mapstructure:"classDir"`
}

type JDBCResult struct {
	Status  string `json:"status"`
	Message string `json:"message"`
}

type LatencyAgg struct {
	Count int64
	Sum   float64
	Max   float64
}

type ListParamParser interface {
	GetDefaultSortBy() string
	GetAllowedSortByColumns() map[string]string
	GetAllowedFilterColumns() map[string]string
	ParseValue(val string, sortBy string) (interface{}, error)
}

type ListParams struct {
	Page        int
	Limit       int
	Query       string
	SortBy      string
	SortOrder   SortOrder
	AfterId     string
	BeforeId    string
	AfterValue  interface{}
	BeforeValue interface{}
	// dynamic filters to apply in WHERE clauses
	Filters []Filter
}

type LokiConfig struct {
	URL        string            `mapstructure:"url"`
	TenantID   string            `mapstructure:"tenantID"`
	APIKey     string            `mapstructure:"apiKey"`
	AuthHeader string            `mapstructure:"authHeader"`
	Labels     map[string]string `mapstructure:"labels"`
	MinLevel   slog.Level        `mapstructure:"minLevel"`
}

type MenuDefinition struct {
	Title string
	Items []MenuItem
}

type MenuItem struct {
	MainText      string // The main text of the list item.
	SecondaryText string // A secondary text to be shown underneath the main text.
	Shortcut      rune   // The key to select the list item directly, 0 if there is no shortcut.
	Selected      func() // The optional function which is called when the item is selected.
}

type MissingRequiredParameterError struct {
	Parameter string `json:"parameter"`
	// contains filtered or unexported fields
}

type PanelDefinition struct {
	// Name is the title or identifier for the panel.
	Name string
	// View is the tview primitive to render as the output panel.
	View tview.Primitive
}

type PartInventorySpec struct {
	Division            string  `json:"division"`
	VendorCode          string  `json:"vendorCode"`
	PartNumber          string  `json:"partNumber"`
	Description         string  `json:"description"`
	BinLocation         string  `json:"binLocation"`
	QuickCode           string  `json:"quickCode"`
	ItemClass           string  `json:"itemClass"`
	ActiveFlag          string  `json:"activeFlag"`
	TaxCode             string  `json:"taxCode"`
	DateAddedYYYYMM     int32   `json:"dateAddedYYYYMM"`
	DateLastCountYYYYMM int32   `json:"dateLastCountYYYYMM"`
	DateLastSaleYYYYMM  int32   `json:"dateLastSaleYYYYMM"`
	UnitWeight          float64 `json:"unitWeight"`
	BackorderFlag       string  `json:"backorderFlag"`
	PackQty             int32   `json:"packQty"`
	OrderMultiplier     int32   `json:"orderMultiplier"`
	JobCode             int32   `json:"jobCode"`
	OnHandQty           int32   `json:"onHandQty"`
	ReservedSA          int32   `json:"reservedSA"`
	ReservedWO          int32   `json:"reservedWO"`
	AvailableQty        int32   `json:"availableQty"`
	ReturnableFlag      string  `json:"returnableFlag"`
	DateLastPriceUpdate int32   `json:"dateLastPriceUpdate"`
	AvgCost             float64 `json:"avgCost"`
	Price1Basis         string  `json:"price1Basis"`
	Price1Value         float64 `json:"price1Value"`
	Price2Basis         string  `json:"price2Basis"`
	Price2Value         float64 `json:"price2Value"`
	Price3Basis         string  `json:"price3Basis"`
	Price3Value         float64 `json:"price3Value"`
	Price4Basis         string  `json:"price4Basis"`
	Price4Value         float64 `json:"price4Value"`
	DeliverCode         string  `json:"deliverCode"`
	OrderCode           string  `json:"orderCode"`
	MinQty              int32   `json:"minQty"`
	MaxQty              int32   `json:"maxQty"`
	OrderQty            int32   `json:"orderQty"`
	LastReceiptDate     int32   `json:"lastReceiptDate"`
	LastReceiptQty      int32   `json:"lastReceiptQty"`
	StockFlag           string  `json:"stockFlag"`
	OpenOnSales         int32   `json:"openOnSales"`
	OpenOnPO            int32   `json:"openOnPO"`
	OpenOnRO            int32   `json:"openOnRO"`
	OpenOnReq           int32   `json:"openOnReq"`
	Peak12MoUsage       int32   `json:"peak12MoUsage"`
	MonthlyUsage        []int32 `json:"monthlyUsage"`
	MonthlyPurchases    []int32 `json:"monthlyPurchases"`
	YearUsageQty        []int32 `json:"yearUsageQty"`
	YearUsageValue      []int64 `json:"yearUsageValue"`
	Comment             string  `json:"comment"`
	CycleCountCode      string  `json:"cycleCountCode"`
	CorePartNumber      string  `json:"corePartNumber"`
	CoreQty             int32   `json:"coreQty"`
	CorePrice           float64 `json:"corePrice"`
	Sup1Vendor          string  `json:"sup1Vendor"`
	Sup1Part            string  `json:"sup1Part"`
	Sup1Price           float64 `json:"sup1Price"`
	Sup2Vendor          string  `json:"sup2Vendor"`
	Sup2Part            string  `json:"sup2Part"`
	Sup2Price           float64 `json:"sup2Price"`
	Sup3Vendor          string  `json:"sup3Vendor"`
	Sup3Part            string  `json:"sup3Part"`
	Sup3Price           float64 `json:"sup3Price"`
	RebuildIndicator    string  `json:"rebuildIndicator"`
	RebuildVendor       string  `json:"rebuildVendor"`
	RebuildPart         string  `json:"rebuildPart"`
	RebuildQtyFactor    int32   `json:"rebuildQtyFactor"`
	PriceScheduleCode   string  `json:"priceScheduleCode"`
	AutoPricingRule     string  `json:"autoPricingRule"`
	AutoPricingClass    string  `json:"autoPricingClass"`
	AutoPricingSource   string  `json:"autoPricingSource"`
	AutoPricingQtyBrk   int32   `json:"autoPricingQtyBrk"`
	AltAvailQty         float64 `json:"altAvailQty"`
	AltOnHandQty        float64 `json:"altOnHandQty"`
	AltUomUnits         int32   `json:"altUomUnits"`
	AltUomCode          string  `json:"altUomCode"`
	AltUomMultiple      int32   `json:"altUomMultiple"`
	AltUomBackorderFlag string  `json:"altUomBackorderFlag"`
	AltUomFreightFlag   string  `json:"altUomFreightFlag"`
	Message1            int32   `json:"message1"`
	Message2            int32   `json:"message2"`
	Message3            int32   `json:"message3"`
}

type PartListParamParser struct{}

type PartService interface {
	GetPart(ctx context.Context, division, partNumber string) (*PartInventorySpec, error)
	ListParts(ctx context.Context, lp ListParams) ([]*PartInventorySpec, error)
}

type ProgressStatus struct {
	RunID            string
	TotalQueries     int
	CompletedQueries int
	PercentComplete  float64
}

type RawListParams struct {
	PageParam        string
	LimitParam       string
	QueryParam       string
	SortByParam      string
	SortOrderParam   string
	AfterIdParam     string
	BeforeIdParam    string
	AfterValueParam  string
	BeforeValueParam string
	// Pre-parsed filters for programmatic usage
	FilterObjects []Filter
}

type RecordNotFoundError struct {
	Type string      `json:"type"`
	Key  interface{} `json:"key"`
	// contains filtered or unexported fields
}

type RegistryKey struct {
	Tenant string
	Agent  string
}

type RegistryStats struct {
	TotalAgents int
	Tenants     map[string]int
	QueryCounts map[RegistryKey]int64
	Latency     map[RegistryKey]LatencyAgg
}

type ResultRow map[string]interface{}

type SortOrder int

type TableEvent struct {
	TableName   string
	EventType   string // "table_created" or "row_inserted"
	RowCount    int
	ColumnCount int
	SampleRow   map[string]interface{}
}

type Theme struct {
	Name   string
	Colors ColorValue
	Style  ComponentStyle
}

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

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

type UI interface {
	SetFocus(p tview.Primitive)
	Run() error
	QuitApplication()

	GetLayout() *ComponentLayout
	GetDIS() DISReaderService
	GetTheme() *Theme
	GetApp() *tview.Application
	GetWinMan() *winman.Manager
	GetAuth() Auth
	GetConfig() *DISUIConfig
	RunPendingAction()
	SetPendingAction(f func())
	GetLogger() *slog.Logger
	AttachToDISLogger() error

	CreateModalDialog(param CreateModalDialogParam) *winman.WindowBase
	CloseModalDialog(wnd *winman.WindowBase, focus tview.Primitive)
	ClearOutputPanel()
	SetOutputPanel(pd PanelDefinition)
}

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

type UnitListParamParser struct{}

type UnitService interface {
	GetByUnitNumber(ctx context.Context, unitNum string) (*UnitSpec, error)
	ListUnits(ctx context.Context, lp ListParams) ([]*UnitSpec, error)
}

type UnitSpec struct {
	UnitID        string     `json:"unitId" validate:"required"`
	Year          string     `json:"year"`
	Make          string     `json:"make"`
	Model         string     `json:"model"`
	Description   string     `json:"description"`
	Serial        *string    `json:"serial,omitempty"`
	Engine        *string    `json:"engine,omitempty"`
	Status        string     `json:"status"`
	ProductCode   *string    `json:"productCode,omitempty"`
	New           bool       `json:"new"`
	Color         *string    `json:"color,omitempty"`
	HorsePower    *int       `json:"horsePower,omitempty"`
	EngineHours   *float64   `json:"engineHours,omitempty"`
	Location      string     `json:"location"`
	Account       string     `json:"account"`
	CreatedAt     time.Time  `json:"createdAt"`
	SoldAt        *time.Time `json:"soldAt,omitempty"`
	InvoiceNumber *string    `json:"invoiceNumber,omitempty"`
	SoldTo        *string    `json:"soldTo,omitempty"`
	RevenueAmount *float64   `json:"revenueAmount,omitempty"`
	Cost          float64    `json:"cost,omitempty"`
	SoldBy        *string    `json:"soldBy,omitempty"`
	SoldByName    *string    `json:"soldByName,omitempty"`
}

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

type ViewModule interface {
	// Name is the display text for the main menu.
	Name() string
	// Shortcut is the rune key to activate this module.
	Shortcut() rune
	// Init is called once after UI and Logger are ready.
	Init(ui UI)
	// Activate is called when the user selects this module.
	Activate()
	// SubMenu returns a MenuDefinition for this module's submenu.
	SubMenu() MenuDefinition
	// OutputPanel returns a PanelDefinition describing the name and view
	// to display in the main output area when this module is active.
	OutputPanel() PanelDefinition
}

type WholeGoodsInvoiceListParamParser struct{}

type WholeGoodsInvoiceSpec struct {
	Division            string    `json:"division"`
	LegacyDS9YA         *int      `json:"ds9ya,omitempty"`
	LineItemNumber      int       `json:"lineItemNumber"`
	InvoiceNumber       string    `json:"invoiceNumber"`
	LegacyDSYGA         *string   `json:"dsyga,omitempty"`
	InvoiceDate         time.Time `json:"invoiceDate"`
	LineItemPrice       float64   `json:"lineItemPrice"`
	LineItemDescription string    `json:"lineItemDescription"`
	LegacyDSWVA         *int      `json:"dswva,omitempty"`
	SoldBy              string    `json:"soldBy"`
}

type WinSize struct {
	X      int
	Y      int
	Width  int
	Height int
}