@@ -196,7 +196,7 @@ int test_init (const char *db_path, int init) {
196196 snprintf (sql , sizeof (sql ), "INSERT INTO users (id, name) VALUES ('%s', '%s');" , value , value );
197197 rc = db_exec (db , sql ); RCHECK
198198 rc = db_expect_int (db , "SELECT COUNT(*) as count FROM users;" , 1 ); RCHECK
199- rc = db_expect_gt0 (db , "SELECT cloudsync_network_sync(250, 10);" ); RCHECK
199+ rc = db_expect_gt0 (db , "SELECT cloudsync_network_sync(250,10);" ); RCHECK
200200 rc = db_expect_gt0 (db , "SELECT COUNT(*) as count FROM users;" ); RCHECK
201201 rc = db_expect_gt0 (db , "SELECT COUNT(*) as count FROM activities;" ); RCHECK
202202 rc = db_expect_int (db , "SELECT COUNT(*) as count FROM workouts;" , 0 ); RCHECK
@@ -228,21 +228,50 @@ ABORT_TEST
228228
229229int test_enable_disable (const char * db_path ) {
230230 sqlite3 * db = NULL ;
231- int rc = open_load_ext (db_path , & db );
231+ int rc = open_load_ext (db_path , & db ); RCHECK
232+
233+ char value [UUID_STR_MAXLEN ];
234+ cloudsync_uuid_v7_string (value , true);
235+ char sql [256 ];
232236
233237 rc = db_exec (db , "SELECT cloudsync_init('*');" ); RCHECK
234238 rc = db_exec (db , "SELECT cloudsync_disable('users');" ); RCHECK
235- rc = db_exec (db , "INSERT INTO users (id, name) VALUES ('12afb', 'provaCmeaakbefa');" ); RCHECK
239+
240+ snprintf (sql , sizeof (sql ), "INSERT INTO users (id, name) VALUES ('%s', '%s');" , value , value );
241+ rc = db_exec (db , sql ); RCHECK
242+
236243 rc = db_exec (db , "SELECT cloudsync_enable('users');" ); RCHECK
237244
245+ snprintf (sql , sizeof (sql ), "INSERT INTO users (id, name) VALUES ('%s-should-sync', '%s-should-sync');" , value , value );
246+ rc = db_exec (db , sql ); RCHECK
247+
238248 // init network with connection string + apikey
239249 char network_init [512 ];
240250 snprintf (network_init , sizeof (network_init ), "SELECT cloudsync_network_init('%s?apikey=%s');" , getenv ("CONNECTION_STRING" ), getenv ("APIKEY" ));
241251 rc = db_exec (db , network_init ); RCHECK
242252
243- rc = db_exec (db , "SELECT cloudsync_network_sync ();" ); RCHECK
253+ rc = db_exec (db , "SELECT cloudsync_network_send_changes ();" ); RCHECK
244254 rc = db_exec (db , "SELECT cloudsync_cleanup('*');" );
245255
256+ sqlite3 * db2 = NULL ;
257+ rc = open_load_ext (":memory:" , & db2 ); RCHECK
258+ rc = db_init (db2 ); RCHECK
259+
260+ rc = db_exec (db2 , "SELECT cloudsync_init('*');" ); RCHECK
261+
262+ // init network with connection string + apikey
263+ rc = db_exec (db2 , network_init ); RCHECK
264+
265+ rc = db_expect_gt0 (db2 , "SELECT cloudsync_network_sync(250,10);" ); RCHECK
266+
267+ snprintf (sql , sizeof (sql ), "SELECT COUNT (* ) FROM users WHERE name = '%s' ;", value);
268+ rc = db_expect_int (db2 , sql , 0 ); RCHECK
269+
270+ snprintf (sql , sizeof (sql ), "SELECT COUNT (* ) FROM users WHERE name = '%s-should-sync' ;", value);
271+ rc = db_expect_int (db2 , sql , 1 ); RCHECK
272+
273+ sqlite3_close (db2 );
274+
246275ABORT_TEST
247276}
248277
0 commit comments