boilerplates

type AMQPConfig struct {
	URL      string `json:"url"`
	Protocol string `json:"protocol"`
	Host     string `json:"host"`
	Port     string `json:"port"`
	User     string `json:"user"`
	Password string `json:"password"`
}

type AnalysisHandler interface {
	StartAnalysis(
		databases *PluginDatabases,
		dispatcherMessage types_amqp.DispatcherPluginMessage,
		config plugin_db.Plugin,
		analysisDoc codeclarity.Analysis,
	) (map[string]any, codeclarity.AnalysisStatus, error)
}

type ConfigError struct {
	Field   string `json:"field"`
	Message string `json:"message"`
}

type ConfigService struct {
	Database DatabaseConfig `json:"database"`
	AMQP     AMQPConfig     `json:"amqp"`
	General  GeneralConfig  `json:"general"`
}

type DatabaseConfig struct {
	Host     string        `json:"host"`
	Port     string        `json:"port"`
	User     string        `json:"user"`
	Password string        `json:"password"`
	Timeout  time.Duration `json:"timeout"`
}

type EcosystemError struct {
	// Core error information
	Message   string    `json:"message"`
	Cause     error     `json:"cause,omitempty"`
	Timestamp time.Time `json:"timestamp"`

	// Context information
	Ecosystem  string `json:"ecosystem,omitempty"`
	Plugin     string `json:"plugin,omitempty"`
	Stage      string `json:"stage,omitempty"`
	AnalysisID string `json:"analysisId,omitempty"`

	// Error classification
	Severity    ErrorSeverity `json:"severity"`
	Category    ErrorCategory `json:"category"`
	Recoverable bool          `json:"recoverable"`

	// Additional context
	StackTrace string                 `json:"stackTrace,omitempty"`
	Metadata   map[string]interface{} `json:"metadata,omitempty"`
}

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

type ErrorCategory string

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

type ErrorRecoveryStrategy struct {
	MaxRetries      int           `json:"maxRetries"`
	RetryDelay      time.Duration `json:"retryDelay"`
	BackoffFactor   float64       `json:"backoffFactor"`
	RecoverableOnly bool          `json:"recoverableOnly"`
}

type ErrorSeverity string

type GeneralConfig struct {
	Environment string `json:"environment"`
	LogLevel    string `json:"logLevel"`
}

type GenericResultMerger[T any] struct {
	// contains filtered or unexported fields
}

type GenericSBOMHandler struct {
	Analyzer SBOMAnalyzer
}

type LicenseAnalysisStats struct {
	NumberOfSpdxLicenses       int            `json:"numberOfSpdxLicenses"`
	NumberOfNonSpdxLicenses    int            `json:"numberOfNonSpdxLicenses"`
	NumberOfCopyLeftLicenses   int            `json:"numberOfCopyLeftLicenses"`
	NumberOfPermissiveLicenses int            `json:"numberOfPermissiveLicenses"`
	LicenseDist                map[string]int `json:"licenseDist"`
}

type LicenseDependencyInfo struct {
	Name              string   `json:"name"`
	Version           string   `json:"version"`
	Licenses          []string `json:"licenses"`
	LicenseExpression string   `json:"licenseExpression"`
	LicenseViolations []string `json:"licenseViolations"`
}

type LicenseOutput struct {
	WorkSpaces     map[string]LicenseWorkspaceInfo `json:"workSpaces"`
	AnalysisStats  LicenseAnalysisStats            `json:"analysisStats"`
	AnalysisStatus string                          `json:"status"`
}

type LicenseResultMerger struct {
	*GenericResultMerger[LicenseOutput]
	// contains filtered or unexported fields
}

type LicenseWorkspaceInfo struct {
	LicensesDepMap              map[string][]string              `json:"licensesDepMap"`
	NonSpdxLicensesDepMap       map[string][]string              `json:"nonSpdxLicensesDepMap"`
	LicenseComplianceViolations []string                         `json:"licenseComplianceViolations"`
	DependencyInfo              map[string]LicenseDependencyInfo `json:"dependencyInfo"`
}

type MergeStrategy string

type MergerUtils struct{}

type PluginBase struct {
	Config    plugin_db.Plugin
	DB        *PluginDatabases
	ConfigSvc *ConfigService
	Logger    *logrus.Logger
	// contains filtered or unexported fields
}

type PluginDatabases struct {
	Codeclarity *bun.DB
	Knowledge   *bun.DB
	Plugins     *bun.DB
}

type QueueConfig struct {
	Name    string
	Durable bool
	Handler func(d amqp.Delivery)
}

type SBOMAnalyzer interface {
	// AnalyzeProject performs the SBOM analysis for a specific language
	AnalyzeProject(projectPath string, analysisId string, knowledgeDB interface{}) (SBOMOutput, error)

	// CanAnalyze checks if this analyzer can handle the given project
	CanAnalyze(projectPath string) bool

	// GetLanguage returns the language this analyzer handles
	GetLanguage() string

	// DetectFramework detects the framework used in the project (optional, can return empty string)
	DetectFramework(projectPath string) string

	// ConvertToMap converts the analyzer's output to map[string]any for storage
	ConvertToMap(output SBOMOutput) map[string]any

	// GetDependencyCount returns the total number of dependencies found
	GetDependencyCount(output SBOMOutput) int
}

type SBOMOutput interface {
	GetStatus() codeclarity.AnalysisStatus
	GetFramework() string
}

type ServiceBase struct {
	ConfigSvc *ConfigService
	DB        *ServiceDatabases

	Metrics     *ServiceMetrics
	ServiceName string
	Logger      *logrus.Logger
	// contains filtered or unexported fields
}

type ServiceConfig struct {
	Name      string `json:"name"`
	Version   string `json:"version"`
	ImageName string `json:"image_name"`
}

type ServiceDatabases struct {
	CodeClarity *bun.DB
	Knowledge   *bun.DB
	Plugins     *bun.DB
	Config      *bun.DB
}

type ServiceMetrics struct {
	// Service health metrics
	ServiceHealthStatus *prometheus.GaugeVec
	ServiceUptime       prometheus.Gauge
	ServiceRestarts     prometheus.Counter

	// Database metrics
	DatabaseConnections   *prometheus.GaugeVec
	DatabaseOperations    *prometheus.CounterVec
	DatabaseQueryDuration *prometheus.HistogramVec
	DatabaseHealthChecks  *prometheus.CounterVec

	// AMQP metrics
	AMQPConnections       *prometheus.GaugeVec
	MessagesProcessed     *prometheus.CounterVec
	MessageProcessingTime *prometheus.HistogramVec
	QueueConsumers        *prometheus.GaugeVec
	// contains filtered or unexported fields
}

type VulnerabilityInfo struct {
	Id              string   `json:"id"`
	PackageName     string   `json:"packageName"`
	VersionAffected string   `json:"versionAffected"`
	Severity        string   `json:"severity"`
	Score           float64  `json:"score"`
	Description     string   `json:"description"`
	References      []string `json:"references"`
	FixedVersions   []string `json:"fixedVersions"`
	Ecosystem       string   `json:"ecosystem"`
	Source          string   `json:"source"` // OSV, NVD, etc.
}

type VulnerabilityOutput struct {
	WorkSpaces     map[string]VulnerabilityWorkspaceInfo `json:"workSpaces"`
	AnalysisStatus string                                `json:"status"`
}

type VulnerabilityResultMerger struct {
	*GenericResultMerger[VulnerabilityOutput]
	// contains filtered or unexported fields
}

type VulnerabilityStats struct {
	Total              int             `json:"total"`
	BySeverity         map[string]int  `json:"bySeverity"`
	ByEcosystem        map[string]int  `json:"byEcosystem"`
	BySource           map[string]int  `json:"bySource"`
	UniquePackages     map[string]bool `json:"-"` // Internal use only
	UniquePackageCount int             `json:"uniquePackageCount"`
}

type VulnerabilityStatsCalculator struct{}

type VulnerabilityWorkspaceInfo struct {
	Vulnerabilities []VulnerabilityInfo `json:"vulnerabilities"`
}

type WorkspaceKey struct {
	Name      string
	Ecosystem string
}