- ([]);
const [selectedProject, setSelectedProject] = useState(null);
- const [selectedDrone, setSelectedDrone] = useState(null);
+ const [selectedDrone, setSelectedDrone] = useState(
+ null,
+ );
const [loading, setLoading] = useState(true);
const [showNewForm, setShowNewForm] = useState(false);
@@ -839,7 +882,10 @@ export default function ProjectManager({ user }: ProjectManagerProps) {
console.error("Failed to lock drone session");
return;
}
- localStorage.setItem('dtp_drone_registration', JSON.stringify(selectedDrone));
+ localStorage.setItem(
+ "dtp_drone_registration",
+ JSON.stringify(selectedDrone),
+ );
navigate(`/projects/${selectedProject._id}/chat-session/${sessionId}`);
} catch (err) {
console.error("Failed to open chat session", err);
diff --git a/gadget-code/frontend/src/pages/assets/gab-ai.jpeg b/gadget-code/frontend/src/pages/assets/gab-ai.jpeg
new file mode 100644
index 0000000..b0333aa
Binary files /dev/null and b/gadget-code/frontend/src/pages/assets/gab-ai.jpeg differ
diff --git a/gadget-code/frontend/src/types/assets.d.ts b/gadget-code/frontend/src/types/assets.d.ts
new file mode 100644
index 0000000..0942e81
--- /dev/null
+++ b/gadget-code/frontend/src/types/assets.d.ts
@@ -0,0 +1,29 @@
+declare module "*.jpeg" {
+ const src: string;
+ export default src;
+}
+
+declare module "*.jpg" {
+ const src: string;
+ export default src;
+}
+
+declare module "*.png" {
+ const src: string;
+ export default src;
+}
+
+declare module "*.gif" {
+ const src: string;
+ export default src;
+}
+
+declare module "*.svg" {
+ const src: string;
+ export default src;
+}
+
+declare module "*.webp" {
+ const src: string;
+ export default src;
+}
diff --git a/gadget-drone/src/services/agent.ts b/gadget-drone/src/services/agent.ts
index 4a49c74..46dabfd 100644
--- a/gadget-drone/src/services/agent.ts
+++ b/gadget-drone/src/services/agent.ts
@@ -337,6 +337,7 @@ class AgentService extends GadgetService {
abortCurrentWorkOrder(): boolean {
if (!this.abortController) return false;
this.abortController.abort();
+ AiService.abort();
return true;
}
diff --git a/gadget-drone/src/services/ai.ts b/gadget-drone/src/services/ai.ts
index 40d29f0..2d438da 100644
--- a/gadget-drone/src/services/ai.ts
+++ b/gadget-drone/src/services/ai.ts
@@ -18,6 +18,7 @@ const aiEnv: IAiEnvironment = {
import { IAiProvider as DbAiProvider, GadgetId, type IDroneModelConfig } from "@gadget/api";
import { GadgetService } from "../lib/service.js";
import {
+ AiApi,
type IAiChatOptions,
type IAiChatResponse,
type IAiGenerateOptions,
@@ -47,6 +48,8 @@ class AiService extends GadgetService {
return "svc:ai";
}
+ private activeApi: AiApi | null = null;
+
async start(): Promise {
this.log.info("started");
}
@@ -103,7 +106,11 @@ class AiService extends GadgetService {
});
const api = this.getApi(config);
const modelConfig: IAiModelConfig = { ...model, provider: config };
- return api.generate(modelConfig, options, streamCallback);
+ try {
+ return await api.generate(modelConfig, options, streamCallback);
+ } finally {
+ this.activeApi = null;
+ }
}
async chat(
@@ -121,11 +128,23 @@ class AiService extends GadgetService {
});
const api = this.getApi(config);
const modelConfig: IAiModelConfig = { ...model, provider: config };
- return await api.chat(modelConfig, options, streamCallback);
+ try {
+ return await api.chat(modelConfig, options, streamCallback);
+ } finally {
+ this.activeApi = null;
+ }
}
getApi(provider: AiProviderConfig) {
- return createAiApi(aiEnv, provider, this.log);
+ const api = createAiApi(aiEnv, provider, this.log);
+ this.activeApi = api;
+ return api;
+ }
+
+ /** Forcefully abort any in-progress request on the active API instance. */
+ abort(): void {
+ this.activeApi?.abort();
+ this.activeApi = null;
}
}
diff --git a/packages/ai/src/api.ts b/packages/ai/src/api.ts
index 3c956d2..a0726a0 100644
--- a/packages/ai/src/api.ts
+++ b/packages/ai/src/api.ts
@@ -196,6 +196,15 @@ export abstract class AiApi {
streamCallback?: IAiResponseStreamFn,
): Promise;
+ /**
+ * Forcefully abort any in-progress API request.
+ * Provider-specific implementations (e.g., Ollama) should terminate
+ * the underlying HTTP request immediately. Default is no-op.
+ */
+ abort(): void {
+ // Override in provider-specific implementations
+ }
+
protected assertNonEmptyChatResponse(response: IAiChatResponse): void {
const hasResponse = response.response.trim().length > 0;
const hasThinking = !!response.thinking?.trim();
diff --git a/packages/ai/src/ollama.ts b/packages/ai/src/ollama.ts
index f8613ce..2bea71e 100644
--- a/packages/ai/src/ollama.ts
+++ b/packages/ai/src/ollama.ts
@@ -34,6 +34,11 @@ export class OllamaAiApi extends AiApi {
});
}
+ /** Forcefully abort any in-progress Ollama API request. */
+ override abort(): void {
+ this.client.abort();
+ }
+
async listModels(): Promise {
const response = await this.client.list();
const models = response.models.map((model) => {
New Chat Session
- {selectedDrone && ( -
-
);
@@ -774,7 +815,9 @@ export default function ProjectManager({ user }: ProjectManagerProps) {
const { slug } = useParams();
const [projects, setProjects] = useStateSelected Drone
-
- {selectedDrone.hostname}
+
+
+
+ 
+
+
+ + Need big-brain inference for this session? +
++ Sign up for Gab AI and get 250 credits to see if it's right for you! +
+ + + +
+
- )}
-
+ New Chat Session
+ {selectedDrone && ( +
+
- Selected Drone
+
+ {selectedDrone.hostname}
+
+
+ {selectedDrone.workspaceDir}
+
- {selectedDrone.workspaceDir}
-
-
+
+
+
+
+
+
+
+
+
+