server

type Authorizer interface {
	CheckContextOperationAuthorized(ctx context.Context, operation string, target string) error
}

type CaseHandler struct {
	web.BaseHandler
	// contains filtered or unexported fields
}

type Casestore interface {
	Create(ctx context.Context, newCase *model.Case) (*model.Case, error)
	Update(ctx context.Context, socCase *model.Case) (*model.Case, error)
	GetCase(ctx context.Context, caseId string) (*model.Case, error)
	GetCaseHistory(ctx context.Context, caseId string) ([]interface{}, error)

	CreateComment(ctx context.Context, newComment *model.Comment) (*model.Comment, error)
	GetComment(ctx context.Context, commentId string) (*model.Comment, error)
	GetComments(ctx context.Context, caseId string) ([]*model.Comment, error)
	UpdateComment(ctx context.Context, comment *model.Comment) (*model.Comment, error)
	DeleteComment(ctx context.Context, id string) error

	CreateRelatedEvent(ctx context.Context, event *model.RelatedEvent) (*model.RelatedEvent, error)
	GetRelatedEvent(ctx context.Context, id string) (*model.RelatedEvent, error)
	GetRelatedEvents(ctx context.Context, caseId string) ([]*model.RelatedEvent, error)
	DeleteRelatedEvent(ctx context.Context, id string) error

	CreateArtifact(ctx context.Context, artifact *model.Artifact) (*model.Artifact, error)
	GetArtifact(ctx context.Context, id string) (*model.Artifact, error)
	GetArtifacts(ctx context.Context, caseId string, groupType string, groupId string) ([]*model.Artifact, error)
	DeleteArtifact(ctx context.Context, id string) error
	UpdateArtifact(ctx context.Context, artifact *model.Artifact) (*model.Artifact, error)

	CreateArtifactStream(ctx context.Context, artifactstream *model.ArtifactStream) (string, error)
	GetArtifactStream(ctx context.Context, id string) (*model.ArtifactStream, error)
	DeleteArtifactStream(ctx context.Context, id string) error
}

type Datastore interface {
	CreateNode(ctx context.Context, id string) *model.Node
	GetNodes(ctx context.Context) []*model.Node
	AddNode(ctx context.Context, node *model.Node) error
	UpdateNode(ctx context.Context, newNode *model.Node) (*model.Node, error)
	GetNextJob(ctx context.Context, nodeId string) *model.Job
	CreateJob(ctx context.Context) *model.Job
	GetJob(ctx context.Context, jobId int) *model.Job
	GetJobs(ctx context.Context, kind string, parameters map[string]interface{}) []*model.Job
	AddJob(ctx context.Context, job *model.Job) error
	AddPivotJob(ctx context.Context, job *model.Job) error
	UpdateJob(ctx context.Context, job *model.Job) error
	DeleteJob(ctx context.Context, jobId int) (*model.Job, error)
	GetPackets(ctx context.Context, jobId int, offset int, count int, unwrap bool) ([]*model.Packet, error)
	SavePacketStream(ctx context.Context, jobId int, reader io.ReadCloser) error
	GetPacketStream(ctx context.Context, jobId int, unwrap bool) (io.ReadCloser, string, int64, error)
}

type EventHandler struct {
	web.BaseHandler
	// contains filtered or unexported fields
}

type Eventstore interface {
	Search(context context.Context, criteria *model.EventSearchCriteria) (*model.EventSearchResults, error)
	Index(ctx context.Context, index string, document map[string]interface{}, id string) (*model.EventIndexResults, error)
	Update(context context.Context, criteria *model.EventUpdateCriteria) (*model.EventUpdateResults, error)
	Delete(context context.Context, index string, id string) error
	Acknowledge(context context.Context, criteria *model.EventAckCriteria) (*model.EventUpdateResults, error)
}

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

type FakeEventstore struct {
	InputDocuments       []map[string]interface{}
	InputContexts        []context.Context
	InputIndexes         []string
	InputIds             []string
	InputSearchCriterias []*model.EventSearchCriteria
	InputUpdateCriterias []*model.EventUpdateCriteria
	InputAckCriterias    []*model.EventAckCriteria
	Err                  error
	SearchResults        []*model.EventSearchResults
	IndexResults         []*model.EventIndexResults
	UpdateResults        []*model.EventUpdateResults
	// contains filtered or unexported fields
}

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

type GridHandler struct {
	web.BaseHandler
	// contains filtered or unexported fields
}

type InfoHandler struct {
	web.BaseHandler
	// contains filtered or unexported fields
}

type JobHandler struct {
	web.BaseHandler
	// contains filtered or unexported fields
}

type JobsHandler struct {
	web.BaseHandler
	// contains filtered or unexported fields
}

type Metrics interface {
	GetGridEps(ctx context.Context) int
	UpdateNodeMetrics(ctx context.Context, node *model.Node) bool
}

type NodeHandler struct {
	web.BaseHandler
	// contains filtered or unexported fields
}

type PacketHandler struct {
	web.BaseHandler
	// contains filtered or unexported fields
}

type QueryHandler struct {
	web.BaseHandler
	// contains filtered or unexported fields
}

type RolesHandler struct {
	web.BaseHandler
	// contains filtered or unexported fields
}

type Rolestore interface {
	GetAssignments(ctx context.Context) (map[string][]string, error)
	PopulateUserRoles(ctx context.Context, user *model.User) error
}

type Server struct {
	Config     *config.ServerConfig
	Host       *web.Host
	Datastore  Datastore
	Userstore  Userstore
	Rolestore  Rolestore
	Eventstore Eventstore
	Casestore  Casestore
	Metrics    Metrics

	Authorizer Authorizer
	Agent      *model.User
	Context    context.Context
	// contains filtered or unexported fields
}

type StreamHandler struct {
	web.BaseHandler
	// contains filtered or unexported fields
}

type UserHandler struct {
	web.BaseHandler
	// contains filtered or unexported fields
}

type UsersHandler struct {
	web.BaseHandler
	// contains filtered or unexported fields
}

type Userstore interface {
	GetUsers(ctx context.Context) ([]*model.User, error)
	DeleteUser(ctx context.Context, id string) error
	GetUser(ctx context.Context, id string) (*model.User, error)
	UpdateUser(ctx context.Context, id string, user *model.User) error
}