From de6ad35f604019ffe1aadf0f19b783b0cad84d82 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Mike=20Schw=C3=B6rer?= <pubgit@mikescher.com>
Date: Wed, 14 Dec 2022 14:29:59 +0100
Subject: [PATCH] new Endpoint: CreateChannel(*)

---
 server/api/handler/api.go | 58 +++++++++++++++++++++++++++++++++++++++
 server/api/router.go      |  1 +
 2 files changed, 59 insertions(+)

diff --git a/server/api/handler/api.go b/server/api/handler/api.go
index 49b5c7f..489cd68 100644
--- a/server/api/handler/api.go
+++ b/server/api/handler/api.go
@@ -615,6 +615,64 @@ func (h APIHandler) GetChannel(g *gin.Context) ginresp.HTTPResponse {
 	return ctx.FinishSuccess(ginresp.JSON(http.StatusOK, channel.JSON(true)))
 }
 
+// CreateChannel swaggerdoc
+//
+// @Summary Create a new (empty) channel
+// @ID      api-channels-create
+// @Tags    API-v2
+//
+// @Param   uid       path     int                        true  "UserID"
+// @Param   post_body body     handler.CreateChannel.body false " "
+//
+// @Success 200       {object} models.ChannelJSON
+// @Failure 400       {object} ginresp.apiError "supplied values/parameters cannot be parsed / are invalid"
+// @Failure 401       {object} ginresp.apiError "user is not authorized / has missing permissions"
+// @Failure 409       {object} ginresp.apiError "channel already exists"
+// @Failure 500       {object} ginresp.apiError "internal server error"
+//
+// @Router  /api/users/{uid}/channels/ [POST]
+func (h APIHandler) CreateChannel(g *gin.Context) ginresp.HTTPResponse {
+	type uri struct {
+		UserID models.UserID `uri:"uid"`
+	}
+	type body struct {
+		Name string `json:"name"`
+	}
+
+	var u uri
+	var b body
+	ctx, errResp := h.app.StartRequest(g, &u, nil, &b, nil)
+	if errResp != nil {
+		return *errResp
+	}
+	defer ctx.Cancel()
+
+	if permResp := ctx.CheckPermissionUserAdmin(u.UserID); permResp != nil {
+		return *permResp
+	}
+
+	channelName := h.app.NormalizeChannelName(b.Name)
+
+	channelExisting, err := h.database.GetChannelByName(ctx, u.UserID, channelName)
+	if err != nil {
+		return ginresp.APIError(g, 500, apierr.DATABASE_ERROR, "Failed to query channel", err)
+	}
+
+	if channelExisting != nil {
+		return ginresp.APIError(g, 409, apierr.CHANNEL_ALREADY_EXISTS, "Channel with this name already exists", nil)
+	}
+
+	subscribeKey := h.app.GenerateRandomAuthKey()
+	sendKey := h.app.GenerateRandomAuthKey()
+
+	channel, err := h.database.CreateChannel(ctx, u.UserID, channelName, subscribeKey, sendKey)
+	if err != nil {
+		return ginresp.APIError(g, 500, apierr.DATABASE_ERROR, "Failed to create channel", err)
+	}
+
+	return ctx.FinishSuccess(ginresp.JSON(http.StatusOK, channel.JSON(true)))
+}
+
 // UpdateChannel swaggerdoc
 //
 // @Summary (Partially) update a channel
diff --git a/server/api/router.go b/server/api/router.go
index 60d0ab6..7fa9f00 100644
--- a/server/api/router.go
+++ b/server/api/router.go
@@ -122,6 +122,7 @@ func (r *Router) Init(e *gin.Engine) {
 		apiv2.DELETE("/users/:uid/clients/:cid", ginresp.Wrap(r.apiHandler.DeleteClient))
 
 		apiv2.GET("/users/:uid/channels", ginresp.Wrap(r.apiHandler.ListChannels))
+		apiv2.POST("/users/:uid/channels", ginresp.Wrap(r.apiHandler.CreateChannel))
 		apiv2.GET("/users/:uid/channels/:cid", ginresp.Wrap(r.apiHandler.GetChannel))
 		apiv2.PATCH("/users/:uid/channels/:cid", ginresp.Wrap(r.apiHandler.UpdateChannel))
 		apiv2.GET("/users/:uid/channels/:cid/messages", ginresp.Wrap(r.apiHandler.ListChannelMessages))