Update stress and media fixtures to sign versioned group records

This commit is contained in:
evgeny committed 2026-10-26 22:52:35 +01:00
1 parent 45257bf37f
commit aefef51c58
2 files changed
+8 -12

No files matched your search

+4 -6
View File
@@ -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) {
+4 -6
View File
@@ -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);