From e51377eeb31b2a2d7a8b3e90279cbc1d72b706e0 Mon Sep 17 00:00:00 2001
From: mr <mr>
Date: Mon, 12 Aug 2024 16:28:02 +0200
Subject: [PATCH] implement remote call for remote action

---
 entrypoint.go | 57 ++++++++++++++++++++++++++++++++++++++-------------
 1 file changed, 43 insertions(+), 14 deletions(-)

diff --git a/entrypoint.go b/entrypoint.go
index e0f7c10..2ce7907 100644
--- a/entrypoint.go
+++ b/entrypoint.go
@@ -18,6 +18,7 @@ import (
 	"cloud.o-forge.io/core/oc-lib/models/workspace"
 	shared_workspace "cloud.o-forge.io/core/oc-lib/models/workspace/shared"
 	"cloud.o-forge.io/core/oc-lib/models/workspace/shared/rules/rule"
+	"cloud.o-forge.io/core/oc-lib/tools"
 	"github.com/rs/zerolog"
 )
 
@@ -96,59 +97,87 @@ func GetLogger() zerolog.Logger {
 	return logs.GetLogger()
 }
 
-func Search(filters *dbs.Filters, word string, collection LibDataEnum) LibDataShallow {
-	d, code, err := models.Model(collection.EnumIndex()).GetAccessor(nil).Search(filters, word)
+func Search(filters *dbs.Filters, word string, collection LibDataEnum, c ...*tools.HTTPCaller) LibDataShallow {
+	var caller *tools.HTTPCaller
+	if len(c) > 0 {
+		caller = c[0]
+	}
+	d, code, err := models.Model(collection.EnumIndex()).GetAccessor(caller).Search(filters, word)
 	if err != nil {
 		return LibDataShallow{Data: d, Code: code, Err: err.Error()}
 	}
 	return LibDataShallow{Data: d, Code: code}
 }
 
-func LoadAll(collection LibDataEnum) LibDataShallow {
-	d, code, err := models.Model(collection.EnumIndex()).GetAccessor(nil).LoadAll()
+func LoadAll(collection LibDataEnum, c ...*tools.HTTPCaller) LibDataShallow {
+	var caller *tools.HTTPCaller
+	if len(c) > 0 {
+		caller = c[0]
+	}
+	d, code, err := models.Model(collection.EnumIndex()).GetAccessor(caller).LoadAll()
 	if err != nil {
 		return LibDataShallow{Data: d, Code: code, Err: err.Error()}
 	}
 	return LibDataShallow{Data: d, Code: code}
 }
 
-func LoadOne(collection LibDataEnum, id string) LibData {
-	d, code, err := models.Model(collection.EnumIndex()).GetAccessor(nil).LoadOne(id)
+func LoadOne(collection LibDataEnum, id string, c ...*tools.HTTPCaller) LibData {
+	var caller *tools.HTTPCaller
+	if len(c) > 0 {
+		caller = c[0]
+	}
+	d, code, err := models.Model(collection.EnumIndex()).GetAccessor(caller).LoadOne(id)
 	if err != nil {
 		return LibData{Data: d, Code: code, Err: err.Error()}
 	}
 	return LibData{Data: d, Code: code}
 }
 
-func UpdateOne(collection LibDataEnum, set map[string]interface{}, id string) LibData {
+func UpdateOne(collection LibDataEnum, set map[string]interface{}, id string, c ...*tools.HTTPCaller) LibData {
+	var caller *tools.HTTPCaller
+	if len(c) > 0 {
+		caller = c[0]
+	}
 	model := models.Model(collection.EnumIndex())
-	d, code, err := model.GetAccessor(nil).UpdateOne(model.Deserialize(set), id)
+	d, code, err := model.GetAccessor(caller).UpdateOne(model.Deserialize(set), id)
 	if err != nil {
 		return LibData{Data: d, Code: code, Err: err.Error()}
 	}
 	return LibData{Data: d, Code: code}
 }
 
-func DeleteOne(collection LibDataEnum, id string) LibData {
-	d, code, err := models.Model(collection.EnumIndex()).GetAccessor(nil).DeleteOne(id)
+func DeleteOne(collection LibDataEnum, id string, c ...*tools.HTTPCaller) LibData {
+	var caller *tools.HTTPCaller
+	if len(c) > 0 {
+		caller = c[0]
+	}
+	d, code, err := models.Model(collection.EnumIndex()).GetAccessor(caller).DeleteOne(id)
 	if err != nil {
 		return LibData{Data: d, Code: code, Err: err.Error()}
 	}
 	return LibData{Data: d, Code: code}
 }
 
-func StoreOne(collection LibDataEnum, object map[string]interface{}) LibData {
+func StoreOne(collection LibDataEnum, object map[string]interface{}, c ...*tools.HTTPCaller) LibData {
+	var caller *tools.HTTPCaller
+	if len(c) > 0 {
+		caller = c[0]
+	}
 	model := models.Model(collection.EnumIndex())
-	d, code, err := model.GetAccessor(nil).StoreOne(model.Deserialize(object))
+	d, code, err := model.GetAccessor(caller).StoreOne(model.Deserialize(object))
 	if err != nil {
 		return LibData{Data: d, Code: code, Err: err.Error()}
 	}
 	return LibData{Data: d, Code: code}
 }
 
-func CopyOne(collection LibDataEnum, object map[string]interface{}) LibData {
+func CopyOne(collection LibDataEnum, object map[string]interface{}, c ...*tools.HTTPCaller) LibData {
+	var caller *tools.HTTPCaller
+	if len(c) > 0 {
+		caller = c[0]
+	}
 	model := models.Model(collection.EnumIndex())
-	d, code, err := model.GetAccessor(nil).CopyOne(model.Deserialize(object))
+	d, code, err := model.GetAccessor(caller).CopyOne(model.Deserialize(object))
 	if err != nil {
 		return LibData{Data: d, Code: code, Err: err.Error()}
 	}