xmppipe/src/xmppipe_send.c

/* Copyright (c) 2019-2023, Michael Santos <michael.santos@gmail.com>
 *
 * Permission to use, copy, modify, and/or distribute this software for any
 * purpose with or without fee is hereby granted, provided that the above
 * copyright notice and this permission notice appear in all copies.
 *
 * THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
 * WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
 * MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
 * ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
 * WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
 * ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
 * OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
 */
#include "xmppipe.h"

static void xmppipe_send_stanza_fmt(xmppipe_state_t *state, const char *buf,
                                    size_t len);

static void xmppipe_send_message(xmppipe_state_t *state, const char *to,
                                 const char *type, const char *buf, size_t len);

static void xmppipe_send_oob(xmppipe_state_t *state, const char *to,
                             const char *type, const char *buf, size_t len);

static void xmppipe_send_http_upload(xmppipe_state_t *state, const char *to,
                                     const char *type, char *buf, size_t len);

void xmppipe_send_stanza(xmppipe_state_t *state, const char *buf, size_t len) {
  switch (state->format) {
  case XMPPIPE_FMT_TEXT:
    xmppipe_send_message(
        state, state->out,
        (state->opt & XMPPIPE_OPT_GROUPCHAT) ? "groupchat" : "chat", buf, len);
    return;

  case XMPPIPE_FMT_CSV:
    xmppipe_send_stanza_fmt(state, buf, len);
    break;

  default:
    if (state->verbose)
      (void)fprintf(stderr, "unsupported format: %d\n", state->format);

    return;
  }
}

static void xmppipe_send_stanza_fmt(xmppipe_state_t *state, const char *buf,
                                    size_t len) {
  char *to = NULL;
  char *type = NULL;
  char *default_type;

  int i;
  size_t n;
  char *tmp;
  char *start;
  char *end;
  char *body = NULL;
  int valid = 0;
  char format = 'm';

  default_type = (state->opt & XMPPIPE_OPT_GROUPCHAT) ? "groupchat" : "chat";

  tmp = xmppipe_strdup(buf);
  start = tmp;

  /* trailing newline */
  end = strchr(start, '\n');
  if (end != NULL)
    *end = '\0';

  for (i = 0; start != NULL; i++) {
    end = strchr(start, ':');
    if (end != NULL)
      *end++ = '\0';

    n = strlen(start);

    if (state->verbose)
      (void)fprintf(stderr, "message:%d:%s\n", i, n == 0 ? "<empty>" : start);

    switch (i) {
    case 0:
      if (n != 1) {
        if (state->verbose)
          (void)fprintf(stderr, "stanza required\n");

        goto XMPPIPE_DONE;
      }

      format = start[0];

      switch (start[0]) {
      case 'm': /* message */
      case 'I': /* message: iniline image using oob stanza */
      case 'u': /* iq: http upload slot */
        break;
      case 'p':
      /* unsupported: fall through */
      default:
        if (state->verbose)
          (void)fprintf(stderr, "unsupported stanza: %c\n", start[0]);

        goto XMPPIPE_DONE;
      }
      break;

    case 1:
      type = xmppipe_fmt_decode((n == 0) ? default_type : start);
      if (type == NULL)
        goto XMPPIPE_DONE;
      break;

    case 2:
      to = xmppipe_fmt_decode((n == 0) ? state->out : start);
      if (to == NULL)
        goto XMPPIPE_DONE;

      break;

    case 3:
      break;

    case 4:
      body = xmppipe_fmt_decode(start);
      if (body == NULL)
        goto XMPPIPE_DONE;

      valid = 1;
      break;

    default:
      goto XMPPIPE_DONE;
    }

    start = end;
  }

XMPPIPE_DONE:
  if (valid == 1) {
    switch (format) {
    case 'I':
      xmppipe_send_oob(state, to, type, body, strlen(body));
      break;
    case 'u':
      xmppipe_send_http_upload(state, to, type, body, strlen(body));
      break;
    case 'm':
    default:
      xmppipe_send_message(state, to, type, body, strlen(body));
      break;
    }
  } else if (state->verbose) {
    (void)fprintf(stderr, "invalid input\n");
  }

  free(tmp);
  free(type);
  free(to);
  free(body);
}

static void xmppipe_send_message(xmppipe_state_t *state, const char *to,
                                 const char *type, const char *buf,
                                 size_t len) {
  xmpp_stanza_t *message;
  char *id;

  id = xmppipe_uuid_gen(state->ctx);

  message = xmppipe_message_new(state->ctx, type, to, id);

  if (state->encode) {
    char *b64 = xmpp_base64_encode(state->ctx, (const unsigned char *)buf, len);

    if (b64 == NULL)
      errx(EXIT_FAILURE, "encode: invalid input: %zu", len);

    xmppipe_message_set_body(message, b64);
    xmpp_free(state->ctx, b64);
  } else {
    xmppipe_message_set_body(message, buf);
  }

  xmppipe_send(state, message);
  xmpp_free(state->ctx, id);
}

static void xmppipe_send_oob(xmppipe_state_t *state, const char *to,
                             const char *type, const char *buf, size_t len) {
  xmpp_stanza_t *message;
  xmpp_stanza_t *x;
  xmpp_stanza_t *url;
  xmpp_stanza_t *text;
  char *id;

  id = xmppipe_uuid_gen(state->ctx);

  message = xmppipe_message_new(state->ctx, type, to, id);

  x = xmppipe_stanza_new(state->ctx);
  xmppipe_stanza_set_name(x, "x");
  xmppipe_stanza_set_ns(x, "jabber:x:oob");

  url = xmppipe_stanza_new(state->ctx);
  xmppipe_stanza_set_name(url, "url");

  text = xmppipe_stanza_new(state->ctx);
  xmppipe_stanza_set_text(text, buf);
  xmppipe_stanza_add_child(url, text);
  (void)xmpp_stanza_release(text);

  xmppipe_stanza_add_child(x, url);
  (void)xmpp_stanza_release(url);

  xmppipe_stanza_add_child(message, x);
  (void)xmpp_stanza_release(x);

  xmppipe_message_set_body(message, buf);

  xmppipe_send(state, message);
  xmpp_free(state->ctx, id);
}

static void xmppipe_send_http_upload(xmppipe_state_t *state, const char *to,
                                     const char *type, char *buf, size_t len) {
  xmpp_stanza_t *iq;
  xmpp_stanza_t *request;
  char *id;
  char *filename = NULL;
  char *size = NULL;
  char *content_type = NULL;

  int i;
  char *start;
  char *end;

  if (state->upload == NULL) {
    if (state->verbose)
      (void)fprintf(stderr, "error: XEP 0363 http upload is not supported\n");
    return;
  }

  id = xmppipe_uuid_gen(state->ctx);

  start = buf;

  /* <filename>|<size>|<content-type> */
  for (i = 0; start != NULL; i++) {
    end = strchr(start, '|');
    if (end != NULL)
      *end++ = '\0';

    switch (i) {
    case 0: /* filename */
      filename = start;
      break;
    case 1: /* size */
      size = start;
      break;
    case 2: /* content-type */
      content_type = start;
      break;
    default:
      /* invalid */
      break;
    }

    start = end;
  }

  if (filename == NULL || size == NULL) {
    if (state->verbose)
      (void)fprintf(stderr, "error: invalid http upload request\n");
    return;
  }

  iq = xmppipe_stanza_new(state->ctx);
  xmppipe_stanza_set_name(iq, "iq");
  xmppipe_stanza_set_attribute(iq, "id", id);
  xmppipe_stanza_set_attribute(iq, "type", "get");
  xmppipe_stanza_set_attribute(iq, "to", state->upload);

  request = xmppipe_stanza_new(state->ctx);
  xmppipe_stanza_set_name(request, "request");
  xmppipe_stanza_set_ns(request, "urn:xmpp:http:upload:0");
  xmppipe_stanza_set_attribute(request, "filename", filename);
  xmppipe_stanza_set_attribute(request, "size", size);

  if (content_type)
    xmppipe_stanza_set_attribute(request, "content-type", content_type);

  xmppipe_stanza_add_child(iq, request);
  (void)xmpp_stanza_release(request);

  xmppipe_send(state, iq);

  (void)xmpp_stanza_release(iq);
  xmpp_free(state->ctx, id);
}

void xmppipe_send(xmppipe_state_t *state, xmpp_stanza_t *const stanza) {
  xmpp_stanza_t *r;

  state->sm_request++;

  xmpp_send(state->conn, stanza);

  if (state->sm_enabled == 0)
    return;

  if (state->sm_request % state->sm_request_interval != 0)
    return;

  r = xmppipe_stanza_new(state->ctx);
  xmppipe_stanza_set_name(r, "r");
  xmppipe_stanza_set_ns(r, "urn:xmpp:sm:3");
  xmpp_send(state->conn, r);
  state->sm_request_unack++;

  (void)xmpp_stanza_release(r);
}