db

package

v0.0.2 Latest Latest Go to latest Published: Sep 17, 2024 License: Apache-2.0 Imports: 28 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/chainreactors/malice-network

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func AddCertificate(caType int, keyType string, commonName string, cert []byte, key []byte) error
func AddContent(pbWebContent *lispb.WebContent, webContentDir string) (*lispb.WebContent, error)
func AddTask(typ string, task *core.Task, td *models.FileDescription) error
func AddWebSite(webSiteName string, webContentDir string) (*lispb.Website, error)
func CreateOperator(name string, typ string, remoteAddr string) error
func CreatePipeline(ppProto *lispb.Pipeline) error
func DeleteAllCertificates() error
func DeleteCertificate(name string) error
func DeleteSession(sessionID string) error
func FindAliveSessions() ([]*lispb.RegisterSession, error)
func FindAllSessions() (*clientpb.Sessions, error)
func FindPipeline(name, listenerID string) (models.Pipeline, error)
func FindSession(sessionID string) (*lispb.RegisterSession, error)
func FindTaskAndMaxTasksID(sessionID string) ([]*models.Task, int, error)
func FindTasksWithNonOneCurTotal(session models.Session) ([]models.Task, error)
func GetAllTasks(sessionID string) ([]models.Task, error)
func GetTaskDescriptionByID(taskID string) (*models.FileDescription, error)
func GetWebContentIDByWebsiteID(websiteID string) ([]string, error)
func HasOperator(typ string) (bool, error)
func ListClients() ([]models.Operator, error)
func ListListeners() ([]models.Operator, error)
func ListPipelines(listenerID string, pipelineType string) ([]models.Pipeline, error)
func NewDBClient() *gorm.DB
func Open(dsn string) gorm.Dialector
func RemoveContent(id string) error
func RemoveWebAllContent(id string) error
func RemoveWebSite(id string) error
func SaveCertificate(certificate *models.Certificate) error
func Session() *gorm.DB
func ToTask(task models.Task) (*core.Task, error)
func UpdateLast(sessionID string) error
func UpdateSession(sessionID, note, group string) error
func UpdateSessionInfo(coreSession *core.Session) error
func UpdateSessionStatus() error
func UpdateTask(task *core.Task, newCur int) error
func WebContentByIDAndPath(id string, path string, webContentDir string, eager bool) (*lispb.WebContent, error)
func WebsiteByName(name string, webContentDir string) (*lispb.Website, error)
func Websites(webContentDir string) ([]*lispb.Website, error)
type Dialector
- func (dialector Dialector) BindVarTo(writer clause.Writer, stmt *gorm.Statement, v interface{})
- func (dialector Dialector) ClauseBuilders() map[string]clause.ClauseBuilder
- func (dialector Dialector) DataTypeOf(field *schema.Field) string
- func (dialector Dialector) DefaultValueOf(field *schema.Field) clause.Expression
- func (dialector Dialector) Explain(sql string, vars ...interface{}) string
- func (dialector Dialector) Initialize(db *gorm.DB) (err error)
- func (dialector Dialector) Migrator(db *gorm.DB) gorm.Migrator
- func (dialector Dialector) Name() string
- func (dialector Dialector) QuoteTo(writer clause.Writer, str string)
- func (dialectopr Dialector) RollbackTo(tx *gorm.DB, name string) error
- func (dialectopr Dialector) SavePoint(tx *gorm.DB, name string) error
type Migrator

Constants ¶

View Source

const DriverName = "sqlite3"

DriverName is the default driver name for SQLite.

Variables ¶

View Source

var (
	// ErrRecordNotFound - Record not found error
	ErrRecordNotFound = gorm.ErrRecordNotFound
	Client            *gorm.DB
)

Client - Database Client

Functions ¶

func AddCertificate ¶ added in v0.0.2

func AddCertificate(caType int, keyType string, commonName string, cert []byte, key []byte) error

AddCertificate add a certificate to the database

func AddContent ¶

func AddContent(pbWebContent *lispb.WebContent, webContentDir string) (*lispb.WebContent, error)

AddContent - Add content to website

func AddTask ¶

func AddTask(typ string, task *core.Task, td *models.FileDescription) error

func AddWebSite ¶

func AddWebSite(webSiteName string, webContentDir string) (*lispb.Website, error)

AddWebsite - Return website, create if it does not exist

func CreateOperator ¶

func CreateOperator(name string, typ string, remoteAddr string) error

func CreatePipeline ¶ added in v0.0.2

func CreatePipeline(ppProto *lispb.Pipeline) error

func DeleteAllCertificates ¶

func DeleteAllCertificates() error

DeleteAllCertificates

func DeleteCertificate ¶

func DeleteCertificate(name string) error

DeleteCertificate

func DeleteSession ¶

func DeleteSession(sessionID string) error

Basic Session OP

func FindAliveSessions ¶

func FindAliveSessions() ([]*lispb.RegisterSession, error)

func FindAllSessions ¶

func FindAllSessions() (*clientpb.Sessions, error)

func FindPipeline ¶ added in v0.0.2

func FindPipeline(name, listenerID string) (models.Pipeline, error)

func FindSession ¶

func FindSession(sessionID string) (*lispb.RegisterSession, error)

func FindTaskAndMaxTasksID ¶

func FindTaskAndMaxTasksID(sessionID string) ([]*models.Task, int, error)

func FindTasksWithNonOneCurTotal ¶

func FindTasksWithNonOneCurTotal(session models.Session) ([]models.Task, error)

func GetAllTasks ¶

func GetAllTasks(sessionID string) ([]models.Task, error)

Task

func GetTaskDescriptionByID ¶

func GetTaskDescriptionByID(taskID string) (*models.FileDescription, error)

func GetWebContentIDByWebsiteID ¶

func GetWebContentIDByWebsiteID(websiteID string) ([]string, error)

func HasOperator ¶ added in v0.0.2

func HasOperator(typ string) (bool, error)

func ListClients ¶ added in v0.0.2

func ListClients() ([]models.Operator, error)

func ListListeners ¶

func ListListeners() ([]models.Operator, error)

func ListPipelines ¶ added in v0.0.2

func ListPipelines(listenerID string, pipelineType string) ([]models.Pipeline, error)

func NewDBClient ¶

func NewDBClient() *gorm.DB

newDBClient - Initialize the db client

func Open ¶

func Open(dsn string) gorm.Dialector

func RemoveContent ¶

func RemoveContent(id string) error

func RemoveWebAllContent ¶

func RemoveWebAllContent(id string) error

func RemoveWebSite ¶

func RemoveWebSite(id string) error

func SaveCertificate ¶

func SaveCertificate(certificate *models.Certificate) error

func Session ¶

func Session() *gorm.DB

Session - Database session

func ToTask ¶

func ToTask(task models.Task) (*core.Task, error)

func UpdateLast ¶

func UpdateLast(sessionID string) error

func UpdateSession ¶

func UpdateSession(sessionID, note, group string) error

func UpdateSessionInfo ¶

func UpdateSessionInfo(coreSession *core.Session) error

func UpdateSessionStatus ¶

func UpdateSessionStatus() error

func UpdateTask ¶

func UpdateTask(task *core.Task, newCur int) error

func WebContentByIDAndPath ¶

func WebContentByIDAndPath(id string, path string, webContentDir string, eager bool) (*lispb.WebContent, error)

WebContent by ID and path

func WebsiteByName ¶

func WebsiteByName(name string, webContentDir string) (*lispb.Website, error)

website WebsiteByName - Get website by name

func Websites ¶

func Websites(webContentDir string) ([]*lispb.Website, error)

Websites - Return all websites

Types ¶

type Dialector ¶

type Dialector struct {
	DriverName string
	DSN        string
	Conn       gorm.ConnPool
}

func (Dialector) BindVarTo ¶

func (dialector Dialector) BindVarTo(writer clause.Writer, stmt *gorm.Statement, v interface{})

func (Dialector) ClauseBuilders ¶

func (dialector Dialector) ClauseBuilders() map[string]clause.ClauseBuilder

func (Dialector) DataTypeOf ¶

func (dialector Dialector) DataTypeOf(field *schema.Field) string

func (Dialector) DefaultValueOf ¶

func (dialector Dialector) DefaultValueOf(field *schema.Field) clause.Expression

func (Dialector) Explain ¶

func (dialector Dialector) Explain(sql string, vars ...interface{}) string

func (Dialector) Initialize ¶

func (dialector Dialector) Initialize(db *gorm.DB) (err error)

func (Dialector) Migrator ¶

func (dialector Dialector) Migrator(db *gorm.DB) gorm.Migrator

func (Dialector) Name ¶

func (dialector Dialector) Name() string

func (Dialector) QuoteTo ¶

func (dialector Dialector) QuoteTo(writer clause.Writer, str string)

func (Dialector) RollbackTo ¶

func (dialectopr Dialector) RollbackTo(tx *gorm.DB, name string) error

func (Dialector) SavePoint ¶

func (dialectopr Dialector) SavePoint(tx *gorm.DB, name string) error

type Migrator ¶

type Migrator struct {
	migrator.Migrator
}

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
models

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL