GCC Code Coverage Report

Directory: cvmfs/
File: cvmfs/notify/messages.cc
Date: 2025-04-20 02:34:28
Exec Total Coverage
Lines: 29 43 67.4%
Branches: 38 113 33.6%
Line Branch Exec Source
1 /**
2 * This file is part of the CernVM File System.
3 */
4
5 #include "messages.h"
6
7 #include <cassert>
8
9 #include "json.h"
10 #include "json_document.h"
11
12 #include "util/logging.h"
13 #include "util/pointer.h"
14 #include "util/string.h"
15
16 namespace {
17
18 const LogFacilities& kLogError = DefaultLogging::error;
19
20 } // namespace
21
22 namespace notify {
23
24 namespace msg {
25
26 3 Activity::Activity() : version_(0), timestamp_(), repository_(), manifest_() {}
27
28 6 Activity::~Activity() {}
29
30 1 bool Activity::operator==(const Activity& other) const {
31
1/2
✓ Branch 0 taken 1 times.
✗ Branch 1 not taken.
 1 return (this->version_ == other.version_) &&
32
1/2
✓ Branch 1 taken 1 times.
✗ Branch 2 not taken.
 2 (this->timestamp_ == other.timestamp_) &&
33
2/4
✓ Branch 0 taken 1 times.
✗ Branch 1 not taken.
✓ Branch 3 taken 1 times.
✗ Branch 4 not taken.
 3 (this->repository_ == other.repository_) &&
34 2 (this->manifest_ == other.manifest_);
35 }
36
37 1 void Activity::ToJSONString(std::string* s) {
38
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 1 times.
 1 assert(s);
39
40
3/6
✓ Branch 1 taken 1 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 1 times.
✗ Branch 5 not taken.
✓ Branch 7 taken 1 times.
✗ Branch 8 not taken.
 2 *s = "{ \"version\" : " + StringifyInt(version_) + ", \"timestamp\" : \"" +
41
2/4
✓ Branch 1 taken 1 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 1 times.
✗ Branch 5 not taken.
 2 timestamp_ + "\", \"type\" : \"activity\", \"repository\" : \"" +
42
4/8
✓ Branch 2 taken 1 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 1 times.
✗ Branch 6 not taken.
✓ Branch 8 taken 1 times.
✗ Branch 9 not taken.
✓ Branch 11 taken 1 times.
✗ Branch 12 not taken.
 3 repository_ + "\", \"manifest\" : \"" + Base64(manifest_) + "\"}";
43 1 }
44
45 2 bool Activity::FromJSONString(const std::string& s) {
46
2/4
✓ Branch 1 taken 2 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 2 times.
✗ Branch 5 not taken.
 2 const UniquePtr<JsonDocument> m(JsonDocument::Create(s));
47
1/2
✗ Branch 1 not taken.
✓ Branch 2 taken 2 times.
 2 if (!m.IsValid()) {
48 ✗ LogCvmfs(kLogCvmfs, kLogError, "Could not create JSON document.");
49 ✗ return false;
50 }
51
52 2 std::string message_type;
53
3/6
✓ Branch 2 taken 2 times.
✗ Branch 3 not taken.
✓ Branch 7 taken 2 times.
✗ Branch 8 not taken.
✗ Branch 11 not taken.
✓ Branch 12 taken 2 times.
 2 if (!GetFromJSON(m->root(), "type", &message_type)) {
54 ✗ LogCvmfs(kLogCvmfs, kLogError, "Could not read message type.");
55 ✗ return false;
56 }
57
2/4
✓ Branch 1 taken 2 times.
✗ Branch 2 not taken.
✗ Branch 3 not taken.
✓ Branch 4 taken 2 times.
 2 if (message_type != "activity") {
58 ✗ LogCvmfs(kLogCvmfs, kLogError, "Invalid message type: %s.",
59 message_type.c_str());
60 ✗ return false;
61 }
62
63
3/6
✓ Branch 2 taken 2 times.
✗ Branch 3 not taken.
✓ Branch 7 taken 2 times.
✗ Branch 8 not taken.
✗ Branch 11 not taken.
✓ Branch 12 taken 2 times.
 2 if (!GetFromJSON(m->root(), "version", &version_)) {
64 ✗ LogCvmfs(kLogCvmfs, kLogError, "Could not read version.");
65 ✗ return false;
66 }
67
68
4/6
✓ Branch 2 taken 2 times.
✗ Branch 3 not taken.
✓ Branch 7 taken 2 times.
✗ Branch 8 not taken.
✓ Branch 11 taken 1 times.
✓ Branch 12 taken 1 times.
 2 if (!GetFromJSON(m->root(), "timestamp", &timestamp_)) {
69
1/5
✗ Branch 0 not taken.
✓ Branch 1 taken 1 times.
✗ Branch 2 not taken.
✗ Branch 3 not taken.
✗ Branch 4 not taken.
 1 LogCvmfs(kLogCvmfs, kLogError, "Could not read timestamp.");
70 1 return false;
71 }
72
3/6
✓ Branch 2 taken 1 times.
✗ Branch 3 not taken.
✓ Branch 7 taken 1 times.
✗ Branch 8 not taken.
✗ Branch 11 not taken.
✓ Branch 12 taken 1 times.
 1 if (!GetFromJSON(m->root(), "repository", &repository_)) {
73 ✗ LogCvmfs(kLogCvmfs, kLogError, "Could not read repository.");
74 ✗ return false;
75 }
76 1 std::string manifest_b64;
77
3/6
✓ Branch 2 taken 1 times.
✗ Branch 3 not taken.
✓ Branch 7 taken 1 times.
✗ Branch 8 not taken.
✗ Branch 11 not taken.
✓ Branch 12 taken 1 times.
 1 if (!GetFromJSON(m->root(), "manifest", &manifest_b64)) {
78 ✗ LogCvmfs(kLogCvmfs, kLogError, "Could not read manifest.");
79 ✗ return false;
80 }
81
2/4
✓ Branch 1 taken 1 times.
✗ Branch 2 not taken.
✗ Branch 3 not taken.
✓ Branch 4 taken 1 times.
 1 if (!Debase64(manifest_b64, &manifest_)) {
82 ✗ LogCvmfs(kLogCvmfs, kLogError, "Could not debase64 manifest.");
83 ✗ return false;
84 }
85
86 1 return true;
87 2 }
88
89 } // namespace msg
90
91 } // namespace notify
92