]> git.saurik.com Git - apple/security.git/blob - OSX/sec/securityd/Regressions/secd-70-engine.c
Security-57336.1.9.tar.gz
[apple/security.git] / OSX / sec / securityd / Regressions / secd-70-engine.c
1 /*
2 * Copyright (c) 2014 Apple Inc. All Rights Reserved.
3 *
4 * @APPLE_LICENSE_HEADER_START@
5 *
6 * This file contains Original Code and/or Modifications of Original Code
7 * as defined in and that are subject to the Apple Public Source License
8 * Version 2.0 (the 'License'). You may not use this file except in
9 * compliance with the License. Please obtain a copy of the License at
10 * http://www.opensource.apple.com/apsl/ and read it before using this
11 * file.
12 *
13 * The Original Code and all software distributed under the License are
14 * distributed on an 'AS IS' basis, WITHOUT WARRANTY OF ANY KIND, EITHER
15 * EXPRESS OR IMPLIED, AND APPLE HEREBY DISCLAIMS ALL SUCH WARRANTIES,
16 * INCLUDING WITHOUT LIMITATION, ANY WARRANTIES OF MERCHANTABILITY,
17 * FITNESS FOR A PARTICULAR PURPOSE, QUIET ENJOYMENT OR NON-INFRINGEMENT.
18 * Please see the License for the specific language governing rights and
19 * limitations under the License.
20 *
21 * @APPLE_LICENSE_HEADER_END@
22 */
23
24
25 // Test syncing between SecItemDataSource and SOSTestDataSource
26
27 #include <SOSCircle/Regressions/SOSTestDevice.h>
28 #include <SOSCircle/Regressions/SOSTestDataSource.h>
29 #include "secd_regressions.h"
30 #include "SecdTestKeychainUtilities.h"
31
32 #include <Security/SecureObjectSync/SOSEngine.h>
33 #include <Security/SecureObjectSync/SOSPeer.h>
34 #include <Security/SecBase64.h>
35 #include <Security/SecItem.h>
36 #include <Security/SecItemPriv.h>
37 #include <corecrypto/ccsha2.h>
38 #include <securityd/SecItemServer.h>
39 #include <securityd/SecItemDataSource.h>
40 #include <utilities/SecCFWrappers.h>
41 #include <utilities/SecIOFormat.h>
42 #include <utilities/SecFileLocations.h>
43
44 #include <AssertMacros.h>
45 #include <stdint.h>
46
47 static int kTestTestCount = 1306;
48
49 __unused static bool SOSCircleHandleCircleWithLock(SOSEngineRef engine, CFStringRef myID, CFDataRef message, CFErrorRef *error) {
50
51 CFMutableArrayRef trustedPeers = CFArrayCreateMutableForCFTypes(kCFAllocatorDefault);
52 CFMutableArrayRef untrustedPeers = CFArrayCreateMutableForCFTypes(kCFAllocatorDefault);
53 CFStringRef peerID = NULL;
54 const uint8_t expected[20] = { 0xea, 0x6c, 0x01, 0x4d,
55 0xc7, 0x2d, 0x6f, 0x8c,
56 0xcd, 0x1e, 0xd9, 0x2a,
57 0xce, 0x1d, 0x41, 0xf0,
58 0xd8, 0xde, 0x89, 0x57 };
59
60 const char resultSize = sizeof(expected);
61
62 CFDataRef coder = CFDataCreate(kCFAllocatorDefault, expected, resultSize);
63 CFArrayForEachC(SOSEngineGetPeerIDs(engine), peerID){
64 CFArrayAppendValue(trustedPeers, peerID);
65 SOSEngineSetCoderData(engine, peerID, coder, error);
66 };
67 CFReleaseNull(coder);
68
69 CFShow(trustedPeers);
70 // all trusted
71 SOSEngineCircleChanged(engine, myID,trustedPeers, untrustedPeers);
72
73 // make first peer untrusted
74 peerID = (CFStringRef)CFArrayGetValueAtIndex(trustedPeers, 0);
75 CFArrayAppendValue(untrustedPeers, peerID);
76 CFArrayRemoveAllValue(trustedPeers, peerID);
77 //we should see peerState cleared out except for the coder!
78 SOSEngineCircleChanged(engine, myID, trustedPeers, untrustedPeers);
79
80 CFArrayAppendValue(trustedPeers, peerID);
81 CFArrayRemoveAllValue(untrustedPeers, peerID);
82
83
84 return true;
85 }
86
87 static void testsync3(const char *name, const char *test_directive, const char *test_reason) {
88 __block int iteration=0;
89 SOSTestDeviceListTestSync(name, test_directive, test_reason, 0, false, ^bool(SOSTestDeviceRef source, SOSTestDeviceRef dest) {
90 iteration++;
91 if (iteration == 12 || iteration == 13) {
92 pass("pre-rcv %@", dest);
93 }
94 if (iteration == 19) {
95 pass("pre-send %@", source);
96 }
97 return false;
98 }, ^bool(SOSTestDeviceRef source, SOSTestDeviceRef dest, SOSMessageRef message) {
99 if (iteration == 10) {
100 pass("pre-add %@", source);
101 //SOSTestDeviceAddGenericItem(source, CFSTR("test_account"), CFSTR("test service"));
102 SOSTestDeviceAddRemoteGenericItem(source, CFSTR("test_account"), CFSTR("test service"));
103 pass("post-add %@", source);
104 return true; // db changed
105 } else if (iteration == 12 || iteration == 15) {
106 pass("post-rcv %@", dest);
107 }
108 return false;
109 }, CFSTR("AAA"), CFSTR("BBB"), CFSTR("CCC"), NULL);
110 }
111
112 static void testsync2(const char *name, const char *test_directive, const char *test_reason, void (^aliceInit)(SOSDataSourceRef ds), void (^bobInit)(SOSDataSourceRef ds), CFStringRef msg, ...) {
113 __block int iteration=0;
114 SOSTestDeviceListTestSync(name, test_directive, test_reason, kSOSPeerVersion, false, ^bool(SOSTestDeviceRef source, SOSTestDeviceRef dest) {
115 if (iteration == 96) {
116 pass("%@ before message", source);
117 }
118 return false;
119 }, ^bool(SOSTestDeviceRef source, SOSTestDeviceRef dest, SOSMessageRef message) {
120 iteration++;
121 if (iteration == 60) {
122 pass("%@ before addition", source);
123 //SOSTestDeviceAddGenericItem(source, CFSTR("test_account"), CFSTR("test service"));
124 SOSTestDeviceAddRemoteGenericItem(source, CFSTR("test_account"), CFSTR("test service"));
125 pass("%@ after addition", source);
126 return true;
127 }
128 return false;
129 }, CFSTR("alice"), CFSTR("bob"), CFSTR("claire"), CFSTR("dave"),CFSTR("edward"), CFSTR("frank"), CFSTR("gary"), NULL);
130 }
131
132 static void testsync(const char *name, const char *test_directive, const char *test_reason, void (^aliceInit)(SOSDataSourceRef ds), void (^bobInit)(SOSDataSourceRef ds), ...) {
133 __block int msg_index = 0;
134 __block int last_msg_index = 0;
135 va_list args;
136 va_start(args, bobInit);
137 CFArrayRef messages = CFArrayCreateForVC(kCFAllocatorDefault, &kCFTypeArrayCallBacks, args);
138 SOSTestDeviceListTestSync(name, test_directive, test_reason, 0, false,
139 ^bool(SOSTestDeviceRef source, SOSTestDeviceRef dest) {
140 if (msg_index == 0) {
141 aliceInit(source->ds);
142 bobInit(dest->ds);
143 return true;
144 }
145 return false;
146 }, ^bool(SOSTestDeviceRef source, SOSTestDeviceRef dest, SOSMessageRef message) {
147 CFStringRef hexMsg = msg_index < CFArrayGetCount(messages) ? (CFStringRef)CFArrayGetValueAtIndex(messages, msg_index) : 0;
148 /* We are expecting a message and msg is it's digest. */
149 if (message) {
150 msg_index++;
151 CFStringRef messageDigestStr = SOSMessageCopyDigestHex(message);
152 if (hexMsg) {
153 if (CFEqual(messageDigestStr, hexMsg)) {
154 pass("%s %@ handled message [%d] %@", name, SOSEngineGetMyID(dest->ds->engine), msg_index, message);
155 } else {
156 TODO: {
157 todo("manifest caching changed");
158 fail("%s %@ received message [%d] digest %@ != %@ %@", name, SOSEngineGetMyID(dest->ds->engine), msg_index, messageDigestStr, hexMsg, message);
159 }
160 }
161 last_msg_index = msg_index;
162 } else {
163 TODO: {
164 todo("manifest caching changed");
165 fail("%s %@ sent extra message [%d] with digest %@: %@", name, SOSEngineGetMyID(source->ds->engine), msg_index, messageDigestStr, message);
166 }
167 }
168 CFReleaseSafe(messageDigestStr);
169 //SOSCircleHandleCircleWithLock(source->ds->engine, SOSEngineGetMyID(source->ds->engine), CFDataCreate(kCFAllocatorDefault, 0, 0), NULL);
170
171 }
172 return false;
173 }, CFSTR("alice"), CFSTR("bob"), NULL);
174
175 if (msg_index < CFArrayGetCount(messages)) {
176 TODO: {
177 todo("manifest caching changed");
178 fail("%s nothing sent expecting message [%d] digest %@", name, msg_index, CFArrayGetValueAtIndex(messages, msg_index));
179 }
180 } else if (last_msg_index < msg_index) {
181 TODO: {
182 todo("manifest caching changed");
183 fail("%s exchanged %d messages not in expected list", name, msg_index - last_msg_index);
184 }
185 }
186
187
188 }
189
190 #if 0
191 // Test syncing an empty circle with 1 to 10 devices and both version 0 and version 2 protocols
192 static void testsyncempty(void) {
193 CFMutableArrayRef deviceIDs = CFArrayCreateMutableForCFTypes(kCFAllocatorDefault);
194 for (int deviceIX=0; deviceIX < 10; ++deviceIX) {
195 CFStringRef deviceID = CFStringCreateWithFormat(kCFAllocatorDefault, NULL, CFSTR("%c"), 'A' + deviceIX);
196 CFArrayAppendValue(deviceIDs, deviceID);
197 CFReleaseSafe(deviceID);
198 if (deviceIX > 0) {
199 for (CFIndex version = 0; version < 3; version += 2) {
200 CFMutableDictionaryRef testDevices = SOSTestDeviceListCreate(false, version, deviceIDs);
201 SOSTestDeviceListSync("syncempty", test_directive, test_reason, testDevices, NULL, NULL);
202 SOSTestDeviceListInSync("syncempty", test_directive, test_reason, testDevices);
203 SOSTestDeviceDestroyEngine(testDevices);
204 CFReleaseSafe(testDevices);
205 }
206 }
207 }
208 CFReleaseSafe(deviceIDs);
209 }
210 #endif
211
212 static CFIndex syncmany_add(int iteration) {
213 if (iteration % 7 < 3 && iteration < 10)
214 return iteration % 17 + 200;
215 return 0;
216 }
217
218 static void testsyncmany(const char *name, const char *test_directive, const char *test_reason, int devFirst, int devCount, int version, CFIndex (*should_add)(int iteration)) {
219 CFMutableArrayRef deviceIDs = CFArrayCreateMutableForCFTypes(kCFAllocatorDefault);
220 for (int deviceIX=0; deviceIX < devCount; ++deviceIX) {
221 CFStringRef deviceID = CFStringCreateWithFormat(kCFAllocatorDefault, NULL, CFSTR("%c"), 'A' + deviceIX);
222 CFArrayAppendValue(deviceIDs, deviceID);
223 CFReleaseSafe(deviceID);
224 if (deviceIX >= devFirst) {
225 CFMutableDictionaryRef testDevices = SOSTestDeviceListCreate(false, version, deviceIDs);
226 __block int iteration = 0;
227 SOSTestDeviceListSync(name, test_directive, test_reason, testDevices, ^bool(SOSTestDeviceRef source, SOSTestDeviceRef dest) {
228 bool didAdd = false;
229 iteration++;
230 // Add 10 items in first 10 sync messages
231 CFIndex toAdd = should_add(iteration);
232 if (toAdd) {
233 CFStringRef account = CFStringCreateWithFormat(kCFAllocatorDefault, NULL, CFSTR("item%d"), iteration);
234 didAdd = SOSTestDeviceAddGenericItems(source, toAdd, account, CFSTR("testsyncmany"));
235 CFReleaseSafe(account);
236 }
237 if (iteration == 279 || iteration == 459)
238 pass("pre-send[%d] %@", iteration, source);
239
240 return didAdd;
241 }, ^bool(SOSTestDeviceRef source, SOSTestDeviceRef dest, SOSMessageRef message) {
242 if (iteration == 262)
243 pass("post-rcv[%d] %@", iteration, dest);
244
245 if (iteration == 272 || iteration == 279)
246 pass("post-send[%d] %@", iteration, source);
247
248 return false;
249 });
250 SOSTestDeviceListInSync(name, test_directive, test_reason, testDevices);
251 SOSTestDeviceDestroyEngine(testDevices);
252 CFReleaseSafe(testDevices);
253 }
254 }
255 CFReleaseSafe(deviceIDs);
256 }
257
258 static void testsync2p(void) {
259 __block int iteration = 0;
260 SOSTestDeviceListTestSync("testsync2p", test_directive, test_reason, 0, false, ^bool(SOSTestDeviceRef source, SOSTestDeviceRef dest) {
261 iteration++;
262 // Add 10 items in first 10 sync messages
263 if (iteration <= 10) {
264 CFStringRef account = CFStringCreateWithFormat(kCFAllocatorDefault, NULL, CFSTR("item%d"), iteration);
265 SOSTestDeviceAddGenericItem(source, account, CFSTR("testsync2p"));
266 CFReleaseSafe(account);
267 return true;
268 }
269 return false;
270 }, ^bool(SOSTestDeviceRef source, SOSTestDeviceRef dest, SOSMessageRef message) {
271 return false;
272 }, CFSTR("Atestsync2p"), CFSTR("Btestsync2p"), NULL);
273 }
274
275 static void synctests(void) {
276 #if 0
277 // TODO: Adding items gives us non predictable creation and mod dates so
278 // the message hashes can't be precomputed.
279 CFDictionaryRef item = CFDictionaryCreateForCFTypes
280 (0,
281 kSecClass, kSecClassGenericPassword,
282 kSecAttrAccessible, kSecAttrAccessibleWhenUnlocked,
283 kSecAttrSynchronizable, kCFBooleanTrue,
284 kSecAttrService, CFSTR("service"),
285 kSecAttrAccount, CFSTR("account"),
286 NULL);
287 SecItemAdd(item, NULL);
288 CFReleaseSafe(item);
289 #endif
290
291 SKIP:
292 {
293
294 #ifdef NO_SERVER
295 // Careful with this in !NO_SERVER, it'll destroy debug keychains.
296 WithPathInKeychainDirectory(CFSTR("keychain-2-debug.db"), ^(const char *keychain_path) {
297 unlink(keychain_path);
298 });
299
300 // Don't ever do this in !NO_SERVER, it'll destroy real keychains.
301 WithPathInKeychainDirectory(CFSTR("keychain-2.db"), ^(const char *keychain_path) {
302 unlink(keychain_path);
303 });
304
305 void kc_dbhandle_reset(void);
306 kc_dbhandle_reset();
307 #else
308 skip("Keychain not reset", kTestTestCount, false);
309 #endif
310
311 testsync3("secd_70_engine3", test_directive, test_reason);
312
313 // Sync between 2 empty dataSources
314 testsync("secd_70_engine", test_directive, test_reason,
315 ^ (SOSDataSourceRef dataSource) {},
316 ^ (SOSDataSourceRef dataSource) {},
317 CFSTR("2AF312E092D67308A0083DFFBF2B6B754B967864"),
318 CFSTR("2AF312E092D67308A0083DFFBF2B6B754B967864"),
319 CFSTR("2AF312E092D67308A0083DFFBF2B6B754B967864"),
320 CFSTR("2AF312E092D67308A0083DFFBF2B6B754B967864"),
321 NULL);
322
323 // Sync a dataSource with one object to an empty dataSource
324 testsync("secd_70_engine-alice1", test_directive, test_reason,
325 ^ (SOSDataSourceRef dataSource) {
326 __block CFErrorRef error = NULL;
327 SOSObjectRef object = SOSDataSourceCreateGenericItem(dataSource, CFSTR("test_account"), CFSTR("test service"));
328 // TODO: Needs to be a SecDBItemRef for the SecItemDataSource...
329 ok(SOSDataSourceWith(dataSource, &error, ^(SOSTransactionRef txn, bool *commit) {
330 ok(SOSDataSourceMergeObject(dataSource, txn, object, NULL, &error), "dataSource %@ added object %@", SOSEngineGetMyID(dataSource->engine), error);
331 }), "ds transaction failed %@", error);
332 CFReleaseSafe(object);
333 CFReleaseNull(error);
334 },
335 ^ (SOSDataSourceRef dataSource) {},
336 CFSTR("DDDB2DCEB7B36F0757F400251ECD11E377A0DCE8"),
337 CFSTR("B2777CC898AE381B3F375B27E4FD9757F6CE9948"),
338 CFSTR("CB67BF9ECF00DC7664834DE7A2D7CC1523D25341"),
339 CFSTR("ADAA3ACE75ED516CB91893413EE9CC9ED04CA47B"),
340
341 //CFSTR("ADAA3ACE75ED516CB91893413EE9CC9ED04CA47B"),
342 //CFSTR("147B6C509908CC4A9FC4263973A842104A64CE01"),
343 //CFSTR("019B494F3C06B48BB02C280AF1E19AD861A7003C"),
344 //CFSTR("ADAA3ACE75ED516CB91893413EE9CC9ED04CA47B"),
345 NULL);
346
347 // Sync a dataSource with one object to another dataSource with the same object
348 testsync("secd_70_engine-alice1bob1", test_directive, test_reason,
349 ^ (SOSDataSourceRef dataSource) {
350 #if 0
351 CFErrorRef error = NULL;
352 // TODO: Needs to be a SecDBItemRef for the SecItemDataSource...
353 CFDictionaryRef object = SOSDataSourceCreateGenericItem(dataSource, CFSTR("test_account"), CFSTR("test service"));
354 ok(SOSDataSourceMergeObject(dataSource, object, NULL, &error), "dataSource %@ added object %@", SOSEngineGetMyID(dataSource->engine), error);
355 CFReleaseSafe(object);
356 CFReleaseNull(error);
357 #endif
358 },
359 ^ (SOSDataSourceRef dataSource) {
360 __block CFErrorRef error = NULL;
361 SOSObjectRef object = SOSDataSourceCreateGenericItem(dataSource, CFSTR("test_account"), CFSTR("test service"));
362 ok(SOSDataSourceWith(dataSource, &error, ^(SOSTransactionRef txn, bool *commit) {
363 ok(SOSDataSourceMergeObject(dataSource, txn, object, NULL, &error), "dataSource %@ added object %@", SOSEngineGetMyID(dataSource->engine), error);
364 }), "ds transaction failed %@", error);
365 CFReleaseSafe(object);
366 CFReleaseNull(error);
367 },
368 CFSTR("2AF312E092D67308A0083DFFBF2B6B754B967864"),
369 CFSTR("CB67BF9ECF00DC7664834DE7A2D7CC1523D25341"),
370 CFSTR("ADAA3ACE75ED516CB91893413EE9CC9ED04CA47B"),
371
372 //CFSTR("ADAA3ACE75ED516CB91893413EE9CC9ED04CA47B"),
373 //CFSTR("ADAA3ACE75ED516CB91893413EE9CC9ED04CA47B"),
374 //CFSTR("ADAA3ACE75ED516CB91893413EE9CC9ED04CA47B"),
375 NULL);
376
377 // Sync a dataSource with one object to another dataSource with the same object
378 testsync("secd_70_engine-alice1bob2", test_directive, test_reason,
379 ^ (SOSDataSourceRef dataSource) {
380 #if 0
381 CFErrorRef error = NULL;
382 // TODO: Needs to be a SecDBItemRef for the SecItemDataSource...
383 SOSObjectRef object = SOSDataSourceCreateGenericItem(dataSource, CFSTR("test_account"), CFSTR("test service"));
384 ok(SOSDataSourceMergeObject(dataSource, object, NULL, &error), "dataSource %@ added object %@", SOSEngineGetMyID(dataSource->engine), error);
385 CFReleaseSafe(object);
386 CFReleaseNull(error);
387 #endif
388 },
389 ^ (SOSDataSourceRef dataSource) {
390 __block CFErrorRef error = NULL;
391 __block SOSObjectRef object = SOSDataSourceCreateGenericItem(dataSource, CFSTR("test_account"), CFSTR("test service"));
392 ok(SOSDataSourceWith(dataSource, &error, ^(SOSTransactionRef txn, bool *commit) {
393 ok(SOSDataSourceMergeObject(dataSource, txn, object, NULL, &error), "dataSource %@ added object %@", SOSEngineGetMyID(dataSource->engine), error);
394 CFReleaseSafe(object);
395 CFReleaseNull(error);
396 object = SOSDataSourceCreateGenericItem(dataSource, CFSTR("account1"), CFSTR("service1"));
397 ok(SOSDataSourceMergeObject(dataSource, txn, object, NULL, &error), "dataSource %@ added object %@", SOSEngineGetMyID(dataSource->engine), error);
398 CFReleaseSafe(object);
399 }), "ds transaction failed %@", error);
400 CFReleaseNull(error);
401 },
402 CFSTR("2AF312E092D67308A0083DFFBF2B6B754B967864"),
403 CFSTR("270EB3953B2E1E295F668CFC27CBB7137991A4BE"),
404 CFSTR("D1B3944E3084425F41B2C2EA0BE82170E10AA37D"),
405
406 //CFSTR("ADAA3ACE75ED516CB91893413EE9CC9ED04CA47B"),
407 //CFSTR("D4049A1063CFBF7CAF8424E13DE3CE926FF5856C"),
408 //CFSTR("9624EA855BBED6B668868BB723443E804D04F6A1"),
409 //CFSTR("063E097CCD4FEB7F3610ED12B3DA828467314846"),
410 //CFSTR("D1B3944E3084425F41B2C2EA0BE82170E10AA37D"),
411 NULL);
412
413 // Sync a dataSource with a tombstone object to another dataSource with the same object
414 TODO: {
415 todo("<rdar://problem/14049022> Test case in sd-70-engine fails due to need for RowID");
416 testsync("secd_70_engine-update", test_directive, test_reason,
417 ^ (SOSDataSourceRef dataSource) {
418 __block CFErrorRef error = NULL;
419 const char *password = "password1";
420 CFDataRef data = CFDataCreate(kCFAllocatorDefault, (const UInt8 *)password, strlen(password));
421 // TODO: Needs to be a SecDBItemRef for the SecItemDataSource...
422 SOSObjectRef object_to_find = SOSDataSourceCreateGenericItemWithData(dataSource, CFSTR("test_account"), CFSTR("test service"), true, NULL);
423 SOSObjectRef object = SOSDataSourceCopyObject(dataSource, object_to_find, &error);
424 SOSObjectRef old_object = NULL;
425 SKIP: {
426 skip("no object", 1, ok(object, "Finding object %@, error: %@", object_to_find, error));
427 CFReleaseNull(data);
428 // TODO: Needs to be a SecDBItemRef for the SecItemDataSource...
429 old_object = SOSDataSourceCreateGenericItem(dataSource, CFSTR("test_account"), CFSTR("test service"));
430 ok(SOSDataSourceWith(dataSource, &error, ^(SOSTransactionRef txn, bool *commit) {
431 ok(SOSDataSourceMergeObject(dataSource, txn, object, NULL, &error), "dataSource %@ update object %@", SOSEngineGetMyID(dataSource->engine), error);
432 }), "ds transaction failed %@", error);
433 }
434 CFReleaseSafe(data);
435 CFReleaseSafe(old_object);
436 CFReleaseSafe(object);
437 CFReleaseNull(error);
438 },
439 ^ (SOSDataSourceRef dataSource) {
440 __block CFErrorRef error = NULL;
441 __block SOSObjectRef object = SOSDataSourceCreateGenericItem(dataSource, CFSTR("test_account"), CFSTR("test service"));
442 ok(SOSDataSourceWith(dataSource, &error, ^(SOSTransactionRef txn, bool *commit) {
443 ok(SOSDataSourceMergeObject(dataSource, txn, object, NULL, &error), "dataSource %@ added object %@", SOSEngineGetMyID(dataSource->engine), error);
444 CFReleaseSafe(object);
445 CFReleaseNull(error);
446 object = SOSDataSourceCreateGenericItem(dataSource, CFSTR("account1"), CFSTR("service1"));
447 ok(SOSDataSourceMergeObject(dataSource, txn, object, NULL, &error), "dataSource %@ added object %@", SOSEngineGetMyID(dataSource->engine), error);
448 CFReleaseSafe(object);
449 }), "ds transaction failed %@", error);
450 CFReleaseNull(error);
451 },
452 CFSTR("2AF312E092D67308A0083DFFBF2B6B754B967864"),
453 CFSTR("270EB3953B2E1E295F668CFC27CBB7137991A4BE"),
454 CFSTR("D1B3944E3084425F41B2C2EA0BE82170E10AA37D"),
455
456 //CFSTR("5D07A221A152D6D6C5F1919189F259A7278A08C5"),
457 //CFSTR("D4049A1063CFBF7CAF8424E13DE3CE926FF5856C"),
458 //CFSTR("137FD34E9BF11B4BA0620E8EBFAB8576BCCCF294"),
459 //CFSTR("5D07A221A152D6D6C5F1919189F259A7278A08C5"),
460 NULL);
461 }
462
463 // Sync a dataSource with one object to another dataSource with the same object
464 testsync("secd_70_engine-foreign-add", test_directive, test_reason,
465 ^ (SOSDataSourceRef dataSource) {
466 },
467 ^ (SOSDataSourceRef dataSource) {
468 __block CFErrorRef error = NULL;
469 const char *password = "password1";
470 CFDataRef data = CFDataCreate(kCFAllocatorDefault, (const UInt8 *)password, strlen(password));
471 __block SOSObjectRef object = SOSDataSourceCreateGenericItemWithData(dataSource, CFSTR("test_account"), CFSTR("test service"), false, data);
472 CFReleaseSafe(data);
473 ok(SOSDataSourceWith(dataSource, &error, ^(SOSTransactionRef txn, bool *commit) {
474 ok(SOSDataSourceMergeObject(dataSource, txn, object, NULL, &error), "dataSource %@ added object %@", SOSEngineGetMyID(dataSource->engine), error);
475 CFReleaseSafe(object);
476 CFReleaseNull(error);
477 object = SOSDataSourceCreateGenericItem(dataSource, CFSTR("account1"), CFSTR("service1"));
478 ok(SOSDataSourceMergeObject(dataSource, txn, object, NULL, &error), "dataSource %@ added object %@", SOSEngineGetMyID(dataSource->engine), error);
479 CFReleaseSafe(object);
480 }), "ds transaction failed %@", error);
481 CFReleaseNull(error);
482 },
483 CFSTR("2AF312E092D67308A0083DFFBF2B6B754B967864"),
484 CFSTR("769F63675CEE9CB968BFD9CA48DB9079BFCAFB6C"),
485 CFSTR("818C24B9BC495940836B9C8F76517C838CEFFA98"),
486
487 //CFSTR("D1B3944E3084425F41B2C2EA0BE82170E10AA37D"),
488 //CFSTR("607EEF976943FD781CFD2B3850E6DC7979AA61EF"),
489 //CFSTR("28434CD1B90CC205460557CAC03D7F12067F2329"),
490 //CFSTR("D1B3944E3084425F41B2C2EA0BE82170E10AA37D"),
491 NULL);
492 }
493
494 // Sync between 2 empty dataSources
495 testsync2("secd_70_engine2", test_directive, test_reason,
496 ^ (SOSDataSourceRef dataSource) {},
497 ^ (SOSDataSourceRef dataSource) {},
498 CFSTR("2AF312E092D67308A0083DFFBF2B6B754B967864"),
499 CFSTR("2AF312E092D67308A0083DFFBF2B6B754B967864"),
500 CFSTR("2AF312E092D67308A0083DFFBF2B6B754B967864"),
501 CFSTR("2AF312E092D67308A0083DFFBF2B6B754B967864"),
502 CFSTR("2AF312E092D67308A0083DFFBF2B6B754B967864"),
503 NULL);
504
505 //testsyncempty();
506 testsyncmany("syncmany", test_directive, test_reason, 9, 10, 0, syncmany_add);
507 testsyncmany("v2syncmany", test_directive, test_reason, 9, 10, 2, syncmany_add);
508 testsync2p();
509 }
510
511 int secd_70_engine(int argc, char *const *argv)
512 {
513 plan_tests(kTestTestCount);
514
515 /* custom keychain dir */
516 secd_test_setup_temp_keychain(__FUNCTION__, NULL);
517
518 synctests();
519
520 return 0;
521 }