Update from https://github.com/cloudimpl/next-coder/commit/07ec8df8633de2739692b0406d708a408aa85e36

Author: CloudimplBot

polycode/client.go

@@ -206,6 +206,11 @@ type SignalEmitRequest struct {
 	Error      Error  `json:"error"`
 }
 
+type RealtimeEventEmitRequest struct {
+	Channel string `json:"channel"`
+	Input   any    `json:"input"`
+}
+
 type SignalWaitRequest struct {
 	SignalName string `json:"signalName"`
 }
@@ -409,6 +414,10 @@ func (sc *ServiceClient) WaitForSignal(sessionId string, req SignalWaitRequest)
 	return res, err
 }
 
+func (sc *ServiceClient) EmitRealtimeEvent(sessionId string, req RealtimeEventEmitRequest) error {
+	return executeApiWithoutResponse(sc.httpClient, sc.baseURL, sessionId, "v1/realtime/event/emit", req)
+}
+
 func (sc *ServiceClient) IncrementCounter(sessionId string, req IncrementCounterRequest) (IncrementCounterResponse, error) {
 	var res IncrementCounterResponse
 	err := executeApiWithResponse(sc.httpClient, sc.baseURL, sessionId, "v1/utils/counter/increment", req, &res)

polycode/context.go

@@ -33,6 +33,7 @@ type WorkflowContext interface {
 	SignalAwait(signalName string) Response
 	SignalResumeSuccess(taskId string, signalName string, data any) error
 	SignalResumeError(taskId string, signalName string, err Error) error
+	EmitRealtimeEvent(channel string, data any) error
 }
 
 type ApiContext interface {
@@ -183,6 +184,15 @@ func (s ContextImpl) SignalResumeError(taskId string, signalName string, err Err
 	return s.serviceClient.EmitSignal(s.sessionId, req)
 }
 
+func (s ContextImpl) EmitRealtimeEvent(channel string, data any) error {
+	req := RealtimeEventEmitRequest{
+		Channel: channel,
+		Input:   data,
+	}
+
+	return s.serviceClient.EmitRealtimeEvent(s.sessionId, req)
+}
+
 func (s ContextImpl) Counter(group string, name string, ttl int64) Counter {
 	return Counter{
 		client:    s.serviceClient,