rest-default-api.js

/**
 * This is the Core REST API my-own-cluster implementation
 * 
 * It allows to execute basic operations like :
 * 
 * - register a blob
 * - plus a blob as a function
 * - plug a blob as a file
 * - call a function
 * 
 * It is mainly used by the CLI program.
 * It is normally bound to the cluster web endpoint during startup (in main.go)
 */

/// reference path="./core-api-guest.d.ts"

const moc = requireApi('core')

function getInputRequest() {
    var bufferId = moc.getInputBufferId()
    var bufferBytes = moc.readExchangeBuffer(bufferId)

    var reqText = new TextDecoder("utf-8").decode(bufferBytes)

    return JSON.parse(reqText)
}

function plugFunction() {
    var req = getInputRequest()

    moc.plugFunction(
        req.method,
        req.path,
        req.name,
        req.start_function,
        req.data || "",
        JSON.stringify(req.tags || {})
    )

    moc.writeExchangeBuffer(moc.getOutputBufferId(), JSON.stringify({
        status: true,
    }))

    return 200
}

function plugFile() {
    var req = getInputRequest()

    moc.plugFile(
        req.method,
        req.path,
        req.name,
        JSON.stringify(req.tags || {})
    )

    moc.writeExchangeBuffer(moc.getOutputBufferId(), JSON.stringify({
        status: true,
    }))

    return 200
}

function unplugPath() {
    var req = getInputRequest()

    moc.unplugPath(
        req.method,
        req.path
    )

    moc.writeExchangeBufferStatusCode(moc.getOutputBufferId(), 200)
    moc.writeExchangeBuffer(moc.getOutputBufferId(), JSON.stringify({
        status: true,
    }))
}

function plugFilter() {
    var req = getInputRequest()

    var filterId = moc.plugFilter(
        req.name,
        req.start_function,
        req.data
    )

    moc.writeExchangeBufferStatusCode(moc.getOutputBufferId(), 200)
    moc.writeExchangeBuffer(moc.getOutputBufferId(), JSON.stringify({
        status: true,
        filter_id: filterId
    }))
}

function unplugFilter() {
    var headers = moc.readExchangeBufferHeaders(moc.getInputBufferId())
    var filterId = headers["x-moc-path-param-filter-id"]

    moc.unplugFilter(filterId)

    moc.writeExchangeBufferStatusCode(moc.getOutputBufferId(), 200)
    moc.writeExchangeBuffer(moc.getOutputBufferId(), JSON.stringify({
        status: true
    }))
}

function registerBlob() {
    var req = getInputRequest()

    var bytes = moc.base64Decode(req.bytes)

    var techID;

    if (req.name) {
        techID = moc.registerBlobWithName(
            req.name,
            req.content_type,
            bytes
        );
    } else {
        techID = moc.registerBlob(
            req.content_type,
            bytes
        );
    }

    moc.writeExchangeBuffer(moc.getOutputBufferId(), JSON.stringify({
        status: true,
        tech_id: techID
    }))

    return 200
}

function callFunction() {
    var req = getInputRequest()

    var inputExchangeBufferId = moc.createExchangeBuffer()
    if (req.input)
        moc.writeExchangeBuffer(inputExchangeBufferId, moc.base64Decode(req.input))

    var outputExchangeBufferId = moc.createExchangeBuffer()

    var result = moc.callFunction(
        req.name,
        req.start_function || "_start",
        req.arguments || [],
        req.mode || "direct",
        inputExchangeBufferId,
        outputExchangeBufferId,
        req.posix_file_name || "",
        req.posix_arguments || [""]
    )

    var response = {
        status: true,
        result: result,
        output: moc.base64Encode(moc.readExchangeBuffer(outputExchangeBufferId))
    }

    moc.writeExchangeBufferStatusCode(moc.getOutputBufferId(), 200)
    moc.writeExchangeBuffer(moc.getOutputBufferId(), JSON.stringify(response))

    moc.freeBuffer(inputExchangeBufferId)
    moc.freeBuffer(outputExchangeBufferId)
}

function exportDatabase() {
    var exp = moc.exportDatabase()

    moc.writeExchangeBufferStatusCode(moc.getOutputBufferId(), 200)
    moc.writeExchangeBuffer(moc.getOutputBufferId(), exp)
}