#include "gnunet_common.h"
#include "gnunet_util_lib.h"
#include "gnunet_pils_service.h"
#include "gnunet_messenger_service.h"

Include dependency graph for messenger_api_message.h:

This graph shows which files directly or indirectly include this file:

Macros
#define	GNUNET_MESSENGER_SALT_ANNOUNCEMENT_KEY "gnunet-messenger-announcement-key-k*d-p!80"

#define	GNUNET_MESSENGER_SALT_EPOCH_KEY "gnunet-messenger-epoch-key-ePGN3bGR-}*i$<2"

#define	GNUNET_MESSENGER_SALT_GROUP_KEY "gnunet-messenger-group-key-L)&7{4i(WSEPpR-"

#define	GNUNET_MESSENGER_SALT_SECRET_KEY "gnunet-messenger-secret-key-}xJ(eTuk[+xu{S"

#define	GNUNET_MESSENGER_SALT_ENCRYPTION_KEY "gnunet-messenger-encryption-key-9*Qaj7A+zv"

#define	GNUNET_MESSENGER_SALT_EPOCH_IV "gnunet-messenger-epoch-iv"

#define	GNUNET_MESSENGER_SALT_ENCRYPTION_IV "gnunet-messenger-encryption-iv"

#define	GNUNET_MESSENGER_SALT_SECRET_IV "gnunet-messenger-secret-iv"

#define	GNUNET_MESSENGER_MAX_MESSAGE_SIZE

#define	GNUNET_MESSENGER_PADDING_MIN (sizeof(uint16_t) + sizeof(char))

#define	GNUNET_MESSENGER_PADDING_LEVEL0 (512)

#define	GNUNET_MESSENGER_PADDING_LEVEL1 (4096)

#define	GNUNET_MESSENGER_PADDING_LEVEL2 (32768)

Enumerations
enum	GNUNET_MESSENGER_PackMode { GNUNET_MESSENGER_PACK_MODE_ENVELOPE = 0x1 , GNUNET_MESSENGER_PACK_MODE_UNKNOWN = 0x0 }

Functions
struct GNUNET_MESSENGER_Message *	create_message (enum GNUNET_MESSENGER_MessageKind kind)
	Creates and allocates a new message with a specific kind.

struct GNUNET_MESSENGER_Message *	copy_message (const struct GNUNET_MESSENGER_Message *message)
	Creates and allocates a copy of a given message.

void	copy_message_header (struct GNUNET_MESSENGER_Message message, const struct GNUNET_MESSENGER_MessageHeader header)
	Copy message header details from another message to a given message.

void	cleanup_message (struct GNUNET_MESSENGER_Message *message)
	Frees the messages body memory.

void	destroy_message (struct GNUNET_MESSENGER_Message *message)
	Destroys a message and frees its memory fully.

enum GNUNET_GenericReturnValue	is_message_session_bound (const struct GNUNET_MESSENGER_Message *message)
	Returns if the message should be bound to a member session.

uint16_t	get_message_kind_size (enum GNUNET_MESSENGER_MessageKind kind, enum GNUNET_GenericReturnValue include_header)
	Returns the minimal size in bytes to encode a message of a specific kind.

uint16_t	get_message_size (const struct GNUNET_MESSENGER_Message *message, enum GNUNET_GenericReturnValue include_header)
	Returns the exact size in bytes to encode a given message.

void	encode_message_signature (const struct GNUNET_MESSENGER_Message message, uint16_t length, char buffer)
	Encodes the signature of a given message into a buffer of a maximum length in bytes.

void	encode_message (const struct GNUNET_MESSENGER_Message message, uint16_t length, char buffer, enum GNUNET_GenericReturnValue include_header)
	Encodes a given message into a buffer of a maximum length in bytes.

enum GNUNET_GenericReturnValue	decode_message (struct GNUNET_MESSENGER_Message message, uint16_t length, const char buffer, enum GNUNET_GenericReturnValue include_header, uint16_t *padding)
	Decodes a message from a given buffer of a maximum length in bytes.

void	hash_message (const struct GNUNET_MESSENGER_Message message, uint16_t length, const char buffer, struct GNUNET_HashCode *hash)
	Calculates a hash of a given buffer with a length in bytes from a message.

void	sign_message (struct GNUNET_MESSENGER_Message message, const struct GNUNET_HashCode hash, const struct GNUNET_CRYPTO_BlindablePrivateKey *key)
	Signs the hash of a message with a given private key.

struct GNUNET_PILS_Operation *	sign_message_by_peer (struct GNUNET_MESSENGER_Message message, const struct GNUNET_HashCode hash, struct GNUNET_PILS_Handle pils, const GNUNET_PILS_SignResultCallback sign_cb, void cls)
	Signs the hash of a message with the peer identity of a given pils service going into a callback with a custom closure on success.

enum GNUNET_GenericReturnValue	sign_message_by_key (struct GNUNET_MESSENGER_Message message, const struct GNUNET_CRYPTO_SymmetricSessionKey key)
	Signs the message body via it's own hmac with a specific shared key.

enum GNUNET_GenericReturnValue	verify_message (const struct GNUNET_MESSENGER_Message message, const struct GNUNET_HashCode hash, const struct GNUNET_CRYPTO_BlindablePublicKey *key)
	Verifies the signature of a given message and its hash with a specific public key.

enum GNUNET_GenericReturnValue	verify_message_by_peer (const struct GNUNET_MESSENGER_Message message, const struct GNUNET_HashCode hash, const struct GNUNET_PeerIdentity *identity)
	Verifies the signature of a given message and its hash with a specific peer's identity.

enum GNUNET_GenericReturnValue	verify_message_by_key (const struct GNUNET_MESSENGER_Message message, const struct GNUNET_CRYPTO_SymmetricSessionKey key)
	Verifies the hmac of a given message body with a specific shared key.

enum GNUNET_GenericReturnValue	encrypt_message (struct GNUNET_MESSENGER_Message message, const struct GNUNET_CRYPTO_HpkePublicKey hpke_key)
	Encrypts a message using a given public key and replaces its body and kind with the now private encrypted message.

enum GNUNET_GenericReturnValue	decrypt_message (struct GNUNET_MESSENGER_Message message, const struct GNUNET_CRYPTO_HpkePrivateKey hpke_key)
	Decrypts a private message using a given private key and replaces its body and kind with the inner encrypted message.

struct GNUNET_MESSENGER_Message *	transcribe_message (const struct GNUNET_MESSENGER_Message message, const struct GNUNET_CRYPTO_BlindablePublicKey key)
	Transcribes a message as a new transcript message using a given public key from the recipient of the encrypted message content.

enum GNUNET_GenericReturnValue	encrypt_secret_message (struct GNUNET_MESSENGER_Message message, const union GNUNET_MESSENGER_EpochIdentifier identifier, const struct GNUNET_CRYPTO_SymmetricSessionKey *key)
	Encrypts a message using a given shared key from an announcement of an epoch and replaces its body and kind with the inner encrypted message.

enum GNUNET_GenericReturnValue	decrypt_secret_message (struct GNUNET_MESSENGER_Message message, const struct GNUNET_CRYPTO_SymmetricSessionKey key)
	Decrypts a secret message using a given shared key and replaces its body and kind with the inner encrypted message.

enum GNUNET_GenericReturnValue	read_transcript_message (struct GNUNET_MESSENGER_Message *message)
	Read the original message from a transcript message and replaces its body and kind with the inner encrypted message.

enum GNUNET_GenericReturnValue	extract_access_message_key (const struct GNUNET_MESSENGER_Message message, const struct GNUNET_CRYPTO_HpkePrivateKey key, struct GNUNET_CRYPTO_SymmetricSessionKey *shared_key)
	Extracts the shared epoch or group key from an access message using the private ephemeral key from an epoch and verifies it via the HMAC from the message body.

enum GNUNET_GenericReturnValue	extract_authorization_message_key (struct GNUNET_MESSENGER_Message message, const struct GNUNET_CRYPTO_SymmetricSessionKey key, struct GNUNET_CRYPTO_SymmetricSessionKey *shared_key)
	Extracts the shared epoch or group key from an authorization message using a previously exchanged shared key and verifies it via the HMAC from the message body.

struct GNUNET_TIME_Relative	get_message_timeout (const struct GNUNET_MESSENGER_Message *message)
	Return the relative timeout of the content from a given message that controls when a delayed handling action of this message needs to be processed at least.

struct GNUNET_MQ_Envelope *	pack_message (struct GNUNET_MESSENGER_Message message, struct GNUNET_HashCode hash, enum GNUNET_MESSENGER_PackMode mode)
	Encodes the message to pack it into a newly allocated envelope if mode is equal to GNUNET_MESSENGER_PACK_MODE_ENVELOPE.

enum GNUNET_GenericReturnValue	is_peer_message (const struct GNUNET_MESSENGER_Message *message)
	Returns whether a specific kind of message can be sent by the service without usage of a clients private key.

enum GNUNET_GenericReturnValue	is_service_message (const struct GNUNET_MESSENGER_Message *message)
	Returns whether a specific kind of message contains service critical information.

enum GNUNET_GenericReturnValue	is_epoch_message (const struct GNUNET_MESSENGER_Message *message)
	Returns whether a certain kind of message from storage contains some specific details that might be required for the overall message graph to function as intended.

enum GNUNET_GenericReturnValue	filter_message_sending (const struct GNUNET_MESSENGER_Message *message)
	Returns whether a specific kind of message should be sent by a client.

const struct GNUNET_ShortHashCode *	get_message_discourse (const struct GNUNET_MESSENGER_Message *message)
	Returns the discourse hash of a message depending on its kind.

Macro Definition Documentation

◆ GNUNET_MESSENGER_SALT_ANNOUNCEMENT_KEY

#define GNUNET_MESSENGER_SALT_ANNOUNCEMENT_KEY "gnunet-messenger-announcement-key-k*d-p!80"

Definition at line 35 of file messenger_api_message.h.

                                        {4i(WSEPpR-"
#define GNUNET_MESSENGER_SALT_SECRET_KEY \
        "gnunet-messenger-secret-key-}xJ(eTuk[+xu{S"
#define GNUNET_MESSENGER_SALT_ENCRYPTION_KEY \
        "gnunet-messenger-encryption-key-9*Qaj7A+zv"
 
#define GNUNET_MESSENGER_SALT_EPOCH_IV "gnunet-messenger-epoch-iv"
#define GNUNET_MESSENGER_SALT_ENCRYPTION_IV "gnunet-messenger-encryption-iv"
#define GNUNET_MESSENGER_SALT_SECRET_IV "gnunet-messenger-secret-iv"
 
#define GNUNET_MESSENGER_MAX_MESSAGE_SIZE (GNUNET_MAX_MESSAGE_SIZE \
                                           - GNUNET_MIN_MESSAGE_SIZE)
 
#define GNUNET_MESSENGER_PADDING_MIN (sizeof(uint16_t) + sizeof(char))
#define GNUNET_MESSENGER_PADDING_LEVEL0 (512)
#define GNUNET_MESSENGER_PADDING_LEVEL1 (4096)
#define GNUNET_MESSENGER_PADDING_LEVEL2 (32768)
 
enum GNUNET_MESSENGER_PackMode
{
  GNUNET_MESSENGER_PACK_MODE_ENVELOPE = 0x1,
  GNUNET_MESSENGER_PACK_MODE_UNKNOWN = 0x0,
};
 
struct GNUNET_MESSENGER_Message*
create_message (enum GNUNET_MESSENGER_MessageKind kind);
 
struct GNUNET_MESSENGER_Message*
copy_message (const struct GNUNET_MESSENGER_Message *message);
 
void
copy_message_header (struct GNUNET_MESSENGER_Message *message,
                     const struct GNUNET_MESSENGER_MessageHeader *header);
 
void
cleanup_message (struct GNUNET_MESSENGER_Message *message);
 
void
destroy_message (struct GNUNET_MESSENGER_Message *message);
 
enum GNUNET_GenericReturnValue
is_message_session_bound (const struct GNUNET_MESSENGER_Message *message);
 
uint16_t
get_message_kind_size (enum GNUNET_MESSENGER_MessageKind kind,
                       enum GNUNET_GenericReturnValue include_header);
 
uint16_t
get_message_size (const struct GNUNET_MESSENGER_Message *message,
                  enum GNUNET_GenericReturnValue include_header);
 
void
encode_message_signature (const struct GNUNET_MESSENGER_Message *message,
                          uint16_t length,
                          char *buffer);
 
void
encode_message (const struct GNUNET_MESSENGER_Message *message,
                uint16_t length,
                char *buffer,
                enum GNUNET_GenericReturnValue include_header);
 
enum GNUNET_GenericReturnValue
decode_message (struct GNUNET_MESSENGER_Message *message,
                uint16_t length,
                const char *buffer,
                enum GNUNET_GenericReturnValue include_header,
                uint16_t *padding);
 
void
hash_message (const struct GNUNET_MESSENGER_Message *message,
              uint16_t length,
              const char *buffer,
              struct GNUNET_HashCode *hash);
 
void
sign_message (struct GNUNET_MESSENGER_Message *message,
              const struct GNUNET_HashCode *hash,
              const struct GNUNET_CRYPTO_BlindablePrivateKey *key);
 
struct GNUNET_PILS_Operation*
sign_message_by_peer (struct GNUNET_MESSENGER_Message *message,
                      const struct GNUNET_HashCode *hash,
                      struct GNUNET_PILS_Handle *pils,
                      const GNUNET_PILS_SignResultCallback sign_cb,
                      void *cls);
 
enum GNUNET_GenericReturnValue
sign_message_by_key (struct GNUNET_MESSENGER_Message *message,
                     const struct GNUNET_CRYPTO_SymmetricSessionKey *key);
 
enum GNUNET_GenericReturnValue
verify_message (const struct GNUNET_MESSENGER_Message *message,
                const struct GNUNET_HashCode *hash,
                const struct GNUNET_CRYPTO_BlindablePublicKey *key);
 
enum GNUNET_GenericReturnValue
verify_message_by_peer (const struct GNUNET_MESSENGER_Message *message,
                        const struct GNUNET_HashCode *hash,
                        const struct GNUNET_PeerIdentity *identity);
 
enum GNUNET_GenericReturnValue
verify_message_by_key (const struct GNUNET_MESSENGER_Message *message,
                       const struct GNUNET_CRYPTO_SymmetricSessionKey *key);
 
enum GNUNET_GenericReturnValue
encrypt_message (struct GNUNET_MESSENGER_Message *message,
                 const struct GNUNET_CRYPTO_HpkePublicKey *hpke_key);
 
enum GNUNET_GenericReturnValue
decrypt_message (struct GNUNET_MESSENGER_Message *message,
                 const struct GNUNET_CRYPTO_HpkePrivateKey *hpke_key);
 
struct GNUNET_MESSENGER_Message*
transcribe_message (const struct GNUNET_MESSENGER_Message *message,
                    const struct GNUNET_CRYPTO_BlindablePublicKey *key);
 
enum GNUNET_GenericReturnValue
encrypt_secret_message (struct GNUNET_MESSENGER_Message *message,
                        const union GNUNET_MESSENGER_EpochIdentifier *identifier
                        ,
                        const struct GNUNET_CRYPTO_SymmetricSessionKey *key);
 
enum GNUNET_GenericReturnValue
decrypt_secret_message (struct GNUNET_MESSENGER_Message *message,
                        const struct GNUNET_CRYPTO_SymmetricSessionKey *key);
 
enum GNUNET_GenericReturnValue
read_transcript_message (struct GNUNET_MESSENGER_Message *message);
 
enum GNUNET_GenericReturnValue
extract_access_message_key (const struct GNUNET_MESSENGER_Message *message,
                            const struct GNUNET_CRYPTO_HpkePrivateKey *key,
                            struct GNUNET_CRYPTO_SymmetricSessionKey *
                            shared_key);
 
enum GNUNET_GenericReturnValue
extract_authorization_message_key (struct GNUNET_MESSENGER_Message *message,
                                   const struct
                                   GNUNET_CRYPTO_SymmetricSessionKey *key,
                                   struct GNUNET_CRYPTO_SymmetricSessionKey *
                                   shared_key);
 
struct GNUNET_TIME_Relative
get_message_timeout (const struct GNUNET_MESSENGER_Message *message);
 
struct GNUNET_MQ_Envelope*
pack_message (struct GNUNET_MESSENGER_Message *message,
              struct GNUNET_HashCode *hash,
              enum GNUNET_MESSENGER_PackMode mode);
 
enum GNUNET_GenericReturnValue
is_peer_message (const struct GNUNET_MESSENGER_Message *message);
 
enum GNUNET_GenericReturnValue
is_service_message (const struct GNUNET_MESSENGER_Message *message);
 
enum GNUNET_GenericReturnValue
is_epoch_message (const struct GNUNET_MESSENGER_Message *message);
 
enum GNUNET_GenericReturnValue
filter_message_sending (const struct GNUNET_MESSENGER_Message *message);
 
const struct GNUNET_ShortHashCode*
get_message_discourse (const struct GNUNET_MESSENGER_Message *message);
 
#endif // GNUNET_MESSENGER_API_MESSAGE_H

◆ GNUNET_MESSENGER_SALT_EPOCH_KEY

#define GNUNET_MESSENGER_SALT_EPOCH_KEY "gnunet-messenger-epoch-key-ePGN3bGR-}*i$<2"

Definition at line 37 of file messenger_api_message.h.

◆ GNUNET_MESSENGER_SALT_GROUP_KEY

#define GNUNET_MESSENGER_SALT_GROUP_KEY "gnunet-messenger-group-key-L)&7{4i(WSEPpR-"

Definition at line 39 of file messenger_api_message.h.

40 {4i(WSEPpR-"

◆ GNUNET_MESSENGER_SALT_SECRET_KEY

#define GNUNET_MESSENGER_SALT_SECRET_KEY "gnunet-messenger-secret-key-}xJ(eTuk[+xu{S"

Definition at line 41 of file messenger_api_message.h.

42 {S"

◆ GNUNET_MESSENGER_SALT_ENCRYPTION_KEY

#define GNUNET_MESSENGER_SALT_ENCRYPTION_KEY "gnunet-messenger-encryption-key-9*Qaj7A+zv"

Definition at line 43 of file messenger_api_message.h.

◆ GNUNET_MESSENGER_SALT_EPOCH_IV

#define GNUNET_MESSENGER_SALT_EPOCH_IV "gnunet-messenger-epoch-iv"

Definition at line 46 of file messenger_api_message.h.

◆ GNUNET_MESSENGER_SALT_ENCRYPTION_IV

#define GNUNET_MESSENGER_SALT_ENCRYPTION_IV "gnunet-messenger-encryption-iv"

Definition at line 47 of file messenger_api_message.h.

◆ GNUNET_MESSENGER_SALT_SECRET_IV

#define GNUNET_MESSENGER_SALT_SECRET_IV "gnunet-messenger-secret-iv"

Definition at line 48 of file messenger_api_message.h.

◆ GNUNET_MESSENGER_MAX_MESSAGE_SIZE

#define GNUNET_MESSENGER_MAX_MESSAGE_SIZE

Value:

(GNUNET_MAX_MESSAGE_SIZE \

- GNUNET_MIN_MESSAGE_SIZE)

GNUNET_MIN_MESSAGE_SIZE

#define GNUNET_MIN_MESSAGE_SIZE

Smallest supported message.

Definition gnunet_util_lib.h:57

GNUNET_MAX_MESSAGE_SIZE

#define GNUNET_MAX_MESSAGE_SIZE

Largest supported message (to be precise, one byte more than the largest possible message,...

Definition gnunet_util_lib.h:52

Definition at line 50 of file messenger_api_message.h.

◆ GNUNET_MESSENGER_PADDING_MIN

#define GNUNET_MESSENGER_PADDING_MIN (sizeof(uint16_t) + sizeof(char))

Definition at line 53 of file messenger_api_message.h.

◆ GNUNET_MESSENGER_PADDING_LEVEL0

#define GNUNET_MESSENGER_PADDING_LEVEL0 (512)

Definition at line 54 of file messenger_api_message.h.

◆ GNUNET_MESSENGER_PADDING_LEVEL1

#define GNUNET_MESSENGER_PADDING_LEVEL1 (4096)

Definition at line 55 of file messenger_api_message.h.

◆ GNUNET_MESSENGER_PADDING_LEVEL2

#define GNUNET_MESSENGER_PADDING_LEVEL2 (32768)

Definition at line 56 of file messenger_api_message.h.

Enumeration Type Documentation

◆ GNUNET_MESSENGER_PackMode

enum GNUNET_MESSENGER_PackMode

Enumerator
GNUNET_MESSENGER_PACK_MODE_ENVELOPE
GNUNET_MESSENGER_PACK_MODE_UNKNOWN

Definition at line 58 of file messenger_api_message.h.

{
  GNUNET_MESSENGER_PACK_MODE_ENVELOPE = 0x1,
  GNUNET_MESSENGER_PACK_MODE_UNKNOWN = 0x0,
};

Function Documentation

◆ create_message()

struct GNUNET_MESSENGER_Message * create_message ( enum GNUNET_MESSENGER_MessageKind kind )

Creates and allocates a new message with a specific kind.

Parameters

[in] kind Kind of message

Returns: New message

Definition at line 50 of file messenger_api_message.c.

{
  struct GNUNET_MESSENGER_Message *message;
 
  message = GNUNET_new (struct GNUNET_MESSENGER_Message);
  message->header.kind = kind;
 
  switch (message->header.kind)
  {
  case GNUNET_MESSENGER_KIND_NAME:
    message->body.name.name = NULL;
    break;
  case GNUNET_MESSENGER_KIND_TEXT:
    message->body.text.text = NULL;
    break;
  case GNUNET_MESSENGER_KIND_FILE:
    message->body.file.uri = NULL;
    break;
  case GNUNET_MESSENGER_KIND_PRIVATE:
    message->body.privacy.length = 0;
    message->body.privacy.data = NULL;
    break;
  case GNUNET_MESSENGER_KIND_TICKET:
    message->body.ticket.identifier = NULL;
    break;
  case GNUNET_MESSENGER_KIND_TRANSCRIPT:
    message->body.transcript.length = 0;
    message->body.transcript.data = NULL;
    break;
  case GNUNET_MESSENGER_KIND_TAG:
    message->body.tag.tag = NULL;
    break;
  case GNUNET_MESSENGER_KIND_TALK:
    message->body.talk.length = 0;
    message->body.talk.data = NULL;
    break;
  case GNUNET_MESSENGER_KIND_SECRET:
    message->body.secret.length = 0;
    message->body.secret.data = NULL;
    break;
  default:
    break;
  }
 
  return message;
}

Referenced by create_message_access(), create_message_announcement(), create_message_appeal(), create_message_authorization(), create_message_connection(), create_message_deletion(), create_message_group(), create_message_id(), create_message_info(), create_message_join(), create_message_key(), create_message_leave(), create_message_merge(), create_message_miss(), create_message_name(), create_message_peer(), create_message_request(), create_message_revolution(), create_message_subscription(), get_store_message(), and transcribe_message().

Here is the caller graph for this function:

◆ copy_message()

struct GNUNET_MESSENGER_Message * copy_message ( const struct GNUNET_MESSENGER_Message * message )

Creates and allocates a copy of a given message.

Parameters

[in] message Message

Returns: New message

Definition at line 99 of file messenger_api_message.c.

{
  struct GNUNET_MESSENGER_Message *copy;
 
  GNUNET_assert (message);
 
  copy = GNUNET_new (struct GNUNET_MESSENGER_Message);
  GNUNET_memcpy (copy, message, sizeof(struct GNUNET_MESSENGER_Message));
 
  switch (message->header.kind)
  {
  case GNUNET_MESSENGER_KIND_NAME:
    copy->body.name.name = message->body.name.name? GNUNET_strdup (
      message->body.name.name) : NULL;
    break;
  case GNUNET_MESSENGER_KIND_TEXT:
    copy->body.text.text = message->body.text.text? GNUNET_strdup (
      message->body.text.text) : NULL;
    break;
  case GNUNET_MESSENGER_KIND_FILE:
    copy->body.file.uri = message->body.file.uri? GNUNET_strdup (
      message->body.file.uri) : NULL;
    break;
  case GNUNET_MESSENGER_KIND_PRIVATE:
    copy->body.privacy.data = copy->body.privacy.length ? GNUNET_malloc (
      copy->body.privacy.length) : NULL;
 
    if (copy->body.privacy.data)
      GNUNET_memcpy (copy->body.privacy.data, message->body.privacy.data,
                     copy->body.privacy.length);
 
    break;
  case GNUNET_MESSENGER_KIND_TICKET:
    copy->body.ticket.identifier = message->body.ticket.identifier?
                                   GNUNET_strdup (
      message->body.ticket.identifier) : NULL;
    break;
  case GNUNET_MESSENGER_KIND_TRANSCRIPT:
    copy->body.transcript.data = copy->body.transcript.length ? GNUNET_malloc (
      copy->body.transcript.length) : NULL;
 
    if (copy->body.transcript.data)
      GNUNET_memcpy (copy->body.transcript.data, message->body.transcript.data,
                     copy->body.transcript.length);
 
    break;
  case GNUNET_MESSENGER_KIND_TAG:
    copy->body.tag.tag = message->body.tag.tag? GNUNET_strdup (
      message->body.tag.tag) : NULL;
    break;
  case GNUNET_MESSENGER_KIND_TALK:
    copy->body.talk.data = copy->body.talk.length ? GNUNET_malloc (
      copy->body.talk.length) : NULL;
 
    if (copy->body.talk.data)
      GNUNET_memcpy (copy->body.talk.data, message->body.talk.data,
                     copy->body.talk.length);
 
    break;
  case GNUNET_MESSENGER_KIND_SECRET:
    copy->body.secret.data = copy->body.secret.length ? GNUNET_malloc (
      copy->body.secret.length) : NULL;
 
    if (copy->body.secret.data)
      GNUNET_memcpy (copy->body.secret.data, message->body.secret.data,
                     copy->body.secret.length);
 
    break;
  default:
    break;
  }
 
  return copy;
}

Referenced by enqueue_message_control(), forward_tunnel_message(), GNUNET_MESSENGER_send_message(), handle_private_message(), handle_room_message(), handle_transcript_message(), handle_tunnel_message(), send_srv_handle_message(), and update_room_secret_message().

Here is the caller graph for this function:

◆ copy_message_header()

void copy_message_header	(	struct GNUNET_MESSENGER_Message *	message,
		const struct GNUNET_MESSENGER_MessageHeader *	header
	)

Copy message header details from another message to a given message.

Parameters

[in,out]	message	Message
[in]	header	Message header

Definition at line 176 of file messenger_api_message.c.

{
  enum GNUNET_MESSENGER_MessageKind kind;
 
  GNUNET_assert ((message) && (header));
 
  kind = message->header.kind;
 
  GNUNET_memcpy (&(message->header), header,
                 sizeof(struct GNUNET_MESSENGER_MessageHeader));
 
  message->header.kind = kind;
}

References GNUNET_assert, GNUNET_memcpy, GNUNET_MESSENGER_Message::header, and GNUNET_MESSENGER_MessageHeader::kind.

Referenced by handle_room_message(), and handle_transcript_message().

Here is the caller graph for this function:

◆ cleanup_message()

void cleanup_message ( struct GNUNET_MESSENGER_Message * message )

Frees the messages body memory.

Parameters

[in,out] message Message

Definition at line 243 of file messenger_api_message.c.

{
  GNUNET_assert (message);
 
  destroy_message_body (message->header.kind, &(message->body));
}

References GNUNET_MESSENGER_Message::body, destroy_message_body(), GNUNET_assert, GNUNET_MESSENGER_Message::header, and GNUNET_MESSENGER_MessageHeader::kind.

Referenced by check_recv_message(), check_send_message(), handle_recv_message(), handle_send_message(), and handle_tunnel_message().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ destroy_message()

void destroy_message ( struct GNUNET_MESSENGER_Message * message )

Destroys a message and frees its memory fully.

Parameters

[in,out] message Message

Definition at line 252 of file messenger_api_message.c.

{
  GNUNET_assert (message);
 
  destroy_message_body (message->header.kind, &(message->body));
 
  GNUNET_free (message);
}

References GNUNET_MESSENGER_Message::body, destroy_message_body(), GNUNET_assert, GNUNET_free, GNUNET_MESSENGER_Message::header, and GNUNET_MESSENGER_MessageHeader::kind.

Referenced by callback_tunnel_message_signed(), clear_queue_messages(), create_message_access(), create_message_announcement(), create_message_authorization(), create_message_peer(), create_message_revolution(), dequeue_from_messages(), dequeue_message_from_room(), destroy_message_control(), enqueue_to_messages(), forward_tunnel_message(), get_store_message(), handle_discourse_subscription(), handle_private_message(), handle_room_delayed_deletion(), handle_transcript_message(), iterate_cancel_signature(), iterate_destroy_message(), iterate_destroy_messages(), iterate_destroy_subscription(), iterate_flag_for_cleanup_discourse_message(), keep_subscription_alive(), send_message_to_room_with_key(), sign_srv_room_message(), task_message_control(), update_room_message(), and update_room_secret_message().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ is_message_session_bound()

enum GNUNET_GenericReturnValue is_message_session_bound ( const struct GNUNET_MESSENGER_Message * message )

Returns if the message should be bound to a member session.

Parameters

[in] message Message

Returns: GNUNET_YES or GNUNET_NO

Definition at line 263 of file messenger_api_message.c.

{
  GNUNET_assert (message);
 
  if ((GNUNET_MESSENGER_KIND_JOIN == message->header.kind) ||
      (GNUNET_MESSENGER_KIND_LEAVE == message->header.kind) ||
      (GNUNET_MESSENGER_KIND_NAME == message->header.kind) ||
      (GNUNET_MESSENGER_KIND_KEY == message->header.kind) ||
      (GNUNET_MESSENGER_KIND_ID == message->header.kind))
    return GNUNET_YES;
  else
    return GNUNET_NO;
}

References GNUNET_assert, GNUNET_MESSENGER_KIND_ID, GNUNET_MESSENGER_KIND_JOIN, GNUNET_MESSENGER_KIND_KEY, GNUNET_MESSENGER_KIND_LEAVE, GNUNET_MESSENGER_KIND_NAME, GNUNET_NO, GNUNET_YES, GNUNET_MESSENGER_Message::header, and GNUNET_MESSENGER_MessageHeader::kind.

Referenced by enqueue_message_to_room(), and update_member_session_history().

Here is the caller graph for this function:

◆ get_message_kind_size()

uint16_t get_message_kind_size	(	enum GNUNET_MESSENGER_MessageKind	kind,
		enum GNUNET_GenericReturnValue	include_header
	)

Returns the minimal size in bytes to encode a message of a specific kind.

Parameters

[in]	kind	Kind of message
[in]	include_header	Flag to include header

Returns: Minimal size to encode

Definition at line 459 of file messenger_api_message.c.

{
  uint16_t length;
 
  length = 0;
 
  if (GNUNET_YES == include_header)
  {
    length += member_size (struct GNUNET_MESSENGER_Message, header.timestamp);
    length += member_size (struct GNUNET_MESSENGER_Message, header.sender_id);
    length += member_size (struct GNUNET_MESSENGER_Message, header.previous);
  }
 
  length += sizeof(kind_t);
 
  return length + get_message_body_kind_size (kind);
}

References get_message_body_kind_size(), GNUNET_YES, GNUNET_MESSENGER_Message::header, member_size, GNUNET_MESSENGER_MessageHeader::previous, GNUNET_MESSENGER_MessageHeader::sender_id, and GNUNET_MESSENGER_MessageHeader::timestamp.

Referenced by calc_usual_padding(), check_recv_message(), check_send_message(), check_tunnel_message(), decode_message(), get_message_size(), and get_store_message().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ get_message_size()

uint16_t get_message_size	(	const struct GNUNET_MESSENGER_Message *	message,
		enum GNUNET_GenericReturnValue	include_header
	)

Returns the exact size in bytes to encode a given message.

Parameters

[in]	message	Message
[in]	include_header	Flag to include header

Returns: Size to encode

Definition at line 534 of file messenger_api_message.c.

{
  uint16_t length;
 
  GNUNET_assert (message);
 
  length = 0;
 
  if (GNUNET_YES == include_header)
    length += GNUNET_CRYPTO_blinded_key_signature_get_length (
      &(message->header.signature));
 
  length += get_message_kind_size (message->header.kind, include_header);
  length += get_message_body_size (message->header.kind, &(message->body));
 
  return length;
}

References GNUNET_MESSENGER_Message::body, get_message_body_size(), get_message_kind_size(), GNUNET_assert, GNUNET_CRYPTO_blinded_key_signature_get_length(), GNUNET_YES, GNUNET_MESSENGER_Message::header, GNUNET_MESSENGER_MessageHeader::kind, and GNUNET_MESSENGER_MessageHeader::signature.

Referenced by iterate_save_messages(), notify_srv_handle_message(), pack_message(), and send_message_to_room().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ encode_message_signature()

void encode_message_signature	(	const struct GNUNET_MESSENGER_Message *	message,
		uint16_t	length,
		char *	buffer
	)

Encodes the signature of a given message into a buffer of a maximum length in bytes.

Parameters

[in]	message	Message
[in]	length	Maximal length to encode
[out]	buffer	Buffer

Definition at line 863 of file messenger_api_message.c.

{
  uint16_t offset = 0;
 
  GNUNET_assert ((message) && (buffer));
 
  encode_step_signature (buffer, offset, &(message->header.signature),
                         length);
}

References encode_step_signature, GNUNET_assert, GNUNET_MESSENGER_Message::header, and GNUNET_MESSENGER_MessageHeader::signature.

Referenced by callback_srv_room_sign_result(), and send_message_to_room().

Here is the caller graph for this function:

◆ encode_message()

void encode_message	(	const struct GNUNET_MESSENGER_Message *	message,
		uint16_t	length,
		char *	buffer,
		enum GNUNET_GenericReturnValue	include_header
	)

Encodes a given message into a buffer of a maximum length in bytes.

Parameters

[in]	message	Message
[in]	length	Maximal length to encode
[out]	buffer	Buffer
[in]	include_header	Flag to include header

Definition at line 877 of file messenger_api_message.c.

{
  uint16_t offset;
  kind_t kind;
 
  GNUNET_assert ((message) && (buffer));
 
  offset = 0;
 
  if (GNUNET_YES == include_header)
    encode_step_signature (buffer, offset, &(message->header.signature),
                           length);
 
  kind = GNUNET_htobe32 ((kind_t) message->header.kind);
 
  if (GNUNET_YES == include_header)
  {
    encode_step (buffer, offset, &(message->header.timestamp));
    encode_step (buffer, offset, &(message->header.sender_id));
    encode_step (buffer, offset, &(message->header.previous));
  }
 
  encode_step (buffer, offset, &kind);
 
  encode_message_body (message->header.kind, &(message->body),
                       length, buffer, offset);
}

References GNUNET_MESSENGER_Message::body, encode_message_body(), encode_step, encode_step_signature, GNUNET_assert, GNUNET_htobe32, GNUNET_YES, GNUNET_MESSENGER_Message::header, GNUNET_MESSENGER_MessageHeader::kind, GNUNET_MESSENGER_MessageHeader::previous, GNUNET_MESSENGER_MessageHeader::sender_id, GNUNET_MESSENGER_MessageHeader::signature, and GNUNET_MESSENGER_MessageHeader::timestamp.

Referenced by iterate_save_messages(), notify_srv_handle_message(), pack_message(), and send_message_to_room().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ decode_message()

enum GNUNET_GenericReturnValue decode_message	(	struct GNUNET_MESSENGER_Message *	message,
		uint16_t	length,
		const char *	buffer,
		enum GNUNET_GenericReturnValue	include_header,
		uint16_t *	padding
	)

Decodes a message from a given buffer of a maximum length in bytes.

If the buffer is too small for a message of its decoded kind the function fails with resulting GNUNET_NO after decoding only the messages header.

On success the function returns GNUNET_YES.

Parameters

[out]	message	Message
[in]	length	Maximal length to decode
[in]	buffer	Buffer
[in]	include_header	Flag to include header
[out]	padding	Padding

Returns: GNUNET_YES on success, otherwise GNUNET_NO

Definition at line 1204 of file messenger_api_message.c.

{
  uint16_t offset;
  uint16_t count;
  kind_t kind;
 
  GNUNET_assert (
    (message) &&
    (buffer) &&
    (length >= get_message_kind_size (GNUNET_MESSENGER_KIND_UNKNOWN,
                                      include_header)));
 
  offset = 0;
 
  if (GNUNET_YES == include_header)
  {
    ssize_t result;
 
    result = GNUNET_CRYPTO_read_blinded_key_signature_from_buffer (
      &(message->header.signature), buffer, length - offset);
 
    if (result < 0)
      return GNUNET_NO;
    else
      offset += result;
  }
 
  count = length - offset;
  if (count < get_message_kind_size (GNUNET_MESSENGER_KIND_UNKNOWN,
                                     include_header))
    return GNUNET_NO;
 
  if (GNUNET_YES == include_header)
  {
    decode_step (buffer, offset, &(message->header.timestamp));
    decode_step (buffer, offset, &(message->header.sender_id));
    decode_step (buffer, offset, &(message->header.previous));
  }
 
  decode_step (buffer, offset, &kind);
  kind = GNUNET_be32toh (kind);
 
  message->header.kind = (enum GNUNET_MESSENGER_MessageKind) kind;
 
  if (count < get_message_kind_size (message->header.kind, include_header))
    return GNUNET_NO;
 
  {
    uint16_t result;
    result = decode_message_body (&(message->header.kind),
                                  &(message->body), length, buffer, offset);
 
    if (padding)
      *padding = result;
  }
 
  return GNUNET_YES;
}

References GNUNET_MESSENGER_Message::body, decode_message_body(), decode_step, get_message_kind_size(), GNUNET_assert, GNUNET_be32toh, GNUNET_CRYPTO_read_blinded_key_signature_from_buffer(), GNUNET_MESSENGER_KIND_UNKNOWN, GNUNET_NO, GNUNET_YES, GNUNET_MESSENGER_Message::header, GNUNET_MESSENGER_MessageHeader::kind, GNUNET_MESSENGER_MessageHeader::previous, result, GNUNET_MESSENGER_MessageHeader::sender_id, GNUNET_MESSENGER_MessageHeader::signature, and GNUNET_MESSENGER_MessageHeader::timestamp.

Referenced by check_recv_message(), check_send_message(), check_tunnel_message(), get_store_message(), handle_recv_message(), handle_send_message(), and handle_tunnel_message().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ hash_message()

void hash_message	(	const struct GNUNET_MESSENGER_Message *	message,
		uint16_t	length,
		const char *	buffer,
		struct GNUNET_HashCode *	hash
	)

Calculates a hash of a given buffer with a length in bytes from a message.

Parameters

[in]	message	Message
[in]	length	Length of buffer
[in]	buffer	Buffer
[out]	hash	Hash

Definition at line 1313 of file messenger_api_message.c.

{
  ssize_t offset;
 
  GNUNET_assert ((message) && (buffer) && (hash));
 
  offset = GNUNET_CRYPTO_blinded_key_signature_get_length (&(message->header.
                                                             signature));
 
  GNUNET_CRYPTO_hash (buffer + offset, length - offset, hash);
}

References GNUNET_assert, GNUNET_CRYPTO_blinded_key_signature_get_length(), GNUNET_CRYPTO_hash(), and GNUNET_MESSENGER_Message::header.

Referenced by check_tunnel_message(), get_store_message(), handle_tunnel_message(), pack_message(), and send_message_to_room().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ sign_message()

void sign_message	(	struct GNUNET_MESSENGER_Message *	message,
		const struct GNUNET_HashCode *	hash,
		const struct GNUNET_CRYPTO_BlindablePrivateKey *	key
	)

Signs the hash of a message with a given private key.

Parameters

[in,out]	message	Message
[in]	hash	Hash of message
[in]	key	Private key

Definition at line 1330 of file messenger_api_message.c.

{
  struct GNUNET_MESSENGER_MessageSignature signature;
 
  GNUNET_assert ((message) && (hash) && (key));
 
  GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Sign message by member: %s\n",
              GNUNET_h2s (hash));
 
  signature.purpose.purpose = htonl (GNUNET_SIGNATURE_PURPOSE_CHAT_MESSAGE);
  signature.purpose.size = htonl (sizeof(signature));
 
  GNUNET_memcpy (&(signature.hash), hash, sizeof(signature.hash));
 
  GNUNET_CRYPTO_blinded_key_sign (key, &signature,
                                  &(message->header.signature));
  message->header.signature.type = key->type;
}

References GNUNET_assert, GNUNET_CRYPTO_blinded_key_sign, GNUNET_ERROR_TYPE_DEBUG, GNUNET_h2s(), GNUNET_log, GNUNET_memcpy, GNUNET_SIGNATURE_PURPOSE_CHAT_MESSAGE, GNUNET_MESSENGER_MessageSignature::hash, GNUNET_MESSENGER_Message::header, key, GNUNET_CRYPTO_SignaturePurpose::purpose, GNUNET_MESSENGER_MessageSignature::purpose, GNUNET_MESSENGER_MessageHeader::signature, GNUNET_CRYPTO_SignaturePurpose::size, and GNUNET_CRYPTO_BlindableKeySignature::type.

Referenced by send_message_to_room().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ sign_message_by_peer()

struct GNUNET_PILS_Operation * sign_message_by_peer	(	struct GNUNET_MESSENGER_Message *	message,
		const struct GNUNET_HashCode *	hash,
		struct GNUNET_PILS_Handle *	pils,
		const GNUNET_PILS_SignResultCallback	sign_cb,
		void *	cls
	)

Signs the hash of a message with the peer identity of a given pils service going into a callback with a custom closure on success.

Parameters

[in,out]	message	Message
[in]	hash	Hash of message
[in,out]	pils	Pils handle
[in]	sign_cb	Signature callback
[in,out]	cls	Closure

Returns: Signature operation or NULL on failure

Definition at line 1353 of file messenger_api_message.c.

{
  struct GNUNET_MESSENGER_MessageSignature signature;
  struct GNUNET_PILS_Operation *operation;
 
  GNUNET_assert ((message) && (hash) && (pils));
 
  GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Sign message by peer: %s\n",
              GNUNET_h2s (hash));
 
  signature.purpose.purpose = htonl (GNUNET_SIGNATURE_PURPOSE_CHAT_MESSAGE);
  signature.purpose.size = htonl (sizeof (signature));
 
  GNUNET_memcpy (&(signature.hash), hash, sizeof (signature.hash));
 
  operation = GNUNET_PILS_sign_by_peer_identity (pils, &(signature.purpose),
                                                 sign_cb, cls);
 
  if (! operation)
    return NULL;
 
  message->header.signature.type = htonl (GNUNET_PUBLIC_KEY_TYPE_EDDSA);
  return operation;
}

References GNUNET_assert, GNUNET_ERROR_TYPE_DEBUG, GNUNET_h2s(), GNUNET_log, GNUNET_memcpy, GNUNET_PILS_sign_by_peer_identity(), GNUNET_PUBLIC_KEY_TYPE_EDDSA, GNUNET_SIGNATURE_PURPOSE_CHAT_MESSAGE, GNUNET_MESSENGER_MessageSignature::hash, GNUNET_MESSENGER_Message::header, pils, GNUNET_CRYPTO_SignaturePurpose::purpose, GNUNET_MESSENGER_MessageSignature::purpose, sign_cb(), GNUNET_MESSENGER_MessageHeader::signature, GNUNET_CRYPTO_SignaturePurpose::size, and GNUNET_CRYPTO_BlindableKeySignature::type.

Referenced by sign_srv_room_message().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ sign_message_by_key()

enum GNUNET_GenericReturnValue sign_message_by_key	(	struct GNUNET_MESSENGER_Message *	message,
		const struct GNUNET_CRYPTO_SymmetricSessionKey *	key
	)

Signs the message body via it's own hmac with a specific shared key.

It requires the message to be of a supported kind of message which contains such an hmac.

On success the message can be verified via verify_message_by_key() afterwards.

Parameters

[in,out]	message	Message
[in]	key	Shared key

Returns: GNUNET_YES on success, GNUNET_NO on failure, otherwise GNUNET_SYSERR

Definition at line 1460 of file messenger_api_message.c.

{
  struct GNUNET_HashCode *hmac;
 
  GNUNET_assert ((message) && (key));
 
  switch (message->header.kind)
  {
  case GNUNET_MESSENGER_KIND_ANNOUNCEMENT:
    hmac = &(message->body.announcement.hmac);
    break;
  case GNUNET_MESSENGER_KIND_ACCESS:
    hmac = &(message->body.access.hmac);
    break;
  case GNUNET_MESSENGER_KIND_REVOLUTION:
    hmac = &(message->body.revolution.hmac);
    break;
  case GNUNET_MESSENGER_KIND_AUTHORIZATION:
    hmac = &(message->body.authorization.hmac);
    break;
  default:
    hmac = NULL;
    break;
  }
 
  if (! hmac)
    return GNUNET_SYSERR;
 
  return calc_message_hmac (message, key, hmac);
}

Referenced by create_message_access(), create_message_announcement(), create_message_authorization(), and create_message_revolution().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ verify_message()

enum GNUNET_GenericReturnValue verify_message	(	const struct GNUNET_MESSENGER_Message *	message,
		const struct GNUNET_HashCode *	hash,
		const struct GNUNET_CRYPTO_BlindablePublicKey *	key
	)

Verifies the signature of a given message and its hash with a specific public key.

The function returns GNUNET_OK if the signature was valid, otherwise GNUNET_SYSERR.

Parameters

[in]	message	Message
[in]	hash	Hash of message
[in]	key	Public key

Returns: GNUNET_OK on success, otherwise GNUNET_SYSERR

Definition at line 1494 of file messenger_api_message.c.

{
  struct GNUNET_MESSENGER_MessageSignature signature;
 
  GNUNET_assert ((message) && (hash) && (key));
 
  if (key->type != message->header.signature.type)
    return GNUNET_SYSERR;
 
  signature.purpose.purpose = htonl (GNUNET_SIGNATURE_PURPOSE_CHAT_MESSAGE);
  signature.purpose.size = htonl (sizeof(signature));
 
  GNUNET_memcpy (&(signature.hash), hash, sizeof(signature.hash));
 
  return GNUNET_CRYPTO_blinded_key_signature_verify (
    GNUNET_SIGNATURE_PURPOSE_CHAT_MESSAGE, &signature,
    &(message->header.signature), key);
}

References GNUNET_assert, GNUNET_CRYPTO_blinded_key_signature_verify, GNUNET_memcpy, GNUNET_SIGNATURE_PURPOSE_CHAT_MESSAGE, GNUNET_SYSERR, GNUNET_MESSENGER_MessageSignature::hash, GNUNET_MESSENGER_Message::header, key, GNUNET_CRYPTO_SignaturePurpose::purpose, GNUNET_MESSENGER_MessageSignature::purpose, GNUNET_MESSENGER_MessageHeader::signature, GNUNET_CRYPTO_SignaturePurpose::size, and GNUNET_CRYPTO_BlindableKeySignature::type.

Referenced by verify_member_session_as_sender().

Here is the caller graph for this function:

◆ verify_message_by_peer()

enum GNUNET_GenericReturnValue verify_message_by_peer	(	const struct GNUNET_MESSENGER_Message *	message,
		const struct GNUNET_HashCode *	hash,
		const struct GNUNET_PeerIdentity *	identity
	)

Verifies the signature of a given message and its hash with a specific peer's identity.

The function returns GNUNET_OK if the signature was valid, otherwise GNUNET_SYSERR.

Parameters

[in]	message	Message
[in]	hash	Hash of message
[in]	identity	Peer identity

Returns: GNUNET_OK on success, otherwise GNUNET_SYSERR

Definition at line 1517 of file messenger_api_message.c.

{
  struct GNUNET_MESSENGER_MessageSignature signature;
 
  GNUNET_assert ((message) && (hash) && (identity));
 
  if (ntohl (GNUNET_PUBLIC_KEY_TYPE_EDDSA) != message->header.signature.type)
    return GNUNET_SYSERR;
 
  signature.purpose.purpose = htonl (GNUNET_SIGNATURE_PURPOSE_CHAT_MESSAGE);
  signature.purpose.size = htonl (sizeof(signature));
 
  GNUNET_memcpy (&(signature.hash), hash, sizeof(signature.hash));
 
  return GNUNET_CRYPTO_verify_peer_identity (
    GNUNET_SIGNATURE_PURPOSE_CHAT_MESSAGE, &(signature.purpose),
    &(message->header.signature.
      eddsa_signature), identity);
}

References GNUNET_assert, GNUNET_CRYPTO_verify_peer_identity(), GNUNET_memcpy, GNUNET_PUBLIC_KEY_TYPE_EDDSA, GNUNET_SIGNATURE_PURPOSE_CHAT_MESSAGE, GNUNET_SYSERR, GNUNET_MESSENGER_MessageSignature::hash, GNUNET_MESSENGER_Message::header, identity, GNUNET_CRYPTO_SignaturePurpose::purpose, GNUNET_MESSENGER_MessageSignature::purpose, GNUNET_MESSENGER_MessageHeader::signature, GNUNET_CRYPTO_SignaturePurpose::size, and GNUNET_CRYPTO_BlindableKeySignature::type.

Referenced by get_store_peer_of(), and verify_store_peer().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ verify_message_by_key()

enum GNUNET_GenericReturnValue verify_message_by_key	(	const struct GNUNET_MESSENGER_Message *	message,
		const struct GNUNET_CRYPTO_SymmetricSessionKey *	key
	)

Verifies the hmac of a given message body with a specific shared key.

The function returns GNUNET_OK if the signature was valid, otherwise GNUNET_SYSERR.

Parameters

[in]	message	Message
[in]	key	Shared key

Returns: GNUNET_OK on success, otherwise GNUNET_SYSERR

Definition at line 1541 of file messenger_api_message.c.

{
  const struct GNUNET_HashCode *msg_hmac;
  struct GNUNET_HashCode hmac;
 
  GNUNET_assert ((message) && (key));
 
  switch (message->header.kind)
  {
  case GNUNET_MESSENGER_KIND_ANNOUNCEMENT:
    msg_hmac = &(message->body.announcement.hmac);
    break;
  case GNUNET_MESSENGER_KIND_ACCESS:
    msg_hmac = &(message->body.access.hmac);
    break;
  case GNUNET_MESSENGER_KIND_REVOLUTION:
    msg_hmac = &(message->body.revolution.hmac);
    break;
  case GNUNET_MESSENGER_KIND_AUTHORIZATION:
    msg_hmac = &(message->body.authorization.hmac);
    break;
  default:
    msg_hmac = NULL;
    break;
  }
 
  if (! msg_hmac)
    return GNUNET_SYSERR;
 
  if (GNUNET_YES != calc_message_hmac (message, key, &hmac))
    return GNUNET_SYSERR;
 
  if (0 == GNUNET_CRYPTO_hash_cmp (&hmac, msg_hmac))
    return GNUNET_OK;
 
  return GNUNET_SYSERR;
}

Referenced by extract_access_message_key(), extract_authorization_message_key(), handle_access_message(), handle_authorization_message(), handle_epoch_announcement(), handle_epoch_group_announcement(), handle_revolution_message(), and send_epoch_announcement_authorization().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ encrypt_message()

enum GNUNET_GenericReturnValue encrypt_message	(	struct GNUNET_MESSENGER_Message *	message,
		const struct GNUNET_CRYPTO_HpkePublicKey *	hpke_key
	)

Encrypts a message using a given public key and replaces its body and kind with the now private encrypted message.

The function returns GNUNET_YES if the operation succeeded, otherwise GNUNET_NO.

Parameters

[in,out]	message	Message
[in]	key	Public key

Returns: GNUNET_YES on success, otherwise GNUNET_NO

Definition at line 1582 of file messenger_api_message.c.

{
  enum GNUNET_GenericReturnValue result;
  struct GNUNET_MESSENGER_ShortMessage shortened;
  uint16_t length, padded_length, encoded_length;
  uint8_t *data;
 
  GNUNET_assert ((message) && (hpke_key));
 
  if (GNUNET_YES == is_service_message (message))
    return GNUNET_NO;
 
  fold_short_message (message, &shortened);
 
  length = get_short_message_size (&shortened, GNUNET_YES);
  padded_length = calc_padded_length (length + encryption_overhead);
 
  GNUNET_assert (padded_length >= length + encryption_overhead);
 
  message->header.kind = GNUNET_MESSENGER_KIND_PRIVATE;
  message->body.privacy.data = GNUNET_malloc (padded_length);
  message->body.privacy.length = padded_length;
 
  encoded_length = (padded_length - encryption_overhead);
 
  GNUNET_assert (padded_length == encoded_length + encryption_overhead);
 
  result = GNUNET_NO;
  data = GNUNET_malloc (encoded_length);
 
  encode_short_message (&shortened, encoded_length, (char *) data);
 
  if (GNUNET_OK != GNUNET_CRYPTO_hpke_seal_oneshot (hpke_key,
                                                    (const uint8_t*)
                                                    "messenger",
                                                    strlen ("messenger"),
                                                    NULL, 0,
                                                    (const uint8_t*) data,
                                                    encoded_length,
                                                    (uint8_t*) message->body.
                                                    privacy.data,
                                                    NULL))
  {
    GNUNET_log (GNUNET_ERROR_TYPE_WARNING, "Encrypting message failed!\n");
 
    unfold_short_message (&shortened, message);
    goto cleanup;
  }
 
  destroy_message_body (shortened.kind, &(shortened.body));
  result = GNUNET_YES;
 
cleanup:
  GNUNET_free (data);
  return result;
}

References GNUNET_MESSENGER_Message::body, GNUNET_MESSENGER_ShortMessage::body, calc_padded_length(), cleanup(), data, GNUNET_MESSENGER_MessagePrivate::data, destroy_message_body(), encode_short_message(), encryption_overhead, fold_short_message(), get_short_message_size(), GNUNET_assert, GNUNET_CRYPTO_hpke_seal_oneshot(), GNUNET_ERROR_TYPE_WARNING, GNUNET_free, GNUNET_log, GNUNET_malloc, GNUNET_MESSENGER_KIND_PRIVATE, GNUNET_NO, GNUNET_OK, GNUNET_YES, GNUNET_MESSENGER_Message::header, is_service_message(), GNUNET_MESSENGER_MessageHeader::kind, GNUNET_MESSENGER_ShortMessage::kind, GNUNET_MESSENGER_MessagePrivate::length, GNUNET_MESSENGER_MessageBody::privacy, result, and unfold_short_message().

Referenced by dequeue_message_from_room(), and send_message_to_room_with_key().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ decrypt_message()

enum GNUNET_GenericReturnValue decrypt_message	(	struct GNUNET_MESSENGER_Message *	message,
		const struct GNUNET_CRYPTO_HpkePrivateKey *	hpke_key
	)

Decrypts a private message using a given private key and replaces its body and kind with the inner encrypted message.

The function returns GNUNET_YES if the operation succeeded, otherwise GNUNET_NO.

Parameters

[in,out]	message	Message
[in]	key	Private key

Returns: GNUNET_YES on success, otherwise GNUNET_NO

Definition at line 1642 of file messenger_api_message.c.

{
  enum GNUNET_GenericReturnValue result;
  uint16_t padded_length, encoded_length;
  uint8_t *data;
 
  GNUNET_assert ((message) && (hpke_key) &&
                 (GNUNET_MESSENGER_KIND_PRIVATE == message->header.kind));
 
  padded_length = message->body.privacy.length;
 
  if (padded_length < encryption_overhead)
  {
    GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
                "Message length too short to decrypt!\n");
 
    return GNUNET_NO;
  }
 
  encoded_length = (padded_length - encryption_overhead);
 
  GNUNET_assert (padded_length == encoded_length + encryption_overhead);
 
  result = GNUNET_NO;
  data = GNUNET_malloc (encoded_length);
 
  if (GNUNET_OK !=
      GNUNET_CRYPTO_hpke_open_oneshot (hpke_key,
                                       (uint8_t*) "messenger",
                                       strlen ("messenger"),
                                       NULL, 0,
                                       (uint8_t*) message->body.privacy.data,
                                       padded_length,
                                       (uint8_t*) data,
                                       NULL))
  {
    GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Decrypting message failed!\n");
 
    goto cleanup;
  }
 
  {
    struct GNUNET_MESSENGER_ShortMessage shortened;
    if (GNUNET_YES != decode_short_message (&shortened,
                                            encoded_length,
                                            (char*) data))
    {
      GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
                  "Decoding decrypted message failed!\n");
 
      goto cleanup;
    }
 
    unfold_short_message (&shortened, message);
    result = GNUNET_YES;
  }
 
cleanup:
  GNUNET_free (data);
  return result;
}

References GNUNET_MESSENGER_Message::body, cleanup(), data, GNUNET_MESSENGER_MessagePrivate::data, decode_short_message(), encryption_overhead, GNUNET_assert, GNUNET_CRYPTO_hpke_open_oneshot(), GNUNET_ERROR_TYPE_DEBUG, GNUNET_ERROR_TYPE_WARNING, GNUNET_free, GNUNET_log, GNUNET_malloc, GNUNET_MESSENGER_KIND_PRIVATE, GNUNET_NO, GNUNET_OK, GNUNET_YES, GNUNET_MESSENGER_Message::header, GNUNET_MESSENGER_MessageHeader::kind, GNUNET_MESSENGER_MessagePrivate::length, GNUNET_MESSENGER_MessageBody::privacy, result, and unfold_short_message().

Referenced by handle_private_message().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ transcribe_message()

struct GNUNET_MESSENGER_Message * transcribe_message	(	const struct GNUNET_MESSENGER_Message *	message,
		const struct GNUNET_CRYPTO_BlindablePublicKey *	key
	)

Transcribes a message as a new transcript message using a given public key from the recipient of the encrypted message content.

Parameters

[in]	message	Message
[in]	key	Public key

Returns: Message transcript

Definition at line 1707 of file messenger_api_message.c.

{
  struct GNUNET_MESSENGER_Message *transcript;
 
  GNUNET_assert ((message) && (key));
 
  if (GNUNET_YES == is_service_message (message))
    return NULL;
 
  transcript = create_message (GNUNET_MESSENGER_KIND_TRANSCRIPT);
 
  if (! transcript)
  {
    GNUNET_log (GNUNET_ERROR_TYPE_WARNING, "Transcribing message failed!\n");
    return NULL;
  }
 
  GNUNET_memcpy (&(transcript->body.transcript.key), key,
                 sizeof(transcript->body.transcript.key));
 
  {
    struct GNUNET_MESSENGER_ShortMessage shortened;
    uint16_t data_length;
 
    fold_short_message (message, &shortened);
 
    data_length = get_short_message_size (&shortened, GNUNET_YES);
 
    transcript->body.transcript.data = GNUNET_malloc (data_length);
    transcript->body.transcript.length = data_length;
 
    encode_short_message (&shortened, data_length,
                          transcript->body.transcript.data);
  }
 
  return transcript;
}

References GNUNET_MESSENGER_Message::body, create_message(), GNUNET_MESSENGER_MessageTranscript::data, encode_short_message(), fold_short_message(), get_short_message_size(), GNUNET_assert, GNUNET_ERROR_TYPE_WARNING, GNUNET_log, GNUNET_malloc, GNUNET_memcpy, GNUNET_MESSENGER_KIND_TRANSCRIPT, GNUNET_YES, is_service_message(), key, GNUNET_MESSENGER_MessageTranscript::key, GNUNET_MESSENGER_MessageTranscript::length, and GNUNET_MESSENGER_MessageBody::transcript.

Referenced by send_message_to_room_with_key().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ encrypt_secret_message()

enum GNUNET_GenericReturnValue encrypt_secret_message	(	struct GNUNET_MESSENGER_Message *	message,
		const union GNUNET_MESSENGER_EpochIdentifier *	identifier,
		const struct GNUNET_CRYPTO_SymmetricSessionKey *	key
	)

Encrypts a message using a given shared key from an announcement of an epoch and replaces its body and kind with the inner encrypted message.

The function returns GNUNET_YES if the operation succeeded, otherwise GNUNET_NO.

Parameters

[in,out]	message	Message
[in]	identifier	Epoch identifier
[in]	key	Shared secret key

Returns: GNUNET_YES on success, otherwise GNUNET_NO

Definition at line 1748 of file messenger_api_message.c.

{
  enum GNUNET_GenericReturnValue result;
  struct GNUNET_MESSENGER_ShortMessage shortened;
  uint16_t length, padded_length;
  uint8_t *data;
 
  GNUNET_assert ((message) && (identifier) && (key));
 
  fold_short_message (message, &shortened);
 
  length = get_short_message_size (&shortened, GNUNET_YES);
  padded_length = calc_padded_length (length + 0);
 
  GNUNET_assert (padded_length >= length + 0);
 
  message->header.kind = GNUNET_MESSENGER_KIND_SECRET;
 
  GNUNET_memcpy (&(message->body.secret.identifier), identifier,
                 sizeof (message->body.secret.identifier));
 
  GNUNET_CRYPTO_random_block (GNUNET_CRYPTO_QUALITY_NONCE,
                              &(message->body.secret.iv),
                              GNUNET_MESSENGER_SECRET_IV_BYTES);
 
  message->body.secret.data = GNUNET_malloc (padded_length);
  message->body.secret.length = padded_length;
 
  result = GNUNET_NO;
  data = GNUNET_malloc (padded_length);
 
  encode_short_message (&shortened, padded_length, (char *) data);
 
  {
    struct GNUNET_CRYPTO_SymmetricInitializationVector iv;
 
    if (GNUNET_YES != GNUNET_CRYPTO_hkdf_gnunet (
          &iv, sizeof (iv),
          GNUNET_MESSENGER_SALT_SECRET_IV,
          sizeof (GNUNET_MESSENGER_SALT_SECRET_IV),
          key, sizeof (*key),
          GNUNET_CRYPTO_kdf_arg (message->body.secret.iv, GNUNET_MESSENGER_SECRET_IV_BYTES)))
    {
      GNUNET_log (GNUNET_ERROR_TYPE_WARNING, "Deriving initialization vector failed!\n");
      unfold_short_message (&shortened, message);
      goto cleanup;
    }
 
    if (-1 == GNUNET_CRYPTO_symmetric_encrypt (data, padded_length, key,
                                               &iv, message->body.secret.data))
    {
      GNUNET_log (GNUNET_ERROR_TYPE_WARNING, "Encrypting message failed!\n");
      unfold_short_message (&shortened, message);
      goto cleanup;
    }
  }
 
  {
    struct GNUNET_CRYPTO_AuthKey auth_key;
 
    if (GNUNET_YES != GNUNET_CRYPTO_hkdf_gnunet (
          &auth_key, sizeof (auth_key),
          GNUNET_MESSENGER_SALT_SECRET_KEY,
          sizeof (GNUNET_MESSENGER_SALT_SECRET_KEY),
          key, sizeof (*key),
          GNUNET_CRYPTO_kdf_arg (message->body.secret.iv, GNUNET_MESSENGER_SECRET_IV_BYTES)))
    {
      GNUNET_log (GNUNET_ERROR_TYPE_WARNING, "Deriving authentication key failed!\n");
      unfold_short_message (&shortened, message);
      goto cleanup;
    }
 
    GNUNET_CRYPTO_hmac (&auth_key, message->body.secret.data, padded_length,
                        &(message->body.secret.hmac));
  }
 
  destroy_message_body (shortened.kind, &(shortened.body));
  result = GNUNET_YES;
 
cleanup:
  GNUNET_free (data);
  return result;
}

Referenced by send_message_to_room().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ decrypt_secret_message()

enum GNUNET_GenericReturnValue decrypt_secret_message	(	struct GNUNET_MESSENGER_Message *	message,
		const struct GNUNET_CRYPTO_SymmetricSessionKey *	key
	)

Decrypts a secret message using a given shared key and replaces its body and kind with the inner encrypted message.

The function returns GNUNET_YES if the operation succeeded, otherwise GNUNET_NO.

Parameters

[in,out]	message	Message
[in]	key	Shared secret key

Returns: GNUNET_YES on success, otherwise GNUNET_NO

Definition at line 1837 of file messenger_api_message.c.

{
  enum GNUNET_GenericReturnValue result;
  uint16_t padded_length;
  uint8_t *data;
 
  GNUNET_assert ((message) && (key) &&
                 (GNUNET_MESSENGER_KIND_SECRET == message->header.kind));
 
  padded_length = message->body.secret.length;
 
  {
    struct GNUNET_CRYPTO_AuthKey auth_key;
    struct GNUNET_HashCode hmac;
 
    if (GNUNET_YES != GNUNET_CRYPTO_hkdf_gnunet (
          &auth_key, sizeof (auth_key),
          GNUNET_MESSENGER_SALT_SECRET_KEY,
          sizeof (GNUNET_MESSENGER_SALT_SECRET_KEY),
          key, sizeof (*key),
          GNUNET_CRYPTO_kdf_arg (message->body.secret.iv, GNUNET_MESSENGER_SECRET_IV_BYTES)))
    {
      GNUNET_log (GNUNET_ERROR_TYPE_WARNING, "Deriving authentication key failed!\n");
      return GNUNET_NO;
    }
 
    GNUNET_CRYPTO_hmac (&auth_key, message->body.secret.data, padded_length,
                        &hmac);
 
    if (0 != GNUNET_CRYPTO_hash_cmp (&(message->body.secret.hmac), &hmac))
    {
      GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
                  "Decrypted message does not match HMAC!\n");
      return GNUNET_NO;
    }
  }
 
  result = GNUNET_NO;
  data = GNUNET_malloc (padded_length);
 
  {
    struct GNUNET_CRYPTO_SymmetricInitializationVector iv;
 
    if (GNUNET_YES != GNUNET_CRYPTO_hkdf_gnunet (
          &iv, sizeof (iv),
          GNUNET_MESSENGER_SALT_SECRET_IV,
          sizeof (GNUNET_MESSENGER_SALT_SECRET_IV),
          key,
          sizeof (*key),
          GNUNET_CRYPTO_kdf_arg (message->body.secret.iv, GNUNET_MESSENGER_SECRET_IV_BYTES)))
    {
      GNUNET_log (GNUNET_ERROR_TYPE_WARNING, "Deriving initialization vector failed!\n");
      goto cleanup;
    }
 
    if (-1 == GNUNET_CRYPTO_symmetric_decrypt (message->body.secret.data,
                                               padded_length,
                                               key, &iv, data))
    {
      GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Decrypting message failed!\n");
      goto cleanup;
    }
  }
 
  {
    struct GNUNET_MESSENGER_ShortMessage shortened;
    if (GNUNET_YES != decode_short_message (&shortened,
                                            padded_length,
                                            (char*) data))
    {
      GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
                  "Decoding decrypted message failed!\n");
 
      goto cleanup;
    }
 
    unfold_short_message (&shortened, message);
    result = GNUNET_YES;
  }
 
cleanup:
  GNUNET_free (data);
  return result;
}

Referenced by update_room_secret_message().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ read_transcript_message()

enum GNUNET_GenericReturnValue read_transcript_message ( struct GNUNET_MESSENGER_Message * message )

Read the original message from a transcript message and replaces its body and kind with the inner encrypted message.

The function returns GNUNET_YES if the operation succeeded, otherwise GNUNET_NO.

Parameters

[in,out] message Message transcript

Returns: GNUNET_YES on success, otherwise GNUNET_NO

Definition at line 1925 of file messenger_api_message.c.

{
  uint16_t data_length;
  struct GNUNET_MESSENGER_ShortMessage shortened;
 
  GNUNET_assert ((message) &&
                 (GNUNET_MESSENGER_KIND_TRANSCRIPT == message->header.kind));
 
  data_length = message->body.transcript.length;
 
  if (GNUNET_YES != decode_short_message (&shortened,
                                          data_length,
                                          message->body.transcript.data))
  {
    GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
                "Decoding decrypted message failed!\n");
 
    return GNUNET_NO;
  }
 
  unfold_short_message (&shortened, message);
  return GNUNET_YES;
}

References GNUNET_MESSENGER_Message::body, GNUNET_MESSENGER_MessageTranscript::data, decode_short_message(), GNUNET_assert, GNUNET_ERROR_TYPE_WARNING, GNUNET_log, GNUNET_MESSENGER_KIND_TRANSCRIPT, GNUNET_NO, GNUNET_YES, GNUNET_MESSENGER_Message::header, GNUNET_MESSENGER_MessageHeader::kind, GNUNET_MESSENGER_MessageTranscript::length, GNUNET_MESSENGER_MessageBody::transcript, and unfold_short_message().

Referenced by handle_transcript_message().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ extract_access_message_key()

enum GNUNET_GenericReturnValue extract_access_message_key	(	const struct GNUNET_MESSENGER_Message *	message,
		const struct GNUNET_CRYPTO_HpkePrivateKey *	key,
		struct GNUNET_CRYPTO_SymmetricSessionKey *	shared_key
	)

Extracts the shared epoch or group key from an access message using the private ephemeral key from an epoch and verifies it via the HMAC from the message body.

The function returns GNUNET_YES if the operation succeeded, otherwise GNUNET_NO.

Parameters

[in]	message	Access message
[in]	key	Private ephemeral key
[out]	shared_key	Shared key

Returns: GNUNET_YES on success, otherwise GNUNET_NO

Definition at line 1951 of file messenger_api_message.c.

{
  GNUNET_assert ((message) && (key) && (shared_key) &&
                 (GNUNET_MESSENGER_KIND_ACCESS == message->header.kind));
 
  if (GNUNET_OK !=
      GNUNET_CRYPTO_hpke_open_oneshot (key,
                                       (uint8_t*) "messenger",
                                       strlen ("messenger"),
                                       NULL, 0,
                                       (uint8_t*) message->body.access.key,
                                       GNUNET_MESSENGER_ACCESS_KEY_BYTES,
                                       (uint8_t*) shared_key,
                                       NULL))
  {
    GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Decrypting shared key failed!\n");
    return GNUNET_NO;
  }
 
  if (GNUNET_OK != verify_message_by_key (message, shared_key))
  {
    GNUNET_log (GNUNET_ERROR_TYPE_WARNING, "Shared key mismatches HMAC!\n");
    return GNUNET_NO;
  }
 
  return GNUNET_YES;
}

References GNUNET_MESSENGER_MessageBody::access, GNUNET_MESSENGER_Message::body, GNUNET_assert, GNUNET_CRYPTO_hpke_open_oneshot(), GNUNET_ERROR_TYPE_DEBUG, GNUNET_ERROR_TYPE_WARNING, GNUNET_log, GNUNET_MESSENGER_ACCESS_KEY_BYTES, GNUNET_MESSENGER_KIND_ACCESS, GNUNET_NO, GNUNET_OK, GNUNET_YES, GNUNET_MESSENGER_Message::header, key, GNUNET_MESSENGER_MessageAccess::key, GNUNET_MESSENGER_MessageHeader::kind, and verify_message_by_key().

Referenced by handle_epoch_announcement_access(), and handle_epoch_group_access().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ extract_authorization_message_key()

enum GNUNET_GenericReturnValue extract_authorization_message_key	(	struct GNUNET_MESSENGER_Message *	message,
		const struct GNUNET_CRYPTO_SymmetricSessionKey *	key,
		struct GNUNET_CRYPTO_SymmetricSessionKey *	shared_key
	)

Extracts the shared epoch or group key from an authorization message using a previously exchanged shared key and verifies it via the HMAC from the message body.

The function returns GNUNET_YES if the operation succeeded, otherwise GNUNET_NO.

Parameters

[in]	message	Access message
[in]	key	Previous shared key
[out]	shared_key	Shared key

Returns: GNUNET_YES on success, otherwise GNUNET_NO

Definition at line 1984 of file messenger_api_message.c.

{
  struct GNUNET_CRYPTO_SymmetricInitializationVector iv;
 
  GNUNET_assert ((message) && (key) && (shared_key) &&
                 (GNUNET_MESSENGER_KIND_AUTHORIZATION == message->header.kind));
 
  if (GNUNET_YES != GNUNET_CRYPTO_hkdf_gnunet (
        &iv, sizeof (iv),
        GNUNET_MESSENGER_SALT_GROUP_KEY,
        sizeof (GNUNET_MESSENGER_SALT_GROUP_KEY),
        key,
        sizeof (*key),
        GNUNET_CRYPTO_kdf_arg_auto (&message->body.authorization.identifier),
      GNUNET_CRYPTO_kdf_arg_auto (&message->body.authorization.event)))
  {
    GNUNET_log (GNUNET_ERROR_TYPE_WARNING, "Deriving initialization vector failed!\n");
    return GNUNET_NO;
  }
 
  if (-1 == GNUNET_CRYPTO_symmetric_decrypt (message->body.authorization.key,
                                             GNUNET_MESSENGER_AUTHORIZATION_KEY_BYTES,
                                             key,
                                             &iv,
                                             shared_key))
  {
    GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Decrypting shared key failed!\n");
    return GNUNET_NO;
  }
 
  if (GNUNET_OK != verify_message_by_key (message, shared_key))
  {
    GNUNET_log (GNUNET_ERROR_TYPE_WARNING, "Shared key mismatches HMAC!\n");
    return GNUNET_NO;
  }
 
  return GNUNET_YES;
}

References GNUNET_MESSENGER_MessageBody::authorization, GNUNET_MESSENGER_Message::body, GNUNET_MESSENGER_MessageAuthorization::event, GNUNET_assert, GNUNET_CRYPTO_hkdf_gnunet, GNUNET_CRYPTO_kdf_arg_auto, GNUNET_CRYPTO_symmetric_decrypt(), GNUNET_ERROR_TYPE_DEBUG, GNUNET_ERROR_TYPE_WARNING, GNUNET_log, GNUNET_MESSENGER_AUTHORIZATION_KEY_BYTES, GNUNET_MESSENGER_KIND_AUTHORIZATION, GNUNET_MESSENGER_SALT_GROUP_KEY, GNUNET_NO, GNUNET_OK, GNUNET_YES, GNUNET_MESSENGER_Message::header, GNUNET_MESSENGER_MessageAuthorization::identifier, key, GNUNET_MESSENGER_MessageAuthorization::key, GNUNET_MESSENGER_MessageHeader::kind, and verify_message_by_key().

Referenced by handle_authorization_message().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ get_message_timeout()

struct GNUNET_TIME_Relative get_message_timeout ( const struct GNUNET_MESSENGER_Message * message )

Return the relative timeout of the content from a given message that controls when a delayed handling action of this message needs to be processed at least.

Parameters

[in] message Message

Returns: Relative timeout of message

Definition at line 2029 of file messenger_api_message.c.

{
  struct GNUNET_TIME_Absolute timestamp;
  struct GNUNET_TIME_Relative timeout;
 
  GNUNET_assert (message);
 
  timestamp = GNUNET_TIME_absolute_ntoh (message->header.timestamp);
 
  switch (message->header.kind)
  {
  case GNUNET_MESSENGER_KIND_DELETION:
    timeout = GNUNET_TIME_relative_ntoh (message->body.deletion.delay);
    break;
  case GNUNET_MESSENGER_KIND_ANNOUNCEMENT:
    timeout = GNUNET_TIME_relative_ntoh (message->body.announcement.timeout);
    break;
  case GNUNET_MESSENGER_KIND_APPEAL:
    timeout = GNUNET_TIME_relative_ntoh (message->body.appeal.timeout);
    break;
  case GNUNET_MESSENGER_KIND_GROUP:
    timeout = GNUNET_TIME_relative_ntoh (message->body.group.timeout);
    break;
  default:
    timeout = GNUNET_TIME_relative_get_zero_ ();
    break;
  }
 
  timestamp = GNUNET_TIME_absolute_add (timestamp, timeout);
 
  timeout = GNUNET_TIME_absolute_get_remaining (timestamp);
  timeout = GNUNET_TIME_relative_min (timeout,
                                      GNUNET_TIME_relative_get_minute_ ());
 
  return timeout;
}

References GNUNET_assert, GNUNET_MESSENGER_KIND_ANNOUNCEMENT, GNUNET_MESSENGER_KIND_APPEAL, GNUNET_MESSENGER_KIND_DELETION, GNUNET_MESSENGER_KIND_GROUP, GNUNET_TIME_absolute_add(), GNUNET_TIME_absolute_get_remaining(), GNUNET_TIME_absolute_ntoh(), GNUNET_TIME_relative_get_minute_(), GNUNET_TIME_relative_get_zero_(), GNUNET_TIME_relative_min(), GNUNET_TIME_relative_ntoh(), timeout, and timestamp().

Referenced by handle_appeal_message(), handle_delete_message(), handle_epoch_announcement(), handle_epoch_announcement_delay(), handle_message_delete(), handle_room_delayed_deletion(), and set_epoch_proposal_group().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ pack_message()

struct GNUNET_MQ_Envelope * pack_message	(	struct GNUNET_MESSENGER_Message *	message,
		struct GNUNET_HashCode *	hash,
		enum GNUNET_MESSENGER_PackMode	mode
	)

Encodes the message to pack it into a newly allocated envelope if mode is equal to GNUNET_MESSENGER_PACK_MODE_ENVELOPE.

Independent of the mode the message will be hashed if hash is not NULL.

Parameters

[out]	message	Message
[out]	hash	Hash of message
[in]	mode	Mode of packing

Returns: Envelope or NULL

Definition at line 2068 of file messenger_api_message.c.

{
  struct GNUNET_MessageHeader *header;
  uint16_t length, padded_length;
  struct GNUNET_MQ_Envelope *env;
  char *buffer;
 
  GNUNET_assert (message);
 
  GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
              "Packing message kind=%u and sender: %s\n",
              message->header.kind, GNUNET_sh2s (&(message->header.sender_id)));
 
  length = get_message_size (message, GNUNET_YES);
  padded_length = calc_padded_length (length);
 
  if (GNUNET_MESSENGER_PACK_MODE_ENVELOPE == mode)
  {
    env = GNUNET_MQ_msg_extra (header, padded_length,
                               GNUNET_MESSAGE_TYPE_CADET_CLI);
    buffer = (char*) &(header[1]);
  }
  else
  {
    env = NULL;
    buffer = GNUNET_malloc (padded_length);
  }
 
  encode_message (message, padded_length, buffer, GNUNET_YES);
 
  if (hash)
    hash_message (message, length, buffer, hash);
 
  if (GNUNET_MESSENGER_PACK_MODE_ENVELOPE != mode)
    GNUNET_free (buffer);
 
  return env;
}

References calc_padded_length(), encode_message(), env, get_message_size(), GNUNET_assert, GNUNET_ERROR_TYPE_DEBUG, GNUNET_free, GNUNET_log, GNUNET_malloc, GNUNET_MESSAGE_TYPE_CADET_CLI, GNUNET_MESSENGER_PACK_MODE_ENVELOPE, GNUNET_MQ_msg_extra, GNUNET_sh2s(), GNUNET_YES, hash_message(), GNUNET_MESSENGER_Message::header, GNUNET_MESSENGER_MessageHeader::kind, mode, and GNUNET_MESSENGER_MessageHeader::sender_id.

Referenced by forward_tunnel_message(), handle_tunnel_message(), and sign_srv_room_message().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ is_peer_message()

enum GNUNET_GenericReturnValue is_peer_message ( const struct GNUNET_MESSENGER_Message * message )

Returns whether a specific kind of message can be sent by the service without usage of a clients private key.

The function returns GNUNET_YES if the kind of message can be signed via a peer's identity, otherwise GNUNET_NO.

Parameters

[in] message Message

Returns: GNUNET_YES if sending is allowed, GNUNET_NO otherwise

Definition at line 2111 of file messenger_api_message.c.

{
  GNUNET_assert (message);
 
  switch (message->header.kind)
  {
  case GNUNET_MESSENGER_KIND_INFO:
  case GNUNET_MESSENGER_KIND_PEER:
  case GNUNET_MESSENGER_KIND_MISS:
  case GNUNET_MESSENGER_KIND_MERGE:
  case GNUNET_MESSENGER_KIND_CONNECTION:
    return GNUNET_YES;
  default:
    return GNUNET_NO;
  }
}

References GNUNET_assert, GNUNET_MESSENGER_KIND_CONNECTION, GNUNET_MESSENGER_KIND_INFO, GNUNET_MESSENGER_KIND_MERGE, GNUNET_MESSENGER_KIND_MISS, GNUNET_MESSENGER_KIND_PEER, GNUNET_NO, GNUNET_YES, GNUNET_MESSENGER_Message::header, and GNUNET_MESSENGER_MessageHeader::kind.

Referenced by callback_found_message(), callback_room_handle_message(), enqueue_message_control(), filter_message_sending(), get_store_member_of(), get_store_peer_of(), handle_room_messages(), is_service_message(), notify_about_members(), notify_srv_handle_message(), process_message_control(), sign_srv_room_message(), and task_message_control().

Here is the caller graph for this function:

◆ is_service_message()

enum GNUNET_GenericReturnValue is_service_message ( const struct GNUNET_MESSENGER_Message * message )

Returns whether a specific kind of message contains service critical information.

That kind of information should not be encrypted via private messages for example to guarantee the service to work properly. The function returns GNUNET_YES if the kind of message needs to be transferred accessible to all peers and their running service. It returns GNUNET_NO if the message can be encrypted to specific subgroups of members without issues. If the kind of message is unknown it returns GNUNET_SYSERR.

Parameters

[in] message Message

Returns: GNUNET_YES if encrypting is disallowed, GNUNET_NO or GNUNET_SYSERR otherwise

Definition at line 2130 of file messenger_api_message.c.

{
  GNUNET_assert (message);
 
  if (GNUNET_YES == is_peer_message (message))
    return GNUNET_YES;
 
  switch (message->header.kind)
  {
  case GNUNET_MESSENGER_KIND_INFO:
    return GNUNET_YES; // Reserved for connection handling only!
  case GNUNET_MESSENGER_KIND_JOIN:
    return GNUNET_YES; // Reserved for member handling only!
  case GNUNET_MESSENGER_KIND_LEAVE:
    return GNUNET_YES; // Reserved for member handling only!
  case GNUNET_MESSENGER_KIND_NAME:
    return GNUNET_YES; // Reserved for member name handling only!
  case GNUNET_MESSENGER_KIND_KEY:
    return GNUNET_YES; // Reserved for member key handling only!
  case GNUNET_MESSENGER_KIND_PEER:
    return GNUNET_YES; // Reserved for connection handling only!
  case GNUNET_MESSENGER_KIND_ID:
    return GNUNET_YES; // Reserved for member id handling only!
  case GNUNET_MESSENGER_KIND_MISS:
    return GNUNET_YES; // Reserved for connection handling only!
  case GNUNET_MESSENGER_KIND_MERGE:
    return GNUNET_YES; // Reserved for peers only!
  case GNUNET_MESSENGER_KIND_REQUEST:
    return GNUNET_YES; // Requests should not apply individually! (inefficiently)
  case GNUNET_MESSENGER_KIND_INVITE:
    return GNUNET_NO;
  case GNUNET_MESSENGER_KIND_TEXT:
    return GNUNET_NO;
  case GNUNET_MESSENGER_KIND_FILE:
    return GNUNET_NO;
  case GNUNET_MESSENGER_KIND_PRIVATE:
    return GNUNET_YES; // Prevent duplicate encryption breaking all access!
  case GNUNET_MESSENGER_KIND_DELETION:
    return GNUNET_YES; // Deletion should not apply individually! (inefficiently)
  case GNUNET_MESSENGER_KIND_CONNECTION:
    return GNUNET_YES; // Reserved for connection handling only!
  case GNUNET_MESSENGER_KIND_TICKET:
    return GNUNET_NO;
  case GNUNET_MESSENGER_KIND_TRANSCRIPT:
    return GNUNET_NO;
  case GNUNET_MESSENGER_KIND_TAG:
    return GNUNET_NO;
  case GNUNET_MESSENGER_KIND_SUBSCRIBTION:
    return GNUNET_YES; // Reserved for subscription handling only!
  case GNUNET_MESSENGER_KIND_TALK:
    return GNUNET_NO;
  case GNUNET_MESSENGER_KIND_ANNOUNCEMENT:
    return GNUNET_YES; // Reserved for epoch and group key exchange!
  case GNUNET_MESSENGER_KIND_SECRET:
    return GNUNET_YES; // Prevent duplicate encryption breaking all access!
  case GNUNET_MESSENGER_KIND_APPEAL:
    return GNUNET_YES; // Reserved for epoch key exchange!
  case GNUNET_MESSENGER_KIND_ACCESS:
    return GNUNET_YES; // Reserved for epoch and group key exchange!
  case GNUNET_MESSENGER_KIND_REVOLUTION:
    return GNUNET_YES; // Reserved for epoch and group key revoking!
  case GNUNET_MESSENGER_KIND_GROUP:
    return GNUNET_YES; // Reserved for group key exchange!
  case GNUNET_MESSENGER_KIND_AUTHORIZATION:
    return GNUNET_YES; // Reserved for epoch and group key exchange!
  default:
    return GNUNET_SYSERR;
  }
}

Referenced by encrypt_message(), send_message_to_room(), and transcribe_message().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ is_epoch_message()

enum GNUNET_GenericReturnValue is_epoch_message ( const struct GNUNET_MESSENGER_Message * message )

Returns whether a certain kind of message from storage contains some specific details that might be required for the overall message graph to function as intended.

The function returns GNUNET_YES if you may not delete the given message because of that, otherwise it returns GNUNET_NO.

Parameters

[in] message Message

Returns: GNUNET_YES if the message contains epoch graph information, GNUNET_NO otherwise

Definition at line 2202 of file messenger_api_message.c.

{
  GNUNET_assert (message);
 
  switch (message->header.kind)
  {
  case GNUNET_MESSENGER_KIND_JOIN:
    return GNUNET_YES;
  case GNUNET_MESSENGER_KIND_LEAVE:
    return GNUNET_YES;
  case GNUNET_MESSENGER_KIND_MERGE:
    return GNUNET_YES;
  default:
    return GNUNET_NO;
  }
}

References GNUNET_assert, GNUNET_MESSENGER_KIND_JOIN, GNUNET_MESSENGER_KIND_LEAVE, GNUNET_MESSENGER_KIND_MERGE, GNUNET_NO, GNUNET_YES, GNUNET_MESSENGER_Message::header, and GNUNET_MESSENGER_MessageHeader::kind.

Referenced by delete_store_message(), GNUNET_MESSENGER_delete_message(), handle_message(), request_room_message_step(), send_message_to_room(), and sign_srv_room_message().

Here is the caller graph for this function:

◆ filter_message_sending()

enum GNUNET_GenericReturnValue filter_message_sending ( const struct GNUNET_MESSENGER_Message * message )

Returns whether a specific kind of message should be sent by a client.

The function returns GNUNET_YES or GNUNET_NO for recommendations and GNUNET_SYSERR for specific kinds of messages which should not be sent manually at all.

Parameters

[in] message Message

Returns: GNUNET_YES if sending is allowed, GNUNET_NO or GNUNET_SYSERR otherwise

Definition at line 2221 of file messenger_api_message.c.

{
  GNUNET_assert (message);
 
  if (GNUNET_YES == is_peer_message (message))
    return GNUNET_SYSERR; // Requires signature of peer rather than member!
 
  switch (message->header.kind)
  {
  case GNUNET_MESSENGER_KIND_INFO:
    return GNUNET_SYSERR; // Reserved for connection handling only!
  case GNUNET_MESSENGER_KIND_JOIN:
    return GNUNET_NO; // Use #GNUNET_MESSENGER_enter_room(...) instead!
  case GNUNET_MESSENGER_KIND_LEAVE:
    return GNUNET_NO; // Use #GNUNET_MESSENGER_close_room(...) instead!
  case GNUNET_MESSENGER_KIND_NAME:
    return GNUNET_YES;
  case GNUNET_MESSENGER_KIND_KEY:
    return GNUNET_NO; // Use #GNUNET_MESSENGER_set_key(...) instead!
  case GNUNET_MESSENGER_KIND_PEER:
    return GNUNET_SYSERR; // Use #GNUNET_MESSENGER_open_room(...) instead!
  case GNUNET_MESSENGER_KIND_ID:
    return GNUNET_NO; // Reserved for member id handling only!
  case GNUNET_MESSENGER_KIND_MISS:
    return GNUNET_SYSERR; // Reserved for connection handling only!
  case GNUNET_MESSENGER_KIND_MERGE:
    return GNUNET_SYSERR; // Reserved for peers only!
  case GNUNET_MESSENGER_KIND_REQUEST:
    return GNUNET_NO; // Use #GNUNET_MESSENGER_get_message(...) instead!
  case GNUNET_MESSENGER_KIND_INVITE:
    return GNUNET_YES;
  case GNUNET_MESSENGER_KIND_TEXT:
    return GNUNET_YES;
  case GNUNET_MESSENGER_KIND_FILE:
    return GNUNET_YES;
  case GNUNET_MESSENGER_KIND_PRIVATE:
    return GNUNET_NO; // Use #GNUNET_MESSENGER_send_message(...) with a contact instead!
  case GNUNET_MESSENGER_KIND_DELETION:
    return GNUNET_NO; // Use #GNUNET_MESSENGER_delete_message(...) instead!
  case GNUNET_MESSENGER_KIND_CONNECTION:
    return GNUNET_SYSERR; // Reserved for connection handling only!
  case GNUNET_MESSENGER_KIND_TICKET:
    return GNUNET_YES;
  case GNUNET_MESSENGER_KIND_TRANSCRIPT:
    return GNUNET_NO; // Use #GNUNET_MESSENGER_send_message(...) with a contact instead!
  case GNUNET_MESSENGER_KIND_TAG:
    return GNUNET_YES;
  case GNUNET_MESSENGER_KIND_SUBSCRIBTION:
    return GNUNET_YES;
  case GNUNET_MESSENGER_KIND_TALK:
    return GNUNET_YES;
  case GNUNET_MESSENGER_KIND_ANNOUNCEMENT:
    return GNUNET_NO; // Should only be used for implicit key exchange!
  case GNUNET_MESSENGER_KIND_SECRET:
    return GNUNET_NO; // Should only be used for implicit forward secrecy!
  case GNUNET_MESSENGER_KIND_APPEAL:
    return GNUNET_NO; // Should only be used for implicit key exchange!
  case GNUNET_MESSENGER_KIND_ACCESS:
    return GNUNET_NO; // Should only be used for implicit key exchange!
  case GNUNET_MESSENGER_KIND_REVOLUTION:
    return GNUNET_NO; // Should only be used for implicit key exchange!
  case GNUNET_MESSENGER_KIND_GROUP:
    return GNUNET_NO; // Should only be used for implicit key exchange!
  case GNUNET_MESSENGER_KIND_AUTHORIZATION:
    return GNUNET_NO; // Should only be used for implicit key exchange!
  default:
    return GNUNET_SYSERR;
  }
}

Referenced by check_send_message(), and GNUNET_MESSENGER_send_message().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ get_message_discourse()

const struct GNUNET_ShortHashCode * get_message_discourse ( const struct GNUNET_MESSENGER_Message * message )

Returns the discourse hash of a message depending on its kind.

If a message contains a discourse hash it will not be stored locally on peers.

Parameters

[in] message Message

Returns: Discourse hash of message or NULL

Definition at line 2293 of file messenger_api_message.c.

{
  GNUNET_assert (message);
 
  switch (message->header.kind)
  {
  case GNUNET_MESSENGER_KIND_SUBSCRIBTION:
    return &(message->body.subscription.discourse);
  case GNUNET_MESSENGER_KIND_TALK:
    return &(message->body.talk.discourse);
  default:
    return NULL;
  }
}

References GNUNET_MESSENGER_Message::body, GNUNET_MESSENGER_MessageSubscribtion::discourse, GNUNET_MESSENGER_MessageTalk::discourse, GNUNET_assert, GNUNET_MESSENGER_KIND_SUBSCRIBTION, GNUNET_MESSENGER_KIND_TALK, GNUNET_MESSENGER_Message::header, GNUNET_MESSENGER_MessageHeader::kind, GNUNET_MESSENGER_MessageBody::subscription, and GNUNET_MESSENGER_MessageBody::talk.

Referenced by handle_message_control(), iterate_flag_for_cleanup_discourse_message(), put_store_message(), send_message_to_room(), and update_message_state().

Here is the caller graph for this function:

Macros

Enumerations

Functions

Macro Definition Documentation

◆ GNUNET_MESSENGER_SALT_ANNOUNCEMENT_KEY

◆ GNUNET_MESSENGER_SALT_EPOCH_KEY

◆ GNUNET_MESSENGER_SALT_GROUP_KEY

◆ GNUNET_MESSENGER_SALT_SECRET_KEY

◆ GNUNET_MESSENGER_SALT_ENCRYPTION_KEY

◆ GNUNET_MESSENGER_SALT_EPOCH_IV

◆ GNUNET_MESSENGER_SALT_ENCRYPTION_IV

◆ GNUNET_MESSENGER_SALT_SECRET_IV

◆ GNUNET_MESSENGER_MAX_MESSAGE_SIZE

◆ GNUNET_MESSENGER_PADDING_MIN

◆ GNUNET_MESSENGER_PADDING_LEVEL0

◆ GNUNET_MESSENGER_PADDING_LEVEL1

◆ GNUNET_MESSENGER_PADDING_LEVEL2

Enumeration Type Documentation

◆ GNUNET_MESSENGER_PackMode

Function Documentation

◆ create_message()

◆ copy_message()

◆ copy_message_header()

◆ cleanup_message()

◆ destroy_message()

◆ is_message_session_bound()

◆ get_message_kind_size()

◆ get_message_size()

◆ encode_message_signature()

◆ encode_message()

◆ decode_message()

◆ hash_message()

◆ sign_message()

◆ sign_message_by_peer()

◆ sign_message_by_key()

◆ verify_message()

◆ verify_message_by_peer()

◆ verify_message_by_key()

◆ encrypt_message()

◆ decrypt_message()

◆ transcribe_message()

◆ encrypt_secret_message()

◆ decrypt_secret_message()

◆ read_transcript_message()

◆ extract_access_message_key()

◆ extract_authorization_message_key()

◆ get_message_timeout()

◆ pack_message()

◆ is_peer_message()

◆ is_service_message()

◆ is_epoch_message()

◆ filter_message_sending()

◆ get_message_discourse()