MbedCloudClient.h

Go to the documentation of this file.

// ----------------------------------------------------------------------------
// Copyright 2016-2021 Pelion.
//
// SPDX-License-Identifier: Apache-2.0
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
//     http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.
// ----------------------------------------------------------------------------


#ifndef __MBED_CLOUD_CLIENT_H__
#define __MBED_CLOUD_CLIENT_H__

#include "include/ServiceClient.h"
#ifndef MBED_CLIENT_DISABLE_EST_FEATURE
#include "est_defs.h"
#endif // !MBED_CLIENT_DISABLE_EST_FEATURE
#include "mbed-cloud-client/MbedCloudClientConfig.h"

#ifndef MBED_CONF_MBED_CLOUD_CLIENT_DISABLE_CERTIFICATE_ENROLLMENT
// This overly long path is needed to have build compatibility with previous
// version. A #include can't just point to a file which is not in application's
// include path and we should not force application to add every internal directory
// of MCC to their paths.
// On next phase, the cmake is used to publish the API paths via
// target_include_directories(), but that requires a bit more cleanups.
#include "certificate-enrollment-client/certificate-enrollment-client/ce_defs.h"
#endif // MBED_CONF_MBED_CLOUD_CLIENT_DISABLE_CERTIFICATE_ENROLLMENT

#ifdef MBED_CONF_MBED_CLOUD_CLIENT_ENABLE_DEVICE_SENTRY
#include "ds_status.h"
#endif // MBED_CONF_MBED_CLOUD_CLIENT_ENABLE_DEVICE_SENTRY

#ifdef MBED_CLOUD_CLIENT_SUPPORT_MULTICAST_UPDATE
#include "multicast.h"
#endif // MBED_CLOUD_CLIENT_SUPPORT_MULTICAST_UPDATE

class MbedCloudClientCallback {

public:

    virtual void value_updated(M2MBase *base, M2MBase::BaseType type) = 0;
};



class MbedCloudClient : public ServiceClientCallback {

public:

    typedef enum {
        ConnectErrorNone                        = M2MInterface::ErrorNone,

        ConnectAlreadyExists                    = M2MInterface::AlreadyExists,

        ConnectBootstrapFailed                  = M2MInterface::BootstrapFailed,

        ConnectInvalidParameters                = M2MInterface::InvalidParameters,

        ConnectNotRegistered                    = M2MInterface::NotRegistered,

        ConnectTimeout                          = M2MInterface::Timeout,

        ConnectNetworkError                     = M2MInterface::NetworkError,

        ConnectResponseParseFailed              = M2MInterface::ResponseParseFailed,

        ConnectUnknownError                     = M2MInterface::UnknownError,

        ConnectMemoryConnectFail                = M2MInterface::MemoryFail,

        ConnectNotAllowed                       = M2MInterface::NotAllowed,

        ConnectSecureConnectionFailed           = M2MInterface::SecureConnectionFailed,

        ConnectDnsResolvingFailed               = M2MInterface::DnsResolvingFailed,

        ConnectorFailedToStoreCredentials       = M2MInterface::FailedToStoreCredentials,

        ConnectorFailedToReadCredentials        = M2MInterface::FailedToReadCredentials,

        ConnectorInvalidCredentials             = M2MInterface::InvalidCertificates,

        ConnectorUnregistrationFailed           = M2MInterface::UnregistrationFailed,

#ifdef MBED_CLOUD_CLIENT_SUPPORT_UPDATE
        UpdateWarningNoActionRequired           = UpdateClient::WarningBase, // Range reserved for Update Error from 0x0400 - 0x04FF
        UpdateWarningCertificateNotFound        = UpdateClient::WarningCertificateNotFound,
        UpdateWarningIdentityNotFound           = UpdateClient::WarningIdentityNotFound,
        UpdateWarningVendorMismatch             = UpdateClient::WarningVendorMismatch,
        UpdateWarningClassMismatch              = UpdateClient::WarningClassMismatch,
        UpdateWarningDeviceMismatch             = UpdateClient::WarningDeviceMismatch,
        UpdateWarningCertificateInvalid         = UpdateClient::WarningCertificateInvalid,
        UpdateWarningSignatureInvalid           = UpdateClient::WarningSignatureInvalid,
        UpdateWarningBadKeytable                = UpdateClient::WarningBadKeytable,
        UpdateWarningURINotFound                = UpdateClient::WarningURINotFound,
        UpdateWarningRollbackProtection         = UpdateClient::WarningRollbackProtection,
        UpdateWarningAuthorizationRejected      = UpdateClient::WarningAuthorizationRejected,
        UpdateWarningAuthorizationUnavailable   = UpdateClient::WarningAuthorizationUnavailable,
        UpdateWarningUnknown                    = UpdateClient::WarningUnknown,
        UpdateCertificateInsertion              = UpdateClient::WarningCertificateInsertion,
        UpdateErrorUserActionRequired           = UpdateClient::ErrorBase,
        UpdateErrorWriteToStorage               = UpdateClient::ErrorWriteToStorage,
        UpdateErrorInvalidHash                  = UpdateClient::ErrorInvalidHash,
        UpdateErrorConnection                   = UpdateClient::ErrorConnection,
        UpdateFatalRebootRequired,
#endif
#ifndef MBED_CONF_MBED_CLOUD_CLIENT_DISABLE_CERTIFICATE_ENROLLMENT
        EnrollmentErrorBase = CE_STATUS_RANGE_BASE,
        EnrollmentErrorEnd = CE_STATUS_RANGE_END,
#endif // MBED_CONF_MBED_CLOUD_CLIENT_DISABLE_CERTIFICATE_ENROLLMENT
#ifdef MBED_CONF_MBED_CLOUD_CLIENT_ENABLE_DEVICE_SENTRY
        DeviceSentryErrorBase = DS_STATUS_RANGE_BASE,
        DeviceSentryErrorEnd = DS_STATUS_RANGE_END,
#endif // MBED_CONF_MBED_CLOUD_CLIENT_ENABLE_DEVICE_SENTRY
#ifdef MBED_CLOUD_CLIENT_SUPPORT_MULTICAST_UPDATE
        MulticastErrorBase = MULTICAST_STATUS_RANGE_BASE,
        MulticastErrorEnd = MULTICAST_STATUS_RANGE_END
#endif // MBED_CLOUD_CLIENT_SUPPORT_MULTICAST_UPDATE

    } Error;

#ifdef MBED_CLOUD_CLIENT_SUPPORT_UPDATE

    enum {
        UpdateRequestInvalid                    = UpdateClient::RequestInvalid,
        UpdateRequestDownload                   = UpdateClient::RequestDownload,
        UpdateRequestInstall                    = UpdateClient::RequestInstall
    };
#endif

    typedef enum {
        Unregistered = 0,
        Registered,
        RegistrationUpdated,
        AlertMode,
        Paused,
        Sleep
    } Status;

    MbedCloudClient();

    MbedCloudClient(void(*on_registered_cb)(void),
                    void(*on_unregistered_cb)(void),
                    void(*on_error_cb)(int)
#ifdef MBED_CLOUD_CLIENT_SUPPORT_UPDATE
                    , void(*update_authorize_cb)(int32_t request) = NULL,
                    void(*update_progress_cb)(uint32_t progress, uint32_t total) = NULL
#endif
                   ) m2m_deprecated;

    MbedCloudClient(void(*on_status_changed_cb)(int),
                    void(*on_error_cb)(int)
#ifdef MBED_CLOUD_CLIENT_SUPPORT_UPDATE
                    , void(*update_authorize_cb)(int32_t request) = NULL,
                    void(*update_progress_cb)(uint32_t progress, uint32_t total) = NULL
#endif
                   );

    virtual ~MbedCloudClient();

    void add_objects(const M2MObjectList &object_list);

    void add_objects(const M2MBaseList &base_list);

    void remove_object(M2MBase *object);

    void set_update_callback(MbedCloudClientCallback *callback);

    bool init();

    bool setup(void *iface, bool full_register = false);

    void on_registered(void(*fn)(void)) m2m_deprecated;

    template<typename T>
    void on_registered(T *object, void (T::*member)(void)) m2m_deprecated;

    void on_error(void(*fn)(int));

    template<typename T>
    void on_error(T *object, void (T::*member)(int));

    void on_status_changed(void(*fn)(int));

    template<typename T>
    void on_status_changed(T *object, void (T::*member)(int));

    void on_unregistered(void(*fn)(void)) m2m_deprecated;

    template<typename T>
    void on_unregistered(T *object, void (T::*member)(void)) m2m_deprecated;

    void on_registration_updated(void(*fn)(void)) m2m_deprecated;

    template<typename T>
    void on_registration_updated(T *object, void (T::*member)(void)) m2m_deprecated;

    void keep_alive() m2m_deprecated;

    void register_update();

    void close();

    const ConnectorClientEndpointInfo *endpoint_info() const;

    M2MInterface *get_m2m_interface();

    void set_queue_sleep_handler(callback_handler handler) m2m_deprecated;

    void set_random_number_callback(random_number_cb callback);

    void set_entropy_callback(entropy_cb callback);

#ifdef MBED_CLOUD_CLIENT_SUPPORT_UPDATE

    void set_update_authorize_handler(void (*handler)(int32_t request)) __attribute__((deprecated("Use set_update_authorize_priority_handler instead")));

    void set_update_authorize_priority_handler(void (*handler)(int32_t request, uint64_t priority));

    void update_authorize(int32_t request);

    void update_reject(int32_t request, int32_t reason);

    void set_update_progress_handler(void (*handler)(uint32_t progress, uint32_t total));
#endif

#ifdef MBED_CLOUD_CLIENT_SUPPORT_MULTICAST_UPDATE

    void on_external_update(void(*fn)(uint32_t start_address, uint32_t firmware_size));
#endif

    const char *error_description() const;

    void send_get_request(DownloadType type,
                          const char *uri,
                          const size_t offset,
                          get_data_cb data_cb,
                          get_data_error_cb error_cb,
                          void *context);

#ifndef MBED_CONF_MBED_CLOUD_CLIENT_DISABLE_CERTIFICATE_ENROLLMENT

    ce_status_e certificate_renew(const char *cert_name);

    void on_certificate_renewal(cert_renewal_cb_f user_cb);
#endif // MBED_CONF_MBED_CLOUD_CLIENT_DISABLE_CERTIFICATE_ENROLLMENT

#ifdef MBED_CLOUD_CLIENT_EDGE_EXTENSION

    const M2MBaseList *get_object_list() const;
#endif // MBED_CLOUD_CLIENT_EDGE_EXTENSION

    void pause();

    void resume(void *iface);

    void alert();

#if defined (MBED_CLIENT_DYNAMIC_LOGGING_BUFFER_SIZE) && (MBED_CLIENT_DYNAMIC_LOGGING_BUFFER_SIZE > 0)

    void set_dynamic_logging_state(bool state, bool stopped_by_update);
#endif // MBED_CLIENT_DYNAMIC_LOGGING_BUFFER_SIZE

#ifndef MBED_CLIENT_DISABLE_EST_FEATURE

    est_status_e est_request_enrollment(const char *cert_name,
                                        const size_t cert_name_length,
                                        uint8_t *csr,
                                        const size_t csr_length,
                                        est_enrollment_result_cb result_cb,
                                        void *context) const;

    void est_free_cert_chain_context(cert_chain_context_s *context) const;
#endif // !MBED_CLIENT_DISABLE_EST_FEATURE

protected: // from ServiceClientCallback

    virtual void complete(ServiceClientCallbackStatus status);

    virtual void error(int error, const char *reason);

    virtual void value_updated(M2MBase *base, M2MBase::BaseType type);

#ifdef MBED_CLOUD_CLIENT_SUPPORT_MULTICAST_UPDATE

    virtual void external_update(uint32_t start_address, uint32_t firmware_size);
#endif

private:

    ServiceClient                                   _client;
    MbedCloudClientCallback                         *_value_callback;
    M2MBaseList                                     _object_list;
    FP0<void>                                       _on_registered;
    FP0<void>                                       _on_unregistered;
    FP0<void>                                       _on_registration_updated;
    FP1<void, int>                                   _on_error;
    FP1<void, int>                                   _on_status_changed;
    const char                                      *_error_description;
    bool                                            _init_done;
#ifdef MBED_CLOUD_CLIENT_SUPPORT_MULTICAST_UPDATE
    FP2<void, uint32_t, uint32_t>                   _on_external_update;
#endif

};

template<typename T>
void MbedCloudClient::on_registered(T *object, void (T::*member)(void))
{
    FP0<void> fp(object, member);
    _on_registered = fp;
}

template<typename T>
void MbedCloudClient::on_error(T *object, void (T::*member)(int))
{
    FP1<void, int> fp(object, member);
    _on_error = fp;
}

template<typename T>
void MbedCloudClient::on_unregistered(T *object, void (T::*member)(void))
{
    FP0<void> fp(object, member);
    _on_unregistered = fp;
}

template<typename T>
void MbedCloudClient::on_registration_updated(T *object, void (T::*member)(void))
{
    FP0<void> fp(object, member);
    _on_registration_updated = fp;
}

template<typename T>
void MbedCloudClient::on_status_changed(T *object, void (T::*member)(int))
{
    FP1<void, int> fp(object, member);
    _on_status_changed = fp;
}
#endif // __MBED_CLOUD_CLIENT_H__