diff options
| author | =Corey Hulen <corey@hulen.com> | 2016-01-20 12:43:44 -0600 |
|---|---|---|
| committer | =Corey Hulen <corey@hulen.com> | 2016-01-20 12:43:44 -0600 |
| commit | 75f8729e2d25467500778e633c45c97e78a8f7a0 (patch) | |
| tree | 47735a3dd609e025837df4460b0d030454358cf1 /api/web_conn.go | |
| parent | aac8d121a00922f007b9c67d890ea9dbcfbe4b8f (diff) | |
| download | chat-75f8729e2d25467500778e633c45c97e78a8f7a0.tar.gz chat-75f8729e2d25467500778e633c45c97e78a8f7a0.tar.bz2 chat-75f8729e2d25467500778e633c45c97e78a8f7a0.zip | |
PLT-7 adding loc db calls for users table
Diffstat (limited to 'api/web_conn.go')
| -rw-r--r-- | api/web_conn.go | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/api/web_conn.go b/api/web_conn.go index aed16aa55..b9c728174 100644 --- a/api/web_conn.go +++ b/api/web_conn.go @@ -30,8 +30,8 @@ type WebConn struct { func NewWebConn(ws *websocket.Conn, teamId string, userId string, sessionId string) *WebConn { go func() { - achan := Srv.Store.User().UpdateUserAndSessionActivity(userId, sessionId, model.GetMillis()) - pchan := Srv.Store.User().UpdateLastPingAt(userId, model.GetMillis()) + achan := Srv.Store.User().UpdateUserAndSessionActivity(utils.T, userId, sessionId, model.GetMillis()) + pchan := Srv.Store.User().UpdateLastPingAt(utils.T, userId, model.GetMillis()) if result := <-achan; result.Err != nil { l4g.Error("Failed to update LastActivityAt for user_id=%v and session_id=%v, err=%v", userId, sessionId, result.Err) @@ -56,7 +56,7 @@ func (c *WebConn) readPump() { c.WebSocket.SetReadDeadline(time.Now().Add(PONG_WAIT)) go func() { - if result := <-Srv.Store.User().UpdateLastPingAt(c.UserId, model.GetMillis()); result.Err != nil { + if result := <-Srv.Store.User().UpdateLastPingAt(utils.T, c.UserId, model.GetMillis()); result.Err != nil { l4g.Error("Failed to updated LastPingAt for user_id=%v, err=%v", c.UserId, result.Err) } }() |