Skip to content

Commit

Permalink
Add v *Viber param to callback events functions
Browse files Browse the repository at this point in the history
  • Loading branch information
mileusna committed Jun 22, 2017
1 parent eaba7cf commit e794e43
Showing 1 changed file with 16 additions and 16 deletions.
32 changes: 16 additions & 16 deletions viber.go
Original file line number Diff line number Diff line change
Expand Up @@ -44,13 +44,13 @@ type Viber struct {
Sender Sender

// event methods
Subscribed func(u User, token uint64, t time.Time)
ConversationStarted func(u User, conversationType, context string, subscribed bool, token uint64, t time.Time) Message
Message func(u User, m Message, token uint64, t time.Time)
Unsubscribed func(userID string, token uint64, t time.Time)
Delivered func(userID string, token uint64, t time.Time)
Seen func(userID string, token uint64, t time.Time)
Failed func(userID string, token uint64, descr string, t time.Time)
Subscribed func(v *Viber, u User, token uint64, t time.Time)
ConversationStarted func(v *Viber, u User, conversationType, context string, subscribed bool, token uint64, t time.Time) Message
Message func(v *Viber, u User, m Message, token uint64, t time.Time)
Unsubscribed func(v *Viber, userID string, token uint64, t time.Time)
Delivered func(v *Viber, userID string, token uint64, t time.Time)
Seen func(v *Viber, userID string, token uint64, t time.Time)
Failed func(v *Viber, userID string, token uint64, descr string, t time.Time)
}

var regexpPeekMsgType = regexp.MustCompile("\"type\":\\s*\"(.*)\"")
Expand Down Expand Up @@ -82,7 +82,7 @@ func (v *Viber) ServeHTTP(w http.ResponseWriter, r *http.Request) {

case "unsubscribed":
if v.Unsubscribed != nil {
go v.Unsubscribed(e.UserID, e.MessageToken, e.Timestamp.Time)
go v.Unsubscribed(v, e.UserID, e.MessageToken, e.Timestamp.Time)
}

case "conversation_started":
Expand All @@ -91,7 +91,7 @@ func (v *Viber) ServeHTTP(w http.ResponseWriter, r *http.Request) {
if err := json.Unmarshal(e.User, &u); err != nil {
return
}
if msg := v.ConversationStarted(u, e.Type, e.Context, e.Subscribed, e.MessageToken, e.Timestamp.Time); msg != nil {
if msg := v.ConversationStarted(v, u, e.Type, e.Context, e.Subscribed, e.MessageToken, e.Timestamp.Time); msg != nil {
msg.SetReceiver("")
msg.SetFrom("")
b, _ := json.Marshal(msg)
Expand All @@ -101,17 +101,17 @@ func (v *Viber) ServeHTTP(w http.ResponseWriter, r *http.Request) {

case "delivered":
if v.Delivered != nil {
go v.Delivered(e.UserID, e.MessageToken, e.Timestamp.Time)
go v.Delivered(v, e.UserID, e.MessageToken, e.Timestamp.Time)
}

case "seen":
if v.Seen != nil {
go v.Seen(e.UserID, e.MessageToken, e.Timestamp.Time)
go v.Seen(v, e.UserID, e.MessageToken, e.Timestamp.Time)
}

case "failed":
if v.Failed != nil {
go v.Failed(e.UserID, e.MessageToken, e.Descr, e.Timestamp.Time)
go v.Failed(v, e.UserID, e.MessageToken, e.Descr, e.Timestamp.Time)
}

case "message":
Expand All @@ -128,28 +128,28 @@ func (v *Viber) ServeHTTP(w http.ResponseWriter, r *http.Request) {
if err := json.Unmarshal(e.Message, &m); err != nil {
return
}
go v.Message(u, &m, e.MessageToken, e.Timestamp.Time)
go v.Message(v, u, &m, e.MessageToken, e.Timestamp.Time)

case "picture":
var m PictureMessage
if err := json.Unmarshal(e.Message, &m); err != nil {
return
}
go v.Message(u, &m, e.MessageToken, e.Timestamp.Time)
go v.Message(v, u, &m, e.MessageToken, e.Timestamp.Time)

case "video":
var m VideoMessage
if err := json.Unmarshal(e.Message, &m); err != nil {
return
}
go v.Message(u, &m, e.MessageToken, e.Timestamp.Time)
go v.Message(v, u, &m, e.MessageToken, e.Timestamp.Time)

case "url":
var m URLMessage
if err := json.Unmarshal(e.Message, &m); err != nil {
return
}
go v.Message(u, &m, e.MessageToken, e.Timestamp.Time)
go v.Message(v, u, &m, e.MessageToken, e.Timestamp.Time)

case "contact":
// TODO
Expand Down

0 comments on commit e794e43

Please sign in to comment.