1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
|
#include "cethcan.h"
struct value {
uint8_t val;
time_t change, valid;
};
struct light {
struct light *next;
struct can_user *u;
char *name;
unsigned logical_addr;
struct value set, actual;
};
static struct light *lights = NULL, **plights = &lights;
struct light *light_find(const char *name)
{
struct light *l;
for (l = lights; l; l = l->next)
if (!strcmp(l->name, name))
break;
return l;
}
int light_set(struct light *l, unsigned value)
{
struct can_message msg;
msg.daddr = CANA_LIGHT_F(0, l->logical_addr);
msg.dlc = 1;
msg.bytes[0] = value;
can_broadcast(l->u, &msg);
return 0;
}
unsigned light_getset(struct light *l)
{
return l->set.val;
}
unsigned light_getact(struct light *l)
{
return l->actual.val;
}
static void light_json_handler(void *arg, json_t *json, enum json_subtype type)
{
struct light *l = arg;
json_t *lobj = json_object();
json_object_set_new(lobj, "klass", json_string("light"));
json_object_set_new(lobj, "addr", json_integer(l->logical_addr));
json_object_set_new(lobj, "actual", json_integer(l->actual.val));
if (type != JSON_LONGPOLL)
json_object_set_new(lobj, "actual_ts", json_integer(l->actual.valid));
json_object_set_new(lobj, "actual_tschg", json_integer(l->actual.change));
json_object_set_new(lobj, "set", json_integer(l->set.val));
if (type != JSON_LONGPOLL)
json_object_set_new(lobj, "set_ts", json_integer(l->set.valid));
json_object_set_new(lobj, "set_tschg", json_integer(l->set.change));
json_object_set_new(json, l->name, lobj);
}
static void light_can_handler(void *arg, struct can_message *msg)
{
struct light *l = arg;
struct value *v = NULL;
unsigned laddr;
uint8_t dval;
if ((msg->daddr & CANA_PROTOCOL) == CANA_LIGHT)
v = &l->set;
if ((msg->daddr & CANA_PROTOCOL) == CANA_SENSOR)
v = &l->actual;
if (!v)
return;
laddr = msg->daddr & 0xfff;
if (l->logical_addr < laddr)
return;
if (l->logical_addr - laddr >= msg->dlc)
return;
dval = msg->bytes[l->logical_addr - laddr];
time(&v->valid);
if (dval != v->val || v->change == 0) {
v->val = dval;
time(&v->change);
lprintf("%s: set %02x", l->u->name, dval);
json_bump_longpoll();
}
}
int light_init_conf(json_t *config)
{
struct light *l;
if (!json_is_object(config)) {
lprintf("light config must be an object/dictionary");
return 1;
}
if (!json_is_integer(json_object_get(config, "addr"))) {
lprintf("light config must have an 'addr' key");
return 1;
}
if (!json_is_string(json_object_get(config, "name"))) {
lprintf("light config must have a 'name' key");
return 1;
}
l = calloc(sizeof(*l), 1);
l->name = strdup(json_string_value(json_object_get(config, "name")));
l->logical_addr = json_integer_value(json_object_get(config, "addr"));
l->u = can_register_alloc(l, light_can_handler, "light[%s]", l->name);
l->u->json = light_json_handler;
*plights = l;
plights = &l->next;
return 0;
}
|
