mirror of
https://github.com/owntracks/recorder.git
synced 2026-04-07 00:26:49 +00:00
48 lines
1.0 KiB
C
48 lines
1.0 KiB
C
#include <stdio.h>
|
|
#include <stdlib.h>
|
|
#include "utstring.h"
|
|
#include "ctype.h"
|
|
#include "udata.h"
|
|
#include "misc.h"
|
|
#include "safewrite.h"
|
|
|
|
char *bindump(char *buf, long buflen)
|
|
{
|
|
static UT_string *out = NULL;
|
|
int i, ch;
|
|
|
|
utstring_renew(out);
|
|
|
|
for (i = 0; i < buflen; i++) {
|
|
ch = buf[i];
|
|
if (isprint(ch)) {
|
|
utstring_printf(out, "%c", ch);
|
|
} else {
|
|
utstring_printf(out, " %02X ", ch & 0xFF);
|
|
}
|
|
}
|
|
return (utstring_body(out));
|
|
}
|
|
|
|
/*
|
|
* At each received message, the recorder invokes this function with the
|
|
* current epoch time and the topic being handled. Use this to update
|
|
* a monitoring hoook. If we have Redis, use that exclusively.
|
|
*/
|
|
|
|
void monitorhook(struct udata *userdata, time_t now, char *topic)
|
|
{
|
|
// struct udata *ud = (struct udata *)userdata;
|
|
|
|
/* TODO: add monitor hook to a "monitor" key in LMDB ? */
|
|
|
|
char mpath[BUFSIZ];
|
|
static UT_string *us = NULL;
|
|
|
|
utstring_renew(us);
|
|
utstring_printf(us, "%ld %s\n", now, topic);
|
|
|
|
sprintf(mpath, "%s/monitor", STORAGEDIR);
|
|
safewrite(mpath, utstring_body(us));
|
|
}
|