diff options
author | George Hazan <ghazan@miranda.im> | 2019-03-26 13:06:41 +0300 |
---|---|---|
committer | George Hazan <ghazan@miranda.im> | 2019-03-26 13:06:41 +0300 |
commit | aec8f049d43d79c6c8c26a7d9ddfd9460d267275 (patch) | |
tree | 5e75220de26fda9b7b0527d550204c78a86ad90c /libs/libaxolotl/src/session_builder.c | |
parent | f2764176c58829d24fee7a830a3c9ac2b57d1906 (diff) |
libaxolotl doesn't exist anymore, it's renamed to libsignal
Diffstat (limited to 'libs/libaxolotl/src/session_builder.c')
-rw-r--r-- | libs/libaxolotl/src/session_builder.c | 352 |
1 files changed, 0 insertions, 352 deletions
diff --git a/libs/libaxolotl/src/session_builder.c b/libs/libaxolotl/src/session_builder.c deleted file mode 100644 index 2bfd62015f..0000000000 --- a/libs/libaxolotl/src/session_builder.c +++ /dev/null @@ -1,352 +0,0 @@ -#include "session_builder.h" -#include "session_builder_internal.h" - -#include <assert.h> -#include <string.h> -#include "session_pre_key.h" -#include "session_record.h" -#include "session_state.h" -#include "ratchet.h" -#include "protocol.h" -#include "key_helper.h" -#include "signal_protocol_internal.h" - -struct session_builder -{ - signal_protocol_store_context *store; - const signal_protocol_address *remote_address; - signal_context *global_context; -}; - -static int session_builder_process_pre_key_signal_message_v3(session_builder *builder, - session_record *record, pre_key_signal_message *message, uint32_t *unsigned_pre_key_id); - -int session_builder_create(session_builder **builder, - signal_protocol_store_context *store, const signal_protocol_address *remote_address, - signal_context *global_context) -{ - session_builder *result = 0; - - assert(store); - assert(global_context); - - result = malloc(sizeof(session_builder)); - if(!result) { - return SG_ERR_NOMEM; - } - memset(result, 0, sizeof(session_builder)); - - result->store = store; - result->remote_address = remote_address; - result->global_context = global_context; - - *builder = result; - return 0; -} - -int session_builder_process_pre_key_signal_message(session_builder *builder, - session_record *record, pre_key_signal_message *message, uint32_t *unsigned_pre_key_id) -{ - int result = 0; - int has_unsigned_pre_key_id_result = 0; - uint32_t unsigned_pre_key_id_result = 0; - ec_public_key *their_identity_key = pre_key_signal_message_get_identity_key(message); - - result = signal_protocol_identity_is_trusted_identity(builder->store, - builder->remote_address, - their_identity_key); - if(result < 0) { - goto complete; - } - if(result == 0) { - result = SG_ERR_UNTRUSTED_IDENTITY; - goto complete; - } - - result = session_builder_process_pre_key_signal_message_v3(builder, record, message, &unsigned_pre_key_id_result); - if(result < 0) { - goto complete; - } - has_unsigned_pre_key_id_result = result; - - result = signal_protocol_identity_save_identity(builder->store, - builder->remote_address, - their_identity_key); - if(result < 0) { - goto complete; - } - - result = has_unsigned_pre_key_id_result; - -complete: - if(result >= 0) { - *unsigned_pre_key_id = unsigned_pre_key_id_result; - } - return result; -} - -static int session_builder_process_pre_key_signal_message_v3(session_builder *builder, - session_record *record, pre_key_signal_message *message, uint32_t *unsigned_pre_key_id) -{ - int result = 0; - uint32_t unsigned_pre_key_id_result = 0; - session_signed_pre_key *our_signed_pre_key = 0; - ratchet_identity_key_pair *our_identity_key = 0; - bob_signal_protocol_parameters *parameters = 0; - session_pre_key *session_our_one_time_pre_key = 0; - ec_key_pair *our_one_time_pre_key = 0; - session_state *state = 0; - uint32_t local_registration_id = 0; - - int has_session_state = session_record_has_session_state(record, - pre_key_signal_message_get_message_version(message), - pre_key_signal_message_get_base_key(message)); - if(has_session_state) { - signal_log(builder->global_context, SG_LOG_INFO, "We've already setup a session for this V3 message, letting bundled message fall through..."); - result = 0; - goto complete; - } - - result = signal_protocol_signed_pre_key_load_key(builder->store, - &our_signed_pre_key, - pre_key_signal_message_get_signed_pre_key_id(message)); - if(result < 0) { - goto complete; - } - - result = signal_protocol_identity_get_key_pair(builder->store, &our_identity_key); - if(result < 0) { - goto complete; - } - - if(pre_key_signal_message_has_pre_key_id(message)) { - result = signal_protocol_pre_key_load_key(builder->store, - &session_our_one_time_pre_key, - pre_key_signal_message_get_pre_key_id(message)); - if(result < 0) { - goto complete; - } - our_one_time_pre_key = session_pre_key_get_key_pair(session_our_one_time_pre_key); - } - - result = bob_signal_protocol_parameters_create( - ¶meters, - our_identity_key, - session_signed_pre_key_get_key_pair(our_signed_pre_key), - our_one_time_pre_key, - session_signed_pre_key_get_key_pair(our_signed_pre_key), - pre_key_signal_message_get_identity_key(message), - pre_key_signal_message_get_base_key(message)); - if(result < 0) { - goto complete; - } - - if(!session_record_is_fresh(record)) { - result = session_record_archive_current_state(record); - if(result < 0) { - goto complete; - } - } - - state = session_record_get_state(record); - - result = ratcheting_session_bob_initialize( - state, parameters, - builder->global_context); - if(result < 0) { - goto complete; - } - - result = signal_protocol_identity_get_local_registration_id(builder->store, &local_registration_id); - if(result < 0) { - goto complete; - } - - session_state_set_local_registration_id(state, local_registration_id); - session_state_set_remote_registration_id(state, - pre_key_signal_message_get_registration_id(message)); - session_state_set_alice_base_key(state, - pre_key_signal_message_get_base_key(message));; - - if(pre_key_signal_message_has_pre_key_id(message) && - pre_key_signal_message_get_pre_key_id(message) != PRE_KEY_MEDIUM_MAX_VALUE) { - unsigned_pre_key_id_result = pre_key_signal_message_get_pre_key_id(message); - result = 1; - } - else { - result = 0; - } - -complete: - SIGNAL_UNREF(parameters); - SIGNAL_UNREF(our_identity_key); - SIGNAL_UNREF(our_signed_pre_key); - SIGNAL_UNREF(session_our_one_time_pre_key); - if(result >= 0) { - *unsigned_pre_key_id = unsigned_pre_key_id_result; - } - return result; -} - -int session_builder_process_pre_key_bundle(session_builder *builder, session_pre_key_bundle *bundle) -{ - int result = 0; - session_record *record = 0; - ec_key_pair *our_base_key = 0; - ratchet_identity_key_pair *our_identity_key = 0; - alice_signal_protocol_parameters *parameters = 0; - ec_public_key *signed_pre_key = 0; - ec_public_key *pre_key = 0; - ec_public_key *their_identity_key = 0; - ec_public_key *their_signed_pre_key = 0; - ec_public_key *their_one_time_pre_key = 0; - int has_their_one_time_pre_key_id = 0; - uint32_t their_one_time_pre_key_id = 0; - session_state *state = 0; - uint32_t local_registration_id = 0; - - assert(builder); - assert(builder->store); - assert(bundle); - signal_lock(builder->global_context); - - result = signal_protocol_identity_is_trusted_identity(builder->store, - builder->remote_address, - session_pre_key_bundle_get_identity_key(bundle)); - if(result < 0) { - goto complete; - } - if(result == 0) { - result = SG_ERR_UNTRUSTED_IDENTITY; - goto complete; - } - - signed_pre_key = session_pre_key_bundle_get_signed_pre_key(bundle); - pre_key = session_pre_key_bundle_get_pre_key(bundle); - - if(signed_pre_key) { - ec_public_key *identity_key = session_pre_key_bundle_get_identity_key(bundle); - signal_buffer *signature = session_pre_key_bundle_get_signed_pre_key_signature(bundle); - - signal_buffer *serialized_signed_pre_key = 0; - result = ec_public_key_serialize(&serialized_signed_pre_key, signed_pre_key); - if(result < 0) { - goto complete; - } - - result = curve_verify_signature(identity_key, - signal_buffer_data(serialized_signed_pre_key), - signal_buffer_len(serialized_signed_pre_key), - signal_buffer_data(signature), - signal_buffer_len(signature)); - - signal_buffer_free(serialized_signed_pre_key); - - if(result == 0) { - signal_log(builder->global_context, SG_LOG_WARNING, "invalid signature on device key!"); - result = SG_ERR_INVALID_KEY; - } - if(result < 0) { - goto complete; - } - } - - if(!signed_pre_key) { - result = SG_ERR_INVALID_KEY; - signal_log(builder->global_context, SG_LOG_WARNING, "no signed pre key!"); - goto complete; - } - - result = signal_protocol_session_load_session(builder->store, &record, builder->remote_address); - if(result < 0) { - goto complete; - } - - result = curve_generate_key_pair(builder->global_context, &our_base_key); - if(result < 0) { - goto complete; - } - - their_identity_key = session_pre_key_bundle_get_identity_key(bundle); - their_signed_pre_key = signed_pre_key; - their_one_time_pre_key = pre_key; - - if(their_one_time_pre_key) { - has_their_one_time_pre_key_id = 1; - their_one_time_pre_key_id = session_pre_key_bundle_get_pre_key_id(bundle); - } - - result = signal_protocol_identity_get_key_pair(builder->store, &our_identity_key); - if(result < 0) { - goto complete; - } - - result = alice_signal_protocol_parameters_create(¶meters, - our_identity_key, - our_base_key, - their_identity_key, - their_signed_pre_key, - their_one_time_pre_key, - their_signed_pre_key); - if(result < 0) { - goto complete; - } - - if(!session_record_is_fresh(record)) { - result = session_record_archive_current_state(record); - if(result < 0) { - goto complete; - } - } - - state = session_record_get_state(record); - - result = ratcheting_session_alice_initialize( - state, parameters, - builder->global_context); - if(result < 0) { - goto complete; - } - - session_state_set_unacknowledged_pre_key_message(state, - has_their_one_time_pre_key_id ? &their_one_time_pre_key_id : 0, - session_pre_key_bundle_get_signed_pre_key_id(bundle), - ec_key_pair_get_public(our_base_key)); - - result = signal_protocol_identity_get_local_registration_id(builder->store, &local_registration_id); - if(result < 0) { - goto complete; - } - - session_state_set_local_registration_id(state, local_registration_id); - session_state_set_remote_registration_id(state, - session_pre_key_bundle_get_registration_id(bundle)); - session_state_set_alice_base_key(state, ec_key_pair_get_public(our_base_key)); - - result = signal_protocol_session_store_session(builder->store, builder->remote_address, record); - if(result < 0) { - goto complete; - } - - result = signal_protocol_identity_save_identity(builder->store, - builder->remote_address, - their_identity_key); - if(result < 0) { - goto complete; - } - -complete: - SIGNAL_UNREF(record); - SIGNAL_UNREF(our_base_key); - SIGNAL_UNREF(our_identity_key); - SIGNAL_UNREF(parameters); - signal_unlock(builder->global_context); - return result; -} - -void session_builder_free(session_builder *builder) -{ - if(builder) { - free(builder); - } -} |