GCC Code Coverage Report

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