MCPcopy Create free account

hub / github.com/asynkor/asynkor / functions

Functions259 in github.com/asynkor/asynkor

⨍ Functions 259◇ Types & classes 55
↓ 93 callersFunctiontoolError
(msg string)
mcp/internal/mcpserver/tools.go:71
↓ 42 callersMethodClose
()
mcp/internal/natsbus/client.go:63
↓ 28 callersFunctionctxForMode
(sessID, mode string)
mcp/internal/mcpserver/handlers_overlap_test.go:14
↓ 28 callersFunctionresultText
(t *testing.T, r *mcp.CallToolResult)
mcp/internal/mcpserver/handlers_session_test.go:92
↓ 27 callersMethodGet
(ctx context.Context, teamID string)
mcp/internal/teamctx/store.go:129
↓ 27 callersFunctioncallStartWithArgs
(t *testing.T, srv *Server, ctx context.Context, args map[string]any)
mcp/internal/mcpserver/handlers_overlap_test.go:28
↓ 24 callersFunctiontoolJSON
(v any)
mcp/internal/mcpserver/tools.go:66
↓ 22 callersFunctiongetArgString
(req mcp.CallToolRequest, key, defaultVal string)
mcp/internal/mcpserver/tools.go:1063
↓ 21 callersFunctionnewTestServer
newTestServer wires a *Server backed by miniredis and no-op nats/teamctx. It is deliberately minimal — the fake teamctx URL is unreachable, so Persist
mcp/internal/mcpserver/handlers_session_test.go:26
↓ 20 callersMethodStart
(ctx context.Context, teamID, sessionID, hostname, plan string, plannedPaths []string)
mcp/internal/work/store.go:167
↓ 19 callersFunctiongetAuthError
(ctx context.Context)
mcp/internal/mcpserver/server.go:604
↓ 19 callersFunctiongetTeam
(ctx context.Context)
mcp/internal/mcpserver/server.go:584
↓ 15 callersMethodListActive
(ctx context.Context, teamID string)
mcp/internal/work/store.go:283
↓ 13 callersFunctiondirExists
(p: string)
client/src/install.ts:70
↓ 13 callersFunctiongetSessionID
(ctx context.Context)
mcp/internal/mcpserver/server.go:594
↓ 13 callersMethodworkKey
(teamID, workID string)
mcp/internal/work/store.go:105
↓ 12 callersMethodGetBySession
(ctx context.Context, teamID, sessionID string)
mcp/internal/work/store.go:264
↓ 11 callersFunctionnewTestStore
(t *testing.T)
mcp/internal/work/store_test.go:14
↓ 11 callersFunctionparseFlags
(args: string[])
client/src/cli.ts:14
↓ 10 callersMethodValidate
Validate returns the full KeyContext. For team-scoped keys Teams has one entry and DefaultTeamID matches it; for user-scoped keys Teams lists every te
mcp/internal/auth/validator.go:75
↓ 10 callersMethodactiveSetKey
(teamID string)
mcp/internal/work/store.go:109
↓ 10 callersFunctionisValidUUID
(s string)
mcp/internal/mcpserver/tools.go:26
↓ 9 callersMethodList
(ctx context.Context, teamID string)
mcp/internal/session/store.go:91
↓ 9 callersMethodclose
()
client/src/proxy.ts:624
↓ 8 callersMethodComplete
(ctx context.Context, teamID, workID, result string, followups []Followup)
mcp/internal/work/store.go:224
↓ 8 callersMethodCreate
(ctx context.Context, sess *Session, heartbeatInterval int)
mcp/internal/session/store.go:38
↓ 8 callersFunctioninjectZones
injectZones pre-populates the teamctx cache for the test team. The fake teamctx Store points at an unreachable URL in newTestServer, so without this s
mcp/internal/mcpserver/handlers_zone_test.go:16
↓ 7 callersFunctiongetHostname
(ctx context.Context)
mcp/internal/mcpserver/server.go:599
↓ 7 callersFunctionpathMatchesAny
(filePath string, patterns []string)
mcp/internal/mcpserver/tools.go:1032
↓ 6 callersMethodAllOpenFollowups
(ctx context.Context, teamID string)
mcp/internal/work/store.go:506
↓ 6 callersFunctionNewValidator
(javaURL, internalToken string)
mcp/internal/auth/validator.go:30
↓ 6 callersMethodTakeFollowup
(ctx context.Context, teamID, followupID, workID string)
mcp/internal/work/store.go:199
↓ 6 callersMethodcheckConfigReload
* checkConfigReload re-reads the config from disk (at most once per * CONFIG_CHECK_INTERVAL_MS) and reconnects the SSE client if the API * key o
client/src/proxy.ts:164
↓ 6 callersFunctionfindAsynkorJson
(startDir: string)
client/src/config.ts:54
↓ 6 callersFunctionnewTestStore
(t *testing.T)
mcp/internal/session/store_test.go:12
↓ 6 callersFunctionrelativeTime
(ts string)
mcp/internal/mcpserver/tools.go:30
↓ 6 callersMethodsessionWorkKey
(teamID, sessionID string)
mcp/internal/work/store.go:121
↓ 5 callersMethodListRecent
(ctx context.Context, teamID string, limit int)
mcp/internal/work/store.go:303
↓ 5 callersMethodactiveSetKey
(teamID string)
mcp/internal/lease/store.go:40
↓ 5 callersMethodconnectToGoServer
()
client/src/proxy.ts:105
↓ 5 callersFunctiongetenv
(key, fallback string)
mcp/config/config.go:23
↓ 5 callersMethodleaseKey
(teamID, path string)
mcp/internal/lease/store.go:36
↓ 5 callersFunctionmergeMcpServers
* Common path for every IDE that consumes the standard `mcpServers: {...}` * shape (Cursor, Windsurf, Claude Code's `~/.claude.json`, etc.).
client/src/install.ts:90
↓ 5 callersMethodparkedListKey
(teamID string)
mcp/internal/work/store.go:117
↓ 5 callersFunctionresolveAllTeams
()
client/src/config.ts:186
↓ 5 callersFunctionresolveTeamSlug
(flags: Record<string, string>, ctx: ApiContext)
client/src/cli.ts:1083
↓ 4 callersMethodAcquireMany
(ctx context.Context, teamID string, paths []string, workID, sessionID, hostname, plan string)
mcp/internal/lease/store.go:100
↓ 4 callersMethodPublish
(teamID, event string, data any)
mcp/internal/natsbus/client.go:34
↓ 4 callersMethodReleaseByWork
(ctx context.Context, teamID, workID string)
mcp/internal/lease/store.go:131
↓ 4 callersFunctionblockedPayload
(blocked []lease.BlockedLease)
mcp/internal/mcpserver/tools.go:1381
↓ 4 callersFunctioncallStart
(t *testing.T, srv *Server, ctx context.Context, plan string)
mcp/internal/mcpserver/handlers_session_test.go:68
↓ 4 callersFunctionctxFor
ctxFor builds a handler context as if makeContextFunc had just run for a POST /message with the given stable sessID.
mcp/internal/mcpserver/handlers_session_test.go:54
↓ 4 callersFunctionparseCSV
(raw string)
mcp/internal/mcpserver/tools.go:1179
↓ 4 callersMethodsessionsSetKey
(teamID string)
mcp/internal/session/store.go:34
↓ 4 callersMethodworkLeasesKey
(teamID, workID string)
mcp/internal/lease/store.go:44
↓ 3 callersMethodDelete
(ctx context.Context, teamID, sessionID string)
mcp/internal/session/store.go:52
↓ 3 callersMethodGetByID
(ctx context.Context, teamID, workID string)
mcp/internal/work/store.go:406
↓ 3 callersMethodPark
(ctx context.Context, teamID, workID, progress, notes string)
mcp/internal/work/store.go:321
↓ 3 callersMethodactiveTeamKey
Active team override for user-scoped keys. Keyed globally (not per team) because the whole point is letting a session switch between teams without rec
mcp/internal/session/store.go:67
↓ 3 callersFunctionask
(q: string)
client/src/cli.ts:629
↓ 3 callersMethodconflictsKey
(teamID string)
mcp/internal/work/store.go:129
↓ 3 callersFunctionfileExists
(p: string)
client/src/install.ts:78
↓ 3 callersFunctioninitConfig
(options: { apiKey: string; serverUrl?: string; team?: string })
client/src/config.ts:125
↓ 3 callersFunctionmockJavaServer
mockJavaServer simulates Java's /internal/validate-key endpoint.
mcp/integration_test.go:20
↓ 3 callersFunctionreadApiContext
()
client/src/cli.ts:1026
↓ 3 callersFunctionsanitizeHeader
sanitizeHeader truncates a header value and strips control characters to prevent log injection and other attacks via agent-supplied headers.
mcp/internal/mcpserver/server.go:622
↓ 3 callersMethodscheduleReconnect
()
client/src/proxy.ts:123
↓ 3 callersMethodsessionKey
(teamID, sessionID string)
mcp/internal/session/store.go:30
↓ 3 callersMethodtakenKey
(teamID string)
mcp/internal/work/store.go:125
↓ 3 callersFunctionupdateClaudeSettings
()
client/src/cli.ts:346
↓ 3 callersFunctionwriteClaudeMd
(content: string)
client/src/cli.ts:276
↓ 3 callersFunctionwriteSlashCommands
()
client/src/cli.ts:333
↓ 2 callersMethodCancel
Cancel removes a work item from the active set, the parked list, and deletes its data. Used for manual cleanup of stale/orphaned work items and auto-c
mcp/internal/work/store.go:453
↓ 2 callersMethodFindTeam
FindTeam returns the TeamContext matching id, or nil.
mcp/internal/auth/types.go:28
↓ 2 callersMethodFollowupTaker
FollowupTaker returns the work ID that currently holds the given followup, or empty string if it is not taken. Used to tell an agent who already has t
mcp/internal/work/store.go:213
↓ 2 callersMethodGetFileContexts
GetFileContexts returns stored file context for paths that have it.
mcp/internal/lease/store.go:264
↓ 2 callersMethodListAll
(ctx context.Context, teamID string)
mcp/internal/lease/store.go:166
↓ 2 callersMethodPersistWork
(teamID string, w *work.Work)
mcp/internal/teamctx/store.go:312
↓ 2 callersMethodRecordConflict
RecordConflict appends one or more conflict events to the team's feed, capped at 100 entries.
mcp/internal/work/store.go:150
↓ 2 callersMethodRecordEvent
(ctx context.Context, teamID string, event Event)
mcp/internal/activity/store.go:36
↓ 2 callersMethodThreadInbox
(teamID, workID, hostname string)
mcp/internal/teamctx/store.go:480
↓ 2 callersFunctionaddTeamToConfig
(team: { slug: string; name?: string; apiKey: string; serverUrl?: string; context?: string; refreshToken?: str
client/src/config.ts:258
↓ 2 callersFunctioncallFinish
(t *testing.T, srv *Server, ctx context.Context, result string)
mcp/internal/mcpserver/handlers_session_test.go:80
↓ 2 callersFunctionconflictPayload
(overlaps []overlapEntry)
mcp/internal/mcpserver/tools.go:1226
↓ 2 callersMethodfileContextKey
(teamID, path string)
mcp/internal/lease/store.go:250
↓ 2 callersFunctiongetKey
(ctx context.Context)
mcp/internal/mcpserver/server.go:589
↓ 2 callersMethodhandleCheck
(ctx context.Context, req mcp.CallToolRequest)
mcp/internal/mcpserver/tools.go:761
↓ 2 callersMethodhandleStart
(ctx context.Context, req mcp.CallToolRequest)
mcp/internal/mcpserver/tools.go:369
↓ 2 callersFunctioninstallAllIdes
(apiKey: string, team?: string)
client/src/install.ts:253
↓ 2 callersFunctionparseJsonTeams
(json: AsynkorJson, serverUrlFallback: string)
client/src/config.ts:165
↓ 2 callersFunctionparseWorkIDSet
(raw string)
mcp/internal/mcpserver/tools.go:1195
↓ 2 callersFunctionprintHelp
()
client/src/cli.ts:1233
↓ 2 callersFunctionprintInstallSummary
(summary: InstallSummary)
client/src/install.ts:285
↓ 2 callersMethodrecentListKey
(teamID string)
mcp/internal/work/store.go:113
↓ 2 callersMethodrecordConflictEvent
(ctx context.Context, teamID, newWorkID, sessID, hostname, plan string, overlaps []overlapEntry, mode string,
mcp/internal/mcpserver/tools.go:1354
↓ 2 callersFunctionsetActiveTeamInConfig
(slug: string)
client/src/config.ts:349
↓ 2 callersFunctionsetupFromJoinLink
(url: string)
client/src/cli.ts:662
↓ 2 callersFunctionsignificantWords
significantWords extracts the non-trivial lowercase word set from a string. Punctuation is stripped, words ≤ 3 chars or in stopwords are dropped.
mcp/internal/mcpserver/tools.go:1108
↓ 2 callersFunctionteamFromResponse
(t validateKeyTeam)
mcp/internal/auth/validator.go:188
↓ 2 callersFunctionteamIDFromSubject
teamIDFromSubject extracts the team ID from a NATS subject of the form "asynkor.team.<TEAM_ID>.<EVENT_PARTS...>". Returns "" if the subject is not in
mcp/internal/mcpserver/server.go:612
next →1–100 of 259, ranked by callers