mirror of
git://git.psyc.eu/libpsyc
synced 2024-08-15 03:19:02 +00:00
363 lines
8.9 KiB
C
363 lines
8.9 KiB
C
#include <ctype.h>
|
|
#include <stdio.h>
|
|
#include <stdlib.h>
|
|
#include <stdint.h>
|
|
#include <assert.h>
|
|
#include <unistd.h>
|
|
#include <getopt.h>
|
|
#include <sys/socket.h>
|
|
|
|
#include <psyc.h>
|
|
#include <psyc/parse.h>
|
|
#include <psyc/render.h>
|
|
#include <psyc/syntax.h>
|
|
|
|
#include "test.c"
|
|
|
|
// max size for routing & entity header
|
|
#define ROUTING_LINES 16
|
|
#define ENTITY_LINES 32
|
|
|
|
// cmd line args
|
|
char *filename, *port = "4440";
|
|
uint8_t verbose, stats;
|
|
uint8_t multiple, single, routing_only, no_render, quiet, progress;
|
|
size_t count = 1, recv_buf_size;
|
|
|
|
PsycParseState parsers[NUM_PARSERS];
|
|
PsycPacket packets[NUM_PARSERS];
|
|
PsycModifier routing[NUM_PARSERS][ROUTING_LINES];
|
|
PsycModifier entity[NUM_PARSERS][ENTITY_LINES];
|
|
|
|
int contbytes, exit_code;
|
|
|
|
static inline void
|
|
resetString (PsycString *s, uint8_t freeptr);
|
|
|
|
// initialize parser & packet variables
|
|
void
|
|
test_init (int i)
|
|
{
|
|
// reset parser state & packet
|
|
psyc_parse_state_init(&parsers[i],
|
|
routing_only ? PSYC_PARSE_ROUTING_ONLY : PSYC_PARSE_ALL);
|
|
|
|
memset(&packets[i], 0, sizeof(PsycPacket));
|
|
memset(&routing[i], 0, sizeof(PsycModifier) * ROUTING_LINES);
|
|
memset(&entity[i], 0, sizeof(PsycModifier) * ENTITY_LINES);
|
|
packets[i].routing.modifiers = routing[i];
|
|
packets[i].entity.modifiers = entity[i];
|
|
}
|
|
|
|
// parse & render input
|
|
int
|
|
test_input (int i, char *recvbuf, size_t nbytes)
|
|
{
|
|
int j, ret, retl, r;
|
|
char sendbuf[SEND_BUF_SIZE];
|
|
char *parsebuf = recvbuf - contbytes;
|
|
/* We have a buffer with pointers pointing to various parts of it:
|
|
* *contbuf-vv
|
|
* buffer: [ ccrrrr]
|
|
* *recvbuf---^^^^
|
|
* *parsebuf-^^^^^^
|
|
*
|
|
* New data is in recvbuf, if it contains an incomplete packet then remaining
|
|
* unparsed data is copied to contbuf that will be parsed during the next call
|
|
* to this function together with the new data.
|
|
*/
|
|
|
|
PsycParseState *parser = &parsers[i];
|
|
PsycPacket *packet = &packets[i];
|
|
|
|
char oper;
|
|
PsycString name, value, elem;
|
|
PsycString *pname = NULL, *pvalue = NULL;
|
|
PsycModifier *mod = NULL;
|
|
PsycParseListState listState;
|
|
size_t len;
|
|
|
|
// Set buffer with data for the parser.
|
|
psyc_parse_buffer_set(parser, parsebuf, contbytes + nbytes);
|
|
contbytes = 0;
|
|
oper = 0;
|
|
name.length = 0;
|
|
value.length = 0;
|
|
|
|
do {
|
|
if (verbose >= 3)
|
|
printf("\n# buffer = [%.*s]\n# part = %d\n",
|
|
(int)parser->buffer.length, parser->buffer.data, parser->part);
|
|
// Parse the next part of the packet (a routing/entity modifier or the body)
|
|
ret = exit_code = psyc_parse(parser, &oper, &name, &value);
|
|
if (verbose >= 2)
|
|
printf("# ret = %d\n", ret);
|
|
|
|
switch (ret) {
|
|
case PSYC_PARSE_ROUTING:
|
|
assert(packet->routing.lines < ROUTING_LINES);
|
|
mod = &(packet->routing.modifiers[packet->routing.lines]);
|
|
pname = &mod->name;
|
|
pvalue = &mod->value;
|
|
mod->flag = PSYC_MODIFIER_ROUTING;
|
|
packet->routing.lines++;
|
|
break;
|
|
|
|
case PSYC_PARSE_STATE_RESYNC:
|
|
case PSYC_PARSE_STATE_RESET:
|
|
packet->stateop = oper;
|
|
break;
|
|
|
|
case PSYC_PARSE_ENTITY_START:
|
|
case PSYC_PARSE_ENTITY_CONT:
|
|
case PSYC_PARSE_ENTITY_END:
|
|
case PSYC_PARSE_ENTITY:
|
|
assert(packet->entity.lines < ENTITY_LINES);
|
|
mod = &(packet->entity.modifiers[packet->entity.lines]);
|
|
pname = &mod->name;
|
|
pvalue = &mod->value;
|
|
|
|
if (ret == PSYC_PARSE_ENTITY || ret == PSYC_PARSE_ENTITY_END) {
|
|
packet->entity.lines++;
|
|
mod->flag = psyc_parse_value_length_found(parser) ?
|
|
PSYC_MODIFIER_NEED_LENGTH : PSYC_MODIFIER_NO_LENGTH;
|
|
}
|
|
break;
|
|
|
|
case PSYC_PARSE_BODY_START:
|
|
case PSYC_PARSE_BODY_CONT:
|
|
case PSYC_PARSE_BODY_END:
|
|
case PSYC_PARSE_BODY:
|
|
pname = &(packet->method);
|
|
pvalue = &(packet->data);
|
|
break;
|
|
|
|
case PSYC_PARSE_COMPLETE:
|
|
if (verbose)
|
|
printf("# Done parsing.\n");
|
|
else if (progress)
|
|
r = write(1, ".", 1);
|
|
if ((filename && !multiple) || (!filename && single))
|
|
ret = -1;
|
|
|
|
if (!no_render) {
|
|
packet->flag = psyc_parse_content_length_found(parser) ?
|
|
PSYC_PACKET_NEED_LENGTH : PSYC_PACKET_NO_LENGTH;
|
|
|
|
if (routing_only) {
|
|
packet->content = packet->data;
|
|
resetString(&(packet->data), 0);
|
|
}
|
|
|
|
psyc_packet_length_set(packet);
|
|
|
|
if (PSYC_RENDER_SUCCESS == psyc_render(packet, sendbuf,
|
|
SEND_BUF_SIZE)) {
|
|
if (!quiet) {
|
|
if (filename && write(1, sendbuf, packet->length) == -1) {
|
|
perror("write");
|
|
ret = -1;
|
|
} else if (!filename && -1 == send(i, sendbuf,
|
|
packet->length, 0)) {
|
|
perror("send");
|
|
ret = -1;
|
|
}
|
|
}
|
|
} else {
|
|
printf("# Render error");
|
|
ret = -1;
|
|
}
|
|
}
|
|
|
|
// reset packet
|
|
packet->routingLength = 0;
|
|
packet->contentLength = 0;
|
|
packet->length = 0;
|
|
packet->flag = 0;
|
|
|
|
for (j = 0; j < packet->routing.lines; j++) {
|
|
resetString(&(packet->routing.modifiers[j].name), 1);
|
|
resetString(&(packet->routing.modifiers[j].value), 1);
|
|
}
|
|
packet->routing.lines = 0;
|
|
|
|
if (routing_only) {
|
|
resetString(&(packet->content), 1);
|
|
} else {
|
|
for (j = 0; j < packet->entity.lines; j++) {
|
|
resetString(&(packet->entity.modifiers[j].name), 1);
|
|
resetString(&(packet->entity.modifiers[j].value), 1);
|
|
}
|
|
packet->entity.lines = 0;
|
|
|
|
resetString(&(packet->method), 1);
|
|
resetString(&(packet->data), 1);
|
|
}
|
|
|
|
break;
|
|
|
|
case PSYC_PARSE_INSUFFICIENT:
|
|
if (verbose >= 2)
|
|
printf("# Insufficient data.\n");
|
|
|
|
contbytes = psyc_parse_remaining_length(parser);
|
|
|
|
if (contbytes > 0) { // copy end of parsebuf before start of recvbuf
|
|
if (verbose >= 3)
|
|
printf("# remaining = [%.*s]\n",
|
|
(int)contbytes, psyc_parse_remaining_buffer(parser));
|
|
assert(contbytes <= CONT_BUF_SIZE); // make sure it fits in the buffer
|
|
memmove(recvbuf - contbytes,
|
|
psyc_parse_remaining_buffer(parser), contbytes);
|
|
}
|
|
ret = 0;
|
|
break;
|
|
|
|
default:
|
|
printf("# Error while parsing: %i\n", ret);
|
|
ret = -1;
|
|
}
|
|
|
|
switch (ret) {
|
|
case PSYC_PARSE_ENTITY_START:
|
|
case PSYC_PARSE_ENTITY_CONT:
|
|
case PSYC_PARSE_BODY_START:
|
|
case PSYC_PARSE_BODY_CONT:
|
|
ret = 0;
|
|
case PSYC_PARSE_ENTITY:
|
|
case PSYC_PARSE_ENTITY_END:
|
|
case PSYC_PARSE_ROUTING:
|
|
case PSYC_PARSE_BODY:
|
|
case PSYC_PARSE_BODY_END:
|
|
if (oper) {
|
|
mod->oper = oper;
|
|
if (verbose >= 2)
|
|
printf("%c", oper);
|
|
}
|
|
|
|
if (name.length) {
|
|
pname->data = malloc(name.length);
|
|
pname->length = name.length;
|
|
|
|
assert(pname->data != NULL);
|
|
memcpy((void*)pname->data, name.data, name.length);
|
|
name.length = 0;
|
|
|
|
if (verbose >= 2)
|
|
printf("%.*s = ", (int)pname->length, pname->data);
|
|
}
|
|
|
|
if (value.length) {
|
|
if (!pvalue->length) {
|
|
if (psyc_parse_value_length_found(parser))
|
|
len = psyc_parse_value_length(parser);
|
|
else
|
|
len = value.length;
|
|
pvalue->data = malloc(len);
|
|
}
|
|
assert(pvalue->data != NULL);
|
|
memcpy((void*)pvalue->data + pvalue->length, value.data, value.length);
|
|
pvalue->length += value.length;
|
|
value.length = 0;
|
|
|
|
if (verbose >= 2) {
|
|
printf("[%.*s]", (int)pvalue->length, pvalue->data);
|
|
if (parser->valueLength > pvalue->length)
|
|
printf("...");
|
|
printf("\n");
|
|
}
|
|
}
|
|
else if (verbose)
|
|
printf("\n");
|
|
|
|
if (verbose >= 3)
|
|
printf("\t\t\t\t\t\t\t\t# n:%ld v:%ld c:%ld r:%ld\n",
|
|
pname->length, pvalue->length,
|
|
parser->contentParsed, parser->routingLength);
|
|
}
|
|
|
|
switch (ret) {
|
|
case PSYC_PARSE_ROUTING:
|
|
case PSYC_PARSE_ENTITY:
|
|
case PSYC_PARSE_ENTITY_END:
|
|
oper = 0;
|
|
name.length = 0;
|
|
value.length = 0;
|
|
|
|
if (psyc_var_is_list(PSYC_S2ARG(*pname))) {
|
|
if (verbose >= 2)
|
|
printf("## LIST START\n");
|
|
|
|
psyc_parse_list_state_init(&listState);
|
|
psyc_parse_list_buffer_set(&listState, PSYC_S2ARG(*pvalue));
|
|
|
|
do {
|
|
retl = psyc_parse_list(&listState, &elem);
|
|
switch (retl) {
|
|
case PSYC_PARSE_LIST_END:
|
|
retl = 0;
|
|
case PSYC_PARSE_LIST_ELEM:
|
|
if (verbose >= 2) {
|
|
printf("|%.*s\n", (int)elem.length, elem.data);
|
|
if (ret == PSYC_PARSE_LIST_END)
|
|
printf("## LIST END");
|
|
}
|
|
break;
|
|
|
|
default:
|
|
printf("# Error while parsing list: %i\n", retl);
|
|
ret = retl = -1;
|
|
}
|
|
}
|
|
while (retl > 0);
|
|
}
|
|
}
|
|
}
|
|
while (ret > 0);
|
|
|
|
if (progress)
|
|
r = write(1, " ", 1);
|
|
|
|
return ret;
|
|
}
|
|
|
|
static inline void
|
|
resetString (PsycString *s, uint8_t freeptr)
|
|
{
|
|
if (freeptr && s->length)
|
|
free((void*)s->data);
|
|
|
|
s->data = NULL;
|
|
s->length = 0;
|
|
}
|
|
|
|
int
|
|
main (int argc, char **argv)
|
|
{
|
|
int c;
|
|
while ((c = getopt (argc, argv, "f:p:b:c:mnqrsvPSh")) != -1) {
|
|
switch (c) {
|
|
CASE_f CASE_p CASE_b CASE_c
|
|
CASE_m CASE_n CASE_q CASE_r
|
|
CASE_s CASE_v CASE_S CASE_P
|
|
case 'h':
|
|
printf(HELP_FILE("test_psyc", "mnqrSsvP")
|
|
HELP_PORT("test_psyc", "nqrsvP")
|
|
HELP_f HELP_p HELP_b HELP_c
|
|
HELP_m HELP_n HELP_r
|
|
HELP_q HELP_S HELP_s
|
|
HELP_v HELP_P HELP_h,
|
|
port, RECV_BUF_SIZE);
|
|
exit(0);
|
|
case '?': exit(-1);
|
|
default: abort();
|
|
}
|
|
}
|
|
|
|
if (filename)
|
|
test_file(filename, count, recv_buf_size);
|
|
else
|
|
test_server(port, count, recv_buf_size);
|
|
|
|
return exit_code;
|
|
}
|