mirror/puter
1
0
Fork 0
mirror of https://github.com/HeyPuter/puter.git synced 2026-01-06 05:00:29 -06:00
Code Issues Packages Projects Releases Wiki Activity

feat: refactor ai to have single entry point and follow defined model structure (#2114)

Browse Source 
* feat: refactor ai to have single entry point and follow defined model structure

* fix: missing openrouter registration

* fix: dedupe models

* feat: provide usage in stream mode 🚀
This commit is contained in:
Daniel Salazar
2025-12-09 15:59:21 -08:00
committed by GitHub
parent 2ab99d38da
commit e2ae313589
119 changed files with 5127 additions and 8839 deletions
Download Patch File Download Diff File Expand all files Collapse all files

53
ws-debug.mjs Normal file
View File

@@ -0,0 +1,53 @@
import { createTestKernel } from './src/backend/tools/test.mjs';
import { WorkerService } from '@heyputer/backend/src/services/worker/WorkerService.js';
import { EntityStoreService } from './src/backend/src/services/EntityStoreService.js';
import { AppLimitedES } from './src/backend/src/om/entitystorage/AppLimitedES.js';
import { ESBuilder } from './src/backend/src/om/entitystorage/ESBuilder.js';
import MaxLimitES from './src/backend/src/om/entitystorage/MaxLimitES.js';
import SQLES from './src/backend/src/om/entitystorage/SQLES.js';
import { SetOwnerES } from './src/backend/src/om/entitystorage/SetOwnerES.js';
import SubdomainES from './src/backend/src/om/entitystorage/SubdomainES.js';
import ValidationES from './src/backend/src/om/entitystorage/ValidationES.js';
import WriteByOwnerOnlyES from './src/backend/src/om/entitystorage/WriteByOwnerOnlyES.js';
import { Actor, UserActorType } from './src/backend/src/services/auth/Actor.js';
trying();
async function trying() {
const tk = await createTestKernel({
serviceMap: { worker: WorkerService, 'es:subdomain': EntityStoreService },
serviceMapArgs: {
'es:subdomain': {
entity: 'subdomain',
upstream: ESBuilder.create([
SQLES,
{ table: 'subdomains', debug: true },
SubdomainES,
AppLimitedES,
WriteByOwnerOnlyES,
ValidationES,
SetOwnerES,
MaxLimitES, { max: 5000 },
]),
},
},
serviceConfigOverrideMap: {
worker: { loggingUrl: 'x' },
database: { path: ':memory:' },
},
initLevelString: 'init',
testCore: true,
globalConfigOverrideMap: {
worker: { reserved_words: [] },
},
});
const su = tk.services.get('su');
const ws = tk.services.get('worker');
const actor = new Actor({ type: new UserActorType({ user: { id: 1, uuid: 'u1', username: 'test' } }) });
globalThis.services = tk.services;
const res = await tk.root_context.arun(() => su.sudo(actor, () => ws.create({ filePath: '/worker.js', workerName: 'MyWorker', authorization: 'auth' })));
console.log('result', res);
}