neno oclib

main.go

@@ -1,6 +1,7 @@
 package main
 
 import (
+	"fmt"
 	"oc-catalog/infrastructure"
 	_ "oc-catalog/routers"
 
@@ -15,9 +16,19 @@ const appname = "oc-catalog"
 func main() {
 	// Init the oc-lib — les routes WebSocket décentralisées sont déclarées ici
 	// car beego.Handler n'alimente pas GlobalControllerRouter.
+	o := oclib.GetConfLoader(appname)
 	oclib.InitAPI(appname, map[string][]string{
 		"/oc/decentralized/:type/:datatype/search/:search": {"GET"},
 	})
+
+	// Table privée opaque_key → real_path, partagée en lecture avec oc-datacenter
+	// via le volume Docker /data.  oc-catalog est le seul writer.
+	sourceKeyPath := o.GetStringDefault("SOURCE_KEY_STORE_PATH", "/data/source-keys.json")
+	if err := infrastructure.InitSourceKeyStore(sourceKeyPath); err != nil {
+		fmt.Println("FATAL: cannot initialize source key store:", err)
+		return
+	}
+
 	go oclib.InitNATSDecentralizedEmitter(tools.COMPUTE_RESOURCE, tools.DATA_RESOURCE,
 		tools.PROCESSING_RESOURCE, tools.STORAGE_RESOURCE, tools.WORKFLOW_RESOURCE)
 	go infrastructure.ListenNATS()