config

var (
	AboutBucket = []byte("about")
	Schemas     = []Schema{
		{
			Version: Version{
				0, 10, 4,
			},
			Buckets: []string{
				"app",
				"user",
			},

			Upgrader: func(old *bolt.DB) error {
				return nil
			},
		},
		{
			Version: Version{
				0, 12, 0,
			},
			Buckets: []string{
				"app",
				"user",
			},
			Upgrader: func(old *bolt.DB) error {
				convertToKV := func(i interface{}) *event.TagSet {
					if i == nil {
						return event.NewTagset(0)
					}
					m := i.(map[string]interface{})
					kv := event.NewTagset(len(m))
					for k, v := range m {
						kv.Set(k, v.(string))
					}

					return kv
				}
				upgradeRawSnapshot := func(buff []byte) ([]byte, error) {

					oldSnap := make(map[string]interface{})
					err := json.Unmarshal(buff, &oldSnap)
					if err != nil {
						return nil, err
					}

					app, ok := oldSnap["app"].(map[string]interface{})
					if !ok {
						return nil, fmt.Errorf("Unable to upgrade snapshot. No 'app' section found.")
					}

					raw_pols, ok := app["policies"]
					if ok {
						pols, ok := raw_pols.(map[string]interface{})
						if ok {
							for k, v := range pols {
								x := v.(map[string]interface{})

								logrus.Debugf("Removing old match/not_match from %s", k)
								x["match"] = convertToKV(x["match"])
								x["not_match"] = convertToKV(x["not_match"])
								x["group_by"] = convertToKV(x["group_by"])
							}
						} else {
							log.Println(reflect.TypeOf(raw_pols).String())
						}

					}

					app["global_policy"] = map[string]interface{}{}

					oldSnap["app"] = app

					return json.Marshal(&oldSnap)

				}

				err := old.Update(func(tx *bolt.Tx) error {

					b := tx.Bucket([]byte("app"))
					if b == nil {
						logrus.Warning("No config snapshots found")
						return nil
					}

					newSnapshots := make([]struct {
						key []byte
						val []byte
					}, 0, b.Stats().KeyN)

					b.ForEach(func(k, v []byte) error {
						logrus.Debugf("Starting snapshot upgrade on: %s", string(k))
						upgraded, err := upgradeRawSnapshot(v)
						if err != nil {
							logrus.Errorf("Unable to upgrade snapshot: %s %s", string(k), err.Error())
						}

						newSnapshots = append(newSnapshots, struct {
							key []byte
							val []byte
						}{
							key: k,
							val: upgraded,
						})

						return nil
					})

					for _, snap := range newSnapshots {
						err := b.Put(snap.key, snap.val)
						if err != nil {
							logrus.Errorf("Unable to write upgraded snapshot to database %s %s", string(snap.key), err.Error())
						}

						logrus.Debugf("Finished snapshot upgrade on: %s", string(snap.key))
					}

					return nil

				})

				return err

			},
		},
		{
			Version: Version{
				0, 13, 0,
			},
			Buckets: []string{
				"app",
				"user",
			},
			Upgrader: func(old *bolt.DB) error {
				upgradeRawSnapshot := func(buff []byte) ([]byte, error) {
					oldSnap := make(map[string]interface{})
					err := json.Unmarshal(buff, &oldSnap)
					if err != nil {
						return nil, err
					}

					app, ok := oldSnap["app"].(map[string]interface{})
					if !ok {
						return nil, fmt.Errorf("Unable to upgrade snapshot. No 'app' section found.")
					}

					app["escalations"] = map[string]interface{}{}

					oldSnap["app"] = app

					return json.Marshal(&oldSnap)
				}

				err := old.Update(func(tx *bolt.Tx) error {

					b := tx.Bucket([]byte("app"))
					if b == nil {
						logrus.Warning("No config snapshots found")
						return nil
					}

					newSnapshots := make([]struct {
						key []byte
						val []byte
					}, 0, b.Stats().KeyN)

					b.ForEach(func(k, v []byte) error {
						logrus.Debugf("Starting snapshot upgrade on: %s", string(k))
						upgraded, err := upgradeRawSnapshot(v)
						if err != nil {
							logrus.Errorf("Unable to upgrade snapshot: %s %s", string(k), err.Error())
						}

						newSnapshots = append(newSnapshots, struct {
							key []byte
							val []byte
						}{
							key: k,
							val: upgraded,
						})

						return nil
					})

					for _, snap := range newSnapshots {
						err := b.Put(snap.key, snap.val)
						if err != nil {
							logrus.Errorf("Unable to write upgraded snapshot to database %s %s", string(snap.key), err.Error())
						}

						logrus.Debugf("Finished snapshot upgrade on: %s", string(snap.key))
					}

					return nil

				})

				return err

			},
		},
	}
)

var (
	Current = Version{
		Major: 0,
		Minor: 15,
		Patch: 1,
	}

	First = Version{
		0, 10, 4,
	}
)

var (
	// BucketNames holds the names of the buckets used to store versioned configs
	BucketNames = []string{
		"app",
		"user",
	}
)