2 Commits

Author SHA1 Message Date
Adrian Zürcher
bf36b023d3 add new repond function message 2025-04-27 09:51:32 +02:00
Adrian Zürcher
a8127cc381 add new response function 2025-04-26 23:58:47 +02:00
2 changed files with 15 additions and 0 deletions

View File

@@ -19,6 +19,10 @@ func (r *Response) SendError(msg string) {
r.Message = msg r.Message = msg
} }
func (r *Response) SendMessage(msg string) {
r.Message = msg
}
func (r *Response) AddGet(get Get) { func (r *Response) AddGet(get Get) {
get.Query = nil get.Query = nil
r.Get = append(r.Get, get) r.Get = append(r.Get, get)
@@ -32,6 +36,13 @@ func (r *Response) AddSubscription(sub Subscribe) {
r.Subscribe = append(r.Subscribe, sub) r.Subscribe = append(r.Subscribe, sub)
} }
func (r *Response) AddUnsubscription(sub Subscribe) {
r.Subscribe = append(r.Subscribe, sub)
}
func (r *Response) AddUPublish(pub Publish) {
r.Publish = append(r.Publish, pub)
}
func (r *Response) IsValid() bool { func (r *Response) IsValid() bool {
return !r.Error return !r.Error
} }

View File

@@ -6,6 +6,10 @@ import (
"github.com/tecamino/tecamino-json_data/models" "github.com/tecamino/tecamino-json_data/models"
) )
func NewResponse() *models.Response {
return &models.Response{}
}
func ParseResponse(b []byte) (*models.Response, error) { func ParseResponse(b []byte) (*models.Response, error) {
r := models.Response{} r := models.Response{}