 85bf1341f3
			
		
	
	85bf1341f3
	
	
	
		
			
			Frontend Enhancements: - Complete React TypeScript frontend with modern UI components - Distributed workflows management interface with real-time updates - Socket.IO integration for live agent status monitoring - Agent management dashboard with cluster visualization - Project management interface with metrics and task tracking - Responsive design with proper error handling and loading states Backend Infrastructure: - Distributed coordinator for multi-agent workflow orchestration - Cluster management API with comprehensive agent operations - Enhanced database models for agents and projects - Project service for filesystem-based project discovery - Performance monitoring and metrics collection - Comprehensive API documentation and error handling Documentation: - Complete distributed development guide (README_DISTRIBUTED.md) - Comprehensive development report with architecture insights - System configuration templates and deployment guides The platform now provides a complete web interface for managing the distributed AI cluster with real-time monitoring, workflow orchestration, and agent coordination capabilities. 🤖 Generated with [Claude Code](https://claude.ai/code) Co-Authored-By: Claude <noreply@anthropic.com>
		
			
				
	
	
		
			69 lines
		
	
	
		
			1.4 KiB
		
	
	
	
		
			JavaScript
		
	
	
	
	
	
			
		
		
	
	
			69 lines
		
	
	
		
			1.4 KiB
		
	
	
	
		
			JavaScript
		
	
	
	
	
	
| 'use strict';
 | |
| 
 | |
| var processFn = function (fn, P, opts) {
 | |
| 	return function () {
 | |
| 		var that = this;
 | |
| 		var args = new Array(arguments.length);
 | |
| 
 | |
| 		for (var i = 0; i < arguments.length; i++) {
 | |
| 			args[i] = arguments[i];
 | |
| 		}
 | |
| 
 | |
| 		return new P(function (resolve, reject) {
 | |
| 			args.push(function (err, result) {
 | |
| 				if (err) {
 | |
| 					reject(err);
 | |
| 				} else if (opts.multiArgs) {
 | |
| 					var results = new Array(arguments.length - 1);
 | |
| 
 | |
| 					for (var i = 1; i < arguments.length; i++) {
 | |
| 						results[i - 1] = arguments[i];
 | |
| 					}
 | |
| 
 | |
| 					resolve(results);
 | |
| 				} else {
 | |
| 					resolve(result);
 | |
| 				}
 | |
| 			});
 | |
| 
 | |
| 			fn.apply(that, args);
 | |
| 		});
 | |
| 	};
 | |
| };
 | |
| 
 | |
| var pify = module.exports = function (obj, P, opts) {
 | |
| 	if (typeof P !== 'function') {
 | |
| 		opts = P;
 | |
| 		P = Promise;
 | |
| 	}
 | |
| 
 | |
| 	opts = opts || {};
 | |
| 	opts.exclude = opts.exclude || [/.+Sync$/];
 | |
| 
 | |
| 	var filter = function (key) {
 | |
| 		var match = function (pattern) {
 | |
| 			return typeof pattern === 'string' ? key === pattern : pattern.test(key);
 | |
| 		};
 | |
| 
 | |
| 		return opts.include ? opts.include.some(match) : !opts.exclude.some(match);
 | |
| 	};
 | |
| 
 | |
| 	var ret = typeof obj === 'function' ? function () {
 | |
| 		if (opts.excludeMain) {
 | |
| 			return obj.apply(this, arguments);
 | |
| 		}
 | |
| 
 | |
| 		return processFn(obj, P, opts).apply(this, arguments);
 | |
| 	} : {};
 | |
| 
 | |
| 	return Object.keys(obj).reduce(function (ret, key) {
 | |
| 		var x = obj[key];
 | |
| 
 | |
| 		ret[key] = typeof x === 'function' && filter(key) ? processFn(x, P, opts) : x;
 | |
| 
 | |
| 		return ret;
 | |
| 	}, ret);
 | |
| };
 | |
| 
 | |
| pify.all = pify;
 |