CERBERUS/LibreChat
1
0
Fork 0
mirror of https://github.com/danny-avila/LibreChat.git synced 2026-08-04 14:57:42 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 6

fix: add skill sync declaration return types

Browse source
This commit is contained in:
Danny Avila 2026-06-07 21:53:56 -04:00
parent c47bc1ecfc
commit 3df7f9f950
3 changed files with 54 additions and 22 deletions
Download patch file Download diff file Expand all files Collapse all files

66
packages/data-schemas/src/methods/skillSync.ts
View file

@ -48,6 +48,48 @@ export type SkillSyncStatusInput = {
deletedFileCount?: number;
};
export type SkillSyncLockInput = {
provider: SkillSyncProvider;
lockOwner: string;
leaseMs: number;
tenantId?: string;
};
export type SkillSyncReleaseLockInput = {
provider: SkillSyncProvider;
lockOwner: string;
tenantId?: string;
};
export type SkillSyncMethods = {
upsertSkillSyncCredential: (
input: UpsertSkillSyncCredentialInput,
) => Promise<SkillSyncCredentialSummary>;
deleteSkillSyncCredential: (
provider: SkillSyncProvider,
credentialKey: string,
) => Promise<{ deleted: boolean }>;
listSkillSyncCredentials: (provider: SkillSyncProvider) => Promise<SkillSyncCredentialSummary[]>;
getSkillSyncCredentialToken: (
provider: SkillSyncProvider,
credentialKey: string,
) => Promise<string | null>;
getSkillSyncCredentialSummary: (
provider: SkillSyncProvider,
credentialKey: string,
) => Promise<SkillSyncCredentialSummary | null>;
listSkillSyncStatuses: (provider: SkillSyncProvider) => Promise<ISkillSyncStatus[]>;
getSkillSyncStatus: (
provider: SkillSyncProvider,
sourceId: string,
tenantId?: string,
) => Promise<ISkillSyncStatus | null>;
upsertSkillSyncStatus: (input: SkillSyncStatusInput) => Promise<ISkillSyncStatus>;
tryAcquireSkillSyncLock: (params: SkillSyncLockInput) => Promise<boolean>;
refreshSkillSyncLock: (params: SkillSyncLockInput) => Promise<boolean>;
releaseSkillSyncLock: (params: SkillSyncReleaseLockInput) => Promise<void>;
};
function hashToken(token: string): string {
return createHash('sha256').update(token).digest('hex');
}
@ -72,7 +114,7 @@ function summarizeCredential(
};
}
export function createSkillSyncMethods(mongoose: typeof import('mongoose')) {
export function createSkillSyncMethods(mongoose: typeof import('mongoose')): SkillSyncMethods {
async function upsertSkillSyncCredential(
input: UpsertSkillSyncCredentialInput,
): Promise<SkillSyncCredentialSummary> {
@ -217,12 +259,7 @@ export function createSkillSyncMethods(mongoose: typeof import('mongoose')) {
return row;
}
async function tryAcquireSkillSyncLock(params: {
provider: SkillSyncProvider;
lockOwner: string;
leaseMs: number;
tenantId?: string;
}): Promise<boolean> {
async function tryAcquireSkillSyncLock(params: SkillSyncLockInput): Promise<boolean> {
const Status = mongoose.models.SkillSyncStatus as Model<ISkillSyncStatusDocument>;
const now = new Date();
const lockExpiresAt = new Date(now.getTime() + params.leaseMs);
@ -285,12 +322,7 @@ export function createSkillSyncMethods(mongoose: typeof import('mongoose')) {
}
}
async function refreshSkillSyncLock(params: {
provider: SkillSyncProvider;
lockOwner: string;
leaseMs: number;
tenantId?: string;
}): Promise<boolean> {
async function refreshSkillSyncLock(params: SkillSyncLockInput): Promise<boolean> {
const Status = mongoose.models.SkillSyncStatus as Model<ISkillSyncStatusDocument>;
const now = new Date();
const row = await Status.findOneAndUpdate(
@ -312,11 +344,7 @@ export function createSkillSyncMethods(mongoose: typeof import('mongoose')) {
return Boolean(row);
}
async function releaseSkillSyncLock(params: {
provider: SkillSyncProvider;
lockOwner: string;
tenantId?: string;
}): Promise<void> {
async function releaseSkillSyncLock(params: SkillSyncReleaseLockInput): Promise<void> {
const Status = mongoose.models.SkillSyncStatus as Model<ISkillSyncStatusDocument>;
await Status.updateOne(
{
@ -352,5 +380,3 @@ export function createSkillSyncMethods(mongoose: typeof import('mongoose')) {
releaseSkillSyncLock,
};
}
export type SkillSyncMethods = ReturnType<typeof createSkillSyncMethods>;

5
packages/data-schemas/src/models/skillSyncCredential.ts
View file

@ -1,7 +1,10 @@
import { Model } from 'mongoose';
import type { ISkillSyncCredentialDocument } from '~/types/skillSync';
import skillSyncCredentialSchema from '~/schema/skillSyncCredential';
export function createSkillSyncCredentialModel(mongoose: typeof import('mongoose')) {
export function createSkillSyncCredentialModel(
mongoose: typeof import('mongoose'),
): Model<ISkillSyncCredentialDocument> {
// GitHub skill sync is intentionally app-wide in v1; credentials are referenced by
// admin-managed config keys and are never returned by tenant-scoped APIs.
return (

5
packages/data-schemas/src/models/skillSyncStatus.ts
View file

@ -1,7 +1,10 @@
import { Model } from 'mongoose';
import type { ISkillSyncStatusDocument } from '~/types/skillSync';
import skillSyncStatusSchema from '~/schema/skillSyncStatus';
export function createSkillSyncStatusModel(mongoose: typeof import('mongoose')) {
export function createSkillSyncStatusModel(
mongoose: typeof import('mongoose'),
): Model<ISkillSyncStatusDocument> {
// GitHub skill sync status supports app-wide YAML sources and tenant-scoped
// resolved config sources from admin overrides.
return (