cell/source/qjs_actor.c

#include "cell.h"
#include "cell_internal.h"

#include <stdlib.h>
#include <string.h>

JSC_CCALL(os_createactor,
  cell_rt *rt = JS_GetContextOpaque(js);
  if (rt->disrupt)
    return JS_ThrowInternalError(js, "Can't start a new actor while disrupting.");

  void *startup = value2wota(js, argv[0], JS_NULL, NULL);
  create_actor(startup);
)

JSC_CCALL(os_mailbox_push,
  if (argc < 2) return JS_ThrowInternalError(js, "Need an actor and a message");
  if (!js_is_blob(js, argv[1])) return JS_ThrowInternalError(js, "Can only send blobs.");

  const char *id = JS_ToCString(js, argv[0]);
  int exist = actor_exists(id);

  if (!exist) {
    JS_FreeCString(js,id);
    return JS_ThrowInternalError(js, "No mailbox found for given ID");
  }
  
  JS_FreeCString(js,id);  
    
/*  JSValue sys = JS_GetPropertyStr(js, argv[1], "__SYSTEM__");
  if (!JS_IsNull(sys)) {
    const char *k = JS_ToCString(js,sys);
    int stop = 0;
    if (strcmp(k, "stop") == 0) {
      stop = 1;
      actor_disrupt(target);
    }
    JS_FreeValue(js,sys);
    JS_FreeCString(js,k);
    
    if (stop) return JS_NULL;
  }
*/    
  size_t size;
  void *data = js_get_blob_data(js, &size, argv[1]);
  if (data == (void*)-1) {
    return JS_EXCEPTION;
  }
  if (size == 0) {
    return JS_ThrowInternalError(js, "No data present in blob");
  }
  
  // Create a new blob and copy the data
  blob *msg_blob = blob_new(size * 8); // Convert bytes to bits
  if (!msg_blob) {
    return JS_ThrowInternalError(js, "Could not allocate blob");
  }
  
  // Copy data to blob
  blob_write_bytes(msg_blob, data, size);
  blob_make_stone(msg_blob); // Make it immutable
  
  const char *err = send_message(id, msg_blob);
  if (err) {
    blob_destroy(msg_blob);
    return JS_ThrowInternalError(js, "Could not send message: %s", err);
  }
)

JSC_CCALL(os_register_actor,
  cell_rt *rt = JS_GetContextOpaque(js);
  const char *id = JS_ToCString(js, argv[0]);
  double ar;
  JS_ToFloat64(js, &ar, argv[3]);
  const char *err = register_actor(id, rt, JS_ToBool(js, argv[2]), ar);
  if (err) return JS_ThrowInternalError(js, "Could not register actor: %s", err);
  rt->message_handle = JS_DupValue(js, argv[1]);
  rt->context = js;
  JS_FreeCString(js, id);
)

JSC_CCALL(os_mailbox_exist,
  const char *id = JS_ToCString(js, argv[0]);
  int exist = actor_exists(id);
  JS_FreeCString(js, id);

  return JS_NewBool(js, exist);
)

JSC_CCALL(os_unneeded,
  cell_rt *actor = JS_GetContextOpaque(js);
  double secs;
  JS_ToFloat64(js, &secs, argv[1]);
  actor_unneeded(actor, argv[0], secs);
)

JSC_CCALL(actor_disrupt,
  cell_rt *crt = JS_GetContextOpaque(js);
  actor_disrupt(crt);
)

JSC_SCALL(actor_setname,
  cell_rt *rt = JS_GetContextOpaque(js);
  rt->name = strdup(str);
)

JSC_CCALL(actor_on_exception,
  cell_rt *rt = JS_GetContextOpaque(js);
  JS_FreeValue(js, rt->on_exception);
  rt->on_exception = JS_DupValue(js,argv[0]);
)

JSC_CCALL(actor_clock,
  if (!JS_IsFunction(argv[0]))
    return JS_ThrowReferenceError(js, "Argument must be a function.");
    
  cell_rt *actor = JS_GetContextOpaque(js);
  actor_clock(actor, argv[0]);
)

JSC_CCALL(actor_delay,
   if (!JS_IsFunction(argv[0]))
    return JS_ThrowReferenceError(js, "Argument must be a function.");

  cell_rt *actor = JS_GetContextOpaque(js);
  double seconds;
  JS_ToFloat64(js, &seconds, argv[1]);
  if (seconds <= 0) {
    actor_clock(actor, argv[0]);
    return JS_NULL;
  }

  uint32_t id = actor_delay(actor, argv[0], seconds);
  return JS_NewUint32(js, id);
)

JSC_CCALL(actor_removetimer,
  cell_rt *actor = JS_GetContextOpaque(js);
  uint32_t timer_id;
  JS_ToUint32(js, &timer_id, argv[0]);
  JSValue removed = actor_remove_timer(actor, timer_id);
  JS_FreeValue(js, removed);
)

static const JSCFunctionListEntry js_actor_funcs[] = {
  MIST_FUNC_DEF(os, createactor, 1),
  MIST_FUNC_DEF(os, mailbox_push, 2),
  MIST_FUNC_DEF(os, mailbox_exist, 1),
  MIST_FUNC_DEF(actor, delay, 2),
  MIST_FUNC_DEF(actor, removetimer, 1),
  MIST_FUNC_DEF(os, register_actor, 4),
  MIST_FUNC_DEF(os, unneeded, 2),
  MIST_FUNC_DEF(actor, disrupt, 0),
  MIST_FUNC_DEF(actor, setname, 1),
  MIST_FUNC_DEF(actor, on_exception, 1),
  MIST_FUNC_DEF(actor, clock, 1),
};

JSValue js_actor_use(JSContext *js) {
  JSValue mod = JS_NewObject(js);
  JS_SetPropertyFunctionList(js,mod,js_actor_funcs,countof(js_actor_funcs));
  return mod;
}