core

type BaseModule struct{}

type Cluegetter struct {
	Config config
	Log    *log.Logger
	Redis  RedisClient
	// contains filtered or unexported fields
}

type ConfigHttpFrontend struct {
	Enabled               bool
	Listen_Port           string
	Listen_Host           string
	Enable_Proxy_Protocol bool
}

type ConfigLuaModule struct {
	Enabled        bool
	Script         string
	ScriptContents string
}

type ConfigModuleGroup struct {
	Module []string
}

type HttpCallback func(w http.ResponseWriter, r *http.Request)

type HttpMessage struct {
	Recipients   []*HttpMessageRecipient
	Headers      []*HttpMessageHeader
	CheckResults []*HttpMessageCheckResult

	Ip           string
	ReverseDns   string
	Helo         string
	SaslUsername string
	SaslMethod   string
	CertIssuer   string
	CertSubject  string
	CipherBits   string
	Cipher       string
	TlsVersion   string

	MtaHostname   string
	MtaDaemonName string

	Id                     string
	SessionId              string
	Date                   *time.Time
	BodySize               uint32
	BodySizeStr            string
	Sender                 string
	RcptCount              int
	Verdict                string
	VerdictMsg             string
	RejectScore            float64
	RejectScoreThreshold   float64
	TempfailScore          float64
	TempfailScoreThreshold float64
	ScoreCombined          float64
}

type HttpMessageCheckResult struct {
	Module        string
	Verdict       string
	Score         float64
	WeightedScore float64
	Duration      float64
	Determinants  string
}

type HttpMessageHeader struct {
	Name string
	Body string
}

type HttpMessageRecipient struct {
	Id     int
	Local  string
	Domain string
	Email  string
}

type HttpViewData struct {
	Config *config
}

type Message struct {
	QueueId  string
	From     *address.Address
	Rcpt     []*address.Address
	Headers  []MessageHeader
	Body     []byte `json:"-"`
	Date     time.Time
	BodySize int
	BodyHash string

	Verdict                int
	VerdictMsg             string
	RejectScore            float64
	RejectScoreThreshold   float64
	TempfailScore          float64
	TempfailScoreThreshold float64

	CheckResults []*MessageCheckResult
	// contains filtered or unexported fields
}

type MessageCheckResult struct {
	Module          string
	SuggestedAction int
	Message         string
	Score           float64
	Determinants    map[string]interface{}
	Duration        time.Duration
	WeightedScore   float64
	Callbacks       []*func(*Message, int)
}

type MessageHeader struct {
	Key   string
	Value string
	// contains filtered or unexported fields
}

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

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

type MilterSession struct {
	DateConnect    time.Time
	DateDisconnect time.Time
	Messages       []*Message
	Instance       uint

	SaslUsername  string
	SaslSender    string
	SaslMethod    string
	CertIssuer    string
	CertSubject   string
	CipherBits    uint32
	Cipher        string
	TlsVersion    string
	Ip            string
	ReverseDns    string
	Hostname      string
	Helo          string
	MtaHostName   string
	MtaDaemonName string
	// contains filtered or unexported fields
}

type Module interface {
	SetCluegetter(*Cluegetter)
	Name() string
	Enable() bool
	Init()
	Stop()
	MessageCheck(msg *Message, done chan bool) *MessageCheckResult
	RecipientCheck(rcpt *address.Address) (verdict int, msg string)
	SessionDisconnect(s *MilterSession)
	Ipc() map[string]func(string)
	Rpc() map[string]chan string
	HttpHandlers() map[string]HttpCallback
}

type ModuleOld struct {
	*BaseModule
	// contains filtered or unexported fields
}

type NullTime struct {
	time.Time
	Valid bool // Valid is true if Time is not NULL
}

type Proto_Message struct {
	Session                *Proto_Session               `protobuf:"bytes,1,opt,name=session" json:"session,omitempty"`
	Id                     string                       `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	From                   string                       `protobuf:"bytes,3,opt,name=from,proto3" json:"from,omitempty"`
	Rcpt                   []string                     `protobuf:"bytes,4,rep,name=rcpt" json:"rcpt,omitempty"`
	Headers                []*Proto_Message_Header      `protobuf:"bytes,5,rep,name=headers" json:"headers,omitempty"`
	Body                   []byte                       `protobuf:"bytes,6,opt,name=body,proto3" json:"body,omitempty"`
	Verdict                Proto_Message_Verdict        `protobuf:"varint,7,opt,name=verdict,proto3,enum=main.Proto_Message_Verdict" json:"verdict,omitempty"`
	VerdictMsg             string                       `protobuf:"bytes,8,opt,name=verdictMsg,proto3" json:"verdictMsg,omitempty"`
	RejectScore            float64                      `protobuf:"fixed64,9,opt,name=rejectScore,proto3" json:"rejectScore,omitempty"`
	RejectScoreThreshold   float64                      `protobuf:"fixed64,10,opt,name=rejectScoreThreshold,proto3" json:"rejectScoreThreshold,omitempty"`
	TempfailScore          float64                      `protobuf:"fixed64,11,opt,name=tempfailScore,proto3" json:"tempfailScore,omitempty"`
	TempfailScoreThreshold float64                      `protobuf:"fixed64,12,opt,name=tempfailScoreThreshold,proto3" json:"tempfailScoreThreshold,omitempty"`
	CheckResults           []*Proto_Message_CheckResult `protobuf:"bytes,13,rep,name=checkResults" json:"checkResults,omitempty"`
}

type Proto_Message_CheckResult struct {
	MessageId     string                `protobuf:"bytes,1,opt,name=message_id,json=messageId,proto3" json:"message_id,omitempty"`
	Module        string                `protobuf:"bytes,2,opt,name=module,proto3" json:"module,omitempty"`
	Verdict       Proto_Message_Verdict `protobuf:"varint,3,opt,name=verdict,proto3,enum=main.Proto_Message_Verdict" json:"verdict,omitempty"`
	Score         float64               `protobuf:"fixed64,4,opt,name=score,proto3" json:"score,omitempty"`
	WeightedScore float64               `protobuf:"fixed64,5,opt,name=weightedScore,proto3" json:"weightedScore,omitempty"`
	Duration      float64               `protobuf:"fixed64,6,opt,name=duration,proto3" json:"duration,omitempty"`
	Determinants  []byte                `protobuf:"bytes,7,opt,name=determinants,proto3" json:"determinants,omitempty"`
}

type Proto_Message_Header struct {
	Key   string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
}

type Proto_Message_Verdict int32

type Proto_Session struct {
	InstanceId    uint64 `protobuf:"varint,1,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
	Id            []byte `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	TimeStart     uint64 `protobuf:"varint,3,opt,name=timeStart,proto3" json:"timeStart,omitempty"`
	TimeEnd       uint64 `protobuf:"varint,4,opt,name=timeEnd,proto3" json:"timeEnd,omitempty"`
	SaslUsername  string `protobuf:"bytes,5,opt,name=saslUsername,proto3" json:"saslUsername,omitempty"`
	SaslSender    string `protobuf:"bytes,6,opt,name=saslSender,proto3" json:"saslSender,omitempty"`
	SaslMethod    string `protobuf:"bytes,7,opt,name=saslMethod,proto3" json:"saslMethod,omitempty"`
	CertIssuer    string `protobuf:"bytes,8,opt,name=certIssuer,proto3" json:"certIssuer,omitempty"`
	CertSubject   string `protobuf:"bytes,9,opt,name=certSubject,proto3" json:"certSubject,omitempty"`
	CipherBits    uint32 `protobuf:"varint,10,opt,name=cipherBits,proto3" json:"cipherBits,omitempty"`
	Cipher        string `protobuf:"bytes,11,opt,name=cipher,proto3" json:"cipher,omitempty"`
	TlsVersion    string `protobuf:"bytes,12,opt,name=tlsVersion,proto3" json:"tlsVersion,omitempty"`
	Ip            string `protobuf:"bytes,13,opt,name=ip,proto3" json:"ip,omitempty"`
	ReverseDns    string `protobuf:"bytes,14,opt,name=reverseDns,proto3" json:"reverseDns,omitempty"`
	Hostname      string `protobuf:"bytes,15,opt,name=hostname,proto3" json:"hostname,omitempty"`
	Helo          string `protobuf:"bytes,16,opt,name=helo,proto3" json:"helo,omitempty"`
	MtaHostName   string `protobuf:"bytes,17,opt,name=mtaHostName,proto3" json:"mtaHostName,omitempty"`
	MtaDaemonName string `protobuf:"bytes,18,opt,name=mtaDaemonName,proto3" json:"mtaDaemonName,omitempty"`
}

type RedisClient interface {
	RedisClientBase

	PSubscribe(patterns ...string) (*redis.PubSub, error)
	Publish(channel, message string) *redis.IntCmd
}

type RedisClientBase interface {
	Del(keys ...string) *redis.IntCmd
	Exists(key string) *redis.BoolCmd
	Expire(key string, expiration time.Duration) *redis.BoolCmd
	Get(key string) *redis.StringCmd
	HSet(key, field, value string) *redis.BoolCmd
	HGetAllMap(key string) *redis.StringStringMapCmd
	LPush(key string, values ...string) *redis.IntCmd
	LPushX(key, value interface{}) *redis.IntCmd
	LRange(key string, start, stop int64) *redis.StringSliceCmd
	LSet(key string, index int64, value interface{}) *redis.StatusCmd
	Ping() *redis.StatusCmd
	RPop(key string) *redis.StringCmd
	SAdd(key string, members ...string) *redis.IntCmd
	SMembers(key string) *redis.StringSliceCmd
	Set(key string, value interface{}, expiration time.Duration) *redis.StatusCmd
	SetNX(key string, value interface{}, expiration time.Duration) *redis.BoolCmd
	ZAdd(key string, members ...redis.Z) *redis.IntCmd
	ZCount(key, min, max string) *redis.IntCmd
	ZRemRangeByScore(key, min, max string) *redis.IntCmd

	Eval(string, []string, []string) *redis.Cmd
	EvalSha(sha1 string, keys []string, args []string) *redis.Cmd
	ScriptExists(scripts ...string) *redis.BoolSliceCmd
	ScriptLoad(script string) *redis.StringCmd
}

type RedisClientMulti interface {
	RedisClientBase
	Exec(f func() error) ([]redis.Cmder, error)
}

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

type Rpc struct {
	// For all intents and purposes this field should be
	// considered required. But we may change that in a
	// far away feature, and we like to be forward
	// compatible with our proto buffers.
	Name                   string                       `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Bayes_Learn_Message    *Rpc__Bayes_Learn_Message    `protobuf:"bytes,1024,opt,name=Bayes_Learn_Message,json=bayesLearnMessage" json:"Bayes_Learn_Message,omitempty"`
	Bayes_Learn_Message_Id *Rpc__Bayes_Learn_Message_Id `protobuf:"bytes,1025,opt,name=Bayes_Learn_Message_Id,json=bayesLearnMessageId" json:"Bayes_Learn_Message_Id,omitempty"`
}

type Rpc__Bayes_Learn_Message struct {
	IsSpam   bool           `protobuf:"varint,1,opt,name=is_spam,json=isSpam,proto3" json:"is_spam,omitempty"`
	Message  *Proto_Message `protobuf:"bytes,2,opt,name=message" json:"message,omitempty"`
	Host     string         `protobuf:"bytes,17,opt,name=host,proto3" json:"host,omitempty"`
	Reporter string         `protobuf:"bytes,18,opt,name=reporter,proto3" json:"reporter,omitempty"`
	Reason   string         `protobuf:"bytes,19,opt,name=reason,proto3" json:"reason,omitempty"`
}

type Rpc__Bayes_Learn_Message_Id struct {
	IsSpam    bool   `protobuf:"varint,1,opt,name=is_spam,json=isSpam,proto3" json:"is_spam,omitempty"`
	MessageId string `protobuf:"bytes,2,opt,name=message_id,json=messageId,proto3" json:"message_id,omitempty"`
	Host      string `protobuf:"bytes,17,opt,name=host,proto3" json:"host,omitempty"`
	Reporter  string `protobuf:"bytes,18,opt,name=reporter,proto3" json:"reporter,omitempty"`
	Reason    string `protobuf:"bytes,19,opt,name=reason,proto3" json:"reason,omitempty"`
}

type SessionConfig struct {
	ClueGetter struct {
		Message_Reject_Score      float64
		Message_Tempfail_Score    float64
		Message_Spamflag_Score    float64
		Breaker_Score             float64
		Insert_Missing_Message_Id bool
	}
	Clamav struct {
		Enabled       bool
		Default_Score float64
		Max_Size      int
	}
	Contacts struct {
		Enabled                 bool
		Whitelist_Address_Score float64
		Whitelist_Domain_Score  float64
		Blacklist_Address_Score float64
		Blacklist_Domain_Score  float64
	}
	Greylisting struct {
		Enabled        bool
		Initial_Score  float64
		Initial_Period uint16
		Whitelist_Spf  []string
	}
	Quotas struct {
		Enabled bool
	}
	Rspamd struct {
		Enabled    bool
		Multiplier float64
	}
	SpamAssassin struct {
		Enabled         bool
		Timeout         float64
		Connect_Timeout float64
		Max_Size        int
	}
}

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