Compare commits
No commits in common. "316893c469bc307dc154998dc83e31d7351379f6" and "2215d331e44bac55b814e3df05c009b92aebe2f8" have entirely different histories.
316893c469
...
2215d331e4
12
README.md
12
README.md
|
@ -1,2 +1,12 @@
|
||||||
# flokatimx
|
## flokatilib
|
||||||
|
|
||||||
|
*Modules and utilities for the incredibly friendly, silver-tongued, and elegantly proportioned community bot*
|
||||||
|
|
||||||
|
#### LICENSE
|
||||||
|
|
||||||
|
See `LICENSE` file.
|
||||||
|
|
||||||
|
#### QUICK INSTALL
|
||||||
|
|
||||||
|
`# make build`
|
||||||
|
|
||||||
|
|
137
irc.go
137
irc.go
|
@ -1,137 +0,0 @@
|
||||||
// vi:ts=4:sts=4:sw=4:noet:tw=72
|
|
||||||
//
|
|
||||||
// flokatirc
|
|
||||||
//
|
|
||||||
// Copyright (c) 2015,2016 Andreas Neue <an@dnix.de>
|
|
||||||
|
|
||||||
package main
|
|
||||||
|
|
||||||
import (
|
|
||||||
"crypto/tls"
|
|
||||||
"flag"
|
|
||||||
"fmt"
|
|
||||||
"strings"
|
|
||||||
"time"
|
|
||||||
|
|
||||||
"git.dnix.de/an/flokatilib/modules"
|
|
||||||
"git.dnix.de/an/xlog"
|
|
||||||
|
|
||||||
irc "github.com/fluffle/goirc/client"
|
|
||||||
)
|
|
||||||
|
|
||||||
var (
|
|
||||||
usetls = flag.Bool("tls", true, "Use TLS")
|
|
||||||
port = flag.String("port", "6697", "Server port")
|
|
||||||
nsname = flag.String("nsname", "NickServ", "NickServ name")
|
|
||||||
nspass = flag.String("nspass", "", "NickServ password")
|
|
||||||
automsgTo = flag.String("automsg_to", "", "Autosend IRC msg recipient")
|
|
||||||
automsgText = flag.String("automsg_text", "", "Autosend IRC msg text")
|
|
||||||
)
|
|
||||||
|
|
||||||
func Irc(say chan string) {
|
|
||||||
//bot := ircx.Classic(*server, *name)
|
|
||||||
cfg := irc.NewConfig(*name)
|
|
||||||
cfg.SSL = *usetls
|
|
||||||
cfg.SSLConfig = &tls.Config{ServerName: *server}
|
|
||||||
cfg.Server = *server + ":" + *port
|
|
||||||
cfg.NewNick = func(n string) string { return n + "^" }
|
|
||||||
cfg.Me.Ident = *name
|
|
||||||
cfg.Me.Name = *name
|
|
||||||
bot := irc.Client(cfg)
|
|
||||||
SetupHandlers(bot, say)
|
|
||||||
|
|
||||||
go CheckConnection(bot)
|
|
||||||
go Ping(bot)
|
|
||||||
|
|
||||||
modules.Init(say, *mods)
|
|
||||||
modules.BotNick = strings.ToLower(*name)
|
|
||||||
|
|
||||||
for {
|
|
||||||
var targets string
|
|
||||||
for {
|
|
||||||
if bot.Connected() {
|
|
||||||
break
|
|
||||||
}
|
|
||||||
time.Sleep(1 * time.Second)
|
|
||||||
}
|
|
||||||
line := strings.Split(<-say, "\n")
|
|
||||||
xlog.Debug("Say: \"%s\"", line)
|
|
||||||
if len(line) < 2 {
|
|
||||||
continue
|
|
||||||
}
|
|
||||||
if line[0] != "*" {
|
|
||||||
targets = line[0]
|
|
||||||
} else {
|
|
||||||
targets = *channels
|
|
||||||
}
|
|
||||||
for _, tar := range strings.Split(targets, ",") {
|
|
||||||
bot.Privmsg(tar, line[1])
|
|
||||||
time.Sleep(1 * time.Second)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
time.Sleep(1 * time.Millisecond)
|
|
||||||
}
|
|
||||||
|
|
||||||
func SetupHandlers(bot *irc.Conn, say chan string) {
|
|
||||||
xlog.Info("Registering handlers")
|
|
||||||
bot.HandleFunc("001", func(c *irc.Conn, l *irc.Line) {
|
|
||||||
go func(c *irc.Conn, l *irc.Line) {
|
|
||||||
if *nspass != "" {
|
|
||||||
xlog.Info("Authenticating with NickServ: %v, %v", *name, "xxxxxx")
|
|
||||||
bot.Privmsg(*nsname, "IDENTIFY "+*name+" "+*nspass)
|
|
||||||
}
|
|
||||||
if *automsgTo != "" && *automsgText != "" {
|
|
||||||
xlog.Info("Sending automsg ...")
|
|
||||||
bot.Privmsg(*automsgTo, *automsgText)
|
|
||||||
}
|
|
||||||
xlog.Info("Joining channels: %v", *channels)
|
|
||||||
for _, ch := range strings.Split(*channels, ",") {
|
|
||||||
bot.Join(ch)
|
|
||||||
}
|
|
||||||
time.Sleep(2 * time.Second)
|
|
||||||
msg := fmt.Sprintf("running on %s", SoftwareInfo())
|
|
||||||
say <- fmt.Sprintf("%s\n\001ACTION %s\001", "*", msg)
|
|
||||||
}(c, l)
|
|
||||||
})
|
|
||||||
bot.HandleFunc("PRIVMSG", func(c *irc.Conn, l *irc.Line) {
|
|
||||||
go func(c *irc.Conn, l *irc.Line) {
|
|
||||||
//TODO: implement message handler table
|
|
||||||
HandleMessage(l)
|
|
||||||
modules.HandleMessage(&modules.Message{From: l.Nick, Channel: l.Args[0], Text: l.Text()})
|
|
||||||
}(c, l)
|
|
||||||
})
|
|
||||||
}
|
|
||||||
|
|
||||||
func CheckConnection(bot *irc.Conn) {
|
|
||||||
for {
|
|
||||||
if !bot.Connected() {
|
|
||||||
xlog.Info("Not connected, connecting ...")
|
|
||||||
if err := bot.Connect(); err != nil {
|
|
||||||
xlog.Error("Unable to dial IRC Server: %v", err)
|
|
||||||
}
|
|
||||||
time.Sleep(10 * time.Second)
|
|
||||||
}
|
|
||||||
time.Sleep(1 * time.Millisecond)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
func HandleMessage(l *irc.Line) {
|
|
||||||
tok := strings.Split(l.Text(), " ")
|
|
||||||
if len(tok) < 1 {
|
|
||||||
return
|
|
||||||
}
|
|
||||||
switch tok[0] {
|
|
||||||
case "!version":
|
|
||||||
//msg := ctcp.Action(fmt.Sprintf("running on %s", SoftwareInfo()))
|
|
||||||
//sayCh <- fmt.Sprintf("%s\n%s", "*", msg)
|
|
||||||
//sayCh <- fmt.Sprintf("%s\n%s", "*", SoftwareInfo())
|
|
||||||
default:
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
func Ping(bot *irc.Conn) {
|
|
||||||
for {
|
|
||||||
time.Sleep(1 * time.Minute)
|
|
||||||
bot.Raw("PING")
|
|
||||||
}
|
|
||||||
}
|
|
4
main.go
4
main.go
|
@ -37,8 +37,8 @@ func main() {
|
||||||
modules.Init(say, *mods)
|
modules.Init(say, *mods)
|
||||||
modules.BotNick = strings.ToLower(*nick)
|
modules.BotNick = strings.ToLower(*nick)
|
||||||
switch *protocol {
|
switch *protocol {
|
||||||
case "irc":
|
//case "irc":
|
||||||
Irc(say)
|
// Irc()
|
||||||
case "matrix":
|
case "matrix":
|
||||||
Matrix(say)
|
Matrix(say)
|
||||||
default:
|
default:
|
||||||
|
|
Loading…
Reference in New Issue