domain

type APIData struct {
	ID         string              `json:"id" bson:"_id,omitempty"`
	Name       string              `json:"name" bson:"name"`
	Data       string              `json:"data" bson:"data"`
	DBMS       string              `json:"dbms" bson:"dbms"`
	ScanResult []APIDataScanResult `json:"scan_result" bson:"scan_result"`
}

type APIDataRepository interface {
	// mongo
	Create(ctx context.Context, data APIData) (string, error)
	AddScanResult(ctx context.Context, id string, data APIDataScanResult) error
	Get(ctx context.Context) ([]APIData, error)
	GetByID(ctx context.Context, id string) (*APIData, error)

	// kafka
	PublishScanMessage(ctx context.Context, id string) error

	// redis
	SetScanRunning(ctx context.Context, id string) (bool, error)
	IsScanRunning(ctx context.Context, id string) (bool, error)
	FinishScan(ctx context.Context, id string) error
}

type APIDataScanResult struct {
	CreatedAt    time.Time `json:"created_at" bson:"created_at"`
	Log          string    `json:"log" bson:"log"`
	IsVulnerable bool      `json:"is_vulnerable" bson:"is_vulnerable"`
}

type APIDataUsecase interface {
	Create(ctx context.Context, data APIData) error
	Get(ctx context.Context) ([]APIData, error)
	GetByID(ctx context.Context, id string) (*APIData, error)
	PublishScanMessage(ctx context.Context, id string) error
	Scan(ctx context.Context, id string) error
	IsScanRunning(ctx context.Context, id string) (bool, error)
}