Adding some configuration, flagging inputs as CertStream

This commit is contained in:
Christopher Talib 2020-01-15 16:46:13 +01:00
parent 1081e0c728
commit 1b25c25aa7

View file

@ -1,6 +1,8 @@
package main
import (
"fmt"
"github.com/CaliDog/certstream-go"
"github.com/op/go-logging"
"gitlab.dcso.lolcat/LABS/styx/models"
@ -8,17 +10,18 @@ import (
)
var (
log = logging.MustGetLogger("example")
log = logging.MustGetLogger("")
)
func main() {
// The false flag specifies that we want heartbeat messages.
stream, errStream := certstream.CertStreamEventStream(false)
fmt.Println("Starting to get data from CertStream...")
for {
select {
case jq := <-stream:
if data, err := utils.ExtractCertFromStream(jq); err == nil {
models.SaveData("test", *data)
models.SaveData("certStream", *data)
}
case err := <-errStream: