Compare commits
No commits in common. "bbf000b4b5b0b0e46e364aeb82217618b0124176" and "c2f56539389bb708353b5b057135b8e341912c1c" have entirely different histories.
bbf000b4b5
...
c2f5653938
65
ngc_hs1.c
Normal file
65
ngc_hs1.c
Normal file
@ -0,0 +1,65 @@
|
|||||||
|
#include "./ngc_hs1.h"
|
||||||
|
|
||||||
|
#include <stdlib.h>
|
||||||
|
|
||||||
|
struct NGC_HS1 {
|
||||||
|
void* temp;
|
||||||
|
|
||||||
|
NGC_HS1_options options;
|
||||||
|
|
||||||
|
// key - key - value store
|
||||||
|
// peer pubkey - msg_id - message(type + text)
|
||||||
|
};
|
||||||
|
|
||||||
|
NGC_HS1* NGC_HS1_new(const struct NGC_HS1_options* options) {
|
||||||
|
NGC_HS1* context = malloc(sizeof(NGC_HS1));
|
||||||
|
|
||||||
|
context->options = *options;
|
||||||
|
|
||||||
|
return context;
|
||||||
|
}
|
||||||
|
|
||||||
|
void NGC_HS1_kill(NGC_HS1* ngc_hs1_ctx) {
|
||||||
|
free(ngc_hs1_ctx);
|
||||||
|
}
|
||||||
|
|
||||||
|
void NGC_HS1_iterate(Tox *tox, NGC_HS1* ngc_hs1_ctx/*, void *user_data*/) {
|
||||||
|
}
|
||||||
|
|
||||||
|
bool NGC_HS1_shim_group_send_message(
|
||||||
|
const Tox *tox,
|
||||||
|
NGC_HS1* ngc_hs1_ctx,
|
||||||
|
|
||||||
|
uint32_t group_number,
|
||||||
|
|
||||||
|
Tox_Message_Type type, const uint8_t *message, size_t length,
|
||||||
|
|
||||||
|
uint32_t *message_id,
|
||||||
|
Tox_Err_Group_Send_Message *error
|
||||||
|
) {
|
||||||
|
uint32_t* msg_id_ptr = message_id;
|
||||||
|
uint32_t msg_id_placeholder = 0;
|
||||||
|
if (msg_id_ptr == NULL) {
|
||||||
|
msg_id_ptr = &msg_id_placeholder;
|
||||||
|
}
|
||||||
|
|
||||||
|
bool ret = tox_group_send_message(tox, group_number, type, message, length, msg_id_ptr, error);
|
||||||
|
|
||||||
|
NGC_HS1_record_own_message(tox, group_number, type, message, length, *msg_id_ptr);
|
||||||
|
|
||||||
|
return ret;
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
// record own msg
|
||||||
|
void NGC_HS1_record_own_message(
|
||||||
|
const Tox *tox,
|
||||||
|
NGC_HS1* ngc_hs1_ctx,
|
||||||
|
|
||||||
|
uint32_t group_number,
|
||||||
|
|
||||||
|
Tox_Message_Type type, const uint8_t *message, size_t length, uint32_t message_id
|
||||||
|
) {
|
||||||
|
printf("record_own_message %u\n", message_id);
|
||||||
|
}
|
||||||
|
|
||||||
549
ngc_hs1.cpp
549
ngc_hs1.cpp
@ -1,549 +0,0 @@
|
|||||||
#include "./ngc_hs1.h"
|
|
||||||
|
|
||||||
#include <cstdint>
|
|
||||||
#include <cassert>
|
|
||||||
#include <new>
|
|
||||||
#include <map>
|
|
||||||
#include <list>
|
|
||||||
#include <set>
|
|
||||||
#include <optional>
|
|
||||||
#include <algorithm>
|
|
||||||
|
|
||||||
struct _GroupID {
|
|
||||||
std::array<uint8_t, TOX_GROUP_CHAT_ID_SIZE> data;
|
|
||||||
|
|
||||||
_GroupID(void) = default;
|
|
||||||
_GroupID(const _GroupID& other) : data(other.data) {}
|
|
||||||
_GroupID(_GroupID&&) = delete;
|
|
||||||
//_GroupID(_GroupID&& other) : data(std::move(other.data)) {}
|
|
||||||
|
|
||||||
bool operator<(const _GroupID& rhs) const {
|
|
||||||
for (size_t i = 0; i < data.size(); i++) {
|
|
||||||
if (data[i] < rhs.data[i]) {
|
|
||||||
return true;
|
|
||||||
} else if (data[i] > rhs.data[i]) {
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
return false; // equal
|
|
||||||
}
|
|
||||||
|
|
||||||
bool operator==(const _GroupID& rhs) const {
|
|
||||||
for (size_t i = 0; i < data.size(); i++) {
|
|
||||||
if (data[i] != rhs.data[i]) {
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
return true;
|
|
||||||
}
|
|
||||||
};
|
|
||||||
|
|
||||||
struct _PeerID {
|
|
||||||
std::array<uint8_t, TOX_GROUP_PEER_PUBLIC_KEY_SIZE> data;
|
|
||||||
|
|
||||||
_PeerID(void) = default;
|
|
||||||
_PeerID(const _PeerID& other) : data(other.data) {}
|
|
||||||
_PeerID(_PeerID&&) = delete;
|
|
||||||
|
|
||||||
bool operator<(const _PeerID& rhs) const {
|
|
||||||
for (size_t i = 0; i < data.size(); i++) {
|
|
||||||
if (data[i] < rhs.data[i]) {
|
|
||||||
return true;
|
|
||||||
} else if (data[i] > rhs.data[i]) {
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
return false; // equal
|
|
||||||
}
|
|
||||||
|
|
||||||
bool operator==(const _PeerID& rhs) const {
|
|
||||||
for (size_t i = 0; i < data.size(); i++) {
|
|
||||||
if (data[i] != rhs.data[i]) {
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
return true;
|
|
||||||
}
|
|
||||||
};
|
|
||||||
|
|
||||||
enum _PacketType : uint8_t {
|
|
||||||
INVALID = 0u,
|
|
||||||
|
|
||||||
// request last (few) message_ids for a peer
|
|
||||||
// - peer_key bytes (peer key we want to know ids for)
|
|
||||||
// - 1 byte (uint8_t count ids, atleast 1)
|
|
||||||
HS_REQUEST_LAST_IDS,
|
|
||||||
|
|
||||||
// respond to a request with 0 or more message ids, sorted by newest first
|
|
||||||
// - peer_key bytes (the msg_ids are from)
|
|
||||||
// - 1 byte (uint8_t count ids, can be 0)
|
|
||||||
// - array [
|
|
||||||
// - msg_id bytes (the message id
|
|
||||||
// - ]
|
|
||||||
HS_RESPONSE_LAST_IDS,
|
|
||||||
|
|
||||||
//TODO: make it possible to go further back
|
|
||||||
};
|
|
||||||
|
|
||||||
const char* _pkgid2str(_PacketType type) {
|
|
||||||
#define _HS1_CASE(x) case (x): return #x;
|
|
||||||
switch (type) {
|
|
||||||
_HS1_CASE(INVALID)
|
|
||||||
_HS1_CASE(HS_REQUEST_LAST_IDS)
|
|
||||||
_HS1_CASE(HS_RESPONSE_LAST_IDS)
|
|
||||||
default: return "<unk>";
|
|
||||||
}
|
|
||||||
#undef _HS1_CASE
|
|
||||||
}
|
|
||||||
|
|
||||||
struct NGC_HS1 {
|
|
||||||
NGC_HS1_options options;
|
|
||||||
|
|
||||||
// callbacks
|
|
||||||
//tox_group_message_cb* client_tox_msg_callback;
|
|
||||||
|
|
||||||
|
|
||||||
// key - key - key - value store
|
|
||||||
// group pubkey - peer pubkey - msg_id - message(type + text)
|
|
||||||
struct Message {
|
|
||||||
uint32_t msg_id{};
|
|
||||||
Tox_Message_Type type{};
|
|
||||||
std::string text{};
|
|
||||||
};
|
|
||||||
|
|
||||||
struct Peer {
|
|
||||||
std::optional<uint32_t> id;
|
|
||||||
std::map<uint32_t, Message> dict;
|
|
||||||
std::list<uint32_t> order; // ordered list of message ids
|
|
||||||
|
|
||||||
// msg_ids we have only heard of, with peer_number of who we heard it from
|
|
||||||
std::map<uint32_t, std::set<uint32_t>> heard_of;
|
|
||||||
|
|
||||||
// dont start immediatly
|
|
||||||
float time_since_last_request_sent {0.f};
|
|
||||||
|
|
||||||
void append(uint32_t msg_id, Tox_Message_Type type, const std::string& text) {
|
|
||||||
order.push_back(msg_id);
|
|
||||||
|
|
||||||
// overwrites
|
|
||||||
auto& new_msg = dict[msg_id];
|
|
||||||
new_msg.msg_id = msg_id;
|
|
||||||
new_msg.type = type;
|
|
||||||
new_msg.text = text;
|
|
||||||
|
|
||||||
if (heard_of.count(msg_id)) {
|
|
||||||
// we got history before we got the message
|
|
||||||
heard_of.erase(msg_id);
|
|
||||||
}
|
|
||||||
|
|
||||||
fprintf(stderr, "######## last msgs ########\n");
|
|
||||||
auto rit = order.crbegin();
|
|
||||||
for (size_t i = 0; i < 10 && rit != order.crend(); i++, rit++) {
|
|
||||||
fprintf(stderr, " %08X - %s\n", *rit, dict.at(*rit).text.c_str());
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
// returns if new (from that peer)
|
|
||||||
bool hear(uint32_t msg_id, uint32_t peer_number) {
|
|
||||||
if (dict.count(msg_id)) {
|
|
||||||
// we know
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
|
|
||||||
if (heard_of.count(msg_id) && heard_of.at(msg_id).count(peer_number)) {
|
|
||||||
// we heard it from that peer before
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
|
|
||||||
heard_of[msg_id].emplace(peer_number);
|
|
||||||
|
|
||||||
return true;
|
|
||||||
}
|
|
||||||
};
|
|
||||||
|
|
||||||
struct Group {
|
|
||||||
std::map<_PeerID, Peer> peers;
|
|
||||||
};
|
|
||||||
|
|
||||||
std::map<_GroupID, Group> history;
|
|
||||||
};
|
|
||||||
|
|
||||||
NGC_HS1* NGC_HS1_new(const struct NGC_HS1_options* options) {
|
|
||||||
NGC_HS1* context = new NGC_HS1;
|
|
||||||
|
|
||||||
context->options = *options;
|
|
||||||
|
|
||||||
return context;
|
|
||||||
}
|
|
||||||
|
|
||||||
void NGC_HS1_kill(NGC_HS1* ngc_hs1_ctx) {
|
|
||||||
delete ngc_hs1_ctx;
|
|
||||||
}
|
|
||||||
|
|
||||||
static void _iterate_group(Tox *tox, NGC_HS1* ngc_hs1_ctx, uint32_t group_number, float time_delta) {
|
|
||||||
//fprintf(stderr, "g:%u\n", g_i);
|
|
||||||
_GroupID g_id{};
|
|
||||||
{ // TODO: error
|
|
||||||
tox_group_get_chat_id(tox, group_number, g_id.data.data(), nullptr);
|
|
||||||
}
|
|
||||||
|
|
||||||
if (ngc_hs1_ctx->history.count(g_id) == 0) {
|
|
||||||
fprintf(stderr, "adding new group: %u %X%X%X%X\n",
|
|
||||||
group_number,
|
|
||||||
g_id.data.data()[0],
|
|
||||||
g_id.data.data()[1],
|
|
||||||
g_id.data.data()[2],
|
|
||||||
g_id.data.data()[3]
|
|
||||||
);
|
|
||||||
ngc_hs1_ctx->history[g_id];
|
|
||||||
} else {
|
|
||||||
auto& group = ngc_hs1_ctx->history[g_id];
|
|
||||||
|
|
||||||
// for each peer
|
|
||||||
for (auto& [key, peer] : group.peers) {
|
|
||||||
//fprintf(stderr, " p: %X%X%X%X\n", key.data.data()[0], key.data.data()[1], key.data.data()[2], key.data.data()[3]);
|
|
||||||
peer.time_since_last_request_sent += time_delta;
|
|
||||||
if (peer.time_since_last_request_sent > 15.f) {
|
|
||||||
peer.time_since_last_request_sent = 0.f;
|
|
||||||
|
|
||||||
fprintf(stderr, "requesting ids for %X%X%X%X\n", key.data.data()[0], key.data.data()[1], key.data.data()[2], key.data.data()[3]);
|
|
||||||
|
|
||||||
// TODO: other way around?
|
|
||||||
// ask everyone if they have newer stuff for this peer
|
|
||||||
|
|
||||||
// - 1 byte packet id
|
|
||||||
// - peer_key bytes (peer key we want to know ids for)
|
|
||||||
// - 1 byte (uint8_t count ids, atleast 1)
|
|
||||||
std::array<uint8_t, 1+TOX_GROUP_PEER_PUBLIC_KEY_SIZE+1> pkg;
|
|
||||||
pkg[0] = HS_REQUEST_LAST_IDS;
|
|
||||||
std::copy(key.data.begin(), key.data.end(), pkg.begin()+1);
|
|
||||||
pkg[1+TOX_GROUP_PEER_PUBLIC_KEY_SIZE] = 5; // request last (up to) 5 msg_ids
|
|
||||||
|
|
||||||
tox_group_send_custom_packet(tox, group_number, true, pkg.data(), pkg.size(), nullptr);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
assert(ngc_hs1_ctx->history.size() != 0);
|
|
||||||
|
|
||||||
assert(ngc_hs1_ctx->history.count(g_id));
|
|
||||||
}
|
|
||||||
|
|
||||||
void NGC_HS1_iterate(Tox *tox, NGC_HS1* ngc_hs1_ctx/*, void *user_data*/) {
|
|
||||||
assert(ngc_hs1_ctx);
|
|
||||||
|
|
||||||
//fprintf(stderr, "groups: %u\n", ngc_hs1_ctx->history.size());
|
|
||||||
|
|
||||||
uint32_t group_count = tox_group_get_number_groups(tox);
|
|
||||||
// this can loop endless if toxcore misbehaves
|
|
||||||
for (uint32_t g_i = 0, g_c_done = 0; g_c_done < group_count; g_i++) {
|
|
||||||
Tox_Err_Group_Is_Connected g_err;
|
|
||||||
if (tox_group_is_connected(tox, g_i, &g_err)) {
|
|
||||||
// valid and connected here
|
|
||||||
// TODO: delta time, or other timers
|
|
||||||
_iterate_group(tox, ngc_hs1_ctx, g_i, 0.02f);
|
|
||||||
g_c_done++;
|
|
||||||
} else if (g_err != TOX_ERR_GROUP_IS_CONNECTED_GROUP_NOT_FOUND) {
|
|
||||||
g_c_done++;
|
|
||||||
} // else do nothing
|
|
||||||
|
|
||||||
// safety
|
|
||||||
if (g_i > group_count + 1000) {
|
|
||||||
fprintf(stderr, "WAY PAST GOUPS in iterate\n");
|
|
||||||
break;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
void NGC_HS1_peer_online(Tox* tox, NGC_HS1* ngc_hs1_ctx, uint32_t group_number, uint32_t peer_number, bool online) {
|
|
||||||
// get group id
|
|
||||||
_GroupID g_id{};
|
|
||||||
{ // TODO: error
|
|
||||||
tox_group_get_chat_id(tox, group_number, g_id.data.data(), nullptr);
|
|
||||||
}
|
|
||||||
|
|
||||||
auto& group = ngc_hs1_ctx->history[g_id];
|
|
||||||
|
|
||||||
if (online) {
|
|
||||||
// get peer id
|
|
||||||
_PeerID p_id{};
|
|
||||||
{ // TODO: error
|
|
||||||
tox_group_peer_get_public_key(tox, group_number, peer_number, p_id.data.data(), nullptr);
|
|
||||||
}
|
|
||||||
|
|
||||||
auto& peer = group.peers[p_id];
|
|
||||||
peer.id = peer_number;
|
|
||||||
} else { // offline
|
|
||||||
// search
|
|
||||||
for (auto& [key, peer] : group.peers) {
|
|
||||||
if (peer.id.has_value() && peer.id.value() == peer_number) {
|
|
||||||
peer.id = {}; // reset
|
|
||||||
break;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
bool NGC_HS1_shim_group_send_message(
|
|
||||||
const Tox *tox,
|
|
||||||
NGC_HS1* ngc_hs1_ctx,
|
|
||||||
|
|
||||||
uint32_t group_number,
|
|
||||||
|
|
||||||
Tox_Message_Type type, const uint8_t *message, size_t length,
|
|
||||||
|
|
||||||
uint32_t *message_id,
|
|
||||||
Tox_Err_Group_Send_Message *error
|
|
||||||
) {
|
|
||||||
uint32_t* msg_id_ptr = message_id;
|
|
||||||
uint32_t msg_id_placeholder = 0;
|
|
||||||
if (msg_id_ptr == nullptr) {
|
|
||||||
msg_id_ptr = &msg_id_placeholder;
|
|
||||||
}
|
|
||||||
|
|
||||||
bool ret = tox_group_send_message(tox, group_number, type, message, length, msg_id_ptr, error);
|
|
||||||
|
|
||||||
NGC_HS1_record_own_message(tox, ngc_hs1_ctx, group_number, type, message, length, *msg_id_ptr);
|
|
||||||
|
|
||||||
return ret;
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
// record own msg
|
|
||||||
void NGC_HS1_record_own_message(
|
|
||||||
const Tox *tox,
|
|
||||||
NGC_HS1* ngc_hs1_ctx,
|
|
||||||
|
|
||||||
uint32_t group_number,
|
|
||||||
|
|
||||||
Tox_Message_Type type, const uint8_t *message, size_t length, uint32_t message_id
|
|
||||||
) {
|
|
||||||
fprintf(stderr, "record_own_message %08X\n", message_id);
|
|
||||||
// get group id
|
|
||||||
_GroupID g_id{};
|
|
||||||
{ // TODO: error
|
|
||||||
tox_group_get_chat_id(tox, group_number, g_id.data.data(), nullptr);
|
|
||||||
}
|
|
||||||
|
|
||||||
// get peer id
|
|
||||||
_PeerID p_id{};
|
|
||||||
{ // TODO: error
|
|
||||||
tox_group_self_get_public_key(tox, group_number, p_id.data.data(), nullptr);
|
|
||||||
}
|
|
||||||
|
|
||||||
ngc_hs1_ctx->history[g_id].peers[p_id].append(message_id, type, std::string{message, message+length});
|
|
||||||
assert(ngc_hs1_ctx->history.size() != 0);
|
|
||||||
assert(ngc_hs1_ctx->history.count(g_id));
|
|
||||||
}
|
|
||||||
|
|
||||||
// record others msg
|
|
||||||
void NGC_HS1_record_message(
|
|
||||||
const Tox *tox,
|
|
||||||
NGC_HS1* ngc_hs1_ctx,
|
|
||||||
|
|
||||||
uint32_t group_number,
|
|
||||||
uint32_t peer_number,
|
|
||||||
|
|
||||||
Tox_Message_Type type, const uint8_t *message, size_t length, uint32_t message_id
|
|
||||||
) {
|
|
||||||
if (!ngc_hs1_ctx->options.record_others) {
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
fprintf(stderr, "record_message %08X\n", message_id);
|
|
||||||
// get group id
|
|
||||||
_GroupID g_id{};
|
|
||||||
{ // TODO: error
|
|
||||||
tox_group_get_chat_id(tox, group_number, g_id.data.data(), nullptr);
|
|
||||||
}
|
|
||||||
|
|
||||||
// get peer id
|
|
||||||
_PeerID p_id{};
|
|
||||||
{ // TODO: error
|
|
||||||
tox_group_peer_get_public_key(tox, group_number, peer_number, p_id.data.data(), nullptr);
|
|
||||||
}
|
|
||||||
|
|
||||||
ngc_hs1_ctx->history[g_id].peers[p_id].append(message_id, type, std::string{message, message+length});
|
|
||||||
}
|
|
||||||
|
|
||||||
static void _handle_HS_REQUEST_LAST_IDS(
|
|
||||||
Tox* tox,
|
|
||||||
NGC_HS1* ngc_hs1_ctx,
|
|
||||||
|
|
||||||
uint32_t group_number,
|
|
||||||
uint32_t peer_number,
|
|
||||||
|
|
||||||
const uint8_t *data,
|
|
||||||
size_t length
|
|
||||||
);
|
|
||||||
|
|
||||||
static void _handle_HS_RESPONSE_LAST_IDS(
|
|
||||||
Tox* tox,
|
|
||||||
NGC_HS1* ngc_hs1_ctx,
|
|
||||||
|
|
||||||
uint32_t group_number,
|
|
||||||
uint32_t peer_number,
|
|
||||||
|
|
||||||
const uint8_t *data,
|
|
||||||
size_t length
|
|
||||||
);
|
|
||||||
|
|
||||||
#define _HS1_HAVE(x, error) if ((length - curser) < (x)) { error; }
|
|
||||||
void NGC_HS1_handle_group_custom_packet(
|
|
||||||
Tox* tox,
|
|
||||||
NGC_HS1* ngc_hs1_ctx,
|
|
||||||
|
|
||||||
uint32_t group_number,
|
|
||||||
uint32_t peer_number,
|
|
||||||
|
|
||||||
const uint8_t *data,
|
|
||||||
size_t length
|
|
||||||
//void *user_data
|
|
||||||
) {
|
|
||||||
size_t curser = 0;
|
|
||||||
|
|
||||||
_HS1_HAVE(1, return)
|
|
||||||
|
|
||||||
_PacketType pkg_type = static_cast<_PacketType>(*(data + curser));
|
|
||||||
curser++;
|
|
||||||
|
|
||||||
fprintf(stderr, "custom_packet [%s] %u\n", _pkgid2str(pkg_type), length);
|
|
||||||
|
|
||||||
switch (pkg_type) {
|
|
||||||
case INVALID:
|
|
||||||
break;
|
|
||||||
case HS_REQUEST_LAST_IDS:
|
|
||||||
_handle_HS_REQUEST_LAST_IDS(tox, ngc_hs1_ctx, group_number, peer_number, data+curser, length-curser);
|
|
||||||
break;
|
|
||||||
case HS_RESPONSE_LAST_IDS:
|
|
||||||
_handle_HS_RESPONSE_LAST_IDS(tox, ngc_hs1_ctx, group_number, peer_number, data+curser, length-curser);
|
|
||||||
break;
|
|
||||||
}
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
||||||
static void _handle_HS_REQUEST_LAST_IDS(
|
|
||||||
Tox* tox,
|
|
||||||
NGC_HS1* ngc_hs1_ctx,
|
|
||||||
|
|
||||||
uint32_t group_number,
|
|
||||||
uint32_t peer_number,
|
|
||||||
|
|
||||||
const uint8_t *data,
|
|
||||||
size_t length
|
|
||||||
) {
|
|
||||||
size_t curser = 0;
|
|
||||||
|
|
||||||
_PeerID p_key;
|
|
||||||
_HS1_HAVE(p_key.data.size(), fprintf(stderr, "packet too small, missing pkey\n"); return)
|
|
||||||
|
|
||||||
std::copy(data+curser, data+curser+p_key.data.size(), p_key.data.begin());
|
|
||||||
curser += p_key.data.size();
|
|
||||||
|
|
||||||
_HS1_HAVE(1, fprintf(stderr, "packet too small, missing count\n"); return)
|
|
||||||
uint8_t last_msg_id_count = data[curser++];
|
|
||||||
|
|
||||||
fprintf(stderr, "got request for last %u ids\n", last_msg_id_count);
|
|
||||||
|
|
||||||
// get group id
|
|
||||||
_GroupID g_id{};
|
|
||||||
{ // TODO: error
|
|
||||||
tox_group_get_chat_id(tox, group_number, g_id.data.data(), nullptr);
|
|
||||||
}
|
|
||||||
|
|
||||||
auto& group = ngc_hs1_ctx->history[g_id];
|
|
||||||
|
|
||||||
std::vector<uint32_t> message_ids{};
|
|
||||||
|
|
||||||
if (!group.peers.empty() && group.peers.count(p_key)) {
|
|
||||||
const auto& peer = group.peers.at(p_key);
|
|
||||||
auto rit = peer.order.crbegin();
|
|
||||||
for (size_t c = 0; c < last_msg_id_count && rit != peer.order.crend(); c++, rit++) {
|
|
||||||
message_ids.push_back(*rit);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
// - 1 byte packet id
|
|
||||||
// respond to a request with 0 or more message ids, sorted by newest first
|
|
||||||
// - peer_key bytes (the msg_ids are from)
|
|
||||||
// - 1 byte (uint8_t count ids, can be 0)
|
|
||||||
// - array [
|
|
||||||
// - msg_id bytes (the message id
|
|
||||||
// - ]
|
|
||||||
//std::array<uint8_t, 1+TOX_GROUP_PEER_PUBLIC_KEY_SIZE+1+> pkg;
|
|
||||||
std::vector<uint8_t> pkg;
|
|
||||||
pkg.resize(1+TOX_GROUP_PEER_PUBLIC_KEY_SIZE+1+sizeof(uint32_t)*message_ids.size());
|
|
||||||
|
|
||||||
size_t packing_curser = 0;
|
|
||||||
|
|
||||||
pkg[packing_curser++] = HS_RESPONSE_LAST_IDS;
|
|
||||||
|
|
||||||
std::copy(p_key.data.begin(), p_key.data.end(), pkg.begin()+packing_curser);
|
|
||||||
packing_curser += p_key.data.size();
|
|
||||||
|
|
||||||
pkg[packing_curser++] = message_ids.size();
|
|
||||||
|
|
||||||
for (size_t i = 0; i < message_ids.size(); i++) {
|
|
||||||
const uint8_t* tmp_ptr = reinterpret_cast<uint8_t*>(message_ids.data()+i);
|
|
||||||
// HACK: little endian
|
|
||||||
//std::copy(tmp_ptr, tmp_ptr+sizeof(uint32_t), pkg.begin()+1+TOX_GROUP_PEER_PUBLIC_KEY_SIZE+1+i*sizeof(uint32_t));
|
|
||||||
std::copy(tmp_ptr, tmp_ptr+sizeof(uint32_t), pkg.begin()+packing_curser);
|
|
||||||
packing_curser += sizeof(uint32_t);
|
|
||||||
}
|
|
||||||
|
|
||||||
tox_group_send_custom_private_packet(tox, group_number, peer_number, true, pkg.data(), pkg.size(), nullptr);
|
|
||||||
}
|
|
||||||
|
|
||||||
static void _handle_HS_RESPONSE_LAST_IDS(
|
|
||||||
Tox* tox,
|
|
||||||
NGC_HS1* ngc_hs1_ctx,
|
|
||||||
|
|
||||||
uint32_t group_number,
|
|
||||||
uint32_t peer_number,
|
|
||||||
|
|
||||||
const uint8_t *data,
|
|
||||||
size_t length
|
|
||||||
) {
|
|
||||||
size_t curser = 0;
|
|
||||||
|
|
||||||
_PeerID p_key;
|
|
||||||
_HS1_HAVE(p_key.data.size(), fprintf(stderr, "packet too small, missing pkey\n"); return)
|
|
||||||
|
|
||||||
std::copy(data+curser, data+curser+p_key.data.size(), p_key.data.begin());
|
|
||||||
curser += p_key.data.size();
|
|
||||||
|
|
||||||
// TODO: did we ask?
|
|
||||||
|
|
||||||
_HS1_HAVE(1, fprintf(stderr, "packet too small, missing count\n"); return)
|
|
||||||
uint8_t last_msg_id_count = data[curser++];
|
|
||||||
|
|
||||||
fprintf(stderr, "got response with last %u ids:\n", last_msg_id_count);
|
|
||||||
|
|
||||||
if (last_msg_id_count == 0) {
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
// get group id
|
|
||||||
_GroupID g_id{};
|
|
||||||
{ // TODO: error
|
|
||||||
tox_group_get_chat_id(tox, group_number, g_id.data.data(), nullptr);
|
|
||||||
}
|
|
||||||
|
|
||||||
// get peer
|
|
||||||
auto& peer = ngc_hs1_ctx->history[g_id].peers[p_key];
|
|
||||||
|
|
||||||
for (size_t i = 0; i < last_msg_id_count && curser+sizeof(uint32_t) <= length; i++) {
|
|
||||||
uint32_t msg_id;
|
|
||||||
// HACK: little endian
|
|
||||||
std::copy(data+curser, data+curser+sizeof(uint32_t), reinterpret_cast<uint8_t*>(&msg_id));
|
|
||||||
curser += sizeof(uint32_t);
|
|
||||||
fprintf(stderr, " %08X", msg_id);
|
|
||||||
|
|
||||||
if (peer.hear(msg_id, peer_number)) {
|
|
||||||
fprintf(stderr, " - NEW");
|
|
||||||
}
|
|
||||||
|
|
||||||
fprintf(stderr, "\n");
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
#undef _HS1_HAVE
|
|
||||||
42
ngc_hs1.h
42
ngc_hs1.h
@ -4,7 +4,7 @@
|
|||||||
// this is a c header
|
// this is a c header
|
||||||
|
|
||||||
// outline:
|
// outline:
|
||||||
// i am disgusting
|
//
|
||||||
|
|
||||||
//#include <stdbool.h>
|
//#include <stdbool.h>
|
||||||
//#include <stddef.h>
|
//#include <stddef.h>
|
||||||
@ -39,9 +39,9 @@ struct NGC_HS1_options {
|
|||||||
// 2 mods
|
// 2 mods
|
||||||
// 3 founders
|
// 3 founders
|
||||||
// 4 no one (above founder)
|
// 4 no one (above founder)
|
||||||
uint8_t default_trust_level /*= 2*/;
|
uint8_t default_trust_level = 2;
|
||||||
|
|
||||||
bool record_others;
|
//bool test;
|
||||||
};
|
};
|
||||||
|
|
||||||
// ========== init / kill ==========
|
// ========== init / kill ==========
|
||||||
@ -52,10 +52,6 @@ void NGC_HS1_kill(NGC_HS1* ngc_hs1_ctx);
|
|||||||
// ========== iterate ==========
|
// ========== iterate ==========
|
||||||
void NGC_HS1_iterate(Tox *tox, NGC_HS1* ngc_hs1_ctx/*, void *user_data*/);
|
void NGC_HS1_iterate(Tox *tox, NGC_HS1* ngc_hs1_ctx/*, void *user_data*/);
|
||||||
|
|
||||||
// ========== peer online/offline ==========
|
|
||||||
|
|
||||||
void NGC_HS1_peer_online(Tox* tox, NGC_HS1* ngc_hs1_ctx, uint32_t group_number, uint32_t peer_number, bool online);
|
|
||||||
|
|
||||||
// ========== send ==========
|
// ========== send ==========
|
||||||
|
|
||||||
// shim (same interface)
|
// shim (same interface)
|
||||||
@ -85,42 +81,10 @@ void NGC_HS1_record_own_message(
|
|||||||
|
|
||||||
// ========== receive message ==========
|
// ========== receive message ==========
|
||||||
|
|
||||||
// !!! no shim, whould require global state !!!
|
|
||||||
// shim (same interface)
|
// shim (same interface)
|
||||||
//typedef void tox_group_message_cb(Tox *tox, uint32_t group_number, uint32_t peer_id, Tox_Message_Type type,
|
|
||||||
//const uint8_t *message, size_t length, uint32_t message_id, void *user_data);
|
|
||||||
//void NGC_HS1_callback_group_message(Tox *tox, NGC_HS1* ngc_hs1_ctx, tox_group_message_cb *callback);
|
|
||||||
|
|
||||||
// record others msg
|
|
||||||
void NGC_HS1_record_message(
|
|
||||||
const Tox *tox,
|
|
||||||
NGC_HS1* ngc_hs1_ctx,
|
|
||||||
|
|
||||||
uint32_t group_number,
|
|
||||||
uint32_t peer_number,
|
|
||||||
|
|
||||||
Tox_Message_Type type, const uint8_t *message, size_t length, uint32_t message_id
|
|
||||||
);
|
|
||||||
|
|
||||||
// ========== receive custom ==========
|
|
||||||
|
|
||||||
// "callback"
|
|
||||||
void NGC_HS1_handle_group_custom_packet(
|
|
||||||
Tox* tox,
|
|
||||||
NGC_HS1* ngc_hs1_ctx,
|
|
||||||
|
|
||||||
uint32_t group_number,
|
|
||||||
uint32_t peer_number,
|
|
||||||
|
|
||||||
const uint8_t *data,
|
|
||||||
size_t length
|
|
||||||
//void *user_data
|
|
||||||
);
|
|
||||||
|
|
||||||
// ========== receive request ==========
|
// ========== receive request ==========
|
||||||
|
|
||||||
//void NGC_HS1_custom_packet(
|
|
||||||
|
|
||||||
// ========== receive answer ==========
|
// ========== receive answer ==========
|
||||||
|
|
||||||
#ifdef __cplusplus
|
#ifdef __cplusplus
|
||||||
|
|||||||
Reference in New Issue
Block a user