Compare commits
No commits in common. "ba484557b83a03ed72d4a48002f4e7f6a057e5ae" and "2ee81c19c8f1f4ea1816416cf45ac01297c3160d" have entirely different histories.
ba484557b8
...
2ee81c19c8
1
.gitignore
vendored
1
.gitignore
vendored
@ -1,2 +1 @@
|
||||
sco
|
||||
.DS_Store
|
||||
|
7
Makefile
7
Makefile
@ -29,7 +29,6 @@ default: fmt
|
||||
|
||||
fmt:
|
||||
go fmt ./...
|
||||
goimports -l -w .
|
||||
|
||||
docker-build:
|
||||
docker build -t $(IMAGENAME) .
|
||||
@ -42,9 +41,5 @@ build: ./$(FN)
|
||||
go-get:
|
||||
cd cmd/$(FN) && go get -v
|
||||
|
||||
vet:
|
||||
go vet ./...
|
||||
bash -c 'test -z "$$(gofmt -l .)"'
|
||||
|
||||
./$(FN): */*.go cmd/*/*.go go-get vet
|
||||
./$(FN): */*.go cmd/*/*.go go-get
|
||||
cd cmd/$(FN) && go build -o ../../$(FN) $(GOFLAGS) .
|
||||
|
17
bot/bot.go
17
bot/bot.go
@ -1,17 +1,16 @@
|
||||
package bot
|
||||
|
||||
//import "github.com/kr/pretty"
|
||||
import "github.com/kr/pretty"
|
||||
import (
|
||||
"fmt"
|
||||
"github.com/mattermost/mattermost-server/v5/model"
|
||||
"github.com/rs/zerolog/log"
|
||||
"os"
|
||||
"os/signal"
|
||||
"regexp"
|
||||
"strings"
|
||||
"syscall"
|
||||
"time"
|
||||
|
||||
"github.com/mattermost/mattermost-server/v5/model"
|
||||
"github.com/rs/zerolog/log"
|
||||
)
|
||||
|
||||
type Bot struct {
|
||||
@ -52,7 +51,7 @@ func (b *Bot) identify() {
|
||||
Msg("starting")
|
||||
}
|
||||
|
||||
func (b *Bot) Main() {
|
||||
func (b *Bot) Main() int {
|
||||
println(b.BotName)
|
||||
|
||||
b.StartupUnixTime = time.Now().Unix()
|
||||
@ -107,6 +106,7 @@ func (b *Bot) Main() {
|
||||
|
||||
// You can block forever with
|
||||
select {}
|
||||
return 0
|
||||
}
|
||||
|
||||
func (b *Bot) MakeSureServerIsRunning() {
|
||||
@ -285,10 +285,9 @@ func (b *Bot) HandleMsgFromDebuggingChannel(event *model.WebSocketEvent) {
|
||||
return
|
||||
}
|
||||
|
||||
if post.Message == "" {
|
||||
// null message, we can probably ignore it.
|
||||
return
|
||||
}
|
||||
// FIXME check and see if the message from mm is a bot message, if so,
|
||||
// ignore it
|
||||
pretty.Print(post)
|
||||
|
||||
if matched, _ := regexp.MatchString(`(?:^|\W)shutdown(?:$|\W)`, post.Message); matched {
|
||||
b.Shutdown()
|
||||
|
@ -1,12 +1,11 @@
|
||||
package bot
|
||||
|
||||
import (
|
||||
"os"
|
||||
"time"
|
||||
|
||||
"github.com/mattn/go-isatty"
|
||||
"github.com/rs/zerolog"
|
||||
"github.com/rs/zerolog/log"
|
||||
"os"
|
||||
"time"
|
||||
)
|
||||
|
||||
func (b *Bot) setupLogging() {
|
||||
|
90
bot/metar.go
90
bot/metar.go
@ -2,92 +2,15 @@ package bot
|
||||
|
||||
//import "github.com/kr/pretty"
|
||||
import (
|
||||
"encoding/json"
|
||||
"fmt"
|
||||
"github.com/rs/zerolog/log"
|
||||
"io/ioutil"
|
||||
"net/http"
|
||||
"os"
|
||||
"regexp"
|
||||
"time"
|
||||
|
||||
"github.com/rs/zerolog/log"
|
||||
)
|
||||
|
||||
type MetarResponse struct {
|
||||
Meta struct {
|
||||
Timestamp time.Time `json:"timestamp"`
|
||||
StationsUpdated string `json:"stations_updated"`
|
||||
} `json:"meta"`
|
||||
Altimeter struct {
|
||||
Repr string `json:"repr"`
|
||||
Value float64 `json:"value"`
|
||||
Spoken string `json:"spoken"`
|
||||
} `json:"altimeter"`
|
||||
Clouds []interface{} `json:"clouds"`
|
||||
FlightRules string `json:"flight_rules"`
|
||||
Other []interface{} `json:"other"`
|
||||
Sanitized string `json:"sanitized"`
|
||||
Visibility struct {
|
||||
Repr string `json:"repr"`
|
||||
Value int `json:"value"`
|
||||
Spoken string `json:"spoken"`
|
||||
} `json:"visibility"`
|
||||
WindDirection struct {
|
||||
Repr string `json:"repr"`
|
||||
Value int `json:"value"`
|
||||
Spoken string `json:"spoken"`
|
||||
} `json:"wind_direction"`
|
||||
WindGust struct {
|
||||
Repr string `json:"repr"`
|
||||
Value int `json:"value"`
|
||||
Spoken string `json:"spoken"`
|
||||
} `json:"wind_gust"`
|
||||
WindSpeed struct {
|
||||
Repr string `json:"repr"`
|
||||
Value int `json:"value"`
|
||||
Spoken string `json:"spoken"`
|
||||
} `json:"wind_speed"`
|
||||
WxCodes []interface{} `json:"wx_codes"`
|
||||
Raw string `json:"raw"`
|
||||
Station string `json:"station"`
|
||||
Time struct {
|
||||
Repr string `json:"repr"`
|
||||
Dt time.Time `json:"dt"`
|
||||
} `json:"time"`
|
||||
Remarks string `json:"remarks"`
|
||||
Dewpoint struct {
|
||||
Repr string `json:"repr"`
|
||||
Value int `json:"value"`
|
||||
Spoken string `json:"spoken"`
|
||||
} `json:"dewpoint"`
|
||||
RemarksInfo struct {
|
||||
DewpointDecimal struct {
|
||||
Repr string `json:"repr"`
|
||||
Value float64 `json:"value"`
|
||||
Spoken string `json:"spoken"`
|
||||
} `json:"dewpoint_decimal"`
|
||||
TemperatureDecimal struct {
|
||||
Repr string `json:"repr"`
|
||||
Value float64 `json:"value"`
|
||||
Spoken string `json:"spoken"`
|
||||
} `json:"temperature_decimal"`
|
||||
} `json:"remarks_info"`
|
||||
RunwayVisibility []interface{} `json:"runway_visibility"`
|
||||
Temperature struct {
|
||||
Repr string `json:"repr"`
|
||||
Value int `json:"value"`
|
||||
Spoken string `json:"spoken"`
|
||||
} `json:"temperature"`
|
||||
WindVariableDirection []interface{} `json:"wind_variable_direction"`
|
||||
Units struct {
|
||||
Altimeter string `json:"altimeter"`
|
||||
Altitude string `json:"altitude"`
|
||||
Temperature string `json:"temperature"`
|
||||
Visibility string `json:"visibility"`
|
||||
WindSpeed string `json:"wind_speed"`
|
||||
} `json:"units"`
|
||||
}
|
||||
|
||||
func (b *Bot) HandleWeatherRequest(channelid string, postid string, message string) {
|
||||
|
||||
// we are using a very bare image with no CA cert bundle
|
||||
@ -129,16 +52,7 @@ func (b *Bot) HandleWeatherRequest(channelid string, postid string, message stri
|
||||
|
||||
data, _ := ioutil.ReadAll(resp.Body)
|
||||
|
||||
var parsedMetarResponse MetarResponse
|
||||
|
||||
log.Info().Msgf("weather %s: %s", loc, data)
|
||||
b.SendMsgToChannel(fmt.Sprintf("weather %s: %s", loc, data), postid, channelid)
|
||||
|
||||
err = nil
|
||||
err = json.Unmarshal([]byte(data), &parsedMetarResponse)
|
||||
|
||||
if err != nil {
|
||||
b.SendMsgToChannel("error deserializing metar data", postid, channelid)
|
||||
return
|
||||
}
|
||||
b.SendMsgToChannel(fmt.Sprintf("weather for `%s`: \n```\n%+v\n```\n", loc, parsedMetarResponse), postid, channelid)
|
||||
}
|
||||
|
@ -1,14 +1,10 @@
|
||||
package main
|
||||
|
||||
import (
|
||||
"os"
|
||||
|
||||
"git.eeqj.de/sneak/sco/bot"
|
||||
)
|
||||
import "os"
|
||||
import "git.eeqj.de/sneak/sco/bot"
|
||||
|
||||
var Version string
|
||||
var Commit string
|
||||
|
||||
var Buildarch string
|
||||
|
||||
func main() {
|
||||
@ -27,5 +23,5 @@ func main() {
|
||||
b.AccountFirstname = "LSV"
|
||||
b.AccountLastname = "Serious Callers Only"
|
||||
})
|
||||
mybot.Main()
|
||||
os.Exit(mybot.Main())
|
||||
}
|
||||
|
Loading…
Reference in New Issue
Block a user