/*
 * Copyright (c) 2021 Cisco and/or its affiliates.
 * 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.
 */
#include <stdio.h>
#include <malloc.h>
#include <sysrepo/xpath.h>

/* Hicn headers */

#include "hicn_model.h"
#include "tlock.h"
#include "../hicn_light.h"
#include "../hicn_light_comm.h"
#include <hicn/util/sstrncpy.h>

/**
 * @brief API to add hicn face ip in hicn-light.
 */
static int hicn_face_ip_add_cb(sr_session_ctx_t *session, const char *path,
                               const sr_val_t *input, const size_t input_cnt,
                               sr_event_t event, uint32_t request_id,
                               sr_val_t **output, size_t *output_cnt,
                               void *private_data) {
  SRP_LOG_DBGMSG("hicn face ip add received successfully");
  hc_face_t face;
  if (strcmp(input[0].data.string_val, "-1")) {
    struct sockaddr_in sa;
    // store this IP address in sa:
    inet_pton(AF_INET, input[0].data.string_val, &(sa.sin_addr));
    face.face.family = AF_INET;
    face.face.local_addr.v4.as_inaddr = sa.sin_addr;

  } else if (strcmp(input[1].data.string_val, "-1")) {
    struct in6_addr *dst = malloc(sizeof(struct in6_addr));
    inet_pton(AF_INET6, input[1].data.string_val, dst);
    face.face.family = AF_INET6;
    face.face.local_addr.v6.as_in6addr = *dst;

  } else {
    SRP_LOG_DBGMSG("Invalid local IP address");
    return SR_ERR_OPERATION_FAILED;
  }

  if (strcmp(input[2].data.string_val, "-1")) {
    struct sockaddr_in sa;
    // store this IP address in sa:
    inet_pton(AF_INET, input[2].data.string_val, &(sa.sin_addr));
    face.face.family = AF_INET;
    face.face.remote_addr.v4.as_inaddr = sa.sin_addr;

  } else if (strcmp(input[3].data.string_val, "-1")) {
    struct in6_addr *dst = malloc(sizeof(struct in6_addr));
    inet_pton(AF_INET6, input[3].data.string_val, dst);
    face.face.family = AF_INET6;
    face.face.remote_addr.v6.as_in6addr = *dst;

  } else {
    SRP_LOG_DBGMSG("Invalid local IP address");
    return SR_ERR_OPERATION_FAILED;
  }

  face.face.netdevice.index =
      input[4].data.uint32_val;  // This is the idx number of interface

  int rc;
  face.id = 0;  // can be empty
  rc = strcpy_s(face.name, sizeof(face.name), "hicn_face");
  if (rc != EOK) return SR_ERR_OPERATION_FAILED;
  face.face.type = 1;

  rc = hc_face_create(hsocket, &face);
  if (rc > 0) {
    SRP_LOG_DBGMSG("Face added successfully");
    return SR_ERR_OK;
  }

  SRP_LOG_DBGMSG("Operation Failed");
  return SR_ERR_OPERATION_FAILED;
}

/**
 * @brief API to del hicn face ip in vpp.
 */
static int hicn_face_ip_del_cb(sr_session_ctx_t *session, const char *path,
                               const sr_val_t *input, const size_t input_cnt,
                               sr_event_t event, uint32_t request_id,
                               sr_val_t **output, size_t *output_cnt,
                               void *private_data) {
  SRP_LOG_DBGMSG("hicn face ip del received successfully");
  face_t *face = NULL;

  face_free(face);

  SRP_LOG_DBGMSG("Operation Failed");
  return SR_ERR_OPERATION_FAILED;
}

/**
 * @brief API to del hicn face ip in vpp.
 */
static int hicn_route_add_cb(sr_session_ctx_t *session, const char *path,
                             const sr_val_t *input, const size_t input_cnt,
                             sr_event_t event, uint32_t request_id,
                             sr_val_t **output, size_t *output_cnt,
                             void *private_data) {
  /*

    SRP_LOG_DBG_MSG("hicn route add received successfully");

    hc_route_t * route;

    if(strcmp(input[0].data.string_val,"-1")){

    struct sockaddr_in sa;
    // store this IP address in sa:
    inet_pton(AF_INET,  input[0].data.string_val, &(sa.sin_addr));
    route.family=AF_INET;
    route.face.hicn.local_addr.v4.as_inaddr=sa.sin_addr;


    }else if(strcmp(input[1].data.string_val,"-1")){

      struct in6_addr *dst = malloc(sizeof(struct in6_addr));
      inet_pton(AF_INET6, input[1].data.string_val, dst);
      face.face.hicn.family=AF_INET6;
      face.face.hicn.local_addr.v6.as_in6addr = *dst;

    }else{
        SRP_LOG_DBG_MSG("Invalid local IP address");
        return SR_ERR_OPERATION_FAILED;
    }


  hc_route_create(hsocket, route);
  */
  return SR_ERR_OK;
}

int hicn_subscribe_events(sr_session_ctx_t *session,
                          sr_subscription_ctx_t **subscription) {
  int rc;
  rc = sr_rpc_subscribe(session, "/hicn:face-ip-add", hicn_face_ip_add_cb,
                        session, 100, SR_SUBSCR_CTX_REUSE, subscription);
  if (rc != SR_ERR_OK) {
    SRP_LOG_DBGMSG("Problem in subscription stat-get\n");
    goto error;
  }

  rc = sr_rpc_subscribe(session, "/hicn:face-ip-del", hicn_face_ip_del_cb,
                        session, 100, SR_SUBSCR_CTX_REUSE, subscription);
  if (rc != SR_ERR_OK) {
    SRP_LOG_DBGMSG("Problem in subscription face-ip-del\n");
    goto error;
  }

  rc = sr_rpc_subscribe(session, "/hicn:route-nhops-add", hicn_route_add_cb,
                        session, 100, SR_SUBSCR_CTX_REUSE, subscription);
  if (rc != SR_ERR_OK) {
    SRP_LOG_DBGMSG("Problem in subscription route-nhops-add\n");
    goto error;
  }

  SRP_LOG_DBGMSG("hicn light initialized successfully.");
  return SR_ERR_OK;

error:
  SRP_LOG_ERRMSG("Error by initialization of the hicn plugin.");
  sr_plugin_cleanup_cb(session, hsocket);
  return rc;
}