Plugin-Entwicklung

@processcube/mein-plugin.cuby/
├── package.json              # NPM Paket-Definition
├── index.js                  # Plugin-Hauptmodul (Lifecycle-Methoden)
├── config-component.js       # Optional: React-Konfigurationskomponente
└── detail-component.js       # Optional: React-Detail-Komponente

{
  "name": "@processcube/mein-plugin.cuby",
  "version": "1.0.0",
  "description": "Mein Cuby Plugin",
  "main": "index.js",
  "type": "module",
  "cuby": {
    "type": "npx",
    "plugin": "index.js",
    "url": "http://localhost:3000"
  }
}

// index.js
 
// Route-Registrierung (läuft auf dem Main-Thread)
export async function init(router, cuby, context) {
  // HTTP-Routen registrieren
  router.get('/status', () => Response.json({ running: true }));
 
  // Socket.IO-Events registrieren
  router.onSocket('custom:event', (data) => {
    console.log('Received:', data);
  });
}
 
// Deployment (läuft im Worker-Prozess)
export async function deploy(productDir, config, onProgress, cuby, context) {
  onProgress(50, 'Konfiguration wird angewendet...');
 
  // Konfigurationsdatei schreiben
  const configPath = `${productDir}/config.json`;
  await Bun.write(configPath, JSON.stringify(config, null, 2));
 
  // ProcessCube-Instanz registrieren
  await cuby.registerProcessCube({
    engineUrl: config.engineUrl,
    lowCodeUrls: [config.lowCodeUrl],
  });
 
  onProgress(100, 'Deployment abgeschlossen');
}
 
// Start (läuft im Worker-Prozess)
export async function start(productDir, cuby, context) {
  // Port reservieren
  const port = await cuby.reservePort(3000);
  console.log(`Plugin gestartet auf Port ${port}`);
}
 
// Stop (läuft im Worker-Prozess)
export async function stop(cuby, context) {
  // Ressourcen freigeben
  await cuby.releasePort(3000);
  console.log('Plugin gestoppt');
}
 
// Undeploy (läuft im Worker-Prozess)
export async function undeploy(productDir, cuby, context) {
  // Artefakte entfernen
  console.log('Plugin entfernt');
}
 
// Konfiguration zurückgeben
export function getConfig() {
  return { engineUrl: 'http://localhost:8000' };
}

export async function init(router, cuby, context) {
  // Event-Handler registrieren
  router.onSocket('my:event', (data) => {
    console.log('Client sendet:', data);
  });
 
  // Event an alle Clients senden
  router.emitSocket('my:update', { status: 'ready' });
 
  // Event an bestimmten Raum senden
  router.emitSocket('my:update', { status: 'ready' }, { room: 'admins' });
}

export async function deploy(productDir, config, onProgress, cuby, context) {
  // Secret speichern
  await cuby.setSecret('db-password', config.dbPassword);
 
  // Secret lesen
  const password = await cuby.getSecret('db-password');
}

function ConfigComponent({ config, onChange, product }) {
  const [engineUrl, setEngineUrl] = useState(config.engineUrl || 'http://localhost:8000');
 
  useEffect(() => {
    onChange({ engineUrl });
  }, [engineUrl]);
 
  return (
    <div className="space-y-4">
      <h3 className="text-lg font-semibold">Engine-Konfiguration</h3>
      <div>
        <label className="block text-sm font-medium mb-1">Engine URL</label>
        <input
          className="w-full px-3 py-2 border rounded-lg"
          value={engineUrl}
          onChange={(e) => setEngineUrl(e.target.value)}
          placeholder="http://localhost:8000"
        />
      </div>
    </div>
  );
}
 
export default ConfigComponent;