MCPcopy Index your code

hub / github.com/refly-ai/refly / functions

Functions5,783 in github.com/refly-ai/refly

↓ 19 callersFunctionshouldDelayJob
(runningCount: number)
apps/api/src/modules/schedule/schedule-rate-limits.spec.ts:93
↓ 19 callersFunctionuseActionResultStoreShallow
(selector: (state: ActionResultState) => T)
packages/stores/src/stores/action-result.ts:458
↓ 18 callersFunctionbatchReplaceRegex
(s: string, replaceMap: Record<string, string>)
packages/utils/src/str.ts:7
↓ 18 callersFunctiongenUniqueId
()
packages/utils/src/id.ts:258
↓ 18 callersMethodinvoke
* Execute a tool and apply post-processing to the result. * * @param tool - The tool to execute * @param input - Input to pass to the tool
apps/api/src/modules/tool/tool-execution/wrapper/wrapper.interface.ts:24
↓ 18 callersMethodroute
( rules: AutoModelRoutingRuleModel[], modelMap: Map<string, ProviderItemModel>, )
apps/api/src/modules/provider/auto-model-router.service.ts:133
↓ 18 callersMethoduploadBuffer
( user: User, param: { fpath: string; buf: Buffer; entityId?: string; entityTy
apps/api/src/modules/misc/misc.service.ts:478
↓ 18 callersFunctionuseAuthStoreShallow
(selector: (state: AuthState) => T)
packages/stores/src/stores/auth.ts:67
↓ 17 callersFunctionaggregateTokenUsage
(usageItems: TokenUsageItem[])
packages/utils/src/models.ts:19
↓ 17 callersMethodfindDefaultProviderItem
( user: User, scene: ModelScene, userPo?: { preferences: string }, )
apps/api/src/modules/provider/provider.service.ts:996
↓ 17 callersFunctiongenerateScheduleSuccessEmail
(data: ScheduleSuccessData)
apps/api/src/modules/schedule/schedule-email-templates.ts:273
↓ 17 callersMethodgetCanvasRawData
( user: User, canvasId: string, options?: { checkOwnership?: boolean }, )
apps/api/src/modules/canvas/canvas.service.ts:259
↓ 17 callersFunctiongetShareLink
(entityType: string, shareId: string)
packages/ai-workspace-common/src/utils/share.ts:1
↓ 17 callersMethodgetType
* Get adapter type * @returns Adapter type identifier
apps/api/src/modules/tool/dynamic-tooling/core/adapter.ts:28
↓ 17 callersMethodsetHeader
* Set default header
apps/api/src/modules/tool/dynamic-tooling/adapters/http-client.ts:108
↓ 17 callersFunctionsortNodeExecutionsByExecutionOrder
( nodeExecutions: T[], )
packages/canvas-common/src/workflow.ts:314
↓ 16 callersFunctionapiRequest
(path: string, options: RequestOptions = {})
packages/cli/src/api/client.ts:50
↓ 16 callersFunctioncreateNode
( id: string, entityId?: string, metadata: Record<string, any> = {}, )
packages/canvas-common/src/data.test.ts:16
↓ 16 callersFunctionextractFileId
(value: unknown)
packages/utils/src/file-id.ts:88
↓ 16 callersMethodgetItem
* Implements StateStorage.getItem
packages/stores/src/stores/utils/storage-manager.ts:283
↓ 16 callersMethodtoDTO
* Transform DriveFile Prisma model to DTO with URL
apps/api/src/modules/drive/drive.service.ts:132
↓ 16 callersMethodupdate
* Update the spinner message
packages/cli/src/utils/spinner.ts:69
↓ 15 callersMethodacquireLock
* Acquire a distributed lock with automatic renewal. * * **IMPORTANT**: Callers MUST always invoke the returned release function when done, *
apps/api/src/modules/common/redis.service.ts:471
↓ 15 callersFunctioncreateWorkflowPlan
( tasks: any[], products: Array<{ id: string; type: any; title: string }> = [], variables: any[] = [], )
packages/canvas-common/src/workflow-plan.test.ts:21
↓ 15 callersFunctionextractChunkContent
(chunk: BaseMessageChunk)
apps/api/src/utils/llm.ts:13
↓ 15 callersMethodgetInventoryItem
* Get inventory item by key * Loads directly from database on each call * @param key - Toolset key * @returns ToolsetInventoryItem or undefin
apps/api/src/modules/tool/inventory/inventory.service.ts:501
↓ 15 callersFunctiongetYYYYMMDD
(date: Date)
packages/utils/src/time.ts:7
↓ 15 callersFunctionisValidFileId
(value: unknown)
packages/utils/src/file-id.ts:79
↓ 15 callersMethodminioClient
(visibility: FileVisibility)
apps/api/src/modules/misc/misc.service.ts:275
↓ 15 callersMethodremoveObject
* Remove an object from storage * @param key The storage key * @param force Whether to force the removal of the object * @returns true if the
apps/api/src/modules/common/object-storage/backend/interface.ts:59
↓ 15 callersFunctiontime
( date: string | number | Date | dayjsConfig.Dayjs, locale: LOCALE = LOCALE.EN, )
packages/ai-workspace-common/src/utils/time.ts:4
↓ 15 callersMethodtoVoucherDTO
* Convert Prisma voucher to DTO
apps/api/src/modules/voucher/voucher.service.ts:1145
↓ 15 callersFunctionuseNodeData
()
packages/ai-workspace-common/src/hooks/canvas/use-node-data.ts:7
↓ 15 callersFunctionwrapEventHandler
(handler: (...args: any[]) => void)
packages/ai-workspace-common/src/hooks/canvas/use-invoke-action.ts:854
↓ 14 callersFunctionTrace
( spanNameOrAttributes?: string | Record<string, string | number | boolean>, staticAttributes?: Record<str
packages/observability/src/trace-decorator.ts:10
↓ 14 callersFunctioncreateNode
(id: string, metadata: Record<string, any> = {})
packages/canvas-common/src/diff.test.ts:9
↓ 14 callersMethoddecrypt
* Decrypts a string that was encrypted with the encrypt method * @param encryptedText The encrypted text as a hex string with IV and auth tag prepe
apps/api/src/modules/common/encryption.service.ts:80
↓ 14 callersFunctionformatDateTime
(dateTime: string | Date, timezone = 'Asia/Shanghai')
apps/api/src/modules/schedule/schedule-email-templates.ts:14
↓ 14 callersFunctiongenActionResultID
()
packages/utils/src/id.ts:116
↓ 14 callersFunctionrunModuleInitWithTimeoutAndRetry
( callback: () => void | Promise<void>, options?: ModuleInitOptions, )
packages/utils/src/on-module-init.ts:31
↓ 14 callersMethodsearch
* Search for similar vectors * @param request Search request parameters * @param filter Filter to apply to the search * @returns Array of sea
apps/api/src/modules/common/vector-search/backend/interface.ts:151
↓ 14 callersMethodsetItem
* Implements StateStorage.setItem with eviction logic
packages/stores/src/stores/utils/storage-manager.ts:296
↓ 14 callersFunctionuseDeleteNode
()
packages/ai-workspace-common/src/hooks/canvas/use-delete-node.ts:12
↓ 13 callersFunctiongetBrowserValue
(getter: () => T, fallback: T)
packages/ui-kit/src/utils/env.ts:38
↓ 13 callersFunctionhandleDelete
()
packages/ai-workspace-common/src/components/canvas/modals/canvas-delete.tsx:23
↓ 13 callersMethodlist
( @LoginedUser() user: User, @Query('limit') limit?: number, @Query('offset') offset?: number, )
apps/api/src/modules/workflow/workflow-cli.controller.ts:819
↓ 13 callersFunctionreplaceAllHtmlFileIds
( content: string, contentUrlMap: Map<string, string>, shareUrlMap: Map<string, string>, )
packages/utils/src/file-id.ts:338
↓ 13 callersMethoduse
* Register a pre-handler to process request before execution * @param handler - Pre-handler function * @returns this for chaining
apps/api/src/modules/tool/dynamic-tooling/core/handler.ts:40
↓ 13 callersFunctionuseFetchShareData
(shareId?: string, options?: RequestInit)
packages/ai-workspace-common/src/hooks/use-fetch-share-data.ts:10
↓ 12 callersFunctionbuildComment
(prefix: string, text: string)
packages/ai-workspace-common/src/components/canvas/integration-docs/utils.ts:468
↓ 12 callersFunctioncalculateCanvasStateDiff
( from: CanvasData, to: CanvasData, )
packages/canvas-common/src/diff.ts:190
↓ 12 callersFunctioncleanup
()
packages/ai-workspace-common/src/utils/image-compression.ts:48
↓ 12 callersFunctioncleanupNodeEvents
(nodeId: string)
packages/ai-workspace-common/src/events/nodeActions.ts:39
↓ 12 callersFunctioncountToken
(content: string)
packages/utils/src/token.ts:66
↓ 12 callersMethodduplicateFile
* Duplicate a file from one storage key to another * @param sourceKey The source storage key * @param targetKey The target storage key * @ret
apps/api/src/modules/common/object-storage/backend/interface.ts:82
↓ 12 callersFunctionget
()
apps/api/src/modules/config/config.decorator.ts:33
↓ 12 callersFunctiongetCanvasDataFromState
(state: CanvasState)
packages/canvas-common/src/sync.ts:255
↓ 12 callersFunctiongetReflyDomainSkillDir
(skillName: string)
packages/cli/src/config/paths.ts:133
↓ 12 callersFunctionhaveToolsetsChanged
( currentToolsets: GenericToolset[] = [], newToolsets: GenericToolset[] = [], )
packages/canvas-common/src/tools.ts:93
↓ 12 callersFunctionlogEvent
( user: { uid: string; email?: string }, eventName: string, value?: string | number, metadata?: Record
packages/telemetry-node/src/index.ts:66
↓ 12 callersMethodnormalizeObjectKey
(key: string)
apps/api/src/modules/common/object-storage/backend/minio.ts:28
↓ 12 callersMethodsetex
(key: string, seconds: number, value: string)
apps/api/src/modules/common/redis.service.ts:168
↓ 12 callersFunctionstoreSignupEntryPoint
(entryPoint: string)
packages/ai-workspace-common/src/hooks/use-pending-voucher-claim.ts:191
↓ 12 callersMethodsyncStorageUsage
(user: User)
apps/api/src/modules/subscription/subscription.service.ts:1186
↓ 12 callersFunctiontruncateAndFilterContent
( text: string, maxTokens: number, )
apps/api/src/modules/tool/utils/token.ts:327
↓ 12 callersFunctionuseSetNodeDataByEntity
()
packages/ai-workspace-common/src/hooks/canvas/use-set-node-data-by-entity.ts:13
↓ 11 callersMethodappendModelResponse
( reason: string | undefined, actionResult: ActionDetail, )
apps/api/src/modules/copilot-autogen/copilot-autogen.service.ts:933
↓ 11 callersMethodcheckStorageUsage
(user: User)
apps/api/src/modules/subscription/subscription.service.ts:819
↓ 11 callersFunctioncn
(...inputs: ClassValue[])
packages/utils/src/cn.ts:4
↓ 11 callersFunctioncreateToolsetWithSensitiveData
( id: string, options: { name?: string; type?: 'regular' | 'mcp'; withToolset?: boolean; w
packages/canvas-common/src/tools.test.ts:30
↓ 11 callersFunctiondeepmerge
(from: T1, to: T2)
packages/utils/src/typesafe.ts:19
↓ 11 callersMethodformatErrorResponse
* Format error response
apps/api/src/modules/internal-mcp/internal-mcp.service.ts:40
↓ 11 callersMethodformatValue
(value: unknown, indent = 0)
packages/cli/src/utils/formatter.ts:696
↓ 11 callersFunctiongenCanvasID
()
packages/utils/src/id.ts:132
↓ 11 callersFunctiongenShareId
(entityType: keyof typeof SHARE_CODE_PREFIX)
apps/api/src/modules/share/share-creation.service.ts:33
↓ 11 callersFunctiongenSkillID
()
packages/utils/src/id.ts:226
↓ 11 callersMethodgenerateStorageKey
( user: User, file: { canvasId: string; name: string; scope?: string; source?: string }, )
apps/api/src/modules/drive/drive.service.ts:136
↓ 11 callersFunctiongetNodeHeight
(node: Node)
packages/canvas-common/src/nodes.ts:123
↓ 11 callersFunctiongetNodeWidth
(node: Node)
packages/canvas-common/src/nodes.ts:136
↓ 11 callersFunctiongetReflyDir
()
packages/cli/src/config/paths.ts:25
↓ 11 callersFunctiongetReflySkillsDir
()
packages/cli/src/config/paths.ts:118
↓ 11 callersFunctiongetSafeMimeType
(filename: string, fallbackMime?: string)
packages/utils/src/file.ts:140
↓ 11 callersFunctiongetYYYYMM
(date: Date)
packages/utils/src/time.ts:1
↓ 11 callersFunctioninitEmptyCanvasState
(options?: InitEmptyCanvasOptions)
packages/canvas-common/src/sync.ts:27
↓ 11 callersFunctionisTTY
()
packages/cli/src/utils/ui.ts:159
↓ 11 callersFunctionprintln
(message: string)
packages/cli/src/utils/logo.ts:60
↓ 11 callersFunctionproviderItemPO2DTO
( providerItem: ProviderItemModel & { provider?: ProviderModel }, )
apps/api/src/modules/provider/provider.dto.ts:33
↓ 11 callersMethodremoveItem
* Implements StateStorage.removeItem
packages/stores/src/stores/utils/storage-manager.ts:342
↓ 11 callersMethodretrieve
(user: User, param: HybridSearchParam)
apps/api/src/modules/rag/rag.service.ts:335
↓ 11 callersFunctionsafeExtract
(content: string, regex: RegExp)
packages/ai-workspace-common/src/components/markdown/plugins/tool-call/toolProcessor.ts:47
↓ 11 callersFunctionsafeStringifyJSON
(value: any, errorCallback?: (e: unknown) => string)
packages/ai-workspace-common/src/utils/parse.ts:12
↓ 11 callersFunctionshouldCreateNewVersion
(state: CanvasState)
packages/canvas-common/src/sync.ts:100
↓ 11 callersFunctionthrowCliError
* Build CLI error response and throw HTTP exception
apps/api/src/modules/workflow/workflow-plan-cli.controller.ts:106
↓ 11 callersFunctionuseDocumentStoreShallow
(selector: (state: DocumentBaseState) => T)
packages/stores/src/stores/document.ts:129
↓ 11 callersFunctionuseListUserTools
( clientOptions: Options<unknown, true> = {}, queryKey?: TQueryKey, options?: Omit<UseQueryOptions<TData
packages/ai-workspace-common/src/queries/queries.ts:1474
↓ 11 callersFunctionwriteSSEResponse
(res: Response, msg: SkillEvent)
apps/api/src/utils/response.ts:11
↓ 10 callersMethodcheckAndTriggerSchedule
* Check and trigger a specific schedule if it's due * This is used to immediately check schedules that were just created/updated * with a near-f
apps/api/src/modules/schedule/schedule-cron.service.ts:125
↓ 10 callersMethodcreateCheckResult
* Create initial check result structure
packages/providers/src/provider-checker/provider-checker.ts:61
↓ 10 callersMethodcreateShare
( @LoginedUser() user: User, @Body() body: CreateShareRequest, )
apps/api/src/modules/share/share.controller.ts:46
↓ 10 callersFunctionestimateToken
(content: MessageContent)
packages/skill-template/src/scheduler/utils/token.ts:19
← previousnext →101–200 of 5,783, ranked by callers