1
0
mirror of https://github.com/mainflux/mainflux.git synced 2025-05-04 22:17:59 +08:00
Aleksandar Novaković 671c32affe
MF-473 - Add metadata field to channel (#476)
* Add metadata field to channels and update things metadata

Add metadata field to channels. Update thing metadata field to be
in JSON format. Update tests..

Signed-off-by: Aleksandar Novakovic <aleksandar.novakovic@mainflux.com>

* Add metadata to channel events

Signed-off-by: Aleksandar Novakovic <aleksandar.novakovic@mainflux.com>

* Add metadata field to channel in go SDK

Signed-off-by: Aleksandar Novakovic <aleksandar.novakovic@mainflux.com>
2018-11-28 15:58:48 +01:00

216 lines
3.8 KiB
Go

//
// Copyright (c) 2018
// Mainflux
//
// SPDX-License-Identifier: Apache-2.0
//
package http
import (
"fmt"
"net/http"
"github.com/mainflux/mainflux"
)
var (
_ mainflux.Response = (*identityRes)(nil)
_ mainflux.Response = (*removeRes)(nil)
_ mainflux.Response = (*thingRes)(nil)
_ mainflux.Response = (*viewThingRes)(nil)
_ mainflux.Response = (*listThingsRes)(nil)
_ mainflux.Response = (*channelRes)(nil)
_ mainflux.Response = (*viewChannelRes)(nil)
_ mainflux.Response = (*listChannelsRes)(nil)
_ mainflux.Response = (*connectionRes)(nil)
_ mainflux.Response = (*disconnectionRes)(nil)
)
type identityRes struct {
id uint64
}
func (res identityRes) Headers() map[string]string {
return map[string]string{
"X-thing-id": fmt.Sprint(res.id),
}
}
func (res identityRes) Code() int {
return http.StatusOK
}
func (res identityRes) Empty() bool {
return true
}
type removeRes struct{}
func (res removeRes) Code() int {
return http.StatusNoContent
}
func (res removeRes) Headers() map[string]string {
return map[string]string{}
}
func (res removeRes) Empty() bool {
return true
}
type thingRes struct {
id string
created bool
}
func (res thingRes) Code() int {
if res.created {
return http.StatusCreated
}
return http.StatusOK
}
func (res thingRes) Headers() map[string]string {
if res.created {
return map[string]string{
"Location": fmt.Sprintf("/things/%s", res.id),
}
}
return map[string]string{}
}
func (res thingRes) Empty() bool {
return true
}
type viewThingRes struct {
ID string `json:"id"`
Owner string `json:"-"`
Type string `json:"type"`
Name string `json:"name,omitempty"`
Key string `json:"key"`
Metadata string `json:"metadata,omitempty"`
}
func (res viewThingRes) Code() int {
return http.StatusOK
}
func (res viewThingRes) Headers() map[string]string {
return map[string]string{}
}
func (res viewThingRes) Empty() bool {
return false
}
type listThingsRes struct {
Things []viewThingRes `json:"things"`
}
func (res listThingsRes) Code() int {
return http.StatusOK
}
func (res listThingsRes) Headers() map[string]string {
return map[string]string{}
}
func (res listThingsRes) Empty() bool {
return false
}
type channelRes struct {
id string
created bool
}
func (res channelRes) Code() int {
if res.created {
return http.StatusCreated
}
return http.StatusOK
}
func (res channelRes) Headers() map[string]string {
if res.created {
return map[string]string{
"Location": fmt.Sprintf("/channels/%s", res.id),
}
}
return map[string]string{}
}
func (res channelRes) Empty() bool {
return true
}
type viewChannelRes struct {
ID string `json:"id"`
Owner string `json:"-"`
Name string `json:"name,omitempty"`
Things []viewThingRes `json:"connected,omitempty"`
Metadata string `json:"metadata,omitempty"`
}
func (res viewChannelRes) Code() int {
return http.StatusOK
}
func (res viewChannelRes) Headers() map[string]string {
return map[string]string{}
}
func (res viewChannelRes) Empty() bool {
return false
}
type listChannelsRes struct {
Channels []viewChannelRes `json:"channels"`
}
func (res listChannelsRes) Code() int {
return http.StatusOK
}
func (res listChannelsRes) Headers() map[string]string {
return map[string]string{}
}
func (res listChannelsRes) Empty() bool {
return false
}
type connectionRes struct{}
func (res connectionRes) Code() int {
return http.StatusOK
}
func (res connectionRes) Headers() map[string]string {
return map[string]string{}
}
func (res connectionRes) Empty() bool {
return true
}
type disconnectionRes struct{}
func (res disconnectionRes) Code() int {
return http.StatusNoContent
}
func (res disconnectionRes) Headers() map[string]string {
return map[string]string{}
}
func (res disconnectionRes) Empty() bool {
return true
}