GCC Code Coverage Report

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