[minor] define jobs using sitectls' new jobs SDK

Author: joecorall

Makefile

@@ -6,7 +6,7 @@ INSTALL_DIR ?= $(or $(dir $(shell which $(BINARY_NAME) 2>/dev/null)),/usr/local/
 deps: work
 	go mod tidy
 
-build: deps
+build:
 	go build -o $(BINARY_NAME) .
 
 install: work build

cmd/backup.go

@@ -0,0 +1,85 @@
+package cmd
+
+import (
+	"fmt"
+	"os/exec"
+	"path/filepath"
+	"strings"
+
+	corecron "github.com/libops/sitectl/pkg/cron"
+	"github.com/spf13/cobra"
+	yaml "gopkg.in/yaml.v3"
+)
+
+var backupRunComponent string
+var backupRunOutput string
+
+var cronExtensionCmd = &cobra.Command{
+	Use:    "__cron",
+	Hidden: true,
+}
+
+var cronExtensionComponentsCmd = &cobra.Command{
+	Use:    "components",
+	Hidden: true,
+	RunE: func(cmd *cobra.Command, args []string) error {
+		specs := []corecron.ComponentSpec{
+			{
+				Name:        "drupal-db-backup",
+				Plugin:      "drupal",
+				Description: "Drupal SQL dump compressed as gzip",
+				Filename:    "drupal.sql.gz",
+			},
+		}
+		data, err := yaml.Marshal(specs)
+		if err != nil {
+			return err
+		}
+		_, err = cmd.OutOrStdout().Write(data)
+		return err
+	},
+}
+
+var cronExtensionRunCmd = &cobra.Command{
+	Use:    "run",
+	Hidden: true,
+	RunE: func(cmd *cobra.Command, args []string) error {
+		if strings.TrimSpace(backupRunComponent) != "drupal-db-backup" {
+			return fmt.Errorf("unknown cron component %q", backupRunComponent)
+		}
+		if strings.TrimSpace(backupRunOutput) == "" {
+			return fmt.Errorf("--output is required")
+		}
+
+		ctx, _, containerName, err := getDrupalContainerFromFlags(cmd)
+		if err != nil {
+			return err
+		}
+
+		if _, err := ctx.RunCommandContext(cmd.Context(), exec.Command("bash", "-lc", buildDrupalComponentBackupScript(containerName, backupRunOutput))); err != nil {
+			return err
+		}
+		fmt.Fprintf(cmd.OutOrStdout(), "Wrote %s\n", filepath.Base(backupRunOutput))
+		return nil
+	},
+}
+
+func buildDrupalComponentBackupScript(containerName, outputPath string) string {
+	return strings.Join([]string{
+		"set -euo pipefail",
+		"mkdir -p " + shellQuote(filepath.Dir(outputPath)),
+		fmt.Sprintf("docker exec %s drush sql-dump -y --skip-tables-list=cache,cache_*,watchdog --structure-tables-list=cache,cache_*,watchdog --debug | gzip -c > %s", shellQuote(containerName), shellQuote(outputPath)),
+	}, "\n")
+}
+
+func shellQuote(value string) string {
+	return "'" + strings.ReplaceAll(value, "'", `'\''`) + "'"
+}
+
+func init() {
+	cronExtensionRunCmd.Flags().StringVar(&backupRunComponent, "component", "", "Cron component name")
+	cronExtensionRunCmd.Flags().StringVar(&backupRunOutput, "output", "", "Absolute output path on the target host")
+
+	cronExtensionCmd.AddCommand(cronExtensionComponentsCmd)
+	cronExtensionCmd.AddCommand(cronExtensionRunCmd)
+}

cmd/backup_extension.go

@@ -1,6 +1,7 @@
 package cmd
 
 import (
+	pluginjobs "github.com/libops/sitectl-drupal/pkg/jobs"
 	"github.com/libops/sitectl/pkg/plugin"
 )
 
@@ -11,16 +12,17 @@ var (
 
 func init() {
 	loginCmd.Flags().Uint("uid", 1, "Drupal user ID to provide a direct login link for")
-
-	backupCmd.Flags().StringVarP(drupalServiceName, "drupal-service", "d", "drupal", "The name of the drupal service in docker compose")
 }
 
 // RegisterCommands registers all drupal commands with the plugin SDK
 func RegisterCommands(s *plugin.SDK) {
 	sdk = s
-	sdk.AddCommand(backupCmd)
+	pluginjobs.Register(s)
+	sdk.AddCommand(sdk.GetMetadataCommand())
+	sdk.AddCommand(cronExtensionCmd)
 	sdk.AddCommand(componentExtensionCmd)
 	sdk.AddCommand(debugExtensionCmd)
 	sdk.AddCommand(drushCmd)
 	sdk.AddCommand(loginCmd)
+	sdk.AddCommand(syncCmd)
 }