/*

Copyright (c) 2013-2018. The YARA Authors. All Rights Reserved.

Redistribution and use in source and binary forms, with or without modification,

are permitted provided that the following conditions are met:

1. Redistributions of source code must retain the above copyright notice, this

list of conditions and the following disclaimer.

2. Redistributions in binary form must reproduce the above copyright notice,

this list of conditions and the following disclaimer in the documentation and/or

other materials provided with the distribution.

3. Neither the name of the copyright holder nor the names of its contributors

may be used to endorse or promote products derived from this software without

specific prior written permission.

THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND

ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED

WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE

DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE LIABLE FOR

ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES

(INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;

LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON

ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT

(INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS

SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.

*/

#include <assert.h>

#include <fcntl.h>

#include <stddef.h>

#include <stdio.h>

#include <string.h>

#include <sys/stat.h>

#ifdef _MSC_VER

#include <io.h>

#include <share.h>

#else

#include <unistd.h>

#endif

#include <yara/compiler.h>

#include <yara/error.h>

#include <yara/exec.h>

#include <yara/lexer.h>

#include <yara/libyara.h>

#include <yara/mem.h>

#include <yara/object.h>

#include <yara/strutils.h>

#include <yara/utils.h>

static void _yr_compiler_default_include_free(

    const char* callback_result_ptr,

    void* user_data)

{

  if (callback_result_ptr != NULL)

  {

    yr_free((void*) callback_result_ptr);

  }

}

const char* _yr_compiler_default_include_callback(

    const char* include_name,

    const char* calling_rule_filename,

    const char* calling_rule_namespace,

    void* user_data)

{

#ifndef _MSC_VER

  struct stat stbuf;

#endif

  char* file_buffer;

#ifdef _MSC_VER

  long file_size;

#else

  off_t file_size;

#endif

  int fd = -1;

#if defined(_MSC_VER)

  _sopen_s(&fd, include_name, _O_RDONLY | _O_BINARY, _SH_DENYWR, _S_IREAD);

#elif defined(_WIN32) || defined(__CYGWIN__)

  fd = open(include_name, O_RDONLY | O_BINARY);

#else

  fd = open(include_name, O_RDONLY);

#endif

  if (fd == -1)

    return NULL;

#ifdef _MSC_VER

  file_size = _filelength(fd);

  if (file_size == -1)

  {

    _close(fd);

    return NULL;

  }

#else

  if ((fstat(fd, &stbuf) != 0) || (!S_ISREG(stbuf.st_mode)))

  {

    close(fd);

    return NULL;

  }

  file_size = stbuf.st_size;

#endif

  file_buffer = (char*) yr_malloc((size_t) file_size + 1);

  if (file_buffer == NULL)

  {

#ifdef _MSC_VER

    _close(fd);

#else

    close(fd);

#endif

    return NULL;

  }

  if (file_size != read(fd, file_buffer, (size_t) file_size))

  {

    yr_free(file_buffer);

#ifdef _MSC_VER

    _close(fd);

#else

    close(fd);

#endif

    return NULL;

  }

  else

  {

    file_buffer[file_size] = '\0';

  }

#ifdef _MSC_VER

  _close(fd);

#else

  close(fd);

#endif

  return file_buffer;

}

////////////////////////////////////////////////////////////////////////////////

// Returns a rule given its index in the rules table.

//

// The returned pointer is valid as long as no other rule is written to the

// table. This is because the write operation may cause the table to be moved to

// a different location in memory. Use the pointer only in a limited scope where

// you can be sure that no other rule is being written during the pointer's

// lifetime.

//

YR_RULE* _yr_compiler_get_rule_by_idx(YR_COMPILER* compiler, uint32_t rule_idx)

{

  return (YR_RULE*) yr_arena_get_ptr(

      compiler->arena, YR_RULES_TABLE, rule_idx * sizeof(YR_RULE));

}

////////////////////////////////////////////////////////////////////////////////

// Stores some data in the YR_SZ_POOL and returns a reference to it.

//

// If the same data was already stored in a previous call to this function the

// data is not written again, a reference to the existing data is returned

// instead.

//

int _yr_compiler_store_data(

    YR_COMPILER* compiler,

    const void* data,

    size_t data_length,

    YR_ARENA_REF* ref)

{

  // Check if the data is already in YR_SZ_POOL by using a hash table.

  uint32_t offset = yr_hash_table_lookup_uint32_raw_key(

      compiler->sz_table, data, data_length, NULL);

  if (offset == UINT32_MAX)

  {

    // The data was not previously written to YR_SZ_POOL, write it and store

    // the reference's offset in the hash table. Storing the buffer number

    // is not necessary, it's always YR_SZ_POOL.

    FAIL_ON_ERROR(yr_arena_write_data(

        compiler->arena, YR_SZ_POOL, data, data_length, ref));

    FAIL_ON_ERROR(yr_hash_table_add_uint32_raw_key(

        compiler->sz_table, data, data_length, NULL, ref->offset));

  }

  else

  {

    ref->buffer_id = YR_SZ_POOL;

    ref->offset = offset;

  }

  return ERROR_SUCCESS;

}

////////////////////////////////////////////////////////////////////////////////

// Similar to _yr_compiler_store_data, but receives a null-terminated string.

//

int _yr_compiler_store_string(

    YR_COMPILER* compiler,

    const char* string,

    YR_ARENA_REF* ref)

{

  return _yr_compiler_store_data(

      compiler,

      (void*) string,

      strlen(string) + 1,  // include the null terminator

      ref);

}

YR_API int yr_compiler_create(YR_COMPILER** compiler)

{

  int result;

  YR_COMPILER* new_compiler;

  new_compiler = (YR_COMPILER*) yr_calloc(1, sizeof(YR_COMPILER));

  if (new_compiler == NULL)

    return ERROR_INSUFFICIENT_MEMORY;

  new_compiler->current_rule_idx = UINT32_MAX;

  new_compiler->next_rule_idx = 0;

  new_compiler->current_string_idx = 0;

  new_compiler->current_namespace_idx = 0;

  new_compiler->current_meta_idx = 0;

  new_compiler->num_namespaces = 0;

  new_compiler->errors = 0;

  new_compiler->callback = NULL;

  new_compiler->rules = NULL;

  new_compiler->include_callback = _yr_compiler_default_include_callback;

  new_compiler->incl_clbk_user_data = NULL;

  new_compiler->include_free = _yr_compiler_default_include_free;

  new_compiler->re_ast_callback = NULL;

  new_compiler->re_ast_clbk_user_data = NULL;

  new_compiler->last_error = ERROR_SUCCESS;

  new_compiler->last_error_line = 0;

  new_compiler->strict_escape = false;

  new_compiler->current_line = 0;

  new_compiler->file_name_stack_ptr = 0;

  new_compiler->fixup_stack_head = NULL;

  new_compiler->loop_index = -1;

  new_compiler->loop_for_of_var_index = -1;

  new_compiler->atoms_config.get_atom_quality = yr_atoms_heuristic_quality;

  new_compiler->atoms_config.quality_warning_threshold =

      YR_ATOM_QUALITY_WARNING_THRESHOLD;

  result = yr_hash_table_create(5000, &new_compiler->rules_table);

  if (result == ERROR_SUCCESS)

    result = yr_hash_table_create(1000, &new_compiler->objects_table);

  if (result == ERROR_SUCCESS)

    result = yr_hash_table_create(10000, &new_compiler->strings_table);

  if (result == ERROR_SUCCESS)

    result = yr_hash_table_create(

        1000, &new_compiler->wildcard_identifiers_table);

  if (result == ERROR_SUCCESS)

    result = yr_hash_table_create(10000, &new_compiler->sz_table);

  if (result == ERROR_SUCCESS)

    result = yr_arena_create(YR_NUM_SECTIONS, 1048576, &new_compiler->arena);

  if (result == ERROR_SUCCESS)

    result = yr_ac_automaton_create(

        new_compiler->arena, &new_compiler->automaton);

  if (result == ERROR_SUCCESS)

  {

    *compiler = new_compiler;

  }

  else  // if error, do cleanup

  {

    yr_compiler_destroy(new_compiler);

  }

  return result;

}

YR_API void yr_compiler_destroy(YR_COMPILER* compiler)

{

  if (compiler->arena != NULL)

    yr_arena_release(compiler->arena);

  if (compiler->automaton != NULL)

    yr_ac_automaton_destroy(compiler->automaton);

  if (compiler->rules_table != NULL)

    yr_hash_table_destroy(compiler->rules_table, NULL);

  if (compiler->strings_table != NULL)

    yr_hash_table_destroy(compiler->strings_table, NULL);

  if (compiler->wildcard_identifiers_table != NULL)

    yr_hash_table_destroy(compiler->wildcard_identifiers_table, NULL);

  if (compiler->sz_table != NULL)

    yr_hash_table_destroy(compiler->sz_table, NULL);

  if (compiler->objects_table != NULL)

    yr_hash_table_destroy(

        compiler->objects_table,

        (YR_HASH_TABLE_FREE_VALUE_FUNC) yr_object_destroy);

  if (compiler->atoms_config.free_quality_table)

    yr_free(compiler->atoms_config.quality_table);

  for (int i = 0; i < compiler->file_name_stack_ptr; i++)

    yr_free(compiler->file_name_stack[i]);

  YR_FIXUP* fixup = compiler->fixup_stack_head;

  while (fixup != NULL)

  {

    YR_FIXUP* next_fixup = fixup->next;

    yr_free(fixup);

    fixup = next_fixup;

  }

  yr_free(compiler);

}

YR_API void yr_compiler_set_callback(

    YR_COMPILER* compiler,

    YR_COMPILER_CALLBACK_FUNC callback,

    void* user_data)

{

  compiler->callback = callback;

  compiler->user_data = user_data;

}

YR_API void yr_compiler_set_include_callback(

    YR_COMPILER* compiler,

    YR_COMPILER_INCLUDE_CALLBACK_FUNC include_callback,

    YR_COMPILER_INCLUDE_FREE_FUNC include_free,

    void* user_data)

{

  compiler->include_callback = include_callback;

  compiler->include_free = include_free;

  compiler->incl_clbk_user_data = user_data;

}

YR_API void yr_compiler_set_re_ast_callback(

    YR_COMPILER* compiler,

    YR_COMPILER_RE_AST_CALLBACK_FUNC re_ast_callback,

    void* user_data)

{

  compiler->re_ast_callback = re_ast_callback;

  compiler->re_ast_clbk_user_data = user_data;

}

////////////////////////////////////////////////////////////////////////////////

// This function allows to specify an atom quality table to be used by the

// compiler for choosing the best atoms from regular expressions and strings.

// When a quality table is set, the compiler uses yr_atoms_table_quality

// instead of yr_atoms_heuristic_quality for computing atom quality. The table

// has an arbitrary number of entries, each composed of YR_MAX_ATOM_LENGTH + 1

// bytes. The first YR_MAX_ATOM_LENGTH bytes from each entry are the atom's

// ones, and the remaining byte is a value in the range 0-255 determining the

// atom's quality. Entries must be lexicographically sorted by atom in ascending

// order.

//

//  [ atom (YR_MAX_ATOM_LENGTH bytes) ] [ quality (1 byte) ]

//

//  [ 00 00 .. 00 00 ] [ 00 ]

//  [ 00 00 .. 00 01 ] [ 45 ]

//  [ 00 00 .. 00 02 ] [ 13 ]

//  ...

//  [ FF FF .. FF FF ] [ 03 ]

//

// The "table" argument must point to a buffer containing the quality in

// the format explained above, and "entries" must contain the number of entries

// in the table. The table can not be freed while the compiler is in use, the

// caller is responsible for freeing the table.

//

// The "warning_threshold" argument must be a number between 0 and 255, if some

// atom chosen for a string have a quality below the specified threshold a

// warning like "<string> is slowing down scanning" is shown.

//

YR_API void yr_compiler_set_atom_quality_table(

    YR_COMPILER* compiler,

    const void* table,

    int entries,

    unsigned char warning_threshold)

{

  compiler->atoms_config.free_quality_table = false;

  compiler->atoms_config.quality_warning_threshold = warning_threshold;

  compiler->atoms_config.get_atom_quality = yr_atoms_table_quality;

  compiler->atoms_config.quality_table_entries = entries;

  compiler->atoms_config.quality_table = (YR_ATOM_QUALITY_TABLE_ENTRY*) table;

}

////////////////////////////////////////////////////////////////////////////////

// Load an atom quality table from a file. The file's content must have the

// format explained in the description for yr_compiler_set_atom_quality_table.

//

YR_API int yr_compiler_load_atom_quality_table(

    YR_COMPILER* compiler,

    const char* filename,

    unsigned char warning_threshold)

{

  long file_size;

  int entries;

  void* table;

  FILE* fh = fopen(filename, "rb");

  if (fh == NULL)

    return ERROR_COULD_NOT_OPEN_FILE;

  fseek(fh, 0L, SEEK_END);

  file_size = ftell(fh);

  fseek(fh, 0L, SEEK_SET);

  if (file_size == -1L)

  {

    fclose(fh);

    return ERROR_COULD_NOT_READ_FILE;

  }

  table = yr_malloc(file_size);

  if (table == NULL)

  {

    fclose(fh);

    return ERROR_INSUFFICIENT_MEMORY;

  }

  entries = (int) file_size / sizeof(YR_ATOM_QUALITY_TABLE_ENTRY);

  if (fread(table, sizeof(YR_ATOM_QUALITY_TABLE_ENTRY), entries, fh) != entries)

  {

    fclose(fh);

    yr_free(table);

    return ERROR_COULD_NOT_READ_FILE;

  }

  fclose(fh);

  yr_compiler_set_atom_quality_table(

      compiler, table, entries, warning_threshold);

  compiler->atoms_config.free_quality_table = true;

  return ERROR_SUCCESS;

}

int _yr_compiler_push_file_name(YR_COMPILER* compiler, const char* file_name)

{

  char* str;

  int i;

  for (i = 0; i < compiler->file_name_stack_ptr; i++)

  {

    if (strcmp(file_name, compiler->file_name_stack[i]) == 0)

      return ERROR_INCLUDES_CIRCULAR_REFERENCE;

  }

  if (compiler->file_name_stack_ptr == YR_MAX_INCLUDE_DEPTH)

    return ERROR_INCLUDE_DEPTH_EXCEEDED;

  str = yr_strdup(file_name);

  if (str == NULL)

    return ERROR_INSUFFICIENT_MEMORY;

  compiler->file_name_stack[compiler->file_name_stack_ptr] = str;

  compiler->file_name_stack_ptr++;

  return ERROR_SUCCESS;

}

void _yr_compiler_pop_file_name(YR_COMPILER* compiler)

{

  if (compiler->file_name_stack_ptr > 0)

  {

    compiler->file_name_stack_ptr--;

    yr_free(compiler->file_name_stack[compiler->file_name_stack_ptr]);

    compiler->file_name_stack[compiler->file_name_stack_ptr] = NULL;

  }

}

int _yr_compiler_get_var_frame(YR_COMPILER* compiler)

{

  int i, result = 0;

  for (i = 0; i < compiler->loop_index; i++)

  {

    result += compiler->loop[i].vars_count +

              compiler->loop[i].vars_internal_count;

  }

  return result;

}

YR_API char* yr_compiler_get_current_file_name(YR_COMPILER* compiler)

{

  if (compiler->file_name_stack_ptr > 0)

  {

    return compiler->file_name_stack[compiler->file_name_stack_ptr - 1];

  }

  else

  {

    return NULL;

  }

}

static int _yr_compiler_set_namespace(

    YR_COMPILER* compiler,

    const char* namespace_)

{

  YR_NAMESPACE* ns = (YR_NAMESPACE*) yr_arena_get_ptr(

      compiler->arena, YR_NAMESPACES_TABLE, 0);

  bool found = false;

  for (int i = 0; i < compiler->num_namespaces; i++, ns++)

  {

    if (strcmp(ns->name, namespace_) == 0)

    {

      found = true;

      compiler->current_namespace_idx = i;

      break;

    }

  }

  if (!found)

  {

    YR_ARENA_REF ref;

    FAIL_ON_ERROR(yr_arena_allocate_struct(

        compiler->arena,

        YR_NAMESPACES_TABLE,

        sizeof(YR_NAMESPACE),

        &ref,

        offsetof(YR_NAMESPACE, name),

        EOL));

    ns = (YR_NAMESPACE*) yr_arena_ref_to_ptr(compiler->arena, &ref);

    FAIL_ON_ERROR(_yr_compiler_store_string(compiler, namespace_, &ref));

    ns->name = (const char*) yr_arena_ref_to_ptr(compiler->arena, &ref);

    ns->idx = compiler->num_namespaces;

    compiler->current_namespace_idx = compiler->num_namespaces;

    compiler->num_namespaces++;

  }

  return ERROR_SUCCESS;

}

YR_API int yr_compiler_add_file(

    YR_COMPILER* compiler,

    FILE* rules_file,

    const char* namespace_,

    const char* file_name)

{

  int result;

  // Don't allow yr_compiler_add_file() after

  // yr_compiler_get_rules() has been called.

  assert(compiler->rules == NULL);

  // Don't allow calls to yr_compiler_add_file() if a previous call to

  // yr_compiler_add_XXXX failed.

  assert(compiler->errors == 0);

  if (namespace_ != NULL)

    compiler->last_error = _yr_compiler_set_namespace(compiler, namespace_);

  else

    compiler->last_error = _yr_compiler_set_namespace(compiler, "default");

  if (compiler->last_error == ERROR_SUCCESS && file_name != NULL)

    compiler->last_error = _yr_compiler_push_file_name(compiler, file_name);

  if (compiler->last_error != ERROR_SUCCESS)

    return ++compiler->errors;

  result = yr_lex_parse_rules_file(rules_file, compiler);

  if (file_name != NULL)

    _yr_compiler_pop_file_name(compiler);

  return result;

}

YR_API int yr_compiler_add_fd(

    YR_COMPILER* compiler,

    YR_FILE_DESCRIPTOR rules_fd,

    const char* namespace_,

    const char* file_name)

{

  int result;

  // Don't allow yr_compiler_add_fd() after

  // yr_compiler_get_rules() has been called.

  assert(compiler->rules == NULL);

  // Don't allow calls to yr_compiler_add_fd() if a previous call to

  // yr_compiler_add_XXXX failed.

  assert(compiler->errors == 0);

  if (namespace_ != NULL)

    compiler->last_error = _yr_compiler_set_namespace(compiler, namespace_);

  else

    compiler->last_error = _yr_compiler_set_namespace(compiler, "default");

  if (compiler->last_error == ERROR_SUCCESS && file_name != NULL)

    compiler->last_error = _yr_compiler_push_file_name(compiler, file_name);

  if (compiler->last_error != ERROR_SUCCESS)

    return ++compiler->errors;

  result = yr_lex_parse_rules_fd(rules_fd, compiler);

  if (file_name != NULL)

    _yr_compiler_pop_file_name(compiler);

  return result;

}

YR_API int yr_compiler_add_bytes(

    YR_COMPILER* compiler,

    const void* rules_data,

    size_t rules_size,

    const char* namespace_)

{

  // Don't allow calls to yr_compiler_add_bytes() after

  // yr_compiler_get_rules() has been called.

  assert(compiler->rules == NULL);

  // Don't allow calls to yr_compiler_add_bytes() if a previous call to

  // yr_compiler_add_XXXX failed.

  assert(compiler->errors == 0);

  if (namespace_ != NULL)

    compiler->last_error = _yr_compiler_set_namespace(compiler, namespace_);

  else

    compiler->last_error = _yr_compiler_set_namespace(compiler, "default");

  if (compiler->last_error != ERROR_SUCCESS)

    return ++compiler->errors;

  return yr_lex_parse_rules_bytes(rules_data, rules_size, compiler);

}

YR_API int yr_compiler_add_string(

    YR_COMPILER* compiler,

    const char* rules_string,

    const char* namespace_)

{

  // Don't allow calls to yr_compiler_add_string() after

  // yr_compiler_get_rules() has been called.

  assert(compiler->rules == NULL);

  // Don't allow calls to yr_compiler_add_string() if a previous call to

  // yr_compiler_add_XXXX failed.

  assert(compiler->errors == 0);

  if (namespace_ != NULL)

    compiler->last_error = _yr_compiler_set_namespace(compiler, namespace_);

  else

    compiler->last_error = _yr_compiler_set_namespace(compiler, "default");

  if (compiler->last_error != ERROR_SUCCESS)

    return ++compiler->errors;

  return yr_lex_parse_rules_string(rules_string, compiler);

}

static int _yr_compiler_compile_rules(YR_COMPILER* compiler)

{

  YR_RULE null_rule;

  YR_EXTERNAL_VARIABLE null_external;

  uint8_t halt = OP_HALT;

  // Write halt instruction at the end of code.

  FAIL_ON_ERROR(yr_arena_write_data(

      compiler->arena, YR_CODE_SECTION, &halt, sizeof(uint8_t), NULL));

  // Write a null rule indicating the end.

  memset(&null_rule, 0xFA, sizeof(YR_RULE));

  null_rule.flags = RULE_FLAGS_NULL;

  FAIL_ON_ERROR(yr_arena_write_data(

      compiler->arena, YR_RULES_TABLE, &null_rule, sizeof(YR_RULE), NULL));

  // Write a null external indicating the end.

  memset(&null_external, 0xFA, sizeof(YR_EXTERNAL_VARIABLE));

  null_external.type = EXTERNAL_VARIABLE_TYPE_NULL;

  FAIL_ON_ERROR(yr_arena_write_data(

      compiler->arena,

      YR_EXTERNAL_VARIABLES_TABLE,

      &null_external,

      sizeof(YR_EXTERNAL_VARIABLE),

      NULL));

  // Write Aho-Corasick automaton to arena.

  FAIL_ON_ERROR(yr_ac_compile(compiler->automaton, compiler->arena));

  YR_ARENA_REF ref;

  FAIL_ON_ERROR(yr_arena_allocate_struct(

      compiler->arena, YR_SUMMARY_SECTION, sizeof(YR_SUMMARY), &ref, EOL));

  YR_SUMMARY* summary = (YR_SUMMARY*) yr_arena_ref_to_ptr(

      compiler->arena, &ref);

  summary->num_namespaces = compiler->num_namespaces;

  summary->num_rules = compiler->next_rule_idx;

  summary->num_strings = compiler->current_string_idx;

  return yr_rules_from_arena(compiler->arena, &compiler->rules);

}

YR_API int yr_compiler_get_rules(YR_COMPILER* compiler, YR_RULES** rules)

{

  // Don't allow calls to yr_compiler_get_rules() if a previous call to

  // yr_compiler_add_XXXX failed.

  assert(compiler->errors == 0);

  *rules = NULL;

  if (compiler->rules == NULL)

    FAIL_ON_ERROR(_yr_compiler_compile_rules(compiler));

  *rules = compiler->rules;

  return ERROR_SUCCESS;

}

static int _yr_compiler_define_variable(

    YR_COMPILER* compiler,

    YR_EXTERNAL_VARIABLE* external)

{

  YR_EXTERNAL_VARIABLE* ext;

  YR_OBJECT* object;

  if (external->identifier == NULL)

    return ERROR_INVALID_ARGUMENT;

  object = (YR_OBJECT*) yr_hash_table_lookup(

      compiler->objects_table, external->identifier, NULL);

  if (object != NULL)

    return ERROR_DUPLICATED_EXTERNAL_VARIABLE;

  YR_ARENA_REF ext_ref;

  YR_ARENA_REF ref;

  FAIL_ON_ERROR(yr_arena_allocate_struct(

      compiler->arena,

      YR_EXTERNAL_VARIABLES_TABLE,

      sizeof(YR_EXTERNAL_VARIABLE),

      &ext_ref,

      offsetof(YR_EXTERNAL_VARIABLE, identifier),

      EOL));

  ext = (YR_EXTERNAL_VARIABLE*) yr_arena_ref_to_ptr(compiler->arena, &ext_ref);

  FAIL_ON_ERROR(

      _yr_compiler_store_string(compiler, external->identifier, &ref));

  ext->identifier = (const char*) yr_arena_ref_to_ptr(compiler->arena, &ref);

  ext->type = external->type;

  ext->value = external->value;

  if (external->type == EXTERNAL_VARIABLE_TYPE_STRING)

  {

    if (external->value.s == NULL)

      return ERROR_INVALID_ARGUMENT;

    FAIL_ON_ERROR(_yr_compiler_store_string(compiler, external->value.s, &ref));

    FAIL_ON_ERROR(yr_arena_make_ptr_relocatable(

        compiler->arena,

        YR_EXTERNAL_VARIABLES_TABLE,

        ext_ref.offset + offsetof(YR_EXTERNAL_VARIABLE, value.s),

        EOL));

    ext->value.s = (char*) yr_arena_ref_to_ptr(compiler->arena, &ref);

  }

  FAIL_ON_ERROR(yr_object_from_external_variable(external, &object));

  FAIL_ON_ERROR_WITH_CLEANUP(

      yr_hash_table_add(

          compiler->objects_table, external->identifier, NULL, (void*) object),

      yr_object_destroy(object));

  return ERROR_SUCCESS;

}

YR_API int yr_compiler_define_integer_variable(

    YR_COMPILER* compiler,

    const char* identifier,

    int64_t value)

{

  YR_EXTERNAL_VARIABLE external;

  external.type = EXTERNAL_VARIABLE_TYPE_INTEGER;

  external.identifier = identifier;

  external.value.i = value;

  FAIL_ON_ERROR(_yr_compiler_define_variable(compiler, &external));

  return ERROR_SUCCESS;

}

YR_API int yr_compiler_define_boolean_variable(

    YR_COMPILER* compiler,

    const char* identifier,

    int value)

{

  YR_EXTERNAL_VARIABLE external;

  external.type = EXTERNAL_VARIABLE_TYPE_BOOLEAN;

  external.identifier = identifier;

  external.value.i = value;

  FAIL_ON_ERROR(_yr_compiler_define_variable(compiler, &external));

  return ERROR_SUCCESS;

}

YR_API int yr_compiler_define_float_variable(

    YR_COMPILER* compiler,

    const char* identifier,

    double value)

{

  YR_EXTERNAL_VARIABLE external;

  external.type = EXTERNAL_VARIABLE_TYPE_FLOAT;

  external.identifier = identifier;

  external.value.f = value;

  FAIL_ON_ERROR(_yr_compiler_define_variable(compiler, &external));

  return ERROR_SUCCESS;

}

YR_API int yr_compiler_define_string_variable(

    YR_COMPILER* compiler,

    const char* identifier,

    const char* value)

{

  YR_EXTERNAL_VARIABLE external;

  external.type = EXTERNAL_VARIABLE_TYPE_STRING;

  external.identifier = identifier;

  external.value.s = (char*) value;

  FAIL_ON_ERROR(_yr_compiler_define_variable(compiler, &external));

  return ERROR_SUCCESS;

}

YR_API char* yr_compiler_get_error_message(

    YR_COMPILER* compiler,

    char* buffer,

    int buffer_size)

{

  uint32_t max_strings_per_rule;

  switch (compiler->last_error)

  {

  case ERROR_INSUFFICIENT_MEMORY:

    snprintf(buffer, buffer_size, "not enough memory");

    break;

  case ERROR_DUPLICATED_IDENTIFIER:

    snprintf(

        buffer,

        buffer_size,

        "duplicated identifier \"%s\"",

        compiler->last_error_extra_info);

    break;

  case ERROR_DUPLICATED_STRING_IDENTIFIER:

    snprintf(

        buffer,

        buffer_size,

        "duplicated string identifier \"%s\"",

        compiler->last_error_extra_info);

    break;

  case ERROR_DUPLICATED_TAG_IDENTIFIER:

    snprintf(

        buffer,

        buffer_size,

        "duplicated tag identifier \"%s\"",

        compiler->last_error_extra_info);

    break;

  case ERROR_DUPLICATED_META_IDENTIFIER:

    snprintf(

        buffer,

        buffer_size,

        "duplicated metadata identifier \"%s\"",

        compiler->last_error_extra_info);

    break;

  case ERROR_DUPLICATED_LOOP_IDENTIFIER:

    snprintf(

        buffer,

        buffer_size,

        "duplicated loop identifier \"%s\"",

        compiler->last_error_extra_info);

    break;

  case ERROR_UNDEFINED_STRING:

    snprintf(

        buffer,

        buffer_size,

        "undefined string \"%s\"",

        compiler->last_error_extra_info);

    break;

  case ERROR_UNDEFINED_IDENTIFIER:

    snprintf(

        buffer,

        buffer_size,

        "undefined identifier \"%s\"",

        compiler->last_error_extra_info);

    break;

  case ERROR_UNREFERENCED_STRING:

    snprintf(

        buffer,

        buffer_size,

        "unreferenced string \"%s\"",

        compiler->last_error_extra_info);

    break;

  case ERROR_EMPTY_STRING:

    snprintf(

        buffer,

        buffer_size,

        "empty string \"%s\"",

        compiler->last_error_extra_info);

    break;

  case ERROR_NOT_A_STRUCTURE:

    snprintf(

        buffer,

        buffer_size,

        "\"%s\" is not a structure",

        compiler->last_error_extra_info);

    break;

  case ERROR_NOT_INDEXABLE:

    snprintf(

        buffer,

        buffer_size,

        "\"%s\" is not an array or dictionary",

        compiler->last_error_extra_info);

    break;

  case ERROR_NOT_A_FUNCTION:

    snprintf(

        buffer,