WIP

plugins/webapi/drng/collectiveBeacon/handler.go

+package collectiveBeacon
+
+import (
+	"net/http"
+
+	cb "github.com/iotaledger/goshimmer/packages/binary/drng/subtypes/collectiveBeacon/payload"
+	generic "github.com/iotaledger/goshimmer/packages/binary/messagelayer/payload"
+	"github.com/iotaledger/goshimmer/plugins/messagelayer"
+	"github.com/iotaledger/hive.go/marshalutil"
+	"github.com/labstack/echo"
+	"github.com/labstack/gommon/log"
+)
+
+// Handler creates a message of the given payload and
+// broadcasts it to the node's neighbors. It returns the message ID if successful.
+func Handler(c echo.Context) error {
+	var request Request
+	if err := c.Bind(&request); err != nil {
+		log.Info(err.Error())
+		return c.JSON(http.StatusBadRequest, Response{Error: err.Error()})
+	}
+
+	//TODO: to check max payload size allowed, if exceeding return an error
+
+	marshalUtil := marshalutil.New(request.Payload)
+	cbPayload, err := cb.Parse(marshalUtil)
+
+	parsedPayload, err := generic.Parse(marshalUtil)
+	if err != nil {
+		return c.JSON(http.StatusBadRequest, Response{Error: "Not a valid Payload"})
+	}
+	tx := messagelayer.MessageFactory.IssuePayload(parsedPayload)
+
+	return c.JSON(http.StatusOK, Response{Id: tx.Id().String()})
+}
+
+type Response struct {
+	Id    string `json:"id,omitempty"`
+	Error string `json:"error,omitempty"`
+}
+
+type Request struct {
+	Payload []byte `json:"payload"`
+}

plugins/webapi/drng/plugin.go

+package drng
+
+import (
+	"github.com/iotaledger/goshimmer/plugins/webapi"
+	"github.com/iotaledger/goshimmer/plugins/webapi/drng/collectiveBeacon"
+	"github.com/iotaledger/hive.go/logger"
+	"github.com/iotaledger/hive.go/node"
+)
+
+var PLUGIN = node.NewPlugin("WebAPI dRNG Endpoint", node.Enabled, configure)
+var log *logger.Logger
+
+func configure(plugin *node.Plugin) {
+	log = logger.NewLogger("API-dRNG")
+	webapi.Server.POST("drng/collectiveBeacon", collectiveBeacon.Handler)
+}