moira

1
package reply
2

3
import (
4
	"encoding/json"
5
	"fmt"
6

7
	"github.com/garyburd/redigo/redis"
8

9
	"go.avito.ru/DO/moira"
10
	"go.avito.ru/DO/moira/database"
11
)
12

13
// Check converts redis DB reply to *moira.CheckData
14
func Check(rep interface{}, err error) (*moira.CheckData, error) {
15
	checkData := &moira.CheckData{}
16
	bytes, err := redis.Bytes(rep, err)
17

18
	if err != nil {
19
		if err == redis.ErrNil {
20
			return nil, database.ErrNil
21
		}
22
		return nil, fmt.Errorf("Failed to read lastCheck: %s", err.Error())
23
	}
24

25
	err = json.Unmarshal(bytes, checkData)
26
	if err != nil {
27
		return nil, fmt.Errorf("Failed to parse lastCheck json %s: %s", string(bytes), err.Error())
28
	}
29

30
	return checkData, nil
31
}
32