Compare commits

..

2 Commits

Author SHA1 Message Date
7cb2a4e017 Parameterize maxTokens 2023-11-05 18:29:57 +00:00
0c2149663f Formatting/comments 2023-11-05 18:19:30 +00:00
3 changed files with 22 additions and 24 deletions

View File

@ -7,6 +7,9 @@ import (
"github.com/spf13/cobra"
)
// TODO: allow setting with flag
const MAX_TOKENS = 256
var rootCmd = &cobra.Command{
Use: "lmcli",
Short: "Interact with Large Language Models",
@ -112,7 +115,6 @@ var newCmd = &cobra.Command{
ConversationID: conversation.ID,
Role: "assistant",
}
reply.RenderTTY(false)
receiver := make(chan string)
@ -120,7 +122,8 @@ var newCmd = &cobra.Command{
go func() {
response <- HandleDelayedResponse(receiver)
}()
err = CreateChatCompletionStream(messages, receiver)
err = CreateChatCompletionStream(messages, MAX_TOKENS, receiver)
if err != nil {
Fatal("%v\n", err)
}
@ -160,7 +163,7 @@ var promptCmd = &cobra.Command{
receiver := make(chan string)
go HandleDelayedResponse(receiver)
err := CreateChatCompletionStream(messages, receiver)
err := CreateChatCompletionStream(messages, MAX_TOKENS, receiver)
if err != nil {
Fatal("%v\n", err)
}

View File

@ -8,7 +8,7 @@ import (
openai "github.com/sashabaranov/go-openai"
)
func CreateChatCompletionRequest(messages []Message) *openai.ChatCompletionRequest {
func CreateChatCompletionRequest(messages []Message, maxTokens int) openai.ChatCompletionRequest {
chatCompletionMessages := []openai.ChatCompletionMessage{}
for _, m := range messages {
chatCompletionMessages = append(chatCompletionMessages, openai.ChatCompletionMessage{
@ -17,23 +17,19 @@ func CreateChatCompletionRequest(messages []Message) *openai.ChatCompletionReque
})
}
return &openai.ChatCompletionRequest{
Model: openai.GPT4,
MaxTokens: 256,
return openai.ChatCompletionRequest{
Model: openai.GPT3Dot5Turbo,
Messages: chatCompletionMessages,
Stream: true,
MaxTokens: maxTokens,
}
}
// CreateChatCompletion accepts a slice of Message and returns the response
// of the Large Language Model.
func CreateChatCompletion(messages []Message) (string, error) {
// CreateChatCompletion submits a Chat Completion API request and returns the
// response.
func CreateChatCompletion(messages []Message, maxTokens int) (string, error) {
client := openai.NewClient(config.OpenAI.APIKey)
resp, err := client.CreateChatCompletion(
context.Background(),
*CreateChatCompletionRequest(messages),
)
req := CreateChatCompletionRequest(messages, maxTokens)
resp, err := client.CreateChatCompletion(context.Background(), req)
if err != nil {
return "", err
}
@ -41,18 +37,15 @@ func CreateChatCompletion(messages []Message) (string, error) {
return resp.Choices[0].Message.Content, nil
}
// CreateChatCompletionStream submits an streaming Chat Completion API request
// and sends the received data to the output channel.
func CreateChatCompletionStream(messages []Message, output chan string) error {
// CreateChatCompletionStream submits a streaming Chat Completion API request
// and streams the received response to the provided output channel.
func CreateChatCompletionStream(messages []Message, maxTokens int, output chan string) error {
client := openai.NewClient(config.OpenAI.APIKey)
ctx := context.Background()
req := CreateChatCompletionRequest(messages)
req.Stream = true
req := CreateChatCompletionRequest(messages, maxTokens)
defer close(output)
stream, err := client.CreateChatCompletionStream(ctx, *req)
stream, err := client.CreateChatCompletionStream(context.Background(), req)
if err != nil {
return err
}

View File

@ -45,7 +45,9 @@ func HandleDelayedResponse(response chan string) string {
firstChunk := true
for chunk := range response {
if firstChunk {
// notify wait animation that we've received data
waitSignal <- ""
// wait for signal that wait animation has completed
<-waitSignal
firstChunk = false
}