databag/net/server/internal/api_getChannelNotification.go

package databag

import (
  "databag/internal/store"
  "errors"
  "github.com/gorilla/mux"
  "gorm.io/gorm"
  "net/http"
)

//GetChannelNotifications gets enabled state of channel
func GetChannelNotification(w http.ResponseWriter, r *http.Request) {

  // get referenced channel
  params := mux.Vars(r)
  channelID := params["channelID"]

  tokenType := ParamTokenType(r)
  if tokenType == APPTokenAgent {
    account, code, err := ParamAgentToken(r, false)
    if err != nil {
      ErrResponse(w, code, err)
      return
    }

    // get channel entry
    slot := store.ChannelSlot{}
    if err := store.DB.Model(&slot).Preload("Channel").Where("channel_slot_id = ? AND account_id = ?", channelID, account.ID).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 empty channel"));
      return;
    }

    // return notification status
    WriteResponse(w, slot.Channel.HostPush)
  } else if tokenType == APPTokenContact {
    card, code, err := ParamContactToken(r, true)
    if err != nil {
      ErrResponse(w, code, err)
      return
    }

    // get channel entry
    slot := store.ChannelSlot{}
    if err := store.DB.Model(&slot).Preload("Channel").Where("channel_slot_id = ? AND account_id = ?", channelID, card.Account.ID).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 empty channel"));
      return;
    }

    // get member entry
    member := store.Member{}
    if err := store.DB.Model(&member).Where("channel_id = ? AND card_id = ?", slot.Channel.ID, card.ID).First(&member).Error; err != nil {
      if errors.Is(err, gorm.ErrRecordNotFound) {
        ErrResponse(w, http.StatusNotFound, err)
      } else {
        ErrResponse(w, http.StatusInternalServerError, err)
      }
      return
    }

    // return notification status
    WriteResponse(w, member.PushEnabled)
  } else {
    ErrResponse(w, http.StatusUnauthorized, errors.New("invalid access token"))
  }
}