testing topic share

net/server/internal/api_content.go

@@ -43,11 +43,6 @@ func GetChannelSize(w http.ResponseWriter, r *http.Request) {
 	w.WriteHeader(http.StatusOK)
 }
 
-func GetChannelSubjectField(w http.ResponseWriter, r *http.Request) {
-	w.Header().Set("Content-Type", "application/json; charset=UTF-8")
-	w.WriteHeader(http.StatusOK)
-}
-
 func GetChannelTopicDetail(w http.ResponseWriter, r *http.Request) {
 	w.Header().Set("Content-Type", "application/json; charset=UTF-8")
 	w.WriteHeader(http.StatusOK)

net/server/internal/api_getChannelSubjectField.go

@@ -0,0 +1,77 @@
+package databag
+
+import (
+  "errors"
+  "strings"
+  "net/http"
+  "gorm.io/gorm"
+  "encoding/base64"
+  "github.com/gorilla/mux"
+  "databag/internal/store"
+  "github.com/valyala/fastjson"
+)
+
+func GetChannelSubjectField(w http.ResponseWriter, r *http.Request) {
+
+  // scan parameters
+  params := mux.Vars(r)
+  channelId := params["channelId"]
+  field := params["field"]
+  elements := strings.Split(field, ".")
+
+  var guid string
+  var act *store.Account
+  tokenType := r.Header.Get("TokenType")
+  if tokenType == APP_TOKENAPP {
+    account, code, err := BearerAppToken(r, false);
+    if err != nil {
+      ErrResponse(w, code, err)
+      return
+    }
+    act = account
+  } else if tokenType == APP_TOKENCONTACT {
+    card, code, err := BearerContactToken(r, true)
+    if err != nil {
+      ErrResponse(w, code, err)
+      return
+    }
+    act = &card.Account
+    guid = card.Guid
+  } else {
+    ErrResponse(w, http.StatusBadRequest, errors.New("unknown token type"))
+    return
+  }
+
+  // load channel
+  var slot store.ChannelSlot
+  if err := store.DB.Preload("Channel.Groups.Cards").Preload("Channel.Cards").Where("account_id = ? AND channel_slot_id = ?", act.ID, channelId).First(&slot).Error; err != nil {
+    if errors.Is(err, gorm.ErrRecordNotFound) {
+      ErrResponse(w, http.StatusNotFound, err)
+    } else {
+      ErrResponse(w, http.StatusInternalServerError, err)
+    }
+    return
+  }
+  if slot.Channel == nil {
+    ErrResponse(w, http.StatusNotFound, errors.New("referenced channel missing"))
+    return
+  }
+
+  // check if channel is shared
+  if tokenType == APP_TOKENCONTACT && !isChannelShared(guid, slot.Channel) {
+    ErrResponse(w, http.StatusNotFound, errors.New("referenced channel not shared"))
+    return
+  }
+
+  // decode data
+  strData := fastjson.GetString([]byte(slot.Channel.Data), elements...)
+  binData, err := base64.StdEncoding.DecodeString(strData)
+  if err != nil {
+    ErrResponse(w, http.StatusNotFound, err)
+    return
+  }
+
+  w.Header().Set("Content-Type", http.DetectContentType(binData))
+  w.Write(binData)
+}
+

net/server/internal/ucTopicShare_test.go

@@ -0,0 +1,74 @@
+package databag
+
+import (
+  "bytes"
+  "testing"
+  "encoding/base64"
+  "github.com/stretchr/testify/assert"
+)
+
+func TestTopicShare(t *testing.T) {
+  var channel *Channel
+  var subject *Subject
+  params := make(map[string]string)
+  header := make(map[string][]string)
+  var err error
+  var data []byte
+
+  // setup testing group
+  set, err := AddTestGroup("topicshare")
+  assert.NoError(t, err)
+
+  // add new channel
+  channel = &Channel{}
+  subject = &Subject{ Data: "channeldata", DataType: "channeldatatype" }
+  assert.NoError(t, ApiTestMsg(AddChannel, "POST", "/content/channels",
+    nil, subject, APP_TOKENAPP, set.A.Token, channel, nil))
+  image := "iVBORw0KGgoAAAANSUhEUgAAAaQAAAGkCAIAAADxLsZiAAAFzElEQVR4nOzWUY3jMBhG0e0qSEqoaIqiaEIoGAxh3gZAldid3nMI+JOiXP3bGOMfwLf7v3oAwAxiBySIHZAgdkCC2AEJYgckiB2QIHZAgtgBCWIHJIgdkCB2QILYAQliBySIHZAgdkCC2AEJYgckiB2QIHZAgtgBCWIHJIgdkCB2QILYAQliBySIHZAgdkCC2AEJYgckiB2QIHZAgtgBCWIHJGzTXnrtx7S3pnk+7qsnnMk3+ny+0dtcdkCC2AEJYgckiB2QIHZAgtgBCWIHJIgdkCB2QILYAQliBySIHZAgdkCC2AEJYgckiB2QIHZAgtgBCWIHJIgdkCB2QILYAQliBySIHZAgdkCC2AEJYgckiB2QIHZAgtgBCWIHJIgdkCB2QILYAQliBySIHZAgdkCC2AEJYgckiB2QIHZAgtgBCWIHJIgdkCB2QILYAQliBySIHZAgdkCC2AEJYgckiB2QIHZAgtgBCWIHJIgdkCB2QILYAQliBySIHZAgdkCC2AEJYgckiB2QIHZAgtgBCWIHJIgdkCB2QILYAQnbtJeej/u0t+Bb+Y/e5rIDEsQOSBA7IEHsgASxAxLEDkgQOyBB7IAEsQMSxA5IEDsgQeyABLEDEsQOSBA7IEHsgASxAxLEDkgQOyBB7IAEsQMSxA5IEDsgQeyABLEDEsQOSBA7IEHsgASxAxLEDkgQOyBB7IAEsQMSxA5IEDsgQeyABLEDEsQOSBA7IEHsgASxAxLEDkgQOyBB7IAEsQMSxA5IEDsgQeyABLEDEsQOSBA7IEHsgASxAxLEDkgQOyBB7IAEsQMSxA5IEDsgQeyABLEDEsQOSBA7IEHsgASxAxLEDkgQOyBB7IAEsQMSbmOM1RsALueyAxLEDkgQOyBB7IAEsQMSxA5IEDsgQeyABLEDEsQOSBA7IEHsgASxAxLEDkgQOyBB7IAEsQMSxA5IEDsgQeyABLEDEsQOSBA7IEHsgASxAxLEDkgQOyBB7IAEsQMSxA5IEDsgQeyABLEDEsQOSBA7IEHsgASxAxLEDkgQOyBB7IAEsQMSxA5IEDsgQeyABLEDEsQOSBA7IEHsgASxAxLEDkgQOyBB7IAEsQMSxA5IEDsgQeyABLEDEsQOSBA7IEHsgASxAxLEDkgQOyBB7IAEsQMSxA5IEDsgQeyAhG31gD/stR+rJ5zv+bivnnAm34hfLjsgQeyABLEDEsQOSBA7IEHsgASxAxLEDkgQOyBB7IAEsQMSxA5IEDsgQeyABLEDEsQOSBA7IEHsgASxAxLEDkgQOyBB7IAEsQMSxA5IEDsgQeyABLEDEsQOSBA7IEHsgASxAxLEDkgQOyBB7IAEsQMSxA5IEDsgQeyABLEDEsQOSBA7IEHsgASxAxLEDkgQOyBB7IAEsQMSxA5IEDsgQeyABLEDEsQOSBA7IEHsgASxAxLEDkgQOyBB7IAEsQMSxA5IEDsgQeyABLEDEsQOSBA7IEHsgASxAxLEDkgQOyBhWz2Az/Laj9UT4BIuOyBB7IAEsQMSxA5IEDsgQeyABLEDEsQOSBA7IEHsgASxAxLEDkgQOyBB7IAEsQMSxA5IEDsgQeyABLEDEsQOSBA7IEHsgASxAxLEDkgQOyBB7IAEsQMSxA5IEDsgQeyABLEDEsQOSBA7IEHsgASxAxLEDkgQOyBB7IAEsQMSxA5IEDsgQeyABLEDEsQOSBA7IEHsgASxAxLEDkgQOyBB7IAEsQMSxA5IEDsgQeyABLEDEsQOSBA7IEHsgASxAxLEDkgQOyBB7IAEsQMSxA5IEDsgQeyABLEDEsQOSBA7IEHsgITbGGP1BoDLueyABLEDEsQOSBA7IEHsgASxAxLEDkgQOyBB7IAEsQMSxA5IEDsgQeyABLEDEsQOSBA7IEHsgASxAxLEDkgQOyBB7IAEsQMSxA5IEDsgQeyABLEDEsQOSBA7IEHsgASxAxLEDkgQOyBB7ICEnwAAAP//DQ4epwV6rzkAAAAASUVORK5CYII="
+  img, _ := base64.StdEncoding.DecodeString(image)
+  subject = &Subject{ Data: "{ \"nested\" : { \"image\" : \"" + image + "\" } }", DataType: "nestedimage" }
+  params["channelId"] = channel.Id
+  assert.NoError(t, ApiTestMsg(SetChannelSubject, "PUT", "/content/channels/{channelId}/subject",
+    &params, subject, APP_TOKENAPP, set.A.Token, channel, nil))
+  params["cardId"] = set.A.B.CardId
+  assert.NoError(t, ApiTestMsg(SetChannelCard, "PUT", "/content/channels/{channelId}/cards/{cardId}",
+    &params, nil, APP_TOKENAPP, set.A.Token, nil, nil))
+  params["cardId"] = set.A.C.CardId
+  assert.NoError(t, ApiTestMsg(SetChannelCard, "PUT", "/content/channels/{channelId}/cards/{cardId}",
+    &params, nil, APP_TOKENAPP, set.A.Token, nil, nil))
+
+  // view channel
+  channel = &Channel{}
+  assert.NoError(t, ApiTestMsg(GetChannel, "GET", "/content/channels/{channelId}",
+    &params, nil, APP_TOKENAPP, set.A.Token, channel, nil))
+  assert.NotNil(t, channel.Data.ChannelDetail);
+  channel = &Channel{}
+  assert.NoError(t, ApiTestMsg(GetChannel, "GET", "/content/channels/{channelId}",
+    &params, nil, APP_TOKENCONTACT, set.B.A.Token, channel, nil))
+  assert.NotNil(t, channel.Data.ChannelDetail);
+  channel = &Channel{}
+  assert.NoError(t, ApiTestMsg(GetChannel, "GET", "/content/channels/{channelId}",
+    &params, nil, APP_TOKENCONTACT, set.B.A.Token, channel, nil))
+  assert.NotNil(t, channel.Data.ChannelDetail);
+  params["field"] = "nested.image"
+  data, header, err = ApiTestData(GetChannelSubjectField, "GET", "/content/channels/{channelId}/subject/{field}",
+    &params, nil, APP_TOKENAPP, set.A.Token)
+  assert.NoError(t, err)
+  assert.Equal(t, "image/png", header["Content-Type"][0])
+  assert.Zero(t, bytes.Compare(img, data))
+  data, header, err = ApiTestData(GetChannelSubjectField, "GET", "/content/channels/{channelId}/subject/{field}",
+    &params, nil, APP_TOKENCONTACT, set.B.A.Token)
+  assert.NoError(t, err)
+  assert.Equal(t, "image/png", header["Content-Type"][0])
+  assert.Zero(t, bytes.Compare(img, data))
+  data, header, err = ApiTestData(GetChannelSubjectField, "GET", "/content/channels/{channelId}/subject/{field}",
+    &params, nil, APP_TOKENCONTACT, set.C.A.Token)
+  assert.NoError(t, err)
+  assert.Equal(t, "image/png", header["Content-Type"][0])
+  assert.Zero(t, bytes.Compare(img, data))
+
+
+
+}
+
+