[Feature Request] rest api for publish messages to device from app

[rogerwangzy]

rest api for publish messages to device from app

[dmytro-landiak]

hey @rogerwangzy,

Thank you for your feature request!

We appreciate you taking the time to share your idea. We agree that having a REST API to publish messages to a device from the TBMQ can be a valuable addition, especially for enhancing integration capabilities.

This is definitely something we believe could benefit many users, and we’ll consider including it in future releases. Stay tuned for updates, and thank you again for helping us improve the platform!

[rogerwangzy]

package org.thingsboard.mqtt.broker.controller;
import lombok.Data;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.security.access.prepost.PreAuthorize;
import org.springframework.web.bind.annotation.*;
import org.thingsboard.mqtt.broker.common.data.DevicePublishMsg;
import org.thingsboard.mqtt.broker.common.data.exception.ThingsboardException;
import org.thingsboard.mqtt.broker.service.mqtt.PublishMsgDeliveryService;
import org.thingsboard.mqtt.broker.service.mqtt.client.session.ClientSessionCtxService;
import org.thingsboard.mqtt.broker.session.ClientSessionCtx;

import java.nio.charset.StandardCharsets;
import java.util.UUID;

@RestController
@requiredargsconstructor
@RequestMapping("/api/publish")
@slf4j
public class PublishController extends BaseController {

private final PublishMsgDeliveryService publishMsgDeliveryService;
private final ClientSessionCtxService clientSessionCtxService;

@PreAuthorize("hasAnyAuthority('SYS_ADMIN')")
@RequestMapping(value = "/toClient", method = RequestMethod.POST)
@ResponseBody
public PublishResponse publishToClient(@RequestBody PublishRequest request) throws ThingsboardException {
    checkNotNull(request);
    try {
        ClientSessionCtx sessionCtx = clientSessionCtxService.getClientSessionCtx(request.getClientId());
        if (sessionCtx == null) {
            return new PublishResponse(false, null, "Client not connected: " + request.getClientId());
        }
        String messageId = UUID.randomUUID().toString();
        DevicePublishMsg publishMsg = DevicePublishMsg.builder()
                .topicName(request.getTopic())
                .payload(request.getPayload().getBytes(StandardCharsets.UTF_8))
                .qos(request.getQos())
                .build();
        publishMsgDeliveryService.sendPublishMsgToClient(sessionCtx, publishMsg, false);
        return new PublishResponse(true, messageId, null);
    } catch (Exception e) {
        throw handleException(e);
    }
}

@Data
public static class PublishRequest {
    private String clientId;
    private String topic;
    private String payload;
    private int qos = 0;
    private boolean retain = false;
}

@Data
public static class PublishResponse {
    private final boolean success;
    private final String messageId;
    private final String error;
}

}