New architecture WP 2

Author: marcobambini

src/cloudsync.c

@@ -52,7 +52,14 @@ db_int64 cloudsync_dbversion_next (db_t *db, cloudsync_context *data, db_int64 m
 int cloudsync_commit_hook (void *ctx);
 void cloudsync_rollback_hook (void *ctx);
 
-//
+// PAYLOAD
+int cloudsync_payload_header_size (void);
+
+//#ifdef CLOUDSYNC_DESKTOP_OS
+int cloudsync_payload_save (cloudsync_context *data, const char *payload_path, int *blob_size);
+//#endif
+
+// END OK
 
 // CLOUDSYNCTABLE CONTEXT
 typedef struct cloudsync_table_context cloudsync_table_context;

src/cloudsync.h

@@ -36,7 +36,7 @@ void cloudsync_sync_key (cloudsync_context *data, const char *key, const char *v
 void *cloudsync_get_auxdata (sqlite3_context *context);
 void cloudsync_set_auxdata (sqlite3_context *context, void *xdata);
 int cloudsync_payload_apply (sqlite3_context *context, const char *payload, int blen);
-int cloudsync_payload_get (sqlite3_context *context, char **blob, int *blob_size, int *db_version, int *seq, sqlite3_int64 *new_db_version, sqlite3_int64 *new_seq);
+int cloudsync_payload_get (cloudsync_context *data, char **blob, int *blob_size, int *db_version, int *seq, sqlite3_int64 *new_db_version, sqlite3_int64 *new_seq);
 
 // used by core
 typedef bool (*cloudsync_payload_apply_callback_t)(void **xdata, cloudsync_pk_decode_bind_context *decoded_change, sqlite3 *db, cloudsync_context *data, int step, int rc);

src/cloudsync_private.h

@@ -41,6 +41,7 @@ int database_exec (db_t *db, const char *sql);  // SQLITE_OK
 int database_exec_callback (db_t *db, const char *sql, int (*callback)(void *xdata, int argc, char **values, char **names), void *xdata); // SQLITE_OK and SQLITE_ABORT
 const char *database_errmsg (db_t *db);
 int database_errcode (db_t *db);
+bool database_in_transaction (db_t *db);
 
 // VM and BINDING
 int  database_prepare (db_t *db, const char *sql, dbvm_t **vm, int flags);          // SQLITE_OK

src/cloudsync_sqlite.c

@@ -37,6 +37,11 @@ int database_errcode (db_t *db) {
     return sqlite3_errcode((sqlite3 *)db);
 }
 
+bool database_in_transaction (db_t *db) {
+    bool in_transaction = (sqlite3_get_autocommit(db) != true);
+    return in_transaction;
+}
+
 // MARK: - VM and BINDING -
 
 int database_prepare (db_t *db, const char *sql, dbvm_t **vm, int flags) {