fix(typespec): Misc fixes in typespec definitions

typespec/common/interfaces.tsp

@@ -1,9 +1,11 @@
 import "@typespec/http";
+import "@typespec/sse";
 
 import "./scalars.tsp";
 import "./types.tsp";
 
 using TypeSpec.Http;
+using TypeSpec.SSE;
 
 namespace Common;
 
@@ -140,28 +142,6 @@ interface ChildLimitOffsetPagination<
     };
 }
 
-interface ChildStreamEndpoint<
-    T,
-    DocString extends valueof string = "Stream events emitted by the parent"
-> {
-    @get
-    @doc(DocString)
-    stream(
-        @path
-        @doc("ID of parent")
-        id: uuid,
-
-        @query
-        @doc("Next page token")
-        next_token: string | null = null,
-    ): {
-        @header contentType: eventStream;
-
-        @body
-        @doc("Stream of events emitted by the parent")
-        body: T;
-    };
-}
 
 interface ChildCreateEndpoint<
     CreateType,
@@ -274,3 +254,20 @@ interface ChildPatchEndpoint<
         body: ResourceUpdatedResponse;
     };
 }
+
+interface ChildStreamEndpoint<
+    T,
+    DocString extends valueof string = "Stream events emitted by the parent"
+> {
+    @get
+    @doc(DocString)
+    stream(
+        @path
+        @doc("ID of parent")
+        id: uuid,
+
+        @query
+        @doc("Next page token")
+        next_token: string | null = null,
+    ): SSEStream<StreamEvent<T>>;
+}

typespec/common/types.tsp

@@ -1,6 +1,8 @@
+import "@typespec/events";
 import "@typespec/http";
 import "@typespec/openapi";
 
+using TypeSpec.Events;
 using TypeSpec.Http;
 using TypeSpec.OpenAPI;
 
@@ -51,4 +53,9 @@ model PaginationOptions {
 
     /** Object to filter results by metadata */
     @query metadata_filter: MetadataFilter,
-}
+}
+
+@events
+union StreamEvent<T> {
+    T;
+}

typespec/main.tsp

@@ -95,6 +95,9 @@ namespace Api {
     @route("/docs")
     interface IndividualDocsRoute extends Docs.IndividualDocEndpoints {}
 
+    @route("/tasks")
+    interface TasksGetRoute extends Tasks.GetEndpoints {}
+
     @route("/agents/{id}/tasks")
     interface TasksRoute extends Tasks.Endpoints {}
 

typespec/package.json

@@ -3,12 +3,14 @@
   "version": "0.4.0",
   "type": "module",
   "dependencies": {
-    "@typespec/compiler": "^0.60.1",
-    "@typespec/http": "^0.60.0",
-    "@typespec/openapi": "^0.60.0",
-    "@typespec/openapi3": "^0.60.0",
-    "@typespec/rest": "^0.60.0",
-    "@typespec/versioning": "^0.60.1"
+    "@typespec/compiler": "^0.61.2",
+    "@typespec/events": "^0.61.0",
+    "@typespec/http": "^0.61.0",
+    "@typespec/openapi": "^0.61.0",
+    "@typespec/openapi3": "^0.61.0",
+    "@typespec/rest": "^0.61.0",
+    "@typespec/sse": "^0.61.0",
+    "@typespec/versioning": "^0.61.0"
   },
   "private": true
 }

typespec/tasks/endpoints.tsp

@@ -15,6 +15,8 @@ namespace Tasks;
 // TASK ENDPOINTS
 //
 
+interface GetEndpoints extends GetEndpoint<Task, "Get a task by id"> {}
+
 interface CreateOrUpdateEndpoints {
     @post
     @doc("Create or update a task")

typespec/tasks/steps.tsp

@@ -59,7 +59,6 @@ alias NonConditionalWorkflowStep =
     | ReturnStep
     | SleepStep
     | ErrorWorkflowStep
-    | YieldStep
     | WaitForInputStep;
 
 alias ConditionalStep = IfElseWorkflowStep | SwitchStep;