Add a regular ping job

client/client.go

@@ -67,7 +67,7 @@ func StartClient(config *config.ClientConfig, userAgent string) {
 	}
 
 	// Set up scheduled tasks
-	tasks := configureTasks(config, certStorage)
+	tasks := configureTasks(client, config, certStorage)
 
 	// Handle termination
 	configureTermination(tasks)
@@ -114,12 +114,13 @@ func validateConfig(c *config.ClientConfig) error {
 	return nil
 }
 
-func configureTasks(config *config.ClientConfig, storage *CertStorage) []Job {
+func configureTasks(client api.CertificateIssuerClient, config *config.ClientConfig, storage *CertStorage) []Job {
 	var tasks []Job
 
+	pinger := *Register(pingServer(client), "Ping intercert host", 10*time.Minute, false)
 	desiredCheck := *Register(ensureCertsFromConfig(storage, config.Domains), "Ensure configured domains is present", 1*time.Hour, true)
 
-	tasks = append(tasks, desiredCheck)
+	tasks = append(tasks, pinger, desiredCheck)
 
 	return tasks
 }

client/tasks.go

@@ -1,9 +1,21 @@
 package client
 
 import (
+	"context"
+	"github.com/evenh/intercert/api"
 	"github.com/go-acme/lego/log"
 )
 
+func pingServer(client api.CertificateIssuerClient) func() {
+	return func() {
+		_, err := client.Ping(context.Background(), &api.PingRequest{Msg: "ping"})
+
+		if err != nil {
+			log.Warnf("Could not ping intercert host: %v", err)
+		}
+	}
+}
+
 // Check that every cert from the config is present in the file system
 func ensureCertsFromConfig(storage *CertStorage, wantedDomains []string) func() {
 	return func() {