#include "messenger_api_message.h"
#include "gnunet_common.h"
#include "gnunet_messenger_service.h"
#include "gnunet_signatures.h"

Include dependency graph for messenger_api_message.c:

Data Structures
struct	GNUNET_MESSENGER_MessageSignature

struct	GNUNET_MESSENGER_ShortMessage

Macros
#define	member_size(type, member) sizeof(((type*) NULL)->member)

#define	max(x, y) (x > y? x : y)

#define	min(x, y) (x < y? x : y)

#define	encode_step_ext(dst, offset, src, size)

#define	encode_step(dst, offset, src)

#define	encode_step_key(dst, offset, src, length)

#define	encode_step_signature(dst, offset, src, length)

#define	decode_step_ext(src, offset, dst, size)

#define	decode_step(src, offset, dst)

#define	decode_step_malloc(src, offset, dst, size, zero)

#define	decode_step_key(src, offset, dst, length)

Typedefs
typedef uint32_t	kind_t

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

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

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. More...

static void	destroy_message_body (enum GNUNET_MESSENGER_MessageKind kind, struct GNUNET_MESSENGER_MessageBody *body)

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

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

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

static void	fold_short_message (const struct GNUNET_MESSENGER_Message message, struct GNUNET_MESSENGER_ShortMessage shortened)

static void	unfold_short_message (struct GNUNET_MESSENGER_ShortMessage shortened, struct GNUNET_MESSENGER_Message message)

static uint16_t	get_message_body_kind_size (enum GNUNET_MESSENGER_MessageKind kind)

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. More...

static uint16_t	get_message_body_size (enum GNUNET_MESSENGER_MessageKind kind, const struct GNUNET_MESSENGER_MessageBody *body)

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. More...

static uint16_t	get_short_message_size (const struct GNUNET_MESSENGER_ShortMessage *message, enum GNUNET_GenericReturnValue include_body)

static uint16_t	calc_usual_padding ()

static uint16_t	calc_padded_length (uint16_t length)

static void	encode_message_body (enum GNUNET_MESSENGER_MessageKind kind, const struct GNUNET_MESSENGER_MessageBody body, uint16_t length, char buffer, uint16_t offset)

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 maximal length in bytes. More...

static void	encode_short_message (const struct GNUNET_MESSENGER_ShortMessage message, uint16_t length, char buffer)

static uint16_t	decode_message_body (enum GNUNET_MESSENGER_MessageKind kind, struct GNUNET_MESSENGER_MessageBody body, uint16_t length, const char *buffer, uint16_t offset)

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 maximal length in bytes. More...

static enum GNUNET_GenericReturnValue	decode_short_message (struct GNUNET_MESSENGER_ShortMessage message, uint16_t length, const char buffer)

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. More...

void	sign_message (struct GNUNET_MESSENGER_Message message, uint16_t length, char buffer, const struct GNUNET_HashCode hash, const struct GNUNET_CRYPTO_PrivateKey key)
	Signs the hash of a message with a given private key and writes the signature into the buffer as well. More...

void	sign_message_by_peer (struct GNUNET_MESSENGER_Message message, uint16_t length, char buffer, const struct GNUNET_HashCode hash, const struct GNUNET_CONFIGURATION_Handle cfg)
	Signs the hash of a message with the peer identity of a given config and writes the signature into the buffer as well. More...

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

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. More...

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

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

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

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. More...

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

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. More...

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

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. More...

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

Macro Definition Documentation

◆ member_size

#define member_size	(	type,
		member
	)	sizeof(((type*) NULL)->member)

Definition at line 276 of file messenger_api_message.c.

◆ max

#define max	(	x,
		y
	)	(x > y? x : y)

Definition at line 476 of file messenger_api_message.c.

◆ min

#define min	(	x,
		y
	)	(x < y? x : y)

Definition at line 505 of file messenger_api_message.c.

◆ encode_step_ext

#define encode_step_ext	(	dst,
		offset,
		src,
		size
	)

Value:

          do { \
          GNUNET_memcpy (dst + offset, src, size);           \
          offset += size;                                    \
} while (0)

Definition at line 507 of file messenger_api_message.c.

◆ encode_step

#define encode_step	(	dst,
		offset,
		src
	)

Value:

          do {          \
          encode_step_ext (dst, offset, src, sizeof(*src)); \
} while (0)

Definition at line 512 of file messenger_api_message.c.

◆ encode_step_key

#define encode_step_key	(	dst,
		offset,
		src,
		length
	)

Value:

          do {        \
          ssize_t result = GNUNET_CRYPTO_write_public_key_to_buffer ( \
            src, dst + offset, length - offset                        \
            );                                                          \
          if (result < 0)                                             \
          GNUNET_break (0);                                         \
          else                                                        \
          offset += result;                                         \
} while (0)

Definition at line 516 of file messenger_api_message.c.

◆ encode_step_signature

#define encode_step_signature	(	dst,
		offset,
		src,
		length
	)

Value:

          do { \
          ssize_t result = GNUNET_CRYPTO_write_signature_to_buffer ( \
            src, dst + offset, length - offset                       \
            );                                                         \
          if (result < 0)                                            \
          GNUNET_break (0);                                        \
          else                                                       \
          offset += result;                                        \
} while (0)

Definition at line 526 of file messenger_api_message.c.

◆ decode_step_ext

#define decode_step_ext	(	src,
		offset,
		dst,
		size
	)

Value:

          do { \
          GNUNET_memcpy (dst, src + offset, size);           \
          offset += size;                                    \
} while (0)

Definition at line 733 of file messenger_api_message.c.

◆ decode_step

#define decode_step	(	src,
		offset,
		dst
	)

Value:

          do {          \
          decode_step_ext (src, offset, dst, sizeof(*dst)); \
} while (0)

Definition at line 738 of file messenger_api_message.c.

◆ decode_step_malloc

#define decode_step_malloc	(	src,
		offset,
		dst,
		size,
		zero
	)

Value:

          do { \
          dst = GNUNET_malloc (size + zero);                          \
          if (zero) dst[size] = 0;                                    \
          decode_step_ext (src, offset, dst, size);                 \
} while (0)

Definition at line 742 of file messenger_api_message.c.

◆ decode_step_key

#define decode_step_key	(	src,
		offset,
		dst,
		length
	)

Value:

          do {   \
          enum GNUNET_GenericReturnValue result;                 \
          size_t read;                                           \
          result = GNUNET_CRYPTO_read_public_key_from_buffer (   \
            src + offset, length - offset, dst, &read            \
            );                                                     \
          if (GNUNET_SYSERR == result)                           \
          GNUNET_break (0);                                    \
          else                                                   \
          offset += read;                                      \
} while (0)

Definition at line 748 of file messenger_api_message.c.

Typedef Documentation

◆ kind_t

typedef uint32_t kind_t

Definition at line 355 of file messenger_api_message.c.

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 45 of file messenger_api_message.c.

{
  struct GNUNET_MESSENGER_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;
  default:
    break;
  }
 
  return message;
}

Referenced by create_message_connection(), create_message_delete(), 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_subscribe(), 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 90 of file messenger_api_message.c.

{
  GNUNET_assert (message);
 
  struct GNUNET_MESSENGER_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;
  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(), and send_srv_handle_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 158 of file messenger_api_message.c.

{
  GNUNET_assert ((message) && (header));
 
  enum GNUNET_MESSENGER_MessageKind 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:

◆ destroy_message_body()

static void destroy_message_body	(	enum GNUNET_MESSENGER_MessageKind	kind,
		struct GNUNET_MESSENGER_MessageBody *	body
	)

static

Definition at line 173 of file messenger_api_message.c.

{
  switch (kind)
  {
  case GNUNET_MESSENGER_KIND_NAME:
    if (body->name.name)
      GNUNET_free (body->name.name);
    break;
  case GNUNET_MESSENGER_KIND_TEXT:
    if (body->text.text)
      GNUNET_free (body->text.text);
    break;
  case GNUNET_MESSENGER_KIND_FILE:
    if (body->file.uri)
      GNUNET_free (body->file.uri);
    break;
  case GNUNET_MESSENGER_KIND_PRIVATE:
    if (body->privacy.data)
      GNUNET_free (body->privacy.data);
    break;
  case GNUNET_MESSENGER_KIND_TICKET:
    if (body->ticket.identifier)
      GNUNET_free (body->ticket.identifier);
    break;
  case GNUNET_MESSENGER_KIND_TRANSCRIPT:
    if (body->transcript.data)
      GNUNET_free (body->transcript.data);
    break;
  case GNUNET_MESSENGER_KIND_TAG:
    if (body->tag.tag)
      GNUNET_free (body->tag.tag);
    break;
  case GNUNET_MESSENGER_KIND_TALK:
    if (body->talk.data)
      GNUNET_free (body->talk.data);
    break;
  default:
    break;
  }
}

Referenced by cleanup_message(), destroy_message(), encrypt_message(), and unfold_short_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 217 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 226 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 clear_queue_messages(), create_message_peer(), dequeue_from_messages(), dequeue_message_from_room(), destroy_message_control(), enqueue_to_messages(), forward_tunnel_message(), get_store_message(), handle_delete_message(), handle_discourse_subscription(), handle_private_message(), handle_transcript_message(), iterate_destroy_message(), iterate_destroy_messages(), iterate_destroy_subscription(), iterate_flag_for_cleanup_discourse_message(), keep_subscription_alive(), send_message_to_room_with_key(), send_tunnel_message(), task_message_control(), and update_room_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 237 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:

◆ fold_short_message()

static void fold_short_message	(	const struct GNUNET_MESSENGER_Message *	message,
		struct GNUNET_MESSENGER_ShortMessage *	shortened
	)

static

Definition at line 253 of file messenger_api_message.c.

{
  shortened->kind = message->header.kind;
 
  GNUNET_memcpy (&(shortened->body), &(message->body), sizeof(struct
                                                              GNUNET_MESSENGER_MessageBody));
}

References GNUNET_MESSENGER_Message::body, GNUNET_MESSENGER_ShortMessage::body, GNUNET_memcpy, GNUNET_MESSENGER_Message::header, GNUNET_MESSENGER_MessageHeader::kind, and GNUNET_MESSENGER_ShortMessage::kind.

Referenced by encrypt_message(), and transcribe_message().

Here is the caller graph for this function:

◆ unfold_short_message()

static void unfold_short_message	(	struct GNUNET_MESSENGER_ShortMessage *	shortened,
		struct GNUNET_MESSENGER_Message *	message
	)

static

Definition at line 264 of file messenger_api_message.c.

{
  destroy_message_body (message->header.kind, &(message->body));
 
  message->header.kind = shortened->kind;
 
  GNUNET_memcpy (&(message->body), &(shortened->body),
                 sizeof(struct GNUNET_MESSENGER_MessageBody));
}

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

Referenced by decrypt_message(), encrypt_message(), and read_transcript_message().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ get_message_body_kind_size()

static uint16_t get_message_body_kind_size ( enum GNUNET_MESSENGER_MessageKind kind )

static

Definition at line 279 of file messenger_api_message.c.

{
  uint16_t length = 0;
 
  switch (kind)
  {
  case GNUNET_MESSENGER_KIND_INFO:
    length += member_size (struct GNUNET_MESSENGER_Message,
                           body.info.messenger_version);
    break;
  case GNUNET_MESSENGER_KIND_PEER:
    length += member_size (struct GNUNET_MESSENGER_Message, body.peer.peer);
    break;
  case GNUNET_MESSENGER_KIND_ID:
    length += member_size (struct GNUNET_MESSENGER_Message, body.id.id);
    break;
  case GNUNET_MESSENGER_KIND_MISS:
    length += member_size (struct GNUNET_MESSENGER_Message, body.miss.peer);
    break;
  case GNUNET_MESSENGER_KIND_MERGE:
    length += member_size (struct GNUNET_MESSENGER_Message,
                           body.merge.previous);
    break;
  case GNUNET_MESSENGER_KIND_REQUEST:
    length += member_size (struct GNUNET_MESSENGER_Message, body.request.hash);
    break;
  case GNUNET_MESSENGER_KIND_INVITE:
    length += member_size (struct GNUNET_MESSENGER_Message, body.invite.door);
    length += member_size (struct GNUNET_MESSENGER_Message, body.invite.key);
    break;
  case GNUNET_MESSENGER_KIND_FILE:
    length += member_size (struct GNUNET_MESSENGER_Message, body.file.key);
    length += member_size (struct GNUNET_MESSENGER_Message, body.file.hash);
    length += member_size (struct GNUNET_MESSENGER_Message, body.file.name);
    break;
  case GNUNET_MESSENGER_KIND_PRIVATE:
    length += member_size (struct GNUNET_MESSENGER_Message, body.privacy.key);
    break;
  case GNUNET_MESSENGER_KIND_DELETE:
    length += member_size (struct GNUNET_MESSENGER_Message, body.deletion.hash);
    length += member_size (struct GNUNET_MESSENGER_Message,
                           body.deletion.delay);
    break;
  case GNUNET_MESSENGER_KIND_CONNECTION:
    length += member_size (struct GNUNET_MESSENGER_Message,
                           body.connection.amount);
    length += member_size (struct GNUNET_MESSENGER_Message,
                           body.connection.flags);
    break;
  case GNUNET_MESSENGER_KIND_TRANSCRIPT:
    length += member_size (struct GNUNET_MESSENGER_Message,
                           body.transcript.hash);
    break;
  case GNUNET_MESSENGER_KIND_TAG:
    length += member_size (struct GNUNET_MESSENGER_Message, body.tag.hash);
    break;
  case GNUNET_MESSENGER_KIND_SUBSCRIBE:
    length += member_size (struct GNUNET_MESSENGER_Message,
                           body.subscribe.discourse);
    length += member_size (struct GNUNET_MESSENGER_Message,
                           body.subscribe.time);
    length += member_size (struct GNUNET_MESSENGER_Message,
                           body.subscribe.flags);
    break;
  case GNUNET_MESSENGER_KIND_TALK:
    length += member_size (struct GNUNET_MESSENGER_Message,
                           body.talk.discourse);
    break;
  default:
    break;
  }
 
  return length;
}

Referenced by get_message_kind_size(), and get_short_message_size().

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 358 of file messenger_api_message.c.

{
  uint16_t 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_body_size()

static uint16_t get_message_body_size	(	enum GNUNET_MESSENGER_MessageKind	kind,
		const struct GNUNET_MESSENGER_MessageBody *	body
	)

static

Definition at line 377 of file messenger_api_message.c.

{
  uint16_t length = 0;
 
  switch (kind)
  {
  case GNUNET_MESSENGER_KIND_JOIN:
    length += GNUNET_CRYPTO_public_key_get_length (&(body->join.key));
    break;
  case GNUNET_MESSENGER_KIND_NAME:
    length += (body->name.name ? strlen (body->name.name) : 0);
    break;
  case GNUNET_MESSENGER_KIND_KEY:
    length += GNUNET_CRYPTO_public_key_get_length (&(body->key.key));
    break;
  case GNUNET_MESSENGER_KIND_TEXT:
    length += (body->text.text ? strlen (body->text.text) : 0);
    break;
  case GNUNET_MESSENGER_KIND_FILE:
    length += (body->file.uri ? strlen (body->file.uri) : 0);
    break;
  case GNUNET_MESSENGER_KIND_PRIVATE:
    length += body->privacy.length;
    break;
  case GNUNET_MESSENGER_KIND_TICKET:
    length += (body->ticket.identifier ? strlen (body->ticket.identifier) : 0);
    break;
  case GNUNET_MESSENGER_KIND_TRANSCRIPT:
    length += GNUNET_CRYPTO_public_key_get_length (&(body->transcript.key));
    length += body->transcript.length;
    break;
  case GNUNET_MESSENGER_KIND_TAG:
    length += (body->tag.tag ? strlen (body->tag.tag) : 0);
    break;
  case GNUNET_MESSENGER_KIND_TALK:
    length += body->talk.length;
    break;
  default:
    break;
  }
 
  return length;
}

Referenced by get_message_size(), and get_short_message_size().

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 424 of file messenger_api_message.c.

{
  GNUNET_assert (message);
 
  uint16_t length = 0;
 
  if (GNUNET_YES == include_header)
    length += GNUNET_CRYPTO_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_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:

◆ get_short_message_size()

static uint16_t get_short_message_size	(	const struct GNUNET_MESSENGER_ShortMessage *	message,
		enum GNUNET_GenericReturnValue	include_body
	)

static

Definition at line 443 of file messenger_api_message.c.

{
  const uint16_t minimum_size = sizeof(struct GNUNET_HashCode) + sizeof(kind_t);
 
  if (message)
    return minimum_size + get_message_body_kind_size (message->kind)
           + (include_body == GNUNET_YES?
              get_message_body_size (message->kind, &(message->body)) : 0);
  else
    return minimum_size;
}

References GNUNET_MESSENGER_ShortMessage::body, get_message_body_kind_size(), get_message_body_size(), GNUNET_YES, and GNUNET_MESSENGER_ShortMessage::kind.

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

Here is the call graph for this function:

Here is the caller graph for this function:

◆ calc_usual_padding()

static uint16_t calc_usual_padding ( )

static

Definition at line 458 of file messenger_api_message.c.

{
  uint16_t padding = 0;
  uint16_t kind_size;
 
  for (unsigned int i = 0; i <= GNUNET_MESSENGER_KIND_MAX; i++)
  {
    kind_size = get_message_kind_size ((enum GNUNET_MESSENGER_MessageKind) i,
                                       GNUNET_YES);
 
    if (kind_size > padding)
      padding = kind_size;
  }
 
  return padding + GNUNET_MESSENGER_PADDING_MIN;
}

References get_message_kind_size(), GNUNET_MESSENGER_KIND_MAX, GNUNET_MESSENGER_PADDING_MIN, and GNUNET_YES.

Referenced by calc_padded_length().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ calc_padded_length()

static uint16_t calc_padded_length ( uint16_t length )

static

Definition at line 479 of file messenger_api_message.c.

{
  static uint16_t usual_padding = 0;
 
  if (! usual_padding)
    usual_padding = calc_usual_padding ();
 
  const uint16_t padded_length = max (
    length + GNUNET_MESSENGER_PADDING_MIN,
    usual_padding
    );
 
  if (padded_length <= GNUNET_MESSENGER_PADDING_LEVEL0)
    return GNUNET_MESSENGER_PADDING_LEVEL0;
 
  if (padded_length <= GNUNET_MESSENGER_PADDING_LEVEL1)
    return GNUNET_MESSENGER_PADDING_LEVEL1;
 
  if (padded_length <= GNUNET_MESSENGER_PADDING_LEVEL2)
    return GNUNET_MESSENGER_PADDING_LEVEL2;
 
  return GNUNET_MESSENGER_MAX_MESSAGE_SIZE;
 
}

References calc_usual_padding(), GNUNET_MESSENGER_MAX_MESSAGE_SIZE, GNUNET_MESSENGER_PADDING_LEVEL0, GNUNET_MESSENGER_PADDING_LEVEL1, GNUNET_MESSENGER_PADDING_LEVEL2, GNUNET_MESSENGER_PADDING_MIN, and max.

Referenced by encrypt_message(), and pack_message().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ encode_message_body()

static void encode_message_body	(	enum GNUNET_MESSENGER_MessageKind	kind,
		const struct GNUNET_MESSENGER_MessageBody *	body,
		uint16_t	length,
		char *	buffer,
		uint16_t	offset
	)

static

Definition at line 537 of file messenger_api_message.c.

{
  uint32_t value0, value1;
  switch (kind)
  {
  case GNUNET_MESSENGER_KIND_INFO:
    value0 = GNUNET_htobe32 (body->info.messenger_version);
 
    encode_step (buffer, offset, &value0);
    break;
  case GNUNET_MESSENGER_KIND_JOIN:
    encode_step_key (buffer, offset, &(body->join.key), length);
    break;
  case GNUNET_MESSENGER_KIND_LEAVE:
    break;
  case GNUNET_MESSENGER_KIND_NAME:
    if (body->name.name)
      encode_step_ext (buffer, offset, body->name.name, min (length - offset,
                                                             strlen (
                                                               body->name.name))
                       );
    break;
  case GNUNET_MESSENGER_KIND_KEY:
    encode_step_key (buffer, offset, &(body->key.key), length);
    break;
  case GNUNET_MESSENGER_KIND_PEER:
    encode_step (buffer, offset, &(body->peer.peer));
    break;
  case GNUNET_MESSENGER_KIND_ID:
    encode_step (buffer, offset, &(body->id.id));
    break;
  case GNUNET_MESSENGER_KIND_MISS:
    encode_step (buffer, offset, &(body->miss.peer));
    break;
  case GNUNET_MESSENGER_KIND_MERGE:
    encode_step (buffer, offset, &(body->merge.previous));
    break;
  case GNUNET_MESSENGER_KIND_REQUEST:
    encode_step (buffer, offset, &(body->request.hash));
    break;
  case GNUNET_MESSENGER_KIND_INVITE:
    encode_step (buffer, offset, &(body->invite.door));
    encode_step (buffer, offset, &(body->invite.key));
    break;
  case GNUNET_MESSENGER_KIND_TEXT:
    if (body->text.text)
      encode_step_ext (buffer, offset, body->text.text, min (length - offset,
                                                             strlen (
                                                               body->text.text))
                       );
    break;
  case GNUNET_MESSENGER_KIND_FILE:
    encode_step (buffer, offset, &(body->file.key));
    encode_step (buffer, offset, &(body->file.hash));
    encode_step_ext (buffer, offset, body->file.name, sizeof(body->file.name));
    if (body->file.uri)
      encode_step_ext (buffer, offset, body->file.uri, min (length - offset,
                                                            strlen (
                                                              body->file.uri)));
    break;
  case GNUNET_MESSENGER_KIND_PRIVATE:
    encode_step (buffer, offset, &(body->privacy.key));
 
    if (body->privacy.data)
      encode_step_ext (buffer, offset, body->privacy.data, min (length - offset,
                                                                body->privacy.
                                                                length));
    break;
  case GNUNET_MESSENGER_KIND_DELETE:
    encode_step (buffer, offset, &(body->deletion.hash));
    encode_step (buffer, offset, &(body->deletion.delay));
    break;
  case GNUNET_MESSENGER_KIND_CONNECTION:
    value0 = GNUNET_htobe32 (body->connection.amount);
    value1 = GNUNET_htobe32 (body->connection.flags);
 
    encode_step (buffer, offset, &value0);
    encode_step (buffer, offset, &value1);
    break;
  case GNUNET_MESSENGER_KIND_TICKET:
    encode_step_ext (buffer, offset, body->ticket.identifier,
                     min (length - offset, strlen (body->ticket.identifier)));
    break;
  case GNUNET_MESSENGER_KIND_TRANSCRIPT:
    encode_step (buffer, offset, &(body->transcript.hash));
    encode_step_key (buffer, offset, &(body->transcript.key), length);
 
    if (body->transcript.data)
      encode_step_ext (buffer, offset, body->transcript.data, min (length
                                                                   - offset,
                                                                   body->
                                                                   transcript.
                                                                   length));
    break;
  case GNUNET_MESSENGER_KIND_TAG:
    encode_step (buffer, offset, &(body->tag.hash));
 
    if (body->tag.tag)
      encode_step_ext (buffer, offset, body->tag.tag, min (length - offset,
                                                           strlen (
                                                             body->tag.tag)));
    break;
  case GNUNET_MESSENGER_KIND_SUBSCRIBE:
    value0 = GNUNET_htobe32 (body->subscribe.flags);
 
    encode_step (buffer, offset, &(body->subscribe.discourse));
    encode_step (buffer, offset, &(body->subscribe.time));
    encode_step (buffer, offset, &value0);
    break;
  case GNUNET_MESSENGER_KIND_TALK:
    encode_step (buffer, offset, &(body->talk.discourse));
 
    if (body->talk.data)
      encode_step_ext (buffer, offset, body->talk.data, min (length - offset,
                                                             body->talk.
                                                             length));
    break;
  default:
    break;
  }
 
  if (offset >= length)
    return;
 
  const uint16_t padding = length - offset;
  const uint16_t used_padding = sizeof(padding) + sizeof(char);
 
  GNUNET_assert (padding >= used_padding);
 
  buffer[offset++] = '\0';
 
  if (padding > used_padding)
    GNUNET_CRYPTO_random_block (GNUNET_CRYPTO_QUALITY_WEAK, buffer + offset,
                                padding - used_padding);
 
  GNUNET_memcpy (buffer + length - sizeof(padding), &padding, sizeof(padding));
}

Referenced by encode_message(), and encode_short_message().

Here is the call graph for this function:

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 maximal 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 681 of file messenger_api_message.c.

{
  GNUNET_assert ((message) && (buffer));
 
  uint16_t offset = 0;
 
  if (GNUNET_YES == include_header)
    encode_step_signature (buffer, offset, &(message->header.signature),
                           length);
 
  const kind_t 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:

◆ encode_short_message()

static void encode_short_message	(	const struct GNUNET_MESSENGER_ShortMessage *	message,
		uint16_t	length,
		char *	buffer
	)

static

Definition at line 711 of file messenger_api_message.c.

{
  struct GNUNET_HashCode hash;
  uint16_t offset = sizeof(hash);
 
  const kind_t kind = GNUNET_htobe32 ((kind_t) message->kind);
 
  encode_step (buffer, offset, &kind);
 
  encode_message_body (message->kind, &(message->body), length, buffer, offset);
 
  GNUNET_CRYPTO_hash (
    buffer + sizeof(hash),
    length - sizeof(hash),
    &hash);
 
  GNUNET_memcpy (buffer, &hash, sizeof(hash));
}

References GNUNET_MESSENGER_ShortMessage::body, encode_message_body(), encode_step, GNUNET_CRYPTO_hash(), GNUNET_htobe32, GNUNET_memcpy, and GNUNET_MESSENGER_ShortMessage::kind.

Referenced by encrypt_message(), and transcribe_message().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ decode_message_body()

static uint16_t decode_message_body	(	enum GNUNET_MESSENGER_MessageKind *	kind,
		struct GNUNET_MESSENGER_MessageBody *	body,
		uint16_t	length,
		const char *	buffer,
		uint16_t	offset
	)

static

Definition at line 761 of file messenger_api_message.c.

{
  uint16_t padding = 0;
 
  GNUNET_memcpy (&padding, buffer + length - sizeof(padding), sizeof(padding));
 
  if (padding > length - offset)
    padding = 0;
 
  const uint16_t end_zero = length - padding;
 
  if ((padding) && (buffer[end_zero] != '\0'))
    padding = 0;
 
  length -= padding;
 
  uint32_t value0, value1;
  switch (*kind)
  {
  case GNUNET_MESSENGER_KIND_INFO:
    decode_step (buffer, offset, &value0);
 
    body->info.messenger_version = GNUNET_be32toh (value0);
    break;
  case GNUNET_MESSENGER_KIND_JOIN:
    decode_step_key (buffer, offset, &(body->join.key), length);
    break;
  case GNUNET_MESSENGER_KIND_LEAVE:
    break;
  case GNUNET_MESSENGER_KIND_NAME:
    if (length > offset)
      decode_step_malloc (buffer, offset, body->name.name, length - offset, 1);
    else
      body->name.name = NULL;
    break;
  case GNUNET_MESSENGER_KIND_KEY:
    decode_step_key (buffer, offset, &(body->key.key), length);
    break;
  case GNUNET_MESSENGER_KIND_PEER:
    decode_step (buffer, offset, &(body->peer.peer));
    break;
  case GNUNET_MESSENGER_KIND_ID:
    decode_step (buffer, offset, &(body->id.id));
    break;
  case GNUNET_MESSENGER_KIND_MISS:
    decode_step (buffer, offset, &(body->miss.peer));
    break;
  case GNUNET_MESSENGER_KIND_MERGE:
    decode_step (buffer, offset, &(body->merge.previous));
    break;
  case GNUNET_MESSENGER_KIND_REQUEST:
    decode_step (buffer, offset, &(body->request.hash));
    break;
  case GNUNET_MESSENGER_KIND_INVITE:
    decode_step (buffer, offset, &(body->invite.door));
    decode_step (buffer, offset, &(body->invite.key));
    break;
  case GNUNET_MESSENGER_KIND_TEXT:
    if (length > offset)
      decode_step_malloc (buffer, offset, body->text.text, length - offset, 1);
    else
      body->text.text = NULL;
    break;
  case GNUNET_MESSENGER_KIND_FILE:
    decode_step (buffer, offset, &(body->file.key));
    decode_step (buffer, offset, &(body->file.hash));
    decode_step_ext (buffer, offset, body->file.name, sizeof(body->file.name));
    if (length > offset)
      decode_step_malloc (buffer, offset, body->file.uri, length - offset, 1);
    else
      body->file.uri = NULL;
    break;
  case GNUNET_MESSENGER_KIND_PRIVATE:
    decode_step (buffer, offset, &(body->privacy.key));
 
    if (length > offset)
    {
      body->privacy.length = (length - offset);
      decode_step_malloc (buffer, offset, body->privacy.data, length - offset,
                          0);
    }
    else
    {
      body->privacy.length = 0;
      body->privacy.data = NULL;
    }
 
    break;
  case GNUNET_MESSENGER_KIND_DELETE:
    decode_step (buffer, offset, &(body->deletion.hash));
    decode_step (buffer, offset, &(body->deletion.delay));
    break;
  case GNUNET_MESSENGER_KIND_CONNECTION:
    decode_step (buffer, offset, &value0);
    decode_step (buffer, offset, &value1);
 
    body->connection.amount = GNUNET_be32toh (value0);
    body->connection.flags = GNUNET_be32toh (value1);
    break;
  case GNUNET_MESSENGER_KIND_TICKET:
    if (length > offset)
      decode_step_malloc (buffer, offset, body->ticket.identifier, length
                          - offset, 1);
    else
      body->ticket.identifier = NULL;
    break;
  case GNUNET_MESSENGER_KIND_TRANSCRIPT:
    decode_step (buffer, offset, &(body->transcript.hash));
    decode_step_key (buffer, offset, &(body->transcript.key), length);
 
    if (length > offset)
    {
      body->transcript.length = (length - offset);
      decode_step_malloc (buffer, offset, body->transcript.data,
                          length - offset, 0);
    }
    else
    {
      body->transcript.length = 0;
      body->transcript.data = NULL;
    }
 
    break;
  case GNUNET_MESSENGER_KIND_TAG:
    decode_step (buffer, offset, &(body->tag.hash));
    if (length > offset)
      decode_step_malloc (buffer, offset, body->tag.tag, length - offset, 1);
    else
      body->tag.tag = NULL;
    break;
  case GNUNET_MESSENGER_KIND_SUBSCRIBE:
    decode_step (buffer, offset, &(body->subscribe.discourse));
    decode_step (buffer, offset, &(body->subscribe.time));
    decode_step (buffer, offset, &value0);
 
    body->subscribe.flags = GNUNET_be32toh (value0);
    break;
  case GNUNET_MESSENGER_KIND_TALK:
    decode_step (buffer, offset, &(body->talk.discourse));
 
    if (length > offset)
    {
      body->talk.length = (length - offset);
      decode_step_malloc (buffer, offset, body->talk.data, length - offset,
                          0);
    }
    else
    {
      body->talk.length = 0;
      body->talk.data = NULL;
    }
 
    break;
  default:
    *kind = GNUNET_MESSENGER_KIND_UNKNOWN;
    break;
  }
 
  return padding;
}

Referenced by decode_message(), and decode_short_message().

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 maximal 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 928 of file messenger_api_message.c.

{
  GNUNET_assert (
    (message) &&
    (buffer) &&
    (length >= get_message_kind_size (GNUNET_MESSENGER_KIND_UNKNOWN,
                                      include_header))
    );
 
  uint16_t offset = 0;
 
  if (GNUNET_YES == include_header)
  {
    ssize_t result = GNUNET_CRYPTO_read_signature_from_buffer (
      &(message->header.signature), buffer, length - offset
      );
 
    if (result < 0)
      return GNUNET_NO;
    else
      offset += result;
  }
 
  const uint16_t count = length - offset;
 
  if (count < get_message_kind_size (GNUNET_MESSENGER_KIND_UNKNOWN,
                                     include_header))
    return GNUNET_NO;
 
  kind_t kind;
 
  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);
 
  message->header.kind = (enum GNUNET_MESSENGER_MessageKind) GNUNET_be32toh (
    kind);
 
  if (count < get_message_kind_size (message->header.kind, include_header))
    return GNUNET_NO;
 
  const uint16_t 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_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:

◆ decode_short_message()

static enum GNUNET_GenericReturnValue decode_short_message	(	struct GNUNET_MESSENGER_ShortMessage *	message,
		uint16_t	length,
		const char *	buffer
	)

static

Definition at line 990 of file messenger_api_message.c.

{
  struct GNUNET_HashCode expected, hash;
  uint16_t offset = sizeof(hash);
 
  if (length < get_short_message_size (NULL, GNUNET_NO))
    return GNUNET_NO;
 
  GNUNET_memcpy (&hash, buffer, sizeof(hash));
 
  GNUNET_CRYPTO_hash (
    buffer + sizeof(hash),
    length - sizeof(hash),
    &expected
    );
 
  if (0 != GNUNET_CRYPTO_hash_cmp (&hash, &expected))
    return GNUNET_NO;
 
  kind_t kind;
 
  decode_step (buffer, offset, &kind);
 
  message->kind = (enum GNUNET_MESSENGER_MessageKind) GNUNET_be32toh (kind);
 
  if (length < get_short_message_size (message, GNUNET_NO))
    return GNUNET_NO;
 
  decode_message_body (&(message->kind), &(message->body), length, buffer,
                       offset);
 
  if (GNUNET_MESSENGER_KIND_UNKNOWN == message->kind)
    return GNUNET_NO;
 
  return GNUNET_YES;
}

References GNUNET_MESSENGER_ShortMessage::body, decode_message_body(), decode_step, get_short_message_size(), GNUNET_be32toh, GNUNET_CRYPTO_hash(), GNUNET_CRYPTO_hash_cmp(), GNUNET_memcpy, GNUNET_MESSENGER_KIND_UNKNOWN, GNUNET_NO, GNUNET_YES, and GNUNET_MESSENGER_ShortMessage::kind.

Referenced by decrypt_message(), and read_transcript_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 1031 of file messenger_api_message.c.

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

References GNUNET_assert, GNUNET_CRYPTO_hash(), GNUNET_CRYPTO_signature_get_length(), GNUNET_MESSENGER_Message::header, and GNUNET_MESSENGER_MessageHeader::signature.

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,
		uint16_t	length,
		char *	buffer,
		const struct GNUNET_HashCode *	hash,
		const struct GNUNET_CRYPTO_PrivateKey *	key
	)

Signs the hash of a message with a given private key and writes the signature into the buffer as well.

Parameters

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

Definition at line 1047 of file messenger_api_message.c.

{
  GNUNET_assert ((message) && (buffer) && (hash) && (key));
 
  GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Sign message by member: %s\n",
              GNUNET_h2s (hash));
 
  struct GNUNET_MESSENGER_MessageSignature signature;
 
  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_sign (key, &signature, &(message->header.signature));
 
  message->header.signature.type = key->type;
 
  uint16_t offset = 0;
  encode_step_signature (buffer, offset, &(message->header.signature), length);
}

References encode_step_signature, GNUNET_assert, GNUNET_CRYPTO_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_EccSignaturePurpose::purpose, GNUNET_MESSENGER_MessageSignature::purpose, GNUNET_MESSENGER_MessageHeader::signature, GNUNET_CRYPTO_EccSignaturePurpose::size, and GNUNET_CRYPTO_Signature::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()

void sign_message_by_peer	(	struct GNUNET_MESSENGER_Message *	message,
		uint16_t	length,
		char *	buffer,
		const struct GNUNET_HashCode *	hash,
		const struct GNUNET_CONFIGURATION_Handle *	cfg
	)

Signs the hash of a message with the peer identity of a given config and writes the signature into the buffer as well.

Parameters

[in,out]	message	Message
[in]	length	Length of buffer
[out]	buffer	Buffer
[in]	hash	Hash of message
[in]	cfg	Peer configuration

Definition at line 1074 of file messenger_api_message.c.

{
  GNUNET_assert ((message) && (buffer) && (hash) && (cfg));
 
  GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Sign message by peer: %s\n",
              GNUNET_h2s (hash));
 
  struct GNUNET_MESSENGER_MessageSignature signature;
 
  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_sign_by_peer_identity (cfg, &(signature.purpose),
                                       &(message->header.signature.
                                         eddsa_signature));
 
  message->header.signature.type = htonl (GNUNET_PUBLIC_KEY_TYPE_EDDSA);
 
  uint16_t offset = 0;
  encode_step_signature (buffer, offset, &(message->header.signature), length);
}

References cfg, encode_step_signature, GNUNET_assert, GNUNET_CRYPTO_sign_by_peer_identity(), GNUNET_ERROR_TYPE_DEBUG, GNUNET_h2s(), GNUNET_log, GNUNET_memcpy, GNUNET_PUBLIC_KEY_TYPE_EDDSA, GNUNET_SIGNATURE_PURPOSE_CHAT_MESSAGE, GNUNET_MESSENGER_MessageSignature::hash, GNUNET_MESSENGER_Message::header, GNUNET_CRYPTO_EccSignaturePurpose::purpose, GNUNET_MESSENGER_MessageSignature::purpose, GNUNET_MESSENGER_MessageHeader::signature, GNUNET_CRYPTO_EccSignaturePurpose::size, and GNUNET_CRYPTO_Signature::type.

Referenced by sign_srv_room_message_by_peer().

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_PublicKey *	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 1103 of file messenger_api_message.c.

{
  GNUNET_assert ((message) && (hash) && (key));
 
  if (key->type != message->header.signature.type)
    return GNUNET_SYSERR;
 
  struct GNUNET_MESSENGER_MessageSignature signature;
 
  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_signature_verify (
    GNUNET_SIGNATURE_PURPOSE_CHAT_MESSAGE, &signature,
    &(message->header.signature), key);
}

References GNUNET_assert, GNUNET_CRYPTO_signature_verify, GNUNET_memcpy, GNUNET_SIGNATURE_PURPOSE_CHAT_MESSAGE, GNUNET_SYSERR, GNUNET_MESSENGER_MessageSignature::hash, GNUNET_MESSENGER_Message::header, key, GNUNET_CRYPTO_EccSignaturePurpose::purpose, GNUNET_MESSENGER_MessageSignature::purpose, GNUNET_MESSENGER_MessageHeader::signature, GNUNET_CRYPTO_EccSignaturePurpose::size, and GNUNET_CRYPTO_Signature::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 1126 of file messenger_api_message.c.

{
  GNUNET_assert ((message) && (hash) && (identity));
 
  if (ntohl (GNUNET_PUBLIC_KEY_TYPE_EDDSA) != message->header.signature.type)
    return GNUNET_SYSERR;
 
  struct GNUNET_MESSENGER_MessageSignature signature;
 
  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_EccSignaturePurpose::purpose, GNUNET_MESSENGER_MessageSignature::purpose, GNUNET_MESSENGER_MessageHeader::signature, GNUNET_CRYPTO_EccSignaturePurpose::size, and GNUNET_CRYPTO_Signature::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:

◆ encrypt_message()

enum GNUNET_GenericReturnValue encrypt_message	(	struct GNUNET_MESSENGER_Message *	message,
		const struct GNUNET_CRYPTO_PublicKey *	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 1150 of file messenger_api_message.c.

{
  struct GNUNET_CRYPTO_EcdhePublicKey hpke_key;
  GNUNET_assert ((message) && (key));
 
  if (GNUNET_YES == is_service_message (message))
    return GNUNET_NO;
 
  struct GNUNET_MESSENGER_ShortMessage shortened;
 
  fold_short_message (message, &shortened);
 
  const uint16_t length = get_short_message_size (&shortened, GNUNET_YES);
  const uint16_t padded_length = calc_padded_length (
    length + GNUNET_CRYPTO_HPKE_SEAL_ONESHOT_OVERHEAD_BYTES
    );
 
  message->header.kind = GNUNET_MESSENGER_KIND_PRIVATE;
  message->body.privacy.data = GNUNET_malloc (padded_length);
  message->body.privacy.length = padded_length;
 
  GNUNET_assert (GNUNET_OK == GNUNET_CRYPTO_hpke_pk_to_x25519 (key, &hpke_key));
  const uint16_t encoded_length = (
    padded_length - GNUNET_CRYPTO_HPKE_SEAL_ONESHOT_OVERHEAD_BYTES
    );
 
  encode_short_message (&shortened, encoded_length, message->body.privacy.data);
 
  if (GNUNET_OK != GNUNET_CRYPTO_hpke_seal_oneshot (&hpke_key,
                                                    (uint8_t*) "messenger",
                                                    strlen ("messenger"),
                                                    NULL, 0,
                                                    (uint8_t*) message->body.
                                                    privacy.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);
    return GNUNET_NO;
  }
 
  destroy_message_body (shortened.kind, &(shortened.body));
  return GNUNET_YES;
}

References GNUNET_MESSENGER_Message::body, GNUNET_MESSENGER_ShortMessage::body, calc_padded_length(), GNUNET_MESSENGER_MessagePrivate::data, destroy_message_body(), encode_short_message(), fold_short_message(), get_short_message_size(), GNUNET_assert, GNUNET_CRYPTO_hpke_pk_to_x25519(), GNUNET_CRYPTO_hpke_seal_oneshot(), GNUNET_CRYPTO_HPKE_SEAL_ONESHOT_OVERHEAD_BYTES, GNUNET_ERROR_TYPE_WARNING, GNUNET_log, GNUNET_malloc, GNUNET_MESSENGER_KIND_PRIVATE, GNUNET_NO, GNUNET_OK, GNUNET_YES, GNUNET_MESSENGER_Message::header, is_service_message(), key, GNUNET_MESSENGER_MessageHeader::kind, GNUNET_MESSENGER_ShortMessage::kind, GNUNET_MESSENGER_MessagePrivate::length, GNUNET_MESSENGER_MessageBody::privacy, 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_PrivateKey *	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 1202 of file messenger_api_message.c.

{
  struct GNUNET_CRYPTO_EcdhePrivateKey hpke_key;
  GNUNET_assert ((message) && (key));
 
  const uint16_t padded_length = message->body.privacy.length;
 
  if (padded_length < GNUNET_CRYPTO_HPKE_SEAL_ONESHOT_OVERHEAD_BYTES)
  {
    GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
                "Message length too short to decrypt!\n");
 
    return GNUNET_NO;
  }
 
  GNUNET_assert (GNUNET_OK == GNUNET_CRYPTO_hpke_sk_to_x25519 (key, &hpke_key));
  const uint16_t encoded_length = (
    padded_length - GNUNET_CRYPTO_HPKE_SEAL_ONESHOT_OVERHEAD_BYTES
    );
 
  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*) message->body.privacy.data,
                                       NULL))
  {
    GNUNET_log (GNUNET_ERROR_TYPE_INFO, "Decrypting message failed!\n");
 
    return GNUNET_NO;
  }
 
  struct GNUNET_MESSENGER_ShortMessage shortened;
 
  if (GNUNET_YES != decode_short_message (&shortened,
                                          encoded_length,
                                          message->body.privacy.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_MessagePrivate::data, decode_short_message(), GNUNET_assert, GNUNET_CRYPTO_hpke_open_oneshot(), GNUNET_CRYPTO_HPKE_SEAL_ONESHOT_OVERHEAD_BYTES, GNUNET_CRYPTO_hpke_sk_to_x25519(), GNUNET_ERROR_TYPE_INFO, GNUNET_ERROR_TYPE_WARNING, GNUNET_log, GNUNET_NO, GNUNET_OK, GNUNET_YES, key, GNUNET_MESSENGER_MessagePrivate::length, GNUNET_MESSENGER_MessageBody::privacy, 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_PublicKey *	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 1256 of file messenger_api_message.c.

{
  GNUNET_assert ((message) && (key));
 
  if (GNUNET_YES == is_service_message (message))
    return NULL;
 
  struct GNUNET_MESSENGER_Message *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;
 
  fold_short_message (message, &shortened);
 
  const uint16_t 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:

◆ 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] transcript Message transcript

Returns: GNUNET_YES on success, otherwise GNUNET_NO

Definition at line 1294 of file messenger_api_message.c.

{
  GNUNET_assert (message);
 
  if (GNUNET_MESSENGER_KIND_TRANSCRIPT != message->header.kind)
    return GNUNET_NO;
 
  const uint16_t data_length = message->body.transcript.length;
 
  struct GNUNET_MESSENGER_ShortMessage shortened;
  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:

◆ pack_message()

struct GNUNET_MQ_Envelope * pack_message	(	struct GNUNET_MESSENGER_Message *	message,
		struct GNUNET_HashCode *	hash,
		const GNUNET_MESSENGER_SignFunction	sign,
		enum GNUNET_MESSENGER_PackMode	mode,
		const void *	cls
	)

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 and it will be signed if the sign function is not NULL.

Parameters

[out]	message	Message
[out]	hash	Hash of message
[in]	sign	Function to sign
[in]	mode	Mode of packing
[in,out]	cls	Closure for signing

Returns: Envelope or NULL

Definition at line 1320 of file messenger_api_message.c.

{
  GNUNET_assert (message);
 
  GNUNET_log (GNUNET_ERROR_TYPE_INFO,
              "Packing message kind=%u and sender: %s\n",
              message->header.kind, GNUNET_sh2s (&(message->header.sender_id)));
 
  struct GNUNET_MessageHeader *header;
 
  const uint16_t length = get_message_size (message, GNUNET_YES);
  const uint16_t padded_length = calc_padded_length (length);
 
  struct GNUNET_MQ_Envelope *env;
  char *buffer;
 
  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 (sign)
      sign (cls, 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_INFO, 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(), iterate_send_room_message(), and pack_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 1372 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(), pack_srv_room_message(), process_message_control(), 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 1391 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_DELETE:
    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_SUBSCRIBE:
    return GNUNET_YES; // Reserved for subscription handling only!
  case GNUNET_MESSENGER_KIND_TALK:
    return GNUNET_NO;
  default:
    return GNUNET_SYSERR;
  }
}

Referenced by encrypt_message(), and transcribe_message().

Here is the call graph for this function:

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 1449 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_DELETE:
    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_SUBSCRIBE:
    return GNUNET_YES;
  case GNUNET_MESSENGER_KIND_TALK:
    return GNUNET_YES;
  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 1507 of file messenger_api_message.c.

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

References GNUNET_MESSENGER_Message::body, GNUNET_MESSENGER_MessageSubscribe::discourse, GNUNET_MESSENGER_MessageTalk::discourse, GNUNET_assert, GNUNET_MESSENGER_KIND_SUBSCRIBE, GNUNET_MESSENGER_KIND_TALK, GNUNET_MESSENGER_Message::header, GNUNET_MESSENGER_MessageHeader::kind, GNUNET_MESSENGER_MessageBody::subscribe, 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:

Data Structures

Macros

Typedefs

Functions

Macro Definition Documentation

◆ member_size

◆ max

◆ min

◆ encode_step_ext

◆ encode_step

◆ encode_step_key

◆ encode_step_signature

◆ decode_step_ext

◆ decode_step

◆ decode_step_malloc

◆ decode_step_key

Typedef Documentation

◆ kind_t

Function Documentation

◆ create_message()

◆ copy_message()

◆ copy_message_header()

◆ destroy_message_body()

◆ cleanup_message()

◆ destroy_message()

◆ is_message_session_bound()

◆ fold_short_message()

◆ unfold_short_message()

◆ get_message_body_kind_size()

◆ get_message_kind_size()

◆ get_message_body_size()

◆ get_message_size()

◆ get_short_message_size()

◆ calc_usual_padding()

◆ calc_padded_length()

◆ encode_message_body()

◆ encode_message()

◆ encode_short_message()

◆ decode_message_body()

◆ decode_message()

◆ decode_short_message()

◆ hash_message()

◆ sign_message()

◆ sign_message_by_peer()

◆ verify_message()

◆ verify_message_by_peer()

◆ encrypt_message()

◆ decrypt_message()

◆ transcribe_message()

◆ read_transcript_message()

◆ pack_message()

◆ is_peer_message()

◆ is_service_message()

◆ filter_message_sending()

◆ get_message_discourse()