diff --git a/tests/test_chat_sync_stress.c b/tests/test_chat_sync_stress.c index c8f759fc..ae1252b5 100644 --- a/tests/test_chat_sync_stress.c +++ b/tests/test_chat_sync_stress.c @@ -143,12 +143,10 @@ static void seed_members(struct UTUN_INSTANCE* self, struct UTUN_INSTANCE* peer) static int insert_record(struct DB_SYNC_INSTANCE* si, struct UTUN_INSTANCE* inst, const char* data, size_t len) { uint64_t ts = db_sync_next_timestamp(si); - uint8_t sig_msg[4096]; size_t off = 0; - memcpy(sig_msg + off, &ts, 8); off += 8; - memcpy(sig_msg + off, data, len); off += len; - uint8_t sig[64]; - if (sc_ed25519_sign(inst->my_ed25519_privkey, sig_msg, off, sig) != SC_OK) return -1; - return db_sync_insert_signed(si, data, len, sig, 64, ts, NULL); + uint8_t sig[64]; struct db_message_revision revision = {.nonce = {1}, .ver = 1}; + if (db_sync_sign_message(db_sync_instance_group_id(si), ts, inst->node_id, &revision, data, len, + inst->my_ed25519_privkey, sig) < 0) return -1; + return db_sync_insert_signed(si, data, len, sig, 64, ts, NULL, &revision); } int main(void) { diff --git a/tests/test_media_delivery_chat.c b/tests/test_media_delivery_chat.c index 1faef247..3649120e 100644 --- a/tests/test_media_delivery_chat.c +++ b/tests/test_media_delivery_chat.c @@ -382,14 +382,12 @@ static int author_publish_message(void) { uint64_t ts = db_sync_next_timestamp(g_si[I_N1]); size_t jl = strlen(json); - uint8_t sig_msg[8700]; size_t soff = 0; - memcpy(sig_msg + soff, &ts, 8); soff += 8; - memcpy(sig_msg + soff, json, jl); soff += jl; - uint8_t sig[64]; - if (sc_ed25519_sign(g_inst[I_N1]->my_ed25519_privkey, sig_msg, soff, sig) != SC_OK) return -1; + uint8_t sig[64]; struct db_message_revision revision = {.nonce = {1}, .ver = 1}; + if (db_sync_sign_message(db_sync_instance_group_id(g_si[I_N1]), ts, g_nid[I_N1], &revision, json, jl, + g_inst[I_N1]->my_ed25519_privkey, sig) < 0) return -1; DEBUG_INFO(DEBUG_CATEGORY_GENERAL, "[mdc] publish media message ts=%llu len=%zu", (unsigned long long)ts, jl); - int rc = db_sync_insert_signed(g_si[I_N1], json, jl, sig, 64, ts, NULL); + int rc = db_sync_insert_signed(g_si[I_N1], json, jl, sig, 64, ts, NULL, &revision); if (rc == 0) { /* анонсируем блоки суперузлам (как on_media_registered в chat_msg.c) */ ensure_supernode_type(I_N1);