/*
// Copyright (c) 2016 Intel Corporation
//
// 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 OC_CLIENT_STATE_H
#define OC_CLIENT_STATE_H

#include <stdbool.h>

#include "oic/messaging/coap/constants.h"
#include "oic/oc_ri.h"
#include "oic/oc_ri_const.h"

#ifdef __cplusplus
extern "C" {
#endif

#ifdef OC_CLIENT
typedef enum { HIGH_QOS = 0, LOW_QOS } oc_qos_t;

typedef struct oc_client_response {
    struct coap_packet_rx *packet;
    struct oc_endpoint *origin;
    oc_status_t code;
    uint32_t observe_option;
} oc_client_response_t;

typedef struct oc_server_handle {
    oc_endpoint_t endpoint;
} oc_server_handle_t;

typedef enum {
    OC_STOP_DISCOVERY = 0,
    OC_CONTINUE_DISCOVERY
} oc_discovery_flags_t;

typedef oc_discovery_flags_t(oc_discovery_cb_t)(const char *, const char *,
                                                oc_string_array_t,
                                                oc_interface_mask_t,
                                                oc_server_handle_t *);

typedef void (*oc_response_handler_t)(oc_client_response_t *);

typedef struct oc_client_cb {
    SLIST_ENTRY(oc_client_cb) next;
    struct os_callout callout;
    oc_string_t uri;
    uint8_t token[COAP_TOKEN_LEN];
    uint8_t token_len;
    uint16_t mid;

    oc_server_handle_t server;

    void *handler;

    bool discovery;
    int32_t observe_seq;
    oc_clock_time_t timestamp;
    oc_qos_t qos;
    oc_method_t method;
} oc_client_cb_t;

bool oc_ri_invoke_client_cb(struct coap_packet_rx *response,
                            oc_endpoint_t *);

oc_client_cb_t *oc_ri_alloc_client_cb(const char *uri,
                                      oc_server_handle_t *server,
                                      oc_method_t method, void *handler,
                                      oc_qos_t qos);

oc_client_cb_t *oc_ri_get_client_cb(const char *uri, oc_server_handle_t *server,
                                    oc_method_t method);

void oc_ri_remove_client_cb_by_mid(uint16_t mid);

oc_discovery_flags_t oc_ri_process_discovery_payload(struct coap_packet_rx *rsp,
                                                     oc_discovery_cb_t *handler,
                                                     oc_endpoint_t *);

bool oc_ri_send_rst(oc_endpoint_t *endpoint, uint8_t *token,
                    uint8_t token_len, uint16_t mid);
#endif

#ifdef __cplusplus
}
#endif

#endif /* OC_CLIENT_STATE_H */