move backend to new structure

2025-08-14 14:59:07 +02:00 · 2024-12-22 21:39:36 +01:00
parent 3c601caf02
commit 5658c10b56
28 changed files with 15 additions and 367 deletions
--- a/cmd/backend/handlers/createPerson.go
+++ b/cmd/backend/handlers/createPerson.go
@@ -0,0 +1,49 @@
+package handlers
+
+import (
+	"encoding/json"
+	"log"
+	"net/http"
+
+	"github.com/gin-gonic/gin"
+	"github.com/neo4j/neo4j-go-driver/v5/neo4j"
+	"github.com/vcscsvcscs/GenerationsHeritage/pkg/memgraph"
+)
+
+func CreatePerson(driver neo4j.DriverWithContext) gin.HandlerFunc {
+	return func(c *gin.Context) {
+		if c.Request.Body == nil || c.ContentType() != "application/json" {
+			log.Printf("ip: %s error: request body is empty or content type is not application/json", c.ClientIP())
+			c.JSON(http.StatusBadRequest, gin.H{"error": "content type must be application/json and request body must not be empty"})
+
+			return
+		}
+
+		var person memgraph.Person
+		err := json.NewDecoder(c.Request.Body).Decode(&person)
+		if err != nil {
+			log.Printf("ip: %s error: %s", c.ClientIP(), err.Error())
+			c.JSON(http.StatusBadRequest, gin.H{"error": "invalid request body"})
+
+			return
+		}
+
+		if err := person.Verify(); err != nil {
+			log.Printf("ip: %s error: %s", c.ClientIP(), err.Error())
+			c.JSON(http.StatusBadRequest, gin.H{"error": "contains-forbidden-characters"})
+
+			return
+		}
+
+		person.ID = c.GetString("id")
+		rec, err := person.CreatePerson(driver)
+		if err != nil {
+			log.Printf("ip: %s error: %s", c.ClientIP(), err.Error())
+			c.JSON(http.StatusBadRequest, gin.H{"error": "already-exists"})
+
+			return
+		}
+
+		c.JSON(http.StatusCreated, gin.H{"person": rec.AsMap()})
+	}
+}
--- a/cmd/backend/handlers/createRelationship.go
+++ b/cmd/backend/handlers/createRelationship.go
@@ -0,0 +1,32 @@
+package handlers
+
+import (
+	"log"
+	"net/http"
+
+	"github.com/gin-gonic/gin"
+	"github.com/neo4j/neo4j-go-driver/v5/neo4j"
+	"github.com/vcscsvcscs/GenerationsHeritage/pkg/memgraph"
+)
+
+func CreateRelationship(driver neo4j.DriverWithContext) gin.HandlerFunc {
+	return func(c *gin.Context) {
+		var relationship memgraph.Relationship
+		if err := c.ShouldBindJSON(&relationship); err != nil {
+			log.Printf("ip: %s error: %s", c.ClientIP(), err)
+			c.JSON(http.StatusBadRequest, gin.H{"error": err.Error()})
+
+			return
+		}
+
+		rec, err := relationship.CreateRelationship(driver)
+		if err != nil {
+			log.Printf("ip: %s error: %s", c.ClientIP(), err)
+			c.JSON(http.StatusInternalServerError, gin.H{"error": "internal server error"})
+
+			return
+		}
+
+		c.JSON(http.StatusCreated, gin.H{"relationship": rec.AsMap()})
+	}
+}
--- a/cmd/backend/handlers/create_relationship_and_person.go
+++ b/cmd/backend/handlers/create_relationship_and_person.go
@@ -0,0 +1,32 @@
+package handlers
+
+import (
+	"log"
+	"net/http"
+
+	"github.com/gin-gonic/gin"
+	"github.com/neo4j/neo4j-go-driver/v5/neo4j"
+	"github.com/vcscsvcscs/GenerationsHeritage/pkg/memgraph"
+)
+
+func CreateRelationshipAndPerson(driver neo4j.DriverWithContext) gin.HandlerFunc {
+	return func(c *gin.Context) {
+		var rp memgraph.RelationshipAndPerson
+		if err := c.ShouldBindJSON(&rp); err != nil {
+			log.Printf("ip: %s error: %s", c.ClientIP(), err)
+			c.JSON(http.StatusBadRequest, gin.H{"error": err.Error()})
+
+			return
+		}
+
+		rec, err := rp.CreateRelationshipAndPerson(driver)
+		if err != nil {
+			log.Printf("ip: %s error: %s", c.ClientIP(), err)
+			c.JSON(http.StatusInternalServerError, gin.H{"error": "internal server error"})
+
+			return
+		}
+
+		c.JSON(http.StatusCreated, gin.H{"relationship": rec.AsMap()})
+	}
+}
--- a/cmd/backend/handlers/deletePerson.go
+++ b/cmd/backend/handlers/deletePerson.go
@@ -0,0 +1,48 @@
+package handlers
+
+import (
+	"encoding/json"
+	"log"
+	"net/http"
+
+	"github.com/gin-gonic/gin"
+	"github.com/neo4j/neo4j-go-driver/v5/neo4j"
+	"github.com/vcscsvcscs/GenerationsHeritage/pkg/memgraph"
+)
+
+func DeletePerson(driver neo4j.DriverWithContext) gin.HandlerFunc {
+	return func(c *gin.Context) {
+		if c.Request.Body == nil || c.ContentType() != "application/json" {
+			log.Printf("ip: %s error: request body is empty or content type is not application/json", c.ClientIP())
+			c.JSON(http.StatusBadRequest, gin.H{"error": "content type must be application/json and request body must not be empty"})
+
+			return
+		}
+
+		var person memgraph.Person
+		err := json.NewDecoder(c.Request.Body).Decode(&person)
+		if err != nil {
+			log.Printf("ip: %s error: %s", c.ClientIP(), err)
+			c.JSON(http.StatusBadRequest, gin.H{"error": "invalid request body"})
+
+			return
+		}
+
+		if person.ID != "" {
+			log.Printf("ip: %s error: %s", c.ClientIP(), err)
+			c.JSON(http.StatusBadRequest, gin.H{"error": "no person ID provided"})
+
+			return
+		}
+
+		err = person.DeletePerson(driver)
+		if err != nil {
+			log.Printf("ip: %s error: %s", c.ClientIP(), err)
+			c.JSON(http.StatusNotFound, gin.H{"error": "could not delete person with ID provided"})
+
+			return
+		}
+
+		c.JSON(http.StatusOK, gin.H{"status": "person deleted successfully"})
+	}
+}
--- a/cmd/backend/handlers/deleteRelationship.go
+++ b/cmd/backend/handlers/deleteRelationship.go
@@ -0,0 +1,32 @@
+package handlers
+
+import (
+	"log"
+	"net/http"
+
+	"github.com/gin-gonic/gin"
+	"github.com/neo4j/neo4j-go-driver/v5/neo4j"
+	"github.com/vcscsvcscs/GenerationsHeritage/pkg/memgraph"
+)
+
+func DeleteRelationship(driver neo4j.DriverWithContext) gin.HandlerFunc {
+	return func(c *gin.Context) {
+		var relationship memgraph.Relationship
+		if err := c.ShouldBindJSON(&relationship); err != nil {
+			log.Printf("ip: %s error: %s", c.ClientIP(), err)
+			c.JSON(http.StatusBadRequest, gin.H{"error": err.Error()})
+
+			return
+		}
+
+		err := relationship.DeleteRelationship(driver)
+		if err != nil {
+			log.Printf("ip: %s error: %s", c.ClientIP(), err)
+			c.JSON(http.StatusInternalServerError, gin.H{"error": "internal server error"})
+
+			return
+		}
+
+		c.JSON(http.StatusAccepted, gin.H{"status": "relationship deleted successfully"})
+	}
+}
--- a/cmd/backend/handlers/updatePerson.go
+++ b/cmd/backend/handlers/updatePerson.go
@@ -0,0 +1,48 @@
+package handlers
+
+import (
+	"encoding/json"
+	"log"
+	"net/http"
+
+	"github.com/gin-gonic/gin"
+	"github.com/neo4j/neo4j-go-driver/v5/neo4j"
+	"github.com/vcscsvcscs/GenerationsHeritage/pkg/memgraph"
+)
+
+func UpdatePerson(driver neo4j.DriverWithContext) gin.HandlerFunc {
+	return func(c *gin.Context) {
+		if c.Request.Body == nil || c.ContentType() != "application/json" {
+			log.Printf("ip: %s error: request body is empty or content type is not application/json", c.ClientIP())
+			c.JSON(http.StatusBadRequest, gin.H{"error": "content type must be application/json and request body must not be empty"})
+
+			return
+		}
+
+		var person memgraph.Person
+		err := json.NewDecoder(c.Request.Body).Decode(&person)
+		if err != nil {
+			log.Printf("ip: %s error: %s", c.ClientIP(), err)
+			c.JSON(http.StatusBadRequest, gin.H{"error": "invalid request body"})
+
+			return
+		}
+
+		if person.ID == "" {
+			log.Printf("ip: %s error: %s", c.ClientIP(), err)
+			c.JSON(http.StatusBadRequest, gin.H{"error": "No ID provided"})
+
+			return
+		}
+
+		rec, err := person.UpdatePerson(driver)
+		if err != nil {
+			log.Printf("ip: %s error: %s", c.ClientIP(), err)
+			c.JSON(http.StatusNotFound, gin.H{"error": "could not update person with information provided"})
+
+			return
+		}
+
+		c.JSON(http.StatusOK, gin.H{"person": rec.AsMap()})
+	}
+}
--- a/cmd/backend/handlers/verifyRelationship.go
+++ b/cmd/backend/handlers/verifyRelationship.go
@@ -0,0 +1,32 @@
+package handlers
+
+import (
+	"log"
+	"net/http"
+
+	"github.com/gin-gonic/gin"
+	"github.com/neo4j/neo4j-go-driver/v5/neo4j"
+	"github.com/vcscsvcscs/GenerationsHeritage/pkg/memgraph"
+)
+
+func VerifyRelationship(driver neo4j.DriverWithContext) gin.HandlerFunc {
+	return func(c *gin.Context) {
+		var relationship memgraph.Relationship
+		if err := c.ShouldBindJSON(&relationship); err != nil {
+			log.Printf("ip: %s error: %s", c.ClientIP(), err)
+			c.JSON(http.StatusBadRequest, gin.H{"error": err.Error()})
+
+			return
+		}
+
+		rec, err := relationship.VerifyRelationship(driver)
+		if err != nil {
+			log.Printf("ip: %s error: %s", c.ClientIP(), err)
+			c.JSON(http.StatusInternalServerError, gin.H{"error": "internal server error"})
+
+			return
+		}
+
+		c.JSON(http.StatusOK, gin.H{"relationship": rec.AsMap()})
+	}
+}
--- a/cmd/backend/handlers/viewFamilyTree.go
+++ b/cmd/backend/handlers/viewFamilyTree.go
@@ -0,0 +1,55 @@
+package handlers
+
+import (
+	"context"
+	"log"
+	"net/http"
+	"time"
+
+	"github.com/gin-gonic/gin"
+	"github.com/neo4j/neo4j-go-driver/v5/neo4j"
+)
+
+func ViewFamiliyTree(driver neo4j.DriverWithContext) gin.HandlerFunc {
+	return func(c *gin.Context) {
+		ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
+		defer cancel()
+
+		session := driver.NewSession(ctx, neo4j.SessionConfig{AccessMode: neo4j.AccessModeRead})
+		defer session.Close(ctx)
+
+		id := c.GetString("id")
+		if id == "" {
+			c.JSON(http.StatusBadRequest, gin.H{"error": "id is required"})
+
+			return
+		}
+
+		query := `
+		MATCH (n:Person {id: $person_id})-[p:Parent*1..]->(family:Person)
+		OPTIONAL MATCH (family)-[c:Child]->(children:Person)
+		WITH family, p, children, c, n
+		OPTIONAL MATCH (children)<-[p2:Parent]-(OtherParents:Person)
+		WITH family, p, children, c, OtherParents, p2,n
+		OPTIONAL MATCH (family)-[s:Spouse]-(spouse:Person)
+		RETURN family, p, children, c, OtherParents, p2, spouse, s, n;`
+
+		result, err := session.Run(ctx, query, map[string]any{"person_id": id})
+		if err != nil {
+			log.Printf("ip: %s error: %s", c.ClientIP(), err)
+			c.JSON(http.StatusInternalServerError, gin.H{"error": "internal server error"})
+
+			return
+		}
+
+		rec, err := result.Collect(ctx)
+		if err != nil {
+			log.Printf("ip: %s error: %s", c.ClientIP(), err)
+			c.JSON(http.StatusNotFound, gin.H{"error": "could not find family tree for person with id: " + id})
+
+			return
+		}
+
+		c.JSON(200, rec)
+	}
+}
--- a/cmd/backend/handlers/viewPerson.go
+++ b/cmd/backend/handlers/viewPerson.go
@@ -0,0 +1,50 @@
+package handlers
+
+import (
+	"context"
+	"log"
+	"net/http"
+	"time"
+
+	"github.com/gin-gonic/gin"
+	"github.com/neo4j/neo4j-go-driver/v5/neo4j"
+)
+
+func ViewPerson(driver neo4j.DriverWithContext) gin.HandlerFunc {
+	return func(c *gin.Context) {
+		ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
+		defer cancel()
+
+		session := driver.NewSession(ctx, neo4j.SessionConfig{AccessMode: neo4j.AccessModeRead})
+		defer session.Close(ctx)
+
+		id := c.Query("id")
+		if id == "" {
+			id = c.GetString("id")
+		}
+
+		if id == "" {
+			c.JSON(http.StatusBadRequest, gin.H{"error": "id is required"})
+
+			return
+		}
+
+		result, err := session.Run(ctx, "MATCH (n:Person) WHERE n.id = $person_id RETURN n;", map[string]any{"person_id": id})
+		if err != nil {
+			log.Printf("ip: %s error: %s", c.ClientIP(), err)
+			c.JSON(http.StatusInternalServerError, gin.H{"error": "internal server error"})
+
+			return
+		}
+
+		rec, err := result.Single(ctx)
+		if err != nil {
+			log.Printf("ip: %s error: %s", c.ClientIP(), err)
+			c.JSON(http.StatusNotFound, gin.H{"error": "could not find person with information provided"})
+
+			return
+		}
+
+		c.JSON(200, rec.AsMap()["n"])
+	}
+}