fixup specifying event type

Author: richiejp

core/http/endpoints/openai/realtime.go

@@ -229,10 +229,7 @@ func registerRealtime(application *application.Application, model, intent string
 
 		sendEvent(c, types.SessionCreatedEvent{
 			ServerEventBase: types.ServerEventBase{
-				EventBase: types.EventBase{
-					EventID: "event_TODO",
-					Type:    string(types.ServerEventTypeSessionCreated),
-				},
+				EventID: "event_TODO",
 			},
 			Session: session.ToServer(),
 		})
@@ -302,10 +299,7 @@ func registerRealtime(application *application.Application, model, intent string
 
 					sendEvent(c, types.SessionUpdatedEvent{
 						ServerEventBase: types.ServerEventBase{
-							EventBase: types.EventBase{
-								EventID: "event_TODO",
-								Type:    string(types.ServerEventTypeSessionUpdated),
-							},
+							EventID: "event_TODO",
 						},
 						Session: session.ToServer(),
 					})
@@ -329,10 +323,7 @@ func registerRealtime(application *application.Application, model, intent string
 
 					sendEvent(c, types.SessionUpdatedEvent{
 						ServerEventBase: types.ServerEventBase{
-							EventBase: types.EventBase{
-								EventID: "event_TODO",
-								Type:    string(types.ServerEventTypeSessionUpdated),
-							},
+							EventID: "event_TODO",
 						},
 						Session: session.ToServer(),
 					})
@@ -421,10 +412,7 @@ func registerRealtime(application *application.Application, model, intent string
 
 				sendEvent(c, types.ConversationItemRetrievedEvent{
 					ServerEventBase: types.ServerEventBase{
-						EventBase: types.EventBase{
-							Type:    string(types.ServerEventTypeConversationItemRetrieved),
-							EventID: "event_TODO",
-						},
+						EventID: "event_TODO",
 					},
 					Item: retrievedItem,
 				})
@@ -473,10 +461,7 @@ func sendEvent(c *websocket.Conn, event types.ServerEvent) {
 func sendError(c *websocket.Conn, code, message, param, eventID string) {
 	errorEvent := types.ErrorEvent{
 		ServerEventBase: types.ServerEventBase{
-			EventBase: types.EventBase{
-				Type:    string(types.ServerEventTypeError),
-				EventID: eventID,
-			},
+			EventID: eventID,
 		},
 		Error: types.Error{
 			Type:    "invalid_request_error",
@@ -645,10 +630,7 @@ func handleVAD(cfg *config.ModelConfig, evaluator *templates.Evaluator, session
 
 				sendEvent(c, types.InputAudioBufferClearedEvent{
 					ServerEventBase: types.ServerEventBase{
-						EventBase: types.EventBase{
-							EventID: "event_TODO",
-							Type:    string(types.ServerEventTypeInputAudioBufferCleared),
-						},
+						EventID: "event_TODO",
 					},
 				})
 
@@ -660,10 +642,7 @@ func handleVAD(cfg *config.ModelConfig, evaluator *templates.Evaluator, session
 			if !speechStarted {
 				sendEvent(c, types.InputAudioBufferSpeechStartedEvent{
 					ServerEventBase: types.ServerEventBase{
-						EventBase: types.EventBase{
-							EventID: "event_TODO",
-							Type:    string(types.ServerEventTypeInputAudioBufferSpeechStarted),
-						},
+						EventID: "event_TODO",
 					},
 					AudioStartMs: time.Since(startTime).Milliseconds(),
 				})
@@ -684,21 +663,15 @@ func handleVAD(cfg *config.ModelConfig, evaluator *templates.Evaluator, session
 
 				sendEvent(c, types.InputAudioBufferSpeechStoppedEvent{
 					ServerEventBase: types.ServerEventBase{
-						EventBase: types.EventBase{
-							EventID: "event_TODO",
-							Type:    string(types.ServerEventTypeInputAudioBufferSpeechStopped),
-						},
+						EventID: "event_TODO",
 					},
 					AudioEndMs: time.Since(startTime).Milliseconds(),
 				})
 				speechStarted = false
 
 				sendEvent(c, types.InputAudioBufferCommittedEvent{
 					ServerEventBase: types.ServerEventBase{
-						EventBase: types.EventBase{
-							EventID: "event_TODO",
-							Type:    string(types.ServerEventTypeInputAudioBufferCommitted),
-						},
+						EventID: "event_TODO",
 					},
 					ItemID:         generateItemID(),
 					PreviousItemID: "TODO",
@@ -756,10 +729,7 @@ func commitUtterance(ctx context.Context, utt []byte, cfg *config.ModelConfig, e
 		transcript = tr.GetText()
 		sendEvent(c, types.ConversationItemInputAudioTranscriptionCompletedEvent{
 			ServerEventBase: types.ServerEventBase{
-				EventBase: types.EventBase{
-					Type:    string(types.ServerEventTypeConversationItemInputAudioTranscriptionCompleted),
-					EventID: "event_TODO",
-				},
+				EventID: "event_TODO",
 			},
 
 			ItemID: generateItemID(),
@@ -820,11 +790,6 @@ func generateResponse(config *config.ModelConfig, evaluator *templates.Evaluator
 	conv.Lock.Unlock()
 
 	sendEvent(c, types.ConversationItemAddedEvent{
-		ServerEventBase: types.ServerEventBase{
-			EventBase: types.EventBase{
-				Type: string(types.ServerEventTypeConversationItemAdded),
-			},
-		},
 		Item: item,
 	})
 
@@ -888,11 +853,6 @@ func generateResponse(config *config.ModelConfig, evaluator *templates.Evaluator
 	}
 
 	sendEvent(c, types.ConversationItemAddedEvent{
-		ServerEventBase: types.ServerEventBase{
-			EventBase: types.EventBase{
-				Type: string(types.ServerEventTypeConversationItemAdded),
-			},
-		},
 		Item: item,
 	})
 
@@ -973,35 +933,23 @@ func generateResponse(config *config.ModelConfig, evaluator *templates.Evaluator
 	audioString := base64.StdEncoding.EncodeToString(audioBytes)
 
 	sendEvent(c, types.ResponseOutputAudioDeltaEvent{
-		ServerEventBase: types.ServerEventBase{
-			EventBase: types.EventBase{
-				Type: string(types.ServerEventTypeResponseOutputAudioDelta),
-			},
-		},
-		ItemID: item.Assistant.ID,
+		ServerEventBase: types.ServerEventBase{},
+		ItemID:          item.Assistant.ID,
 		// TODO: OutputIndex and ContentIndex
 		Delta: audioString,
 	})
 	sendEvent(c, types.ResponseOutputAudioDoneEvent{
-		ServerEventBase: types.ServerEventBase{
-			EventBase: types.EventBase{
-				Type: string(types.ServerEventTypeResponseOutputAudioDone),
-			},
-		},
-		ItemID: item.Assistant.ID,
+		ServerEventBase: types.ServerEventBase{},
+		ItemID:          item.Assistant.ID,
 		// TODO: Indexs
 	})
 
 	// OpenAI does not send the audio as part of the conversation.
 	// It's sent as audio deltas or the user can request it with conversation.item.retrieve.
 	conv.Lock.Lock()
 	doneEvent := types.ConversationItemDoneEvent{
-		ServerEventBase: types.ServerEventBase{
-			EventBase: types.EventBase{
-				Type: string(types.ServerEventTypeConversationItemDone),
-			},
-		},
-		Item: item,
+		ServerEventBase: types.ServerEventBase{},
+		Item:            item,
 	}
 	item.Assistant.Content[0].Audio = audioString
 	conv.Lock.Unlock()