/*
|
Copyright (c) 2009-2019 Roger Light <roger@atchoo.org>
|
|
All rights reserved. This program and the accompanying materials
|
are made available under the terms of the Eclipse Public License v1.0
|
and Eclipse Distribution License v1.0 which accompany this distribution.
|
|
The Eclipse Public License is available at
|
http://www.eclipse.org/legal/epl-v10.html
|
and the Eclipse Distribution License is available at
|
http://www.eclipse.org/org/documents/edl-v10.php.
|
|
Contributors:
|
Roger Light - initial implementation and documentation.
|
*/
|
|
#include "config.h"
|
|
#include <stdio.h>
|
#include <string.h>
|
|
#include "mosquitto_broker_internal.h"
|
#include "memory_mosq.h"
|
#include "mqtt_protocol.h"
|
#include "packet_mosq.h"
|
#include "send_mosq.h"
|
#include "util_mosq.h"
|
|
int handle__connack(struct mosquitto_db *db, struct mosquitto *context)
|
{
|
int rc;
|
uint8_t connect_acknowledge;
|
uint8_t reason_code;
|
int i;
|
char *notification_topic;
|
int notification_topic_len;
|
char notification_payload;
|
mosquitto_property *properties = NULL;
|
|
if(!context){
|
return MOSQ_ERR_INVAL;
|
}
|
log__printf(NULL, MOSQ_LOG_DEBUG, "Received CONNACK on connection %s.", context->id);
|
if(packet__read_byte(&context->in_packet, &connect_acknowledge)) return 1;
|
if(packet__read_byte(&context->in_packet, &reason_code)) return 1;
|
|
if(context->protocol == mosq_p_mqtt5){
|
rc = property__read_all(CMD_CONNACK, &context->in_packet, &properties);
|
if(rc) return rc;
|
mosquitto_property_free_all(&properties);
|
}
|
mosquitto_property_free_all(&properties); /* FIXME - TEMPORARY UNTIL PROPERTIES PROCESSED */
|
|
switch(reason_code){
|
case CONNACK_ACCEPTED:
|
if(context->bridge){
|
if(context->bridge->notifications){
|
notification_payload = '1';
|
if(context->bridge->notification_topic){
|
if(!context->bridge->notifications_local_only){
|
if(send__real_publish(context, mosquitto__mid_generate(context),
|
context->bridge->notification_topic, 1, ¬ification_payload, 1, true, 0, NULL, NULL, 0)){
|
|
return 1;
|
}
|
}
|
db__messages_easy_queue(db, context, context->bridge->notification_topic, 1, 1, ¬ification_payload, 1, 0, NULL);
|
}else{
|
notification_topic_len = strlen(context->bridge->remote_clientid)+strlen("$SYS/broker/connection//state");
|
notification_topic = mosquitto__malloc(sizeof(char)*(notification_topic_len+1));
|
if(!notification_topic) return MOSQ_ERR_NOMEM;
|
|
snprintf(notification_topic, notification_topic_len+1, "$SYS/broker/connection/%s/state", context->bridge->remote_clientid);
|
notification_payload = '1';
|
if(!context->bridge->notifications_local_only){
|
if(send__real_publish(context, mosquitto__mid_generate(context),
|
notification_topic, 1, ¬ification_payload, 1, true, 0, NULL, NULL, 0)){
|
|
mosquitto__free(notification_topic);
|
return 1;
|
}
|
}
|
db__messages_easy_queue(db, context, notification_topic, 1, 1, ¬ification_payload, 1, 0, NULL);
|
mosquitto__free(notification_topic);
|
}
|
}
|
for(i=0; i<context->bridge->topic_count; i++){
|
if(context->bridge->topics[i].direction == bd_in || context->bridge->topics[i].direction == bd_both){
|
if(send__subscribe(context, NULL, 1, &context->bridge->topics[i].remote_topic, context->bridge->topics[i].qos, NULL)){
|
return 1;
|
}
|
}else{
|
if(context->bridge->attempt_unsubscribe){
|
if(send__unsubscribe(context, NULL, 1, &context->bridge->topics[i].remote_topic, NULL)){
|
/* direction = inwards only. This means we should not be subscribed
|
* to the topic. It is possible that we used to be subscribed to
|
* this topic so unsubscribe. */
|
return 1;
|
}
|
}
|
}
|
}
|
for(i=0; i<context->bridge->topic_count; i++){
|
if(context->bridge->topics[i].direction == bd_out || context->bridge->topics[i].direction == bd_both){
|
sub__retain_queue(db, context,
|
context->bridge->topics[i].local_topic,
|
context->bridge->topics[i].qos, 0);
|
}
|
}
|
}
|
context__set_state(context, mosq_cs_connected);
|
return MOSQ_ERR_SUCCESS;
|
case CONNACK_REFUSED_PROTOCOL_VERSION:
|
if(context->bridge){
|
context->bridge->try_private_accepted = false;
|
}
|
log__printf(NULL, MOSQ_LOG_ERR, "Connection Refused: unacceptable protocol version");
|
return 1;
|
case CONNACK_REFUSED_IDENTIFIER_REJECTED:
|
log__printf(NULL, MOSQ_LOG_ERR, "Connection Refused: identifier rejected");
|
return 1;
|
case CONNACK_REFUSED_SERVER_UNAVAILABLE:
|
log__printf(NULL, MOSQ_LOG_ERR, "Connection Refused: broker unavailable");
|
return 1;
|
case CONNACK_REFUSED_BAD_USERNAME_PASSWORD:
|
log__printf(NULL, MOSQ_LOG_ERR, "Connection Refused: broker unavailable");
|
return 1;
|
case CONNACK_REFUSED_NOT_AUTHORIZED:
|
log__printf(NULL, MOSQ_LOG_ERR, "Connection Refused: not authorised");
|
return 1;
|
default:
|
log__printf(NULL, MOSQ_LOG_ERR, "Connection Refused: unknown reason");
|
return 1;
|
}
|
return 1;
|
}
|
