1565757771

Committed 29 Nov 2024 07:56AM UTC coverage: 87.019%. Remained the same

Build # 1565757771

Build Type

push

gitlab-ci

Committed by

web-flow

Commit Message

Merge pull request #434 from alfrunes/1.22.x

chore(deps): Upgrade golang to latest

Run Details

2869 of 3297 relevant lines covered (87.02%)

131.0 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

93.1

/store/mongo/migration_1_1_4.go

// Copyright 2021 Northern.tech AS
//
//    Licensed under the Apache License, Version 2.0 (the "License");
//    you may not use this file except in compliance with the License.
//    You may obtain a copy of the License at
//
//        http://www.apache.org/licenses/LICENSE-2.0
//
//    Unless required by applicable law or agreed to in writing, software
//    distributed under the License is distributed on an "AS IS" BASIS,
//    WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
//    See the License for the specific language governing permissions and
//    limitations under the License.

package mongo

import (
        "context"

        "github.com/mendersoftware/go-lib-micro/mongo/migrate"
        mstore "github.com/mendersoftware/go-lib-micro/store"
        "github.com/pkg/errors"
        "go.mongodb.org/mongo-driver/bson"
        "go.mongodb.org/mongo-driver/mongo"
        mopts "go.mongodb.org/mongo-driver/mongo/options"
)

const (
        OldDbUniqueEmailIndexName = "uniqueEmail"
)

type migration_1_1_4 struct {
        ds  *DataStoreMongo
        ctx context.Context
}

const ErrCodeIndexOptionsError = 85

func (m *migration_1_1_4) Up(from migrate.Version) error {
        c := m.ds.client.Database(mstore.DbFromContext(m.ctx, DbName)).
                Collection(DbUsersColl)

        idxUsers := c.Indexes()

        // create new index with predictable name
        indexOptions := mopts.Index()
        indexOptions.SetUnique(true)
        indexOptions.SetName(DbUniqueEmailIndexName)

        uniqueEmailIndex := mongo.IndexModel{
                Keys:    bson.D{{Key: DbUserEmail, Value: 1}},
                Options: indexOptions,
        }

        _, err := idxUsers.CreateOne(m.ctx, uniqueEmailIndex)
        if err != nil {
                if mgoErr, ok := err.(mongo.CommandError); ok {
                        if mgoErr.Code == ErrCodeIndexOptionsError {
                                _, e := idxUsers.DropOne(m.ctx, OldDbUniqueEmailIndexName)
                                if e != nil {
                                        return errors.Wrap(err, e.Error())
                                }
                                _, err = idxUsers.CreateOne(m.ctx, uniqueEmailIndex)
                        }
                }
        }

        return err
}

func (m *migration_1_1_4) Version() migrate.Version {
        return migrate.MakeVersion(1, 1, 4)
}

1	// Copyright 2021 Northern.tech AS
2	//
3	// Licensed under the Apache License, Version 2.0 (the "License");
4	// you may not use this file except in compliance with the License.
5	// You may obtain a copy of the License at
6	//
7	// http://www.apache.org/licenses/LICENSE-2.0
8	//
9	// Unless required by applicable law or agreed to in writing, software
10	// distributed under the License is distributed on an "AS IS" BASIS,
11	// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12	// See the License for the specific language governing permissions and
13	// limitations under the License.
14
15	package mongo
16
17	import (
18	"context"
19
20	"github.com/mendersoftware/go-lib-micro/mongo/migrate"
21	mstore "github.com/mendersoftware/go-lib-micro/store"
22	"github.com/pkg/errors"
23	"go.mongodb.org/mongo-driver/bson"
24	"go.mongodb.org/mongo-driver/mongo"
25	mopts "go.mongodb.org/mongo-driver/mongo/options"
26	)
27
28	const (
29	OldDbUniqueEmailIndexName = "uniqueEmail"
30	)
31
32	type migration_1_1_4 struct {
33	ds *DataStoreMongo
34	ctx context.Context
35	}
36
37	const ErrCodeIndexOptionsError = 85
38
39	func (m *migration_1_1_4) Up(from migrate.Version) error {	248✔
40	c := m.ds.client.Database(mstore.DbFromContext(m.ctx, DbName)).	248✔
41	Collection(DbUsersColl)	248✔
42		248✔
43	idxUsers := c.Indexes()	248✔
44		248✔
45	// create new index with predictable name	248✔
46	indexOptions := mopts.Index()	248✔
47	indexOptions.SetUnique(true)	248✔
48	indexOptions.SetName(DbUniqueEmailIndexName)	248✔
49		248✔
50	uniqueEmailIndex := mongo.IndexModel{	248✔
51	Keys: bson.D{{Key: DbUserEmail, Value: 1}},	248✔
52	Options: indexOptions,	248✔
53	}	248✔
54		248✔
55	_, err := idxUsers.CreateOne(m.ctx, uniqueEmailIndex)	248✔
56	if err != nil {	250✔
57	if mgoErr, ok := err.(mongo.CommandError); ok {	4✔
58	if mgoErr.Code == ErrCodeIndexOptionsError {	4✔
59	_, e := idxUsers.DropOne(m.ctx, OldDbUniqueEmailIndexName)	2✔
60	if e != nil {	2✔
61	return errors.Wrap(err, e.Error())	×
62	}	×
63	_, err = idxUsers.CreateOne(m.ctx, uniqueEmailIndex)	2✔
64	}
65	}
66	}
67
68	return err	248✔
69	}
70
71	func (m *migration_1_1_4) Version() migrate.Version {	768✔
72	return migrate.MakeVersion(1, 1, 4)	768✔
73	}	768✔

mendersoftware / useradm / 1565757771

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous