mirror/bbfdm
1
0
Fork 0
mirror of https://dev.iopsys.eu/bbf/bbfdm.git synced 2025-12-10 07:44:39 +01:00
Code Issues Projects Releases Packages Wiki Activity Actions

Add support for Device.IP.ActivePort.

Browse source
This commit is contained in:
Mohd Mehdi 2024-07-26 11:36:07 +00:00 • committed by IOPSYS Dev
parent c4de0336b7
commit 8ed9c7bb5f
No known key found for this signature in database
6 changed files with 214 additions and 232 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

182
libbbfdm/dmtree/tr181/activeport.c Normal file
View file

@ -0,0 +1,182 @@
/*
* Copyright (C) 2024 iopsys Software Solutions AB
*
* This program is free software; you can redistribute it and/or modify
* it under the terms of the GNU Lesser General Public License version 2.1
* as published by the Free Software Foundation
*
* Author: Mohd Husaam Mehdi <husaam.mehdi@genexis.eu>
*/
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <arpa/inet.h>
#include <netinet/in.h>
#include "activeport.h"
#define STATUS_SIZE 16
typedef struct {
char local_ip[INET6_ADDRSTRLEN];
uint16_t local_port;
char remote_ip[INET6_ADDRSTRLEN];
uint16_t remote_port;
unsigned int state;
} ActivePort;
/*************************************************************
* UTILITY METHODS
**************************************************************/
void format_ipv6_address(const char *hex_str_ip, char *ipv6_addr)
{
struct in6_addr addr = {};
sscanf(hex_str_ip, "%08X%08X%08X%08X",
&addr.s6_addr32[0], &addr.s6_addr32[1],
&addr.s6_addr32[2], &addr.s6_addr32[3]);
// Convert the address to the standard IPv6 format
inet_ntop(AF_INET6, &addr, ipv6_addr, INET6_ADDRSTRLEN);
}
void parse_tcp_line(const char* line, int is_ipv6, ActivePort* port)
{
unsigned int local_port, remote_port;
unsigned int state;
char local_ip[INET6_ADDRSTRLEN] = {0};
char remote_ip[INET6_ADDRSTRLEN] = {0};
if (is_ipv6) {
char local_ip6[33] = {0}, remote_ip6[33] = {0};
sscanf(line, "%*d: %32s:%4X %32s:%4X %2X", local_ip6, &local_port, remote_ip6, &remote_port, &state);
format_ipv6_address(local_ip6, local_ip);
format_ipv6_address(remote_ip6, remote_ip);
} else {
unsigned int local_ip_num, remote_ip_num;
sscanf(line, "%*d: %8X:%4X %8X:%4X %2X", &local_ip_num, &local_port, &remote_ip_num, &remote_port, &state);
struct in_addr local_addr = { local_ip_num };
struct in_addr remote_addr = { remote_ip_num };
inet_ntop(AF_INET, &local_addr, local_ip, INET_ADDRSTRLEN);
inet_ntop(AF_INET, &remote_addr, remote_ip, INET_ADDRSTRLEN);
}
DM_STRNCPY(port->local_ip, local_ip, INET6_ADDRSTRLEN);
port->local_port = local_port;
DM_STRNCPY(port->remote_ip, remote_ip, INET6_ADDRSTRLEN);
port->remote_port = remote_port;
port->state = state;
}
/*************************************************************
* ENTRY METHOD
**************************************************************/
static void browse_ip_port(struct dmctx *dmctx, DMNODE *parent_node, bool is_ipv6, const char *proc_path, int *id, char *inst)
{
if (proc_path == NULL || DM_STRLEN(proc_path) == 0)
return;
FILE* fp = fopen(proc_path, "r");
if (fp == NULL) {
return;
}
char line[256] = {0};
fgets(line, sizeof(line), fp); // Skip header line
while (fgets(line, sizeof(line), fp)) {
struct dm_data curr_data = {0};
ActivePort port;
memset(&port, 0, sizeof(port));
parse_tcp_line(line, is_ipv6, &port);
// only display LISTEN or ESTABLISHED
if (port.state != 1 && port.state != 10)
continue;
curr_data.additional_data = (void *)(&port);
inst = handle_instance_without_section(dmctx, parent_node, ++(*id));
if (DM_LINK_INST_OBJ(dmctx, parent_node, (void *)&curr_data, inst) == DM_STOP)
break;
}
fclose(fp);
}
int browseIPActivePortInst(struct dmctx *dmctx, DMNODE *parent_node, void *prev_data, char *prev_instance)
{
char *inst = NULL;
int id = 0;
browse_ip_port(dmctx, parent_node, 0, "/proc/net/tcp", &id, inst);
browse_ip_port(dmctx, parent_node, 1, "/proc/net/tcp6", &id, inst);
return 0;
}
/*************************************************************
* GET & SET PARAM
**************************************************************/
static int get_IP_ActivePort_LocalIPAddress(char *refparam, struct dmctx *ctx, void *data, char *instance, char **value)
{
*value = dmstrdup(((ActivePort *)((struct dm_data *)data)->additional_data)->local_ip);
return 0;
}
static int get_IP_ActivePort_LocalPort(char *refparam, struct dmctx *ctx, void *data, char *instance, char **value)
{
dmasprintf(value, "%u", ((ActivePort *)((struct dm_data *)data)->additional_data)->local_port);
return 0;
}
static int get_IP_ActivePort_RemoteIPAddress(char *refparam, struct dmctx *ctx, void *data, char *instance, char **value)
{
*value = dmstrdup(((ActivePort *)((struct dm_data *)data)->additional_data)->remote_ip);
return 0;
}
static int get_IP_ActivePort_RemotePort(char *refparam, struct dmctx *ctx, void *data, char *instance, char **value)
{
dmasprintf(value, "%u", ((ActivePort *)((struct dm_data *)data)->additional_data)->remote_port);
return 0;
}
static int get_IP_ActivePort_Status(char *refparam, struct dmctx *ctx, void *data, char *instance, char **value)
{
unsigned int state = (((ActivePort *)((struct dm_data *)data)->additional_data)->state);
switch (state) {
case 1:
*value = "ESTABLISHED";
break;
case 10:
*value = "LISTEN";
break;
default:
*value = "";
break;
}
return 0;
}
/**********************************************************************************************************************************
* OBJ & PARAM DEFINITION
***********************************************************************************************************************************/
/* *** Device.IP.ActivePort.{i}. *** */
DMLEAF tIPActivePortParams[] = {
/* PARAM, permission, type, getvalue, setvalue, bbfdm_type */
{"LocalIPAddress", &DMREAD, DMT_STRING, get_IP_ActivePort_LocalIPAddress, NULL, BBFDM_BOTH},
{"LocalPort", &DMREAD, DMT_UNINT, get_IP_ActivePort_LocalPort, NULL, BBFDM_BOTH},
{"RemoteIPAddress", &DMREAD, DMT_STRING, get_IP_ActivePort_RemoteIPAddress, NULL, BBFDM_BOTH},
{"RemotePort", &DMREAD, DMT_UNINT, get_IP_ActivePort_RemotePort, NULL, BBFDM_BOTH},
{"Status", &DMREAD, DMT_STRING, get_IP_ActivePort_Status, NULL, BBFDM_BOTH},
{0}
};

20
libbbfdm/dmtree/tr181/activeport.h Normal file
View file

@ -0,0 +1,20 @@
/*
* Copyright (C) 2024 iopsys Software Solutions AB
*
* This program is free software; you can redistribute it and/or modify
* it under the terms of the GNU Lesser General Public License version 2.1
* as published by the Free Software Foundation
*
* Author: Mohd Husaam Mehdi <husaam.mehdi@iopsys.eu>
*/
#ifndef __ACTIVE_PORT_H
#define __ACTIVE_PORT_H
#include "libbbfdm-api/dmcommon.h"
extern DMLEAF tIPActivePortParams[];
int browseIPActivePortInst(struct dmctx *dmctx, DMNODE *parent_node, void *prev_data, char *prev_instance);
#endif

10
libbbfdm/dmtree/tr181/ip.c
View file

@ -12,6 +12,7 @@
#include "dmlayer.h"
#include "ip.h"
#include "activeport.h"
/*************************************************************
* INIT
@ -1090,6 +1091,13 @@ static int get_IP_InterfaceNumberOfEntries(char *refparam, struct dmctx *ctx, vo
return 0;
}
static int get_IP_ActivePortNumberOfEntries(char *refparam, struct dmctx *ctx, void *data, char *instance, char **value)
{
int cnt = get_number_of_entries(ctx, data, instance, browseIPActivePortInst);
dmasprintf(value, "%d", cnt);
return 0;
}
/*#Device.IP.Interface.{i}.Enable!UCI:network/interface,@i-1/disabled*/
static int get_IPInterface_Enable(char *refparam, struct dmctx *ctx, void *data, char *instance, char **value)
{
@ -2196,6 +2204,7 @@ static int operate_IPInterface_Reset(char *refparam, struct dmctx *ctx, void *da
DMOBJ tIPObj[] = {
/* OBJ, permission, addobj, delobj, checkdep, browseinstobj, nextdynamicobj, dynamicleaf, nextobj, leaf, linker, bbfdm_type, uniqueKeys, version*/
{"Interface", &DMWRITE, addObjIPInterface, delObjIPInterface, NULL, browseIPInterfaceInst, NULL, NULL, tIPInterfaceObj, tIPInterfaceParams, NULL, BBFDM_BOTH, NULL},
{"ActivePort", &DMREAD, NULL, NULL, NULL, browseIPActivePortInst, NULL, NULL, NULL, tIPActivePortParams, NULL, BBFDM_BOTH, NULL},
{0}
};
@ -2209,6 +2218,7 @@ DMLEAF tIPParams[] = {
{"IPv6Status", &DMREAD, DMT_STRING, get_IP_IPv6Status, NULL, BBFDM_BOTH},
{"ULAPrefix", &DMWRITE, DMT_STRING, get_IP_ULAPrefix, set_IP_ULAPrefix, BBFDM_BOTH},
{"InterfaceNumberOfEntries", &DMREAD, DMT_UNINT, get_IP_InterfaceNumberOfEntries, NULL, BBFDM_BOTH},
{"ActivePortNumberOfEntries", &DMREAD, DMT_UNINT, get_IP_ActivePortNumberOfEntries, NULL, BBFDM_BOTH},
{0}
};

11
utilities/Makefile
View file

@ -1,8 +1,6 @@
CC ?= gcc
PROG = bbf_configd
OBJS = src/ubus/bbf_config.o src/ubus/utils.o
ACTIVE-PORT = active-port
ACTIVE-PORT_OBJS = src/ubus/active-port.o
PROG_CFLAGS = $(CFLAGS) -Wall -Werror
PROG_LDFLAGS = $(LDFLAGS)
@ -15,18 +13,13 @@ INSTALL_DIR = /usr/sbin
.PHONY: all clean install
all: $(PROG) $(ACTIVE-PORT)
all: $(PROG)
$(PROG): $(OBJS)
$(CC) $(PROG_LDFLAGS) -o $@ $^ $(PROG_LIBS)
$(ACTIVE-PORT): $(ACTIVE-PORT_OBJS)
$(CC) $(PROG_LDFLAGS) -o $@ $^ $(PROG_LIBS)
clean:
rm -f $(PROG)
rm -f $(ACTIVE-PORT)
install: $(PROG) $(ACTIVE-PORT)
install: $(PROG)
install -m 0755 $(PROG) $(INSTALL_DIR)
install -m 0755 $(ACTIVE-PORT) $(INSTALL_DIR)

32
utilities/README.md
View file

@ -78,35 +78,3 @@ Currently have two variants of bbf.config, which can be enabled with below compi
1. CONFIG_BBF_CONFIGMNGR_SCRIPT_BACKEND => Simple rpcd script based backend
2. CONFIG_BBF_CONFIGMNGR_C_BACKEND => C based application backend with PID monitoring (default)
## active-port
This directory has active-port utility which implements active-port ubus object. This object contains one function: dump, which dumps informat
ion of all active tcp ports.
```bash
root@sh31b-f04dd44304e0:~# ubus call active-port dump
{
"connections": [
{
"local_ip": "127.0.0.1",
"local_port": "5038",
"remote_ip": "0.0.0.0",
"remote_port": "*",
"status": "LISTEN"
},
{
"local_ip": "0.0.0.0",
"local_port": "8080",
"remote_ip": "0.0.0.0",
"remote_port": "*",
"status": "LISTEN"
},
...
]
}
```
## Usage
This ubus call is used by Device.IP.ActivePort datamodel object.

191
utilities/src/ubus/active-port.c
View file

@ -1,191 +0,0 @@
/*
* active_port.c: active-port daemon that provides active-port ubus object
* and a dump method which read from netstat output and
* returns local and remote IP and port and connections state.
* This is done for Device.IP.ActivePort object, whose json
* maps to this ubus call.
*
* Copyright (C) 2024 IOPSYS Software Solutions AB. All rights reserved.
*
* Author: Mohd Husaam Mehdi <husaam.mehdi@genexis.eu>
*
* See LICENSE file for license related information.
*/
#include <stdio.h>
#include <unistd.h>
#include <syslog.h>
#include <libubox/blobmsg.h>
#include <libubox/uloop.h>
#include <libubus.h>
#define MAX_LINE_LEN 256
static int parse_ip_port(char *str, char **ip, char **port)
{
char *colon = NULL;
// get the last colon in string
colon = strrchr(str, ':');
if (!colon) {
syslog(LOG_ERR, "active-port(%s,%u): ERROR (ip port not separated by ':')\n", __func__, __LINE__);
return 1;
}
*colon = '\0';
*ip = str;
*port = colon + 1;
return 0;
}
static const struct blobmsg_policy active_port_policy[] = {};
static int parse_line(char *line, struct blob_buf *b)
{
char *local_ip = NULL;
char *local_port = NULL;
char *remote_ip = NULL;
char *remote_port = NULL;
bool established = false;
char *token = NULL, *end = NULL;
// split the columns
token = strtok_r(line, " ", &end);
int i = 0;
while (token != NULL) {
switch (i) {
// first column
case 0:
if (parse_ip_port(token, &local_ip, &local_port) != 0)
return 1;
i++;
break;
// second column
case 1:
if (parse_ip_port(token, &remote_ip, &remote_port) != 0)
return 1;
i++;
break;
case 2:
// if established is found strncmp would be 0 and established would be 1
established = !strncmp(token, "ESTABLISHED", strlen("ESTABLISHED"));
i++;
break;
default:
syslog(LOG_ERR, "active-port(%s,%u): ERROR (extra column in netstat)\n", __func__, __LINE__);
return 1;
}
token = strtok_r(NULL, " ", &end);
}
if (!local_ip || !local_port || !remote_ip || !remote_port) {
syslog(LOG_ERR, "active-port(%s,%u): ERROR (missing data in netstat)\n", __func__, __LINE__);
return 1;
}
void *dd = NULL;
dd = blobmsg_open_table(b, "");
blobmsg_add_string(b, "local_ip", local_ip);
blobmsg_add_string(b, "local_port", local_port);
blobmsg_add_string(b, "remote_ip", remote_ip);
blobmsg_add_string(b, "remote_port", remote_port);
blobmsg_add_string(b, "status", established ? "ESTABLISHED" : "LISTEN");
blobmsg_close_table(b, dd);
return 0;
}
static int active_port_dump_handler(struct ubus_context *ctx, struct ubus_object *obj __attribute__((unused)),
struct ubus_request_data *req, const char *method __attribute__((unused)),
struct blob_attr *msg)
{
struct blob_buf b = {0};
memset(&b, 0, sizeof(struct blob_buf));
blob_buf_init(&b, 0);
FILE *pp = NULL;
char cmd[64] = {0};
// get the output of netstat (do not resolve ip addresses, get tcp connections, all kinds of states)
// skip the first two rows(headers) and print the 4th, 5th and 6th column separated by single space
snprintf(cmd, sizeof(cmd), "netstat -nta 2>/dev/null | awk \'NR>2 {print $4, $5, $6}\'");
pp = popen(cmd, "r");
if (pp != NULL) {
void *d = NULL;
d = blobmsg_open_array(&b, "connections");
char line[MAX_LINE_LEN] = {0};
while (fgets(line, MAX_LINE_LEN, pp) != NULL) {
// remove_new_line
line[strcspn(line, "\n")] = 0;
// stop parsing if there is a problem in one of the lines
if (parse_line(line, &b) != 0)
break;
}
pclose(pp);
blobmsg_close_array(&b, d);
} else {
blobmsg_add_string(&b, "error", "Could not run netstat");
goto end;
}
end:
ubus_send_reply(ctx, req, b.head);
blob_buf_free(&b);
return 0;
}
static const struct ubus_method active_port_methods[] = {
UBUS_METHOD("dump", active_port_dump_handler, active_port_policy),
};
static struct ubus_object_type active_port_object_type = UBUS_OBJECT_TYPE("active-port", active_port_methods);
static struct ubus_object active_port_object = {
.name = "active-port",
.type = &active_port_object_type,
.methods = active_port_methods,
.n_methods = ARRAY_SIZE(active_port_methods),
};
int main(int argc, char **argv)
{
struct ubus_context *uctx;
openlog("active-port", LOG_CONS | LOG_PID | LOG_NDELAY, LOG_LOCAL1);
uctx = ubus_connect(NULL);
if (uctx == NULL) {
printf("Can't create UBUS context");
return -1;
}
uloop_init();
ubus_add_uloop(uctx);
if (ubus_add_object(uctx, &active_port_object))
goto exit;
uloop_run();
exit:
uloop_done();
ubus_free(uctx);
closelog();
return 0;
}