Read XSD path from configuration

enduro.toml

@@ -232,6 +232,10 @@ namespace = "default"
 taskQueue = "preprocessing"
 workflowName = "preprocessing"
 
+[validatePremis]
+enabled = true
+xsdPath = "/home/enduro/premis.xsd"
+
 [failedSips]
 endpoint = "http://minio.enduro-sdps:9000"
 pathStyle = true

hack/kube/base/enduro.yaml

@@ -70,6 +70,8 @@ spec:
               value: "grafana-agent.enduro-sdps:4317"
             - name: ENDURO_TELEMETRY_TRACES_SAMPLING_RATIO
               value: "1.0"
+            - name: ENDURO_VALIDATEPREMIS_ENABLED
+              value: "false"
           ports:
             - containerPort: 9000
             - containerPort: 9002

internal/config/config.go

@@ -22,6 +22,7 @@ import (
 	"github.com/artefactual-sdps/enduro/internal/db"
 	"github.com/artefactual-sdps/enduro/internal/event"
 	"github.com/artefactual-sdps/enduro/internal/package_"
+	"github.com/artefactual-sdps/enduro/internal/premis"
 	"github.com/artefactual-sdps/enduro/internal/preprocessing"
 	"github.com/artefactual-sdps/enduro/internal/pres"
 	"github.com/artefactual-sdps/enduro/internal/storage"
@@ -54,6 +55,7 @@ type Configuration struct {
 	Upload          package_.UploadConfig
 	Watcher         watcher.Config
 	Telemetry       telemetry.Config
+	ValidatePREMIS  premis.Config
 
 	FailedSIPs bucket.Config
 	FailedPIPs bucket.Config
@@ -67,6 +69,7 @@ func (c *Configuration) Validate() error {
 		c.BagIt.Validate(),
 		c.Preprocessing.Validate(),
 		c.Upload.Validate(),
+		c.ValidatePREMIS.Validate(),
 	)
 }
 

internal/premis/config.go

@@ -0,0 +1,26 @@
+package premis
+
+import (
+	"errors"
+	"fmt"
+	"os"
+)
+
+type Config struct {
+	Enabled bool
+	XSDPath string
+}
+
+// Validate implements config.ConfigurationValidator.
+func (c Config) Validate() error {
+	if !c.Enabled {
+		return nil
+	}
+	if c.XSDPath == "" {
+		return errors.New("xsdPath is required in the [validatePremis] configuration when enabled")
+	}
+	if _, err := os.Stat(c.XSDPath); err != nil {
+		return fmt.Errorf("xsdPath in [validatePremis] not found: %v", err)
+	}
+	return nil
+}

internal/workflow/processing.go

@@ -444,7 +444,7 @@ func (w *ProcessingWorkflow) SessionHandler(
 	activityOpts := withActivityOptsForRequest(sessCtx)
 	err := temporalsdk_workflow.ExecuteActivity(activityOpts, xmlvalidate.Name, xmlvalidate.Params{
 		XMLPath: filepath.Join(tinfo.TempPath, "data", "metadata", "premis.xml"),
-		XSDPath: "/home/enduro/premis.xsd",
+		XSDPath: w.cfg.ValidatePREMIS.XSDPath,
 	}).Get(activityOpts, nil)
 	if err != nil {
 		return err