tristan/ZealOS
1
0
Fork 0
mirror of https://github.com/Zeal-Operating-System/ZealOS.git synced 2024-12-25 15:10:28 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

freeing memory

Browse source
This commit is contained in:
y4my4my4m 2023-08-24 14:28:21 +09:00
parent f4cf93c43d
commit 85fe748331
1 changed files with 9 additions and 41 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

50
src/Home/Net/Programs/Skynet/Skynet.ZC
View file

@ -1,11 +1,11 @@
#define SERVER_ADDR "skynet.middleware.com" #define SERVER_ADDR "skynet.middleware.com"
#define SERVER_PORT 9000 #define SERVER_PORT 9000
#define INITIAL_BUF_SIZE 8192 #define INITIAL_BUF_SIZE 2048
#define DEFAULT_SYSTEMPROMPT "You are a helpful assistant but roleplay as skynet from Terminator." #define DEFAULT_SYSTEMPROMPT "You are a helpful assistant but roleplay as skynet from Terminator."
#include "::/Home/Net/Utilities/JSON/JSON" #include "::/Home/Net/Utilities/JSON/JSON"
class Message { class Message {
U8 role[10]; // "user" or "assistant" U8 role[10]; // "user" or "assistant"
U8 content[1048]; U8 content[1024];
} history[100]; } history[100];
I64 currentHistoryCount = 0; I64 currentHistoryCount = 0;
@ -17,26 +17,6 @@ U0 AppendToHistory(U8 *role, U8 *content) {
} }
} }
U8* ParseCompletion(U8 *response)
{
U8 *start = StrFind("\"content\": \"", response);
if (!start)
{
return NULL; // Pattern not found
}
start += 12; // Move pointer after '"content": "'
U8 *end = StrFind("\"", start); // Find the closing double quote
if (!end)
{
return NULL;
}
*end = 0; // Null terminate the completion string
return start;
}
U8 *StrChr(U8 *Str,U8 Pivot) U8 *StrChr(U8 *Str,U8 Pivot)
{ {
//U8 *Orig=Str; //U8 *Orig=Str;
@ -70,15 +50,15 @@ I64 Skynet(U8 *message, U8 *system, U8 *model)
for (index = 0; index < currentHistoryCount; index++) { for (index = 0; index < currentHistoryCount; index++) {
U8 *msg = StrPrint(NULL, "{\"role\": \"%s\",\"content\": \"%s\"},", history[index].role, history[index].content); U8 *msg = StrPrint(NULL, "{\"role\": \"%s\",\"content\": \"%s\"},", history[index].role, history[index].content);
messages = CatPrint(messages, msg); messages = CatPrint(messages, msg);
// Free(msg); Free(msg);
} }
U8 *currentUserMsg = StrPrint(NULL, "{\"role\": \"user\",\"content\": \"%s\"}", message); U8 *currentUserMsg = StrPrint(NULL, "{\"role\": \"user\",\"content\": \"%s\"}", message);
messages = CatPrint(messages, currentUserMsg); messages = CatPrint(messages, currentUserMsg);
// Free(currentUserMsg); Free(currentUserMsg);
U8 *payload = StrPrint(NULL, "{\"model\": \"%s\",\"messages\": [%s]}", model, messages); U8 *payload = StrPrint(NULL, "{\"model\": \"%s\",\"messages\": [%s]}", model, messages);
// Free(messages); Free(messages);
//SysLog(payload); //SysLog(payload);
@ -98,9 +78,9 @@ I64 Skynet(U8 *message, U8 *system, U8 *model)
U8 *fullRequest = StrPrint(NULL, "%s%s", requestHeader, payload); U8 *fullRequest = StrPrint(NULL, "%s%s", requestHeader, payload);
TCPSocketSendString(sock, fullRequest); TCPSocketSendString(sock, fullRequest);
// Free(requestHeader); Free(requestHeader);
// Free(payload); Free(payload);
// Free(fullRequest); Free(fullRequest);
I64 responseLength = TCPSocketReceive(sock, responseBuf, bufferSize - 1); I64 responseLength = TCPSocketReceive(sock, responseBuf, bufferSize - 1);
responseBuf[responseLength] = 0; // Null-terminate the buffer for safety responseBuf[responseLength] = 0; // Null-terminate the buffer for safety
@ -120,20 +100,8 @@ I64 Skynet(U8 *message, U8 *system, U8 *model)
responseLength += TCPSocketReceive(sock, responseBuf + responseLength, bufferSize - responseLength - 1); responseLength += TCPSocketReceive(sock, responseBuf + responseLength, bufferSize - responseLength - 1);
responseBuf[responseLength] = 0; responseBuf[responseLength] = 0;
} }
//SysLog(responseBuf); //SysLog(responseBuf);
//U8 *jsonPayload = StrFind("\r\n\r\n", responseBuf);
//if (!jsonPayload) {
// PrintErr("Warning: bad Json payload.");
// TCPSocketClose(sock);
// return -1;
//}
//jsonPayload += 4;
// U8 *completion = ParseCompletion(jsonPayload);
// U8 *completion = JSONKeyValueGet(RemoveBeforeJSON(responseBuf), "content");
CCompCtrl *cc = CompCtrlNew(MStrPrint("%s", RemoveBeforeJSON(responseBuf))); CCompCtrl *cc = CompCtrlNew(MStrPrint("%s", RemoveBeforeJSON(responseBuf)));
CJSONDataEntry *jsonData = JSONParse(cc); CJSONDataEntry *jsonData = JSONParse(cc);
@ -166,7 +134,7 @@ I64 Skynet(U8 *message, U8 *system, U8 *model)
} }
U8 *completion = contentEntry->string_data; U8 *completion = contentEntry->string_data;
SysLog(completion); //SysLog(completion);
CompCtrlDel(cc); CompCtrlDel(cc);
"\n$$RED$$ Skynet: $$YELLOW$$%s$$FG$$\n", completion; "\n$$RED$$ Skynet: $$YELLOW$$%s$$FG$$\n", completion;