GNUnet  0.11.x
gnunet-service-messenger_message_recv.c
Go to the documentation of this file.
1 /*
2  This file is part of GNUnet.
3  Copyright (C) 2020--2021 GNUnet e.V.
4 
5  GNUnet is free software: you can redistribute it and/or modify it
6  under the terms of the GNU Affero General Public License as published
7  by the Free Software Foundation, either version 3 of the License,
8  or (at your option) any later version.
9 
10  GNUnet is distributed in the hope that it will be useful, but
11  WITHOUT ANY WARRANTY; without even the implied warranty of
12  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
13  Affero General Public License for more details.
14 
15  You should have received a copy of the GNU Affero General Public License
16  along with this program. If not, see <http://www.gnu.org/licenses/>.
17 
18  SPDX-License-Identifier: AGPL3.0-or-later
19  */
27 
29 
30 static void
33 {
34  if (session->prev)
35  forward_about_members (room, tunnel, session->prev, map);
36 
37  struct GNUNET_MESSENGER_MessageStore *message_store = get_room_message_store(room);
38  struct GNUNET_MESSENGER_ListMessage *element;
39 
40  for (element = session->messages.head; element; element = element->next)
41  {
43  continue;
44 
45  if (GNUNET_OK != GNUNET_CONTAINER_multihashmap_put(map, &(element->hash), NULL,
47  GNUNET_log(GNUNET_ERROR_TYPE_WARNING, "Forwarding of session message could be duplicated!\n");
48 
49  const struct GNUNET_MESSENGER_Message *message = get_store_message(message_store, &(element->hash));
50 
51  if (message)
52  forward_tunnel_message(tunnel, message, &(element->hash));
53  }
54 }
55 
56 static int
57 iterate_forward_members (void *cls, const struct GNUNET_IDENTITY_PublicKey *public_key,
58  struct GNUNET_MESSENGER_MemberSession *session)
59 {
60  struct GNUNET_MESSENGER_SrvTunnel *tunnel = cls;
61 
63  return GNUNET_YES;
64 
66 
67  forward_about_members (tunnel->room, tunnel, session, map);
68 
70  return GNUNET_YES;
71 }
72 
73 int
75  const struct GNUNET_MESSENGER_Message *message, const struct GNUNET_HashCode *hash)
76 {
77  const uint32_t version = get_tunnel_messenger_version(tunnel);
78 
80  {
81  disconnect_tunnel(tunnel);
82  return GNUNET_NO;
83  }
84 
85  if (version == get_tunnel_messenger_version(tunnel))
86  return GNUNET_NO;
87 
88  if (room->host)
89  {
90  const struct GNUNET_MESSENGER_Ego *ego = get_handle_ego(room->host);
91 
92  send_tunnel_message (tunnel, room->host, create_message_info(ego));
93  }
94 
95  struct GNUNET_PeerIdentity peer;
96  get_tunnel_peer_identity(tunnel, &peer);
97 
98  if (GNUNET_YES != contains_list_tunnels(&(room->basement), &peer))
99  {
100  struct GNUNET_MESSENGER_MemberStore *member_store = get_room_member_store(room);
101 
102  iterate_store_members(member_store, iterate_forward_members, tunnel);
103  }
104 
105  check_room_peer_status(room, tunnel);
106 
107  return GNUNET_NO;
108 }
109 
110 int
112  const struct GNUNET_MESSENGER_Message *message, const struct GNUNET_HashCode *hash)
113 {
114  struct GNUNET_PeerIdentity peer;
115  GNUNET_PEER_resolve (tunnel->peer, &peer);
116 
117  if (0 == GNUNET_memcmp(&peer, &(message->body.peer.peer)))
118  {
119  if (!tunnel->peer_message)
120  tunnel->peer_message = GNUNET_new(struct GNUNET_HashCode);
121 
122  GNUNET_memcpy(tunnel->peer_message, &hash, sizeof(hash));
123  }
124 
125  return GNUNET_YES;
126 }
127 
128 static void
130  const struct GNUNET_MESSENGER_Message *message,
131  const struct GNUNET_HashCode *hash)
132 {
133  struct GNUNET_MESSENGER_SrvTunnel *tunnel = tunnel;
134 
135  if (!message)
136  {
137  struct GNUNET_MESSENGER_OperationStore *operation_store = get_room_operation_store(room);
138 
140  operation_store,
141  hash,
144  );
145  }
146  else
147  forward_tunnel_message (tunnel, message, hash);
148 }
149 
150 /*
151  * Function returns GNUNET_NO to drop forwarding the request.
152  * It will only be forwarded if it can't be answered!
153  */
154 int
156  const struct GNUNET_MESSENGER_Message *message, const struct GNUNET_HashCode *hash)
157 {
158  struct GNUNET_MESSENGER_MemberStore *member_store = get_room_member_store(room);
159  struct GNUNET_MESSENGER_Member *member = get_store_member_of(member_store, message);
160 
161  GNUNET_log(GNUNET_ERROR_TYPE_DEBUG, "Request for message (%s)\n", GNUNET_h2s (hash));
162 
163  if (!member)
164  return GNUNET_NO;
165 
166  struct GNUNET_MESSENGER_MemberSession *session = get_member_session_of(member, message, hash);
167 
168  if ((!session) || (GNUNET_YES != check_member_session_history(session, hash, GNUNET_NO)))
169  return GNUNET_NO;
170 
171  if (GNUNET_NO == request_room_message(room, &(message->body.request.hash), session, callback_found_message, tunnel))
172  return GNUNET_YES;
173 
174  return GNUNET_NO;
175 }
struct GNUNET_PeerIdentity peer
The peer identity of the sender opening a room.
int contains_list_tunnels(struct GNUNET_MESSENGER_ListTunnels *tunnels, const struct GNUNET_PeerIdentity *peer)
Tests linearly if the list of tunnels peer identities contains a specific peer identity and returns G...
struct GNUNET_MESSENGER_MessageStore * get_room_message_store(struct GNUNET_MESSENGER_SrvRoom *room)
Returns the used message store of a given room.
struct GNUNET_MESSENGER_ListMessage * next
struct GNUNET_MESSENGER_ListMessage * head
void check_room_peer_status(struct GNUNET_MESSENGER_SrvRoom *room, struct GNUNET_MESSENGER_SrvTunnel *tunnel)
Checks the current state of opening a given room from this peer and re-publishes it if necessary to a...
GNUnet MESSENGER service.
int iterate_store_members(struct GNUNET_MESSENGER_MemberStore *store, GNUNET_MESSENGER_MemberIteratorCallback it, void *cls)
Iterate through all member sessions currently connected to the members of the given member store and ...
int is_member_session_completed(const struct GNUNET_MESSENGER_MemberSession *session)
Returns if the given member session has been completed.
struct GNUNET_HashCode hash
The hash of the requested message.
uint32_t messenger_version
The version of GNUnet Messenger API.
#define GNUNET_memcpy(dst, src, n)
Call memcpy() but check for n being 0 first.
const char * GNUNET_h2s(const struct GNUNET_HashCode *hc)
Convert a hash value to a string (for printing debug messages).
#define GNUNET_new(type)
Allocate a struct or union of the given type.
int GNUNET_CONTAINER_multihashmap_contains(const struct GNUNET_CONTAINER_MultiHashMap *map, const struct GNUNET_HashCode *key)
Check if the map contains any value under the given key (including values that are NULL)...
void GNUNET_PEER_resolve(GNUNET_PEER_Id id, struct GNUNET_PeerIdentity *pid)
Convert an interned PID to a normal peer identity.
Definition: peer.c:225
int recv_message_info(struct GNUNET_MESSENGER_SrvRoom *room, struct GNUNET_MESSENGER_SrvTunnel *tunnel, const struct GNUNET_MESSENGER_Message *message, const struct GNUNET_HashCode *hash)
Handles a received info message to change the current member id to the one generated by the host conn...
Internal representation of the hash map.
struct GNUNET_MESSENGER_MemberStore * get_room_member_store(struct GNUNET_MESSENGER_SrvRoom *room)
Returns the used member store of a given room.
static struct GNUNET_CONTAINER_MultiPeerMap * map
Handle to the map used to store old latency values for peers.
uint32_t get_tunnel_messenger_version(const struct GNUNET_MESSENGER_SrvTunnel *tunnel)
Returns the current messenger version the peer connected via a given tunnel has reported to be using ...
struct GNUNET_MESSENGER_MessageRequest request
struct GNUNET_MESSENGER_OperationStore * get_room_operation_store(struct GNUNET_MESSENGER_SrvRoom *room)
Returns the used operation store of a given room.
, &#39; bother checking if a value already exists (faster than GNUNET_CONTAINER_MULTIHASHMAPOPTION_...
int request_room_message(struct GNUNET_MESSENGER_SrvRoom *room, const struct GNUNET_HashCode *hash, const struct GNUNET_MESSENGER_MemberSession *session, GNUNET_MESSENGER_MessageRequestCallback callback, void *cls)
Requests a message from a room identified by a given hash.
void GNUNET_CONTAINER_multihashmap_destroy(struct GNUNET_CONTAINER_MultiHashMap *map)
Destroy a hash map.
void get_tunnel_peer_identity(const struct GNUNET_MESSENGER_SrvTunnel *tunnel, struct GNUNET_PeerIdentity *peer)
Writes the peer identity of the peer connected via tunnel to this peer into the peer parameter...
struct GNUNET_MESSENGER_Message * create_message_info(const struct GNUNET_MESSENGER_Ego *ego)
Creates and allocates a new info message containing the hosts EGO public key and a newly generated un...
struct GNUNET_MESSENGER_MessageBody body
Body.
struct GNUNET_MESSENGER_SrvRoom * room
A 512-bit hashcode.
int check_member_session_history(const struct GNUNET_MESSENGER_MemberSession *session, const struct GNUNET_HashCode *hash, int ownership)
Checks the history of a session for a specific message which is identified by its hash and if the own...
int recv_message_request(struct GNUNET_MESSENGER_SrvRoom *room, struct GNUNET_MESSENGER_SrvTunnel *tunnel, const struct GNUNET_MESSENGER_Message *message, const struct GNUNET_HashCode *hash)
Handles a received request message by checking for the requested message and forwarding it back if th...
const struct GNUNET_MESSENGER_Message * get_store_message(struct GNUNET_MESSENGER_MessageStore *store, const struct GNUNET_HashCode *hash)
Returns the message from a message store matching a given hash.
#define GNUNET_MESSENGER_REQUEST_DELAY
struct GNUNET_MESSENGER_SrvHandle * host
static int iterate_forward_members(void *cls, const struct GNUNET_IDENTITY_PublicKey *public_key, struct GNUNET_MESSENGER_MemberSession *session)
GNUnet MESSENGER service.
struct GNUNET_MESSENGER_MessageInfo info
struct GNUNET_MESSENGER_ListMessages messages
struct GNUNET_MESSENGER_MessagePeer peer
int GNUNET_CONTAINER_multihashmap_put(struct GNUNET_CONTAINER_MultiHashMap *map, const struct GNUNET_HashCode *key, void *value, enum GNUNET_CONTAINER_MultiHashMapOption opt)
Store a key-value pair in the map.
int use_store_operation(struct GNUNET_MESSENGER_OperationStore *store, const struct GNUNET_HashCode *hash, enum GNUNET_MESSENGER_OperationType type, struct GNUNET_TIME_Relative delay)
Tries to use an operation under a given hash in a specific operation store.
#define GNUNET_memcmp(a, b)
Compare memory in a and b, where both must be of the same pointer type.
struct GNUNET_MESSENGER_Member * get_store_member_of(struct GNUNET_MESSENGER_MemberStore *store, const struct GNUNET_MESSENGER_Message *message)
Returns the member of a store using a sender id of a given message.
int recv_message_peer(struct GNUNET_MESSENGER_SrvRoom *room, struct GNUNET_MESSENGER_SrvTunnel *tunnel, const struct GNUNET_MESSENGER_Message *message, const struct GNUNET_HashCode *hash)
Handles a received peer message to link it to its origin tunnel if the peer identity matches...
void forward_tunnel_message(struct GNUNET_MESSENGER_SrvTunnel *tunnel, const struct GNUNET_MESSENGER_Message *message, const struct GNUNET_HashCode *hash)
Forwards a given message with a known hash through a tunnel.
The identity of the host (wraps the signing key of the peer).
An identity key as per LSD0001.
int update_tunnel_messenger_version(struct GNUNET_MESSENGER_SrvTunnel *tunnel, uint32_t version)
Updates the messenger version of the tunnel to a given version if it is compatible to the running pee...
struct GNUNET_MESSENGER_ListTunnels basement
static void forward_about_members(struct GNUNET_MESSENGER_SrvRoom *room, struct GNUNET_MESSENGER_SrvTunnel *tunnel, struct GNUNET_MESSENGER_MemberSession *session, struct GNUNET_CONTAINER_MultiHashMap *map)
#define GNUNET_log(kind,...)
int send_tunnel_message(struct GNUNET_MESSENGER_SrvTunnel *tunnel, void *handle, struct GNUNET_MESSENGER_Message *message)
Sends a message by packing it automatically into an envelope and passing it through the tunnel...
struct GNUNET_CONTAINER_MultiHashMap * GNUNET_CONTAINER_multihashmap_create(unsigned int len, int do_not_copy_keys)
Create a multi hash map.
void disconnect_tunnel(struct GNUNET_MESSENGER_SrvTunnel *tunnel)
Disconnects and unbinds a channel from a tunnel.
static void callback_found_message(void *cls, struct GNUNET_MESSENGER_SrvRoom *room, const struct GNUNET_MESSENGER_Message *message, const struct GNUNET_HashCode *hash)
struct GNUNET_MESSENGER_MemberSession * get_member_session_of(struct GNUNET_MESSENGER_Member *member, const struct GNUNET_MESSENGER_Message *message, const struct GNUNET_HashCode *hash)
Returns the member session of a member using a public key which can verify the signature of a given m...
struct GNUNET_MESSENGER_MemberSession * prev
const struct GNUNET_MESSENGER_Ego * get_handle_ego(const struct GNUNET_MESSENGER_SrvHandle *handle)
Returns the EGO used by a given handle.