1197570064

Committed 01 Mar 2024 06:24PM UTC coverage: 52.222% (-28.4%) from 80.645%

Build # 1197570064

Build Type

Pull #998

gitlab-ci

Committed by

web-flow

Commit Message

chore: bump github.com/Azure/azure-sdk-for-go/sdk/azcore

Bumps [github.com/Azure/azure-sdk-for-go/sdk/azcore](https://github.com/Azure/azure-sdk-for-go) from 1.9.1 to 1.10.0.
- [Release notes](https://github.com/Azure/azure-sdk-for-go/releases)
- [Changelog](https://github.com/Azure/azure-sdk-for-go/blob/main/documentation/release.md)
- [Commits](https://github.com/Azure/azure-sdk-for-go/compare/sdk/azcore/v1.9.1...sdk/azcore/v1.10.0)

---
updated-dependencies:
- dependency-name: github.com/Azure/azure-sdk-for-go/sdk/azcore
  dependency-type: direct:production
  update-type: version-update:semver-minor
...

Signed-off-by: dependabot[bot] <support@github.com>

Pull Request Pull Request #998: chore: bump github.com/Azure/azure-sdk-for-go/sdk/azcore from 1.9.1 to 1.10.0

Run Details

5218 of 9992 relevant lines covered (52.22%)

0.55 hits per line

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

87.5

/store/mongo/datastore_mongo_last_status.go

// Copyright 2023 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/pkg/errors"
        "go.mongodb.org/mongo-driver/bson"
        mopts "go.mongodb.org/mongo-driver/mongo/options"

        "github.com/mendersoftware/go-lib-micro/identity"
        mstore "github.com/mendersoftware/go-lib-micro/store"

        "github.com/mendersoftware/deployments/model"
)

var (
        ErrTenantRequired = errors.New("tenant id is required")
)

func (db *DataStoreMongo) SaveLastDeviceDeploymentStatus(
        ctx context.Context,
        deviceDeployment model.DeviceDeployment,
) error {
        tenantId := ""
        id := identity.FromContext(ctx)
        if id != nil {
                tenantId = id.Tenant
        }
        filter := bson.M{
                "_id": deviceDeployment.DeviceId,
        }

        lastStatus := model.DeviceDeploymentLastStatus{
                DeviceId:               deviceDeployment.DeviceId,
                DeploymentId:           deviceDeployment.DeploymentId,
                DeviceDeploymentId:     deviceDeployment.Id,
                DeviceDeploymentStatus: deviceDeployment.Status,
                TenantId:               tenantId,
        }

        database := db.client.Database(mstore.DbFromContext(ctx, DatabaseName))
        collDevs := database.Collection(CollectionDevicesLastStatus)
        var err error
        replaceOptions := mopts.Replace()
        replaceOptions.SetUpsert(true)
        _, err = collDevs.ReplaceOne(ctx, filter, lastStatus, replaceOptions)
        return err
}

func (db *DataStoreMongo) GetLastDeviceDeploymentStatus(
        ctx context.Context,
        devicesIds []string,
) ([]model.DeviceDeploymentLastStatus, error) {
        database := db.client.Database(mstore.DbFromContext(ctx, DatabaseName))
        collDevs := database.Collection(CollectionDevicesLastStatus)

        tenantId := ""
        id := identity.FromContext(ctx)
        if id != nil && id.Tenant != "" {
                tenantId = id.Tenant
        }
        filter := bson.M{
                "_id":              bson.M{"$in": devicesIds},
                StorageKeyTenantId: tenantId,
        }
        var statuses []model.DeviceDeploymentLastStatus
        cursor, err := collDevs.Find(ctx, filter)
        if err != nil {
                return statuses, err
        }

        err = cursor.All(ctx, &statuses)
        if err != nil {
                return statuses, err
        }

        return statuses, err
}

1	// Copyright 2023 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	package mongo
15
16	import (
17	"context"
18
19	"github.com/pkg/errors"
20	"go.mongodb.org/mongo-driver/bson"
21	mopts "go.mongodb.org/mongo-driver/mongo/options"
22
23	"github.com/mendersoftware/go-lib-micro/identity"
24	mstore "github.com/mendersoftware/go-lib-micro/store"
25
26	"github.com/mendersoftware/deployments/model"
27	)
28
29	var (
30	ErrTenantRequired = errors.New("tenant id is required")
31	)
32
33	func (db *DataStoreMongo) SaveLastDeviceDeploymentStatus(
34	ctx context.Context,
35	deviceDeployment model.DeviceDeployment,
36	) error {	1✔
37	tenantId := ""	1✔
38	id := identity.FromContext(ctx)	1✔
39	if id != nil {	2✔
40	tenantId = id.Tenant	1✔
41	}	1✔
42	filter := bson.M{	1✔
43	"_id": deviceDeployment.DeviceId,	1✔
44	}	1✔
45		1✔
46	lastStatus := model.DeviceDeploymentLastStatus{	1✔
47	DeviceId: deviceDeployment.DeviceId,	1✔
48	DeploymentId: deviceDeployment.DeploymentId,	1✔
49	DeviceDeploymentId: deviceDeployment.Id,	1✔
50	DeviceDeploymentStatus: deviceDeployment.Status,	1✔
51	TenantId: tenantId,	1✔
52	}	1✔
53		1✔
54	database := db.client.Database(mstore.DbFromContext(ctx, DatabaseName))	1✔
55	collDevs := database.Collection(CollectionDevicesLastStatus)	1✔
56	var err error	1✔
57	replaceOptions := mopts.Replace()	1✔
58	replaceOptions.SetUpsert(true)	1✔
59	_, err = collDevs.ReplaceOne(ctx, filter, lastStatus, replaceOptions)	1✔
60	return err	1✔
61	}
62
63	func (db *DataStoreMongo) GetLastDeviceDeploymentStatus(
64	ctx context.Context,
65	devicesIds []string,
66	) ([]model.DeviceDeploymentLastStatus, error) {	1✔
67	database := db.client.Database(mstore.DbFromContext(ctx, DatabaseName))	1✔
68	collDevs := database.Collection(CollectionDevicesLastStatus)	1✔
69		1✔
70	tenantId := ""	1✔
71	id := identity.FromContext(ctx)	1✔
72	if id != nil && id.Tenant != "" {	1✔
73	tenantId = id.Tenant	×
74	}	×
75	filter := bson.M{	1✔
76	"_id": bson.M{"$in": devicesIds},	1✔
77	StorageKeyTenantId: tenantId,	1✔
78	}	1✔
79	var statuses []model.DeviceDeploymentLastStatus	1✔
80	cursor, err := collDevs.Find(ctx, filter)	1✔
81	if err != nil {	1✔
82	return statuses, err	×
83	}	×
84
85	err = cursor.All(ctx, &statuses)	1✔
86	if err != nil {	1✔
87	return statuses, err	×
88	}	×
89
90	return statuses, err	1✔
91	}

mendersoftware / deployments / 1197570064

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