Update OCLIB

infrastructure/nats.go

@@ -2,11 +2,8 @@ package infrastructure
 
 import (
 	"encoding/json"
-	"fmt"
 
 	oclib "cloud.o-forge.io/core/oc-lib"
-	"cloud.o-forge.io/core/oc-lib/config"
-	"cloud.o-forge.io/core/oc-lib/models/peer"
 	"cloud.o-forge.io/core/oc-lib/models/resources"
 	"cloud.o-forge.io/core/oc-lib/tools"
 )
@@ -60,48 +57,5 @@ func ListenNATS() {
 				SearchStream[resp.User] <- p // TODO when do we update it in our catalog ?
 			}
 		},
-		tools.CREATE_PEER: func(resp tools.NATSResponse) {
-			if resp.FromApp == config.GetAppName() {
-				return
-			}
-			var p peer.Peer
-			err := json.Unmarshal(resp.Payload, &p)
-			if err == nil && p.Relation == peer.BLACKLIST {
-				for _, col := range ressourceCols {
-					access := oclib.NewRequestAdmin(col, nil)
-					datas := access.Search(nil, p.UUID, false)
-					for _, data := range datas.Data {
-						access.DeleteOne(data.GetID())
-					}
-				}
-			}
-		},
-		tools.CREATE_RESOURCE: func(resp tools.NATSResponse) {
-			if resp.FromApp == config.GetAppName() {
-				return
-			}
-			p := map[string]interface{}{}
-			err := json.Unmarshal(resp.Payload, &p)
-			if err == nil {
-				access := oclib.NewRequestAdmin(oclib.LibDataEnum(resp.Datatype), nil)
-				if data := access.LoadOne(fmt.Sprintf("%v", p["id"])); data.Data != nil {
-					delete(p, "id")
-					access.UpdateOne(p, fmt.Sprintf("%v", p["id"]))
-				} else {
-					access.StoreOne(p)
-				}
-			}
-		},
-		tools.REMOVE_RESOURCE: func(resp tools.NATSResponse) {
-			if resp.FromApp == config.GetAppName() {
-				return
-			}
-			p := map[string]interface{}{}
-			access := oclib.NewRequestAdmin(oclib.LibDataEnum(resp.Datatype), nil)
-			err := json.Unmarshal(resp.Payload, &p)
-			if err == nil {
-				access.DeleteOne(fmt.Sprintf("%v", p["id"]))
-			}
-		},
 	})
 }