Module: PostfixStatusLine::Core

Defined in:

ext/postfix_status_line_core.c

Class Method Summary

• .parse(v_str, v_mask, v_hash, v_salt, v_parse_time, v_sha_algo) ⇒ Object

Class Method Details

.parse(v_str, v_mask, v_hash, v_salt, v_parse_time, v_sha_algo) ⇒ Object

# File 'ext/postfix_status_line_core.c', line 318

static VALUE rb_postfix_status_line_parse(VALUE self, VALUE v_str, VALUE v_mask, VALUE v_hash, VALUE v_salt, VALUE v_parse_time, VALUE v_sha_algo) {
  Check_Type(v_str, T_STRING);

  char *str = RSTRING_PTR(v_str);
  size_t len = RSTRING_LEN(v_str);

  if (len < 1) {
    return Qnil;
  }

  bool mask = rb_value_to_bool(v_mask);
  bool parse_time = rb_value_to_bool(v_parse_time);

  bool include_hash = false;
  char *salt = NULL;
  size_t salt_len = -1;

  if (rb_value_to_bool(v_hash)) {
#ifdef HAVE_OPENSSL_SHA_H
    include_hash = true;

    if (!NIL_P(v_salt)) {
      Check_Type(v_salt, T_STRING);
      salt = RSTRING_PTR(v_salt);
      salt_len = RSTRING_LEN(v_salt);
    }
#else
    rb_raise(rb_eArgError, "OpenSSL is not linked");
#endif // HAVE_OPENSSL_SHA_H
  }

  int sha_algo = 512;

  if (!NIL_P(v_sha_algo)) {
#ifdef HAVE_OPENSSL_SHA_H
    sha_algo = NUM2INT(v_sha_algo);
#else
    rb_raise(rb_eArgError, "OpenSSL is not linked");
#endif // HAVE_OPENSSL_SHA_H
  }

  DIGEST_SHA digest_sha_func = NULL;

#ifdef HAVE_OPENSSL_SHA_H
  switch (sha_algo) {
    case 1:
      digest_sha_func = digest_sha;
      break;
    case 224:
      digest_sha_func = digest_sha224;
      break;
    case 256:
      digest_sha_func = digest_sha256;
      break;
    case 384:
      digest_sha_func = digest_sha384;
      break;
    case 512:
      digest_sha_func = digest_sha512;
      break;
    default:
      rb_raise(rb_eArgError, "Invalid SHA algorithm");
  }
#endif // HAVE_OPENSSL_SHA_H

  char buf[len + 1];
  strncpy(buf, str, len);
  buf[len] = '\0';

  char *tm, *hostname, *process, *queue_id, *attrs;

  if (!split_line1(buf, &tm, &hostname, &process, &queue_id, &attrs)) {
    return Qnil;
  }

  VALUE hash = rb_hash_new();
  rb_hash_aset(hash, rb_str_new2("time"), rb_str_new2(tm));
  rb_hash_aset(hash, rb_str_new2("hostname"), rb_str_new2(hostname));
  rb_hash_aset(hash, rb_str_new2("process"), rb_str_new2(process));
  rb_hash_aset(hash, rb_str_new2("queue_id"), rb_str_new2(queue_id));

  if (parse_time) {
    put_epoch(tm, hash);
  }

  split_line2(attrs, mask, hash, include_hash, salt, salt_len, digest_sha_func);

  return hash;
}