@totemorg/agent

v1.6.0

Published

6 months ago

Totem agent

Downloads

0High
0Medium
0Low

AGENT

Add TOTEM agents to your compute cloud. Regulate workflows. Fetch data.

Install

npm install @totemorg/enums

Manage

npm run start ?					# List start options
npm run verminor				# Roll minor version
npm run vermajor				# Roll major version
npm run redoc					# Regen documentation
npm run pubminor				# republish as minor version
npm run pubmajor				# republish as major version

Usage

To add your compute agents to TOTEM's compute cloud, simply register your agents using the following code pattern

// revise as needed
const 
	need$ = false,
	needFetch = false,
	totems = {
		RLEU: "https://RLENET.126:8443",
		RLEC: "https://RLENET.216:8443",
		WWW: "http://totem.hopto.org",
		SBU: "https://totem.nga.mil:8443",
		COE: "https://totem.coe.nga.mil",
		LOCAL: "http://localhost:8080"
	},
	totem = totems.LOCAL,
	port = 3333,
	agents = {	// define your agents here
	};

// do not alter
const
	{ $ } = need$
		? require("/mnt/totem/man")
		: { $ : null },

	{ Fetch } = needFetch 
			? require("/mnt/totem/enums")
			: { Fetch: ( url, cb ) => {
	const {pathname,protocol} = new URL(url);
	switch (protocol) {
		case "http:":
			return require("http").get(url, res => {
				var txt = "";
				res.on("data", data => txt += data.toString());
				res.on("end", () => cb(txt) );
			}).end();

		case "file:": 
			return require("fs").readFile( "."+pathname, "utf-8", (err,txt) => cb(err?null:txt) );
	}
} };

Fetch(`${totem}/agent?port=${port}&keys=${Object.keys(agents)}`, setup => eval(setup));

For example, to create add, cat, getinfo, dft, python, R and opencv agents that listen for requests on port 3333, replace the agents = {}; with

agents = {	// define your agents here
	add: (req,res) => {	// an agent to add x and y
		const 
			{x,y} = req.query,
			calc = (x,y) => x+y;

		res( calc(x,y) );
	},

	cat: (req,res) => {	// an agent to concatenate x with y
		const 
			{x,y} = req.query,
			calc = (x,y) => [x,y];

		res( calc(x,y) );
	},

	backlog: (req,res) => {	// check my task queue
		Fetch( `${totem}/agent?tasks=all`, msg => {
			const tasks = JSON.parse(msg);

			res( `I've got ${tasks.length} to work on` );
			tasks.forEach( task => {
				console.log("working", task);
			});
		});
	},

	getfile: (req,res) => {	// send a text file
		Fetch( "file:/root/test.txt", txt => res(txt) );
	},

	// following agents require $ 

	dft: (req,res) => {	// fft of a large-dim x-post array + with a small-dim a-query offset 
		const
			{ y } = ctx = $("y=dft(x+a)", {		// context for $
				x: req.body.x || [0,0,0,0,0,0,0,1,1,1,0,0,0,0,0,0,0],
				a: req.query.a
			});

		res( y.$("re&im") );
	},

	python: (req,res) => {	// test python engine
		const
			{ a } = $.py(`
		import numpy as np;

		print 'console log: an array if i need it', np.array([1,2,3]);

		def f(x,y):
			return x+y;

		a=f(x,y)
		`, {
				x: req.query.x,
				y: req.query.y
			});

		res( a );
	},

	R: (req,res) => {	// test R engine
		const
			{ a } = ctx = $.R(`
		print('you da man');
		print('R input ctx=');str(CTX);
		CTX$d = 'this is a test';
		CTX$e = list(x=1,y=2,z=3);
		CTX$a = CTX$x + CTX$y;
		CTX$g = list(4,5,6);
		CTX$h = TRUE;
		`, {
				x: req.query.x,
				y: req.query.y
			});

		//console.log(ctx);
		res( ctx );
	},

	opencv: (req,res) => {	// test opencv/caffe engine
		const 
			ctx = $.cv("dummy code", {
				output: {	// classifier output port parms
					scale: 0,
					dim: 100,
					delta: 1,
					hits: 10,
					cascade: ["path1", "path2"]
				},
				input: {// image input port parms
				}
			});

		res( ctx );
	}
};

where

the last 5 agents require need$ enabled to include TOTEMs matrix minupulator
the last 3 agents demonstrate R-opencv-python support (assummed installed on your host).
enable needFetch to use TOTEM's full-featured Fetch.

Program Reference

agent

Attach endpoint agents to your compute cloud. Regulate workflows. Fetch data.

Requires: module:http, module:https, module:os, module:busy, module:mime, module:@totemorg/enums

agent
- static
- inner