yakgrpc

package
v1.2.1-sp8 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jun 15, 2023 License: AGPL-3.0 Imports: 83 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	KEY_ProgressManager     = "JznQXuFDSepeNWHbiLGEwONiaBxhvj_PROGRESS_MANAGER"
	KEY_SimpleDetectManager = "JznQXuFDSepeNWHbiLGEwONiaBxhvj_SIMPLE_DETECT_MANAGER"
)
View Source 
const EXECUTEPACKET_CODE = `` /* 1081-byte string literal not displayed */
View Source 
const MITMFilterKeyRecords = "uWokegBnCQdnxezJtMVo_MITMFilterKeyRecords"
View Source 
const MITMReplacerKeyRecords = "R1oHf8xca6CobwVg2_MITMReplacerKeyRecords"
View Source 
const MatchedRules = "MatchedRules"
View Source 
const PORTSCAN_PLUGIN_TRIGGER_CODE = `` /* 1324-byte string literal not displayed */
View Source 
const (
	YAK_ENGINE_DEFAULT_SCAN_PROXY = "YAK_ENGINE_DEFAULT_SCAN_PROXY"
)

Variables

View Source 
var BatchPoCTemplate, _ = template.New("BatchPoCTemplate").Parse(`

isHttps = cli.Have("https", cli.setDefault({{ .https }}))
target = cli.String("target", cli.setDefault("{{ .target }}"))
concurrent = cli.Int("concurrent", cli.setDefault(10))

packet = ` + "`" + `{{ .packetTemplate }}` + "`" + `

debug = cli.Have("debug", cli.setDefault(true))

if debug {
    loglevel("debug")
}

batchPacket = func(target) {
    return httpool.Pool(
        packet, 
        # httpool.proxy("http://127.0.0.1:8083"),
        # httpool.proxy("http://127.0.0.1:7890"),
        httpool.rawMode(true),
        httpool.size(concurrent), 
        httpool.redirectTimes(5),
        httpool.perRequestTimeout(10),
        httpool.fuzz(true),
        httpool.fuzzParams({
            "target": target,
        }),
    )
}

if YAK_MAIN {
    res, err = batchPacket(target)
    if err != nil {
        log.error("send packet error: %s", err)
        return
    }

    for result = range res {

        if result.Error != nil {
            yakit.Error("Request[%v] Payload: %v Failed: %v", result.Url, result.Payloads, result.Error)
            continue
        }

        yakit.Info("[%v] Request Result Received! payloads: %v", result.Url, result.Payloads)

        reqBytes := result.RequestRaw
        rspBytes := result.ResponseRaw

        if debug {
            println(string(reqBytes))
            println("---------------------------------")
            println(string(rspBytes))
        }

        // 处理结果
        riskTarget = target
        if str.MatchAllOfRegexp(rspBytes, ` + "`" + `(?i)foundtextinRsp!` + "`" + `) || str.MatchAllOfSubString(rspBytes, "FoundTextInResponse") {
            urlIns, _ = str.ExtractURLFromHTTPRequestRaw(reqBytes, isHttps)
            if urlIns == nil {
                riskTarget = urlIns.String()
            }
            yakit.Info("Matched for %v", target)
            # Save to RiskTable
            risk.NewRisk(
                riskTarget, risk.severity("high"), risk.type("poc"),
                risk.title("English Title"),            ## English Title for Risk
                risk.titleVerbose("中文标题"),           ##  中文标题
                risk.details({
                    "target": riskTarget,
                    "request": reqBytes,
                    "response": rspBytes,
                }),
            )
        }
    }
}

/*
type palm/common/mutate.(_httpResult) struct {
  Fields(可用字段): 
      Url: string  
      Request: *http.Request  
      Error: error  
      RequestRaw: []uint8  
      ResponseRaw: []uint8  
      Response: *http.Response  
      DurationMs: int64  
      Timestamp: int64  
      Payloads: []string  
  StructMethods(结构方法/函数): 
  PtrStructMethods(指针结构方法/函数): 
}
*/


`)
View Source 
var OrdinaryPoCTemplate, _ = template.New("OrdinaryPoCTemplate").Parse(`
isHttps = cli.Have("https", cli.setDefault({{ .https }}))
target = cli.String("target", cli.setDefault("{{ .target }}"))

packet = ` + "`" + `
{{ .packetTemplate }}` + "`" + `

debug = cli.Have("debug", cli.setDefault(true))

if debug {
    loglevel("debug")
}

sendPacket = func(target) {
    return poc.HTTP(
        packet, 
        poc.timeout(10),
        # poc.proxy("http://127.0.0.1:8083"),
        # poc.proxy("http://127.0.0.1:7890"),
        poc.redirectTimes(3),  # 重定向次数
        poc.https(isHttps),
        poc.params({
            "target": target,
        },
    ))
}

if YAK_MAIN {
    rspBytes, reqBytes, err = sendPacket(target)
    if err != nil {
        log.error("send packet error: %s", err)
        return
    }

    if debug {
        println(string(reqBytes))
        println("---------------------------------")
        println(string(rspBytes))
    }

    riskTarget = target
    if str.MatchAllOfRegexp(rspBytes, ` + "`" + `(?i)foundtextinRsp!` + "`" + `) || str.MatchAllOfSubString(rspBytes, "FoundTextInResponse") {
        urlIns, _ = str.ExtractURLFromHTTPRequestRaw(reqBytes, isHttps)
        if urlIns == nil {
            riskTarget = urlIns.String()
        }
        yakit.Info("Matched for %v", target)
        # Save to RiskTable
        risk.NewRisk(
            riskTarget, risk.severity("high"), risk.type("poc"),
            risk.title("English Title"),            ## English Title for Risk
            risk.titleVerbose("中文标题"),           ##  中文标题
            risk.details({
                "target": riskTarget,
                "request": reqBytes,
                "response": rspBytes,
            }),
        )
    }
}
















`)
View Source 
var (
	OriginRiskStats *ypb.RiskTableStats
)
View Source 
var YakitAllTables = yakit.ProjectTables
View Source 
var YakitProfileTables = yakit.ProfileTables

Functions

func AfterAndBeforeIsExit added in v1.2.2 

func AfterAndBeforeIsExit(id int64) (before, after bool)

func Chardet 

func Chardet(raw []byte) string

func CheckDefault 

func CheckDefault(ProjectName, Type string, FolderId, ChildFolderId int64) error

func ConvertMultiYakScriptToExecBatchRequest added in v1.2.2 

func ConvertMultiYakScriptToExecBatchRequest(req *ypb.ExecRequest, script []*ypb.YakScript, batchMode bool) (*ypb.ExecRequest, []func(), error)

func ConvertYakScriptToExecRequest 

func ConvertYakScriptToExecRequest(req *ypb.ExecRequest, script *yakit.YakScript, batchMode bool) (*ypb.ExecRequest, []func(), error)

func GRPCYakScriptToYakitScript 

func GRPCYakScriptToYakitScript(script *ypb.YakScript) *yakit.YakScript

func GetScanProxyEnviron 

func GetScanProxyEnviron() string

func IsContain 

func IsContain(items []*ypb.MenuItemGroup, item string) bool

func IsValueInSortedSlice added in v1.2.2 

func IsValueInSortedSlice(value string, slice []string) bool

func NewMITMReplacer 

func NewMITMReplacer(initFunc ...func() []*ypb.MITMContentReplacer) *mitmReplacer

func NewRiskGRPCModel 

func NewRiskGRPCModel(p *yakit.Risk) *ypb.NewRisk

func PortsServiceTypeGroup added in v1.2.2 

func PortsServiceTypeGroup(data []*yakit.PortsTypeGroup) ypb.QueryPortsGroupResponse

func QueryYakScriptByNames 

func QueryYakScriptByNames(db *gorm.DB, req []string) []*ypb.DownloadOnlinePluginByScriptName

func ReplaceString 

func ReplaceString(s string) string

func SaveFromYakitLog 

func SaveFromYakitLog(l *yaklib.YakitLog, db *gorm.DB)

func StripHTTPRequestGzip 

func StripHTTPRequestGzip(reqIns *http.Request, req []byte) (*http.Request, []byte)

func ToGrpcPort 

func ToGrpcPort(r *yakit.Port) *ypb.Port

Types

type JavaBytesCodeType 

type JavaBytesCodeType string
const (
	JavaBytesCodeType_FromBytes                 JavaBytesCodeType = "FromBytes"
	JavaBytesCodeType_RuntimeExec               JavaBytesCodeType = "RuntimeExec"
	JavaBytesCodeType_ProcessBuilderExec        JavaBytesCodeType = "ProcessBuilderExec"
	JavaBytesCodeType_ProcessImplExec           JavaBytesCodeType = "ProcessImplExec"
	JavaBytesCodeType_DNSlog                    JavaBytesCodeType = "DNSlog"
	JavaBytesCodeType_SpringEcho                JavaBytesCodeType = "SpringEcho"
	JavaBytesCodeType_ModifyTomcatMaxHeaderSize JavaBytesCodeType = "ModifyTomcatMaxHeaderSize"
	JavaBytesCodeType_TcpReverse                JavaBytesCodeType = "TcpReverse"
	JavaBytesCodeType_TcpReverseShell           JavaBytesCodeType = "TcpReverseShell"
)

type JavaClassGeneraterOption 

type JavaClassGeneraterOption string
const (
	JavaClassGeneraterOption_ClassName                 JavaClassGeneraterOption = "ClassName"
	JavaClassGeneraterOption_IsConstructer             JavaClassGeneraterOption = "IsConstructer"
	JavaClassGeneraterOption_IsObfuscation             JavaClassGeneraterOption = "IsObfuscation"
	JavaClassGeneraterOption_Bytes                     JavaClassGeneraterOption = "Bytes"
	JavaClassGeneraterOption_Command                   JavaClassGeneraterOption = "Command"
	JavaClassGeneraterOption_Domain                    JavaClassGeneraterOption = "Domain"
	JavaClassGeneraterOption_Host                      JavaClassGeneraterOption = "Host"
	JavaClassGeneraterOption_Port                      JavaClassGeneraterOption = "Port"
	JavaClassGeneraterOption_TcpReverseToken           JavaClassGeneraterOption = "TcpReverseToken"
	JavaClassGeneraterOption_SpringHeaderKey           JavaClassGeneraterOption = "SpringHeaderKey"
	JavaClassGeneraterOption_SpringHeaderValue         JavaClassGeneraterOption = "SpringHeaderValue"
	JavaClassGeneraterOption_SpringParam               JavaClassGeneraterOption = "SpringParam"
	JavaClassGeneraterOption_IsSpringRuntimeExecAction JavaClassGeneraterOption = "IsSpringRuntimeExec"
	JavaClassGeneraterOption_IsSpringEchoBody          JavaClassGeneraterOption = "IsSpringEchoBody"
)

type JavaClassGeneraterOptionTypeVerbose 

type JavaClassGeneraterOptionTypeVerbose string
const (
	String      JavaClassGeneraterOptionTypeVerbose = "String"
	Base64Bytes JavaClassGeneraterOptionTypeVerbose = "Base64Bytes"
	StringBool  JavaClassGeneraterOptionTypeVerbose = "StringBool"
	StringPort  JavaClassGeneraterOptionTypeVerbose = "StringPort"
)

type MITMFilterManager 

type MITMFilterManager struct {
	IncludeHostnames []string `json:"includeHostnames"`
	ExcludeHostnames []string `json:"excludeHostnames"`
	IncludeSuffix    []string `json:"includeSuffix"`
	ExcludeSuffix    []string `json:"excludeSuffix"`
	ExcludeMethods   []string `json:"excludeMethods"`
	ExcludeMIME      []string `json:"excludeMIME"`
	ExcludeUri       []string `json:"excludeUri"`
	IncludeUri       []string `json:"includeUri"`
	// contains filtered or unexported fields
}

func NewMITMFilterManager 

func NewMITMFilterManager(db *gorm.DB) *MITMFilterManager

func (*MITMFilterManager) IsEmpty 

func (m *MITMFilterManager) IsEmpty() bool

func (*MITMFilterManager) Recover 

func (m *MITMFilterManager) Recover()

func (*MITMFilterManager) Save 

func (m *MITMFilterManager) Save()

type OpenPortServerStreamerHelperRWC 

type OpenPortServerStreamerHelperRWC struct {
	io.ReadWriteCloser

	LocalAddr  string
	RemoveAddr string
	// contains filtered or unexported fields
}

OpenPortServerStreamerHelperRWC

func (*OpenPortServerStreamerHelperRWC) Close 

func (s *OpenPortServerStreamerHelperRWC) Close() (err error)

func (*OpenPortServerStreamerHelperRWC) Read 

func (c *OpenPortServerStreamerHelperRWC) Read(b []byte) (n int, _ error)

func (*OpenPortServerStreamerHelperRWC) Write 

func (s *OpenPortServerStreamerHelperRWC) Write(b []byte) (int, error)

type Progress 

type Progress struct {
	Uid                  string
	CreatedAt            int64
	CurrentProgress      float64
	YakScriptOnlineGroup string
	// 记录指针
	LastRecordPtr int64
	TaskName      string
	// 额外信息
	ExtraInfo string
}

type ProgressManager 

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

func NewProgressManager 

func NewProgressManager(db *gorm.DB) *ProgressManager

func (*ProgressManager) AddExecBatchTaskToPool 

func (p *ProgressManager) AddExecBatchTaskToPool(uid string, percent float64, yakScriptOnlineGroup, taskName string, req *ypb.ExecBatchYakScriptRequest)

func (*ProgressManager) AddSimpleDetectTaskToPool 

func (p *ProgressManager) AddSimpleDetectTaskToPool(uid string, req *ypb.RecordPortScanRequest)

func (*ProgressManager) GetProgressByUid 

func (p *ProgressManager) GetProgressByUid(uid string, removeOld bool) (*ypb.ExecBatchYakScriptRequest, error)

func (*ProgressManager) GetProgressFromDatabase 

func (p *ProgressManager) GetProgressFromDatabase(KEY string) []*Progress

func (*ProgressManager) GetSimpleProgressByUid 

func (p *ProgressManager) GetSimpleProgressByUid(uid string, removeOld, isPop bool) (*ypb.RecordPortScanRequest, error)

func (*ProgressManager) SaveProgressToDatabase 

func (p *ProgressManager) SaveProgressToDatabase(KEY string, progress []*Progress)

type Server 

type Server struct {
	ypb.YakServer
	// contains filtered or unexported fields
}

func NewServer 

func NewServer() (*Server, error)

func NewServerWithLogCache added in v1.2.2 

func NewServerWithLogCache(b bool) (*Server, error)

func (*Server) AddMenus 

func (s *Server) AddMenus(ctx context.Context, req *ypb.AddMenuRequest) (*ypb.Empty, error)

func (*Server) AddToMenu 

func (s *Server) AddToMenu(ctx context.Context, req *ypb.AddToMenuRequest) (*ypb.Empty, error)

func (*Server) ApplyClassToFacades 

func (s *Server) ApplyClassToFacades(ctx context.Context, req *ypb.ApplyClassToFacadesParamsWithVerbose) (*ypb.Empty, error)

func (*Server) AttachCombinedOutput 

func (s *Server) AttachCombinedOutput(req *ypb.AttachCombinedOutputRequest, server ypb.Yak_AttachCombinedOutputServer) error

func (*Server) AutoDecode 

func (s *Server) AutoDecode(ctx context.Context, req *ypb.AutoDecodeRequest) (*ypb.AutoDecodeResponse, error)

func (*Server) AutoUpdateYakModule 

func (s *Server) AutoUpdateYakModule(_ *ypb.Empty, stream ypb.Yak_AutoUpdateYakModuleServer) error

func (*Server) AvailableLocalAddr 

func (s *Server) AvailableLocalAddr(ctx context.Context, empty *ypb.Empty) (*ypb.AvailableLocalAddrResponse, error)

func (*Server) BytesToBase64 

func (s *Server) BytesToBase64(ctx context.Context, req *ypb.BytesToBase64Request) (*ypb.BytesToBase64Response, error)

func (*Server) CheckLicense 

func (s *Server) CheckLicense(ctx context.Context, r *ypb.CheckLicenseRequest) (_ *ypb.Empty, unexpectedError error)

func (*Server) Codec 

func (s *Server) Codec(ctx context.Context, req *ypb.CodecRequest) (*ypb.CodecResponse, error)

func (*Server) ConfigGlobalReverse 

func (s *Server) ConfigGlobalReverse(req *ypb.ConfigGlobalReverseParams, stream ypb.Yak_ConfigGlobalReverseServer) error

func (*Server) ConvertFuzzerResponseToHTTPFlow 

func (s *Server) ConvertFuzzerResponseToHTTPFlow(ctx context.Context, in *ypb.FuzzerResponse) (*ypb.HTTPFlow, error)

func (*Server) CreateWebsocketFuzzer 

func (s *Server) CreateWebsocketFuzzer(stream ypb.Yak_CreateWebsocketFuzzerServer) error

func (*Server) CreateYaklangShell 

func (s *Server) CreateYaklangShell(server ypb.Yak_CreateYaklangShellServer) error

func (*Server) DebugPlugin added in v1.2.2 

func (s *Server) DebugPlugin(req *ypb.DebugPluginRequest, stream ypb.Yak_DebugPluginServer) error

func (*Server) DelKey 

func (s *Server) DelKey(ctx context.Context, req *ypb.GetKeyRequest) (*ypb.Empty, error)

func (*Server) DeleteAllLocalPlugins 

func (s *Server) DeleteAllLocalPlugins(ctx context.Context, req *ypb.Empty) (*ypb.Empty, error)

func (*Server) DeleteAllMenu 

func (s *Server) DeleteAllMenu(ctx context.Context, req *ypb.QueryAllMenuItemRequest) (*ypb.Empty, error)

func (*Server) DeleteAllMenuItem 

func (s *Server) DeleteAllMenuItem(ctx context.Context, req *ypb.Empty) (*ypb.Empty, error)

func (*Server) DeleteChaosMakerRuleByID 

func (s *Server) DeleteChaosMakerRuleByID(ctx context.Context, req *ypb.DeleteChaosMakerRuleByIDRequest) (*ypb.Empty, error)

func (*Server) DeleteDomains 

func (s *Server) DeleteDomains(ctx context.Context, req *ypb.DeleteDomainsRequest) (*ypb.Empty, error)

func (*Server) DeleteHTTPFlows 

func (s *Server) DeleteHTTPFlows(ctx context.Context, r *ypb.DeleteHTTPFlowRequest) (*ypb.Empty, error)

func (*Server) DeleteHistoryHTTPFuzzerTask 

func (s *Server) DeleteHistoryHTTPFuzzerTask(ctx context.Context, d *ypb.DeleteHistoryHTTPFuzzerTaskRequest) (*ypb.Empty, error)

func (*Server) DeleteHosts 

func (s *Server) DeleteHosts(ctx context.Context, req *ypb.DeleteHostsRequest) (*ypb.Empty, error)

func (*Server) DeleteLocalPluginsByWhere 

func (s *Server) DeleteLocalPluginsByWhere(ctx context.Context, req *ypb.DeleteLocalPluginsByWhereRequest) (*ypb.Empty, error)

func (*Server) DeleteMarkdownDocument 

func (s *Server) DeleteMarkdownDocument(ctx context.Context, req *ypb.GetMarkdownDocumentRequest) (*ypb.Empty, error)

func (*Server) DeletePayload 

func (s *Server) DeletePayload(ctx context.Context, req *ypb.DeletePayloadRequest) (*ypb.Empty, error)

func (*Server) DeletePayloadByGroup 

func (s *Server) DeletePayloadByGroup(ctx context.Context, req *ypb.DeletePayloadByGroupRequest) (*ypb.Empty, error)

func (*Server) DeletePluginByUserID 

func (s *Server) DeletePluginByUserID(ctx context.Context, req *ypb.DeletePluginByUserIDRequest) (*ypb.Empty, error)

func (*Server) DeletePorts 

func (s *Server) DeletePorts(ctx context.Context, req *ypb.DeletePortsRequest) (*ypb.Empty, error)

func (*Server) DeleteProject 

func (s *Server) DeleteProject(ctx context.Context, req *ypb.DeleteProjectRequest) (*ypb.Empty, error)

func (*Server) DeleteReport 

func (s *Server) DeleteReport(ctx context.Context, d *ypb.DeleteReportRequest) (*ypb.Empty, error)

func (*Server) DeleteRisk 

func (s *Server) DeleteRisk(ctx context.Context, req *ypb.DeleteRiskRequest) (*ypb.Empty, error)

func (*Server) DeleteScreenRecorders added in v1.2.2 

func (s *Server) DeleteScreenRecorders(ctx context.Context, req *ypb.QueryScreenRecorderRequest) (*ypb.Empty, error)

func (*Server) DeleteYakScript 

func (s *Server) DeleteYakScript(ctx context.Context, req *ypb.DeleteYakScriptRequest) (*ypb.Empty, error)

func (*Server) DeleteYakScriptExec 

func (s *Server) DeleteYakScriptExec(ctx context.Context, req *ypb.Empty) (*ypb.Empty, error)

func (*Server) DeleteYakScriptExecResult 

func (s *Server) DeleteYakScriptExecResult(ctx context.Context, req *ypb.DeleteYakScriptExecResultRequest) (*ypb.Empty, error)

func (*Server) DownloadMITMCert 

func (s *Server) DownloadMITMCert(ctx context.Context, _ *ypb.Empty) (*ypb.MITMCert, error)

func (*Server) DownloadOnlinePluginAll 

func (s *Server) DownloadOnlinePluginAll(req *ypb.DownloadOnlinePluginByTokenRequest, stream ypb.Yak_DownloadOnlinePluginAllServer) error

func (*Server) DownloadOnlinePluginById 

func (s *Server) DownloadOnlinePluginById(ctx context.Context, req *ypb.DownloadOnlinePluginByIdRequest) (*ypb.Empty, error)

func (*Server) DownloadOnlinePluginByIds 

func (s *Server) DownloadOnlinePluginByIds(ctx context.Context, req *ypb.DownloadOnlinePluginByIdsRequest) (*ypb.Empty, error)

func (*Server) DownloadOnlinePluginByScriptNames 

func (s *Server) DownloadOnlinePluginByScriptNames(ctx context.Context, req *ypb.DownloadOnlinePluginByScriptNamesRequest) (*ypb.DownloadOnlinePluginByScriptNamesResponse, error)

func (*Server) DownloadReport 

func (s *Server) DownloadReport(ctx context.Context, req *ypb.DownloadReportRequest) (*ypb.Empty, error)

func (*Server) Echo 

func (s *Server) Echo(ctx context.Context, req *ypb.EchoRequest) (*ypb.EchoResposne, error)

func (*Server) Exec 

func (s *Server) Exec(req *ypb.ExecRequest, stream ypb.Yak_ExecServer) error

func (*Server) ExecBatchYakScript 

func (s *Server) ExecBatchYakScript(req *ypb.ExecBatchYakScriptRequest, stream ypb.Yak_ExecBatchYakScriptServer) error

func (*Server) ExecPacketScan 

func (s *Server) ExecPacketScan(req *ypb.ExecPacketScanRequest, stream ypb.Yak_ExecPacketScanServer) error

func (*Server) ExecWithContext 

func (s *Server) ExecWithContext(ctx context.Context, req *ypb.ExecRequest, stream ypb.Yak_ExecServer) error

func (*Server) ExecYakScript 

func (s *Server) ExecYakScript(req *ypb.ExecRequest, stream ypb.Yak_ExecYakScriptServer) error

func (*Server) ExecYakitPluginsByYakScriptFilter 

func (s *Server) ExecYakitPluginsByYakScriptFilter(req *ypb.ExecYakitPluginsByYakScriptFilterRequest, stream ypb.Yak_ExecYakitPluginsByYakScriptFilterServer) error

func (*Server) ExecuteBatchPacketYakScript 

func (s *Server) ExecuteBatchPacketYakScript(req *ypb.ExecuteBatchPacketYakScriptParams, stream ypb.Yak_ExecuteBatchPacketYakScriptServer) error

func (*Server) ExecuteChaosMakerRule 

func (s *Server) ExecuteChaosMakerRule(req *ypb.ExecuteChaosMakerRuleRequest, stream ypb.Yak_ExecuteChaosMakerRuleServer) error

func (*Server) ExecutePacketYakScript 

func (s *Server) ExecutePacketYakScript(req *ypb.ExecutePacketYakScriptParams, stream ypb.Yak_ExecutePacketYakScriptServer) error

func (*Server) ExportMITMReplacerRules 

func (s *Server) ExportMITMReplacerRules(ctx context.Context, _ *ypb.Empty) (*ypb.ExportMITMReplacerRulesResponse, error)

func (*Server) ExportMenuItem 

func (s *Server) ExportMenuItem(ctx context.Context, req *ypb.Empty) (*ypb.ExportMenuItemResult, error)

func (*Server) ExportProject 

func (s *Server) ExportProject(req *ypb.ExportProjectRequest, stream ypb.Yak_ExportProjectServer) error

func (*Server) ExportYakPluginBatch 

func (s *Server) ExportYakPluginBatch(script *yakit.YakScript, dir, OutputPluginDir string) (string, error)

func (*Server) ExportYakScript 

func (s *Server) ExportYakScript(ctx context.Context, req *ypb.ExportYakScriptRequest) (*ypb.ExportYakScriptResponse, error)

func (*Server) ExtractData 

func (s *Server) ExtractData(server ypb.Yak_ExtractDataServer) error

func (*Server) ExtractDataToFile 

func (s *Server) ExtractDataToFile(input ypb.Yak_ExtractDataToFileServer) error

func (*Server) ExtractHTTPResponse 

func (s *Server) ExtractHTTPResponse(ctx context.Context, req *ypb.ExtractHTTPResponseParams) (*ypb.ExtractHTTPResponseResult, error)

func (*Server) ExtractUrl 

func (s *Server) ExtractUrl(ctx context.Context, req *ypb.FuzzerRequest) (*ypb.ExtractedUrl, error)

func (*Server) FixUploadPacket 

func (s *Server) FixUploadPacket(ctx context.Context, req *ypb.FixUploadPacketRequest) (*ypb.FixUploadPacketResponse, error)

func (*Server) ForceUpdateAvailableYakScriptTags 

func (s *Server) ForceUpdateAvailableYakScriptTags(ctx context.Context, req *ypb.Empty) (*ypb.Empty, error)

func (*Server) GenerateCSRFPocByPacket 

func (s *Server) GenerateCSRFPocByPacket(ctx context.Context, req *ypb.GenerateCSRFPocByPacketRequest) (*ypb.GenerateCSRFPocByPacketResponse, error)

func (*Server) GenerateExtractRule 

func (s *Server) GenerateExtractRule(
	ctx context.Context,
	req *ypb.GenerateExtractRuleRequest,
) (*ypb.GenerateExtractRuleResponse, error)

func (*Server) GenerateWebsiteTree 

func (s *Server) GenerateWebsiteTree(ctx context.Context, req *ypb.GenerateWebsiteTreeRequest) (
	*ypb.GenerateWebsiteTreeResponse, error,
)

func (*Server) GenerateYakCodeByPacket 

func (s *Server) GenerateYakCodeByPacket(ctx context.Context, req *ypb.GenerateYakCodeByPacketRequest) (*ypb.GenerateYakCodeByPacketResponse, error)

func (*Server) GenerateYsoBytes 

func (s *Server) GenerateYsoBytes(ctx context.Context, req *ypb.YsoOptionsRequerstWithVerbose) (*ypb.YsoBytesResponse, error)

func (*Server) GenerateYsoCode 

func (s *Server) GenerateYsoCode(ctx context.Context, req *ypb.YsoOptionsRequerstWithVerbose) (*ypb.YsoCodeResponse, error)

func (*Server) GetAllMenuItem 

func (s *Server) GetAllMenuItem(ctx context.Context, req *ypb.Empty) (*ypb.MenuByGroup, error)

func (*Server) GetAllPayload 

func (s *Server) GetAllPayload(ctx context.Context, req *ypb.GetAllPayloadRequest) (*ypb.GetAllPayloadResponse, error)

func (*Server) GetAllPayloadGroup 

func (s *Server) GetAllPayloadGroup(ctx context.Context, _ *ypb.Empty) (*ypb.GetAllPayloadGroupResponse, error)

func (*Server) GetAllProcessEnvKey 

func (s *Server) GetAllProcessEnvKey(ctx context.Context, req *ypb.Empty) (*ypb.GetProcessEnvKeyResult, error)

func (*Server) GetAllYsoClassGeneraterOptions 

func (s *Server) GetAllYsoClassGeneraterOptions(ctx context.Context, req *ypb.YsoOptionsRequerstWithVerbose) (*ypb.YsoClassOptionsResponseWithVerbose, error)

func (*Server) GetAllYsoClassOptions 

func (s *Server) GetAllYsoClassOptions(ctx context.Context, req *ypb.YsoOptionsRequerstWithVerbose) (*ypb.YsoOptionsWithVerbose, error)

func (*Server) GetAllYsoGadgetOptions 

func (s *Server) GetAllYsoGadgetOptions(ctx context.Context, _ *ypb.Empty) (*ypb.YsoOptionsWithVerbose, error)

func (*Server) GetAvailableBruteTypes 

func (s *Server) GetAvailableBruteTypes(ctx context.Context, req *ypb.Empty) (*ypb.GetAvailableBruteTypesResponse, error)

func (*Server) GetAvailableYakScriptTags 

func (s *Server) GetAvailableYakScriptTags(ctx context.Context, req *ypb.Empty) (*ypb.Fields, error)

func (*Server) GetCVE 

func (s *Server) GetCVE(ctx context.Context, req *ypb.GetCVERequest) (*ypb.CVEDetailEx, error)

func (*Server) GetCurrentProject 

func (s *Server) GetCurrentProject(ctx context.Context, _ *ypb.Empty) (*ypb.ProjectDescription, error)

func (*Server) GetCurrentRules 

func (s *Server) GetCurrentRules(c context.Context, req *ypb.Empty) (*ypb.MITMContentReplacers, error)

func (*Server) GetCurrentYakBridgeLogServer 

func (s *Server) GetCurrentYakBridgeLogServer(ctx context.Context, l *ypb.Empty) (*ypb.YakDNSLogBridgeAddr, error)

func (*Server) GetDefaultProject 

func (s *Server) GetDefaultProject(ctx context.Context, req *ypb.Empty) (*ypb.ProjectDescription, error)

func (*Server) GetEngineDefaultProxy 

func (s *Server) GetEngineDefaultProxy(ctx context.Context, e *ypb.Empty) (*ypb.DefaultProxyResult, error)

func (*Server) GetExecBatchYakScriptUnfinishedTask 

func (s *Server) GetExecBatchYakScriptUnfinishedTask(ctx context.Context, req *ypb.Empty) (*ypb.GetExecBatchYakScriptUnfinishedTaskResponse, error)

func (*Server) GetExecBatchYakScriptUnfinishedTaskByUid 

func (s *Server) GetExecBatchYakScriptUnfinishedTaskByUid(ctx context.Context, req *ypb.GetExecBatchYakScriptUnfinishedTaskByUidRequest) (*ypb.ExecBatchYakScriptRequest, error)

func (*Server) GetGlobalReverseServer 

func (s *Server) GetGlobalReverseServer(ctx context.Context, req *ypb.Empty) (*ypb.GetGlobalReverseServerResponse, error)

func (*Server) GetHTTPFlowByHash 

func (s *Server) GetHTTPFlowByHash(_ context.Context, r *ypb.GetHTTPFlowByHashRequest) (*ypb.HTTPFlow, error)

func (*Server) GetHTTPFlowById 

func (s *Server) GetHTTPFlowById(_ context.Context, r *ypb.GetHTTPFlowByIdRequest) (*ypb.HTTPFlow, error)

func (*Server) GetHTTPPacketBody 

func (s *Server) GetHTTPPacketBody(ctx context.Context, req *ypb.GetHTTPPacketBodyRequest) (*ypb.Bytes, error)

func (*Server) GetHistoryHTTPFuzzerTask 

func (s *Server) GetHistoryHTTPFuzzerTask(ctx context.Context, req *ypb.GetHistoryHTTPFuzzerTaskRequest) (*ypb.HistoryHTTPFuzzerTaskDetail, error)

func (*Server) GetKey 

func (s *Server) GetKey(ctx context.Context, req *ypb.GetKeyRequest) (*ypb.GetKeyResult, error)

func (*Server) GetLicense 

func (s *Server) GetLicense(ctx context.Context, _ *ypb.Empty) (_ *ypb.GetLicenseResponse, unexpectedError error)

func (*Server) GetMITMFilter 

func (s *Server) GetMITMFilter(ctx context.Context, req *ypb.Empty) (*ypb.SetMITMFilterRequest, error)

func (*Server) GetMachineID 

func (s *Server) GetMachineID(ctx context.Context, _ *ypb.Empty) (*ypb.GetMachineIDResponse, error)

func (*Server) GetMarkdownDocument 

func (s *Server) GetMarkdownDocument(ctx context.Context, req *ypb.GetMarkdownDocumentRequest) (*ypb.GetMarkdownDocumentResponse, error)

func (*Server) GetMenuItemById 

func (s *Server) GetMenuItemById(ctx context.Context, req *ypb.GetMenuItemByIdRequest) (*ypb.MenuItem, error)

func (*Server) GetOneScreenRecorders added in v1.2.2 

func (s *Server) GetOneScreenRecorders(ctx context.Context, req *ypb.GetOneScreenRecorderRequest) (*ypb.ScreenRecorder, error)

func (*Server) GetOnlineProfile 

func (s *Server) GetOnlineProfile(ctx context.Context, req *ypb.Empty) (*ypb.OnlineProfile, error)

func (*Server) GetProfileDatabase 

func (*Server) GetProfileDatabase() *gorm.DB

func (*Server) GetProjectDatabase 

func (*Server) GetProjectDatabase() *gorm.DB

func (*Server) GetProjects 

func (s *Server) GetProjects(ctx context.Context, req *ypb.GetProjectsRequest) (*ypb.GetProjectsResponse, error)

func (*Server) GetRequestBodyByHTTPFlowID 

func (s *Server) GetRequestBodyByHTTPFlowID(ctx context.Context, req *ypb.DownloadBodyByHTTPFlowIDRequest) (*ypb.Bytes, error)

func (*Server) GetResponseBodyByHTTPFlowID 

func (s *Server) GetResponseBodyByHTTPFlowID(ctx context.Context, req *ypb.DownloadBodyByHTTPFlowIDRequest) (*ypb.Bytes, error)

func (*Server) GetSimpleDetectUnfinishedTask 

func (s *Server) GetSimpleDetectUnfinishedTask(ctx context.Context, req *ypb.Empty) (*ypb.GetSimpleDetectUnfinishedTaskResponse, error)

func (*Server) GetSimpleDetectUnfinishedTaskByUid 

func (s *Server) GetSimpleDetectUnfinishedTaskByUid(ctx context.Context, req *ypb.GetExecBatchYakScriptUnfinishedTaskByUidRequest) (*ypb.RecordPortScanRequest, error)

func (*Server) GetSystemProxy 

func (s *Server) GetSystemProxy(ctx context.Context, req *ypb.Empty) (*ypb.GetSystemProxyResult, error)

func (*Server) GetTunnelServerExternalIP 

func (s *Server) GetTunnelServerExternalIP(ctx context.Context, p *ypb.GetTunnelServerExternalIPParams) (*ypb.GetTunnelServerExternalIPResponse, error)

func (*Server) GetYakScriptById 

func (s *Server) GetYakScriptById(ctx context.Context, req *ypb.GetYakScriptByIdRequest) (*ypb.YakScript, error)

func (*Server) GetYakScriptByName 

func (s *Server) GetYakScriptByName(ctx context.Context, req *ypb.GetYakScriptByNameRequest) (*ypb.YakScript, error)

func (*Server) GetYakScriptByOnlineID 

func (s *Server) GetYakScriptByOnlineID(ctx context.Context, req *ypb.GetYakScriptByOnlineIDRequest) (*ypb.YakScript, error)

func (*Server) GetYakScriptTags 

func (s *Server) GetYakScriptTags(c context.Context, req *ypb.Empty) (*ypb.GetYakScriptTagsResponse, error)

func (*Server) GetYakScriptTagsAndType 

func (s *Server) GetYakScriptTagsAndType(ctx context.Context, req *ypb.Empty) (*ypb.GetYakScriptTagsAndTypeResponse, error)

func (*Server) GetYakVMBuildInMethodCompletion 

func (s *Server) GetYakVMBuildInMethodCompletion(
	ctx context.Context,
	req *ypb.GetYakVMBuildInMethodCompletionRequest,
) (*ypb.GetYakVMBuildInMethodCompletionResponse, error)

func (*Server) GetYakitCompletionRaw 

func (s *Server) GetYakitCompletionRaw(ctx context.Context, _ *ypb.Empty) (*ypb.YakitCompletionRawResponse, error)

func (*Server) HTTPFlowsExtract added in v1.2.2 

func (s *Server) HTTPFlowsExtract(ctx context.Context, req *ypb.HTTPFlowsExtractRequest) (*ypb.Empty, error)

func (*Server) HTTPFlowsFieldGroup 

func (s *Server) HTTPFlowsFieldGroup(ctx context.Context, req *ypb.HTTPFlowsFieldGroupRequest) (*ypb.HTTPFlowsFieldGroupResponse, error)

func (*Server) HTTPFlowsShare added in v1.2.2 

func (s *Server) HTTPFlowsShare(ctx context.Context, req *ypb.HTTPFlowsShareRequest) (*ypb.HTTPFlowsShareResponse, error)

func (*Server) HTTPFuzzer 

func (s *Server) HTTPFuzzer(req *ypb.FuzzerRequest, stream ypb.Yak_HTTPFuzzerServer) (finalError error)

func (*Server) HTTPRequestAnalyzer 

func (s *Server) HTTPRequestAnalyzer(ctx context.Context, req *ypb.HTTPRequestAnalysisMaterial) (*ypb.HTTPRequestAnalysis, error)

func (*Server) HTTPRequestBuilder added in v1.2.2 

func (s *Server) HTTPRequestBuilder(ctx context.Context, req *ypb.HTTPRequestBuilderParams) (*ypb.HTTPRequestBuilderResponse, error)

func (*Server) HTTPRequestMutate 

func (s *Server) HTTPRequestMutate(ctx context.Context, req *ypb.HTTPRequestMutateParams) (*ypb.MutateResult, error)

func (*Server) HTTPResponseMutate 

func (s *Server) HTTPResponseMutate(ctx context.Context, req *ypb.HTTPResponseMutateParams) (*ypb.MutateResult, error)

func (*Server) IgnoreYakScript 

func (s *Server) IgnoreYakScript(ctx context.Context, req *ypb.DeleteYakScriptRequest) (*ypb.Empty, error)

func (*Server) ImportChaosMakerRules 

func (s *Server) ImportChaosMakerRules(ctx context.Context, req *ypb.ImportChaosMakerRulesRequest) (*ypb.Empty, error)

func (*Server) ImportMITMReplacerRules 

func (s *Server) ImportMITMReplacerRules(ctx context.Context, req *ypb.ImportMITMReplacerRulesRequest) (*ypb.Empty, error)

func (*Server) ImportMenuItem 

func (s *Server) ImportMenuItem(ctx context.Context, req *ypb.ImportMenuItemRequest) (*ypb.Empty, error)

func (*Server) ImportProject 

func (s *Server) ImportProject(req *ypb.ImportProjectRequest, stream ypb.Yak_ImportProjectServer) error

func (*Server) InstallScrecorder 

func (s *Server) InstallScrecorder(req *ypb.InstallScrecorderRequest, stream ypb.Yak_InstallScrecorderServer) error

func (*Server) IsCVEDatabaseReady 

func (s *Server) IsCVEDatabaseReady(ctx context.Context, req *ypb.IsCVEDatabaseReadyRequest) (*ypb.IsCVEDatabaseReadyResponse, error)

func (*Server) IsMultipartFormDataRequest 

func (s *Server) IsMultipartFormDataRequest(ctx context.Context, req *ypb.FixUploadPacketRequest) (*ypb.IsMultipartFormDataRequestResult, error)

func (*Server) IsPrivilegedForNetRaw 

func (s *Server) IsPrivilegedForNetRaw(ctx context.Context, req *ypb.Empty) (*ypb.IsPrivilegedForNetRawResponse, error)

func (*Server) IsProjectNameValid 

func (s *Server) IsProjectNameValid(ctx context.Context, req *ypb.IsProjectNameValidRequest) (*ypb.Empty, error)

func (*Server) IsRemoteAddrAvailable 

func (s *Server) IsRemoteAddrAvailable(ctx context.Context, req *ypb.IsRemoteAddrAvailableRequest) (*ypb.IsRemoteAddrAvailableResponse, error)

func (*Server) IsScrecorderReady 

func (s *Server) IsScrecorderReady(ctx context.Context, req *ypb.IsScrecorderReadyRequest) (*ypb.IsScrecorderReadyResponse, error)

func (*Server) LoadNucleiTemplates 

func (s *Server) LoadNucleiTemplates(ctx context.Context, req *ypb.Empty) (*ypb.Empty, error)

func (*Server) MITM 

func (s *Server) MITM(stream ypb.Yak_MITMServer) error

func (*Server) MatchHTTPResponse 

func (s *Server) MatchHTTPResponse(ctx context.Context, req *ypb.MatchHTTPResponseParams) (*ypb.MatchHTTPResponseResult, error)

func (*Server) MigrateLegacyDatabase 

func (s *Server) MigrateLegacyDatabase(ctx context.Context, req *ypb.Empty) (*ypb.Empty, error)

func (*Server) NewProject 

func (s *Server) NewProject(ctx context.Context, req *ypb.NewProjectRequest) (*ypb.NewProjectResponse, error)

func (*Server) NewRiskRead 

func (s *Server) NewRiskRead(ctx context.Context, req *ypb.NewRiskReadRequest) (*ypb.Empty, error)

func (*Server) OpenPort 

func (s *Server) OpenPort(inputStream ypb.Yak_OpenPortServer) error

func (*Server) PopExecBatchYakScriptUnfinishedTaskByUid 

func (s *Server) PopExecBatchYakScriptUnfinishedTaskByUid(ctx context.Context, req *ypb.GetExecBatchYakScriptUnfinishedTaskByUidRequest) (*ypb.ExecBatchYakScriptRequest, error)

func (*Server) PopSimpleDetectUnfinishedTaskByUid 

func (s *Server) PopSimpleDetectUnfinishedTaskByUid(ctx context.Context, req *ypb.GetExecBatchYakScriptUnfinishedTaskByUidRequest) (*ypb.RecordPortScanRequest, error)

func (*Server) PortScan 

func (s *Server) PortScan(req *ypb.PortScanRequest, stream ypb.Yak_PortScanServer) error

func (*Server) PreloadHTTPFuzzerParams 

func (s *Server) PreloadHTTPFuzzerParams(ctx context.Context, req *ypb.PreloadHTTPFuzzerParamsRequest) (*ypb.PreloadHTTPFuzzerParamsResponse, error)

func (*Server) PromotePermissionForUserPcap 

func (s *Server) PromotePermissionForUserPcap(ctx context.Context, req *ypb.Empty) (*ypb.Empty, error)

func (*Server) QueryAllMenuItem 

func (s *Server) QueryAllMenuItem(ctx context.Context, req *ypb.QueryAllMenuItemRequest) (*ypb.MenuByGroup, error)

func (*Server) QueryAvailableReportFrom 

func (s *Server) QueryAvailableReportFrom(ctx context.Context, _ *ypb.Empty) (*ypb.Fields, error)

func (*Server) QueryAvailableRiskLevel 

func (s *Server) QueryAvailableRiskLevel(ctx context.Context, _ *ypb.Empty) (*ypb.Fields, error)

func (*Server) QueryAvailableRiskType 

func (s *Server) QueryAvailableRiskType(ctx context.Context, req *ypb.Empty) (*ypb.Fields, error)

func (*Server) QueryCVE 

func (s *Server) QueryCVE(ctx context.Context, req *ypb.QueryCVERequest) (*ypb.QueryCVEResponse, error)

func (*Server) QueryChaosMakerRule 

func (s *Server) QueryChaosMakerRule(ctx context.Context, req *ypb.QueryChaosMakerRuleRequest) (*ypb.QueryChaosMakerRuleResponse, error)

func (*Server) QueryDNSLogByToken 

func (s *Server) QueryDNSLogByToken(ctx context.Context, req *ypb.QueryDNSLogByTokenRequest) (*ypb.QueryDNSLogByTokenResponse, error)

func (*Server) QueryDomains 

func (s *Server) QueryDomains(ctx context.Context, req *ypb.QueryDomainsRequest) (*ypb.QueryDomainsResponse, error)

func (*Server) QueryExecHistory 

func (s *Server) QueryExecHistory(ctx context.Context, req *ypb.ExecHistoryRequest) (*ypb.ExecHistoryRecordResponse, error)

func (*Server) QueryGroupsByYakScriptId 

func (s *Server) QueryGroupsByYakScriptId(ctx context.Context, req *ypb.QueryGroupsByYakScriptIdRequest) (*ypb.GroupNames, error)

func (*Server) QueryHTTPFlowByIds 

func (s *Server) QueryHTTPFlowByIds(_ context.Context, r *ypb.GetHTTPFlowByIdsRequest) (*ypb.HTTPFlows, error)

func (*Server) QueryHTTPFlows 

func (s *Server) QueryHTTPFlows(ctx context.Context, req *ypb.QueryHTTPFlowRequest) (*ypb.QueryHTTPFlowResponse, error)

func (*Server) QueryHTTPFlowsIds 

func (s *Server) QueryHTTPFlowsIds(ctx context.Context, req *ypb.QueryHTTPFlowsIdsRequest) (*ypb.QueryHTTPFlowsIdsResponse, error)

func (*Server) QueryHTTPFuzzerResponseByTaskIdRequest 

func (s *Server) QueryHTTPFuzzerResponseByTaskIdRequest(ctx context.Context, req *ypb.QueryHTTPFuzzerResponseByTaskIdRequest) (*ypb.QueryHTTPFuzzerResponseByTaskIdResponse, error)

func (*Server) QueryHistoryHTTPFuzzerTask 

func (s *Server) QueryHistoryHTTPFuzzerTask(ctx context.Context, req *ypb.Empty) (*ypb.HistoryHTTPFuzzerTasks, error)

func (*Server) QueryHistoryHTTPFuzzerTaskEx 

func (s *Server) QueryHistoryHTTPFuzzerTaskEx(ctx context.Context, req *ypb.QueryHistoryHTTPFuzzerTaskExParams) (*ypb.HistoryHTTPFuzzerTasksResponse, error)

func (*Server) QueryHosts 

func (s *Server) QueryHosts(ctx context.Context, req *ypb.QueryHostsRequest) (*ypb.QueryHostsResponse, error)

func (*Server) QueryICMPTrigger 

func (s *Server) QueryICMPTrigger(ctx context.Context, req *ypb.QueryICMPTriggerRequest) (*ypb.QueryICMPTriggerResponse, error)

func (*Server) QueryMITMRuleExtractedData 

func (s *Server) QueryMITMRuleExtractedData(ctx context.Context, req *ypb.QueryMITMRuleExtractedDataRequest) (*ypb.QueryMITMRuleExtractedDataResponse, error)

func (*Server) QueryNewRisk 

func (s *Server) QueryNewRisk(ctx context.Context, req *ypb.QueryNewRiskRequest) (*ypb.QueryNewRiskResponse, error)

func (*Server) QueryPayload 

func (s *Server) QueryPayload(ctx context.Context, req *ypb.QueryPayloadRequest) (*ypb.QueryPayloadResponse, error)

func (*Server) QueryPorts 

func (s *Server) QueryPorts(ctx context.Context, req *ypb.QueryPortsRequest) (*ypb.QueryPortsResponse, error)

func (*Server) QueryPortsGroup added in v1.2.2 

func (s *Server) QueryPortsGroup(ctx context.Context, req *ypb.Empty) (*ypb.QueryPortsGroupResponse, error)

func (*Server) QueryProjectDetail 

func (s *Server) QueryProjectDetail(ctx context.Context, req *ypb.QueryProjectDetailRequest) (*ypb.ProjectDescription, error)

func (*Server) QueryRandomPortTrigger 

func (s *Server) QueryRandomPortTrigger(ctx context.Context, r *ypb.QueryRandomPortTriggerRequest) (*ypb.RandomPortTriggerNotification, error)

func (*Server) QueryReport 

func (s *Server) QueryReport(ctx context.Context, d *ypb.QueryReportRequest) (*ypb.Report, error)

func (*Server) QueryReports 

func (s *Server) QueryReports(ctx context.Context, d *ypb.QueryReportsRequest) (*ypb.QueryReportsResponse, error)

func (*Server) QueryRisk 

func (s *Server) QueryRisk(ctx context.Context, req *ypb.QueryRiskRequest) (*ypb.Risk, error)

func (*Server) QueryRiskTableStats 

func (s *Server) QueryRiskTableStats(ctx context.Context, e *ypb.Empty) (*ypb.RiskTableStats, error)

func (*Server) QueryRisks 

func (s *Server) QueryRisks(ctx context.Context, req *ypb.QueryRisksRequest) (*ypb.QueryRisksResponse, error)

func (*Server) QueryScreenRecorders 

func (s *Server) QueryScreenRecorders(ctx context.Context, req *ypb.QueryScreenRecorderRequest) (*ypb.QueryScreenRecorderResponse, error)

func (*Server) QueryWebsocketFlowByHTTPFlowWebsocketHash 

func (s *Server) QueryWebsocketFlowByHTTPFlowWebsocketHash(ctx context.Context, req *ypb.QueryWebsocketFlowByHTTPFlowWebsocketHashRequest) (*ypb.WebsocketFlows, error)

func (*Server) QueryYakScript 

func (s *Server) QueryYakScript(ctx context.Context, req *ypb.QueryYakScriptRequest) (*ypb.QueryYakScriptResponse, error)

func (*Server) QueryYakScriptByOnlineGroup 

func (s *Server) QueryYakScriptByOnlineGroup(c context.Context, req *ypb.QueryYakScriptByOnlineGroupRequest) (*ypb.QueryYakScriptLocalAndUserResponse, error)

func (*Server) QueryYakScriptByYakScriptName 

func (s *Server) QueryYakScriptByYakScriptName(req *ypb.QueryYakScriptRequest, stream ypb.Yak_QueryYakScriptByYakScriptNameServer) error

func (*Server) QueryYakScriptExecResult 

func (s *Server) QueryYakScriptExecResult(ctx context.Context, req *ypb.QueryYakScriptExecResultRequest) (*ypb.QueryYakScriptExecResultResponse, error)

func (*Server) QueryYakScriptLocalAll 

func (s *Server) QueryYakScriptLocalAll(c context.Context, req *ypb.Empty) (*ypb.QueryYakScriptLocalAndUserResponse, error)

func (*Server) QueryYakScriptLocalAndUser 

func (s *Server) QueryYakScriptLocalAndUser(c context.Context, req *ypb.QueryYakScriptLocalAndUserRequest) (*ypb.QueryYakScriptLocalAndUserResponse, error)

func (*Server) QueryYakScriptNameInExecResult 

func (s *Server) QueryYakScriptNameInExecResult(ctx context.Context, req *ypb.Empty) (*ypb.YakScriptNames, error)

func (*Server) RecoverExecBatchYakScriptUnfinishedTask 

func (s *Server) RecoverExecBatchYakScriptUnfinishedTask(req *ypb.RecoverExecBatchYakScriptUnfinishedTaskRequest, stream ypb.Yak_RecoverExecBatchYakScriptUnfinishedTaskServer) error

func (*Server) RecoverSimpleDetectUnfinishedTask 

func (s *Server) RecoverSimpleDetectUnfinishedTask(req *ypb.RecoverExecBatchYakScriptUnfinishedTaskRequest, stream ypb.Yak_RecoverSimpleDetectUnfinishedTaskServer) error

func (*Server) RedirectRequest 

func (s *Server) RedirectRequest(ctx context.Context, req *ypb.RedirectRequestParams) (*ypb.FuzzerResponse, error)

func (*Server) RegisterFacadesHTTP 

func (s *Server) RegisterFacadesHTTP(ctx context.Context, req *ypb.RegisterFacadesHTTPRequest) (*ypb.RegisterFacadesHTTPResponse, error)

func (*Server) RemoveFromMenu 

func (s *Server) RemoveFromMenu(ctx context.Context, req *ypb.RemoveFromMenuRequest) (*ypb.Empty, error)

func (*Server) RemoveProject 

func (s *Server) RemoveProject(ctx context.Context, req *ypb.RemoveProjectRequest) (*ypb.Empty, error)

func (*Server) RenderVariables 

func (s *Server) RenderVariables(ctx context.Context, req *ypb.RenderVariablesRequest) (*ypb.RenderVariablesResponse, error)

func (*Server) RequireDNSLogDomain 

func (s *Server) RequireDNSLogDomain(ctx context.Context, addr *ypb.YakDNSLogBridgeAddr) (*ypb.DNSLogRootDomain, error)

func (*Server) RequireICMPRandomLength 

func (s *Server) RequireICMPRandomLength(ctx context.Context, req *ypb.Empty) (*ypb.RequireICMPRandomLengthResponse, error)

func (*Server) RequireRandomPortToken 

func (s *Server) RequireRandomPortToken(ctx context.Context, req *ypb.Empty) (*ypb.RandomPortInfo, error)

func (*Server) ResetAndInvalidUserData 

func (s *Server) ResetAndInvalidUserData(ctx context.Context, req *ypb.ResetAndInvalidUserDataRequest) (*ypb.Empty, error)

func (*Server) ResetRiskTableStats 

func (s *Server) ResetRiskTableStats(ctx context.Context, e *ypb.Empty) (*ypb.Empty, error)

func (*Server) SaveCancelSimpleDetect 

func (s *Server) SaveCancelSimpleDetect(ctx context.Context, req *ypb.RecordPortScanRequest) (*ypb.Empty, error)

func (*Server) SaveMarkdownDocument 

func (s *Server) SaveMarkdownDocument(ctx context.Context, req *ypb.SaveMarkdownDocumentRequest) (*ypb.Empty, error)

func (*Server) SavePayload 

func (s *Server) SavePayload(ctx context.Context, req *ypb.SavePayloadRequest) (*ypb.Empty, error)

func (*Server) SavePayloadStream 

func (s *Server) SavePayloadStream(req *ypb.SavePayloadRequest, stream ypb.Yak_SavePayloadStreamServer) error

func (*Server) SaveSetTagForHTTPFlow 

func (s *Server) SaveSetTagForHTTPFlow(id int64, hash string, tags []string) error

func (*Server) SaveTextToTemporalFile 

func (s *Server) SaveTextToTemporalFile(ctx context.Context, req *ypb.SaveTextToTemporalFileRequest) (*ypb.SaveTextToTemporalFileResponse, error)

func (*Server) SaveYakScript 

func (s *Server) SaveYakScript(ctx context.Context, script *ypb.YakScript) (*ypb.YakScript, error)

func (*Server) SetCurrentProject 

func (s *Server) SetCurrentProject(ctx context.Context, req *ypb.SetCurrentProjectRequest) (*ypb.Empty, error)

func (*Server) SetCurrentRules 

func (s *Server) SetCurrentRules(c context.Context, req *ypb.MITMContentReplacers) (*ypb.Empty, error)

func (*Server) SetEngineDefaultProxy 

func (s *Server) SetEngineDefaultProxy(ctx context.Context, d *ypb.DefaultProxyResult) (*ypb.Empty, error)

func (*Server) SetKey 

func (s *Server) SetKey(ctx context.Context, req *ypb.SetKeyRequest) (*ypb.Empty, error)

func (*Server) SetMITMFilter 

func (s *Server) SetMITMFilter(ctx context.Context, req *ypb.SetMITMFilterRequest) (*ypb.SetMITMFilterResponse, error)

func (*Server) SetOnlineProfile 

func (s *Server) SetOnlineProfile(ctx context.Context, req *ypb.OnlineProfile) (*ypb.Empty, error)

func (*Server) SetProcessEnvKey 

func (s *Server) SetProcessEnvKey(ctx context.Context, req *ypb.SetKeyRequest) (*ypb.Empty, error)

func (*Server) SetSystemProxy 

func (s *Server) SetSystemProxy(ctx context.Context, req *ypb.SetSystemProxyRequest) (*ypb.Empty, error)

func (*Server) SetTagForHTTPFlow 

func (s *Server) SetTagForHTTPFlow(ctx context.Context, req *ypb.SetTagForHTTPFlowRequest) (*ypb.Empty, error)

func (*Server) SetYakBridgeLogServer 

func (s *Server) SetYakBridgeLogServer(ctx context.Context, l *ypb.YakDNSLogBridgeAddr) (*ypb.Empty, error)

func (*Server) SimpleDetect 

func (s *Server) SimpleDetect(req *ypb.RecordPortScanRequest, stream ypb.Yak_SimpleDetectServer) error

func (*Server) StartBrute 

func (s *Server) StartBrute(params *ypb.StartBruteParams, stream ypb.Yak_StartBruteServer) error

func (*Server) StartFacades 

func (s *Server) StartFacades(req *ypb.StartFacadesParams, stream ypb.Yak_StartFacadesServer) error

func (*Server) StartFacadesWithYsoObject 

func (s *Server) StartFacadesWithYsoObject(req *ypb.StartFacadesWithYsoParams, stream ypb.Yak_StartFacadesWithYsoObjectServer) error

func (*Server) StartScrecorder 

func (s *Server) StartScrecorder(req *ypb.StartScrecorderRequest, stream ypb.Yak_StartScrecorderServer) error

func (*Server) StaticAnalyzeError 

func (s *Server) StaticAnalyzeError(ctx context.Context, r *ypb.StaticAnalyzeErrorRequest) (*ypb.StaticAnalyzeErrorResponse, error)

func (*Server) StringFuzzer 

func (s *Server) StringFuzzer(rootCtx context.Context, req *ypb.StringFuzzerRequest) (*ypb.StringFuzzerResponse, error)

func (*Server) UnIgnoreYakScript 

func (s *Server) UnIgnoreYakScript(ctx context.Context, req *ypb.DeleteYakScriptRequest) (*ypb.Empty, error)

func (*Server) UpdateCVEDatabase 

func (s *Server) UpdateCVEDatabase(req *ypb.UpdateCVEDatabaseRequest, stream ypb.Yak_UpdateCVEDatabaseServer) error

func (*Server) UpdateFromGithub 

func (s *Server) UpdateFromGithub(ctx context.Context, req *ypb.UpdateFromGithubRequest) (*ypb.Empty, error)

func (*Server) UpdateFromYakitResource 

func (s *Server) UpdateFromYakitResource(ctx context.Context, req *ypb.UpdateFromYakitResourceRequest) (*ypb.Empty, error)

func (*Server) UpdatePayload 

func (s *Server) UpdatePayload(ctx context.Context, req *ypb.UpdatePayloadRequest) (*ypb.Empty, error)

func (*Server) UpdateScreenRecorders added in v1.2.2 

func (s *Server) UpdateScreenRecorders(ctx context.Context, req *ypb.UpdateScreenRecorderRequest) (*ypb.Empty, error)

func (*Server) UploadRiskToOnline 

func (s *Server) UploadRiskToOnline(ctx context.Context, req *ypb.UploadRiskToOnlineRequest) (*ypb.Empty, error)

func (*Server) UploadScreenRecorders added in v1.2.2 

func (s *Server) UploadScreenRecorders(ctx context.Context, req *ypb.UploadScreenRecorderRequest) (*ypb.Empty, error)

func (*Server) VerifyTunnelServerDomain 

func (s *Server) VerifyTunnelServerDomain(ctx context.Context, p *ypb.VerifyTunnelServerDomainParams) (*ypb.VerifyTunnelServerDomainResponse, error)

func (*Server) Version 

func (s *Server) Version(ctx context.Context, _ *ypb.Empty) (*ypb.VersionResponse, error)

func (*Server) ViewPortScanCode 

func (s *Server) ViewPortScanCode(ctx context.Context, req *ypb.Empty) (*ypb.SimpleScript, error)

func (*Server) YakScriptIsInMenu 

func (s *Server) YakScriptIsInMenu(ctx context.Context, req *ypb.YakScriptIsInMenuRequest) (*ypb.Empty, error)

func (*Server) YaklangCompileAndFormat 

func (s *Server) YaklangCompileAndFormat(cx context.Context, req *ypb.YaklangCompileAndFormatRequest) (*ypb.YaklangCompileAndFormatResponse, error)

func (*Server) YsoDump 

func (s *Server) YsoDump(ctx context.Context, req *ypb.YsoBytesObject) (*ypb.YsoDumpResponse, error)

type VAttachCombinedOutputServer 

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

func NewVAttachCombinedOutputServer 

func NewVAttachCombinedOutputServer(send func(msg *ypb.ExecResult) error) *VAttachCombinedOutputServer

func (*VAttachCombinedOutputServer) Cancel 

func (v *VAttachCombinedOutputServer) Cancel()

func (*VAttachCombinedOutputServer) Context 

func (v *VAttachCombinedOutputServer) Context() context.Context

func (*VAttachCombinedOutputServer) IsValid 

func (v *VAttachCombinedOutputServer) IsValid() bool

func (*VAttachCombinedOutputServer) RecvMsg 

func (v *VAttachCombinedOutputServer) RecvMsg(m interface{}) error

func (*VAttachCombinedOutputServer) Send 

func (v *VAttachCombinedOutputServer) Send(result *ypb.ExecResult) error

func (*VAttachCombinedOutputServer) SendHeader 

func (v *VAttachCombinedOutputServer) SendHeader(md grpcMetadata.MD) error

func (*VAttachCombinedOutputServer) SendMsg 

func (v *VAttachCombinedOutputServer) SendMsg(m interface{}) error

func (*VAttachCombinedOutputServer) SetHeader 

func (v *VAttachCombinedOutputServer) SetHeader(md grpcMetadata.MD) error

func (*VAttachCombinedOutputServer) SetTrailer 

func (v *VAttachCombinedOutputServer) SetTrailer(md grpcMetadata.MD)

type YakExecServerWrapper 

type YakExecServerWrapper struct {
	grpc.ServerStream
	// contains filtered or unexported fields
}

func NewYakExecServerWrapper 

func NewYakExecServerWrapper(stream grpc.ServerStream, handle func(result *ypb.ExecResult) error) *YakExecServerWrapper

func (*YakExecServerWrapper) Send 

func (y *YakExecServerWrapper) Send(result *ypb.ExecResult) error

type YakOutputStreamerHelperWC 

type YakOutputStreamerHelperWC struct {
	io.WriteCloser
	// contains filtered or unexported fields
}

OpenPortServerStreamerHelperRWC

func (*YakOutputStreamerHelperWC) Close 

func (s *YakOutputStreamerHelperWC) Close() (err error)

func (*YakOutputStreamerHelperWC) Write 

func (s *YakOutputStreamerHelperWC) Write(b []byte) (int, error)

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.