From 271d74b4ddd4af00bc12ea847937abd186c7f57e Mon Sep 17 00:00:00 2001 From: pb Date: Wed, 9 Jul 2025 12:07:54 +0200 Subject: [PATCH] return b.Data rather than the whole b object --- controllers/booking.go | 15 ++++++++++++++- 1 file changed, 14 insertions(+), 1 deletion(-) diff --git a/controllers/booking.go b/controllers/booking.go index a61824b..2154bc1 100644 --- a/controllers/booking.go +++ b/controllers/booking.go @@ -232,6 +232,8 @@ func (o *BookingController) Post() { * - datacenter_resource_id: the id of the datacenter * - workflow_execution: the workflow execution */ + logger := oclib.GetLogger() + logger.Info().Msg("Received a Booking") var resp booking.Booking user, peerID, groups := oclib.ExtractTokenInfo(*o.Ctx.Request) err := json.Unmarshal(o.Ctx.Input.CopyBody(10000000), &resp) @@ -244,6 +246,7 @@ func (o *BookingController) Post() { o.ServeJSON() return } + if resp.ResourceType == tools.COMPUTE_RESOURCE { // later should check... health for any such as docker... res := oclib.NewRequest(oclib.LibDataEnum(oclib.COMPUTE_RESOURCE), user, peerID, groups, nil).LoadOne(resp.ResourceID) @@ -311,12 +314,13 @@ func (o *BookingController) Post() { }() } + logger.Info().Msg("Creating new namespace : " + resp.ExecutionsID) if err := o.createNamespace(resp.ExecutionsID); err != nil { fmt.Println(err.Error()) } o.Data["json"] = map[string]interface{}{ - "data": []interface{}{b}, + "data": b.Data, "code": 200, "error": "", } @@ -443,6 +447,15 @@ func (o *BookingController) createNamespace(ns string) error { if err != nil { return nil } + + ok, err := serv.GetNamespace(o.Ctx.Request.Context(), ns) + if ok == nil && err == nil { + return nil + } + if err != nil { + return err + } + err = serv.CreateNamespace(o.Ctx.Request.Context(), ns) if err != nil { return err