Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/cedriking/spark
/ functions
Functions
95 in github.com/cedriking/spark
⨍
Functions
95
◇
Types & classes
46
↓ 10 callers
Method
get
(key: string)
src/store/index.ts:2
↓ 9 callers
Method
set
(key: string, value: T)
src/store/index.ts:3
↓ 8 callers
Function
countTokens
(text: string)
src/util.ts:33
↓ 7 callers
Function
checkPath
( agentId: string, path: string, sendMessage: (message: any) => void )
src/module/definitions/filesystem.ts:181
↓ 6 callers
Function
defineModule
(inputs1: ModuleDefinitionInputs1<S>)
src/module/define-module.ts:9
↓ 5 callers
Function
agentName
(agentId: string)
src/util.ts:24
↓ 4 callers
Method
mkdirs
()
src/store/file-store.ts:53
↓ 4 callers
Method
send
(message: Message)
src/message-bus.ts:6
↓ 4 callers
Method
subscribe
(listener: (message: Message) => void)
src/message-bus.ts:4
↓ 3 callers
Method
delete
(key: string)
src/store/index.ts:4
↓ 3 callers
Function
getUsageText
(actionDef: ActionDefinition)
src/module/util.ts:4
↓ 3 callers
Method
pathFor
(key: string)
src/store/file-store.ts:57
↓ 2 callers
Method
append
(event: Event)
src/memory/memory.ts:23
↓ 2 callers
Function
checkExists
(path: string)
src/store/file-store.ts:66
↓ 2 callers
Function
createChatCompletion
(request: { messages: ChatGPTMessage[]; temperature?: number; })
src/openai.ts:7
↓ 2 callers
Method
getKeys
()
src/store/index.ts:5
↓ 2 callers
Function
makeDecision
(events: Event[])
src/make-decision.ts:6
↓ 2 callers
Function
messageSourceName
(source: MessageSource)
src/util.ts:20
↓ 2 callers
Method
retrieve
()
src/memory/memory.ts:39
↓ 2 callers
Method
summarize
* Compress the event history when it becomes too large in order to free up the context window.
src/memory/memory.ts:101
↓ 2 callers
Function
toOpenAiMessage
(event: Event)
src/make-decision.ts:27
↓ 1 callers
Function
addMessageTypes
(record: T)
src/message.ts:54
↓ 1 callers
Function
agentSource
(id: string)
src/message.ts:29
↓ 1 callers
Function
cuid
()
src/services/ChatGPT.ts:198
↓ 1 callers
Function
decodeFilename
(filename: string)
src/store/file-store.ts:100
↓ 1 callers
Function
encodeFilename
(filename: string)
src/store/file-store.ts:89
↓ 1 callers
Method
getCompletion
( payload: OpenAIStreamPayload = this.payload )
src/services/ChatGPT.ts:169
↓ 1 callers
Method
getCumulativeTokenCounts
(events: Event[])
src/memory/memory.ts:188
↓ 1 callers
Method
getIntroduction
()
src/memory/memory.ts:55
↓ 1 callers
Method
getModels
()
src/services/ChatGPT.ts:52
↓ 1 callers
Method
getModuleForAction
(name: string)
src/module/module-manager.ts:34
↓ 1 callers
Function
getPageSummary
(maxSummaryTokens: number, url: string)
src/module/definitions/web.ts:93
↓ 1 callers
Function
getSearchResults
(searchString: string)
src/module/definitions/web.ts:84
↓ 1 callers
Method
handle
(agentId: string, { actionDef, parameters }: Action)
src/action-handler.ts:12
↓ 1 callers
Function
main
()
src/main.ts:29
↓ 1 callers
Function
parseAction
( actionDictionary: Map<string, ActionDefinition>, text: string )
src/parse-action.ts:19
↓ 1 callers
Function
pinnedMessage
({ state })
src/module/definitions/goals.ts:18
↓ 1 callers
Method
printEvent
(event: Event)
src/memory/memory.ts:200
↓ 1 callers
Method
removeErrors
(events: Event[])
src/memory/memory.ts:76
↓ 1 callers
Method
run
(task: Task<T>)
src/task-queue.ts:12
↓ 1 callers
Method
runNext
()
src/task-queue.ts:41
↓ 1 callers
Method
runPeriodically
(task: Task, milliseconds: number)
src/task-queue.ts:19
↓ 1 callers
Method
sendRequestToOpenAI
( messages: ChatGPTMessage[], temperature?: number, onProgress?: (partialResponse: string, message
src/services/ChatGPT.ts:80
↓ 1 callers
Function
sleep
(milliseconds: number)
src/util.ts:4
↓ 1 callers
Method
start
()
src/agent.ts:27
↓ 1 callers
Function
startConsole
(agentIds: string[], messageBus: MessageBus)
src/console.ts:13
↓ 1 callers
Method
takeAction
()
src/agent.ts:53
↓ 1 callers
Method
unsubscribe
(listener: (message: Message) => void)
src/message-bus.ts:5
↓ 1 callers
Function
webSocketServer
(messageBus: MessageBus, port: number)
src/web-socket-server.ts:4
Method
constructor
()
src/redis-message-bus.ts:10
Method
constructor
()
src/in-memory-message-bus.ts:8
Method
constructor
( public id: string, private memory: Memory, private messageBus: MessageBus, private moduleMan
src/agent.ts:16
Method
constructor
( private agentIds: string[], private messageBus: MessageBus, private moduleManager: ModuleManager
src/action-handler.ts:6
Method
constructor
( private moduleManager: ModuleManager, public moduleDef: ModuleDefinition<S, A> )
src/module/module-instance.ts:7
Method
constructor
( public agentId: string, public allAgentIds: string[], moduleDefinitions: ModuleDefinition[] )
src/module/module-manager.ts:10
Method
constructor
( private agentId: string, private moduleManager: ModuleManager, private store: Store<Event[]>,
src/memory/memory.ts:16
Method
constructor
(private stringStore: Store<string>)
src/store/json-store.ts:4
Method
constructor
(private namespaces: string[])
src/store/file-store.ts:8
Method
constructor
()
src/services/ChatGPT.ts:48
Method
context
()
src/module/module-instance.ts:22
Function
countTokens
(event: Event)
src/memory/memory.ts:219
Function
decodeChar
(encodedChar: string)
src/store/file-store.ts:85
Method
delete
(key: string)
src/store/json-store.ts:15
Method
delete
(key: string)
src/store/file-store.ts:24
Method
delete
(key: string)
src/store/in-memory-store.ts:14
Method
dirPath
()
src/store/file-store.ts:61
Function
encodeChar
(char: string)
src/store/file-store.ts:81
Function
execute
({ parameters: { goal }, context: { agentId, state }, sendMessage, })
src/module/definitions/goals.ts:43
Function
execute
({ parameters: { path }, context: { agentId }, sendMessage, })
src/module/definitions/filesystem.ts:25
Function
execute
()
src/module/definitions/core.ts:84
Function
execute
({ parameters: { searchString }, context: { agentId }, sendMessage, })
src/module/definitions/web.ts:24
Function
execute
({ parameters: { title, content }, context: { agentId, state }, sendMessage, })
src/module/definitions/notes.ts:34
Function
execute
({ context: { agentId, allAgentIds }, sendMessage })
src/module/definitions/messaging.ts:11
Method
get
(key: string)
src/store/json-store.ts:6
Method
get
(key: string)
src/store/file-store.ts:10
Method
get
(key: string)
src/store/in-memory-store.ts:6
Method
getKeys
()
src/store/json-store.ts:19
Method
getKeys
()
src/store/file-store.ts:33
Method
getKeys
()
src/store/in-memory-store.ts:18
Method
key
()
src/memory/memory.ts:196
Method
length
()
src/task-queue.ts:8
Function
pinnedMessage
({ state })
src/module/definitions/notes.ts:10
Method
send
(message: Message)
src/redis-message-bus.ts:29
Method
send
(message: Message)
src/in-memory-message-bus.ts:20
Method
set
(key: string, value: T)
src/store/json-store.ts:11
Method
set
(key: string, value: string)
src/store/file-store.ts:19
Method
set
(key: string, value: string)
src/store/in-memory-store.ts:10
Function
singleTargetSystemMessage
( agentId: string, content: string )
src/message.ts:66
Function
sleepUntil
(condition: () => boolean)
src/util.ts:8
Method
state
()
src/module/module-instance.ts:12
Method
stop
()
src/task-queue.ts:32
Method
subscribe
(listener: (message: Message) => void)
src/redis-message-bus.ts:15
Method
subscribe
(listener: (message: Message) => void)
src/in-memory-message-bus.ts:12
Method
unsubscribe
(listener: (message: Message) => void)
src/redis-message-bus.ts:24
Method
unsubscribe
(listener: (message: Message) => void)
src/in-memory-message-bus.ts:16