9271533862

Committed 28 May 2024 02:47PM UTC coverage: 60.301% (-2.3%) from 62.648%

Build # 9271533862

Build Type

Pull #1359

github

Committed by

web-flow

Commit Message

Merge 21e9a049a into 7502bc247

Pull Request Pull Request #1359: sync: Add a protobuf for the existing sync protocol

Run Details

4912 of 12254 branches covered (40.08%)

Branch coverage included in aggregate %.

0 of 287 new or added lines in 5 files covered. (0.0%)

97 existing lines in 6 files now uncovered.

16707 of 23598 relevant lines covered (70.8%)

7054.72 hits per line

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

0.0

/Source/santasyncservice/SNTSyncPostflight.mm

/// Copyright 2015 Google Inc. All rights reserved.
///
/// 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.

#import "Source/santasyncservice/SNTSyncPostflight.h"

#import <MOLXPCConnection/MOLXPCConnection.h>

#import "Source/common/SNTSyncConstants.h"
#import "Source/common/SNTXPCControlInterface.h"
#import "Source/santasyncservice/SNTSyncState.h"

#include <google/protobuf/arena.h>
#include "Source/santasyncservice/syncv1.pb.h"
namespace pbv1 = ::santa::sync::v1;

@implementation SNTSyncPostflight

- (NSURL *)stageURL {
  NSString *stageName = [@"postflight" stringByAppendingFormat:@"/%@", self.syncState.machineID];
  return [NSURL URLWithString:stageName relativeToURL:self.syncState.syncBaseURL];
}

- (BOOL)sync {
  google::protobuf::Arena arena;
  auto req = google::protobuf::Arena::Create<::pbv1::PostflightRequest>(&arena);
  req->set_rules_received(self.syncState.rulesReceived);
  req->set_rules_processed(self.syncState.rulesProcessed);

  [self performRequest:[self requestWithMessage:req]];

  id<SNTDaemonControlXPC> rop = [self.daemonConn synchronousRemoteObjectProxy];

  // Set client mode if it changed
  if (self.syncState.clientMode) {
    [rop setClientMode:self.syncState.clientMode
                 reply:^{
                 }];
  }

  // Remove clean sync flag if we did a clean or clean all sync
  if (self.syncState.syncType != SNTSyncTypeNormal) {
    [rop setSyncTypeRequired:SNTSyncTypeNormal
                       reply:^{
                       }];
  }

  // Update allowlist/blocklist regexes
  if (self.syncState.allowlistRegex) {
    [rop setAllowedPathRegex:self.syncState.allowlistRegex
                       reply:^{
                       }];
  }
  if (self.syncState.blocklistRegex) {
    [rop setBlockedPathRegex:self.syncState.blocklistRegex
                       reply:^{
                       }];
  }

  if (self.syncState.blockUSBMount != nil) {
    [rop setBlockUSBMount:[self.syncState.blockUSBMount boolValue]
                    reply:^{
                    }];
  }
  if (self.syncState.remountUSBMode) {
    [rop setRemountUSBMode:self.syncState.remountUSBMode
                     reply:^{
                     }];
  }

  if (self.syncState.enableBundles) {
    [rop setEnableBundles:[self.syncState.enableBundles boolValue]
                    reply:^{
                    }];
  }

  if (self.syncState.enableTransitiveRules) {
    [rop setEnableTransitiveRules:[self.syncState.enableTransitiveRules boolValue]
                            reply:^{
                            }];
  }

  if (self.syncState.enableAllEventUpload) {
    [rop setEnableAllEventUpload:[self.syncState.enableAllEventUpload boolValue]
                           reply:^{
                           }];
  }

  if (self.syncState.disableUnknownEventUpload) {
    [rop setDisableUnknownEventUpload:[self.syncState.disableUnknownEventUpload boolValue]
                                reply:^{
                                }];
  }

  if (self.syncState.overrideFileAccessAction) {
    [rop setOverrideFileAccessAction:self.syncState.overrideFileAccessAction
                               reply:^{
                               }];
  }

  // Update last sync success
  [rop setFullSyncLastSuccess:[NSDate date]
                        reply:^{
                        }];

  return YES;
}

@end

1	/// Copyright 2015 Google Inc. All rights reserved.
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	#import "Source/santasyncservice/SNTSyncPostflight.h"
16
17	#import <MOLXPCConnection/MOLXPCConnection.h>
18
19	#import "Source/common/SNTSyncConstants.h"
20	#import "Source/common/SNTXPCControlInterface.h"
21	#import "Source/santasyncservice/SNTSyncState.h"
22
23	#include <google/protobuf/arena.h>
24	#include "Source/santasyncservice/syncv1.pb.h"
25	namespace pbv1 = ::santa::sync::v1;
26
27	@implementation SNTSyncPostflight
28
29	- (NSURL *)stageURL {	×
30	NSString *stageName = [@"postflight" stringByAppendingFormat:@"/%@", self.syncState.machineID];	×
31	return [NSURL URLWithString:stageName relativeToURL:self.syncState.syncBaseURL];	×
32	}	×
33
34	- (BOOL)sync {	×
NEW 35	google::protobuf::Arena arena;	×
NEW 36	auto req = google::protobuf::Arena::Create<::pbv1::PostflightRequest>(&arena);	×
NEW 37	req->set_rules_received(self.syncState.rulesReceived);	×
NEW 38	req->set_rules_processed(self.syncState.rulesProcessed);	×
39
NEW 40	[self performRequest:[self requestWithMessage:req]];	×
41
42	id<SNTDaemonControlXPC> rop = [self.daemonConn synchronousRemoteObjectProxy];	×
43
44	// Set client mode if it changed
45	if (self.syncState.clientMode) {	×
46	[rop setClientMode:self.syncState.clientMode	×
47	reply:^{	×
48	}];	×
49	}	×
50
51	// Remove clean sync flag if we did a clean or clean all sync
52	if (self.syncState.syncType != SNTSyncTypeNormal) {	×
53	[rop setSyncTypeRequired:SNTSyncTypeNormal	×
54	reply:^{	×
55	}];	×
56	}	×
57
58	// Update allowlist/blocklist regexes
59	if (self.syncState.allowlistRegex) {	×
60	[rop setAllowedPathRegex:self.syncState.allowlistRegex	×
61	reply:^{	×
62	}];	×
63	}	×
64	if (self.syncState.blocklistRegex) {	×
65	[rop setBlockedPathRegex:self.syncState.blocklistRegex	×
66	reply:^{	×
67	}];	×
68	}	×
69
70	if (self.syncState.blockUSBMount != nil) {	×
71	[rop setBlockUSBMount:[self.syncState.blockUSBMount boolValue]	×
72	reply:^{	×
73	}];	×
74	}	×
75	if (self.syncState.remountUSBMode) {	×
76	[rop setRemountUSBMode:self.syncState.remountUSBMode	×
77	reply:^{	×
78	}];	×
79	}	×
80
81	if (self.syncState.enableBundles) {	×
82	[rop setEnableBundles:[self.syncState.enableBundles boolValue]	×
83	reply:^{	×
84	}];	×
85	}	×
86
87	if (self.syncState.enableTransitiveRules) {	×
88	[rop setEnableTransitiveRules:[self.syncState.enableTransitiveRules boolValue]	×
89	reply:^{	×
90	}];	×
91	}	×
92
93	if (self.syncState.enableAllEventUpload) {	×
94	[rop setEnableAllEventUpload:[self.syncState.enableAllEventUpload boolValue]	×
95	reply:^{	×
96	}];	×
97	}	×
98
99	if (self.syncState.disableUnknownEventUpload) {	×
100	[rop setDisableUnknownEventUpload:[self.syncState.disableUnknownEventUpload boolValue]	×
101	reply:^{	×
102	}];	×
103	}	×
104
105	if (self.syncState.overrideFileAccessAction) {	×
106	[rop setOverrideFileAccessAction:self.syncState.overrideFileAccessAction	×
107	reply:^{	×
108	}];	×
109	}	×
110
111	// Update last sync success
112	[rop setFullSyncLastSuccess:[NSDate date]	×
113	reply:^{	×
114	}];	×
115
116	return YES;	×
117	}	×
118
119	@end

google / santa / 9271533862

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