native_runtime_stack.c

Go to the documentation of this file.

/**
 * @file
 * @brief Resolves the runtime apps directory, fingerprints it for reload detection, logs startup state, and matches requests to mounted apps.
 */
 
#include "native_runtime_stack.h"
 
#include "native_app_config.h"
#include "native_json_config.h"
#include "native_support.h"
 
#ifndef PHAROS_RUNTIME_STACK_VERSION
#define PHAROS_RUNTIME_STACK_VERSION "0.7.23"
#endif
 
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <time.h>
 
#ifdef _WIN32
#define native_runtime_stack_strdup _strdup
#else
#include <unistd.h>
#define native_runtime_stack_strdup strdup
#endif
 
static char *shell_quote_runtime_stack_native(const char *value) {
  size_t len = 2;
  const char *cursor;
  char *quoted;
  char *out;
  if (value == NULL) {
    return native_runtime_stack_strdup("''");
  }
  for (cursor = value; *cursor != '\0'; cursor++) {
    if (*cursor == '\'') {
      len += 4;
    } else {
      len += 1;
    }
  }
  quoted = (char *)malloc(len + 1);
  if (quoted == NULL) {
    return NULL;
  }
  out = quoted;
  *out++ = '\'';
  for (cursor = value; *cursor != '\0'; cursor++) {
    if (*cursor == '\'') {
      memcpy(out, "'\\''", 4);
      out += 4;
    } else {
      *out++ = *cursor;
    }
  }
  *out++ = '\'';
  *out = '\0';
  return quoted;
}
 
char *runtime_apps_dir_native(const char *conf_path) {
  char *raw = NULL;
  char *resolved = NULL;
  if (conf_path == NULL || conf_path[0] == '\0') {
    return current_working_directory();
  }
  raw = conf_lookup_value(conf_path, "apps_dir");
  if (raw == NULL || raw[0] == '\0') {
    free(raw);
    return current_working_directory();
  }
  resolved = resolve_conf_relative_path_native(conf_path, raw);
  free(raw);
  return resolved;
}
 
char *runtime_apps_fingerprint_native(const char *apps_dir) {
#ifndef __wasm__
  char *quoted_apps_dir = NULL;
  char command[16384];
  FILE *pipe = NULL;
  char buffer[256];
  char *fingerprint = NULL;
  if (apps_dir == NULL || apps_dir[0] == '\0') {
    return NULL;
  }
  quoted_apps_dir = shell_quote_runtime_stack_native(apps_dir);
  if (quoted_apps_dir == NULL) {
    return NULL;
  }
  snprintf(
    command,
    sizeof(command),
    "find %s -mindepth 1 -maxdepth 2 \\( -name pharos.app.json -o -name app.conf -o -path '*/runtime/*' \\) -type f -print 2>/dev/null | sort | xargs cat 2>/dev/null | shasum -a 256",
    quoted_apps_dir
  );
  free(quoted_apps_dir);
  pipe = popen(command, "r");
  if (pipe == NULL) {
    return NULL;
  }
  if (fgets(buffer, sizeof(buffer), pipe) != NULL) {
    size_t len = strcspn(buffer, " \t\r\n");
    fingerprint = dup_range(buffer, len);
  }
  pclose(pipe);
  return fingerprint;
#else
  (void)apps_dir;
  return NULL;
#endif
}
 
static void runtime_loaded_app_context_native(const AppRuntime *app, char *buffer, size_t buffer_len) {
  const char *mount = app != NULL && app->base_path != NULL ? app->base_path : "";
  const char *context = mount;
  if (context[0] == '/') {
    context++;
  }
  if (context[0] == '\0') {
    context = app != NULL && app->app_id != NULL ? app->app_id : "";
  }
  snprintf(buffer, buffer_len, "%s", context);
}
 
void runtime_log_banner_native(const RuntimeStack *stack, const ServeConfig *config, long load_ms) {
  Buffer loaded_apps;
  size_t i;
  time_t now = time(NULL);
  struct tm tm_utc;
  char timestamp[32];
  char context[256];
  buffer_init(&loaded_apps);
#ifdef _WIN32
  gmtime_s(&tm_utc, &now);
#else
  gmtime_r(&now, &tm_utc);
#endif
  strftime(timestamp, sizeof(timestamp), "%Y-%m-%dT%H:%M:%SZ", &tm_utc);
  for (i = 0; i < stack->count; i++) {
    runtime_loaded_app_context_native(&stack->apps[i], context, sizeof(context));
    if (context[0] == '\0') {
      continue;
    }
    if (loaded_apps.len > 0) {
      buffer_append(&loaded_apps, ",", 1);
    }
    buffer_append(&loaded_apps, context, strlen(context));
  }
  printf("%s INFO Pharos %s threaded: true\n", timestamp, PHAROS_RUNTIME_STACK_VERSION);
  printf("%s INFO app_count: %zu\n", timestamp, stack->count);
  printf("%s INFO loaded_apps: %s\n", timestamp, loaded_apps.data != NULL ? loaded_apps.data : "");
  printf("%s STATUS listening_on: %s started in: %ldms\n",
    timestamp,
    config->socket_path != NULL ? config->socket_path : config->host,
    load_ms);
  fflush(stdout);
  buffer_free(&loaded_apps);
}
 
AppRuntime *runtime_match_app_native(RuntimeStack *stack, const char *path) {
  AppRuntime *best = NULL;
  size_t best_len = 0;
  size_t index;
  for (index = 0; index < stack->count; index++) {
    AppRuntime *app = &stack->apps[index];
    const char *mount = app->base_path != NULL ? app->base_path : "";
    size_t mount_len = strlen(mount);
    if (mount_len == 0) {
      if (best == NULL) {
        best = app;
      }
      continue;
    }
    if (strcmp(path, mount) == 0 || (starts_with(path, mount) && (path[mount_len] == '/' || path[mount_len] == '\0' || path[mount_len] == '?'))) {
      if (mount_len > best_len) {
        best = app;
        best_len = mount_len;
      }
    }
  }
  return best;
}