metrics.c

#include "main-header.h"
#include "metrics/metrics.h"
 
static uint8_t mbuf[256];
 
typedef struct metric {
  uint32_t      integer;
  uint8_t       metric_number;
  uint8_t       number_type;
} _metric;
 
typedef struct metric_set {
  struct metric metrics[METRIC_COUNT];
} _metric_set;
 
#define SEND_FREQUENCY_SECS 120
static long int metric_send_counter;
 
static struct metric_set metricset;
 
void metric_init() {
  memset(&metricset, 0, sizeof(metricset));
  metric_send_counter = 0;
}
 
static struct metric *find_metric_entry(int mnum) {
  int i;
  struct metric *res = NULL;
 
  for (i = 0; i < METRIC_COUNT; i++) {
    struct metric *m = &metricset.metrics[i];
    if (m->metric_number == mnum) {
      return m;
    }
    if ((res == NULL) && (m->metric_number == 0)) {
      res = m;
    }
  }
  if (res != NULL) {
    res->metric_number = mnum;
    res->integer = 0;
  }
  return res;
}
void metric_set_by_number(int metric, uint32_t value) {
  struct metric *m = find_metric_entry(metric);
 
  if (m == NULL) {
    printf("No metric available\r\n");
    return;
  }
  m->integer = value;
}
 
void metric_inc_by_number(int metric) {
  struct metric *m = find_metric_entry(metric);
 
  if (m == NULL) {
    printf("No metric available\r\n");
    return;
  }
  m->integer++;
}
 
// send current metrics out to server
void metric_send() {
  int i;
  struct command *com = alloc_command();
 
  if (com == NULL) {
    return;
  }
  command_init(com);
  com->target = CLOUD_SERVER;
  com->com = 56; // metric
  com->flags = COMFLAGS_DATA | COMFLAGS_SUCCESS;
  struct shifter shstruct;
  struct shifter *sh = &shstruct;
 
  shifter_init(sh, (uint8_t *)&mbuf, sizeof(mbuf));
 
  shift_into_uint8(sh, 1); // segment start indicator that what follows is a number array
  for (i = 0; i < METRIC_COUNT; i++) {
    struct metric *m = &metricset.metrics[i];
    if (m->metric_number == 0) {
      continue;
    }
    shift_into_uint8(sh, m->metric_number);
    shift_into_uint8(sh, m->number_type);
    shift_into_uint32(sh, m->integer);
  }
  shift_into_uint8(sh, 0); // end segment
  if (shift_error(sh) != 0) {
    printf("[metric] Shifter error: %i\r\n", shift_error(sh));
    free_command(com);
    return;
  }
  printf("[metric] sending %i bytes\r\n", sh->validbytes);
  command_add_binary_arg(com, sh->validbytes, mbuf);
  send_command(com);
  free_command(com);
}
void metric_loop() {
  if (mculib_has_time_passed(SEND_FREQUENCY_SECS, &metric_send_counter)) {
    metric_send();
  }
}