2b4b2c513c
* new: add email connection shell * new: add secure & insecure smtp * new: read email * new: more email logic * feat: automatically reply * feat: poc email response * feat: introduce email concurrency and reply functionality * feat: html replies * refactor: make email.go legible * feat: add email connection docs * fix: startup error handling and dial error
131 lines
3.0 KiB
Go
131 lines
3.0 KiB
Go
package services
|
|
|
|
import (
|
|
"encoding/json"
|
|
|
|
"github.com/mudler/LocalAGI/pkg/config"
|
|
"github.com/mudler/LocalAGI/pkg/xlog"
|
|
"github.com/mudler/LocalAGI/services/connectors"
|
|
|
|
"github.com/mudler/LocalAGI/core/state"
|
|
)
|
|
|
|
const (
|
|
// Connectors
|
|
ConnectorIRC = "irc"
|
|
ConnectorTelegram = "telegram"
|
|
ConnectorSlack = "slack"
|
|
ConnectorDiscord = "discord"
|
|
ConnectorGithubIssues = "github-issues"
|
|
ConnectorGithubPRs = "github-prs"
|
|
ConnectorTwitter = "twitter"
|
|
ConnectorMatrix = "matrix"
|
|
ConnectorEmail = "email"
|
|
)
|
|
|
|
var AvailableConnectors = []string{
|
|
ConnectorIRC,
|
|
ConnectorTelegram,
|
|
ConnectorSlack,
|
|
ConnectorDiscord,
|
|
ConnectorGithubIssues,
|
|
ConnectorGithubPRs,
|
|
ConnectorTwitter,
|
|
ConnectorMatrix,
|
|
ConnectorEmail,
|
|
}
|
|
|
|
func Connectors(a *state.AgentConfig) []state.Connector {
|
|
conns := []state.Connector{}
|
|
|
|
for _, c := range a.Connector {
|
|
var config map[string]string
|
|
if err := json.Unmarshal([]byte(c.Config), &config); err != nil {
|
|
xlog.Info("Error unmarshalling connector config", err)
|
|
continue
|
|
}
|
|
switch c.Type {
|
|
case ConnectorTelegram:
|
|
cc, err := connectors.NewTelegramConnector(config)
|
|
if err != nil {
|
|
xlog.Info("Error creating telegram connector", err)
|
|
continue
|
|
}
|
|
|
|
conns = append(conns, cc)
|
|
case ConnectorSlack:
|
|
conns = append(conns, connectors.NewSlack(config))
|
|
case ConnectorDiscord:
|
|
conns = append(conns, connectors.NewDiscord(config))
|
|
case ConnectorGithubIssues:
|
|
conns = append(conns, connectors.NewGithubIssueWatcher(config))
|
|
case ConnectorGithubPRs:
|
|
conns = append(conns, connectors.NewGithubPRWatcher(config))
|
|
case ConnectorIRC:
|
|
conns = append(conns, connectors.NewIRC(config))
|
|
case ConnectorTwitter:
|
|
cc, err := connectors.NewTwitterConnector(config)
|
|
if err != nil {
|
|
xlog.Info("Error creating twitter connector", err)
|
|
continue
|
|
}
|
|
conns = append(conns, cc)
|
|
case ConnectorMatrix:
|
|
conns = append(conns, connectors.NewMatrix(config))
|
|
case ConnectorEmail:
|
|
conns = append(conns, connectors.NewEmail(config))
|
|
}
|
|
}
|
|
return conns
|
|
}
|
|
|
|
func ConnectorsConfigMeta() []config.FieldGroup {
|
|
return []config.FieldGroup{
|
|
{
|
|
Name: "discord",
|
|
Label: "Discord",
|
|
Fields: connectors.DiscordConfigMeta(),
|
|
},
|
|
{
|
|
Name: "slack",
|
|
Label: "Slack",
|
|
Fields: connectors.SlackConfigMeta(),
|
|
},
|
|
{
|
|
Name: "telegram",
|
|
Label: "Telegram",
|
|
Fields: connectors.TelegramConfigMeta(),
|
|
},
|
|
{
|
|
Name: "github-issues",
|
|
Label: "GitHub Issues",
|
|
Fields: connectors.GithubIssueConfigMeta(),
|
|
},
|
|
{
|
|
Name: "github-prs",
|
|
Label: "GitHub PRs",
|
|
Fields: connectors.GithubPRConfigMeta(),
|
|
},
|
|
{
|
|
Name: "irc",
|
|
Label: "IRC",
|
|
Fields: connectors.IRCConfigMeta(),
|
|
},
|
|
{
|
|
Name: "twitter",
|
|
Label: "Twitter",
|
|
Fields: connectors.TwitterConfigMeta(),
|
|
},
|
|
{
|
|
Name: "matrix",
|
|
Label: "Matrix",
|
|
Fields: connectors.MatrixConfigMeta(),
|
|
},
|
|
{
|
|
Name: "email",
|
|
Label: "Email",
|
|
Fields: connectors.EmailConfigMeta(),
|
|
},
|
|
}
|
|
}
|