Function ExpireSessions

cmd/cql-proxy/model/session.go:348–373

ExpireSessions expires session object in database.

(db *gorp.DbMap)

// ExpireSessions expires session object in database.
func ExpireSessions(db *gorp.DbMap) (expireCount int64, err error) {
	var sessions []*Session
	_, err = db.Select(&sessions, `SELECT * FROM "session" WHERE "expire" <= ?`,
		time.Now().Unix())
	if err != nil {
		err = errors.Wrapf(err, "get sessions to expire failed")
		return
	}

	if len(sessions) == 0 {
		return
	}

	var args []interface{}

	for _, s := range sessions {
		args = append(args, s)
	}

	expireCount, err = db.Delete(args...)
	if err != nil {
		err = errors.Wrapf(err, "remove expired sessions failed")
	}

	return
}