-
Notifications
You must be signed in to change notification settings - Fork 2
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
Showing
35 changed files
with
584 additions
and
85 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,81 @@ | ||
| #' Chat4R Function with Streaming | ||
| #' | ||
| #' @title chat4R_streaming: Interact with GPT-4o (default) with streaming using OpenAI API | ||
| #' @description This function uses the OpenAI API to interact with the | ||
| #' GPT-4o model (default) and generates responses based on user input with | ||
| #' streaming data back to R | ||
| #' In this function, currently, "gpt-4o-mini", "gpt-4o", and "gpt-4-turbo" | ||
| #' can be selected as OpenAI's LLM model. | ||
| #' @param content A string containing the user's input message. | ||
| #' @param api_key A string containing the user's OpenAI API key. | ||
| #' Defaults to the value of the environment variable "OPENAI_API_KEY". | ||
| #' @param Model A string specifying the GPT model to use (default: "GPT-4o"). | ||
| #' @param temperature A numeric value controlling the randomness of the model's output (default: 1). | ||
| #' @importFrom httr POST add_headers content | ||
| #' @importFrom jsonlite toJSON fromJSON | ||
| #' @return A data frame containing the response from the GPT model. | ||
| #' @export chat4R_streaming | ||
| #' @author Satoshi Kume | ||
| #' @examples | ||
| #' \dontrun{ | ||
| #' Sys.setenv(OPENAI_API_KEY = "Your API key") | ||
| #' response <- chat4R_streaming(content = "What is the capital of France?") | ||
| #' response | ||
| #' } | ||
|
|
||
| chat4R_streaming <- function(content, | ||
| Model = "gpt-4o-mini", | ||
| temperature = 1, | ||
| api_key = Sys.getenv("OPENAI_API_KEY")) { | ||
|
|
||
| # Define parameters | ||
| api_url <- "https://api.openai.com/v1/chat/completions" | ||
| n <- 1 | ||
| top_p <- 1 | ||
|
|
||
| # Configure headers for the API request | ||
| headers <- c(`Content-Type` = "application/json", | ||
| `Authorization` = paste("Bearer", api_key)) | ||
|
|
||
| # Define the body of the API request | ||
| body <- list(model = Model, | ||
| messages = list(list(role = "user", content = content)), | ||
| temperature = temperature, top_p = top_p, n = n, | ||
| stream = TRUE) | ||
|
|
||
| # Function to process streaming data | ||
| streaming_callback <- function(data) { | ||
|
|
||
| #print(data) | ||
| # Convert raw data to character | ||
| message <- rawToChar(data) | ||
| #print(message) | ||
|
|
||
| # Split message into lines | ||
| lines <- unlist(strsplit(message, "\n")) | ||
| #print(lines) | ||
|
|
||
| for (line in lines) { | ||
| if(line == "data: [DONE]"){}else{ | ||
| if(line != ""){ | ||
| # Remove the "data: " prefix | ||
| json_line <- sub("data: ", "", line) | ||
| #print(json_line) | ||
| json <- fromJSON(json_line)$choices$delta$content | ||
| cat(json) | ||
| }}} | ||
| } | ||
|
|
||
| # Perform the request with streaming using httr::write_stream | ||
| response <- httr::POST( | ||
| url = api_url, | ||
| body = body, | ||
| encode = "json", | ||
| httr::add_headers(.headers = headers), | ||
| httr::write_stream(streaming_callback) | ||
| ) | ||
|
|
||
| # Check response status | ||
| #print(response) | ||
|
|
||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,96 @@ | ||
| #' chat4Rv2 Function | ||
| #' | ||
| #' @title chat4Rv2: Interact with gpt-4o-mini (default) using OpenAI API | ||
| #' @description This function uses the OpenAI API to interact with the | ||
| #' gpt-4o-mini model (default) and generates responses based on user input. | ||
| #' In this function, currently, "gpt-4o-mini", "gpt-4o", "gpt-4", "gpt-4-turbo" and "gpt-3.5-turbo" | ||
| #' can be selected as OpenAI's LLM model. | ||
| #' @param content A string containing the user's input message. | ||
| #' @param api_key A string containing the user's OpenAI API key. | ||
| #' Defaults to the value of the environment variable "OPENAI_API_KEY". | ||
| #' @param Model A string specifying the GPT model to use (default: "gpt-4o-mini"). | ||
| #' @param temperature A numeric value controlling the randomness of the model's output (default: 1). | ||
| #' @param simple Logical, if TRUE, only the content of the model's message will be returned. | ||
| #' @param fromJSON_parsed Logical, if TRUE, content will be parsed from JSON. | ||
| #' @param system_set A string containing the system message to set the context. | ||
| #' If provided, it will be added as the first message in the conversation. | ||
| #' Default is an empty string. | ||
| #' @importFrom httr POST add_headers content | ||
| #' @importFrom jsonlite toJSON | ||
| #' @return A data frame containing the response from the GPT model. | ||
| #' @export chat4Rv2 | ||
| #' @author Satoshi Kume | ||
| #' @examples | ||
| #' \dontrun{ | ||
| #' Sys.setenv(OPENAI_API_KEY = "Your API key") | ||
| #' # Using chat4Rv2 without system_set (default behavior) | ||
| #' response <- chat4Rv2(content = "What is the capital of France?") | ||
| #' response | ||
| #' | ||
| #' # Using chat4Rv2 with a system_set provided | ||
| #' response <- chat4Rv2(content = "What is the capital of France?", | ||
| #' system_set = "You are a helpful assistant.") | ||
| #' response | ||
| #' } | ||
|
|
||
|
|
||
| chat4Rv2 <- function(content, | ||
| Model = "gpt-4o-mini", | ||
| temperature = 1, | ||
| simple = TRUE, | ||
| fromJSON_parsed = FALSE, | ||
| system_set = "", | ||
| api_key = Sys.getenv("OPENAI_API_KEY")) { | ||
|
|
||
| # Define parameters | ||
| api_url <- "https://api.openai.com/v1/chat/completions" | ||
| n <- 1 | ||
| top_p <- 1 | ||
|
|
||
| # Configure headers for the API request | ||
| headers <- httr::add_headers(`Content-Type` = "application/json", | ||
| `Authorization` = paste("Bearer", api_key)) | ||
|
|
||
| # Construct messages list depending on system_set parameter | ||
| if (nzchar(system_set)) { | ||
| # Include system message if provided | ||
| messages_list <- list( | ||
| list(role = "system", content = system_set), | ||
| list(role = "user", content = content) | ||
| ) | ||
| } else { | ||
| # Only include user message if system_set is empty | ||
| messages_list <- list( | ||
| list(role = "user", content = content) | ||
| ) | ||
| } | ||
|
|
||
| # Define the body of the API request | ||
| body <- list(model = Model, | ||
| messages = messages_list, | ||
| temperature = temperature, | ||
| top_p = top_p, | ||
| n = n) | ||
|
|
||
| # Send a POST request to the OpenAI server | ||
| response <- httr::POST(url = api_url, | ||
| body = jsonlite::toJSON(body, auto_unbox = TRUE), | ||
| encode = "json", | ||
| config = headers) | ||
|
|
||
| # Extract and return the response content | ||
| if (simple) { | ||
| return(data.frame(content = httr::content(response, "parsed")$choices[[1]]$message$content)) | ||
| } else { | ||
| if (fromJSON_parsed) { | ||
| raw_content <- httr::content(response, "raw") | ||
| char_content <- rawToChar(raw_content) | ||
| parsed_data <- jsonlite::fromJSON(char_content) | ||
| return(parsed_data) | ||
| } else { | ||
| return(data.frame(httr::content(response, "parsed"))) | ||
| } | ||
| } | ||
| } | ||
|
|
||
|
|
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.