feat: add car file upload support

api/status_check.go

@@ -27,6 +27,13 @@ func ConfigureStatusCheckRouter(e *echo.Group, node *core.LightNode) {
 		var content core.Content
 		node.DB.Raw("select * from contents as c where requesting_api_key = ? and id = ?", authParts[1], c.Param("id")).Scan(&content)
 		content.RequestingApiKey = ""
+
+		if content.ID == 0 {
+			return c.JSON(404, map[string]interface{}{
+				"message": "Content not found. Please check if you have the proper API key or if the content id is valid",
+			})
+		}
+
 		return c.JSON(200, map[string]interface{}{
 			"content": content,
 		})

api/upload.go

@@ -1,8 +1,10 @@
 package api
 
 import (
+	"context"
 	"fmt"
 	"github.com/application-research/edge-ur/jobs"
+	"github.com/ipld/go-car"
 	"github.com/spf13/viper"
 	"strings"
 	"time"
@@ -63,9 +65,58 @@ func ConfigurePinningRouter(e *echo.Group, node *core.LightNode) {
 	var DeltaUploadApi = viper.Get("DELTA_NODE_API").(string)
 	content := e.Group("/content")
 	content.POST("/add", handlePinAddToNode(node, DeltaUploadApi))
+	content.POST("/add-car", handlePinAddCarToNode(node, DeltaUploadApi))
 
 }
 
+func handlePinAddCarToNode(node *core.LightNode, DeltaUploadApi string) func(c echo.Context) error {
+	return func(c echo.Context) error {
+		authorizationString := c.Request().Header.Get("Authorization")
+		authParts := strings.Split(authorizationString, " ")
+
+		file, err := c.FormFile("data")
+		src, err := file.Open()
+		srcR := src
+
+		if err != nil {
+			c.JSON(500, UploadResponse{
+				Status:  "error",
+				Message: "Error pinning the car file:" + err.Error(),
+			})
+		}
+
+		carHeader, err := car.LoadCar(context.Background(), node.Node.Blockstore, src)
+		if err != nil {
+			c.JSON(500, UploadResponse{
+				Status:  "error",
+				Message: "Error loading car file: " + err.Error(),
+			})
+		}
+
+		rootCid := carHeader.Roots[0].String()
+
+		// insert a new record
+		newContent := core.Content{
+			Name:             file.Filename,
+			Size:             file.Size,
+			Cid:              rootCid,
+			DeltaNodeUrl:     DeltaUploadApi,
+			RequestingApiKey: authParts[1],
+			Status:           "pinned",
+			CreatedAt:        time.Now(),
+			UpdatedAt:        time.Now(),
+		}
+
+		node.DB.Create(&newContent)
+
+		job := jobs.CreateNewDispatcher()
+		job.AddJob(jobs.NewUploadToEstuaryProcessor(node, newContent, srcR))
+		job.Start(1)
+
+		return nil
+	}
+}
+
 func handlePinAddToNode(node *core.LightNode, DeltaUploadApi string) func(c echo.Context) error {
 	return func(c echo.Context) error {
 		authorizationString := c.Request().Header.Get("Authorization")

go.mod

@@ -17,6 +17,7 @@ require (
 	github.com/ipfs/go-path v0.3.0
 	github.com/ipfs/go-unixfs v0.4.1
 	github.com/ipfs/go-unixfsnode v1.4.0
+	github.com/ipld/go-car v0.5.0
 	github.com/ipld/go-codec-dagpb v1.3.2
 	github.com/ipld/go-ipld-prime v0.17.0
 	github.com/labstack/echo/v4 v4.9.1
@@ -127,7 +128,6 @@ require (
 	github.com/ipfs/go-peertaskqueue v0.7.1 // indirect
 	github.com/ipfs/go-verifcid v0.0.1 // indirect
 	github.com/ipfs/interface-go-ipfs-core v0.7.0 // indirect
-	github.com/ipld/go-car v0.5.0 // indirect
 	github.com/jackpal/go-nat-pmp v1.0.2 // indirect
 	github.com/jbenet/go-temp-err-catcher v0.1.0 // indirect
 	github.com/jbenet/goprocess v0.1.4 // indirect