googlegroups

type AffiliationClient interface {
	GetIdentityByUser(key string, value string) (*affiliation.AffIdentity, error)
	AddIdentity(identity *affiliation.Identity) bool
	GetOrganizations(uuid string, projectSlug string) *[]affiliation.Enrollment
}

type AuthClientProvider interface {
	GetToken(env string) (string, error)
}

type EnrichedMessage struct {
	From                 string    `json:"from"`
	Date                 time.Time `json:"date"`
	To                   []string  `json:"to"`
	MessageID            string    `json:"message_id"`
	InReplyTo            string    `json:"in_reply_to"`
	References           string    `json:"references"`
	Subject              string    `json:"subject"`
	Topic                string    `json:"topic"`
	MessageBody          string    `json:"message_body"`
	TopicID              string    `json:"topic_id"`
	BackendVersion       string    `json:"backend_version"`
	UUID                 string    `json:"uuid"`
	Origin               string    `json:"origin"`
	MetadataUpdatedOn    time.Time `json:"metadata__updated_on"`
	BackendName          string    `json:"backend_name"`
	MetadataTimestamp    time.Time `json:"metadata__timestamp"`
	MetadataEnrichedOn   time.Time `json:"metadata__enriched_on"`
	ProjectSlug          string    `json:"project_slug"`
	GroupName            string    `json:"group_name"`
	Project              string    `json:"project"`
	Root                 bool      `json:"root"`
	FromBot              bool      `json:"from_bot"`
	ChangedAt            time.Time `json:"changed_at"`
	AuthorName           string    `json:"author_name"`
	AuthorID             string    `json:"author_id"`
	AuthorUUID           string    `json:"author_uuid"`
	AuthorOrgName        string    `json:"author_org_name"`
	AuthorUserName       string    `json:"author_user_name"`
	AuthorBot            bool      `json:"author_bot"`
	AuthorMultiOrgNames  []string  `json:"author_multi_org_names"`
	MboxAuthorDomain     string    `json:"mbox_author_domain"`
	IsGoogleGroupMessage int       `json:"is_google_group_message"`
	Timezone             int       `json:"timezone"`
	ViaCommunityGroup    bool      `json:"via_community_group"`
}

type Enricher struct {
	DSName                string // Datasource will be used as key for ES
	ElasticSearchProvider *elastic.ClientProvider
	// contains filtered or unexported fields
}

type Fetcher struct {
	DSName                string
	HTTPClientProvider    *http.ClientProvider
	ElasticSearchProvider *elastic.ClientProvider
	BackendVersion        string
	DateFrom              time.Time
	GroupName             string
	ProjectSlug           string
	Project               string
}

type GoogleGroupMessage struct {
	ID      string `json:"id"`
	Author  string `json:"author"`
	Date    string `json:"date"`
	File    string `json:"file"`
	Message string `json:"message"`
}

type GoogleGroupMessageThread struct {
	Topic    string                `json:"topic"`
	ID       string                `json:"id"`
	Messages []*GoogleGroupMessage `json:"messages"`
}

type GoogleGroupMessages struct {
	Messages []*GoogleGroupMessageThread
}

type HeadersData struct {
	// Date is the date the message was originally sent
	Date string
	// MessageID is the message id
	MessageID string
	// InReplyTo is who the email was sent to. This can contain multiple
	// addresses if the email was forwarded.
	InReplyTo string
	// References
	References string
	// Sender is the entity that originally created and sent the message
	Sender string
	// From is the name - email address combo of the email author
	From string
	// Subject is the subject of the email
	Subject string
	// To is the email recipient.
	To []string
	// DeliveredTo is to whom the email was sent to. This can contain multiple
	// addresses if the email was forwarded.
	DeliveredTo []string
	MailingList string
}

type HitSource struct {
	ID        string    `json:"id"`
	ChangedAt time.Time `json:"changed_at"`
}

type Hits struct {
	Hits []NestedHits `json:"hits"`
}

type Manager struct {
	Slug                   string
	GroupName              string
	SHConnString           string
	FetcherBackendVersion  string
	EnricherBackendVersion string
	Fetch                  bool
	Enrich                 bool
	ESUrl                  string
	ESUsername             string
	ESPassword             string
	ESIndex                string
	FromDate               *time.Time
	HTTPTimeout            time.Duration
	Project                string
	FetchSize              int
	EnrichSize             int
	AffBaseURL             string
	ESCacheURL             string
	ESCacheUsername        string
	ESCachePassword        string
	AuthGrantType          string
	AuthClientID           string
	AuthClientSecret       string
	AuthAudience           string
	Auth0URL               string
	Environment            string
	WebHookURL             string
	// contains filtered or unexported fields
}

type NHits struct {
	Hits []NestedRawHits `json:"hits"`
}

type NestedHits struct {
	ID     string    `json:"_id"`
	Source HitSource `json:"_source"`
}

type NestedRawHits struct {
	ID     string     `json:"_id"`
	Source RawMessage `json:"_source"`
}

type RawHits struct {
	Hits NHits `json:"hits"`
}

type RawMessage struct {
	From              string    `json:"from"`
	Date              time.Time `json:"date"`
	To                []string  `json:"to"`
	MessageID         string    `json:"message_id"`
	InReplyTo         string    `json:"in_reply_to"`
	References        string    `json:"references"`
	Subject           string    `json:"subject"`
	MessageBody       string    `json:"message_body"`
	TopicID           string    `json:"topic_id"`
	Topic             string    `json:"topic"`
	BackendVersion    string    `json:"backend_version"`
	UUID              string    `json:"uuid"`
	Origin            string    `json:"origin"`
	MetadataUpdatedOn time.Time `json:"metadata__updated_on"`
	BackendName       string    `json:"backend_name"`
	MetadataTimestamp time.Time `json:"metadata__timestamp"`
	ProjectSlug       string    `json:"project_slug"`
	GroupName         string    `json:"group_name"`
	Project           string    `json:"project"`
	ChangedAt         time.Time `json:"changed_at"`
	Timezone          int       `json:"timezone"`
}

type TopHits struct {
	Hits Hits `json:"hits"`
}