MCPcopy Create free account

hub / github.com/asynkor/asynkor / functions

Functions259 in github.com/asynkor/asynkor

⨍ Functions 259◇ Types & classes 55
↓ 2 callersFunctionwriteUserConfig
(options: { apiKey: string; serverUrl?: string; team?: string })
client/src/config.ts:142
↓ 2 callersFunctionzonePayload
(hits zoneHits)
mcp/internal/mcpserver/tools.go:1333
↓ 1 callersMethodAcquire
(ctx context.Context, teamID, path, workID, sessionID, hostname, plan string)
mcp/internal/lease/store.go:65
↓ 1 callersMethodCheckPaths
(ctx context.Context, teamID string, paths []string)
mcp/internal/lease/store.go:147
↓ 1 callersMethodCleanupStale
(ctx context.Context, teamID string, maxAge time.Duration)
mcp/internal/work/store.go:421
↓ 1 callersMethodClearActiveTeam
(ctx context.Context, sessionID string)
mcp/internal/session/store.go:87
↓ 1 callersMethodCreateMemory
(teamID, content string, paths, tags []string, agentSession string)
mcp/internal/teamctx/store.go:246
↓ 1 callersMethodDeleteMemory
(teamID, memoryID string)
mcp/internal/teamctx/store.go:282
↓ 1 callersMethodGetActiveTeam
(ctx context.Context, sessionID string)
mcp/internal/session/store.go:71
↓ 1 callersMethodGetRelevantContext
(teamID string, paths []string)
mcp/internal/teamctx/store.go:609
↓ 1 callersMethodGetThread
(teamID, threadID string)
mcp/internal/teamctx/store.go:515
↓ 1 callersMethodListParked
(ctx context.Context, teamID string)
mcp/internal/work/store.go:353
↓ 1 callersFunctionNew
( cfg *config.Config, validator *auth.Validator, sessionStore *session.Store, workStore *work.Store, leas
mcp/internal/mcpserver/server.go:49
↓ 1 callersFunctionNewStore
(r *redis.Client)
mcp/internal/work/store.go:55
↓ 1 callersFunctionNewStore
(r *redis.Client)
mcp/internal/session/store.go:26
↓ 1 callersMethodOpenThread
(teamID, openerWorkID, openerHost, targetKind, targetValue, topic, body string, contextPaths []string)
mcp/internal/teamctx/store.go:441
↓ 1 callersMethodReplyThread
(teamID, threadID, authorWorkID, authorHost, body string, close bool)
mcp/internal/teamctx/store.go:545
↓ 1 callersMethodResumeParked
(ctx context.Context, teamID, workID, newSessionID, newHostname string)
mcp/internal/work/store.go:368
↓ 1 callersMethodSetActiveTeam
(ctx context.Context, sessionID, teamID string, heartbeatInterval int)
mcp/internal/session/store.go:79
↓ 1 callersMethodSetCacheForTest
SetCacheForTest pre-populates the in-memory cache for a team. It exists so handler tests can inject rules / zones / memories without standing up a fak
mcp/internal/teamctx/store.go:123
↓ 1 callersMethodSetFileContext
SetFileContext stores what an agent did to a file, for the next acquirer.
mcp/internal/lease/store.go:255
↓ 1 callersMethodStart
()
mcp/internal/mcpserver/server.go:71
↓ 1 callersMethodSubscribe
(subject string, handler func(subject string, data []byte))
mcp/internal/natsbus/client.go:50
↓ 1 callersMethodUpdateProjectContext
(teamID, content, summary, agentSession string)
mcp/internal/teamctx/store.go:205
↓ 1 callersMethodWaitAndAcquire
(ctx context.Context, teamID string, paths []string, workID, sessionID, hostname, plan string, timeout time.Du
mcp/internal/lease/store.go:186
↓ 1 callersMethodactivityKey
(teamID string)
mcp/internal/activity/store.go:32
↓ 1 callersFunctionallAcknowledged
allAcknowledged returns true iff every overlapping work ID is present in the caller-supplied acknowledgement set. Partial acknowledgement is not accep
mcp/internal/mcpserver/tools.go:1211
↓ 1 callersFunctionallZonesAcknowledged
allZonesAcknowledged returns true iff every blocking zone hit has its zone ID in the caller-supplied acknowledgement set. Mirrors the allAcknowledged
mcp/internal/mcpserver/tools.go:1318
↓ 1 callersFunctionargsMap
(req mcp.CallToolRequest)
mcp/internal/mcpserver/tools.go:1056
↓ 1 callersMethodbuildTransport
()
client/src/proxy.ts:91
↓ 1 callersFunctioncmdInit
(args: string[])
client/src/cli.ts:572
↓ 1 callersFunctioncmdInstall
(args: string[])
client/src/cli.ts:815
↓ 1 callersFunctioncmdInvite
(args: string[])
client/src/cli.ts:1111
↓ 1 callersFunctioncmdKeys
(args: string[])
client/src/cli.ts:1170
↓ 1 callersFunctioncmdLogin
(args: string[])
client/src/cli.ts:703
↓ 1 callersFunctioncmdSetup
(args: string[])
client/src/cli.ts:693
↓ 1 callersFunctioncmdStart
(args: string[])
client/src/cli.ts:385
↓ 1 callersFunctioncmdStatus
()
client/src/cli.ts:857
↓ 1 callersFunctioncmdTeams
(args: string[])
client/src/cli.ts:897
↓ 1 callersMethodcreateStdioServer
()
client/src/proxy.ts:431
↓ 1 callersFunctiondetectOverlap
detectOverlap returns a non-empty human-readable reason if the new work should be flagged as overlapping with an existing active work, or "" if there
mcp/internal/mcpserver/tools.go:1146
↓ 1 callersMethoddetected
True if any signal (config dir or binary) suggests this IDE is installed.
client/src/install.ts:47
↓ 1 callersFunctionextractAPIKey
(r *http.Request)
mcp/internal/mcpserver/server.go:574
↓ 1 callersMethodfetch
(teamID string)
mcp/internal/teamctx/store.go:180
↓ 1 callersFunctionfetchJoinLink
* Claim a one-time join link and get a team API key. * * The URL the user pastes is the shareable frontend URL (e.g. * https://asynkor.com/join/TOK
client/src/cli.ts:220
↓ 1 callersMethodfindParkedEntryBytes
findParkedEntryBytes returns the raw bytes of the parked-list entry whose parsed Work.ID matches workID, or nil if not found. Used by Cancel to LRem l
mcp/internal/work/store.go:489
↓ 1 callersFunctiongenerateIdeConfig
(ide: IdeType, apiKey: string)
client/src/cli.ts:422
↓ 1 callersMethodhandleFinish
(ctx context.Context, req mcp.CallToolRequest)
mcp/internal/mcpserver/tools.go:622
↓ 1 callersMethodhandleTeamSwitch
(args: Record<string, unknown> | undefined)
client/src/proxy.ts:286
↓ 1 callersMethodhandleTeamsList
()
client/src/proxy.ts:255
↓ 1 callersMethodinstall
Write/merge the Asynkor MCP server into the IDE's user-scope config.
client/src/install.ts:49
↓ 1 callersFunctionisValidSubjectPart
isValidSubjectPart checks that a string is safe to use as a NATS subject token. Dots, wildcards, and whitespace could allow subscription hijacking.
mcp/internal/natsbus/client.go:13
↓ 1 callersFunctionjaccardSimilarity
jaccardSimilarity returns the Jaccard index over two word sets, in [0, 1].
mcp/internal/mcpserver/tools.go:1123
↓ 1 callersFunctionloadConfig
()
client/src/config.ts:113
↓ 1 callersMethodmakeContextFunc
()
mcp/internal/mcpserver/server.go:131
↓ 1 callersFunctionmatchedZonesForPaths
matchedZonesForPaths returns one zoneHit per (zone, planned-path) match. A zone is hit at most once even if multiple planned paths fall inside it — du
mcp/internal/mcpserver/tools.go:1273
↓ 1 callersFunctionnewTestRedis
(t *testing.T)
mcp/integration_test.go:57
↓ 1 callersFunctionparseDuration
* Parses "7d", "12h", "30m" into hours (integer). * Returns undefined if input is empty; throws on malformed input.
client/src/cli.ts:1096
↓ 1 callersFunctionreadJsonFile
(file: string)
client/src/install.ts:54
↓ 1 callersMethodrefreshApiKey
* Attempt to refresh an expired API key using the stored refresh token. * Flow: refresh JWT → create new API key → update config on disk → reconnec
client/src/proxy.ts:374
↓ 1 callersMethodregisterResources
(mcpServer *server.MCPServer)
mcp/internal/mcpserver/server.go:537
↓ 1 callersMethodregisterTools
(mcpServer *server.MCPServer)
mcp/internal/mcpserver/server.go:264
↓ 1 callersFunctionremoveTeamFromConfig
(slug: string)
client/src/config.ts:299
↓ 1 callersMethodrequiringAck
requiringAck returns the subset of hits whose action is "block" or "confirm" — both must be acknowledged via acknowledge_zone before the start can pro
mcp/internal/mcpserver/tools.go:1292
↓ 1 callersFunctionresolveConfig
()
client/src/config.ts:72
↓ 1 callersFunctionresolveJoinApiUrl
* Map a public frontend join URL to its backend claim endpoint. The frontend * host might be `asynkor.com` (prod), `staging.asynkor.com`, or somethin
client/src/cli.ts:253
↓ 1 callersFunctionserverBlock
(apiKey: string, team?: string)
client/src/install.ts:30
↓ 1 callersMethodstartSubscriptionPoll
(uri: string, server: Server)
client/src/proxy.ts:220
↓ 1 callersMethodstopSubscriptionPoll
(uri: string)
client/src/proxy.ts:245
↓ 1 callersFunctionteammatesPayload
(active []*work.Work)
mcp/internal/mcpserver/tools.go:1244
↓ 1 callersFunctiontryJson
(text: string)
client/src/cli.ts:1079
↓ 1 callersFunctionupdateTeamKeyInConfig
(slug: string, newApiKey: string, newRefreshToken?: string)
client/src/config.ts:324
↓ 1 callersMethodwarnings
warnings returns the subset of hits whose action is "warn" — they should surface in the response but never refuse the start.
mcp/internal/mcpserver/tools.go:1304
↓ 1 callersFunctionwriteAsynkorJson
(data: Record<string, unknown>)
client/src/cli.ts:271
↓ 1 callersFunctionwriteIdeConfig
(ide: IdeType, apiKey: string)
client/src/cli.ts:521
↓ 1 callersFunctionwriteJsonFile
(file: string, data: Record<string, any>)
client/src/install.ts:65
MethodCloseThread
(teamID, threadID string)
mcp/internal/teamctx/store.go:582
FunctionLoad
()
mcp/config/config.go:13
FunctionNew
(rawURL string)
mcp/internal/redisstore/client.go:10
FunctionNew
(url string)
mcp/internal/natsbus/client.go:21
FunctionNewStore
(r *redis.Client)
mcp/internal/activity/store.go:28
FunctionNewStore
(javaURL, internalToken string)
mcp/internal/teamctx/store.go:110
FunctionNewStore
(r *redis.Client)
mcp/internal/lease/store.go:32
MethodRefreshByWork
(ctx context.Context, teamID, workID string)
mcp/internal/lease/store.go:224
MethodTakeFollowup
(teamID, followupID, workID string)
mcp/internal/teamctx/store.go:370
FunctionTestCheck_MatchesPlannedPaths
TestCheck_MatchesPlannedPaths verifies that asynkor_check now surfaces overlap against PlannedPaths too, not just FilesTouched. Before the fix, check
mcp/internal/mcpserver/handlers_overlap_test.go:342
FunctionTestCheck_ZoneSurfacesEnforcement
TestCheck_ZoneSurfacesEnforcement verifies that asynkor_check tells the agent what enforcement will happen at start time, not just that a zone exists.
mcp/internal/mcpserver/handlers_zone_test.go:247
FunctionTestFullWorkCycle
TestFullWorkCycle tests: validate → start work → get briefing → complete work → check followups.
mcp/integration_test.go:106
FunctionTestGoJavaIntegration_BadToken
TestGoJavaIntegration_BadToken verifies that wrong INTERNAL_TOKEN is rejected.
mcp/integration_test.go:94
FunctionTestGoJavaIntegration_ValidateKey
TestGoJavaIntegration verifies the full auth validation flow: Go calls Java's /internal/validate-key and correctly parses the team context.
mcp/integration_test.go:69
FunctionTestHandlerSession_FinishWithDifferentSessionFails
TestHandlerSession_FinishWithDifferentSessionFails locks in the intended isolation: work started under one session is not visible to a different sessi
mcp/internal/mcpserver/handlers_session_test.go:149
FunctionTestHandlerSession_MultipleStartsSameSession
TestHandlerSession_MultipleStartsSameSession verifies that re-calling start in the same session replaces the previous active work (the Lua startScript
mcp/internal/mcpserver/handlers_session_test.go:173
FunctionTestHandlerSession_StartFinishRoundTrip
TestHandlerSession_StartFinishRoundTrip is the regression test for the bug where makeContextFunc generated a fresh UUID on every POST, causing asynkor
mcp/internal/mcpserver/handlers_session_test.go:109
FunctionTestOverlap_BlockModeAcknowledgeAllowsStart
TestOverlap_BlockModeAcknowledgeAllowsStart verifies the override path: passing acknowledge_overlap with every conflicting work_id lets the start proc
mcp/internal/mcpserver/handlers_overlap_test.go:249
FunctionTestOverlap_BlockModePartialAckStillBlocks
TestOverlap_BlockModePartialAckStillBlocks verifies that acknowledging only one of two conflicting work_ids is not enough — the agent must acknowledge
mcp/internal/mcpserver/handlers_overlap_test.go:282
FunctionTestOverlap_BlockModeRefusesWithoutAck
TestOverlap_BlockModeRefusesWithoutAck verifies that in block mode, an overlapping start is refused with ok=false and a conflicts payload.
mcp/internal/mcpserver/handlers_overlap_test.go:210
FunctionTestOverlap_PlanTextSimilarity
TestOverlap_PlanTextSimilarity verifies the fallback heuristic: when neither side provides paths, plan-text Jaccard similarity still flags obviously r
mcp/internal/mcpserver/handlers_overlap_test.go:122
FunctionTestOverlap_PlanTextSimilarity_KeepsHighSignalVerbs
TestOverlap_PlanTextSimilarity_KeepsHighSignalVerbs locks in the audit fix: removing "add", "fix", "update", "change" from the stopword list means sho
mcp/internal/mcpserver/handlers_overlap_test.go:158
FunctionTestOverlap_PlanTextSimilarity_UnrelatedShortPlansDoNotMatch
TestOverlap_PlanTextSimilarity_UnrelatedShortPlansDoNotMatch verifies the other side of the stopword fix: two short plans whose only shared word is th
mcp/internal/mcpserver/handlers_overlap_test.go:187
FunctionTestOverlap_SameSessionDoesNotFlagItself
TestOverlap_SameSessionDoesNotFlagItself verifies that calling asynkor_start again in the same session (a deliberate pivot) does not self-flag. Only O
mcp/internal/mcpserver/handlers_overlap_test.go:317
← previousnext →101–200 of 259, ranked by callers